volume_server_pb

package
v0.0.0-...-d8c34b0 Latest Latest
Warning

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

 Go to latest Published: Sep 12, 2019 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Overview

Package volume_server_pb is a generated protocol buffer package.

It is generated from these files: 

volume_server.proto

It has these top-level messages: 

BatchDeleteRequest
BatchDeleteResponse
DeleteResult
Empty
VacuumVolumeCheckRequest
VacuumVolumeCheckResponse
VacuumVolumeCompactRequest
VacuumVolumeCompactResponse
VacuumVolumeCommitRequest
VacuumVolumeCommitResponse
VacuumVolumeCleanupRequest
VacuumVolumeCleanupResponse
DeleteCollectionRequest
DeleteCollectionResponse
AllocateVolumeRequest
AllocateVolumeResponse
VolumeSyncStatusRequest
VolumeSyncStatusResponse
VolumeIncrementalCopyRequest
VolumeIncrementalCopyResponse
VolumeMountRequest
VolumeMountResponse
VolumeUnmountRequest
VolumeUnmountResponse
VolumeDeleteRequest
VolumeDeleteResponse
VolumeMarkReadonlyRequest
VolumeMarkReadonlyResponse
VolumeCopyRequest
VolumeCopyResponse
CopyFileRequest
CopyFileResponse
VolumeTailSenderRequest
VolumeTailSenderResponse
VolumeTailReceiverRequest
VolumeTailReceiverResponse
VolumeEcShardsGenerateRequest
VolumeEcShardsGenerateResponse
VolumeEcShardsRebuildRequest
VolumeEcShardsRebuildResponse
VolumeEcShardsCopyRequest
VolumeEcShardsCopyResponse
VolumeEcShardsDeleteRequest
VolumeEcShardsDeleteResponse
VolumeEcShardsMountRequest
VolumeEcShardsMountResponse
VolumeEcShardsUnmountRequest
VolumeEcShardsUnmountResponse
VolumeEcShardReadRequest
VolumeEcShardReadResponse
VolumeEcBlobDeleteRequest
VolumeEcBlobDeleteResponse
ReadVolumeFileStatusRequest
ReadVolumeFileStatusResponse
DiskStatus
MemStatus

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterVolumeServerServer 

func RegisterVolumeServerServer(s *grpc.Server, srv VolumeServerServer)

Types

type AllocateVolumeRequest 

type AllocateVolumeRequest struct {
	VolumeId           uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
	Collection         string `protobuf:"bytes,2,opt,name=collection" json:"collection,omitempty"`
	Preallocate        int64  `protobuf:"varint,3,opt,name=preallocate" json:"preallocate,omitempty"`
	Replication        string `protobuf:"bytes,4,opt,name=replication" json:"replication,omitempty"`
	Ttl                string `protobuf:"bytes,5,opt,name=ttl" json:"ttl,omitempty"`
	MemoryMapMaxSizeMB uint32 `protobuf:"varint,6,opt,name=memorymapmaxsizemb" json:"memorymapmaxsizemb,omitempty"`
}

func (*AllocateVolumeRequest) Descriptor 

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

func (*AllocateVolumeRequest) GetCollection 

func (m *AllocateVolumeRequest) GetCollection() string

func (*AllocateVolumeRequest) GetMemoryMapMaxSizeMB 

func (m *AllocateVolumeRequest) GetMemoryMapMaxSizeMB() uint32

func (*AllocateVolumeRequest) GetPreallocate 

func (m *AllocateVolumeRequest) GetPreallocate() int64

func (*AllocateVolumeRequest) GetReplication 

func (m *AllocateVolumeRequest) GetReplication() string

func (*AllocateVolumeRequest) GetTtl 

func (m *AllocateVolumeRequest) GetTtl() string

func (*AllocateVolumeRequest) GetVolumeId 

func (m *AllocateVolumeRequest) GetVolumeId() uint32

func (*AllocateVolumeRequest) ProtoMessage 

func (*AllocateVolumeRequest) ProtoMessage()

func (*AllocateVolumeRequest) Reset 

func (m *AllocateVolumeRequest) Reset()

func (*AllocateVolumeRequest) String 

func (m *AllocateVolumeRequest) String() string

type AllocateVolumeResponse 

type AllocateVolumeResponse struct {
}

func (*AllocateVolumeResponse) Descriptor 

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

func (*AllocateVolumeResponse) ProtoMessage 

func (*AllocateVolumeResponse) ProtoMessage()

func (*AllocateVolumeResponse) Reset 

func (m *AllocateVolumeResponse) Reset()

func (*AllocateVolumeResponse) String 

func (m *AllocateVolumeResponse) String() string

type BatchDeleteRequest 

type BatchDeleteRequest struct {
	FileIds []string `protobuf:"bytes,1,rep,name=file_ids,json=fileIds" json:"file_ids,omitempty"`
}

func (*BatchDeleteRequest) Descriptor 

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

func (*BatchDeleteRequest) GetFileIds 

func (m *BatchDeleteRequest) GetFileIds() []string

func (*BatchDeleteRequest) ProtoMessage 

func (*BatchDeleteRequest) ProtoMessage()

func (*BatchDeleteRequest) Reset 

func (m *BatchDeleteRequest) Reset()

func (*BatchDeleteRequest) String 

func (m *BatchDeleteRequest) String() string

type BatchDeleteResponse 

type BatchDeleteResponse struct {
	Results []*DeleteResult `protobuf:"bytes,1,rep,name=results" json:"results,omitempty"`
}

func (*BatchDeleteResponse) Descriptor 

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

func (*BatchDeleteResponse) GetResults 

func (m *BatchDeleteResponse) GetResults() []*DeleteResult

func (*BatchDeleteResponse) ProtoMessage 

func (*BatchDeleteResponse) ProtoMessage()

func (*BatchDeleteResponse) Reset 

func (m *BatchDeleteResponse) Reset()

func (*BatchDeleteResponse) String 

func (m *BatchDeleteResponse) String() string

type CopyFileRequest 

type CopyFileRequest struct {
	VolumeId           uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
	Ext                string `protobuf:"bytes,2,opt,name=ext" json:"ext,omitempty"`
	CompactionRevision uint32 `protobuf:"varint,3,opt,name=compaction_revision,json=compactionRevision" json:"compaction_revision,omitempty"`
	StopOffset         uint64 `protobuf:"varint,4,opt,name=stop_offset,json=stopOffset" json:"stop_offset,omitempty"`
	Collection         string `protobuf:"bytes,5,opt,name=collection" json:"collection,omitempty"`
	IsEcVolume         bool   `protobuf:"varint,6,opt,name=is_ec_volume,json=isEcVolume" json:"is_ec_volume,omitempty"`
}

func (*CopyFileRequest) Descriptor 

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

func (*CopyFileRequest) GetCollection 

func (m *CopyFileRequest) GetCollection() string

func (*CopyFileRequest) GetCompactionRevision 

func (m *CopyFileRequest) GetCompactionRevision() uint32

func (*CopyFileRequest) GetExt 

func (m *CopyFileRequest) GetExt() string

func (*CopyFileRequest) GetIsEcVolume 

func (m *CopyFileRequest) GetIsEcVolume() bool

func (*CopyFileRequest) GetStopOffset 

func (m *CopyFileRequest) GetStopOffset() uint64

func (*CopyFileRequest) GetVolumeId 

func (m *CopyFileRequest) GetVolumeId() uint32

func (*CopyFileRequest) ProtoMessage 

func (*CopyFileRequest) ProtoMessage()

func (*CopyFileRequest) Reset 

func (m *CopyFileRequest) Reset()

func (*CopyFileRequest) String 

func (m *CopyFileRequest) String() string

type CopyFileResponse 

type CopyFileResponse struct {
	FileContent []byte `protobuf:"bytes,1,opt,name=file_content,json=fileContent,proto3" json:"file_content,omitempty"`
}

func (*CopyFileResponse) Descriptor 

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

func (*CopyFileResponse) GetFileContent 

