management

package
v0.9.1-rc3 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewClient 

func NewClient(ctx waitctx.RestrictiveContext, opts ...ManagementClientOption) (managementv1.ManagementClient, error)

Types

type CapabilitiesDataSource 

type CapabilitiesDataSource interface {
	CapabilitiesStore() capabilities.BackendStore
	NodeManagerServer() capabilityv1.NodeManagerServer
}

CapabilitiesDataSource provides a way to obtain data which the management server needs to serve capabilities-related endpoints

type ConditionWatcher added in v0.9.1 

type ConditionWatcher interface {
	WatchEvents()
}

func NewConditionWatcher added in v0.9.1 

func NewConditionWatcher(cl ...func()) ConditionWatcher

type CoreDataSource 

type CoreDataSource interface {
	StorageBackend() storage.Backend
	TLSConfig() *tls.Config
}

CoreDataSource provides a way to obtain data which the management server needs to serve its core API

type DashboardSettingsManager added in v0.6.0 

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

func (*DashboardSettingsManager) GetDashboardSettings added in v0.6.0 

func (m *DashboardSettingsManager) GetDashboardSettings(
	ctx context.Context,
	_ *emptypb.Empty,
) (*managementv1.DashboardSettings, error)

func (*DashboardSettingsManager) UpdateDashboardSettings added in v0.6.0 

func (m *DashboardSettingsManager) UpdateDashboardSettings(
	ctx context.Context,
	settings *managementv1.DashboardSettings,
) (*emptypb.Empty, error)

type HealthStatusDataSource added in v0.5.4 

type HealthStatusDataSource interface {
	GetClusterHealthStatus(ref *corev1.Reference) (*corev1.HealthStatus, error)
	WatchClusterHealthStatus(ctx context.Context) <-chan *corev1.ClusterHealthStatus
}

type ManagementClientOption 

type ManagementClientOption func(*ManagementClientOptions)

func WithDialOptions 

func WithDialOptions(options ...grpc.DialOption) ManagementClientOption

func WithListenAddress 

func WithListenAddress(addr string) ManagementClientOption

type ManagementClientOptions 

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

type ManagementServerOption 

type ManagementServerOption func(*managementServerOptions)

func WithCapabilitiesDataSource 

func WithCapabilitiesDataSource(src CapabilitiesDataSource) ManagementServerOption

func WithHealthStatusDataSource added in v0.5.4 

func WithHealthStatusDataSource(src HealthStatusDataSource) ManagementServerOption

func WithLifecycler 

func WithLifecycler(lc config.Lifecycler) ManagementServerOption

type ManagementWatcherHooks added in v0.9.1 

type ManagementWatcherHooks[T proto.Message] struct {
	// contains filtered or unexported fields
}

func NewManagementWatcherHooks added in v0.9.1 

func NewManagementWatcherHooks[T proto.Message](ctx context.Context) *ManagementWatcherHooks[T]

func (*ManagementWatcherHooks[T]) HandleEvent added in v0.9.1 

func (h *ManagementWatcherHooks[T]) HandleEvent(event T)

func (*ManagementWatcherHooks[T]) RegisterHook added in v0.9.1 

func (h *ManagementWatcherHooks[T]) RegisterHook(filter func(T) bool, hooks ...func(context.Context, T) error)

type Server 

type Server struct {
	managementv1.UnsafeManagementServer
	// contains filtered or unexported fields
}

func NewServer 

func NewServer(
	ctx context.Context,
	conf *v1beta1.ManagementSpec,
	cds CoreDataSource,
	pluginLoader plugins.LoaderInterface,
	opts ...ManagementServerOption,
) *Server

func (*Server) APIExtensions 

func (m *Server) APIExtensions(context.Context, *emptypb.Empty) (*managementv1.APIExtensionInfoList, error)

func (*Server) CancelCapabilityUninstall added in v0.6.0 

func (m *Server) CancelCapabilityUninstall(
	ctx context.Context,
	req *managementv1.CapabilityUninstallCancelRequest,
) (*emptypb.Empty, error)

func (*Server) CapabilityInstaller 

func (m *Server) CapabilityInstaller(
	_ context.Context,
	req *managementv1.CapabilityInstallerRequest,
) (*managementv1.CapabilityInstallerResponse, error)

func (*Server) CapabilityUninstallStatus added in v0.6.0 

func (m *Server) CapabilityUninstallStatus(
	ctx context.Context,
	req *managementv1.CapabilityStatusRequest,
) (*corev1.TaskStatus, error)

func (*Server) CertsInfo 

func (m *Server) CertsInfo(_ context.Context, _ *emptypb.Empty) (*managementv1.CertsInfoResponse, error)

func (*Server) Collect 

func (s *Server) Collect(c chan<- prometheus.Metric)

func (*Server) CreateBootstrapToken 

func (m *Server) CreateBootstrapToken(
	ctx context.Context,
	req *managementv1.CreateBootstrapTokenRequest,
) (*corev1.BootstrapToken, error)

func (*Server) CreateRole 

func (s *Server) CreateRole(ctx context.Context, in *corev1.Role) (*emptypb.Empty, error)

func (*Server) CreateRoleBinding 

func (s *Server) CreateRoleBinding(ctx context.Context, in *corev1.RoleBinding) (*emptypb.Empty, error)

