file

Documentation

Index

• type FileReceiver
  • func (fr *FileReceiver) Finalize() error
  • func (fr *FileReceiver) Init(msg proto.Message) error
  • func (fr *FileReceiver) Push(data []byte, metadata proto.Message) error
• type FileStreamer
  • func (fs *FileStreamer) Finalize() error
  • func (fs *FileStreamer) GetNext() ([]byte, proto.Message, error)
  • func (fs *FileStreamer) HasNext() bool
  • func (fs *FileStreamer) Init(msg proto.Message) error

Types

type FileReceiver

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

func (*FileReceiver) Finalize

func (fr *FileReceiver) Finalize() error

func (*FileReceiver) Init

func (fr *FileReceiver) Init(msg proto.Message) error

func (*FileReceiver) Push

func (fr *FileReceiver) Push(data []byte, metadata proto.Message) error

type FileStreamer

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

func (*FileStreamer) Finalize

func (fs *FileStreamer) Finalize() error

func (*FileStreamer) GetNext

func (fs *FileStreamer) GetNext() ([]byte, proto.Message, error)

func (*FileStreamer) HasNext

func (fs *FileStreamer) HasNext() bool

func (*FileStreamer) Init

func (fs *FileStreamer) Init(msg proto.Message) error