msg

package
v2.2.0+incompatible Latest Latest
Warning

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

Go to latest
Published: Aug 23, 2019 License: Apache-2.0 Imports: 8 Imported by: 0

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 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 (m *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 (m *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,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 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 (m *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,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 (*DataMsgReply_DataChangesReplies) ProtoMessage

func (*DataMsgReply_DataChangesReplies) ProtoMessage()

func (*DataMsgReply_DataChangesReplies) Reset

func (*DataMsgReply_DataChangesReplies) 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 (m *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,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 (*DataMsgReply_DataResyncsReplies) ProtoMessage

func (*DataMsgReply_DataResyncsReplies) ProtoMessage()

func (*DataMsgReply_DataResyncsReplies) Reset

func (*DataMsgReply_DataResyncsReplies) 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 (m *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,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 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 (m *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)
}

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 (*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 (m *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,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 (*DataResyncReplies_DataResyncsReplies) ProtoMessage

func (*DataResyncReplies_DataResyncsReplies) ProtoMessage()

func (*DataResyncReplies_DataResyncsReplies) Reset

func (*DataResyncReplies_DataResyncsReplies) 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 (*DataResyncReplies_DataResyncsReplies) XXX_Size added in v1.6.0

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,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 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 (m *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 (m *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,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 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 (m *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) 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 added in v1.6.0

func (m *Error) XXX_DiscardUnknown()

func (*Error) XXX_Marshal added in v1.6.0

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

func (*Error) XXX_Merge added in v1.6.0

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

func (*Error) XXX_Size added in v1.6.0

func (m *Error) XXX_Size() int

func (*Error) XXX_Unmarshal added in v1.6.0

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 added in v1.6.0

func (m *PingReply) XXX_DiscardUnknown()

func (*PingReply) XXX_Marshal added in v1.6.0

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

func (*PingReply) XXX_Merge added in v1.6.0

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

func (*PingReply) XXX_Size added in v1.6.0

func (m *PingReply) XXX_Size() int

func (*PingReply) XXX_Unmarshal added in v1.6.0

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 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 (m *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 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 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 (m *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) 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 added in v1.6.0

func (m *Seq) XXX_DiscardUnknown()

func (*Seq) XXX_Marshal added in v1.6.0

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

func (*Seq) XXX_Merge added in v1.6.0

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

func (*Seq) XXX_Size added in v1.6.0

func (m *Seq) XXX_Size() int

func (*Seq) XXX_Unmarshal added in v1.6.0

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL