Documentation
¶
Index ¶
- type ChipIngressClient
- func (_m *ChipIngressClient) EXPECT() *ChipIngressClient_Expecter
- func (_m *ChipIngressClient) Ping(ctx context.Context, in *pb.EmptyRequest, opts ...grpc.CallOption) (*pb.PingResponse, error)
- func (_m *ChipIngressClient) Publish(ctx context.Context, in *v2pb.CloudEvent, opts ...grpc.CallOption) (*pb.PublishResponse, error)
- func (_m *ChipIngressClient) PublishBatch(ctx context.Context, in *pb.CloudEventBatch, opts ...grpc.CallOption) (*pb.PublishResponse, error)
- func (_m *ChipIngressClient) StreamEvents(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[pb.StreamEventsRequest, pb.StreamEventsResponse], ...)
- type ChipIngressClient_Expecter
- func (_e *ChipIngressClient_Expecter) Ping(ctx interface{}, in interface{}, opts ...interface{}) *ChipIngressClient_Ping_Call
- func (_e *ChipIngressClient_Expecter) Publish(ctx interface{}, in interface{}, opts ...interface{}) *ChipIngressClient_Publish_Call
- func (_e *ChipIngressClient_Expecter) PublishBatch(ctx interface{}, in interface{}, opts ...interface{}) *ChipIngressClient_PublishBatch_Call
- func (_e *ChipIngressClient_Expecter) StreamEvents(ctx interface{}, opts ...interface{}) *ChipIngressClient_StreamEvents_Call
- type ChipIngressClient_Ping_Call
- func (_c *ChipIngressClient_Ping_Call) Return(_a0 *pb.PingResponse, _a1 error) *ChipIngressClient_Ping_Call
- func (_c *ChipIngressClient_Ping_Call) Run(run func(ctx context.Context, in *pb.EmptyRequest, opts ...grpc.CallOption)) *ChipIngressClient_Ping_Call
- func (_c *ChipIngressClient_Ping_Call) RunAndReturn(...) *ChipIngressClient_Ping_Call
- type ChipIngressClient_PublishBatch_Call
- func (_c *ChipIngressClient_PublishBatch_Call) Return(_a0 *pb.PublishResponse, _a1 error) *ChipIngressClient_PublishBatch_Call
- func (_c *ChipIngressClient_PublishBatch_Call) Run(run func(ctx context.Context, in *pb.CloudEventBatch, opts ...grpc.CallOption)) *ChipIngressClient_PublishBatch_Call
- func (_c *ChipIngressClient_PublishBatch_Call) RunAndReturn(...) *ChipIngressClient_PublishBatch_Call
- type ChipIngressClient_Publish_Call
- func (_c *ChipIngressClient_Publish_Call) Return(_a0 *pb.PublishResponse, _a1 error) *ChipIngressClient_Publish_Call
- func (_c *ChipIngressClient_Publish_Call) Run(run func(ctx context.Context, in *v2pb.CloudEvent, opts ...grpc.CallOption)) *ChipIngressClient_Publish_Call
- func (_c *ChipIngressClient_Publish_Call) RunAndReturn(...) *ChipIngressClient_Publish_Call
- type ChipIngressClient_StreamEvents_Call
- func (_c *ChipIngressClient_StreamEvents_Call) Return(_a0 grpc.BidiStreamingClient[pb.StreamEventsRequest, pb.StreamEventsResponse], ...) *ChipIngressClient_StreamEvents_Call
- func (_c *ChipIngressClient_StreamEvents_Call) Run(run func(ctx context.Context, opts ...grpc.CallOption)) *ChipIngressClient_StreamEvents_Call
- func (_c *ChipIngressClient_StreamEvents_Call) RunAndReturn(...) *ChipIngressClient_StreamEvents_Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ChipIngressClient ¶
ChipIngressClient is an autogenerated mock type for the ChipIngressClient type
func NewChipIngressClient ¶
func NewChipIngressClient(t interface {
mock.TestingT
Cleanup(func())
}) *ChipIngressClient
NewChipIngressClient creates a new instance of ChipIngressClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*ChipIngressClient) EXPECT ¶
func (_m *ChipIngressClient) EXPECT() *ChipIngressClient_Expecter
func (*ChipIngressClient) Ping ¶
func (_m *ChipIngressClient) Ping(ctx context.Context, in *pb.EmptyRequest, opts ...grpc.CallOption) (*pb.PingResponse, error)
Ping provides a mock function with given fields: ctx, in, opts
func (*ChipIngressClient) Publish ¶
func (_m *ChipIngressClient) Publish(ctx context.Context, in *v2pb.CloudEvent, opts ...grpc.CallOption) (*pb.PublishResponse, error)
Publish provides a mock function with given fields: ctx, in, opts
func (*ChipIngressClient) PublishBatch ¶
func (_m *ChipIngressClient) PublishBatch(ctx context.Context, in *pb.CloudEventBatch, opts ...grpc.CallOption) (*pb.PublishResponse, error)
PublishBatch provides a mock function with given fields: ctx, in, opts
func (*ChipIngressClient) StreamEvents ¶ added in v0.7.1
func (_m *ChipIngressClient) StreamEvents(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[pb.StreamEventsRequest, pb.StreamEventsResponse], error)
StreamEvents provides a mock function with given fields: ctx, opts
type ChipIngressClient_Expecter ¶
type ChipIngressClient_Expecter struct {
// contains filtered or unexported fields
}
func (*ChipIngressClient_Expecter) Ping ¶
func (_e *ChipIngressClient_Expecter) Ping(ctx interface{}, in interface{}, opts ...interface{}) *ChipIngressClient_Ping_Call
Ping is a helper method to define mock.On call
- ctx context.Context
- in *pb.EmptyRequest
- opts ...grpc.CallOption
func (*ChipIngressClient_Expecter) Publish ¶
func (_e *ChipIngressClient_Expecter) Publish(ctx interface{}, in interface{}, opts ...interface{}) *ChipIngressClient_Publish_Call
Publish is a helper method to define mock.On call
- ctx context.Context
- in *v2pb.CloudEvent
- opts ...grpc.CallOption
func (*ChipIngressClient_Expecter) PublishBatch ¶
func (_e *ChipIngressClient_Expecter) PublishBatch(ctx interface{}, in interface{}, opts ...interface{}) *ChipIngressClient_PublishBatch_Call
PublishBatch is a helper method to define mock.On call
- ctx context.Context
- in *pb.CloudEventBatch
- opts ...grpc.CallOption
func (*ChipIngressClient_Expecter) StreamEvents ¶ added in v0.7.1
func (_e *ChipIngressClient_Expecter) StreamEvents(ctx interface{}, opts ...interface{}) *ChipIngressClient_StreamEvents_Call
StreamEvents is a helper method to define mock.On call
- ctx context.Context
- opts ...grpc.CallOption
type ChipIngressClient_Ping_Call ¶
ChipIngressClient_Ping_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Ping'
func (*ChipIngressClient_Ping_Call) Return ¶
func (_c *ChipIngressClient_Ping_Call) Return(_a0 *pb.PingResponse, _a1 error) *ChipIngressClient_Ping_Call
func (*ChipIngressClient_Ping_Call) Run ¶
func (_c *ChipIngressClient_Ping_Call) Run(run func(ctx context.Context, in *pb.EmptyRequest, opts ...grpc.CallOption)) *ChipIngressClient_Ping_Call
func (*ChipIngressClient_Ping_Call) RunAndReturn ¶
func (_c *ChipIngressClient_Ping_Call) RunAndReturn(run func(context.Context, *pb.EmptyRequest, ...grpc.CallOption) (*pb.PingResponse, error)) *ChipIngressClient_Ping_Call
type ChipIngressClient_PublishBatch_Call ¶
ChipIngressClient_PublishBatch_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'PublishBatch'
func (*ChipIngressClient_PublishBatch_Call) Return ¶
func (_c *ChipIngressClient_PublishBatch_Call) Return(_a0 *pb.PublishResponse, _a1 error) *ChipIngressClient_PublishBatch_Call
func (*ChipIngressClient_PublishBatch_Call) Run ¶
func (_c *ChipIngressClient_PublishBatch_Call) Run(run func(ctx context.Context, in *pb.CloudEventBatch, opts ...grpc.CallOption)) *ChipIngressClient_PublishBatch_Call
func (*ChipIngressClient_PublishBatch_Call) RunAndReturn ¶
func (_c *ChipIngressClient_PublishBatch_Call) RunAndReturn(run func(context.Context, *pb.CloudEventBatch, ...grpc.CallOption) (*pb.PublishResponse, error)) *ChipIngressClient_PublishBatch_Call
type ChipIngressClient_Publish_Call ¶
ChipIngressClient_Publish_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Publish'
func (*ChipIngressClient_Publish_Call) Return ¶
func (_c *ChipIngressClient_Publish_Call) Return(_a0 *pb.PublishResponse, _a1 error) *ChipIngressClient_Publish_Call
func (*ChipIngressClient_Publish_Call) Run ¶
func (_c *ChipIngressClient_Publish_Call) Run(run func(ctx context.Context, in *v2pb.CloudEvent, opts ...grpc.CallOption)) *ChipIngressClient_Publish_Call
func (*ChipIngressClient_Publish_Call) RunAndReturn ¶
func (_c *ChipIngressClient_Publish_Call) RunAndReturn(run func(context.Context, *v2pb.CloudEvent, ...grpc.CallOption) (*pb.PublishResponse, error)) *ChipIngressClient_Publish_Call
type ChipIngressClient_StreamEvents_Call ¶ added in v0.7.1
ChipIngressClient_StreamEvents_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'StreamEvents'
func (*ChipIngressClient_StreamEvents_Call) Return ¶ added in v0.7.1
func (_c *ChipIngressClient_StreamEvents_Call) Return(_a0 grpc.BidiStreamingClient[pb.StreamEventsRequest, pb.StreamEventsResponse], _a1 error) *ChipIngressClient_StreamEvents_Call
func (*ChipIngressClient_StreamEvents_Call) Run ¶ added in v0.7.1
func (_c *ChipIngressClient_StreamEvents_Call) Run(run func(ctx context.Context, opts ...grpc.CallOption)) *ChipIngressClient_StreamEvents_Call
func (*ChipIngressClient_StreamEvents_Call) RunAndReturn ¶ added in v0.7.1
func (_c *ChipIngressClient_StreamEvents_Call) RunAndReturn(run func(context.Context, ...grpc.CallOption) (grpc.BidiStreamingClient[pb.StreamEventsRequest, pb.StreamEventsResponse], error)) *ChipIngressClient_StreamEvents_Call