Documentation ¶
Index ¶
- func RegisterTransactionServiceHandler(s server.Server, hdlr TransactionServiceHandler, opts ...server.HandlerOption) error
- type ReadRequest
- func (*ReadRequest) Descriptor() ([]byte, []int)
- func (m *ReadRequest) GetKey() string
- func (*ReadRequest) ProtoMessage()
- func (m *ReadRequest) Reset()
- func (m *ReadRequest) String() string
- func (m *ReadRequest) Validate() error
- func (m *ReadRequest) XXX_DiscardUnknown()
- func (m *ReadRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ReadRequest) XXX_Merge(src proto.Message)
- func (m *ReadRequest) XXX_Size() int
- func (m *ReadRequest) XXX_Unmarshal(b []byte) error
- type ReadRequestValidationError
- func (e ReadRequestValidationError) Cause() error
- func (e ReadRequestValidationError) Error() string
- func (e ReadRequestValidationError) ErrorName() string
- func (e ReadRequestValidationError) Field() string
- func (e ReadRequestValidationError) Key() bool
- func (e ReadRequestValidationError) Reason() string
- type TransactionEvent
- func (*TransactionEvent) Descriptor() ([]byte, []int)
- func (m *TransactionEvent) GetReq() []byte
- func (m *TransactionEvent) GetRsp() []byte
- func (*TransactionEvent) ProtoMessage()
- func (m *TransactionEvent) Reset()
- func (m *TransactionEvent) String() string
- func (m *TransactionEvent) Validate() error
- func (m *TransactionEvent) XXX_DiscardUnknown()
- func (m *TransactionEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TransactionEvent) XXX_Merge(src proto.Message)
- func (m *TransactionEvent) XXX_Size() int
- func (m *TransactionEvent) XXX_Unmarshal(b []byte) error
- type TransactionEventValidationError
- func (e TransactionEventValidationError) Cause() error
- func (e TransactionEventValidationError) Error() string
- func (e TransactionEventValidationError) ErrorName() string
- func (e TransactionEventValidationError) Field() string
- func (e TransactionEventValidationError) Key() bool
- func (e TransactionEventValidationError) Reason() string
- type TransactionService
- type TransactionServiceHandler
- type WriteRequest
- func (*WriteRequest) Descriptor() ([]byte, []int)
- func (m *WriteRequest) GetEvent() *TransactionEvent
- func (m *WriteRequest) GetKey() string
- func (*WriteRequest) ProtoMessage()
- func (m *WriteRequest) Reset()
- func (m *WriteRequest) String() string
- func (m *WriteRequest) Validate() error
- func (m *WriteRequest) XXX_DiscardUnknown()
- func (m *WriteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *WriteRequest) XXX_Merge(src proto.Message)
- func (m *WriteRequest) XXX_Size() int
- func (m *WriteRequest) XXX_Unmarshal(b []byte) error
- type WriteRequestValidationError
- func (e WriteRequestValidationError) Cause() error
- func (e WriteRequestValidationError) Error() string
- func (e WriteRequestValidationError) ErrorName() string
- func (e WriteRequestValidationError) Field() string
- func (e WriteRequestValidationError) Key() bool
- func (e WriteRequestValidationError) Reason() string
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterTransactionServiceHandler ¶
func RegisterTransactionServiceHandler(s server.Server, hdlr TransactionServiceHandler, opts ...server.HandlerOption) error
Types ¶
type ReadRequest ¶
type ReadRequest struct { Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ReadRequest) Descriptor ¶
func (*ReadRequest) Descriptor() ([]byte, []int)
func (*ReadRequest) GetKey ¶
func (m *ReadRequest) GetKey() string
func (*ReadRequest) ProtoMessage ¶
func (*ReadRequest) ProtoMessage()
func (*ReadRequest) Reset ¶
func (m *ReadRequest) Reset()
func (*ReadRequest) String ¶
func (m *ReadRequest) String() string
func (*ReadRequest) Validate ¶
func (m *ReadRequest) Validate() error
Validate is disabled for ReadRequest. This method will always return nil.
func (*ReadRequest) XXX_DiscardUnknown ¶
func (m *ReadRequest) XXX_DiscardUnknown()
func (*ReadRequest) XXX_Marshal ¶
func (m *ReadRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ReadRequest) XXX_Merge ¶
func (m *ReadRequest) XXX_Merge(src proto.Message)
func (*ReadRequest) XXX_Size ¶
func (m *ReadRequest) XXX_Size() int
func (*ReadRequest) XXX_Unmarshal ¶
func (m *ReadRequest) XXX_Unmarshal(b []byte) error
type ReadRequestValidationError ¶
type ReadRequestValidationError struct {
// contains filtered or unexported fields
}
ReadRequestValidationError is the validation error returned by ReadRequest.Validate if the designated constraints aren't met.
func (ReadRequestValidationError) Cause ¶
func (e ReadRequestValidationError) Cause() error
Cause function returns cause value.
func (ReadRequestValidationError) Error ¶
func (e ReadRequestValidationError) Error() string
Error satisfies the builtin error interface
func (ReadRequestValidationError) ErrorName ¶
func (e ReadRequestValidationError) ErrorName() string
ErrorName returns error name.
func (ReadRequestValidationError) Field ¶
func (e ReadRequestValidationError) Field() string
Field function returns field value.
func (ReadRequestValidationError) Key ¶
func (e ReadRequestValidationError) Key() bool
Key function returns key value.
func (ReadRequestValidationError) Reason ¶
func (e ReadRequestValidationError) Reason() string
Reason function returns reason value.
type TransactionEvent ¶
type TransactionEvent struct { // request Req []byte `protobuf:"bytes,1,opt,name=req,proto3" json:"req,omitempty"` // responce Rsp []byte `protobuf:"bytes,2,opt,name=rsp,proto3" json:"rsp,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Transaction Event
func (*TransactionEvent) Descriptor ¶
func (*TransactionEvent) Descriptor() ([]byte, []int)
func (*TransactionEvent) GetReq ¶
func (m *TransactionEvent) GetReq() []byte
func (*TransactionEvent) GetRsp ¶
func (m *TransactionEvent) GetRsp() []byte
func (*TransactionEvent) ProtoMessage ¶
func (*TransactionEvent) ProtoMessage()
func (*TransactionEvent) Reset ¶
func (m *TransactionEvent) Reset()
func (*TransactionEvent) String ¶
func (m *TransactionEvent) String() string
func (*TransactionEvent) Validate ¶
func (m *TransactionEvent) Validate() error
Validate checks the field values on TransactionEvent with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.
func (*TransactionEvent) XXX_DiscardUnknown ¶
func (m *TransactionEvent) XXX_DiscardUnknown()
func (*TransactionEvent) XXX_Marshal ¶
func (m *TransactionEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TransactionEvent) XXX_Merge ¶
func (m *TransactionEvent) XXX_Merge(src proto.Message)
func (*TransactionEvent) XXX_Size ¶
func (m *TransactionEvent) XXX_Size() int
func (*TransactionEvent) XXX_Unmarshal ¶
func (m *TransactionEvent) XXX_Unmarshal(b []byte) error
type TransactionEventValidationError ¶
type TransactionEventValidationError struct {
// contains filtered or unexported fields
}
TransactionEventValidationError is the validation error returned by TransactionEvent.Validate if the designated constraints aren't met.
func (TransactionEventValidationError) Cause ¶
func (e TransactionEventValidationError) Cause() error
Cause function returns cause value.
func (TransactionEventValidationError) Error ¶
func (e TransactionEventValidationError) Error() string
Error satisfies the builtin error interface
func (TransactionEventValidationError) ErrorName ¶
func (e TransactionEventValidationError) ErrorName() string
ErrorName returns error name.
func (TransactionEventValidationError) Field ¶
func (e TransactionEventValidationError) Field() string
Field function returns field value.
func (TransactionEventValidationError) Key ¶
func (e TransactionEventValidationError) Key() bool
Key function returns key value.
func (TransactionEventValidationError) Reason ¶
func (e TransactionEventValidationError) Reason() string
Reason function returns reason value.
type TransactionService ¶
type TransactionService interface { Read(ctx context.Context, in *ReadRequest, opts ...client.CallOption) (*TransactionEvent, error) Write(ctx context.Context, in *WriteRequest, opts ...client.CallOption) (*empty.Empty, error) }
func NewTransactionService ¶
func NewTransactionService(name string, c client.Client) TransactionService
type TransactionServiceHandler ¶
type TransactionServiceHandler interface { Read(context.Context, *ReadRequest, *TransactionEvent) error Write(context.Context, *WriteRequest, *empty.Empty) error }
type WriteRequest ¶
type WriteRequest struct { Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` Event *TransactionEvent `protobuf:"bytes,2,opt,name=event,proto3" json:"event,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*WriteRequest) Descriptor ¶
func (*WriteRequest) Descriptor() ([]byte, []int)
func (*WriteRequest) GetEvent ¶
func (m *WriteRequest) GetEvent() *TransactionEvent
func (*WriteRequest) GetKey ¶
func (m *WriteRequest) GetKey() string
func (*WriteRequest) ProtoMessage ¶
func (*WriteRequest) ProtoMessage()
func (*WriteRequest) Reset ¶
func (m *WriteRequest) Reset()
func (*WriteRequest) String ¶
func (m *WriteRequest) String() string
func (*WriteRequest) Validate ¶
func (m *WriteRequest) Validate() error
Validate is disabled for WriteRequest. This method will always return nil.
func (*WriteRequest) XXX_DiscardUnknown ¶
func (m *WriteRequest) XXX_DiscardUnknown()
func (*WriteRequest) XXX_Marshal ¶
func (m *WriteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*WriteRequest) XXX_Merge ¶
func (m *WriteRequest) XXX_Merge(src proto.Message)
func (*WriteRequest) XXX_Size ¶
func (m *WriteRequest) XXX_Size() int
func (*WriteRequest) XXX_Unmarshal ¶
func (m *WriteRequest) XXX_Unmarshal(b []byte) error
type WriteRequestValidationError ¶
type WriteRequestValidationError struct {
// contains filtered or unexported fields
}
WriteRequestValidationError is the validation error returned by WriteRequest.Validate if the designated constraints aren't met.
func (WriteRequestValidationError) Cause ¶
func (e WriteRequestValidationError) Cause() error
Cause function returns cause value.
func (WriteRequestValidationError) Error ¶
func (e WriteRequestValidationError) Error() string
Error satisfies the builtin error interface
func (WriteRequestValidationError) ErrorName ¶
func (e WriteRequestValidationError) ErrorName() string
ErrorName returns error name.
func (WriteRequestValidationError) Field ¶
func (e WriteRequestValidationError) Field() string
Field function returns field value.
func (WriteRequestValidationError) Key ¶
func (e WriteRequestValidationError) Key() bool
Key function returns key value.
func (WriteRequestValidationError) Reason ¶
func (e WriteRequestValidationError) Reason() string
Reason function returns reason value.