testing

Documentation

Index

• type MockAppChannel
  • func NewMockAppChannel(t mockConstructorTestingTNewMockAppChannel) *MockAppChannel
  • func (_m *MockAppChannel) GetAppConfig() (*config.ApplicationConfig, error)
  • func (_m *MockAppChannel) GetBaseAddress() string
  • func (_m *MockAppChannel) HealthProbe(ctx context.Context) (bool, error)
  • func (_m *MockAppChannel) InvokeMethod(ctx context.Context, req *v1.InvokeMethodRequest) (*v1.InvokeMethodResponse, error)
  • func (_m *MockAppChannel) SetAppHealth(ah *apphealth.AppHealth)
• type MockClientConn
  • func (m *MockClientConn) Close() error
  • func (m *MockClientConn) Invoke(ctx context.Context, method string, args interface{}, reply interface{}, ...) error
• type MockServer
  • func (m *MockServer) HealthCheck(ctx context.Context, in *emptypb.Empty) (*runtimev1pb.HealthCheckResponse, error)
  • func (m *MockServer) ListInputBindings(ctx context.Context, in *emptypb.Empty) (*runtimev1pb.ListInputBindingsResponse, error)
  • func (m *MockServer) ListTopicSubscriptions(ctx context.Context, in *emptypb.Empty) (*runtimev1pb.ListTopicSubscriptionsResponse, error)
  • func (m *MockServer) OnBindingEvent(ctx context.Context, in *runtimev1pb.BindingEventRequest) (*runtimev1pb.BindingEventResponse, error)
  • func (m *MockServer) OnInvoke(ctx context.Context, in *commonv1pb.InvokeRequest) (*commonv1pb.InvokeResponse, error)
  • func (m *MockServer) OnTopicEvent(ctx context.Context, in *runtimev1pb.TopicEventRequest) (*runtimev1pb.TopicEventResponse, error)

Types

type MockAppChannel

type MockAppChannel struct {
	mock.Mock
}

MockAppChannel is an autogenerated mock type for the AppChannel type

func NewMockAppChannel

func NewMockAppChannel(t mockConstructorTestingTNewMockAppChannel) *MockAppChannel

NewMockAppChannel creates a new instance of MockAppChannel. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.

func (*MockAppChannel) GetAppConfig

func (_m *MockAppChannel) GetAppConfig() (*config.ApplicationConfig, error)

GetAppConfig provides a mock function with given fields:

func (*MockAppChannel) GetBaseAddress

func (_m *MockAppChannel) GetBaseAddress() string

GetBaseAddress provides a mock function with given fields:

func (*MockAppChannel) HealthProbe

func (_m *MockAppChannel) HealthProbe(ctx context.Context) (bool, error)

HealthProbe provides a mock function with given fields: ctx

func (*MockAppChannel) InvokeMethod

func (_m *MockAppChannel) InvokeMethod(ctx context.Context, req *v1.InvokeMethodRequest) (*v1.InvokeMethodResponse, error)

InvokeMethod provides a mock function with given fields: ctx, req

func (*MockAppChannel) SetAppHealth

func (_m *MockAppChannel) SetAppHealth(ah *apphealth.AppHealth)

SetAppHealth provides a mock function with given fields: ah

type MockClientConn

type MockClientConn struct {
	grpc.ClientConnInterface
	InvokeFn func(ctx context.Context, method string, args interface{}, reply interface{}, opts ...grpc.CallOption) error
}

MockClientConn is a mock implementation of grpc.ClientConnInterface.

func (*MockClientConn) Close

func (m *MockClientConn) Close() error

Close implements io.Closer.

func (*MockClientConn) Invoke

func (m *MockClientConn) Invoke(ctx context.Context, method string, args interface{}, reply interface{}, opts ...grpc.CallOption) error

type MockServer

type MockServer struct {
	Error                    error
	Subscriptions            []*runtimev1pb.TopicSubscription
	Bindings                 []string
	BindingEventResponse     runtimev1pb.BindingEventResponse
	TopicEventResponseStatus runtimev1pb.TopicEventResponse_TopicEventResponseStatus
}

MockServer implementation of fake user app server. It implements both AppCallback and AppCallbackHealthCheck.

func (*MockServer) HealthCheck

func (m *MockServer) HealthCheck(ctx context.Context, in *emptypb.Empty) (*runtimev1pb.HealthCheckResponse, error)

func (*MockServer) ListInputBindings

func (m *MockServer) ListInputBindings(ctx context.Context, in *emptypb.Empty) (*runtimev1pb.ListInputBindingsResponse, error)

func (*MockServer) ListTopicSubscriptions

func (m *MockServer) ListTopicSubscriptions(ctx context.Context, in *emptypb.Empty) (*runtimev1pb.ListTopicSubscriptionsResponse, error)

func (*MockServer) OnBindingEvent

func (m *MockServer) OnBindingEvent(ctx context.Context, in *runtimev1pb.BindingEventRequest) (*runtimev1pb.BindingEventResponse, error)

func (*MockServer) OnInvoke

func (m *MockServer) OnInvoke(ctx context.Context, in *commonv1pb.InvokeRequest) (*commonv1pb.InvokeResponse, error)

func (*MockServer) OnTopicEvent

func (m *MockServer) OnTopicEvent(ctx context.Context, in *runtimev1pb.TopicEventRequest) (*runtimev1pb.TopicEventResponse, error)