pb

package
v0.0.0-...-6aa601a Latest Latest
Warning

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

 Go to latest Published: Aug 30, 2021 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthPb        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPb          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupPb = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var Code_name = map[int32]string{
	0: "OK",
	1: "ERROR",
	2: "EndOfExtent",
	4: "EVersionLow",
	5: "NotLEADER",
	6: "LockedByOther",
	7: "ClientStreamVersionTooHigh",
	8: "NotFound",
}
View Source 
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 {
	ExtentID uint64   `protobuf:"varint,1,opt,name=extentID,proto3" json:"extentID,omitempty"`
	Blocks   []*Block `protobuf:"bytes,2,rep,name=blocks,proto3" json:"blocks,omitempty"`
	Eversion uint64   `protobuf:"varint,3,opt,name=eversion,proto3" json:"eversion,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"`
}

func (*AppendRequest) Descriptor 

func (*AppendRequest) Descriptor() ([]byte, []int)

func (*AppendRequest) GetBlocks 

func (m *AppendRequest) GetBlocks() []*Block

func (*AppendRequest) GetEversion 

func (m *AppendRequest) GetEversion() uint64

func (*AppendRequest) GetExtentID 

func (m *AppendRequest) GetExtentID() uint64

func (*AppendRequest) GetMustSync 

func (m *AppendRequest) GetMustSync() bool

func (*AppendRequest) GetRevision 

func (m *AppendRequest) GetRevision() int64

func (*AppendRequest) Marshal 

func (m *AppendRequest) Marshal() (dAtA []byte, err error)

func (*AppendRequest) MarshalTo 

func (m *AppendRequest) MarshalTo(dAtA []byte) (int, 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_Size 

func (m *AppendRequest) XXX_Size() int

func (*AppendRequest) XXX_Unmarshal 

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

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

func (m *AppendResponse) MarshalTo(dAtA []byte) (int, 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 BlobStreams 

type BlobStreams struct {
	Blobs map[uint64]uint64 `` /* 153-byte string literal not displayed */
}

func (*BlobStreams) Descriptor 

func (*BlobStreams) Descriptor() ([]byte, []int)

func (*BlobStreams) GetBlobs 

func (m *BlobStreams) GetBlobs() map[uint64]uint64

func (*BlobStreams) Marshal 

func (m *BlobStreams) Marshal() (dAtA []byte, err error)

func (*BlobStreams) MarshalTo 

func (m *BlobStreams) MarshalTo(dAtA []byte) (int, error)

func (*BlobStreams) MarshalToSizedBuffer 

func (m *BlobStreams) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*BlobStreams) ProtoMessage 

func (*BlobStreams) ProtoMessage()

func (*BlobStreams) Reset 

func (m *BlobStreams) Reset()

func (*BlobStreams) Size 

func (m *BlobStreams) Size() (n int)

func (*BlobStreams) String 

func (m *BlobStreams) String() string

func (*BlobStreams) Unmarshal 

func (m *BlobStreams) Unmarshal(dAtA []byte) error

func (*BlobStreams) XXX_DiscardUnknown 

func (m *BlobStreams) XXX_DiscardUnknown()

func (*BlobStreams) XXX_Marshal 

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

func (*BlobStreams) XXX_Merge 

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

func (*BlobStreams) XXX_Size 

func (m *BlobStreams) XXX_Size() int

func (*BlobStreams) XXX_Unmarshal 

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

type Block 

type Block struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
}

func (*Block) Descriptor 

func (*Block) Descriptor() ([]byte, []int)

func (*Block) GetData 

func (m *Block) GetData() []byte

func (*Block) Marshal 

func (m *Block) Marshal() (dAtA []byte, err error)

func (*Block) MarshalTo 

func (m *Block) MarshalTo(dAtA []byte) (int, error)

func (*Block) MarshalToSizedBuffer 

func (m *Block) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Block) ProtoMessage 

func (*Block) ProtoMessage()

func (*Block) Reset 

func (m *Block) Reset()

func (*Block) Size 

func (m *Block) Size() (n int)

func (*Block) String 

func (m *Block) String() string

func (*Block) Unmarshal 

func (m *Block) Unmarshal(dAtA []byte) error

func (*Block) XXX_DiscardUnknown 

func (m *Block) XXX_DiscardUnknown()

func (*Block) XXX_Marshal 

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

func (*Block) XXX_Merge 

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

func (*Block) XXX_Size 

func (m *Block) XXX_Size() int

func (*Block) XXX_Unmarshal 

func (m *Block) 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 Code 

type Code int32
const (
	Code_OK                         Code = 0
	Code_ERROR                      Code = 1
	Code_EndOfExtent                Code = 2
	Code_EVersionLow                Code = 4
	Code_NotLEADER                  Code = 5
	Code_LockedByOther              Code = 6
	Code_ClientStreamVersionTooHigh Code = 7
	Code_NotFound                   Code = 8
)

func (Code) EnumDescriptor 

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

func (Code) String 

func (x Code) String() string

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

func (*DF) GetFree 

func (m *DF) GetFree() uint64

func (*DF) GetOnline 

func (m *DF) GetOnline() bool

func (*DF) GetTotal 

func (m *DF) GetTotal() uint64

func (*DF) Marshal 

func (m *DF) Marshal() (dAtA []byte, err error)

func (*DF) MarshalTo 

func (m *DF) MarshalTo(dAtA []byte) (int, error)

func (*DF) MarshalToSizedBuffer 

func (m *DF) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DF) ProtoMessage 

func (*DF) ProtoMessage()

func (*DF) Reset 

func (m *DF) Reset()

func (*DF) Size 

func (m *DF) Size() (n int)

func (*DF) String 

func (m *DF) String() string

func (*DF) Unmarshal 

func (m *DF) Unmarshal(dAtA []byte) error

func (*DF) XXX_DiscardUnknown 

func (m *DF) XXX_DiscardUnknown()

func (*DF) XXX_Marshal 

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

func (*DF) XXX_Merge 

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

func (*DF) XXX_Size 

func (m *DF) XXX_Size() int

func (*DF) XXX_Unmarshal 

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

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

func (*DfRequest) GetDiskIDs 

func (m *DfRequest) GetDiskIDs() []uint64

func (*DfRequest) GetTasks 

func (m *DfRequest) GetTasks() []*RecoveryTask

func (*DfRequest) Marshal 

func (m *DfRequest) Marshal() (dAtA []byte, err error)

func (*DfRequest) MarshalTo 

func (m *DfRequest) MarshalTo(dAtA []byte) (int, error)

func (*DfRequest) MarshalToSizedBuffer 

func (m *DfRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DfRequest) ProtoMessage 

func (*DfRequest) ProtoMessage()

func (*DfRequest) Reset 

func (m *DfRequest) Reset()

func (*DfRequest) Size 

func (m *DfRequest) Size() (n int)

func (*DfRequest) String 

func (m *DfRequest) String() string

func (*DfRequest) Unmarshal 

func (m *DfRequest) Unmarshal(dAtA []byte) error

func (*DfRequest) XXX_DiscardUnknown 

func (m *DfRequest) XXX_DiscardUnknown()

func (*DfRequest) XXX_Marshal 

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

func (*DfRequest) XXX_Merge 

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

func (*DfRequest) XXX_Size 

func (m *DfRequest) XXX_Size() int

func (*DfRequest) XXX_Unmarshal 

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

type DfResponse 

type DfResponse struct {
	DoneTask   []*RecoveryTask `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() []*RecoveryTask

func (*DfResponse) Marshal 

func (m *DfResponse) Marshal() (dAtA []byte, err error)

func (*DfResponse) MarshalTo 

func (m *DfResponse) MarshalTo(dAtA []byte) (int, 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) Descriptor() ([]byte, []int)

func (*DiskInfo) GetDiskID 

func (m *DiskInfo) GetDiskID() uint64

func (*DiskInfo) GetOnline 

func (m *DiskInfo) GetOnline() bool

func (*DiskInfo) GetUuid 

func (m *DiskInfo) GetUuid() string

func (*DiskInfo) Marshal 

func (m *DiskInfo) Marshal() (dAtA []byte, err error)

func (*DiskInfo) MarshalTo 

func (m *DiskInfo) MarshalTo(dAtA []byte) (int, error)

func (*DiskInfo) MarshalToSizedBuffer 

func (m *DiskInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DiskInfo) ProtoMessage 

func (*DiskInfo) ProtoMessage()

func (*DiskInfo) Reset 

func (m *DiskInfo) Reset()

func (*DiskInfo) Size 

func (m *DiskInfo) Size() (n int)

func (*DiskInfo) String 

func (m *DiskInfo) String() string

func (*DiskInfo) Unmarshal 

func (m *DiskInfo) Unmarshal(dAtA []byte) error

func (*DiskInfo) XXX_DiscardUnknown 

func (m *DiskInfo) XXX_DiscardUnknown()

func (*DiskInfo) XXX_Marshal 

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

func (*DiskInfo) XXX_Merge 

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

func (*DiskInfo) XXX_Size 

func (m *DiskInfo) XXX_Size() int

func (*DiskInfo) XXX_Unmarshal 

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

type Entry 

type Entry struct {
	Key       []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value     []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Meta      uint32 `protobuf:"varint,3,opt,name=meta,proto3" json:"meta,omitempty"`
	ExpiresAt uint64 `protobuf:"varint,4,opt,name=ExpiresAt,proto3" json:"ExpiresAt,omitempty"`
}

func (*Entry) Descriptor 

func (*Entry) Descriptor() ([]byte, []int)

func (*Entry) GetExpiresAt 

func (m *Entry) GetExpiresAt() uint64

func (*Entry) GetKey 

func (m *Entry) GetKey() []byte

func (*Entry) GetMeta 

func (m *Entry) GetMeta() uint32

func (*Entry) GetValue 

func (m *Entry) GetValue() []byte

func (*Entry) Marshal 

func (m *Entry) Marshal() (dAtA []byte, err error)

func (*Entry) MarshalTo 

func (m *Entry) MarshalTo(dAtA []byte) (int, error)

func (*Entry) MarshalToSizedBuffer 

func (m *Entry) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Entry) ProtoMessage 

func (*Entry) ProtoMessage()

func (*Entry) Reset 

func (m *Entry) Reset()

func (*Entry) Size 

func (m *Entry) Size() (n int)

func (*Entry) String 

func (m *Entry) String() string

func (*Entry) Unmarshal 

func (m *Entry) Unmarshal(dAtA []byte) error

func (*Entry) XXX_DiscardUnknown 

func (m *Entry) XXX_DiscardUnknown()

func (*Entry) XXX_Marshal 

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

func (*Entry) XXX_Merge 

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

func (*Entry) XXX_Size 

func (m *Entry) XXX_Size() int

func (*Entry) XXX_Unmarshal 

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

type EntryInfo 

type EntryInfo struct {
	Log *Entry `protobuf:"bytes,1,opt,name=log,proto3" json:"log,omitempty"`
	//used when read bigger blocks log.value = nil, log.meta & bitValuePointer > 0
	ExtentID      uint64 `protobuf:"varint,2,opt,name=extentID,proto3" json:"extentID,omitempty"`
	Offset        uint32 `protobuf:"varint,3,opt,name=offset,proto3" json:"offset,omitempty"`
	EstimatedSize uint64 `protobuf:"varint,4,opt,name=estimatedSize,proto3" json:"estimatedSize,omitempty"`
	End           uint32 `protobuf:"varint,5,opt,name=end,proto3" json:"end,omitempty"`
}

func (*EntryInfo) Descriptor 

func (*EntryInfo) Descriptor() ([]byte, []int)

func (*EntryInfo) GetEnd 

func (m *EntryInfo) GetEnd() uint32

func (*EntryInfo) GetEstimatedSize 

func (m *EntryInfo) GetEstimatedSize() uint64

func (*EntryInfo) GetExtentID 

func (m *EntryInfo) GetExtentID() uint64

func (*EntryInfo) GetLog 

func (m *EntryInfo) GetLog() *Entry

func (*EntryInfo) GetOffset 

func (m *EntryInfo) GetOffset() uint32

func (*EntryInfo) Marshal 

func (m *EntryInfo) Marshal() (dAtA []byte, err error)

func (*EntryInfo) MarshalTo 

func (m *EntryInfo) MarshalTo(dAtA []byte) (int, error)

func (*EntryInfo) MarshalToSizedBuffer 

func (m *EntryInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EntryInfo) ProtoMessage 

func (*EntryInfo) ProtoMessage()

func (*EntryInfo) Reset 

func (m *EntryInfo) Reset()

func (*EntryInfo) Size 

func (m *EntryInfo) Size() (n int)

func (*EntryInfo) String 

func (m *EntryInfo) String() string

func (*EntryInfo) Unmarshal 

func (m *EntryInfo) Unmarshal(dAtA []byte) error

func (*EntryInfo) XXX_DiscardUnknown 

func (m *EntryInfo) XXX_DiscardUnknown()

func (*EntryInfo) XXX_Marshal 

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

func (*EntryInfo) XXX_Merge 

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

func (*EntryInfo) XXX_Size 

func (m *EntryInfo) XXX_Size() int

func (*EntryInfo) XXX_Unmarshal 

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

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

func (m *ExtentInfo) MarshalTo(dAtA []byte) (int, 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, in *AppendRequest, opts ...grpc.CallOption) (*AppendResponse, error)
	ReadEntries(ctx context.Context, in *ReadEntriesRequest, opts ...grpc.CallOption) (*ReadEntriesResponse, error)
	SmartReadBlocks(ctx context.Context, in *ReadBlocksRequest, opts ...grpc.CallOption) (*ReadBlocksResponse, 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)
	ReplicateBlocks(ctx context.Context, in *ReplicateBlocksRequest, opts ...grpc.CallOption) (*ReplicateBlocksResponse, error)
	ReadBlocks(ctx context.Context, in *ReadBlocksRequest, opts ...grpc.CallOption) (*ReadBlocksResponse, error)
	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(context.Context, *AppendRequest) (*AppendResponse, error)
	ReadEntries(context.Context, *ReadEntriesRequest) (*ReadEntriesResponse, error)
	SmartReadBlocks(context.Context, *ReadBlocksRequest) (*ReadBlocksResponse, 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
	ReplicateBlocks(context.Context, *ReplicateBlocksRequest) (*ReplicateBlocksResponse, error)
	ReadBlocks(context.Context, *ReadBlocksRequest) (*ReadBlocksResponse, error)
	AllocExtent(context.Context, *AllocExtentRequest) (*AllocExtentResponse, error)
}

ExtentServiceServer is the server API for ExtentService service.

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

func (m *MemberValue) MarshalTo(dAtA []byte) (int, 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"`
}

func (*MultiModifySplitRequest) Descriptor 

func (*MultiModifySplitRequest) Descriptor() ([]byte, []int)

func (*MultiModifySplitRequest) GetLogStreamSealedLength 

func (m *MultiModifySplitRequest) GetLogStreamSealedLength() 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) Descriptor() ([]byte, []int)

func (*NodeInfo) GetAddress 

func (m *NodeInfo) GetAddress() string

func (*NodeInfo) GetDisks 

func (m *NodeInfo) GetDisks() []uint64

func (*NodeInfo) GetNodeID 

func (m *NodeInfo) GetNodeID() uint64

func (*NodeInfo) Marshal 

func (m *NodeInfo) Marshal() (dAtA []byte, err error)

func (*NodeInfo) MarshalTo 

func (m *NodeInfo) MarshalTo(dAtA []byte) (int, error)

func (*NodeInfo) MarshalToSizedBuffer 

func (m *NodeInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*NodeInfo) ProtoMessage 

func (*NodeInfo) ProtoMessage()

func (*NodeInfo) Reset 

func (m *NodeInfo) Reset()

func (*NodeInfo) Size 

func (m *NodeInfo) Size() (n int)

func (*NodeInfo) String 

func (m *NodeInfo) String() string

func (*NodeInfo) Unmarshal 

func (m *NodeInfo) Unmarshal(dAtA []byte) error

func (*NodeInfo) XXX_DiscardUnknown 

func (m *NodeInfo) XXX_DiscardUnknown()

func (*NodeInfo) XXX_Marshal 

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

func (*NodeInfo) XXX_Merge 

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

func (*NodeInfo) XXX_Size 

func (m *NodeInfo) XXX_Size() int

func (*NodeInfo) XXX_Unmarshal 

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

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

func (m *NodesInfoRequest) MarshalTo(dAtA []byte) (int, 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) Descriptor() ([]byte, []int)

func (*Payload) GetData 

func (m *Payload) GetData() []byte

func (*Payload) Marshal 

func (m *Payload) Marshal() (dAtA []byte, err error)

func (*Payload) MarshalTo 

func (m *Payload) MarshalTo(dAtA []byte) (int, error)

func (*Payload) MarshalToSizedBuffer 

func (m *Payload) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Payload) ProtoMessage 

func (*Payload) ProtoMessage()

func (*Payload) Reset 

func (m *Payload) Reset()

func (*Payload) Size 

func (m *Payload) Size() (n int)

func (*Payload) String 

func (m *Payload) String() string

func (*Payload) Unmarshal 

func (m *Payload) Unmarshal(dAtA []byte) error

func (*Payload) XXX_DiscardUnknown 

func (m *Payload) XXX_DiscardUnknown()

func (*Payload) XXX_Marshal 

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

func (*Payload) XXX_Merge 

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

func (*Payload) XXX_Size 

func (m *Payload) XXX_Size() int

func (*Payload) XXX_Unmarshal 

func (m *Payload) 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) MarshalTo 

func (m *ReAvaliRequest) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *ReAvaliResponse) MarshalTo(dAtA []byte) (int, 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 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"`
}

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) 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 {
	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"`
	Blocks  []*Block `protobuf:"bytes,3,rep,name=blocks,proto3" json:"blocks,omitempty"`
	End     uint32   `protobuf:"varint,4,opt,name=end,proto3" json:"end,omitempty"`
	Offsets []uint32 `protobuf:"varint,5,rep,packed,name=offsets,proto3" json:"offsets,omitempty"`
}

func (*ReadBlocksResponse) Descriptor 

func (*ReadBlocksResponse) Descriptor() ([]byte, []int)

func (*ReadBlocksResponse) GetBlocks 

func (m *ReadBlocksResponse) GetBlocks() []*Block

func (*ReadBlocksResponse) GetCode 

func (m *ReadBlocksResponse) GetCode() Code

func (*ReadBlocksResponse) GetCodeDes 

func (m *ReadBlocksResponse) GetCodeDes() string

func (*ReadBlocksResponse) GetEnd 

func (m *ReadBlocksResponse) GetEnd() uint32

func (*ReadBlocksResponse) GetOffsets 

func (m *ReadBlocksResponse) GetOffsets() []uint32

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_Size 

func (m *ReadBlocksResponse) XXX_Size() int

func (*ReadBlocksResponse) XXX_Unmarshal 

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

type ReadEntriesRequest 

type ReadEntriesRequest 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"`
	Replay   uint32 `protobuf:"varint,3,opt,name=replay,proto3" json:"replay,omitempty"`
	Eversion uint64 `protobuf:"varint,4,opt,name=eversion,proto3" json:"eversion,omitempty"`
}

func (*ReadEntriesRequest) Descriptor 

func (*ReadEntriesRequest) Descriptor() ([]byte, []int)

func (*ReadEntriesRequest) GetEversion 

func (m *ReadEntriesRequest) GetEversion() uint64

func (*ReadEntriesRequest) GetExtentID 

func (m *ReadEntriesRequest) GetExtentID() uint64

func (*ReadEntriesRequest) GetOffset 

func (m *ReadEntriesRequest) GetOffset() uint32

func (*ReadEntriesRequest) GetReplay 

func (m *ReadEntriesRequest) GetReplay() uint32

func (*ReadEntriesRequest) Marshal 

func (m *ReadEntriesRequest) Marshal() (dAtA []byte, err error)

func (*ReadEntriesRequest) MarshalTo 

func (m *ReadEntriesRequest) MarshalTo(dAtA []byte) (int, error)

func (*ReadEntriesRequest) MarshalToSizedBuffer 

func (m *ReadEntriesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReadEntriesRequest) ProtoMessage 

func (*ReadEntriesRequest) ProtoMessage()

func (*ReadEntriesRequest) Reset 

func (m *ReadEntriesRequest) Reset()

func (*ReadEntriesRequest) Size 

func (m *ReadEntriesRequest) Size() (n int)

func (*ReadEntriesRequest) String 

func (m *ReadEntriesRequest) String() string

func (*ReadEntriesRequest) Unmarshal 

func (m *ReadEntriesRequest) Unmarshal(dAtA []byte) error

func (*ReadEntriesRequest) XXX_DiscardUnknown 

func (m *ReadEntriesRequest) XXX_DiscardUnknown()

func (*ReadEntriesRequest) XXX_Marshal 

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

func (*ReadEntriesRequest) XXX_Merge 

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

func (*ReadEntriesRequest) XXX_Size 

func (m *ReadEntriesRequest) XXX_Size() int

func (*ReadEntriesRequest) XXX_Unmarshal 

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

type ReadEntriesResponse 

type ReadEntriesResponse 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"`
	Entries []*EntryInfo `protobuf:"bytes,3,rep,name=entries,proto3" json:"entries,omitempty"`
	End     uint32       `protobuf:"varint,4,opt,name=end,proto3" json:"end,omitempty"`
}

func (*ReadEntriesResponse) Descriptor 

func (*ReadEntriesResponse) Descriptor() ([]byte, []int)

func (*ReadEntriesResponse) GetCode 

func (m *ReadEntriesResponse) GetCode() Code

func (*ReadEntriesResponse) GetCodeDes 

func (m *ReadEntriesResponse) GetCodeDes() string

func (*ReadEntriesResponse) GetEnd 

func (m *ReadEntriesResponse) GetEnd() uint32

func (*ReadEntriesResponse) GetEntries 

func (m *ReadEntriesResponse) GetEntries() []*EntryInfo

func (*ReadEntriesResponse) Marshal 

func (m *ReadEntriesResponse) Marshal() (dAtA []byte, err error)

func (*ReadEntriesResponse) MarshalTo 

func (m *ReadEntriesResponse) MarshalTo(dAtA []byte) (int, error)

func (*ReadEntriesResponse) MarshalToSizedBuffer 

func (m *ReadEntriesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReadEntriesResponse) ProtoMessage 

func (*ReadEntriesResponse) ProtoMessage()

func (*ReadEntriesResponse) Reset 

func (m *ReadEntriesResponse) Reset()

func (*ReadEntriesResponse) Size 

func (m *ReadEntriesResponse) Size() (n int)

func (*ReadEntriesResponse) String 

func (m *ReadEntriesResponse) String() string

func (*ReadEntriesResponse) Unmarshal 

func (m *ReadEntriesResponse) Unmarshal(dAtA []byte) error

func (*ReadEntriesResponse) XXX_DiscardUnknown 

func (m *ReadEntriesResponse) XXX_DiscardUnknown()

func (*ReadEntriesResponse) XXX_Marshal 

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

func (*ReadEntriesResponse) XXX_Merge 

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

func (*ReadEntriesResponse) XXX_Size 

func (m *ReadEntriesResponse) XXX_Size() int

func (*ReadEntriesResponse) XXX_Unmarshal 

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

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"`
	ReadyDiskID uint64 `protobuf:"varint,5,opt,name=readyDiskID,proto3" json:"readyDiskID,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) GetReadyDiskID 

func (m *RecoveryTask) GetReadyDiskID() 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) MarshalTo 

func (m *RecoveryTask) MarshalTo(dAtA []byte) (int, 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 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 ReplicateBlocksRequest 

type ReplicateBlocksRequest struct {
	ExtentID uint64   `protobuf:"varint,1,opt,name=extentID,proto3" json:"extentID,omitempty"`
	Commit   uint32   `protobuf:"varint,2,opt,name=commit,proto3" json:"commit,omitempty"`
	Blocks   []*Block `protobuf:"bytes,3,rep,name=blocks,proto3" json:"blocks,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"`
}

func (*ReplicateBlocksRequest) Descriptor 

func (*ReplicateBlocksRequest) Descriptor() ([]byte, []int)

func (*ReplicateBlocksRequest) GetBlocks 

func (m *ReplicateBlocksRequest) GetBlocks() []*Block

func (*ReplicateBlocksRequest) GetCommit 

func (m *ReplicateBlocksRequest) GetCommit() uint32

func (*ReplicateBlocksRequest) GetExtentID 

func (m *ReplicateBlocksRequest) GetExtentID() uint64

func (*ReplicateBlocksRequest) GetMustSync 

func (m *ReplicateBlocksRequest) GetMustSync() bool

func (*ReplicateBlocksRequest) GetRevision 

func (m *ReplicateBlocksRequest) GetRevision() int64

func (*ReplicateBlocksRequest) Marshal 

func (m *ReplicateBlocksRequest) Marshal() (dAtA []byte, err error)

func (*ReplicateBlocksRequest) MarshalTo 

func (m *ReplicateBlocksRequest) MarshalTo(dAtA []byte) (int, error)

func (*ReplicateBlocksRequest) MarshalToSizedBuffer 

func (m *ReplicateBlocksRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReplicateBlocksRequest) ProtoMessage 

func (*ReplicateBlocksRequest) ProtoMessage()

func (*ReplicateBlocksRequest) Reset 

func (m *ReplicateBlocksRequest) Reset()

func (*ReplicateBlocksRequest) Size 

func (m *ReplicateBlocksRequest) Size() (n int)

func (*ReplicateBlocksRequest) String 

func (m *ReplicateBlocksRequest) String() string

func (*ReplicateBlocksRequest) Unmarshal 

func (m *ReplicateBlocksRequest) Unmarshal(dAtA []byte) error

func (*ReplicateBlocksRequest) XXX_DiscardUnknown 

func (m *ReplicateBlocksRequest) XXX_DiscardUnknown()

func (*ReplicateBlocksRequest) XXX_Marshal 

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

func (*ReplicateBlocksRequest) XXX_Merge 

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

func (*ReplicateBlocksRequest) XXX_Size 

func (m *ReplicateBlocksRequest) XXX_Size() int

func (*ReplicateBlocksRequest) XXX_Unmarshal 

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

type ReplicateBlocksResponse 

type ReplicateBlocksResponse 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 (*ReplicateBlocksResponse) Descriptor 

func (*ReplicateBlocksResponse) Descriptor() ([]byte, []int)

func (*ReplicateBlocksResponse) GetCode 

func (m *ReplicateBlocksResponse) GetCode() Code

func (*ReplicateBlocksResponse) GetCodeDes 

func (m *ReplicateBlocksResponse) GetCodeDes() string

func (*ReplicateBlocksResponse) GetEnd 

func (m *ReplicateBlocksResponse) GetEnd() uint32

func (*ReplicateBlocksResponse) GetOffsets 

func (m *ReplicateBlocksResponse) GetOffsets() []uint32

func (*ReplicateBlocksResponse) Marshal 

func (m *ReplicateBlocksResponse) Marshal() (dAtA []byte, err error)

func (*ReplicateBlocksResponse) MarshalTo 

func (m *ReplicateBlocksResponse) MarshalTo(dAtA []byte) (int, error)

func (*ReplicateBlocksResponse) MarshalToSizedBuffer 

func (m *ReplicateBlocksResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReplicateBlocksResponse) ProtoMessage 

func (*ReplicateBlocksResponse) ProtoMessage()

func (*ReplicateBlocksResponse) Reset 

func (m *ReplicateBlocksResponse) Reset()

func (*ReplicateBlocksResponse) Size 

func (m *ReplicateBlocksResponse) Size() (n int)

func (*ReplicateBlocksResponse) String 

func (m *ReplicateBlocksResponse) String() string

func (*ReplicateBlocksResponse) Unmarshal 

func (m *ReplicateBlocksResponse) Unmarshal(dAtA []byte) error

func (*ReplicateBlocksResponse) XXX_DiscardUnknown 

func (m *ReplicateBlocksResponse) XXX_DiscardUnknown()

func (*ReplicateBlocksResponse) XXX_Marshal 

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

func (*ReplicateBlocksResponse) XXX_Merge 

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

func (*ReplicateBlocksResponse) XXX_Size 

func (m *ReplicateBlocksResponse) XXX_Size() int

func (*ReplicateBlocksResponse) XXX_Unmarshal 

func (m *ReplicateBlocksResponse) 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) MarshalTo 

func (m *StatusRequest) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *StatusResponse) MarshalTo(dAtA []byte) (int, 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"`
	Sversion int64  `protobuf:"varint,5,opt,name=sversion,proto3" json:"sversion,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) GetSversion 

func (m *StreamAllocExtentRequest) GetSversion() int64

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"`
	Sversion  uint64   `protobuf:"varint,3,opt,name=sversion,proto3" json:"sversion,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) GetSversion 

func (m *StreamInfo) GetSversion() uint64

func (*StreamInfo) Marshal 

func (m *StreamInfo) Marshal() (dAtA []byte, err error)

func (*StreamInfo) MarshalTo 

func (m *StreamInfo) MarshalTo(dAtA []byte) (int, 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)
	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)
	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"`
	Sversion  int64  `protobuf:"varint,5,opt,name=sversion,proto3" json:"sversion,omitempty"`
	GabageKey string `protobuf:"bytes,6,opt,name=gabageKey,proto3" json:"gabageKey,omitempty"`
}

func (*TruncateRequest) Descriptor 

func (*TruncateRequest) Descriptor() ([]byte, []int)

func (*TruncateRequest) GetExtentID 

func (m *TruncateRequest) GetExtentID() uint64

func (*TruncateRequest) GetGabageKey 

func (m *TruncateRequest) GetGabageKey() string

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

func (m *TruncateRequest) GetSversion() int64

func (*TruncateRequest) Marshal 

func (m *TruncateRequest) Marshal() (dAtA []byte, err error)

func (*TruncateRequest) MarshalTo 

func (m *TruncateRequest) MarshalTo(dAtA []byte) (int, 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"`
	Blobs   *BlobStreams `protobuf:"bytes,3,opt,name=blobs,proto3" json:"blobs,omitempty"`
}

func (*TruncateResponse) Descriptor 

func (*TruncateResponse) Descriptor() ([]byte, []int)

func (*TruncateResponse) GetBlobs 

func (m *TruncateResponse) GetBlobs() *BlobStreams

func (*TruncateResponse) GetCode 

func (m *TruncateResponse) GetCode() Code

func (*TruncateResponse) GetCodeDes 

func (m *TruncateResponse) GetCodeDes() string

func (*TruncateResponse) Marshal 

func (m *TruncateResponse) Marshal() (dAtA []byte, err error)

func (*TruncateResponse) MarshalTo 

func (m *TruncateResponse) MarshalTo(dAtA []byte) (int, 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(ctx context.Context, req *AppendRequest) (*AppendResponse, 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(ctx context.Context, req *ReadBlocksRequest) (*ReadBlocksResponse, error)

func (*UnimplementedExtentServiceServer) ReadEntries 

func (*UnimplementedExtentServiceServer) ReadEntries(ctx context.Context, req *ReadEntriesRequest) (*ReadEntriesResponse, error)

func (*UnimplementedExtentServiceServer) ReplicateBlocks 

func (*UnimplementedExtentServiceServer) ReplicateBlocks(ctx context.Context, req *ReplicateBlocksRequest) (*ReplicateBlocksResponse, error)

func (*UnimplementedExtentServiceServer) RequireRecovery 

func (*UnimplementedExtentServiceServer) RequireRecovery(ctx context.Context, req *RequireRecoveryRequest) (*RequireRecoveryResponse, error)

func (*UnimplementedExtentServiceServer) SmartReadBlocks 

func (*UnimplementedExtentServiceServer) SmartReadBlocks(ctx context.Context, req *ReadBlocksRequest) (*ReadBlocksResponse, 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) Truncate 

func (*UnimplementedStreamManagerServiceServer) Truncate(ctx context.Context, req *TruncateRequest) (*TruncateResponse, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

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