mocks

package
v0.4.0 Latest Latest
Warning

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

 Go to latest Published: May 14, 2025 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockAerospikeClient 

type MockAerospikeClient struct {
	mock.Mock
}

MockAerospikeClient is an autogenerated mock type for the AerospikeClient type

func NewMockAerospikeClient 

func NewMockAerospikeClient(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockAerospikeClient

NewMockAerospikeClient creates a new instance of MockAerospikeClient. 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 (*MockAerospikeClient) BatchOperate 

func (_m *MockAerospikeClient) BatchOperate(policy *aerospike.BatchPolicy, records []aerospike.BatchRecordIfc) aerospike.Error

BatchOperate provides a mock function with given fields: policy, records

func (*MockAerospikeClient) Close 

func (_m *MockAerospikeClient) Close()

Close provides a mock function with given fields:

func (*MockAerospikeClient) Cluster 

func (_m *MockAerospikeClient) Cluster() *aerospike.Cluster

Cluster provides a mock function with given fields:

func (*MockAerospikeClient) CreateComplexIndex 

func (_m *MockAerospikeClient) CreateComplexIndex(policy *aerospike.WritePolicy, namespace string, set string, indexName string, binName string, indexType aerospike.IndexType, indexCollectionType aerospike.IndexCollectionType, ctx ...*aerospike.CDTContext) (*aerospike.IndexTask, aerospike.Error)

CreateComplexIndex provides a mock function with given fields: policy, namespace, set, indexName, binName, indexType, indexCollectionType, ctx

func (*MockAerospikeClient) DropIndex 

func (_m *MockAerospikeClient) DropIndex(policy *aerospike.WritePolicy, namespace string, set string, indexName string) aerospike.Error

DropIndex provides a mock function with given fields: policy, namespace, set, indexName

func (*MockAerospikeClient) EXPECT 

func (_m *MockAerospikeClient) EXPECT() *MockAerospikeClient_Expecter

func (*MockAerospikeClient) GetDefaultInfoPolicy 

func (_m *MockAerospikeClient) GetDefaultInfoPolicy() *aerospike.InfoPolicy

GetDefaultInfoPolicy provides a mock function with given fields:

func (*MockAerospikeClient) GetDefaultScanPolicy 

func (_m *MockAerospikeClient) GetDefaultScanPolicy() *aerospike.ScanPolicy

GetDefaultScanPolicy provides a mock function with given fields:

func (*MockAerospikeClient) GetDefaultWritePolicy 

func (_m *MockAerospikeClient) GetDefaultWritePolicy() *aerospike.WritePolicy

GetDefaultWritePolicy provides a mock function with given fields:

func (*MockAerospikeClient) GetNodes 

func (_m *MockAerospikeClient) GetNodes() []*aerospike.Node

GetNodes provides a mock function with given fields:

func (*MockAerospikeClient) Put 

func (_m *MockAerospikeClient) Put(policy *aerospike.WritePolicy, key *aerospike.Key, bins aerospike.BinMap) aerospike.Error

Put provides a mock function with given fields: policy, key, bins

func (*MockAerospikeClient) PutPayload 

func (_m *MockAerospikeClient) PutPayload(policy *aerospike.WritePolicy, key *aerospike.Key, payload []byte) aerospike.Error

PutPayload provides a mock function with given fields: policy, key, payload

func (*MockAerospikeClient) RegisterUDF 

func (_m *MockAerospikeClient) RegisterUDF(policy *aerospike.WritePolicy, udfBody []byte, serverPath string, language aerospike.Language) (*aerospike.RegisterTask, aerospike.Error)

RegisterUDF provides a mock function with given fields: policy, udfBody, serverPath, language

func (*MockAerospikeClient) ScanNode 

func (_m *MockAerospikeClient) ScanNode(scanPolicy *aerospike.ScanPolicy, node *aerospike.Node, namespace string, setName string, binNames ...string) (*aerospike.Recordset, aerospike.Error)

ScanNode provides a mock function with given fields: scanPolicy, node, namespace, setName, binNames

func (*MockAerospikeClient) ScanPartitions 

func (_m *MockAerospikeClient) ScanPartitions(scanPolicy *aerospike.ScanPolicy, partitionFilter *aerospike.PartitionFilter, namespace string, setName string, binNames ...string) (*aerospike.Recordset, aerospike.Error)

ScanPartitions provides a mock function with given fields: scanPolicy, partitionFilter, namespace, setName, binNames

type MockAerospikeClient_BatchOperate_Call 

type MockAerospikeClient_BatchOperate_Call struct {
	*mock.Call
}

MockAerospikeClient_BatchOperate_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'BatchOperate'

func (*MockAerospikeClient_BatchOperate_Call) Return 

func (_c *MockAerospikeClient_BatchOperate_Call) Return(_a0 aerospike.Error) *MockAerospikeClient_BatchOperate_Call

func (*MockAerospikeClient_BatchOperate_Call) Run 

func (_c *MockAerospikeClient_BatchOperate_Call) Run(run func(policy *aerospike.BatchPolicy, records []aerospike.BatchRecordIfc)) *MockAerospikeClient_BatchOperate_Call

func (*MockAerospikeClient_BatchOperate_Call) RunAndReturn 

func (_c *MockAerospikeClient_BatchOperate_Call) RunAndReturn(run func(*aerospike.BatchPolicy, []aerospike.BatchRecordIfc) aerospike.Error) *MockAerospikeClient_BatchOperate_Call

type MockAerospikeClient_Close_Call 

type MockAerospikeClient_Close_Call struct {
	*mock.Call
}

MockAerospikeClient_Close_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Close'

func (*MockAerospikeClient_Close_Call) Return 

func (_c *MockAerospikeClient_Close_Call) Return() *MockAerospikeClient_Close_Call

func (*MockAerospikeClient_Close_Call) Run 

func (_c *MockAerospikeClient_Close_Call) Run(run func()) *MockAerospikeClient_Close_Call

func (*MockAerospikeClient_Close_Call) RunAndReturn 

func (_c *MockAerospikeClient_Close_Call) RunAndReturn(run func()) *MockAerospikeClient_Close_Call

type MockAerospikeClient_Cluster_Call 

type MockAerospikeClient_Cluster_Call struct {
	*mock.Call
}

MockAerospikeClient_Cluster_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Cluster'

func (*MockAerospikeClient_Cluster_Call) Return 

func (_c *MockAerospikeClient_Cluster_Call) Return(_a0 *aerospike.Cluster) *MockAerospikeClient_Cluster_Call

func (*MockAerospikeClient_Cluster_Call) Run 

func (_c *MockAerospikeClient_Cluster_Call) Run(run func()) *MockAerospikeClient_Cluster_Call

func (*MockAerospikeClient_Cluster_Call) RunAndReturn 

func (_c *MockAerospikeClient_Cluster_Call) RunAndReturn(run func() *aerospike.Cluster) *MockAerospikeClient_Cluster_Call

type MockAerospikeClient_CreateComplexIndex_Call 

type MockAerospikeClient_CreateComplexIndex_Call struct {
	*mock.Call
}

MockAerospikeClient_CreateComplexIndex_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateComplexIndex'

func (*MockAerospikeClient_CreateComplexIndex_Call) Return 

func (_c *MockAerospikeClient_CreateComplexIndex_Call) Return(_a0 *aerospike.IndexTask, _a1 aerospike.Error) *MockAerospikeClient_CreateComplexIndex_Call

func (*MockAerospikeClient_CreateComplexIndex_Call) Run 

func (_c *MockAerospikeClient_CreateComplexIndex_Call) Run(run func(policy *aerospike.WritePolicy, namespace string, set string, indexName string, binName string, indexType aerospike.IndexType, indexCollectionType aerospike.IndexCollectionType, ctx ...*aerospike.CDTContext)) *MockAerospikeClient_CreateComplexIndex_Call

func (*MockAerospikeClient_CreateComplexIndex_Call) RunAndReturn 

func (_c *MockAerospikeClient_CreateComplexIndex_Call) RunAndReturn(run func(*aerospike.WritePolicy, string, string, string, string, aerospike.IndexType, aerospike.IndexCollectionType, ...*aerospike.CDTContext) (*aerospike.IndexTask, aerospike.Error)) *MockAerospikeClient_CreateComplexIndex_Call

type MockAerospikeClient_DropIndex_Call 

type MockAerospikeClient_DropIndex_Call struct {
	*mock.Call
}

MockAerospikeClient_DropIndex_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DropIndex'

func (*MockAerospikeClient_DropIndex_Call) Return 

func (_c *MockAerospikeClient_DropIndex_Call) Return(_a0 aerospike.Error) *MockAerospikeClient_DropIndex_Call

func (*MockAerospikeClient_DropIndex_Call) Run 

func (_c *MockAerospikeClient_DropIndex_Call) Run(run func(policy *aerospike.WritePolicy, namespace string, set string, indexName string)) *MockAerospikeClient_DropIndex_Call

func (*MockAerospikeClient_DropIndex_Call) RunAndReturn 

func (_c *MockAerospikeClient_DropIndex_Call) RunAndReturn(run func(*aerospike.WritePolicy, string, string, string) aerospike.Error) *MockAerospikeClient_DropIndex_Call

type MockAerospikeClient_Expecter 

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

func (*MockAerospikeClient_Expecter) BatchOperate 

func (_e *MockAerospikeClient_Expecter) BatchOperate(policy interface{}, records interface{}) *MockAerospikeClient_BatchOperate_Call

BatchOperate is a helper method to define mock.On call

  • policy *aerospike.BatchPolicy
  • records []aerospike.BatchRecordIfc

func (*MockAerospikeClient_Expecter) Close 

func (_e *MockAerospikeClient_Expecter) Close() *MockAerospikeClient_Close_Call

Close is a helper method to define mock.On call

func (*MockAerospikeClient_Expecter) Cluster 

func (_e *MockAerospikeClient_Expecter) Cluster() *MockAerospikeClient_Cluster_Call

Cluster is a helper method to define mock.On call

func (*MockAerospikeClient_Expecter) CreateComplexIndex 

func (_e *MockAerospikeClient_Expecter) CreateComplexIndex(policy interface{}, namespace interface{}, set interface{}, indexName interface{}, binName interface{}, indexType interface{}, indexCollectionType interface{}, ctx ...interface{}) *MockAerospikeClient_CreateComplexIndex_Call

CreateComplexIndex is a helper method to define mock.On call

  • policy *aerospike.WritePolicy
  • namespace string
  • set string
  • indexName string
  • binName string
  • indexType aerospike.IndexType
  • indexCollectionType aerospike.IndexCollectionType
  • ctx ...*aerospike.CDTContext

func (*MockAerospikeClient_Expecter) DropIndex 

func (_e *MockAerospikeClient_Expecter) DropIndex(policy interface{}, namespace interface{}, set interface{}, indexName interface{}) *MockAerospikeClient_DropIndex_Call

DropIndex is a helper method to define mock.On call

  • policy *aerospike.WritePolicy
  • namespace string
  • set string
  • indexName string

func (*MockAerospikeClient_Expecter) GetDefaultInfoPolicy 

func (_e *MockAerospikeClient_Expecter) GetDefaultInfoPolicy() *MockAerospikeClient_GetDefaultInfoPolicy_Call

GetDefaultInfoPolicy is a helper method to define mock.On call

func (*MockAerospikeClient_Expecter) GetDefaultScanPolicy 

func (_e *MockAerospikeClient_Expecter) GetDefaultScanPolicy() *MockAerospikeClient_GetDefaultScanPolicy_Call

GetDefaultScanPolicy is a helper method to define mock.On call

func (*MockAerospikeClient_Expecter) GetDefaultWritePolicy 

func (_e *MockAerospikeClient_Expecter) GetDefaultWritePolicy() *MockAerospikeClient_GetDefaultWritePolicy_Call

GetDefaultWritePolicy is a helper method to define mock.On call

func (*MockAerospikeClient_Expecter) GetNodes 

func (_e *MockAerospikeClient_Expecter) GetNodes() *MockAerospikeClient_GetNodes_Call

GetNodes is a helper method to define mock.On call

func (*MockAerospikeClient_Expecter) Put 

func (_e *MockAerospikeClient_Expecter) Put(policy interface{}, key interface{}, bins interface{}) *MockAerospikeClient_Put_Call

Put is a helper method to define mock.On call

  • policy *aerospike.WritePolicy
  • key *aerospike.Key
  • bins aerospike.BinMap

func (*MockAerospikeClient_Expecter) PutPayload 

func (_e *MockAerospikeClient_Expecter) PutPayload(policy interface{}, key interface{}, payload interface{}) *MockAerospikeClient_PutPayload_Call

PutPayload is a helper method to define mock.On call

  • policy *aerospike.WritePolicy
  • key *aerospike.Key
  • payload []byte

func (*MockAerospikeClient_Expecter) RegisterUDF 

func (_e *MockAerospikeClient_Expecter) RegisterUDF(policy interface{}, udfBody interface{}, serverPath interface{}, language interface{}) *MockAerospikeClient_RegisterUDF_Call

RegisterUDF is a helper method to define mock.On call

  • policy *aerospike.WritePolicy
  • udfBody []byte
  • serverPath string
  • language aerospike.Language

func (*MockAerospikeClient_Expecter) ScanNode 

func (_e *MockAerospikeClient_Expecter) ScanNode(scanPolicy interface{}, node interface{}, namespace interface{}, setName interface{}, binNames ...interface{}) *MockAerospikeClient_ScanNode_Call

ScanNode is a helper method to define mock.On call

  • scanPolicy *aerospike.ScanPolicy
  • node *aerospike.Node
  • namespace string
  • setName string
  • binNames ...string

func (*MockAerospikeClient_Expecter) ScanPartitions 

func (_e *MockAerospikeClient_Expecter) ScanPartitions(scanPolicy interface{}, partitionFilter interface{}, namespace interface{}, setName interface{}, binNames ...interface{}) *MockAerospikeClient_ScanPartitions_Call

ScanPartitions is a helper method to define mock.On call

  • scanPolicy *aerospike.ScanPolicy
  • partitionFilter *aerospike.PartitionFilter
  • namespace string
  • setName string
  • binNames ...string

type MockAerospikeClient_GetDefaultInfoPolicy_Call 

type MockAerospikeClient_GetDefaultInfoPolicy_Call struct {
	*mock.Call
}

MockAerospikeClient_GetDefaultInfoPolicy_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetDefaultInfoPolicy'

func (*MockAerospikeClient_GetDefaultInfoPolicy_Call) Return 

func (_c *MockAerospikeClient_GetDefaultInfoPolicy_Call) Return(_a0 *aerospike.InfoPolicy) *MockAerospikeClient_GetDefaultInfoPolicy_Call

func (*MockAerospikeClient_GetDefaultInfoPolicy_Call) Run 

func (_c *MockAerospikeClient_GetDefaultInfoPolicy_Call) Run(run func()) *MockAerospikeClient_GetDefaultInfoPolicy_Call

func (*MockAerospikeClient_GetDefaultInfoPolicy_Call) RunAndReturn 

func (_c *MockAerospikeClient_GetDefaultInfoPolicy_Call) RunAndReturn(run func() *aerospike.InfoPolicy) *MockAerospikeClient_GetDefaultInfoPolicy_Call

type MockAerospikeClient_GetDefaultScanPolicy_Call 

type MockAerospikeClient_GetDefaultScanPolicy_Call struct {
	*mock.Call
}

MockAerospikeClient_GetDefaultScanPolicy_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetDefaultScanPolicy'

func (*MockAerospikeClient_GetDefaultScanPolicy_Call) Return 

func (_c *MockAerospikeClient_GetDefaultScanPolicy_Call) Return(_a0 *aerospike.ScanPolicy) *MockAerospikeClient_GetDefaultScanPolicy_Call

func (*MockAerospikeClient_GetDefaultScanPolicy_Call) Run 

func (_c *MockAerospikeClient_GetDefaultScanPolicy_Call) Run(run func()) *MockAerospikeClient_GetDefaultScanPolicy_Call

func (*MockAerospikeClient_GetDefaultScanPolicy_Call) RunAndReturn 

func (_c *MockAerospikeClient_GetDefaultScanPolicy_Call) RunAndReturn(run func() *aerospike.ScanPolicy) *MockAerospikeClient_GetDefaultScanPolicy_Call

type MockAerospikeClient_GetDefaultWritePolicy_Call 

type MockAerospikeClient_GetDefaultWritePolicy_Call struct {
	*mock.Call
}

MockAerospikeClient_GetDefaultWritePolicy_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetDefaultWritePolicy'

func (*MockAerospikeClient_GetDefaultWritePolicy_Call) Return 

func (_c *MockAerospikeClient_GetDefaultWritePolicy_Call) Return(_a0 *aerospike.WritePolicy) *MockAerospikeClient_GetDefaultWritePolicy_Call

func (*MockAerospikeClient_GetDefaultWritePolicy_Call) Run 

func (_c *MockAerospikeClient_GetDefaultWritePolicy_Call) Run(run func()) *MockAerospikeClient_GetDefaultWritePolicy_Call

func (*MockAerospikeClient_GetDefaultWritePolicy_Call) RunAndReturn 

func (_c *MockAerospikeClient_GetDefaultWritePolicy_Call) RunAndReturn(run func() *aerospike.WritePolicy) *MockAerospikeClient_GetDefaultWritePolicy_Call

type MockAerospikeClient_GetNodes_Call 

type MockAerospikeClient_GetNodes_Call struct {
	*mock.Call
}

MockAerospikeClient_GetNodes_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetNodes'

func (*MockAerospikeClient_GetNodes_Call) Return 

func (_c *MockAerospikeClient_GetNodes_Call) Return(_a0 []*aerospike.Node) *MockAerospikeClient_GetNodes_Call

func (*MockAerospikeClient_GetNodes_Call) Run 

func (_c *MockAerospikeClient_GetNodes_Call) Run(run func()) *MockAerospikeClient_GetNodes_Call

func (*MockAerospikeClient_GetNodes_Call) RunAndReturn 

func (_c *MockAerospikeClient_GetNodes_Call) RunAndReturn(run func() []*aerospike.Node) *MockAerospikeClient_GetNodes_Call

type MockAerospikeClient_PutPayload_Call 

type MockAerospikeClient_PutPayload_Call struct {
	*mock.Call
}

MockAerospikeClient_PutPayload_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'PutPayload'

func (*MockAerospikeClient_PutPayload_Call) Return 

func (_c *MockAerospikeClient_PutPayload_Call) Return(_a0 aerospike.Error) *MockAerospikeClient_PutPayload_Call

func (*MockAerospikeClient_PutPayload_Call) Run 

func (_c *MockAerospikeClient_PutPayload_Call) Run(run func(policy *aerospike.WritePolicy, key *aerospike.Key, payload []byte)) *MockAerospikeClient_PutPayload_Call

func (*MockAerospikeClient_PutPayload_Call) RunAndReturn 

func (_c *MockAerospikeClient_PutPayload_Call) RunAndReturn(run func(*aerospike.WritePolicy, *aerospike.Key, []byte) aerospike.Error) *MockAerospikeClient_PutPayload_Call

type MockAerospikeClient_Put_Call 

type MockAerospikeClient_Put_Call struct {
	*mock.Call
}

MockAerospikeClient_Put_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Put'

func (*MockAerospikeClient_Put_Call) Return 

func (_c *MockAerospikeClient_Put_Call) Return(_a0 aerospike.Error) *MockAerospikeClient_Put_Call

func (*MockAerospikeClient_Put_Call) Run 

func (_c *MockAerospikeClient_Put_Call) Run(run func(policy *aerospike.WritePolicy, key *aerospike.Key, bins aerospike.BinMap)) *MockAerospikeClient_Put_Call

func (*MockAerospikeClient_Put_Call) RunAndReturn 

func (_c *MockAerospikeClient_Put_Call) RunAndReturn(run func(*aerospike.WritePolicy, *aerospike.Key, aerospike.BinMap) aerospike.Error) *MockAerospikeClient_Put_Call

type MockAerospikeClient_RegisterUDF_Call 

type MockAerospikeClient_RegisterUDF_Call struct {
	*mock.Call
}

MockAerospikeClient_RegisterUDF_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RegisterUDF'

func (*MockAerospikeClient_RegisterUDF_Call) Return 

func (_c *MockAerospikeClient_RegisterUDF_Call) Return(_a0 *aerospike.RegisterTask, _a1 aerospike.Error) *MockAerospikeClient_RegisterUDF_Call

func (*MockAerospikeClient_RegisterUDF_Call) Run 

func (_c *MockAerospikeClient_RegisterUDF_Call) Run(run func(policy *aerospike.WritePolicy, udfBody []byte, serverPath string, language aerospike.Language)) *MockAerospikeClient_RegisterUDF_Call

func (*MockAerospikeClient_RegisterUDF_Call) RunAndReturn 

func (_c *MockAerospikeClient_RegisterUDF_Call) RunAndReturn(run func(*aerospike.WritePolicy, []byte, string, aerospike.Language) (*aerospike.RegisterTask, aerospike.Error)) *MockAerospikeClient_RegisterUDF_Call

type MockAerospikeClient_ScanNode_Call 

type MockAerospikeClient_ScanNode_Call struct {
	*mock.Call
}

MockAerospikeClient_ScanNode_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ScanNode'

func (*MockAerospikeClient_ScanNode_Call) Return 

func (_c *MockAerospikeClient_ScanNode_Call) Return(_a0 *aerospike.Recordset, _a1 aerospike.Error) *MockAerospikeClient_ScanNode_Call

func (*MockAerospikeClient_ScanNode_Call) Run 

func (_c *MockAerospikeClient_ScanNode_Call) Run(run func(scanPolicy *aerospike.ScanPolicy, node *aerospike.Node, namespace string, setName string, binNames ...string)) *MockAerospikeClient_ScanNode_Call

func (*MockAerospikeClient_ScanNode_Call) RunAndReturn 

func (_c *MockAerospikeClient_ScanNode_Call) RunAndReturn(run func(*aerospike.ScanPolicy, *aerospike.Node, string, string, ...string) (*aerospike.Recordset, aerospike.Error)) *MockAerospikeClient_ScanNode_Call

type MockAerospikeClient_ScanPartitions_Call 

type MockAerospikeClient_ScanPartitions_Call struct {
	*mock.Call
}

MockAerospikeClient_ScanPartitions_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ScanPartitions'

func (*MockAerospikeClient_ScanPartitions_Call) Return 

func (_c *MockAerospikeClient_ScanPartitions_Call) Return(_a0 *aerospike.Recordset, _a1 aerospike.Error) *MockAerospikeClient_ScanPartitions_Call

func (*MockAerospikeClient_ScanPartitions_Call) Run 

func (_c *MockAerospikeClient_ScanPartitions_Call) Run(run func(scanPolicy *aerospike.ScanPolicy, partitionFilter *aerospike.PartitionFilter, namespace string, setName string, binNames ...string)) *MockAerospikeClient_ScanPartitions_Call

func (*MockAerospikeClient_ScanPartitions_Call) RunAndReturn 

func (_c *MockAerospikeClient_ScanPartitions_Call) RunAndReturn(run func(*aerospike.ScanPolicy, *aerospike.PartitionFilter, string, string, ...string) (*aerospike.Recordset, aerospike.Error)) *MockAerospikeClient_ScanPartitions_Call

type MockDecoder 

type MockDecoder[T models.TokenConstraint] struct {
	mock.Mock
}

MockDecoder is an autogenerated mock type for the Decoder type

func NewMockDecoder 

func NewMockDecoder[T models.TokenConstraint](t interface {
	mock.TestingT
	Cleanup(func())
}) *MockDecoder[T]

NewMockDecoder creates a new instance of MockDecoder. 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 (*MockDecoder[T]) EXPECT 

func (_m *MockDecoder[T]) EXPECT() *MockDecoder_Expecter[T]

func (*MockDecoder[T]) NextToken 

func (_m *MockDecoder[T]) NextToken() (T, error)

NextToken provides a mock function with given fields:

type MockDecoder_Expecter 

type MockDecoder_Expecter[T models.TokenConstraint] struct {
	// contains filtered or unexported fields
}

func (*MockDecoder_Expecter[T]) NextToken 

func (_e *MockDecoder_Expecter[T]) NextToken() *MockDecoder_NextToken_Call[T]

NextToken is a helper method to define mock.On call

type MockDecoder_NextToken_Call 

type MockDecoder_NextToken_Call[T models.TokenConstraint] struct {
	*mock.Call
}

MockDecoder_NextToken_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'NextToken'

func (*MockDecoder_NextToken_Call[T]) Return 

func (_c *MockDecoder_NextToken_Call[T]) Return(_a0 T, _a1 error) *MockDecoder_NextToken_Call[T]

func (*MockDecoder_NextToken_Call[T]) Run 

func (_c *MockDecoder_NextToken_Call[T]) Run(run func()) *MockDecoder_NextToken_Call[T]

func (*MockDecoder_NextToken_Call[T]) RunAndReturn 

func (_c *MockDecoder_NextToken_Call[T]) RunAndReturn(run func() (T, error)) *MockDecoder_NextToken_Call[T]

type MockEncoder 

type MockEncoder[T models.TokenConstraint] struct {
	mock.Mock
}

MockEncoder is an autogenerated mock type for the Encoder type

func NewMockEncoder 

func NewMockEncoder[T models.TokenConstraint](t interface {
	mock.TestingT
	Cleanup(func())
}) *MockEncoder[T]

NewMockEncoder creates a new instance of MockEncoder. 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 (*MockEncoder[T]) EXPECT 

func (_m *MockEncoder[T]) EXPECT() *MockEncoder_Expecter[T]

func (*MockEncoder[T]) EncodeToken 

func (_m *MockEncoder[T]) EncodeToken(_a0 T) ([]byte, error)

EncodeToken provides a mock function with given fields: _a0

func (*MockEncoder[T]) GenerateFilename 

func (_m *MockEncoder[T]) GenerateFilename(prefix string, suffix string) string

GenerateFilename provides a mock function with given fields: prefix, suffix

func (*MockEncoder[T]) GetHeader 

func (_m *MockEncoder[T]) GetHeader(_a0 uint64) []byte

GetHeader provides a mock function with given fields: _a0

type MockEncoder_EncodeToken_Call 

type MockEncoder_EncodeToken_Call[T models.TokenConstraint] struct {
	*mock.Call
}

MockEncoder_EncodeToken_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'EncodeToken'

func (*MockEncoder_EncodeToken_Call[T]) Return 

func (_c *MockEncoder_EncodeToken_Call[T]) Return(_a0 []byte, _a1 error) *MockEncoder_EncodeToken_Call[T]

func (*MockEncoder_EncodeToken_Call[T]) Run 

func (_c *MockEncoder_EncodeToken_Call[T]) Run(run func(_a0 T)) *MockEncoder_EncodeToken_Call[T]

func (*MockEncoder_EncodeToken_Call[T]) RunAndReturn 

func (_c *MockEncoder_EncodeToken_Call[T]) RunAndReturn(run func(T) ([]byte, error)) *MockEncoder_EncodeToken_Call[T]

type MockEncoder_Expecter 

type MockEncoder_Expecter[T models.TokenConstraint] struct {
	// contains filtered or unexported fields
}

func (*MockEncoder_Expecter[T]) EncodeToken 

func (_e *MockEncoder_Expecter[T]) EncodeToken(_a0 interface{}) *MockEncoder_EncodeToken_Call[T]

EncodeToken is a helper method to define mock.On call

  • _a0 T

func (*MockEncoder_Expecter[T]) GenerateFilename 

func (_e *MockEncoder_Expecter[T]) GenerateFilename(prefix interface{}, suffix interface{}) *MockEncoder_GenerateFilename_Call[T]

GenerateFilename is a helper method to define mock.On call

  • prefix string
  • suffix string

func (*MockEncoder_Expecter[T]) GetHeader 

func (_e *MockEncoder_Expecter[T]) GetHeader(_a0 interface{}) *MockEncoder_GetHeader_Call[T]

GetHeader is a helper method to define mock.On call

  • _a0 uint64

type MockEncoder_GenerateFilename_Call 

type MockEncoder_GenerateFilename_Call[T models.TokenConstraint] struct {
	*mock.Call
}

MockEncoder_GenerateFilename_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GenerateFilename'

func (*MockEncoder_GenerateFilename_Call[T]) Return 

func (_c *MockEncoder_GenerateFilename_Call[T]) Return(_a0 string) *MockEncoder_GenerateFilename_Call[T]

func (*MockEncoder_GenerateFilename_Call[T]) Run 

func (_c *MockEncoder_GenerateFilename_Call[T]) Run(run func(prefix string, suffix string)) *MockEncoder_GenerateFilename_Call[T]

func (*MockEncoder_GenerateFilename_Call[T]) RunAndReturn 

func (_c *MockEncoder_GenerateFilename_Call[T]) RunAndReturn(run func(string, string) string) *MockEncoder_GenerateFilename_Call[T]

type MockEncoder_GetHeader_Call 

type MockEncoder_GetHeader_Call[T models.TokenConstraint] struct {
	*mock.Call
}

MockEncoder_GetHeader_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetHeader'

func (*MockEncoder_GetHeader_Call[T]) Return 

func (_c *MockEncoder_GetHeader_Call[T]) Return(_a0 []byte) *MockEncoder_GetHeader_Call[T]

func (*MockEncoder_GetHeader_Call[T]) Run 

func (_c *MockEncoder_GetHeader_Call[T]) Run(run func(_a0 uint64)) *MockEncoder_GetHeader_Call[T]

func (*MockEncoder_GetHeader_Call[T]) RunAndReturn 

func (_c *MockEncoder_GetHeader_Call[T]) RunAndReturn(run func(uint64) []byte) *MockEncoder_GetHeader_Call[T]

type MockRestorer 

type MockRestorer struct {
	mock.Mock
}

MockRestorer is an autogenerated mock type for the Restorer type

func NewMockRestorer 

func NewMockRestorer(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockRestorer

NewMockRestorer creates a new instance of MockRestorer. 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 (*MockRestorer) EXPECT 

func (_m *MockRestorer) EXPECT() *MockRestorer_Expecter

func (*MockRestorer) GetMetrics 

func (_m *MockRestorer) GetMetrics() *models.Metrics

GetMetrics provides a mock function with given fields:

func (*MockRestorer) GetStats 

func (_m *MockRestorer) GetStats() *models.RestoreStats

GetStats provides a mock function with given fields:

func (*MockRestorer) Wait 

func (_m *MockRestorer) Wait(ctx context.Context) error

Wait provides a mock function with given fields: ctx

type MockRestorer_Expecter 

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

func (*MockRestorer_Expecter) GetMetrics 

func (_e *MockRestorer_Expecter) GetMetrics() *MockRestorer_GetMetrics_Call

GetMetrics is a helper method to define mock.On call

func (*MockRestorer_Expecter) GetStats 

func (_e *MockRestorer_Expecter) GetStats() *MockRestorer_GetStats_Call

GetStats is a helper method to define mock.On call

func (*MockRestorer_Expecter) Wait 

func (_e *MockRestorer_Expecter) Wait(ctx interface{}) *MockRestorer_Wait_Call

Wait is a helper method to define mock.On call

  • ctx context.Context

type MockRestorer_GetMetrics_Call 

type MockRestorer_GetMetrics_Call struct {
	*mock.Call
}

MockRestorer_GetMetrics_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetMetrics'

func (*MockRestorer_GetMetrics_Call) Return 

func (_c *MockRestorer_GetMetrics_Call) Return(_a0 *models.Metrics) *MockRestorer_GetMetrics_Call

func (*MockRestorer_GetMetrics_Call) Run 

func (_c *MockRestorer_GetMetrics_Call) Run(run func()) *MockRestorer_GetMetrics_Call

func (*MockRestorer_GetMetrics_Call) RunAndReturn 

func (_c *MockRestorer_GetMetrics_Call) RunAndReturn(run func() *models.Metrics) *MockRestorer_GetMetrics_Call

type MockRestorer_GetStats_Call 

type MockRestorer_GetStats_Call struct {
	*mock.Call
}

MockRestorer_GetStats_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetStats'

func (*MockRestorer_GetStats_Call) Return 

func (_c *MockRestorer_GetStats_Call) Return(_a0 *models.RestoreStats) *MockRestorer_GetStats_Call

func (*MockRestorer_GetStats_Call) Run 

func (_c *MockRestorer_GetStats_Call) Run(run func()) *MockRestorer_GetStats_Call

func (*MockRestorer_GetStats_Call) RunAndReturn 

func (_c *MockRestorer_GetStats_Call) RunAndReturn(run func() *models.RestoreStats) *MockRestorer_GetStats_Call

type MockRestorer_Wait_Call 

type MockRestorer_Wait_Call struct {
	*mock.Call
}

MockRestorer_Wait_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Wait'

func (*MockRestorer_Wait_Call) Return 

func (_c *MockRestorer_Wait_Call) Return(_a0 error) *MockRestorer_Wait_Call

func (*MockRestorer_Wait_Call) Run 

func (_c *MockRestorer_Wait_Call) Run(run func(ctx context.Context)) *MockRestorer_Wait_Call

func (*MockRestorer_Wait_Call) RunAndReturn 

func (_c *MockRestorer_Wait_Call) RunAndReturn(run func(context.Context) error) *MockRestorer_Wait_Call

type MockStreamingReader 

type MockStreamingReader struct {
	mock.Mock
}

MockStreamingReader is an autogenerated mock type for the StreamingReader type

func NewMockStreamingReader 

func NewMockStreamingReader(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockStreamingReader

NewMockStreamingReader creates a new instance of MockStreamingReader. 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 (*MockStreamingReader) EXPECT 

func (_m *MockStreamingReader) EXPECT() *MockStreamingReader_Expecter

func (*MockStreamingReader) GetNumber 

func (_m *MockStreamingReader) GetNumber() int64

GetNumber provides a mock function with given fields:

func (*MockStreamingReader) GetSize 

func (_m *MockStreamingReader) GetSize() int64

GetSize provides a mock function with given fields:

func (*MockStreamingReader) GetType 

func (_m *MockStreamingReader) GetType() string

GetType provides a mock function with given fields:

func (*MockStreamingReader) ListObjects 

func (_m *MockStreamingReader) ListObjects(ctx context.Context, path string) ([]string, error)

ListObjects provides a mock function with given fields: ctx, path

func (*MockStreamingReader) StreamFile 

func (_m *MockStreamingReader) StreamFile(ctx context.Context, filename string, readersCh chan<- models.File, errorsCh chan<- error)

StreamFile provides a mock function with given fields: ctx, filename, readersCh, errorsCh

func (*MockStreamingReader) StreamFiles 

func (_m *MockStreamingReader) StreamFiles(_a0 context.Context, _a1 chan<- models.File, _a2 chan<- error)

StreamFiles provides a mock function with given fields: _a0, _a1, _a2

type MockStreamingReader_Expecter 

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

func (*MockStreamingReader_Expecter) GetNumber 

func (_e *MockStreamingReader_Expecter) GetNumber() *MockStreamingReader_GetNumber_Call

GetNumber is a helper method to define mock.On call

func (*MockStreamingReader_Expecter) GetSize 

func (_e *MockStreamingReader_Expecter) GetSize() *MockStreamingReader_GetSize_Call

GetSize is a helper method to define mock.On call

func (*MockStreamingReader_Expecter) GetType 

func (_e *MockStreamingReader_Expecter) GetType() *MockStreamingReader_GetType_Call

GetType is a helper method to define mock.On call

func (*MockStreamingReader_Expecter) ListObjects 

func (_e *MockStreamingReader_Expecter) ListObjects(ctx interface{}, path interface{}) *MockStreamingReader_ListObjects_Call

ListObjects is a helper method to define mock.On call

  • ctx context.Context
  • path string

func (*MockStreamingReader_Expecter) StreamFile 

func (_e *MockStreamingReader_Expecter) StreamFile(ctx interface{}, filename interface{}, readersCh interface{}, errorsCh interface{}) *MockStreamingReader_StreamFile_Call

StreamFile is a helper method to define mock.On call

  • ctx context.Context
  • filename string
  • readersCh chan<- models.File
  • errorsCh chan<- error

func (*MockStreamingReader_Expecter) StreamFiles 

func (_e *MockStreamingReader_Expecter) StreamFiles(_a0 interface{}, _a1 interface{}, _a2 interface{}) *MockStreamingReader_StreamFiles_Call

StreamFiles is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 chan<- models.File
  • _a2 chan<- error

type MockStreamingReader_GetNumber_Call 

type MockStreamingReader_GetNumber_Call struct {
	*mock.Call
}

MockStreamingReader_GetNumber_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetNumber'

func (*MockStreamingReader_GetNumber_Call) Return 

func (_c *MockStreamingReader_GetNumber_Call) Return(_a0 int64) *MockStreamingReader_GetNumber_Call

func (*MockStreamingReader_GetNumber_Call) Run 

func (_c *MockStreamingReader_GetNumber_Call) Run(run func()) *MockStreamingReader_GetNumber_Call

func (*MockStreamingReader_GetNumber_Call) RunAndReturn 

func (_c *MockStreamingReader_GetNumber_Call) RunAndReturn(run func() int64) *MockStreamingReader_GetNumber_Call

type MockStreamingReader_GetSize_Call 

type MockStreamingReader_GetSize_Call struct {
	*mock.Call
}

MockStreamingReader_GetSize_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetSize'

func (*MockStreamingReader_GetSize_Call) Return 

func (_c *MockStreamingReader_GetSize_Call) Return(_a0 int64) *MockStreamingReader_GetSize_Call

func (*MockStreamingReader_GetSize_Call) Run 

func (_c *MockStreamingReader_GetSize_Call) Run(run func()) *MockStreamingReader_GetSize_Call

func (*MockStreamingReader_GetSize_Call) RunAndReturn 

func (_c *MockStreamingReader_GetSize_Call) RunAndReturn(run func() int64) *MockStreamingReader_GetSize_Call

type MockStreamingReader_GetType_Call 

type MockStreamingReader_GetType_Call struct {
	*mock.Call
}

MockStreamingReader_GetType_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetType'

func (*MockStreamingReader_GetType_Call) Return 

func (_c *MockStreamingReader_GetType_Call) Return(_a0 string) *MockStreamingReader_GetType_Call

func (*MockStreamingReader_GetType_Call) Run 

func (_c *MockStreamingReader_GetType_Call) Run(run func()) *MockStreamingReader_GetType_Call

func (*MockStreamingReader_GetType_Call) RunAndReturn 

func (_c *MockStreamingReader_GetType_Call) RunAndReturn(run func() string) *MockStreamingReader_GetType_Call

type MockStreamingReader_ListObjects_Call 

type MockStreamingReader_ListObjects_Call struct {
	*mock.Call
}

MockStreamingReader_ListObjects_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ListObjects'

func (*MockStreamingReader_ListObjects_Call) Return 

func (_c *MockStreamingReader_ListObjects_Call) Return(_a0 []string, _a1 error) *MockStreamingReader_ListObjects_Call

func (*MockStreamingReader_ListObjects_Call) Run 

func (_c *MockStreamingReader_ListObjects_Call) Run(run func(ctx context.Context, path string)) *MockStreamingReader_ListObjects_Call

func (*MockStreamingReader_ListObjects_Call) RunAndReturn 

func (_c *MockStreamingReader_ListObjects_Call) RunAndReturn(run func(context.Context, string) ([]string, error)) *MockStreamingReader_ListObjects_Call

type MockStreamingReader_StreamFile_Call 

type MockStreamingReader_StreamFile_Call struct {
	*mock.Call
}

MockStreamingReader_StreamFile_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'StreamFile'

func (*MockStreamingReader_StreamFile_Call) Return 

func (_c *MockStreamingReader_StreamFile_Call) Return() *MockStreamingReader_StreamFile_Call

func (*MockStreamingReader_StreamFile_Call) Run 

func (_c *MockStreamingReader_StreamFile_Call) Run(run func(ctx context.Context, filename string, readersCh chan<- models.File, errorsCh chan<- error)) *MockStreamingReader_StreamFile_Call

func (*MockStreamingReader_StreamFile_Call) RunAndReturn 

func (_c *MockStreamingReader_StreamFile_Call) RunAndReturn(run func(context.Context, string, chan<- models.File, chan<- error)) *MockStreamingReader_StreamFile_Call

type MockStreamingReader_StreamFiles_Call 

type MockStreamingReader_StreamFiles_Call struct {
	*mock.Call
}

MockStreamingReader_StreamFiles_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'StreamFiles'

func (*MockStreamingReader_StreamFiles_Call) Return 

func (_c *MockStreamingReader_StreamFiles_Call) Return() *MockStreamingReader_StreamFiles_Call

func (*MockStreamingReader_StreamFiles_Call) Run 

func (_c *MockStreamingReader_StreamFiles_Call) Run(run func(_a0 context.Context, _a1 chan<- models.File, _a2 chan<- error)) *MockStreamingReader_StreamFiles_Call

func (*MockStreamingReader_StreamFiles_Call) RunAndReturn 

func (_c *MockStreamingReader_StreamFiles_Call) RunAndReturn(run func(context.Context, chan<- models.File, chan<- error)) *MockStreamingReader_StreamFiles_Call

type MockWriter 

type MockWriter struct {
	mock.Mock
}

MockWriter is an autogenerated mock type for the Writer type

func NewMockWriter 

func NewMockWriter(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockWriter

NewMockWriter creates a new instance of MockWriter. 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 (*MockWriter) EXPECT 

func (_m *MockWriter) EXPECT() *MockWriter_Expecter

func (*MockWriter) GetType 

func (_m *MockWriter) GetType() string

GetType provides a mock function with given fields:

func (*MockWriter) NewWriter 

func (_m *MockWriter) NewWriter(ctx context.Context, filename string) (io.WriteCloser, error)

NewWriter provides a mock function with given fields: ctx, filename

func (*MockWriter) RemoveFiles 

func (_m *MockWriter) RemoveFiles(ctx context.Context) error

RemoveFiles provides a mock function with given fields: ctx

type MockWriter_Expecter 

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

func (*MockWriter_Expecter) GetType 

func (_e *MockWriter_Expecter) GetType() *MockWriter_GetType_Call

GetType is a helper method to define mock.On call

func (*MockWriter_Expecter) NewWriter 

func (_e *MockWriter_Expecter) NewWriter(ctx interface{}, filename interface{}) *MockWriter_NewWriter_Call

NewWriter is a helper method to define mock.On call

  • ctx context.Context
  • filename string

func (*MockWriter_Expecter) RemoveFiles 

func (_e *MockWriter_Expecter) RemoveFiles(ctx interface{}) *MockWriter_RemoveFiles_Call

RemoveFiles is a helper method to define mock.On call

  • ctx context.Context

type MockWriter_GetType_Call 

type MockWriter_GetType_Call struct {
	*mock.Call
}

MockWriter_GetType_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetType'

func (*MockWriter_GetType_Call) Return 

func (_c *MockWriter_GetType_Call) Return(_a0 string) *MockWriter_GetType_Call

func (*MockWriter_GetType_Call) Run 

func (_c *MockWriter_GetType_Call) Run(run func()) *MockWriter_GetType_Call

func (*MockWriter_GetType_Call) RunAndReturn 

func (_c *MockWriter_GetType_Call) RunAndReturn(run func() string) *MockWriter_GetType_Call

type MockWriter_NewWriter_Call 

type MockWriter_NewWriter_Call struct {
	*mock.Call
}

MockWriter_NewWriter_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'NewWriter'

func (*MockWriter_NewWriter_Call) Return 

func (_c *MockWriter_NewWriter_Call) Return(_a0 io.WriteCloser, _a1 error) *MockWriter_NewWriter_Call

func (*MockWriter_NewWriter_Call) Run 

func (_c *MockWriter_NewWriter_Call) Run(run func(ctx context.Context, filename string)) *MockWriter_NewWriter_Call

func (*MockWriter_NewWriter_Call) RunAndReturn 

func (_c *MockWriter_NewWriter_Call) RunAndReturn(run func(context.Context, string) (io.WriteCloser, error)) *MockWriter_NewWriter_Call

type MockWriter_RemoveFiles_Call 

type MockWriter_RemoveFiles_Call struct {
	*mock.Call
}

MockWriter_RemoveFiles_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RemoveFiles'

func (*MockWriter_RemoveFiles_Call) Return 

func (_c *MockWriter_RemoveFiles_Call) Return(_a0 error) *MockWriter_RemoveFiles_Call

func (*MockWriter_RemoveFiles_Call) Run 

func (_c *MockWriter_RemoveFiles_Call) Run(run func(ctx context.Context)) *MockWriter_RemoveFiles_Call

func (*MockWriter_RemoveFiles_Call) RunAndReturn 

func (_c *MockWriter_RemoveFiles_Call) RunAndReturn(run func(context.Context) error) *MockWriter_RemoveFiles_Call

type MockinfoGetter 

type MockinfoGetter struct {
	mock.Mock
}

MockinfoGetter is an autogenerated mock type for the infoGetter type

func NewMockinfoGetter 

func NewMockinfoGetter(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockinfoGetter

NewMockinfoGetter creates a new instance of MockinfoGetter. 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 (*MockinfoGetter) EXPECT 

func (_m *MockinfoGetter) EXPECT() *MockinfoGetter_Expecter

func (*MockinfoGetter) GetRackNodes 

func (_m *MockinfoGetter) GetRackNodes(rackID int) ([]string, error)

GetRackNodes provides a mock function with given fields: rackID

func (*MockinfoGetter) GetRecordCount 

func (_m *MockinfoGetter) GetRecordCount(namespace string, sets []string) (uint64, error)

GetRecordCount provides a mock function with given fields: namespace, sets

func (*MockinfoGetter) GetService 

func (_m *MockinfoGetter) GetService(node string) (string, error)

GetService provides a mock function with given fields: node

type MockinfoGetter_Expecter 

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

func (*MockinfoGetter_Expecter) GetRackNodes 

func (_e *MockinfoGetter_Expecter) GetRackNodes(rackID interface{}) *MockinfoGetter_GetRackNodes_Call

GetRackNodes is a helper method to define mock.On call

  • rackID int

func (*MockinfoGetter_Expecter) GetRecordCount 

func (_e *MockinfoGetter_Expecter) GetRecordCount(namespace interface{}, sets interface{}) *MockinfoGetter_GetRecordCount_Call

GetRecordCount is a helper method to define mock.On call

  • namespace string
  • sets []string

func (*MockinfoGetter_Expecter) GetService 

func (_e *MockinfoGetter_Expecter) GetService(node interface{}) *MockinfoGetter_GetService_Call

GetService is a helper method to define mock.On call

  • node string

type MockinfoGetter_GetRackNodes_Call 

type MockinfoGetter_GetRackNodes_Call struct {
	*mock.Call
}

MockinfoGetter_GetRackNodes_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetRackNodes'

func (*MockinfoGetter_GetRackNodes_Call) Return 

func (_c *MockinfoGetter_GetRackNodes_Call) Return(_a0 []string, _a1 error) *MockinfoGetter_GetRackNodes_Call

func (*MockinfoGetter_GetRackNodes_Call) Run 

func (_c *MockinfoGetter_GetRackNodes_Call) Run(run func(rackID int)) *MockinfoGetter_GetRackNodes_Call

func (*MockinfoGetter_GetRackNodes_Call) RunAndReturn 

func (_c *MockinfoGetter_GetRackNodes_Call) RunAndReturn(run func(int) ([]string, error)) *MockinfoGetter_GetRackNodes_Call

type MockinfoGetter_GetRecordCount_Call 

type MockinfoGetter_GetRecordCount_Call struct {
	*mock.Call
}

MockinfoGetter_GetRecordCount_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetRecordCount'

func (*MockinfoGetter_GetRecordCount_Call) Return 

func (_c *MockinfoGetter_GetRecordCount_Call) Return(_a0 uint64, _a1 error) *MockinfoGetter_GetRecordCount_Call

func (*MockinfoGetter_GetRecordCount_Call) Run 

func (_c *MockinfoGetter_GetRecordCount_Call) Run(run func(namespace string, sets []string)) *MockinfoGetter_GetRecordCount_Call

func (*MockinfoGetter_GetRecordCount_Call) RunAndReturn 

func (_c *MockinfoGetter_GetRecordCount_Call) RunAndReturn(run func(string, []string) (uint64, error)) *MockinfoGetter_GetRecordCount_Call

type MockinfoGetter_GetService_Call 

type MockinfoGetter_GetService_Call struct {
	*mock.Call
}

MockinfoGetter_GetService_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetService'

func (*MockinfoGetter_GetService_Call) Return 

func (_c *MockinfoGetter_GetService_Call) Return(_a0 string, _a1 error) *MockinfoGetter_GetService_Call

func (*MockinfoGetter_GetService_Call) Run 

func (_c *MockinfoGetter_GetService_Call) Run(run func(node string)) *MockinfoGetter_GetService_Call

func (*MockinfoGetter_GetService_Call) RunAndReturn 

func (_c *MockinfoGetter_GetService_Call) RunAndReturn(run func(string) (string, error)) *MockinfoGetter_GetService_Call

type MockstatsSetterToken 

type MockstatsSetterToken struct {
	mock.Mock
}

MockstatsSetterToken is an autogenerated mock type for the statsSetterToken type

func NewMockstatsSetterToken 

func NewMockstatsSetterToken(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockstatsSetterToken

NewMockstatsSetterToken creates a new instance of MockstatsSetterToken. 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 (*MockstatsSetterToken) AddSIndexes 

func (_m *MockstatsSetterToken) AddSIndexes(_a0 uint32)

AddSIndexes provides a mock function with given fields: _a0

func (*MockstatsSetterToken) AddUDFs 

func (_m *MockstatsSetterToken) AddUDFs(_a0 uint32)

AddUDFs provides a mock function with given fields: _a0

func (*MockstatsSetterToken) EXPECT 

func (_m *MockstatsSetterToken) EXPECT() *MockstatsSetterToken_Expecter

type MockstatsSetterToken_AddSIndexes_Call 

type MockstatsSetterToken_AddSIndexes_Call struct {
	*mock.Call
}

MockstatsSetterToken_AddSIndexes_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AddSIndexes'

func (*MockstatsSetterToken_AddSIndexes_Call) Return 

func (_c *MockstatsSetterToken_AddSIndexes_Call) Return() *MockstatsSetterToken_AddSIndexes_Call

func (*MockstatsSetterToken_AddSIndexes_Call) Run 

func (_c *MockstatsSetterToken_AddSIndexes_Call) Run(run func(_a0 uint32)) *MockstatsSetterToken_AddSIndexes_Call

func (*MockstatsSetterToken_AddSIndexes_Call) RunAndReturn 

func (_c *MockstatsSetterToken_AddSIndexes_Call) RunAndReturn(run func(uint32)) *MockstatsSetterToken_AddSIndexes_Call

type MockstatsSetterToken_AddUDFs_Call 

type MockstatsSetterToken_AddUDFs_Call struct {
	*mock.Call
}

MockstatsSetterToken_AddUDFs_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AddUDFs'

func (*MockstatsSetterToken_AddUDFs_Call) Return 

func (_c *MockstatsSetterToken_AddUDFs_Call) Return() *MockstatsSetterToken_AddUDFs_Call

func (*MockstatsSetterToken_AddUDFs_Call) Run 

func (_c *MockstatsSetterToken_AddUDFs_Call) Run(run func(_a0 uint32)) *MockstatsSetterToken_AddUDFs_Call

func (*MockstatsSetterToken_AddUDFs_Call) RunAndReturn 

func (_c *MockstatsSetterToken_AddUDFs_Call) RunAndReturn(run func(uint32)) *MockstatsSetterToken_AddUDFs_Call

type MockstatsSetterToken_Expecter 

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

func (*MockstatsSetterToken_Expecter) AddSIndexes 

func (_e *MockstatsSetterToken_Expecter) AddSIndexes(_a0 interface{}) *MockstatsSetterToken_AddSIndexes_Call

AddSIndexes is a helper method to define mock.On call

  • _a0 uint32

func (*MockstatsSetterToken_Expecter) AddUDFs 

func (_e *MockstatsSetterToken_Expecter) AddUDFs(_a0 interface{}) *MockstatsSetterToken_AddUDFs_Call

AddUDFs is a helper method to define mock.On call

  • _a0 uint32

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.