mocks

func (m *MockAerospikeClient) Abort(txn *aerov8.Txn) (aerov8.AbortStatus, aerov8.Error)

func (m *MockAerospikeClient) BatchDelete(policy *aerov8.BatchPolicy, deletePolicy *aerov8.BatchDeletePolicy, keys []*aerov8.Key) ([]*aerov8.BatchRecord, aerov8.Error)

func (m *MockAerospikeClient) BatchExecute(policy *aerov8.BatchPolicy, udfPolicy *aerov8.BatchUDFPolicy, keys []*aerov8.Key, packageName, functionName string, argsUDF ...aerov8.Value) ([]*aerov8.BatchRecord, aerov8.Error)

func (m *MockAerospikeClient) BatchExists(policy *aerov8.BatchPolicy, keys []*aerov8.Key) ([]bool, aerov8.Error)

func (m *MockAerospikeClient) BatchGet(policy *aerov8.BatchPolicy, keys []*aerov8.Key, binNames ...string) ([]*aerov8.Record, aerov8.Error)

func (m *MockAerospikeClient) BatchGetComplex(policy *aerov8.BatchPolicy, records []*aerov8.BatchRead) aerov8.Error

func (m *MockAerospikeClient) BatchGetHeader(policy *aerov8.BatchPolicy, keys []*aerov8.Key) ([]*aerov8.Record, aerov8.Error)

func (m *MockAerospikeClient) BatchGetOperate(policy *aerov8.BatchPolicy, keys []*aerov8.Key, ops ...*aerov8.Operation) ([]*aerov8.Record, aerov8.Error)

func (m *MockAerospikeClient) BatchOperate(policy *aerov8.BatchPolicy, records []aerov8.BatchRecordIfc) aerov8.Error

func (m *MockAerospikeClient) ChangePassword(policy *aerov8.AdminPolicy, user, password string) aerov8.Error

func (m *MockAerospikeClient) Close()

func (m *MockAerospikeClient) Cluster() *aerov8.Cluster

func (m *MockAerospikeClient) Commit(txn *aerov8.Txn) (aerov8.CommitStatus, aerov8.Error)

func (m *MockAerospikeClient) CreateComplexIndex(policy *aerov8.WritePolicy, namespace, setName, indexName, binName string, indexType aerov8.IndexType, indexCollectionType aerov8.IndexCollectionType, ctx ...*aerov8.CDTContext) (*aerov8.IndexTask, aerov8.Error)

func (m *MockAerospikeClient) CreateIndex(policy *aerov8.WritePolicy, namespace, setName, indexName, binName string, indexType aerov8.IndexType) (*aerov8.IndexTask, aerov8.Error)

func (m *MockAerospikeClient) CreateRole(policy *aerov8.AdminPolicy, roleName string, privileges []aerov8.Privilege, whitelist []string, readQuota, writeQuota uint32) aerov8.Error

func (m *MockAerospikeClient) CreateUser(policy *aerov8.AdminPolicy, user, password string, roles []string) aerov8.Error

func (m *MockAerospikeClient) Delete(policy *aerov8.WritePolicy, key *aerov8.Key) (bool, aerov8.Error)

func (m *MockAerospikeClient) DropIndex(policy *aerov8.WritePolicy, namespace, setName, indexName string) aerov8.Error

func (m *MockAerospikeClient) DropRole(policy *aerov8.AdminPolicy, roleName string) aerov8.Error

func (m *MockAerospikeClient) DropUser(policy *aerov8.AdminPolicy, user string) aerov8.Error

func (m *MockAerospikeClient) Execute(policy *aerov8.WritePolicy, key *aerov8.Key, packageName, functionName string, argsExec ...aerov8.Value) (any, aerov8.Error)

func (m *MockAerospikeClient) ExecuteUDF(policy *aerov8.QueryPolicy, statement *aerov8.Statement, packageName, functionName string, functionArgs ...aerov8.Value) (*aerov8.ExecuteTask, aerov8.Error)

func (m *MockAerospikeClient) ExecuteUDFNode(policy *aerov8.QueryPolicy, node *aerov8.Node, statement *aerov8.Statement, packageName, functionName string, functionArgs ...aerov8.Value) (*aerov8.ExecuteTask, aerov8.Error)

func (m *MockAerospikeClient) Exists(policy *aerov8.BasePolicy, key *aerov8.Key) (bool, aerov8.Error)

func (m *MockAerospikeClient) Get(policy *aerov8.BasePolicy, key *aerov8.Key, binNames ...string) (*aerov8.Record, aerov8.Error)

func (m *MockAerospikeClient) GetDefaultAdminPolicy() *aerov8.AdminPolicy

func (m *MockAerospikeClient) GetDefaultBatchDeletePolicy() *aerov8.BatchDeletePolicy

func (m *MockAerospikeClient) GetDefaultBatchPolicy() *aerov8.BatchPolicy

func (m *MockAerospikeClient) GetDefaultBatchReadPolicy() *aerov8.BatchReadPolicy

func (m *MockAerospikeClient) GetDefaultBatchUDFPolicy() *aerov8.BatchUDFPolicy

func (m *MockAerospikeClient) GetDefaultBatchWritePolicy() *aerov8.BatchWritePolicy

func (m *MockAerospikeClient) GetDefaultInfoPolicy() *aerov8.InfoPolicy

func (m *MockAerospikeClient) GetDefaultPolicy() *aerov8.BasePolicy

func (m *MockAerospikeClient) GetDefaultQueryPolicy() *aerov8.QueryPolicy

func (m *MockAerospikeClient) GetDefaultScanPolicy() *aerov8.ScanPolicy

func (m *MockAerospikeClient) GetDefaultTxnRollPolicy() *aerov8.TxnRollPolicy

func (m *MockAerospikeClient) GetDefaultTxnVerifyPolicy() *aerov8.TxnVerifyPolicy

func (m *MockAerospikeClient) GetDefaultWritePolicy() *aerov8.WritePolicy

func (m *MockAerospikeClient) GetHeader(policy *aerov8.BasePolicy, key *aerov8.Key) (*aerov8.Record, aerov8.Error)

func (m *MockAerospikeClient) GetNodeNames() []string

func (m *MockAerospikeClient) GetNodes() []*aerov8.Node

func (m *MockAerospikeClient) GrantPrivileges(policy *aerov8.AdminPolicy, roleName string, privileges []aerov8.Privilege) aerov8.Error

func (m *MockAerospikeClient) GrantRoles(policy *aerov8.AdminPolicy, user string, roles []string) aerov8.Error

func (m *MockAerospikeClient) IsConnected() bool

func (m *MockAerospikeClient) ListUDF(policy *aerov8.BasePolicy) ([]*aerov8.UDF, aerov8.Error)

func (m *MockAerospikeClient) Operate(policy *aerov8.WritePolicy, key *aerov8.Key, operations ...*aerov8.Operation) (*aerov8.Record, aerov8.Error)

func (m *MockAerospikeClient) Put(policy *aerov8.WritePolicy, key *aerov8.Key, binMap aerov8.BinMap) aerov8.Error

func (m *MockAerospikeClient) PutBins(policy *aerov8.WritePolicy, key *aerov8.Key, bins ...*aerov8.Bin) aerov8.Error

func (m *MockAerospikeClient) Query(policy *aerov8.QueryPolicy, statement *aerov8.Statement) (*aerov8.Recordset, aerov8.Error)

func (m *MockAerospikeClient) QueryExecute(policy *aerov8.QueryPolicy, writePolicy *aerov8.WritePolicy, statement *aerov8.Statement, ops ...*aerov8.Operation) (*aerov8.ExecuteTask, aerov8.Error)

func (m *MockAerospikeClient) QueryNode(policy *aerov8.QueryPolicy, node *aerov8.Node, statement *aerov8.Statement) (*aerov8.Recordset, aerov8.Error)

func (m *MockAerospikeClient) QueryPartitions(policy *aerov8.QueryPolicy, statement *aerov8.Statement, partitionFilter *aerov8.PartitionFilter) (*aerov8.Recordset, aerov8.Error)

func (m *MockAerospikeClient) QueryRole(policy *aerov8.AdminPolicy, role string) (*aerov8.Role, aerov8.Error)

func (m *MockAerospikeClient) QueryRoles(policy *aerov8.AdminPolicy) ([]*aerov8.Role, aerov8.Error)

func (m *MockAerospikeClient) QueryUser(policy *aerov8.AdminPolicy, user string) (*aerov8.UserRoles, aerov8.Error)

func (m *MockAerospikeClient) QueryUsers(policy *aerov8.AdminPolicy) ([]*aerov8.UserRoles, aerov8.Error)

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

func (m *MockAerospikeClient) RegisterUDFFromFile(policy *aerov8.WritePolicy, clientPath, serverPath string, language aerov8.Language) (*aerov8.RegisterTask, aerov8.Error)

func (m *MockAerospikeClient) RemoveUDF(policy *aerov8.WritePolicy, udfName string) (*aerov8.RemoveTask, aerov8.Error)

func (m *MockAerospikeClient) RevokePrivileges(policy *aerov8.AdminPolicy, roleName string, privileges []aerov8.Privilege) aerov8.Error

func (m *MockAerospikeClient) RevokeRoles(policy *aerov8.AdminPolicy, user string, roles []string) aerov8.Error

func (m *MockAerospikeClient) ScanAll(policy *aerov8.ScanPolicy, namespace, setName string, binNames ...string) (*aerov8.Recordset, aerov8.Error)

func (m *MockAerospikeClient) ScanNode(policy *aerov8.ScanPolicy, node *aerov8.Node, namespace, setName string, binNames ...string) (*aerov8.Recordset, aerov8.Error)

func (m *MockAerospikeClient) ScanPartitions(policy *aerov8.ScanPolicy, partitionFilter *aerov8.PartitionFilter, namespace, setName string, binNames ...string) (*aerov8.Recordset, aerov8.Error)

func (m *MockAerospikeClient) SetDefaultAdminPolicy(policy *aerov8.AdminPolicy)

func (m *MockAerospikeClient) SetDefaultBatchDeletePolicy(policy *aerov8.BatchDeletePolicy)

func (m *MockAerospikeClient) SetDefaultBatchPolicy(policy *aerov8.BatchPolicy)

func (m *MockAerospikeClient) SetDefaultBatchReadPolicy(policy *aerov8.BatchReadPolicy)

func (m *MockAerospikeClient) SetDefaultBatchUDFPolicy(policy *aerov8.BatchUDFPolicy)

func (m *MockAerospikeClient) SetDefaultBatchWritePolicy(policy *aerov8.BatchWritePolicy)

func (m *MockAerospikeClient) SetDefaultInfoPolicy(policy *aerov8.InfoPolicy)

func (m *MockAerospikeClient) SetDefaultPolicy(policy *aerov8.BasePolicy)

func (m *MockAerospikeClient) SetDefaultQueryPolicy(policy *aerov8.QueryPolicy)

func (m *MockAerospikeClient) SetDefaultScanPolicy(policy *aerov8.ScanPolicy)

func (m *MockAerospikeClient) SetDefaultTxnRollPolicy(policy *aerov8.TxnRollPolicy)

func (m *MockAerospikeClient) SetDefaultTxnVerifyPolicy(policy *aerov8.TxnVerifyPolicy)

func (m *MockAerospikeClient) SetDefaultWritePolicy(policy *aerov8.WritePolicy)

func (m *MockAerospikeClient) SetQuotas(policy *aerov8.AdminPolicy, roleName string, readQuota, writeQuota uint32) aerov8.Error

func (m *MockAerospikeClient) SetWhitelist(policy *aerov8.AdminPolicy, roleName string, whitelist []string) aerov8.Error

func (m *MockAerospikeClient) SetXDRFilter(policy *aerov8.InfoPolicy, datacenter, namespace string, filter *aerov8.Expression) aerov8.Error

func (m *MockAerospikeClient) Stats() (map[string]any, aerov8.Error)

func (m *MockAerospikeClient) String() string

func (m *MockAerospikeClient) Touch(policy *aerov8.WritePolicy, key *aerov8.Key) aerov8.Error

func (m *MockAerospikeClient) WarmUp(count int) (int, aerov8.Error)

func (m *MockElasticSearchHelper) Bulk(ctx context.Context, cluster string, operations []elasticsearch.BulkOperation) (elasticsearch.BulkResponse, error)

func (m *MockElasticSearchHelper) Count(ctx context.Context, cluster string, index string) (elasticsearch.CountResponse, error)

func (m *MockElasticSearchHelper) CountByQuery(ctx context.Context, cluster string, index string, query elasticsearch.Query) (elasticsearch.CountResponse, error)

func (m *MockElasticSearchHelper) Delete(ctx context.Context, cluster string, index string, docID string) (elasticsearch.DeleteResponse, error)

func (m *MockElasticSearchHelper) DeleteByQuery(ctx context.Context, cluster string, index string, query interface{}) (elasticsearch.DeleteByQueryResponse, error)

func (m *MockElasticSearchHelper) IncrementalSearch(ctx context.Context, cluster string, index string, searchQuery elasticsearch.SearchQuery) (elasticsearch.SearchResponse, error)

func (m *MockElasticSearchHelper) Index(ctx context.Context, cluster string, index string, docID string, document interface{}) (elasticsearch.IndexResponse, error)

func (m *MockElasticSearchHelper) RawCountQuery(ctx context.Context, cluster, index, query string) (elasticsearch.CountResponse, error)

func (m *MockElasticSearchHelper) RawSearchQuery(ctx context.Context, cluster, index, query string) (elasticsearch.SearchResponse, error)

func (m *MockElasticSearchHelper) Search(ctx context.Context, cluster string, index string, query elasticsearch.Query) (elasticsearch.SearchResponse, error)

func (m *MockElasticSearchHelper) SearchByDocId(ctx context.Context, cluster string, index string, docId string) (elasticsearch.SearchByDocIdResponse, error)

func (m *MockElasticSearchHelper) Update(ctx context.Context, cluster string, index string, docID string, document interface{}) (elasticsearch.UpdateResponse, error)

func (m *MockElasticSearchHelper) UpdateByQuery(ctx context.Context, cluster string, index string, query interface{}) (elasticsearch.UpdateByQueryResponse, error)

func (m *MockMemcachedClient) Add(item *memcache.Item) error

func (m *MockMemcachedClient) Append(item *memcache.Item) error

func (m *MockMemcachedClient) Close() error

func (m *MockMemcachedClient) CompareAndSwap(item *memcache.Item) error

func (m *MockMemcachedClient) Decrement(key string, delta uint64) (uint64, error)

func (m *MockMemcachedClient) Delete(key string) error

func (m *MockMemcachedClient) DeleteAll() error

func (m *MockMemcachedClient) FlushAll() error

func (m *MockMemcachedClient) Get(key string) (*memcache.Item, error)

func (m *MockMemcachedClient) GetAndTouch(key string, expiration int32) (*memcache.Item, error)

func (m *MockMemcachedClient) GetMulti(keys []string) (map[string]*memcache.Item, error)

func (m *MockMemcachedClient) Increment(key string, delta uint64) (uint64, error)

func (m *MockMemcachedClient) Ping() error

func (m *MockMemcachedClient) Prepend(item *memcache.Item) error

func (m *MockMemcachedClient) Replace(item *memcache.Item) error

func (m *MockMemcachedClient) Set(item *memcache.Item) error

func (m *MockMemcachedClient) Touch(key string, seconds int32) error

func (m *MockRedisClient) Append(ctx context.Context, key, value string) *redisv9.IntCmd

func (m *MockRedisClient) Close() error

func (m *MockRedisClient) Decr(ctx context.Context, key string) *redisv9.IntCmd

func (m *MockRedisClient) DecrBy(ctx context.Context, key string, value int64) *redisv9.IntCmd

func (m *MockRedisClient) Del(ctx context.Context, keys ...string) *redisv9.IntCmd

func (m *MockRedisClient) Eval(ctx context.Context, script string, keys []string, args ...interface{}) *redisv9.Cmd

func (m *MockRedisClient) Exists(ctx context.Context, keys ...string) *redisv9.IntCmd

func (m *MockRedisClient) Expire(ctx context.Context, key string, expiration time.Duration) *redisv9.BoolCmd

func (m *MockRedisClient) Get(ctx context.Context, key string) *redisv9.StringCmd

func (m *MockRedisClient) GetSet(ctx context.Context, key string, value interface{}) *redisv9.StringCmd

func (m *MockRedisClient) HDel(ctx context.Context, key string, fields ...string) *redisv9.IntCmd