func (m *CopyFileResponse) GetFileContent() []byte

func (*CopyFileResponse) ProtoMessage 

func (*CopyFileResponse) ProtoMessage()

func (*CopyFileResponse) Reset 

func (m *CopyFileResponse) Reset()

func (*CopyFileResponse) String 

func (m *CopyFileResponse) String() string

type DeleteCollectionRequest 

type DeleteCollectionRequest struct {
	Collection string `protobuf:"bytes,1,opt,name=collection" json:"collection,omitempty"`
}

func (*DeleteCollectionRequest) Descriptor 

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

func (*DeleteCollectionRequest) GetCollection 

func (m *DeleteCollectionRequest) GetCollection() string

func (*DeleteCollectionRequest) ProtoMessage 

func (*DeleteCollectionRequest) ProtoMessage()

func (*DeleteCollectionRequest) Reset 

func (m *DeleteCollectionRequest) Reset()

func (*DeleteCollectionRequest) String 

func (m *DeleteCollectionRequest) String() string

type DeleteCollectionResponse 

type DeleteCollectionResponse struct {
}

func (*DeleteCollectionResponse) Descriptor 

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

func (*DeleteCollectionResponse) ProtoMessage 

func (*DeleteCollectionResponse) ProtoMessage()

func (*DeleteCollectionResponse) Reset 

func (m *DeleteCollectionResponse) Reset()

func (*DeleteCollectionResponse) String 

func (m *DeleteCollectionResponse) String() string

type DeleteResult 

type DeleteResult struct {
	FileId  string `protobuf:"bytes,1,opt,name=file_id,json=fileId" json:"file_id,omitempty"`
	Status  int32  `protobuf:"varint,2,opt,name=status" json:"status,omitempty"`
	Error   string `protobuf:"bytes,3,opt,name=error" json:"error,omitempty"`
	Size    uint32 `protobuf:"varint,4,opt,name=size" json:"size,omitempty"`
	Version uint32 `protobuf:"varint,5,opt,name=version" json:"version,omitempty"`
}

func (*DeleteResult) Descriptor 

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

func (*DeleteResult) GetError 

func (m *DeleteResult) GetError() string

func (*DeleteResult) GetFileId 

func (m *DeleteResult) GetFileId() string

func (*DeleteResult) GetSize 

func (m *DeleteResult) GetSize() uint32

func (*DeleteResult) GetStatus 

func (m *DeleteResult) GetStatus() int32

func (*DeleteResult) GetVersion 

func (m *DeleteResult) GetVersion() uint32

func (*DeleteResult) ProtoMessage 

func (*DeleteResult) ProtoMessage()

func (*DeleteResult) Reset 

func (m *DeleteResult) Reset()

func (*DeleteResult) String 

func (m *DeleteResult) String() string

type DiskStatus 

type DiskStatus struct {
	Dir  string `protobuf:"bytes,1,opt,name=dir" json:"dir,omitempty"`
	All  uint64 `protobuf:"varint,2,opt,name=all" json:"all,omitempty"`
	Used uint64 `protobuf:"varint,3,opt,name=used" json:"used,omitempty"`
	Free uint64 `protobuf:"varint,4,opt,name=free" json:"free,omitempty"`
}

func (*DiskStatus) Descriptor 

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

func (*DiskStatus) GetAll 

func (m *DiskStatus) GetAll() uint64

func (*DiskStatus) GetDir 

func (m *DiskStatus) GetDir() string

func (*DiskStatus) GetFree 

func (m *DiskStatus) GetFree() uint64

func (*DiskStatus) GetUsed 

func (m *DiskStatus) GetUsed() uint64

func (*DiskStatus) ProtoMessage 

func (*DiskStatus) ProtoMessage()

func (*DiskStatus) Reset 

func (m *DiskStatus) Reset()

func (*DiskStatus) String 

func (m *DiskStatus) String() string

type Empty 

type Empty struct {
}

func (*Empty) Descriptor 

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

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) Reset 

func (m *Empty) Reset()

func (*Empty) String 

func (m *Empty) String() string

type MemStatus 

type MemStatus struct {
	Goroutines int32  `protobuf:"varint,1,opt,name=goroutines" json:"goroutines,omitempty"`
	All        uint64 `protobuf:"varint,2,opt,name=all" json:"all,omitempty"`
	Used       uint64 `protobuf:"varint,3,opt,name=used" json:"used,omitempty"`
	Free       uint64 `protobuf:"varint,4,opt,name=free" json:"free,omitempty"`
	Self       uint64 `protobuf:"varint,5,opt,name=self" json:"self,omitempty"`
	Heap       uint64 `protobuf:"varint,6,opt,name=heap" json:"heap,omitempty"`
	Stack      uint64 `protobuf:"varint,7,opt,name=stack" json:"stack,omitempty"`
}

func (*MemStatus) Descriptor 

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

func (*MemStatus) GetAll 

func (m *MemStatus) GetAll() uint64

func (*MemStatus) GetFree 

func (m *MemStatus) GetFree() uint64

func (*MemStatus) GetGoroutines 

func (m *MemStatus) GetGoroutines() int32

func (*MemStatus) GetHeap 

func (m *MemStatus) GetHeap() uint64

func (*MemStatus) GetSelf 

func (m *MemStatus) GetSelf() uint64

func (*MemStatus) GetStack 

func (m *MemStatus) GetStack() uint64

func (*MemStatus) GetUsed 

func (m *MemStatus) GetUsed() uint64

func (*MemStatus) ProtoMessage 

func (*MemStatus) ProtoMessage()

func (*MemStatus) Reset 

func (m *MemStatus) Reset()

func (*MemStatus) String 

func (m *MemStatus) String() string

type ReadVolumeFileStatusRequest 

type ReadVolumeFileStatusRequest struct {
	VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
}

func (*ReadVolumeFileStatusRequest) Descriptor 

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

func (*ReadVolumeFileStatusRequest) GetVolumeId 

func (m *ReadVolumeFileStatusRequest) GetVolumeId() uint32

func (*ReadVolumeFileStatusRequest) ProtoMessage 

func (*ReadVolumeFileStatusRequest) ProtoMessage()

func (*ReadVolumeFileStatusRequest) Reset 

func (m *ReadVolumeFileStatusRequest) Reset()

func (*ReadVolumeFileStatusRequest) String 

func (m *ReadVolumeFileStatusRequest) String() string

type ReadVolumeFileStatusResponse 

type ReadVolumeFileStatusResponse struct {
	VolumeId                uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
	IdxFileTimestampSeconds uint64 `` /* 128-byte string literal not displayed */
	IdxFileSize             uint64 `protobuf:"varint,3,opt,name=idx_file_size,json=idxFileSize" json:"idx_file_size,omitempty"`
	DatFileTimestampSeconds uint64 `` /* 128-byte string literal not displayed */
	DatFileSize             uint64 `protobuf:"varint,5,opt,name=dat_file_size,json=datFileSize" json:"dat_file_size,omitempty"`
	FileCount               uint64 `protobuf:"varint,6,opt,name=file_count,json=fileCount" json:"file_count,omitempty"`
	CompactionRevision      uint32 `protobuf:"varint,7,opt,name=compaction_revision,json=compactionRevision" json:"compaction_revision,omitempty"`
	Collection              string `protobuf:"bytes,8,opt,name=collection" json:"collection,omitempty"`
}

func (*ReadVolumeFileStatusResponse) Descriptor 

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

func (*ReadVolumeFileStatusResponse) GetCollection 

func (m *ReadVolumeFileStatusResponse) GetCollection() string

func (*ReadVolumeFileStatusResponse) GetCompactionRevision 

func (m *ReadVolumeFileStatusResponse) GetCompactionRevision() uint32

func (*ReadVolumeFileStatusResponse) GetDatFileSize 

func (m *ReadVolumeFileStatusResponse) GetDatFileSize() uint64

func (*ReadVolumeFileStatusResponse) GetDatFileTimestampSeconds 

func (m *ReadVolumeFileStatusResponse) GetDatFileTimestampSeconds() uint64

func (*ReadVolumeFileStatusResponse) GetFileCount 

func (m *ReadVolumeFileStatusResponse) GetFileCount() uint64

func (*ReadVolumeFileStatusResponse) GetIdxFileSize 

func (m *ReadVolumeFileStatusResponse) GetIdxFileSize() uint64

func (*ReadVolumeFileStatusResponse) GetIdxFileTimestampSeconds 

func (m *ReadVolumeFileStatusResponse) GetIdxFileTimestampSeconds() uint64

func (*ReadVolumeFileStatusResponse) GetVolumeId 

func (m *ReadVolumeFileStatusResponse) GetVolumeId() uint32

func (*ReadVolumeFileStatusResponse) ProtoMessage 

func (*ReadVolumeFileStatusResponse) ProtoMessage()

func (*ReadVolumeFileStatusResponse) Reset 

func (m *ReadVolumeFileStatusResponse) Reset()

func (*ReadVolumeFileStatusResponse) String 

func (m *ReadVolumeFileStatusResponse) String() string

type VacuumVolumeCheckRequest 

type VacuumVolumeCheckRequest struct {
	VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
}

func (*VacuumVolumeCheckRequest) Descriptor 

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

func (*VacuumVolumeCheckRequest) GetVolumeId 

func (m *VacuumVolumeCheckRequest) GetVolumeId() uint32

func (*VacuumVolumeCheckRequest) ProtoMessage 

func (*VacuumVolumeCheckRequest) ProtoMessage()

func (*VacuumVolumeCheckRequest) Reset 

func (m *VacuumVolumeCheckRequest) Reset()

func (*VacuumVolumeCheckRequest) String 

func (m *VacuumVolumeCheckRequest) String() string

type VacuumVolumeCheckResponse 

type VacuumVolumeCheckResponse struct {
	GarbageRatio float64 `protobuf:"fixed64,1,opt,name=garbage_ratio,json=garbageRatio" json:"garbage_ratio,omitempty"`
}

func (*VacuumVolumeCheckResponse) Descriptor 

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

func (*VacuumVolumeCheckResponse) GetGarbageRatio 

func (m *VacuumVolumeCheckResponse) GetGarbageRatio() float64

func (*VacuumVolumeCheckResponse) ProtoMessage 

func (*VacuumVolumeCheckResponse) ProtoMessage()

func (*VacuumVolumeCheckResponse) Reset 

func (m *VacuumVolumeCheckResponse) Reset()

func (*VacuumVolumeCheckResponse) String 

func (m *VacuumVolumeCheckResponse) String() string

type VacuumVolumeCleanupRequest 

type VacuumVolumeCleanupRequest struct {
	VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
}

func (*VacuumVolumeCleanupRequest) Descriptor 

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

func (*VacuumVolumeCleanupRequest) GetVolumeId 

func (m *VacuumVolumeCleanupRequest) GetVolumeId() uint32

func (*VacuumVolumeCleanupRequest) ProtoMessage 

func (*VacuumVolumeCleanupRequest) ProtoMessage()

func (*VacuumVolumeCleanupRequest) Reset 

func (m *VacuumVolumeCleanupRequest) Reset()

func (*VacuumVolumeCleanupRequest) String 

func (m *VacuumVolumeCleanupRequest) String() string

type VacuumVolumeCleanupResponse 

type VacuumVolumeCleanupResponse struct {
}

func (*VacuumVolumeCleanupResponse) Descriptor 

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

func (*VacuumVolumeCleanupResponse) ProtoMessage 

func (*VacuumVolumeCleanupResponse) ProtoMessage()

func (*VacuumVolumeCleanupResponse) Reset 

func (m *VacuumVolumeCleanupResponse) Reset()

func (*VacuumVolumeCleanupResponse) String 

func (m *VacuumVolumeCleanupResponse) String() string

type VacuumVolumeCommitRequest 

type VacuumVolumeCommitRequest struct {
	VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
}

func (*VacuumVolumeCommitRequest) Descriptor 

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

func (*VacuumVolumeCommitRequest) GetVolumeId 

func (m *VacuumVolumeCommitRequest) GetVolumeId() uint32

func (*VacuumVolumeCommitRequest) ProtoMessage 

func (*VacuumVolumeCommitRequest) ProtoMessage()

func (*VacuumVolumeCommitRequest) Reset 

func (m *VacuumVolumeCommitRequest) Reset()

func (*VacuumVolumeCommitRequest) String 

func (m *VacuumVolumeCommitRequest) String() string

type VacuumVolumeCommitResponse 

type VacuumVolumeCommitResponse struct {
}

func (*VacuumVolumeCommitResponse) Descriptor 

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

func (*VacuumVolumeCommitResponse) ProtoMessage 

func (*VacuumVolumeCommitResponse) ProtoMessage()

func (*VacuumVolumeCommitResponse) Reset 

func (m *VacuumVolumeCommitResponse) Reset()

func (*VacuumVolumeCommitResponse) String 

func (m *VacuumVolumeCommitResponse) String() string

type VacuumVolumeCompactRequest 

type VacuumVolumeCompactRequest struct {
	VolumeId    uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
	Preallocate int64  `protobuf:"varint,2,opt,name=preallocate" json:"preallocate,omitempty"`
}

func (*VacuumVolumeCompactRequest) Descriptor 

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

func (*VacuumVolumeCompactRequest) GetPreallocate 

func (m *VacuumVolumeCompactRequest) GetPreallocate() int64

func (*VacuumVolumeCompactRequest) GetVolumeId 

func (m *VacuumVolumeCompactRequest) GetVolumeId() uint32

func (*VacuumVolumeCompactRequest) ProtoMessage 

func (*VacuumVolumeCompactRequest) ProtoMessage()

func (*VacuumVolumeCompactRequest) Reset 

func (m *VacuumVolumeCompactRequest) Reset()

func (*VacuumVolumeCompactRequest) String 

func (m *VacuumVolumeCompactRequest) String() string

type VacuumVolumeCompactResponse 

type VacuumVolumeCompactResponse struct {
}

func (*VacuumVolumeCompactResponse) Descriptor 

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

func (*VacuumVolumeCompactResponse) ProtoMessage 

func (*VacuumVolumeCompactResponse) ProtoMessage()

func (*VacuumVolumeCompactResponse) Reset 

func (m *VacuumVolumeCompactResponse) Reset()

func (*VacuumVolumeCompactResponse) String 

func (m *VacuumVolumeCompactResponse) String() string

type VolumeCopyRequest 

type VolumeCopyRequest struct {
	VolumeId       uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
	Collection     string `protobuf:"bytes,2,opt,name=collection" json:"collection,omitempty"`
	Replication    string `protobuf:"bytes,3,opt,name=replication" json:"replication,omitempty"`
	Ttl            string `protobuf:"bytes,4,opt,name=ttl" json:"ttl,omitempty"`
	SourceDataNode string `protobuf:"bytes,5,opt,name=source_data_node,json=sourceDataNode" json:"source_data_node,omitempty"`
}

func (*VolumeCopyRequest) Descriptor 

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

func (*VolumeCopyRequest) GetCollection 

func (m *VolumeCopyRequest) GetCollection() string

func (*VolumeCopyRequest) GetReplication 

func (m *VolumeCopyRequest) GetReplication() string

func (*VolumeCopyRequest) GetSourceDataNode 

func (m *VolumeCopyRequest) GetSourceDataNode() string

func (*VolumeCopyRequest) GetTtl 

func (m *VolumeCopyRequest) GetTtl() string

func (*VolumeCopyRequest) GetVolumeId 

func (m *VolumeCopyRequest) GetVolumeId() uint32

func (*VolumeCopyRequest) ProtoMessage 

func (*VolumeCopyRequest) ProtoMessage()

func (*VolumeCopyRequest) Reset 

func (m *VolumeCopyRequest) Reset()

func (*VolumeCopyRequest) String 

func (m *VolumeCopyRequest) String() string

type VolumeCopyResponse 

