transporttest

package
v1.7.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 20, 2017 License: MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

View Source 
const DefaultTTLDelta = 20 * time.Millisecond

DefaultTTLDelta is the default TTLDelta used by RequestMatchers.

Variables

This section is empty.

Functions

This section is empty.

Types

type ContextMatcher 

type ContextMatcher struct {
	TTLDelta time.Duration
	// contains filtered or unexported fields
}

ContextMatcher is a Matcher for verifying that a context's deadline is within expected bounds: the current time, plus a TTL, plus or minus some tolerance.

func NewContextMatcher 

func NewContextMatcher(t *testing.T, options ...ContextMatcherOption) *ContextMatcher

NewContextMatcher creates a ContextMatcher to verify properties about a Context.

func (*ContextMatcher) Matches 

func (c *ContextMatcher) Matches(got interface{}) bool

Matches a context against an expected context, returning true only if the given object is a context with a deadline that is now, plus the expected TTL, plus or minus some tolerance.

func (*ContextMatcher) String 

func (c *ContextMatcher) String() string

type ContextMatcherOption 

type ContextMatcherOption interface {
	// contains filtered or unexported methods
}

ContextMatcherOption customizes the behavior of a ContextMatcher.

type ContextTTL 

type ContextTTL time.Duration

ContextTTL requires that a Context have the given TTL on it, with a tolerance of TTLDelta.

type EchoHandler added in v1.5.0 

type EchoHandler struct{}

EchoHandler is a unary handler that echoes the request body on the response body for any inbound request.

func (EchoHandler) Handle added in v1.5.0 

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

Handle handles an inbound request by copying the request body to the response body.

type EchoRouter added in v1.5.0 

type EchoRouter struct{}

EchoRouter is a router that echoes all unary inbound requests, with no explicit procedures.

func (EchoRouter) Choose added in v1.5.0 

func (EchoRouter) Choose(ctx context.Context, req *transport.Request) (transport.HandlerSpec, error)

Choose always returns a unary echo handler.

func (EchoRouter) Procedures added in v1.5.0 

func (EchoRouter) Procedures() []transport.Procedure

Procedures returns no explicitly supported procedures.

type FakeResponseWriter 

type FakeResponseWriter struct {
	IsApplicationError bool
	Headers            transport.Headers
	Body               bytes.Buffer
}

FakeResponseWriter is a ResponseWriter that records the headers and the body written to it.

func (*FakeResponseWriter) AddHeaders 

func (fw *FakeResponseWriter) AddHeaders(h transport.Headers)

AddHeaders for FakeResponseWriter.

func (*FakeResponseWriter) SetApplicationError 

func (fw *FakeResponseWriter) SetApplicationError()

SetApplicationError for FakeResponseWriter.

func (*FakeResponseWriter) Write 

func (fw *FakeResponseWriter) Write(s []byte) (int, error)

Write for FakeResponseWriter.

type MockClientConfig 

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

Mock of ClientConfig interface

func NewMockClientConfig 

func NewMockClientConfig(ctrl *gomock.Controller) *MockClientConfig

func (*MockClientConfig) Caller 

func (_m *MockClientConfig) Caller() string

func (*MockClientConfig) EXPECT 

func (_m *MockClientConfig) EXPECT() *_MockClientConfigRecorder

func (*MockClientConfig) GetOnewayOutbound 

func (_m *MockClientConfig) GetOnewayOutbound() transport.OnewayOutbound

func (*MockClientConfig) GetUnaryOutbound 

func (_m *MockClientConfig) GetUnaryOutbound() transport.UnaryOutbound

func (*MockClientConfig) Service 

func (_m *MockClientConfig) Service() string

type MockClientConfigProvider 

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

Mock of ClientConfigProvider interface

func NewMockClientConfigProvider 

func NewMockClientConfigProvider(ctrl *gomock.Controller) *MockClientConfigProvider

func (*MockClientConfigProvider) ClientConfig 

func (_m *MockClientConfigProvider) ClientConfig(_param0 string) transport.ClientConfig

func (*MockClientConfigProvider) EXPECT 

func (_m *MockClientConfigProvider) EXPECT() *_MockClientConfigProviderRecorder

type MockInbound 

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

Mock of Inbound interface

func NewMockInbound 

func NewMockInbound(ctrl *gomock.Controller) *MockInbound

func (*MockInbound) EXPECT 

func (_m *MockInbound) EXPECT() *_MockInboundRecorder

func (*MockInbound) IsRunning 

func (_m *MockInbound) IsRunning() bool

func (*MockInbound) SetRouter 

func (_m *MockInbound) SetRouter(_param0 transport.Router)

func (*MockInbound) Start 

func (_m *MockInbound) Start() error

func (*MockInbound) Stop 

func (_m *MockInbound) Stop() error

func (*MockInbound) Transports 

func (_m *MockInbound) Transports() []transport.Transport

type MockOnewayHandler 

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

Mock of OnewayHandler interface

func NewMockOnewayHandler 

func NewMockOnewayHandler(ctrl *gomock.Controller) *MockOnewayHandler

func (*MockOnewayHandler) EXPECT 

func (_m *MockOnewayHandler) EXPECT() *_MockOnewayHandlerRecorder

func (*MockOnewayHandler) HandleOneway 

func (_m *MockOnewayHandler) HandleOneway(_param0 context.Context, _param1 *transport.Request) error

type MockOnewayOutbound 

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

Mock of OnewayOutbound interface

func NewMockOnewayOutbound 

