Versions in this module Expand all Collapse all v1 v1.2.8 Feb 29, 2024 v1.2.7 Feb 28, 2022 Changes in this version + var StdioData_Channel_name = map[int32]string + var StdioData_Channel_value = map[string]int32 + func RegisterGRPCBrokerServer(s *grpc.Server, srv GRPCBrokerServer) + func RegisterGRPCControllerServer(s *grpc.Server, srv GRPCControllerServer) + func RegisterGRPCStdioServer(s *grpc.Server, srv GRPCStdioServer) + type ConnInfo struct + Address string + Network string + ServiceId uint32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ConnInfo) Descriptor() ([]byte, []int) + func (*ConnInfo) ProtoMessage() + func (dst *ConnInfo) XXX_Merge(src proto.Message) + func (m *ConnInfo) GetAddress() string + func (m *ConnInfo) GetNetwork() string + func (m *ConnInfo) GetServiceId() uint32 + func (m *ConnInfo) Reset() + func (m *ConnInfo) String() string + func (m *ConnInfo) XXX_DiscardUnknown() + func (m *ConnInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ConnInfo) XXX_Size() int + func (m *ConnInfo) XXX_Unmarshal(b []byte) error + type Empty struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Empty) Descriptor() ([]byte, []int) + func (*Empty) ProtoMessage() + func (dst *Empty) XXX_Merge(src proto.Message) + func (m *Empty) Reset() + func (m *Empty) String() string + func (m *Empty) XXX_DiscardUnknown() + func (m *Empty) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Empty) XXX_Size() int + func (m *Empty) XXX_Unmarshal(b []byte) error + type GRPCBrokerClient interface + StartStream func(ctx context.Context, opts ...grpc.CallOption) (GRPCBroker_StartStreamClient, error) + func NewGRPCBrokerClient(cc *grpc.ClientConn) 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.ClientConn) GRPCControllerClient + type GRPCControllerServer interface + Shutdown func(context.Context, *Empty) (*Empty, error) + type GRPCStdioClient interface + StreamStdio func(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (GRPCStdio_StreamStdioClient, error) + func NewGRPCStdioClient(cc *grpc.ClientConn) GRPCStdioClient + type GRPCStdioServer interface + StreamStdio func(*empty.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 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*StdioData) Descriptor() ([]byte, []int) + func (*StdioData) ProtoMessage() + func (dst *StdioData) XXX_Merge(src proto.Message) + func (m *StdioData) GetChannel() StdioData_Channel + func (m *StdioData) GetData() []byte + func (m *StdioData) Reset() + func (m *StdioData) String() string + func (m *StdioData) XXX_DiscardUnknown() + func (m *StdioData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *StdioData) XXX_Size() int + func (m *StdioData) XXX_Unmarshal(b []byte) error + type StdioData_Channel int32 + const StdioData_INVALID + const StdioData_STDERR + const StdioData_STDOUT + func (StdioData_Channel) EnumDescriptor() ([]byte, []int) + func (x StdioData_Channel) String() string
Go to main page