embedetcd

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 EmbedEtcd interface {
	Init(context.Context, Config) error
	Start(context.Context) (<-chan struct{}, error)
	Stop(context.Context)
}

type EventType string

type LeaderInfo struct {
	LeaderID   string `json:"leader_id"`
	LeaderName string `json:"leader_name"`
}

type Member interface {
	RegisterMembershipChangedProcessor(MembershipEventProcessor)
	ResignIfLeader()
	IsLeader() bool
	GetLeaderID() string
	GetLeaderAddr() string
	IsReady() bool
}

type MembershipChangedEvent struct {
	Type   EventType
	Leader uint64
}

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

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

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