Documentation ¶
Overview ¶
Code generated by counterfeiter. DO NOT EDIT.
Index ¶
- type FakeIServerClient
- func (fake *FakeIServerClient) GetSetPipelinesCommandByService(arg1 context.Context, arg2 string) (*protos.GetSetPipelinesCommandsByServiceResponse, error)
- func (fake *FakeIServerClient) GetSetPipelinesCommandByServiceArgsForCall(i int) (context.Context, string)
- func (fake *FakeIServerClient) GetSetPipelinesCommandByServiceCallCount() int
- func (fake *FakeIServerClient) GetSetPipelinesCommandByServiceCalls(...)
- func (fake *FakeIServerClient) GetSetPipelinesCommandByServiceReturns(result1 *protos.GetSetPipelinesCommandsByServiceResponse, result2 error)
- func (fake *FakeIServerClient) GetSetPipelinesCommandByServiceReturnsOnCall(i int, result1 *protos.GetSetPipelinesCommandsByServiceResponse, result2 error)
- func (fake *FakeIServerClient) GetTailStream(arg1 context.Context) (protos.Internal_SendTailClient, error)
- func (fake *FakeIServerClient) GetTailStreamArgsForCall(i int) context.Context
- func (fake *FakeIServerClient) GetTailStreamCallCount() int
- func (fake *FakeIServerClient) GetTailStreamCalls(stub func(context.Context) (protos.Internal_SendTailClient, error))
- func (fake *FakeIServerClient) GetTailStreamReturns(result1 protos.Internal_SendTailClient, result2 error)
- func (fake *FakeIServerClient) GetTailStreamReturnsOnCall(i int, result1 protos.Internal_SendTailClient, result2 error)
- func (fake *FakeIServerClient) HeartBeat(arg1 context.Context, arg2 *protos.HeartbeatRequest) error
- func (fake *FakeIServerClient) HeartBeatArgsForCall(i int) (context.Context, *protos.HeartbeatRequest)
- func (fake *FakeIServerClient) HeartBeatCallCount() int
- func (fake *FakeIServerClient) HeartBeatCalls(stub func(context.Context, *protos.HeartbeatRequest) error)
- func (fake *FakeIServerClient) HeartBeatReturns(result1 error)
- func (fake *FakeIServerClient) HeartBeatReturnsOnCall(i int, result1 error)
- func (fake *FakeIServerClient) Invocations() map[string][][]interface{}
- func (fake *FakeIServerClient) NewAudience(arg1 context.Context, arg2 *protos.Audience, arg3 string) error
- func (fake *FakeIServerClient) NewAudienceArgsForCall(i int) (context.Context, *protos.Audience, string)
- func (fake *FakeIServerClient) NewAudienceCallCount() int
- func (fake *FakeIServerClient) NewAudienceCalls(stub func(context.Context, *protos.Audience, string) error)
- func (fake *FakeIServerClient) NewAudienceReturns(result1 error)
- func (fake *FakeIServerClient) NewAudienceReturnsOnCall(i int, result1 error)
- func (fake *FakeIServerClient) Notify(arg1 context.Context, arg2 *protos.Pipeline, arg3 *protos.PipelineStep, ...) error
- func (fake *FakeIServerClient) NotifyArgsForCall(i int) (context.Context, *protos.Pipeline, *protos.PipelineStep, *protos.Audience, ...)
- func (fake *FakeIServerClient) NotifyCallCount() int
- func (fake *FakeIServerClient) NotifyCalls(...)
- func (fake *FakeIServerClient) NotifyReturns(result1 error)
- func (fake *FakeIServerClient) NotifyReturnsOnCall(i int, result1 error)
- func (fake *FakeIServerClient) Reconnect() error
- func (fake *FakeIServerClient) ReconnectCallCount() int
- func (fake *FakeIServerClient) ReconnectCalls(stub func() error)
- func (fake *FakeIServerClient) ReconnectReturns(result1 error)
- func (fake *FakeIServerClient) ReconnectReturnsOnCall(i int, result1 error)
- func (fake *FakeIServerClient) Register(arg1 context.Context, arg2 *protos.RegisterRequest) (protos.Internal_RegisterClient, error)
- func (fake *FakeIServerClient) RegisterArgsForCall(i int) (context.Context, *protos.RegisterRequest)
- func (fake *FakeIServerClient) RegisterCallCount() int
- func (fake *FakeIServerClient) RegisterCalls(...)
- func (fake *FakeIServerClient) RegisterReturns(result1 protos.Internal_RegisterClient, result2 error)
- func (fake *FakeIServerClient) RegisterReturnsOnCall(i int, result1 protos.Internal_RegisterClient, result2 error)
- func (fake *FakeIServerClient) SendMetrics(arg1 context.Context, arg2 []*types.CounterEntry) error
- func (fake *FakeIServerClient) SendMetricsArgsForCall(i int) (context.Context, []*types.CounterEntry)
- func (fake *FakeIServerClient) SendMetricsCallCount() int
- func (fake *FakeIServerClient) SendMetricsCalls(stub func(context.Context, []*types.CounterEntry) error)
- func (fake *FakeIServerClient) SendMetricsReturns(result1 error)
- func (fake *FakeIServerClient) SendMetricsReturnsOnCall(i int, result1 error)
- func (fake *FakeIServerClient) SendSchema(arg1 context.Context, arg2 *protos.Audience, arg3 []byte) error
- func (fake *FakeIServerClient) SendSchemaArgsForCall(i int) (context.Context, *protos.Audience, []byte)
- func (fake *FakeIServerClient) SendSchemaCallCount() int
- func (fake *FakeIServerClient) SendSchemaCalls(stub func(context.Context, *protos.Audience, []byte) error)
- func (fake *FakeIServerClient) SendSchemaReturns(result1 error)
- func (fake *FakeIServerClient) SendSchemaReturnsOnCall(i int, result1 error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type FakeIServerClient ¶
type FakeIServerClient struct { GetSetPipelinesCommandByServiceStub func(context.Context, string) (*protos.GetSetPipelinesCommandsByServiceResponse, error) GetTailStreamStub func(context.Context) (protos.Internal_SendTailClient, error) HeartBeatStub func(context.Context, *protos.HeartbeatRequest) error NewAudienceStub func(context.Context, *protos.Audience, string) error NotifyStub func(context.Context, *protos.Pipeline, *protos.PipelineStep, *protos.Audience, []byte, protos.NotifyRequest_ConditionType) error ReconnectStub func() error RegisterStub func(context.Context, *protos.RegisterRequest) (protos.Internal_RegisterClient, error) SendMetricsStub func(context.Context, []*types.CounterEntry) error SendSchemaStub func(context.Context, *protos.Audience, []byte) error // contains filtered or unexported fields }
func (*FakeIServerClient) GetSetPipelinesCommandByService ¶
func (fake *FakeIServerClient) GetSetPipelinesCommandByService(arg1 context.Context, arg2 string) (*protos.GetSetPipelinesCommandsByServiceResponse, error)
func (*FakeIServerClient) GetSetPipelinesCommandByServiceArgsForCall ¶
func (fake *FakeIServerClient) GetSetPipelinesCommandByServiceArgsForCall(i int) (context.Context, string)
func (*FakeIServerClient) GetSetPipelinesCommandByServiceCallCount ¶
func (fake *FakeIServerClient) GetSetPipelinesCommandByServiceCallCount() int
func (*FakeIServerClient) GetSetPipelinesCommandByServiceCalls ¶
func (fake *FakeIServerClient) GetSetPipelinesCommandByServiceCalls(stub func(context.Context, string) (*protos.GetSetPipelinesCommandsByServiceResponse, error))
func (*FakeIServerClient) GetSetPipelinesCommandByServiceReturns ¶
func (fake *FakeIServerClient) GetSetPipelinesCommandByServiceReturns(result1 *protos.GetSetPipelinesCommandsByServiceResponse, result2 error)
func (*FakeIServerClient) GetSetPipelinesCommandByServiceReturnsOnCall ¶
func (fake *FakeIServerClient) GetSetPipelinesCommandByServiceReturnsOnCall(i int, result1 *protos.GetSetPipelinesCommandsByServiceResponse, result2 error)
func (*FakeIServerClient) GetTailStream ¶
func (fake *FakeIServerClient) GetTailStream(arg1 context.Context) (protos.Internal_SendTailClient, error)
func (*FakeIServerClient) GetTailStreamArgsForCall ¶
func (fake *FakeIServerClient) GetTailStreamArgsForCall(i int) context.Context
func (*FakeIServerClient) GetTailStreamCallCount ¶
func (fake *FakeIServerClient) GetTailStreamCallCount() int
func (*FakeIServerClient) GetTailStreamCalls ¶
func (fake *FakeIServerClient) GetTailStreamCalls(stub func(context.Context) (protos.Internal_SendTailClient, error))
func (*FakeIServerClient) GetTailStreamReturns ¶
func (fake *FakeIServerClient) GetTailStreamReturns(result1 protos.Internal_SendTailClient, result2 error)
func (*FakeIServerClient) GetTailStreamReturnsOnCall ¶
func (fake *FakeIServerClient) GetTailStreamReturnsOnCall(i int, result1 protos.Internal_SendTailClient, result2 error)
func (*FakeIServerClient) HeartBeat ¶
func (fake *FakeIServerClient) HeartBeat(arg1 context.Context, arg2 *protos.HeartbeatRequest) error
func (*FakeIServerClient) HeartBeatArgsForCall ¶
func (fake *FakeIServerClient) HeartBeatArgsForCall(i int) (context.Context, *protos.HeartbeatRequest)
func (*FakeIServerClient) HeartBeatCallCount ¶
func (fake *FakeIServerClient) HeartBeatCallCount() int
func (*FakeIServerClient) HeartBeatCalls ¶
func (fake *FakeIServerClient) HeartBeatCalls(stub func(context.Context, *protos.HeartbeatRequest) error)
func (*FakeIServerClient) HeartBeatReturns ¶
func (fake *FakeIServerClient) HeartBeatReturns(result1 error)
func (*FakeIServerClient) HeartBeatReturnsOnCall ¶
func (fake *FakeIServerClient) HeartBeatReturnsOnCall(i int, result1 error)
func (*FakeIServerClient) Invocations ¶
func (fake *FakeIServerClient) Invocations() map[string][][]interface{}
func (*FakeIServerClient) NewAudience ¶
func (*FakeIServerClient) NewAudienceArgsForCall ¶
func (*FakeIServerClient) NewAudienceCallCount ¶
func (fake *FakeIServerClient) NewAudienceCallCount() int
func (*FakeIServerClient) NewAudienceCalls ¶
func (*FakeIServerClient) NewAudienceReturns ¶
func (fake *FakeIServerClient) NewAudienceReturns(result1 error)
func (*FakeIServerClient) NewAudienceReturnsOnCall ¶
func (fake *FakeIServerClient) NewAudienceReturnsOnCall(i int, result1 error)
func (*FakeIServerClient) Notify ¶
func (fake *FakeIServerClient) Notify(arg1 context.Context, arg2 *protos.Pipeline, arg3 *protos.PipelineStep, arg4 *protos.Audience, arg5 []byte, arg6 protos.NotifyRequest_ConditionType) error
func (*FakeIServerClient) NotifyArgsForCall ¶
func (fake *FakeIServerClient) NotifyArgsForCall(i int) (context.Context, *protos.Pipeline, *protos.PipelineStep, *protos.Audience, []byte, protos.NotifyRequest_ConditionType)
func (*FakeIServerClient) NotifyCallCount ¶
func (fake *FakeIServerClient) NotifyCallCount() int
func (*FakeIServerClient) NotifyCalls ¶
func (fake *FakeIServerClient) NotifyCalls(stub func(context.Context, *protos.Pipeline, *protos.PipelineStep, *protos.Audience, []byte, protos.NotifyRequest_ConditionType) error)
func (*FakeIServerClient) NotifyReturns ¶
func (fake *FakeIServerClient) NotifyReturns(result1 error)
func (*FakeIServerClient) NotifyReturnsOnCall ¶
func (fake *FakeIServerClient) NotifyReturnsOnCall(i int, result1 error)
func (*FakeIServerClient) Reconnect ¶
func (fake *FakeIServerClient) Reconnect() error
func (*FakeIServerClient) ReconnectCallCount ¶
func (fake *FakeIServerClient) ReconnectCallCount() int
func (*FakeIServerClient) ReconnectCalls ¶
func (fake *FakeIServerClient) ReconnectCalls(stub func() error)
func (*FakeIServerClient) ReconnectReturns ¶
func (fake *FakeIServerClient) ReconnectReturns(result1 error)
func (*FakeIServerClient) ReconnectReturnsOnCall ¶
func (fake *FakeIServerClient) ReconnectReturnsOnCall(i int, result1 error)
func (*FakeIServerClient) Register ¶
func (fake *FakeIServerClient) Register(arg1 context.Context, arg2 *protos.RegisterRequest) (protos.Internal_RegisterClient, error)
func (*FakeIServerClient) RegisterArgsForCall ¶
func (fake *FakeIServerClient) RegisterArgsForCall(i int) (context.Context, *protos.RegisterRequest)
func (*FakeIServerClient) RegisterCallCount ¶
func (fake *FakeIServerClient) RegisterCallCount() int
func (*FakeIServerClient) RegisterCalls ¶
func (fake *FakeIServerClient) RegisterCalls(stub func(context.Context, *protos.RegisterRequest) (protos.Internal_RegisterClient, error))
func (*FakeIServerClient) RegisterReturns ¶
func (fake *FakeIServerClient) RegisterReturns(result1 protos.Internal_RegisterClient, result2 error)
func (*FakeIServerClient) RegisterReturnsOnCall ¶
func (fake *FakeIServerClient) RegisterReturnsOnCall(i int, result1 protos.Internal_RegisterClient, result2 error)
func (*FakeIServerClient) SendMetrics ¶
func (fake *FakeIServerClient) SendMetrics(arg1 context.Context, arg2 []*types.CounterEntry) error
func (*FakeIServerClient) SendMetricsArgsForCall ¶
func (fake *FakeIServerClient) SendMetricsArgsForCall(i int) (context.Context, []*types.CounterEntry)
func (*FakeIServerClient) SendMetricsCallCount ¶
func (fake *FakeIServerClient) SendMetricsCallCount() int
func (*FakeIServerClient) SendMetricsCalls ¶
func (fake *FakeIServerClient) SendMetricsCalls(stub func(context.Context, []*types.CounterEntry) error)
func (*FakeIServerClient) SendMetricsReturns ¶
func (fake *FakeIServerClient) SendMetricsReturns(result1 error)
func (*FakeIServerClient) SendMetricsReturnsOnCall ¶
func (fake *FakeIServerClient) SendMetricsReturnsOnCall(i int, result1 error)
func (*FakeIServerClient) SendSchema ¶
func (*FakeIServerClient) SendSchemaArgsForCall ¶
func (*FakeIServerClient) SendSchemaCallCount ¶
func (fake *FakeIServerClient) SendSchemaCallCount() int
func (*FakeIServerClient) SendSchemaCalls ¶
func (*FakeIServerClient) SendSchemaReturns ¶
func (fake *FakeIServerClient) SendSchemaReturns(result1 error)
func (*FakeIServerClient) SendSchemaReturnsOnCall ¶
func (fake *FakeIServerClient) SendSchemaReturnsOnCall(i int, result1 error)
Click to show internal directories.
Click to hide internal directories.