protos

Documentation

Index

• func PrintProtos(_ context.Context, ps <-chan ID, errs chan<- error) (*sync.WaitGroup, error)
• func Read(file string, out proto.Message) error
• func Write(path string, p proto.Message) error
• type ID
• type Sink

Functions

func PrintProtos

func PrintProtos(_ context.Context, ps <-chan ID, errs chan<- error) (*sync.WaitGroup, error)

PrintProtos prints passed protos as JSON to the stdout. Returns a WaitGroup which finishes after all protos have been printed, or if an error is encountered.

func Read

func Read(file string, out proto.Message) error

func Write

func Write(path string, p proto.Message) error

Types

type ID

type ID interface {
	proto.Message
	ID() uint32
}

type Sink

type Sink func(context.Context, <-chan ID, chan<- error) (*sync.WaitGroup, error)