mocks

Documentation

Index

• type ClusterInfoProvider
  • func (_m *ClusterInfoProvider) AmIWriter(writerNodes []uint64) bool
  • func (_m *ClusterInfoProvider) FindOwnerForKey(key []byte) uint64
  • func (_m *ClusterInfoProvider) FindOwnerForPartition(partitionID int) uint64
  • func (_m *ClusterInfoProvider) FindPartitionForKey(key []byte) int
  • func (_m *ClusterInfoProvider) GetAddressFor(nodeID uint64) string
  • func (_m *ClusterInfoProvider) IsLocal(key []byte) bool
  • func (_m *ClusterInfoProvider) MyPartitions() []int
• type ConnectionCache
  • func (_m *ConnectionCache) Close()
  • func (_m *ConnectionCache) GetLowIsolationReadClient(nodeID uint64) (pb.LowIsolationReadClient, error)
  • func (_m *ConnectionCache) GetRaftTransportClient(nodeID uint64) (pb.RaftTransportClient, error)
  • func (_m *ConnectionCache) GetRemoteReadClient(nodeID uint64) (pb.RemoteReadClient, error)
• type DataStoreTxn
  • func (_m *DataStoreTxn) Commit() error
  • func (_m *DataStoreTxn) Get(key []byte) []byte
  • func (_m *DataStoreTxn) Rollback() error
  • func (_m *DataStoreTxn) Set(key []byte, value []byte) error
• type DataStoreTxnProvider
  • func (_m *DataStoreTxnProvider) Close()
  • func (_m *DataStoreTxnProvider) Delete()
  • func (_m *DataStoreTxnProvider) Snapshot(w io.Writer) error
  • func (_m *DataStoreTxnProvider) StartTxn(writable bool) (util.DataStoreTxn, error)
• type PartialSnapshotHandler
  • func (_m *PartialSnapshotHandler) Consume(partitionID int, snapshotData []byte) error
  • func (_m *PartialSnapshotHandler) Provide(partitionID int, lastSnapshot raftpb.Snapshot, ...) ([]byte, error)
• type PartitionedDataStore
  • func (_m *PartitionedDataStore) Close()
  • func (_m *PartitionedDataStore) CreatePartition(partitionID int) (util.DataStoreTxnProvider, error)
  • func (_m *PartitionedDataStore) GetPartition(partitionID int) (util.DataStoreTxnProvider, error)
  • func (_m *PartitionedDataStore) Snapshot(w io.Writer) error
• type RemoteReadClient
  • func (_m *RemoteReadClient) RemoteRead(ctx context.Context, in *pb.RemoteReadRequest, opts ...grpc.CallOption) (*pb.RemoteReadResponse, error)
• type SnapshotHandler
  • func (_m *SnapshotHandler) Consume(snapshotData []byte) error
  • func (_m *SnapshotHandler) Provide(lastSnapshot raftpb.Snapshot, entriesAppliedSinceLastSnapshot []raftpb.Entry) ([]byte, error)

Types

type ClusterInfoProvider

type ClusterInfoProvider struct {
	mock.Mock
}

ClusterInfoProvider is an autogenerated mock type for the ClusterInfoProvider type

func (*ClusterInfoProvider) AmIWriter

func (_m *ClusterInfoProvider) AmIWriter(writerNodes []uint64) bool

AmIWriter provides a mock function with given fields: writerNodes

func (*ClusterInfoProvider) FindOwnerForKey

func (_m *ClusterInfoProvider) FindOwnerForKey(key []byte) uint64

FindOwnerForKey provides a mock function with given fields: key

func (*ClusterInfoProvider) FindOwnerForPartition

func (_m *ClusterInfoProvider) FindOwnerForPartition(partitionID int) uint64

FindOwnerForPartition provides a mock function with given fields: partitionID

func (*ClusterInfoProvider) FindPartitionForKey

func (_m *ClusterInfoProvider) FindPartitionForKey(key []byte) int

FindPartitionForKey provides a mock function with given fields: key

func (*ClusterInfoProvider) GetAddressFor

func (_m *ClusterInfoProvider) GetAddressFor(nodeID uint64) string

GetAddressFor provides a mock function with given fields: nodeID

func (*ClusterInfoProvider) IsLocal

func (_m *ClusterInfoProvider) IsLocal(key []byte) bool

IsLocal provides a mock function with given fields: key

func (*ClusterInfoProvider) MyPartitions

func (_m *ClusterInfoProvider) MyPartitions() []int

MyPartitions provides a mock function with given fields:

type ConnectionCache

type ConnectionCache struct {
	mock.Mock
}

ConnectionCache is an autogenerated mock type for the ConnectionCache type

func (*ConnectionCache) Close

func (_m *ConnectionCache) Close()

Close provides a mock function with given fields:

func (*ConnectionCache) GetLowIsolationReadClient

func (_m *ConnectionCache) GetLowIsolationReadClient(nodeID uint64) (pb.LowIsolationReadClient, error)