func (m *MockRedisClient) HExists(ctx context.Context, key, field string) *redisv9.BoolCmd

func (m *MockRedisClient) HGet(ctx context.Context, key, field string) *redisv9.StringCmd

func (m *MockRedisClient) HGetAll(ctx context.Context, key string) *redisv9.MapStringStringCmd

func (m *MockRedisClient) HIncrBy(ctx context.Context, key, field string, incr int64) *redisv9.IntCmd

func (m *MockRedisClient) HLen(ctx context.Context, key string) *redisv9.IntCmd

func (m *MockRedisClient) HMGet(ctx context.Context, key string, fields ...string) *redisv9.SliceCmd

func (m *MockRedisClient) HMSet(ctx context.Context, key string, values ...interface{}) *redisv9.BoolCmd

func (m *MockRedisClient) HSet(ctx context.Context, key string, values ...interface{}) *redisv9.IntCmd

func (m *MockRedisClient) Incr(ctx context.Context, key string) *redisv9.IntCmd

func (m *MockRedisClient) IncrBy(ctx context.Context, key string, value int64) *redisv9.IntCmd

func (m *MockRedisClient) Keys(ctx context.Context, pattern string) *redisv9.StringSliceCmd

func (m *MockRedisClient) LLen(ctx context.Context, key string) *redisv9.IntCmd

func (m *MockRedisClient) LPop(ctx context.Context, key string) *redisv9.StringCmd

func (m *MockRedisClient) LPush(ctx context.Context, key string, values ...interface{}) *redisv9.IntCmd

func (m *MockRedisClient) LRange(ctx context.Context, key string, start, stop int64) *redisv9.StringSliceCmd

func (m *MockRedisClient) LRem(ctx context.Context, key string, count int64, value interface{}) *redisv9.IntCmd

func (m *MockRedisClient) LTrim(ctx context.Context, key string, start, stop int64) *redisv9.StatusCmd

func (m *MockRedisClient) MGet(ctx context.Context, keys ...string) *redisv9.SliceCmd

func (m *MockRedisClient) MSet(ctx context.Context, values ...interface{}) *redisv9.StatusCmd

func (m *MockRedisClient) Persist(ctx context.Context, key string) *redisv9.BoolCmd

func (m *MockRedisClient) Ping(ctx context.Context) *redisv9.StatusCmd

func (m *MockRedisClient) Publish(ctx context.Context, channel string, message interface{}) *redisv9.IntCmd

func (m *MockRedisClient) RPop(ctx context.Context, key string) *redisv9.StringCmd

func (m *MockRedisClient) RPush(ctx context.Context, key string, values ...interface{}) *redisv9.IntCmd

func (m *MockRedisClient) SAdd(ctx context.Context, key string, members ...interface{}) *redisv9.IntCmd

func (m *MockRedisClient) SIsMember(ctx context.Context, key string, member interface{}) *redisv9.BoolCmd

func (m *MockRedisClient) SMembers(ctx context.Context, key string) *redisv9.StringSliceCmd

func (m *MockRedisClient) SRem(ctx context.Context, key string, members ...interface{}) *redisv9.IntCmd

func (m *MockRedisClient) Set(ctx context.Context, key string, value interface{}, expiration time.Duration) *redisv9.StatusCmd

func (m *MockRedisClient) SetNX(ctx context.Context, key string, value interface{}, expiration time.Duration) *redisv9.BoolCmd

func (m *MockRedisClient) StrLen(ctx context.Context, key string) *redisv9.IntCmd

func (m *MockRedisClient) Subscribe(ctx context.Context, channels ...string) *redisv9.PubSub

func (m *MockRedisClient) TTL(ctx context.Context, key string) *redisv9.DurationCmd

func (m *MockRedisClient) ZAdd(ctx context.Context, key string, members ...redisv9.Z) *redisv9.IntCmd

func (m *MockRedisClient) ZRange(ctx context.Context, key string, start, stop int64) *redisv9.StringSliceCmd

func (m *MockRedisClient) ZRem(ctx context.Context, key string, members ...interface{}) *redisv9.IntCmd

func (m *MockRedisClient) ZRemRangeByScore(ctx context.Context, key, min, max string) *redisv9.IntCmd