Documentation ¶
Index ¶
- func NewLastKnownDetailsApplier(storageBackend storage.ClusterStore) ...
- type ConnectionHandler
- type ConnectionHandlerFunc
- type DelegateServer
- func (d *DelegateServer) Broadcast(ctx context.Context, req *streamv1.BroadcastMessage) (*streamv1.BroadcastReplyList, error)
- func (d *DelegateServer) HandleAgentConnection(ctx context.Context, clientSet agentv1.ClientSet)
- func (d *DelegateServer) Request(ctx context.Context, req *streamv1.DelegatedMessage) (*totem.RPC, error)
- type Gateway
- func (g *Gateway) CapabilitiesStore() capabilities.BackendStore
- func (g *Gateway) GetClusterHealthStatus(ref *corev1.Reference) (*corev1.HealthStatus, error)
- func (g *Gateway) ListenAndServe(ctx context.Context) error
- func (g *Gateway) MustRegisterCollector(collector prometheus.Collector)
- func (g *Gateway) NodeManagerServer() capabilityv1.NodeManagerServer
- func (g *Gateway) StorageBackend() storage.Backend
- func (g *Gateway) TLSConfig() *tls.Config
- func (g *Gateway) WatchClusterHealthStatus(ctx context.Context) <-chan *corev1.ClusterHealthStatus
- type GatewayGRPCServer
- type GatewayHTTPServer
- type GatewayOption
- type GatewayOptions
- type MetricsEndpointHandler
- type RatelimiterInterceptor
- type RatelimiterOption
- type StreamServer
- func (s *StreamServer) Connect(stream streamv1.Stream_ConnectServer) error
- func (s *StreamServer) InternalServiceRegistrar() grpc.ServiceRegistrar
- func (s *StreamServer) OnPluginLoad(ext types.StreamAPIExtensionPlugin, md meta.PluginMeta, cc *grpc.ClientConn)
- func (s *StreamServer) RegisterService(desc *grpc.ServiceDesc, impl any)
- type SyncRequester
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewLastKnownDetailsApplier ¶ added in v0.8.0
func NewLastKnownDetailsApplier(storageBackend storage.ClusterStore) func(srv interface{}, ss grpc.ServerStream, info *grpc.StreamServerInfo, handler grpc.StreamHandler) error
Types ¶
type ConnectionHandler ¶ added in v0.5.4
func MultiConnectionHandler ¶ added in v0.6.0
func MultiConnectionHandler(handlers ...ConnectionHandler) ConnectionHandler
type ConnectionHandlerFunc ¶ added in v0.6.0
func (ConnectionHandlerFunc) HandleAgentConnection ¶ added in v0.6.0
func (f ConnectionHandlerFunc) HandleAgentConnection(ctx context.Context, clientSet agentv1.ClientSet)
type DelegateServer ¶ added in v0.8.2
type DelegateServer struct { streamv1.UnsafeDelegateServer // contains filtered or unexported fields }
func NewDelegateServer ¶ added in v0.8.2
func NewDelegateServer(clusterStore storage.ClusterStore, lg *zap.SugaredLogger) *DelegateServer
func (*DelegateServer) Broadcast ¶ added in v0.8.2
func (d *DelegateServer) Broadcast(ctx context.Context, req *streamv1.BroadcastMessage) (*streamv1.BroadcastReplyList, error)
func (*DelegateServer) HandleAgentConnection ¶ added in v0.8.2
func (d *DelegateServer) HandleAgentConnection(ctx context.Context, clientSet agentv1.ClientSet)
func (*DelegateServer) Request ¶ added in v0.8.2
func (d *DelegateServer) Request(ctx context.Context, req *streamv1.DelegatedMessage) (*totem.RPC, error)
type Gateway ¶
type Gateway struct { GatewayOptions // contains filtered or unexported fields }
func NewGateway ¶
func NewGateway(ctx context.Context, conf *config.GatewayConfig, pl plugins.LoaderInterface, opts ...GatewayOption) *Gateway
func (*Gateway) CapabilitiesStore ¶
func (g *Gateway) CapabilitiesStore() capabilities.BackendStore
Implements management.CapabilitiesDataSource
func (*Gateway) GetClusterHealthStatus ¶ added in v0.6.0
Implements management.HealthStatusDataSource
func (*Gateway) MustRegisterCollector ¶
func (g *Gateway) MustRegisterCollector(collector prometheus.Collector)
func (*Gateway) NodeManagerServer ¶ added in v0.6.0
func (g *Gateway) NodeManagerServer() capabilityv1.NodeManagerServer
Implements management.CapabilitiesDataSource
func (*Gateway) StorageBackend ¶
Implements management.CoreDataSource
func (*Gateway) WatchClusterHealthStatus ¶ added in v0.6.0
func (g *Gateway) WatchClusterHealthStatus(ctx context.Context) <-chan *corev1.ClusterHealthStatus
Implements management.HealthStatusDataSource
type GatewayGRPCServer ¶ added in v0.5.4
type GatewayGRPCServer struct { streamv1.UnsafeStreamServer // contains filtered or unexported fields }
func NewGRPCServer ¶ added in v0.5.4
func NewGRPCServer( cfg *v1beta1.GatewayConfigSpec, lg *zap.SugaredLogger, opts ...grpc.ServerOption, ) *GatewayGRPCServer
func (*GatewayGRPCServer) ListenAndServe ¶ added in v0.5.4
func (s *GatewayGRPCServer) ListenAndServe(ctx context.Context) error
func (*GatewayGRPCServer) RegisterService ¶ added in v0.5.4
func (s *GatewayGRPCServer) RegisterService(desc *grpc.ServiceDesc, impl any)
type GatewayHTTPServer ¶ added in v0.5.4
type GatewayHTTPServer struct {
// contains filtered or unexported fields
}
func NewHTTPServer ¶ added in v0.5.4
func NewHTTPServer( ctx context.Context, cfg *v1beta1.GatewayConfigSpec, lg *zap.SugaredLogger, pl plugins.LoaderInterface, ) *GatewayHTTPServer
func (*GatewayHTTPServer) ListenAndServe ¶ added in v0.5.4
func (s *GatewayHTTPServer) ListenAndServe(ctx context.Context) error
type GatewayOption ¶
type GatewayOption func(*GatewayOptions)
func WithExtraUpdateHandlers ¶ added in v0.11.0
func WithExtraUpdateHandlers(handlers ...update.UpdateTypeHandler) GatewayOption
func WithLifecycler ¶
func WithLifecycler(lc config.Lifecycler) GatewayOption
type GatewayOptions ¶
type GatewayOptions struct {
// contains filtered or unexported fields
}
type MetricsEndpointHandler ¶
type MetricsEndpointHandler struct {
// contains filtered or unexported fields
}
func NewMetricsEndpointHandler ¶
func NewMetricsEndpointHandler(cfg v1beta1.MetricsSpec) *MetricsEndpointHandler
func (*MetricsEndpointHandler) Handler ¶ added in v0.6.0
func (h *MetricsEndpointHandler) Handler() http.Handler
type RatelimiterInterceptor ¶ added in v0.11.0
type RatelimiterInterceptor struct {
// contains filtered or unexported fields
}
func NewRateLimiterInterceptor ¶ added in v0.11.0
func NewRateLimiterInterceptor(lg *zap.SugaredLogger, opts ...RatelimiterOption) *RatelimiterInterceptor
func (*RatelimiterInterceptor) StreamServerInterceptor ¶ added in v0.11.0
func (r *RatelimiterInterceptor) StreamServerInterceptor() grpc.StreamServerInterceptor
type RatelimiterOption ¶ added in v0.11.0
type RatelimiterOption func(*ratelimiterOptions)
func WithBurst ¶ added in v0.11.0
func WithBurst(burst int) RatelimiterOption
func WithRate ¶ added in v0.11.0
func WithRate(rate float64) RatelimiterOption
type StreamServer ¶ added in v0.5.4
type StreamServer struct { streamv1.UnimplementedStreamServer // contains filtered or unexported fields }
func NewStreamServer ¶ added in v0.5.4
func NewStreamServer( handler ConnectionHandler, clusterStore storage.ClusterStore, metricsRegisterer prometheus.Registerer, lg *zap.SugaredLogger, ) *StreamServer
func (*StreamServer) Connect ¶ added in v0.5.4
func (s *StreamServer) Connect(stream streamv1.Stream_ConnectServer) error
func (*StreamServer) InternalServiceRegistrar ¶ added in v0.9.2
func (s *StreamServer) InternalServiceRegistrar() grpc.ServiceRegistrar
func (*StreamServer) OnPluginLoad ¶ added in v0.9.0
func (s *StreamServer) OnPluginLoad(ext types.StreamAPIExtensionPlugin, md meta.PluginMeta, cc *grpc.ClientConn)
func (*StreamServer) RegisterService ¶ added in v0.5.4
func (s *StreamServer) RegisterService(desc *grpc.ServiceDesc, impl any)
type SyncRequester ¶ added in v0.6.0
type SyncRequester struct { capabilityv1.UnsafeNodeManagerServer // contains filtered or unexported fields }
func NewSyncRequester ¶ added in v0.6.0
func NewSyncRequester(lg *zap.SugaredLogger) *SyncRequester
func (*SyncRequester) HandleAgentConnection ¶ added in v0.6.0
func (f *SyncRequester) HandleAgentConnection(ctx context.Context, clientSet agentv1.ClientSet)
func (*SyncRequester) RequestSync ¶ added in v0.6.0
func (f *SyncRequester) RequestSync(ctx context.Context, req *capabilityv1.SyncRequest) (*emptypb.Empty, error)
Implements capabilityv1.NodeManagerServer
Click to show internal directories.
Click to hide internal directories.