protoutil

Documentation

Index

• Variables
• func Clone[T proto.Message](m T) T
• func ReadStream(r io.Reader, m proto.Message) error
• func WriteStream(w io.Writer, m proto.Message) error
• type ChunkStreamReader
  • func NewChunkStreamReader(or OffsetReader, size int) *ChunkStreamReader
  • func (r *ChunkStreamReader) Read(m protoreflect.ProtoMessage) error
  • func (r *ChunkStreamReader) Reset()
• type ChunkStreamWriter
  • func NewChunkStreamWriter(w ioutil.WriteFlusher, size int) (*ChunkStreamWriter, error)
  • func (w *ChunkStreamWriter) Reset()
  • func (w *ChunkStreamWriter) Size(m protoreflect.ProtoMessage) int
  • func (w *ChunkStreamWriter) Write(m protoreflect.ProtoMessage) error
• type OffsetReader

Variables

var ErrMaxChunkStreamSize = errors.New("message exceeds max segment size")

Functions

func Clone

func Clone[T proto.Message](m T) T

Clone ...

func ReadStream

func ReadStream(r io.Reader, m proto.Message) error

ReadStream ...

func WriteStream

func WriteStream(w io.Writer, m proto.Message) error

WriteStream ...

Types

type ChunkStreamReader

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

func NewChunkStreamReader

func NewChunkStreamReader(or OffsetReader, size int) *ChunkStreamReader

func (*ChunkStreamReader) Read

func (r *ChunkStreamReader) Read(m protoreflect.ProtoMessage) error

func (*ChunkStreamReader) Reset

func (r *ChunkStreamReader) Reset()

type ChunkStreamWriter

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

func NewChunkStreamWriter

func NewChunkStreamWriter(w ioutil.WriteFlusher, size int) (*ChunkStreamWriter, error)

func (*ChunkStreamWriter) Reset

func (w *ChunkStreamWriter) Reset()

func (*ChunkStreamWriter) Size

func (w *ChunkStreamWriter) Size(m protoreflect.ProtoMessage) int

func (*ChunkStreamWriter) Write

func (w *ChunkStreamWriter) Write(m protoreflect.ProtoMessage) error

type OffsetReader

type OffsetReader interface {
	io.Reader
	Offset() uint64
}