resources

Documentation

Index

• Constants
• func CombineLabels(maps ...map[string]string) map[string]string
• func FindManagerImage(ctx context.Context, c client.Client) (string, corev1.PullPolicy, error)
• func NewGatewayLabels() map[string]string
• func ReconcileAll(r reconciler.ResourceReconciler, resources []Resource) k8sutil.RequeueOp
• type ComponentReconciler
• type OpensearchLabels
  • func NewOpensearchLabels() OpensearchLabels
• type Resource
  • func Absent(obj client.Object) Resource
  • func Created(obj client.Object) Resource
  • func CreatedIff(condition bool, obj client.Object) Resource
  • func Error(obj client.Object, err error) Resource
  • func Present(obj client.Object) Resource
  • func PresentIff(condition bool, obj client.Object) Resource
• type ResourceWithLog

Constants

const (
	PretrainedModelLabel = "opni.io/pretrained-model"
	ServiceLabel         = "opni.io/service"
	OpniClusterName      = "opni.io/cluster-name"
	AppNameLabel         = "app.kubernetes.io/name"
	PartOfLabel          = "app.kubernetes.io/part-of"
	InstanceLabel        = "app.kubernetes.io/instance"
	HostTopologyKey      = "kubernetes.io/hostname"
	OpniClusterID        = "opni.io/cluster-id"
	OpniBootstrapToken   = "opni.io/bootstrap-token"
	OpniInferenceType    = "opni.io/inference-type"
	OpniConfigHash       = "opni.io/config-hash"
)

Functions

func CombineLabels

func CombineLabels(maps ...map[string]string) map[string]string

func FindManagerImage

func FindManagerImage(ctx context.Context, c client.Client) (string, corev1.PullPolicy, error)

func NewGatewayLabels

func NewGatewayLabels() map[string]string

func ReconcileAll

func ReconcileAll(r reconciler.ResourceReconciler, resources []Resource) k8sutil.RequeueOp

Types

type ComponentReconciler

type ComponentReconciler func() (*reconcile.Result, error)

ComponentReconciler reconciler interface

type OpensearchLabels

type OpensearchLabels map[string]string

func NewOpensearchLabels

func NewOpensearchLabels() OpensearchLabels

type Resource

type Resource func() (runtime.Object, reconciler.DesiredState, error)

Resource redeclaration of function with return type kubernetes Object

func Absent

func Absent(obj client.Object) Resource

func Created

func Created(obj client.Object) Resource

func CreatedIff

func CreatedIff(condition bool, obj client.Object) Resource

func Error

func Error(obj client.Object, err error) Resource

func Present

func Present(obj client.Object) Resource

func PresentIff

func PresentIff(condition bool, obj client.Object) Resource

type ResourceWithLog

type ResourceWithLog func(log logr.Logger) runtime.Object

ResourceWithLog redeclaration of function with logging parameter and return type kubernetes Object