ops

package

v0.9.0 Latest Latest Go to latest Published: Mar 17, 2023 License: Apache-2.0 Imports: 21 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/rancher/opni

Links

Open Source Insights

Documentation ¶

Index ¶

type AlertingOpsNode
- func NewAlertingOpsNode(ctx context.Context, clusterDriver future.Future[drivers.ClusterDriver], ...) *AlertingOpsNode
type AlertingOpsNodeOption
type AlertingOpsNodeOptions

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type AlertingOpsNode ¶

type AlertingOpsNode struct {
	alertops.UnsafeAlertingAdminServer
	alertops.UnsafeConfigReconcilerServer

	AlertingOpsNodeOptions

	*shared.AlertingClusterOptions

	ClusterDriver future.Future[drivers.ClusterDriver]
	// contains filtered or unexported fields
}

Manages all dynamic backend configurations that must interact with & modify the runtime cluster

func NewAlertingOpsNode ¶

func NewAlertingOpsNode(
	ctx context.Context,
	clusterDriver future.Future[drivers.ClusterDriver],
	storageClientSet future.Future[storage.AlertingClientSet],
	opts ...AlertingOpsNodeOption) *AlertingOpsNode

func (*AlertingOpsNode) ConfigureCluster ¶

func (a *AlertingOpsNode) ConfigureCluster(ctx context.Context, conf *alertops.ClusterConfiguration) (*emptypb.Empty, error)

func (*AlertingOpsNode) ConnectRemoteSyncer ¶ added in v0.8.2

func (a *AlertingOpsNode) ConnectRemoteSyncer(
	req *alertops.ConnectRequest,
	remoteServer alertops.ConfigReconciler_ConnectRemoteSyncerServer,
) error

func (*AlertingOpsNode) GetAvailableCacheEndpoint ¶ added in v0.9.0

func (a *AlertingOpsNode) GetAvailableCacheEndpoint(ctx context.Context, options *shared.AlertingClusterOptions) (string, error)

func (*AlertingOpsNode) GetAvailableEndpoint ¶

func (a *AlertingOpsNode) GetAvailableEndpoint(ctx context.Context, options *shared.AlertingClusterOptions) (string, error)

func (*AlertingOpsNode) GetClusterConfiguration ¶

func (a *AlertingOpsNode) GetClusterConfiguration(ctx context.Context, _ *emptypb.Empty) (*alertops.ClusterConfiguration, error)

func (*AlertingOpsNode) GetClusterStatus ¶

func (a *AlertingOpsNode) GetClusterStatus(ctx context.Context, _ *emptypb.Empty) (*alertops.InstallStatus, error)

func (*AlertingOpsNode) GetRuntimeOptions ¶

func (a *AlertingOpsNode) GetRuntimeOptions(ctx context.Context) (shared.AlertingClusterOptions, error)

func (*AlertingOpsNode) InstallCluster ¶

func (a *AlertingOpsNode) InstallCluster(ctx context.Context, _ *emptypb.Empty) (*emptypb.Empty, error)

func (*AlertingOpsNode) SendManualSyncRequest ¶ added in v0.8.2

func (a *AlertingOpsNode) SendManualSyncRequest(
	ctx context.Context,
	routerKeys []string,
	routers storage.RouterStorage,
)

routerKeys correspond to the global key or tenant-ed keys

func (*AlertingOpsNode) UninstallCluster ¶

func (a *AlertingOpsNode) UninstallCluster(ctx context.Context, req *alertops.UninstallRequest) (*emptypb.Empty, error)

type AlertingOpsNodeOption ¶

type AlertingOpsNodeOption func(*AlertingOpsNodeOptions)

type AlertingOpsNodeOptions ¶

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

Source Files ¶

View all Source files

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