pluginhostv1

package
v4.0.0 Latest Latest
Warning

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

 Go to latest Published: Jul 20, 2026 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ControlPackageHost_Dispatch_FullMethodName      = "/anix.pluginhost.v1.ControlPackageHost/Dispatch"
	ControlPackageHost_OpenWebSocket_FullMethodName = "/anix.pluginhost.v1.ControlPackageHost/OpenWebSocket"
	ControlPackageHost_Migrate_FullMethodName       = "/anix.pluginhost.v1.ControlPackageHost/Migrate"
	ControlPackageHost_Health_FullMethodName        = "/anix.pluginhost.v1.ControlPackageHost/Health"
	ControlPackageHost_Drain_FullMethodName         = "/anix.pluginhost.v1.ControlPackageHost/Drain"
)

Variables

View Source 
var ControlPackageHost_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "anix.pluginhost.v1.ControlPackageHost",
	HandlerType: (*ControlPackageHostServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Dispatch",
			Handler:    _ControlPackageHost_Dispatch_Handler,
		},
		{
			MethodName: "Migrate",
			Handler:    _ControlPackageHost_Migrate_Handler,
		},
		{
			MethodName: "Health",
			Handler:    _ControlPackageHost_Health_Handler,
		},
		{
			MethodName: "Drain",
			Handler:    _ControlPackageHost_Drain_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "OpenWebSocket",
			Handler:       _ControlPackageHost_OpenWebSocket_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "api/pluginhost/v1/control_host.proto",
}

ControlPackageHost_ServiceDesc is the grpc.ServiceDesc for ControlPackageHost service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_api_pluginhost_v1_control_host_proto protoreflect.FileDescriptor

Functions

func RegisterControlPackageHostServer 

func RegisterControlPackageHostServer(s grpc.ServiceRegistrar, srv ControlPackageHostServer)

Types

type ControlPackageHostClient 

type ControlPackageHostClient interface {
	Dispatch(ctx context.Context, in *DispatchRequest, opts ...grpc.CallOption) (*DispatchResponse, error)
	OpenWebSocket(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[WebSocketFrame, WebSocketFrame], error)
	Migrate(ctx context.Context, in *MigrationRequest, opts ...grpc.CallOption) (*MigrationResponse, error)
	Health(ctx context.Context, in *HealthRequest, opts ...grpc.CallOption) (*HealthResponse, error)
	Drain(ctx context.Context, in *DrainRequest, opts ...grpc.CallOption) (*DrainResponse, error)
}

ControlPackageHostClient is the client API for ControlPackageHost service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewControlPackageHostClient 

func NewControlPackageHostClient(cc grpc.ClientConnInterface) ControlPackageHostClient

type ControlPackageHostServer 

type ControlPackageHostServer interface {
	Dispatch(context.Context, *DispatchRequest) (*DispatchResponse, error)
	OpenWebSocket(grpc.BidiStreamingServer[WebSocketFrame, WebSocketFrame]) error
	Migrate(context.Context, *MigrationRequest) (*MigrationResponse, error)
	Health(context.Context, *HealthRequest) (*HealthResponse, error)
	Drain(context.Context, *DrainRequest) (*DrainResponse, error)
	// contains filtered or unexported methods
}

ControlPackageHostServer is the server API for ControlPackageHost service. All implementations must embed UnimplementedControlPackageHostServer for forward compatibility.

type ControlPackageHost_OpenWebSocketClient 

type ControlPackageHost_OpenWebSocketClient = grpc.BidiStreamingClient[WebSocketFrame, WebSocketFrame]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type ControlPackageHost_OpenWebSocketServer 

type ControlPackageHost_OpenWebSocketServer = grpc.BidiStreamingServer[WebSocketFrame, WebSocketFrame]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type DispatchRequest 

