gateway

Documentation

Index

• type ConnectionHandler
• type Gateway
  • func NewGateway(ctx context.Context, conf *config.GatewayConfig, pl plugins.LoaderInterface, ...) *Gateway
  • func (g *Gateway) CapabilitiesStore() capabilities.BackendStore
  • func (g *Gateway) ClusterHealthStatus(ref *corev1.Reference) (*corev1.HealthStatus, error)
  • func (g *Gateway) ListenAndServe(ctx context.Context) error
  • func (g *Gateway) MustRegisterCollector(collector prometheus.Collector)
  • func (g *Gateway) StorageBackend() storage.Backend
  • func (g *Gateway) TLSConfig() *tls.Config
• type GatewayGRPCServer
  • func NewGRPCServer(cfg *v1beta1.GatewayConfigSpec, lg *zap.SugaredLogger, ...) *GatewayGRPCServer
  • func (s *GatewayGRPCServer) ListenAndServe(ctx context.Context) error
  • func (s *GatewayGRPCServer) RegisterService(desc *grpc.ServiceDesc, impl any)
• type GatewayHTTPServer
  • func NewHTTPServer(ctx context.Context, cfg *v1beta1.GatewayConfigSpec, lg *zap.SugaredLogger, ...) *GatewayHTTPServer
  • func (s *GatewayHTTPServer) ListenAndServe(ctx waitctx.RestrictiveContext) error
• type GatewayOption
  • func WithLifecycler(lc config.Lifecycler) GatewayOption
• type GatewayOptions
• type MetricsEndpointHandler
  • func NewMetricsEndpointHandler(cfg v1beta1.MetricsSpec) *MetricsEndpointHandler
  • func (h *MetricsEndpointHandler) ListenAndServe(ctx context.Context) error
  • func (h *MetricsEndpointHandler) MustRegister(collectors ...prometheus.Collector)
• type StreamServer
  • func NewStreamServer(handler ConnectionHandler, lg *zap.SugaredLogger) *StreamServer
  • func (s *StreamServer) AddRemote(cc *grpc.ClientConn, services []*descriptorpb.ServiceDescriptorProto) error
  • func (s *StreamServer) Connect(stream streamv1.Stream_ConnectServer) error
  • func (s *StreamServer) RegisterService(desc *grpc.ServiceDesc, impl any)
• type UnaryService
  • func NewUnaryService() UnaryService
  • func (u *UnaryService) Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, ...) (interface{}, error)
  • func (u *UnaryService) RegisterUnaryPlugins(ctx waitctx.RestrictiveContext, s grpc.ServiceRegistrar, ...)
• type UnknownUnaryMetadata

Types

type ConnectionHandler

type ConnectionHandler interface {
	HandleAgentConnection(context.Context, agent.ClientSet)
}

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) ClusterHealthStatus

func (g *Gateway) ClusterHealthStatus(ref *corev1.Reference) (*corev1.HealthStatus, error)

Implements management.HealthStatusDataSource

func (*Gateway) ListenAndServe

func (g *Gateway) ListenAndServe(ctx context.Context) error

func (*Gateway) MustRegisterCollector

func (g *Gateway) MustRegisterCollector(collector prometheus.Collector)

func (*Gateway) StorageBackend

func (g *Gateway) StorageBackend() storage.Backend

Implements management.CoreDataSource

func (*Gateway) TLSConfig

func (g *Gateway) TLSConfig() *tls.Config

Implements management.CoreDataSource

type GatewayGRPCServer

type GatewayGRPCServer struct {
	streamv1.UnsafeStreamServer
	// contains filtered or unexported fields
}

func NewGRPCServer

func NewGRPCServer(
	cfg *v1beta1.GatewayConfigSpec,
	lg *zap.SugaredLogger,
	opts ...grpc.ServerOption,
) *GatewayGRPCServer

func (*GatewayGRPCServer) ListenAndServe

func (s *GatewayGRPCServer) ListenAndServe(ctx context.Context) error

func (*GatewayGRPCServer) RegisterService

func (s *GatewayGRPCServer) RegisterService(desc *grpc.ServiceDesc, impl any)

type GatewayHTTPServer

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

func NewHTTPServer

func NewHTTPServer(
	ctx context.Context,
	cfg *v1beta1.GatewayConfigSpec,
	lg *zap.SugaredLogger,
	pl plugins.LoaderInterface,
) *GatewayHTTPServer

func (*GatewayHTTPServer) ListenAndServe

func (s *GatewayHTTPServer) ListenAndServe(ctx waitctx.RestrictiveContext) error

type GatewayOption

type GatewayOption func(*GatewayOptions)

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) ListenAndServe

func (h *MetricsEndpointHandler) ListenAndServe(ctx context.Context) error

func (*MetricsEndpointHandler) MustRegister

func (h *MetricsEndpointHandler) MustRegister(collectors ...prometheus.Collector)

type StreamServer

type StreamServer struct {
	streamv1.UnsafeStreamServer
	// contains filtered or unexported fields
}

func NewStreamServer

func NewStreamServer(handler ConnectionHandler, lg *zap.SugaredLogger) *StreamServer

func (*StreamServer) AddRemote

func (s *StreamServer) AddRemote(cc *grpc.ClientConn, services []*descriptorpb.ServiceDescriptorProto) error

func (*StreamServer) Connect

func (s *StreamServer) Connect(stream streamv1.Stream_ConnectServer) error

func (*StreamServer) RegisterService

func (s *StreamServer) RegisterService(desc *grpc.ServiceDesc, impl any)

type UnaryService

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

func NewUnaryService

func NewUnaryService() UnaryService

func (*UnaryService) Handler

func (u *UnaryService) Handler(
	srv interface{},
	ctx context.Context,
	dec func(interface{}) error,
	interceptor grpc.UnaryServerInterceptor,
) (interface{}, error)

func (*UnaryService) RegisterUnaryPlugins

func (u *UnaryService) RegisterUnaryPlugins(ctx waitctx.RestrictiveContext, s grpc.ServiceRegistrar, pl plugins.LoaderInterface)

type UnknownUnaryMetadata

type UnknownUnaryMetadata struct {
	Conn       *grpc.ClientConn
	InputType  *desc.MessageDescriptor
	OutputType *desc.MessageDescriptor
}