mocks

package
v0.5.1 Latest Latest
Warning

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

 Go to latest Published: Jul 8, 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 (_mock *MockAerospikeClient) BatchOperate(policy *aerospike.BatchPolicy, records []aerospike.BatchRecordIfc) aerospike.Error

BatchOperate provides a mock function for the type MockAerospikeClient

func (*MockAerospikeClient) Close 

func (_mock *MockAerospikeClient) Close()

Close provides a mock function for the type MockAerospikeClient

func (*MockAerospikeClient) Cluster 

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

Cluster provides a mock function for the type MockAerospikeClient

func (*MockAerospikeClient) CreateComplexIndex 

func (_mock *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 for the type MockAerospikeClient

func (*MockAerospikeClient) DropIndex 

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

DropIndex provides a mock function for the type MockAerospikeClient

func (*MockAerospikeClient) EXPECT 

func (_m *MockAerospikeClient) EXPECT() *MockAerospikeClient_Expecter

func (*MockAerospikeClient) GetDefaultInfoPolicy 

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

GetDefaultInfoPolicy provides a mock function for the type MockAerospikeClient

func (*MockAerospikeClient) GetDefaultScanPolicy 

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

GetDefaultScanPolicy provides a mock function for the type MockAerospikeClient

func (*MockAerospikeClient) GetDefaultWritePolicy 

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

GetDefaultWritePolicy provides a mock function for the type MockAerospikeClient

func (*MockAerospikeClient) GetNodes 

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

GetNodes provides a mock function for the type MockAerospikeClient

func (*MockAerospikeClient) Put 

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

Put provides a mock function for the type MockAerospikeClient

func (*MockAerospikeClient) PutPayload 

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

PutPayload provides a mock function for the type MockAerospikeClient

func (*MockAerospikeClient) RegisterUDF 

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

RegisterUDF provides a mock function for the type MockAerospikeClient

func (*MockAerospikeClient) ScanNode 

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

ScanNode provides a mock function for the type MockAerospikeClient

func (*MockAerospikeClient) ScanPartitions 

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

ScanPartitions provides a mock function for the type MockAerospikeClient

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(error 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(policy *aerospike.BatchPolicy, records []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(cluster *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(indexTask *aerospike.IndexTask, error 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(policy *aerospike.WritePolicy, namespace string, set string, indexName string, binName string, indexType aerospike.IndexType, indexCollectionType aerospike.IndexCollectionType, ctx ...*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(error 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(policy *aerospike.WritePolicy, namespace string, set string, indexName 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
  • records

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
  • namespace
  • set
  • indexName
  • binName
  • indexType
  • indexCollectionType
  • ctx

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
  • namespace
  • set
  • indexName

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
  • key
  • bins

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
  • key
  • payload

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
  • udfBody
  • serverPath
  • 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
  • node
  • namespace
  • setName
  • binNames

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
  • partitionFilter
  • namespace
  • setName
  • binNames

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(infoPolicy *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(scanPolicy *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(writePolicy *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(nodes []*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(error 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(policy *aerospike.WritePolicy, key *aerospike.Key, payload []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(error 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(policy *aerospike.WritePolicy, key *aerospike.Key, bins 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(registerTask *aerospike.RegisterTask, error 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(policy *aerospike.WritePolicy, udfBody []byte, serverPath string, language 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(recordset *aerospike.Recordset, error 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(scanPolicy *aerospike.ScanPolicy, node *aerospike.Node, namespace string, setName string, binNames ...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(recordset *aerospike.Recordset, error 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(scanPolicy *aerospike.ScanPolicy, partitionFilter *aerospike.PartitionFilter, namespace string, setName string, binNames ...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 (_mock *MockDecoder[T]) NextToken() (T, error)

NextToken provides a mock function for the type MockDecoder

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(v T, err 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 (_mock *MockEncoder[T]) EncodeToken(v T) ([]byte, error)

EncodeToken provides a mock function for the type MockEncoder

func (*MockEncoder[T]) GenerateFilename 

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

GenerateFilename provides a mock function for the type MockEncoder

func (*MockEncoder[T]) GetHeader 

func (_mock *MockEncoder[T]) GetHeader(v uint64) []byte

GetHeader provides a mock function for the type MockEncoder

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(bytes []byte, err error) *MockEncoder_EncodeToken_Call[T]

func (*MockEncoder_EncodeToken_Call[T]) Run 

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

func (*MockEncoder_EncodeToken_Call[T]) RunAndReturn 

func (_c *MockEncoder_EncodeToken_Call[T]) RunAndReturn(run func(v 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(v interface{}) *MockEncoder_EncodeToken_Call[T]

EncodeToken is a helper method to define mock.On call

  • v

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
  • suffix

func (*MockEncoder_Expecter[T]) GetHeader 

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

GetHeader is a helper method to define mock.On call

  • v

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(s 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(prefix string, suffix 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(bytes []byte) *MockEncoder_GetHeader_Call[T]

func (*MockEncoder_GetHeader_Call[T]) Run 

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

func (*MockEncoder_GetHeader_Call[T]) RunAndReturn 

func (_c *MockEncoder_GetHeader_Call[T]) RunAndReturn(run func(v 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 (_mock *MockRestorer) GetMetrics() *models.Metrics

GetMetrics provides a mock function for the type MockRestorer

func (*MockRestorer) GetStats 

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

GetStats provides a mock function for the type MockRestorer

func (*MockRestorer) Wait 

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

Wait provides a mock function for the type MockRestorer

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

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(metrics *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(restoreStats *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(err 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(ctx 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 (_mock *MockStreamingReader) GetNumber() int64

GetNumber provides a mock function for the type MockStreamingReader

func (*MockStreamingReader) GetSize 

func (_mock *MockStreamingReader) GetSize() int64

GetSize provides a mock function for the type MockStreamingReader

func (*MockStreamingReader) GetType 

func (_mock *MockStreamingReader) GetType() string

GetType provides a mock function for the type MockStreamingReader

func (*MockStreamingReader) ListObjects 

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

ListObjects provides a mock function for the type MockStreamingReader

func (*MockStreamingReader) StreamFile 

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

StreamFile provides a mock function for the type MockStreamingReader

func (*MockStreamingReader) StreamFiles 

func (_mock *MockStreamingReader) StreamFiles(context1 context.Context, fileCh chan<- models.File, errCh chan<- error)

StreamFiles provides a mock function for the type MockStreamingReader

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
  • path

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
  • filename
  • readersCh
  • errorsCh

func (*MockStreamingReader_Expecter) StreamFiles 

func (_e *MockStreamingReader_Expecter) StreamFiles(context1 interface{}, fileCh interface{}, errCh interface{}) *MockStreamingReader_StreamFiles_Call

StreamFiles is a helper method to define mock.On call

  • context1
  • fileCh
  • errCh

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(n 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(n 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(s 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(strings []string, err 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(ctx context.Context, path 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(ctx context.Context, filename string, readersCh chan<- models.File, errorsCh 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(context1 context.Context, fileCh chan<- models.File, errCh chan<- error)) *MockStreamingReader_StreamFiles_Call

func (*MockStreamingReader_StreamFiles_Call) RunAndReturn 

func (_c *MockStreamingReader_StreamFiles_Call) RunAndReturn(run func(context1 context.Context, fileCh chan<- models.File, errCh 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 (_mock *MockWriter) GetType() string

GetType provides a mock function for the type MockWriter

func (*MockWriter) NewWriter 

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

NewWriter provides a mock function for the type MockWriter

func (*MockWriter) Remove 

func (_mock *MockWriter) Remove(ctx context.Context, path string) error

Remove provides a mock function for the type MockWriter

func (*MockWriter) RemoveFiles 

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

RemoveFiles provides a mock function for the type MockWriter

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
  • filename

func (*MockWriter_Expecter) Remove 

func (_e *MockWriter_Expecter) Remove(ctx interface{}, path interface{}) *MockWriter_Remove_Call

Remove is a helper method to define mock.On call

  • ctx
  • path

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

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(s 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(writeCloser io.WriteCloser, err 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(ctx context.Context, filename 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(err 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(ctx context.Context) error) *MockWriter_RemoveFiles_Call

type MockWriter_Remove_Call 

type MockWriter_Remove_Call struct {
	*mock.Call
}

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

func (*MockWriter_Remove_Call) Return 

func (_c *MockWriter_Remove_Call) Return(err error) *MockWriter_Remove_Call

func (*MockWriter_Remove_Call) Run 

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

func (*MockWriter_Remove_Call) RunAndReturn 

func (_c *MockWriter_Remove_Call) RunAndReturn(run func(ctx context.Context, path string) error) *MockWriter_Remove_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 (_mock *MockinfoGetter) GetRackNodes(rackID int) ([]string, error)

GetRackNodes provides a mock function for the type MockinfoGetter

func (*MockinfoGetter) GetRecordCount 

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

GetRecordCount provides a mock function for the type MockinfoGetter

func (*MockinfoGetter) GetService 

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

GetService provides a mock function for the type MockinfoGetter

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

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
  • sets

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

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(strings []string, err 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(rackID 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(v uint64, err 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(namespace string, sets []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(s string, err 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(node 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 (_mock *MockstatsSetterToken) AddSIndexes(v uint32)

AddSIndexes provides a mock function for the type MockstatsSetterToken

func (*MockstatsSetterToken) AddUDFs 

func (_mock *MockstatsSetterToken) AddUDFs(v uint32)

AddUDFs provides a mock function for the type MockstatsSetterToken

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(v uint32)) *MockstatsSetterToken_AddSIndexes_Call

func (*MockstatsSetterToken_AddSIndexes_Call) RunAndReturn 

func (_c *MockstatsSetterToken_AddSIndexes_Call) RunAndReturn(run func(v 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(v uint32)) *MockstatsSetterToken_AddUDFs_Call

func (*MockstatsSetterToken_AddUDFs_Call) RunAndReturn 

func (_c *MockstatsSetterToken_AddUDFs_Call) RunAndReturn(run func(v 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(v interface{}) *MockstatsSetterToken_AddSIndexes_Call

AddSIndexes is a helper method to define mock.On call

  • v

func (*MockstatsSetterToken_Expecter) AddUDFs 

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

AddUDFs is a helper method to define mock.On call

  • v

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.