type DispatchRequest struct {
	PackageId           string `protobuf:"bytes,1,opt,name=package_id,json=packageId,proto3" json:"package_id,omitempty"`
	PackageVersion      string `protobuf:"bytes,2,opt,name=package_version,json=packageVersion,proto3" json:"package_version,omitempty"`
	RouteGeneration     uint64 `protobuf:"varint,3,opt,name=route_generation,json=routeGeneration,proto3" json:"route_generation,omitempty"`
	RequestId           string `protobuf:"bytes,4,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	IdempotencyKey      string `protobuf:"bytes,5,opt,name=idempotency_key,json=idempotencyKey,proto3" json:"idempotency_key,omitempty"`
	RouteId             string `protobuf:"bytes,6,opt,name=route_id,json=routeId,proto3" json:"route_id,omitempty"`
	Method              string `protobuf:"bytes,7,opt,name=method,proto3" json:"method,omitempty"`
	RequestBody         []byte `protobuf:"bytes,8,opt,name=request_body,json=requestBody,proto3" json:"request_body,omitempty"`
	PrincipalJson       []byte `protobuf:"bytes,9,opt,name=principal_json,json=principalJson,proto3" json:"principal_json,omitempty"`
	DeadlineUnixMillis  int64  `protobuf:"varint,10,opt,name=deadline_unix_millis,json=deadlineUnixMillis,proto3" json:"deadline_unix_millis,omitempty"`
	RequestMetadataJson []byte `protobuf:"bytes,11,opt,name=request_metadata_json,json=requestMetadataJson,proto3" json:"request_metadata_json,omitempty"`
	BridgeCapability    []byte `protobuf:"bytes,12,opt,name=bridge_capability,json=bridgeCapability,proto3" json:"bridge_capability,omitempty"`
	// contains filtered or unexported fields
}

func (*DispatchRequest) Descriptor deprecated 

func (*DispatchRequest) Descriptor() ([]byte, []int)

Deprecated: Use DispatchRequest.ProtoReflect.Descriptor instead.

func (*DispatchRequest) GetBridgeCapability 

func (x *DispatchRequest) GetBridgeCapability() []byte

func (*DispatchRequest) GetDeadlineUnixMillis 

func (x *DispatchRequest) GetDeadlineUnixMillis() int64

func (*DispatchRequest) GetIdempotencyKey 

func (x *DispatchRequest) GetIdempotencyKey() string

func (*DispatchRequest) GetMethod 

func (x *DispatchRequest) GetMethod() string

func (*DispatchRequest) GetPackageId 

func (x *DispatchRequest) GetPackageId() string

func (*DispatchRequest) GetPackageVersion 

func (x *DispatchRequest) GetPackageVersion() string

func (*DispatchRequest) GetPrincipalJson 

func (x *DispatchRequest) GetPrincipalJson() []byte

func (*DispatchRequest) GetRequestBody 

func (x *DispatchRequest) GetRequestBody() []byte

func (*DispatchRequest) GetRequestId 

func (x *DispatchRequest) GetRequestId() string

func (*DispatchRequest) GetRequestMetadataJson 

func (x *DispatchRequest) GetRequestMetadataJson() []byte

func (*DispatchRequest) GetRouteGeneration 

func (x *DispatchRequest) GetRouteGeneration() uint64

func (*DispatchRequest) GetRouteId 

func (x *DispatchRequest) GetRouteId() string

func (*DispatchRequest) ProtoMessage 

func (*DispatchRequest) ProtoMessage()

func (*DispatchRequest) ProtoReflect 

func (x *DispatchRequest) ProtoReflect() protoreflect.Message

func (*DispatchRequest) Reset 

func (x *DispatchRequest) Reset()

func (*DispatchRequest) String 

func (x *DispatchRequest) String() string

type DispatchResponse 

type DispatchResponse struct {
	StatusCode   uint32    `protobuf:"varint,1,opt,name=status_code,json=statusCode,proto3" json:"status_code,omitempty"`
	ResponseBody []byte    `protobuf:"bytes,2,opt,name=response_body,json=responseBody,proto3" json:"response_body,omitempty"`
	Headers      []*Header `protobuf:"bytes,3,rep,name=headers,proto3" json:"headers,omitempty"`
	OperationId  string    `protobuf:"bytes,4,opt,name=operation_id,json=operationId,proto3" json:"operation_id,omitempty"`
	FailureCode  string    `protobuf:"bytes,5,opt,name=failure_code,json=failureCode,proto3" json:"failure_code,omitempty"`
	// contains filtered or unexported fields
}

func (*DispatchResponse) Descriptor deprecated 

func (*DispatchResponse) Descriptor() ([]byte, []int)

Deprecated: Use DispatchResponse.ProtoReflect.Descriptor instead.

func (*DispatchResponse) GetFailureCode 

func (x *DispatchResponse) GetFailureCode() string

func (*DispatchResponse) GetHeaders 

func (x *DispatchResponse) GetHeaders() []*Header

func (*DispatchResponse) GetOperationId 

func (x *DispatchResponse) GetOperationId() string

func (*DispatchResponse) GetResponseBody 

func (x *DispatchResponse) GetResponseBody() []byte

func (*DispatchResponse) GetStatusCode 

func (x *DispatchResponse) GetStatusCode() uint32

func (*DispatchResponse) ProtoMessage 

func (*DispatchResponse) ProtoMessage()

func (*DispatchResponse) ProtoReflect 

func (x *DispatchResponse) ProtoReflect() protoreflect.Message

func (*DispatchResponse) Reset 

func (x *DispatchResponse) Reset()

func (*DispatchResponse) String 

func (x *DispatchResponse) String() string

type DrainRequest 

type DrainRequest struct {
	RouteGeneration    uint64 `protobuf:"varint,1,opt,name=route_generation,json=routeGeneration,proto3" json:"route_generation,omitempty"`
	DeadlineUnixMillis int64  `protobuf:"varint,2,opt,name=deadline_unix_millis,json=deadlineUnixMillis,proto3" json:"deadline_unix_millis,omitempty"`
	// contains filtered or unexported fields
}

func (*DrainRequest) Descriptor deprecated 

func (*DrainRequest) Descriptor() ([]byte, []int)

Deprecated: Use DrainRequest.ProtoReflect.Descriptor instead.

func (*DrainRequest) GetDeadlineUnixMillis 

func (x *DrainRequest) GetDeadlineUnixMillis() int64

func (*DrainRequest) GetRouteGeneration 

func (x *DrainRequest) GetRouteGeneration() uint64

func (*DrainRequest) ProtoMessage 

func (*DrainRequest) ProtoMessage()

func (*DrainRequest) ProtoReflect 

func (x *DrainRequest) ProtoReflect() protoreflect.Message

func (*DrainRequest) Reset 

func (x *DrainRequest) Reset()

func (*DrainRequest) String 

func (x *DrainRequest) String() string

type DrainResponse 

type DrainResponse struct {
	Drained  bool   `protobuf:"varint,1,opt,name=drained,proto3" json:"drained,omitempty"`
	InFlight uint64 `protobuf:"varint,2,opt,name=in_flight,json=inFlight,proto3" json:"in_flight,omitempty"`
	// contains filtered or unexported fields
}

func (*DrainResponse) Descriptor deprecated 

func (*DrainResponse) Descriptor() ([]byte, []int)

Deprecated: Use DrainResponse.ProtoReflect.Descriptor instead.

func (*DrainResponse) GetDrained 

func (x *DrainResponse) GetDrained() bool

func (*DrainResponse) GetInFlight 

func (x *DrainResponse) GetInFlight() uint64

func (*DrainResponse) ProtoMessage 

func (*DrainResponse) ProtoMessage()

func (*DrainResponse) ProtoReflect 

func (x *DrainResponse) ProtoReflect() protoreflect.Message

func (*DrainResponse) Reset 

func (x *DrainResponse) Reset()

func (*DrainResponse) String 

func (x *DrainResponse) String() string
type Header struct {
	Name  string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*Header) Descriptor deprecated 

func (*Header) Descriptor() ([]byte, []int)

Deprecated: Use Header.ProtoReflect.Descriptor instead.

func (*Header) GetName 

func (x *Header) GetName() string

func (*Header) GetValue 

func (x *Header) GetValue() string

func (*Header) ProtoMessage 

func (*Header) ProtoMessage()

func (*Header) ProtoReflect 

func (x *Header) ProtoReflect() protoreflect.Message

func (*Header) Reset 

func (x *Header) Reset()

func (*Header) String 

func (x *Header) String() string

type HealthRequest 

type HealthRequest struct {
	RouteGeneration uint64 `protobuf:"varint,1,opt,name=route_generation,json=routeGeneration,proto3" json:"route_generation,omitempty"`
	// contains filtered or unexported fields
}

func (*HealthRequest) Descriptor deprecated 

func (*HealthRequest) Descriptor() ([]byte, []int)

Deprecated: Use HealthRequest.ProtoReflect.Descriptor instead.

func (*HealthRequest) GetRouteGeneration 

func (x *HealthRequest) GetRouteGeneration() uint64

func (*HealthRequest) ProtoMessage 

func (*HealthRequest) ProtoMessage()

func (*HealthRequest) ProtoReflect 

func (x *HealthRequest) ProtoReflect() protoreflect.Message

func (*HealthRequest) Reset 

func (x *HealthRequest) Reset()

func (*HealthRequest) String 

func (x *HealthRequest) String() string

type HealthResponse 

type HealthResponse struct {
	Healthy     bool   `protobuf:"varint,1,opt,name=healthy,proto3" json:"healthy,omitempty"`
	LeaseId     string `protobuf:"bytes,2,opt,name=lease_id,json=leaseId,proto3" json:"lease_id,omitempty"`
	DetailsJson string `protobuf:"bytes,3,opt,name=details_json,json=detailsJson,proto3" json:"details_json,omitempty"`
	// contains filtered or unexported fields
}

func (*HealthResponse) Descriptor deprecated 

func (*HealthResponse) Descriptor() ([]byte, []int)

Deprecated: Use HealthResponse.ProtoReflect.Descriptor instead.

func (*HealthResponse) GetDetailsJson 

func (x *HealthResponse) GetDetailsJson() string

func (*HealthResponse) GetHealthy 

func (x *HealthResponse) GetHealthy() bool

func (*HealthResponse) GetLeaseId 

func (x *HealthResponse) GetLeaseId() string

func (*HealthResponse) ProtoMessage 

func (*HealthResponse) ProtoMessage()

func (*HealthResponse) ProtoReflect 

func (x *HealthResponse) ProtoReflect() protoreflect.Message

func (*HealthResponse) Reset 

func (x *HealthResponse) Reset()

func (*HealthResponse) String 

func (x *HealthResponse) String() string

type MigrationRequest 

type MigrationRequest struct {
	PackageId          string `protobuf:"bytes,1,opt,name=package_id,json=packageId,proto3" json:"package_id,omitempty"`
	PackageVersion     string `protobuf:"bytes,2,opt,name=package_version,json=packageVersion,proto3" json:"package_version,omitempty"`
	MigrationId        string `protobuf:"bytes,3,opt,name=migration_id,json=migrationId,proto3" json:"migration_id,omitempty"`
	Checkpoint         string `protobuf:"bytes,4,opt,name=checkpoint,proto3" json:"checkpoint,omitempty"`
	RouteGeneration    uint64 `protobuf:"varint,5,opt,name=route_generation,json=routeGeneration,proto3" json:"route_generation,omitempty"`
	BridgeCapability   []byte `protobuf:"bytes,6,opt,name=bridge_capability,json=bridgeCapability,proto3" json:"bridge_capability,omitempty"`
	DeadlineUnixMillis int64  `protobuf:"varint,7,opt,name=deadline_unix_millis,json=deadlineUnixMillis,proto3" json:"deadline_unix_millis,omitempty"`
	// contains filtered or unexported fields
}

func (*MigrationRequest) Descriptor deprecated 

func (*MigrationRequest) Descriptor() ([]byte, []int)

Deprecated: Use MigrationRequest.ProtoReflect.Descriptor instead.

func (*MigrationRequest) GetBridgeCapability 

func (x *MigrationRequest) GetBridgeCapability() []byte

func (*MigrationRequest) GetCheckpoint 

func (x *MigrationRequest) GetCheckpoint() string

func (*MigrationRequest) GetDeadlineUnixMillis 

func (x *MigrationRequest) GetDeadlineUnixMillis() int64

func (*MigrationRequest) GetMigrationId 

func (x *MigrationRequest) GetMigrationId() string

func (*MigrationRequest) GetPackageId 

func (x *MigrationRequest) GetPackageId() string

func (*MigrationRequest) GetPackageVersion 

func (x *MigrationRequest) GetPackageVersion() string

func (*MigrationRequest) GetRouteGeneration 

func (x *MigrationRequest) GetRouteGeneration() uint64

func (*MigrationRequest) ProtoMessage 

func (*MigrationRequest) ProtoMessage()

func (*MigrationRequest) ProtoReflect 

func (x *MigrationRequest) ProtoReflect() protoreflect.Message

func (*MigrationRequest) Reset 

func (x *MigrationRequest) Reset()

func (*MigrationRequest) String 

func (x *MigrationRequest) String() string

type MigrationResponse 

type MigrationResponse struct {
	Checkpoint       string `protobuf:"bytes,1,opt,name=checkpoint,proto3" json:"checkpoint,omitempty"`
	ValidationDigest string `protobuf:"bytes,2,opt,name=validation_digest,json=validationDigest,proto3" json:"validation_digest,omitempty"`
	Complete         bool   `protobuf:"varint,3,opt,name=complete,proto3" json:"complete,omitempty"`
	FailureCode      string `protobuf:"bytes,4,opt,name=failure_code,json=failureCode,proto3" json:"failure_code,omitempty"`
	// contains filtered or unexported fields
}

func (*MigrationResponse) Descriptor deprecated 

func (*MigrationResponse) Descriptor() ([]byte, []int)

Deprecated: Use MigrationResponse.ProtoReflect.Descriptor instead.

func (*MigrationResponse) GetCheckpoint 

func (x *MigrationResponse) GetCheckpoint() string

func (*MigrationResponse) GetComplete 

func (x *MigrationResponse) GetComplete() bool

func (*MigrationResponse) GetFailureCode 

func (x *MigrationResponse) GetFailureCode() string

func (*MigrationResponse) GetValidationDigest 

func (x *MigrationResponse) GetValidationDigest() string

func (*MigrationResponse) ProtoMessage 

func (*MigrationResponse) ProtoMessage()

func (*MigrationResponse) ProtoReflect 

func (x *MigrationResponse) ProtoReflect() protoreflect.Message

func (*MigrationResponse) Reset 

func (x *MigrationResponse) Reset()

func (*MigrationResponse) String 

func (x *MigrationResponse) String() string

type UnimplementedControlPackageHostServer 

type UnimplementedControlPackageHostServer struct{}

UnimplementedControlPackageHostServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedControlPackageHostServer) Dispatch 

func (UnimplementedControlPackageHostServer) Dispatch(context.Context, *DispatchRequest) (*DispatchResponse, error)

func (UnimplementedControlPackageHostServer) Drain 

func (UnimplementedControlPackageHostServer) Drain(context.Context, *DrainRequest) (*DrainResponse, error)

func (UnimplementedControlPackageHostServer) Health 

func (UnimplementedControlPackageHostServer) Health(context.Context, *HealthRequest) (*HealthResponse, error)

func (UnimplementedControlPackageHostServer) Migrate 

func (UnimplementedControlPackageHostServer) Migrate(context.Context, *MigrationRequest) (*MigrationResponse, error)

func (UnimplementedControlPackageHostServer) OpenWebSocket 

func (UnimplementedControlPackageHostServer) OpenWebSocket(grpc.BidiStreamingServer[WebSocketFrame, WebSocketFrame]) error

type UnsafeControlPackageHostServer 

type UnsafeControlPackageHostServer interface {
	// contains filtered or unexported methods
}

UnsafeControlPackageHostServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ControlPackageHostServer will result in compilation errors.

type WebSocketClose 

type WebSocketClose struct {
	Code   uint32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

func (*WebSocketClose) Descriptor deprecated 

func (*WebSocketClose) Descriptor() ([]byte, []int)

Deprecated: Use WebSocketClose.ProtoReflect.Descriptor instead.

func (*WebSocketClose) GetCode 

func (x *WebSocketClose) GetCode() uint32

func (*WebSocketClose) GetReason 

func (x *WebSocketClose) GetReason() string

func (*WebSocketClose) ProtoMessage 

func (*WebSocketClose) ProtoMessage()

func (*WebSocketClose) ProtoReflect 

func (x *WebSocketClose) ProtoReflect() protoreflect.Message

func (*WebSocketClose) Reset 

func (x *WebSocketClose) Reset()

func (*WebSocketClose) String 

func (x *WebSocketClose) String() string

type WebSocketFrame 

type WebSocketFrame struct {

	// Types that are valid to be assigned to Value:
	//
	//	*WebSocketFrame_Open
	//	*WebSocketFrame_Data
	//	*WebSocketFrame_Close
	Value isWebSocketFrame_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

func (*WebSocketFrame) Descriptor deprecated 

func (*WebSocketFrame) Descriptor() ([]byte, []int)

Deprecated: Use WebSocketFrame.ProtoReflect.Descriptor instead.

func (*WebSocketFrame) GetClose 

func (x *WebSocketFrame) GetClose() *WebSocketClose

func (*WebSocketFrame) GetData 

func (x *WebSocketFrame) GetData() []byte

func (*WebSocketFrame) GetOpen 

func (x *WebSocketFrame) GetOpen() *WebSocketOpen

func (*WebSocketFrame) GetValue 

func (x *WebSocketFrame) GetValue() isWebSocketFrame_Value

func (*WebSocketFrame) ProtoMessage 

func (*WebSocketFrame) ProtoMessage()

func (*WebSocketFrame) ProtoReflect 

func (x *WebSocketFrame) ProtoReflect() protoreflect.Message

func (*WebSocketFrame) Reset 

func (x *WebSocketFrame) Reset()

func (*WebSocketFrame) String 

func (x *WebSocketFrame) String() string

type WebSocketFrame_Close 

type WebSocketFrame_Close struct {
	Close *WebSocketClose `protobuf:"bytes,3,opt,name=close,proto3,oneof"`
}

type WebSocketFrame_Data 

type WebSocketFrame_Data struct {
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3,oneof"`
}

