mock_store

Documentation

Overview

Package mock_store is a generated GoMock package.

Index

• type MockElection
  • func NewMockElection(ctrl *gomock.Controller) *MockElection
  • func (m *MockElection) EXPECT() *MockElectionMockRecorder
  • func (m *MockElection) Leader() (string, error)
  • func (m *MockElection) RunForElection() (<-chan bool, <-chan error)
  • func (m *MockElection) Stop()
• type MockElectionMockRecorder
  • func (mr *MockElectionMockRecorder) Leader() *gomock.Call
  • func (mr *MockElectionMockRecorder) RunForElection() *gomock.Call
  • func (mr *MockElectionMockRecorder) Stop() *gomock.Call
• type MockStore
  • func NewMockStore(ctrl *gomock.Controller) *MockStore
  • func (m *MockStore) AtomicPutClusterData(ctx context.Context, cd *cluster.ClusterData, previous *store.KVPair) (*store.KVPair, error)
  • func (m *MockStore) EXPECT() *MockStoreMockRecorder
  • func (m *MockStore) GetClusterData(ctx context.Context) (*cluster.ClusterData, *store.KVPair, error)
  • func (m *MockStore) GetKeepersInfo(ctx context.Context) (cluster.KeepersInfo, error)
  • func (m *MockStore) GetProxiesInfo(ctx context.Context) (cluster.ProxiesInfo, error)
  • func (m *MockStore) GetSentinelsInfo(ctx context.Context) (cluster.SentinelsInfo, error)
  • func (m *MockStore) PutClusterData(ctx context.Context, cd *cluster.ClusterData) error
  • func (m *MockStore) SetKeeperInfo(ctx context.Context, id string, ms *cluster.KeeperInfo, ttl time.Duration) error
  • func (m *MockStore) SetProxyInfo(ctx context.Context, pi *cluster.ProxyInfo, ttl time.Duration) error
  • func (m *MockStore) SetSentinelInfo(ctx context.Context, si *cluster.SentinelInfo, ttl time.Duration) error
• type MockStoreMockRecorder
  • func (mr *MockStoreMockRecorder) AtomicPutClusterData(ctx, cd, previous interface{}) *gomock.Call
  • func (mr *MockStoreMockRecorder) GetClusterData(ctx interface{}) *gomock.Call
  • func (mr *MockStoreMockRecorder) GetKeepersInfo(ctx interface{}) *gomock.Call
  • func (mr *MockStoreMockRecorder) GetProxiesInfo(ctx interface{}) *gomock.Call
  • func (mr *MockStoreMockRecorder) GetSentinelsInfo(ctx interface{}) *gomock.Call
  • func (mr *MockStoreMockRecorder) PutClusterData(ctx, cd interface{}) *gomock.Call
  • func (mr *MockStoreMockRecorder) SetKeeperInfo(ctx, id, ms, ttl interface{}) *gomock.Call
  • func (mr *MockStoreMockRecorder) SetProxyInfo(ctx, pi, ttl interface{}) *gomock.Call
  • func (mr *MockStoreMockRecorder) SetSentinelInfo(ctx, si, ttl interface{}) *gomock.Call

Types

type MockElection

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

MockElection is a mock of Election interface

func NewMockElection

func NewMockElection(ctrl *gomock.Controller) *MockElection

NewMockElection creates a new mock instance

func (*MockElection) EXPECT

func (m *MockElection) EXPECT() *MockElectionMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockElection) Leader

func (m *MockElection) Leader() (string, error)

Leader mocks base method

func (*MockElection) RunForElection

func (m *MockElection) RunForElection() (<-chan bool, <-chan error)

RunForElection mocks base method

func (*MockElection) Stop

func (m *MockElection) Stop()

Stop mocks base method

type MockElectionMockRecorder

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

MockElectionMockRecorder is the mock recorder for MockElection

func (*MockElectionMockRecorder) Leader

func (mr *MockElectionMockRecorder) Leader() *gomock.Call

Leader indicates an expected call of Leader

func (*MockElectionMockRecorder) RunForElection

func (mr *MockElectionMockRecorder) RunForElection() *gomock.Call

RunForElection indicates an expected call of RunForElection

func (*MockElectionMockRecorder) Stop

func (mr *MockElectionMockRecorder) Stop() *gomock.Call

Stop indicates an expected call of Stop

type MockStore

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

MockStore is a mock of Store interface

