Documentation ¶
Index ¶
- func RegisterCommandableServer(s *grpc.Server, srv CommandableServer)
- type CommandableClient
- type CommandableServer
- type ErrorDescription
- func (*ErrorDescription) Descriptor() ([]byte, []int)
- func (m *ErrorDescription) GetCategory() string
- func (m *ErrorDescription) GetCause() string
- func (m *ErrorDescription) GetCode() string
- func (m *ErrorDescription) GetCorrelationId() string
- func (m *ErrorDescription) GetDetails() map[string]string
- func (m *ErrorDescription) GetMessage() string
- func (m *ErrorDescription) GetStackTrace() string
- func (m *ErrorDescription) GetStatus() int32
- func (*ErrorDescription) ProtoMessage()
- func (m *ErrorDescription) Reset()
- func (m *ErrorDescription) String() string
- func (m *ErrorDescription) XXX_DiscardUnknown()
- func (m *ErrorDescription) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ErrorDescription) XXX_Merge(src proto.Message)
- func (m *ErrorDescription) XXX_Size() int
- func (m *ErrorDescription) XXX_Unmarshal(b []byte) error
- type InvokeReply
- func (*InvokeReply) Descriptor() ([]byte, []int)
- func (m *InvokeReply) GetError() *ErrorDescription
- func (m *InvokeReply) GetResultEmpty() bool
- func (m *InvokeReply) GetResultJson() string
- func (*InvokeReply) ProtoMessage()
- func (m *InvokeReply) Reset()
- func (m *InvokeReply) String() string
- func (m *InvokeReply) XXX_DiscardUnknown()
- func (m *InvokeReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *InvokeReply) XXX_Merge(src proto.Message)
- func (m *InvokeReply) XXX_Size() int
- func (m *InvokeReply) XXX_Unmarshal(b []byte) error
- type InvokeRequest
- func (*InvokeRequest) Descriptor() ([]byte, []int)
- func (m *InvokeRequest) GetArgsEmpty() bool
- func (m *InvokeRequest) GetArgsJson() string
- func (m *InvokeRequest) GetCorrelationId() string
- func (m *InvokeRequest) GetMethod() string
- func (*InvokeRequest) ProtoMessage()
- func (m *InvokeRequest) Reset()
- func (m *InvokeRequest) String() string
- func (m *InvokeRequest) XXX_DiscardUnknown()
- func (m *InvokeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *InvokeRequest) XXX_Merge(src proto.Message)
- func (m *InvokeRequest) XXX_Size() int
- func (m *InvokeRequest) XXX_Unmarshal(b []byte) error
- type UnimplementedCommandableServer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterCommandableServer ¶
func RegisterCommandableServer(s *grpc.Server, 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://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewCommandableClient ¶
func NewCommandableClient(cc grpc.ClientConnInterface) CommandableClient
type CommandableServer ¶
type CommandableServer interface {
Invoke(context.Context, *InvokeRequest) (*InvokeReply, error)
}
CommandableServer is the server API for Commandable service.
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 */ XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ErrorDescription) Descriptor ¶
func (*ErrorDescription) Descriptor() ([]byte, []int)
func (*ErrorDescription) GetCategory ¶
func (m *ErrorDescription) GetCategory() string
func (*ErrorDescription) GetCause ¶
func (m *ErrorDescription) GetCause() string
func (*ErrorDescription) GetCode ¶
func (m *ErrorDescription) GetCode() string
func (*ErrorDescription) GetCorrelationId ¶
func (m *ErrorDescription) GetCorrelationId() string
func (*ErrorDescription) GetDetails ¶
func (m *ErrorDescription) GetDetails() map[string]string
func (*ErrorDescription) GetMessage ¶
func (m *ErrorDescription) GetMessage() string
func (*ErrorDescription) GetStackTrace ¶
func (m *ErrorDescription) GetStackTrace() string
func (*ErrorDescription) GetStatus ¶
func (m *ErrorDescription) GetStatus() int32
func (*ErrorDescription) ProtoMessage ¶
func (*ErrorDescription) ProtoMessage()
func (*ErrorDescription) Reset ¶
func (m *ErrorDescription) Reset()
func (*ErrorDescription) String ¶
func (m *ErrorDescription) String() string
func (*ErrorDescription) XXX_DiscardUnknown ¶
func (m *ErrorDescription) XXX_DiscardUnknown()
func (*ErrorDescription) XXX_Marshal ¶
func (m *ErrorDescription) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ErrorDescription) XXX_Merge ¶
func (m *ErrorDescription) XXX_Merge(src proto.Message)
func (*ErrorDescription) XXX_Size ¶
func (m *ErrorDescription) XXX_Size() int
func (*ErrorDescription) XXX_Unmarshal ¶
func (m *ErrorDescription) XXX_Unmarshal(b []byte) error
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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
The response message containing the invocation response
func (*InvokeReply) Descriptor ¶
func (*InvokeReply) Descriptor() ([]byte, []int)
func (*InvokeReply) GetError ¶
func (m *InvokeReply) GetError() *ErrorDescription
func (*InvokeReply) GetResultEmpty ¶
func (m *InvokeReply) GetResultEmpty() bool
func (*InvokeReply) GetResultJson ¶
func (m *InvokeReply) GetResultJson() string
func (*InvokeReply) ProtoMessage ¶
func (*InvokeReply) ProtoMessage()
func (*InvokeReply) Reset ¶
func (m *InvokeReply) Reset()
func (*InvokeReply) String ¶
func (m *InvokeReply) String() string
func (*InvokeReply) XXX_DiscardUnknown ¶
func (m *InvokeReply) XXX_DiscardUnknown()
func (*InvokeReply) XXX_Marshal ¶
func (m *InvokeReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*InvokeReply) XXX_Merge ¶
func (m *InvokeReply) XXX_Merge(src proto.Message)
func (*InvokeReply) XXX_Size ¶
func (m *InvokeReply) XXX_Size() int
func (*InvokeReply) XXX_Unmarshal ¶
func (m *InvokeReply) XXX_Unmarshal(b []byte) error
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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
The request message containing the invocation request.
func (*InvokeRequest) Descriptor ¶
func (*InvokeRequest) Descriptor() ([]byte, []int)
func (*InvokeRequest) GetArgsEmpty ¶
func (m *InvokeRequest) GetArgsEmpty() bool
func (*InvokeRequest) GetArgsJson ¶
func (m *InvokeRequest) GetArgsJson() string
func (*InvokeRequest) GetCorrelationId ¶
func (m *InvokeRequest) GetCorrelationId() string
func (*InvokeRequest) GetMethod ¶
func (m *InvokeRequest) GetMethod() string
func (*InvokeRequest) ProtoMessage ¶
func (*InvokeRequest) ProtoMessage()
func (*InvokeRequest) Reset ¶
func (m *InvokeRequest) Reset()
func (*InvokeRequest) String ¶
func (m *InvokeRequest) String() string
func (*InvokeRequest) XXX_DiscardUnknown ¶
func (m *InvokeRequest) XXX_DiscardUnknown()
func (*InvokeRequest) XXX_Marshal ¶
func (m *InvokeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*InvokeRequest) XXX_Merge ¶
func (m *InvokeRequest) XXX_Merge(src proto.Message)
func (*InvokeRequest) XXX_Size ¶
func (m *InvokeRequest) XXX_Size() int
func (*InvokeRequest) XXX_Unmarshal ¶
func (m *InvokeRequest) XXX_Unmarshal(b []byte) error
type UnimplementedCommandableServer ¶
type UnimplementedCommandableServer struct { }
UnimplementedCommandableServer can be embedded to have forward compatible implementations.
func (*UnimplementedCommandableServer) Invoke ¶
func (*UnimplementedCommandableServer) Invoke(ctx context.Context, req *InvokeRequest) (*InvokeReply, error)
Click to show internal directories.
Click to hide internal directories.