gateway

package
v0.6.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 16, 2022 License: Apache-2.0 Imports: 67 Imported by: 0

Documentation

Index

Constants

View Source
const (
	LabelOpsterCluster  = "opster.io/opensearch-cluster"
	LabelOpsterNodePool = "opster.io/opensearch-nodepool"
	TopologyKeyK8sHost  = "kubernetes.io/hostname"
)
View Source
const (
	OpensearchBindingName = "opni-logging"
)

Variables

This section is empty.

Functions

func ClusterStatusDescription

func ClusterStatusDescription(s ClusterStatus) string

func ReplaceInArray

func ReplaceInArray[T comparable](array []T, old T, new T) []T

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 Plugin

func NewPlugin

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

func (*Plugin) CreateOrUpdateOpensearchCluster

func (p *Plugin) CreateOrUpdateOpensearchCluster(
	ctx context.Context,
	cluster *loggingadmin.OpensearchCluster,
) (*emptypb.Empty, error)

func (*Plugin) DeleteOpensearchCluster

func (p *Plugin) DeleteOpensearchCluster(
	ctx context.Context,
	empty *emptypb.Empty,
) (*emptypb.Empty, error)

func (*Plugin) DoUpgrade

func (p *Plugin) DoUpgrade(context.Context, *emptypb.Empty) (*emptypb.Empty, error)

func (*Plugin) GetDetails

func (*Plugin) GetOpensearchCluster

func (p *Plugin) GetOpensearchCluster(
	ctx context.Context,
	empty *emptypb.Empty,
) (*loggingadmin.OpensearchCluster, error)

func (*Plugin) GetOpensearchStatus

func (p *Plugin) GetOpensearchStatus(ctx context.Context, in *emptypb.Empty) (*loggingadmin.StatusResponse, error)

func (*Plugin) GetStorageClasses

func (p *Plugin) GetStorageClasses(ctx context.Context, in *emptypb.Empty) (*loggingadmin.StorageClassResponse, error)

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

func WithVersion

func WithVersion(version string) 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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL