actor

Documentation

Index

• func MergeAnnotations(t, s map[string]string) map[string]string
• func NewCleanResourceActor(client kubernetes.ClientSet, logger logr.Logger) actor.Actor
• func NewEnsureResourceActor(client kubernetes.ClientSet, logger logr.Logger) actor.Actor
• func NewEnsureSlotsActor(client kubernetes.ClientSet, logger logr.Logger) actor.Actor
• func NewHealPodActor(client kubernetes.ClientSet, logger logr.Logger) actor.Actor
• func NewJoinNodeActor(client kubernetes.ClientSet, logger logr.Logger) actor.Actor
• func NewRebalanceActor(client kubernetes.ClientSet, logger logr.Logger) actor.Actor
• func NewUpdateAccountActor(client kubernetes.ClientSet, logger logr.Logger) actor.Actor
• func NewUpdateConfigActor(client kubernetes.ClientSet, logger logr.Logger) actor.Actor
• type SlotMigrateStatus

Functions

func MergeAnnotations

func MergeAnnotations(t, s map[string]string) map[string]string

func NewCleanResourceActor

func NewCleanResourceActor(client kubernetes.ClientSet, logger logr.Logger) actor.Actor

func NewEnsureResourceActor

func NewEnsureResourceActor(client kubernetes.ClientSet, logger logr.Logger) actor.Actor

func NewEnsureSlotsActor

func NewEnsureSlotsActor(client kubernetes.ClientSet, logger logr.Logger) actor.Actor

func NewHealPodActor

func NewHealPodActor(client kubernetes.ClientSet, logger logr.Logger) actor.Actor

func NewJoinNodeActor

func NewJoinNodeActor(client kubernetes.ClientSet, logger logr.Logger) actor.Actor

func NewRebalanceActor

func NewRebalanceActor(client kubernetes.ClientSet, logger logr.Logger) actor.Actor

func NewUpdateAccountActor

func NewUpdateAccountActor(client kubernetes.ClientSet, logger logr.Logger) actor.Actor

func NewUpdateConfigActor

func NewUpdateConfigActor(client kubernetes.ClientSet, logger logr.Logger) actor.Actor

Types

type SlotMigrateStatus

type SlotMigrateStatus struct {
	Slot          int
	SourceShard   int
	SourceLabeled bool
	DestShard     int
	DestLabeled   bool
}