controller

Documentation

Index

• func Destruct[T any](obj T) (*unstructured.Unstructured, error)
• func Restructure[T any](obj any) (any, error)
• type CallbackFunc
• type Controller
  • func NewController(f ...ControllerOptionFunc) *Controller
  • func (c *Controller) Start()
• type ControllerOptionFunc
  • func WithCallback(callback CallbackFunc) ControllerOptionFunc
  • func WithClient(client *dynamic.DynamicClient) ControllerOptionFunc
  • func WithInformer(name string, informer InformerBuilder) ControllerOptionFunc
  • func WithObjectKinds(objectKinds ...schema.GroupKind) ControllerOptionFunc
  • func WithObjectLinks(objectLinks ...RuntimeLinkFunc) ControllerOptionFunc
  • func WithPolicyKinds(policyKinds ...schema.GroupKind) ControllerOptionFunc
• type ControllerOptions
• type EventType
  • func (t *EventType) String() string
• type GatewayAPITopology
  • func NewGatewayAPITopology(policyKinds, objectKinds []schema.GroupKind, objectLinks []RuntimeLinkFunc) *GatewayAPITopology
  • func (t *GatewayAPITopology) Get() *machinery.Topology
  • func (t *GatewayAPITopology) Refresh(objs Store)
• type InformerBuilder
  • func For[T RuntimeObject](resource schema.GroupVersionResource, namespace string, ...) InformerBuilder
• type InformerBuilderOptions
• type InformerBuilderOptionsFunc
  • func FilterResourcesByField(selector string) InformerBuilderOptionsFunc
  • func FilterResourcesByLabel(selector string) InformerBuilderOptionsFunc
• type Object
  • func (g *Object) GetName() string
  • func (g *Object) GetNamespace() string
  • func (g *Object) GetURL() string
  • func (g *Object) GroupVersionKind() schema.GroupVersionKind
  • func (g *Object) SetGroupVersionKind(schema.GroupVersionKind)
• type RuntimeLinkFunc
• type RuntimeObject
• type Store

Functions

func Destruct

func Destruct[T any](obj T) (*unstructured.Unstructured, error)

func Restructure

func Restructure[T any](obj any) (any, error)

Types

type CallbackFunc

type CallbackFunc func(EventType, RuntimeObject, RuntimeObject, *machinery.Topology)

type Controller

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

func NewController

func NewController(f ...ControllerOptionFunc) *Controller

func (*Controller) Start

func (c *Controller) Start()

Starts starts the informers and blocks until a stop signal is received

type ControllerOptionFunc

type ControllerOptionFunc func(*ControllerOptions)

func WithCallback

func WithCallback(callback CallbackFunc) ControllerOptionFunc

func WithClient

func WithClient(client *dynamic.DynamicClient) ControllerOptionFunc

func WithInformer

func WithInformer(name string, informer InformerBuilder) ControllerOptionFunc

func WithObjectKinds

func WithObjectKinds(objectKinds ...schema.GroupKind) ControllerOptionFunc

func WithObjectLinks

func WithObjectLinks(objectLinks ...RuntimeLinkFunc) ControllerOptionFunc

func WithPolicyKinds

func WithPolicyKinds(policyKinds ...schema.GroupKind) ControllerOptionFunc

type ControllerOptions

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

type EventType

type EventType int

const (
	CreateEvent EventType = iota
	UpdateEvent
	DeleteEvent
)

func (*EventType) String

func (t *EventType) String() string

type GatewayAPITopology

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

func NewGatewayAPITopology

func NewGatewayAPITopology(policyKinds, objectKinds []schema.GroupKind, objectLinks []RuntimeLinkFunc) *GatewayAPITopology

func (*GatewayAPITopology) Get

func (t *GatewayAPITopology) Get() *machinery.Topology

func (*GatewayAPITopology) Refresh

func (t *GatewayAPITopology) Refresh(objs Store)

type InformerBuilder

type InformerBuilder func(controller *Controller) cache.SharedInformer

func For

func For[T RuntimeObject](resource schema.GroupVersionResource, namespace string, options ...InformerBuilderOptionsFunc) InformerBuilder

type InformerBuilderOptions

type InformerBuilderOptions struct {
	LabelSelector string
	FieldSelector string
}

type InformerBuilderOptionsFunc

type InformerBuilderOptionsFunc func(*InformerBuilderOptions)

func FilterResourcesByField

func FilterResourcesByField(selector string) InformerBuilderOptionsFunc

func FilterResourcesByLabel

func FilterResourcesByLabel(selector string) InformerBuilderOptionsFunc

type Object

type Object struct {
	RuntimeObject RuntimeObject
}

func (*Object) GetName

func (g *Object) GetName() string

func (*Object) GetNamespace

func (g *Object) GetNamespace() string

func (*Object) GetURL

func (g *Object) GetURL() string

func (*Object) GroupVersionKind

func (g *Object) GroupVersionKind() schema.GroupVersionKind

func (*Object) SetGroupVersionKind

func (g *Object) SetGroupVersionKind(schema.GroupVersionKind)

type RuntimeLinkFunc

type RuntimeLinkFunc func(objs Store) machinery.LinkFunc

type RuntimeObject

type RuntimeObject interface {
	runtime.Object
	metav1.Object
}

type Store

type Store map[schema.GroupKind]map[string]RuntimeObject