msg

package
v2.5.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 15, 2020 License: Apache-2.0 Imports: 11 Imported by: 1

Documentation

Overview

Package msg contains: - the definition of PROTOBUF structures and gRPC service, - helpers for mapping between PROTOBUF structures & the datasync_api.go.

Index

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) Done 

func (ev *ChangeEvent) Done(err error)

Done does nothing yet.

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

func (*ChangeWatchResp) GetValue 

func (ev *ChangeWatchResp) GetValue(val proto.Message) error

GetValue - see the comments in the interface datasync.ChangeEvent.

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 

func (m *DataChangeReply) XXX_DiscardUnknown()

func (*DataChangeReply) XXX_Marshal 

func (m *DataChangeReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DataChangeReply) XXX_Merge 

func (m *DataChangeReply) XXX_Merge(src proto.Message)

func (*DataChangeReply) XXX_Size 

func (m *DataChangeReply) XXX_Size() int

func (*DataChangeReply) XXX_Unmarshal 

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 

func (m *DataChangeRequest) XXX_DiscardUnknown()

func (*DataChangeRequest) XXX_Marshal 

func (m *DataChangeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DataChangeRequest) XXX_Merge 

func (m *DataChangeRequest) XXX_Merge(src proto.Message)

func (*DataChangeRequest) XXX_Size 

func (m *DataChangeRequest) XXX_Size() int

func (*DataChangeRequest) XXX_Unmarshal 

func (m *DataChangeRequest) XXX_Unmarshal(b []byte) error

type DataMsgReply 

