streamtest

Documentation

Index

• func DefaultMsgReceiverMock(me []*MsgError) *msgReceiverMock
• func DefaultMsgSenderMock(s *ImmuServiceSender_StreamMock, chunkSize int) *msgSenderMock
• func GenerateDummyFile(filename string, size int) (*os.File, error)
• func GetSHA256(r io.Reader) ([]byte, error)
• func GetTrailer(payloadSize int) []byte
• type ChunkError
• type ErrReader
  • func (r *ErrReader) Read(m []byte) (int, error)
• type ImmuServiceReceiver_StreamMock
  • func DefaultImmuServiceReceiverStreamMock(ce []*ChunkError) *ImmuServiceReceiver_StreamMock
  • func (ism *ImmuServiceReceiver_StreamMock) Recv() (*schema.Chunk, error)
• type ImmuServiceSender_StreamMock
  • func DefaultImmuServiceSenderStreamMock() *ImmuServiceSender_StreamMock
  • func (iss *ImmuServiceSender_StreamMock) RecvMsg(m interface{}) error
  • func (iss *ImmuServiceSender_StreamMock) Send(c *schema.Chunk) error
• type MsgError

Functions

func DefaultMsgReceiverMock

func DefaultMsgReceiverMock(me []*MsgError) *msgReceiverMock

func DefaultMsgSenderMock

func DefaultMsgSenderMock(s *ImmuServiceSender_StreamMock, chunkSize int) *msgSenderMock

func GenerateDummyFile

func GenerateDummyFile(filename string, size int) (*os.File, error)

func GetSHA256

func GetSHA256(r io.Reader) ([]byte, error)

func GetTrailer

func GetTrailer(payloadSize int) []byte

Types

type ChunkError

type ChunkError struct {
	C *schema.Chunk
	E error
}

type ErrReader

type ErrReader struct {
	ReadF func([]byte) (int, error)
}

func (*ErrReader) Read

func (r *ErrReader) Read(m []byte) (int, error)

type ImmuServiceReceiver_StreamMock

type ImmuServiceReceiver_StreamMock struct {
	RecvF func() (*schema.Chunk, error)
	// contains filtered or unexported fields
}

func DefaultImmuServiceReceiverStreamMock

func DefaultImmuServiceReceiverStreamMock(ce []*ChunkError) *ImmuServiceReceiver_StreamMock

func (*ImmuServiceReceiver_StreamMock) Recv

func (ism *ImmuServiceReceiver_StreamMock) Recv() (*schema.Chunk, error)

type ImmuServiceSender_StreamMock

type ImmuServiceSender_StreamMock struct {
	SendF    func(*schema.Chunk) error
	RecvMsgF func(m interface{}) error
}

func DefaultImmuServiceSenderStreamMock

func DefaultImmuServiceSenderStreamMock() *ImmuServiceSender_StreamMock

func (*ImmuServiceSender_StreamMock) RecvMsg

func (iss *ImmuServiceSender_StreamMock) RecvMsg(m interface{}) error

func (*ImmuServiceSender_StreamMock) Send

func (iss *ImmuServiceSender_StreamMock) Send(c *schema.Chunk) error

type MsgError

type MsgError struct {
	M []byte
	E error
}