Documentation ¶
Index ¶
- Variables
- func RegisterExtentServiceServer(s *grpc.Server, srv ExtentServiceServer)
- func RegisterStreamManagerServiceServer(s *grpc.Server, srv StreamManagerServiceServer)
- type AllocExtentRequest
- func (*AllocExtentRequest) Descriptor() ([]byte, []int)
- func (m *AllocExtentRequest) GetExtentID() uint64
- func (m *AllocExtentRequest) Marshal() (dAtA []byte, err error)
- func (m *AllocExtentRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *AllocExtentRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*AllocExtentRequest) ProtoMessage()
- func (m *AllocExtentRequest) Reset()
- func (m *AllocExtentRequest) Size() (n int)
- func (m *AllocExtentRequest) String() string
- func (m *AllocExtentRequest) Unmarshal(dAtA []byte) error
- func (m *AllocExtentRequest) XXX_DiscardUnknown()
- func (m *AllocExtentRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AllocExtentRequest) XXX_Merge(src proto.Message)
- func (m *AllocExtentRequest) XXX_Size() int
- func (m *AllocExtentRequest) XXX_Unmarshal(b []byte) error
- type AllocExtentResponse
- func (*AllocExtentResponse) Descriptor() ([]byte, []int)
- func (m *AllocExtentResponse) GetCode() Code
- func (m *AllocExtentResponse) GetCodeDes() string
- func (m *AllocExtentResponse) GetDiskID() uint64
- func (m *AllocExtentResponse) Marshal() (dAtA []byte, err error)
- func (m *AllocExtentResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *AllocExtentResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*AllocExtentResponse) ProtoMessage()
- func (m *AllocExtentResponse) Reset()
- func (m *AllocExtentResponse) Size() (n int)
- func (m *AllocExtentResponse) String() string
- func (m *AllocExtentResponse) Unmarshal(dAtA []byte) error
- func (m *AllocExtentResponse) XXX_DiscardUnknown()
- func (m *AllocExtentResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AllocExtentResponse) XXX_Merge(src proto.Message)
- func (m *AllocExtentResponse) XXX_Size() int
- func (m *AllocExtentResponse) XXX_Unmarshal(b []byte) error
- type AppendRequest
- func (*AppendRequest) Descriptor() ([]byte, []int)
- func (m *AppendRequest) GetData() isAppendRequest_Data
- func (m *AppendRequest) GetHeader() *AppendRequestHeader
- func (m *AppendRequest) GetPayload() []byte
- func (m *AppendRequest) Marshal() (dAtA []byte, err error)
- func (m *AppendRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *AppendRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*AppendRequest) ProtoMessage()
- func (m *AppendRequest) Reset()
- func (m *AppendRequest) Size() (n int)
- func (m *AppendRequest) String() string
- func (m *AppendRequest) Unmarshal(dAtA []byte) error
- func (m *AppendRequest) XXX_DiscardUnknown()
- func (m *AppendRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AppendRequest) XXX_Merge(src proto.Message)
- func (*AppendRequest) XXX_OneofWrappers() []interface{}
- func (m *AppendRequest) XXX_Size() int
- func (m *AppendRequest) XXX_Unmarshal(b []byte) error
- type AppendRequestHeader
- func (*AppendRequestHeader) Descriptor() ([]byte, []int)
- func (m *AppendRequestHeader) GetBlocks() []uint32
- func (m *AppendRequestHeader) GetCommit() uint32
- func (m *AppendRequestHeader) GetEversion() uint64
- func (m *AppendRequestHeader) GetExtentID() uint64
- func (m *AppendRequestHeader) GetMustSync() bool
- func (m *AppendRequestHeader) GetRevision() int64
- func (m *AppendRequestHeader) Marshal() (dAtA []byte, err error)
- func (m *AppendRequestHeader) MarshalTo(dAtA []byte) (int, error)
- func (m *AppendRequestHeader) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*AppendRequestHeader) ProtoMessage()
- func (m *AppendRequestHeader) Reset()
- func (m *AppendRequestHeader) Size() (n int)
- func (m *AppendRequestHeader) String() string
- func (m *AppendRequestHeader) Unmarshal(dAtA []byte) error
- func (m *AppendRequestHeader) XXX_DiscardUnknown()
- func (m *AppendRequestHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AppendRequestHeader) XXX_Merge(src proto.Message)
- func (m *AppendRequestHeader) XXX_Size() int
- func (m *AppendRequestHeader) XXX_Unmarshal(b []byte) error
- type AppendRequest_Header
- type AppendRequest_Payload
- type AppendResponse
- func (*AppendResponse) Descriptor() ([]byte, []int)
- func (m *AppendResponse) GetCode() Code
- func (m *AppendResponse) GetCodeDes() string
- func (m *AppendResponse) GetEnd() uint32
- func (m *AppendResponse) GetOffsets() []uint32
- func (m *AppendResponse) Marshal() (dAtA []byte, err error)
- func (m *AppendResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *AppendResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*AppendResponse) ProtoMessage()
- func (m *AppendResponse) Reset()
- func (m *AppendResponse) Size() (n int)
- func (m *AppendResponse) String() string
- func (m *AppendResponse) Unmarshal(dAtA []byte) error
- func (m *AppendResponse) XXX_DiscardUnknown()
- func (m *AppendResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AppendResponse) XXX_Merge(src proto.Message)
- func (m *AppendResponse) XXX_Size() int
- func (m *AppendResponse) XXX_Unmarshal(b []byte) error
- type CheckCommitLengthRequest
- func (*CheckCommitLengthRequest) Descriptor() ([]byte, []int)
- func (m *CheckCommitLengthRequest) GetOwnerKey() string
- func (m *CheckCommitLengthRequest) GetRevision() int64
- func (m *CheckCommitLengthRequest) GetStreamID() uint64
- func (m *CheckCommitLengthRequest) Marshal() (dAtA []byte, err error)
- func (m *CheckCommitLengthRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *CheckCommitLengthRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CheckCommitLengthRequest) ProtoMessage()
- func (m *CheckCommitLengthRequest) Reset()
- func (m *CheckCommitLengthRequest) Size() (n int)
- func (m *CheckCommitLengthRequest) String() string
- func (m *CheckCommitLengthRequest) Unmarshal(dAtA []byte) error
- func (m *CheckCommitLengthRequest) XXX_DiscardUnknown()
- func (m *CheckCommitLengthRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CheckCommitLengthRequest) XXX_Merge(src proto.Message)
- func (m *CheckCommitLengthRequest) XXX_Size() int
- func (m *CheckCommitLengthRequest) XXX_Unmarshal(b []byte) error
- type CheckCommitLengthResponse
- func (*CheckCommitLengthResponse) Descriptor() ([]byte, []int)
- func (m *CheckCommitLengthResponse) GetCode() Code
- func (m *CheckCommitLengthResponse) GetCodeDes() string
- func (m *CheckCommitLengthResponse) GetEnd() uint32
- func (m *CheckCommitLengthResponse) GetLastExInfo() *ExtentInfo
- func (m *CheckCommitLengthResponse) GetStreamInfo() *StreamInfo
- func (m *CheckCommitLengthResponse) Marshal() (dAtA []byte, err error)
- func (m *CheckCommitLengthResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *CheckCommitLengthResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CheckCommitLengthResponse) ProtoMessage()
- func (m *CheckCommitLengthResponse) Reset()
- func (m *CheckCommitLengthResponse) Size() (n int)
- func (m *CheckCommitLengthResponse) String() string
- func (m *CheckCommitLengthResponse) Unmarshal(dAtA []byte) error
- func (m *CheckCommitLengthResponse) XXX_DiscardUnknown()
- func (m *CheckCommitLengthResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CheckCommitLengthResponse) XXX_Merge(src proto.Message)
- func (m *CheckCommitLengthResponse) XXX_Size() int
- func (m *CheckCommitLengthResponse) XXX_Unmarshal(b []byte) error
- type Code
- type CommitLengthRequest
- func (*CommitLengthRequest) Descriptor() ([]byte, []int)
- func (m *CommitLengthRequest) GetExtentID() uint64
- func (m *CommitLengthRequest) GetRevision() int64
- func (m *CommitLengthRequest) Marshal() (dAtA []byte, err error)
- func (m *CommitLengthRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *CommitLengthRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CommitLengthRequest) ProtoMessage()
- func (m *CommitLengthRequest) Reset()
- func (m *CommitLengthRequest) Size() (n int)
- func (m *CommitLengthRequest) String() string
- func (m *CommitLengthRequest) Unmarshal(dAtA []byte) error
- func (m *CommitLengthRequest) XXX_DiscardUnknown()
- func (m *CommitLengthRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CommitLengthRequest) XXX_Merge(src proto.Message)
- func (m *CommitLengthRequest) XXX_Size() int
- func (m *CommitLengthRequest) XXX_Unmarshal(b []byte) error
- type CommitLengthResponse
- func (*CommitLengthResponse) Descriptor() ([]byte, []int)
- func (m *CommitLengthResponse) GetCode() Code
- func (m *CommitLengthResponse) GetCodeDes() string
- func (m *CommitLengthResponse) GetLength() uint32
- func (m *CommitLengthResponse) Marshal() (dAtA []byte, err error)
- func (m *CommitLengthResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *CommitLengthResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CommitLengthResponse) ProtoMessage()
- func (m *CommitLengthResponse) Reset()
- func (m *CommitLengthResponse) Size() (n int)
- func (m *CommitLengthResponse) String() string
- func (m *CommitLengthResponse) Unmarshal(dAtA []byte) error
- func (m *CommitLengthResponse) XXX_DiscardUnknown()
- func (m *CommitLengthResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CommitLengthResponse) XXX_Merge(src proto.Message)
- func (m *CommitLengthResponse) XXX_Size() int
- func (m *CommitLengthResponse) XXX_Unmarshal(b []byte) error
- type CopyExtentRequest
- func (*CopyExtentRequest) Descriptor() ([]byte, []int)
- func (m *CopyExtentRequest) GetEversion() uint64
- func (m *CopyExtentRequest) GetExtentID() uint64
- func (m *CopyExtentRequest) GetOffset() uint64
- func (m *CopyExtentRequest) GetSize_() uint64
- func (m *CopyExtentRequest) Marshal() (dAtA []byte, err error)
- func (m *CopyExtentRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *CopyExtentRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CopyExtentRequest) ProtoMessage()
- func (m *CopyExtentRequest) Reset()
- func (m *CopyExtentRequest) Size() (n int)
- func (m *CopyExtentRequest) String() string
- func (m *CopyExtentRequest) Unmarshal(dAtA []byte) error
- func (m *CopyExtentRequest) XXX_DiscardUnknown()
- func (m *CopyExtentRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CopyExtentRequest) XXX_Merge(src proto.Message)
- func (m *CopyExtentRequest) XXX_Size() int
- func (m *CopyExtentRequest) XXX_Unmarshal(b []byte) error
- type CopyExtentResponse
- func (*CopyExtentResponse) Descriptor() ([]byte, []int)
- func (m *CopyExtentResponse) GetData() isCopyExtentResponse_Data
- func (m *CopyExtentResponse) GetHeader() *CopyResponseHeader
- func (m *CopyExtentResponse) GetPayload() []byte
- func (m *CopyExtentResponse) Marshal() (dAtA []byte, err error)
- func (m *CopyExtentResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *CopyExtentResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CopyExtentResponse) ProtoMessage()
- func (m *CopyExtentResponse) Reset()
- func (m *CopyExtentResponse) Size() (n int)
- func (m *CopyExtentResponse) String() string
- func (m *CopyExtentResponse) Unmarshal(dAtA []byte) error
- func (m *CopyExtentResponse) XXX_DiscardUnknown()
- func (m *CopyExtentResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CopyExtentResponse) XXX_Merge(src proto.Message)
- func (*CopyExtentResponse) XXX_OneofWrappers() []interface{}
- func (m *CopyExtentResponse) XXX_Size() int
- func (m *CopyExtentResponse) XXX_Unmarshal(b []byte) error
- type CopyExtentResponse_Header
- type CopyExtentResponse_Payload
- type CopyResponseHeader
- func (*CopyResponseHeader) Descriptor() ([]byte, []int)
- func (m *CopyResponseHeader) GetCode() Code
- func (m *CopyResponseHeader) GetCodeDes() string
- func (m *CopyResponseHeader) GetPayloadLen() uint64
- func (m *CopyResponseHeader) Marshal() (dAtA []byte, err error)
- func (m *CopyResponseHeader) MarshalTo(dAtA []byte) (int, error)
- func (m *CopyResponseHeader) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CopyResponseHeader) ProtoMessage()
- func (m *CopyResponseHeader) Reset()
- func (m *CopyResponseHeader) Size() (n int)
- func (m *CopyResponseHeader) String() string
- func (m *CopyResponseHeader) Unmarshal(dAtA []byte) error
- func (m *CopyResponseHeader) XXX_DiscardUnknown()
- func (m *CopyResponseHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CopyResponseHeader) XXX_Merge(src proto.Message)
- func (m *CopyResponseHeader) XXX_Size() int
- func (m *CopyResponseHeader) XXX_Unmarshal(b []byte) error
- type CreateExtentRequest
- func (*CreateExtentRequest) Descriptor() ([]byte, []int)
- func (m *CreateExtentRequest) GetStreamID() uint64
- func (m *CreateExtentRequest) Marshal() (dAtA []byte, err error)
- func (m *CreateExtentRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *CreateExtentRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CreateExtentRequest) ProtoMessage()
- func (m *CreateExtentRequest) Reset()
- func (m *CreateExtentRequest) Size() (n int)
- func (m *CreateExtentRequest) String() string
- func (m *CreateExtentRequest) Unmarshal(dAtA []byte) error
- func (m *CreateExtentRequest) XXX_DiscardUnknown()
- func (m *CreateExtentRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CreateExtentRequest) XXX_Merge(src proto.Message)
- func (m *CreateExtentRequest) XXX_Size() int
- func (m *CreateExtentRequest) XXX_Unmarshal(b []byte) error
- type CreateExtentResponse
- func (*CreateExtentResponse) Descriptor() ([]byte, []int)
- func (m *CreateExtentResponse) GetCode() Code
- func (m *CreateExtentResponse) GetCodeDes() string
- func (m *CreateExtentResponse) GetExtentID() uint64
- func (m *CreateExtentResponse) Marshal() (dAtA []byte, err error)
- func (m *CreateExtentResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *CreateExtentResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CreateExtentResponse) ProtoMessage()
- func (m *CreateExtentResponse) Reset()
- func (m *CreateExtentResponse) Size() (n int)
- func (m *CreateExtentResponse) String() string
- func (m *CreateExtentResponse) Unmarshal(dAtA []byte) error
- func (m *CreateExtentResponse) XXX_DiscardUnknown()
- func (m *CreateExtentResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CreateExtentResponse) XXX_Merge(src proto.Message)
- func (m *CreateExtentResponse) XXX_Size() int
- func (m *CreateExtentResponse) XXX_Unmarshal(b []byte) error
- type CreateStreamRequest
- func (*CreateStreamRequest) Descriptor() ([]byte, []int)
- func (m *CreateStreamRequest) GetDataShard() uint32
- func (m *CreateStreamRequest) GetParityShard() uint32
- func (m *CreateStreamRequest) Marshal() (dAtA []byte, err error)
- func (m *CreateStreamRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *CreateStreamRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CreateStreamRequest) ProtoMessage()
- func (m *CreateStreamRequest) Reset()
- func (m *CreateStreamRequest) Size() (n int)
- func (m *CreateStreamRequest) String() string
- func (m *CreateStreamRequest) Unmarshal(dAtA []byte) error
- func (m *CreateStreamRequest) XXX_DiscardUnknown()
- func (m *CreateStreamRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CreateStreamRequest) XXX_Merge(src proto.Message)
- func (m *CreateStreamRequest) XXX_Size() int
- func (m *CreateStreamRequest) XXX_Unmarshal(b []byte) error
- type CreateStreamResponse
- func (*CreateStreamResponse) Descriptor() ([]byte, []int)
- func (m *CreateStreamResponse) GetCode() Code
- func (m *CreateStreamResponse) GetCodeDes() string
- func (m *CreateStreamResponse) GetExtent() *ExtentInfo
- func (m *CreateStreamResponse) GetStream() *StreamInfo
- func (m *CreateStreamResponse) Marshal() (dAtA []byte, err error)
- func (m *CreateStreamResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *CreateStreamResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CreateStreamResponse) ProtoMessage()
- func (m *CreateStreamResponse) Reset()
- func (m *CreateStreamResponse) Size() (n int)
- func (m *CreateStreamResponse) String() string
- func (m *CreateStreamResponse) Unmarshal(dAtA []byte) error
- func (m *CreateStreamResponse) XXX_DiscardUnknown()
- func (m *CreateStreamResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CreateStreamResponse) XXX_Merge(src proto.Message)
- func (m *CreateStreamResponse) XXX_Size() int
- func (m *CreateStreamResponse) XXX_Unmarshal(b []byte) error
- type DF
- func (*DF) Descriptor() ([]byte, []int)
- func (m *DF) GetFree() uint64
- func (m *DF) GetOnline() bool
- func (m *DF) GetTotal() uint64
- func (m *DF) Marshal() (dAtA []byte, err error)
- func (m *DF) MarshalTo(dAtA []byte) (int, error)
- func (m *DF) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*DF) ProtoMessage()
- func (m *DF) Reset()
- func (m *DF) Size() (n int)
- func (m *DF) String() string
- func (m *DF) Unmarshal(dAtA []byte) error
- func (m *DF) XXX_DiscardUnknown()
- func (m *DF) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DF) XXX_Merge(src proto.Message)
- func (m *DF) XXX_Size() int
- func (m *DF) XXX_Unmarshal(b []byte) error
- type DfRequest
- func (*DfRequest) Descriptor() ([]byte, []int)
- func (m *DfRequest) GetDiskIDs() []uint64
- func (m *DfRequest) GetTasks() []*RecoveryTask
- func (m *DfRequest) Marshal() (dAtA []byte, err error)
- func (m *DfRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *DfRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*DfRequest) ProtoMessage()
- func (m *DfRequest) Reset()
- func (m *DfRequest) Size() (n int)
- func (m *DfRequest) String() string
- func (m *DfRequest) Unmarshal(dAtA []byte) error
- func (m *DfRequest) XXX_DiscardUnknown()
- func (m *DfRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DfRequest) XXX_Merge(src proto.Message)
- func (m *DfRequest) XXX_Size() int
- func (m *DfRequest) XXX_Unmarshal(b []byte) error
- type DfResponse
- func (*DfResponse) Descriptor() ([]byte, []int)
- func (m *DfResponse) GetDiskStatus() map[uint64]*DF
- func (m *DfResponse) GetDoneTask() []*RecoveryTaskStatus
- func (m *DfResponse) Marshal() (dAtA []byte, err error)
- func (m *DfResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *DfResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*DfResponse) ProtoMessage()
- func (m *DfResponse) Reset()
- func (m *DfResponse) Size() (n int)
- func (m *DfResponse) String() string
- func (m *DfResponse) Unmarshal(dAtA []byte) error
- func (m *DfResponse) XXX_DiscardUnknown()
- func (m *DfResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DfResponse) XXX_Merge(src proto.Message)
- func (m *DfResponse) XXX_Size() int
- func (m *DfResponse) XXX_Unmarshal(b []byte) error
- type DiskInfo
- func (*DiskInfo) Descriptor() ([]byte, []int)
- func (m *DiskInfo) GetDiskID() uint64
- func (m *DiskInfo) GetOnline() bool
- func (m *DiskInfo) GetUuid() string
- func (m *DiskInfo) Marshal() (dAtA []byte, err error)
- func (m *DiskInfo) MarshalTo(dAtA []byte) (int, error)
- func (m *DiskInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*DiskInfo) ProtoMessage()
- func (m *DiskInfo) Reset()
- func (m *DiskInfo) Size() (n int)
- func (m *DiskInfo) String() string
- func (m *DiskInfo) Unmarshal(dAtA []byte) error
- func (m *DiskInfo) XXX_DiscardUnknown()
- func (m *DiskInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DiskInfo) XXX_Merge(src proto.Message)
- func (m *DiskInfo) XXX_Size() int
- func (m *DiskInfo) XXX_Unmarshal(b []byte) error
- type ExtentInfo
- func (*ExtentInfo) Descriptor() ([]byte, []int)
- func (m *ExtentInfo) GetAvali() uint32
- func (m *ExtentInfo) GetEversion() uint64
- func (m *ExtentInfo) GetExtentID() uint64
- func (m *ExtentInfo) GetParity() []uint64
- func (m *ExtentInfo) GetParityDisk() []uint64
- func (m *ExtentInfo) GetRefs() uint64
- func (m *ExtentInfo) GetReplicateDisks() []uint64
- func (m *ExtentInfo) GetReplicates() []uint64
- func (m *ExtentInfo) GetSealedLength() uint64
- func (m *ExtentInfo) Marshal() (dAtA []byte, err error)
- func (m *ExtentInfo) MarshalTo(dAtA []byte) (int, error)
- func (m *ExtentInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ExtentInfo) ProtoMessage()
- func (m *ExtentInfo) Reset()
- func (m *ExtentInfo) Size() (n int)
- func (m *ExtentInfo) String() string
- func (m *ExtentInfo) Unmarshal(dAtA []byte) error
- func (m *ExtentInfo) XXX_DiscardUnknown()
- func (m *ExtentInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ExtentInfo) XXX_Merge(src proto.Message)
- func (m *ExtentInfo) XXX_Size() int
- func (m *ExtentInfo) XXX_Unmarshal(b []byte) error
- type ExtentInfoRequest
- func (*ExtentInfoRequest) Descriptor() ([]byte, []int)
- func (m *ExtentInfoRequest) GetExtentID() uint64
- func (m *ExtentInfoRequest) Marshal() (dAtA []byte, err error)
- func (m *ExtentInfoRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ExtentInfoRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ExtentInfoRequest) ProtoMessage()
- func (m *ExtentInfoRequest) Reset()
- func (m *ExtentInfoRequest) Size() (n int)
- func (m *ExtentInfoRequest) String() string
- func (m *ExtentInfoRequest) Unmarshal(dAtA []byte) error
- func (m *ExtentInfoRequest) XXX_DiscardUnknown()
- func (m *ExtentInfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ExtentInfoRequest) XXX_Merge(src proto.Message)
- func (m *ExtentInfoRequest) XXX_Size() int
- func (m *ExtentInfoRequest) XXX_Unmarshal(b []byte) error
- type ExtentInfoResponse
- func (*ExtentInfoResponse) Descriptor() ([]byte, []int)
- func (m *ExtentInfoResponse) GetCode() Code
- func (m *ExtentInfoResponse) GetCodeDes() string
- func (m *ExtentInfoResponse) GetExInfo() *ExtentInfo
- func (m *ExtentInfoResponse) Marshal() (dAtA []byte, err error)
- func (m *ExtentInfoResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *ExtentInfoResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ExtentInfoResponse) ProtoMessage()
- func (m *ExtentInfoResponse) Reset()
- func (m *ExtentInfoResponse) Size() (n int)
- func (m *ExtentInfoResponse) String() string
- func (m *ExtentInfoResponse) Unmarshal(dAtA []byte) error
- func (m *ExtentInfoResponse) XXX_DiscardUnknown()
- func (m *ExtentInfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ExtentInfoResponse) XXX_Merge(src proto.Message)
- func (m *ExtentInfoResponse) XXX_Size() int
- func (m *ExtentInfoResponse) XXX_Unmarshal(b []byte) error
- type ExtentServiceClient
- type ExtentServiceServer
- type ExtentService_AppendClient
- type ExtentService_AppendServer
- type ExtentService_CopyExtentClient
- type ExtentService_CopyExtentServer
- type ExtentService_HeartbeatClient
- type ExtentService_HeartbeatServer
- type ExtentService_ReadBlocksClient
- type ExtentService_ReadBlocksServer
- type MemberValue
- func (*MemberValue) Descriptor() ([]byte, []int)
- func (m *MemberValue) GetGrpcURL() string
- func (m *MemberValue) GetID() uint64
- func (m *MemberValue) GetName() string
- func (m *MemberValue) Marshal() (dAtA []byte, err error)
- func (m *MemberValue) MarshalTo(dAtA []byte) (int, error)
- func (m *MemberValue) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MemberValue) ProtoMessage()
- func (m *MemberValue) Reset()
- func (m *MemberValue) Size() (n int)
- func (m *MemberValue) String() string
- func (m *MemberValue) Unmarshal(dAtA []byte) error
- func (m *MemberValue) XXX_DiscardUnknown()
- func (m *MemberValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MemberValue) XXX_Merge(src proto.Message)
- func (m *MemberValue) XXX_Size() int
- func (m *MemberValue) XXX_Unmarshal(b []byte) error
- type MultiModifySplitRequest
- func (*MultiModifySplitRequest) Descriptor() ([]byte, []int)
- func (m *MultiModifySplitRequest) GetLogStreamSealedLength() uint32
- func (m *MultiModifySplitRequest) GetMetaStreamSealedLength() uint32
- func (m *MultiModifySplitRequest) GetMidKey() []byte
- func (m *MultiModifySplitRequest) GetOwnerKey() string
- func (m *MultiModifySplitRequest) GetPartID() uint64
- func (m *MultiModifySplitRequest) GetRevision() int64
- func (m *MultiModifySplitRequest) GetRowStreamSealedLength() uint32
- func (m *MultiModifySplitRequest) Marshal() (dAtA []byte, err error)
- func (m *MultiModifySplitRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *MultiModifySplitRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MultiModifySplitRequest) ProtoMessage()
- func (m *MultiModifySplitRequest) Reset()
- func (m *MultiModifySplitRequest) Size() (n int)
- func (m *MultiModifySplitRequest) String() string
- func (m *MultiModifySplitRequest) Unmarshal(dAtA []byte) error
- func (m *MultiModifySplitRequest) XXX_DiscardUnknown()
- func (m *MultiModifySplitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MultiModifySplitRequest) XXX_Merge(src proto.Message)
- func (m *MultiModifySplitRequest) XXX_Size() int
- func (m *MultiModifySplitRequest) XXX_Unmarshal(b []byte) error
- type MultiModifySplitResponse
- func (*MultiModifySplitResponse) Descriptor() ([]byte, []int)
- func (m *MultiModifySplitResponse) GetCode() Code
- func (m *MultiModifySplitResponse) GetCodeDes() string
- func (m *MultiModifySplitResponse) Marshal() (dAtA []byte, err error)
- func (m *MultiModifySplitResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *MultiModifySplitResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MultiModifySplitResponse) ProtoMessage()
- func (m *MultiModifySplitResponse) Reset()
- func (m *MultiModifySplitResponse) Size() (n int)
- func (m *MultiModifySplitResponse) String() string
- func (m *MultiModifySplitResponse) Unmarshal(dAtA []byte) error
- func (m *MultiModifySplitResponse) XXX_DiscardUnknown()
- func (m *MultiModifySplitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MultiModifySplitResponse) XXX_Merge(src proto.Message)
- func (m *MultiModifySplitResponse) XXX_Size() int
- func (m *MultiModifySplitResponse) XXX_Unmarshal(b []byte) error
- type NodeInfo
- func (*NodeInfo) Descriptor() ([]byte, []int)
- func (m *NodeInfo) GetAddress() string
- func (m *NodeInfo) GetDisks() []uint64
- func (m *NodeInfo) GetNodeID() uint64
- func (m *NodeInfo) Marshal() (dAtA []byte, err error)
- func (m *NodeInfo) MarshalTo(dAtA []byte) (int, error)
- func (m *NodeInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*NodeInfo) ProtoMessage()
- func (m *NodeInfo) Reset()
- func (m *NodeInfo) Size() (n int)
- func (m *NodeInfo) String() string
- func (m *NodeInfo) Unmarshal(dAtA []byte) error
- func (m *NodeInfo) XXX_DiscardUnknown()
- func (m *NodeInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NodeInfo) XXX_Merge(src proto.Message)
- func (m *NodeInfo) XXX_Size() int
- func (m *NodeInfo) XXX_Unmarshal(b []byte) error
- type NodesInfoRequest
- func (*NodesInfoRequest) Descriptor() ([]byte, []int)
- func (m *NodesInfoRequest) Marshal() (dAtA []byte, err error)
- func (m *NodesInfoRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *NodesInfoRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*NodesInfoRequest) ProtoMessage()
- func (m *NodesInfoRequest) Reset()
- func (m *NodesInfoRequest) Size() (n int)
- func (m *NodesInfoRequest) String() string
- func (m *NodesInfoRequest) Unmarshal(dAtA []byte) error
- func (m *NodesInfoRequest) XXX_DiscardUnknown()
- func (m *NodesInfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NodesInfoRequest) XXX_Merge(src proto.Message)
- func (m *NodesInfoRequest) XXX_Size() int
- func (m *NodesInfoRequest) XXX_Unmarshal(b []byte) error
- type NodesInfoResponse
- func (*NodesInfoResponse) Descriptor() ([]byte, []int)
- func (m *NodesInfoResponse) GetCode() Code
- func (m *NodesInfoResponse) GetCodeDes() string
- func (m *NodesInfoResponse) GetNodes() map[uint64]*NodeInfo
- func (m *NodesInfoResponse) Marshal() (dAtA []byte, err error)
- func (m *NodesInfoResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *NodesInfoResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*NodesInfoResponse) ProtoMessage()
- func (m *NodesInfoResponse) Reset()
- func (m *NodesInfoResponse) Size() (n int)
- func (m *NodesInfoResponse) String() string
- func (m *NodesInfoResponse) Unmarshal(dAtA []byte) error
- func (m *NodesInfoResponse) XXX_DiscardUnknown()
- func (m *NodesInfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NodesInfoResponse) XXX_Merge(src proto.Message)
- func (m *NodesInfoResponse) XXX_Size() int
- func (m *NodesInfoResponse) XXX_Unmarshal(b []byte) error
- type Payload
- func (*Payload) Descriptor() ([]byte, []int)
- func (m *Payload) GetData() []byte
- func (m *Payload) Marshal() (dAtA []byte, err error)
- func (m *Payload) MarshalTo(dAtA []byte) (int, error)
- func (m *Payload) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Payload) ProtoMessage()
- func (m *Payload) Reset()
- func (m *Payload) Size() (n int)
- func (m *Payload) String() string
- func (m *Payload) Unmarshal(dAtA []byte) error
- func (m *Payload) XXX_DiscardUnknown()
- func (m *Payload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Payload) XXX_Merge(src proto.Message)
- func (m *Payload) XXX_Size() int
- func (m *Payload) XXX_Unmarshal(b []byte) error
- type PunchHolesRequest
- func (*PunchHolesRequest) Descriptor() ([]byte, []int)
- func (m *PunchHolesRequest) GetExtentIDs() []uint64
- func (m *PunchHolesRequest) GetOwnerKey() string
- func (m *PunchHolesRequest) GetRevision() int64
- func (m *PunchHolesRequest) GetStreamID() uint64
- func (m *PunchHolesRequest) Marshal() (dAtA []byte, err error)
- func (m *PunchHolesRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *PunchHolesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PunchHolesRequest) ProtoMessage()
- func (m *PunchHolesRequest) Reset()
- func (m *PunchHolesRequest) Size() (n int)
- func (m *PunchHolesRequest) String() string
- func (m *PunchHolesRequest) Unmarshal(dAtA []byte) error
- func (m *PunchHolesRequest) XXX_DiscardUnknown()
- func (m *PunchHolesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PunchHolesRequest) XXX_Merge(src proto.Message)
- func (m *PunchHolesRequest) XXX_Size() int
- func (m *PunchHolesRequest) XXX_Unmarshal(b []byte) error
- type PunchHolesResponse
- func (*PunchHolesResponse) Descriptor() ([]byte, []int)
- func (m *PunchHolesResponse) GetCode() Code
- func (m *PunchHolesResponse) GetCodeDes() string
- func (m *PunchHolesResponse) GetStream() *StreamInfo
- func (m *PunchHolesResponse) Marshal() (dAtA []byte, err error)
- func (m *PunchHolesResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *PunchHolesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PunchHolesResponse) ProtoMessage()
- func (m *PunchHolesResponse) Reset()
- func (m *PunchHolesResponse) Size() (n int)
- func (m *PunchHolesResponse) String() string
- func (m *PunchHolesResponse) Unmarshal(dAtA []byte) error
- func (m *PunchHolesResponse) XXX_DiscardUnknown()
- func (m *PunchHolesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PunchHolesResponse) XXX_Merge(src proto.Message)
- func (m *PunchHolesResponse) XXX_Size() int
- func (m *PunchHolesResponse) XXX_Unmarshal(b []byte) error
- type ReAvaliRequest
- func (*ReAvaliRequest) Descriptor() ([]byte, []int)
- func (m *ReAvaliRequest) GetEversion() uint64
- func (m *ReAvaliRequest) GetExtentID() uint64
- func (m *ReAvaliRequest) Marshal() (dAtA []byte, err error)
- func (m *ReAvaliRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ReAvaliRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ReAvaliRequest) ProtoMessage()
- func (m *ReAvaliRequest) Reset()
- func (m *ReAvaliRequest) Size() (n int)
- func (m *ReAvaliRequest) String() string
- func (m *ReAvaliRequest) Unmarshal(dAtA []byte) error
- func (m *ReAvaliRequest) XXX_DiscardUnknown()
- func (m *ReAvaliRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ReAvaliRequest) XXX_Merge(src proto.Message)
- func (m *ReAvaliRequest) XXX_Size() int
- func (m *ReAvaliRequest) XXX_Unmarshal(b []byte) error
- type ReAvaliResponse
- func (*ReAvaliResponse) Descriptor() ([]byte, []int)
- func (m *ReAvaliResponse) GetCode() Code
- func (m *ReAvaliResponse) GetCodeDes() string
- func (m *ReAvaliResponse) Marshal() (dAtA []byte, err error)
- func (m *ReAvaliResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *ReAvaliResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ReAvaliResponse) ProtoMessage()
- func (m *ReAvaliResponse) Reset()
- func (m *ReAvaliResponse) Size() (n int)
- func (m *ReAvaliResponse) String() string
- func (m *ReAvaliResponse) Unmarshal(dAtA []byte) error
- func (m *ReAvaliResponse) XXX_DiscardUnknown()
- func (m *ReAvaliResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ReAvaliResponse) XXX_Merge(src proto.Message)
- func (m *ReAvaliResponse) XXX_Size() int
- func (m *ReAvaliResponse) XXX_Unmarshal(b []byte) error
- type ReadBlockResponseHeader
- func (*ReadBlockResponseHeader) Descriptor() ([]byte, []int)
- func (m *ReadBlockResponseHeader) GetBlockSizes() []uint32
- func (m *ReadBlockResponseHeader) GetCode() Code
- func (m *ReadBlockResponseHeader) GetCodeDes() string
- func (m *ReadBlockResponseHeader) GetEnd() uint32
- func (m *ReadBlockResponseHeader) GetOffsets() []uint32
- func (m *ReadBlockResponseHeader) Marshal() (dAtA []byte, err error)
- func (m *ReadBlockResponseHeader) MarshalTo(dAtA []byte) (int, error)
- func (m *ReadBlockResponseHeader) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ReadBlockResponseHeader) ProtoMessage()
- func (m *ReadBlockResponseHeader) Reset()
- func (m *ReadBlockResponseHeader) Size() (n int)
- func (m *ReadBlockResponseHeader) String() string
- func (m *ReadBlockResponseHeader) Unmarshal(dAtA []byte) error
- func (m *ReadBlockResponseHeader) XXX_DiscardUnknown()
- func (m *ReadBlockResponseHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ReadBlockResponseHeader) XXX_Merge(src proto.Message)
- func (m *ReadBlockResponseHeader) XXX_Size() int
- func (m *ReadBlockResponseHeader) XXX_Unmarshal(b []byte) error
- type ReadBlocksRequest
- func (*ReadBlocksRequest) Descriptor() ([]byte, []int)
- func (m *ReadBlocksRequest) GetEversion() uint64
- func (m *ReadBlocksRequest) GetExtentID() uint64
- func (m *ReadBlocksRequest) GetNumOfBlocks() uint32
- func (m *ReadBlocksRequest) GetOffset() uint32
- func (m *ReadBlocksRequest) GetOnlyLastBlock() bool
- func (m *ReadBlocksRequest) Marshal() (dAtA []byte, err error)
- func (m *ReadBlocksRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ReadBlocksRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ReadBlocksRequest) ProtoMessage()
- func (m *ReadBlocksRequest) Reset()
- func (m *ReadBlocksRequest) Size() (n int)
- func (m *ReadBlocksRequest) String() string
- func (m *ReadBlocksRequest) Unmarshal(dAtA []byte) error
- func (m *ReadBlocksRequest) XXX_DiscardUnknown()
- func (m *ReadBlocksRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ReadBlocksRequest) XXX_Merge(src proto.Message)
- func (m *ReadBlocksRequest) XXX_Size() int
- func (m *ReadBlocksRequest) XXX_Unmarshal(b []byte) error
- type ReadBlocksResponse
- func (*ReadBlocksResponse) Descriptor() ([]byte, []int)
- func (m *ReadBlocksResponse) GetData() isReadBlocksResponse_Data
- func (m *ReadBlocksResponse) GetHeader() *ReadBlockResponseHeader
- func (m *ReadBlocksResponse) GetPayload() []byte
- func (m *ReadBlocksResponse) Marshal() (dAtA []byte, err error)
- func (m *ReadBlocksResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *ReadBlocksResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ReadBlocksResponse) ProtoMessage()
- func (m *ReadBlocksResponse) Reset()
- func (m *ReadBlocksResponse) Size() (n int)
- func (m *ReadBlocksResponse) String() string
- func (m *ReadBlocksResponse) Unmarshal(dAtA []byte) error
- func (m *ReadBlocksResponse) XXX_DiscardUnknown()
- func (m *ReadBlocksResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ReadBlocksResponse) XXX_Merge(src proto.Message)
- func (*ReadBlocksResponse) XXX_OneofWrappers() []interface{}
- func (m *ReadBlocksResponse) XXX_Size() int
- func (m *ReadBlocksResponse) XXX_Unmarshal(b []byte) error
- type ReadBlocksResponse_Header
- type ReadBlocksResponse_Payload
- type RecoveryTask
- func (*RecoveryTask) Descriptor() ([]byte, []int)
- func (m *RecoveryTask) GetExtentID() uint64
- func (m *RecoveryTask) GetNodeID() uint64
- func (m *RecoveryTask) GetReplaceID() uint64
- func (m *RecoveryTask) GetStartTime() int64
- func (m *RecoveryTask) Marshal() (dAtA []byte, err error)
- func (m *RecoveryTask) MarshalTo(dAtA []byte) (int, error)
- func (m *RecoveryTask) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*RecoveryTask) ProtoMessage()
- func (m *RecoveryTask) Reset()
- func (m *RecoveryTask) Size() (n int)
- func (m *RecoveryTask) String() string
- func (m *RecoveryTask) Unmarshal(dAtA []byte) error
- func (m *RecoveryTask) XXX_DiscardUnknown()
- func (m *RecoveryTask) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RecoveryTask) XXX_Merge(src proto.Message)
- func (m *RecoveryTask) XXX_Size() int
- func (m *RecoveryTask) XXX_Unmarshal(b []byte) error
- type RecoveryTaskStatus
- func (*RecoveryTaskStatus) Descriptor() ([]byte, []int)
- func (m *RecoveryTaskStatus) GetReadyDiskID() uint64
- func (m *RecoveryTaskStatus) GetTask() *RecoveryTask
- func (m *RecoveryTaskStatus) Marshal() (dAtA []byte, err error)
- func (m *RecoveryTaskStatus) MarshalTo(dAtA []byte) (int, error)
- func (m *RecoveryTaskStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*RecoveryTaskStatus) ProtoMessage()
- func (m *RecoveryTaskStatus) Reset()
- func (m *RecoveryTaskStatus) Size() (n int)
- func (m *RecoveryTaskStatus) String() string
- func (m *RecoveryTaskStatus) Unmarshal(dAtA []byte) error
- func (m *RecoveryTaskStatus) XXX_DiscardUnknown()
- func (m *RecoveryTaskStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RecoveryTaskStatus) XXX_Merge(src proto.Message)
- func (m *RecoveryTaskStatus) XXX_Size() int
- func (m *RecoveryTaskStatus) XXX_Unmarshal(b []byte) error
- type RegisterNodeRequest
- func (*RegisterNodeRequest) Descriptor() ([]byte, []int)
- func (m *RegisterNodeRequest) GetAddr() string
- func (m *RegisterNodeRequest) GetDiskUUIDs() []string
- func (m *RegisterNodeRequest) Marshal() (dAtA []byte, err error)
- func (m *RegisterNodeRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *RegisterNodeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*RegisterNodeRequest) ProtoMessage()
- func (m *RegisterNodeRequest) Reset()
- func (m *RegisterNodeRequest) Size() (n int)
- func (m *RegisterNodeRequest) String() string
- func (m *RegisterNodeRequest) Unmarshal(dAtA []byte) error
- func (m *RegisterNodeRequest) XXX_DiscardUnknown()
- func (m *RegisterNodeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RegisterNodeRequest) XXX_Merge(src proto.Message)
- func (m *RegisterNodeRequest) XXX_Size() int
- func (m *RegisterNodeRequest) XXX_Unmarshal(b []byte) error
- type RegisterNodeResponse
- func (*RegisterNodeResponse) Descriptor() ([]byte, []int)
- func (m *RegisterNodeResponse) GetCode() Code
- func (m *RegisterNodeResponse) GetCodeDes() string
- func (m *RegisterNodeResponse) GetDiskUUIDs() map[string]uint64
- func (m *RegisterNodeResponse) GetNodeId() uint64
- func (m *RegisterNodeResponse) Marshal() (dAtA []byte, err error)
- func (m *RegisterNodeResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *RegisterNodeResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*RegisterNodeResponse) ProtoMessage()
- func (m *RegisterNodeResponse) Reset()
- func (m *RegisterNodeResponse) Size() (n int)
- func (m *RegisterNodeResponse) String() string
- func (m *RegisterNodeResponse) Unmarshal(dAtA []byte) error
- func (m *RegisterNodeResponse) XXX_DiscardUnknown()
- func (m *RegisterNodeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RegisterNodeResponse) XXX_Merge(src proto.Message)
- func (m *RegisterNodeResponse) XXX_Size() int
- func (m *RegisterNodeResponse) XXX_Unmarshal(b []byte) error
- type RequireRecoveryRequest
- func (*RequireRecoveryRequest) Descriptor() ([]byte, []int)
- func (m *RequireRecoveryRequest) GetTask() *RecoveryTask
- func (m *RequireRecoveryRequest) Marshal() (dAtA []byte, err error)
- func (m *RequireRecoveryRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *RequireRecoveryRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*RequireRecoveryRequest) ProtoMessage()
- func (m *RequireRecoveryRequest) Reset()
- func (m *RequireRecoveryRequest) Size() (n int)
- func (m *RequireRecoveryRequest) String() string
- func (m *RequireRecoveryRequest) Unmarshal(dAtA []byte) error
- func (m *RequireRecoveryRequest) XXX_DiscardUnknown()
- func (m *RequireRecoveryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RequireRecoveryRequest) XXX_Merge(src proto.Message)
- func (m *RequireRecoveryRequest) XXX_Size() int
- func (m *RequireRecoveryRequest) XXX_Unmarshal(b []byte) error
- type RequireRecoveryResponse
- func (*RequireRecoveryResponse) Descriptor() ([]byte, []int)
- func (m *RequireRecoveryResponse) GetCode() Code
- func (m *RequireRecoveryResponse) GetCodeDes() string
- func (m *RequireRecoveryResponse) Marshal() (dAtA []byte, err error)
- func (m *RequireRecoveryResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *RequireRecoveryResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*RequireRecoveryResponse) ProtoMessage()
- func (m *RequireRecoveryResponse) Reset()
- func (m *RequireRecoveryResponse) Size() (n int)
- func (m *RequireRecoveryResponse) String() string
- func (m *RequireRecoveryResponse) Unmarshal(dAtA []byte) error
- func (m *RequireRecoveryResponse) XXX_DiscardUnknown()
- func (m *RequireRecoveryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RequireRecoveryResponse) XXX_Merge(src proto.Message)
- func (m *RequireRecoveryResponse) XXX_Size() int
- func (m *RequireRecoveryResponse) XXX_Unmarshal(b []byte) error
- type StatusRequest
- func (*StatusRequest) Descriptor() ([]byte, []int)
- func (m *StatusRequest) Marshal() (dAtA []byte, err error)
- func (m *StatusRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *StatusRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*StatusRequest) ProtoMessage()
- func (m *StatusRequest) Reset()
- func (m *StatusRequest) Size() (n int)
- func (m *StatusRequest) String() string
- func (m *StatusRequest) Unmarshal(dAtA []byte) error
- func (m *StatusRequest) XXX_DiscardUnknown()
- func (m *StatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StatusRequest) XXX_Merge(src proto.Message)
- func (m *StatusRequest) XXX_Size() int
- func (m *StatusRequest) XXX_Unmarshal(b []byte) error
- type StatusResponse
- func (*StatusResponse) Descriptor() ([]byte, []int)
- func (m *StatusResponse) GetCode() Code
- func (m *StatusResponse) GetCodeDes() string
- func (m *StatusResponse) Marshal() (dAtA []byte, err error)
- func (m *StatusResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *StatusResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*StatusResponse) ProtoMessage()
- func (m *StatusResponse) Reset()
- func (m *StatusResponse) Size() (n int)
- func (m *StatusResponse) String() string
- func (m *StatusResponse) Unmarshal(dAtA []byte) error
- func (m *StatusResponse) XXX_DiscardUnknown()
- func (m *StatusResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StatusResponse) XXX_Merge(src proto.Message)
- func (m *StatusResponse) XXX_Size() int
- func (m *StatusResponse) XXX_Unmarshal(b []byte) error
- type StreamAllocExtentRequest
- func (*StreamAllocExtentRequest) Descriptor() ([]byte, []int)
- func (m *StreamAllocExtentRequest) GetEnd() uint32
- func (m *StreamAllocExtentRequest) GetOwnerKey() string
- func (m *StreamAllocExtentRequest) GetRevision() int64
- func (m *StreamAllocExtentRequest) GetStreamID() uint64
- func (m *StreamAllocExtentRequest) Marshal() (dAtA []byte, err error)
- func (m *StreamAllocExtentRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *StreamAllocExtentRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*StreamAllocExtentRequest) ProtoMessage()
- func (m *StreamAllocExtentRequest) Reset()
- func (m *StreamAllocExtentRequest) Size() (n int)
- func (m *StreamAllocExtentRequest) String() string
- func (m *StreamAllocExtentRequest) Unmarshal(dAtA []byte) error
- func (m *StreamAllocExtentRequest) XXX_DiscardUnknown()
- func (m *StreamAllocExtentRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StreamAllocExtentRequest) XXX_Merge(src proto.Message)
- func (m *StreamAllocExtentRequest) XXX_Size() int
- func (m *StreamAllocExtentRequest) XXX_Unmarshal(b []byte) error
- type StreamAllocExtentResponse
- func (*StreamAllocExtentResponse) Descriptor() ([]byte, []int)
- func (m *StreamAllocExtentResponse) GetCode() Code
- func (m *StreamAllocExtentResponse) GetCodeDes() string
- func (m *StreamAllocExtentResponse) GetLastExInfo() *ExtentInfo
- func (m *StreamAllocExtentResponse) GetStreamInfo() *StreamInfo
- func (m *StreamAllocExtentResponse) Marshal() (dAtA []byte, err error)
- func (m *StreamAllocExtentResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *StreamAllocExtentResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*StreamAllocExtentResponse) ProtoMessage()
- func (m *StreamAllocExtentResponse) Reset()
- func (m *StreamAllocExtentResponse) Size() (n int)
- func (m *StreamAllocExtentResponse) String() string
- func (m *StreamAllocExtentResponse) Unmarshal(dAtA []byte) error
- func (m *StreamAllocExtentResponse) XXX_DiscardUnknown()
- func (m *StreamAllocExtentResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StreamAllocExtentResponse) XXX_Merge(src proto.Message)
- func (m *StreamAllocExtentResponse) XXX_Size() int
- func (m *StreamAllocExtentResponse) XXX_Unmarshal(b []byte) error
- type StreamInfo
- func (*StreamInfo) Descriptor() ([]byte, []int)
- func (m *StreamInfo) GetExtentIDs() []uint64
- func (m *StreamInfo) GetStreamID() uint64
- func (m *StreamInfo) Marshal() (dAtA []byte, err error)
- func (m *StreamInfo) MarshalTo(dAtA []byte) (int, error)
- func (m *StreamInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*StreamInfo) ProtoMessage()
- func (m *StreamInfo) Reset()
- func (m *StreamInfo) Size() (n int)
- func (m *StreamInfo) String() string
- func (m *StreamInfo) Unmarshal(dAtA []byte) error
- func (m *StreamInfo) XXX_DiscardUnknown()
- func (m *StreamInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StreamInfo) XXX_Merge(src proto.Message)
- func (m *StreamInfo) XXX_Size() int
- func (m *StreamInfo) XXX_Unmarshal(b []byte) error
- type StreamInfoRequest
- func (*StreamInfoRequest) Descriptor() ([]byte, []int)
- func (m *StreamInfoRequest) GetStreamIDs() []uint64
- func (m *StreamInfoRequest) Marshal() (dAtA []byte, err error)
- func (m *StreamInfoRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *StreamInfoRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*StreamInfoRequest) ProtoMessage()
- func (m *StreamInfoRequest) Reset()
- func (m *StreamInfoRequest) Size() (n int)
- func (m *StreamInfoRequest) String() string
- func (m *StreamInfoRequest) Unmarshal(dAtA []byte) error
- func (m *StreamInfoRequest) XXX_DiscardUnknown()
- func (m *StreamInfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StreamInfoRequest) XXX_Merge(src proto.Message)
- func (m *StreamInfoRequest) XXX_Size() int
- func (m *StreamInfoRequest) XXX_Unmarshal(b []byte) error
- type StreamInfoResponse
- func (*StreamInfoResponse) Descriptor() ([]byte, []int)
- func (m *StreamInfoResponse) GetCode() Code
- func (m *StreamInfoResponse) GetCodeDes() string
- func (m *StreamInfoResponse) GetExtents() map[uint64]*ExtentInfo
- func (m *StreamInfoResponse) GetStreams() map[uint64]*StreamInfo
- func (m *StreamInfoResponse) Marshal() (dAtA []byte, err error)
- func (m *StreamInfoResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *StreamInfoResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*StreamInfoResponse) ProtoMessage()
- func (m *StreamInfoResponse) Reset()
- func (m *StreamInfoResponse) Size() (n int)
- func (m *StreamInfoResponse) String() string
- func (m *StreamInfoResponse) Unmarshal(dAtA []byte) error
- func (m *StreamInfoResponse) XXX_DiscardUnknown()
- func (m *StreamInfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StreamInfoResponse) XXX_Merge(src proto.Message)
- func (m *StreamInfoResponse) XXX_Size() int
- func (m *StreamInfoResponse) XXX_Unmarshal(b []byte) error
- type StreamManagerServiceClient
- type StreamManagerServiceServer
- type TruncateRequest
- func (*TruncateRequest) Descriptor() ([]byte, []int)
- func (m *TruncateRequest) GetExtentID() uint64
- func (m *TruncateRequest) GetOwnerKey() string
- func (m *TruncateRequest) GetRevision() int64
- func (m *TruncateRequest) GetStreamID() uint64
- func (m *TruncateRequest) Marshal() (dAtA []byte, err error)
- func (m *TruncateRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *TruncateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*TruncateRequest) ProtoMessage()
- func (m *TruncateRequest) Reset()
- func (m *TruncateRequest) Size() (n int)
- func (m *TruncateRequest) String() string
- func (m *TruncateRequest) Unmarshal(dAtA []byte) error
- func (m *TruncateRequest) XXX_DiscardUnknown()
- func (m *TruncateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TruncateRequest) XXX_Merge(src proto.Message)
- func (m *TruncateRequest) XXX_Size() int
- func (m *TruncateRequest) XXX_Unmarshal(b []byte) error
- type TruncateResponse
- func (*TruncateResponse) Descriptor() ([]byte, []int)
- func (m *TruncateResponse) GetCode() Code
- func (m *TruncateResponse) GetCodeDes() string
- func (m *TruncateResponse) GetUpdatedStreamInfo() *StreamInfo
- func (m *TruncateResponse) Marshal() (dAtA []byte, err error)
- func (m *TruncateResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *TruncateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*TruncateResponse) ProtoMessage()
- func (m *TruncateResponse) Reset()
- func (m *TruncateResponse) Size() (n int)
- func (m *TruncateResponse) String() string
- func (m *TruncateResponse) Unmarshal(dAtA []byte) error
- func (m *TruncateResponse) XXX_DiscardUnknown()
- func (m *TruncateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TruncateResponse) XXX_Merge(src proto.Message)
- func (m *TruncateResponse) XXX_Size() int
- func (m *TruncateResponse) XXX_Unmarshal(b []byte) error
- type UnimplementedExtentServiceServer
- func (*UnimplementedExtentServiceServer) AllocExtent(ctx context.Context, req *AllocExtentRequest) (*AllocExtentResponse, error)
- func (*UnimplementedExtentServiceServer) Append(srv ExtentService_AppendServer) error
- func (*UnimplementedExtentServiceServer) CommitLength(ctx context.Context, req *CommitLengthRequest) (*CommitLengthResponse, error)
- func (*UnimplementedExtentServiceServer) CopyExtent(req *CopyExtentRequest, srv ExtentService_CopyExtentServer) error
- func (*UnimplementedExtentServiceServer) Df(ctx context.Context, req *DfRequest) (*DfResponse, error)
- func (*UnimplementedExtentServiceServer) Heartbeat(req *Payload, srv ExtentService_HeartbeatServer) error
- func (*UnimplementedExtentServiceServer) ReAvali(ctx context.Context, req *ReAvaliRequest) (*ReAvaliResponse, error)
- func (*UnimplementedExtentServiceServer) ReadBlocks(req *ReadBlocksRequest, srv ExtentService_ReadBlocksServer) error
- func (*UnimplementedExtentServiceServer) RequireRecovery(ctx context.Context, req *RequireRecoveryRequest) (*RequireRecoveryResponse, error)
- type UnimplementedStreamManagerServiceServer
- func (*UnimplementedStreamManagerServiceServer) CheckCommitLength(ctx context.Context, req *CheckCommitLengthRequest) (*CheckCommitLengthResponse, error)
- func (*UnimplementedStreamManagerServiceServer) CreateStream(ctx context.Context, req *CreateStreamRequest) (*CreateStreamResponse, error)
- func (*UnimplementedStreamManagerServiceServer) ExtentInfo(ctx context.Context, req *ExtentInfoRequest) (*ExtentInfoResponse, error)
- func (*UnimplementedStreamManagerServiceServer) MultiModifySplit(ctx context.Context, req *MultiModifySplitRequest) (*MultiModifySplitResponse, error)
- func (*UnimplementedStreamManagerServiceServer) NodesInfo(ctx context.Context, req *NodesInfoRequest) (*NodesInfoResponse, error)
- func (*UnimplementedStreamManagerServiceServer) RegisterNode(ctx context.Context, req *RegisterNodeRequest) (*RegisterNodeResponse, error)
- func (*UnimplementedStreamManagerServiceServer) Status(ctx context.Context, req *StatusRequest) (*StatusResponse, error)
- func (*UnimplementedStreamManagerServiceServer) StreamAllocExtent(ctx context.Context, req *StreamAllocExtentRequest) (*StreamAllocExtentResponse, error)
- func (*UnimplementedStreamManagerServiceServer) StreamInfo(ctx context.Context, req *StreamInfoRequest) (*StreamInfoResponse, error)
- func (*UnimplementedStreamManagerServiceServer) StreamPunchHoles(ctx context.Context, req *PunchHolesRequest) (*PunchHolesResponse, error)
- func (*UnimplementedStreamManagerServiceServer) Truncate(ctx context.Context, req *TruncateRequest) (*TruncateResponse, error)
Constants ¶
This section is empty.
Variables ¶
var ( ErrInvalidLengthPb = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowPb = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupPb = fmt.Errorf("proto: unexpected end of group") )
var Code_name = map[int32]string{
0: "OK",
1: "ERROR",
2: "EndOfExtent",
4: "EVersionLow",
5: "NotLEADER",
6: "LockedByOther",
7: "ClientStreamVersionTooHigh",
8: "NotFound",
}
var Code_value = map[string]int32{
"OK": 0,
"ERROR": 1,
"EndOfExtent": 2,
"EVersionLow": 4,
"NotLEADER": 5,
"LockedByOther": 6,
"ClientStreamVersionTooHigh": 7,
"NotFound": 8,
}
Functions ¶
func RegisterExtentServiceServer ¶
func RegisterExtentServiceServer(s *grpc.Server, srv ExtentServiceServer)
func RegisterStreamManagerServiceServer ¶
func RegisterStreamManagerServiceServer(s *grpc.Server, srv StreamManagerServiceServer)
Types ¶
type AllocExtentRequest ¶
type AllocExtentRequest struct {
ExtentID uint64 `protobuf:"varint,1,opt,name=extentID,proto3" json:"extentID,omitempty"`
}
func (*AllocExtentRequest) Descriptor ¶
func (*AllocExtentRequest) Descriptor() ([]byte, []int)
func (*AllocExtentRequest) GetExtentID ¶
func (m *AllocExtentRequest) GetExtentID() uint64
func (*AllocExtentRequest) Marshal ¶
func (m *AllocExtentRequest) Marshal() (dAtA []byte, err error)
func (*AllocExtentRequest) MarshalTo ¶
func (m *AllocExtentRequest) MarshalTo(dAtA []byte) (int, error)
func (*AllocExtentRequest) MarshalToSizedBuffer ¶
func (m *AllocExtentRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*AllocExtentRequest) ProtoMessage ¶
func (*AllocExtentRequest) ProtoMessage()
func (*AllocExtentRequest) Reset ¶
func (m *AllocExtentRequest) Reset()
func (*AllocExtentRequest) Size ¶
func (m *AllocExtentRequest) Size() (n int)
func (*AllocExtentRequest) String ¶
func (m *AllocExtentRequest) String() string
func (*AllocExtentRequest) Unmarshal ¶
func (m *AllocExtentRequest) Unmarshal(dAtA []byte) error
func (*AllocExtentRequest) XXX_DiscardUnknown ¶
func (m *AllocExtentRequest) XXX_DiscardUnknown()
func (*AllocExtentRequest) XXX_Marshal ¶
func (m *AllocExtentRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AllocExtentRequest) XXX_Merge ¶
func (m *AllocExtentRequest) XXX_Merge(src proto.Message)
func (*AllocExtentRequest) XXX_Size ¶
func (m *AllocExtentRequest) XXX_Size() int
func (*AllocExtentRequest) XXX_Unmarshal ¶
func (m *AllocExtentRequest) XXX_Unmarshal(b []byte) error
type AllocExtentResponse ¶
type AllocExtentResponse struct { Code Code `protobuf:"varint,1,opt,name=code,proto3,enum=pb.Code" json:"code,omitempty"` CodeDes string `protobuf:"bytes,2,opt,name=codeDes,proto3" json:"codeDes,omitempty"` DiskID uint64 `protobuf:"varint,3,opt,name=diskID,proto3" json:"diskID,omitempty"` }
func (*AllocExtentResponse) Descriptor ¶
func (*AllocExtentResponse) Descriptor() ([]byte, []int)
func (*AllocExtentResponse) GetCode ¶
func (m *AllocExtentResponse) GetCode() Code
func (*AllocExtentResponse) GetCodeDes ¶
func (m *AllocExtentResponse) GetCodeDes() string
func (*AllocExtentResponse) GetDiskID ¶
func (m *AllocExtentResponse) GetDiskID() uint64
func (*AllocExtentResponse) Marshal ¶
func (m *AllocExtentResponse) Marshal() (dAtA []byte, err error)
func (*AllocExtentResponse) MarshalTo ¶
func (m *AllocExtentResponse) MarshalTo(dAtA []byte) (int, error)
func (*AllocExtentResponse) MarshalToSizedBuffer ¶
func (m *AllocExtentResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*AllocExtentResponse) ProtoMessage ¶
func (*AllocExtentResponse) ProtoMessage()
func (*AllocExtentResponse) Reset ¶
func (m *AllocExtentResponse) Reset()
func (*AllocExtentResponse) Size ¶
func (m *AllocExtentResponse) Size() (n int)
func (*AllocExtentResponse) String ¶
func (m *AllocExtentResponse) String() string
func (*AllocExtentResponse) Unmarshal ¶
func (m *AllocExtentResponse) Unmarshal(dAtA []byte) error
func (*AllocExtentResponse) XXX_DiscardUnknown ¶
func (m *AllocExtentResponse) XXX_DiscardUnknown()
func (*AllocExtentResponse) XXX_Marshal ¶
func (m *AllocExtentResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AllocExtentResponse) XXX_Merge ¶
func (m *AllocExtentResponse) XXX_Merge(src proto.Message)
func (*AllocExtentResponse) XXX_Size ¶
func (m *AllocExtentResponse) XXX_Size() int
func (*AllocExtentResponse) XXX_Unmarshal ¶
func (m *AllocExtentResponse) XXX_Unmarshal(b []byte) error
type AppendRequest ¶
type AppendRequest struct { // Types that are valid to be assigned to Data: // *AppendRequest_Header // *AppendRequest_Payload Data isAppendRequest_Data `protobuf_oneof:"data"` }
func (*AppendRequest) Descriptor ¶
func (*AppendRequest) Descriptor() ([]byte, []int)
func (*AppendRequest) GetData ¶
func (m *AppendRequest) GetData() isAppendRequest_Data
func (*AppendRequest) GetHeader ¶
func (m *AppendRequest) GetHeader() *AppendRequestHeader
func (*AppendRequest) GetPayload ¶
func (m *AppendRequest) GetPayload() []byte
func (*AppendRequest) Marshal ¶
func (m *AppendRequest) Marshal() (dAtA []byte, err error)
func (*AppendRequest) MarshalToSizedBuffer ¶
func (m *AppendRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*AppendRequest) ProtoMessage ¶
func (*AppendRequest) ProtoMessage()
func (*AppendRequest) Reset ¶
func (m *AppendRequest) Reset()
func (*AppendRequest) Size ¶
func (m *AppendRequest) Size() (n int)
func (*AppendRequest) String ¶
func (m *AppendRequest) String() string
func (*AppendRequest) Unmarshal ¶
func (m *AppendRequest) Unmarshal(dAtA []byte) error
func (*AppendRequest) XXX_DiscardUnknown ¶
func (m *AppendRequest) XXX_DiscardUnknown()
func (*AppendRequest) XXX_Marshal ¶
func (m *AppendRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AppendRequest) XXX_Merge ¶
func (m *AppendRequest) XXX_Merge(src proto.Message)
func (*AppendRequest) XXX_OneofWrappers ¶
func (*AppendRequest) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*AppendRequest) XXX_Size ¶
func (m *AppendRequest) XXX_Size() int
func (*AppendRequest) XXX_Unmarshal ¶
func (m *AppendRequest) XXX_Unmarshal(b []byte) error
type AppendRequestHeader ¶
type AppendRequestHeader struct { ExtentID uint64 `protobuf:"varint,1,opt,name=extentID,proto3" json:"extentID,omitempty"` Eversion uint64 `protobuf:"varint,2,opt,name=eversion,proto3" json:"eversion,omitempty"` Commit uint32 `protobuf:"varint,3,opt,name=commit,proto3" json:"commit,omitempty"` Revision int64 `protobuf:"varint,4,opt,name=revision,proto3" json:"revision,omitempty"` MustSync bool `protobuf:"varint,5,opt,name=mustSync,proto3" json:"mustSync,omitempty"` Blocks []uint32 `protobuf:"varint,6,rep,packed,name=blocks,proto3" json:"blocks,omitempty"` }
func (*AppendRequestHeader) Descriptor ¶
func (*AppendRequestHeader) Descriptor() ([]byte, []int)
func (*AppendRequestHeader) GetBlocks ¶
func (m *AppendRequestHeader) GetBlocks() []uint32
func (*AppendRequestHeader) GetCommit ¶
func (m *AppendRequestHeader) GetCommit() uint32
func (*AppendRequestHeader) GetEversion ¶
func (m *AppendRequestHeader) GetEversion() uint64
func (*AppendRequestHeader) GetExtentID ¶
func (m *AppendRequestHeader) GetExtentID() uint64
func (*AppendRequestHeader) GetMustSync ¶
func (m *AppendRequestHeader) GetMustSync() bool
func (*AppendRequestHeader) GetRevision ¶
func (m *AppendRequestHeader) GetRevision() int64
func (*AppendRequestHeader) Marshal ¶
func (m *AppendRequestHeader) Marshal() (dAtA []byte, err error)
func (*AppendRequestHeader) MarshalTo ¶
func (m *AppendRequestHeader) MarshalTo(dAtA []byte) (int, error)
func (*AppendRequestHeader) MarshalToSizedBuffer ¶
func (m *AppendRequestHeader) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*AppendRequestHeader) ProtoMessage ¶
func (*AppendRequestHeader) ProtoMessage()
func (*AppendRequestHeader) Reset ¶
func (m *AppendRequestHeader) Reset()
func (*AppendRequestHeader) Size ¶
func (m *AppendRequestHeader) Size() (n int)
func (*AppendRequestHeader) String ¶
func (m *AppendRequestHeader) String() string
func (*AppendRequestHeader) Unmarshal ¶
func (m *AppendRequestHeader) Unmarshal(dAtA []byte) error
func (*AppendRequestHeader) XXX_DiscardUnknown ¶
func (m *AppendRequestHeader) XXX_DiscardUnknown()
func (*AppendRequestHeader) XXX_Marshal ¶
func (m *AppendRequestHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AppendRequestHeader) XXX_Merge ¶
func (m *AppendRequestHeader) XXX_Merge(src proto.Message)
func (*AppendRequestHeader) XXX_Size ¶
func (m *AppendRequestHeader) XXX_Size() int
func (*AppendRequestHeader) XXX_Unmarshal ¶
func (m *AppendRequestHeader) XXX_Unmarshal(b []byte) error
type AppendRequest_Header ¶
type AppendRequest_Header struct {
Header *AppendRequestHeader `protobuf:"bytes,1,opt,name=header,proto3,oneof" json:"header,omitempty"`
}
func (*AppendRequest_Header) MarshalTo ¶
func (m *AppendRequest_Header) MarshalTo(dAtA []byte) (int, error)
func (*AppendRequest_Header) MarshalToSizedBuffer ¶
func (m *AppendRequest_Header) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*AppendRequest_Header) Size ¶
func (m *AppendRequest_Header) Size() (n int)
type AppendRequest_Payload ¶
type AppendRequest_Payload struct {
Payload []byte `protobuf:"bytes,2,opt,name=payload,proto3,oneof" json:"payload,omitempty"`
}
func (*AppendRequest_Payload) MarshalTo ¶
func (m *AppendRequest_Payload) MarshalTo(dAtA []byte) (int, error)
func (*AppendRequest_Payload) MarshalToSizedBuffer ¶
func (m *AppendRequest_Payload) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*AppendRequest_Payload) Size ¶
func (m *AppendRequest_Payload) Size() (n int)
type AppendResponse ¶
type AppendResponse struct { Code Code `protobuf:"varint,1,opt,name=code,proto3,enum=pb.Code" json:"code,omitempty"` CodeDes string `protobuf:"bytes,2,opt,name=codeDes,proto3" json:"codeDes,omitempty"` Offsets []uint32 `protobuf:"varint,3,rep,packed,name=offsets,proto3" json:"offsets,omitempty"` End uint32 `protobuf:"varint,4,opt,name=end,proto3" json:"end,omitempty"` }
func (*AppendResponse) Descriptor ¶
func (*AppendResponse) Descriptor() ([]byte, []int)
func (*AppendResponse) GetCode ¶
func (m *AppendResponse) GetCode() Code
func (*AppendResponse) GetCodeDes ¶
func (m *AppendResponse) GetCodeDes() string
func (*AppendResponse) GetEnd ¶
func (m *AppendResponse) GetEnd() uint32
func (*AppendResponse) GetOffsets ¶
func (m *AppendResponse) GetOffsets() []uint32
func (*AppendResponse) Marshal ¶
func (m *AppendResponse) Marshal() (dAtA []byte, err error)
func (*AppendResponse) MarshalToSizedBuffer ¶
func (m *AppendResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*AppendResponse) ProtoMessage ¶
func (*AppendResponse) ProtoMessage()
func (*AppendResponse) Reset ¶
func (m *AppendResponse) Reset()
func (*AppendResponse) Size ¶
func (m *AppendResponse) Size() (n int)
func (*AppendResponse) String ¶
func (m *AppendResponse) String() string
func (*AppendResponse) Unmarshal ¶
func (m *AppendResponse) Unmarshal(dAtA []byte) error
func (*AppendResponse) XXX_DiscardUnknown ¶
func (m *AppendResponse) XXX_DiscardUnknown()
func (*AppendResponse) XXX_Marshal ¶
func (m *AppendResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AppendResponse) XXX_Merge ¶
func (m *AppendResponse) XXX_Merge(src proto.Message)
func (*AppendResponse) XXX_Size ¶
func (m *AppendResponse) XXX_Size() int
func (*AppendResponse) XXX_Unmarshal ¶
func (m *AppendResponse) XXX_Unmarshal(b []byte) error
type CheckCommitLengthRequest ¶
type CheckCommitLengthRequest struct { StreamID uint64 `protobuf:"varint,1,opt,name=streamID,proto3" json:"streamID,omitempty"` OwnerKey string `protobuf:"bytes,2,opt,name=ownerKey,proto3" json:"ownerKey,omitempty"` Revision int64 `protobuf:"varint,3,opt,name=revision,proto3" json:"revision,omitempty"` }
func (*CheckCommitLengthRequest) Descriptor ¶
func (*CheckCommitLengthRequest) Descriptor() ([]byte, []int)
func (*CheckCommitLengthRequest) GetOwnerKey ¶
func (m *CheckCommitLengthRequest) GetOwnerKey() string
func (*CheckCommitLengthRequest) GetRevision ¶
func (m *CheckCommitLengthRequest) GetRevision() int64
func (*CheckCommitLengthRequest) GetStreamID ¶
func (m *CheckCommitLengthRequest) GetStreamID() uint64
func (*CheckCommitLengthRequest) Marshal ¶
func (m *CheckCommitLengthRequest) Marshal() (dAtA []byte, err error)
func (*CheckCommitLengthRequest) MarshalTo ¶
func (m *CheckCommitLengthRequest) MarshalTo(dAtA []byte) (int, error)
func (*CheckCommitLengthRequest) MarshalToSizedBuffer ¶
func (m *CheckCommitLengthRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CheckCommitLengthRequest) ProtoMessage ¶
func (*CheckCommitLengthRequest) ProtoMessage()
func (*CheckCommitLengthRequest) Reset ¶
func (m *CheckCommitLengthRequest) Reset()
func (*CheckCommitLengthRequest) Size ¶
func (m *CheckCommitLengthRequest) Size() (n int)
func (*CheckCommitLengthRequest) String ¶
func (m *CheckCommitLengthRequest) String() string
func (*CheckCommitLengthRequest) Unmarshal ¶
func (m *CheckCommitLengthRequest) Unmarshal(dAtA []byte) error
func (*CheckCommitLengthRequest) XXX_DiscardUnknown ¶
func (m *CheckCommitLengthRequest) XXX_DiscardUnknown()
func (*CheckCommitLengthRequest) XXX_Marshal ¶
func (m *CheckCommitLengthRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CheckCommitLengthRequest) XXX_Merge ¶
func (m *CheckCommitLengthRequest) XXX_Merge(src proto.Message)
func (*CheckCommitLengthRequest) XXX_Size ¶
func (m *CheckCommitLengthRequest) XXX_Size() int
func (*CheckCommitLengthRequest) XXX_Unmarshal ¶
func (m *CheckCommitLengthRequest) XXX_Unmarshal(b []byte) error
type CheckCommitLengthResponse ¶
type CheckCommitLengthResponse struct { Code Code `protobuf:"varint,1,opt,name=code,proto3,enum=pb.Code" json:"code,omitempty"` CodeDes string `protobuf:"bytes,2,opt,name=codeDes,proto3" json:"codeDes,omitempty"` StreamInfo *StreamInfo `protobuf:"bytes,3,opt,name=streamInfo,proto3" json:"streamInfo,omitempty"` End uint32 `protobuf:"varint,4,opt,name=end,proto3" json:"end,omitempty"` LastExInfo *ExtentInfo `protobuf:"bytes,5,opt,name=lastExInfo,proto3" json:"lastExInfo,omitempty"` }
func (*CheckCommitLengthResponse) Descriptor ¶
func (*CheckCommitLengthResponse) Descriptor() ([]byte, []int)
func (*CheckCommitLengthResponse) GetCode ¶
func (m *CheckCommitLengthResponse) GetCode() Code
func (*CheckCommitLengthResponse) GetCodeDes ¶
func (m *CheckCommitLengthResponse) GetCodeDes() string
func (*CheckCommitLengthResponse) GetEnd ¶
func (m *CheckCommitLengthResponse) GetEnd() uint32
func (*CheckCommitLengthResponse) GetLastExInfo ¶
func (m *CheckCommitLengthResponse) GetLastExInfo() *ExtentInfo
func (*CheckCommitLengthResponse) GetStreamInfo ¶
func (m *CheckCommitLengthResponse) GetStreamInfo() *StreamInfo
func (*CheckCommitLengthResponse) Marshal ¶
func (m *CheckCommitLengthResponse) Marshal() (dAtA []byte, err error)
func (*CheckCommitLengthResponse) MarshalTo ¶
func (m *CheckCommitLengthResponse) MarshalTo(dAtA []byte) (int, error)
func (*CheckCommitLengthResponse) MarshalToSizedBuffer ¶
func (m *CheckCommitLengthResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CheckCommitLengthResponse) ProtoMessage ¶
func (*CheckCommitLengthResponse) ProtoMessage()
func (*CheckCommitLengthResponse) Reset ¶
func (m *CheckCommitLengthResponse) Reset()
func (*CheckCommitLengthResponse) Size ¶
func (m *CheckCommitLengthResponse) Size() (n int)
func (*CheckCommitLengthResponse) String ¶
func (m *CheckCommitLengthResponse) String() string
func (*CheckCommitLengthResponse) Unmarshal ¶
func (m *CheckCommitLengthResponse) Unmarshal(dAtA []byte) error
func (*CheckCommitLengthResponse) XXX_DiscardUnknown ¶
func (m *CheckCommitLengthResponse) XXX_DiscardUnknown()
func (*CheckCommitLengthResponse) XXX_Marshal ¶
func (m *CheckCommitLengthResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CheckCommitLengthResponse) XXX_Merge ¶
func (m *CheckCommitLengthResponse) XXX_Merge(src proto.Message)
func (*CheckCommitLengthResponse) XXX_Size ¶
func (m *CheckCommitLengthResponse) XXX_Size() int
func (*CheckCommitLengthResponse) XXX_Unmarshal ¶
func (m *CheckCommitLengthResponse) XXX_Unmarshal(b []byte) error
type CommitLengthRequest ¶
type CommitLengthRequest struct { ExtentID uint64 `protobuf:"varint,1,opt,name=extentID,proto3" json:"extentID,omitempty"` Revision int64 `protobuf:"varint,2,opt,name=revision,proto3" json:"revision,omitempty"` }
func (*CommitLengthRequest) Descriptor ¶
func (*CommitLengthRequest) Descriptor() ([]byte, []int)
func (*CommitLengthRequest) GetExtentID ¶
func (m *CommitLengthRequest) GetExtentID() uint64
func (*CommitLengthRequest) GetRevision ¶
func (m *CommitLengthRequest) GetRevision() int64
func (*CommitLengthRequest) Marshal ¶
func (m *CommitLengthRequest) Marshal() (dAtA []byte, err error)
func (*CommitLengthRequest) MarshalTo ¶
func (m *CommitLengthRequest) MarshalTo(dAtA []byte) (int, error)
func (*CommitLengthRequest) MarshalToSizedBuffer ¶
func (m *CommitLengthRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CommitLengthRequest) ProtoMessage ¶
func (*CommitLengthRequest) ProtoMessage()
func (*CommitLengthRequest) Reset ¶
func (m *CommitLengthRequest) Reset()
func (*CommitLengthRequest) Size ¶
func (m *CommitLengthRequest) Size() (n int)
func (*CommitLengthRequest) String ¶
func (m *CommitLengthRequest) String() string
func (*CommitLengthRequest) Unmarshal ¶
func (m *CommitLengthRequest) Unmarshal(dAtA []byte) error
func (*CommitLengthRequest) XXX_DiscardUnknown ¶
func (m *CommitLengthRequest) XXX_DiscardUnknown()
func (*CommitLengthRequest) XXX_Marshal ¶
func (m *CommitLengthRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CommitLengthRequest) XXX_Merge ¶
func (m *CommitLengthRequest) XXX_Merge(src proto.Message)
func (*CommitLengthRequest) XXX_Size ¶
func (m *CommitLengthRequest) XXX_Size() int
func (*CommitLengthRequest) XXX_Unmarshal ¶
func (m *CommitLengthRequest) XXX_Unmarshal(b []byte) error
type CommitLengthResponse ¶
type CommitLengthResponse struct { Code Code `protobuf:"varint,1,opt,name=code,proto3,enum=pb.Code" json:"code,omitempty"` CodeDes string `protobuf:"bytes,2,opt,name=codeDes,proto3" json:"codeDes,omitempty"` Length uint32 `protobuf:"varint,3,opt,name=length,proto3" json:"length,omitempty"` }
func (*CommitLengthResponse) Descriptor ¶
func (*CommitLengthResponse) Descriptor() ([]byte, []int)
func (*CommitLengthResponse) GetCode ¶
func (m *CommitLengthResponse) GetCode() Code
func (*CommitLengthResponse) GetCodeDes ¶
func (m *CommitLengthResponse) GetCodeDes() string
func (*CommitLengthResponse) GetLength ¶
func (m *CommitLengthResponse) GetLength() uint32
func (*CommitLengthResponse) Marshal ¶
func (m *CommitLengthResponse) Marshal() (dAtA []byte, err error)
func (*CommitLengthResponse) MarshalTo ¶
func (m *CommitLengthResponse) MarshalTo(dAtA []byte) (int, error)
func (*CommitLengthResponse) MarshalToSizedBuffer ¶
func (m *CommitLengthResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CommitLengthResponse) ProtoMessage ¶
func (*CommitLengthResponse) ProtoMessage()
func (*CommitLengthResponse) Reset ¶
func (m *CommitLengthResponse) Reset()
func (*CommitLengthResponse) Size ¶
func (m *CommitLengthResponse) Size() (n int)
func (*CommitLengthResponse) String ¶
func (m *CommitLengthResponse) String() string
func (*CommitLengthResponse) Unmarshal ¶
func (m *CommitLengthResponse) Unmarshal(dAtA []byte) error
func (*CommitLengthResponse) XXX_DiscardUnknown ¶
func (m *CommitLengthResponse) XXX_DiscardUnknown()
func (*CommitLengthResponse) XXX_Marshal ¶
func (m *CommitLengthResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CommitLengthResponse) XXX_Merge ¶
func (m *CommitLengthResponse) XXX_Merge(src proto.Message)
func (*CommitLengthResponse) XXX_Size ¶
func (m *CommitLengthResponse) XXX_Size() int
func (*CommitLengthResponse) XXX_Unmarshal ¶
func (m *CommitLengthResponse) XXX_Unmarshal(b []byte) error
type CopyExtentRequest ¶
type CopyExtentRequest struct { ExtentID uint64 `protobuf:"varint,1,opt,name=extentID,proto3" json:"extentID,omitempty"` Offset uint64 `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"` Size_ uint64 `protobuf:"varint,3,opt,name=size,proto3" json:"size,omitempty"` Eversion uint64 `protobuf:"varint,4,opt,name=eversion,proto3" json:"eversion,omitempty"` }
func (*CopyExtentRequest) Descriptor ¶
func (*CopyExtentRequest) Descriptor() ([]byte, []int)
func (*CopyExtentRequest) GetEversion ¶
func (m *CopyExtentRequest) GetEversion() uint64
func (*CopyExtentRequest) GetExtentID ¶
func (m *CopyExtentRequest) GetExtentID() uint64
func (*CopyExtentRequest) GetOffset ¶
func (m *CopyExtentRequest) GetOffset() uint64
func (*CopyExtentRequest) GetSize_ ¶
func (m *CopyExtentRequest) GetSize_() uint64
func (*CopyExtentRequest) Marshal ¶
func (m *CopyExtentRequest) Marshal() (dAtA []byte, err error)
func (*CopyExtentRequest) MarshalTo ¶
func (m *CopyExtentRequest) MarshalTo(dAtA []byte) (int, error)
func (*CopyExtentRequest) MarshalToSizedBuffer ¶
func (m *CopyExtentRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CopyExtentRequest) ProtoMessage ¶
func (*CopyExtentRequest) ProtoMessage()
func (*CopyExtentRequest) Reset ¶
func (m *CopyExtentRequest) Reset()
func (*CopyExtentRequest) Size ¶
func (m *CopyExtentRequest) Size() (n int)
func (*CopyExtentRequest) String ¶
func (m *CopyExtentRequest) String() string
func (*CopyExtentRequest) Unmarshal ¶
func (m *CopyExtentRequest) Unmarshal(dAtA []byte) error
func (*CopyExtentRequest) XXX_DiscardUnknown ¶
func (m *CopyExtentRequest) XXX_DiscardUnknown()
func (*CopyExtentRequest) XXX_Marshal ¶
func (m *CopyExtentRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CopyExtentRequest) XXX_Merge ¶
func (m *CopyExtentRequest) XXX_Merge(src proto.Message)
func (*CopyExtentRequest) XXX_Size ¶
func (m *CopyExtentRequest) XXX_Size() int
func (*CopyExtentRequest) XXX_Unmarshal ¶
func (m *CopyExtentRequest) XXX_Unmarshal(b []byte) error
type CopyExtentResponse ¶
type CopyExtentResponse struct { // Types that are valid to be assigned to Data: // *CopyExtentResponse_Header // *CopyExtentResponse_Payload Data isCopyExtentResponse_Data `protobuf_oneof:"data"` }
func (*CopyExtentResponse) Descriptor ¶
func (*CopyExtentResponse) Descriptor() ([]byte, []int)
func (*CopyExtentResponse) GetData ¶
func (m *CopyExtentResponse) GetData() isCopyExtentResponse_Data
func (*CopyExtentResponse) GetHeader ¶
func (m *CopyExtentResponse) GetHeader() *CopyResponseHeader
func (*CopyExtentResponse) GetPayload ¶
func (m *CopyExtentResponse) GetPayload() []byte
func (*CopyExtentResponse) Marshal ¶
func (m *CopyExtentResponse) Marshal() (dAtA []byte, err error)
func (*CopyExtentResponse) MarshalTo ¶
func (m *CopyExtentResponse) MarshalTo(dAtA []byte) (int, error)
func (*CopyExtentResponse) MarshalToSizedBuffer ¶
func (m *CopyExtentResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CopyExtentResponse) ProtoMessage ¶
func (*CopyExtentResponse) ProtoMessage()
func (*CopyExtentResponse) Reset ¶
func (m *CopyExtentResponse) Reset()
func (*CopyExtentResponse) Size ¶
func (m *CopyExtentResponse) Size() (n int)
func (*CopyExtentResponse) String ¶
func (m *CopyExtentResponse) String() string
func (*CopyExtentResponse) Unmarshal ¶
func (m *CopyExtentResponse) Unmarshal(dAtA []byte) error
func (*CopyExtentResponse) XXX_DiscardUnknown ¶
func (m *CopyExtentResponse) XXX_DiscardUnknown()
func (*CopyExtentResponse) XXX_Marshal ¶
func (m *CopyExtentResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CopyExtentResponse) XXX_Merge ¶
func (m *CopyExtentResponse) XXX_Merge(src proto.Message)
func (*CopyExtentResponse) XXX_OneofWrappers ¶
func (*CopyExtentResponse) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*CopyExtentResponse) XXX_Size ¶
func (m *CopyExtentResponse) XXX_Size() int
func (*CopyExtentResponse) XXX_Unmarshal ¶
func (m *CopyExtentResponse) XXX_Unmarshal(b []byte) error
type CopyExtentResponse_Header ¶
type CopyExtentResponse_Header struct {
Header *CopyResponseHeader `protobuf:"bytes,1,opt,name=header,proto3,oneof" json:"header,omitempty"`
}
func (*CopyExtentResponse_Header) MarshalTo ¶
func (m *CopyExtentResponse_Header) MarshalTo(dAtA []byte) (int, error)
func (*CopyExtentResponse_Header) MarshalToSizedBuffer ¶
func (m *CopyExtentResponse_Header) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CopyExtentResponse_Header) Size ¶
func (m *CopyExtentResponse_Header) Size() (n int)
type CopyExtentResponse_Payload ¶
type CopyExtentResponse_Payload struct {
Payload []byte `protobuf:"bytes,2,opt,name=payload,proto3,oneof" json:"payload,omitempty"`
}
func (*CopyExtentResponse_Payload) MarshalTo ¶
func (m *CopyExtentResponse_Payload) MarshalTo(dAtA []byte) (int, error)
func (*CopyExtentResponse_Payload) MarshalToSizedBuffer ¶
func (m *CopyExtentResponse_Payload) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CopyExtentResponse_Payload) Size ¶
func (m *CopyExtentResponse_Payload) Size() (n int)
type CopyResponseHeader ¶
type CopyResponseHeader struct { Code Code `protobuf:"varint,1,opt,name=code,proto3,enum=pb.Code" json:"code,omitempty"` CodeDes string `protobuf:"bytes,2,opt,name=codeDes,proto3" json:"codeDes,omitempty"` PayloadLen uint64 `protobuf:"varint,3,opt,name=payloadLen,proto3" json:"payloadLen,omitempty"` }
maybe
func (*CopyResponseHeader) Descriptor ¶
func (*CopyResponseHeader) Descriptor() ([]byte, []int)
func (*CopyResponseHeader) GetCode ¶
func (m *CopyResponseHeader) GetCode() Code
func (*CopyResponseHeader) GetCodeDes ¶
func (m *CopyResponseHeader) GetCodeDes() string
func (*CopyResponseHeader) GetPayloadLen ¶
func (m *CopyResponseHeader) GetPayloadLen() uint64
func (*CopyResponseHeader) Marshal ¶
func (m *CopyResponseHeader) Marshal() (dAtA []byte, err error)
func (*CopyResponseHeader) MarshalTo ¶
func (m *CopyResponseHeader) MarshalTo(dAtA []byte) (int, error)
func (*CopyResponseHeader) MarshalToSizedBuffer ¶
func (m *CopyResponseHeader) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CopyResponseHeader) ProtoMessage ¶
func (*CopyResponseHeader) ProtoMessage()
func (*CopyResponseHeader) Reset ¶
func (m *CopyResponseHeader) Reset()
func (*CopyResponseHeader) Size ¶
func (m *CopyResponseHeader) Size() (n int)
func (*CopyResponseHeader) String ¶
func (m *CopyResponseHeader) String() string
func (*CopyResponseHeader) Unmarshal ¶
func (m *CopyResponseHeader) Unmarshal(dAtA []byte) error
func (*CopyResponseHeader) XXX_DiscardUnknown ¶
func (m *CopyResponseHeader) XXX_DiscardUnknown()
func (*CopyResponseHeader) XXX_Marshal ¶
func (m *CopyResponseHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CopyResponseHeader) XXX_Merge ¶
func (m *CopyResponseHeader) XXX_Merge(src proto.Message)
func (*CopyResponseHeader) XXX_Size ¶
func (m *CopyResponseHeader) XXX_Size() int
func (*CopyResponseHeader) XXX_Unmarshal ¶
func (m *CopyResponseHeader) XXX_Unmarshal(b []byte) error
type CreateExtentRequest ¶
type CreateExtentRequest struct {
StreamID uint64 `protobuf:"varint,1,opt,name=streamID,proto3" json:"streamID,omitempty"`
}
func (*CreateExtentRequest) Descriptor ¶
func (*CreateExtentRequest) Descriptor() ([]byte, []int)
func (*CreateExtentRequest) GetStreamID ¶
func (m *CreateExtentRequest) GetStreamID() uint64
func (*CreateExtentRequest) Marshal ¶
func (m *CreateExtentRequest) Marshal() (dAtA []byte, err error)
func (*CreateExtentRequest) MarshalTo ¶
func (m *CreateExtentRequest) MarshalTo(dAtA []byte) (int, error)
func (*CreateExtentRequest) MarshalToSizedBuffer ¶
func (m *CreateExtentRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CreateExtentRequest) ProtoMessage ¶
func (*CreateExtentRequest) ProtoMessage()
func (*CreateExtentRequest) Reset ¶
func (m *CreateExtentRequest) Reset()
func (*CreateExtentRequest) Size ¶
func (m *CreateExtentRequest) Size() (n int)
func (*CreateExtentRequest) String ¶
func (m *CreateExtentRequest) String() string
func (*CreateExtentRequest) Unmarshal ¶
func (m *CreateExtentRequest) Unmarshal(dAtA []byte) error
func (*CreateExtentRequest) XXX_DiscardUnknown ¶
func (m *CreateExtentRequest) XXX_DiscardUnknown()
func (*CreateExtentRequest) XXX_Marshal ¶
func (m *CreateExtentRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CreateExtentRequest) XXX_Merge ¶
func (m *CreateExtentRequest) XXX_Merge(src proto.Message)
func (*CreateExtentRequest) XXX_Size ¶
func (m *CreateExtentRequest) XXX_Size() int
func (*CreateExtentRequest) XXX_Unmarshal ¶
func (m *CreateExtentRequest) XXX_Unmarshal(b []byte) error
type CreateExtentResponse ¶
type CreateExtentResponse struct { Code Code `protobuf:"varint,1,opt,name=code,proto3,enum=pb.Code" json:"code,omitempty"` CodeDes string `protobuf:"bytes,2,opt,name=codeDes,proto3" json:"codeDes,omitempty"` ExtentID uint64 `protobuf:"varint,3,opt,name=extentID,proto3" json:"extentID,omitempty"` }
func (*CreateExtentResponse) Descriptor ¶
func (*CreateExtentResponse) Descriptor() ([]byte, []int)
func (*CreateExtentResponse) GetCode ¶
func (m *CreateExtentResponse) GetCode() Code
func (*CreateExtentResponse) GetCodeDes ¶
func (m *CreateExtentResponse) GetCodeDes() string
func (*CreateExtentResponse) GetExtentID ¶
func (m *CreateExtentResponse) GetExtentID() uint64
func (*CreateExtentResponse) Marshal ¶
func (m *CreateExtentResponse) Marshal() (dAtA []byte, err error)
func (*CreateExtentResponse) MarshalTo ¶
func (m *CreateExtentResponse) MarshalTo(dAtA []byte) (int, error)
func (*CreateExtentResponse) MarshalToSizedBuffer ¶
func (m *CreateExtentResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CreateExtentResponse) ProtoMessage ¶
func (*CreateExtentResponse) ProtoMessage()
func (*CreateExtentResponse) Reset ¶
func (m *CreateExtentResponse) Reset()
func (*CreateExtentResponse) Size ¶
func (m *CreateExtentResponse) Size() (n int)
func (*CreateExtentResponse) String ¶
func (m *CreateExtentResponse) String() string
func (*CreateExtentResponse) Unmarshal ¶
func (m *CreateExtentResponse) Unmarshal(dAtA []byte) error
func (*CreateExtentResponse) XXX_DiscardUnknown ¶
func (m *CreateExtentResponse) XXX_DiscardUnknown()
func (*CreateExtentResponse) XXX_Marshal ¶
func (m *CreateExtentResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CreateExtentResponse) XXX_Merge ¶
func (m *CreateExtentResponse) XXX_Merge(src proto.Message)
func (*CreateExtentResponse) XXX_Size ¶
func (m *CreateExtentResponse) XXX_Size() int
func (*CreateExtentResponse) XXX_Unmarshal ¶
func (m *CreateExtentResponse) XXX_Unmarshal(b []byte) error
type CreateStreamRequest ¶
type CreateStreamRequest struct { DataShard uint32 `protobuf:"varint,1,opt,name=dataShard,proto3" json:"dataShard,omitempty"` ParityShard uint32 `protobuf:"varint,2,opt,name=parityShard,proto3" json:"parityShard,omitempty"` }
func (*CreateStreamRequest) Descriptor ¶
func (*CreateStreamRequest) Descriptor() ([]byte, []int)
func (*CreateStreamRequest) GetDataShard ¶
func (m *CreateStreamRequest) GetDataShard() uint32
func (*CreateStreamRequest) GetParityShard ¶
func (m *CreateStreamRequest) GetParityShard() uint32
func (*CreateStreamRequest) Marshal ¶
func (m *CreateStreamRequest) Marshal() (dAtA []byte, err error)
func (*CreateStreamRequest) MarshalTo ¶
func (m *CreateStreamRequest) MarshalTo(dAtA []byte) (int, error)
func (*CreateStreamRequest) MarshalToSizedBuffer ¶
func (m *CreateStreamRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CreateStreamRequest) ProtoMessage ¶
func (*CreateStreamRequest) ProtoMessage()
func (*CreateStreamRequest) Reset ¶
func (m *CreateStreamRequest) Reset()
func (*CreateStreamRequest) Size ¶
func (m *CreateStreamRequest) Size() (n int)
func (*CreateStreamRequest) String ¶
func (m *CreateStreamRequest) String() string
func (*CreateStreamRequest) Unmarshal ¶
func (m *CreateStreamRequest) Unmarshal(dAtA []byte) error
func (*CreateStreamRequest) XXX_DiscardUnknown ¶
func (m *CreateStreamRequest) XXX_DiscardUnknown()
func (*CreateStreamRequest) XXX_Marshal ¶
func (m *CreateStreamRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CreateStreamRequest) XXX_Merge ¶
func (m *CreateStreamRequest) XXX_Merge(src proto.Message)
func (*CreateStreamRequest) XXX_Size ¶
func (m *CreateStreamRequest) XXX_Size() int
func (*CreateStreamRequest) XXX_Unmarshal ¶
func (m *CreateStreamRequest) XXX_Unmarshal(b []byte) error
type CreateStreamResponse ¶
type CreateStreamResponse struct { Code Code `protobuf:"varint,1,opt,name=code,proto3,enum=pb.Code" json:"code,omitempty"` CodeDes string `protobuf:"bytes,2,opt,name=codeDes,proto3" json:"codeDes,omitempty"` Stream *StreamInfo `protobuf:"bytes,3,opt,name=stream,proto3" json:"stream,omitempty"` Extent *ExtentInfo `protobuf:"bytes,4,opt,name=extent,proto3" json:"extent,omitempty"` }
func (*CreateStreamResponse) Descriptor ¶
func (*CreateStreamResponse) Descriptor() ([]byte, []int)
func (*CreateStreamResponse) GetCode ¶
func (m *CreateStreamResponse) GetCode() Code
func (*CreateStreamResponse) GetCodeDes ¶
func (m *CreateStreamResponse) GetCodeDes() string
func (*CreateStreamResponse) GetExtent ¶
func (m *CreateStreamResponse) GetExtent() *ExtentInfo
func (*CreateStreamResponse) GetStream ¶
func (m *CreateStreamResponse) GetStream() *StreamInfo
func (*CreateStreamResponse) Marshal ¶
func (m *CreateStreamResponse) Marshal() (dAtA []byte, err error)
func (*CreateStreamResponse) MarshalTo ¶
func (m *CreateStreamResponse) MarshalTo(dAtA []byte) (int, error)
func (*CreateStreamResponse) MarshalToSizedBuffer ¶
func (m *CreateStreamResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CreateStreamResponse) ProtoMessage ¶
func (*CreateStreamResponse) ProtoMessage()
func (*CreateStreamResponse) Reset ¶
func (m *CreateStreamResponse) Reset()
func (*CreateStreamResponse) Size ¶
func (m *CreateStreamResponse) Size() (n int)
func (*CreateStreamResponse) String ¶
func (m *CreateStreamResponse) String() string
func (*CreateStreamResponse) Unmarshal ¶
func (m *CreateStreamResponse) Unmarshal(dAtA []byte) error
func (*CreateStreamResponse) XXX_DiscardUnknown ¶
func (m *CreateStreamResponse) XXX_DiscardUnknown()
func (*CreateStreamResponse) XXX_Marshal ¶
func (m *CreateStreamResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CreateStreamResponse) XXX_Merge ¶
func (m *CreateStreamResponse) XXX_Merge(src proto.Message)
func (*CreateStreamResponse) XXX_Size ¶
func (m *CreateStreamResponse) XXX_Size() int
func (*CreateStreamResponse) XXX_Unmarshal ¶
func (m *CreateStreamResponse) XXX_Unmarshal(b []byte) error
type DF ¶
type DF struct { Total uint64 `protobuf:"varint,1,opt,name=total,proto3" json:"total,omitempty"` Free uint64 `protobuf:"varint,2,opt,name=free,proto3" json:"free,omitempty"` Online bool `protobuf:"varint,3,opt,name=online,proto3" json:"online,omitempty"` }
func (*DF) Descriptor ¶
func (*DF) ProtoMessage ¶
func (*DF) ProtoMessage()
func (*DF) XXX_DiscardUnknown ¶
func (m *DF) XXX_DiscardUnknown()
func (*DF) XXX_Unmarshal ¶
type DfRequest ¶
type DfRequest struct { Tasks []*RecoveryTask `protobuf:"bytes,1,rep,name=tasks,proto3" json:"tasks,omitempty"` DiskIDs []uint64 `protobuf:"varint,2,rep,packed,name=diskIDs,proto3" json:"diskIDs,omitempty"` }
func (*DfRequest) Descriptor ¶
func (*DfRequest) GetDiskIDs ¶
func (*DfRequest) GetTasks ¶
func (m *DfRequest) GetTasks() []*RecoveryTask
func (*DfRequest) MarshalToSizedBuffer ¶
func (*DfRequest) ProtoMessage ¶
func (*DfRequest) ProtoMessage()
func (*DfRequest) XXX_DiscardUnknown ¶
func (m *DfRequest) XXX_DiscardUnknown()
func (*DfRequest) XXX_Marshal ¶
func (*DfRequest) XXX_Unmarshal ¶
type DfResponse ¶
type DfResponse struct { DoneTask []*RecoveryTaskStatus `protobuf:"bytes,4,rep,name=doneTask,proto3" json:"doneTask,omitempty"` DiskStatus map[uint64]*DF `` /* 162-byte string literal not displayed */ }
DfResponse does't need to Code/CodeDes
func (*DfResponse) Descriptor ¶
func (*DfResponse) Descriptor() ([]byte, []int)
func (*DfResponse) GetDiskStatus ¶
func (m *DfResponse) GetDiskStatus() map[uint64]*DF
func (*DfResponse) GetDoneTask ¶
func (m *DfResponse) GetDoneTask() []*RecoveryTaskStatus
func (*DfResponse) Marshal ¶
func (m *DfResponse) Marshal() (dAtA []byte, err error)
func (*DfResponse) MarshalToSizedBuffer ¶
func (m *DfResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*DfResponse) ProtoMessage ¶
func (*DfResponse) ProtoMessage()
func (*DfResponse) Reset ¶
func (m *DfResponse) Reset()
func (*DfResponse) Size ¶
func (m *DfResponse) Size() (n int)
func (*DfResponse) String ¶
func (m *DfResponse) String() string
func (*DfResponse) Unmarshal ¶
func (m *DfResponse) Unmarshal(dAtA []byte) error
func (*DfResponse) XXX_DiscardUnknown ¶
func (m *DfResponse) XXX_DiscardUnknown()
func (*DfResponse) XXX_Marshal ¶
func (m *DfResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DfResponse) XXX_Merge ¶
func (m *DfResponse) XXX_Merge(src proto.Message)
func (*DfResponse) XXX_Size ¶
func (m *DfResponse) XXX_Size() int
func (*DfResponse) XXX_Unmarshal ¶
func (m *DfResponse) XXX_Unmarshal(b []byte) error
type DiskInfo ¶
type DiskInfo struct { DiskID uint64 `protobuf:"varint,1,opt,name=diskID,proto3" json:"diskID,omitempty"` Online bool `protobuf:"varint,2,opt,name=online,proto3" json:"online,omitempty"` Uuid string `protobuf:"bytes,3,opt,name=uuid,proto3" json:"uuid,omitempty"` }
func (*DiskInfo) Descriptor ¶
func (*DiskInfo) MarshalToSizedBuffer ¶
func (*DiskInfo) ProtoMessage ¶
func (*DiskInfo) ProtoMessage()
func (*DiskInfo) XXX_DiscardUnknown ¶
func (m *DiskInfo) XXX_DiscardUnknown()
func (*DiskInfo) XXX_Marshal ¶
func (*DiskInfo) XXX_Unmarshal ¶
type ExtentInfo ¶
type ExtentInfo struct { ExtentID uint64 `protobuf:"varint,1,opt,name=extentID,proto3" json:"extentID,omitempty"` Replicates []uint64 `protobuf:"varint,2,rep,packed,name=replicates,proto3" json:"replicates,omitempty"` Parity []uint64 `protobuf:"varint,3,rep,packed,name=parity,proto3" json:"parity,omitempty"` Eversion uint64 `protobuf:"varint,4,opt,name=eversion,proto3" json:"eversion,omitempty"` Refs uint64 `protobuf:"varint,5,opt,name=refs,proto3" json:"refs,omitempty"` SealedLength uint64 `protobuf:"varint,6,opt,name=SealedLength,proto3" json:"SealedLength,omitempty"` Avali uint32 `protobuf:"varint,7,opt,name=avali,proto3" json:"avali,omitempty"` ReplicateDisks []uint64 `protobuf:"varint,8,rep,packed,name=replicateDisks,proto3" json:"replicateDisks,omitempty"` ParityDisk []uint64 `protobuf:"varint,9,rep,packed,name=parityDisk,proto3" json:"parityDisk,omitempty"` }
func (*ExtentInfo) Descriptor ¶
func (*ExtentInfo) Descriptor() ([]byte, []int)
func (*ExtentInfo) GetAvali ¶
func (m *ExtentInfo) GetAvali() uint32
func (*ExtentInfo) GetEversion ¶
func (m *ExtentInfo) GetEversion() uint64
func (*ExtentInfo) GetExtentID ¶
func (m *ExtentInfo) GetExtentID() uint64
func (*ExtentInfo) GetParity ¶
func (m *ExtentInfo) GetParity() []uint64
func (*ExtentInfo) GetParityDisk ¶
func (m *ExtentInfo) GetParityDisk() []uint64
func (*ExtentInfo) GetRefs ¶
func (m *ExtentInfo) GetRefs() uint64
func (*ExtentInfo) GetReplicateDisks ¶
func (m *ExtentInfo) GetReplicateDisks() []uint64
func (*ExtentInfo) GetReplicates ¶
func (m *ExtentInfo) GetReplicates() []uint64
func (*ExtentInfo) GetSealedLength ¶
func (m *ExtentInfo) GetSealedLength() uint64
func (*ExtentInfo) Marshal ¶
func (m *ExtentInfo) Marshal() (dAtA []byte, err error)
func (*ExtentInfo) MarshalToSizedBuffer ¶
func (m *ExtentInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ExtentInfo) ProtoMessage ¶
func (*ExtentInfo) ProtoMessage()
func (*ExtentInfo) Reset ¶
func (m *ExtentInfo) Reset()
func (*ExtentInfo) Size ¶
func (m *ExtentInfo) Size() (n int)
func (*ExtentInfo) String ¶
func (m *ExtentInfo) String() string
func (*ExtentInfo) Unmarshal ¶
func (m *ExtentInfo) Unmarshal(dAtA []byte) error
func (*ExtentInfo) XXX_DiscardUnknown ¶
func (m *ExtentInfo) XXX_DiscardUnknown()
func (*ExtentInfo) XXX_Marshal ¶
func (m *ExtentInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ExtentInfo) XXX_Merge ¶
func (m *ExtentInfo) XXX_Merge(src proto.Message)
func (*ExtentInfo) XXX_Size ¶
func (m *ExtentInfo) XXX_Size() int
func (*ExtentInfo) XXX_Unmarshal ¶
func (m *ExtentInfo) XXX_Unmarshal(b []byte) error
type ExtentInfoRequest ¶
type ExtentInfoRequest struct {
ExtentID uint64 `protobuf:"varint,1,opt,name=extentID,proto3" json:"extentID,omitempty"`
}
func (*ExtentInfoRequest) Descriptor ¶
func (*ExtentInfoRequest) Descriptor() ([]byte, []int)
func (*ExtentInfoRequest) GetExtentID ¶
func (m *ExtentInfoRequest) GetExtentID() uint64
func (*ExtentInfoRequest) Marshal ¶
func (m *ExtentInfoRequest) Marshal() (dAtA []byte, err error)
func (*ExtentInfoRequest) MarshalTo ¶
func (m *ExtentInfoRequest) MarshalTo(dAtA []byte) (int, error)
func (*ExtentInfoRequest) MarshalToSizedBuffer ¶
func (m *ExtentInfoRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ExtentInfoRequest) ProtoMessage ¶
func (*ExtentInfoRequest) ProtoMessage()
func (*ExtentInfoRequest) Reset ¶
func (m *ExtentInfoRequest) Reset()
func (*ExtentInfoRequest) Size ¶
func (m *ExtentInfoRequest) Size() (n int)
func (*ExtentInfoRequest) String ¶
func (m *ExtentInfoRequest) String() string
func (*ExtentInfoRequest) Unmarshal ¶
func (m *ExtentInfoRequest) Unmarshal(dAtA []byte) error
func (*ExtentInfoRequest) XXX_DiscardUnknown ¶
func (m *ExtentInfoRequest) XXX_DiscardUnknown()
func (*ExtentInfoRequest) XXX_Marshal ¶
func (m *ExtentInfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ExtentInfoRequest) XXX_Merge ¶
func (m *ExtentInfoRequest) XXX_Merge(src proto.Message)
func (*ExtentInfoRequest) XXX_Size ¶
func (m *ExtentInfoRequest) XXX_Size() int
func (*ExtentInfoRequest) XXX_Unmarshal ¶
func (m *ExtentInfoRequest) XXX_Unmarshal(b []byte) error
type ExtentInfoResponse ¶
type ExtentInfoResponse struct { Code Code `protobuf:"varint,1,opt,name=code,proto3,enum=pb.Code" json:"code,omitempty"` CodeDes string `protobuf:"bytes,2,opt,name=codeDes,proto3" json:"codeDes,omitempty"` ExInfo *ExtentInfo `protobuf:"bytes,3,opt,name=exInfo,proto3" json:"exInfo,omitempty"` }
func (*ExtentInfoResponse) Descriptor ¶
func (*ExtentInfoResponse) Descriptor() ([]byte, []int)
func (*ExtentInfoResponse) GetCode ¶
func (m *ExtentInfoResponse) GetCode() Code
func (*ExtentInfoResponse) GetCodeDes ¶
func (m *ExtentInfoResponse) GetCodeDes() string
func (*ExtentInfoResponse) GetExInfo ¶
func (m *ExtentInfoResponse) GetExInfo() *ExtentInfo
func (*ExtentInfoResponse) Marshal ¶
func (m *ExtentInfoResponse) Marshal() (dAtA []byte, err error)
func (*ExtentInfoResponse) MarshalTo ¶
func (m *ExtentInfoResponse) MarshalTo(dAtA []byte) (int, error)
func (*ExtentInfoResponse) MarshalToSizedBuffer ¶
func (m *ExtentInfoResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ExtentInfoResponse) ProtoMessage ¶
func (*ExtentInfoResponse) ProtoMessage()
func (*ExtentInfoResponse) Reset ¶
func (m *ExtentInfoResponse) Reset()
func (*ExtentInfoResponse) Size ¶
func (m *ExtentInfoResponse) Size() (n int)
func (*ExtentInfoResponse) String ¶
func (m *ExtentInfoResponse) String() string
func (*ExtentInfoResponse) Unmarshal ¶
func (m *ExtentInfoResponse) Unmarshal(dAtA []byte) error
func (*ExtentInfoResponse) XXX_DiscardUnknown ¶
func (m *ExtentInfoResponse) XXX_DiscardUnknown()
func (*ExtentInfoResponse) XXX_Marshal ¶
func (m *ExtentInfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ExtentInfoResponse) XXX_Merge ¶
func (m *ExtentInfoResponse) XXX_Merge(src proto.Message)
func (*ExtentInfoResponse) XXX_Size ¶
func (m *ExtentInfoResponse) XXX_Size() int
func (*ExtentInfoResponse) XXX_Unmarshal ¶
func (m *ExtentInfoResponse) XXX_Unmarshal(b []byte) error
type ExtentServiceClient ¶
type ExtentServiceClient interface { //from stream client Append(ctx context.Context, opts ...grpc.CallOption) (ExtentService_AppendClient, error) //rpc ReadEntries(ReadEntriesRequest) returns (ReadEntriesResponse){} //rpc SmartReadBlocks(ReadBlocksRequest) returns (ReadBlocksResponse){} ReadBlocks(ctx context.Context, in *ReadBlocksRequest, opts ...grpc.CallOption) (ExtentService_ReadBlocksClient, error) //internal rpc ReAvali(ctx context.Context, in *ReAvaliRequest, opts ...grpc.CallOption) (*ReAvaliResponse, error) CopyExtent(ctx context.Context, in *CopyExtentRequest, opts ...grpc.CallOption) (ExtentService_CopyExtentClient, error) Df(ctx context.Context, in *DfRequest, opts ...grpc.CallOption) (*DfResponse, error) RequireRecovery(ctx context.Context, in *RequireRecoveryRequest, opts ...grpc.CallOption) (*RequireRecoveryResponse, error) CommitLength(ctx context.Context, in *CommitLengthRequest, opts ...grpc.CallOption) (*CommitLengthResponse, error) Heartbeat(ctx context.Context, in *Payload, opts ...grpc.CallOption) (ExtentService_HeartbeatClient, error) //rpc ReplicateBlocks(ReplicateBlocksRequest) returns (ReplicateBlocksResponse) {} AllocExtent(ctx context.Context, in *AllocExtentRequest, opts ...grpc.CallOption) (*AllocExtentResponse, error) }
ExtentServiceClient is the client API for ExtentService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewExtentServiceClient ¶
func NewExtentServiceClient(cc *grpc.ClientConn) ExtentServiceClient
type ExtentServiceServer ¶
type ExtentServiceServer interface { //from stream client Append(ExtentService_AppendServer) error //rpc ReadEntries(ReadEntriesRequest) returns (ReadEntriesResponse){} //rpc SmartReadBlocks(ReadBlocksRequest) returns (ReadBlocksResponse){} ReadBlocks(*ReadBlocksRequest, ExtentService_ReadBlocksServer) error //internal rpc ReAvali(context.Context, *ReAvaliRequest) (*ReAvaliResponse, error) CopyExtent(*CopyExtentRequest, ExtentService_CopyExtentServer) error Df(context.Context, *DfRequest) (*DfResponse, error) RequireRecovery(context.Context, *RequireRecoveryRequest) (*RequireRecoveryResponse, error) CommitLength(context.Context, *CommitLengthRequest) (*CommitLengthResponse, error) Heartbeat(*Payload, ExtentService_HeartbeatServer) error //rpc ReplicateBlocks(ReplicateBlocksRequest) returns (ReplicateBlocksResponse) {} AllocExtent(context.Context, *AllocExtentRequest) (*AllocExtentResponse, error) }
ExtentServiceServer is the server API for ExtentService service.
type ExtentService_AppendClient ¶
type ExtentService_AppendClient interface { Send(*AppendRequest) error CloseAndRecv() (*AppendResponse, error) grpc.ClientStream }
type ExtentService_AppendServer ¶
type ExtentService_AppendServer interface { SendAndClose(*AppendResponse) error Recv() (*AppendRequest, error) grpc.ServerStream }
type ExtentService_CopyExtentClient ¶
type ExtentService_CopyExtentClient interface { Recv() (*CopyExtentResponse, error) grpc.ClientStream }
type ExtentService_CopyExtentServer ¶
type ExtentService_CopyExtentServer interface { Send(*CopyExtentResponse) error grpc.ServerStream }
type ExtentService_HeartbeatClient ¶
type ExtentService_HeartbeatClient interface { Recv() (*Payload, error) grpc.ClientStream }
type ExtentService_HeartbeatServer ¶
type ExtentService_HeartbeatServer interface { Send(*Payload) error grpc.ServerStream }
type ExtentService_ReadBlocksClient ¶
type ExtentService_ReadBlocksClient interface { Recv() (*ReadBlocksResponse, error) grpc.ClientStream }
type ExtentService_ReadBlocksServer ¶
type ExtentService_ReadBlocksServer interface { Send(*ReadBlocksResponse) error grpc.ServerStream }
type MemberValue ¶
type MemberValue struct { ID uint64 `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"` Name string `protobuf:"bytes,2,opt,name=Name,proto3" json:"Name,omitempty"` GrpcURL string `protobuf:"bytes,3,opt,name=GrpcURL,proto3" json:"GrpcURL,omitempty"` }
used in Etcd Campaign
func (*MemberValue) Descriptor ¶
func (*MemberValue) Descriptor() ([]byte, []int)
func (*MemberValue) GetGrpcURL ¶
func (m *MemberValue) GetGrpcURL() string
func (*MemberValue) GetID ¶
func (m *MemberValue) GetID() uint64
func (*MemberValue) GetName ¶
func (m *MemberValue) GetName() string
func (*MemberValue) Marshal ¶
func (m *MemberValue) Marshal() (dAtA []byte, err error)
func (*MemberValue) MarshalToSizedBuffer ¶
func (m *MemberValue) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MemberValue) ProtoMessage ¶
func (*MemberValue) ProtoMessage()
func (*MemberValue) Reset ¶
func (m *MemberValue) Reset()
func (*MemberValue) Size ¶
func (m *MemberValue) Size() (n int)
func (*MemberValue) String ¶
func (m *MemberValue) String() string
func (*MemberValue) Unmarshal ¶
func (m *MemberValue) Unmarshal(dAtA []byte) error
func (*MemberValue) XXX_DiscardUnknown ¶
func (m *MemberValue) XXX_DiscardUnknown()
func (*MemberValue) XXX_Marshal ¶
func (m *MemberValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MemberValue) XXX_Merge ¶
func (m *MemberValue) XXX_Merge(src proto.Message)
func (*MemberValue) XXX_Size ¶
func (m *MemberValue) XXX_Size() int
func (*MemberValue) XXX_Unmarshal ¶
func (m *MemberValue) XXX_Unmarshal(b []byte) error
type MultiModifySplitRequest ¶
type MultiModifySplitRequest struct { PartID uint64 `protobuf:"varint,1,opt,name=partID,proto3" json:"partID,omitempty"` MidKey []byte `protobuf:"bytes,2,opt,name=midKey,proto3" json:"midKey,omitempty"` OwnerKey string `protobuf:"bytes,3,opt,name=ownerKey,proto3" json:"ownerKey,omitempty"` Revision int64 `protobuf:"varint,4,opt,name=revision,proto3" json:"revision,omitempty"` LogStreamSealedLength uint32 `protobuf:"varint,5,opt,name=logStreamSealedLength,proto3" json:"logStreamSealedLength,omitempty"` RowStreamSealedLength uint32 `protobuf:"varint,6,opt,name=rowStreamSealedLength,proto3" json:"rowStreamSealedLength,omitempty"` MetaStreamSealedLength uint32 `protobuf:"varint,7,opt,name=metaStreamSealedLength,proto3" json:"metaStreamSealedLength,omitempty"` }
func (*MultiModifySplitRequest) Descriptor ¶
func (*MultiModifySplitRequest) Descriptor() ([]byte, []int)
func (*MultiModifySplitRequest) GetLogStreamSealedLength ¶
func (m *MultiModifySplitRequest) GetLogStreamSealedLength() uint32
func (*MultiModifySplitRequest) GetMetaStreamSealedLength ¶
func (m *MultiModifySplitRequest) GetMetaStreamSealedLength() uint32
func (*MultiModifySplitRequest) GetMidKey ¶
func (m *MultiModifySplitRequest) GetMidKey() []byte
func (*MultiModifySplitRequest) GetOwnerKey ¶
func (m *MultiModifySplitRequest) GetOwnerKey() string
func (*MultiModifySplitRequest) GetPartID ¶
func (m *MultiModifySplitRequest) GetPartID() uint64
func (*MultiModifySplitRequest) GetRevision ¶
func (m *MultiModifySplitRequest) GetRevision() int64
func (*MultiModifySplitRequest) GetRowStreamSealedLength ¶
func (m *MultiModifySplitRequest) GetRowStreamSealedLength() uint32
func (*MultiModifySplitRequest) Marshal ¶
func (m *MultiModifySplitRequest) Marshal() (dAtA []byte, err error)
func (*MultiModifySplitRequest) MarshalTo ¶
func (m *MultiModifySplitRequest) MarshalTo(dAtA []byte) (int, error)
func (*MultiModifySplitRequest) MarshalToSizedBuffer ¶
func (m *MultiModifySplitRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MultiModifySplitRequest) ProtoMessage ¶
func (*MultiModifySplitRequest) ProtoMessage()
func (*MultiModifySplitRequest) Reset ¶
func (m *MultiModifySplitRequest) Reset()
func (*MultiModifySplitRequest) Size ¶
func (m *MultiModifySplitRequest) Size() (n int)
func (*MultiModifySplitRequest) String ¶
func (m *MultiModifySplitRequest) String() string
func (*MultiModifySplitRequest) Unmarshal ¶
func (m *MultiModifySplitRequest) Unmarshal(dAtA []byte) error
func (*MultiModifySplitRequest) XXX_DiscardUnknown ¶
func (m *MultiModifySplitRequest) XXX_DiscardUnknown()
func (*MultiModifySplitRequest) XXX_Marshal ¶
func (m *MultiModifySplitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MultiModifySplitRequest) XXX_Merge ¶
func (m *MultiModifySplitRequest) XXX_Merge(src proto.Message)
func (*MultiModifySplitRequest) XXX_Size ¶
func (m *MultiModifySplitRequest) XXX_Size() int
func (*MultiModifySplitRequest) XXX_Unmarshal ¶
func (m *MultiModifySplitRequest) XXX_Unmarshal(b []byte) error
type MultiModifySplitResponse ¶
type MultiModifySplitResponse struct { Code Code `protobuf:"varint,1,opt,name=code,proto3,enum=pb.Code" json:"code,omitempty"` CodeDes string `protobuf:"bytes,2,opt,name=codeDes,proto3" json:"codeDes,omitempty"` }
func (*MultiModifySplitResponse) Descriptor ¶
func (*MultiModifySplitResponse) Descriptor() ([]byte, []int)
func (*MultiModifySplitResponse) GetCode ¶
func (m *MultiModifySplitResponse) GetCode() Code
func (*MultiModifySplitResponse) GetCodeDes ¶
func (m *MultiModifySplitResponse) GetCodeDes() string
func (*MultiModifySplitResponse) Marshal ¶
func (m *MultiModifySplitResponse) Marshal() (dAtA []byte, err error)
func (*MultiModifySplitResponse) MarshalTo ¶
func (m *MultiModifySplitResponse) MarshalTo(dAtA []byte) (int, error)
func (*MultiModifySplitResponse) MarshalToSizedBuffer ¶
func (m *MultiModifySplitResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MultiModifySplitResponse) ProtoMessage ¶
func (*MultiModifySplitResponse) ProtoMessage()
func (*MultiModifySplitResponse) Reset ¶
func (m *MultiModifySplitResponse) Reset()
func (*MultiModifySplitResponse) Size ¶
func (m *MultiModifySplitResponse) Size() (n int)
func (*MultiModifySplitResponse) String ¶
func (m *MultiModifySplitResponse) String() string
func (*MultiModifySplitResponse) Unmarshal ¶
func (m *MultiModifySplitResponse) Unmarshal(dAtA []byte) error
func (*MultiModifySplitResponse) XXX_DiscardUnknown ¶
func (m *MultiModifySplitResponse) XXX_DiscardUnknown()
func (*MultiModifySplitResponse) XXX_Marshal ¶
func (m *MultiModifySplitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MultiModifySplitResponse) XXX_Merge ¶
func (m *MultiModifySplitResponse) XXX_Merge(src proto.Message)
func (*MultiModifySplitResponse) XXX_Size ¶
func (m *MultiModifySplitResponse) XXX_Size() int
func (*MultiModifySplitResponse) XXX_Unmarshal ¶
func (m *MultiModifySplitResponse) XXX_Unmarshal(b []byte) error
type NodeInfo ¶
type NodeInfo struct { NodeID uint64 `protobuf:"varint,1,opt,name=nodeID,proto3" json:"nodeID,omitempty"` Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"` Disks []uint64 `protobuf:"varint,3,rep,packed,name=disks,proto3" json:"disks,omitempty"` }
func (*NodeInfo) Descriptor ¶
func (*NodeInfo) GetAddress ¶
func (*NodeInfo) MarshalToSizedBuffer ¶
func (*NodeInfo) ProtoMessage ¶
func (*NodeInfo) ProtoMessage()
func (*NodeInfo) XXX_DiscardUnknown ¶
func (m *NodeInfo) XXX_DiscardUnknown()
func (*NodeInfo) XXX_Marshal ¶
func (*NodeInfo) XXX_Unmarshal ¶
type NodesInfoRequest ¶
type NodesInfoRequest struct { }
func (*NodesInfoRequest) Descriptor ¶
func (*NodesInfoRequest) Descriptor() ([]byte, []int)
func (*NodesInfoRequest) Marshal ¶
func (m *NodesInfoRequest) Marshal() (dAtA []byte, err error)
func (*NodesInfoRequest) MarshalToSizedBuffer ¶
func (m *NodesInfoRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*NodesInfoRequest) ProtoMessage ¶
func (*NodesInfoRequest) ProtoMessage()
func (*NodesInfoRequest) Reset ¶
func (m *NodesInfoRequest) Reset()
func (*NodesInfoRequest) Size ¶
func (m *NodesInfoRequest) Size() (n int)
func (*NodesInfoRequest) String ¶
func (m *NodesInfoRequest) String() string
func (*NodesInfoRequest) Unmarshal ¶
func (m *NodesInfoRequest) Unmarshal(dAtA []byte) error
func (*NodesInfoRequest) XXX_DiscardUnknown ¶
func (m *NodesInfoRequest) XXX_DiscardUnknown()
func (*NodesInfoRequest) XXX_Marshal ¶
func (m *NodesInfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*NodesInfoRequest) XXX_Merge ¶
func (m *NodesInfoRequest) XXX_Merge(src proto.Message)
func (*NodesInfoRequest) XXX_Size ¶
func (m *NodesInfoRequest) XXX_Size() int
func (*NodesInfoRequest) XXX_Unmarshal ¶
func (m *NodesInfoRequest) XXX_Unmarshal(b []byte) error
type NodesInfoResponse ¶
type NodesInfoResponse struct { Code Code `protobuf:"varint,1,opt,name=code,proto3,enum=pb.Code" json:"code,omitempty"` CodeDes string `protobuf:"bytes,2,opt,name=codeDes,proto3" json:"codeDes,omitempty"` Nodes map[uint64]*NodeInfo `` /* 152-byte string literal not displayed */ }
func (*NodesInfoResponse) Descriptor ¶
func (*NodesInfoResponse) Descriptor() ([]byte, []int)
func (*NodesInfoResponse) GetCode ¶
func (m *NodesInfoResponse) GetCode() Code
func (*NodesInfoResponse) GetCodeDes ¶
func (m *NodesInfoResponse) GetCodeDes() string
func (*NodesInfoResponse) GetNodes ¶
func (m *NodesInfoResponse) GetNodes() map[uint64]*NodeInfo
func (*NodesInfoResponse) Marshal ¶
func (m *NodesInfoResponse) Marshal() (dAtA []byte, err error)
func (*NodesInfoResponse) MarshalTo ¶
func (m *NodesInfoResponse) MarshalTo(dAtA []byte) (int, error)
func (*NodesInfoResponse) MarshalToSizedBuffer ¶
func (m *NodesInfoResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*NodesInfoResponse) ProtoMessage ¶
func (*NodesInfoResponse) ProtoMessage()
func (*NodesInfoResponse) Reset ¶
func (m *NodesInfoResponse) Reset()
func (*NodesInfoResponse) Size ¶
func (m *NodesInfoResponse) Size() (n int)
func (*NodesInfoResponse) String ¶
func (m *NodesInfoResponse) String() string
func (*NodesInfoResponse) Unmarshal ¶
func (m *NodesInfoResponse) Unmarshal(dAtA []byte) error
func (*NodesInfoResponse) XXX_DiscardUnknown ¶
func (m *NodesInfoResponse) XXX_DiscardUnknown()
func (*NodesInfoResponse) XXX_Marshal ¶
func (m *NodesInfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*NodesInfoResponse) XXX_Merge ¶
func (m *NodesInfoResponse) XXX_Merge(src proto.Message)
func (*NodesInfoResponse) XXX_Size ¶
func (m *NodesInfoResponse) XXX_Size() int
func (*NodesInfoResponse) XXX_Unmarshal ¶
func (m *NodesInfoResponse) XXX_Unmarshal(b []byte) error
type Payload ¶
type Payload struct {
Data []byte `protobuf:"bytes,1,opt,name=Data,proto3" json:"Data,omitempty"`
}
func (*Payload) Descriptor ¶
func (*Payload) MarshalToSizedBuffer ¶
func (*Payload) ProtoMessage ¶
func (*Payload) ProtoMessage()
func (*Payload) XXX_DiscardUnknown ¶
func (m *Payload) XXX_DiscardUnknown()
func (*Payload) XXX_Marshal ¶
func (*Payload) XXX_Unmarshal ¶
type PunchHolesRequest ¶
type PunchHolesRequest struct { StreamID uint64 `protobuf:"varint,1,opt,name=streamID,proto3" json:"streamID,omitempty"` ExtentIDs []uint64 `protobuf:"varint,2,rep,packed,name=extentIDs,proto3" json:"extentIDs,omitempty"` OwnerKey string `protobuf:"bytes,4,opt,name=ownerKey,proto3" json:"ownerKey,omitempty"` Revision int64 `protobuf:"varint,5,opt,name=revision,proto3" json:"revision,omitempty"` }
func (*PunchHolesRequest) Descriptor ¶
func (*PunchHolesRequest) Descriptor() ([]byte, []int)
func (*PunchHolesRequest) GetExtentIDs ¶
func (m *PunchHolesRequest) GetExtentIDs() []uint64
func (*PunchHolesRequest) GetOwnerKey ¶
func (m *PunchHolesRequest) GetOwnerKey() string
func (*PunchHolesRequest) GetRevision ¶
func (m *PunchHolesRequest) GetRevision() int64
func (*PunchHolesRequest) GetStreamID ¶
func (m *PunchHolesRequest) GetStreamID() uint64
func (*PunchHolesRequest) Marshal ¶
func (m *PunchHolesRequest) Marshal() (dAtA []byte, err error)
func (*PunchHolesRequest) MarshalTo ¶
func (m *PunchHolesRequest) MarshalTo(dAtA []byte) (int, error)
func (*PunchHolesRequest) MarshalToSizedBuffer ¶
func (m *PunchHolesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PunchHolesRequest) ProtoMessage ¶
func (*PunchHolesRequest) ProtoMessage()
func (*PunchHolesRequest) Reset ¶
func (m *PunchHolesRequest) Reset()
func (*PunchHolesRequest) Size ¶
func (m *PunchHolesRequest) Size() (n int)
func (*PunchHolesRequest) String ¶
func (m *PunchHolesRequest) String() string
func (*PunchHolesRequest) Unmarshal ¶
func (m *PunchHolesRequest) Unmarshal(dAtA []byte) error
func (*PunchHolesRequest) XXX_DiscardUnknown ¶
func (m *PunchHolesRequest) XXX_DiscardUnknown()
func (*PunchHolesRequest) XXX_Marshal ¶
func (m *PunchHolesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PunchHolesRequest) XXX_Merge ¶
func (m *PunchHolesRequest) XXX_Merge(src proto.Message)
func (*PunchHolesRequest) XXX_Size ¶
func (m *PunchHolesRequest) XXX_Size() int
func (*PunchHolesRequest) XXX_Unmarshal ¶
func (m *PunchHolesRequest) XXX_Unmarshal(b []byte) error
type PunchHolesResponse ¶
type PunchHolesResponse struct { Code Code `protobuf:"varint,1,opt,name=code,proto3,enum=pb.Code" json:"code,omitempty"` CodeDes string `protobuf:"bytes,2,opt,name=codeDes,proto3" json:"codeDes,omitempty"` Stream *StreamInfo `protobuf:"bytes,3,opt,name=stream,proto3" json:"stream,omitempty"` }
func (*PunchHolesResponse) Descriptor ¶
func (*PunchHolesResponse) Descriptor() ([]byte, []int)
func (*PunchHolesResponse) GetCode ¶
func (m *PunchHolesResponse) GetCode() Code
func (*PunchHolesResponse) GetCodeDes ¶
func (m *PunchHolesResponse) GetCodeDes() string
func (*PunchHolesResponse) GetStream ¶
func (m *PunchHolesResponse) GetStream() *StreamInfo
func (*PunchHolesResponse) Marshal ¶
func (m *PunchHolesResponse) Marshal() (dAtA []byte, err error)
func (*PunchHolesResponse) MarshalTo ¶
func (m *PunchHolesResponse) MarshalTo(dAtA []byte) (int, error)
func (*PunchHolesResponse) MarshalToSizedBuffer ¶
func (m *PunchHolesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PunchHolesResponse) ProtoMessage ¶
func (*PunchHolesResponse) ProtoMessage()
func (*PunchHolesResponse) Reset ¶
func (m *PunchHolesResponse) Reset()
func (*PunchHolesResponse) Size ¶
func (m *PunchHolesResponse) Size() (n int)
func (*PunchHolesResponse) String ¶
func (m *PunchHolesResponse) String() string
func (*PunchHolesResponse) Unmarshal ¶
func (m *PunchHolesResponse) Unmarshal(dAtA []byte) error
func (*PunchHolesResponse) XXX_DiscardUnknown ¶
func (m *PunchHolesResponse) XXX_DiscardUnknown()
func (*PunchHolesResponse) XXX_Marshal ¶
func (m *PunchHolesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PunchHolesResponse) XXX_Merge ¶
func (m *PunchHolesResponse) XXX_Merge(src proto.Message)
func (*PunchHolesResponse) XXX_Size ¶
func (m *PunchHolesResponse) XXX_Size() int
func (*PunchHolesResponse) XXX_Unmarshal ¶
func (m *PunchHolesResponse) XXX_Unmarshal(b []byte) error
type ReAvaliRequest ¶
type ReAvaliRequest struct { ExtentID uint64 `protobuf:"varint,1,opt,name=extentID,proto3" json:"extentID,omitempty"` Eversion uint64 `protobuf:"varint,2,opt,name=eversion,proto3" json:"eversion,omitempty"` }
func (*ReAvaliRequest) Descriptor ¶
func (*ReAvaliRequest) Descriptor() ([]byte, []int)
func (*ReAvaliRequest) GetEversion ¶
func (m *ReAvaliRequest) GetEversion() uint64
func (*ReAvaliRequest) GetExtentID ¶
func (m *ReAvaliRequest) GetExtentID() uint64
func (*ReAvaliRequest) Marshal ¶
func (m *ReAvaliRequest) Marshal() (dAtA []byte, err error)
func (*ReAvaliRequest) MarshalToSizedBuffer ¶
func (m *ReAvaliRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ReAvaliRequest) ProtoMessage ¶
func (*ReAvaliRequest) ProtoMessage()
func (*ReAvaliRequest) Reset ¶
func (m *ReAvaliRequest) Reset()
func (*ReAvaliRequest) Size ¶
func (m *ReAvaliRequest) Size() (n int)
func (*ReAvaliRequest) String ¶
func (m *ReAvaliRequest) String() string
func (*ReAvaliRequest) Unmarshal ¶
func (m *ReAvaliRequest) Unmarshal(dAtA []byte) error
func (*ReAvaliRequest) XXX_DiscardUnknown ¶
func (m *ReAvaliRequest) XXX_DiscardUnknown()
func (*ReAvaliRequest) XXX_Marshal ¶
func (m *ReAvaliRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ReAvaliRequest) XXX_Merge ¶
func (m *ReAvaliRequest) XXX_Merge(src proto.Message)
func (*ReAvaliRequest) XXX_Size ¶
func (m *ReAvaliRequest) XXX_Size() int
func (*ReAvaliRequest) XXX_Unmarshal ¶
func (m *ReAvaliRequest) XXX_Unmarshal(b []byte) error
type ReAvaliResponse ¶
type ReAvaliResponse struct { Code Code `protobuf:"varint,1,opt,name=code,proto3,enum=pb.Code" json:"code,omitempty"` CodeDes string `protobuf:"bytes,2,opt,name=codeDes,proto3" json:"codeDes,omitempty"` }
func (*ReAvaliResponse) Descriptor ¶
func (*ReAvaliResponse) Descriptor() ([]byte, []int)
func (*ReAvaliResponse) GetCode ¶
func (m *ReAvaliResponse) GetCode() Code
func (*ReAvaliResponse) GetCodeDes ¶
func (m *ReAvaliResponse) GetCodeDes() string
func (*ReAvaliResponse) Marshal ¶
func (m *ReAvaliResponse) Marshal() (dAtA []byte, err error)
func (*ReAvaliResponse) MarshalToSizedBuffer ¶
func (m *ReAvaliResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ReAvaliResponse) ProtoMessage ¶
func (*ReAvaliResponse) ProtoMessage()
func (*ReAvaliResponse) Reset ¶
func (m *ReAvaliResponse) Reset()
func (*ReAvaliResponse) Size ¶
func (m *ReAvaliResponse) Size() (n int)
func (*ReAvaliResponse) String ¶
func (m *ReAvaliResponse) String() string
func (*ReAvaliResponse) Unmarshal ¶
func (m *ReAvaliResponse) Unmarshal(dAtA []byte) error
func (*ReAvaliResponse) XXX_DiscardUnknown ¶
func (m *ReAvaliResponse) XXX_DiscardUnknown()
func (*ReAvaliResponse) XXX_Marshal ¶
func (m *ReAvaliResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ReAvaliResponse) XXX_Merge ¶
func (m *ReAvaliResponse) XXX_Merge(src proto.Message)
func (*ReAvaliResponse) XXX_Size ¶
func (m *ReAvaliResponse) XXX_Size() int
func (*ReAvaliResponse) XXX_Unmarshal ¶
func (m *ReAvaliResponse) XXX_Unmarshal(b []byte) error
type ReadBlockResponseHeader ¶
type ReadBlockResponseHeader struct { Code Code `protobuf:"varint,1,opt,name=code,proto3,enum=pb.Code" json:"code,omitempty"` CodeDes string `protobuf:"bytes,2,opt,name=codeDes,proto3" json:"codeDes,omitempty"` Offsets []uint32 `protobuf:"varint,3,rep,packed,name=offsets,proto3" json:"offsets,omitempty"` End uint32 `protobuf:"varint,4,opt,name=end,proto3" json:"end,omitempty"` BlockSizes []uint32 `protobuf:"varint,5,rep,packed,name=blockSizes,proto3" json:"blockSizes,omitempty"` }
func (*ReadBlockResponseHeader) Descriptor ¶
func (*ReadBlockResponseHeader) Descriptor() ([]byte, []int)
func (*ReadBlockResponseHeader) GetBlockSizes ¶
func (m *ReadBlockResponseHeader) GetBlockSizes() []uint32
func (*ReadBlockResponseHeader) GetCode ¶
func (m *ReadBlockResponseHeader) GetCode() Code
func (*ReadBlockResponseHeader) GetCodeDes ¶
func (m *ReadBlockResponseHeader) GetCodeDes() string
func (*ReadBlockResponseHeader) GetEnd ¶
func (m *ReadBlockResponseHeader) GetEnd() uint32
func (*ReadBlockResponseHeader) GetOffsets ¶
func (m *ReadBlockResponseHeader) GetOffsets() []uint32
func (*ReadBlockResponseHeader) Marshal ¶
func (m *ReadBlockResponseHeader) Marshal() (dAtA []byte, err error)
func (*ReadBlockResponseHeader) MarshalTo ¶
func (m *ReadBlockResponseHeader) MarshalTo(dAtA []byte) (int, error)
func (*ReadBlockResponseHeader) MarshalToSizedBuffer ¶
func (m *ReadBlockResponseHeader) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ReadBlockResponseHeader) ProtoMessage ¶
func (*ReadBlockResponseHeader) ProtoMessage()
func (*ReadBlockResponseHeader) Reset ¶
func (m *ReadBlockResponseHeader) Reset()
func (*ReadBlockResponseHeader) Size ¶
func (m *ReadBlockResponseHeader) Size() (n int)
func (*ReadBlockResponseHeader) String ¶
func (m *ReadBlockResponseHeader) String() string
func (*ReadBlockResponseHeader) Unmarshal ¶
func (m *ReadBlockResponseHeader) Unmarshal(dAtA []byte) error
func (*ReadBlockResponseHeader) XXX_DiscardUnknown ¶
func (m *ReadBlockResponseHeader) XXX_DiscardUnknown()
func (*ReadBlockResponseHeader) XXX_Marshal ¶
func (m *ReadBlockResponseHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ReadBlockResponseHeader) XXX_Merge ¶
func (m *ReadBlockResponseHeader) XXX_Merge(src proto.Message)
func (*ReadBlockResponseHeader) XXX_Size ¶
func (m *ReadBlockResponseHeader) XXX_Size() int
func (*ReadBlockResponseHeader) XXX_Unmarshal ¶
func (m *ReadBlockResponseHeader) XXX_Unmarshal(b []byte) error
type ReadBlocksRequest ¶
type ReadBlocksRequest struct { ExtentID uint64 `protobuf:"varint,1,opt,name=extentID,proto3" json:"extentID,omitempty"` Offset uint32 `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"` NumOfBlocks uint32 `protobuf:"varint,3,opt,name=numOfBlocks,proto3" json:"numOfBlocks,omitempty"` Eversion uint64 `protobuf:"varint,4,opt,name=eversion,proto3" json:"eversion,omitempty"` OnlyLastBlock bool `protobuf:"varint,5,opt,name=onlyLastBlock,proto3" json:"onlyLastBlock,omitempty"` }
func (*ReadBlocksRequest) Descriptor ¶
func (*ReadBlocksRequest) Descriptor() ([]byte, []int)
func (*ReadBlocksRequest) GetEversion ¶
func (m *ReadBlocksRequest) GetEversion() uint64
func (*ReadBlocksRequest) GetExtentID ¶
func (m *ReadBlocksRequest) GetExtentID() uint64
func (*ReadBlocksRequest) GetNumOfBlocks ¶
func (m *ReadBlocksRequest) GetNumOfBlocks() uint32
func (*ReadBlocksRequest) GetOffset ¶
func (m *ReadBlocksRequest) GetOffset() uint32
func (*ReadBlocksRequest) GetOnlyLastBlock ¶
func (m *ReadBlocksRequest) GetOnlyLastBlock() bool
func (*ReadBlocksRequest) Marshal ¶
func (m *ReadBlocksRequest) Marshal() (dAtA []byte, err error)
func (*ReadBlocksRequest) MarshalTo ¶
func (m *ReadBlocksRequest) MarshalTo(dAtA []byte) (int, error)
func (*ReadBlocksRequest) MarshalToSizedBuffer ¶
func (m *ReadBlocksRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ReadBlocksRequest) ProtoMessage ¶
func (*ReadBlocksRequest) ProtoMessage()
func (*ReadBlocksRequest) Reset ¶
func (m *ReadBlocksRequest) Reset()
func (*ReadBlocksRequest) Size ¶
func (m *ReadBlocksRequest) Size() (n int)
func (*ReadBlocksRequest) String ¶
func (m *ReadBlocksRequest) String() string
func (*ReadBlocksRequest) Unmarshal ¶
func (m *ReadBlocksRequest) Unmarshal(dAtA []byte) error
func (*ReadBlocksRequest) XXX_DiscardUnknown ¶
func (m *ReadBlocksRequest) XXX_DiscardUnknown()
func (*ReadBlocksRequest) XXX_Marshal ¶
func (m *ReadBlocksRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ReadBlocksRequest) XXX_Merge ¶
func (m *ReadBlocksRequest) XXX_Merge(src proto.Message)
func (*ReadBlocksRequest) XXX_Size ¶
func (m *ReadBlocksRequest) XXX_Size() int
func (*ReadBlocksRequest) XXX_Unmarshal ¶
func (m *ReadBlocksRequest) XXX_Unmarshal(b []byte) error
type ReadBlocksResponse ¶
type ReadBlocksResponse struct { // Types that are valid to be assigned to Data: // *ReadBlocksResponse_Header // *ReadBlocksResponse_Payload Data isReadBlocksResponse_Data `protobuf_oneof:"data"` }
func (*ReadBlocksResponse) Descriptor ¶
func (*ReadBlocksResponse) Descriptor() ([]byte, []int)
func (*ReadBlocksResponse) GetData ¶
func (m *ReadBlocksResponse) GetData() isReadBlocksResponse_Data
func (*ReadBlocksResponse) GetHeader ¶
func (m *ReadBlocksResponse) GetHeader() *ReadBlockResponseHeader
func (*ReadBlocksResponse) GetPayload ¶
func (m *ReadBlocksResponse) GetPayload() []byte
func (*ReadBlocksResponse) Marshal ¶
func (m *ReadBlocksResponse) Marshal() (dAtA []byte, err error)
func (*ReadBlocksResponse) MarshalTo ¶
func (m *ReadBlocksResponse) MarshalTo(dAtA []byte) (int, error)
func (*ReadBlocksResponse) MarshalToSizedBuffer ¶
func (m *ReadBlocksResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ReadBlocksResponse) ProtoMessage ¶
func (*ReadBlocksResponse) ProtoMessage()
func (*ReadBlocksResponse) Reset ¶
func (m *ReadBlocksResponse) Reset()
func (*ReadBlocksResponse) Size ¶
func (m *ReadBlocksResponse) Size() (n int)
func (*ReadBlocksResponse) String ¶
func (m *ReadBlocksResponse) String() string
func (*ReadBlocksResponse) Unmarshal ¶
func (m *ReadBlocksResponse) Unmarshal(dAtA []byte) error
func (*ReadBlocksResponse) XXX_DiscardUnknown ¶
func (m *ReadBlocksResponse) XXX_DiscardUnknown()
func (*ReadBlocksResponse) XXX_Marshal ¶
func (m *ReadBlocksResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ReadBlocksResponse) XXX_Merge ¶
func (m *ReadBlocksResponse) XXX_Merge(src proto.Message)
func (*ReadBlocksResponse) XXX_OneofWrappers ¶
func (*ReadBlocksResponse) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*ReadBlocksResponse) XXX_Size ¶
func (m *ReadBlocksResponse) XXX_Size() int
func (*ReadBlocksResponse) XXX_Unmarshal ¶
func (m *ReadBlocksResponse) XXX_Unmarshal(b []byte) error
type ReadBlocksResponse_Header ¶
type ReadBlocksResponse_Header struct {
Header *ReadBlockResponseHeader `protobuf:"bytes,1,opt,name=header,proto3,oneof" json:"header,omitempty"`
}
func (*ReadBlocksResponse_Header) MarshalTo ¶
func (m *ReadBlocksResponse_Header) MarshalTo(dAtA []byte) (int, error)
func (*ReadBlocksResponse_Header) MarshalToSizedBuffer ¶
func (m *ReadBlocksResponse_Header) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ReadBlocksResponse_Header) Size ¶
func (m *ReadBlocksResponse_Header) Size() (n int)
type ReadBlocksResponse_Payload ¶
type ReadBlocksResponse_Payload struct {
Payload []byte `protobuf:"bytes,2,opt,name=payload,proto3,oneof" json:"payload,omitempty"`
}
func (*ReadBlocksResponse_Payload) MarshalTo ¶
func (m *ReadBlocksResponse_Payload) MarshalTo(dAtA []byte) (int, error)
func (*ReadBlocksResponse_Payload) MarshalToSizedBuffer ¶
func (m *ReadBlocksResponse_Payload) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ReadBlocksResponse_Payload) Size ¶
func (m *ReadBlocksResponse_Payload) Size() (n int)
type RecoveryTask ¶
type RecoveryTask struct { ExtentID uint64 `protobuf:"varint,1,opt,name=extentID,proto3" json:"extentID,omitempty"` ReplaceID uint64 `protobuf:"varint,2,opt,name=replaceID,proto3" json:"replaceID,omitempty"` NodeID uint64 `protobuf:"varint,3,opt,name=nodeID,proto3" json:"nodeID,omitempty"` StartTime int64 `protobuf:"varint,4,opt,name=startTime,proto3" json:"startTime,omitempty"` }
func (*RecoveryTask) Descriptor ¶
func (*RecoveryTask) Descriptor() ([]byte, []int)
func (*RecoveryTask) GetExtentID ¶
func (m *RecoveryTask) GetExtentID() uint64
func (*RecoveryTask) GetNodeID ¶
func (m *RecoveryTask) GetNodeID() uint64
func (*RecoveryTask) GetReplaceID ¶
func (m *RecoveryTask) GetReplaceID() uint64
func (*RecoveryTask) GetStartTime ¶
func (m *RecoveryTask) GetStartTime() int64
func (*RecoveryTask) Marshal ¶
func (m *RecoveryTask) Marshal() (dAtA []byte, err error)
func (*RecoveryTask) MarshalToSizedBuffer ¶
func (m *RecoveryTask) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*RecoveryTask) ProtoMessage ¶
func (*RecoveryTask) ProtoMessage()
func (*RecoveryTask) Reset ¶
func (m *RecoveryTask) Reset()
func (*RecoveryTask) Size ¶
func (m *RecoveryTask) Size() (n int)
func (*RecoveryTask) String ¶
func (m *RecoveryTask) String() string
func (*RecoveryTask) Unmarshal ¶
func (m *RecoveryTask) Unmarshal(dAtA []byte) error
func (*RecoveryTask) XXX_DiscardUnknown ¶
func (m *RecoveryTask) XXX_DiscardUnknown()
func (*RecoveryTask) XXX_Marshal ¶
func (m *RecoveryTask) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RecoveryTask) XXX_Merge ¶
func (m *RecoveryTask) XXX_Merge(src proto.Message)
func (*RecoveryTask) XXX_Size ¶
func (m *RecoveryTask) XXX_Size() int
func (*RecoveryTask) XXX_Unmarshal ¶
func (m *RecoveryTask) XXX_Unmarshal(b []byte) error
type RecoveryTaskStatus ¶
type RecoveryTaskStatus struct { Task *RecoveryTask `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"` ReadyDiskID uint64 `protobuf:"varint,2,opt,name=readyDiskID,proto3" json:"readyDiskID,omitempty"` }
func (*RecoveryTaskStatus) Descriptor ¶
func (*RecoveryTaskStatus) Descriptor() ([]byte, []int)
func (*RecoveryTaskStatus) GetReadyDiskID ¶
func (m *RecoveryTaskStatus) GetReadyDiskID() uint64
func (*RecoveryTaskStatus) GetTask ¶
func (m *RecoveryTaskStatus) GetTask() *RecoveryTask
func (*RecoveryTaskStatus) Marshal ¶
func (m *RecoveryTaskStatus) Marshal() (dAtA []byte, err error)
func (*RecoveryTaskStatus) MarshalTo ¶
func (m *RecoveryTaskStatus) MarshalTo(dAtA []byte) (int, error)
func (*RecoveryTaskStatus) MarshalToSizedBuffer ¶
func (m *RecoveryTaskStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*RecoveryTaskStatus) ProtoMessage ¶
func (*RecoveryTaskStatus) ProtoMessage()
func (*RecoveryTaskStatus) Reset ¶
func (m *RecoveryTaskStatus) Reset()
func (*RecoveryTaskStatus) Size ¶
func (m *RecoveryTaskStatus) Size() (n int)
func (*RecoveryTaskStatus) String ¶
func (m *RecoveryTaskStatus) String() string
func (*RecoveryTaskStatus) Unmarshal ¶
func (m *RecoveryTaskStatus) Unmarshal(dAtA []byte) error
func (*RecoveryTaskStatus) XXX_DiscardUnknown ¶
func (m *RecoveryTaskStatus) XXX_DiscardUnknown()
func (*RecoveryTaskStatus) XXX_Marshal ¶
func (m *RecoveryTaskStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RecoveryTaskStatus) XXX_Merge ¶
func (m *RecoveryTaskStatus) XXX_Merge(src proto.Message)
func (*RecoveryTaskStatus) XXX_Size ¶
func (m *RecoveryTaskStatus) XXX_Size() int
func (*RecoveryTaskStatus) XXX_Unmarshal ¶
func (m *RecoveryTaskStatus) XXX_Unmarshal(b []byte) error
type RegisterNodeRequest ¶
type RegisterNodeRequest struct { Addr string `protobuf:"bytes,1,opt,name=addr,proto3" json:"addr,omitempty"` DiskUUIDs []string `protobuf:"bytes,2,rep,name=diskUUIDs,proto3" json:"diskUUIDs,omitempty"` }
func (*RegisterNodeRequest) Descriptor ¶
func (*RegisterNodeRequest) Descriptor() ([]byte, []int)
func (*RegisterNodeRequest) GetAddr ¶
func (m *RegisterNodeRequest) GetAddr() string
func (*RegisterNodeRequest) GetDiskUUIDs ¶
func (m *RegisterNodeRequest) GetDiskUUIDs() []string
func (*RegisterNodeRequest) Marshal ¶
func (m *RegisterNodeRequest) Marshal() (dAtA []byte, err error)
func (*RegisterNodeRequest) MarshalTo ¶
func (m *RegisterNodeRequest) MarshalTo(dAtA []byte) (int, error)
func (*RegisterNodeRequest) MarshalToSizedBuffer ¶
func (m *RegisterNodeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*RegisterNodeRequest) ProtoMessage ¶
func (*RegisterNodeRequest) ProtoMessage()
func (*RegisterNodeRequest) Reset ¶
func (m *RegisterNodeRequest) Reset()
func (*RegisterNodeRequest) Size ¶
func (m *RegisterNodeRequest) Size() (n int)
func (*RegisterNodeRequest) String ¶
func (m *RegisterNodeRequest) String() string
func (*RegisterNodeRequest) Unmarshal ¶
func (m *RegisterNodeRequest) Unmarshal(dAtA []byte) error
func (*RegisterNodeRequest) XXX_DiscardUnknown ¶
func (m *RegisterNodeRequest) XXX_DiscardUnknown()
func (*RegisterNodeRequest) XXX_Marshal ¶
func (m *RegisterNodeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RegisterNodeRequest) XXX_Merge ¶
func (m *RegisterNodeRequest) XXX_Merge(src proto.Message)
func (*RegisterNodeRequest) XXX_Size ¶
func (m *RegisterNodeRequest) XXX_Size() int
func (*RegisterNodeRequest) XXX_Unmarshal ¶
func (m *RegisterNodeRequest) XXX_Unmarshal(b []byte) error
type RegisterNodeResponse ¶
type RegisterNodeResponse struct { Code Code `protobuf:"varint,1,opt,name=code,proto3,enum=pb.Code" json:"code,omitempty"` CodeDes string `protobuf:"bytes,2,opt,name=codeDes,proto3" json:"codeDes,omitempty"` NodeId uint64 `protobuf:"varint,3,opt,name=nodeId,proto3" json:"nodeId,omitempty"` DiskUUIDs map[string]uint64 `` /* 160-byte string literal not displayed */ }
func (*RegisterNodeResponse) Descriptor ¶
func (*RegisterNodeResponse) Descriptor() ([]byte, []int)
func (*RegisterNodeResponse) GetCode ¶
func (m *RegisterNodeResponse) GetCode() Code
func (*RegisterNodeResponse) GetCodeDes ¶
func (m *RegisterNodeResponse) GetCodeDes() string
func (*RegisterNodeResponse) GetDiskUUIDs ¶
func (m *RegisterNodeResponse) GetDiskUUIDs() map[string]uint64
func (*RegisterNodeResponse) GetNodeId ¶
func (m *RegisterNodeResponse) GetNodeId() uint64
func (*RegisterNodeResponse) Marshal ¶
func (m *RegisterNodeResponse) Marshal() (dAtA []byte, err error)
func (*RegisterNodeResponse) MarshalTo ¶
func (m *RegisterNodeResponse) MarshalTo(dAtA []byte) (int, error)
func (*RegisterNodeResponse) MarshalToSizedBuffer ¶
func (m *RegisterNodeResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*RegisterNodeResponse) ProtoMessage ¶
func (*RegisterNodeResponse) ProtoMessage()
func (*RegisterNodeResponse) Reset ¶
func (m *RegisterNodeResponse) Reset()
func (*RegisterNodeResponse) Size ¶
func (m *RegisterNodeResponse) Size() (n int)
func (*RegisterNodeResponse) String ¶
func (m *RegisterNodeResponse) String() string
func (*RegisterNodeResponse) Unmarshal ¶
func (m *RegisterNodeResponse) Unmarshal(dAtA []byte) error
func (*RegisterNodeResponse) XXX_DiscardUnknown ¶
func (m *RegisterNodeResponse) XXX_DiscardUnknown()
func (*RegisterNodeResponse) XXX_Marshal ¶
func (m *RegisterNodeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RegisterNodeResponse) XXX_Merge ¶
func (m *RegisterNodeResponse) XXX_Merge(src proto.Message)
func (*RegisterNodeResponse) XXX_Size ¶
func (m *RegisterNodeResponse) XXX_Size() int
func (*RegisterNodeResponse) XXX_Unmarshal ¶
func (m *RegisterNodeResponse) XXX_Unmarshal(b []byte) error
type RequireRecoveryRequest ¶
type RequireRecoveryRequest struct {
Task *RecoveryTask `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
}
func (*RequireRecoveryRequest) Descriptor ¶
func (*RequireRecoveryRequest) Descriptor() ([]byte, []int)
func (*RequireRecoveryRequest) GetTask ¶
func (m *RequireRecoveryRequest) GetTask() *RecoveryTask
func (*RequireRecoveryRequest) Marshal ¶
func (m *RequireRecoveryRequest) Marshal() (dAtA []byte, err error)
func (*RequireRecoveryRequest) MarshalTo ¶
func (m *RequireRecoveryRequest) MarshalTo(dAtA []byte) (int, error)
func (*RequireRecoveryRequest) MarshalToSizedBuffer ¶
func (m *RequireRecoveryRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*RequireRecoveryRequest) ProtoMessage ¶
func (*RequireRecoveryRequest) ProtoMessage()
func (*RequireRecoveryRequest) Reset ¶
func (m *RequireRecoveryRequest) Reset()
func (*RequireRecoveryRequest) Size ¶
func (m *RequireRecoveryRequest) Size() (n int)
func (*RequireRecoveryRequest) String ¶
func (m *RequireRecoveryRequest) String() string
func (*RequireRecoveryRequest) Unmarshal ¶
func (m *RequireRecoveryRequest) Unmarshal(dAtA []byte) error
func (*RequireRecoveryRequest) XXX_DiscardUnknown ¶
func (m *RequireRecoveryRequest) XXX_DiscardUnknown()
func (*RequireRecoveryRequest) XXX_Marshal ¶
func (m *RequireRecoveryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RequireRecoveryRequest) XXX_Merge ¶
func (m *RequireRecoveryRequest) XXX_Merge(src proto.Message)
func (*RequireRecoveryRequest) XXX_Size ¶
func (m *RequireRecoveryRequest) XXX_Size() int
func (*RequireRecoveryRequest) XXX_Unmarshal ¶
func (m *RequireRecoveryRequest) XXX_Unmarshal(b []byte) error
type RequireRecoveryResponse ¶
type RequireRecoveryResponse struct { Code Code `protobuf:"varint,1,opt,name=code,proto3,enum=pb.Code" json:"code,omitempty"` CodeDes string `protobuf:"bytes,2,opt,name=codeDes,proto3" json:"codeDes,omitempty"` }
func (*RequireRecoveryResponse) Descriptor ¶
func (*RequireRecoveryResponse) Descriptor() ([]byte, []int)
func (*RequireRecoveryResponse) GetCode ¶
func (m *RequireRecoveryResponse) GetCode() Code
func (*RequireRecoveryResponse) GetCodeDes ¶
func (m *RequireRecoveryResponse) GetCodeDes() string
func (*RequireRecoveryResponse) Marshal ¶
func (m *RequireRecoveryResponse) Marshal() (dAtA []byte, err error)
func (*RequireRecoveryResponse) MarshalTo ¶
func (m *RequireRecoveryResponse) MarshalTo(dAtA []byte) (int, error)
func (*RequireRecoveryResponse) MarshalToSizedBuffer ¶
func (m *RequireRecoveryResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*RequireRecoveryResponse) ProtoMessage ¶
func (*RequireRecoveryResponse) ProtoMessage()
func (*RequireRecoveryResponse) Reset ¶
func (m *RequireRecoveryResponse) Reset()
func (*RequireRecoveryResponse) Size ¶
func (m *RequireRecoveryResponse) Size() (n int)
func (*RequireRecoveryResponse) String ¶
func (m *RequireRecoveryResponse) String() string
func (*RequireRecoveryResponse) Unmarshal ¶
func (m *RequireRecoveryResponse) Unmarshal(dAtA []byte) error
func (*RequireRecoveryResponse) XXX_DiscardUnknown ¶
func (m *RequireRecoveryResponse) XXX_DiscardUnknown()
func (*RequireRecoveryResponse) XXX_Marshal ¶
func (m *RequireRecoveryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RequireRecoveryResponse) XXX_Merge ¶
func (m *RequireRecoveryResponse) XXX_Merge(src proto.Message)
func (*RequireRecoveryResponse) XXX_Size ¶
func (m *RequireRecoveryResponse) XXX_Size() int
func (*RequireRecoveryResponse) XXX_Unmarshal ¶
func (m *RequireRecoveryResponse) XXX_Unmarshal(b []byte) error
type StatusRequest ¶
type StatusRequest struct { }
func (*StatusRequest) Descriptor ¶
func (*StatusRequest) Descriptor() ([]byte, []int)
func (*StatusRequest) Marshal ¶
func (m *StatusRequest) Marshal() (dAtA []byte, err error)
func (*StatusRequest) MarshalToSizedBuffer ¶
func (m *StatusRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*StatusRequest) ProtoMessage ¶
func (*StatusRequest) ProtoMessage()
func (*StatusRequest) Reset ¶
func (m *StatusRequest) Reset()
func (*StatusRequest) Size ¶
func (m *StatusRequest) Size() (n int)
func (*StatusRequest) String ¶
func (m *StatusRequest) String() string
func (*StatusRequest) Unmarshal ¶
func (m *StatusRequest) Unmarshal(dAtA []byte) error
func (*StatusRequest) XXX_DiscardUnknown ¶
func (m *StatusRequest) XXX_DiscardUnknown()
func (*StatusRequest) XXX_Marshal ¶
func (m *StatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StatusRequest) XXX_Merge ¶
func (m *StatusRequest) XXX_Merge(src proto.Message)
func (*StatusRequest) XXX_Size ¶
func (m *StatusRequest) XXX_Size() int
func (*StatusRequest) XXX_Unmarshal ¶
func (m *StatusRequest) XXX_Unmarshal(b []byte) error
type StatusResponse ¶
type StatusResponse struct { Code Code `protobuf:"varint,1,opt,name=code,proto3,enum=pb.Code" json:"code,omitempty"` CodeDes string `protobuf:"bytes,2,opt,name=codeDes,proto3" json:"codeDes,omitempty"` }
func (*StatusResponse) Descriptor ¶
func (*StatusResponse) Descriptor() ([]byte, []int)
func (*StatusResponse) GetCode ¶
func (m *StatusResponse) GetCode() Code
func (*StatusResponse) GetCodeDes ¶
func (m *StatusResponse) GetCodeDes() string
func (*StatusResponse) Marshal ¶
func (m *StatusResponse) Marshal() (dAtA []byte, err error)
func (*StatusResponse) MarshalToSizedBuffer ¶
func (m *StatusResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*StatusResponse) ProtoMessage ¶
func (*StatusResponse) ProtoMessage()
func (*StatusResponse) Reset ¶
func (m *StatusResponse) Reset()
func (*StatusResponse) Size ¶
func (m *StatusResponse) Size() (n int)
func (*StatusResponse) String ¶
func (m *StatusResponse) String() string
func (*StatusResponse) Unmarshal ¶
func (m *StatusResponse) Unmarshal(dAtA []byte) error
func (*StatusResponse) XXX_DiscardUnknown ¶
func (m *StatusResponse) XXX_DiscardUnknown()
func (*StatusResponse) XXX_Marshal ¶
func (m *StatusResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StatusResponse) XXX_Merge ¶
func (m *StatusResponse) XXX_Merge(src proto.Message)
func (*StatusResponse) XXX_Size ¶
func (m *StatusResponse) XXX_Size() int
func (*StatusResponse) XXX_Unmarshal ¶
func (m *StatusResponse) XXX_Unmarshal(b []byte) error
type StreamAllocExtentRequest ¶
type StreamAllocExtentRequest struct { StreamID uint64 `protobuf:"varint,1,opt,name=streamID,proto3" json:"streamID,omitempty"` OwnerKey string `protobuf:"bytes,2,opt,name=ownerKey,proto3" json:"ownerKey,omitempty"` Revision int64 `protobuf:"varint,3,opt,name=revision,proto3" json:"revision,omitempty"` End uint32 `protobuf:"varint,4,opt,name=end,proto3" json:"end,omitempty"` }
func (*StreamAllocExtentRequest) Descriptor ¶
func (*StreamAllocExtentRequest) Descriptor() ([]byte, []int)
func (*StreamAllocExtentRequest) GetEnd ¶
func (m *StreamAllocExtentRequest) GetEnd() uint32
func (*StreamAllocExtentRequest) GetOwnerKey ¶
func (m *StreamAllocExtentRequest) GetOwnerKey() string
func (*StreamAllocExtentRequest) GetRevision ¶
func (m *StreamAllocExtentRequest) GetRevision() int64
func (*StreamAllocExtentRequest) GetStreamID ¶
func (m *StreamAllocExtentRequest) GetStreamID() uint64
func (*StreamAllocExtentRequest) Marshal ¶
func (m *StreamAllocExtentRequest) Marshal() (dAtA []byte, err error)
func (*StreamAllocExtentRequest) MarshalTo ¶
func (m *StreamAllocExtentRequest) MarshalTo(dAtA []byte) (int, error)
func (*StreamAllocExtentRequest) MarshalToSizedBuffer ¶
func (m *StreamAllocExtentRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*StreamAllocExtentRequest) ProtoMessage ¶
func (*StreamAllocExtentRequest) ProtoMessage()
func (*StreamAllocExtentRequest) Reset ¶
func (m *StreamAllocExtentRequest) Reset()
func (*StreamAllocExtentRequest) Size ¶
func (m *StreamAllocExtentRequest) Size() (n int)
func (*StreamAllocExtentRequest) String ¶
func (m *StreamAllocExtentRequest) String() string
func (*StreamAllocExtentRequest) Unmarshal ¶
func (m *StreamAllocExtentRequest) Unmarshal(dAtA []byte) error
func (*StreamAllocExtentRequest) XXX_DiscardUnknown ¶
func (m *StreamAllocExtentRequest) XXX_DiscardUnknown()
func (*StreamAllocExtentRequest) XXX_Marshal ¶
func (m *StreamAllocExtentRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StreamAllocExtentRequest) XXX_Merge ¶
func (m *StreamAllocExtentRequest) XXX_Merge(src proto.Message)
func (*StreamAllocExtentRequest) XXX_Size ¶
func (m *StreamAllocExtentRequest) XXX_Size() int
func (*StreamAllocExtentRequest) XXX_Unmarshal ¶
func (m *StreamAllocExtentRequest) XXX_Unmarshal(b []byte) error
type StreamAllocExtentResponse ¶
type StreamAllocExtentResponse struct { Code Code `protobuf:"varint,1,opt,name=code,proto3,enum=pb.Code" json:"code,omitempty"` CodeDes string `protobuf:"bytes,2,opt,name=codeDes,proto3" json:"codeDes,omitempty"` StreamInfo *StreamInfo `protobuf:"bytes,3,opt,name=streamInfo,proto3" json:"streamInfo,omitempty"` LastExInfo *ExtentInfo `protobuf:"bytes,4,opt,name=lastExInfo,proto3" json:"lastExInfo,omitempty"` }
func (*StreamAllocExtentResponse) Descriptor ¶
func (*StreamAllocExtentResponse) Descriptor() ([]byte, []int)
func (*StreamAllocExtentResponse) GetCode ¶
func (m *StreamAllocExtentResponse) GetCode() Code
func (*StreamAllocExtentResponse) GetCodeDes ¶
func (m *StreamAllocExtentResponse) GetCodeDes() string
func (*StreamAllocExtentResponse) GetLastExInfo ¶
func (m *StreamAllocExtentResponse) GetLastExInfo() *ExtentInfo
func (*StreamAllocExtentResponse) GetStreamInfo ¶
func (m *StreamAllocExtentResponse) GetStreamInfo() *StreamInfo
func (*StreamAllocExtentResponse) Marshal ¶
func (m *StreamAllocExtentResponse) Marshal() (dAtA []byte, err error)
func (*StreamAllocExtentResponse) MarshalTo ¶
func (m *StreamAllocExtentResponse) MarshalTo(dAtA []byte) (int, error)
func (*StreamAllocExtentResponse) MarshalToSizedBuffer ¶
func (m *StreamAllocExtentResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*StreamAllocExtentResponse) ProtoMessage ¶
func (*StreamAllocExtentResponse) ProtoMessage()
func (*StreamAllocExtentResponse) Reset ¶
func (m *StreamAllocExtentResponse) Reset()
func (*StreamAllocExtentResponse) Size ¶
func (m *StreamAllocExtentResponse) Size() (n int)
func (*StreamAllocExtentResponse) String ¶
func (m *StreamAllocExtentResponse) String() string
func (*StreamAllocExtentResponse) Unmarshal ¶
func (m *StreamAllocExtentResponse) Unmarshal(dAtA []byte) error
func (*StreamAllocExtentResponse) XXX_DiscardUnknown ¶
func (m *StreamAllocExtentResponse) XXX_DiscardUnknown()
func (*StreamAllocExtentResponse) XXX_Marshal ¶
func (m *StreamAllocExtentResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StreamAllocExtentResponse) XXX_Merge ¶
func (m *StreamAllocExtentResponse) XXX_Merge(src proto.Message)
func (*StreamAllocExtentResponse) XXX_Size ¶
func (m *StreamAllocExtentResponse) XXX_Size() int
func (*StreamAllocExtentResponse) XXX_Unmarshal ¶
func (m *StreamAllocExtentResponse) XXX_Unmarshal(b []byte) error
type StreamInfo ¶
type StreamInfo struct { StreamID uint64 `protobuf:"varint,1,opt,name=streamID,proto3" json:"streamID,omitempty"` ExtentIDs []uint64 `protobuf:"varint,2,rep,packed,name=extentIDs,proto3" json:"extentIDs,omitempty"` }
func (*StreamInfo) Descriptor ¶
func (*StreamInfo) Descriptor() ([]byte, []int)
func (*StreamInfo) GetExtentIDs ¶
func (m *StreamInfo) GetExtentIDs() []uint64
func (*StreamInfo) GetStreamID ¶
func (m *StreamInfo) GetStreamID() uint64
func (*StreamInfo) Marshal ¶
func (m *StreamInfo) Marshal() (dAtA []byte, err error)
func (*StreamInfo) MarshalToSizedBuffer ¶
func (m *StreamInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*StreamInfo) ProtoMessage ¶
func (*StreamInfo) ProtoMessage()
func (*StreamInfo) Reset ¶
func (m *StreamInfo) Reset()
func (*StreamInfo) Size ¶
func (m *StreamInfo) Size() (n int)
func (*StreamInfo) String ¶
func (m *StreamInfo) String() string
func (*StreamInfo) Unmarshal ¶
func (m *StreamInfo) Unmarshal(dAtA []byte) error
func (*StreamInfo) XXX_DiscardUnknown ¶
func (m *StreamInfo) XXX_DiscardUnknown()
func (*StreamInfo) XXX_Marshal ¶
func (m *StreamInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StreamInfo) XXX_Merge ¶
func (m *StreamInfo) XXX_Merge(src proto.Message)
func (*StreamInfo) XXX_Size ¶
func (m *StreamInfo) XXX_Size() int
func (*StreamInfo) XXX_Unmarshal ¶
func (m *StreamInfo) XXX_Unmarshal(b []byte) error
type StreamInfoRequest ¶
type StreamInfoRequest struct {
StreamIDs []uint64 `protobuf:"varint,1,rep,packed,name=streamIDs,proto3" json:"streamIDs,omitempty"`
}
func (*StreamInfoRequest) Descriptor ¶
func (*StreamInfoRequest) Descriptor() ([]byte, []int)
func (*StreamInfoRequest) GetStreamIDs ¶
func (m *StreamInfoRequest) GetStreamIDs() []uint64
func (*StreamInfoRequest) Marshal ¶
func (m *StreamInfoRequest) Marshal() (dAtA []byte, err error)
func (*StreamInfoRequest) MarshalTo ¶
func (m *StreamInfoRequest) MarshalTo(dAtA []byte) (int, error)
func (*StreamInfoRequest) MarshalToSizedBuffer ¶
func (m *StreamInfoRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*StreamInfoRequest) ProtoMessage ¶
func (*StreamInfoRequest) ProtoMessage()
func (*StreamInfoRequest) Reset ¶
func (m *StreamInfoRequest) Reset()
func (*StreamInfoRequest) Size ¶
func (m *StreamInfoRequest) Size() (n int)
func (*StreamInfoRequest) String ¶
func (m *StreamInfoRequest) String() string
func (*StreamInfoRequest) Unmarshal ¶
func (m *StreamInfoRequest) Unmarshal(dAtA []byte) error
func (*StreamInfoRequest) XXX_DiscardUnknown ¶
func (m *StreamInfoRequest) XXX_DiscardUnknown()
func (*StreamInfoRequest) XXX_Marshal ¶
func (m *StreamInfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StreamInfoRequest) XXX_Merge ¶
func (m *StreamInfoRequest) XXX_Merge(src proto.Message)
func (*StreamInfoRequest) XXX_Size ¶
func (m *StreamInfoRequest) XXX_Size() int
func (*StreamInfoRequest) XXX_Unmarshal ¶
func (m *StreamInfoRequest) XXX_Unmarshal(b []byte) error
type StreamInfoResponse ¶
type StreamInfoResponse struct { Code Code `protobuf:"varint,1,opt,name=code,proto3,enum=pb.Code" json:"code,omitempty"` CodeDes string `protobuf:"bytes,2,opt,name=codeDes,proto3" json:"codeDes,omitempty"` Streams map[uint64]*StreamInfo `` /* 156-byte string literal not displayed */ Extents map[uint64]*ExtentInfo `` /* 156-byte string literal not displayed */ }
func (*StreamInfoResponse) Descriptor ¶
func (*StreamInfoResponse) Descriptor() ([]byte, []int)
func (*StreamInfoResponse) GetCode ¶
func (m *StreamInfoResponse) GetCode() Code
func (*StreamInfoResponse) GetCodeDes ¶
func (m *StreamInfoResponse) GetCodeDes() string
func (*StreamInfoResponse) GetExtents ¶
func (m *StreamInfoResponse) GetExtents() map[uint64]*ExtentInfo
func (*StreamInfoResponse) GetStreams ¶
func (m *StreamInfoResponse) GetStreams() map[uint64]*StreamInfo
func (*StreamInfoResponse) Marshal ¶
func (m *StreamInfoResponse) Marshal() (dAtA []byte, err error)
func (*StreamInfoResponse) MarshalTo ¶
func (m *StreamInfoResponse) MarshalTo(dAtA []byte) (int, error)
func (*StreamInfoResponse) MarshalToSizedBuffer ¶
func (m *StreamInfoResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*StreamInfoResponse) ProtoMessage ¶
func (*StreamInfoResponse) ProtoMessage()
func (*StreamInfoResponse) Reset ¶
func (m *StreamInfoResponse) Reset()
func (*StreamInfoResponse) Size ¶
func (m *StreamInfoResponse) Size() (n int)
func (*StreamInfoResponse) String ¶
func (m *StreamInfoResponse) String() string
func (*StreamInfoResponse) Unmarshal ¶
func (m *StreamInfoResponse) Unmarshal(dAtA []byte) error
func (*StreamInfoResponse) XXX_DiscardUnknown ¶
func (m *StreamInfoResponse) XXX_DiscardUnknown()
func (*StreamInfoResponse) XXX_Marshal ¶
func (m *StreamInfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StreamInfoResponse) XXX_Merge ¶
func (m *StreamInfoResponse) XXX_Merge(src proto.Message)
func (*StreamInfoResponse) XXX_Size ¶
func (m *StreamInfoResponse) XXX_Size() int
func (*StreamInfoResponse) XXX_Unmarshal ¶
func (m *StreamInfoResponse) XXX_Unmarshal(b []byte) error
type StreamManagerServiceClient ¶
type StreamManagerServiceClient interface { StreamInfo(ctx context.Context, in *StreamInfoRequest, opts ...grpc.CallOption) (*StreamInfoResponse, error) ExtentInfo(ctx context.Context, in *ExtentInfoRequest, opts ...grpc.CallOption) (*ExtentInfoResponse, error) NodesInfo(ctx context.Context, in *NodesInfoRequest, opts ...grpc.CallOption) (*NodesInfoResponse, error) Status(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*StatusResponse, error) CheckCommitLength(ctx context.Context, in *CheckCommitLengthRequest, opts ...grpc.CallOption) (*CheckCommitLengthResponse, error) StreamAllocExtent(ctx context.Context, in *StreamAllocExtentRequest, opts ...grpc.CallOption) (*StreamAllocExtentResponse, error) StreamPunchHoles(ctx context.Context, in *PunchHolesRequest, opts ...grpc.CallOption) (*PunchHolesResponse, error) CreateStream(ctx context.Context, in *CreateStreamRequest, opts ...grpc.CallOption) (*CreateStreamResponse, error) RegisterNode(ctx context.Context, in *RegisterNodeRequest, opts ...grpc.CallOption) (*RegisterNodeResponse, error) Truncate(ctx context.Context, in *TruncateRequest, opts ...grpc.CallOption) (*TruncateResponse, error) MultiModifySplit(ctx context.Context, in *MultiModifySplitRequest, opts ...grpc.CallOption) (*MultiModifySplitResponse, error) }
StreamManagerServiceClient is the client API for StreamManagerService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewStreamManagerServiceClient ¶
func NewStreamManagerServiceClient(cc *grpc.ClientConn) StreamManagerServiceClient
type StreamManagerServiceServer ¶
type StreamManagerServiceServer interface { StreamInfo(context.Context, *StreamInfoRequest) (*StreamInfoResponse, error) ExtentInfo(context.Context, *ExtentInfoRequest) (*ExtentInfoResponse, error) NodesInfo(context.Context, *NodesInfoRequest) (*NodesInfoResponse, error) Status(context.Context, *StatusRequest) (*StatusResponse, error) CheckCommitLength(context.Context, *CheckCommitLengthRequest) (*CheckCommitLengthResponse, error) StreamAllocExtent(context.Context, *StreamAllocExtentRequest) (*StreamAllocExtentResponse, error) StreamPunchHoles(context.Context, *PunchHolesRequest) (*PunchHolesResponse, error) CreateStream(context.Context, *CreateStreamRequest) (*CreateStreamResponse, error) RegisterNode(context.Context, *RegisterNodeRequest) (*RegisterNodeResponse, error) Truncate(context.Context, *TruncateRequest) (*TruncateResponse, error) MultiModifySplit(context.Context, *MultiModifySplitRequest) (*MultiModifySplitResponse, error) }
StreamManagerServiceServer is the server API for StreamManagerService service.
type TruncateRequest ¶
type TruncateRequest struct { StreamID uint64 `protobuf:"varint,1,opt,name=streamID,proto3" json:"streamID,omitempty"` ExtentID uint64 `protobuf:"varint,2,opt,name=extentID,proto3" json:"extentID,omitempty"` OwnerKey string `protobuf:"bytes,3,opt,name=ownerKey,proto3" json:"ownerKey,omitempty"` Revision int64 `protobuf:"varint,4,opt,name=revision,proto3" json:"revision,omitempty"` }
func (*TruncateRequest) Descriptor ¶
func (*TruncateRequest) Descriptor() ([]byte, []int)
func (*TruncateRequest) GetExtentID ¶
func (m *TruncateRequest) GetExtentID() uint64
func (*TruncateRequest) GetOwnerKey ¶
func (m *TruncateRequest) GetOwnerKey() string
func (*TruncateRequest) GetRevision ¶
func (m *TruncateRequest) GetRevision() int64
func (*TruncateRequest) GetStreamID ¶
func (m *TruncateRequest) GetStreamID() uint64
func (*TruncateRequest) Marshal ¶
func (m *TruncateRequest) Marshal() (dAtA []byte, err error)
func (*TruncateRequest) MarshalToSizedBuffer ¶
func (m *TruncateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*TruncateRequest) ProtoMessage ¶
func (*TruncateRequest) ProtoMessage()
func (*TruncateRequest) Reset ¶
func (m *TruncateRequest) Reset()
func (*TruncateRequest) Size ¶
func (m *TruncateRequest) Size() (n int)
func (*TruncateRequest) String ¶
func (m *TruncateRequest) String() string
func (*TruncateRequest) Unmarshal ¶
func (m *TruncateRequest) Unmarshal(dAtA []byte) error
func (*TruncateRequest) XXX_DiscardUnknown ¶
func (m *TruncateRequest) XXX_DiscardUnknown()
func (*TruncateRequest) XXX_Marshal ¶
func (m *TruncateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TruncateRequest) XXX_Merge ¶
func (m *TruncateRequest) XXX_Merge(src proto.Message)
func (*TruncateRequest) XXX_Size ¶
func (m *TruncateRequest) XXX_Size() int
func (*TruncateRequest) XXX_Unmarshal ¶
func (m *TruncateRequest) XXX_Unmarshal(b []byte) error
type TruncateResponse ¶
type TruncateResponse struct { Code Code `protobuf:"varint,1,opt,name=code,proto3,enum=pb.Code" json:"code,omitempty"` CodeDes string `protobuf:"bytes,2,opt,name=codeDes,proto3" json:"codeDes,omitempty"` UpdatedStreamInfo *StreamInfo `protobuf:"bytes,3,opt,name=updatedStreamInfo,proto3" json:"updatedStreamInfo,omitempty"` }
func (*TruncateResponse) Descriptor ¶
func (*TruncateResponse) Descriptor() ([]byte, []int)
func (*TruncateResponse) GetCode ¶
func (m *TruncateResponse) GetCode() Code
func (*TruncateResponse) GetCodeDes ¶
func (m *TruncateResponse) GetCodeDes() string
func (*TruncateResponse) GetUpdatedStreamInfo ¶
func (m *TruncateResponse) GetUpdatedStreamInfo() *StreamInfo
func (*TruncateResponse) Marshal ¶
func (m *TruncateResponse) Marshal() (dAtA []byte, err error)
func (*TruncateResponse) MarshalToSizedBuffer ¶
func (m *TruncateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*TruncateResponse) ProtoMessage ¶
func (*TruncateResponse) ProtoMessage()
func (*TruncateResponse) Reset ¶
func (m *TruncateResponse) Reset()
func (*TruncateResponse) Size ¶
func (m *TruncateResponse) Size() (n int)
func (*TruncateResponse) String ¶
func (m *TruncateResponse) String() string
func (*TruncateResponse) Unmarshal ¶
func (m *TruncateResponse) Unmarshal(dAtA []byte) error
func (*TruncateResponse) XXX_DiscardUnknown ¶
func (m *TruncateResponse) XXX_DiscardUnknown()
func (*TruncateResponse) XXX_Marshal ¶
func (m *TruncateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TruncateResponse) XXX_Merge ¶
func (m *TruncateResponse) XXX_Merge(src proto.Message)
func (*TruncateResponse) XXX_Size ¶
func (m *TruncateResponse) XXX_Size() int
func (*TruncateResponse) XXX_Unmarshal ¶
func (m *TruncateResponse) XXX_Unmarshal(b []byte) error
type UnimplementedExtentServiceServer ¶
type UnimplementedExtentServiceServer struct { }
UnimplementedExtentServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedExtentServiceServer) AllocExtent ¶
func (*UnimplementedExtentServiceServer) AllocExtent(ctx context.Context, req *AllocExtentRequest) (*AllocExtentResponse, error)
func (*UnimplementedExtentServiceServer) Append ¶
func (*UnimplementedExtentServiceServer) Append(srv ExtentService_AppendServer) error
func (*UnimplementedExtentServiceServer) CommitLength ¶
func (*UnimplementedExtentServiceServer) CommitLength(ctx context.Context, req *CommitLengthRequest) (*CommitLengthResponse, error)
func (*UnimplementedExtentServiceServer) CopyExtent ¶
func (*UnimplementedExtentServiceServer) CopyExtent(req *CopyExtentRequest, srv ExtentService_CopyExtentServer) error
func (*UnimplementedExtentServiceServer) Df ¶
func (*UnimplementedExtentServiceServer) Df(ctx context.Context, req *DfRequest) (*DfResponse, error)
func (*UnimplementedExtentServiceServer) Heartbeat ¶
func (*UnimplementedExtentServiceServer) Heartbeat(req *Payload, srv ExtentService_HeartbeatServer) error
func (*UnimplementedExtentServiceServer) ReAvali ¶
func (*UnimplementedExtentServiceServer) ReAvali(ctx context.Context, req *ReAvaliRequest) (*ReAvaliResponse, error)
func (*UnimplementedExtentServiceServer) ReadBlocks ¶
func (*UnimplementedExtentServiceServer) ReadBlocks(req *ReadBlocksRequest, srv ExtentService_ReadBlocksServer) error
func (*UnimplementedExtentServiceServer) RequireRecovery ¶
func (*UnimplementedExtentServiceServer) RequireRecovery(ctx context.Context, req *RequireRecoveryRequest) (*RequireRecoveryResponse, error)
type UnimplementedStreamManagerServiceServer ¶
type UnimplementedStreamManagerServiceServer struct { }
UnimplementedStreamManagerServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedStreamManagerServiceServer) CheckCommitLength ¶
func (*UnimplementedStreamManagerServiceServer) CheckCommitLength(ctx context.Context, req *CheckCommitLengthRequest) (*CheckCommitLengthResponse, error)
func (*UnimplementedStreamManagerServiceServer) CreateStream ¶
func (*UnimplementedStreamManagerServiceServer) CreateStream(ctx context.Context, req *CreateStreamRequest) (*CreateStreamResponse, error)
func (*UnimplementedStreamManagerServiceServer) ExtentInfo ¶
func (*UnimplementedStreamManagerServiceServer) ExtentInfo(ctx context.Context, req *ExtentInfoRequest) (*ExtentInfoResponse, error)
func (*UnimplementedStreamManagerServiceServer) MultiModifySplit ¶
func (*UnimplementedStreamManagerServiceServer) MultiModifySplit(ctx context.Context, req *MultiModifySplitRequest) (*MultiModifySplitResponse, error)
func (*UnimplementedStreamManagerServiceServer) NodesInfo ¶
func (*UnimplementedStreamManagerServiceServer) NodesInfo(ctx context.Context, req *NodesInfoRequest) (*NodesInfoResponse, error)
func (*UnimplementedStreamManagerServiceServer) RegisterNode ¶
func (*UnimplementedStreamManagerServiceServer) RegisterNode(ctx context.Context, req *RegisterNodeRequest) (*RegisterNodeResponse, error)
func (*UnimplementedStreamManagerServiceServer) Status ¶
func (*UnimplementedStreamManagerServiceServer) Status(ctx context.Context, req *StatusRequest) (*StatusResponse, error)
func (*UnimplementedStreamManagerServiceServer) StreamAllocExtent ¶
func (*UnimplementedStreamManagerServiceServer) StreamAllocExtent(ctx context.Context, req *StreamAllocExtentRequest) (*StreamAllocExtentResponse, error)
func (*UnimplementedStreamManagerServiceServer) StreamInfo ¶
func (*UnimplementedStreamManagerServiceServer) StreamInfo(ctx context.Context, req *StreamInfoRequest) (*StreamInfoResponse, error)
func (*UnimplementedStreamManagerServiceServer) StreamPunchHoles ¶
func (*UnimplementedStreamManagerServiceServer) StreamPunchHoles(ctx context.Context, req *PunchHolesRequest) (*PunchHolesResponse, error)
func (*UnimplementedStreamManagerServiceServer) Truncate ¶
func (*UnimplementedStreamManagerServiceServer) Truncate(ctx context.Context, req *TruncateRequest) (*TruncateResponse, error)