orchestration

README

This directory holds Orchestration layer of Voyager architecture.

Documentation

Index

• Constants
• func ByConfigMapNameIndex(obj interface{}) ([]string, error)
• func ByConfigMapNameIndexKey(namespace string, configMapName string) string
• func SetupAdmissionWebhooks(r *chi.Mux)
• type Controller
  • func (c *Controller) Process(ctx *ctrl.ProcessContext) (external bool, retriable bool, err error)
  • func (c *Controller) Run(ctx context.Context)
• type Entangler

Constants

const (
	ByConfigMapNameIndexName    = "configMapNamespace"
	ReasonStatusRetrievalFailed = "StatusRetrievalFailed"
)

Functions

func ByConfigMapNameIndex

func ByConfigMapNameIndex(obj interface{}) ([]string, error)

func ByConfigMapNameIndexKey

func ByConfigMapNameIndexKey(namespace string, configMapName string) string

func SetupAdmissionWebhooks

func SetupAdmissionWebhooks(r *chi.Mux)

Types

type Controller

type Controller struct {
	Logger       *zap.Logger
	Clock        clock.Clock
	ReadyForWork func()

	NamespaceInformer cache.SharedIndexInformer
	StateInformer     cache.SharedIndexInformer
	BundleInformer    cache.SharedIndexInformer
	ConfigMapInformer cache.SharedIndexInformer
	StateClient       orch_v1client.StatesGetter
	BundleClient      smithClient_v1.BundlesGetter

	StateTransitionsCounter *prometheus.CounterVec

	Entangler           Entangler
	SpecCheck           updater.SpecCheck
	BundleObjectUpdater updater.ObjectUpdater
}

func (*Controller) Process

func (c *Controller) Process(ctx *ctrl.ProcessContext) (external bool, retriable bool, err error)

func (*Controller) Run

func (c *Controller) Run(ctx context.Context)

type Entangler

type Entangler interface {
	Entangle(*orch_v1.State, *wiring.EntangleContext) wiring.EntangleResult
	Status(*orch_v1.StateResource, *wiring.StatusContext) wiring.StatusResult
}