mocks

package
v0.3.0 Latest Latest
Warning

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

 Go to latest Published: Mar 27, 2026 License: BSD-2-Clause Imports: 8 Imported by: 0

Documentation

Overview

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BaseCommandCreator 

type BaseCommandCreator struct {
	CreateCommandStub func(iam.Initiator, base.Event) base.Command

	DeleteCommandStub func(iam.Initiator, base.EventID) base.Command

	NewCommandStub func(base.CommandOperation, iam.Initiator, base.EventID, base.Event) base.Command

	NewCommandWithHeaderStub func(base.CommandOperation, iam.Initiator, base.EventID, base.Event, base.CommandHeader) base.Command

	PatchCommandStub func(iam.Initiator, base.EventID, base.Event) base.Command

	UpdateCommandStub func(iam.Initiator, base.EventID, base.Event) base.Command
	// contains filtered or unexported fields
}

func (*BaseCommandCreator) CreateCommand 

func (fake *BaseCommandCreator) CreateCommand(arg1 iam.Initiator, arg2 base.Event) base.Command

func (*BaseCommandCreator) CreateCommandArgsForCall 

func (fake *BaseCommandCreator) CreateCommandArgsForCall(i int) (iam.Initiator, base.Event)

func (*BaseCommandCreator) CreateCommandCallCount 

func (fake *BaseCommandCreator) CreateCommandCallCount() int

func (*BaseCommandCreator) CreateCommandCalls 

func (fake *BaseCommandCreator) CreateCommandCalls(stub func(iam.Initiator, base.Event) base.Command)

func (*BaseCommandCreator) CreateCommandReturns 

func (fake *BaseCommandCreator) CreateCommandReturns(result1 base.Command)

func (*BaseCommandCreator) CreateCommandReturnsOnCall 

func (fake *BaseCommandCreator) CreateCommandReturnsOnCall(i int, result1 base.Command)

func (*BaseCommandCreator) DeleteCommand 

func (fake *BaseCommandCreator) DeleteCommand(arg1 iam.Initiator, arg2 base.EventID) base.Command

func (*BaseCommandCreator) DeleteCommandArgsForCall 

func (fake *BaseCommandCreator) DeleteCommandArgsForCall(i int) (iam.Initiator, base.EventID)

func (*BaseCommandCreator) DeleteCommandCallCount 

func (fake *BaseCommandCreator) DeleteCommandCallCount() int

func (*BaseCommandCreator) DeleteCommandCalls 

func (fake *BaseCommandCreator) DeleteCommandCalls(stub func(iam.Initiator, base.EventID) base.Command)

func (*BaseCommandCreator) DeleteCommandReturns 

func (fake *BaseCommandCreator) DeleteCommandReturns(result1 base.Command)

func (*BaseCommandCreator) DeleteCommandReturnsOnCall 

func (fake *BaseCommandCreator) DeleteCommandReturnsOnCall(i int, result1 base.Command)

func (*BaseCommandCreator) Invocations 

func (fake *BaseCommandCreator) Invocations() map[string][][]interface{}

func (*BaseCommandCreator) NewCommand 

func (fake *BaseCommandCreator) NewCommand(arg1 base.CommandOperation, arg2 iam.Initiator, arg3 base.EventID, arg4 base.Event) base.Command

func (*BaseCommandCreator) NewCommandArgsForCall 

func (fake *BaseCommandCreator) NewCommandArgsForCall(i int) (base.CommandOperation, iam.Initiator, base.EventID, base.Event)

func (*BaseCommandCreator) NewCommandCallCount 

func (fake *BaseCommandCreator) NewCommandCallCount() int

func (*BaseCommandCreator) NewCommandCalls 

func (fake *BaseCommandCreator) NewCommandCalls(stub func(base.CommandOperation, iam.Initiator, base.EventID, base.Event) base.Command)

func (*BaseCommandCreator) NewCommandReturns 

func (fake *BaseCommandCreator) NewCommandReturns(result1 base.Command)

func (*BaseCommandCreator) NewCommandReturnsOnCall 

func (fake *BaseCommandCreator) NewCommandReturnsOnCall(i int, result1 base.Command)

func (*BaseCommandCreator) NewCommandWithHeader 

func (fake *BaseCommandCreator) NewCommandWithHeader(arg1 base.CommandOperation, arg2 iam.Initiator, arg3 base.EventID, arg4 base.Event, arg5 base.CommandHeader) base.Command

func (*BaseCommandCreator) NewCommandWithHeaderArgsForCall 

func (fake *BaseCommandCreator) NewCommandWithHeaderArgsForCall(i int) (base.CommandOperation, iam.Initiator, base.EventID, base.Event, base.CommandHeader)

func (*BaseCommandCreator) NewCommandWithHeaderCallCount 

func (fake *BaseCommandCreator) NewCommandWithHeaderCallCount() int

func (*BaseCommandCreator) NewCommandWithHeaderCalls 

func (fake *BaseCommandCreator) NewCommandWithHeaderCalls(stub func(base.CommandOperation, iam.Initiator, base.EventID, base.Event, base.CommandHeader) base.Command)

func (*BaseCommandCreator) NewCommandWithHeaderReturns 

func (fake *BaseCommandCreator) NewCommandWithHeaderReturns(result1 base.Command)

func (*BaseCommandCreator) NewCommandWithHeaderReturnsOnCall 

func (fake *BaseCommandCreator) NewCommandWithHeaderReturnsOnCall(i int, result1 base.Command)

func (*BaseCommandCreator) PatchCommand 

func (fake *BaseCommandCreator) PatchCommand(arg1 iam.Initiator, arg2 base.EventID, arg3 base.Event) base.Command

func (*BaseCommandCreator) PatchCommandArgsForCall 

func (fake *BaseCommandCreator) PatchCommandArgsForCall(i int) (iam.Initiator, base.EventID, base.Event)

func (*BaseCommandCreator) PatchCommandCallCount 

func (fake *BaseCommandCreator) PatchCommandCallCount() int

func (*BaseCommandCreator) PatchCommandCalls 

func (fake *BaseCommandCreator) PatchCommandCalls(stub func(iam.Initiator, base.EventID, base.Event) base.Command)

func (*BaseCommandCreator) PatchCommandReturns 

func (fake *BaseCommandCreator) PatchCommandReturns(result1 base.Command)

func (*BaseCommandCreator) PatchCommandReturnsOnCall 

func (fake *BaseCommandCreator) PatchCommandReturnsOnCall(i int, result1 base.Command)

func (*BaseCommandCreator) UpdateCommand 

func (fake *BaseCommandCreator) UpdateCommand(arg1 iam.Initiator, arg2 base.EventID, arg3 base.Event) base.Command

func (*BaseCommandCreator) UpdateCommandArgsForCall 

func (fake *BaseCommandCreator) UpdateCommandArgsForCall(i int) (iam.Initiator, base.EventID, base.Event)

func (*BaseCommandCreator) UpdateCommandCallCount 

func (fake *BaseCommandCreator) UpdateCommandCallCount() int

func (*BaseCommandCreator) UpdateCommandCalls 

func (fake *BaseCommandCreator) UpdateCommandCalls(stub func(iam.Initiator, base.EventID, base.Event) base.Command)

func (*BaseCommandCreator) UpdateCommandReturns 

func (fake *BaseCommandCreator) UpdateCommandReturns(result1 base.Command)

func (*BaseCommandCreator) UpdateCommandReturnsOnCall 

func (fake *BaseCommandCreator) UpdateCommandReturnsOnCall(i int, result1 base.Command)

type BaseResultHandler 

type BaseResultHandler struct {
	HandleResultStub func(context.Context, base.Result) error
	// contains filtered or unexported fields
}

