streaming

Dec 29, 2020

Changes in this version

+ func NewFileStreamWriter(stream DuplexMessageStream, bf BeginFile) (io.WriteCloser, error)

+ type FileStream interface

+ BeginFile func() BeginFile

Feb 12, 2020

Changes in this version

+ func FileEnd() *isp.Message

+ func IsEndOfFile(msg *isp.Message) bool

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

+ type BeginFile struct

+ ContentLength int64

+ ContentType string

+ FileName string

+ FormData FormData

+ FormDataName string

+ func ReadFile(stream DuplexMessageStream, ...) (*BeginFile, error)

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

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

+ type DuplexMessageStream interface

+ Recv func() (*isp.Message, error)

+ Send func(*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