metamanager

Documentation

Index

• Constants
• type CachedPodListFunc
• type Manager
  • func NewManager(emitter metrics.MetricEmitter, cachedPods CachedPodListFunc, ...) *Manager
  • func (m *Manager) GetPods() []*v1.Pod
  • func (m *Manager) ReconcilePods() ([]string, map[string]struct{}, error)
  • func (m *Manager) RegistPodAddedFunc(podAddedFunc PodAddedFunc)
  • func (m *Manager) RegistPodDeletedFunc(podDeletedFunc PodDeletedFunc)
  • func (m *Manager) Run(ctx context.Context, reconcilePeriod time.Duration)
• type PodAddedFunc
• type PodDeletedFunc

Constants

const (
	MetricReconcileFail = "metamanager_reconcile_fail"
)

Types

type CachedPodListFunc

type CachedPodListFunc func() sets.String

type Manager

type Manager struct {
	*metaserver.MetaServer
	// contains filtered or unexported fields
}

func NewManager

func NewManager(
	emitter metrics.MetricEmitter,
	cachedPods CachedPodListFunc,
	metaServer *metaserver.MetaServer,
) *Manager

func (*Manager) GetPods

func (m *Manager) GetPods() []*v1.Pod

func (*Manager) ReconcilePods

func (m *Manager) ReconcilePods() ([]string, map[string]struct{}, error)

ReconcilePods returns a list of new pods and pod should be deleted

func (*Manager) RegistPodAddedFunc

func (m *Manager) RegistPodAddedFunc(podAddedFunc PodAddedFunc)

func (*Manager) RegistPodDeletedFunc

func (m *Manager) RegistPodDeletedFunc(podDeletedFunc PodDeletedFunc)

func (*Manager) Run

func (m *Manager) Run(ctx context.Context, reconcilePeriod time.Duration)

type PodAddedFunc

type PodAddedFunc func(podUID string)

type PodDeletedFunc

type PodDeletedFunc func(podUID string)