management

package
v0.5.4 Latest Latest
Warning

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

 Go to latest Published: Jul 26, 2022 License: Apache-2.0 Imports: 50 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewClient 

func NewClient(ctx context.Context, opts ...ManagementClientOption) (managementv1.ManagementClient, error)

Types

type CapabilitiesDataSource 

type CapabilitiesDataSource interface {
	CapabilitiesStore() capabilities.BackendStore
}

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

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

type HealthStatusDataSource interface {
	ClusterHealthStatus(ref *corev1.Reference) (*corev1.HealthStatus, error)
}

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 Server 

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

func NewServer 

func NewServer(
	ctx waitctx.RestrictiveContext,
	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) CapabilityInstaller 

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

func (*Server) CertsInfo 

func (m *Server) CertsInfo(ctx 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(
	ctx context.Context,
	ref *corev1.Reference,
) (*corev1.HealthStatus, error)

func (*Server) GetConfig 

func (m *Server) GetConfig(
	ctx context.Context,
	_ *emptypb.Empty,
) (*managementv1.GatewayConfig, 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) ListBootstrapTokens 

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

func (*Server) ListCapabilities 

func (m *Server) ListCapabilities(ctx context.Context, _ *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 waitctx.RestrictiveContext) 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) UpdateConfig 

func (m *Server) UpdateConfig(
	ctx context.Context,
	in *managementv1.UpdateConfigRequest,
) (*emptypb.Empty, 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
}

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.