The highest tagged major version is v2.

streaming

package

v1.3.0 Latest Latest Go to latest Published: Jun 4, 2019 License: GPL-3.0 Imports: 8 Imported by: 2

Details

This section is empty.

This section is empty.

func FileEnd() *isp.Message

func IsEndOfFile(msg *isp.Message) bool

func WriteFile(stream DuplexMessageStream, path string, bf BeginFile) error

type BeginFile struct {
	FileName      string
	FormDataName  string
	ContentType   string
	ContentLength int64
	FormData      FormData
}

func ReadFile(stream DuplexMessageStream, fileFactory func(bf BeginFile) (*os.File, error), sendResponse bool) (*BeginFile, error)

func (bf *BeginFile) FromMessage(msg *isp.Message) error

func (bf BeginFile) ToMessage() *isp.Message

type DuplexMessageStream interface {
	Send(*isp.Message) error
	Recv() (*isp.Message, error)
}

type FileFactory func(bf BeginFile) (*os.File, error)

type FormData map[string]interface{}

func (fd FormData) GetIntValue(field string) (int64, error)

func (fd FormData) GetStringValue(field string) (string, error)

type StreamConsumer func(stream DuplexMessageStream, md metadata.MD) error