type VolumeCopyResponse struct {
	LastAppendAtNs uint64 `protobuf:"varint,1,opt,name=last_append_at_ns,json=lastAppendAtNs" json:"last_append_at_ns,omitempty"`
}

func (*VolumeCopyResponse) Descriptor 

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

func (*VolumeCopyResponse) GetLastAppendAtNs 

func (m *VolumeCopyResponse) GetLastAppendAtNs() uint64

func (*VolumeCopyResponse) ProtoMessage 

func (*VolumeCopyResponse) ProtoMessage()

func (*VolumeCopyResponse) Reset 

func (m *VolumeCopyResponse) Reset()

func (*VolumeCopyResponse) String 

func (m *VolumeCopyResponse) String() string

type VolumeDeleteRequest 

type VolumeDeleteRequest struct {
	VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
}

func (*VolumeDeleteRequest) Descriptor 

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

func (*VolumeDeleteRequest) GetVolumeId 

func (m *VolumeDeleteRequest) GetVolumeId() uint32

func (*VolumeDeleteRequest) ProtoMessage 

func (*VolumeDeleteRequest) ProtoMessage()

func (*VolumeDeleteRequest) Reset 

func (m *VolumeDeleteRequest) Reset()

func (*VolumeDeleteRequest) String 

func (m *VolumeDeleteRequest) String() string

type VolumeDeleteResponse 

type VolumeDeleteResponse struct {
}

func (*VolumeDeleteResponse) Descriptor 

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

func (*VolumeDeleteResponse) ProtoMessage 

func (*VolumeDeleteResponse) ProtoMessage()

func (*VolumeDeleteResponse) Reset 

func (m *VolumeDeleteResponse) Reset()

func (*VolumeDeleteResponse) String 

func (m *VolumeDeleteResponse) String() string

type VolumeEcBlobDeleteRequest 

type VolumeEcBlobDeleteRequest struct {
	VolumeId   uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
	Collection string `protobuf:"bytes,2,opt,name=collection" json:"collection,omitempty"`
	FileKey    uint64 `protobuf:"varint,3,opt,name=file_key,json=fileKey" json:"file_key,omitempty"`
	Version    uint32 `protobuf:"varint,4,opt,name=version" json:"version,omitempty"`
}

func (*VolumeEcBlobDeleteRequest) Descriptor 

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

func (*VolumeEcBlobDeleteRequest) GetCollection 

func (m *VolumeEcBlobDeleteRequest) GetCollection() string

func (*VolumeEcBlobDeleteRequest) GetFileKey 

func (m *VolumeEcBlobDeleteRequest) GetFileKey() uint64

func (*VolumeEcBlobDeleteRequest) GetVersion 

func (m *VolumeEcBlobDeleteRequest) GetVersion() uint32

func (*VolumeEcBlobDeleteRequest) GetVolumeId 

func (m *VolumeEcBlobDeleteRequest) GetVolumeId() uint32

func (*VolumeEcBlobDeleteRequest) ProtoMessage 

func (*VolumeEcBlobDeleteRequest) ProtoMessage()

func (*VolumeEcBlobDeleteRequest) Reset 

func (m *VolumeEcBlobDeleteRequest) Reset()

func (*VolumeEcBlobDeleteRequest) String 

func (m *VolumeEcBlobDeleteRequest) String() string

type VolumeEcBlobDeleteResponse 

type VolumeEcBlobDeleteResponse struct {
}

func (*VolumeEcBlobDeleteResponse) Descriptor 

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

func (*VolumeEcBlobDeleteResponse) ProtoMessage 

func (*VolumeEcBlobDeleteResponse) ProtoMessage()

func (*VolumeEcBlobDeleteResponse) Reset 

func (m *VolumeEcBlobDeleteResponse) Reset()

func (*VolumeEcBlobDeleteResponse) String 

func (m *VolumeEcBlobDeleteResponse) String() string

type VolumeEcShardReadRequest 

type VolumeEcShardReadRequest struct {
	VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
	ShardId  uint32 `protobuf:"varint,2,opt,name=shard_id,json=shardId" json:"shard_id,omitempty"`
	Offset   int64  `protobuf:"varint,3,opt,name=offset" json:"offset,omitempty"`
	Size     int64  `protobuf:"varint,4,opt,name=size" json:"size,omitempty"`
	FileKey  uint64 `protobuf:"varint,5,opt,name=file_key,json=fileKey" json:"file_key,omitempty"`
}

func (*VolumeEcShardReadRequest) Descriptor 

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

func (*VolumeEcShardReadRequest) GetFileKey 

func (m *VolumeEcShardReadRequest) GetFileKey() uint64

func (*VolumeEcShardReadRequest) GetOffset 

func (m *VolumeEcShardReadRequest) GetOffset() int64

func (*VolumeEcShardReadRequest) GetShardId 

func (m *VolumeEcShardReadRequest) GetShardId() uint32

func (*VolumeEcShardReadRequest) GetSize 

func (m *VolumeEcShardReadRequest) GetSize() int64

func (*VolumeEcShardReadRequest) GetVolumeId 

func (m *VolumeEcShardReadRequest) GetVolumeId() uint32

func (*VolumeEcShardReadRequest) ProtoMessage 

func (*VolumeEcShardReadRequest) ProtoMessage()

func (*VolumeEcShardReadRequest) Reset 

func (m *VolumeEcShardReadRequest) Reset()

func (*VolumeEcShardReadRequest) String 

func (m *VolumeEcShardReadRequest) String() string

type VolumeEcShardReadResponse 

type VolumeEcShardReadResponse struct {
	Data      []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	IsDeleted bool   `protobuf:"varint,2,opt,name=is_deleted,json=isDeleted" json:"is_deleted,omitempty"`
}

func (*VolumeEcShardReadResponse) Descriptor 

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

func (*VolumeEcShardReadResponse) GetData 

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

func (*VolumeEcShardReadResponse) GetIsDeleted 

func (m *VolumeEcShardReadResponse) GetIsDeleted() bool

func (*VolumeEcShardReadResponse) ProtoMessage 

func (*VolumeEcShardReadResponse) ProtoMessage()

func (*VolumeEcShardReadResponse) Reset 

func (m *VolumeEcShardReadResponse) Reset()

func (*VolumeEcShardReadResponse) String 

func (m *VolumeEcShardReadResponse) String() string

type VolumeEcShardsCopyRequest 

type VolumeEcShardsCopyRequest struct {
	VolumeId       uint32   `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
	Collection     string   `protobuf:"bytes,2,opt,name=collection" json:"collection,omitempty"`
	ShardIds       []uint32 `protobuf:"varint,3,rep,packed,name=shard_ids,json=shardIds" json:"shard_ids,omitempty"`
	CopyEcxFile    bool     `protobuf:"varint,4,opt,name=copy_ecx_file,json=copyEcxFile" json:"copy_ecx_file,omitempty"`
	SourceDataNode string   `protobuf:"bytes,5,opt,name=source_data_node,json=sourceDataNode" json:"source_data_node,omitempty"`
}

func (*VolumeEcShardsCopyRequest) Descriptor 

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

func (*VolumeEcShardsCopyRequest) GetCollection 

func (m *VolumeEcShardsCopyRequest) GetCollection() string

func (*VolumeEcShardsCopyRequest) GetCopyEcxFile 

func (m *VolumeEcShardsCopyRequest) GetCopyEcxFile() bool

func (*VolumeEcShardsCopyRequest) GetShardIds 

func (m *VolumeEcShardsCopyRequest) GetShardIds() []uint32

func (*VolumeEcShardsCopyRequest) GetSourceDataNode 

func (m *VolumeEcShardsCopyRequest) GetSourceDataNode() string

func (*VolumeEcShardsCopyRequest) GetVolumeId 

func (m *VolumeEcShardsCopyRequest) GetVolumeId() uint32

func (*VolumeEcShardsCopyRequest) ProtoMessage 

func (*VolumeEcShardsCopyRequest) ProtoMessage()

func (*VolumeEcShardsCopyRequest) Reset 

func (m *VolumeEcShardsCopyRequest) Reset()

func (*VolumeEcShardsCopyRequest) String 

func (m *VolumeEcShardsCopyRequest) String() string

type VolumeEcShardsCopyResponse 

type VolumeEcShardsCopyResponse struct {
}

func (*VolumeEcShardsCopyResponse) Descriptor 

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

func (*VolumeEcShardsCopyResponse) ProtoMessage 

func (*VolumeEcShardsCopyResponse) ProtoMessage()

func (*VolumeEcShardsCopyResponse) Reset 

func (m *VolumeEcShardsCopyResponse) Reset()

func (*VolumeEcShardsCopyResponse) String 

func (m *VolumeEcShardsCopyResponse) String() string

type VolumeEcShardsDeleteRequest 

type VolumeEcShardsDeleteRequest struct {
	VolumeId   uint32   `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
	Collection string   `protobuf:"bytes,2,opt,name=collection" json:"collection,omitempty"`
	ShardIds   []uint32 `protobuf:"varint,3,rep,packed,name=shard_ids,json=shardIds" json:"shard_ids,omitempty"`
}

func (*VolumeEcShardsDeleteRequest) Descriptor 

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

func (*VolumeEcShardsDeleteRequest) GetCollection 

func (m *VolumeEcShardsDeleteRequest) GetCollection() string

func (*VolumeEcShardsDeleteRequest) GetShardIds 

func (m *VolumeEcShardsDeleteRequest) GetShardIds() []uint32

func (*VolumeEcShardsDeleteRequest) GetVolumeId 

func (m *VolumeEcShardsDeleteRequest) GetVolumeId() uint32

func (*VolumeEcShardsDeleteRequest) ProtoMessage 

func (*VolumeEcShardsDeleteRequest) ProtoMessage()

func (*VolumeEcShardsDeleteRequest) Reset 

func (m *VolumeEcShardsDeleteRequest) Reset()

func (*VolumeEcShardsDeleteRequest) String 

func (m *VolumeEcShardsDeleteRequest) String() string

type VolumeEcShardsDeleteResponse 

type VolumeEcShardsDeleteResponse struct {
}

func (*VolumeEcShardsDeleteResponse) Descriptor 

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

func (*VolumeEcShardsDeleteResponse) ProtoMessage 

func (*VolumeEcShardsDeleteResponse) ProtoMessage()

func (*VolumeEcShardsDeleteResponse) Reset 

func (m *VolumeEcShardsDeleteResponse) Reset()

func (*VolumeEcShardsDeleteResponse) String 

func (m *VolumeEcShardsDeleteResponse) String() string

type VolumeEcShardsGenerateRequest 

type VolumeEcShardsGenerateRequest struct {
	VolumeId   uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
	Collection string `protobuf:"bytes,2,opt,name=collection" json:"collection,omitempty"`
}

func (*VolumeEcShardsGenerateRequest) Descriptor 

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

func (*VolumeEcShardsGenerateRequest) GetCollection 

func (m *VolumeEcShardsGenerateRequest) GetCollection() string

func (*VolumeEcShardsGenerateRequest) GetVolumeId 

func (m *VolumeEcShardsGenerateRequest) GetVolumeId() uint32

func (*VolumeEcShardsGenerateRequest) ProtoMessage 

func (*VolumeEcShardsGenerateRequest) ProtoMessage()

func (*VolumeEcShardsGenerateRequest) Reset 

func (m *VolumeEcShardsGenerateRequest) Reset()

func (*VolumeEcShardsGenerateRequest) String 

func (m *VolumeEcShardsGenerateRequest) String() string

type VolumeEcShardsGenerateResponse 

type VolumeEcShardsGenerateResponse struct {
}

func (*VolumeEcShardsGenerateResponse) Descriptor 

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

func (*VolumeEcShardsGenerateResponse) ProtoMessage 

func (*VolumeEcShardsGenerateResponse) ProtoMessage()

func (*VolumeEcShardsGenerateResponse) Reset 

func (m *VolumeEcShardsGenerateResponse) Reset()

func (*VolumeEcShardsGenerateResponse) String 

func (m *VolumeEcShardsGenerateResponse) String() string

type VolumeEcShardsMountRequest 

type VolumeEcShardsMountRequest struct {
	VolumeId   uint32   `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
	Collection string   `protobuf:"bytes,2,opt,name=collection" json:"collection,omitempty"`
	ShardIds   []uint32 `protobuf:"varint,3,rep,packed,name=shard_ids,json=shardIds" json:"shard_ids,omitempty"`
}

func (*VolumeEcShardsMountRequest) Descriptor 

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

func (*VolumeEcShardsMountRequest) GetCollection 

func (m *VolumeEcShardsMountRequest) GetCollection() string

func (*VolumeEcShardsMountRequest) GetShardIds 

func (m *VolumeEcShardsMountRequest) GetShardIds() []uint32

func (*VolumeEcShardsMountRequest) GetVolumeId 

func (m *VolumeEcShardsMountRequest) GetVolumeId() uint32

func (*VolumeEcShardsMountRequest) ProtoMessage 

func (*VolumeEcShardsMountRequest) ProtoMessage()

func (*VolumeEcShardsMountRequest) Reset 

func (m *VolumeEcShardsMountRequest) Reset()

func (*VolumeEcShardsMountRequest) String 

func (m *VolumeEcShardsMountRequest) String() string

type VolumeEcShardsMountResponse 

type VolumeEcShardsMountResponse struct {
}

func (*VolumeEcShardsMountResponse) Descriptor 

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

func (*VolumeEcShardsMountResponse) ProtoMessage 

func (*VolumeEcShardsMountResponse) ProtoMessage()

func (*VolumeEcShardsMountResponse) Reset 

func (m *VolumeEcShardsMountResponse) Reset()

func (*VolumeEcShardsMountResponse) String 

func (m *VolumeEcShardsMountResponse) String() string

type VolumeEcShardsRebuildRequest 

type VolumeEcShardsRebuildRequest struct {
	VolumeId   uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
	Collection string `protobuf:"bytes,2,opt,name=collection" json:"collection,omitempty"`
}

func (*VolumeEcShardsRebuildRequest) Descriptor 

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

func (*VolumeEcShardsRebuildRequest) GetCollection 

func (m *VolumeEcShardsRebuildRequest) GetCollection() string

func (*VolumeEcShardsRebuildRequest) GetVolumeId 

func (m *VolumeEcShardsRebuildRequest) GetVolumeId() uint32

func (*VolumeEcShardsRebuildRequest) ProtoMessage 

func (*VolumeEcShardsRebuildRequest) ProtoMessage()

func (*VolumeEcShardsRebuildRequest) Reset 

func (m *VolumeEcShardsRebuildRequest) Reset()

func (*VolumeEcShardsRebuildRequest) String 

func (m *VolumeEcShardsRebuildRequest) String() string

type VolumeEcShardsRebuildResponse 

type VolumeEcShardsRebuildResponse struct {
	RebuiltShardIds []uint32 `protobuf:"varint,1,rep,packed,name=rebuilt_shard_ids,json=rebuiltShardIds" json:"rebuilt_shard_ids,omitempty"`
}

func (*VolumeEcShardsRebuildResponse) Descriptor 

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

func (*VolumeEcShardsRebuildResponse) GetRebuiltShardIds 

func (m *VolumeEcShardsRebuildResponse) GetRebuiltShardIds() []uint32

func (*VolumeEcShardsRebuildResponse) ProtoMessage 

func (*VolumeEcShardsRebuildResponse) ProtoMessage()

func (*VolumeEcShardsRebuildResponse) Reset 

func (m *VolumeEcShardsRebuildResponse) Reset()

func (*VolumeEcShardsRebuildResponse) String 

func (m *VolumeEcShardsRebuildResponse) String() string

type VolumeEcShardsUnmountRequest 

type VolumeEcShardsUnmountRequest struct {
	VolumeId uint32   `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
	ShardIds []uint32 `protobuf:"varint,3,rep,packed,name=shard_ids,json=shardIds" json:"shard_ids,omitempty"`
}

func (*VolumeEcShardsUnmountRequest) Descriptor 

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

func (*VolumeEcShardsUnmountRequest) GetShardIds 

func (m *VolumeEcShardsUnmountRequest) GetShardIds() []uint32

func (*VolumeEcShardsUnmountRequest) GetVolumeId 

func (m *VolumeEcShardsUnmountRequest) GetVolumeId() uint32

func (*VolumeEcShardsUnmountRequest) ProtoMessage 

func (*VolumeEcShardsUnmountRequest) ProtoMessage()

func (*VolumeEcShardsUnmountRequest) Reset 

func (m *VolumeEcShardsUnmountRequest) Reset()

func (*VolumeEcShardsUnmountRequest) String 

func (m *VolumeEcShardsUnmountRequest) String() string

type VolumeEcShardsUnmountResponse 

type VolumeEcShardsUnmountResponse struct {
}

func (*VolumeEcShardsUnmountResponse) Descriptor 

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

func (*VolumeEcShardsUnmountResponse) ProtoMessage 

func (*VolumeEcShardsUnmountResponse) ProtoMessage()

func (*VolumeEcShardsUnmountResponse) Reset 

func (m *VolumeEcShardsUnmountResponse) Reset()

func (*VolumeEcShardsUnmountResponse) String 

func (m *VolumeEcShardsUnmountResponse) String() string

type VolumeIncrementalCopyRequest 

type VolumeIncrementalCopyRequest struct {
	VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
	SinceNs  uint64 `protobuf:"varint,2,opt,name=since_ns,json=sinceNs" json:"since_ns,omitempty"`
}

func (*VolumeIncrementalCopyRequest) Descriptor 

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

func (*VolumeIncrementalCopyRequest) GetSinceNs 

func (m *VolumeIncrementalCopyRequest) GetSinceNs() uint64

func (*VolumeIncrementalCopyRequest) GetVolumeId 

func (m *VolumeIncrementalCopyRequest) GetVolumeId() uint32

func (*VolumeIncrementalCopyRequest) ProtoMessage 

func (*VolumeIncrementalCopyRequest) ProtoMessage()

func (*VolumeIncrementalCopyRequest) Reset 

func (m *VolumeIncrementalCopyRequest) Reset()

func (*VolumeIncrementalCopyRequest) String 

func (m *VolumeIncrementalCopyRequest) String() string

type VolumeIncrementalCopyResponse 

type VolumeIncrementalCopyResponse struct {
	FileContent []byte `protobuf:"bytes,1,opt,name=file_content,json=fileContent,proto3" json:"file_content,omitempty"`
}

func (*VolumeIncrementalCopyResponse) Descriptor 

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

func (*VolumeIncrementalCopyResponse) GetFileContent 

func (m *VolumeIncrementalCopyResponse) GetFileContent() []byte

func (*VolumeIncrementalCopyResponse) ProtoMessage 

func (*VolumeIncrementalCopyResponse) ProtoMessage()

func (*VolumeIncrementalCopyResponse) Reset 

func (m *VolumeIncrementalCopyResponse) Reset()

func (*VolumeIncrementalCopyResponse) String 

func (m *VolumeIncrementalCopyResponse) String() string

type VolumeMarkReadonlyRequest 

type VolumeMarkReadonlyRequest struct {
	VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
}

func (*VolumeMarkReadonlyRequest) Descriptor 

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

func (*VolumeMarkReadonlyRequest) GetVolumeId 

func (m *VolumeMarkReadonlyRequest) GetVolumeId() uint32

func (*VolumeMarkReadonlyRequest) ProtoMessage 

func (*VolumeMarkReadonlyRequest) ProtoMessage()

func (*VolumeMarkReadonlyRequest) Reset 

func (m *VolumeMarkReadonlyRequest) Reset()

func (*VolumeMarkReadonlyRequest) String 

func (m *VolumeMarkReadonlyRequest) String() string

type VolumeMarkReadonlyResponse 

type VolumeMarkReadonlyResponse struct {
}

func (*VolumeMarkReadonlyResponse) Descriptor 

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

func (*VolumeMarkReadonlyResponse) ProtoMessage 

func (*VolumeMarkReadonlyResponse) ProtoMessage()

func (*VolumeMarkReadonlyResponse) Reset 

func (m *VolumeMarkReadonlyResponse) Reset()

func (*VolumeMarkReadonlyResponse) String 

func (m *VolumeMarkReadonlyResponse) String() string

type VolumeMountRequest 

type VolumeMountRequest struct {
	VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
}

func (*VolumeMountRequest) Descriptor 

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

func (*VolumeMountRequest) GetVolumeId 

func (m *VolumeMountRequest) GetVolumeId() uint32

func (*VolumeMountRequest) ProtoMessage 

func (*VolumeMountRequest) ProtoMessage()

func (*VolumeMountRequest) Reset 

func (m *VolumeMountRequest) Reset()

func (*VolumeMountRequest) String 

func (m *VolumeMountRequest) String() string

type VolumeMountResponse 

type VolumeMountResponse struct {
}

func (*VolumeMountResponse) Descriptor 

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

func (*VolumeMountResponse) ProtoMessage 

func (*VolumeMountResponse) ProtoMessage()

func (*VolumeMountResponse) Reset 

func (m *VolumeMountResponse) Reset()

func (*VolumeMountResponse) String 

func (m *VolumeMountResponse) String() string

type VolumeServerClient 

type VolumeServerClient interface {
	// Experts only: takes multiple fid parameters. This function does not propagate deletes to replicas.
	BatchDelete(ctx context.Context, in *BatchDeleteRequest, opts ...grpc.CallOption) (*BatchDeleteResponse, error)
	VacuumVolumeCheck(ctx context.Context, in *VacuumVolumeCheckRequest, opts ...grpc.CallOption) (*VacuumVolumeCheckResponse, error)
	VacuumVolumeCompact(ctx context.Context, in *VacuumVolumeCompactRequest, opts ...grpc.CallOption) (*VacuumVolumeCompactResponse, error)
	VacuumVolumeCommit(ctx context.Context, in *VacuumVolumeCommitRequest, opts ...grpc.CallOption) (*VacuumVolumeCommitResponse, error)
	VacuumVolumeCleanup(ctx context.Context, in *VacuumVolumeCleanupRequest, opts ...grpc.CallOption) (*VacuumVolumeCleanupResponse, error)
	DeleteCollection(ctx context.Context, in *DeleteCollectionRequest, opts ...grpc.CallOption) (*DeleteCollectionResponse, error)
	AllocateVolume(ctx context.Context, in *AllocateVolumeRequest, opts ...grpc.CallOption) (*AllocateVolumeResponse, error)
	VolumeSyncStatus(ctx context.Context, in *VolumeSyncStatusRequest, opts ...grpc.CallOption) (*VolumeSyncStatusResponse, error)
	VolumeIncrementalCopy(ctx context.Context, in *VolumeIncrementalCopyRequest, opts ...grpc.CallOption) (VolumeServer_VolumeIncrementalCopyClient, error)
	VolumeMount(ctx context.Context, in *VolumeMountRequest, opts ...grpc.CallOption) (*VolumeMountResponse, error)
	VolumeUnmount(ctx context.Context, in *VolumeUnmountRequest, opts ...grpc.CallOption) (*VolumeUnmountResponse, error)
	VolumeDelete(ctx context.Context, in *VolumeDeleteRequest, opts ...grpc.CallOption) (*VolumeDeleteResponse, error)
	VolumeMarkReadonly(ctx context.Context, in *VolumeMarkReadonlyRequest, opts ...grpc.CallOption) (*VolumeMarkReadonlyResponse, error)
	// copy the .idx .dat files, and mount this volume
	VolumeCopy(ctx context.Context, in *VolumeCopyRequest, opts ...grpc.CallOption) (*VolumeCopyResponse, error)
	ReadVolumeFileStatus(ctx context.Context, in *ReadVolumeFileStatusRequest, opts ...grpc.CallOption) (*ReadVolumeFileStatusResponse, error)
	CopyFile(ctx context.Context, in *CopyFileRequest, opts ...grpc.CallOption) (VolumeServer_CopyFileClient, error)
	VolumeTailSender(ctx context.Context, in *VolumeTailSenderRequest, opts ...grpc.CallOption) (VolumeServer_VolumeTailSenderClient, error)
	VolumeTailReceiver(ctx context.Context, in *VolumeTailReceiverRequest, opts ...grpc.CallOption) (*VolumeTailReceiverResponse, error)
	// erasure coding
	VolumeEcShardsGenerate(ctx context.Context, in *VolumeEcShardsGenerateRequest, opts ...grpc.CallOption) (*VolumeEcShardsGenerateResponse, error)
	VolumeEcShardsRebuild(ctx context.Context, in *VolumeEcShardsRebuildRequest, opts ...grpc.CallOption) (*VolumeEcShardsRebuildResponse, error)
	VolumeEcShardsCopy(ctx context.Context, in *VolumeEcShardsCopyRequest, opts ...grpc.CallOption) (*VolumeEcShardsCopyResponse, error)
	VolumeEcShardsDelete(ctx context.Context, in *VolumeEcShardsDeleteRequest, opts ...grpc.CallOption) (*VolumeEcShardsDeleteResponse, error)
	VolumeEcShardsMount(ctx context.Context, in *VolumeEcShardsMountRequest, opts ...grpc.CallOption) (*VolumeEcShardsMountResponse, error)
	VolumeEcShardsUnmount(ctx context.Context, in *VolumeEcShardsUnmountRequest, opts ...grpc.CallOption) (*VolumeEcShardsUnmountResponse, error)
	VolumeEcShardRead(ctx context.Context, in *VolumeEcShardReadRequest, opts ...grpc.CallOption) (VolumeServer_VolumeEcShardReadClient, error)
	VolumeEcBlobDelete(ctx context.Context, in *VolumeEcBlobDeleteRequest, opts ...grpc.CallOption) (*VolumeEcBlobDeleteResponse, error)
}

