testutil

Documentation

Index

• type FakeServerStream
  • func NewFakeServerStream(ctx context.Context) *FakeServerStream
  • func (f *FakeServerStream) Context() context.Context
  • func (f *FakeServerStream) RecvMsg(m interface{}) error
  • func (f *FakeServerStream) SendHeader(metadata.MD) error
  • func (f *FakeServerStream) SendMsg(m interface{}) error
  • func (f *FakeServerStream) SetHeader(metadata.MD) error
  • func (f *FakeServerStream) SetTrailer(metadata.MD)

Types

type FakeServerStream

type FakeServerStream struct {
	// contains filtered or unexported fields
}

Lazily implemented imitation of grpc.ServerStream, useful for directly invoking streaming grpc endpoints when testing servers

func NewFakeServerStream

func NewFakeServerStream(ctx context.Context) *FakeServerStream

func (*FakeServerStream) Context

func (f *FakeServerStream) Context() context.Context

func (*FakeServerStream) RecvMsg

func (f *FakeServerStream) RecvMsg(m interface{}) error

func (*FakeServerStream) SendHeader

func (f *FakeServerStream) SendHeader(metadata.MD) error

func (*FakeServerStream) SendMsg

func (f *FakeServerStream) SendMsg(m interface{}) error

func (*FakeServerStream) SetHeader

func (f *FakeServerStream) SetHeader(metadata.MD) error

func (*FakeServerStream) SetTrailer

func (f *FakeServerStream) SetTrailer(metadata.MD)