gateway

Documentation

Index

• Constants
• func ClusterStatusDescription(s ClusterStatus, extraInfo ...string) string
• func Scheme(ctx context.Context) meta.Scheme
• type ClusterStatus
• type LoggingManagerV2
  • func (m *LoggingManagerV2) CreateOrUpdateOpensearchCluster(ctx context.Context, cluster *loggingadmin.OpensearchClusterV2) (*emptypb.Empty, error)
  • func (m *LoggingManagerV2) DeleteOpensearchCluster(ctx context.Context, _ *emptypb.Empty) (*emptypb.Empty, error)
  • func (m *LoggingManagerV2) DoUpgrade(ctx context.Context, _ *emptypb.Empty) (*emptypb.Empty, error)
  • func (m *LoggingManagerV2) GetOpensearchCluster(ctx context.Context, _ *emptypb.Empty) (*loggingadmin.OpensearchClusterV2, error)
  • func (m *LoggingManagerV2) GetOpensearchStatus(ctx context.Context, _ *emptypb.Empty) (*loggingadmin.StatusResponse, error)
  • func (m *LoggingManagerV2) GetStorageClasses(ctx context.Context, _ *emptypb.Empty) (*loggingadmin.StorageClassResponse, error)
  • func (m *LoggingManagerV2) UpgradeAvailable(ctx context.Context, _ *emptypb.Empty) (*loggingadmin.UpgradeAvailableResponse, error)
• type Plugin
  • func NewPlugin(ctx context.Context, opts ...PluginOption) *Plugin
  • func (p *Plugin) NewLoggingManagerForPlugin() *LoggingManagerV2
  • func (p *Plugin) StreamServers() []streamext.Server
  • func (p *Plugin) UseKeyValueStore(client system.KeyValueStoreClient)
  • func (p *Plugin) UseManagementAPI(client managementv1.ManagementClient)
  • func (p *Plugin) UseNodeManagerClient(client capabilityv1.NodeManagerClient)
• type PluginOption
  • func FeatureOverride(flagOverride featureflags.FeatureFlag) PluginOption
  • func WithNamespace(namespace string) PluginOption
  • func WithNatsRef(ref *corev1.LocalObjectReference) PluginOption
  • func WithOpensearchCluster(cluster *opnimeta.OpensearchClusterRef) PluginOption
  • func WithRestConfig(restconfig *rest.Config) PluginOption
• type PluginOptions
• type UninstallTaskRunner
  • func (a *UninstallTaskRunner) OnTaskCompleted(ctx context.Context, ti task.ActiveTask, state task.State, args ...any)
  • func (a *UninstallTaskRunner) OnTaskRunning(ctx context.Context, ti task.ActiveTask) error

Constants

const (
	OpensearchBindingName = "opni-logging"
	OpniPreprocessingPort = 4317
)

Functions

func ClusterStatusDescription

func ClusterStatusDescription(s ClusterStatus, extraInfo ...string) string

func Scheme

func Scheme(ctx context.Context) meta.Scheme

Types

type ClusterStatus

type ClusterStatus int

const (
	ClusterStatusPending ClusterStatus = iota + 1
	ClusterStatusGreen
	ClusterStatusYellow
	ClusterStatusRed
	ClusterStatusError
)

type LoggingManagerV2

type LoggingManagerV2 struct {
	loggingadmin.UnsafeLoggingAdminV2Server
	// contains filtered or unexported fields
}

func (*LoggingManagerV2) CreateOrUpdateOpensearchCluster

func (m *LoggingManagerV2) CreateOrUpdateOpensearchCluster(ctx context.Context, cluster *loggingadmin.OpensearchClusterV2) (*emptypb.Empty, error)

func (*LoggingManagerV2) DeleteOpensearchCluster

func (m *LoggingManagerV2) DeleteOpensearchCluster(ctx context.Context, _ *emptypb.Empty) (*emptypb.Empty, error)

func (*LoggingManagerV2) DoUpgrade

func (m *LoggingManagerV2) DoUpgrade(ctx context.Context, _ *emptypb.Empty) (*emptypb.Empty, error)

func (*LoggingManagerV2) GetOpensearchCluster

func (m *LoggingManagerV2) GetOpensearchCluster(ctx context.Context, _ *emptypb.Empty) (*loggingadmin.OpensearchClusterV2, error)

func (*LoggingManagerV2) GetOpensearchStatus

func (m *LoggingManagerV2) GetOpensearchStatus(ctx context.Context, _ *emptypb.Empty) (*loggingadmin.StatusResponse, error)

func (*LoggingManagerV2) GetStorageClasses

func (m *LoggingManagerV2) GetStorageClasses(ctx context.Context, _ *emptypb.Empty) (*loggingadmin.StorageClassResponse, error)

func (*LoggingManagerV2) UpgradeAvailable

func (m *LoggingManagerV2) UpgradeAvailable(ctx context.Context, _ *emptypb.Empty) (*loggingadmin.UpgradeAvailableResponse, error)

type Plugin

type Plugin struct {
	PluginOptions
	capabilityv1.UnsafeBackendServer
	opensearch.UnsafeOpensearchServer
	system.UnimplementedSystemPluginClient
	loggingadmin.UnsafeLoggingAdminServer
	// contains filtered or unexported fields
}

func NewPlugin

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

func (*Plugin) NewLoggingManagerForPlugin

func (p *Plugin) NewLoggingManagerForPlugin() *LoggingManagerV2

func (*Plugin) StreamServers

func (p *Plugin) StreamServers() []streamext.Server

func (*Plugin) UseKeyValueStore

func (p *Plugin) UseKeyValueStore(client system.KeyValueStoreClient)

func (*Plugin) UseManagementAPI

func (p *Plugin) UseManagementAPI(client managementv1.ManagementClient)

func (*Plugin) UseNodeManagerClient

func (p *Plugin) UseNodeManagerClient(client capabilityv1.NodeManagerClient)

type PluginOption

type PluginOption func(*PluginOptions)

func FeatureOverride

func FeatureOverride(flagOverride featureflags.FeatureFlag) PluginOption

func WithNamespace

func WithNamespace(namespace string) PluginOption

func WithNatsRef

func WithNatsRef(ref *corev1.LocalObjectReference) PluginOption

func WithOpensearchCluster

func WithOpensearchCluster(cluster *opnimeta.OpensearchClusterRef) PluginOption

func WithRestConfig

func WithRestConfig(restconfig *rest.Config) PluginOption

type PluginOptions

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

type UninstallTaskRunner

type UninstallTaskRunner struct {
	uninstall.DefaultPendingHandler
	// contains filtered or unexported fields
}

func (*UninstallTaskRunner) OnTaskCompleted

func (a *UninstallTaskRunner) OnTaskCompleted(ctx context.Context, ti task.ActiveTask, state task.State, args ...any)

func (*UninstallTaskRunner) OnTaskRunning

func (a *UninstallTaskRunner) OnTaskRunning(ctx context.Context, ti task.ActiveTask) error