protobuf

package

v1.0.0-rc2.8 Latest Latest Go to latest Published: Jun 17, 2021 License: BSD-3-Clause Imports: 6 Imported by: 0

Details

This section is empty.

View Source

var ErrTimeout = errors.New("timeout")

func NewWriterAndReader(s p2p.Stream) (Writer, Reader)

type Message = proto.Message

func ReadMessages(r io.Reader, newMessage func() Message) (m []Message, err error)

type Reader struct {
	ggio.Reader
}

func NewReader(r io.Reader) Reader

func (r Reader) ReadMsgWithContext(ctx context.Context, msg proto.Message) error

type Writer struct {
	ggio.Writer
}

func NewWriter(w io.Writer) Writer

func (w Writer) WriteMsgWithContext(ctx context.Context, msg proto.Message) error

Path	Synopsis
internal
pb Package pb holds only Protocol Buffer definitions and generated code for testing purposes.	Package pb holds only Protocol Buffer definitions and generated code for testing purposes.