types

Jan 22, 2018

Changes in this version

type GiveHeader

+ func (h *GiveHeader) ApplyClientStreamRequest(opts *api.ClientStreamRequestOpts)

type Port

+ Listener net.Listener

+ func (n *Port) ApplyClientStreamRequest(opts *api.ClientStreamRequestOpts)

type Procedure

+ func (n *Procedure) ApplyClientStreamRequest(opts *api.ClientStreamRequestOpts)

+ type RecvStreamMsg struct

+ WantBody []byte

+ WantDecodeErrMsgs []string

+ WantErrMsgs []string

+ func (s *RecvStreamMsg) ApplyClientStream(t testing.TB, c *transport.ClientStream)

+ func (s *RecvStreamMsg) ApplyServerStream(c *transport.ServerStream) error

+ type SendStreamMsg struct

+ BodyFunc func() io.ReadCloser

+ WantErrMsgs []string

+ func (s *SendStreamMsg) ApplyClientStream(t testing.TB, c *transport.ClientStream)

+ func (s *SendStreamMsg) ApplyServerStream(c *transport.ServerStream) error

type Service

+ func (n *Service) ApplyClientStreamRequest(opts *api.ClientStreamRequestOpts)

type ShardKey

+ func (n *ShardKey) ApplyClientStreamRequest(opts *api.ClientStreamRequestOpts)

type WantHeader

+ func (h *WantHeader) ApplyServerStream(c *transport.ServerStream) error

Nov 22, 2017

Changes in this version

+ type GiveHeader struct

+ Key string

+ Value string

+ func (h *GiveHeader) ApplyRequest(opts *api.RequestOpts)

+ func (h *GiveHeader) Handle(ctx context.Context, req *transport.Request, resw transport.ResponseWriter, ...) error

+ type Name struct

+ Name string

+ func (n *Name) ApplyProc(opts *api.ProcOpts)

+ func (n *Name) ApplyService(opts *api.ServiceOpts)

+ type OrderedHandler struct

+ Handlers []api.UnaryHandler

+ func (h *OrderedHandler) ApplyProc(opts *api.ProcOpts)

+ func (h *OrderedHandler) Handle(ctx context.Context, req *transport.Request, resw transport.ResponseWriter) error

+ func (h *OrderedHandler) Start(t testing.TB) error

+ func (h *OrderedHandler) Stop(t testing.TB) error

+ type Port struct

+ Port uint16

+ func (n *Port) ApplyRequest(opts *api.RequestOpts)

+ func (n *Port) ApplyService(opts *api.ServiceOpts)

+ type PortProvider struct

+ func NewPortProvider(t testing.TB) *PortProvider

+ func (p *PortProvider) NamedPort(id string) *Port

+ type Procedure struct

+ Procedure string

+ func (n *Procedure) ApplyRequest(opts *api.RequestOpts)

+ type Service struct

+ Service string

+ func (n *Service) ApplyRequest(opts *api.RequestOpts)

+ type ShardKey struct

+ ShardKey string

+ func (n *ShardKey) ApplyRequest(opts *api.RequestOpts)

+ type UnaryHandler struct

+ Handler api.UnaryHandler

+ Middleware []api.UnaryInboundMiddleware

+ func (h *UnaryHandler) ApplyHandler(opts *api.HandlerOpts)

+ func (h *UnaryHandler) ApplyProc(opts *api.ProcOpts)

+ func (h *UnaryHandler) Handle(ctx context.Context, req *transport.Request, resw transport.ResponseWriter) error

+ func (h *UnaryHandler) Start(t testing.TB) error

+ func (h *UnaryHandler) Stop(t testing.TB) error

+ type WantHeader struct

+ Key string

+ Value string

+ func (h *WantHeader) ApplyRequest(opts *api.RequestOpts)

+ func (h *WantHeader) Handle(ctx context.Context, req *transport.Request, resw transport.ResponseWriter, ...) error