type WebSocketFrame_Open 

type WebSocketFrame_Open struct {
	Open *WebSocketOpen `protobuf:"bytes,1,opt,name=open,proto3,oneof"`
}

type WebSocketOpen 

type WebSocketOpen struct {
	PackageId           string `protobuf:"bytes,1,opt,name=package_id,json=packageId,proto3" json:"package_id,omitempty"`
	PackageVersion      string `protobuf:"bytes,2,opt,name=package_version,json=packageVersion,proto3" json:"package_version,omitempty"`
	RouteGeneration     uint64 `protobuf:"varint,3,opt,name=route_generation,json=routeGeneration,proto3" json:"route_generation,omitempty"`
	RouteId             string `protobuf:"bytes,4,opt,name=route_id,json=routeId,proto3" json:"route_id,omitempty"`
	PrincipalJson       []byte `protobuf:"bytes,5,opt,name=principal_json,json=principalJson,proto3" json:"principal_json,omitempty"`
	RequestId           string `protobuf:"bytes,6,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	IdempotencyKey      string `protobuf:"bytes,7,opt,name=idempotency_key,json=idempotencyKey,proto3" json:"idempotency_key,omitempty"`
	DeadlineUnixMillis  int64  `protobuf:"varint,8,opt,name=deadline_unix_millis,json=deadlineUnixMillis,proto3" json:"deadline_unix_millis,omitempty"`
	RequestMetadataJson []byte `protobuf:"bytes,9,opt,name=request_metadata_json,json=requestMetadataJson,proto3" json:"request_metadata_json,omitempty"`
	BridgeCapability    []byte `protobuf:"bytes,10,opt,name=bridge_capability,json=bridgeCapability,proto3" json:"bridge_capability,omitempty"`
	// contains filtered or unexported fields
}

func (*WebSocketOpen) Descriptor deprecated 

func (*WebSocketOpen) Descriptor() ([]byte, []int)

Deprecated: Use WebSocketOpen.ProtoReflect.Descriptor instead.

func (*WebSocketOpen) GetBridgeCapability 

func (x *WebSocketOpen) GetBridgeCapability() []byte

func (*WebSocketOpen) GetDeadlineUnixMillis 

func (x *WebSocketOpen) GetDeadlineUnixMillis() int64

func (*WebSocketOpen) GetIdempotencyKey 

func (x *WebSocketOpen) GetIdempotencyKey() string

func (*WebSocketOpen) GetPackageId 

func (x *WebSocketOpen) GetPackageId() string

func (*WebSocketOpen) GetPackageVersion 

func (x *WebSocketOpen) GetPackageVersion() string

func (*WebSocketOpen) GetPrincipalJson 

func (x *WebSocketOpen) GetPrincipalJson() []byte

func (*WebSocketOpen) GetRequestId 

func (x *WebSocketOpen) GetRequestId() string

func (*WebSocketOpen) GetRequestMetadataJson 

func (x *WebSocketOpen) GetRequestMetadataJson() []byte

func (*WebSocketOpen) GetRouteGeneration 

func (x *WebSocketOpen) GetRouteGeneration() uint64

func (*WebSocketOpen) GetRouteId 

func (x *WebSocketOpen) GetRouteId() string

func (*WebSocketOpen) ProtoMessage 

func (*WebSocketOpen) ProtoMessage()

func (*WebSocketOpen) ProtoReflect 

func (x *WebSocketOpen) ProtoReflect() protoreflect.Message

func (*WebSocketOpen) Reset 

func (x *WebSocketOpen) Reset()

func (*WebSocketOpen) String 

func (x *WebSocketOpen) String() string

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.