synthesis

Documentation

Index

• func NewExecController(mgr ctrl.Manager, cfg *Config, conn SynthesizerConnection) error
• func NewPodLifecycleController(mgr ctrl.Manager, cfg *Config) error
• func NewSliceCleanupController(mgr ctrl.Manager) error
• func NewStatusController(mgr ctrl.Manager) error
• type Config
• type SynthesizerConnection
• type SynthesizerConnectionFunc
  • func (s SynthesizerConnectionFunc) Synthesize(ctx context.Context, syn *apiv1.Synthesizer, pod *corev1.Pod, ...) (io.Reader, error)
• type SynthesizerPodConnection
  • func NewSynthesizerConnection(mgr ctrl.Manager) (*SynthesizerPodConnection, error)
  • func (s *SynthesizerPodConnection) Synthesize(ctx context.Context, syn *apiv1.Synthesizer, pod *corev1.Pod, input []byte) (io.Reader, error)

Functions

func NewExecController

func NewExecController(mgr ctrl.Manager, cfg *Config, conn SynthesizerConnection) error

func NewPodLifecycleController

func NewPodLifecycleController(mgr ctrl.Manager, cfg *Config) error

NewPodLifecycleController is responsible for creating and deleting pods as needed to synthesize compositions.

func NewSliceCleanupController

func NewSliceCleanupController(mgr ctrl.Manager) error

func NewStatusController

func NewStatusController(mgr ctrl.Manager) error

NewStatusController updates composition statuses as pods transition through states.

Types

type Config

type Config struct {
	SliceCreationQPS  float64
	PodNamespace      string
	PodServiceAccount string

	TaintTolerationKey   string
	TaintTolerationValue string

	NodeAffinityKey   string
	NodeAffinityValue string
}

type SynthesizerConnection

type SynthesizerConnection interface {
	Synthesize(ctx context.Context, syn *apiv1.Synthesizer, pod *corev1.Pod, input []byte) (io.Reader, error)
}

type SynthesizerConnectionFunc

type SynthesizerConnectionFunc func(ctx context.Context, syn *apiv1.Synthesizer, pod *corev1.Pod, inputsJson []byte) (io.Reader, error)

func (SynthesizerConnectionFunc) Synthesize

func (s SynthesizerConnectionFunc) Synthesize(ctx context.Context, syn *apiv1.Synthesizer, pod *corev1.Pod, inputsJson []byte) (io.Reader, error)

type SynthesizerPodConnection

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

func NewSynthesizerConnection

func NewSynthesizerConnection(mgr ctrl.Manager) (*SynthesizerPodConnection, error)

func (*SynthesizerPodConnection) Synthesize

func (s *SynthesizerPodConnection) Synthesize(ctx context.Context, syn *apiv1.Synthesizer, pod *corev1.Pod, input []byte) (io.Reader, error)