func (*BaseResultHandler) HandleResult 

func (fake *BaseResultHandler) HandleResult(arg1 context.Context, arg2 base.Result) error

func (*BaseResultHandler) HandleResultArgsForCall 

func (fake *BaseResultHandler) HandleResultArgsForCall(i int) (context.Context, base.Result)

func (*BaseResultHandler) HandleResultCallCount 

func (fake *BaseResultHandler) HandleResultCallCount() int

func (*BaseResultHandler) HandleResultCalls 

func (fake *BaseResultHandler) HandleResultCalls(stub func(context.Context, base.Result) error)

func (*BaseResultHandler) HandleResultReturns 

func (fake *BaseResultHandler) HandleResultReturns(result1 error)

func (*BaseResultHandler) HandleResultReturnsOnCall 

func (fake *BaseResultHandler) HandleResultReturnsOnCall(i int, result1 error)

func (*BaseResultHandler) Invocations 

func (fake *BaseResultHandler) Invocations() map[string][][]interface{}

type BaseResultHandlerTx 

type BaseResultHandlerTx struct {
	HandleResultStub func(context.Context, kv.Tx, base.Result) error
	// contains filtered or unexported fields
}

func (*BaseResultHandlerTx) HandleResult 

func (fake *BaseResultHandlerTx) HandleResult(arg1 context.Context, arg2 kv.Tx, arg3 base.Result) error

func (*BaseResultHandlerTx) HandleResultArgsForCall 

func (fake *BaseResultHandlerTx) HandleResultArgsForCall(i int) (context.Context, kv.Tx, base.Result)

func (*BaseResultHandlerTx) HandleResultCallCount 

func (fake *BaseResultHandlerTx) HandleResultCallCount() int

func (*BaseResultHandlerTx) HandleResultCalls 

func (fake *BaseResultHandlerTx) HandleResultCalls(stub func(context.Context, kv.Tx, base.Result) error)

func (*BaseResultHandlerTx) HandleResultReturns 

func (fake *BaseResultHandlerTx) HandleResultReturns(result1 error)

func (*BaseResultHandlerTx) HandleResultReturnsOnCall 

func (fake *BaseResultHandlerTx) HandleResultReturnsOnCall(i int, result1 error)

func (*BaseResultHandlerTx) Invocations 

func (fake *BaseResultHandlerTx) Invocations() map[string][][]interface{}

type CDBCommandObjectExecutor added in v0.2.0 

type CDBCommandObjectExecutor struct {
	CommandOperationStub func() base.CommandOperation

	HandleCommandStub func(context.Context, cdb.CommandObject) (*base.EventID, base.Event, error)

	SendResultEnabledStub func() bool
	// contains filtered or unexported fields
}

func (*CDBCommandObjectExecutor) CommandOperation added in v0.2.0 

func (fake *CDBCommandObjectExecutor) CommandOperation() base.CommandOperation

func (*CDBCommandObjectExecutor) CommandOperationCallCount added in v0.2.0 

func (fake *CDBCommandObjectExecutor) CommandOperationCallCount() int

func (*CDBCommandObjectExecutor) CommandOperationCalls added in v0.2.0 

func (fake *CDBCommandObjectExecutor) CommandOperationCalls(stub func() base.CommandOperation)

func (*CDBCommandObjectExecutor) CommandOperationReturns added in v0.2.0 

func (fake *CDBCommandObjectExecutor) CommandOperationReturns(result1 base.CommandOperation)

func (*CDBCommandObjectExecutor) CommandOperationReturnsOnCall added in v0.2.0 

func (fake *CDBCommandObjectExecutor) CommandOperationReturnsOnCall(i int, result1 base.CommandOperation)

func (*CDBCommandObjectExecutor) HandleCommand added in v0.2.0 

func (fake *CDBCommandObjectExecutor) HandleCommand(arg1 context.Context, arg2 cdb.CommandObject) (*base.EventID, base.Event, error)

func (*CDBCommandObjectExecutor) HandleCommandArgsForCall added in v0.2.0 

func (fake *CDBCommandObjectExecutor) HandleCommandArgsForCall(i int) (context.Context, cdb.CommandObject)

func (*CDBCommandObjectExecutor) HandleCommandCallCount added in v0.2.0 

func (fake *CDBCommandObjectExecutor) HandleCommandCallCount() int

func (*CDBCommandObjectExecutor) HandleCommandCalls added in v0.2.0 

func (fake *CDBCommandObjectExecutor) HandleCommandCalls(stub func(context.Context, cdb.CommandObject) (*base.EventID, base.Event, error))

func (*CDBCommandObjectExecutor) HandleCommandReturns added in v0.2.0 

func (fake *CDBCommandObjectExecutor) HandleCommandReturns(result1 *base.EventID, result2 base.Event, result3 error)

func (*CDBCommandObjectExecutor) HandleCommandReturnsOnCall added in v0.2.0 

func (fake *CDBCommandObjectExecutor) HandleCommandReturnsOnCall(i int, result1 *base.EventID, result2 base.Event, result3 error)

func (*CDBCommandObjectExecutor) Invocations added in v0.2.0 

func (fake *CDBCommandObjectExecutor) Invocations() map[string][][]interface{}

func (*CDBCommandObjectExecutor) SendResultEnabled added in v0.2.0 

func (fake *CDBCommandObjectExecutor) SendResultEnabled() bool

func (*CDBCommandObjectExecutor) SendResultEnabledCallCount added in v0.2.0 

func (fake *CDBCommandObjectExecutor) SendResultEnabledCallCount() int

func (*CDBCommandObjectExecutor) SendResultEnabledCalls added in v0.2.0 

func (fake *CDBCommandObjectExecutor) SendResultEnabledCalls(stub func() bool)

func (*CDBCommandObjectExecutor) SendResultEnabledReturns added in v0.2.0 

func (fake *CDBCommandObjectExecutor) SendResultEnabledReturns(result1 bool)

func (*CDBCommandObjectExecutor) SendResultEnabledReturnsOnCall added in v0.2.0 

func (fake *CDBCommandObjectExecutor) SendResultEnabledReturnsOnCall(i int, result1 bool)

type CDBCommandObjectExecutorTx added in v0.2.0 

type CDBCommandObjectExecutorTx struct {
	CommandOperationStub func() base.CommandOperation

	HandleCommandStub func(context.Context, kv.Tx, cdb.CommandObject) (*base.EventID, base.Event, error)

	SendResultEnabledStub func() bool
	// contains filtered or unexported fields
}

func (*CDBCommandObjectExecutorTx) CommandOperation added in v0.2.0 

func (fake *CDBCommandObjectExecutorTx) CommandOperation() base.CommandOperation

func (*CDBCommandObjectExecutorTx) CommandOperationCallCount added in v0.2.0 

func (fake *CDBCommandObjectExecutorTx) CommandOperationCallCount() int

func (*CDBCommandObjectExecutorTx) CommandOperationCalls added in v0.2.0 

func (fake *CDBCommandObjectExecutorTx) CommandOperationCalls(stub func() base.CommandOperation)

func (*CDBCommandObjectExecutorTx) CommandOperationReturns added in v0.2.0 

func (fake *CDBCommandObjectExecutorTx) CommandOperationReturns(result1 base.CommandOperation)

func (*CDBCommandObjectExecutorTx) CommandOperationReturnsOnCall added in v0.2.0 

func (fake *CDBCommandObjectExecutorTx) CommandOperationReturnsOnCall(i int, result1 base.CommandOperation)

func (*CDBCommandObjectExecutorTx) HandleCommand added in v0.2.0 

