Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterConnectServiceServer(s grpc.ServiceRegistrar, srv ConnectServiceServer)
- type ConnectServiceClient
- type ConnectServiceServer
- type ConnectService_FetchResponseDataClient
- type ConnectService_FetchResponseDataServer
- type DataRequest
- type DataResponse
- type SendCommandRequest
- func (*SendCommandRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SendCommandRequest) GetMessage() string
- func (*SendCommandRequest) ProtoMessage()
- func (x *SendCommandRequest) ProtoReflect() protoreflect.Message
- func (x *SendCommandRequest) Reset()
- func (x *SendCommandRequest) String() string
- type SendCommandResponse
- func (*SendCommandResponse) Descriptor() ([]byte, []int)deprecated
- func (x *SendCommandResponse) GetCode() uint64
- func (x *SendCommandResponse) GetMessage() string
- func (*SendCommandResponse) ProtoMessage()
- func (x *SendCommandResponse) ProtoReflect() protoreflect.Message
- func (x *SendCommandResponse) Reset()
- func (x *SendCommandResponse) String() string
- type UnimplementedConnectServiceServer
- type UnsafeConnectServiceServer
Constants ¶
View Source
const ( ConnectService_FetchResponseData_FullMethodName = "/ConnectService/FetchResponseData" ConnectService_SendCommand_FullMethodName = "/ConnectService/SendCommand" )
Variables ¶
View Source
var ConnectService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "ConnectService", HandlerType: (*ConnectServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "SendCommand", Handler: _ConnectService_SendCommand_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "FetchResponseData", Handler: _ConnectService_FetchResponseData_Handler, ServerStreams: true, }, }, Metadata: "connect.proto", }
ConnectService_ServiceDesc is the grpc.ServiceDesc for ConnectService 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_connect_proto protoreflect.FileDescriptor
Functions ¶
func RegisterConnectServiceServer ¶
func RegisterConnectServiceServer(s grpc.ServiceRegistrar, srv ConnectServiceServer)
Types ¶
type ConnectServiceClient ¶
type ConnectServiceClient interface {
FetchResponseData(ctx context.Context, in *DataRequest, opts ...grpc.CallOption) (ConnectService_FetchResponseDataClient, error)
SendCommand(ctx context.Context, in *SendCommandRequest, opts ...grpc.CallOption) (*SendCommandResponse, error)
}
ConnectServiceClient is the client API for ConnectService 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 NewConnectServiceClient ¶
func NewConnectServiceClient(cc grpc.ClientConnInterface) ConnectServiceClient
type ConnectServiceServer ¶
type ConnectServiceServer interface {
FetchResponseData(*DataRequest, ConnectService_FetchResponseDataServer) error
SendCommand(context.Context, *SendCommandRequest) (*SendCommandResponse, error)
// contains filtered or unexported methods
}
ConnectServiceServer is the server API for ConnectService service. All implementations must embed UnimplementedConnectServiceServer for forward compatibility
type ConnectService_FetchResponseDataClient ¶
type ConnectService_FetchResponseDataClient interface {
Recv() (*DataResponse, error)
grpc.ClientStream
}
type ConnectService_FetchResponseDataServer ¶
type ConnectService_FetchResponseDataServer interface {
Send(*DataResponse) error
grpc.ServerStream
}
type DataRequest ¶
type DataRequest struct {
// contains filtered or unexported fields
}
func (*DataRequest) Descriptor
deprecated
func (*DataRequest) Descriptor() ([]byte, []int)
Deprecated: Use DataRequest.ProtoReflect.Descriptor instead.
func (*DataRequest) ProtoMessage ¶
func (*DataRequest) ProtoMessage()
func (*DataRequest) ProtoReflect ¶
func (x *DataRequest) ProtoReflect() protoreflect.Message
func (*DataRequest) Reset ¶
func (x *DataRequest) Reset()
func (*DataRequest) String ¶
func (x *DataRequest) String() string
type DataResponse ¶
type DataResponse struct {
Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
// contains filtered or unexported fields
}
func (*DataResponse) Descriptor
deprecated
func (*DataResponse) Descriptor() ([]byte, []int)
Deprecated: Use DataResponse.ProtoReflect.Descriptor instead.
func (*DataResponse) GetMessage ¶
func (x *DataResponse) GetMessage() string
func (*DataResponse) ProtoMessage ¶
func (*DataResponse) ProtoMessage()
func (*DataResponse) ProtoReflect ¶
func (x *DataResponse) ProtoReflect() protoreflect.Message
func (*DataResponse) Reset ¶
func (x *DataResponse) Reset()
func (*DataResponse) String ¶
func (x *DataResponse) String() string
type SendCommandRequest ¶
type SendCommandRequest struct {
Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
// contains filtered or unexported fields
}
func (*SendCommandRequest) Descriptor
deprecated
func (*SendCommandRequest) Descriptor() ([]byte, []int)
Deprecated: Use SendCommandRequest.ProtoReflect.Descriptor instead.
func (*SendCommandRequest) GetMessage ¶
func (x *SendCommandRequest) GetMessage() string
func (*SendCommandRequest) ProtoMessage ¶
func (*SendCommandRequest) ProtoMessage()
func (*SendCommandRequest) ProtoReflect ¶
func (x *SendCommandRequest) ProtoReflect() protoreflect.Message
func (*SendCommandRequest) Reset ¶
func (x *SendCommandRequest) Reset()
func (*SendCommandRequest) String ¶
func (x *SendCommandRequest) String() string
type SendCommandResponse ¶
type SendCommandResponse struct {
Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
Code uint64 `protobuf:"varint,2,opt,name=code,proto3" json:"code,omitempty"`
// contains filtered or unexported fields
}
func (*SendCommandResponse) Descriptor
deprecated
func (*SendCommandResponse) Descriptor() ([]byte, []int)
Deprecated: Use SendCommandResponse.ProtoReflect.Descriptor instead.
func (*SendCommandResponse) GetCode ¶
func (x *SendCommandResponse) GetCode() uint64
func (*SendCommandResponse) GetMessage ¶
func (x *SendCommandResponse) GetMessage() string
func (*SendCommandResponse) ProtoMessage ¶
func (*SendCommandResponse) ProtoMessage()
func (*SendCommandResponse) ProtoReflect ¶
func (x *SendCommandResponse) ProtoReflect() protoreflect.Message
func (*SendCommandResponse) Reset ¶
func (x *SendCommandResponse) Reset()
func (*SendCommandResponse) String ¶
func (x *SendCommandResponse) String() string
type UnimplementedConnectServiceServer ¶
type UnimplementedConnectServiceServer struct {
}
UnimplementedConnectServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedConnectServiceServer) FetchResponseData ¶
func (UnimplementedConnectServiceServer) FetchResponseData(*DataRequest, ConnectService_FetchResponseDataServer) error
func (UnimplementedConnectServiceServer) SendCommand ¶
func (UnimplementedConnectServiceServer) SendCommand(context.Context, *SendCommandRequest) (*SendCommandResponse, error)
type UnsafeConnectServiceServer ¶
type UnsafeConnectServiceServer interface {
// contains filtered or unexported methods
}
UnsafeConnectServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ConnectServiceServer will result in compilation errors.
Source Files
Click to show internal directories.
Click to hide internal directories.