gateway

package
v0.12.1 Latest Latest
Warning

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

 Go to latest Published: Nov 17, 2023 License: Apache-2.0 Imports: 58 Imported by: 0

Documentation

Index

Constants

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

Variables

This section is empty.

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 added in v0.7.0 

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

func (*LoggingManagerV2) CreateOrUpdateOpensearchCluster added in v0.7.0 

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

func (*LoggingManagerV2) CreateOrUpdateSnapshotSchedule added in v0.12.0 

func (m *LoggingManagerV2) CreateOrUpdateSnapshotSchedule(
	ctx context.Context,
	snapshot *loggingadmin.SnapshotSchedule,
) (*emptypb.Empty, error)

func (*LoggingManagerV2) DeleteOpensearchCluster added in v0.7.0 

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

func (*LoggingManagerV2) DeleteSnapshotSchedule added in v0.12.0 

func (m *LoggingManagerV2) DeleteSnapshotSchedule(ctx context.Context, ref *loggingadmin.SnapshotReference) (*emptypb.Empty, error)

func (*LoggingManagerV2) DoUpgrade added in v0.7.0 

func (m *LoggingManagerV2) DoUpgrade(ctx context.Context, options *loggingadmin.UpgradeOptions) (*emptypb.Empty, error)

func (*LoggingManagerV2) GetOpensearchCluster added in v0.7.0 

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

func (*LoggingManagerV2) GetOpensearchStatus added in v0.7.0 

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

func (*LoggingManagerV2) GetSnapshotSchedule added in v0.12.0 

func (m *LoggingManagerV2) GetSnapshotSchedule(
	ctx context.Context,
	ref *loggingadmin.SnapshotReference,
) (*loggingadmin.SnapshotSchedule, error)

func (*LoggingManagerV2) GetStorageClasses added in v0.7.0 

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

func (*LoggingManagerV2) ListSnapshotSchedules added in v0.12.0 

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

func (*LoggingManagerV2) UpgradeAvailable added in v0.7.0 

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

type Plugin 

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

func NewPlugin 

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

func (*Plugin) NewLoggingManagerForPlugin added in v0.7.0 

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) UseStreamClient added in v0.12.0 

func (p *Plugin) UseStreamClient(cc grpc.ClientConnInterface)

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

Source Files

View all Source files

Directories

Path Synopsis
drivers
backend
backend/kubernetes_manager
management
management/kubernetes_manager

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.