func (fake *CDBCommandObjectExecutorTx) HandleCommand(arg1 context.Context, arg2 kv.Tx, arg3 cdb.CommandObject) (*base.EventID, base.Event, error)

func (*CDBCommandObjectExecutorTx) HandleCommandArgsForCall added in v0.2.0 

func (fake *CDBCommandObjectExecutorTx) HandleCommandArgsForCall(i int) (context.Context, kv.Tx, cdb.CommandObject)

func (*CDBCommandObjectExecutorTx) HandleCommandCallCount added in v0.2.0 

func (fake *CDBCommandObjectExecutorTx) HandleCommandCallCount() int

func (*CDBCommandObjectExecutorTx) HandleCommandCalls added in v0.2.0 

func (fake *CDBCommandObjectExecutorTx) HandleCommandCalls(stub func(context.Context, kv.Tx, cdb.CommandObject) (*base.EventID, base.Event, error))

func (*CDBCommandObjectExecutorTx) HandleCommandReturns added in v0.2.0 

func (fake *CDBCommandObjectExecutorTx) HandleCommandReturns(result1 *base.EventID, result2 base.Event, result3 error)

func (*CDBCommandObjectExecutorTx) HandleCommandReturnsOnCall added in v0.2.0 

func (fake *CDBCommandObjectExecutorTx) HandleCommandReturnsOnCall(i int, result1 *base.EventID, result2 base.Event, result3 error)

func (*CDBCommandObjectExecutorTx) Invocations added in v0.2.0 

func (fake *CDBCommandObjectExecutorTx) Invocations() map[string][][]interface{}

func (*CDBCommandObjectExecutorTx) SendResultEnabled added in v0.2.0 

func (fake *CDBCommandObjectExecutorTx) SendResultEnabled() bool

func (*CDBCommandObjectExecutorTx) SendResultEnabledCallCount added in v0.2.0 

func (fake *CDBCommandObjectExecutorTx) SendResultEnabledCallCount() int

func (*CDBCommandObjectExecutorTx) SendResultEnabledCalls added in v0.2.0 

func (fake *CDBCommandObjectExecutorTx) SendResultEnabledCalls(stub func() bool)

func (*CDBCommandObjectExecutorTx) SendResultEnabledReturns added in v0.2.0 

func (fake *CDBCommandObjectExecutorTx) SendResultEnabledReturns(result1 bool)

func (*CDBCommandObjectExecutorTx) SendResultEnabledReturnsOnCall added in v0.2.0 

func (fake *CDBCommandObjectExecutorTx) SendResultEnabledReturnsOnCall(i int, result1 bool)

type CDBCommandObjectHandler added in v0.2.0 

type CDBCommandObjectHandler struct {
	HandleStub func(context.Context, cdb.CommandObject) error
	// contains filtered or unexported fields
}

func (*CDBCommandObjectHandler) Handle added in v0.2.0 

func (fake *CDBCommandObjectHandler) Handle(arg1 context.Context, arg2 cdb.CommandObject) error

func (*CDBCommandObjectHandler) HandleArgsForCall added in v0.2.0 

func (fake *CDBCommandObjectHandler) HandleArgsForCall(i int) (context.Context, cdb.CommandObject)

func (*CDBCommandObjectHandler) HandleCallCount added in v0.2.0 

func (fake *CDBCommandObjectHandler) HandleCallCount() int

func (*CDBCommandObjectHandler) HandleCalls added in v0.2.0 

func (fake *CDBCommandObjectHandler) HandleCalls(stub func(context.Context, cdb.CommandObject) error)

func (*CDBCommandObjectHandler) HandleReturns added in v0.2.0 

func (fake *CDBCommandObjectHandler) HandleReturns(result1 error)

func (*CDBCommandObjectHandler) HandleReturnsOnCall added in v0.2.0 

func (fake *CDBCommandObjectHandler) HandleReturnsOnCall(i int, result1 error)

func (*CDBCommandObjectHandler) Invocations added in v0.2.0 

func (fake *CDBCommandObjectHandler) Invocations() map[string][][]interface{}

type CDBCommandObjectHandlerTx added in v0.2.0 

type CDBCommandObjectHandlerTx struct {
	HandleStub func(context.Context, kv.Tx, cdb.CommandObject) error
	// contains filtered or unexported fields
}

func (*CDBCommandObjectHandlerTx) Handle added in v0.2.0 

func (fake *CDBCommandObjectHandlerTx) Handle(arg1 context.Context, arg2 kv.Tx, arg3 cdb.CommandObject) error

func (*CDBCommandObjectHandlerTx) HandleArgsForCall added in v0.2.0 

func (fake *CDBCommandObjectHandlerTx) HandleArgsForCall(i int) (context.Context, kv.Tx, cdb.CommandObject)

func (*CDBCommandObjectHandlerTx) HandleCallCount added in v0.2.0 

func (fake *CDBCommandObjectHandlerTx) HandleCallCount() int

func (*CDBCommandObjectHandlerTx) HandleCalls added in v0.2.0 

func (fake *CDBCommandObjectHandlerTx) HandleCalls(stub func(context.Context, kv.Tx, cdb.CommandObject) error)

func (*CDBCommandObjectHandlerTx) HandleReturns added in v0.2.0 

func (fake *CDBCommandObjectHandlerTx) HandleReturns(result1 error)

func (*CDBCommandObjectHandlerTx) HandleReturnsOnCall added in v0.2.0 

func (fake *CDBCommandObjectHandlerTx) HandleReturnsOnCall(i int, result1 error)

func (*CDBCommandObjectHandlerTx) Invocations added in v0.2.0 

func (fake *CDBCommandObjectHandlerTx) Invocations() map[string][][]interface{}

type CDBCommandObjectSender added in v0.2.0 

type CDBCommandObjectSender struct {
	SendCommandObjectStub func(context.Context, cdb.CommandObject) error

	SendCommandObjectsStub func(context.Context, cdb.CommandObjects) error
	// contains filtered or unexported fields
}

func (*CDBCommandObjectSender) Invocations added in v0.2.0 

func (fake *CDBCommandObjectSender) Invocations() map[string][][]interface{}

func (*CDBCommandObjectSender) SendCommandObject added in v0.2.0 

func (fake *CDBCommandObjectSender) SendCommandObject(arg1 context.Context, arg2 cdb.CommandObject) error

func (*CDBCommandObjectSender) SendCommandObjectArgsForCall added in v0.2.0 

func (fake *CDBCommandObjectSender) SendCommandObjectArgsForCall(i int) (context.Context, cdb.CommandObject)

func (*CDBCommandObjectSender) SendCommandObjectCallCount added in v0.2.0 

func (fake *CDBCommandObjectSender) SendCommandObjectCallCount() int

func (*CDBCommandObjectSender) SendCommandObjectCalls added in v0.2.0 

func (fake *CDBCommandObjectSender) SendCommandObjectCalls(stub func(context.Context, cdb.CommandObject) error)

func (*CDBCommandObjectSender) SendCommandObjectReturns added in v0.2.0 

func (fake *CDBCommandObjectSender) SendCommandObjectReturns(result1 error)

func (*CDBCommandObjectSender) SendCommandObjectReturnsOnCall added in v0.2.0 

func (fake *CDBCommandObjectSender) SendCommandObjectReturnsOnCall(i int, result1 error)

func (*CDBCommandObjectSender) SendCommandObjects added in v0.2.0 

func (fake *CDBCommandObjectSender) SendCommandObjects(arg1 context.Context, arg2 cdb.CommandObjects) error

func (*CDBCommandObjectSender) SendCommandObjectsArgsForCall added in v0.2.0 

func (fake *CDBCommandObjectSender) SendCommandObjectsArgsForCall(i int) (context.Context, cdb.CommandObjects)

func (*CDBCommandObjectSender) SendCommandObjectsCallCount added in v0.2.0 

func (fake *CDBCommandObjectSender) SendCommandObjectsCallCount() int

func (*CDBCommandObjectSender) SendCommandObjectsCalls added in v0.2.0 

func (fake *CDBCommandObjectSender) SendCommandObjectsCalls(stub func(context.Context, cdb.CommandObjects) error)

func (*CDBCommandObjectSender) SendCommandObjectsReturns added in v0.2.0 

func (fake *CDBCommandObjectSender) SendCommandObjectsReturns(result1 error)

func (*CDBCommandObjectSender) SendCommandObjectsReturnsOnCall added in v0.2.0 

func (fake *CDBCommandObjectSender) SendCommandObjectsReturnsOnCall(i int, result1 error)

type CDBEventObjectSender added in v0.2.0 

type CDBEventObjectSender struct {
	SendDeleteStub func(context.Context, cdb.EventObject) error

	SendUpdateStub func(context.Context, cdb.EventObject) error
	// contains filtered or unexported fields
}

func (*CDBEventObjectSender) Invocations added in v0.2.0 

func (fake *CDBEventObjectSender) Invocations() map[string][][]interface{}

func (*CDBEventObjectSender) SendDelete added in v0.2.0 

func (fake *CDBEventObjectSender) SendDelete(arg1 context.Context, arg2 cdb.EventObject) error

func (*CDBEventObjectSender) SendDeleteArgsForCall added in v0.2.0 

func (fake *CDBEventObjectSender) SendDeleteArgsForCall(i int) (context.Context, cdb.EventObject)

func (*CDBEventObjectSender) SendDeleteCallCount added in v0.2.0 

func (fake *CDBEventObjectSender) SendDeleteCallCount() int

func (*CDBEventObjectSender) SendDeleteCalls added in v0.2.0 

func (fake *CDBEventObjectSender) SendDeleteCalls(stub func(context.Context, cdb.EventObject) error)

func (*CDBEventObjectSender) SendDeleteReturns added in v0.2.0 

func (fake *CDBEventObjectSender) SendDeleteReturns(result1 error)

func (*CDBEventObjectSender) SendDeleteReturnsOnCall added in v0.2.0 

func (fake *CDBEventObjectSender) SendDeleteReturnsOnCall(i int, result1 error)

func (*CDBEventObjectSender) SendUpdate added in v0.2.0 

func (fake *CDBEventObjectSender) SendUpdate(arg1 context.Context, arg2 cdb.EventObject) error

func (*CDBEventObjectSender) SendUpdateArgsForCall added in v0.2.0 

func (fake *CDBEventObjectSender) SendUpdateArgsForCall(i int) (context.Context, cdb.EventObject)

func (*CDBEventObjectSender) SendUpdateCallCount added in v0.2.0 

func (fake *CDBEventObjectSender) SendUpdateCallCount() int

func (*CDBEventObjectSender) SendUpdateCalls added in v0.2.0 

func (fake *CDBEventObjectSender) SendUpdateCalls(stub func(context.Context, cdb.EventObject) error)

func (*CDBEventObjectSender) SendUpdateReturns added in v0.2.0 

func (fake *CDBEventObjectSender) SendUpdateReturns(result1 error)

func (*CDBEventObjectSender) SendUpdateReturnsOnCall added in v0.2.0 

func (fake *CDBEventObjectSender) SendUpdateReturnsOnCall(i int, result1 error)

type CDBResultBroadcaster added in v0.2.0 

type CDBResultBroadcaster struct {
	BroadcastStub func(context.Context, cdb.SchemaID, base.Result) error
	// contains filtered or unexported fields
}

func (*CDBResultBroadcaster) Broadcast added in v0.2.0 

func (fake *CDBResultBroadcaster) Broadcast(arg1 context.Context, arg2 cdb.SchemaID, arg3 base.Result) error

func (*CDBResultBroadcaster) BroadcastArgsForCall added in v0.2.0 

func (fake *CDBResultBroadcaster) BroadcastArgsForCall(i int) (context.Context, cdb.SchemaID, base.Result)

func (*CDBResultBroadcaster) BroadcastCallCount added in v0.2.0 

func (fake *CDBResultBroadcaster) BroadcastCallCount() int

func (*CDBResultBroadcaster) BroadcastCalls added in v0.2.0 

func (fake *CDBResultBroadcaster) BroadcastCalls(stub func(context.Context, cdb.SchemaID, base.Result) error)

func (*CDBResultBroadcaster) BroadcastReturns added in v0.2.0 

func (fake *CDBResultBroadcaster) BroadcastReturns(result1 error)

func (*CDBResultBroadcaster) BroadcastReturnsOnCall added in v0.2.0 

func (fake *CDBResultBroadcaster) BroadcastReturnsOnCall(i int, result1 error)

func (*CDBResultBroadcaster) Invocations added in v0.2.0 

func (fake *CDBResultBroadcaster) Invocations() map[string][][]interface{}

type CDBResultObjectSender added in v0.2.0 

type CDBResultObjectSender struct {
	SendStub func(context.Context, cdb.ResultObject) error
	// contains filtered or unexported fields
}

func (*CDBResultObjectSender) Invocations added in v0.2.0 

func (fake *CDBResultObjectSender) Invocations() map[string][][]interface{}

func (*CDBResultObjectSender) Send added in v0.2.0 

func (fake *CDBResultObjectSender) Send(arg1 context.Context, arg2 cdb.ResultObject) error

func (*CDBResultObjectSender) SendArgsForCall added in v0.2.0 

func (fake *CDBResultObjectSender) SendArgsForCall(i int) (context.Context, cdb.ResultObject)

func (*CDBResultObjectSender) SendCallCount added in v0.2.0 

func (fake *CDBResultObjectSender) SendCallCount() int

func (*CDBResultObjectSender) SendCalls added in v0.2.0 

func (fake *CDBResultObjectSender) SendCalls(stub func(context.Context, cdb.ResultObject) error)

func (*CDBResultObjectSender) SendReturns added in v0.2.0 

func (fake *CDBResultObjectSender) SendReturns(result1 error)

func (*CDBResultObjectSender) SendReturnsOnCall added in v0.2.0 

func (fake *CDBResultObjectSender) SendReturnsOnCall(i int, result1 error)

type CDBResultProvider added in v0.2.0 

type CDBResultProvider struct {
	ResultForStub func(context.Context, base.Command) (*base.Result, error)
	// contains filtered or unexported fields
}

func (*CDBResultProvider) Invocations added in v0.2.0 

func (fake *CDBResultProvider) Invocations() map[string][][]interface{}

func (*CDBResultProvider) ResultFor added in v0.2.0 

func (fake *CDBResultProvider) ResultFor(arg1 context.Context, arg2 base.Command) (*base.Result, error)

func (*CDBResultProvider) ResultForArgsForCall added in v0.2.0 

func (fake *CDBResultProvider) ResultForArgsForCall(i int) (context.Context, base.Command)

func (*CDBResultProvider) ResultForCallCount added in v0.2.0 

func (fake *CDBResultProvider) ResultForCallCount() int

func (*CDBResultProvider) ResultForCalls added in v0.2.0 

func (fake *CDBResultProvider) ResultForCalls(stub func(context.Context, base.Command) (*base.Result, error))

func (*CDBResultProvider) ResultForReturns added in v0.2.0 

func (fake *CDBResultProvider) ResultForReturns(result1 *base.Result, result2 error)

func (*CDBResultProvider) ResultForReturnsOnCall added in v0.2.0 

func (fake *CDBResultProvider) ResultForReturnsOnCall(i int, result1 *base.Result, result2 error)

type CDBSchemaStore added in v0.2.0 

type CDBSchemaStore struct {
	AddStub func(context.Context, ...cdb.Schema) error

	GetStub func(context.Context, cdb.SchemaID) (*cdb.Schema, error)

	RemoveStub func(context.Context, ...cdb.SchemaID) error

	StreamStub func(context.Context, chan<- cdb.Schema) error
	// contains filtered or unexported fields
}

func (*CDBSchemaStore) Add added in v0.2.0 

func (fake *CDBSchemaStore) Add(arg1 context.Context, arg2 ...cdb.Schema) error

func (*CDBSchemaStore) AddArgsForCall added in v0.2.0 

func (fake *CDBSchemaStore) AddArgsForCall(i int) (context.Context, []cdb.Schema)

func (*CDBSchemaStore) AddCallCount added in v0.2.0 

func (fake *CDBSchemaStore) AddCallCount() int

func (*CDBSchemaStore) AddCalls added in v0.2.0 

func (fake *CDBSchemaStore) AddCalls(stub func(context.Context, ...cdb.Schema) error)

func (*CDBSchemaStore) AddReturns added in v0.2.0 

func (fake *CDBSchemaStore) AddReturns(result1 error)

func (*CDBSchemaStore) AddReturnsOnCall added in v0.2.0 

func (fake *CDBSchemaStore) AddReturnsOnCall(i int, result1 error)

func (*CDBSchemaStore) Get added in v0.2.0 

func (fake *CDBSchemaStore) Get(arg1 context.Context, arg2 cdb.SchemaID) (*cdb.Schema, error)

func (*CDBSchemaStore) GetArgsForCall added in v0.2.0 

func (fake *CDBSchemaStore) GetArgsForCall(i int) (context.Context, cdb.SchemaID)

func (*CDBSchemaStore) GetCallCount added in v0.2.0 

func (fake *CDBSchemaStore) GetCallCount() int

func (*CDBSchemaStore) GetCalls added in v0.2.0 

func (fake *CDBSchemaStore) GetCalls(stub func(context.Context, cdb.SchemaID) (*cdb.Schema, error))

func (*CDBSchemaStore) GetReturns added in v0.2.0 

func (fake *CDBSchemaStore) GetReturns(result1 *cdb.Schema, result2 error)

func (*CDBSchemaStore) GetReturnsOnCall added in v0.2.0 

func (fake *CDBSchemaStore) GetReturnsOnCall(i int, result1 *cdb.Schema, result2 error)

func (*CDBSchemaStore) Invocations added in v0.2.0 

func (fake *CDBSchemaStore) Invocations() map[string][][]interface{}

func (*CDBSchemaStore) Remove added in v0.2.0 

func (fake *CDBSchemaStore) Remove(arg1 context.Context, arg2 ...cdb.SchemaID) error

func (*CDBSchemaStore) RemoveArgsForCall added in v0.2.0 

func (fake *CDBSchemaStore) RemoveArgsForCall(i int) (context.Context, []cdb.SchemaID)

func (*CDBSchemaStore) RemoveCallCount added in v0.2.0 

func (fake *CDBSchemaStore) RemoveCallCount() int

func (*CDBSchemaStore) RemoveCalls added in v0.2.0 

func (fake *CDBSchemaStore) RemoveCalls(stub func(context.Context, ...cdb.SchemaID) error)

func (*CDBSchemaStore) RemoveReturns added in v0.2.0 

func (fake *CDBSchemaStore) RemoveReturns(result1 error)

func (*CDBSchemaStore) RemoveReturnsOnCall added in v0.2.0 

func (fake *CDBSchemaStore) RemoveReturnsOnCall(i int, result1 error)

func (*CDBSchemaStore) Stream added in v0.2.0 

func (fake *CDBSchemaStore) Stream(arg1 context.Context, arg2 chan<- cdb.Schema) error

func (*CDBSchemaStore) StreamArgsForCall added in v0.2.0 

func (fake *CDBSchemaStore) StreamArgsForCall(i int) (context.Context, chan<- cdb.Schema)

func (*CDBSchemaStore) StreamCallCount added in v0.2.0 

func (fake *CDBSchemaStore) StreamCallCount() int

func (*CDBSchemaStore) StreamCalls added in v0.2.0 

func (fake *CDBSchemaStore) StreamCalls(stub func(context.Context, chan<- cdb.Schema) error)

func (*CDBSchemaStore) StreamReturns added in v0.2.0 

func (fake *CDBSchemaStore) StreamReturns(result1 error)

func (*CDBSchemaStore) StreamReturnsOnCall added in v0.2.0 

func (fake *CDBSchemaStore) StreamReturnsOnCall(i int, result1 error)

type CDBSchemaStoreTx added in v0.2.0 

type CDBSchemaStoreTx struct {
	AddStub func(context.Context, kv.Tx, ...cdb.Schema) error

	GetStub func(context.Context, kv.Tx, cdb.SchemaID) (*cdb.Schema, error)

	RemoveStub func(context.Context, kv.Tx, ...cdb.SchemaID) error

	StreamStub func(context.Context, kv.Tx, chan<- cdb.Schema) error
	// contains filtered or unexported fields
}

func (*CDBSchemaStoreTx) Add added in v0.2.0 

func (fake *CDBSchemaStoreTx) Add(arg1 context.Context, arg2 kv.Tx, arg3 ...cdb.Schema) error

func (*CDBSchemaStoreTx) AddArgsForCall added in v0.2.0 

func (fake *CDBSchemaStoreTx) AddArgsForCall(i int) (context.Context, kv.Tx, []cdb.Schema)

func (*CDBSchemaStoreTx) AddCallCount added in v0.2.0 

func (fake *CDBSchemaStoreTx) AddCallCount() int

func (*CDBSchemaStoreTx) AddCalls added in v0.2.0 

func (fake *CDBSchemaStoreTx) AddCalls(stub func(context.Context, kv.Tx, ...cdb.Schema) error)

func (*CDBSchemaStoreTx) AddReturns added in v0.2.0 

func (fake *CDBSchemaStoreTx) AddReturns(result1 error)

func (*CDBSchemaStoreTx) AddReturnsOnCall added in v0.2.0 

func (fake *CDBSchemaStoreTx) AddReturnsOnCall(i int, result1 error)

func (*CDBSchemaStoreTx) Get added in v0.2.0 

func (fake *CDBSchemaStoreTx) Get(arg1 context.Context, arg2 kv.Tx, arg3 cdb.SchemaID) (*cdb.Schema, error)

func (*CDBSchemaStoreTx) GetArgsForCall added in v0.2.0 

func (fake *CDBSchemaStoreTx) GetArgsForCall(i int) (context.Context, kv.Tx, cdb.SchemaID)

func (*CDBSchemaStoreTx) GetCallCount added in v0.2.0 

func (fake *CDBSchemaStoreTx) GetCallCount() int

func (*CDBSchemaStoreTx) GetCalls added in v0.2.0 

func (fake *CDBSchemaStoreTx) GetCalls(stub func(context.Context, kv.Tx, cdb.SchemaID) (*cdb.Schema, error))

func (*CDBSchemaStoreTx) GetReturns added in v0.2.0 

func (fake *CDBSchemaStoreTx) GetReturns(result1 *cdb.Schema, result2 error)

func (*CDBSchemaStoreTx) GetReturnsOnCall added in v0.2.0 

func (fake *CDBSchemaStoreTx) GetReturnsOnCall(i int, result1 *cdb.Schema, result2 error)

func (*CDBSchemaStoreTx) Invocations added in v0.2.0 

