mocks

package
v0.3.1 Latest Latest
Warning

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

 Go to latest Published: Dec 23, 2024 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) 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 added in v0.2.0 

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) 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 added in v0.2.0 

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_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 added in v0.2.0 

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 added in v0.2.0 

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

func (*MockAerospikeClient_ScanNode_Call) Run added in v0.2.0 

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 added in v0.2.0 

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 struct {
	mock.Mock
}

MockDecoder is an autogenerated mock type for the Decoder type

func NewMockDecoder 

func NewMockDecoder(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockDecoder

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) EXPECT 

func (_m *MockDecoder) EXPECT() *MockDecoder_Expecter

func (*MockDecoder) NextToken 

func (_m *MockDecoder) NextToken() (*models.Token, error)

NextToken provides a mock function with given fields:

type MockDecoder_Expecter 

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

func (*MockDecoder_Expecter) NextToken 

func (_e *MockDecoder_Expecter) NextToken() *MockDecoder_NextToken_Call

NextToken is a helper method to define mock.On call

type MockDecoder_NextToken_Call 

type MockDecoder_NextToken_Call 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) Return 

func (_c *MockDecoder_NextToken_Call) Return(_a0 *models.Token, _a1 error) *MockDecoder_NextToken_Call

func (*MockDecoder_NextToken_Call) Run 

func (_c *MockDecoder_NextToken_Call) Run(run func()) *MockDecoder_NextToken_Call

func (*MockDecoder_NextToken_Call) RunAndReturn 

func (_c *MockDecoder_NextToken_Call) RunAndReturn(run func() (*models.Token, error)) *MockDecoder_NextToken_Call

type MockEncoder 

type MockEncoder struct {
	mock.Mock
}

MockEncoder is an autogenerated mock type for the Encoder type

func NewMockEncoder 

func NewMockEncoder(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockEncoder

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) EXPECT 

func (_m *MockEncoder) EXPECT() *MockEncoder_Expecter

func (*MockEncoder) EncodeToken 

func (_m *MockEncoder) EncodeToken(_a0 *models.Token) ([]byte, error)

EncodeToken provides a mock function with given fields: _a0

func (*MockEncoder) GenerateFilename 

func (_m *MockEncoder) GenerateFilename(prefix string, suffix string) string

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

func (*MockEncoder) GetHeader 

func (_m *MockEncoder) GetHeader() []byte

GetHeader provides a mock function with given fields:

type MockEncoder_EncodeToken_Call 

type MockEncoder_EncodeToken_Call 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) Return 

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

func (*MockEncoder_EncodeToken_Call) Run 

func (_c *MockEncoder_EncodeToken_Call) Run(run func(_a0 *models.Token)) *MockEncoder_EncodeToken_Call

func (*MockEncoder_EncodeToken_Call) RunAndReturn 

func (_c *MockEncoder_EncodeToken_Call) RunAndReturn(run func(*models.Token) ([]byte, error)) *MockEncoder_EncodeToken_Call

type MockEncoder_Expecter 

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

func (*MockEncoder_Expecter) EncodeToken 

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

EncodeToken is a helper method to define mock.On call

  • _a0 *models.Token

func (*MockEncoder_Expecter) GenerateFilename 

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

GenerateFilename is a helper method to define mock.On call

  • prefix string
  • suffix string

func (*MockEncoder_Expecter) GetHeader 

func (_e *MockEncoder_Expecter) GetHeader() *MockEncoder_GetHeader_Call

GetHeader is a helper method to define mock.On call

type MockEncoder_GenerateFilename_Call 

type MockEncoder_GenerateFilename_Call 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) Return 

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

func (*MockEncoder_GenerateFilename_Call) Run 

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

func (*MockEncoder_GenerateFilename_Call) RunAndReturn 

func (_c *MockEncoder_GenerateFilename_Call) RunAndReturn(run func(string, string) string) *MockEncoder_GenerateFilename_Call

type MockEncoder_GetHeader_Call 

type MockEncoder_GetHeader_Call 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) Return 

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

func (*MockEncoder_GetHeader_Call) Run 

func (_c *MockEncoder_GetHeader_Call) Run(run func()) *MockEncoder_GetHeader_Call

func (*MockEncoder_GetHeader_Call) RunAndReturn 

func (_c *MockEncoder_GetHeader_Call) RunAndReturn(run func() []byte) *MockEncoder_GetHeader_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) GetType 

func (_m *MockStreamingReader) GetType() string

GetType provides a mock function with given fields:

func (*MockStreamingReader) StreamFile added in v0.2.0 

func (_m *MockStreamingReader) StreamFile(ctx context.Context, filename string, readersCh chan<- io.ReadCloser, 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<- io.ReadCloser, _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) GetType 

func (_e *MockStreamingReader_Expecter) GetType() *MockStreamingReader_GetType_Call

GetType is a helper method to define mock.On call

func (*MockStreamingReader_Expecter) StreamFile added in v0.2.0 

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<- io.ReadCloser
  • 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<- io.ReadCloser
  • _a2 chan<- error

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_StreamFile_Call added in v0.2.0 

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 added in v0.2.0 

func (_c *MockStreamingReader_StreamFile_Call) Return() *MockStreamingReader_StreamFile_Call

func (*MockStreamingReader_StreamFile_Call) Run added in v0.2.0 

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

func (*MockStreamingReader_StreamFile_Call) RunAndReturn added in v0.2.0 

func (_c *MockStreamingReader_StreamFile_Call) RunAndReturn(run func(context.Context, string, chan<- io.ReadCloser, 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<- io.ReadCloser, _a2 chan<- error)) *MockStreamingReader_StreamFiles_Call

func (*MockStreamingReader_StreamFiles_Call) RunAndReturn 

func (_c *MockStreamingReader_StreamFiles_Call) RunAndReturn(run func(context.Context, chan<- io.ReadCloser, 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 added in v0.2.0 

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 added in v0.2.0 

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 added in v0.2.0 

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 added in v0.2.0 

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

func (*MockWriter_RemoveFiles_Call) Run added in v0.2.0 

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

func (*MockWriter_RemoveFiles_Call) RunAndReturn added in v0.2.0 

func (_c *MockWriter_RemoveFiles_Call) RunAndReturn(run func(context.Context) error) *MockWriter_RemoveFiles_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.