type DataMsgReply struct {
	MsgId                *Seq                             `protobuf:"bytes,1,opt,name=msgId,proto3" json:"msgId,omitempty"`
	Error                *Error                           `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	DataChanges          *DataMsgReply_DataChangesReplies `protobuf:"bytes,3,opt,name=dataChanges,proto3" json:"dataChanges,omitempty"`
	DataResyncs          *DataMsgReply_DataResyncsReplies `protobuf:"bytes,4,opt,name=dataResyncs,proto3" 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 

func (m *DataMsgReply) XXX_DiscardUnknown()

func (*DataMsgReply) XXX_Marshal 

func (m *DataMsgReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DataMsgReply) XXX_Merge 

func (m *DataMsgReply) XXX_Merge(src proto.Message)

func (*DataMsgReply) XXX_Size 

func (m *DataMsgReply) XXX_Size() int

func (*DataMsgReply) XXX_Unmarshal 

func (m *DataMsgReply) XXX_Unmarshal(b []byte) error

type DataMsgReply_DataChangesReplies 

type DataMsgReply_DataChangesReplies struct {
	Replies              []*DataChangeReply `protobuf:"bytes,1,rep,name=replies,proto3" 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 

func (m *DataMsgReply_DataChangesReplies) XXX_DiscardUnknown()

func (*DataMsgReply_DataChangesReplies) XXX_Marshal 

func (m *DataMsgReply_DataChangesReplies) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DataMsgReply_DataChangesReplies) XXX_Merge 

func (m *DataMsgReply_DataChangesReplies) XXX_Merge(src proto.Message)

func (*DataMsgReply_DataChangesReplies) XXX_Size 

func (m *DataMsgReply_DataChangesReplies) XXX_Size() int

func (*DataMsgReply_DataChangesReplies) XXX_Unmarshal 

func (m *DataMsgReply_DataChangesReplies) XXX_Unmarshal(b []byte) error

type DataMsgReply_DataResyncsReplies 

type DataMsgReply_DataResyncsReplies struct {
	Replies              []*DataResyncReply `protobuf:"bytes,1,rep,name=replies,proto3" 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 

func (m *DataMsgReply_DataResyncsReplies) XXX_DiscardUnknown()

func (*DataMsgReply_DataResyncsReplies) XXX_Marshal 

func (m *DataMsgReply_DataResyncsReplies) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DataMsgReply_DataResyncsReplies) XXX_Merge 

func (m *DataMsgReply_DataResyncsReplies) XXX_Merge(src proto.Message)

func (*DataMsgReply_DataResyncsReplies) XXX_Size 

func (m *DataMsgReply_DataResyncsReplies) XXX_Size() int

func (*DataMsgReply_DataResyncsReplies) XXX_Unmarshal 

func (m *DataMsgReply_DataResyncsReplies) XXX_Unmarshal(b []byte) error

type DataMsgRequest 

type DataMsgRequest struct {
	MsgId                *Seq                 `protobuf:"bytes,1,opt,name=msgId,proto3" json:"msgId,omitempty"`
	Txn                  *Seq                 `protobuf:"bytes,2,opt,name=txn,proto3" json:"txn,omitempty"`
	DataChanges          []*DataChangeRequest `protobuf:"bytes,3,rep,name=dataChanges,proto3" json:"dataChanges,omitempty"`
	DataResyncs          []*DataResyncRequest `protobuf:"bytes,4,rep,name=dataResyncs,proto3" 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 

func (m *DataMsgRequest) XXX_DiscardUnknown()

func (*DataMsgRequest) XXX_Marshal 

func (m *DataMsgRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DataMsgRequest) XXX_Merge 

func (m *DataMsgRequest) XXX_Merge(src proto.Message)

func (*DataMsgRequest) XXX_Size 

func (m *DataMsgRequest) XXX_Size() int

func (*DataMsgRequest) XXX_Unmarshal 

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)
}

DataMsgServiceClient is the client API for DataMsgService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

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)
}

DataMsgServiceServer is the server API for DataMsgService service.

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,proto3" json:"msgId,omitempty"`
	Error                *Error                                `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	DataResyncs          *DataResyncReplies_DataResyncsReplies `protobuf:"bytes,3,opt,name=dataResyncs,proto3" 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 

func (m *DataResyncReplies) XXX_DiscardUnknown()

func (*DataResyncReplies) XXX_Marshal 

func (m *DataResyncReplies) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DataResyncReplies) XXX_Merge 

func (m *DataResyncReplies) XXX_Merge(src proto.Message)

func (*DataResyncReplies) XXX_Size 

func (m *DataResyncReplies) XXX_Size() int

func (*DataResyncReplies) XXX_Unmarshal 

func (m *DataResyncReplies) XXX_Unmarshal(b []byte) error

type DataResyncReplies_DataResyncsReplies 

type DataResyncReplies_DataResyncsReplies struct {
	Replies              []*DataResyncReply `protobuf:"bytes,1,rep,name=replies,proto3" 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 

func (m *DataResyncReplies_DataResyncsReplies) XXX_DiscardUnknown()

func (*DataResyncReplies_DataResyncsReplies) XXX_Marshal 

func (m *DataResyncReplies_DataResyncsReplies) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DataResyncReplies_DataResyncsReplies) XXX_Merge 

func (m *DataResyncReplies_DataResyncsReplies) XXX_Merge(src proto.Message)

func (*DataResyncReplies_DataResyncsReplies) XXX_Size 

func (m *DataResyncReplies_DataResyncsReplies) XXX_Size() int

func (*DataResyncReplies_DataResyncsReplies) XXX_Unmarshal 

func (m *DataResyncReplies_DataResyncsReplies) XXX_Unmarshal(b []byte) error

type DataResyncReply 

type DataResyncReply struct {
	ResyncId *Seq   `protobuf:"bytes,1,opt,name=resyncId,proto3" 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 

func (m *DataResyncReply) XXX_DiscardUnknown()

func (*DataResyncReply) XXX_Marshal 

func (m *DataResyncReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DataResyncReply) XXX_Merge 

func (m *DataResyncReply) XXX_Merge(src proto.Message)

func (*DataResyncReply) XXX_Size 

func (m *DataResyncReply) XXX_Size() int

func (*DataResyncReply) XXX_Unmarshal 

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 

func (m *DataResyncRequest) XXX_DiscardUnknown()

func (*DataResyncRequest) XXX_Marshal 

func (m *DataResyncRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DataResyncRequest) XXX_Merge 

func (m *DataResyncRequest) XXX_Merge(src proto.Message)

func (*DataResyncRequest) XXX_Size 

func (m *DataResyncRequest) XXX_Size() int

func (*DataResyncRequest) XXX_Unmarshal 

func (m *DataResyncRequest) XXX_Unmarshal(b []byte) error

type DataResyncRequests 

type DataResyncRequests struct {
	MsgId                *Seq                 `protobuf:"bytes,1,opt,name=msgId,proto3" json:"msgId,omitempty"`
	DataResyncs          []*DataResyncRequest `protobuf:"bytes,2,rep,name=dataResyncs,proto3" 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 

func (m *DataResyncRequests) XXX_DiscardUnknown()

func (*DataResyncRequests) XXX_Marshal 

func (m *DataResyncRequests) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DataResyncRequests) XXX_Merge 

func (m *DataResyncRequests) XXX_Merge(src proto.Message)

func (*DataResyncRequests) XXX_Size 

func (m *DataResyncRequests) XXX_Size() int

func (*DataResyncRequests) XXX_Unmarshal 

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) Descriptor() ([]byte, []int)

func (*Error) GetMessage 

func (m *Error) GetMessage() string

func (*Error) ProtoMessage 

func (*Error) ProtoMessage()

func (*Error) Reset 

func (m *Error) Reset()

func (*Error) String 

func (m *Error) String() string

func (*Error) XXX_DiscardUnknown 

func (m *Error) XXX_DiscardUnknown()

func (*Error) XXX_Marshal 

func (m *Error) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Error) XXX_Merge 

func (m *Error) XXX_Merge(src proto.Message)

func (*Error) XXX_Size 

func (m *Error) XXX_Size() int

func (*Error) XXX_Unmarshal 

func (m *Error) XXX_Unmarshal(b []byte) error

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) Descriptor() ([]byte, []int)

func (*PingReply) GetMessage 

func (m *PingReply) GetMessage() string

func (*PingReply) ProtoMessage 

func (*PingReply) ProtoMessage()

func (*PingReply) Reset 

func (m *PingReply) Reset()

func (*PingReply) String 

func (m *PingReply) String() string

func (*PingReply) XXX_DiscardUnknown 

func (m *PingReply) XXX_DiscardUnknown()

func (*PingReply) XXX_Marshal 

func (m *PingReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PingReply) XXX_Merge 

func (m *PingReply) XXX_Merge(src proto.Message)

func (*PingReply) XXX_Size 

func (m *PingReply) XXX_Size() int

func (*PingReply) XXX_Unmarshal 

func (m *PingReply) XXX_Unmarshal(b []byte) error

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 

func (m *PingRequest) XXX_DiscardUnknown()

func (*PingRequest) XXX_Marshal 

func (m *PingRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PingRequest) XXX_Merge 

func (m *PingRequest) XXX_Merge(src proto.Message)

func (*PingRequest) XXX_Size 

func (m *PingRequest) XXX_Size() int

func (*PingRequest) XXX_Unmarshal 

func (m *PingRequest) XXX_Unmarshal(b []byte) error

type PutDel 

type PutDel int32
const (
	PutDel_PUT PutDel = 0
	PutDel_DEL PutDel = 1
)

func (PutDel) EnumDescriptor 

func (PutDel) EnumDescriptor() ([]byte, []int)

func (PutDel) String 

func (x PutDel) String() string

type ResyncNeededCallback 

type ResyncNeededCallback struct {
	MsgId *Seq `protobuf:"bytes,1,opt,name=msgId,proto3" json:"msgId,omitempty"`
	// Optional
	Error                *Error   `protobuf:"bytes,2,opt,name=error,proto3" 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 

func (m *ResyncNeededCallback) XXX_DiscardUnknown()

func (*ResyncNeededCallback) XXX_Marshal 

func (m *ResyncNeededCallback) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResyncNeededCallback) XXX_Merge 

func (m *ResyncNeededCallback) XXX_Merge(src proto.Message)

func (*ResyncNeededCallback) XXX_Size 

func (m *ResyncNeededCallback) XXX_Size() int

func (*ResyncNeededCallback) XXX_Unmarshal 

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) Descriptor() ([]byte, []int)

func (*Seq) GetOriginator 

func (m *Seq) GetOriginator() string

func (*Seq) GetSeq 

func (m *Seq) GetSeq() uint32

func (*Seq) GetSeqCreatedSec 

func (m *Seq) GetSeqCreatedSec() int64

func (*Seq) ProtoMessage 

func (*Seq) ProtoMessage()

func (*Seq) Reset 

func (m *Seq) Reset()

func (*Seq) String 

func (m *Seq) String() string

func (*Seq) XXX_DiscardUnknown 

func (m *Seq) XXX_DiscardUnknown()

func (*Seq) XXX_Marshal 

func (m *Seq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Seq) XXX_Merge 

func (m *Seq) XXX_Merge(src proto.Message)

func (*Seq) XXX_Size 

func (m *Seq) XXX_Size() int

func (*Seq) XXX_Unmarshal 

func (m *Seq) XXX_Unmarshal(b []byte) error

type UnimplementedDataMsgServiceServer 

type UnimplementedDataMsgServiceServer struct {
}

UnimplementedDataMsgServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedDataMsgServiceServer) DataChanges 

func (*UnimplementedDataMsgServiceServer) DataChanges(srv DataMsgService_DataChangesServer) error

func (*UnimplementedDataMsgServiceServer) DataResyncs 

func (*UnimplementedDataMsgServiceServer) DataResyncs(ctx context.Context, req *DataResyncRequests) (*DataResyncReplies, error)

func (*UnimplementedDataMsgServiceServer) Ping 

func (*UnimplementedDataMsgServiceServer) Ping(ctx context.Context, req *PingRequest) (*PingReply, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.