GetLowIsolationReadClient provides a mock function with given fields: nodeID

func (*ConnectionCache) GetRaftTransportClient

func (_m *ConnectionCache) GetRaftTransportClient(nodeID uint64) (pb.RaftTransportClient, error)

GetRaftTransportClient provides a mock function with given fields: nodeID

func (*ConnectionCache) GetRemoteReadClient

func (_m *ConnectionCache) GetRemoteReadClient(nodeID uint64) (pb.RemoteReadClient, error)

GetRemoteReadClient provides a mock function with given fields: nodeID

type DataStoreTxn

type DataStoreTxn struct {
	mock.Mock
}

DataStoreTxn is an autogenerated mock type for the DataStoreTxn type

func (*DataStoreTxn) Commit

func (_m *DataStoreTxn) Commit() error

Commit provides a mock function with given fields:

func (*DataStoreTxn) Get

func (_m *DataStoreTxn) Get(key []byte) []byte

Get provides a mock function with given fields: key

func (*DataStoreTxn) Rollback

func (_m *DataStoreTxn) Rollback() error

Rollback provides a mock function with given fields:

func (*DataStoreTxn) Set

func (_m *DataStoreTxn) Set(key []byte, value []byte) error

Set provides a mock function with given fields: key, value

type DataStoreTxnProvider

type DataStoreTxnProvider struct {
	mock.Mock
}

DataStoreTxnProvider is an autogenerated mock type for the DataStoreTxnProvider type

func (*DataStoreTxnProvider) Close

func (_m *DataStoreTxnProvider) Close()

Close provides a mock function with given fields:

func (*DataStoreTxnProvider) Delete

func (_m *DataStoreTxnProvider) Delete()

Delete provides a mock function with given fields:

func (*DataStoreTxnProvider) Snapshot

func (_m *DataStoreTxnProvider) Snapshot(w io.Writer) error

Snapshot provides a mock function with given fields: w

func (*DataStoreTxnProvider) StartTxn

func (_m *DataStoreTxnProvider) StartTxn(writable bool) (util.DataStoreTxn, error)

StartTxn provides a mock function with given fields: writable

type PartialSnapshotHandler

type PartialSnapshotHandler struct {
	mock.Mock
}

PartialSnapshotHandler is an autogenerated mock type for the PartialSnapshotHandler type

func (*PartialSnapshotHandler) Consume

func (_m *PartialSnapshotHandler) Consume(partitionID int, snapshotData []byte) error

Consume provides a mock function with given fields: partitionID, snapshotData

func (*PartialSnapshotHandler) Provide

func (_m *PartialSnapshotHandler) Provide(partitionID int, lastSnapshot raftpb.Snapshot, entriesAppliedSinceLastSnapshot []raftpb.Entry) ([]byte, error)

Provide provides a mock function with given fields: partitionID, lastSnapshot, entriesAppliedSinceLastSnapshot

type PartitionedDataStore

type PartitionedDataStore struct {
	mock.Mock
}

PartitionedDataStore is an autogenerated mock type for the PartitionedDataStore type

func (*PartitionedDataStore) Close

func (_m *PartitionedDataStore) Close()

Close provides a mock function with given fields:

func (*PartitionedDataStore) CreatePartition

func (_m *PartitionedDataStore) CreatePartition(partitionID int) (util.DataStoreTxnProvider, error)

CreatePartition provides a mock function with given fields: partitionID

func (*PartitionedDataStore) GetPartition

func (_m *PartitionedDataStore) GetPartition(partitionID int) (util.DataStoreTxnProvider, error)

GetPartition provides a mock function with given fields: partitionID

func (*PartitionedDataStore) Snapshot

func (_m *PartitionedDataStore) Snapshot(w io.Writer) error

Snapshot provides a mock function with given fields: w

type RemoteReadClient

type RemoteReadClient struct {
	mock.Mock
}

RemoteReadClient is an autogenerated mock type for the RemoteReadClient type

func (*RemoteReadClient) RemoteRead

func (_m *RemoteReadClient) RemoteRead(ctx context.Context, in *pb.RemoteReadRequest, opts ...grpc.CallOption) (*pb.RemoteReadResponse, error)

RemoteRead provides a mock function with given fields: ctx, in, opts

type SnapshotHandler

type SnapshotHandler struct {
	mock.Mock
}

SnapshotHandler is an autogenerated mock type for the SnapshotHandler type

func (*SnapshotHandler) Consume

func (_m *SnapshotHandler) Consume(snapshotData []byte) error

Consume provides a mock function with given fields: snapshotData

func (*SnapshotHandler) Provide

func (_m *SnapshotHandler) Provide(lastSnapshot raftpb.Snapshot, entriesAppliedSinceLastSnapshot []raftpb.Entry) ([]byte, error)

Provide provides a mock function with given fields: lastSnapshot, entriesAppliedSinceLastSnapshot