controller

Documentation

Index

• Constants
• func CreateOrUpdateValidatingWebhookConfiguration(clientset kubernetes.Interface, caPEM *bytes.Buffer, port int32, ...) error
• func GenerateX509Cert(webhookName string, webhookNamespace string) (*tls.Certificate, *bytes.Buffer, error)
• func GetClient() (kubernetes.Interface, error)
• func GetEnvWithDefault(key, defaultValue string) string
• type GMConnectorReconciler
  • func (r *GMConnectorReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *GMConnectorReconciler) SetupWithManager(mgr ctrl.Manager) error
• type RouterCfg

Constants

const (
	Configmap         = "Configmap"
	ConfigmapGaudi    = "ConfigmapGaudi"
	Embedding         = "Embedding"
	TeiEmbedding      = "TeiEmbedding"
	TeiEmbeddingGaudi = "TeiEmbeddingGaudi"
	VectorDB          = "VectorDB"
	Retriever         = "Retriever"
	Reranking         = "Reranking"
	TeiReranking      = "TeiReranking"
	Tgi               = "Tgi"
	TgiGaudi          = "TgiGaudi"
	TgiNvidia         = "TgiNvidia"
	Llm               = "Llm"
	DocSum            = "DocSum"
	Router            = "router"
	DataPrep          = "DataPrep"

	WebRetriever = "WebRetriever"

	Service    = "Service"
	Deployment = "Deployment"

	METADATA_PLATFORM        = "gmc/platform"
	DefaultRouterServiceName = "router-service"
	ASR                      = "Asr"
	TTS                      = "Tts"
	SpeechT5                 = "SpeechT5"
	SpeechT5Gaudi            = "SpeechT5Gaudi"
	Whisper                  = "Whisper"
	WhisperGaudi             = "WhisperGaudi"
	UI                       = "UI"
)

Functions

func CreateOrUpdateValidatingWebhookConfiguration

func CreateOrUpdateValidatingWebhookConfiguration(clientset kubernetes.Interface, caPEM *bytes.Buffer, port int32, webhookService, webhookNamespace string) error

func GenerateX509Cert

func GenerateX509Cert(webhookName string, webhookNamespace string) (*tls.Certificate, *bytes.Buffer, error)

GenerateX509Cert generate a self-signed CA for given organization and sign certificate with the CA for given common name and dns names it resurns the CA in PEM format, certificate and private key in X509 format

func GetClient

func GetClient() (kubernetes.Interface, error)

Initializing the kube client

func GetEnvWithDefault

func GetEnvWithDefault(key, defaultValue string) string

Types

type GMConnectorReconciler

type GMConnectorReconciler struct {
	client.Client
	Scheme *runtime.Scheme
}

GMConnectorReconciler reconciles a GMConnector object

func (*GMConnectorReconciler) Reconcile

func (r *GMConnectorReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

+kubebuilder:rbac:groups=gmc.opea.io,resources=gmconnectors,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups=gmc.opea.io,resources=gmconnectors/status,verbs=get;update;patch +kubebuilder:rbac:groups=gmc.opea.io,resources=gmconnectors/finalizers,verbs=update +kubebuilder:rbac:groups=gmc.opea.io,resources=deployments,verbs=get;list;watch;create;update;patch;delete +kubebuilder:rbac:groups=gmc.opea.io,resources=deployments/status,verbs=get Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state. the GMConnector object against the actual cluster state, and then perform operations to make the cluster state reflect the state specified by the user.

For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.17.3/pkg/reconcile

func (*GMConnectorReconciler) SetupWithManager

func (r *GMConnectorReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type RouterCfg

type RouterCfg struct {
	Namespace   string
	SvcName     string
	DplymntName string
	NoProxy     string
	HttpProxy   string
	HttpsProxy  string
	GRAPH_JSON  string
}