Documentation
¶
Index ¶
- Variables
- func RegisterCommandableServer(s grpc.ServiceRegistrar, srv CommandableServer)
- type CommandableClient
- type CommandableServer
- type ErrorDescription
- func (*ErrorDescription) Descriptor() ([]byte, []int)deprecated
- func (x *ErrorDescription) GetCategory() string
- func (x *ErrorDescription) GetCause() string
- func (x *ErrorDescription) GetCode() string
- func (x *ErrorDescription) GetCorrelationId() string
- func (x *ErrorDescription) GetDetails() map[string]string
- func (x *ErrorDescription) GetMessage() string
- func (x *ErrorDescription) GetStackTrace() string
- func (x *ErrorDescription) GetStatus() int32
- func (*ErrorDescription) ProtoMessage()
- func (x *ErrorDescription) ProtoReflect() protoreflect.Message
- func (x *ErrorDescription) Reset()
- func (x *ErrorDescription) String() string
- type InvokeReply
- func (*InvokeReply) Descriptor() ([]byte, []int)deprecated
- func (x *InvokeReply) GetError() *ErrorDescription
- func (x *InvokeReply) GetResultEmpty() bool
- func (x *InvokeReply) GetResultJson() string
- func (*InvokeReply) ProtoMessage()
- func (x *InvokeReply) ProtoReflect() protoreflect.Message
- func (x *InvokeReply) Reset()
- func (x *InvokeReply) String() string
- type InvokeRequest
- func (*InvokeRequest) Descriptor() ([]byte, []int)deprecated
- func (x *InvokeRequest) GetArgsEmpty() bool
- func (x *InvokeRequest) GetArgsJson() string
- func (x *InvokeRequest) GetCorrelationId() string
- func (x *InvokeRequest) GetMethod() string
- func (*InvokeRequest) ProtoMessage()
- func (x *InvokeRequest) ProtoReflect() protoreflect.Message
- func (x *InvokeRequest) Reset()
- func (x *InvokeRequest) String() string
- type UnimplementedCommandableServer
- type UnsafeCommandableServer
Constants ¶
This section is empty.
Variables ¶
var Commandable_ServiceDesc = grpc.ServiceDesc{ ServiceName: "commandable.Commandable", HandlerType: (*CommandableServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "invoke", Handler: _Commandable_Invoke_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "protos/commandable.proto", }
Commandable_ServiceDesc is the grpc.ServiceDesc for Commandable service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_protos_commandable_proto protoreflect.FileDescriptor
Functions ¶
func RegisterCommandableServer ¶
func RegisterCommandableServer(s grpc.ServiceRegistrar, srv CommandableServer)
Types ¶
type CommandableClient ¶
type CommandableClient interface {
Invoke(ctx context.Context, in *InvokeRequest, opts ...grpc.CallOption) (*InvokeReply, error)
}
CommandableClient is the client API for Commandable 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 NewCommandableClient ¶
func NewCommandableClient(cc grpc.ClientConnInterface) CommandableClient
type CommandableServer ¶
type CommandableServer interface { Invoke(context.Context, *InvokeRequest) (*InvokeReply, error) // contains filtered or unexported methods }
CommandableServer is the server API for Commandable service. All implementations must embed UnimplementedCommandableServer for forward compatibility
type ErrorDescription ¶
type ErrorDescription struct { Category string `protobuf:"bytes,1,opt,name=category,proto3" json:"category,omitempty"` Code string `protobuf:"bytes,2,opt,name=code,proto3" json:"code,omitempty"` CorrelationId string `protobuf:"bytes,3,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"` Status int32 `protobuf:"varint,4,opt,name=status,proto3" json:"status,omitempty"` Message string `protobuf:"bytes,5,opt,name=message,proto3" json:"message,omitempty"` Cause string `protobuf:"bytes,6,opt,name=cause,proto3" json:"cause,omitempty"` StackTrace string `protobuf:"bytes,7,opt,name=stack_trace,json=stackTrace,proto3" json:"stack_trace,omitempty"` Details map[string]string `` /* 155-byte string literal not displayed */ // contains filtered or unexported fields }
func (*ErrorDescription) Descriptor
deprecated
func (*ErrorDescription) Descriptor() ([]byte, []int)
Deprecated: Use ErrorDescription.ProtoReflect.Descriptor instead.
func (*ErrorDescription) GetCategory ¶
func (x *ErrorDescription) GetCategory() string
func (*ErrorDescription) GetCause ¶
func (x *ErrorDescription) GetCause() string
func (*ErrorDescription) GetCode ¶
func (x *ErrorDescription) GetCode() string
func (*ErrorDescription) GetCorrelationId ¶
func (x *ErrorDescription) GetCorrelationId() string
func (*ErrorDescription) GetDetails ¶
func (x *ErrorDescription) GetDetails() map[string]string
func (*ErrorDescription) GetMessage ¶
func (x *ErrorDescription) GetMessage() string
func (*ErrorDescription) GetStackTrace ¶
func (x *ErrorDescription) GetStackTrace() string
func (*ErrorDescription) GetStatus ¶
func (x *ErrorDescription) GetStatus() int32
func (*ErrorDescription) ProtoMessage ¶
func (*ErrorDescription) ProtoMessage()
func (*ErrorDescription) ProtoReflect ¶ added in v1.2.3
func (x *ErrorDescription) ProtoReflect() protoreflect.Message
func (*ErrorDescription) Reset ¶
func (x *ErrorDescription) Reset()
func (*ErrorDescription) String ¶
func (x *ErrorDescription) String() string
type InvokeReply ¶
type InvokeReply struct { Error *ErrorDescription `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"` ResultEmpty bool `protobuf:"varint,2,opt,name=result_empty,json=resultEmpty,proto3" json:"result_empty,omitempty"` ResultJson string `protobuf:"bytes,3,opt,name=result_json,json=resultJson,proto3" json:"result_json,omitempty"` // contains filtered or unexported fields }
The response message containing the invocation response
func (*InvokeReply) Descriptor
deprecated
func (*InvokeReply) Descriptor() ([]byte, []int)
Deprecated: Use InvokeReply.ProtoReflect.Descriptor instead.
func (*InvokeReply) GetError ¶
func (x *InvokeReply) GetError() *ErrorDescription
func (*InvokeReply) GetResultEmpty ¶
func (x *InvokeReply) GetResultEmpty() bool
func (*InvokeReply) GetResultJson ¶
func (x *InvokeReply) GetResultJson() string
func (*InvokeReply) ProtoMessage ¶
func (*InvokeReply) ProtoMessage()
func (*InvokeReply) ProtoReflect ¶ added in v1.2.3
func (x *InvokeReply) ProtoReflect() protoreflect.Message
func (*InvokeReply) Reset ¶
func (x *InvokeReply) Reset()
func (*InvokeReply) String ¶
func (x *InvokeReply) String() string
type InvokeRequest ¶
type InvokeRequest struct { Method string `protobuf:"bytes,1,opt,name=method,proto3" json:"method,omitempty"` CorrelationId string `protobuf:"bytes,2,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"` ArgsEmpty bool `protobuf:"varint,3,opt,name=args_empty,json=argsEmpty,proto3" json:"args_empty,omitempty"` ArgsJson string `protobuf:"bytes,4,opt,name=args_json,json=argsJson,proto3" json:"args_json,omitempty"` // contains filtered or unexported fields }
The request message containing the invocation request.
func (*InvokeRequest) Descriptor
deprecated
func (*InvokeRequest) Descriptor() ([]byte, []int)
Deprecated: Use InvokeRequest.ProtoReflect.Descriptor instead.
func (*InvokeRequest) GetArgsEmpty ¶
func (x *InvokeRequest) GetArgsEmpty() bool
func (*InvokeRequest) GetArgsJson ¶
func (x *InvokeRequest) GetArgsJson() string
func (*InvokeRequest) GetCorrelationId ¶
func (x *InvokeRequest) GetCorrelationId() string
func (*InvokeRequest) GetMethod ¶
func (x *InvokeRequest) GetMethod() string
func (*InvokeRequest) ProtoMessage ¶
func (*InvokeRequest) ProtoMessage()
func (*InvokeRequest) ProtoReflect ¶ added in v1.2.3
func (x *InvokeRequest) ProtoReflect() protoreflect.Message
func (*InvokeRequest) Reset ¶
func (x *InvokeRequest) Reset()
func (*InvokeRequest) String ¶
func (x *InvokeRequest) String() string
type UnimplementedCommandableServer ¶
type UnimplementedCommandableServer struct { }
UnimplementedCommandableServer must be embedded to have forward compatible implementations.
func (UnimplementedCommandableServer) Invoke ¶
func (UnimplementedCommandableServer) Invoke(context.Context, *InvokeRequest) (*InvokeReply, error)
type UnsafeCommandableServer ¶ added in v1.2.3
type UnsafeCommandableServer interface {
// contains filtered or unexported methods
}
UnsafeCommandableServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to CommandableServer will result in compilation errors.