Versions in this module Expand all Collapse all v1 v1.7.0 Feb 26, 2026 Changes in this version + const GRPCBroker_StartStream_FullMethodName + const GRPCController_Shutdown_FullMethodName + const GRPCStdio_StreamStdio_FullMethodName + var File_internal_plugin_grpc_broker_proto protoreflect.FileDescriptor + var File_internal_plugin_grpc_controller_proto protoreflect.FileDescriptor + var File_internal_plugin_grpc_stdio_proto protoreflect.FileDescriptor + var GRPCBroker_ServiceDesc = grpc.ServiceDesc + var GRPCController_ServiceDesc = grpc.ServiceDesc + var GRPCStdio_ServiceDesc = grpc.ServiceDesc + var StdioData_Channel_name = map[int32]string + var StdioData_Channel_value = map[string]int32 + func RegisterGRPCBrokerServer(s grpc.ServiceRegistrar, srv GRPCBrokerServer) + func RegisterGRPCControllerServer(s grpc.ServiceRegistrar, srv GRPCControllerServer) + func RegisterGRPCStdioServer(s grpc.ServiceRegistrar, srv GRPCStdioServer) + type ConnInfo struct + Address string + Knock *ConnInfo_Knock + Network string + ServiceId uint32 + func (*ConnInfo) Descriptor() ([]byte, []int) + func (*ConnInfo) ProtoMessage() + func (x *ConnInfo) GetAddress() string + func (x *ConnInfo) GetKnock() *ConnInfo_Knock + func (x *ConnInfo) GetNetwork() string + func (x *ConnInfo) GetServiceId() uint32 + func (x *ConnInfo) ProtoReflect() protoreflect.Message + func (x *ConnInfo) Reset() + func (x *ConnInfo) String() string + type ConnInfo_Knock struct + Ack bool + Error string + Knock bool + func (*ConnInfo_Knock) Descriptor() ([]byte, []int) + func (*ConnInfo_Knock) ProtoMessage() + func (x *ConnInfo_Knock) GetAck() bool + func (x *ConnInfo_Knock) GetError() string + func (x *ConnInfo_Knock) GetKnock() bool + func (x *ConnInfo_Knock) ProtoReflect() protoreflect.Message + func (x *ConnInfo_Knock) Reset() + func (x *ConnInfo_Knock) String() string + type Empty struct + func (*Empty) Descriptor() ([]byte, []int) + func (*Empty) ProtoMessage() + func (x *Empty) ProtoReflect() protoreflect.Message + func (x *Empty) Reset() + func (x *Empty) String() string + type GRPCBrokerClient interface + StartStream func(ctx context.Context, opts ...grpc.CallOption) (GRPCBroker_StartStreamClient, error) + func NewGRPCBrokerClient(cc grpc.ClientConnInterface) GRPCBrokerClient + type GRPCBrokerServer interface + StartStream func(GRPCBroker_StartStreamServer) error + type GRPCBroker_StartStreamClient interface + Recv func() (*ConnInfo, error) + Send func(*ConnInfo) error + type GRPCBroker_StartStreamServer interface + Recv func() (*ConnInfo, error) + Send func(*ConnInfo) error + type GRPCControllerClient interface + Shutdown func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error) + func NewGRPCControllerClient(cc grpc.ClientConnInterface) GRPCControllerClient + type GRPCControllerServer interface + Shutdown func(context.Context, *Empty) (*Empty, error) + type GRPCStdioClient interface + StreamStdio func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (GRPCStdio_StreamStdioClient, error) + func NewGRPCStdioClient(cc grpc.ClientConnInterface) GRPCStdioClient + type GRPCStdioServer interface + StreamStdio func(*emptypb.Empty, GRPCStdio_StreamStdioServer) error + type GRPCStdio_StreamStdioClient interface + Recv func() (*StdioData, error) + type GRPCStdio_StreamStdioServer interface + Send func(*StdioData) error + type StdioData struct + Channel StdioData_Channel + Data []byte + func (*StdioData) Descriptor() ([]byte, []int) + func (*StdioData) ProtoMessage() + func (x *StdioData) GetChannel() StdioData_Channel + func (x *StdioData) GetData() []byte + func (x *StdioData) ProtoReflect() protoreflect.Message + func (x *StdioData) Reset() + func (x *StdioData) String() string + type StdioData_Channel int32 + const StdioData_INVALID + const StdioData_STDERR + const StdioData_STDOUT + func (StdioData_Channel) Descriptor() protoreflect.EnumDescriptor + func (StdioData_Channel) EnumDescriptor() ([]byte, []int) + func (StdioData_Channel) Type() protoreflect.EnumType + func (x StdioData_Channel) Enum() *StdioData_Channel + func (x StdioData_Channel) Number() protoreflect.EnumNumber + func (x StdioData_Channel) String() string + type UnimplementedGRPCBrokerServer struct + func (UnimplementedGRPCBrokerServer) StartStream(GRPCBroker_StartStreamServer) error + type UnimplementedGRPCControllerServer struct + func (UnimplementedGRPCControllerServer) Shutdown(context.Context, *Empty) (*Empty, error) + type UnimplementedGRPCStdioServer struct + func (UnimplementedGRPCStdioServer) StreamStdio(*emptypb.Empty, GRPCStdio_StreamStdioServer) error + type UnsafeGRPCBrokerServer interface + type UnsafeGRPCControllerServer interface + type UnsafeGRPCStdioServer interface
Go to main page