func NewVolumeServerClient 

func NewVolumeServerClient(cc *grpc.ClientConn) VolumeServerClient

type VolumeServerServer 

type VolumeServerServer interface {
	// Experts only: takes multiple fid parameters. This function does not propagate deletes to replicas.
	BatchDelete(context.Context, *BatchDeleteRequest) (*BatchDeleteResponse, error)
	VacuumVolumeCheck(context.Context, *VacuumVolumeCheckRequest) (*VacuumVolumeCheckResponse, error)
	VacuumVolumeCompact(context.Context, *VacuumVolumeCompactRequest) (*VacuumVolumeCompactResponse, error)
	VacuumVolumeCommit(context.Context, *VacuumVolumeCommitRequest) (*VacuumVolumeCommitResponse, error)
	VacuumVolumeCleanup(context.Context, *VacuumVolumeCleanupRequest) (*VacuumVolumeCleanupResponse, error)
	DeleteCollection(context.Context, *DeleteCollectionRequest) (*DeleteCollectionResponse, error)
	AllocateVolume(context.Context, *AllocateVolumeRequest) (*AllocateVolumeResponse, error)
	VolumeSyncStatus(context.Context, *VolumeSyncStatusRequest) (*VolumeSyncStatusResponse, error)
	VolumeIncrementalCopy(*VolumeIncrementalCopyRequest, VolumeServer_VolumeIncrementalCopyServer) error
	VolumeMount(context.Context, *VolumeMountRequest) (*VolumeMountResponse, error)
	VolumeUnmount(context.Context, *VolumeUnmountRequest) (*VolumeUnmountResponse, error)
	VolumeDelete(context.Context, *VolumeDeleteRequest) (*VolumeDeleteResponse, error)
	VolumeMarkReadonly(context.Context, *VolumeMarkReadonlyRequest) (*VolumeMarkReadonlyResponse, error)
	// copy the .idx .dat files, and mount this volume
	VolumeCopy(context.Context, *VolumeCopyRequest) (*VolumeCopyResponse, error)
	ReadVolumeFileStatus(context.Context, *ReadVolumeFileStatusRequest) (*ReadVolumeFileStatusResponse, error)
	CopyFile(*CopyFileRequest, VolumeServer_CopyFileServer) error
	VolumeTailSender(*VolumeTailSenderRequest, VolumeServer_VolumeTailSenderServer) error
	VolumeTailReceiver(context.Context, *VolumeTailReceiverRequest) (*VolumeTailReceiverResponse, error)
	// erasure coding
	VolumeEcShardsGenerate(context.Context, *VolumeEcShardsGenerateRequest) (*VolumeEcShardsGenerateResponse, error)
	VolumeEcShardsRebuild(context.Context, *VolumeEcShardsRebuildRequest) (*VolumeEcShardsRebuildResponse, error)
	VolumeEcShardsCopy(context.Context, *VolumeEcShardsCopyRequest) (*VolumeEcShardsCopyResponse, error)
	VolumeEcShardsDelete(context.Context, *VolumeEcShardsDeleteRequest) (*VolumeEcShardsDeleteResponse, error)
	VolumeEcShardsMount(context.Context, *VolumeEcShardsMountRequest) (*VolumeEcShardsMountResponse, error)
	VolumeEcShardsUnmount(context.Context, *VolumeEcShardsUnmountRequest) (*VolumeEcShardsUnmountResponse, error)
	VolumeEcShardRead(*VolumeEcShardReadRequest, VolumeServer_VolumeEcShardReadServer) error
	VolumeEcBlobDelete(context.Context, *VolumeEcBlobDeleteRequest) (*VolumeEcBlobDeleteResponse, error)
}

type VolumeServer_CopyFileClient 

type VolumeServer_CopyFileClient interface {
	Recv() (*CopyFileResponse, error)
	grpc.ClientStream
}

type VolumeServer_CopyFileServer 

type VolumeServer_CopyFileServer interface {
	Send(*CopyFileResponse) error
	grpc.ServerStream
}

type VolumeServer_VolumeEcShardReadClient 

type VolumeServer_VolumeEcShardReadClient interface {
	Recv() (*VolumeEcShardReadResponse, error)
	grpc.ClientStream
}

type VolumeServer_VolumeEcShardReadServer 

type VolumeServer_VolumeEcShardReadServer interface {
	Send(*VolumeEcShardReadResponse) error
	grpc.ServerStream
}

type VolumeServer_VolumeIncrementalCopyClient 

type VolumeServer_VolumeIncrementalCopyClient interface {
	Recv() (*VolumeIncrementalCopyResponse, error)
	grpc.ClientStream
}

type VolumeServer_VolumeIncrementalCopyServer 

type VolumeServer_VolumeIncrementalCopyServer interface {
	Send(*VolumeIncrementalCopyResponse) error
	grpc.ServerStream
}

type VolumeServer_VolumeTailSenderClient 

type VolumeServer_VolumeTailSenderClient interface {
	Recv() (*VolumeTailSenderResponse, error)
	grpc.ClientStream
}

type VolumeServer_VolumeTailSenderServer 

type VolumeServer_VolumeTailSenderServer interface {
	Send(*VolumeTailSenderResponse) error
	grpc.ServerStream
}

type VolumeSyncStatusRequest 

type VolumeSyncStatusRequest struct {
	VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
}

func (*VolumeSyncStatusRequest) Descriptor 

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

func (*VolumeSyncStatusRequest) GetVolumeId 

func (m *VolumeSyncStatusRequest) GetVolumeId() uint32

func (*VolumeSyncStatusRequest) ProtoMessage 

func (*VolumeSyncStatusRequest) ProtoMessage()

func (*VolumeSyncStatusRequest) Reset 

func (m *VolumeSyncStatusRequest) Reset()

func (*VolumeSyncStatusRequest) String 

func (m *VolumeSyncStatusRequest) String() string

type VolumeSyncStatusResponse 

type VolumeSyncStatusResponse struct {
	VolumeId        uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
	Collection      string `protobuf:"bytes,2,opt,name=collection" json:"collection,omitempty"`
	Replication     string `protobuf:"bytes,4,opt,name=replication" json:"replication,omitempty"`
	Ttl             string `protobuf:"bytes,5,opt,name=ttl" json:"ttl,omitempty"`
	TailOffset      uint64 `protobuf:"varint,6,opt,name=tail_offset,json=tailOffset" json:"tail_offset,omitempty"`
	CompactRevision uint32 `protobuf:"varint,7,opt,name=compact_revision,json=compactRevision" json:"compact_revision,omitempty"`
	IdxFileSize     uint64 `protobuf:"varint,8,opt,name=idx_file_size,json=idxFileSize" json:"idx_file_size,omitempty"`
}

func (*VolumeSyncStatusResponse) Descriptor 

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

func (*VolumeSyncStatusResponse) GetCollection 

func (m *VolumeSyncStatusResponse) GetCollection() string

func (*VolumeSyncStatusResponse) GetCompactRevision 

func (m *VolumeSyncStatusResponse) GetCompactRevision() uint32

func (*VolumeSyncStatusResponse) GetIdxFileSize 

func (m *VolumeSyncStatusResponse) GetIdxFileSize() uint64

func (*VolumeSyncStatusResponse) GetReplication 

func (m *VolumeSyncStatusResponse) GetReplication() string

func (*VolumeSyncStatusResponse) GetTailOffset 

func (m *VolumeSyncStatusResponse) GetTailOffset() uint64

func (*VolumeSyncStatusResponse) GetTtl 

func (m *VolumeSyncStatusResponse) GetTtl() string

func (*VolumeSyncStatusResponse) GetVolumeId 

func (m *VolumeSyncStatusResponse) GetVolumeId() uint32

func (*VolumeSyncStatusResponse) ProtoMessage 

func (*VolumeSyncStatusResponse) ProtoMessage()

func (*VolumeSyncStatusResponse) Reset 

func (m *VolumeSyncStatusResponse) Reset()

func (*VolumeSyncStatusResponse) String 

func (m *VolumeSyncStatusResponse) String() string

type VolumeTailReceiverRequest 

type VolumeTailReceiverRequest struct {
	VolumeId           uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
	SinceNs            uint64 `protobuf:"varint,2,opt,name=since_ns,json=sinceNs" json:"since_ns,omitempty"`
	IdleTimeoutSeconds uint32 `protobuf:"varint,3,opt,name=idle_timeout_seconds,json=idleTimeoutSeconds" json:"idle_timeout_seconds,omitempty"`
	SourceVolumeServer string `protobuf:"bytes,4,opt,name=source_volume_server,json=sourceVolumeServer" json:"source_volume_server,omitempty"`
}

func (*VolumeTailReceiverRequest) Descriptor 

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

func (*VolumeTailReceiverRequest) GetIdleTimeoutSeconds 

func (m *VolumeTailReceiverRequest) GetIdleTimeoutSeconds() uint32

func (*VolumeTailReceiverRequest) GetSinceNs 

func (m *VolumeTailReceiverRequest) GetSinceNs() uint64

func (*VolumeTailReceiverRequest) GetSourceVolumeServer 

func (m *VolumeTailReceiverRequest) GetSourceVolumeServer() string

func (*VolumeTailReceiverRequest) GetVolumeId 

func (m *VolumeTailReceiverRequest) GetVolumeId() uint32

func (*VolumeTailReceiverRequest) ProtoMessage 

func (*VolumeTailReceiverRequest) ProtoMessage()

func (*VolumeTailReceiverRequest) Reset 

func (m *VolumeTailReceiverRequest) Reset()

func (*VolumeTailReceiverRequest) String 

func (m *VolumeTailReceiverRequest) String() string

type VolumeTailReceiverResponse 

type VolumeTailReceiverResponse struct {
}

func (*VolumeTailReceiverResponse) Descriptor 

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

func (*VolumeTailReceiverResponse) ProtoMessage 

func (*VolumeTailReceiverResponse) ProtoMessage()

func (*VolumeTailReceiverResponse) Reset 

func (m *VolumeTailReceiverResponse) Reset()

func (*VolumeTailReceiverResponse) String 

func (m *VolumeTailReceiverResponse) String() string

type VolumeTailSenderRequest 

type VolumeTailSenderRequest struct {
	VolumeId           uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
	SinceNs            uint64 `protobuf:"varint,2,opt,name=since_ns,json=sinceNs" json:"since_ns,omitempty"`
	IdleTimeoutSeconds uint32 `protobuf:"varint,3,opt,name=idle_timeout_seconds,json=idleTimeoutSeconds" json:"idle_timeout_seconds,omitempty"`
}

func (*VolumeTailSenderRequest) Descriptor 

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

func (*VolumeTailSenderRequest) GetIdleTimeoutSeconds 

func (m *VolumeTailSenderRequest) GetIdleTimeoutSeconds() uint32

func (*VolumeTailSenderRequest) GetSinceNs 

func (m *VolumeTailSenderRequest) GetSinceNs() uint64

func (*VolumeTailSenderRequest) GetVolumeId 

func (m *VolumeTailSenderRequest) GetVolumeId() uint32

func (*VolumeTailSenderRequest) ProtoMessage 

func (*VolumeTailSenderRequest) ProtoMessage()

func (*VolumeTailSenderRequest) Reset 

func (m *VolumeTailSenderRequest) Reset()

func (*VolumeTailSenderRequest) String 

func (m *VolumeTailSenderRequest) String() string

type VolumeTailSenderResponse 

type VolumeTailSenderResponse struct {
	NeedleHeader []byte `protobuf:"bytes,1,opt,name=needle_header,json=needleHeader,proto3" json:"needle_header,omitempty"`
	NeedleBody   []byte `protobuf:"bytes,2,opt,name=needle_body,json=needleBody,proto3" json:"needle_body,omitempty"`
	IsLastChunk  bool   `protobuf:"varint,3,opt,name=is_last_chunk,json=isLastChunk" json:"is_last_chunk,omitempty"`
}

func (*VolumeTailSenderResponse) Descriptor 

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

func (*VolumeTailSenderResponse) GetIsLastChunk 

func (m *VolumeTailSenderResponse) GetIsLastChunk() bool

func (*VolumeTailSenderResponse) GetNeedleBody 

func (m *VolumeTailSenderResponse) GetNeedleBody() []byte

func (*VolumeTailSenderResponse) GetNeedleHeader 

func (m *VolumeTailSenderResponse) GetNeedleHeader() []byte

func (*VolumeTailSenderResponse) ProtoMessage 

func (*VolumeTailSenderResponse) ProtoMessage()

func (*VolumeTailSenderResponse) Reset 

func (m *VolumeTailSenderResponse) Reset()

func (*VolumeTailSenderResponse) String 

func (m *VolumeTailSenderResponse) String() string

type VolumeUnmountRequest 

type VolumeUnmountRequest struct {
	VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
}

func (*VolumeUnmountRequest) Descriptor 

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

func (*VolumeUnmountRequest) GetVolumeId 

func (m *VolumeUnmountRequest) GetVolumeId() uint32

func (*VolumeUnmountRequest) ProtoMessage 

func (*VolumeUnmountRequest) ProtoMessage()

func (*VolumeUnmountRequest) Reset 

func (m *VolumeUnmountRequest) Reset()

func (*VolumeUnmountRequest) String 

func (m *VolumeUnmountRequest) String() string

type VolumeUnmountResponse 

type VolumeUnmountResponse struct {
}

func (*VolumeUnmountResponse) Descriptor 

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

func (*VolumeUnmountResponse) ProtoMessage 

func (*VolumeUnmountResponse) ProtoMessage()

func (*VolumeUnmountResponse) Reset 

func (m *VolumeUnmountResponse) Reset()

func (*VolumeUnmountResponse) String 

func (m *VolumeUnmountResponse) String() string

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.