memberlist_manager

Documentation

Index

• Constants
• type CRMemberlistStore
  • func NewCRMemberlistStore(dynamicClient dynamic.Interface, coordinatorNamespace string, ...) *CRMemberlistStore
  • func (s *CRMemberlistStore) GetMemberlist(ctx context.Context) (return_memberlist *Memberlist, resourceVersion string, err error)
  • func (s *CRMemberlistStore) UpdateMemberlist(ctx context.Context, memberlist *Memberlist, resourceVersion string) error
• type IMemberlistManager
• type IMemberlistStore
• type IWatcher
• type KubernetesWatcher
  • func NewKubernetesWatcher(clientset kubernetes.Interface, coordinator_namespace string, pod_label string, ...) *KubernetesWatcher
  • func (w *KubernetesWatcher) ListReadyMembers() (Memberlist, error)
  • func (w *KubernetesWatcher) RegisterCallback(callback NodeWatcherCallback)
  • func (w *KubernetesWatcher) Start() error
  • func (w *KubernetesWatcher) Stop() error
• type Memberlist
• type MemberlistManager
  • func NewMemberlistManager(nodeWatcher IWatcher, memberlistStore IMemberlistStore) *MemberlistManager
  • func (m *MemberlistManager) SetReconcileCount(count uint)
  • func (m *MemberlistManager) SetReconcileInterval(interval time.Duration)
  • func (m *MemberlistManager) Start() error
  • func (m *MemberlistManager) Stop() error
• type NodeWatcherCallback
• type Status

Constants

const MemberLabel = "member-type"

Types

type CRMemberlistStore

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

func NewCRMemberlistStore

func NewCRMemberlistStore(dynamicClient dynamic.Interface, coordinatorNamespace string, memberlistCustomResource string) *CRMemberlistStore

func (*CRMemberlistStore) GetMemberlist

func (s *CRMemberlistStore) GetMemberlist(ctx context.Context) (return_memberlist *Memberlist, resourceVersion string, err error)

func (*CRMemberlistStore) UpdateMemberlist

func (s *CRMemberlistStore) UpdateMemberlist(ctx context.Context, memberlist *Memberlist, resourceVersion string) error

type IMemberlistManager

type IMemberlistManager interface {
	common.Component
}

type IMemberlistStore

type IMemberlistStore interface {
	GetMemberlist(ctx context.Context) (return_memberlist *Memberlist, resourceVersion string, err error)
	UpdateMemberlist(ctx context.Context, memberlist *Memberlist, resourceVersion string) error
}

type IWatcher

type IWatcher interface {
	common.Component
	RegisterCallback(callback NodeWatcherCallback)
	ListReadyMembers() (Memberlist, error)
}

type KubernetesWatcher

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

func NewKubernetesWatcher

func NewKubernetesWatcher(clientset kubernetes.Interface, coordinator_namespace string, pod_label string, resyncPeriod time.Duration) *KubernetesWatcher

func (*KubernetesWatcher) ListReadyMembers

func (w *KubernetesWatcher) ListReadyMembers() (Memberlist, error)

func (*KubernetesWatcher) RegisterCallback

func (w *KubernetesWatcher) RegisterCallback(callback NodeWatcherCallback)

Register a queue

func (*KubernetesWatcher) Start

func (w *KubernetesWatcher) Start() error

func (*KubernetesWatcher) Stop

func (w *KubernetesWatcher) Stop() error

Stop the kubernetes watcher

type Memberlist

type Memberlist []string

type MemberlistManager

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

func NewMemberlistManager

func NewMemberlistManager(nodeWatcher IWatcher, memberlistStore IMemberlistStore) *MemberlistManager

func (*MemberlistManager) SetReconcileCount

func (m *MemberlistManager) SetReconcileCount(count uint)

func (*MemberlistManager) SetReconcileInterval

func (m *MemberlistManager) SetReconcileInterval(interval time.Duration)

func (*MemberlistManager) Start

func (m *MemberlistManager) Start() error

func (*MemberlistManager) Stop

func (m *MemberlistManager) Stop() error

type NodeWatcherCallback

type NodeWatcherCallback func(node_ip string)

type Status

type Status int

const (
	Ready Status = iota
	NotReady
	Unknown
)

Enum for status