streaming

Documentation

Index

• func FileEnd() *isp.Message
• func IsEndOfFile(msg *isp.Message) bool
• func NewFileStreamWriter(stream DuplexMessageStream, bf BeginFile) (io.WriteCloser, error)
• func WriteFile(stream DuplexMessageStream, path string, bf BeginFile) error
• type BeginFile
  • func ReadFile(stream DuplexMessageStream, ...) (*BeginFile, error)
  • func (bf *BeginFile) FromMessage(msg *isp.Message) error
  • func (bf BeginFile) ToMessage() *isp.Message
• type DuplexMessageStream
• type FileFactory
• type FileStream
• type FormData
  • func (fd FormData) GetIntValue(field string) (int64, error)
  • func (fd FormData) GetStringValue(field string) (string, error)
• type StreamConsumer

Functions

func FileEnd

func FileEnd() *isp.Message

func IsEndOfFile

func IsEndOfFile(msg *isp.Message) bool

func NewFileStreamWriter

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

func WriteFile

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

Types

type BeginFile

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

func ReadFile

func ReadFile(stream DuplexMessageStream, fileFactory func(bf BeginFile) (io.WriteCloser, error), sendResponse bool) (*BeginFile, error)

func (*BeginFile) FromMessage

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

func (BeginFile) ToMessage

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

type DuplexMessageStream

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

type FileFactory

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

type FileStream

type FileStream interface {
	BeginFile() BeginFile
}

type FormData

type FormData map[string]interface{}

func (FormData) GetIntValue

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

func (FormData) GetStringValue

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

type StreamConsumer

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