gateway

Documentation

Index

• Constants
• Variables
• func Scheme(ctx context.Context) meta.Scheme
• type AIOpsPlugin
  • func NewPlugin(ctx context.Context, opts ...PluginOption) *AIOpsPlugin
  • func (p *AIOpsPlugin) ClusterWorkloadAggregation(ctx context.Context, in *corev1.Reference) (*modeltraining.WorkloadAggregationList, error)
  • func (s *AIOpsPlugin) DeleteAISettings(ctx context.Context, _ *emptypb.Empty) (*emptypb.Empty, error)
  • func (s *AIOpsPlugin) DoUpgrade(ctx context.Context, _ *emptypb.Empty) (*emptypb.Empty, error)
  • func (p *AIOpsPlugin) GPUInfo(ctx context.Context, _ *emptypb.Empty) (*modeltraining.GPUInfoList, error)
  • func (s *AIOpsPlugin) GetAISettings(ctx context.Context, _ *emptypb.Empty) (*admin.AISettings, error)
  • func (p *AIOpsPlugin) GetModelStatus(ctx context.Context, _ *emptypb.Empty) (*modeltraining.ModelStatus, error)
  • func (p *AIOpsPlugin) GetModelTrainingParameters(ctx context.Context, _ *emptypb.Empty) (*modeltraining.ModelTrainingParametersList, error)
  • func (s *AIOpsPlugin) GetRuntimeClasses(ctx context.Context, _ *emptypb.Empty) (*admin.RuntimeClassResponse, error)
  • func (p *AIOpsPlugin) LaunchAIServices(ctx context.Context) (*emptypb.Empty, error)
  • func (s *AIOpsPlugin) PutAISettings(ctx context.Context, settings *admin.AISettings) (*emptypb.Empty, error)
  • func (p *AIOpsPlugin) PutModelTrainingStatus(ctx context.Context, in *modeltraining.ModelStatus) (*emptypb.Empty, error)
  • func (p *AIOpsPlugin) TrainModel(ctx context.Context, in *modeltraining.ModelTrainingParametersList) (*modeltraining.ModelTrainingResponse, error)
  • func (s *AIOpsPlugin) UpgradeAvailable(ctx context.Context, _ *emptypb.Empty) (*admin.UpgradeAvailableResponse, error)
  • func (p *AIOpsPlugin) UseManagementAPI(_ managementv1.ManagementClient)
• type Aggregations
  • func (a *Aggregations) Add(bucket Bucket)
• type AggregationsSpec
• type Bucket
• type BucketSpec
• type ClusterAggregation
• type DeploymentLogCount
• type Key
• type ModelTrainingParameters
• type NamespaceAggregation
• type PluginOption
  • func WithNamespace(namespace string) PluginOption
  • func WithOpensearchCluster(cluster *opnimeta.OpensearchClusterRef) PluginOption
  • func WithRestConfig(restconfig *rest.Config) PluginOption
  • func WithVersion(version string) PluginOption
• type PluginOptions
• type SearchResponse

Constants

const (
	OpniServicesName = "opni"
)

Variables

var (
	DefaultModelSources = map[pretrainedModelType]*string{
						// contains filtered or unexported fields
	}
	ModelHyperParameters = map[pretrainedModelType]map[string]intstr.IntOrString{
							// contains filtered or unexported fields
	}
)

Functions

func Scheme

func Scheme(ctx context.Context) meta.Scheme

Types

type AIOpsPlugin

type AIOpsPlugin struct {
	PluginOptions
	modeltraining.UnsafeModelTrainingServer
	admin.UnsafeAIAdminServer
	system.UnimplementedSystemPluginClient

	Logger *zap.SugaredLogger
	// contains filtered or unexported fields
}

func NewPlugin

func NewPlugin(ctx context.Context, opts ...PluginOption) *AIOpsPlugin

func (*AIOpsPlugin) ClusterWorkloadAggregation

func (p *AIOpsPlugin) ClusterWorkloadAggregation(ctx context.Context, in *corev1.Reference) (*modeltraining.WorkloadAggregationList, error)

func (*AIOpsPlugin) DeleteAISettings

func (s *AIOpsPlugin) DeleteAISettings(ctx context.Context, _ *emptypb.Empty) (*emptypb.Empty, error)

func (*AIOpsPlugin) DoUpgrade

func (s *AIOpsPlugin) DoUpgrade(ctx context.Context, _ *emptypb.Empty) (*emptypb.Empty, error)

func (*AIOpsPlugin) GPUInfo

func (p *AIOpsPlugin) GPUInfo(ctx context.Context, _ *emptypb.Empty) (*modeltraining.GPUInfoList, error)

func (*AIOpsPlugin) GetAISettings

func (s *AIOpsPlugin) GetAISettings(ctx context.Context, _ *emptypb.Empty) (*admin.AISettings, error)

func (*AIOpsPlugin) GetModelStatus

func (p *AIOpsPlugin) GetModelStatus(ctx context.Context, _ *emptypb.Empty) (*modeltraining.ModelStatus, error)

func (*AIOpsPlugin) GetModelTrainingParameters

func (p *AIOpsPlugin) GetModelTrainingParameters(ctx context.Context, _ *emptypb.Empty) (*modeltraining.ModelTrainingParametersList, error)

func (*AIOpsPlugin) GetRuntimeClasses

func (s *AIOpsPlugin) GetRuntimeClasses(ctx context.Context, _ *emptypb.Empty) (*admin.RuntimeClassResponse, error)

func (*AIOpsPlugin) LaunchAIServices

func (p *AIOpsPlugin) LaunchAIServices(ctx context.Context) (*emptypb.Empty, error)

func (*AIOpsPlugin) PutAISettings

func (s *AIOpsPlugin) PutAISettings(ctx context.Context, settings *admin.AISettings) (*emptypb.Empty, error)

func (*AIOpsPlugin) PutModelTrainingStatus

func (p *AIOpsPlugin) PutModelTrainingStatus(ctx context.Context, in *modeltraining.ModelStatus) (*emptypb.Empty, error)

func (*AIOpsPlugin) TrainModel

func (p *AIOpsPlugin) TrainModel(ctx context.Context, in *modeltraining.ModelTrainingParametersList) (*modeltraining.ModelTrainingResponse, error)

func (*AIOpsPlugin) UpgradeAvailable

func (s *AIOpsPlugin) UpgradeAvailable(ctx context.Context, _ *emptypb.Empty) (*admin.UpgradeAvailableResponse, error)

func (*AIOpsPlugin) UseManagementAPI

func (p *AIOpsPlugin) UseManagementAPI(_ managementv1.ManagementClient)

type Aggregations

type Aggregations struct {
	ByCluster map[string]*ClusterAggregation `json:",inline,omitEmpty"`
}

func (*Aggregations) Add

func (a *Aggregations) Add(bucket Bucket)

type AggregationsSpec

type AggregationsSpec struct {
	Bucket BucketSpec `json:"bucket"`
}

type Bucket

type Bucket struct {
	Key      Key `json:"key"`
	DocCount int `json:"doc_count"`
}

type BucketSpec

type BucketSpec struct {
	AfterKey *Key     `json:"after_key"`
	Buckets  []Bucket `json:"buckets"`
}

type ClusterAggregation

type ClusterAggregation struct {
	ByNamespace map[string]*NamespaceAggregation `json:",inline,omitEmpty"`
}

type DeploymentLogCount

type DeploymentLogCount struct {
	DeploymentName string `json:"deployment_name"`
	Count          int    `json:"doc_count"`
}

type Key

type Key struct {
	ClusterID      string `json:"cluster_id"`
	NamespaceName  string `json:"namespace_name"`
	DeploymentName string `json:"deployment_name"`
}

type ModelTrainingParameters

type ModelTrainingParameters struct {
	UUID      string                         `json:"uuid,omitempty"`
	Workloads map[string]map[string][]string `json:"workloads,omitempty"`
}

type NamespaceAggregation

type NamespaceAggregation struct {
	ByDeployment map[string]*DeploymentLogCount `json:",inline,omitEmpty"`
}

type PluginOption

type PluginOption func(*PluginOptions)

func WithNamespace

func WithNamespace(namespace string) PluginOption

func WithOpensearchCluster

func WithOpensearchCluster(cluster *opnimeta.OpensearchClusterRef) PluginOption

func WithRestConfig

func WithRestConfig(restconfig *rest.Config) PluginOption

func WithVersion

func WithVersion(version string) PluginOption

type PluginOptions

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

type SearchResponse

type SearchResponse struct {
	Aggregations AggregationsSpec `json:"aggregations"`
}