Versions in this module Expand all Collapse all v4 v4.0.0 Jul 20, 2026 Changes in this version + const ControlPackageHost_Dispatch_FullMethodName + const ControlPackageHost_Drain_FullMethodName + const ControlPackageHost_Health_FullMethodName + const ControlPackageHost_Migrate_FullMethodName + const ControlPackageHost_OpenWebSocket_FullMethodName + var ControlPackageHost_ServiceDesc = grpc.ServiceDesc + var File_api_pluginhost_v1_control_host_proto protoreflect.FileDescriptor + func RegisterControlPackageHostServer(s grpc.ServiceRegistrar, srv ControlPackageHostServer) + type ControlPackageHostClient interface + Dispatch func(ctx context.Context, in *DispatchRequest, opts ...grpc.CallOption) (*DispatchResponse, error) + Drain func(ctx context.Context, in *DrainRequest, opts ...grpc.CallOption) (*DrainResponse, error) + Health func(ctx context.Context, in *HealthRequest, opts ...grpc.CallOption) (*HealthResponse, error) + Migrate func(ctx context.Context, in *MigrationRequest, opts ...grpc.CallOption) (*MigrationResponse, error) + OpenWebSocket func(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[WebSocketFrame, WebSocketFrame], error) + func NewControlPackageHostClient(cc grpc.ClientConnInterface) ControlPackageHostClient + type ControlPackageHostServer interface + Dispatch func(context.Context, *DispatchRequest) (*DispatchResponse, error) + Drain func(context.Context, *DrainRequest) (*DrainResponse, error) + Health func(context.Context, *HealthRequest) (*HealthResponse, error) + Migrate func(context.Context, *MigrationRequest) (*MigrationResponse, error) + OpenWebSocket func(grpc.BidiStreamingServer[WebSocketFrame, WebSocketFrame]) error + type ControlPackageHost_OpenWebSocketClient = grpc.BidiStreamingClient[WebSocketFrame, WebSocketFrame] + type ControlPackageHost_OpenWebSocketServer = grpc.BidiStreamingServer[WebSocketFrame, WebSocketFrame] + type DispatchRequest struct + BridgeCapability []byte + DeadlineUnixMillis int64 + IdempotencyKey string + Method string + PackageId string + PackageVersion string + PrincipalJson []byte + RequestBody []byte + RequestId string + RequestMetadataJson []byte + RouteGeneration uint64 + RouteId string + func (*DispatchRequest) Descriptor() ([]byte, []int) + func (*DispatchRequest) ProtoMessage() + func (x *DispatchRequest) GetBridgeCapability() []byte + func (x *DispatchRequest) GetDeadlineUnixMillis() int64 + func (x *DispatchRequest) GetIdempotencyKey() string + func (x *DispatchRequest) GetMethod() string + func (x *DispatchRequest) GetPackageId() string + func (x *DispatchRequest) GetPackageVersion() string + func (x *DispatchRequest) GetPrincipalJson() []byte + func (x *DispatchRequest) GetRequestBody() []byte + func (x *DispatchRequest) GetRequestId() string + func (x *DispatchRequest) GetRequestMetadataJson() []byte + func (x *DispatchRequest) GetRouteGeneration() uint64 + func (x *DispatchRequest) GetRouteId() string + func (x *DispatchRequest) ProtoReflect() protoreflect.Message + func (x *DispatchRequest) Reset() + func (x *DispatchRequest) String() string + type DispatchResponse struct + FailureCode string + Headers []*Header + OperationId string + ResponseBody []byte + StatusCode uint32 + func (*DispatchResponse) Descriptor() ([]byte, []int) + func (*DispatchResponse) ProtoMessage() + func (x *DispatchResponse) GetFailureCode() string + func (x *DispatchResponse) GetHeaders() []*Header + func (x *DispatchResponse) GetOperationId() string + func (x *DispatchResponse) GetResponseBody() []byte + func (x *DispatchResponse) GetStatusCode() uint32 + func (x *DispatchResponse) ProtoReflect() protoreflect.Message + func (x *DispatchResponse) Reset() + func (x *DispatchResponse) String() string + type DrainRequest struct + DeadlineUnixMillis int64 + RouteGeneration uint64 + func (*DrainRequest) Descriptor() ([]byte, []int) + func (*DrainRequest) ProtoMessage() + func (x *DrainRequest) GetDeadlineUnixMillis() int64 + func (x *DrainRequest) GetRouteGeneration() uint64 + func (x *DrainRequest) ProtoReflect() protoreflect.Message + func (x *DrainRequest) Reset() + func (x *DrainRequest) String() string + type DrainResponse struct + Drained bool + InFlight uint64 + func (*DrainResponse) Descriptor() ([]byte, []int) + func (*DrainResponse) ProtoMessage() + func (x *DrainResponse) GetDrained() bool + func (x *DrainResponse) GetInFlight() uint64 + func (x *DrainResponse) ProtoReflect() protoreflect.Message + func (x *DrainResponse) Reset() + func (x *DrainResponse) String() string + type Header struct + Name string + Value string + func (*Header) Descriptor() ([]byte, []int) + func (*Header) ProtoMessage() + func (x *Header) GetName() string + func (x *Header) GetValue() string + func (x *Header) ProtoReflect() protoreflect.Message + func (x *Header) Reset() + func (x *Header) String() string + type HealthRequest struct + RouteGeneration uint64 + func (*HealthRequest) Descriptor() ([]byte, []int) + func (*HealthRequest) ProtoMessage() + func (x *HealthRequest) GetRouteGeneration() uint64 + func (x *HealthRequest) ProtoReflect() protoreflect.Message + func (x *HealthRequest) Reset() + func (x *HealthRequest) String() string + type HealthResponse struct + DetailsJson string + Healthy bool + LeaseId string + func (*HealthResponse) Descriptor() ([]byte, []int) + func (*HealthResponse) ProtoMessage() + func (x *HealthResponse) GetDetailsJson() string + func (x *HealthResponse) GetHealthy() bool + func (x *HealthResponse) GetLeaseId() string + func (x *HealthResponse) ProtoReflect() protoreflect.Message + func (x *HealthResponse) Reset() + func (x *HealthResponse) String() string + type MigrationRequest struct + BridgeCapability []byte + Checkpoint string + DeadlineUnixMillis int64 + MigrationId string + PackageId string + PackageVersion string + RouteGeneration uint64 + func (*MigrationRequest) Descriptor() ([]byte, []int) + func (*MigrationRequest) ProtoMessage() + func (x *MigrationRequest) GetBridgeCapability() []byte + func (x *MigrationRequest) GetCheckpoint() string + func (x *MigrationRequest) GetDeadlineUnixMillis() int64 + func (x *MigrationRequest) GetMigrationId() string + func (x *MigrationRequest) GetPackageId() string + func (x *MigrationRequest) GetPackageVersion() string + func (x *MigrationRequest) GetRouteGeneration() uint64 + func (x *MigrationRequest) ProtoReflect() protoreflect.Message + func (x *MigrationRequest) Reset() + func (x *MigrationRequest) String() string + type MigrationResponse struct + Checkpoint string + Complete bool + FailureCode string + ValidationDigest string + func (*MigrationResponse) Descriptor() ([]byte, []int) + func (*MigrationResponse) ProtoMessage() + func (x *MigrationResponse) GetCheckpoint() string + func (x *MigrationResponse) GetComplete() bool + func (x *MigrationResponse) GetFailureCode() string + func (x *MigrationResponse) GetValidationDigest() string + func (x *MigrationResponse) ProtoReflect() protoreflect.Message + func (x *MigrationResponse) Reset() + func (x *MigrationResponse) String() string + type UnimplementedControlPackageHostServer struct + func (UnimplementedControlPackageHostServer) Dispatch(context.Context, *DispatchRequest) (*DispatchResponse, error) + func (UnimplementedControlPackageHostServer) Drain(context.Context, *DrainRequest) (*DrainResponse, error) + func (UnimplementedControlPackageHostServer) Health(context.Context, *HealthRequest) (*HealthResponse, error) + func (UnimplementedControlPackageHostServer) Migrate(context.Context, *MigrationRequest) (*MigrationResponse, error) + func (UnimplementedControlPackageHostServer) OpenWebSocket(grpc.BidiStreamingServer[WebSocketFrame, WebSocketFrame]) error + type UnsafeControlPackageHostServer interface + type WebSocketClose struct + Code uint32 + Reason string + func (*WebSocketClose) Descriptor() ([]byte, []int) + func (*WebSocketClose) ProtoMessage() + func (x *WebSocketClose) GetCode() uint32 + func (x *WebSocketClose) GetReason() string + func (x *WebSocketClose) ProtoReflect() protoreflect.Message + func (x *WebSocketClose) Reset() + func (x *WebSocketClose) String() string + type WebSocketFrame struct + Value isWebSocketFrame_Value + func (*WebSocketFrame) Descriptor() ([]byte, []int) + func (*WebSocketFrame) ProtoMessage() + func (x *WebSocketFrame) GetClose() *WebSocketClose + func (x *WebSocketFrame) GetData() []byte + func (x *WebSocketFrame) GetOpen() *WebSocketOpen + func (x *WebSocketFrame) GetValue() isWebSocketFrame_Value + func (x *WebSocketFrame) ProtoReflect() protoreflect.Message + func (x *WebSocketFrame) Reset() + func (x *WebSocketFrame) String() string + type WebSocketFrame_Close struct + Close *WebSocketClose + type WebSocketFrame_Data struct + Data []byte + type WebSocketFrame_Open struct + Open *WebSocketOpen + type WebSocketOpen struct + BridgeCapability []byte + DeadlineUnixMillis int64 + IdempotencyKey string + PackageId string + PackageVersion string + PrincipalJson []byte + RequestId string + RequestMetadataJson []byte + RouteGeneration uint64 + RouteId string + func (*WebSocketOpen) Descriptor() ([]byte, []int) + func (*WebSocketOpen) ProtoMessage() + func (x *WebSocketOpen) GetBridgeCapability() []byte + func (x *WebSocketOpen) GetDeadlineUnixMillis() int64 + func (x *WebSocketOpen) GetIdempotencyKey() string + func (x *WebSocketOpen) GetPackageId() string + func (x *WebSocketOpen) GetPackageVersion() string + func (x *WebSocketOpen) GetPrincipalJson() []byte + func (x *WebSocketOpen) GetRequestId() string + func (x *WebSocketOpen) GetRequestMetadataJson() []byte + func (x *WebSocketOpen) GetRouteGeneration() uint64 + func (x *WebSocketOpen) GetRouteId() string + func (x *WebSocketOpen) ProtoReflect() protoreflect.Message + func (x *WebSocketOpen) Reset() + func (x *WebSocketOpen) String() string
Go to main page