file

package
v3.0.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 15, 2021 License: MIT Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL