protoio

package

v1.17.0 Latest Latest Go to latest Published: Nov 30, 2025 License: Apache-2.0 Imports: 6 Imported by: 0

Details

Package protoio contains I/O functions for protocol buffers.

This section is empty.

This section is empty.

func ReadMessage(fname string, pb proto.Message) error

ReadMessage reads a protocol buffer message from fname, and unmarshalls it into pb.

func ReadTextMessage(fname string, pb proto.Message) error

ReadTextMessage reads a text format protocol buffer message from fname, and unmarshalls it into pb.

func WriteMessage(fname string, pb proto.Message, perm os.FileMode, ops ...safeio.FileOp) error

WriteMessage marshals pb and atomically writes it into fname.

func WriteTextMessage(fname string, pb proto.Message, perm os.FileMode, ops ...safeio.FileOp) error

WriteTextMessage marshals pb in text format and atomically writes it into fname.

type Store struct {
	// contains filtered or unexported fields
}

Store represents a persistent protocol buffer message store.

func NewStore(dir string) (*Store, error)

NewStore returns a new Store instance. It will create dir if needed.

func (s *Store) Get(id string, m proto.Message) (bool, error)

Get a message from the store.

func (s *Store) ListIDs() ([]string, error)

ListIDs in the store.

func (s *Store) Put(id string, m proto.Message) error

Put a message into the store.

Path	Synopsis
testpb