member

Documentation

Overview

Package member is a generated GoMock package.

Index

• Variables
• type Config
• type EventType
• type LeaderInfo
• type Member
  • func New(cfg Config) Member
• type MembershipChangedEvent
• type MembershipEventProcessor
• type MockMember
  • func NewMockMember(ctrl *gomock.Controller) *MockMember
  • func (m *MockMember) EXPECT() *MockMemberMockRecorder
  • func (m *MockMember) GetLeaderAddr() string
  • func (m *MockMember) GetLeaderID() string
  • func (m *MockMember) Init(arg0 context.Context) error
  • func (m *MockMember) IsLeader() bool
  • func (m *MockMember) IsReady() bool
  • func (m *MockMember) RegisterMembershipChangedProcessor(arg0 MembershipEventProcessor)
  • func (m *MockMember) ResignIfLeader()
  • func (m *MockMember) Start(arg0 context.Context) error
  • func (m *MockMember) Stop(arg0 context.Context)
• type MockMemberMockRecorder
  • func (mr *MockMemberMockRecorder) GetLeaderAddr() *gomock.Call
  • func (mr *MockMemberMockRecorder) GetLeaderID() *gomock.Call
  • func (mr *MockMemberMockRecorder) Init(arg0 interface{}) *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
  • func (mr *MockMemberMockRecorder) Start(arg0 interface{}) *gomock.Call
  • func (mr *MockMemberMockRecorder) Stop(arg0 interface{}) *gomock.Call

Variables

var (
	ErrStartEtcd         = errors.New("start etcd failed")
	ErrStartEtcdCanceled = errors.New("etcd start canceled")
)

Types

type Config

type Config struct {
	LeaseDurationInSecond int               `yaml:"lease_duration_in_sec"`
	EtcdEndpoints         []string          `yaml:"etcd"`
	Topology              map[string]string `yaml:"topology"`
	ComponentName         string            `yaml:"component_name"`
	NodeName              string            `yaml:"-"`
}

type EventType

type EventType string

const (
	EventBecomeLeader   EventType = "leader"
	EventBecomeFollower EventType = "follower"
)

type LeaderInfo

type LeaderInfo struct {
	LeaderID   string
	LeaderAddr string
}

type Member

type Member interface {
	Init(context.Context) error
	Start(context.Context) error
	Stop(context.Context)
	RegisterMembershipChangedProcessor(MembershipEventProcessor)
	ResignIfLeader()
	IsLeader() bool
	GetLeaderID() string
	GetLeaderAddr() string
	IsReady() bool
}

func New

func New(cfg Config) Member

type MembershipChangedEvent

type MembershipChangedEvent struct {
	Type EventType
}

type MembershipEventProcessor

type MembershipEventProcessor func(ctx context.Context, event MembershipChangedEvent) error

type MockMember

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

MockMember is a mock of Member interface.

func NewMockMember

func NewMockMember(ctrl *gomock.Controller) *MockMember

NewMockMember creates a new mock instance.

func (*MockMember) EXPECT

func (m *MockMember) EXPECT() *MockMemberMockRecorder

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

func (*MockMember) GetLeaderAddr

func (m *MockMember) GetLeaderAddr() string

GetLeaderAddr mocks base method.

func (*MockMember) GetLeaderID

func (m *MockMember) GetLeaderID() string

GetLeaderID mocks base method.

func (*MockMember) Init

func (m *MockMember) Init(arg0 context.Context) error

Init mocks base method.

func (*MockMember) IsLeader

func (m *MockMember) IsLeader() bool

IsLeader mocks base method.

func (*MockMember) IsReady

func (m *MockMember) IsReady() bool

IsReady mocks base method.

func (*MockMember) RegisterMembershipChangedProcessor

func (m *MockMember) RegisterMembershipChangedProcessor(arg0 MembershipEventProcessor)

RegisterMembershipChangedProcessor mocks base method.

func (*MockMember) ResignIfLeader

func (m *MockMember) ResignIfLeader()

ResignIfLeader mocks base method.

func (*MockMember) Start

func (m *MockMember) Start(arg0 context.Context) error

Start mocks base method.

func (*MockMember) Stop

func (m *MockMember) Stop(arg0 context.Context)

Stop mocks base method.

type MockMemberMockRecorder

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

MockMemberMockRecorder is the mock recorder for MockMember.

func (*MockMemberMockRecorder) GetLeaderAddr

func (mr *MockMemberMockRecorder) GetLeaderAddr() *gomock.Call

GetLeaderAddr indicates an expected call of GetLeaderAddr.

func (*MockMemberMockRecorder) GetLeaderID

func (mr *MockMemberMockRecorder) GetLeaderID() *gomock.Call

GetLeaderID indicates an expected call of GetLeaderID.

func (*MockMemberMockRecorder) Init

func (mr *MockMemberMockRecorder) Init(arg0 interface{}) *gomock.Call

Init indicates an expected call of Init.

func (*MockMemberMockRecorder) IsLeader

func (mr *MockMemberMockRecorder) IsLeader() *gomock.Call

IsLeader indicates an expected call of IsLeader.

func (*MockMemberMockRecorder) IsReady

func (mr *MockMemberMockRecorder) IsReady() *gomock.Call

IsReady indicates an expected call of IsReady.

func (*MockMemberMockRecorder) RegisterMembershipChangedProcessor

func (mr *MockMemberMockRecorder) RegisterMembershipChangedProcessor(arg0 interface{}) *gomock.Call

RegisterMembershipChangedProcessor indicates an expected call of RegisterMembershipChangedProcessor.

func (*MockMemberMockRecorder) ResignIfLeader

func (mr *MockMemberMockRecorder) ResignIfLeader() *gomock.Call

ResignIfLeader indicates an expected call of ResignIfLeader.

func (*MockMemberMockRecorder) Start

func (mr *MockMemberMockRecorder) Start(arg0 interface{}) *gomock.Call

Start indicates an expected call of Start.

func (*MockMemberMockRecorder) Stop

func (mr *MockMemberMockRecorder) Stop(arg0 interface{}) *gomock.Call

Stop indicates an expected call of Stop.