func (*Server) DeleteCluster 

func (m *Server) DeleteCluster(
	ctx context.Context,
	ref *corev1.Reference,
) (*emptypb.Empty, error)

func (*Server) DeleteRole 

func (s *Server) DeleteRole(ctx context.Context, in *corev1.Reference) (*emptypb.Empty, error)

func (*Server) DeleteRoleBinding 

func (s *Server) DeleteRoleBinding(ctx context.Context, in *corev1.Reference) (*emptypb.Empty, error)

func (*Server) Describe 

func (s *Server) Describe(c chan<- *prometheus.Desc)

func (*Server) EditCluster 

func (m *Server) EditCluster(
	ctx context.Context,
	in *managementv1.EditClusterRequest,
) (*corev1.Cluster, error)

func (*Server) GetBootstrapToken 

func (m *Server) GetBootstrapToken(
	ctx context.Context,
	ref *corev1.Reference,
) (*corev1.BootstrapToken, error)

func (*Server) GetCluster 

func (m *Server) GetCluster(
	ctx context.Context,
	ref *corev1.Reference,
) (*corev1.Cluster, error)

func (*Server) GetClusterHealthStatus added in v0.5.4 

func (m *Server) GetClusterHealthStatus(
	_ context.Context,
	ref *corev1.Reference,
) (*corev1.HealthStatus, error)

func (*Server) GetConfig 

func (m *Server) GetConfig(
	_ context.Context,
	_ *emptypb.Empty,
) (*managementv1.GatewayConfig, error)

func (*Server) GetDashboardSettings added in v0.6.0 

func (m *Server) GetDashboardSettings(
	ctx context.Context,
	in *emptypb.Empty,
) (*managementv1.DashboardSettings, error)

func (*Server) GetRole 

func (s *Server) GetRole(ctx context.Context, in *corev1.Reference) (*corev1.Role, error)

func (*Server) GetRoleBinding 

func (s *Server) GetRoleBinding(ctx context.Context, in *corev1.Reference) (*corev1.RoleBinding, error)

func (*Server) InstallCapability added in v0.6.0 

func (m *Server) InstallCapability(
	ctx context.Context,
	in *managementv1.CapabilityInstallRequest,
) (*capabilityv1.InstallResponse, error)

func (*Server) ListBootstrapTokens 

func (m *Server) ListBootstrapTokens(
	ctx context.Context,
	_ *emptypb.Empty,
) (*corev1.BootstrapTokenList, error)

func (*Server) ListCapabilities 

func (m *Server) ListCapabilities(ctx context.Context, in *emptypb.Empty) (*managementv1.CapabilityList, error)

func (*Server) ListClusters 

func (m *Server) ListClusters(
	ctx context.Context,
	in *managementv1.ListClustersRequest,
) (*corev1.ClusterList, error)

func (*Server) ListRoleBindings 

func (s *Server) ListRoleBindings(ctx context.Context, _ *emptypb.Empty) (*corev1.RoleBindingList, error)

func (*Server) ListRoles 

func (s *Server) ListRoles(ctx context.Context, _ *emptypb.Empty) (*corev1.RoleList, error)

func (*Server) ListenAndServe 

func (m *Server) ListenAndServe(ctx context.Context) error

func (*Server) RevokeBootstrapToken 

func (m *Server) RevokeBootstrapToken(
	ctx context.Context,
	ref *corev1.Reference,
) (*emptypb.Empty, error)

func (*Server) SubjectAccess 

func (s *Server) SubjectAccess(ctx context.Context, sar *corev1.SubjectAccessRequest) (*corev1.ReferenceList, error)

func (*Server) UninstallCapability added in v0.6.0 

func (m *Server) UninstallCapability(
	ctx context.Context,
	in *managementv1.CapabilityUninstallRequest,
) (*emptypb.Empty, error)

func (*Server) UpdateConfig 

func (m *Server) UpdateConfig(
	_ context.Context,
	in *managementv1.UpdateConfigRequest,
) (*emptypb.Empty, error)

func (*Server) UpdateDashboardSettings added in v0.6.0 

func (m *Server) UpdateDashboardSettings(
	ctx context.Context,
	in *managementv1.DashboardSettings,
) (*emptypb.Empty, error)

func (*Server) WatchClusterHealthStatus added in v0.6.0 

func (m *Server) WatchClusterHealthStatus(
	_ *emptypb.Empty,
	stream managementv1.Management_WatchClusterHealthStatusServer,
) error

func (*Server) WatchClusters 

func (m *Server) WatchClusters(
	in *managementv1.WatchClustersRequest,
	stream managementv1.Management_WatchClustersServer,
) error

type StreamDirector 

type StreamDirector func(ctx context.Context, fullMethodName string) (context.Context, *UnknownStreamMetadata, error)

type UnknownStreamMetadata 

type UnknownStreamMetadata struct {
	Conn            *grpc.ClientConn
	InputType       *desc.MessageDescriptor
	OutputType      *desc.MessageDescriptor
	ServerStreaming bool
	ClientStreaming bool
}

type WatcherHooks added in v0.9.1 

type WatcherHooks[T any] interface {
	RegisterEvent(eventType func(T) bool, hooks ...func(context.Context, T) error)
	HandleEvent(T)
}

Source Files

View all Source files

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.