Documentation
¶
Index ¶
- Variables
- type AwakeReply
- type AwakeRequest
- type CreateSnapshotReply
- func (*CreateSnapshotReply) Descriptor() ([]byte, []int)deprecated
- func (x *CreateSnapshotReply) GetReason() string
- func (x *CreateSnapshotReply) GetSuccess() bool
- func (*CreateSnapshotReply) ProtoMessage()
- func (x *CreateSnapshotReply) ProtoReflect() protoreflect.Message
- func (x *CreateSnapshotReply) Reset()
- func (x *CreateSnapshotReply) String() string
- type CreateSnapshotRequest
- func (*CreateSnapshotRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateSnapshotRequest) GetSnapshotID() string
- func (*CreateSnapshotRequest) ProtoMessage()
- func (x *CreateSnapshotRequest) ProtoReflect() protoreflect.Message
- func (x *CreateSnapshotRequest) Reset()
- func (x *CreateSnapshotRequest) String() string
- type FetchSnapshotReply
- func (*FetchSnapshotReply) Descriptor() ([]byte, []int)deprecated
- func (x *FetchSnapshotReply) GetCount() int64
- func (x *FetchSnapshotReply) GetLastKey() []byte
- func (x *FetchSnapshotReply) GetReason() string
- func (x *FetchSnapshotReply) GetSuccess() bool
- func (*FetchSnapshotReply) ProtoMessage()
- func (x *FetchSnapshotReply) ProtoReflect() protoreflect.Message
- func (x *FetchSnapshotReply) Reset()
- func (x *FetchSnapshotReply) String() string
- type FetchSnapshotRequest
- func (*FetchSnapshotRequest) Descriptor() ([]byte, []int)deprecated
- func (x *FetchSnapshotRequest) GetCollection() string
- func (x *FetchSnapshotRequest) GetCount() int64
- func (x *FetchSnapshotRequest) GetKey() []byte
- func (x *FetchSnapshotRequest) GetOffset() uint64
- func (x *FetchSnapshotRequest) GetSnapshotID() string
- func (x *FetchSnapshotRequest) GetSubscriberID() string
- func (*FetchSnapshotRequest) ProtoMessage()
- func (x *FetchSnapshotRequest) ProtoReflect() protoreflect.Message
- func (x *FetchSnapshotRequest) Reset()
- func (x *FetchSnapshotRequest) String() string
- type GetStateReply
- func (*GetStateReply) Descriptor() ([]byte, []int)deprecated
- func (x *GetStateReply) GetCount() uint64
- func (x *GetStateReply) GetLastSeq() uint64
- func (x *GetStateReply) GetReason() string
- func (x *GetStateReply) GetSnapshotCount() uint64
- func (x *GetStateReply) GetSnapshotLastSeq() uint64
- func (x *GetStateReply) GetSuccess() bool
- func (*GetStateReply) ProtoMessage()
- func (x *GetStateReply) ProtoReflect() protoreflect.Message
- func (x *GetStateReply) Reset()
- func (x *GetStateReply) String() string
- type GetStateRequest
- type Packet
- type PipelineReply
- func (*PipelineReply) Descriptor() ([]byte, []int)deprecated
- func (x *PipelineReply) GetReason() string
- func (x *PipelineReply) GetSuccess() bool
- func (*PipelineReply) ProtoMessage()
- func (x *PipelineReply) ProtoReflect() protoreflect.Message
- func (x *PipelineReply) Reset()
- func (x *PipelineReply) String() string
- type PullEventsReply
- func (*PullEventsReply) Descriptor() ([]byte, []int)deprecated
- func (x *PullEventsReply) GetEvents() [][]byte
- func (x *PullEventsReply) GetLastSeq() uint64
- func (x *PullEventsReply) GetReason() string
- func (x *PullEventsReply) GetSuccess() bool
- func (*PullEventsReply) ProtoMessage()
- func (x *PullEventsReply) ProtoReflect() protoreflect.Message
- func (x *PullEventsReply) Reset()
- func (x *PullEventsReply) String() string
- type PullEventsRequest
- func (*PullEventsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *PullEventsRequest) GetCount() int64
- func (x *PullEventsRequest) GetOffset() uint64
- func (x *PullEventsRequest) GetPipelineID() uint64
- func (x *PullEventsRequest) GetStartAt() uint64
- func (x *PullEventsRequest) GetSubscriberID() string
- func (*PullEventsRequest) ProtoMessage()
- func (x *PullEventsRequest) ProtoReflect() protoreflect.Message
- func (x *PullEventsRequest) Reset()
- func (x *PullEventsRequest) String() string
- type PullSnapshotReply
- func (*PullSnapshotReply) Descriptor() ([]byte, []int)deprecated
- func (x *PullSnapshotReply) GetLastKey() []byte
- func (x *PullSnapshotReply) GetReason() string
- func (x *PullSnapshotReply) GetRecords() [][]byte
- func (x *PullSnapshotReply) GetSuccess() bool
- func (*PullSnapshotReply) ProtoMessage()
- func (x *PullSnapshotReply) ProtoReflect() protoreflect.Message
- func (x *PullSnapshotReply) Reset()
- func (x *PullSnapshotReply) String() string
- type PullSnapshotRequest
- func (*PullSnapshotRequest) Descriptor() ([]byte, []int)deprecated
- func (x *PullSnapshotRequest) GetCollection() string
- func (x *PullSnapshotRequest) GetCount() int64
- func (x *PullSnapshotRequest) GetKey() []byte
- func (x *PullSnapshotRequest) GetOffset() uint64
- func (x *PullSnapshotRequest) GetSnapshotID() string
- func (x *PullSnapshotRequest) GetSubscriberID() string
- func (*PullSnapshotRequest) ProtoMessage()
- func (x *PullSnapshotRequest) ProtoReflect() protoreflect.Message
- func (x *PullSnapshotRequest) Reset()
- func (x *PullSnapshotRequest) String() string
- type ReleaseSnapshotReply
- func (*ReleaseSnapshotReply) Descriptor() ([]byte, []int)deprecated
- func (x *ReleaseSnapshotReply) GetReason() string
- func (x *ReleaseSnapshotReply) GetSuccess() bool
- func (*ReleaseSnapshotReply) ProtoMessage()
- func (x *ReleaseSnapshotReply) ProtoReflect() protoreflect.Message
- func (x *ReleaseSnapshotReply) Reset()
- func (x *ReleaseSnapshotReply) String() string
- type ReleaseSnapshotRequest
- func (*ReleaseSnapshotRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ReleaseSnapshotRequest) GetSnapshotID() string
- func (*ReleaseSnapshotRequest) ProtoMessage()
- func (x *ReleaseSnapshotRequest) ProtoReflect() protoreflect.Message
- func (x *ReleaseSnapshotRequest) Reset()
- func (x *ReleaseSnapshotRequest) String() string
- type SuspendReply
- func (*SuspendReply) Descriptor() ([]byte, []int)deprecated
- func (x *SuspendReply) GetReason() string
- func (x *SuspendReply) GetSuccess() bool
- func (*SuspendReply) ProtoMessage()
- func (x *SuspendReply) ProtoReflect() protoreflect.Message
- func (x *SuspendReply) Reset()
- func (x *SuspendReply) String() string
- type SuspendRequest
- func (*SuspendRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SuspendRequest) GetSequence() uint64
- func (x *SuspendRequest) GetSubscriberID() string
- func (*SuspendRequest) ProtoMessage()
- func (x *SuspendRequest) ProtoReflect() protoreflect.Message
- func (x *SuspendRequest) Reset()
- func (x *SuspendRequest) String() string
Constants ¶
This section is empty.
Variables ¶
var File_pipeline_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type AwakeReply ¶ added in v0.2.25
type AwakeReply struct { Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"` // contains filtered or unexported fields }
func (*AwakeReply) Descriptor
deprecated
added in
v0.2.25
func (*AwakeReply) Descriptor() ([]byte, []int)
Deprecated: Use AwakeReply.ProtoReflect.Descriptor instead.
func (*AwakeReply) GetReason ¶ added in v0.2.25
func (x *AwakeReply) GetReason() string
func (*AwakeReply) GetSuccess ¶ added in v0.2.25
func (x *AwakeReply) GetSuccess() bool
func (*AwakeReply) ProtoMessage ¶ added in v0.2.25
func (*AwakeReply) ProtoMessage()
func (*AwakeReply) ProtoReflect ¶ added in v0.2.25
func (x *AwakeReply) ProtoReflect() protoreflect.Message
func (*AwakeReply) Reset ¶ added in v0.2.25
func (x *AwakeReply) Reset()
func (*AwakeReply) String ¶ added in v0.2.25
func (x *AwakeReply) String() string
type AwakeRequest ¶ added in v0.2.25
type AwakeRequest struct { SubscriberID string `protobuf:"bytes,1,opt,name=subscriberID,proto3" json:"subscriberID,omitempty"` // contains filtered or unexported fields }
func (*AwakeRequest) Descriptor
deprecated
added in
v0.2.25
func (*AwakeRequest) Descriptor() ([]byte, []int)
Deprecated: Use AwakeRequest.ProtoReflect.Descriptor instead.
func (*AwakeRequest) GetSubscriberID ¶ added in v0.2.25
func (x *AwakeRequest) GetSubscriberID() string
func (*AwakeRequest) ProtoMessage ¶ added in v0.2.25
func (*AwakeRequest) ProtoMessage()
func (*AwakeRequest) ProtoReflect ¶ added in v0.2.25
func (x *AwakeRequest) ProtoReflect() protoreflect.Message
func (*AwakeRequest) Reset ¶ added in v0.2.25
func (x *AwakeRequest) Reset()
func (*AwakeRequest) String ¶ added in v0.2.25
func (x *AwakeRequest) String() string
type CreateSnapshotReply ¶
type CreateSnapshotReply struct { Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"` // contains filtered or unexported fields }
func (*CreateSnapshotReply) Descriptor
deprecated
func (*CreateSnapshotReply) Descriptor() ([]byte, []int)
Deprecated: Use CreateSnapshotReply.ProtoReflect.Descriptor instead.
func (*CreateSnapshotReply) GetReason ¶
func (x *CreateSnapshotReply) GetReason() string
func (*CreateSnapshotReply) GetSuccess ¶
func (x *CreateSnapshotReply) GetSuccess() bool
func (*CreateSnapshotReply) ProtoMessage ¶
func (*CreateSnapshotReply) ProtoMessage()
func (*CreateSnapshotReply) ProtoReflect ¶ added in v0.2.25
func (x *CreateSnapshotReply) ProtoReflect() protoreflect.Message
func (*CreateSnapshotReply) Reset ¶
func (x *CreateSnapshotReply) Reset()
func (*CreateSnapshotReply) String ¶
func (x *CreateSnapshotReply) String() string
type CreateSnapshotRequest ¶
type CreateSnapshotRequest struct { SnapshotID string `protobuf:"bytes,1,opt,name=snapshotID,proto3" json:"snapshotID,omitempty"` // contains filtered or unexported fields }
func (*CreateSnapshotRequest) Descriptor
deprecated
func (*CreateSnapshotRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateSnapshotRequest.ProtoReflect.Descriptor instead.
func (*CreateSnapshotRequest) GetSnapshotID ¶
func (x *CreateSnapshotRequest) GetSnapshotID() string
func (*CreateSnapshotRequest) ProtoMessage ¶
func (*CreateSnapshotRequest) ProtoMessage()
func (*CreateSnapshotRequest) ProtoReflect ¶ added in v0.2.25
func (x *CreateSnapshotRequest) ProtoReflect() protoreflect.Message
func (*CreateSnapshotRequest) Reset ¶
func (x *CreateSnapshotRequest) Reset()
func (*CreateSnapshotRequest) String ¶
func (x *CreateSnapshotRequest) String() string
type FetchSnapshotReply ¶
type FetchSnapshotReply struct { Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"` LastKey []byte `protobuf:"bytes,3,opt,name=lastKey,proto3" json:"lastKey,omitempty"` Count int64 `protobuf:"varint,4,opt,name=count,proto3" json:"count,omitempty"` // contains filtered or unexported fields }
func (*FetchSnapshotReply) Descriptor
deprecated
func (*FetchSnapshotReply) Descriptor() ([]byte, []int)
Deprecated: Use FetchSnapshotReply.ProtoReflect.Descriptor instead.
func (*FetchSnapshotReply) GetCount ¶
func (x *FetchSnapshotReply) GetCount() int64
func (*FetchSnapshotReply) GetLastKey ¶
func (x *FetchSnapshotReply) GetLastKey() []byte
func (*FetchSnapshotReply) GetReason ¶
func (x *FetchSnapshotReply) GetReason() string
func (*FetchSnapshotReply) GetSuccess ¶
func (x *FetchSnapshotReply) GetSuccess() bool
func (*FetchSnapshotReply) ProtoMessage ¶
func (*FetchSnapshotReply) ProtoMessage()
func (*FetchSnapshotReply) ProtoReflect ¶ added in v0.2.25
func (x *FetchSnapshotReply) ProtoReflect() protoreflect.Message
func (*FetchSnapshotReply) Reset ¶
func (x *FetchSnapshotReply) Reset()
func (*FetchSnapshotReply) String ¶
func (x *FetchSnapshotReply) String() string
type FetchSnapshotRequest ¶
type FetchSnapshotRequest struct { SnapshotID string `protobuf:"bytes,1,opt,name=snapshotID,proto3" json:"snapshotID,omitempty"` SubscriberID string `protobuf:"bytes,2,opt,name=subscriberID,proto3" json:"subscriberID,omitempty"` Collection string `protobuf:"bytes,3,opt,name=collection,proto3" json:"collection,omitempty"` Key []byte `protobuf:"bytes,4,opt,name=key,proto3" json:"key,omitempty"` Offset uint64 `protobuf:"varint,5,opt,name=offset,proto3" json:"offset,omitempty"` Count int64 `protobuf:"varint,6,opt,name=count,proto3" json:"count,omitempty"` // contains filtered or unexported fields }
func (*FetchSnapshotRequest) Descriptor
deprecated
func (*FetchSnapshotRequest) Descriptor() ([]byte, []int)
Deprecated: Use FetchSnapshotRequest.ProtoReflect.Descriptor instead.
func (*FetchSnapshotRequest) GetCollection ¶
func (x *FetchSnapshotRequest) GetCollection() string
func (*FetchSnapshotRequest) GetCount ¶
func (x *FetchSnapshotRequest) GetCount() int64
func (*FetchSnapshotRequest) GetKey ¶
func (x *FetchSnapshotRequest) GetKey() []byte
func (*FetchSnapshotRequest) GetOffset ¶
func (x *FetchSnapshotRequest) GetOffset() uint64
func (*FetchSnapshotRequest) GetSnapshotID ¶
func (x *FetchSnapshotRequest) GetSnapshotID() string
func (*FetchSnapshotRequest) GetSubscriberID ¶
func (x *FetchSnapshotRequest) GetSubscriberID() string
func (*FetchSnapshotRequest) ProtoMessage ¶
func (*FetchSnapshotRequest) ProtoMessage()
func (*FetchSnapshotRequest) ProtoReflect ¶ added in v0.2.25
func (x *FetchSnapshotRequest) ProtoReflect() protoreflect.Message
func (*FetchSnapshotRequest) Reset ¶
func (x *FetchSnapshotRequest) Reset()
func (*FetchSnapshotRequest) String ¶
func (x *FetchSnapshotRequest) String() string
type GetStateReply ¶
type GetStateReply struct { Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"` LastSeq uint64 `protobuf:"varint,3,opt,name=lastSeq,proto3" json:"lastSeq,omitempty"` Count uint64 `protobuf:"varint,4,opt,name=count,proto3" json:"count,omitempty"` SnapshotLastSeq uint64 `protobuf:"varint,5,opt,name=snapshotLastSeq,proto3" json:"snapshotLastSeq,omitempty"` SnapshotCount uint64 `protobuf:"varint,6,opt,name=snapshotCount,proto3" json:"snapshotCount,omitempty"` // contains filtered or unexported fields }
func (*GetStateReply) Descriptor
deprecated
func (*GetStateReply) Descriptor() ([]byte, []int)
Deprecated: Use GetStateReply.ProtoReflect.Descriptor instead.
func (*GetStateReply) GetCount ¶
func (x *GetStateReply) GetCount() uint64
func (*GetStateReply) GetLastSeq ¶
func (x *GetStateReply) GetLastSeq() uint64
func (*GetStateReply) GetReason ¶
func (x *GetStateReply) GetReason() string
func (*GetStateReply) GetSnapshotCount ¶ added in v0.2.28
func (x *GetStateReply) GetSnapshotCount() uint64
func (*GetStateReply) GetSnapshotLastSeq ¶ added in v0.2.27
func (x *GetStateReply) GetSnapshotLastSeq() uint64
func (*GetStateReply) GetSuccess ¶
func (x *GetStateReply) GetSuccess() bool
func (*GetStateReply) ProtoMessage ¶
func (*GetStateReply) ProtoMessage()
func (*GetStateReply) ProtoReflect ¶ added in v0.2.25
func (x *GetStateReply) ProtoReflect() protoreflect.Message
func (*GetStateReply) Reset ¶
func (x *GetStateReply) Reset()
func (*GetStateReply) String ¶
func (x *GetStateReply) String() string
type GetStateRequest ¶
type GetStateRequest struct {
// contains filtered or unexported fields
}
func (*GetStateRequest) Descriptor
deprecated
func (*GetStateRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetStateRequest.ProtoReflect.Descriptor instead.
func (*GetStateRequest) ProtoMessage ¶
func (*GetStateRequest) ProtoMessage()
func (*GetStateRequest) ProtoReflect ¶ added in v0.2.25
func (x *GetStateRequest) ProtoReflect() protoreflect.Message
func (*GetStateRequest) Reset ¶
func (x *GetStateRequest) Reset()
func (*GetStateRequest) String ¶
func (x *GetStateRequest) String() string
type Packet ¶ added in v0.2.25
type Packet struct {
// contains filtered or unexported fields
}
func (*Packet) Descriptor
deprecated
added in
v0.2.25
func (*Packet) ProtoMessage ¶ added in v0.2.25
func (*Packet) ProtoMessage()
func (*Packet) ProtoReflect ¶ added in v0.2.25
func (x *Packet) ProtoReflect() protoreflect.Message
type PipelineReply ¶
type PipelineReply struct { Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"` // contains filtered or unexported fields }
func (*PipelineReply) Descriptor
deprecated
func (*PipelineReply) Descriptor() ([]byte, []int)
Deprecated: Use PipelineReply.ProtoReflect.Descriptor instead.
func (*PipelineReply) GetReason ¶
func (x *PipelineReply) GetReason() string
func (*PipelineReply) GetSuccess ¶
func (x *PipelineReply) GetSuccess() bool
func (*PipelineReply) ProtoMessage ¶
func (*PipelineReply) ProtoMessage()
func (*PipelineReply) ProtoReflect ¶ added in v0.2.25
func (x *PipelineReply) ProtoReflect() protoreflect.Message
func (*PipelineReply) Reset ¶
func (x *PipelineReply) Reset()
func (*PipelineReply) String ¶
func (x *PipelineReply) String() string
type PullEventsReply ¶ added in v0.2.25
type PullEventsReply struct { Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"` LastSeq uint64 `protobuf:"varint,3,opt,name=lastSeq,proto3" json:"lastSeq,omitempty"` Events [][]byte `protobuf:"bytes,4,rep,name=events,proto3" json:"events,omitempty"` // contains filtered or unexported fields }
func (*PullEventsReply) Descriptor
deprecated
added in
v0.2.25
func (*PullEventsReply) Descriptor() ([]byte, []int)
Deprecated: Use PullEventsReply.ProtoReflect.Descriptor instead.
func (*PullEventsReply) GetEvents ¶ added in v0.2.25
func (x *PullEventsReply) GetEvents() [][]byte
func (*PullEventsReply) GetLastSeq ¶ added in v0.2.25
func (x *PullEventsReply) GetLastSeq() uint64
func (*PullEventsReply) GetReason ¶ added in v0.2.25
func (x *PullEventsReply) GetReason() string
func (*PullEventsReply) GetSuccess ¶ added in v0.2.25
func (x *PullEventsReply) GetSuccess() bool
func (*PullEventsReply) ProtoMessage ¶ added in v0.2.25
func (*PullEventsReply) ProtoMessage()
func (*PullEventsReply) ProtoReflect ¶ added in v0.2.25
func (x *PullEventsReply) ProtoReflect() protoreflect.Message
func (*PullEventsReply) Reset ¶ added in v0.2.25
func (x *PullEventsReply) Reset()
func (*PullEventsReply) String ¶ added in v0.2.25
func (x *PullEventsReply) String() string
type PullEventsRequest ¶ added in v0.2.25
type PullEventsRequest struct { SubscriberID string `protobuf:"bytes,1,opt,name=subscriberID,proto3" json:"subscriberID,omitempty"` PipelineID uint64 `protobuf:"varint,2,opt,name=pipelineID,proto3" json:"pipelineID,omitempty"` StartAt uint64 `protobuf:"varint,3,opt,name=startAt,proto3" json:"startAt,omitempty"` Offset uint64 `protobuf:"varint,4,opt,name=offset,proto3" json:"offset,omitempty"` Count int64 `protobuf:"varint,5,opt,name=count,proto3" json:"count,omitempty"` // contains filtered or unexported fields }
func (*PullEventsRequest) Descriptor
deprecated
added in
v0.2.25
func (*PullEventsRequest) Descriptor() ([]byte, []int)
Deprecated: Use PullEventsRequest.ProtoReflect.Descriptor instead.
func (*PullEventsRequest) GetCount ¶ added in v0.2.25
func (x *PullEventsRequest) GetCount() int64
func (*PullEventsRequest) GetOffset ¶ added in v0.2.25
func (x *PullEventsRequest) GetOffset() uint64
func (*PullEventsRequest) GetPipelineID ¶ added in v0.2.25
func (x *PullEventsRequest) GetPipelineID() uint64
func (*PullEventsRequest) GetStartAt ¶ added in v0.2.25
func (x *PullEventsRequest) GetStartAt() uint64
func (*PullEventsRequest) GetSubscriberID ¶ added in v0.2.25
func (x *PullEventsRequest) GetSubscriberID() string
func (*PullEventsRequest) ProtoMessage ¶ added in v0.2.25
func (*PullEventsRequest) ProtoMessage()
func (*PullEventsRequest) ProtoReflect ¶ added in v0.2.25
func (x *PullEventsRequest) ProtoReflect() protoreflect.Message
func (*PullEventsRequest) Reset ¶ added in v0.2.25
func (x *PullEventsRequest) Reset()
func (*PullEventsRequest) String ¶ added in v0.2.25
func (x *PullEventsRequest) String() string
type PullSnapshotReply ¶ added in v0.2.25
type PullSnapshotReply struct { Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"` LastKey []byte `protobuf:"bytes,3,opt,name=lastKey,proto3" json:"lastKey,omitempty"` Records [][]byte `protobuf:"bytes,4,rep,name=records,proto3" json:"records,omitempty"` // contains filtered or unexported fields }
func (*PullSnapshotReply) Descriptor
deprecated
added in
v0.2.25
func (*PullSnapshotReply) Descriptor() ([]byte, []int)
Deprecated: Use PullSnapshotReply.ProtoReflect.Descriptor instead.
func (*PullSnapshotReply) GetLastKey ¶ added in v0.2.25
func (x *PullSnapshotReply) GetLastKey() []byte
func (*PullSnapshotReply) GetReason ¶ added in v0.2.25
func (x *PullSnapshotReply) GetReason() string
func (*PullSnapshotReply) GetRecords ¶ added in v0.2.25
func (x *PullSnapshotReply) GetRecords() [][]byte
func (*PullSnapshotReply) GetSuccess ¶ added in v0.2.25
func (x *PullSnapshotReply) GetSuccess() bool
func (*PullSnapshotReply) ProtoMessage ¶ added in v0.2.25
func (*PullSnapshotReply) ProtoMessage()
func (*PullSnapshotReply) ProtoReflect ¶ added in v0.2.25
func (x *PullSnapshotReply) ProtoReflect() protoreflect.Message
func (*PullSnapshotReply) Reset ¶ added in v0.2.25
func (x *PullSnapshotReply) Reset()
func (*PullSnapshotReply) String ¶ added in v0.2.25
func (x *PullSnapshotReply) String() string
type PullSnapshotRequest ¶ added in v0.2.25
type PullSnapshotRequest struct { SnapshotID string `protobuf:"bytes,1,opt,name=snapshotID,proto3" json:"snapshotID,omitempty"` SubscriberID string `protobuf:"bytes,2,opt,name=subscriberID,proto3" json:"subscriberID,omitempty"` Collection string `protobuf:"bytes,3,opt,name=collection,proto3" json:"collection,omitempty"` Key []byte `protobuf:"bytes,4,opt,name=key,proto3" json:"key,omitempty"` Offset uint64 `protobuf:"varint,5,opt,name=offset,proto3" json:"offset,omitempty"` Count int64 `protobuf:"varint,6,opt,name=count,proto3" json:"count,omitempty"` // contains filtered or unexported fields }
func (*PullSnapshotRequest) Descriptor
deprecated
added in
v0.2.25
func (*PullSnapshotRequest) Descriptor() ([]byte, []int)
Deprecated: Use PullSnapshotRequest.ProtoReflect.Descriptor instead.
func (*PullSnapshotRequest) GetCollection ¶ added in v0.2.25
func (x *PullSnapshotRequest) GetCollection() string
func (*PullSnapshotRequest) GetCount ¶ added in v0.2.25
func (x *PullSnapshotRequest) GetCount() int64
func (*PullSnapshotRequest) GetKey ¶ added in v0.2.25
func (x *PullSnapshotRequest) GetKey() []byte
func (*PullSnapshotRequest) GetOffset ¶ added in v0.2.25
func (x *PullSnapshotRequest) GetOffset() uint64
func (*PullSnapshotRequest) GetSnapshotID ¶ added in v0.2.25
func (x *PullSnapshotRequest) GetSnapshotID() string
func (*PullSnapshotRequest) GetSubscriberID ¶ added in v0.2.25
func (x *PullSnapshotRequest) GetSubscriberID() string
func (*PullSnapshotRequest) ProtoMessage ¶ added in v0.2.25
func (*PullSnapshotRequest) ProtoMessage()
func (*PullSnapshotRequest) ProtoReflect ¶ added in v0.2.25
func (x *PullSnapshotRequest) ProtoReflect() protoreflect.Message
func (*PullSnapshotRequest) Reset ¶ added in v0.2.25
func (x *PullSnapshotRequest) Reset()
func (*PullSnapshotRequest) String ¶ added in v0.2.25
func (x *PullSnapshotRequest) String() string
type ReleaseSnapshotReply ¶
type ReleaseSnapshotReply struct { Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"` // contains filtered or unexported fields }
func (*ReleaseSnapshotReply) Descriptor
deprecated
func (*ReleaseSnapshotReply) Descriptor() ([]byte, []int)
Deprecated: Use ReleaseSnapshotReply.ProtoReflect.Descriptor instead.
func (*ReleaseSnapshotReply) GetReason ¶
func (x *ReleaseSnapshotReply) GetReason() string
func (*ReleaseSnapshotReply) GetSuccess ¶
func (x *ReleaseSnapshotReply) GetSuccess() bool
func (*ReleaseSnapshotReply) ProtoMessage ¶
func (*ReleaseSnapshotReply) ProtoMessage()
func (*ReleaseSnapshotReply) ProtoReflect ¶ added in v0.2.25
func (x *ReleaseSnapshotReply) ProtoReflect() protoreflect.Message
func (*ReleaseSnapshotReply) Reset ¶
func (x *ReleaseSnapshotReply) Reset()
func (*ReleaseSnapshotReply) String ¶
func (x *ReleaseSnapshotReply) String() string
type ReleaseSnapshotRequest ¶
type ReleaseSnapshotRequest struct { SnapshotID string `protobuf:"bytes,1,opt,name=snapshotID,proto3" json:"snapshotID,omitempty"` // contains filtered or unexported fields }
func (*ReleaseSnapshotRequest) Descriptor
deprecated
func (*ReleaseSnapshotRequest) Descriptor() ([]byte, []int)
Deprecated: Use ReleaseSnapshotRequest.ProtoReflect.Descriptor instead.
func (*ReleaseSnapshotRequest) GetSnapshotID ¶
func (x *ReleaseSnapshotRequest) GetSnapshotID() string
func (*ReleaseSnapshotRequest) ProtoMessage ¶
func (*ReleaseSnapshotRequest) ProtoMessage()
func (*ReleaseSnapshotRequest) ProtoReflect ¶ added in v0.2.25
func (x *ReleaseSnapshotRequest) ProtoReflect() protoreflect.Message
func (*ReleaseSnapshotRequest) Reset ¶
func (x *ReleaseSnapshotRequest) Reset()
func (*ReleaseSnapshotRequest) String ¶
func (x *ReleaseSnapshotRequest) String() string
type SuspendReply ¶
type SuspendReply struct { Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"` // contains filtered or unexported fields }
func (*SuspendReply) Descriptor
deprecated
func (*SuspendReply) Descriptor() ([]byte, []int)
Deprecated: Use SuspendReply.ProtoReflect.Descriptor instead.
func (*SuspendReply) GetReason ¶
func (x *SuspendReply) GetReason() string
func (*SuspendReply) GetSuccess ¶
func (x *SuspendReply) GetSuccess() bool
func (*SuspendReply) ProtoMessage ¶
func (*SuspendReply) ProtoMessage()
func (*SuspendReply) ProtoReflect ¶ added in v0.2.25
func (x *SuspendReply) ProtoReflect() protoreflect.Message
func (*SuspendReply) Reset ¶
func (x *SuspendReply) Reset()
func (*SuspendReply) String ¶
func (x *SuspendReply) String() string
type SuspendRequest ¶
type SuspendRequest struct { SubscriberID string `protobuf:"bytes,1,opt,name=subscriberID,proto3" json:"subscriberID,omitempty"` Sequence uint64 `protobuf:"varint,3,opt,name=Sequence,proto3" json:"Sequence,omitempty"` // contains filtered or unexported fields }
func (*SuspendRequest) Descriptor
deprecated
func (*SuspendRequest) Descriptor() ([]byte, []int)
Deprecated: Use SuspendRequest.ProtoReflect.Descriptor instead.
func (*SuspendRequest) GetSequence ¶
func (x *SuspendRequest) GetSequence() uint64
func (*SuspendRequest) GetSubscriberID ¶
func (x *SuspendRequest) GetSubscriberID() string
func (*SuspendRequest) ProtoMessage ¶
func (*SuspendRequest) ProtoMessage()
func (*SuspendRequest) ProtoReflect ¶ added in v0.2.25
func (x *SuspendRequest) ProtoReflect() protoreflect.Message
func (*SuspendRequest) Reset ¶
func (x *SuspendRequest) Reset()
func (*SuspendRequest) String ¶
func (x *SuspendRequest) String() string