etcd

Documentation

Index

• func FindNonLocalhost(addrs []string) (string, error)
• func IsLearnerReady(leaderStatus, learnerStatus *clientv3.StatusResponse) bool
• type APIMember
• type APIMemberInput
• type APIMemberJoinInput
• type APIMemberJoinOutput
• type APIMembersOutput
• type ClusterStatus
  • func (cst *ClusterStatus) FindLeaderStatus() *clientv3.StatusResponse
  • func (cst *ClusterStatus) FindLearnerStatus() *clientv3.StatusResponse
• type LeaderClusterReconciler
  • func NewLeaderClusterConciler(i roles.Instance) *LeaderClusterReconciler
  • func (lcr *LeaderClusterReconciler) ClusterStatus(ctx context.Context) (*ClusterStatus, error)
  • func (lcr *LeaderClusterReconciler) MemberAdded(m *etcdserverpb.Member)
  • func (lcr *LeaderClusterReconciler) MemberRemoved(id uint64)
  • func (lcr *LeaderClusterReconciler) Reconcile()
  • func (lcr *LeaderClusterReconciler) Start()
  • func (lcr *LeaderClusterReconciler) Stop()
• type Role
  • func New(instance roles.Instance) *Role
  • func (r *Role) APIClusterJoin() usecase.Interactor
  • func (r *Role) APIClusterMembers() usecase.Interactor
  • func (r *Role) APIClusterMoveLeader() usecase.Interactor
  • func (r *Role) APIClusterRemove() usecase.Interactor
  • func (ee *Role) Config() *embed.Config
  • func (ee *Role) Start(ctx context.Context, cfg []byte) error
  • func (ee *Role) Stop()

Functions

func FindNonLocalhost

func FindNonLocalhost(addrs []string) (string, error)

func IsLearnerReady

func IsLearnerReady(leaderStatus, learnerStatus *clientv3.StatusResponse) bool

Types

type APIMember

type APIMember struct {
	Name      string `json:"name"`
	ID        string `json:"id"`
	IsLearner bool   `json:"isLearner"`
	IsLeader  bool   `json:"isLeader"`
}

type APIMemberInput

type APIMemberInput struct {
	PeerID string `query:"peerID" required:"true"`
}

type APIMemberJoinInput

type APIMemberJoinInput struct {
	Peer       string `json:"peer" maxLength:"255"`
	Roles      string `json:"roles"`
	Identifier string `json:"identifier"`
}

type APIMemberJoinOutput

type APIMemberJoinOutput struct {
	EtcdInitialCluster string `json:"etcdInitialCluster"`
}

type APIMembersOutput

type APIMembersOutput struct {
	Members []APIMember `json:"members"`
}

type ClusterStatus

type ClusterStatus struct {
	Healthy      error
	MemberStatus map[uint64]*clientv3.StatusResponse
}

func (*ClusterStatus) FindLeaderStatus

func (cst *ClusterStatus) FindLeaderStatus() *clientv3.StatusResponse

func (*ClusterStatus) FindLearnerStatus

func (cst *ClusterStatus) FindLearnerStatus() *clientv3.StatusResponse

type LeaderClusterReconciler

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

func NewLeaderClusterConciler

func NewLeaderClusterConciler(i roles.Instance) *LeaderClusterReconciler

func (*LeaderClusterReconciler) ClusterStatus

func (lcr *LeaderClusterReconciler) ClusterStatus(ctx context.Context) (*ClusterStatus, error)

func (*LeaderClusterReconciler) MemberAdded

func (lcr *LeaderClusterReconciler) MemberAdded(m *etcdserverpb.Member)

func (*LeaderClusterReconciler) MemberRemoved

func (lcr *LeaderClusterReconciler) MemberRemoved(id uint64)

func (*LeaderClusterReconciler) Reconcile

func (lcr *LeaderClusterReconciler) Reconcile()

func (*LeaderClusterReconciler) Start

func (lcr *LeaderClusterReconciler) Start()

func (*LeaderClusterReconciler) Stop

func (lcr *LeaderClusterReconciler) Stop()

type Role

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

func New

func New(instance roles.Instance) *Role

func (*Role) APIClusterJoin

func (r *Role) APIClusterJoin() usecase.Interactor

func (*Role) APIClusterMembers

func (r *Role) APIClusterMembers() usecase.Interactor

func (*Role) APIClusterMoveLeader

func (r *Role) APIClusterMoveLeader() usecase.Interactor

func (*Role) APIClusterRemove

func (r *Role) APIClusterRemove() usecase.Interactor

func (*Role) Config

func (ee *Role) Config() *embed.Config

func (*Role) Start

func (ee *Role) Start(ctx context.Context, cfg []byte) error

func (*Role) Stop

func (ee *Role) Stop()