func NewMockStore

func NewMockStore(ctrl *gomock.Controller) *MockStore

NewMockStore creates a new mock instance

func (*MockStore) AtomicPutClusterData

func (m *MockStore) AtomicPutClusterData(ctx context.Context, cd *cluster.ClusterData, previous *store.KVPair) (*store.KVPair, error)

AtomicPutClusterData mocks base method

func (*MockStore) EXPECT

func (m *MockStore) EXPECT() *MockStoreMockRecorder

EXPECT returns an object that allows the caller to indicate expected use

func (*MockStore) GetClusterData

func (m *MockStore) GetClusterData(ctx context.Context) (*cluster.ClusterData, *store.KVPair, error)

GetClusterData mocks base method

func (*MockStore) GetKeepersInfo

func (m *MockStore) GetKeepersInfo(ctx context.Context) (cluster.KeepersInfo, error)

GetKeepersInfo mocks base method

func (*MockStore) GetProxiesInfo

func (m *MockStore) GetProxiesInfo(ctx context.Context) (cluster.ProxiesInfo, error)

GetProxiesInfo mocks base method

func (*MockStore) GetSentinelsInfo

func (m *MockStore) GetSentinelsInfo(ctx context.Context) (cluster.SentinelsInfo, error)

GetSentinelsInfo mocks base method

func (*MockStore) PutClusterData

func (m *MockStore) PutClusterData(ctx context.Context, cd *cluster.ClusterData) error

PutClusterData mocks base method

func (*MockStore) SetKeeperInfo

func (m *MockStore) SetKeeperInfo(ctx context.Context, id string, ms *cluster.KeeperInfo, ttl time.Duration) error

SetKeeperInfo mocks base method

func (*MockStore) SetProxyInfo

func (m *MockStore) SetProxyInfo(ctx context.Context, pi *cluster.ProxyInfo, ttl time.Duration) error

SetProxyInfo mocks base method

func (*MockStore) SetSentinelInfo

func (m *MockStore) SetSentinelInfo(ctx context.Context, si *cluster.SentinelInfo, ttl time.Duration) error

SetSentinelInfo mocks base method

type MockStoreMockRecorder

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

MockStoreMockRecorder is the mock recorder for MockStore

func (*MockStoreMockRecorder) AtomicPutClusterData

func (mr *MockStoreMockRecorder) AtomicPutClusterData(ctx, cd, previous interface{}) *gomock.Call

AtomicPutClusterData indicates an expected call of AtomicPutClusterData

func (*MockStoreMockRecorder) GetClusterData

func (mr *MockStoreMockRecorder) GetClusterData(ctx interface{}) *gomock.Call

GetClusterData indicates an expected call of GetClusterData

func (*MockStoreMockRecorder) GetKeepersInfo

func (mr *MockStoreMockRecorder) GetKeepersInfo(ctx interface{}) *gomock.Call

GetKeepersInfo indicates an expected call of GetKeepersInfo

func (*MockStoreMockRecorder) GetProxiesInfo

func (mr *MockStoreMockRecorder) GetProxiesInfo(ctx interface{}) *gomock.Call

GetProxiesInfo indicates an expected call of GetProxiesInfo

func (*MockStoreMockRecorder) GetSentinelsInfo

func (mr *MockStoreMockRecorder) GetSentinelsInfo(ctx interface{}) *gomock.Call

GetSentinelsInfo indicates an expected call of GetSentinelsInfo

func (*MockStoreMockRecorder) PutClusterData

func (mr *MockStoreMockRecorder) PutClusterData(ctx, cd interface{}) *gomock.Call

PutClusterData indicates an expected call of PutClusterData

func (*MockStoreMockRecorder) SetKeeperInfo

func (mr *MockStoreMockRecorder) SetKeeperInfo(ctx, id, ms, ttl interface{}) *gomock.Call

SetKeeperInfo indicates an expected call of SetKeeperInfo

func (*MockStoreMockRecorder) SetProxyInfo

func (mr *MockStoreMockRecorder) SetProxyInfo(ctx, pi, ttl interface{}) *gomock.Call

SetProxyInfo indicates an expected call of SetProxyInfo

func (*MockStoreMockRecorder) SetSentinelInfo

func (mr *MockStoreMockRecorder) SetSentinelInfo(ctx, si, ttl interface{}) *gomock.Call

SetSentinelInfo indicates an expected call of SetSentinelInfo