Documentation ¶
Overview ¶
Package msg contains: - the definition of PROTOBUF structures and gRPC service, - helpers for mapping between PROTOBUF structures & the datasync_api.go.
Index ¶
- Variables
- func RegisterDataMsgServiceServer(s *grpc.Server, srv DataMsgServiceServer)
- type ChangeEvent
- type ChangeWatchResp
- type DataChangeReply
- func (*DataChangeReply) Descriptor() ([]byte, []int)
- func (m *DataChangeReply) GetKey() string
- func (m *DataChangeReply) GetOperationType() PutDel
- func (m *DataChangeReply) GetResult() uint32
- func (*DataChangeReply) ProtoMessage()
- func (m *DataChangeReply) Reset()
- func (m *DataChangeReply) String() string
- func (m *DataChangeReply) XXX_DiscardUnknown()
- func (m *DataChangeReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *DataChangeReply) XXX_Merge(src proto.Message)
- func (m *DataChangeReply) XXX_Size() int
- func (m *DataChangeReply) XXX_Unmarshal(b []byte) error
- type DataChangeRequest
- func (*DataChangeRequest) Descriptor() ([]byte, []int)
- func (m *DataChangeRequest) GetContent() []byte
- func (m *DataChangeRequest) GetContentType() string
- func (m *DataChangeRequest) GetKey() string
- func (m *DataChangeRequest) GetOperationType() PutDel
- func (*DataChangeRequest) ProtoMessage()
- func (m *DataChangeRequest) Reset()
- func (m *DataChangeRequest) String() string
- func (m *DataChangeRequest) XXX_DiscardUnknown()
- func (m *DataChangeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *DataChangeRequest) XXX_Merge(src proto.Message)
- func (m *DataChangeRequest) XXX_Size() int
- func (m *DataChangeRequest) XXX_Unmarshal(b []byte) error
- type DataMsgReply
- func (*DataMsgReply) Descriptor() ([]byte, []int)
- func (m *DataMsgReply) GetDataChanges() *DataMsgReply_DataChangesReplies
- func (m *DataMsgReply) GetDataResyncs() *DataMsgReply_DataResyncsReplies
- func (m *DataMsgReply) GetError() *Error
- func (m *DataMsgReply) GetMsgId() *Seq
- func (*DataMsgReply) ProtoMessage()
- func (m *DataMsgReply) Reset()
- func (m *DataMsgReply) String() string
- func (m *DataMsgReply) XXX_DiscardUnknown()
- func (m *DataMsgReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *DataMsgReply) XXX_Merge(src proto.Message)
- func (m *DataMsgReply) XXX_Size() int
- func (m *DataMsgReply) XXX_Unmarshal(b []byte) error
- type DataMsgReply_DataChangesReplies
- func (*DataMsgReply_DataChangesReplies) Descriptor() ([]byte, []int)
- func (m *DataMsgReply_DataChangesReplies) GetReplies() []*DataChangeReply
- func (*DataMsgReply_DataChangesReplies) ProtoMessage()
- func (m *DataMsgReply_DataChangesReplies) Reset()
- func (m *DataMsgReply_DataChangesReplies) String() string
- func (m *DataMsgReply_DataChangesReplies) XXX_DiscardUnknown()
- func (m *DataMsgReply_DataChangesReplies) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *DataMsgReply_DataChangesReplies) XXX_Merge(src proto.Message)
- func (m *DataMsgReply_DataChangesReplies) XXX_Size() int
- func (m *DataMsgReply_DataChangesReplies) XXX_Unmarshal(b []byte) error
- type DataMsgReply_DataResyncsReplies
- func (*DataMsgReply_DataResyncsReplies) Descriptor() ([]byte, []int)
- func (m *DataMsgReply_DataResyncsReplies) GetReplies() []*DataResyncReply
- func (*DataMsgReply_DataResyncsReplies) ProtoMessage()
- func (m *DataMsgReply_DataResyncsReplies) Reset()
- func (m *DataMsgReply_DataResyncsReplies) String() string
- func (m *DataMsgReply_DataResyncsReplies) XXX_DiscardUnknown()
- func (m *DataMsgReply_DataResyncsReplies) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *DataMsgReply_DataResyncsReplies) XXX_Merge(src proto.Message)
- func (m *DataMsgReply_DataResyncsReplies) XXX_Size() int
- func (m *DataMsgReply_DataResyncsReplies) XXX_Unmarshal(b []byte) error
- type DataMsgRequest
- func (*DataMsgRequest) Descriptor() ([]byte, []int)
- func (m *DataMsgRequest) GetDataChanges() []*DataChangeRequest
- func (m *DataMsgRequest) GetDataResyncs() []*DataResyncRequest
- func (m *DataMsgRequest) GetMsgId() *Seq
- func (m *DataMsgRequest) GetTxn() *Seq
- func (*DataMsgRequest) ProtoMessage()
- func (m *DataMsgRequest) Reset()
- func (m *DataMsgRequest) String() string
- func (m *DataMsgRequest) XXX_DiscardUnknown()
- func (m *DataMsgRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *DataMsgRequest) XXX_Merge(src proto.Message)
- func (m *DataMsgRequest) XXX_Size() int
- func (m *DataMsgRequest) XXX_Unmarshal(b []byte) error
- type DataMsgServiceClient
- type DataMsgServiceServer
- type DataMsgService_DataChangesClient
- type DataMsgService_DataChangesServer
- type DataResyncReplies
- func (*DataResyncReplies) Descriptor() ([]byte, []int)
- func (m *DataResyncReplies) GetDataResyncs() *DataResyncReplies_DataResyncsReplies
- func (m *DataResyncReplies) GetError() *Error
- func (m *DataResyncReplies) GetMsgId() *Seq
- func (*DataResyncReplies) ProtoMessage()
- func (m *DataResyncReplies) Reset()
- func (m *DataResyncReplies) String() string
- func (m *DataResyncReplies) XXX_DiscardUnknown()
- func (m *DataResyncReplies) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *DataResyncReplies) XXX_Merge(src proto.Message)
- func (m *DataResyncReplies) XXX_Size() int
- func (m *DataResyncReplies) XXX_Unmarshal(b []byte) error
- type DataResyncReplies_DataResyncsReplies
- func (*DataResyncReplies_DataResyncsReplies) Descriptor() ([]byte, []int)
- func (m *DataResyncReplies_DataResyncsReplies) GetReplies() []*DataResyncReply
- func (*DataResyncReplies_DataResyncsReplies) ProtoMessage()
- func (m *DataResyncReplies_DataResyncsReplies) Reset()
- func (m *DataResyncReplies_DataResyncsReplies) String() string
- func (m *DataResyncReplies_DataResyncsReplies) XXX_DiscardUnknown()
- func (m *DataResyncReplies_DataResyncsReplies) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *DataResyncReplies_DataResyncsReplies) XXX_Merge(src proto.Message)
- func (m *DataResyncReplies_DataResyncsReplies) XXX_Size() int
- func (m *DataResyncReplies_DataResyncsReplies) XXX_Unmarshal(b []byte) error
- type DataResyncReply
- func (*DataResyncReply) Descriptor() ([]byte, []int)
- func (m *DataResyncReply) GetKey() string
- func (m *DataResyncReply) GetResult() uint32
- func (m *DataResyncReply) GetResyncId() *Seq
- func (*DataResyncReply) ProtoMessage()
- func (m *DataResyncReply) Reset()
- func (m *DataResyncReply) String() string
- func (m *DataResyncReply) XXX_DiscardUnknown()
- func (m *DataResyncReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *DataResyncReply) XXX_Merge(src proto.Message)
- func (m *DataResyncReply) XXX_Size() int
- func (m *DataResyncReply) XXX_Unmarshal(b []byte) error
- type DataResyncRequest
- func (*DataResyncRequest) Descriptor() ([]byte, []int)
- func (m *DataResyncRequest) GetContent() []byte
- func (m *DataResyncRequest) GetContentType() string
- func (m *DataResyncRequest) GetKey() string
- func (*DataResyncRequest) ProtoMessage()
- func (m *DataResyncRequest) Reset()
- func (m *DataResyncRequest) String() string
- func (m *DataResyncRequest) XXX_DiscardUnknown()
- func (m *DataResyncRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *DataResyncRequest) XXX_Merge(src proto.Message)
- func (m *DataResyncRequest) XXX_Size() int
- func (m *DataResyncRequest) XXX_Unmarshal(b []byte) error
- type DataResyncRequests
- func (*DataResyncRequests) Descriptor() ([]byte, []int)
- func (m *DataResyncRequests) GetDataResyncs() []*DataResyncRequest
- func (m *DataResyncRequests) GetMsgId() *Seq
- func (*DataResyncRequests) ProtoMessage()
- func (m *DataResyncRequests) Reset()
- func (m *DataResyncRequests) String() string
- func (m *DataResyncRequests) XXX_DiscardUnknown()
- func (m *DataResyncRequests) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *DataResyncRequests) XXX_Merge(src proto.Message)
- func (m *DataResyncRequests) XXX_Size() int
- func (m *DataResyncRequests) XXX_Unmarshal(b []byte) error
- type Error
- func (*Error) Descriptor() ([]byte, []int)
- func (m *Error) GetMessage() string
- func (*Error) ProtoMessage()
- func (m *Error) Reset()
- func (m *Error) String() string
- func (m *Error) XXX_DiscardUnknown()
- func (m *Error) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Error) XXX_Merge(src proto.Message)
- func (m *Error) XXX_Size() int
- func (m *Error) XXX_Unmarshal(b []byte) error
- type PingReply
- func (*PingReply) Descriptor() ([]byte, []int)
- func (m *PingReply) GetMessage() string
- func (*PingReply) ProtoMessage()
- func (m *PingReply) Reset()
- func (m *PingReply) String() string
- func (m *PingReply) XXX_DiscardUnknown()
- func (m *PingReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *PingReply) XXX_Merge(src proto.Message)
- func (m *PingReply) XXX_Size() int
- func (m *PingReply) XXX_Unmarshal(b []byte) error
- type PingRequest
- func (*PingRequest) Descriptor() ([]byte, []int)
- func (m *PingRequest) GetMessage() string
- func (*PingRequest) ProtoMessage()
- func (m *PingRequest) Reset()
- func (m *PingRequest) String() string
- func (m *PingRequest) XXX_DiscardUnknown()
- func (m *PingRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *PingRequest) XXX_Merge(src proto.Message)
- func (m *PingRequest) XXX_Size() int
- func (m *PingRequest) XXX_Unmarshal(b []byte) error
- type PutDel
- type ResyncNeededCallback
- func (*ResyncNeededCallback) Descriptor() ([]byte, []int)
- func (m *ResyncNeededCallback) GetError() *Error
- func (m *ResyncNeededCallback) GetMsgId() *Seq
- func (*ResyncNeededCallback) ProtoMessage()
- func (m *ResyncNeededCallback) Reset()
- func (m *ResyncNeededCallback) String() string
- func (m *ResyncNeededCallback) XXX_DiscardUnknown()
- func (m *ResyncNeededCallback) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ResyncNeededCallback) XXX_Merge(src proto.Message)
- func (m *ResyncNeededCallback) XXX_Size() int
- func (m *ResyncNeededCallback) XXX_Unmarshal(b []byte) error
- type Seq
- func (*Seq) Descriptor() ([]byte, []int)
- func (m *Seq) GetOriginator() string
- func (m *Seq) GetSeq() uint32
- func (m *Seq) GetSeqCreatedSec() int64
- func (*Seq) ProtoMessage()
- func (m *Seq) Reset()
- func (m *Seq) String() string
- func (m *Seq) XXX_DiscardUnknown()
- func (m *Seq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Seq) XXX_Merge(src proto.Message)
- func (m *Seq) XXX_Size() int
- func (m *Seq) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
View Source
var PutDel_name = map[int32]string{
0: "PUT",
1: "DEL",
}
View Source
var PutDel_value = map[string]int32{
"PUT": 0,
"DEL": 1,
}
Functions ¶
func RegisterDataMsgServiceServer ¶
func RegisterDataMsgServiceServer(s *grpc.Server, srv DataMsgServiceServer)
Types ¶
type ChangeEvent ¶
type ChangeEvent struct {
// contains filtered or unexported fields
}
ChangeEvent represents change event with changes.
func NewChangeWatchResp ¶
func NewChangeWatchResp(ctx context.Context, message *DataChangeRequest, callback func(error)) *ChangeEvent
NewChangeWatchResp is a constructor.
func (*ChangeEvent) GetChanges ¶
func (ev *ChangeEvent) GetChanges() []datasync.ProtoWatchResp
GetChanges returns list of changes for the change event.
func (*ChangeEvent) GetContext ¶
func (ev *ChangeEvent) GetContext() context.Context
GetContext returns the context associated with the event.
type ChangeWatchResp ¶
type ChangeWatchResp struct {
// contains filtered or unexported fields
}
ChangeWatchResp adapts Datamessage to interface datasync.ChangeEvent.
func (*ChangeWatchResp) GetChangeType ¶
func (ev *ChangeWatchResp) GetChangeType() datasync.Op
GetChangeType - see the comment in implemented interface datasync.ChangeEvent.
func (*ChangeWatchResp) GetKey ¶
func (ev *ChangeWatchResp) GetKey() string
GetKey returns the key associated with the change.
func (*ChangeWatchResp) GetPrevValue ¶
func (ev *ChangeWatchResp) GetPrevValue(prevVal proto.Message) (prevExists bool, err error)
GetPrevValue returns the value before change.
func (*ChangeWatchResp) GetRevision ¶
func (ev *ChangeWatchResp) GetRevision() int64
GetRevision //TODO
type DataChangeReply ¶
type DataChangeReply struct { Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"` OperationType PutDel `protobuf:"varint,3,opt,name=operationType,proto3,enum=msg.PutDel" json:"operationType,omitempty"` // zero means success Result uint32 `protobuf:"varint,4,opt,name=result,proto3" json:"result,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DataChangeReply) Descriptor ¶
func (*DataChangeReply) Descriptor() ([]byte, []int)
func (*DataChangeReply) GetKey ¶
func (m *DataChangeReply) GetKey() string
func (*DataChangeReply) GetOperationType ¶
func (m *DataChangeReply) GetOperationType() PutDel
func (*DataChangeReply) GetResult ¶
func (m *DataChangeReply) GetResult() uint32
func (*DataChangeReply) ProtoMessage ¶
func (*DataChangeReply) ProtoMessage()
func (*DataChangeReply) Reset ¶
func (m *DataChangeReply) Reset()
func (*DataChangeReply) String ¶
func (m *DataChangeReply) String() string
func (*DataChangeReply) XXX_DiscardUnknown ¶ added in v1.6.0
func (m *DataChangeReply) XXX_DiscardUnknown()
func (*DataChangeReply) XXX_Marshal ¶ added in v1.6.0
func (m *DataChangeReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DataChangeReply) XXX_Merge ¶ added in v1.6.0
func (dst *DataChangeReply) XXX_Merge(src proto.Message)
func (*DataChangeReply) XXX_Size ¶ added in v1.6.0
func (m *DataChangeReply) XXX_Size() int
func (*DataChangeReply) XXX_Unmarshal ¶ added in v1.6.0
func (m *DataChangeReply) XXX_Unmarshal(b []byte) error
type DataChangeRequest ¶
type DataChangeRequest struct { Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` OperationType PutDel `protobuf:"varint,2,opt,name=operationType,proto3,enum=msg.PutDel" json:"operationType,omitempty"` Content []byte `protobuf:"bytes,3,opt,name=content,proto3" json:"content,omitempty"` ContentType string `protobuf:"bytes,4,opt,name=content_type,json=contentType,proto3" json:"content_type,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DataChangeRequest) Descriptor ¶
func (*DataChangeRequest) Descriptor() ([]byte, []int)
func (*DataChangeRequest) GetContent ¶
func (m *DataChangeRequest) GetContent() []byte
func (*DataChangeRequest) GetContentType ¶
func (m *DataChangeRequest) GetContentType() string
func (*DataChangeRequest) GetKey ¶
func (m *DataChangeRequest) GetKey() string
func (*DataChangeRequest) GetOperationType ¶
func (m *DataChangeRequest) GetOperationType() PutDel
func (*DataChangeRequest) ProtoMessage ¶
func (*DataChangeRequest) ProtoMessage()
func (*DataChangeRequest) Reset ¶
func (m *DataChangeRequest) Reset()
func (*DataChangeRequest) String ¶
func (m *DataChangeRequest) String() string
func (*DataChangeRequest) XXX_DiscardUnknown ¶ added in v1.6.0
func (m *DataChangeRequest) XXX_DiscardUnknown()
func (*DataChangeRequest) XXX_Marshal ¶ added in v1.6.0
func (m *DataChangeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DataChangeRequest) XXX_Merge ¶ added in v1.6.0
func (dst *DataChangeRequest) XXX_Merge(src proto.Message)
func (*DataChangeRequest) XXX_Size ¶ added in v1.6.0
func (m *DataChangeRequest) XXX_Size() int
func (*DataChangeRequest) XXX_Unmarshal ¶ added in v1.6.0
func (m *DataChangeRequest) XXX_Unmarshal(b []byte) error
type DataMsgReply ¶
type DataMsgReply struct { MsgId *Seq `protobuf:"bytes,1,opt,name=msgId" json:"msgId,omitempty"` Error *Error `protobuf:"bytes,2,opt,name=error" json:"error,omitempty"` DataChanges *DataMsgReply_DataChangesReplies `protobuf:"bytes,3,opt,name=dataChanges" json:"dataChanges,omitempty"` DataResyncs *DataMsgReply_DataResyncsReplies `protobuf:"bytes,4,opt,name=dataResyncs" json:"dataResyncs,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DataMsgReply) Descriptor ¶
func (*DataMsgReply) Descriptor() ([]byte, []int)
func (*DataMsgReply) GetDataChanges ¶
func (m *DataMsgReply) GetDataChanges() *DataMsgReply_DataChangesReplies
func (*DataMsgReply) GetDataResyncs ¶
func (m *DataMsgReply) GetDataResyncs() *DataMsgReply_DataResyncsReplies
func (*DataMsgReply) GetError ¶
func (m *DataMsgReply) GetError() *Error
func (*DataMsgReply) GetMsgId ¶
func (m *DataMsgReply) GetMsgId() *Seq
func (*DataMsgReply) ProtoMessage ¶
func (*DataMsgReply) ProtoMessage()
func (*DataMsgReply) Reset ¶
func (m *DataMsgReply) Reset()
func (*DataMsgReply) String ¶
func (m *DataMsgReply) String() string
func (*DataMsgReply) XXX_DiscardUnknown ¶ added in v1.6.0
func (m *DataMsgReply) XXX_DiscardUnknown()
func (*DataMsgReply) XXX_Marshal ¶ added in v1.6.0
func (m *DataMsgReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DataMsgReply) XXX_Merge ¶ added in v1.6.0
func (dst *DataMsgReply) XXX_Merge(src proto.Message)
func (*DataMsgReply) XXX_Size ¶ added in v1.6.0
func (m *DataMsgReply) XXX_Size() int
func (*DataMsgReply) XXX_Unmarshal ¶ added in v1.6.0
func (m *DataMsgReply) XXX_Unmarshal(b []byte) error
type DataMsgReply_DataChangesReplies ¶
type DataMsgReply_DataChangesReplies struct { Replies []*DataChangeReply `protobuf:"bytes,1,rep,name=replies" json:"replies,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DataMsgReply_DataChangesReplies) Descriptor ¶
func (*DataMsgReply_DataChangesReplies) Descriptor() ([]byte, []int)
func (*DataMsgReply_DataChangesReplies) GetReplies ¶
func (m *DataMsgReply_DataChangesReplies) GetReplies() []*DataChangeReply
func (*DataMsgReply_DataChangesReplies) ProtoMessage ¶
func (*DataMsgReply_DataChangesReplies) ProtoMessage()
func (*DataMsgReply_DataChangesReplies) Reset ¶
func (m *DataMsgReply_DataChangesReplies) Reset()
func (*DataMsgReply_DataChangesReplies) String ¶
func (m *DataMsgReply_DataChangesReplies) String() string
func (*DataMsgReply_DataChangesReplies) XXX_DiscardUnknown ¶ added in v1.6.0
func (m *DataMsgReply_DataChangesReplies) XXX_DiscardUnknown()
func (*DataMsgReply_DataChangesReplies) XXX_Marshal ¶ added in v1.6.0
func (m *DataMsgReply_DataChangesReplies) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DataMsgReply_DataChangesReplies) XXX_Merge ¶ added in v1.6.0
func (dst *DataMsgReply_DataChangesReplies) XXX_Merge(src proto.Message)
func (*DataMsgReply_DataChangesReplies) XXX_Size ¶ added in v1.6.0
func (m *DataMsgReply_DataChangesReplies) XXX_Size() int
func (*DataMsgReply_DataChangesReplies) XXX_Unmarshal ¶ added in v1.6.0
func (m *DataMsgReply_DataChangesReplies) XXX_Unmarshal(b []byte) error
type DataMsgReply_DataResyncsReplies ¶
type DataMsgReply_DataResyncsReplies struct { Replies []*DataResyncReply `protobuf:"bytes,1,rep,name=replies" json:"replies,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DataMsgReply_DataResyncsReplies) Descriptor ¶
func (*DataMsgReply_DataResyncsReplies) Descriptor() ([]byte, []int)
func (*DataMsgReply_DataResyncsReplies) GetReplies ¶
func (m *DataMsgReply_DataResyncsReplies) GetReplies() []*DataResyncReply
func (*DataMsgReply_DataResyncsReplies) ProtoMessage ¶
func (*DataMsgReply_DataResyncsReplies) ProtoMessage()
func (*DataMsgReply_DataResyncsReplies) Reset ¶
func (m *DataMsgReply_DataResyncsReplies) Reset()
func (*DataMsgReply_DataResyncsReplies) String ¶
func (m *DataMsgReply_DataResyncsReplies) String() string
func (*DataMsgReply_DataResyncsReplies) XXX_DiscardUnknown ¶ added in v1.6.0
func (m *DataMsgReply_DataResyncsReplies) XXX_DiscardUnknown()
func (*DataMsgReply_DataResyncsReplies) XXX_Marshal ¶ added in v1.6.0
func (m *DataMsgReply_DataResyncsReplies) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DataMsgReply_DataResyncsReplies) XXX_Merge ¶ added in v1.6.0
func (dst *DataMsgReply_DataResyncsReplies) XXX_Merge(src proto.Message)
func (*DataMsgReply_DataResyncsReplies) XXX_Size ¶ added in v1.6.0
func (m *DataMsgReply_DataResyncsReplies) XXX_Size() int
func (*DataMsgReply_DataResyncsReplies) XXX_Unmarshal ¶ added in v1.6.0
func (m *DataMsgReply_DataResyncsReplies) XXX_Unmarshal(b []byte) error
type DataMsgRequest ¶
type DataMsgRequest struct { MsgId *Seq `protobuf:"bytes,1,opt,name=msgId" json:"msgId,omitempty"` Txn *Seq `protobuf:"bytes,2,opt,name=txn" json:"txn,omitempty"` DataChanges []*DataChangeRequest `protobuf:"bytes,3,rep,name=dataChanges" json:"dataChanges,omitempty"` DataResyncs []*DataResyncRequest `protobuf:"bytes,4,rep,name=dataResyncs" json:"dataResyncs,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DataMsgRequest) Descriptor ¶
func (*DataMsgRequest) Descriptor() ([]byte, []int)
func (*DataMsgRequest) GetDataChanges ¶
func (m *DataMsgRequest) GetDataChanges() []*DataChangeRequest
func (*DataMsgRequest) GetDataResyncs ¶
func (m *DataMsgRequest) GetDataResyncs() []*DataResyncRequest
func (*DataMsgRequest) GetMsgId ¶
func (m *DataMsgRequest) GetMsgId() *Seq
func (*DataMsgRequest) GetTxn ¶
func (m *DataMsgRequest) GetTxn() *Seq
func (*DataMsgRequest) ProtoMessage ¶
func (*DataMsgRequest) ProtoMessage()
func (*DataMsgRequest) Reset ¶
func (m *DataMsgRequest) Reset()
func (*DataMsgRequest) String ¶
func (m *DataMsgRequest) String() string
func (*DataMsgRequest) XXX_DiscardUnknown ¶ added in v1.6.0
func (m *DataMsgRequest) XXX_DiscardUnknown()
func (*DataMsgRequest) XXX_Marshal ¶ added in v1.6.0
func (m *DataMsgRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DataMsgRequest) XXX_Merge ¶ added in v1.6.0
func (dst *DataMsgRequest) XXX_Merge(src proto.Message)
func (*DataMsgRequest) XXX_Size ¶ added in v1.6.0
func (m *DataMsgRequest) XXX_Size() int
func (*DataMsgRequest) XXX_Unmarshal ¶ added in v1.6.0
func (m *DataMsgRequest) XXX_Unmarshal(b []byte) error
type DataMsgServiceClient ¶
type DataMsgServiceClient interface { DataChanges(ctx context.Context, opts ...grpc.CallOption) (DataMsgService_DataChangesClient, error) DataResyncs(ctx context.Context, in *DataResyncRequests, opts ...grpc.CallOption) (*DataResyncReplies, error) Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingReply, error) }
func NewDataMsgServiceClient ¶
func NewDataMsgServiceClient(cc *grpc.ClientConn) DataMsgServiceClient
type DataMsgServiceServer ¶
type DataMsgServiceServer interface { DataChanges(DataMsgService_DataChangesServer) error DataResyncs(context.Context, *DataResyncRequests) (*DataResyncReplies, error) Ping(context.Context, *PingRequest) (*PingReply, error) }
type DataMsgService_DataChangesClient ¶
type DataMsgService_DataChangesClient interface { Send(*DataChangeRequest) error Recv() (*DataChangeReply, error) grpc.ClientStream }
type DataMsgService_DataChangesServer ¶
type DataMsgService_DataChangesServer interface { Send(*DataChangeReply) error Recv() (*DataChangeRequest, error) grpc.ServerStream }
type DataResyncReplies ¶
type DataResyncReplies struct { MsgId *Seq `protobuf:"bytes,1,opt,name=msgId" json:"msgId,omitempty"` Error *Error `protobuf:"bytes,2,opt,name=error" json:"error,omitempty"` DataResyncs *DataResyncReplies_DataResyncsReplies `protobuf:"bytes,3,opt,name=dataResyncs" json:"dataResyncs,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DataResyncReplies) Descriptor ¶
func (*DataResyncReplies) Descriptor() ([]byte, []int)
func (*DataResyncReplies) GetDataResyncs ¶
func (m *DataResyncReplies) GetDataResyncs() *DataResyncReplies_DataResyncsReplies
func (*DataResyncReplies) GetError ¶
func (m *DataResyncReplies) GetError() *Error
func (*DataResyncReplies) GetMsgId ¶
func (m *DataResyncReplies) GetMsgId() *Seq
func (*DataResyncReplies) ProtoMessage ¶
func (*DataResyncReplies) ProtoMessage()
func (*DataResyncReplies) Reset ¶
func (m *DataResyncReplies) Reset()
func (*DataResyncReplies) String ¶
func (m *DataResyncReplies) String() string
func (*DataResyncReplies) XXX_DiscardUnknown ¶ added in v1.6.0
func (m *DataResyncReplies) XXX_DiscardUnknown()
func (*DataResyncReplies) XXX_Marshal ¶ added in v1.6.0
func (m *DataResyncReplies) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DataResyncReplies) XXX_Merge ¶ added in v1.6.0
func (dst *DataResyncReplies) XXX_Merge(src proto.Message)
func (*DataResyncReplies) XXX_Size ¶ added in v1.6.0
func (m *DataResyncReplies) XXX_Size() int
func (*DataResyncReplies) XXX_Unmarshal ¶ added in v1.6.0
func (m *DataResyncReplies) XXX_Unmarshal(b []byte) error
type DataResyncReplies_DataResyncsReplies ¶
type DataResyncReplies_DataResyncsReplies struct { Replies []*DataResyncReply `protobuf:"bytes,1,rep,name=replies" json:"replies,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DataResyncReplies_DataResyncsReplies) Descriptor ¶
func (*DataResyncReplies_DataResyncsReplies) Descriptor() ([]byte, []int)
func (*DataResyncReplies_DataResyncsReplies) GetReplies ¶
func (m *DataResyncReplies_DataResyncsReplies) GetReplies() []*DataResyncReply
func (*DataResyncReplies_DataResyncsReplies) ProtoMessage ¶
func (*DataResyncReplies_DataResyncsReplies) ProtoMessage()
func (*DataResyncReplies_DataResyncsReplies) Reset ¶
func (m *DataResyncReplies_DataResyncsReplies) Reset()
func (*DataResyncReplies_DataResyncsReplies) String ¶
func (m *DataResyncReplies_DataResyncsReplies) String() string
func (*DataResyncReplies_DataResyncsReplies) XXX_DiscardUnknown ¶ added in v1.6.0
func (m *DataResyncReplies_DataResyncsReplies) XXX_DiscardUnknown()
func (*DataResyncReplies_DataResyncsReplies) XXX_Marshal ¶ added in v1.6.0
func (m *DataResyncReplies_DataResyncsReplies) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DataResyncReplies_DataResyncsReplies) XXX_Merge ¶ added in v1.6.0
func (dst *DataResyncReplies_DataResyncsReplies) XXX_Merge(src proto.Message)
func (*DataResyncReplies_DataResyncsReplies) XXX_Size ¶ added in v1.6.0
func (m *DataResyncReplies_DataResyncsReplies) XXX_Size() int
func (*DataResyncReplies_DataResyncsReplies) XXX_Unmarshal ¶ added in v1.6.0
func (m *DataResyncReplies_DataResyncsReplies) XXX_Unmarshal(b []byte) error
type DataResyncReply ¶
type DataResyncReply struct { ResyncId *Seq `protobuf:"bytes,1,opt,name=resyncId" json:"resyncId,omitempty"` Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"` // zero means success Result uint32 `protobuf:"varint,3,opt,name=result,proto3" json:"result,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DataResyncReply) Descriptor ¶
func (*DataResyncReply) Descriptor() ([]byte, []int)
func (*DataResyncReply) GetKey ¶
func (m *DataResyncReply) GetKey() string
func (*DataResyncReply) GetResult ¶
func (m *DataResyncReply) GetResult() uint32
func (*DataResyncReply) GetResyncId ¶
func (m *DataResyncReply) GetResyncId() *Seq
func (*DataResyncReply) ProtoMessage ¶
func (*DataResyncReply) ProtoMessage()
func (*DataResyncReply) Reset ¶
func (m *DataResyncReply) Reset()
func (*DataResyncReply) String ¶
func (m *DataResyncReply) String() string
func (*DataResyncReply) XXX_DiscardUnknown ¶ added in v1.6.0
func (m *DataResyncReply) XXX_DiscardUnknown()
func (*DataResyncReply) XXX_Marshal ¶ added in v1.6.0
func (m *DataResyncReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DataResyncReply) XXX_Merge ¶ added in v1.6.0
func (dst *DataResyncReply) XXX_Merge(src proto.Message)
func (*DataResyncReply) XXX_Size ¶ added in v1.6.0
func (m *DataResyncReply) XXX_Size() int
func (*DataResyncReply) XXX_Unmarshal ¶ added in v1.6.0
func (m *DataResyncReply) XXX_Unmarshal(b []byte) error
type DataResyncRequest ¶
type DataResyncRequest struct { Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` Content []byte `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"` ContentType string `protobuf:"bytes,3,opt,name=content_type,json=contentType,proto3" json:"content_type,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DataResyncRequest) Descriptor ¶
func (*DataResyncRequest) Descriptor() ([]byte, []int)
func (*DataResyncRequest) GetContent ¶
func (m *DataResyncRequest) GetContent() []byte
func (*DataResyncRequest) GetContentType ¶
func (m *DataResyncRequest) GetContentType() string
func (*DataResyncRequest) GetKey ¶
func (m *DataResyncRequest) GetKey() string
func (*DataResyncRequest) ProtoMessage ¶
func (*DataResyncRequest) ProtoMessage()
func (*DataResyncRequest) Reset ¶
func (m *DataResyncRequest) Reset()
func (*DataResyncRequest) String ¶
func (m *DataResyncRequest) String() string
func (*DataResyncRequest) XXX_DiscardUnknown ¶ added in v1.6.0
func (m *DataResyncRequest) XXX_DiscardUnknown()
func (*DataResyncRequest) XXX_Marshal ¶ added in v1.6.0
func (m *DataResyncRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DataResyncRequest) XXX_Merge ¶ added in v1.6.0
func (dst *DataResyncRequest) XXX_Merge(src proto.Message)
func (*DataResyncRequest) XXX_Size ¶ added in v1.6.0
func (m *DataResyncRequest) XXX_Size() int
func (*DataResyncRequest) XXX_Unmarshal ¶ added in v1.6.0
func (m *DataResyncRequest) XXX_Unmarshal(b []byte) error
type DataResyncRequests ¶
type DataResyncRequests struct { MsgId *Seq `protobuf:"bytes,1,opt,name=msgId" json:"msgId,omitempty"` DataResyncs []*DataResyncRequest `protobuf:"bytes,2,rep,name=dataResyncs" json:"dataResyncs,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DataResyncRequests) Descriptor ¶
func (*DataResyncRequests) Descriptor() ([]byte, []int)
func (*DataResyncRequests) GetDataResyncs ¶
func (m *DataResyncRequests) GetDataResyncs() []*DataResyncRequest
func (*DataResyncRequests) GetMsgId ¶
func (m *DataResyncRequests) GetMsgId() *Seq
func (*DataResyncRequests) ProtoMessage ¶
func (*DataResyncRequests) ProtoMessage()
func (*DataResyncRequests) Reset ¶
func (m *DataResyncRequests) Reset()
func (*DataResyncRequests) String ¶
func (m *DataResyncRequests) String() string
func (*DataResyncRequests) XXX_DiscardUnknown ¶ added in v1.6.0
func (m *DataResyncRequests) XXX_DiscardUnknown()
func (*DataResyncRequests) XXX_Marshal ¶ added in v1.6.0
func (m *DataResyncRequests) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DataResyncRequests) XXX_Merge ¶ added in v1.6.0
func (dst *DataResyncRequests) XXX_Merge(src proto.Message)
func (*DataResyncRequests) XXX_Size ¶ added in v1.6.0
func (m *DataResyncRequests) XXX_Size() int
func (*DataResyncRequests) XXX_Unmarshal ¶ added in v1.6.0
func (m *DataResyncRequests) XXX_Unmarshal(b []byte) error
type Error ¶
type Error struct { Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Error) Descriptor ¶
func (*Error) GetMessage ¶
func (*Error) ProtoMessage ¶
func (*Error) ProtoMessage()
func (*Error) XXX_DiscardUnknown ¶ added in v1.6.0
func (m *Error) XXX_DiscardUnknown()
func (*Error) XXX_Marshal ¶ added in v1.6.0
func (*Error) XXX_Unmarshal ¶ added in v1.6.0
type PingReply ¶
type PingReply struct { Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*PingReply) Descriptor ¶
func (*PingReply) GetMessage ¶
func (*PingReply) ProtoMessage ¶
func (*PingReply) ProtoMessage()
func (*PingReply) XXX_DiscardUnknown ¶ added in v1.6.0
func (m *PingReply) XXX_DiscardUnknown()
func (*PingReply) XXX_Marshal ¶ added in v1.6.0
func (*PingReply) XXX_Unmarshal ¶ added in v1.6.0
type PingRequest ¶
type PingRequest struct { Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*PingRequest) Descriptor ¶
func (*PingRequest) Descriptor() ([]byte, []int)
func (*PingRequest) GetMessage ¶
func (m *PingRequest) GetMessage() string
func (*PingRequest) ProtoMessage ¶
func (*PingRequest) ProtoMessage()
func (*PingRequest) Reset ¶
func (m *PingRequest) Reset()
func (*PingRequest) String ¶
func (m *PingRequest) String() string
func (*PingRequest) XXX_DiscardUnknown ¶ added in v1.6.0
func (m *PingRequest) XXX_DiscardUnknown()
func (*PingRequest) XXX_Marshal ¶ added in v1.6.0
func (m *PingRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PingRequest) XXX_Merge ¶ added in v1.6.0
func (dst *PingRequest) XXX_Merge(src proto.Message)
func (*PingRequest) XXX_Size ¶ added in v1.6.0
func (m *PingRequest) XXX_Size() int
func (*PingRequest) XXX_Unmarshal ¶ added in v1.6.0
func (m *PingRequest) XXX_Unmarshal(b []byte) error
type ResyncNeededCallback ¶
type ResyncNeededCallback struct { MsgId *Seq `protobuf:"bytes,1,opt,name=msgId" json:"msgId,omitempty"` // Optional Error *Error `protobuf:"bytes,2,opt,name=error" json:"error,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ResyncNeededCallback) Descriptor ¶
func (*ResyncNeededCallback) Descriptor() ([]byte, []int)
func (*ResyncNeededCallback) GetError ¶
func (m *ResyncNeededCallback) GetError() *Error
func (*ResyncNeededCallback) GetMsgId ¶
func (m *ResyncNeededCallback) GetMsgId() *Seq
func (*ResyncNeededCallback) ProtoMessage ¶
func (*ResyncNeededCallback) ProtoMessage()
func (*ResyncNeededCallback) Reset ¶
func (m *ResyncNeededCallback) Reset()
func (*ResyncNeededCallback) String ¶
func (m *ResyncNeededCallback) String() string
func (*ResyncNeededCallback) XXX_DiscardUnknown ¶ added in v1.6.0
func (m *ResyncNeededCallback) XXX_DiscardUnknown()
func (*ResyncNeededCallback) XXX_Marshal ¶ added in v1.6.0
func (m *ResyncNeededCallback) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ResyncNeededCallback) XXX_Merge ¶ added in v1.6.0
func (dst *ResyncNeededCallback) XXX_Merge(src proto.Message)
func (*ResyncNeededCallback) XXX_Size ¶ added in v1.6.0
func (m *ResyncNeededCallback) XXX_Size() int
func (*ResyncNeededCallback) XXX_Unmarshal ¶ added in v1.6.0
func (m *ResyncNeededCallback) XXX_Unmarshal(b []byte) error
type Seq ¶
type Seq struct { // The server that generates this seq Originator string `protobuf:"bytes,1,opt,name=originator,proto3" json:"originator,omitempty"` // UNIX Timestamp of seqence restart // google.protobuf.Timestamp seqCreated = 2; SeqCreatedSec int64 `protobuf:"varint,2,opt,name=seqCreatedSec,proto3" json:"seqCreatedSec,omitempty"` // Sequence Seq uint32 `protobuf:"varint,4,opt,name=seq,proto3" json:"seq,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Seq) Descriptor ¶
func (*Seq) GetOriginator ¶
func (*Seq) GetSeqCreatedSec ¶
func (*Seq) ProtoMessage ¶
func (*Seq) ProtoMessage()
func (*Seq) XXX_DiscardUnknown ¶ added in v1.6.0
func (m *Seq) XXX_DiscardUnknown()
func (*Seq) XXX_Marshal ¶ added in v1.6.0
func (*Seq) XXX_Unmarshal ¶ added in v1.6.0
Click to show internal directories.
Click to hide internal directories.