Versions in this module Expand all Collapse all v0 v0.1.2 Feb 6, 2025 v0.1.1 Sep 10, 2024 v0.1.0 Mar 10, 2024 Changes in this version + var File_datamsg_proto protoreflect.FileDescriptor + var PutDel_name = map[int32]string + var PutDel_value = map[string]int32 + func RegisterDataMsgServiceServer(s *grpc.Server, srv DataMsgServiceServer) + type ChangeEvent struct + func NewChangeWatchResp(ctx context.Context, message *DataChangeRequest, callback func(error)) *ChangeEvent + func (ev *ChangeEvent) Done(err error) + func (ev *ChangeEvent) GetChanges() []datasync.ProtoWatchResp + func (ev *ChangeEvent) GetContext() context.Context + type ChangeWatchResp struct + func (ev *ChangeWatchResp) GetChangeType() datasync.Op + func (ev *ChangeWatchResp) GetKey() string + func (ev *ChangeWatchResp) GetPrevValue(prevVal proto.Message) (prevExists bool, err error) + func (ev *ChangeWatchResp) GetRevision() int64 + func (ev *ChangeWatchResp) GetValue(val proto.Message) error + type DataChangeReply struct + Key string + OperationType PutDel + Result uint32 + func (*DataChangeReply) Descriptor() ([]byte, []int) + func (*DataChangeReply) ProtoMessage() + func (x *DataChangeReply) GetKey() string + func (x *DataChangeReply) GetOperationType() PutDel + func (x *DataChangeReply) GetResult() uint32 + func (x *DataChangeReply) ProtoReflect() protoreflect.Message + func (x *DataChangeReply) Reset() + func (x *DataChangeReply) String() string + type DataChangeRequest struct + Content []byte + ContentType string + Key string + OperationType PutDel + func (*DataChangeRequest) Descriptor() ([]byte, []int) + func (*DataChangeRequest) ProtoMessage() + func (x *DataChangeRequest) GetContent() []byte + func (x *DataChangeRequest) GetContentType() string + func (x *DataChangeRequest) GetKey() string + func (x *DataChangeRequest) GetOperationType() PutDel + func (x *DataChangeRequest) ProtoReflect() protoreflect.Message + func (x *DataChangeRequest) Reset() + func (x *DataChangeRequest) String() string + type DataMsgReply struct + DataChanges *DataMsgReply_DataChangesReplies + DataResyncs *DataMsgReply_DataResyncsReplies + Error *Error + MsgId *Seq + func (*DataMsgReply) Descriptor() ([]byte, []int) + func (*DataMsgReply) ProtoMessage() + func (x *DataMsgReply) GetDataChanges() *DataMsgReply_DataChangesReplies + func (x *DataMsgReply) GetDataResyncs() *DataMsgReply_DataResyncsReplies + func (x *DataMsgReply) GetError() *Error + func (x *DataMsgReply) GetMsgId() *Seq + func (x *DataMsgReply) ProtoReflect() protoreflect.Message + func (x *DataMsgReply) Reset() + func (x *DataMsgReply) String() string + type DataMsgReply_DataChangesReplies struct + Replies []*DataChangeReply + func (*DataMsgReply_DataChangesReplies) Descriptor() ([]byte, []int) + func (*DataMsgReply_DataChangesReplies) ProtoMessage() + func (x *DataMsgReply_DataChangesReplies) GetReplies() []*DataChangeReply + func (x *DataMsgReply_DataChangesReplies) ProtoReflect() protoreflect.Message + func (x *DataMsgReply_DataChangesReplies) Reset() + func (x *DataMsgReply_DataChangesReplies) String() string + type DataMsgReply_DataResyncsReplies struct + Replies []*DataResyncReply + func (*DataMsgReply_DataResyncsReplies) Descriptor() ([]byte, []int) + func (*DataMsgReply_DataResyncsReplies) ProtoMessage() + func (x *DataMsgReply_DataResyncsReplies) GetReplies() []*DataResyncReply + func (x *DataMsgReply_DataResyncsReplies) ProtoReflect() protoreflect.Message + func (x *DataMsgReply_DataResyncsReplies) Reset() + func (x *DataMsgReply_DataResyncsReplies) String() string + type DataMsgRequest struct + DataChanges []*DataChangeRequest + DataResyncs []*DataResyncRequest + MsgId *Seq + Txn *Seq + func (*DataMsgRequest) Descriptor() ([]byte, []int) + func (*DataMsgRequest) ProtoMessage() + func (x *DataMsgRequest) GetDataChanges() []*DataChangeRequest + func (x *DataMsgRequest) GetDataResyncs() []*DataResyncRequest + func (x *DataMsgRequest) GetMsgId() *Seq + func (x *DataMsgRequest) GetTxn() *Seq + func (x *DataMsgRequest) ProtoReflect() protoreflect.Message + func (x *DataMsgRequest) Reset() + func (x *DataMsgRequest) String() string + type DataMsgServiceClient interface + DataChanges func(ctx context.Context, opts ...grpc.CallOption) (DataMsgService_DataChangesClient, error) + DataResyncs func(ctx context.Context, in *DataResyncRequests, opts ...grpc.CallOption) (*DataResyncReplies, error) + Ping func(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingReply, error) + func NewDataMsgServiceClient(cc grpc.ClientConnInterface) DataMsgServiceClient + type DataMsgServiceServer interface + DataChanges func(DataMsgService_DataChangesServer) error + DataResyncs func(context.Context, *DataResyncRequests) (*DataResyncReplies, error) + Ping func(context.Context, *PingRequest) (*PingReply, error) + type DataMsgService_DataChangesClient interface + Recv func() (*DataChangeReply, error) + Send func(*DataChangeRequest) error + type DataMsgService_DataChangesServer interface + Recv func() (*DataChangeRequest, error) + Send func(*DataChangeReply) error + type DataResyncReplies struct + DataResyncs *DataResyncReplies_DataResyncsReplies + Error *Error + MsgId *Seq + func (*DataResyncReplies) Descriptor() ([]byte, []int) + func (*DataResyncReplies) ProtoMessage() + func (x *DataResyncReplies) GetDataResyncs() *DataResyncReplies_DataResyncsReplies + func (x *DataResyncReplies) GetError() *Error + func (x *DataResyncReplies) GetMsgId() *Seq + func (x *DataResyncReplies) ProtoReflect() protoreflect.Message + func (x *DataResyncReplies) Reset() + func (x *DataResyncReplies) String() string + type DataResyncReplies_DataResyncsReplies struct + Replies []*DataResyncReply + func (*DataResyncReplies_DataResyncsReplies) Descriptor() ([]byte, []int) + func (*DataResyncReplies_DataResyncsReplies) ProtoMessage() + func (x *DataResyncReplies_DataResyncsReplies) GetReplies() []*DataResyncReply + func (x *DataResyncReplies_DataResyncsReplies) ProtoReflect() protoreflect.Message + func (x *DataResyncReplies_DataResyncsReplies) Reset() + func (x *DataResyncReplies_DataResyncsReplies) String() string + type DataResyncReply struct + Key string + Result uint32 + ResyncId *Seq + func (*DataResyncReply) Descriptor() ([]byte, []int) + func (*DataResyncReply) ProtoMessage() + func (x *DataResyncReply) GetKey() string + func (x *DataResyncReply) GetResult() uint32 + func (x *DataResyncReply) GetResyncId() *Seq + func (x *DataResyncReply) ProtoReflect() protoreflect.Message + func (x *DataResyncReply) Reset() + func (x *DataResyncReply) String() string + type DataResyncRequest struct + Content []byte + ContentType string + Key string + func (*DataResyncRequest) Descriptor() ([]byte, []int) + func (*DataResyncRequest) ProtoMessage() + func (x *DataResyncRequest) GetContent() []byte + func (x *DataResyncRequest) GetContentType() string + func (x *DataResyncRequest) GetKey() string + func (x *DataResyncRequest) ProtoReflect() protoreflect.Message + func (x *DataResyncRequest) Reset() + func (x *DataResyncRequest) String() string + type DataResyncRequests struct + DataResyncs []*DataResyncRequest + MsgId *Seq + func (*DataResyncRequests) Descriptor() ([]byte, []int) + func (*DataResyncRequests) ProtoMessage() + func (x *DataResyncRequests) GetDataResyncs() []*DataResyncRequest + func (x *DataResyncRequests) GetMsgId() *Seq + func (x *DataResyncRequests) ProtoReflect() protoreflect.Message + func (x *DataResyncRequests) Reset() + func (x *DataResyncRequests) String() string + type Error struct + Message string + func (*Error) Descriptor() ([]byte, []int) + func (*Error) ProtoMessage() + func (x *Error) GetMessage() string + func (x *Error) ProtoReflect() protoreflect.Message + func (x *Error) Reset() + func (x *Error) String() string + type PingReply struct + Message string + func (*PingReply) Descriptor() ([]byte, []int) + func (*PingReply) ProtoMessage() + func (x *PingReply) GetMessage() string + func (x *PingReply) ProtoReflect() protoreflect.Message + func (x *PingReply) Reset() + func (x *PingReply) String() string + type PingRequest struct + Message string + func (*PingRequest) Descriptor() ([]byte, []int) + func (*PingRequest) ProtoMessage() + func (x *PingRequest) GetMessage() string + func (x *PingRequest) ProtoReflect() protoreflect.Message + func (x *PingRequest) Reset() + func (x *PingRequest) String() string + type PutDel int32 + const PutDel_DEL + const PutDel_PUT + func (PutDel) Descriptor() protoreflect.EnumDescriptor + func (PutDel) EnumDescriptor() ([]byte, []int) + func (PutDel) Type() protoreflect.EnumType + func (x PutDel) Enum() *PutDel + func (x PutDel) Number() protoreflect.EnumNumber + func (x PutDel) String() string + type ResyncNeededCallback struct + Error *Error + MsgId *Seq + func (*ResyncNeededCallback) Descriptor() ([]byte, []int) + func (*ResyncNeededCallback) ProtoMessage() + func (x *ResyncNeededCallback) GetError() *Error + func (x *ResyncNeededCallback) GetMsgId() *Seq + func (x *ResyncNeededCallback) ProtoReflect() protoreflect.Message + func (x *ResyncNeededCallback) Reset() + func (x *ResyncNeededCallback) String() string + type Seq struct + Originator string + Seq uint32 + SeqCreatedSec int64 + func (*Seq) Descriptor() ([]byte, []int) + func (*Seq) ProtoMessage() + func (x *Seq) GetOriginator() string + func (x *Seq) GetSeq() uint32 + func (x *Seq) GetSeqCreatedSec() int64 + func (x *Seq) ProtoReflect() protoreflect.Message + func (x *Seq) Reset() + func (x *Seq) String() string + type UnimplementedDataMsgServiceServer struct + func (*UnimplementedDataMsgServiceServer) DataChanges(DataMsgService_DataChangesServer) error + func (*UnimplementedDataMsgServiceServer) DataResyncs(context.Context, *DataResyncRequests) (*DataResyncReplies, error) + func (*UnimplementedDataMsgServiceServer) Ping(context.Context, *PingRequest) (*PingReply, error)
Go to main page