func NewMockOnewayOutbound(ctrl *gomock.Controller) *MockOnewayOutbound

func (*MockOnewayOutbound) CallOneway 

func (_m *MockOnewayOutbound) CallOneway(_param0 context.Context, _param1 *transport.Request) (transport.Ack, error)

func (*MockOnewayOutbound) EXPECT 

func (_m *MockOnewayOutbound) EXPECT() *_MockOnewayOutboundRecorder

func (*MockOnewayOutbound) IsRunning 

func (_m *MockOnewayOutbound) IsRunning() bool

func (*MockOnewayOutbound) Start 

func (_m *MockOnewayOutbound) Start() error

func (*MockOnewayOutbound) Stop 

func (_m *MockOnewayOutbound) Stop() error

func (*MockOnewayOutbound) Transports 

func (_m *MockOnewayOutbound) Transports() []transport.Transport

type MockRouteTable 

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

Mock of RouteTable interface

func NewMockRouteTable 

func NewMockRouteTable(ctrl *gomock.Controller) *MockRouteTable

func (*MockRouteTable) Choose 

func (_m *MockRouteTable) Choose(_param0 context.Context, _param1 *transport.Request) (transport.HandlerSpec, error)

func (*MockRouteTable) EXPECT 

func (_m *MockRouteTable) EXPECT() *_MockRouteTableRecorder

func (*MockRouteTable) Procedures 

func (_m *MockRouteTable) Procedures() []transport.Procedure

func (*MockRouteTable) Register 

func (_m *MockRouteTable) Register(_param0 []transport.Procedure)

type MockRouter 

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

Mock of Router interface

func NewMockRouter 

func NewMockRouter(ctrl *gomock.Controller) *MockRouter

func (*MockRouter) Choose 

func (_m *MockRouter) Choose(_param0 context.Context, _param1 *transport.Request) (transport.HandlerSpec, error)

func (*MockRouter) EXPECT 

func (_m *MockRouter) EXPECT() *_MockRouterRecorder

func (*MockRouter) Procedures 

func (_m *MockRouter) Procedures() []transport.Procedure

type MockTransport added in v1.7.0 

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

Mock of Transport interface

func NewMockTransport added in v1.7.0 

func NewMockTransport(ctrl *gomock.Controller) *MockTransport

func (*MockTransport) EXPECT added in v1.7.0 

func (_m *MockTransport) EXPECT() *_MockTransportRecorder

func (*MockTransport) IsRunning added in v1.7.0 

func (_m *MockTransport) IsRunning() bool

func (*MockTransport) Start added in v1.7.0 

func (_m *MockTransport) Start() error

func (*MockTransport) Stop added in v1.7.0 

func (_m *MockTransport) Stop() error

type MockUnaryHandler 

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

Mock of UnaryHandler interface

func NewMockUnaryHandler 

func NewMockUnaryHandler(ctrl *gomock.Controller) *MockUnaryHandler

func (*MockUnaryHandler) EXPECT 

func (_m *MockUnaryHandler) EXPECT() *_MockUnaryHandlerRecorder

func (*MockUnaryHandler) Handle 

func (_m *MockUnaryHandler) Handle(_param0 context.Context, _param1 *transport.Request, _param2 transport.ResponseWriter) error

type MockUnaryOutbound 

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

Mock of UnaryOutbound interface

func NewMockUnaryOutbound 

func NewMockUnaryOutbound(ctrl *gomock.Controller) *MockUnaryOutbound

func (*MockUnaryOutbound) Call 

func (_m *MockUnaryOutbound) Call(_param0 context.Context, _param1 *transport.Request) (*transport.Response, error)

func (*MockUnaryOutbound) EXPECT 

func (_m *MockUnaryOutbound) EXPECT() *_MockUnaryOutboundRecorder

func (*MockUnaryOutbound) IsRunning 

func (_m *MockUnaryOutbound) IsRunning() bool

func (*MockUnaryOutbound) Start 

func (_m *MockUnaryOutbound) Start() error

func (*MockUnaryOutbound) Stop 

func (_m *MockUnaryOutbound) Stop() error

func (*MockUnaryOutbound) Transports 

func (_m *MockUnaryOutbound) Transports() []transport.Transport

type RequestMatcher 

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

RequestMatcher may be used in gomock argument lists to assert that two requests match.

Requests are considered to be matching if:

  • All their primitive parameters match.
  • The headers of the received request include all the headers from the source request. It may include extra headers.
  • The contents of the request bodies are the same.

func NewRequestMatcher 

func NewRequestMatcher(t *testing.T, r *transport.Request) RequestMatcher

NewRequestMatcher constructs a new RequestMatcher from the given testing.T and request.

The request's contents are read in their entirety and replaced with a bytes.Reader.

func (RequestMatcher) Matches 

func (m RequestMatcher) Matches(got interface{}) bool

Matches checks if the given object matches the Request provided in NewRequestMatcher.

func (RequestMatcher) String 

func (m RequestMatcher) String() string

type ResponseMatcher 

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

ResponseMatcher is similar to RequestMatcher but for responses.

func NewResponseMatcher 

func NewResponseMatcher(t *testing.T, r *transport.Response) ResponseMatcher

NewResponseMatcher builds a new ResponseMatcher that verifies that responses match the given Response.

func (ResponseMatcher) Matches 

func (m ResponseMatcher) Matches(got interface{}) bool

Matches checks if the given object matches the Response provided in NewResponseMatcher.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.