packagebridgev1

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 (
	KernelPackageBridge_Invoke_FullMethodName        = "/anixops.packagebridge.v1.KernelPackageBridge/Invoke"
	KernelPackageBridge_OpenWebSocket_FullMethodName = "/anixops.packagebridge.v1.KernelPackageBridge/OpenWebSocket"
)

Variables

View Source 
var File_api_packagebridge_v1_package_bridge_proto protoreflect.FileDescriptor
View Source 
var KernelPackageBridge_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "anixops.packagebridge.v1.KernelPackageBridge",
	HandlerType: (*KernelPackageBridgeServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Invoke",
			Handler:    _KernelPackageBridge_Invoke_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "OpenWebSocket",
			Handler:       _KernelPackageBridge_OpenWebSocket_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "api/packagebridge/v1/package_bridge.proto",
}

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

Functions

func RegisterKernelPackageBridgeServer 

func RegisterKernelPackageBridgeServer(s grpc.ServiceRegistrar, srv KernelPackageBridgeServer)

Types

type InvokeRequest 

type InvokeRequest struct {
	Capability []byte `protobuf:"bytes,1,opt,name=capability,proto3" json:"capability,omitempty"`
	Operation  string `protobuf:"bytes,2,opt,name=operation,proto3" json:"operation,omitempty"`
	Payload    []byte `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

func (*InvokeRequest) Descriptor deprecated 

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

Deprecated: Use InvokeRequest.ProtoReflect.Descriptor instead.

func (*InvokeRequest) GetCapability 

func (x *InvokeRequest) GetCapability() []byte

func (*InvokeRequest) GetOperation 

func (x *InvokeRequest) GetOperation() string

func (*InvokeRequest) GetPayload 

func (x *InvokeRequest) GetPayload() []byte

func (*InvokeRequest) ProtoMessage 

func (*InvokeRequest) ProtoMessage()

func (*InvokeRequest) ProtoReflect 

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

func (*InvokeRequest) Reset 

func (x *InvokeRequest) Reset()

func (*InvokeRequest) String 

func (x *InvokeRequest) String() string

type InvokeResponse 

type InvokeResponse struct {
	ResponseBody []byte            `protobuf:"bytes,1,opt,name=response_body,json=responseBody,proto3" json:"response_body,omitempty"`
	StatusCode   uint32            `protobuf:"varint,2,opt,name=status_code,json=statusCode,proto3" json:"status_code,omitempty"`
	Headers      []*ResponseHeader `protobuf:"bytes,3,rep,name=headers,proto3" json:"headers,omitempty"`
	// contains filtered or unexported fields
}

func (*InvokeResponse) Descriptor deprecated 

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

Deprecated: Use InvokeResponse.ProtoReflect.Descriptor instead.

func (*InvokeResponse) GetHeaders 

func (x *InvokeResponse) GetHeaders() []*ResponseHeader

func (*InvokeResponse) GetResponseBody 

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

func (*InvokeResponse) GetStatusCode 

func (x *InvokeResponse) GetStatusCode() uint32

func (*InvokeResponse) ProtoMessage 

func (*InvokeResponse) ProtoMessage()

func (*InvokeResponse) ProtoReflect 

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

func (*InvokeResponse) Reset 

func (x *InvokeResponse) Reset()

func (*InvokeResponse) String 

func (x *InvokeResponse) String() string

type KernelPackageBridgeClient 

type KernelPackageBridgeClient interface {
	Invoke(ctx context.Context, in *InvokeRequest, opts ...grpc.CallOption) (*InvokeResponse, error)
	OpenWebSocket(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[WebSocketFrame, WebSocketFrame], error)
}

KernelPackageBridgeClient is the client API for KernelPackageBridge 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.

KernelPackageBridge is a private, per-host channel. It exposes named kernel operations only; package hosts never receive database or signing credentials.

func NewKernelPackageBridgeClient 

func NewKernelPackageBridgeClient(cc grpc.ClientConnInterface) KernelPackageBridgeClient

type KernelPackageBridgeServer 

type KernelPackageBridgeServer interface {
	Invoke(context.Context, *InvokeRequest) (*InvokeResponse, error)
	OpenWebSocket(grpc.BidiStreamingServer[WebSocketFrame, WebSocketFrame]) error
	// contains filtered or unexported methods
}

KernelPackageBridgeServer is the server API for KernelPackageBridge service. All implementations must embed UnimplementedKernelPackageBridgeServer for forward compatibility.

KernelPackageBridge is a private, per-host channel. It exposes named kernel operations only; package hosts never receive database or signing credentials.

type KernelPackageBridge_OpenWebSocketClient 

type KernelPackageBridge_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 KernelPackageBridge_OpenWebSocketServer 

type KernelPackageBridge_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 ResponseHeader 

type ResponseHeader 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 (*ResponseHeader) Descriptor deprecated 

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

Deprecated: Use ResponseHeader.ProtoReflect.Descriptor instead.

func (*ResponseHeader) GetName 

func (x *ResponseHeader) GetName() string

func (*ResponseHeader) GetValue 

func (x *ResponseHeader) GetValue() string

func (*ResponseHeader) ProtoMessage 

func (*ResponseHeader) ProtoMessage()

func (*ResponseHeader) ProtoReflect 

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

func (*ResponseHeader) Reset 

func (x *ResponseHeader) Reset()

func (*ResponseHeader) String 

func (x *ResponseHeader) String() string

type UnimplementedKernelPackageBridgeServer 

type UnimplementedKernelPackageBridgeServer struct{}

UnimplementedKernelPackageBridgeServer 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 (UnimplementedKernelPackageBridgeServer) Invoke 

func (UnimplementedKernelPackageBridgeServer) Invoke(context.Context, *InvokeRequest) (*InvokeResponse, error)

func (UnimplementedKernelPackageBridgeServer) OpenWebSocket 

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

type UnsafeKernelPackageBridgeServer 

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

UnsafeKernelPackageBridgeServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to KernelPackageBridgeServer 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
}

WebSocketFrame is available only on the private inherited bridge. The first client frame must be an open frame; every later frame is data or close.

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 {
	Capability []byte `protobuf:"bytes,1,opt,name=capability,proto3" json:"capability,omitempty"`
	Operation  string `protobuf:"bytes,2,opt,name=operation,proto3" json:"operation,omitempty"`
	// contains filtered or unexported fields
}

func (*WebSocketOpen) Descriptor deprecated 

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

Deprecated: Use WebSocketOpen.ProtoReflect.Descriptor instead.

func (*WebSocketOpen) GetCapability 

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

func (*WebSocketOpen) GetOperation 

func (x *WebSocketOpen) GetOperation() 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.