Versions in this module Expand all Collapse all v4 v4.0.0 Jul 20, 2026 Changes in this version + const DefaultMaxResponseBytes + type DispatchRequest struct + BridgeCapability []byte + DeadlineUnixMillis int64 + IdempotencyKey string + Metadata RequestMetadata + Method string + PackageID string + PackageVersion string + PrincipalJSON []byte + RequestBody []byte + RequestID string + RouteGeneration uint64 + RouteID string + type DispatchResponse struct + FailureCode string + Headers []Header + OperationID string + ResponseBody []byte + StatusCode uint32 + type DrainResponse struct + Drained bool + InFlight uint64 + type Header struct + Name string + Value string + type HealthResponse struct + DetailsJSON string + Healthy bool + LeaseID string + type MigrationRequest struct + BridgeCapability []byte + Checkpoint string + DeadlineUnixMillis int64 + MigrationID string + PackageID string + PackageVersion string + RouteGeneration uint64 + type MigrationResponse struct + Checkpoint string + Complete bool + FailureCode string + ValidationDigest string + type Package interface + Dispatch func(context.Context, DispatchRequest) (DispatchResponse, error) + Drain func(context.Context) (DrainResponse, error) + Health func(context.Context) (HealthResponse, error) + Migrate func(context.Context, MigrationRequest) (MigrationResponse, error) + type RequestMetadata struct + ClientIP string + Headers map[string][]string + NodeID uint + Path string + PathParams map[string]string + Query map[string][]string + TrustedAgentWebSocketAuth bool + TrustedAgentWebSocketForwardNode bool + UserAgent string + type Server struct + func NewServer(config ServerConfig, packageImpl Package) (*Server, error) + func (s *Server) Dispatch(ctx context.Context, request *pluginhostv1.DispatchRequest) (*pluginhostv1.DispatchResponse, error) + func (s *Server) Drain(ctx context.Context, request *pluginhostv1.DrainRequest) (*pluginhostv1.DrainResponse, error) + func (s *Server) Health(ctx context.Context, request *pluginhostv1.HealthRequest) (*pluginhostv1.HealthResponse, error) + func (s *Server) Migrate(ctx context.Context, request *pluginhostv1.MigrationRequest) (*pluginhostv1.MigrationResponse, error) + func (s *Server) OpenWebSocket(stream pluginhostv1.ControlPackageHost_OpenWebSocketServer) error + type ServerConfig struct + MaxResponseBytes int + PackageID string + PackageVersion string + type WebSocketClose struct + Code uint32 + Reason string + type WebSocketFrame struct + Close *WebSocketClose + Data []byte + type WebSocketOpen struct + BridgeCapability []byte + DeadlineUnixMillis int64 + IdempotencyKey string + Metadata RequestMetadata + PackageID string + PackageVersion string + PrincipalJSON []byte + RequestID string + RouteGeneration uint64 + RouteID string + type WebSocketPackage interface + OpenWebSocket func(context.Context, WebSocketOpen, WebSocketStream) error + type WebSocketStream interface + Recv func() (WebSocketFrame, error) + Send func(WebSocketFrame) error
Go to main page