func (fake *CDBSchemaStoreTx) Invocations() map[string][][]interface{}

func (*CDBSchemaStoreTx) Remove added in v0.2.0 

func (fake *CDBSchemaStoreTx) Remove(arg1 context.Context, arg2 kv.Tx, arg3 ...cdb.SchemaID) error

func (*CDBSchemaStoreTx) RemoveArgsForCall added in v0.2.0 

func (fake *CDBSchemaStoreTx) RemoveArgsForCall(i int) (context.Context, kv.Tx, []cdb.SchemaID)

func (*CDBSchemaStoreTx) RemoveCallCount added in v0.2.0 

func (fake *CDBSchemaStoreTx) RemoveCallCount() int

func (*CDBSchemaStoreTx) RemoveCalls added in v0.2.0 

func (fake *CDBSchemaStoreTx) RemoveCalls(stub func(context.Context, kv.Tx, ...cdb.SchemaID) error)

func (*CDBSchemaStoreTx) RemoveReturns added in v0.2.0 

func (fake *CDBSchemaStoreTx) RemoveReturns(result1 error)

func (*CDBSchemaStoreTx) RemoveReturnsOnCall added in v0.2.0 

func (fake *CDBSchemaStoreTx) RemoveReturnsOnCall(i int, result1 error)

func (*CDBSchemaStoreTx) Stream added in v0.2.0 

func (fake *CDBSchemaStoreTx) Stream(arg1 context.Context, arg2 kv.Tx, arg3 chan<- cdb.Schema) error

func (*CDBSchemaStoreTx) StreamArgsForCall added in v0.2.0 

func (fake *CDBSchemaStoreTx) StreamArgsForCall(i int) (context.Context, kv.Tx, chan<- cdb.Schema)

func (*CDBSchemaStoreTx) StreamCallCount added in v0.2.0 

func (fake *CDBSchemaStoreTx) StreamCallCount() int

func (*CDBSchemaStoreTx) StreamCalls added in v0.2.0 

func (fake *CDBSchemaStoreTx) StreamCalls(stub func(context.Context, kv.Tx, chan<- cdb.Schema) error)

func (*CDBSchemaStoreTx) StreamReturns added in v0.2.0 

func (fake *CDBSchemaStoreTx) StreamReturns(result1 error)

func (*CDBSchemaStoreTx) StreamReturnsOnCall added in v0.2.0 

func (fake *CDBSchemaStoreTx) StreamReturnsOnCall(i int, result1 error)

type CdbK8sSchemaConnector added in v0.2.0 

type CdbK8sSchemaConnector struct {
	ListenStub func(context.Context, cache.ResourceEventHandler) error

	SetupCustomResourceDefinitionStub func(context.Context) error
	// contains filtered or unexported fields
}

func (*CdbK8sSchemaConnector) Invocations added in v0.2.0 

func (fake *CdbK8sSchemaConnector) Invocations() map[string][][]interface{}

func (*CdbK8sSchemaConnector) Listen added in v0.2.0 

func (fake *CdbK8sSchemaConnector) Listen(arg1 context.Context, arg2 cache.ResourceEventHandler) error

func (*CdbK8sSchemaConnector) ListenArgsForCall added in v0.2.0 

func (fake *CdbK8sSchemaConnector) ListenArgsForCall(i int) (context.Context, cache.ResourceEventHandler)

func (*CdbK8sSchemaConnector) ListenCallCount added in v0.2.0 

func (fake *CdbK8sSchemaConnector) ListenCallCount() int

func (*CdbK8sSchemaConnector) ListenCalls added in v0.2.0 

func (fake *CdbK8sSchemaConnector) ListenCalls(stub func(context.Context, cache.ResourceEventHandler) error)

func (*CdbK8sSchemaConnector) ListenReturns added in v0.2.0 

func (fake *CdbK8sSchemaConnector) ListenReturns(result1 error)

func (*CdbK8sSchemaConnector) ListenReturnsOnCall added in v0.2.0 

func (fake *CdbK8sSchemaConnector) ListenReturnsOnCall(i int, result1 error)

func (*CdbK8sSchemaConnector) SetupCustomResourceDefinition added in v0.2.0 

func (fake *CdbK8sSchemaConnector) SetupCustomResourceDefinition(arg1 context.Context) error

func (*CdbK8sSchemaConnector) SetupCustomResourceDefinitionArgsForCall added in v0.2.0 

func (fake *CdbK8sSchemaConnector) SetupCustomResourceDefinitionArgsForCall(i int) context.Context

func (*CdbK8sSchemaConnector) SetupCustomResourceDefinitionCallCount added in v0.2.0 

func (fake *CdbK8sSchemaConnector) SetupCustomResourceDefinitionCallCount() int

func (*CdbK8sSchemaConnector) SetupCustomResourceDefinitionCalls added in v0.2.0 

func (fake *CdbK8sSchemaConnector) SetupCustomResourceDefinitionCalls(stub func(context.Context) error)

func (*CdbK8sSchemaConnector) SetupCustomResourceDefinitionReturns added in v0.2.0 

func (fake *CdbK8sSchemaConnector) SetupCustomResourceDefinitionReturns(result1 error)

func (*CdbK8sSchemaConnector) SetupCustomResourceDefinitionReturnsOnCall added in v0.2.0 

func (fake *CdbK8sSchemaConnector) SetupCustomResourceDefinitionReturnsOnCall(i int, result1 error)

type IAMPermissionCheck added in v0.2.0 

type IAMPermissionCheck struct {
	CheckStub func(context.Context, kv.Tx, iam.Initiator) error
	// contains filtered or unexported fields
}

func (*IAMPermissionCheck) Check added in v0.2.0 

func (fake *IAMPermissionCheck) Check(arg1 context.Context, arg2 kv.Tx, arg3 iam.Initiator) error

func (*IAMPermissionCheck) CheckArgsForCall added in v0.2.0 

func (fake *IAMPermissionCheck) CheckArgsForCall(i int) (context.Context, kv.Tx, iam.Initiator)

func (*IAMPermissionCheck) CheckCallCount added in v0.2.0 

func (fake *IAMPermissionCheck) CheckCallCount() int

func (*IAMPermissionCheck) CheckCalls added in v0.2.0 

func (fake *IAMPermissionCheck) CheckCalls(stub func(context.Context, kv.Tx, iam.Initiator) error)

func (*IAMPermissionCheck) CheckReturns added in v0.2.0 

func (fake *IAMPermissionCheck) CheckReturns(result1 error)

func (*IAMPermissionCheck) CheckReturnsOnCall added in v0.2.0 

func (fake *IAMPermissionCheck) CheckReturnsOnCall(i int, result1 error)

func (*IAMPermissionCheck) Invocations added in v0.2.0 

func (fake *IAMPermissionCheck) Invocations() map[string][][]interface{}

type IAMPermissionChecker added in v0.2.0 

type IAMPermissionChecker struct {
	CheckStub func(context.Context, kv.Tx, iam.Initiator, iam.PermissionCheck) error
	// contains filtered or unexported fields
}

func (*IAMPermissionChecker) Check added in v0.2.0 

func (fake *IAMPermissionChecker) Check(arg1 context.Context, arg2 kv.Tx, arg3 iam.Initiator, arg4 iam.PermissionCheck) error

func (*IAMPermissionChecker) CheckArgsForCall added in v0.2.0 

func (fake *IAMPermissionChecker) CheckArgsForCall(i int) (context.Context, kv.Tx, iam.Initiator, iam.PermissionCheck)

func (*IAMPermissionChecker) CheckCallCount added in v0.2.0 

func (fake *IAMPermissionChecker) CheckCallCount() int

func (*IAMPermissionChecker) CheckCalls added in v0.2.0 

func (fake *IAMPermissionChecker) CheckCalls(stub func(context.Context, kv.Tx, iam.Initiator, iam.PermissionCheck) error)

func (*IAMPermissionChecker) CheckReturns added in v0.2.0 

func (fake *IAMPermissionChecker) CheckReturns(result1 error)

func (*IAMPermissionChecker) CheckReturnsOnCall added in v0.2.0 

func (fake *IAMPermissionChecker) CheckReturnsOnCall(i int, result1 error)

func (*IAMPermissionChecker) Invocations added in v0.2.0 

func (fake *IAMPermissionChecker) Invocations() map[string][][]interface{}

type IAMPermissionCheckerMetrics added in v0.2.0 

type IAMPermissionCheckerMetrics struct {
	PermissionCheckFailureCounterIncStub func()

	PermissionCheckSuccessCounterIncStub func()

	PermissionCheckTotalCounterIncStub func()
	// contains filtered or unexported fields
}

func (*IAMPermissionCheckerMetrics) Invocations added in v0.2.0 

func (fake *IAMPermissionCheckerMetrics) Invocations() map[string][][]interface{}

func (*IAMPermissionCheckerMetrics) PermissionCheckFailureCounterInc added in v0.2.0 

func (fake *IAMPermissionCheckerMetrics) PermissionCheckFailureCounterInc()

func (*IAMPermissionCheckerMetrics) PermissionCheckFailureCounterIncCallCount added in v0.2.0 

func (fake *IAMPermissionCheckerMetrics) PermissionCheckFailureCounterIncCallCount() int

func (*IAMPermissionCheckerMetrics) PermissionCheckFailureCounterIncCalls added in v0.2.0 

func (fake *IAMPermissionCheckerMetrics) PermissionCheckFailureCounterIncCalls(stub func())

func (*IAMPermissionCheckerMetrics) PermissionCheckSuccessCounterInc added in v0.2.0 

func (fake *IAMPermissionCheckerMetrics) PermissionCheckSuccessCounterInc()

func (*IAMPermissionCheckerMetrics) PermissionCheckSuccessCounterIncCallCount added in v0.2.0 

func (fake *IAMPermissionCheckerMetrics) PermissionCheckSuccessCounterIncCallCount() int

func (*IAMPermissionCheckerMetrics) PermissionCheckSuccessCounterIncCalls added in v0.2.0 

func (fake *IAMPermissionCheckerMetrics) PermissionCheckSuccessCounterIncCalls(stub func())

func (*IAMPermissionCheckerMetrics) PermissionCheckTotalCounterInc added in v0.2.0 

func (fake *IAMPermissionCheckerMetrics) PermissionCheckTotalCounterInc()

func (*IAMPermissionCheckerMetrics) PermissionCheckTotalCounterIncCallCount added in v0.2.0 

func (fake *IAMPermissionCheckerMetrics) PermissionCheckTotalCounterIncCallCount() int

func (*IAMPermissionCheckerMetrics) PermissionCheckTotalCounterIncCalls added in v0.2.0 

func (fake *IAMPermissionCheckerMetrics) PermissionCheckTotalCounterIncCalls(stub func())

type RawCommandObjectExecutor added in v0.2.0 

type RawCommandObjectExecutor struct {
	CommandOperationStub func() base.CommandOperation

	HandleCommandStub func(context.Context, kv.Tx, raw.CommandObject) (*base.EventID, base.Event, error)

	SendResultEnabledStub func() bool
	// contains filtered or unexported fields
}

func (*RawCommandObjectExecutor) CommandOperation added in v0.2.0 

func (fake *RawCommandObjectExecutor) CommandOperation() base.CommandOperation

func (*RawCommandObjectExecutor) CommandOperationCallCount added in v0.2.0 

func (fake *RawCommandObjectExecutor) CommandOperationCallCount() int

func (*RawCommandObjectExecutor) CommandOperationCalls added in v0.2.0 

func (fake *RawCommandObjectExecutor) CommandOperationCalls(stub func() base.CommandOperation)

func (*RawCommandObjectExecutor) CommandOperationReturns added in v0.2.0 

func (fake *RawCommandObjectExecutor) CommandOperationReturns(result1 base.CommandOperation)

func (*RawCommandObjectExecutor) CommandOperationReturnsOnCall added in v0.2.0 

func (fake *RawCommandObjectExecutor) CommandOperationReturnsOnCall(i int, result1 base.CommandOperation)

func (*RawCommandObjectExecutor) HandleCommand added in v0.2.0 

func (fake *RawCommandObjectExecutor) HandleCommand(arg1 context.Context, arg2 kv.Tx, arg3 raw.CommandObject) (*base.EventID, base.Event, error)

func (*RawCommandObjectExecutor) HandleCommandArgsForCall added in v0.2.0 

func (fake *RawCommandObjectExecutor) HandleCommandArgsForCall(i int) (context.Context, kv.Tx, raw.CommandObject)

func (*RawCommandObjectExecutor) HandleCommandCallCount added in v0.2.0 

func (fake *RawCommandObjectExecutor) HandleCommandCallCount() int

func (*RawCommandObjectExecutor) HandleCommandCalls added in v0.2.0 

func (fake *RawCommandObjectExecutor) HandleCommandCalls(stub func(context.Context, kv.Tx, raw.CommandObject) (*base.EventID, base.Event, error))

func (*RawCommandObjectExecutor) HandleCommandReturns added in v0.2.0 

func (fake *RawCommandObjectExecutor) HandleCommandReturns(result1 *base.EventID, result2 base.Event, result3 error)

func (*RawCommandObjectExecutor) HandleCommandReturnsOnCall added in v0.2.0 

func (fake *RawCommandObjectExecutor) HandleCommandReturnsOnCall(i int, result1 *base.EventID, result2 base.Event, result3 error)

func (*RawCommandObjectExecutor) Invocations added in v0.2.0 

func (fake *RawCommandObjectExecutor) Invocations() map[string][][]interface{}

func (*RawCommandObjectExecutor) SendResultEnabled added in v0.2.0 

func (fake *RawCommandObjectExecutor) SendResultEnabled() bool

func (*RawCommandObjectExecutor) SendResultEnabledCallCount added in v0.2.0 

func (fake *RawCommandObjectExecutor) SendResultEnabledCallCount() int

func (*RawCommandObjectExecutor) SendResultEnabledCalls added in v0.2.0 

func (fake *RawCommandObjectExecutor) SendResultEnabledCalls(stub func() bool)

func (*RawCommandObjectExecutor) SendResultEnabledReturns added in v0.2.0 

func (fake *RawCommandObjectExecutor) SendResultEnabledReturns(result1 bool)

func (*RawCommandObjectExecutor) SendResultEnabledReturnsOnCall added in v0.2.0 

func (fake *RawCommandObjectExecutor) SendResultEnabledReturnsOnCall(i int, result1 bool)

type RawCommandObjectHandler added in v0.2.0 

type RawCommandObjectHandler struct {
	HandleStub func(context.Context, kv.Tx, raw.CommandObject) error
	// contains filtered or unexported fields
}

func (*RawCommandObjectHandler) Handle added in v0.2.0 

func (fake *RawCommandObjectHandler) Handle(arg1 context.Context, arg2 kv.Tx, arg3 raw.CommandObject) error

func (*RawCommandObjectHandler) HandleArgsForCall added in v0.2.0 

func (fake *RawCommandObjectHandler) HandleArgsForCall(i int) (context.Context, kv.Tx, raw.CommandObject)

func (*RawCommandObjectHandler) HandleCallCount added in v0.2.0 

func (fake *RawCommandObjectHandler) HandleCallCount() int

func (*RawCommandObjectHandler) HandleCalls added in v0.2.0 

func (fake *RawCommandObjectHandler) HandleCalls(stub func(context.Context, kv.Tx, raw.CommandObject) error)

func (*RawCommandObjectHandler) HandleReturns added in v0.2.0 

func (fake *RawCommandObjectHandler) HandleReturns(result1 error)

func (*RawCommandObjectHandler) HandleReturnsOnCall added in v0.2.0 

func (fake *RawCommandObjectHandler) HandleReturnsOnCall(i int, result1 error)

func (*RawCommandObjectHandler) Invocations added in v0.2.0 

func (fake *RawCommandObjectHandler) Invocations() map[string][][]interface{}

type RawCommandObjectSender added in v0.2.0 

type RawCommandObjectSender struct {
	SendCommandObjectStub func(context.Context, raw.CommandObject) error

	SendCommandObjectsStub func(context.Context, raw.CommandObjects) error
	// contains filtered or unexported fields
}

func (*RawCommandObjectSender) Invocations added in v0.2.0 

func (fake *RawCommandObjectSender) Invocations() map[string][][]interface{}

func (*RawCommandObjectSender) SendCommandObject added in v0.2.0 

func (fake *RawCommandObjectSender) SendCommandObject(arg1 context.Context, arg2 raw.CommandObject) error

func (*RawCommandObjectSender) SendCommandObjectArgsForCall added in v0.2.0 

func (fake *RawCommandObjectSender) SendCommandObjectArgsForCall(i int) (context.Context, raw.CommandObject)

func (*RawCommandObjectSender) SendCommandObjectCallCount added in v0.2.0 

func (fake *RawCommandObjectSender) SendCommandObjectCallCount() int

func (*RawCommandObjectSender) SendCommandObjectCalls added in v0.2.0 

func (fake *RawCommandObjectSender) SendCommandObjectCalls(stub func(context.Context, raw.CommandObject) error)

func (*RawCommandObjectSender) SendCommandObjectReturns added in v0.2.0 

func (fake *RawCommandObjectSender) SendCommandObjectReturns(result1 error)

func (*RawCommandObjectSender) SendCommandObjectReturnsOnCall added in v0.2.0 

func (fake *RawCommandObjectSender) SendCommandObjectReturnsOnCall(i int, result1 error)

func (*RawCommandObjectSender) SendCommandObjects added in v0.2.0 

func (fake *RawCommandObjectSender) SendCommandObjects(arg1 context.Context, arg2 raw.CommandObjects) error

func (*RawCommandObjectSender) SendCommandObjectsArgsForCall added in v0.2.0 

func (fake *RawCommandObjectSender) SendCommandObjectsArgsForCall(i int) (context.Context, raw.CommandObjects)

func (*RawCommandObjectSender) SendCommandObjectsCallCount added in v0.2.0 

func (fake *RawCommandObjectSender) SendCommandObjectsCallCount() int

func (*RawCommandObjectSender) SendCommandObjectsCalls added in v0.2.0 

func (fake *RawCommandObjectSender) SendCommandObjectsCalls(stub func(context.Context, raw.CommandObjects) error)

func (*RawCommandObjectSender) SendCommandObjectsReturns added in v0.2.0 

func (fake *RawCommandObjectSender) SendCommandObjectsReturns(result1 error)

func (*RawCommandObjectSender) SendCommandObjectsReturnsOnCall added in v0.2.0 

func (fake *RawCommandObjectSender) SendCommandObjectsReturnsOnCall(i int, result1 error)

type RawK8sSchemaConnector added in v0.2.0 

type RawK8sSchemaConnector struct {
	ListenStub func(context.Context, cache.ResourceEventHandler) error

	SetupCustomResourceDefinitionStub func(context.Context) error
	// contains filtered or unexported fields
}

func (*RawK8sSchemaConnector) Invocations added in v0.2.0 

func (fake *RawK8sSchemaConnector) Invocations() map[string][][]interface{}

func (*RawK8sSchemaConnector) Listen added in v0.2.0 

func (fake *RawK8sSchemaConnector) Listen(arg1 context.Context, arg2 cache.ResourceEventHandler) error

func (*RawK8sSchemaConnector) ListenArgsForCall added in v0.2.0 

func (fake *RawK8sSchemaConnector) ListenArgsForCall(i int) (context.Context, cache.ResourceEventHandler)

func (*RawK8sSchemaConnector) ListenCallCount added in v0.2.0 

func (fake *RawK8sSchemaConnector) ListenCallCount() int

func (*RawK8sSchemaConnector) ListenCalls added in v0.2.0 

func (fake *RawK8sSchemaConnector) ListenCalls(stub func(context.Context, cache.ResourceEventHandler) error)

func (*RawK8sSchemaConnector) ListenReturns added in v0.2.0 

func (fake *RawK8sSchemaConnector) ListenReturns(result1 error)

func (*RawK8sSchemaConnector) ListenReturnsOnCall added in v0.2.0 

func (fake *RawK8sSchemaConnector) ListenReturnsOnCall(i int, result1 error)

func (*RawK8sSchemaConnector) SetupCustomResourceDefinition added in v0.2.0 

func (fake *RawK8sSchemaConnector) SetupCustomResourceDefinition(arg1 context.Context) error

func (*RawK8sSchemaConnector) SetupCustomResourceDefinitionArgsForCall added in v0.2.0 

func (fake *RawK8sSchemaConnector) SetupCustomResourceDefinitionArgsForCall(i int) context.Context

func (*RawK8sSchemaConnector) SetupCustomResourceDefinitionCallCount added in v0.2.0 

func (fake *RawK8sSchemaConnector) SetupCustomResourceDefinitionCallCount() int

func (*RawK8sSchemaConnector) SetupCustomResourceDefinitionCalls added in v0.2.0 

func (fake *RawK8sSchemaConnector) SetupCustomResourceDefinitionCalls(stub func(context.Context) error)

func (*RawK8sSchemaConnector) SetupCustomResourceDefinitionReturns added in v0.2.0 

func (fake *RawK8sSchemaConnector) SetupCustomResourceDefinitionReturns(result1 error)

func (*RawK8sSchemaConnector) SetupCustomResourceDefinitionReturnsOnCall added in v0.2.0 

func (fake *RawK8sSchemaConnector) SetupCustomResourceDefinitionReturnsOnCall(i int, result1 error)

type RawResultObjectSender added in v0.2.0 

type RawResultObjectSender struct {
	SendStub func(context.Context, raw.ResultObject) error
	// contains filtered or unexported fields
}

func (*RawResultObjectSender) Invocations added in v0.2.0 

func (fake *RawResultObjectSender) Invocations() map[string][][]interface{}

func (*RawResultObjectSender) Send added in v0.2.0 

func (fake *RawResultObjectSender) Send(arg1 context.Context, arg2 raw.ResultObject) error

func (*RawResultObjectSender) SendArgsForCall added in v0.2.0 

func (fake *RawResultObjectSender) SendArgsForCall(i int) (context.Context, raw.ResultObject)

func (*RawResultObjectSender) SendCallCount added in v0.2.0 

func (fake *RawResultObjectSender) SendCallCount() int

func (*RawResultObjectSender) SendCalls added in v0.2.0 

func (fake *RawResultObjectSender) SendCalls(stub func(context.Context, raw.ResultObject) error)

func (*RawResultObjectSender) SendReturns added in v0.2.0 

func (fake *RawResultObjectSender) SendReturns(result1 error)

func (*RawResultObjectSender) SendReturnsOnCall added in v0.2.0 

func (fake *RawResultObjectSender) SendReturnsOnCall(i int, result1 error)

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.