Documentation ¶
Overview ¶
Package embedetcd is a generated GoMock package.
Index ¶
- Constants
- Variables
- func New(topology map[string]string) *embedEtcd
- type Config
- type EmbedEtcd
- type EventType
- type LeaderInfo
- type Member
- type MembershipChangedEvent
- type MembershipEventProcessor
- type MockMember
- func (m *MockMember) EXPECT() *MockMemberMockRecorder
- func (m *MockMember) GetLeaderAddr() string
- func (m *MockMember) GetLeaderID() string
- func (m *MockMember) IsLeader() bool
- func (m *MockMember) IsReady() bool
- func (m *MockMember) RegisterMembershipChangedProcessor(arg0 MembershipEventProcessor)
- func (m *MockMember) ResignIfLeader()
- type MockMemberMockRecorder
- func (mr *MockMemberMockRecorder) GetLeaderAddr() *gomock.Call
- func (mr *MockMemberMockRecorder) GetLeaderID() *gomock.Call
- func (mr *MockMemberMockRecorder) IsLeader() *gomock.Call
- func (mr *MockMemberMockRecorder) IsReady() *gomock.Call
- func (mr *MockMemberMockRecorder) RegisterMembershipChangedProcessor(arg0 interface{}) *gomock.Call
- func (mr *MockMemberMockRecorder) ResignIfLeader() *gomock.Call
Constants ¶
const ( EventBecomeLeader = "leader" EventBecomeFollower = "follower" )
Variables ¶
var ( ErrStartEtcd = errors.New("start etcd failed") ErrStartEtcdCanceled = errors.New("etcd start canceled") )
var ( ErrNewMember = errors.New("create member failed") ErrKVGet = errors.New("get kv data failed") ErrKeyNotFound = errors.New("key didn't found in kv store") ErrUnmarshall = errors.New("unmarshall data from kv failed") )
var ( // EtcdStartTimeout the timeout of the startup etcd. EtcdStartTimeout = time.Minute * 5 )
Functions ¶
Types ¶
type Config ¶
type Config struct { Name string `yaml:"name"` DataDir string `yaml:"data_dir"` ListenClientAddr string `yaml:"listen_client_addr"` ListenPeerAddr string `yaml:"listen_peer_addr"` AdvertiseClientAddr string `yaml:"advertise_client_addr"` AdvertisePeerAddr string `yaml:"advertise_peer_addr"` Clusters []string `yaml:"clusters"` }
type LeaderInfo ¶
type Member ¶
type Member interface { RegisterMembershipChangedProcessor(MembershipEventProcessor) ResignIfLeader() IsLeader() bool GetLeaderID() string GetLeaderAddr() string IsReady() bool }
type MembershipChangedEvent ¶
type MembershipEventProcessor ¶
type MembershipEventProcessor func(ctx context.Context, event MembershipChangedEvent) error
type MockMember ¶ added in v0.1.2
type MockMember struct {
// contains filtered or unexported fields
}
MockMember is a mock of Member interface.
func NewMockMember ¶ added in v0.1.2
func NewMockMember(ctrl *gomock.Controller) *MockMember
NewMockMember creates a new mock instance.
func (*MockMember) EXPECT ¶ added in v0.1.2
func (m *MockMember) EXPECT() *MockMemberMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockMember) GetLeaderAddr ¶ added in v0.1.2
func (m *MockMember) GetLeaderAddr() string
GetLeaderAddr mocks base method.
func (*MockMember) GetLeaderID ¶ added in v0.1.2
func (m *MockMember) GetLeaderID() string
GetLeaderID mocks base method.
func (*MockMember) IsLeader ¶ added in v0.1.2
func (m *MockMember) IsLeader() bool
IsLeader mocks base method.
func (*MockMember) IsReady ¶ added in v0.1.2
func (m *MockMember) IsReady() bool
IsReady mocks base method.
func (*MockMember) RegisterMembershipChangedProcessor ¶ added in v0.1.2
func (m *MockMember) RegisterMembershipChangedProcessor(arg0 MembershipEventProcessor)
RegisterMembershipChangedProcessor mocks base method.
func (*MockMember) ResignIfLeader ¶ added in v0.1.2
func (m *MockMember) ResignIfLeader()
ResignIfLeader mocks base method.
type MockMemberMockRecorder ¶ added in v0.1.2
type MockMemberMockRecorder struct {
// contains filtered or unexported fields
}
MockMemberMockRecorder is the mock recorder for MockMember.
func (*MockMemberMockRecorder) GetLeaderAddr ¶ added in v0.1.2
func (mr *MockMemberMockRecorder) GetLeaderAddr() *gomock.Call
GetLeaderAddr indicates an expected call of GetLeaderAddr.
func (*MockMemberMockRecorder) GetLeaderID ¶ added in v0.1.2
func (mr *MockMemberMockRecorder) GetLeaderID() *gomock.Call
GetLeaderID indicates an expected call of GetLeaderID.
func (*MockMemberMockRecorder) IsLeader ¶ added in v0.1.2
func (mr *MockMemberMockRecorder) IsLeader() *gomock.Call
IsLeader indicates an expected call of IsLeader.
func (*MockMemberMockRecorder) IsReady ¶ added in v0.1.2
func (mr *MockMemberMockRecorder) IsReady() *gomock.Call
IsReady indicates an expected call of IsReady.
func (*MockMemberMockRecorder) RegisterMembershipChangedProcessor ¶ added in v0.1.2
func (mr *MockMemberMockRecorder) RegisterMembershipChangedProcessor(arg0 interface{}) *gomock.Call
RegisterMembershipChangedProcessor indicates an expected call of RegisterMembershipChangedProcessor.
func (*MockMemberMockRecorder) ResignIfLeader ¶ added in v0.1.2
func (mr *MockMemberMockRecorder) ResignIfLeader() *gomock.Call
ResignIfLeader indicates an expected call of ResignIfLeader.