volume_server_pb

package
v0.0.0-...-2206af0 Latest Latest
Warning

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

 Go to latest Published: Apr 12, 2022 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_volume_server_proto protoreflect.FileDescriptor

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,proto3" json:"volume_id,omitempty"`
	Collection         string `protobuf:"bytes,2,opt,name=collection,proto3" json:"collection,omitempty"`
	Preallocate        int64  `protobuf:"varint,3,opt,name=preallocate,proto3" json:"preallocate,omitempty"`
	Replication        string `protobuf:"bytes,4,opt,name=replication,proto3" json:"replication,omitempty"`
	Ttl                string `protobuf:"bytes,5,opt,name=ttl,proto3" json:"ttl,omitempty"`
	MemoryMapMaxSizeMb uint32 `protobuf:"varint,6,opt,name=memory_map_max_size_mb,json=memoryMapMaxSizeMb,proto3" json:"memory_map_max_size_mb,omitempty"`
	// contains filtered or unexported fields
}

func (*AllocateVolumeRequest) Descriptor deprecated 

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

Deprecated: Use AllocateVolumeRequest.ProtoReflect.Descriptor instead.

func (*AllocateVolumeRequest) GetCollection 

func (x *AllocateVolumeRequest) GetCollection() string

func (*AllocateVolumeRequest) GetMemoryMapMaxSizeMb 

func (x *AllocateVolumeRequest) GetMemoryMapMaxSizeMb() uint32

func (*AllocateVolumeRequest) GetPreallocate 

func (x *AllocateVolumeRequest) GetPreallocate() int64

func (*AllocateVolumeRequest) GetReplication 

func (x *AllocateVolumeRequest) GetReplication() string

func (*AllocateVolumeRequest) GetTtl 

func (x *AllocateVolumeRequest) GetTtl() string

func (*AllocateVolumeRequest) GetVolumeId 

func (x *AllocateVolumeRequest) GetVolumeId() uint32

func (*AllocateVolumeRequest) ProtoMessage 

func (*AllocateVolumeRequest) ProtoMessage()

func (*AllocateVolumeRequest) ProtoReflect 

func (x *AllocateVolumeRequest) ProtoReflect() protoreflect.Message

func (*AllocateVolumeRequest) Reset 

func (x *AllocateVolumeRequest) Reset()

func (*AllocateVolumeRequest) String 

func (x *AllocateVolumeRequest) String() string

type AllocateVolumeResponse 

type AllocateVolumeResponse struct {
	// contains filtered or unexported fields
}

func (*AllocateVolumeResponse) Descriptor deprecated 

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

Deprecated: Use AllocateVolumeResponse.ProtoReflect.Descriptor instead.

func (*AllocateVolumeResponse) ProtoMessage 

func (*AllocateVolumeResponse) ProtoMessage()

func (*AllocateVolumeResponse) ProtoReflect 

func (x *AllocateVolumeResponse) ProtoReflect() protoreflect.Message

func (*AllocateVolumeResponse) Reset 

func (x *AllocateVolumeResponse) Reset()

func (*AllocateVolumeResponse) String 

func (x *AllocateVolumeResponse) String() string

type BatchDeleteRequest 

type BatchDeleteRequest struct {
	FileIds         []string `protobuf:"bytes,1,rep,name=file_ids,json=fileIds,proto3" json:"file_ids,omitempty"`
	SkipCookieCheck bool     `protobuf:"varint,2,opt,name=skip_cookie_check,json=skipCookieCheck,proto3" json:"skip_cookie_check,omitempty"`
	// contains filtered or unexported fields
}

func (*BatchDeleteRequest) Descriptor deprecated 

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

Deprecated: Use BatchDeleteRequest.ProtoReflect.Descriptor instead.

func (*BatchDeleteRequest) GetFileIds 

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

func (*BatchDeleteRequest) GetSkipCookieCheck 

func (x *BatchDeleteRequest) GetSkipCookieCheck() bool

func (*BatchDeleteRequest) ProtoMessage 

func (*BatchDeleteRequest) ProtoMessage()

func (*BatchDeleteRequest) ProtoReflect 

func (x *BatchDeleteRequest) ProtoReflect() protoreflect.Message

func (*BatchDeleteRequest) Reset 

func (x *BatchDeleteRequest) Reset()

func (*BatchDeleteRequest) String 

func (x *BatchDeleteRequest) String() string

type BatchDeleteResponse 

type BatchDeleteResponse struct {
	Results []*DeleteResult `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	// contains filtered or unexported fields
}

func (*BatchDeleteResponse) Descriptor deprecated 

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

Deprecated: Use BatchDeleteResponse.ProtoReflect.Descriptor instead.

func (*BatchDeleteResponse) GetResults 

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

func (*BatchDeleteResponse) ProtoMessage 

func (*BatchDeleteResponse) ProtoMessage()

func (*BatchDeleteResponse) ProtoReflect 

func (x *BatchDeleteResponse) ProtoReflect() protoreflect.Message

func (*BatchDeleteResponse) Reset 

func (x *BatchDeleteResponse) Reset()

func (*BatchDeleteResponse) String 

func (x *BatchDeleteResponse) String() string

type CopyFileRequest 

type CopyFileRequest struct {
	VolumeId                 uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId,proto3" json:"volume_id,omitempty"`
	Ext                      string `protobuf:"bytes,2,opt,name=ext,proto3" json:"ext,omitempty"`
	CompactionRevision       uint32 `protobuf:"varint,3,opt,name=compaction_revision,json=compactionRevision,proto3" json:"compaction_revision,omitempty"`
	StopOffset               uint64 `protobuf:"varint,4,opt,name=stop_offset,json=stopOffset,proto3" json:"stop_offset,omitempty"`
	Collection               string `protobuf:"bytes,5,opt,name=collection,proto3" json:"collection,omitempty"`
	IsEcVolume               bool   `protobuf:"varint,6,opt,name=is_ec_volume,json=isEcVolume,proto3" json:"is_ec_volume,omitempty"`
	IgnoreSourceFileNotFound bool   `` /* 140-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CopyFileRequest) Descriptor deprecated 

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

Deprecated: Use CopyFileRequest.ProtoReflect.Descriptor instead.

func (*CopyFileRequest) GetCollection 

func (x *CopyFileRequest) GetCollection() string

func (*CopyFileRequest) GetCompactionRevision 

func (x *CopyFileRequest) GetCompactionRevision() uint32

func (*CopyFileRequest) GetExt 

func (x *CopyFileRequest) GetExt() string

func (*CopyFileRequest) GetIgnoreSourceFileNotFound 

func (x *CopyFileRequest) GetIgnoreSourceFileNotFound() bool

func (*CopyFileRequest) GetIsEcVolume 

func (x *CopyFileRequest) GetIsEcVolume() bool

func (*CopyFileRequest) GetStopOffset 

func (x *CopyFileRequest) GetStopOffset() uint64

func (*CopyFileRequest) GetVolumeId 

func (x *CopyFileRequest) GetVolumeId() uint32

func (*CopyFileRequest) ProtoMessage 

func (*CopyFileRequest) ProtoMessage()

func (*CopyFileRequest) ProtoReflect 

func (x *CopyFileRequest) ProtoReflect() protoreflect.Message

func (*CopyFileRequest) Reset 

func (x *CopyFileRequest) Reset()

func (*CopyFileRequest) String 

func (x *CopyFileRequest) String() string

type CopyFileResponse 

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

func (*CopyFileResponse) Descriptor deprecated 

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

Deprecated: Use CopyFileResponse.ProtoReflect.Descriptor instead.

func (*CopyFileResponse) GetFileContent 

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

func (*CopyFileResponse) ProtoMessage 

func (*CopyFileResponse) ProtoMessage()

func (*CopyFileResponse) ProtoReflect 

func (x *CopyFileResponse) ProtoReflect() protoreflect.Message

func (*CopyFileResponse) Reset 

func (x *CopyFileResponse) Reset()

func (*CopyFileResponse) String 

func (x *CopyFileResponse) String() string

type DeleteCollectionRequest 

type DeleteCollectionRequest struct {
	Collection string `protobuf:"bytes,1,opt,name=collection,proto3" json:"collection,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteCollectionRequest) Descriptor deprecated 

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

Deprecated: Use DeleteCollectionRequest.ProtoReflect.Descriptor instead.

func (*DeleteCollectionRequest) GetCollection 

func (x *DeleteCollectionRequest) GetCollection() string

func (*DeleteCollectionRequest) ProtoMessage 

func (*DeleteCollectionRequest) ProtoMessage()

func (*DeleteCollectionRequest) ProtoReflect 

func (x *DeleteCollectionRequest) ProtoReflect() protoreflect.Message

func (*DeleteCollectionRequest) Reset 

func (x *DeleteCollectionRequest) Reset()

func (*DeleteCollectionRequest) String 

func (x *DeleteCollectionRequest) String() string

type DeleteCollectionResponse 

type DeleteCollectionResponse struct {
	// contains filtered or unexported fields
}

func (*DeleteCollectionResponse) Descriptor deprecated 

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

Deprecated: Use DeleteCollectionResponse.ProtoReflect.Descriptor instead.

func (*DeleteCollectionResponse) ProtoMessage 

func (*DeleteCollectionResponse) ProtoMessage()

func (*DeleteCollectionResponse) ProtoReflect 

func (x *DeleteCollectionResponse) ProtoReflect() protoreflect.Message

func (*DeleteCollectionResponse) Reset 

func (x *DeleteCollectionResponse) Reset()

func (*DeleteCollectionResponse) String 

func (x *DeleteCollectionResponse) String() string

type DeleteResult 

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

func (*DeleteResult) Descriptor deprecated 

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

Deprecated: Use DeleteResult.ProtoReflect.Descriptor instead.

func (*DeleteResult) GetError 

func (x *DeleteResult) GetError() string

func (*DeleteResult) GetFileId 

func (x *DeleteResult) GetFileId() string

func (*DeleteResult) GetSize 

func (x *DeleteResult) GetSize() uint32

func (*DeleteResult) GetStatus 

func (x *DeleteResult) GetStatus() int32

func (*DeleteResult) GetVersion 

func (x *DeleteResult) GetVersion() uint32

func (*DeleteResult) ProtoMessage 

func (*DeleteResult) ProtoMessage()

func (*DeleteResult) ProtoReflect 

func (x *DeleteResult) ProtoReflect() protoreflect.Message

func (*DeleteResult) Reset 

func (x *DeleteResult) Reset()

func (*DeleteResult) String 

func (x *DeleteResult) String() string

type DiskStatus 

type DiskStatus struct {
	Dir         string  `protobuf:"bytes,1,opt,name=dir,proto3" json:"dir,omitempty"`
	All         uint64  `protobuf:"varint,2,opt,name=all,proto3" json:"all,omitempty"`
	Used        uint64  `protobuf:"varint,3,opt,name=used,proto3" json:"used,omitempty"`
	Free        uint64  `protobuf:"varint,4,opt,name=free,proto3" json:"free,omitempty"`
	PercentFree float32 `protobuf:"fixed32,5,opt,name=percent_free,json=percentFree,proto3" json:"percent_free,omitempty"`
	PercentUsed float32 `protobuf:"fixed32,6,opt,name=percent_used,json=percentUsed,proto3" json:"percent_used,omitempty"`
	// contains filtered or unexported fields
}

func (*DiskStatus) Descriptor deprecated 

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

Deprecated: Use DiskStatus.ProtoReflect.Descriptor instead.

func (*DiskStatus) GetAll 

func (x *DiskStatus) GetAll() uint64

func (*DiskStatus) GetDir 

func (x *DiskStatus) GetDir() string

func (*DiskStatus) GetFree 

func (x *DiskStatus) GetFree() uint64

func (*DiskStatus) GetPercentFree 

func (x *DiskStatus) GetPercentFree() float32

func (*DiskStatus) GetPercentUsed 

func (x *DiskStatus) GetPercentUsed() float32

func (*DiskStatus) GetUsed 

func (x *DiskStatus) GetUsed() uint64

func (*DiskStatus) ProtoMessage 

func (*DiskStatus) ProtoMessage()

func (*DiskStatus) ProtoReflect 

func (x *DiskStatus) ProtoReflect() protoreflect.Message

func (*DiskStatus) Reset 

func (x *DiskStatus) Reset()

func (*DiskStatus) String 

func (x *DiskStatus) String() string

type Empty 

type Empty struct {
	// contains filtered or unexported fields
}

func (*Empty) Descriptor deprecated 

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

Deprecated: Use Empty.ProtoReflect.Descriptor instead.

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) ProtoReflect 

func (x *Empty) ProtoReflect() protoreflect.Message

func (*Empty) Reset 

func (x *Empty) Reset()

func (*Empty) String 

func (x *Empty) String() string

type MemStatus 

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

func (*MemStatus) Descriptor deprecated 

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

Deprecated: Use MemStatus.ProtoReflect.Descriptor instead.

func (*MemStatus) GetAll 

func (x *MemStatus) GetAll() uint64

func (*MemStatus) GetFree 

func (x *MemStatus) GetFree() uint64

func (*MemStatus) GetGoroutines 

func (x *MemStatus) GetGoroutines() int32

func (*MemStatus) GetHeap 

func (x *MemStatus) GetHeap() uint64

func (*MemStatus) GetSelf 

func (x *MemStatus) GetSelf() uint64

func (*MemStatus) GetStack 

func (x *MemStatus) GetStack() uint64

func (*MemStatus) GetUsed 

func (x *MemStatus) GetUsed() uint64

func (*MemStatus) ProtoMessage 

func (*MemStatus) ProtoMessage()

func (*MemStatus) ProtoReflect 

func (x *MemStatus) ProtoReflect() protoreflect.Message

func (*MemStatus) Reset 

func (x *MemStatus) Reset()

func (*MemStatus) String 

func (x *MemStatus) String() string

type QueriedStripe 

type QueriedStripe struct {
	Records []byte `protobuf:"bytes,1,opt,name=records,proto3" json:"records,omitempty"`
	// contains filtered or unexported fields
}

func (*QueriedStripe) Descriptor deprecated 

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

Deprecated: Use QueriedStripe.ProtoReflect.Descriptor instead.

func (*QueriedStripe) GetRecords 

func (x *QueriedStripe) GetRecords() []byte

func (*QueriedStripe) ProtoMessage 

func (*QueriedStripe) ProtoMessage()

func (*QueriedStripe) ProtoReflect 

func (x *QueriedStripe) ProtoReflect() protoreflect.Message

func (*QueriedStripe) Reset 

func (x *QueriedStripe) Reset()

func (*QueriedStripe) String 

func (x *QueriedStripe) String() string

type QueryRequest 

type QueryRequest struct {
	Selections          []string                          `protobuf:"bytes,1,rep,name=selections,proto3" json:"selections,omitempty"`
	FromFileIds         []string                          `protobuf:"bytes,2,rep,name=from_file_ids,json=fromFileIds,proto3" json:"from_file_ids,omitempty"`
	Filter              *QueryRequest_Filter              `protobuf:"bytes,3,opt,name=filter,proto3" json:"filter,omitempty"`
	InputSerialization  *QueryRequest_InputSerialization  `protobuf:"bytes,4,opt,name=input_serialization,json=inputSerialization,proto3" json:"input_serialization,omitempty"`
	OutputSerialization *QueryRequest_OutputSerialization `protobuf:"bytes,5,opt,name=output_serialization,json=outputSerialization,proto3" json:"output_serialization,omitempty"`
	// contains filtered or unexported fields
}

select on volume servers

func (*QueryRequest) Descriptor deprecated 

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

Deprecated: Use QueryRequest.ProtoReflect.Descriptor instead.

func (*QueryRequest) GetFilter 

func (x *QueryRequest) GetFilter() *QueryRequest_Filter

func (*QueryRequest) GetFromFileIds 

func (x *QueryRequest) GetFromFileIds() []string

func (*QueryRequest) GetInputSerialization 

func (x *QueryRequest) GetInputSerialization() *QueryRequest_InputSerialization

func (*QueryRequest) GetOutputSerialization 

func (x *QueryRequest) GetOutputSerialization() *QueryRequest_OutputSerialization

func (*QueryRequest) GetSelections 

func (x *QueryRequest) GetSelections() []string

func (*QueryRequest) ProtoMessage 

func (*QueryRequest) ProtoMessage()

func (*QueryRequest) ProtoReflect 

func (x *QueryRequest) ProtoReflect() protoreflect.Message

func (*QueryRequest) Reset 

func (x *QueryRequest) Reset()

func (*QueryRequest) String 

func (x *QueryRequest) String() string

type QueryRequest_Filter 

type QueryRequest_Filter struct {
	Field   string `protobuf:"bytes,1,opt,name=field,proto3" json:"field,omitempty"`
	Operand string `protobuf:"bytes,2,opt,name=operand,proto3" json:"operand,omitempty"`
	Value   string `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryRequest_Filter) Descriptor deprecated 

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

Deprecated: Use QueryRequest_Filter.ProtoReflect.Descriptor instead.

func (*QueryRequest_Filter) GetField 

func (x *QueryRequest_Filter) GetField() string

func (*QueryRequest_Filter) GetOperand 

func (x *QueryRequest_Filter) GetOperand() string

func (*QueryRequest_Filter) GetValue 

func (x *QueryRequest_Filter) GetValue() string

func (*QueryRequest_Filter) ProtoMessage 

func (*QueryRequest_Filter) ProtoMessage()

func (*QueryRequest_Filter) ProtoReflect 

func (x *QueryRequest_Filter) ProtoReflect() protoreflect.Message

func (*QueryRequest_Filter) Reset 

func (x *QueryRequest_Filter) Reset()

func (*QueryRequest_Filter) String 

func (x *QueryRequest_Filter) String() string

type QueryRequest_InputSerialization 

type QueryRequest_InputSerialization struct {

	// NONE | GZIP | BZIP2
	CompressionType string                                        `protobuf:"bytes,1,opt,name=compression_type,json=compressionType,proto3" json:"compression_type,omitempty"`
	CsvInput        *QueryRequest_InputSerialization_CSVInput     `protobuf:"bytes,2,opt,name=csv_input,json=csvInput,proto3" json:"csv_input,omitempty"`
	JsonInput       *QueryRequest_InputSerialization_JSONInput    `protobuf:"bytes,3,opt,name=json_input,json=jsonInput,proto3" json:"json_input,omitempty"`
	ParquetInput    *QueryRequest_InputSerialization_ParquetInput `protobuf:"bytes,4,opt,name=parquet_input,json=parquetInput,proto3" json:"parquet_input,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryRequest_InputSerialization) Descriptor deprecated 

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

Deprecated: Use QueryRequest_InputSerialization.ProtoReflect.Descriptor instead.

func (*QueryRequest_InputSerialization) GetCompressionType 

func (x *QueryRequest_InputSerialization) GetCompressionType() string

func (*QueryRequest_InputSerialization) GetCsvInput 

func (x *QueryRequest_InputSerialization) GetCsvInput() *QueryRequest_InputSerialization_CSVInput

func (*QueryRequest_InputSerialization) GetJsonInput 

func (x *QueryRequest_InputSerialization) GetJsonInput() *QueryRequest_InputSerialization_JSONInput

func (*QueryRequest_InputSerialization) GetParquetInput 

func (x *QueryRequest_InputSerialization) GetParquetInput() *QueryRequest_InputSerialization_ParquetInput

func (*QueryRequest_InputSerialization) ProtoMessage 

func (*QueryRequest_InputSerialization) ProtoMessage()

func (*QueryRequest_InputSerialization) ProtoReflect 

func (x *QueryRequest_InputSerialization) ProtoReflect() protoreflect.Message

func (*QueryRequest_InputSerialization) Reset 

func (x *QueryRequest_InputSerialization) Reset()

func (*QueryRequest_InputSerialization) String 

func (x *QueryRequest_InputSerialization) String() string

type QueryRequest_InputSerialization_CSVInput 

type QueryRequest_InputSerialization_CSVInput struct {
	FileHeaderInfo       string `protobuf:"bytes,1,opt,name=file_header_info,json=fileHeaderInfo,proto3" json:"file_header_info,omitempty"`                   // Valid values: NONE | USE | IGNORE
	RecordDelimiter      string `protobuf:"bytes,2,opt,name=record_delimiter,json=recordDelimiter,proto3" json:"record_delimiter,omitempty"`                  // Default: \n
	FieldDelimiter       string `protobuf:"bytes,3,opt,name=field_delimiter,json=fieldDelimiter,proto3" json:"field_delimiter,omitempty"`                     // Default: ,
	QuoteCharactoer      string `protobuf:"bytes,4,opt,name=quote_charactoer,json=quoteCharactoer,proto3" json:"quote_charactoer,omitempty"`                  // Default: "
	QuoteEscapeCharacter string `protobuf:"bytes,5,opt,name=quote_escape_character,json=quoteEscapeCharacter,proto3" json:"quote_escape_character,omitempty"` // Default: "
	Comments             string `protobuf:"bytes,6,opt,name=comments,proto3" json:"comments,omitempty"`                                                       // Default: #
	// If true, records might contain record delimiters within quote characters
	AllowQuotedRecordDelimiter bool `` // default False.
	/* 144-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*QueryRequest_InputSerialization_CSVInput) Descriptor deprecated 

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

Deprecated: Use QueryRequest_InputSerialization_CSVInput.ProtoReflect.Descriptor instead.

func (*QueryRequest_InputSerialization_CSVInput) GetAllowQuotedRecordDelimiter 

func (x *QueryRequest_InputSerialization_CSVInput) GetAllowQuotedRecordDelimiter() bool

func (*QueryRequest_InputSerialization_CSVInput) GetComments 

func (x *QueryRequest_InputSerialization_CSVInput) GetComments() string

func (*QueryRequest_InputSerialization_CSVInput) GetFieldDelimiter 

func (x *QueryRequest_InputSerialization_CSVInput) GetFieldDelimiter() string

func (*QueryRequest_InputSerialization_CSVInput) GetFileHeaderInfo 

func (x *QueryRequest_InputSerialization_CSVInput) GetFileHeaderInfo() string

func (*QueryRequest_InputSerialization_CSVInput) GetQuoteCharactoer 

func (x *QueryRequest_InputSerialization_CSVInput) GetQuoteCharactoer() string

func (*QueryRequest_InputSerialization_CSVInput) GetQuoteEscapeCharacter 

func (x *QueryRequest_InputSerialization_CSVInput) GetQuoteEscapeCharacter() string

func (*QueryRequest_InputSerialization_CSVInput) GetRecordDelimiter 

func (x *QueryRequest_InputSerialization_CSVInput) GetRecordDelimiter() string

func (*QueryRequest_InputSerialization_CSVInput) ProtoMessage 

func (*QueryRequest_InputSerialization_CSVInput) ProtoMessage()

func (*QueryRequest_InputSerialization_CSVInput) ProtoReflect 

func (x *QueryRequest_InputSerialization_CSVInput) ProtoReflect() protoreflect.Message

func (*QueryRequest_InputSerialization_CSVInput) Reset 

func (x *QueryRequest_InputSerialization_CSVInput) Reset()

func (*QueryRequest_InputSerialization_CSVInput) String 

func (x *QueryRequest_InputSerialization_CSVInput) String() string

type QueryRequest_InputSerialization_JSONInput 

type QueryRequest_InputSerialization_JSONInput struct {
	Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"` // Valid values: DOCUMENT | LINES
	// contains filtered or unexported fields
}

func (*QueryRequest_InputSerialization_JSONInput) Descriptor deprecated 

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

Deprecated: Use QueryRequest_InputSerialization_JSONInput.ProtoReflect.Descriptor instead.

func (*QueryRequest_InputSerialization_JSONInput) GetType 

func (x *QueryRequest_InputSerialization_JSONInput) GetType() string

func (*QueryRequest_InputSerialization_JSONInput) ProtoMessage 

func (*QueryRequest_InputSerialization_JSONInput) ProtoMessage()

func (*QueryRequest_InputSerialization_JSONInput) ProtoReflect 

func (x *QueryRequest_InputSerialization_JSONInput) ProtoReflect() protoreflect.Message

func (*QueryRequest_InputSerialization_JSONInput) Reset 

func (x *QueryRequest_InputSerialization_JSONInput) Reset()

func (*QueryRequest_InputSerialization_JSONInput) String 

func (x *QueryRequest_InputSerialization_JSONInput) String() string

type QueryRequest_InputSerialization_ParquetInput 

type QueryRequest_InputSerialization_ParquetInput struct {
	// contains filtered or unexported fields
}

func (*QueryRequest_InputSerialization_ParquetInput) Descriptor deprecated 

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

Deprecated: Use QueryRequest_InputSerialization_ParquetInput.ProtoReflect.Descriptor instead.

func (*QueryRequest_InputSerialization_ParquetInput) ProtoMessage 

func (*QueryRequest_InputSerialization_ParquetInput) ProtoMessage()

func (*QueryRequest_InputSerialization_ParquetInput) ProtoReflect 

func (x *QueryRequest_InputSerialization_ParquetInput) ProtoReflect() protoreflect.Message

func (*QueryRequest_InputSerialization_ParquetInput) Reset 

func (x *QueryRequest_InputSerialization_ParquetInput) Reset()

func (*QueryRequest_InputSerialization_ParquetInput) String 

func (x *QueryRequest_InputSerialization_ParquetInput) String() string

type QueryRequest_OutputSerialization 

type QueryRequest_OutputSerialization struct {
	CsvOutput  *QueryRequest_OutputSerialization_CSVOutput  `protobuf:"bytes,2,opt,name=csv_output,json=csvOutput,proto3" json:"csv_output,omitempty"`
	JsonOutput *QueryRequest_OutputSerialization_JSONOutput `protobuf:"bytes,3,opt,name=json_output,json=jsonOutput,proto3" json:"json_output,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryRequest_OutputSerialization) Descriptor deprecated 

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

Deprecated: Use QueryRequest_OutputSerialization.ProtoReflect.Descriptor instead.

func (*QueryRequest_OutputSerialization) GetCsvOutput 

func (x *QueryRequest_OutputSerialization) GetCsvOutput() *QueryRequest_OutputSerialization_CSVOutput

func (*QueryRequest_OutputSerialization) GetJsonOutput 

func (x *QueryRequest_OutputSerialization) GetJsonOutput() *QueryRequest_OutputSerialization_JSONOutput

func (*QueryRequest_OutputSerialization) ProtoMessage 

func (*QueryRequest_OutputSerialization) ProtoMessage()

func (*QueryRequest_OutputSerialization) ProtoReflect 

func (x *QueryRequest_OutputSerialization) ProtoReflect() protoreflect.Message

func (*QueryRequest_OutputSerialization) Reset 

func (x *QueryRequest_OutputSerialization) Reset()

func (*QueryRequest_OutputSerialization) String 

func (x *QueryRequest_OutputSerialization) String() string

type QueryRequest_OutputSerialization_CSVOutput 

type QueryRequest_OutputSerialization_CSVOutput struct {
	QuoteFields          string `protobuf:"bytes,1,opt,name=quote_fields,json=quoteFields,proto3" json:"quote_fields,omitempty"`                              // Valid values: ALWAYS | ASNEEDED
	RecordDelimiter      string `protobuf:"bytes,2,opt,name=record_delimiter,json=recordDelimiter,proto3" json:"record_delimiter,omitempty"`                  // Default: \n
	FieldDelimiter       string `protobuf:"bytes,3,opt,name=field_delimiter,json=fieldDelimiter,proto3" json:"field_delimiter,omitempty"`                     // Default: ,
	QuoteCharactoer      string `protobuf:"bytes,4,opt,name=quote_charactoer,json=quoteCharactoer,proto3" json:"quote_charactoer,omitempty"`                  // Default: "
	QuoteEscapeCharacter string `protobuf:"bytes,5,opt,name=quote_escape_character,json=quoteEscapeCharacter,proto3" json:"quote_escape_character,omitempty"` // Default: "
	// contains filtered or unexported fields
}

func (*QueryRequest_OutputSerialization_CSVOutput) Descriptor deprecated 

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

Deprecated: Use QueryRequest_OutputSerialization_CSVOutput.ProtoReflect.Descriptor instead.

func (*QueryRequest_OutputSerialization_CSVOutput) GetFieldDelimiter 

func (x *QueryRequest_OutputSerialization_CSVOutput) GetFieldDelimiter() string

func (*QueryRequest_OutputSerialization_CSVOutput) GetQuoteCharactoer 

func (x *QueryRequest_OutputSerialization_CSVOutput) GetQuoteCharactoer() string

func (*QueryRequest_OutputSerialization_CSVOutput) GetQuoteEscapeCharacter 

func (x *QueryRequest_OutputSerialization_CSVOutput) GetQuoteEscapeCharacter() string

func (*QueryRequest_OutputSerialization_CSVOutput) GetQuoteFields 

func (x *QueryRequest_OutputSerialization_CSVOutput) GetQuoteFields() string

func (*QueryRequest_OutputSerialization_CSVOutput) GetRecordDelimiter 

func (x *QueryRequest_OutputSerialization_CSVOutput) GetRecordDelimiter() string

func (*QueryRequest_OutputSerialization_CSVOutput) ProtoMessage 

func (*QueryRequest_OutputSerialization_CSVOutput) ProtoMessage()

func (*QueryRequest_OutputSerialization_CSVOutput) ProtoReflect 

func (x *QueryRequest_OutputSerialization_CSVOutput) ProtoReflect() protoreflect.Message

func (*QueryRequest_OutputSerialization_CSVOutput) Reset 

func (x *QueryRequest_OutputSerialization_CSVOutput) Reset()

func (*QueryRequest_OutputSerialization_CSVOutput) String 

func (x *QueryRequest_OutputSerialization_CSVOutput) String() string

type QueryRequest_OutputSerialization_JSONOutput 

type QueryRequest_OutputSerialization_JSONOutput struct {
	RecordDelimiter string `protobuf:"bytes,1,opt,name=record_delimiter,json=recordDelimiter,proto3" json:"record_delimiter,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryRequest_OutputSerialization_JSONOutput) Descriptor deprecated 

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

Deprecated: Use QueryRequest_OutputSerialization_JSONOutput.ProtoReflect.Descriptor instead.

func (*QueryRequest_OutputSerialization_JSONOutput) GetRecordDelimiter 

func (x *QueryRequest_OutputSerialization_JSONOutput) GetRecordDelimiter() string

func (*QueryRequest_OutputSerialization_JSONOutput) ProtoMessage 

func (*QueryRequest_OutputSerialization_JSONOutput) ProtoMessage()

func (*QueryRequest_OutputSerialization_JSONOutput) ProtoReflect 

func (x *QueryRequest_OutputSerialization_JSONOutput) ProtoReflect() protoreflect.Message

func (*QueryRequest_OutputSerialization_JSONOutput) Reset 

func (x *QueryRequest_OutputSerialization_JSONOutput) Reset()

func (*QueryRequest_OutputSerialization_JSONOutput) String 

func (x *QueryRequest_OutputSerialization_JSONOutput) String() string

type ReadVolumeFileStatusRequest 

type ReadVolumeFileStatusRequest struct {
	VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId,proto3" json:"volume_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadVolumeFileStatusRequest) Descriptor deprecated 

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

Deprecated: Use ReadVolumeFileStatusRequest.ProtoReflect.Descriptor instead.

func (*ReadVolumeFileStatusRequest) GetVolumeId 

func (x *ReadVolumeFileStatusRequest) GetVolumeId() uint32

func (*ReadVolumeFileStatusRequest) ProtoMessage 

func (*ReadVolumeFileStatusRequest) ProtoMessage()

func (*ReadVolumeFileStatusRequest) ProtoReflect 

func (x *ReadVolumeFileStatusRequest) ProtoReflect() protoreflect.Message

func (*ReadVolumeFileStatusRequest) Reset 

func (x *ReadVolumeFileStatusRequest) Reset()

func (*ReadVolumeFileStatusRequest) String 

func (x *ReadVolumeFileStatusRequest) String() string

type ReadVolumeFileStatusResponse 

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

func (*ReadVolumeFileStatusResponse) Descriptor deprecated 

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

Deprecated: Use ReadVolumeFileStatusResponse.ProtoReflect.Descriptor instead.

func (*ReadVolumeFileStatusResponse) GetCollection 

func (x *ReadVolumeFileStatusResponse) GetCollection() string

func (*ReadVolumeFileStatusResponse) GetCompactionRevision 

func (x *ReadVolumeFileStatusResponse) GetCompactionRevision() uint32

func (*ReadVolumeFileStatusResponse) GetDatFileSize 

func (x *ReadVolumeFileStatusResponse) GetDatFileSize() uint64

func (*ReadVolumeFileStatusResponse) GetDatFileTimestampSeconds 

func (x *ReadVolumeFileStatusResponse) GetDatFileTimestampSeconds() uint64

func (*ReadVolumeFileStatusResponse) GetFileCount 

func (x *ReadVolumeFileStatusResponse) GetFileCount() uint64

func (*ReadVolumeFileStatusResponse) GetIdxFileSize 

func (x *ReadVolumeFileStatusResponse) GetIdxFileSize() uint64

func (*ReadVolumeFileStatusResponse) GetIdxFileTimestampSeconds 

func (x *ReadVolumeFileStatusResponse) GetIdxFileTimestampSeconds() uint64

func (*ReadVolumeFileStatusResponse) GetVolumeId 

func (x *ReadVolumeFileStatusResponse) GetVolumeId() uint32

func (*ReadVolumeFileStatusResponse) ProtoMessage 

func (*ReadVolumeFileStatusResponse) ProtoMessage()

func (*ReadVolumeFileStatusResponse) ProtoReflect 

func (x *ReadVolumeFileStatusResponse) ProtoReflect() protoreflect.Message

func (*ReadVolumeFileStatusResponse) Reset 

func (x *ReadVolumeFileStatusResponse) Reset()

func (*ReadVolumeFileStatusResponse) String 

func (x *ReadVolumeFileStatusResponse) String() string

type RemoteFile 

type RemoteFile struct {
	BackendType  string `protobuf:"bytes,1,opt,name=backend_type,json=backendType,proto3" json:"backend_type,omitempty"`
	BackendId    string `protobuf:"bytes,2,opt,name=backend_id,json=backendId,proto3" json:"backend_id,omitempty"`
	Key          string `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	Offset       uint64 `protobuf:"varint,4,opt,name=offset,proto3" json:"offset,omitempty"`
	FileSize     uint64 `protobuf:"varint,5,opt,name=file_size,json=fileSize,proto3" json:"file_size,omitempty"`
	ModifiedTime uint64 `protobuf:"varint,6,opt,name=modified_time,json=modifiedTime,proto3" json:"modified_time,omitempty"`
	Extension    string `protobuf:"bytes,7,opt,name=extension,proto3" json:"extension,omitempty"`
	// contains filtered or unexported fields
}

tired storage on volume servers

func (*RemoteFile) BackendName 

func (m *RemoteFile) BackendName() string

func (*RemoteFile) Descriptor deprecated 

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

Deprecated: Use RemoteFile.ProtoReflect.Descriptor instead.

func (*RemoteFile) GetBackendId 

func (x *RemoteFile) GetBackendId() string

func (*RemoteFile) GetBackendType 

func (x *RemoteFile) GetBackendType() string

func (*RemoteFile) GetExtension 

func (x *RemoteFile) GetExtension() string

func (*RemoteFile) GetFileSize 

func (x *RemoteFile) GetFileSize() uint64

func (*RemoteFile) GetKey 

func (x *RemoteFile) GetKey() string

func (*RemoteFile) GetModifiedTime 

func (x *RemoteFile) GetModifiedTime() uint64

func (*RemoteFile) GetOffset 

func (x *RemoteFile) GetOffset() uint64

func (*RemoteFile) ProtoMessage 

func (*RemoteFile) ProtoMessage()

func (*RemoteFile) ProtoReflect 

func (x *RemoteFile) ProtoReflect() protoreflect.Message

func (*RemoteFile) Reset 

func (x *RemoteFile) Reset()

func (*RemoteFile) String 

func (x *RemoteFile) String() string

type UnimplementedVolumeServerServer 

type UnimplementedVolumeServerServer struct {
}

UnimplementedVolumeServerServer can be embedded to have forward compatible implementations.

func (*UnimplementedVolumeServerServer) AllocateVolume 

func (*UnimplementedVolumeServerServer) AllocateVolume(context.Context, *AllocateVolumeRequest) (*AllocateVolumeResponse, error)

func (*UnimplementedVolumeServerServer) BatchDelete 

func (*UnimplementedVolumeServerServer) BatchDelete(context.Context, *BatchDeleteRequest) (*BatchDeleteResponse, error)

func (*UnimplementedVolumeServerServer) CopyFile 

func (*UnimplementedVolumeServerServer) CopyFile(*CopyFileRequest, VolumeServer_CopyFileServer) error

func (*UnimplementedVolumeServerServer) DeleteCollection 

func (*UnimplementedVolumeServerServer) DeleteCollection(context.Context, *DeleteCollectionRequest) (*DeleteCollectionResponse, error)

func (*UnimplementedVolumeServerServer) Query 

func (*UnimplementedVolumeServerServer) Query(*QueryRequest, VolumeServer_QueryServer) error

func (*UnimplementedVolumeServerServer) ReadVolumeFileStatus 

func (*UnimplementedVolumeServerServer) ReadVolumeFileStatus(context.Context, *ReadVolumeFileStatusRequest) (*ReadVolumeFileStatusResponse, error)

func (*UnimplementedVolumeServerServer) VacuumVolumeCheck 

func (*UnimplementedVolumeServerServer) VacuumVolumeCheck(context.Context, *VacuumVolumeCheckRequest) (*VacuumVolumeCheckResponse, error)

func (*UnimplementedVolumeServerServer) VacuumVolumeCleanup 

func (*UnimplementedVolumeServerServer) VacuumVolumeCleanup(context.Context, *VacuumVolumeCleanupRequest) (*VacuumVolumeCleanupResponse, error)

func (*UnimplementedVolumeServerServer) VacuumVolumeCommit 

func (*UnimplementedVolumeServerServer) VacuumVolumeCommit(context.Context, *VacuumVolumeCommitRequest) (*VacuumVolumeCommitResponse, error)

func (*UnimplementedVolumeServerServer) VacuumVolumeCompact 

func (*UnimplementedVolumeServerServer) VacuumVolumeCompact(context.Context, *VacuumVolumeCompactRequest) (*VacuumVolumeCompactResponse, error)

func (*UnimplementedVolumeServerServer) VolumeConfigure 

func (*UnimplementedVolumeServerServer) VolumeConfigure(context.Context, *VolumeConfigureRequest) (*VolumeConfigureResponse, error)

func (*UnimplementedVolumeServerServer) VolumeCopy 

func (*UnimplementedVolumeServerServer) VolumeCopy(context.Context, *VolumeCopyRequest) (*VolumeCopyResponse, error)

func (*UnimplementedVolumeServerServer) VolumeDelete 

func (*UnimplementedVolumeServerServer) VolumeDelete(context.Context, *VolumeDeleteRequest) (*VolumeDeleteResponse, error)

func (*UnimplementedVolumeServerServer) VolumeEcBlobDelete 

func (*UnimplementedVolumeServerServer) VolumeEcBlobDelete(context.Context, *VolumeEcBlobDeleteRequest) (*VolumeEcBlobDeleteResponse, error)

func (*UnimplementedVolumeServerServer) VolumeEcShardRead 

func (*UnimplementedVolumeServerServer) VolumeEcShardRead(*VolumeEcShardReadRequest, VolumeServer_VolumeEcShardReadServer) error

func (*UnimplementedVolumeServerServer) VolumeEcShardsCopy 

func (*UnimplementedVolumeServerServer) VolumeEcShardsCopy(context.Context, *VolumeEcShardsCopyRequest) (*VolumeEcShardsCopyResponse, error)

func (*UnimplementedVolumeServerServer) VolumeEcShardsDelete 

func (*UnimplementedVolumeServerServer) VolumeEcShardsDelete(context.Context, *VolumeEcShardsDeleteRequest) (*VolumeEcShardsDeleteResponse, error)

func (*UnimplementedVolumeServerServer) VolumeEcShardsGenerate 

func (*UnimplementedVolumeServerServer) VolumeEcShardsGenerate(context.Context, *VolumeEcShardsGenerateRequest) (*VolumeEcShardsGenerateResponse, error)

func (*UnimplementedVolumeServerServer) VolumeEcShardsMount 

func (*UnimplementedVolumeServerServer) VolumeEcShardsMount(context.Context, *VolumeEcShardsMountRequest) (*VolumeEcShardsMountResponse, error)

func (*UnimplementedVolumeServerServer) VolumeEcShardsRebuild 

func (*UnimplementedVolumeServerServer) VolumeEcShardsRebuild(context.Context, *VolumeEcShardsRebuildRequest) (*VolumeEcShardsRebuildResponse, error)

func (*UnimplementedVolumeServerServer) VolumeEcShardsToVolume 

func (*UnimplementedVolumeServerServer) VolumeEcShardsToVolume(context.Context, *VolumeEcShardsToVolumeRequest) (*VolumeEcShardsToVolumeResponse, error)

func (*UnimplementedVolumeServerServer) VolumeEcShardsUnmount 

func (*UnimplementedVolumeServerServer) VolumeEcShardsUnmount(context.Context, *VolumeEcShardsUnmountRequest) (*VolumeEcShardsUnmountResponse, error)

func (*UnimplementedVolumeServerServer) VolumeIncrementalCopy 

func (*UnimplementedVolumeServerServer) VolumeIncrementalCopy(*VolumeIncrementalCopyRequest, VolumeServer_VolumeIncrementalCopyServer) error

func (*UnimplementedVolumeServerServer) VolumeMarkReadonly 

func (*UnimplementedVolumeServerServer) VolumeMarkReadonly(context.Context, *VolumeMarkReadonlyRequest) (*VolumeMarkReadonlyResponse, error)

func (*UnimplementedVolumeServerServer) VolumeMarkWritable 

func (*UnimplementedVolumeServerServer) VolumeMarkWritable(context.Context, *VolumeMarkWritableRequest) (*VolumeMarkWritableResponse, error)

func (*UnimplementedVolumeServerServer) VolumeMount 

func (*UnimplementedVolumeServerServer) VolumeMount(context.Context, *VolumeMountRequest) (*VolumeMountResponse, error)

func (*UnimplementedVolumeServerServer) VolumeNeedleStatus 

func (*UnimplementedVolumeServerServer) VolumeNeedleStatus(context.Context, *VolumeNeedleStatusRequest) (*VolumeNeedleStatusResponse, error)

func (*UnimplementedVolumeServerServer) VolumeServerLeave 

func (*UnimplementedVolumeServerServer) VolumeServerLeave(context.Context, *VolumeServerLeaveRequest) (*VolumeServerLeaveResponse, error)

func (*UnimplementedVolumeServerServer) VolumeServerStatus 

func (*UnimplementedVolumeServerServer) VolumeServerStatus(context.Context, *VolumeServerStatusRequest) (*VolumeServerStatusResponse, error)

func (*UnimplementedVolumeServerServer) VolumeStatus 

func (*UnimplementedVolumeServerServer) VolumeStatus(context.Context, *VolumeStatusRequest) (*VolumeStatusResponse, error)

func (*UnimplementedVolumeServerServer) VolumeSyncStatus 

func (*UnimplementedVolumeServerServer) VolumeSyncStatus(context.Context, *VolumeSyncStatusRequest) (*VolumeSyncStatusResponse, error)

func (*UnimplementedVolumeServerServer) VolumeTailReceiver 

func (*UnimplementedVolumeServerServer) VolumeTailReceiver(context.Context, *VolumeTailReceiverRequest) (*VolumeTailReceiverResponse, error)

func (*UnimplementedVolumeServerServer) VolumeTailSender 

func (*UnimplementedVolumeServerServer) VolumeTailSender(*VolumeTailSenderRequest, VolumeServer_VolumeTailSenderServer) error

func (*UnimplementedVolumeServerServer) VolumeTierMoveDatFromRemote 

func (*UnimplementedVolumeServerServer) VolumeTierMoveDatFromRemote(*VolumeTierMoveDatFromRemoteRequest, VolumeServer_VolumeTierMoveDatFromRemoteServer) error

func (*UnimplementedVolumeServerServer) VolumeTierMoveDatToRemote 

func (*UnimplementedVolumeServerServer) VolumeTierMoveDatToRemote(*VolumeTierMoveDatToRemoteRequest, VolumeServer_VolumeTierMoveDatToRemoteServer) error

func (*UnimplementedVolumeServerServer) VolumeUnmount 

func (*UnimplementedVolumeServerServer) VolumeUnmount(context.Context, *VolumeUnmountRequest) (*VolumeUnmountResponse, error)

type VacuumVolumeCheckRequest 

type VacuumVolumeCheckRequest struct {
	VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId,proto3" json:"volume_id,omitempty"`
	// contains filtered or unexported fields
}

func (*VacuumVolumeCheckRequest) Descriptor deprecated 

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

Deprecated: Use VacuumVolumeCheckRequest.ProtoReflect.Descriptor instead.

func (*VacuumVolumeCheckRequest) GetVolumeId 

func (x *VacuumVolumeCheckRequest) GetVolumeId() uint32

func (*VacuumVolumeCheckRequest) ProtoMessage 

func (*VacuumVolumeCheckRequest) ProtoMessage()

func (*VacuumVolumeCheckRequest) ProtoReflect 

func (x *VacuumVolumeCheckRequest) ProtoReflect() protoreflect.Message

func (*VacuumVolumeCheckRequest) Reset 

func (x *VacuumVolumeCheckRequest) Reset()

func (*VacuumVolumeCheckRequest) String 

func (x *VacuumVolumeCheckRequest) String() string

type VacuumVolumeCheckResponse 

type VacuumVolumeCheckResponse struct {
	GarbageRatio float64 `protobuf:"fixed64,1,opt,name=garbage_ratio,json=garbageRatio,proto3" json:"garbage_ratio,omitempty"`
	// contains filtered or unexported fields
}

func (*VacuumVolumeCheckResponse) Descriptor deprecated 

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

Deprecated: Use VacuumVolumeCheckResponse.ProtoReflect.Descriptor instead.

func (*VacuumVolumeCheckResponse) GetGarbageRatio 

func (x *VacuumVolumeCheckResponse) GetGarbageRatio() float64

func (*VacuumVolumeCheckResponse) ProtoMessage 

func (*VacuumVolumeCheckResponse) ProtoMessage()

func (*VacuumVolumeCheckResponse) ProtoReflect 

func (x *VacuumVolumeCheckResponse) ProtoReflect() protoreflect.Message

func (*VacuumVolumeCheckResponse) Reset 

func (x *VacuumVolumeCheckResponse) Reset()

func (*VacuumVolumeCheckResponse) String 

func (x *VacuumVolumeCheckResponse) String() string

type VacuumVolumeCleanupRequest 

type VacuumVolumeCleanupRequest struct {
	VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId,proto3" json:"volume_id,omitempty"`
	// contains filtered or unexported fields
}

func (*VacuumVolumeCleanupRequest) Descriptor deprecated 

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

Deprecated: Use VacuumVolumeCleanupRequest.ProtoReflect.Descriptor instead.

func (*VacuumVolumeCleanupRequest) GetVolumeId 

func (x *VacuumVolumeCleanupRequest) GetVolumeId() uint32

func (*VacuumVolumeCleanupRequest) ProtoMessage 

func (*VacuumVolumeCleanupRequest) ProtoMessage()

func (*VacuumVolumeCleanupRequest) ProtoReflect 

func (x *VacuumVolumeCleanupRequest) ProtoReflect() protoreflect.Message

func (*VacuumVolumeCleanupRequest) Reset 

func (x *VacuumVolumeCleanupRequest) Reset()

func (*VacuumVolumeCleanupRequest) String 

func (x *VacuumVolumeCleanupRequest) String() string

type VacuumVolumeCleanupResponse 

type VacuumVolumeCleanupResponse struct {
	// contains filtered or unexported fields
}

func (*VacuumVolumeCleanupResponse) Descriptor deprecated 

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

Deprecated: Use VacuumVolumeCleanupResponse.ProtoReflect.Descriptor instead.

func (*VacuumVolumeCleanupResponse) ProtoMessage 

func (*VacuumVolumeCleanupResponse) ProtoMessage()

func (*VacuumVolumeCleanupResponse) ProtoReflect 

func (x *VacuumVolumeCleanupResponse) ProtoReflect() protoreflect.Message

func (*VacuumVolumeCleanupResponse) Reset 

func (x *VacuumVolumeCleanupResponse) Reset()

func (*VacuumVolumeCleanupResponse) String 

func (x *VacuumVolumeCleanupResponse) String() string

type VacuumVolumeCommitRequest 

type VacuumVolumeCommitRequest struct {
	VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId,proto3" json:"volume_id,omitempty"`
	// contains filtered or unexported fields
}

func (*VacuumVolumeCommitRequest) Descriptor deprecated 

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

Deprecated: Use VacuumVolumeCommitRequest.ProtoReflect.Descriptor instead.

func (*VacuumVolumeCommitRequest) GetVolumeId 

func (x *VacuumVolumeCommitRequest) GetVolumeId() uint32

func (*VacuumVolumeCommitRequest) ProtoMessage 

func (*VacuumVolumeCommitRequest) ProtoMessage()

func (*VacuumVolumeCommitRequest) ProtoReflect 

func (x *VacuumVolumeCommitRequest) ProtoReflect() protoreflect.Message

func (*VacuumVolumeCommitRequest) Reset 

func (x *VacuumVolumeCommitRequest) Reset()

func (*VacuumVolumeCommitRequest) String 

func (x *VacuumVolumeCommitRequest) String() string

type VacuumVolumeCommitResponse 

type VacuumVolumeCommitResponse struct {
	IsReadOnly bool `protobuf:"varint,1,opt,name=is_read_only,json=isReadOnly,proto3" json:"is_read_only,omitempty"`
	// contains filtered or unexported fields
}

func (*VacuumVolumeCommitResponse) Descriptor deprecated 

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

Deprecated: Use VacuumVolumeCommitResponse.ProtoReflect.Descriptor instead.

func (*VacuumVolumeCommitResponse) GetIsReadOnly 

func (x *VacuumVolumeCommitResponse) GetIsReadOnly() bool

func (*VacuumVolumeCommitResponse) ProtoMessage 

func (*VacuumVolumeCommitResponse) ProtoMessage()

func (*VacuumVolumeCommitResponse) ProtoReflect 

func (x *VacuumVolumeCommitResponse) ProtoReflect() protoreflect.Message

func (*VacuumVolumeCommitResponse) Reset 

func (x *VacuumVolumeCommitResponse) Reset()

func (*VacuumVolumeCommitResponse) String 

func (x *VacuumVolumeCommitResponse) String() string

type VacuumVolumeCompactRequest 

type VacuumVolumeCompactRequest struct {
	VolumeId    uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId,proto3" json:"volume_id,omitempty"`
	Preallocate int64  `protobuf:"varint,2,opt,name=preallocate,proto3" json:"preallocate,omitempty"`
	// contains filtered or unexported fields
}

func (*VacuumVolumeCompactRequest) Descriptor deprecated 

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

Deprecated: Use VacuumVolumeCompactRequest.ProtoReflect.Descriptor instead.

func (*VacuumVolumeCompactRequest) GetPreallocate 

func (x *VacuumVolumeCompactRequest) GetPreallocate() int64

func (*VacuumVolumeCompactRequest) GetVolumeId 

func (x *VacuumVolumeCompactRequest) GetVolumeId() uint32

func (*VacuumVolumeCompactRequest) ProtoMessage 

func (*VacuumVolumeCompactRequest) ProtoMessage()

func (*VacuumVolumeCompactRequest) ProtoReflect 

func (x *VacuumVolumeCompactRequest) ProtoReflect() protoreflect.Message

func (*VacuumVolumeCompactRequest) Reset 

func (x *VacuumVolumeCompactRequest) Reset()

func (*VacuumVolumeCompactRequest) String 

func (x *VacuumVolumeCompactRequest) String() string

type VacuumVolumeCompactResponse 

type VacuumVolumeCompactResponse struct {
	// contains filtered or unexported fields
}

func (*VacuumVolumeCompactResponse) Descriptor deprecated 

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

Deprecated: Use VacuumVolumeCompactResponse.ProtoReflect.Descriptor instead.

func (*VacuumVolumeCompactResponse) ProtoMessage 

func (*VacuumVolumeCompactResponse) ProtoMessage()

func (*VacuumVolumeCompactResponse) ProtoReflect 

func (x *VacuumVolumeCompactResponse) ProtoReflect() protoreflect.Message

func (*VacuumVolumeCompactResponse) Reset 

func (x *VacuumVolumeCompactResponse) Reset()

func (*VacuumVolumeCompactResponse) String 

func (x *VacuumVolumeCompactResponse) String() string

type VolumeConfigureRequest 

type VolumeConfigureRequest struct {
	VolumeId    uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId,proto3" json:"volume_id,omitempty"`
	Replication string `protobuf:"bytes,2,opt,name=replication,proto3" json:"replication,omitempty"`
	// contains filtered or unexported fields
}

func (*VolumeConfigureRequest) Descriptor deprecated 

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

Deprecated: Use VolumeConfigureRequest.ProtoReflect.Descriptor instead.

func (*VolumeConfigureRequest) GetReplication 

func (x *VolumeConfigureRequest) GetReplication() string

func (*VolumeConfigureRequest) GetVolumeId 

func (x *VolumeConfigureRequest) GetVolumeId() uint32

func (*VolumeConfigureRequest) ProtoMessage 

func (*VolumeConfigureRequest) ProtoMessage()

func (*VolumeConfigureRequest) ProtoReflect 

func (x *VolumeConfigureRequest) ProtoReflect() protoreflect.Message

func (*VolumeConfigureRequest) Reset 

func (x *VolumeConfigureRequest) Reset()

func (*VolumeConfigureRequest) String 

func (x *VolumeConfigureRequest) String() string

type VolumeConfigureResponse 

type VolumeConfigureResponse struct {
	Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*VolumeConfigureResponse) Descriptor deprecated 

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

Deprecated: Use VolumeConfigureResponse.ProtoReflect.Descriptor instead.

func (*VolumeConfigureResponse) GetError 

func (x *VolumeConfigureResponse) GetError() string

func (*VolumeConfigureResponse) ProtoMessage 

func (*VolumeConfigureResponse) ProtoMessage()

func (*VolumeConfigureResponse) ProtoReflect 

func (x *VolumeConfigureResponse) ProtoReflect() protoreflect.Message

func (*VolumeConfigureResponse) Reset 

func (x *VolumeConfigureResponse) Reset()

func (*VolumeConfigureResponse) String 

func (x *VolumeConfigureResponse) String() string

type VolumeCopyRequest 

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

func (*VolumeCopyRequest) Descriptor deprecated 

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

Deprecated: Use VolumeCopyRequest.ProtoReflect.Descriptor instead.

func (*VolumeCopyRequest) GetCollection 

func (x *VolumeCopyRequest) GetCollection() string

func (*VolumeCopyRequest) GetReplication 

func (x *VolumeCopyRequest) GetReplication() string

func (*VolumeCopyRequest) GetSourceDataNode 

func (x *VolumeCopyRequest) GetSourceDataNode() string

func (*VolumeCopyRequest) GetTtl 

func (x *VolumeCopyRequest) GetTtl() string

func (*VolumeCopyRequest) GetVolumeId 

func (x *VolumeCopyRequest) GetVolumeId() uint32

func (*VolumeCopyRequest) ProtoMessage 

func (*VolumeCopyRequest) ProtoMessage()

func (*VolumeCopyRequest) ProtoReflect 

func (x *VolumeCopyRequest) ProtoReflect() protoreflect.Message

func (*VolumeCopyRequest) Reset 

func (x *VolumeCopyRequest) Reset()

func (*VolumeCopyRequest) String 

func (x *VolumeCopyRequest) String() string

type VolumeCopyResponse 

type VolumeCopyResponse struct {
	LastAppendAtNs uint64 `protobuf:"varint,1,opt,name=last_append_at_ns,json=lastAppendAtNs,proto3" json:"last_append_at_ns,omitempty"`
	// contains filtered or unexported fields
}

func (*VolumeCopyResponse) Descriptor deprecated 

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

Deprecated: Use VolumeCopyResponse.ProtoReflect.Descriptor instead.

func (*VolumeCopyResponse) GetLastAppendAtNs 

func (x *VolumeCopyResponse) GetLastAppendAtNs() uint64

func (*VolumeCopyResponse) ProtoMessage 

func (*VolumeCopyResponse) ProtoMessage()

func (*VolumeCopyResponse) ProtoReflect 

func (x *VolumeCopyResponse) ProtoReflect() protoreflect.Message

func (*VolumeCopyResponse) Reset 

func (x *VolumeCopyResponse) Reset()

func (*VolumeCopyResponse) String 

func (x *VolumeCopyResponse) String() string

type VolumeDeleteRequest 

type VolumeDeleteRequest struct {
	VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId,proto3" json:"volume_id,omitempty"`
	// contains filtered or unexported fields
}

func (*VolumeDeleteRequest) Descriptor deprecated 

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

Deprecated: Use VolumeDeleteRequest.ProtoReflect.Descriptor instead.

func (*VolumeDeleteRequest) GetVolumeId 

func (x *VolumeDeleteRequest) GetVolumeId() uint32

func (*VolumeDeleteRequest) ProtoMessage 

func (*VolumeDeleteRequest) ProtoMessage()

func (*VolumeDeleteRequest) ProtoReflect 

func (x *VolumeDeleteRequest) ProtoReflect() protoreflect.Message

func (*VolumeDeleteRequest) Reset 

func (x *VolumeDeleteRequest) Reset()

func (*VolumeDeleteRequest) String 

func (x *VolumeDeleteRequest) String() string

type VolumeDeleteResponse 

type VolumeDeleteResponse struct {
	// contains filtered or unexported fields
}

func (*VolumeDeleteResponse) Descriptor deprecated 

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

Deprecated: Use VolumeDeleteResponse.ProtoReflect.Descriptor instead.

func (*VolumeDeleteResponse) ProtoMessage 

func (*VolumeDeleteResponse) ProtoMessage()

func (*VolumeDeleteResponse) ProtoReflect 

func (x *VolumeDeleteResponse) ProtoReflect() protoreflect.Message

func (*VolumeDeleteResponse) Reset 

func (x *VolumeDeleteResponse) Reset()

func (*VolumeDeleteResponse) String 

func (x *VolumeDeleteResponse) String() string

type VolumeEcBlobDeleteRequest 

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

func (*VolumeEcBlobDeleteRequest) Descriptor deprecated 

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

Deprecated: Use VolumeEcBlobDeleteRequest.ProtoReflect.Descriptor instead.

func (*VolumeEcBlobDeleteRequest) GetCollection 

func (x *VolumeEcBlobDeleteRequest) GetCollection() string

func (*VolumeEcBlobDeleteRequest) GetFileKey 

func (x *VolumeEcBlobDeleteRequest) GetFileKey() uint64

func (*VolumeEcBlobDeleteRequest) GetVersion 

func (x *VolumeEcBlobDeleteRequest) GetVersion() uint32

func (*VolumeEcBlobDeleteRequest) GetVolumeId 

func (x *VolumeEcBlobDeleteRequest) GetVolumeId() uint32

func (*VolumeEcBlobDeleteRequest) ProtoMessage 

func (*VolumeEcBlobDeleteRequest) ProtoMessage()

func (*VolumeEcBlobDeleteRequest) ProtoReflect 

func (x *VolumeEcBlobDeleteRequest) ProtoReflect() protoreflect.Message

func (*VolumeEcBlobDeleteRequest) Reset 

func (x *VolumeEcBlobDeleteRequest) Reset()

func (*VolumeEcBlobDeleteRequest) String 

func (x *VolumeEcBlobDeleteRequest) String() string

type VolumeEcBlobDeleteResponse 

type VolumeEcBlobDeleteResponse struct {
	// contains filtered or unexported fields
}

func (*VolumeEcBlobDeleteResponse) Descriptor deprecated 

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

Deprecated: Use VolumeEcBlobDeleteResponse.ProtoReflect.Descriptor instead.

func (*VolumeEcBlobDeleteResponse) ProtoMessage 

func (*VolumeEcBlobDeleteResponse) ProtoMessage()

func (*VolumeEcBlobDeleteResponse) ProtoReflect 

func (x *VolumeEcBlobDeleteResponse) ProtoReflect() protoreflect.Message

func (*VolumeEcBlobDeleteResponse) Reset 

func (x *VolumeEcBlobDeleteResponse) Reset()

func (*VolumeEcBlobDeleteResponse) String 

func (x *VolumeEcBlobDeleteResponse) String() string

type VolumeEcShardReadRequest 

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

func (*VolumeEcShardReadRequest) Descriptor deprecated 

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

Deprecated: Use VolumeEcShardReadRequest.ProtoReflect.Descriptor instead.

func (*VolumeEcShardReadRequest) GetFileKey 

func (x *VolumeEcShardReadRequest) GetFileKey() uint64

func (*VolumeEcShardReadRequest) GetOffset 

func (x *VolumeEcShardReadRequest) GetOffset() int64

func (*VolumeEcShardReadRequest) GetShardId 

func (x *VolumeEcShardReadRequest) GetShardId() uint32

func (*VolumeEcShardReadRequest) GetSize 

func (x *VolumeEcShardReadRequest) GetSize() int64

func (*VolumeEcShardReadRequest) GetVolumeId 

func (x *VolumeEcShardReadRequest) GetVolumeId() uint32

func (*VolumeEcShardReadRequest) ProtoMessage 

func (*VolumeEcShardReadRequest) ProtoMessage()

func (*VolumeEcShardReadRequest) ProtoReflect 

func (x *VolumeEcShardReadRequest) ProtoReflect() protoreflect.Message

func (*VolumeEcShardReadRequest) Reset 

func (x *VolumeEcShardReadRequest) Reset()

func (*VolumeEcShardReadRequest) String 

func (x *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,proto3" json:"is_deleted,omitempty"`
	// contains filtered or unexported fields
}

func (*VolumeEcShardReadResponse) Descriptor deprecated 

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

Deprecated: Use VolumeEcShardReadResponse.ProtoReflect.Descriptor instead.

func (*VolumeEcShardReadResponse) GetData 

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

func (*VolumeEcShardReadResponse) GetIsDeleted 

func (x *VolumeEcShardReadResponse) GetIsDeleted() bool

func (*VolumeEcShardReadResponse) ProtoMessage 

func (*VolumeEcShardReadResponse) ProtoMessage()

func (*VolumeEcShardReadResponse) ProtoReflect 

func (x *VolumeEcShardReadResponse) ProtoReflect() protoreflect.Message

func (*VolumeEcShardReadResponse) Reset 

func (x *VolumeEcShardReadResponse) Reset()

func (*VolumeEcShardReadResponse) String 

func (x *VolumeEcShardReadResponse) String() string

type VolumeEcShardsCopyRequest 

type VolumeEcShardsCopyRequest struct {
	VolumeId       uint32   `protobuf:"varint,1,opt,name=volume_id,json=volumeId,proto3" json:"volume_id,omitempty"`
	Collection     string   `protobuf:"bytes,2,opt,name=collection,proto3" json:"collection,omitempty"`
	ShardIds       []uint32 `protobuf:"varint,3,rep,packed,name=shard_ids,json=shardIds,proto3" json:"shard_ids,omitempty"`
	CopyEcxFile    bool     `protobuf:"varint,4,opt,name=copy_ecx_file,json=copyEcxFile,proto3" json:"copy_ecx_file,omitempty"`
	SourceDataNode string   `protobuf:"bytes,5,opt,name=source_data_node,json=sourceDataNode,proto3" json:"source_data_node,omitempty"`
	CopyEcjFile    bool     `protobuf:"varint,6,opt,name=copy_ecj_file,json=copyEcjFile,proto3" json:"copy_ecj_file,omitempty"`
	CopyVifFile    bool     `protobuf:"varint,7,opt,name=copy_vif_file,json=copyVifFile,proto3" json:"copy_vif_file,omitempty"`
	// contains filtered or unexported fields
}

func (*VolumeEcShardsCopyRequest) Descriptor deprecated 

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

Deprecated: Use VolumeEcShardsCopyRequest.ProtoReflect.Descriptor instead.

func (*VolumeEcShardsCopyRequest) GetCollection 

func (x *VolumeEcShardsCopyRequest) GetCollection() string

func (*VolumeEcShardsCopyRequest) GetCopyEcjFile 

func (x *VolumeEcShardsCopyRequest) GetCopyEcjFile() bool

func (*VolumeEcShardsCopyRequest) GetCopyEcxFile 

func (x *VolumeEcShardsCopyRequest) GetCopyEcxFile() bool

func (*VolumeEcShardsCopyRequest) GetCopyVifFile 

func (x *VolumeEcShardsCopyRequest) GetCopyVifFile() bool

func (*VolumeEcShardsCopyRequest) GetShardIds 

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

func (*VolumeEcShardsCopyRequest) GetSourceDataNode 

func (x *VolumeEcShardsCopyRequest) GetSourceDataNode() string

func (*VolumeEcShardsCopyRequest) GetVolumeId 

func (x *VolumeEcShardsCopyRequest) GetVolumeId() uint32

func (*VolumeEcShardsCopyRequest) ProtoMessage 

func (*VolumeEcShardsCopyRequest) ProtoMessage()

func (*VolumeEcShardsCopyRequest) ProtoReflect 

func (x *VolumeEcShardsCopyRequest) ProtoReflect() protoreflect.Message

func (*VolumeEcShardsCopyRequest) Reset 

func (x *VolumeEcShardsCopyRequest) Reset()

func (*VolumeEcShardsCopyRequest) String 

func (x *VolumeEcShardsCopyRequest) String() string

type VolumeEcShardsCopyResponse 

type VolumeEcShardsCopyResponse struct {
	// contains filtered or unexported fields
}

func (*VolumeEcShardsCopyResponse) Descriptor deprecated 

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

Deprecated: Use VolumeEcShardsCopyResponse.ProtoReflect.Descriptor instead.

func (*VolumeEcShardsCopyResponse) ProtoMessage 

func (*VolumeEcShardsCopyResponse) ProtoMessage()

func (*VolumeEcShardsCopyResponse) ProtoReflect 

func (x *VolumeEcShardsCopyResponse) ProtoReflect() protoreflect.Message

func (*VolumeEcShardsCopyResponse) Reset 

func (x *VolumeEcShardsCopyResponse) Reset()

func (*VolumeEcShardsCopyResponse) String 

func (x *VolumeEcShardsCopyResponse) String() string

type VolumeEcShardsDeleteRequest 

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

func (*VolumeEcShardsDeleteRequest) Descriptor deprecated 

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

Deprecated: Use VolumeEcShardsDeleteRequest.ProtoReflect.Descriptor instead.

func (*VolumeEcShardsDeleteRequest) GetCollection 

func (x *VolumeEcShardsDeleteRequest) GetCollection() string

func (*VolumeEcShardsDeleteRequest) GetShardIds 

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

func (*VolumeEcShardsDeleteRequest) GetVolumeId 

func (x *VolumeEcShardsDeleteRequest) GetVolumeId() uint32

func (*VolumeEcShardsDeleteRequest) ProtoMessage 

func (*VolumeEcShardsDeleteRequest) ProtoMessage()

func (*VolumeEcShardsDeleteRequest) ProtoReflect 

func (x *VolumeEcShardsDeleteRequest) ProtoReflect() protoreflect.Message

func (*VolumeEcShardsDeleteRequest) Reset 

func (x *VolumeEcShardsDeleteRequest) Reset()

func (*VolumeEcShardsDeleteRequest) String 

func (x *VolumeEcShardsDeleteRequest) String() string

type VolumeEcShardsDeleteResponse 

type VolumeEcShardsDeleteResponse struct {
	// contains filtered or unexported fields
}

func (*VolumeEcShardsDeleteResponse) Descriptor deprecated 

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

Deprecated: Use VolumeEcShardsDeleteResponse.ProtoReflect.Descriptor instead.

func (*VolumeEcShardsDeleteResponse) ProtoMessage 

func (*VolumeEcShardsDeleteResponse) ProtoMessage()

func (*VolumeEcShardsDeleteResponse) ProtoReflect 

func (x *VolumeEcShardsDeleteResponse) ProtoReflect() protoreflect.Message

func (*VolumeEcShardsDeleteResponse) Reset 

func (x *VolumeEcShardsDeleteResponse) Reset()

func (*VolumeEcShardsDeleteResponse) String 

func (x *VolumeEcShardsDeleteResponse) String() string

type VolumeEcShardsGenerateRequest 

type VolumeEcShardsGenerateRequest struct {
	VolumeId   uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId,proto3" json:"volume_id,omitempty"`
	Collection string `protobuf:"bytes,2,opt,name=collection,proto3" json:"collection,omitempty"`
	// contains filtered or unexported fields
}

func (*VolumeEcShardsGenerateRequest) Descriptor deprecated 

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

Deprecated: Use VolumeEcShardsGenerateRequest.ProtoReflect.Descriptor instead.

func (*VolumeEcShardsGenerateRequest) GetCollection 

func (x *VolumeEcShardsGenerateRequest) GetCollection() string

func (*VolumeEcShardsGenerateRequest) GetVolumeId 

func (x *VolumeEcShardsGenerateRequest) GetVolumeId() uint32

func (*VolumeEcShardsGenerateRequest) ProtoMessage 

func (*VolumeEcShardsGenerateRequest) ProtoMessage()

func (*VolumeEcShardsGenerateRequest) ProtoReflect 

func (x *VolumeEcShardsGenerateRequest) ProtoReflect() protoreflect.Message

func (*VolumeEcShardsGenerateRequest) Reset 

func (x *VolumeEcShardsGenerateRequest) Reset()

func (*VolumeEcShardsGenerateRequest) String 

func (x *VolumeEcShardsGenerateRequest) String() string

type VolumeEcShardsGenerateResponse 

type VolumeEcShardsGenerateResponse struct {
	// contains filtered or unexported fields
}

func (*VolumeEcShardsGenerateResponse) Descriptor deprecated 

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

Deprecated: Use VolumeEcShardsGenerateResponse.ProtoReflect.Descriptor instead.

func (*VolumeEcShardsGenerateResponse) ProtoMessage 

func (*VolumeEcShardsGenerateResponse) ProtoMessage()

func (*VolumeEcShardsGenerateResponse) ProtoReflect 

func (x *VolumeEcShardsGenerateResponse) ProtoReflect() protoreflect.Message

func (*VolumeEcShardsGenerateResponse) Reset 

func (x *VolumeEcShardsGenerateResponse) Reset()

func (*VolumeEcShardsGenerateResponse) String 

func (x *VolumeEcShardsGenerateResponse) String() string

type VolumeEcShardsMountRequest 

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

func (*VolumeEcShardsMountRequest) Descriptor deprecated 

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

Deprecated: Use VolumeEcShardsMountRequest.ProtoReflect.Descriptor instead.

func (*VolumeEcShardsMountRequest) GetCollection 

func (x *VolumeEcShardsMountRequest) GetCollection() string

func (*VolumeEcShardsMountRequest) GetShardIds 

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

func (*VolumeEcShardsMountRequest) GetVolumeId 

func (x *VolumeEcShardsMountRequest) GetVolumeId() uint32

func (*VolumeEcShardsMountRequest) ProtoMessage 

func (*VolumeEcShardsMountRequest) ProtoMessage()

func (*VolumeEcShardsMountRequest) ProtoReflect 

func (x *VolumeEcShardsMountRequest) ProtoReflect() protoreflect.Message

func (*VolumeEcShardsMountRequest) Reset 

func (x *VolumeEcShardsMountRequest) Reset()

func (*VolumeEcShardsMountRequest) String 

func (x *VolumeEcShardsMountRequest) String() string

type VolumeEcShardsMountResponse 

type VolumeEcShardsMountResponse struct {
	// contains filtered or unexported fields
}

func (*VolumeEcShardsMountResponse) Descriptor deprecated 

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

Deprecated: Use VolumeEcShardsMountResponse.ProtoReflect.Descriptor instead.

func (*VolumeEcShardsMountResponse) ProtoMessage 

func (*VolumeEcShardsMountResponse) ProtoMessage()

func (*VolumeEcShardsMountResponse) ProtoReflect 

func (x *VolumeEcShardsMountResponse) ProtoReflect() protoreflect.Message

func (*VolumeEcShardsMountResponse) Reset 

func (x *VolumeEcShardsMountResponse) Reset()

func (*VolumeEcShardsMountResponse) String 

func (x *VolumeEcShardsMountResponse) String() string

type VolumeEcShardsRebuildRequest 

type VolumeEcShardsRebuildRequest struct {
	VolumeId   uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId,proto3" json:"volume_id,omitempty"`
	Collection string `protobuf:"bytes,2,opt,name=collection,proto3" json:"collection,omitempty"`
	// contains filtered or unexported fields
}

func (*VolumeEcShardsRebuildRequest) Descriptor deprecated 

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

Deprecated: Use VolumeEcShardsRebuildRequest.ProtoReflect.Descriptor instead.

func (*VolumeEcShardsRebuildRequest) GetCollection 

func (x *VolumeEcShardsRebuildRequest) GetCollection() string

func (*VolumeEcShardsRebuildRequest) GetVolumeId 

func (x *VolumeEcShardsRebuildRequest) GetVolumeId() uint32

func (*VolumeEcShardsRebuildRequest) ProtoMessage 

func (*VolumeEcShardsRebuildRequest) ProtoMessage()

func (*VolumeEcShardsRebuildRequest) ProtoReflect 

func (x *VolumeEcShardsRebuildRequest) ProtoReflect() protoreflect.Message

func (*VolumeEcShardsRebuildRequest) Reset 

func (x *VolumeEcShardsRebuildRequest) Reset()

func (*VolumeEcShardsRebuildRequest) String 

func (x *VolumeEcShardsRebuildRequest) String() string

type VolumeEcShardsRebuildResponse 

type VolumeEcShardsRebuildResponse struct {
	RebuiltShardIds []uint32 `protobuf:"varint,1,rep,packed,name=rebuilt_shard_ids,json=rebuiltShardIds,proto3" json:"rebuilt_shard_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*VolumeEcShardsRebuildResponse) Descriptor deprecated 

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

Deprecated: Use VolumeEcShardsRebuildResponse.ProtoReflect.Descriptor instead.

func (*VolumeEcShardsRebuildResponse) GetRebuiltShardIds 

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

func (*VolumeEcShardsRebuildResponse) ProtoMessage 

func (*VolumeEcShardsRebuildResponse) ProtoMessage()

func (*VolumeEcShardsRebuildResponse) ProtoReflect 

func (x *VolumeEcShardsRebuildResponse) ProtoReflect() protoreflect.Message

func (*VolumeEcShardsRebuildResponse) Reset 

func (x *VolumeEcShardsRebuildResponse) Reset()

func (*VolumeEcShardsRebuildResponse) String 

func (x *VolumeEcShardsRebuildResponse) String() string

type VolumeEcShardsToVolumeRequest 

type VolumeEcShardsToVolumeRequest struct {
	VolumeId   uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId,proto3" json:"volume_id,omitempty"`
	Collection string `protobuf:"bytes,2,opt,name=collection,proto3" json:"collection,omitempty"`
	// contains filtered or unexported fields
}

func (*VolumeEcShardsToVolumeRequest) Descriptor deprecated 

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

Deprecated: Use VolumeEcShardsToVolumeRequest.ProtoReflect.Descriptor instead.

func (*VolumeEcShardsToVolumeRequest) GetCollection 

func (x *VolumeEcShardsToVolumeRequest) GetCollection() string

func (*VolumeEcShardsToVolumeRequest) GetVolumeId 

func (x *VolumeEcShardsToVolumeRequest) GetVolumeId() uint32

func (*VolumeEcShardsToVolumeRequest) ProtoMessage 

func (*VolumeEcShardsToVolumeRequest) ProtoMessage()

func (*VolumeEcShardsToVolumeRequest) ProtoReflect 

func (x *VolumeEcShardsToVolumeRequest) ProtoReflect() protoreflect.Message

func (*VolumeEcShardsToVolumeRequest) Reset 

func (x *VolumeEcShardsToVolumeRequest) Reset()

func (*VolumeEcShardsToVolumeRequest) String 

func (x *VolumeEcShardsToVolumeRequest) String() string

type VolumeEcShardsToVolumeResponse 

type VolumeEcShardsToVolumeResponse struct {
	// contains filtered or unexported fields
}

func (*VolumeEcShardsToVolumeResponse) Descriptor deprecated 

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

Deprecated: Use VolumeEcShardsToVolumeResponse.ProtoReflect.Descriptor instead.

func (*VolumeEcShardsToVolumeResponse) ProtoMessage 

func (*VolumeEcShardsToVolumeResponse) ProtoMessage()

func (*VolumeEcShardsToVolumeResponse) ProtoReflect 

func (x *VolumeEcShardsToVolumeResponse) ProtoReflect() protoreflect.Message

func (*VolumeEcShardsToVolumeResponse) Reset 

func (x *VolumeEcShardsToVolumeResponse) Reset()

func (*VolumeEcShardsToVolumeResponse) String 

func (x *VolumeEcShardsToVolumeResponse) String() string

type VolumeEcShardsUnmountRequest 

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

func (*VolumeEcShardsUnmountRequest) Descriptor deprecated 

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

Deprecated: Use VolumeEcShardsUnmountRequest.ProtoReflect.Descriptor instead.

func (*VolumeEcShardsUnmountRequest) GetShardIds 

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

func (*VolumeEcShardsUnmountRequest) GetVolumeId 

func (x *VolumeEcShardsUnmountRequest) GetVolumeId() uint32

func (*VolumeEcShardsUnmountRequest) ProtoMessage 

func (*VolumeEcShardsUnmountRequest) ProtoMessage()

func (*VolumeEcShardsUnmountRequest) ProtoReflect 

func (x *VolumeEcShardsUnmountRequest) ProtoReflect() protoreflect.Message

func (*VolumeEcShardsUnmountRequest) Reset 

func (x *VolumeEcShardsUnmountRequest) Reset()

func (*VolumeEcShardsUnmountRequest) String 

func (x *VolumeEcShardsUnmountRequest) String() string

type VolumeEcShardsUnmountResponse 

type VolumeEcShardsUnmountResponse struct {
	// contains filtered or unexported fields
}

func (*VolumeEcShardsUnmountResponse) Descriptor deprecated 

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

Deprecated: Use VolumeEcShardsUnmountResponse.ProtoReflect.Descriptor instead.

func (*VolumeEcShardsUnmountResponse) ProtoMessage 

func (*VolumeEcShardsUnmountResponse) ProtoMessage()

func (*VolumeEcShardsUnmountResponse) ProtoReflect 

func (x *VolumeEcShardsUnmountResponse) ProtoReflect() protoreflect.Message

func (*VolumeEcShardsUnmountResponse) Reset 

func (x *VolumeEcShardsUnmountResponse) Reset()

func (*VolumeEcShardsUnmountResponse) String 

func (x *VolumeEcShardsUnmountResponse) String() string

type VolumeIncrementalCopyRequest 

type VolumeIncrementalCopyRequest struct {
	VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId,proto3" json:"volume_id,omitempty"`
	SinceNs  uint64 `protobuf:"varint,2,opt,name=since_ns,json=sinceNs,proto3" json:"since_ns,omitempty"`
	// contains filtered or unexported fields
}

func (*VolumeIncrementalCopyRequest) Descriptor deprecated 

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

Deprecated: Use VolumeIncrementalCopyRequest.ProtoReflect.Descriptor instead.

func (*VolumeIncrementalCopyRequest) GetSinceNs 

func (x *VolumeIncrementalCopyRequest) GetSinceNs() uint64

func (*VolumeIncrementalCopyRequest) GetVolumeId 

func (x *VolumeIncrementalCopyRequest) GetVolumeId() uint32

func (*VolumeIncrementalCopyRequest) ProtoMessage 

func (*VolumeIncrementalCopyRequest) ProtoMessage()

func (*VolumeIncrementalCopyRequest) ProtoReflect 

func (x *VolumeIncrementalCopyRequest) ProtoReflect() protoreflect.Message

func (*VolumeIncrementalCopyRequest) Reset 

func (x *VolumeIncrementalCopyRequest) Reset()

func (*VolumeIncrementalCopyRequest) String 

func (x *VolumeIncrementalCopyRequest) String() string

type VolumeIncrementalCopyResponse 

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

func (*VolumeIncrementalCopyResponse) Descriptor deprecated 

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

Deprecated: Use VolumeIncrementalCopyResponse.ProtoReflect.Descriptor instead.

func (*VolumeIncrementalCopyResponse) GetFileContent 

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

func (*VolumeIncrementalCopyResponse) ProtoMessage 

func (*VolumeIncrementalCopyResponse) ProtoMessage()

func (*VolumeIncrementalCopyResponse) ProtoReflect 

func (x *VolumeIncrementalCopyResponse) ProtoReflect() protoreflect.Message

func (*VolumeIncrementalCopyResponse) Reset 

func (x *VolumeIncrementalCopyResponse) Reset()

func (*VolumeIncrementalCopyResponse) String 

func (x *VolumeIncrementalCopyResponse) String() string

type VolumeInfo 

type VolumeInfo struct {
	Files       []*RemoteFile `protobuf:"bytes,1,rep,name=files,proto3" json:"files,omitempty"`
	Version     uint32        `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
	Replication string        `protobuf:"bytes,3,opt,name=replication,proto3" json:"replication,omitempty"`
	// contains filtered or unexported fields
}

func (*VolumeInfo) Descriptor deprecated 

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

Deprecated: Use VolumeInfo.ProtoReflect.Descriptor instead.

func (*VolumeInfo) GetFiles 

func (x *VolumeInfo) GetFiles() []*RemoteFile

func (*VolumeInfo) GetReplication 

func (x *VolumeInfo) GetReplication() string

func (*VolumeInfo) GetVersion 

func (x *VolumeInfo) GetVersion() uint32

func (*VolumeInfo) ProtoMessage 

func (*VolumeInfo) ProtoMessage()

func (*VolumeInfo) ProtoReflect 

func (x *VolumeInfo) ProtoReflect() protoreflect.Message

func (*VolumeInfo) Reset 

func (x *VolumeInfo) Reset()

func (*VolumeInfo) String 

func (x *VolumeInfo) String() string

type VolumeMarkReadonlyRequest 

type VolumeMarkReadonlyRequest struct {
	VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId,proto3" json:"volume_id,omitempty"`
	// contains filtered or unexported fields
}

func (*VolumeMarkReadonlyRequest) Descriptor deprecated 

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

Deprecated: Use VolumeMarkReadonlyRequest.ProtoReflect.Descriptor instead.

func (*VolumeMarkReadonlyRequest) GetVolumeId 

func (x *VolumeMarkReadonlyRequest) GetVolumeId() uint32

func (*VolumeMarkReadonlyRequest) ProtoMessage 

func (*VolumeMarkReadonlyRequest) ProtoMessage()

func (*VolumeMarkReadonlyRequest) ProtoReflect 

func (x *VolumeMarkReadonlyRequest) ProtoReflect() protoreflect.Message

func (*VolumeMarkReadonlyRequest) Reset 

func (x *VolumeMarkReadonlyRequest) Reset()

func (*VolumeMarkReadonlyRequest) String 

func (x *VolumeMarkReadonlyRequest) String() string

type VolumeMarkReadonlyResponse 

type VolumeMarkReadonlyResponse struct {
	// contains filtered or unexported fields
}

func (*VolumeMarkReadonlyResponse) Descriptor deprecated 

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

Deprecated: Use VolumeMarkReadonlyResponse.ProtoReflect.Descriptor instead.

func (*VolumeMarkReadonlyResponse) ProtoMessage 

func (*VolumeMarkReadonlyResponse) ProtoMessage()

func (*VolumeMarkReadonlyResponse) ProtoReflect 

func (x *VolumeMarkReadonlyResponse) ProtoReflect() protoreflect.Message

func (*VolumeMarkReadonlyResponse) Reset 

func (x *VolumeMarkReadonlyResponse) Reset()

func (*VolumeMarkReadonlyResponse) String 

func (x *VolumeMarkReadonlyResponse) String() string

type VolumeMarkWritableRequest 

type VolumeMarkWritableRequest struct {
	VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId,proto3" json:"volume_id,omitempty"`
	// contains filtered or unexported fields
}

func (*VolumeMarkWritableRequest) Descriptor deprecated 

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

Deprecated: Use VolumeMarkWritableRequest.ProtoReflect.Descriptor instead.

func (*VolumeMarkWritableRequest) GetVolumeId 

func (x *VolumeMarkWritableRequest) GetVolumeId() uint32

func (*VolumeMarkWritableRequest) ProtoMessage 

func (*VolumeMarkWritableRequest) ProtoMessage()

func (*VolumeMarkWritableRequest) ProtoReflect 

func (x *VolumeMarkWritableRequest) ProtoReflect() protoreflect.Message

func (*VolumeMarkWritableRequest) Reset 

func (x *VolumeMarkWritableRequest) Reset()

func (*VolumeMarkWritableRequest) String 

func (x *VolumeMarkWritableRequest) String() string

type VolumeMarkWritableResponse 

type VolumeMarkWritableResponse struct {
	// contains filtered or unexported fields
}

func (*VolumeMarkWritableResponse) Descriptor deprecated 

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

Deprecated: Use VolumeMarkWritableResponse.ProtoReflect.Descriptor instead.

func (*VolumeMarkWritableResponse) ProtoMessage 

func (*VolumeMarkWritableResponse) ProtoMessage()

func (*VolumeMarkWritableResponse) ProtoReflect 

func (x *VolumeMarkWritableResponse) ProtoReflect() protoreflect.Message

func (*VolumeMarkWritableResponse) Reset 

func (x *VolumeMarkWritableResponse) Reset()

func (*VolumeMarkWritableResponse) String 

func (x *VolumeMarkWritableResponse) String() string

type VolumeMountRequest 

type VolumeMountRequest struct {
	VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId,proto3" json:"volume_id,omitempty"`
	// contains filtered or unexported fields
}

func (*VolumeMountRequest) Descriptor deprecated 

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

Deprecated: Use VolumeMountRequest.ProtoReflect.Descriptor instead.

func (*VolumeMountRequest) GetVolumeId 

func (x *VolumeMountRequest) GetVolumeId() uint32

func (*VolumeMountRequest) ProtoMessage 

func (*VolumeMountRequest) ProtoMessage()

func (*VolumeMountRequest) ProtoReflect 

func (x *VolumeMountRequest) ProtoReflect() protoreflect.Message

func (*VolumeMountRequest) Reset 

func (x *VolumeMountRequest) Reset()

func (*VolumeMountRequest) String 

func (x *VolumeMountRequest) String() string

type VolumeMountResponse 

type VolumeMountResponse struct {
	// contains filtered or unexported fields
}

func (*VolumeMountResponse) Descriptor deprecated 

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

Deprecated: Use VolumeMountResponse.ProtoReflect.Descriptor instead.

func (*VolumeMountResponse) ProtoMessage 

func (*VolumeMountResponse) ProtoMessage()

func (*VolumeMountResponse) ProtoReflect 

func (x *VolumeMountResponse) ProtoReflect() protoreflect.Message

func (*VolumeMountResponse) Reset 

func (x *VolumeMountResponse) Reset()

func (*VolumeMountResponse) String 

func (x *VolumeMountResponse) String() string

type VolumeNeedleStatusRequest 

type VolumeNeedleStatusRequest struct {
	VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId,proto3" json:"volume_id,omitempty"`
	NeedleId uint64 `protobuf:"varint,2,opt,name=needle_id,json=needleId,proto3" json:"needle_id,omitempty"`
	// contains filtered or unexported fields
}

func (*VolumeNeedleStatusRequest) Descriptor deprecated 

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

Deprecated: Use VolumeNeedleStatusRequest.ProtoReflect.Descriptor instead.

func (*VolumeNeedleStatusRequest) GetNeedleId 

func (x *VolumeNeedleStatusRequest) GetNeedleId() uint64

func (*VolumeNeedleStatusRequest) GetVolumeId 

func (x *VolumeNeedleStatusRequest) GetVolumeId() uint32

func (*VolumeNeedleStatusRequest) ProtoMessage 

func (*VolumeNeedleStatusRequest) ProtoMessage()

func (*VolumeNeedleStatusRequest) ProtoReflect 

func (x *VolumeNeedleStatusRequest) ProtoReflect() protoreflect.Message

func (*VolumeNeedleStatusRequest) Reset 

func (x *VolumeNeedleStatusRequest) Reset()

func (*VolumeNeedleStatusRequest) String 

func (x *VolumeNeedleStatusRequest) String() string

type VolumeNeedleStatusResponse 

type VolumeNeedleStatusResponse struct {
	NeedleId     uint64 `protobuf:"varint,1,opt,name=needle_id,json=needleId,proto3" json:"needle_id,omitempty"`
	Cookie       uint32 `protobuf:"varint,2,opt,name=cookie,proto3" json:"cookie,omitempty"`
	Size         uint32 `protobuf:"varint,3,opt,name=size,proto3" json:"size,omitempty"`
	LastModified uint64 `protobuf:"varint,4,opt,name=last_modified,json=lastModified,proto3" json:"last_modified,omitempty"`
	Crc          uint32 `protobuf:"varint,5,opt,name=crc,proto3" json:"crc,omitempty"`
	Ttl          string `protobuf:"bytes,6,opt,name=ttl,proto3" json:"ttl,omitempty"`
	// contains filtered or unexported fields
}

func (*VolumeNeedleStatusResponse) Descriptor deprecated 

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

Deprecated: Use VolumeNeedleStatusResponse.ProtoReflect.Descriptor instead.

func (*VolumeNeedleStatusResponse) GetCookie 

func (x *VolumeNeedleStatusResponse) GetCookie() uint32

func (*VolumeNeedleStatusResponse) GetCrc 

func (x *VolumeNeedleStatusResponse) GetCrc() uint32

func (*VolumeNeedleStatusResponse) GetLastModified 

func (x *VolumeNeedleStatusResponse) GetLastModified() uint64

func (*VolumeNeedleStatusResponse) GetNeedleId 

func (x *VolumeNeedleStatusResponse) GetNeedleId() uint64

func (*VolumeNeedleStatusResponse) GetSize 

func (x *VolumeNeedleStatusResponse) GetSize() uint32

func (*VolumeNeedleStatusResponse) GetTtl 

func (x *VolumeNeedleStatusResponse) GetTtl() string

func (*VolumeNeedleStatusResponse) ProtoMessage 

func (*VolumeNeedleStatusResponse) ProtoMessage()

func (*VolumeNeedleStatusResponse) ProtoReflect 

func (x *VolumeNeedleStatusResponse) ProtoReflect() protoreflect.Message

func (*VolumeNeedleStatusResponse) Reset 

func (x *VolumeNeedleStatusResponse) Reset()

func (*VolumeNeedleStatusResponse) String 

func (x *VolumeNeedleStatusResponse) 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)
	VolumeMarkWritable(ctx context.Context, in *VolumeMarkWritableRequest, opts ...grpc.CallOption) (*VolumeMarkWritableResponse, error)
	VolumeConfigure(ctx context.Context, in *VolumeConfigureRequest, opts ...grpc.CallOption) (*VolumeConfigureResponse, error)
	VolumeStatus(ctx context.Context, in *VolumeStatusRequest, opts ...grpc.CallOption) (*VolumeStatusResponse, 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)
	VolumeEcShardsToVolume(ctx context.Context, in *VolumeEcShardsToVolumeRequest, opts ...grpc.CallOption) (*VolumeEcShardsToVolumeResponse, error)
	// tiered storage
	VolumeTierMoveDatToRemote(ctx context.Context, in *VolumeTierMoveDatToRemoteRequest, opts ...grpc.CallOption) (VolumeServer_VolumeTierMoveDatToRemoteClient, error)
	VolumeTierMoveDatFromRemote(ctx context.Context, in *VolumeTierMoveDatFromRemoteRequest, opts ...grpc.CallOption) (VolumeServer_VolumeTierMoveDatFromRemoteClient, error)
	VolumeServerStatus(ctx context.Context, in *VolumeServerStatusRequest, opts ...grpc.CallOption) (*VolumeServerStatusResponse, error)
	VolumeServerLeave(ctx context.Context, in *VolumeServerLeaveRequest, opts ...grpc.CallOption) (*VolumeServerLeaveResponse, error)
	// <experimental> query
	Query(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (VolumeServer_QueryClient, error)
	VolumeNeedleStatus(ctx context.Context, in *VolumeNeedleStatusRequest, opts ...grpc.CallOption) (*VolumeNeedleStatusResponse, error)
}

VolumeServerClient is the client API for VolumeServer service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewVolumeServerClient 

func NewVolumeServerClient(cc grpc.ClientConnInterface) VolumeServerClient

type VolumeServerLeaveRequest 

type VolumeServerLeaveRequest struct {
	// contains filtered or unexported fields
}

func (*VolumeServerLeaveRequest) Descriptor deprecated 

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

Deprecated: Use VolumeServerLeaveRequest.ProtoReflect.Descriptor instead.

func (*VolumeServerLeaveRequest) ProtoMessage 

func (*VolumeServerLeaveRequest) ProtoMessage()

func (*VolumeServerLeaveRequest) ProtoReflect 

func (x *VolumeServerLeaveRequest) ProtoReflect() protoreflect.Message

func (*VolumeServerLeaveRequest) Reset 

func (x *VolumeServerLeaveRequest) Reset()

func (*VolumeServerLeaveRequest) String 

func (x *VolumeServerLeaveRequest) String() string

type VolumeServerLeaveResponse 

type VolumeServerLeaveResponse struct {
	// contains filtered or unexported fields
}

func (*VolumeServerLeaveResponse) Descriptor deprecated 

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

Deprecated: Use VolumeServerLeaveResponse.ProtoReflect.Descriptor instead.

func (*VolumeServerLeaveResponse) ProtoMessage 

func (*VolumeServerLeaveResponse) ProtoMessage()

func (*VolumeServerLeaveResponse) ProtoReflect 

func (x *VolumeServerLeaveResponse) ProtoReflect() protoreflect.Message

func (*VolumeServerLeaveResponse) Reset 

func (x *VolumeServerLeaveResponse) Reset()

func (*VolumeServerLeaveResponse) String 

func (x *VolumeServerLeaveResponse) String() string

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)
	VolumeMarkWritable(context.Context, *VolumeMarkWritableRequest) (*VolumeMarkWritableResponse, error)
	VolumeConfigure(context.Context, *VolumeConfigureRequest) (*VolumeConfigureResponse, error)
	VolumeStatus(context.Context, *VolumeStatusRequest) (*VolumeStatusResponse, 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)
	VolumeEcShardsToVolume(context.Context, *VolumeEcShardsToVolumeRequest) (*VolumeEcShardsToVolumeResponse, error)
	// tiered storage
	VolumeTierMoveDatToRemote(*VolumeTierMoveDatToRemoteRequest, VolumeServer_VolumeTierMoveDatToRemoteServer) error
	VolumeTierMoveDatFromRemote(*VolumeTierMoveDatFromRemoteRequest, VolumeServer_VolumeTierMoveDatFromRemoteServer) error
	VolumeServerStatus(context.Context, *VolumeServerStatusRequest) (*VolumeServerStatusResponse, error)
	VolumeServerLeave(context.Context, *VolumeServerLeaveRequest) (*VolumeServerLeaveResponse, error)
	// <experimental> query
	Query(*QueryRequest, VolumeServer_QueryServer) error
	VolumeNeedleStatus(context.Context, *VolumeNeedleStatusRequest) (*VolumeNeedleStatusResponse, error)
}

VolumeServerServer is the server API for VolumeServer service.

type VolumeServerStatusRequest 

type VolumeServerStatusRequest struct {
	// contains filtered or unexported fields
}

func (*VolumeServerStatusRequest) Descriptor deprecated 

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

Deprecated: Use VolumeServerStatusRequest.ProtoReflect.Descriptor instead.

func (*VolumeServerStatusRequest) ProtoMessage 

func (*VolumeServerStatusRequest) ProtoMessage()

func (*VolumeServerStatusRequest) ProtoReflect 

func (x *VolumeServerStatusRequest) ProtoReflect() protoreflect.Message

func (*VolumeServerStatusRequest) Reset 

func (x *VolumeServerStatusRequest) Reset()

func (*VolumeServerStatusRequest) String 

func (x *VolumeServerStatusRequest) String() string

type VolumeServerStatusResponse 

type VolumeServerStatusResponse struct {
	DiskStatuses []*DiskStatus `protobuf:"bytes,1,rep,name=disk_statuses,json=diskStatuses,proto3" json:"disk_statuses,omitempty"`
	MemoryStatus *MemStatus    `protobuf:"bytes,2,opt,name=memory_status,json=memoryStatus,proto3" json:"memory_status,omitempty"`
	// contains filtered or unexported fields
}

func (*VolumeServerStatusResponse) Descriptor deprecated 

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

Deprecated: Use VolumeServerStatusResponse.ProtoReflect.Descriptor instead.

func (*VolumeServerStatusResponse) GetDiskStatuses 

func (x *VolumeServerStatusResponse) GetDiskStatuses() []*DiskStatus

func (*VolumeServerStatusResponse) GetMemoryStatus 

func (x *VolumeServerStatusResponse) GetMemoryStatus() *MemStatus

func (*VolumeServerStatusResponse) ProtoMessage 

func (*VolumeServerStatusResponse) ProtoMessage()

func (*VolumeServerStatusResponse) ProtoReflect 

func (x *VolumeServerStatusResponse) ProtoReflect() protoreflect.Message

func (*VolumeServerStatusResponse) Reset 

func (x *VolumeServerStatusResponse) Reset()

func (*VolumeServerStatusResponse) String 

func (x *VolumeServerStatusResponse) String() string

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_QueryClient 

type VolumeServer_QueryClient interface {
	Recv() (*QueriedStripe, error)
	grpc.ClientStream
}

type VolumeServer_QueryServer 

type VolumeServer_QueryServer interface {
	Send(*QueriedStripe) 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 VolumeServer_VolumeTierMoveDatFromRemoteClient 

type VolumeServer_VolumeTierMoveDatFromRemoteClient interface {
	Recv() (*VolumeTierMoveDatFromRemoteResponse, error)
	grpc.ClientStream
}

type VolumeServer_VolumeTierMoveDatFromRemoteServer 

type VolumeServer_VolumeTierMoveDatFromRemoteServer interface {
	Send(*VolumeTierMoveDatFromRemoteResponse) error
	grpc.ServerStream
}

type VolumeServer_VolumeTierMoveDatToRemoteClient 

type VolumeServer_VolumeTierMoveDatToRemoteClient interface {
	Recv() (*VolumeTierMoveDatToRemoteResponse, error)
	grpc.ClientStream
}

type VolumeServer_VolumeTierMoveDatToRemoteServer 

type VolumeServer_VolumeTierMoveDatToRemoteServer interface {
	Send(*VolumeTierMoveDatToRemoteResponse) error
	grpc.ServerStream
}

type VolumeStatusRequest 

type VolumeStatusRequest struct {
	VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId,proto3" json:"volume_id,omitempty"`
	// contains filtered or unexported fields
}

func (*VolumeStatusRequest) Descriptor deprecated 

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

Deprecated: Use VolumeStatusRequest.ProtoReflect.Descriptor instead.

func (*VolumeStatusRequest) GetVolumeId 

func (x *VolumeStatusRequest) GetVolumeId() uint32

func (*VolumeStatusRequest) ProtoMessage 

func (*VolumeStatusRequest) ProtoMessage()

func (*VolumeStatusRequest) ProtoReflect 

func (x *VolumeStatusRequest) ProtoReflect() protoreflect.Message

func (*VolumeStatusRequest) Reset 

func (x *VolumeStatusRequest) Reset()

func (*VolumeStatusRequest) String 

func (x *VolumeStatusRequest) String() string

type VolumeStatusResponse 

type VolumeStatusResponse struct {
	IsReadOnly bool `protobuf:"varint,1,opt,name=is_read_only,json=isReadOnly,proto3" json:"is_read_only,omitempty"`
	// contains filtered or unexported fields
}

func (*VolumeStatusResponse) Descriptor deprecated 

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

Deprecated: Use VolumeStatusResponse.ProtoReflect.Descriptor instead.

func (*VolumeStatusResponse) GetIsReadOnly 

func (x *VolumeStatusResponse) GetIsReadOnly() bool

func (*VolumeStatusResponse) ProtoMessage 

func (*VolumeStatusResponse) ProtoMessage()

func (*VolumeStatusResponse) ProtoReflect 

func (x *VolumeStatusResponse) ProtoReflect() protoreflect.Message

func (*VolumeStatusResponse) Reset 

func (x *VolumeStatusResponse) Reset()

func (*VolumeStatusResponse) String 

func (x *VolumeStatusResponse) String() string

type VolumeSyncStatusRequest 

type VolumeSyncStatusRequest struct {
	VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId,proto3" json:"volume_id,omitempty"`
	// contains filtered or unexported fields
}

func (*VolumeSyncStatusRequest) Descriptor deprecated 

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

Deprecated: Use VolumeSyncStatusRequest.ProtoReflect.Descriptor instead.

func (*VolumeSyncStatusRequest) GetVolumeId 

func (x *VolumeSyncStatusRequest) GetVolumeId() uint32

func (*VolumeSyncStatusRequest) ProtoMessage 

func (*VolumeSyncStatusRequest) ProtoMessage()

func (*VolumeSyncStatusRequest) ProtoReflect 

func (x *VolumeSyncStatusRequest) ProtoReflect() protoreflect.Message

func (*VolumeSyncStatusRequest) Reset 

func (x *VolumeSyncStatusRequest) Reset()

func (*VolumeSyncStatusRequest) String 

func (x *VolumeSyncStatusRequest) String() string

type VolumeSyncStatusResponse 

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

func (*VolumeSyncStatusResponse) Descriptor deprecated 

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

Deprecated: Use VolumeSyncStatusResponse.ProtoReflect.Descriptor instead.

func (*VolumeSyncStatusResponse) GetCollection 

func (x *VolumeSyncStatusResponse) GetCollection() string

func (*VolumeSyncStatusResponse) GetCompactRevision 

func (x *VolumeSyncStatusResponse) GetCompactRevision() uint32

func (*VolumeSyncStatusResponse) GetIdxFileSize 

func (x *VolumeSyncStatusResponse) GetIdxFileSize() uint64

func (*VolumeSyncStatusResponse) GetReplication 

func (x *VolumeSyncStatusResponse) GetReplication() string

func (*VolumeSyncStatusResponse) GetTailOffset 

func (x *VolumeSyncStatusResponse) GetTailOffset() uint64

func (*VolumeSyncStatusResponse) GetTtl 

func (x *VolumeSyncStatusResponse) GetTtl() string

func (*VolumeSyncStatusResponse) GetVolumeId 

func (x *VolumeSyncStatusResponse) GetVolumeId() uint32

func (*VolumeSyncStatusResponse) ProtoMessage 

func (*VolumeSyncStatusResponse) ProtoMessage()

func (*VolumeSyncStatusResponse) ProtoReflect 

func (x *VolumeSyncStatusResponse) ProtoReflect() protoreflect.Message

func (*VolumeSyncStatusResponse) Reset 

func (x *VolumeSyncStatusResponse) Reset()

func (*VolumeSyncStatusResponse) String 

func (x *VolumeSyncStatusResponse) String() string

type VolumeTailReceiverRequest 

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

func (*VolumeTailReceiverRequest) Descriptor deprecated 

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

Deprecated: Use VolumeTailReceiverRequest.ProtoReflect.Descriptor instead.

func (*VolumeTailReceiverRequest) GetIdleTimeoutSeconds 

func (x *VolumeTailReceiverRequest) GetIdleTimeoutSeconds() uint32

func (*VolumeTailReceiverRequest) GetSinceNs 

func (x *VolumeTailReceiverRequest) GetSinceNs() uint64

func (*VolumeTailReceiverRequest) GetSourceVolumeServer 

func (x *VolumeTailReceiverRequest) GetSourceVolumeServer() string

func (*VolumeTailReceiverRequest) GetVolumeId 

func (x *VolumeTailReceiverRequest) GetVolumeId() uint32

func (*VolumeTailReceiverRequest) ProtoMessage 

func (*VolumeTailReceiverRequest) ProtoMessage()

func (*VolumeTailReceiverRequest) ProtoReflect 

func (x *VolumeTailReceiverRequest) ProtoReflect() protoreflect.Message

func (*VolumeTailReceiverRequest) Reset 

func (x *VolumeTailReceiverRequest) Reset()

func (*VolumeTailReceiverRequest) String 

func (x *VolumeTailReceiverRequest) String() string

type VolumeTailReceiverResponse 

type VolumeTailReceiverResponse struct {
	// contains filtered or unexported fields
}

func (*VolumeTailReceiverResponse) Descriptor deprecated 

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

Deprecated: Use VolumeTailReceiverResponse.ProtoReflect.Descriptor instead.

func (*VolumeTailReceiverResponse) ProtoMessage 

func (*VolumeTailReceiverResponse) ProtoMessage()

func (*VolumeTailReceiverResponse) ProtoReflect 

func (x *VolumeTailReceiverResponse) ProtoReflect() protoreflect.Message

func (*VolumeTailReceiverResponse) Reset 

func (x *VolumeTailReceiverResponse) Reset()

func (*VolumeTailReceiverResponse) String 

func (x *VolumeTailReceiverResponse) String() string

type VolumeTailSenderRequest 

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

func (*VolumeTailSenderRequest) Descriptor deprecated 

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

Deprecated: Use VolumeTailSenderRequest.ProtoReflect.Descriptor instead.

func (*VolumeTailSenderRequest) GetIdleTimeoutSeconds 

func (x *VolumeTailSenderRequest) GetIdleTimeoutSeconds() uint32

func (*VolumeTailSenderRequest) GetSinceNs 

func (x *VolumeTailSenderRequest) GetSinceNs() uint64

func (*VolumeTailSenderRequest) GetVolumeId 

func (x *VolumeTailSenderRequest) GetVolumeId() uint32

func (*VolumeTailSenderRequest) ProtoMessage 

func (*VolumeTailSenderRequest) ProtoMessage()

func (*VolumeTailSenderRequest) ProtoReflect 

func (x *VolumeTailSenderRequest) ProtoReflect() protoreflect.Message

func (*VolumeTailSenderRequest) Reset 

func (x *VolumeTailSenderRequest) Reset()

func (*VolumeTailSenderRequest) String 

func (x *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,proto3" json:"is_last_chunk,omitempty"`
	// contains filtered or unexported fields
}

func (*VolumeTailSenderResponse) Descriptor deprecated 

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

Deprecated: Use VolumeTailSenderResponse.ProtoReflect.Descriptor instead.

func (*VolumeTailSenderResponse) GetIsLastChunk 

func (x *VolumeTailSenderResponse) GetIsLastChunk() bool

func (*VolumeTailSenderResponse) GetNeedleBody 

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

func (*VolumeTailSenderResponse) GetNeedleHeader 

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

func (*VolumeTailSenderResponse) ProtoMessage 

func (*VolumeTailSenderResponse) ProtoMessage()

func (*VolumeTailSenderResponse) ProtoReflect 

func (x *VolumeTailSenderResponse) ProtoReflect() protoreflect.Message

func (*VolumeTailSenderResponse) Reset 

func (x *VolumeTailSenderResponse) Reset()

func (*VolumeTailSenderResponse) String 

func (x *VolumeTailSenderResponse) String() string

type VolumeTierMoveDatFromRemoteRequest 

type VolumeTierMoveDatFromRemoteRequest struct {
	VolumeId          uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId,proto3" json:"volume_id,omitempty"`
	Collection        string `protobuf:"bytes,2,opt,name=collection,proto3" json:"collection,omitempty"`
	KeepRemoteDatFile bool   `protobuf:"varint,3,opt,name=keep_remote_dat_file,json=keepRemoteDatFile,proto3" json:"keep_remote_dat_file,omitempty"`
	// contains filtered or unexported fields
}

func (*VolumeTierMoveDatFromRemoteRequest) Descriptor deprecated 

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

Deprecated: Use VolumeTierMoveDatFromRemoteRequest.ProtoReflect.Descriptor instead.

func (*VolumeTierMoveDatFromRemoteRequest) GetCollection 

func (x *VolumeTierMoveDatFromRemoteRequest) GetCollection() string

func (*VolumeTierMoveDatFromRemoteRequest) GetKeepRemoteDatFile 

func (x *VolumeTierMoveDatFromRemoteRequest) GetKeepRemoteDatFile() bool

func (*VolumeTierMoveDatFromRemoteRequest) GetVolumeId 

func (x *VolumeTierMoveDatFromRemoteRequest) GetVolumeId() uint32

func (*VolumeTierMoveDatFromRemoteRequest) ProtoMessage 

func (*VolumeTierMoveDatFromRemoteRequest) ProtoMessage()

func (*VolumeTierMoveDatFromRemoteRequest) ProtoReflect 

func (x *VolumeTierMoveDatFromRemoteRequest) ProtoReflect() protoreflect.Message

func (*VolumeTierMoveDatFromRemoteRequest) Reset 

func (x *VolumeTierMoveDatFromRemoteRequest) Reset()

func (*VolumeTierMoveDatFromRemoteRequest) String 

func (x *VolumeTierMoveDatFromRemoteRequest) String() string

type VolumeTierMoveDatFromRemoteResponse 

type VolumeTierMoveDatFromRemoteResponse struct {
	Processed           int64   `protobuf:"varint,1,opt,name=processed,proto3" json:"processed,omitempty"`
	ProcessedPercentage float32 `protobuf:"fixed32,2,opt,name=processedPercentage,proto3" json:"processedPercentage,omitempty"`
	// contains filtered or unexported fields
}

func (*VolumeTierMoveDatFromRemoteResponse) Descriptor deprecated 

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

Deprecated: Use VolumeTierMoveDatFromRemoteResponse.ProtoReflect.Descriptor instead.

func (*VolumeTierMoveDatFromRemoteResponse) GetProcessed 

func (x *VolumeTierMoveDatFromRemoteResponse) GetProcessed() int64

func (*VolumeTierMoveDatFromRemoteResponse) GetProcessedPercentage 

func (x *VolumeTierMoveDatFromRemoteResponse) GetProcessedPercentage() float32

func (*VolumeTierMoveDatFromRemoteResponse) ProtoMessage 

func (*VolumeTierMoveDatFromRemoteResponse) ProtoMessage()

func (*VolumeTierMoveDatFromRemoteResponse) ProtoReflect 

func (x *VolumeTierMoveDatFromRemoteResponse) ProtoReflect() protoreflect.Message

func (*VolumeTierMoveDatFromRemoteResponse) Reset 

func (x *VolumeTierMoveDatFromRemoteResponse) Reset()

func (*VolumeTierMoveDatFromRemoteResponse) String 

func (x *VolumeTierMoveDatFromRemoteResponse) String() string

type VolumeTierMoveDatToRemoteRequest 

type VolumeTierMoveDatToRemoteRequest struct {
	VolumeId               uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId,proto3" json:"volume_id,omitempty"`
	Collection             string `protobuf:"bytes,2,opt,name=collection,proto3" json:"collection,omitempty"`
	DestinationBackendName string `` /* 129-byte string literal not displayed */
	KeepLocalDatFile       bool   `protobuf:"varint,4,opt,name=keep_local_dat_file,json=keepLocalDatFile,proto3" json:"keep_local_dat_file,omitempty"`
	// contains filtered or unexported fields
}

func (*VolumeTierMoveDatToRemoteRequest) Descriptor deprecated 

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

Deprecated: Use VolumeTierMoveDatToRemoteRequest.ProtoReflect.Descriptor instead.

func (*VolumeTierMoveDatToRemoteRequest) GetCollection 

func (x *VolumeTierMoveDatToRemoteRequest) GetCollection() string

func (*VolumeTierMoveDatToRemoteRequest) GetDestinationBackendName 

func (x *VolumeTierMoveDatToRemoteRequest) GetDestinationBackendName() string

func (*VolumeTierMoveDatToRemoteRequest) GetKeepLocalDatFile 

func (x *VolumeTierMoveDatToRemoteRequest) GetKeepLocalDatFile() bool

func (*VolumeTierMoveDatToRemoteRequest) GetVolumeId 

func (x *VolumeTierMoveDatToRemoteRequest) GetVolumeId() uint32

func (*VolumeTierMoveDatToRemoteRequest) ProtoMessage 

func (*VolumeTierMoveDatToRemoteRequest) ProtoMessage()

func (*VolumeTierMoveDatToRemoteRequest) ProtoReflect 

func (x *VolumeTierMoveDatToRemoteRequest) ProtoReflect() protoreflect.Message

func (*VolumeTierMoveDatToRemoteRequest) Reset 

func (x *VolumeTierMoveDatToRemoteRequest) Reset()

func (*VolumeTierMoveDatToRemoteRequest) String 

func (x *VolumeTierMoveDatToRemoteRequest) String() string

type VolumeTierMoveDatToRemoteResponse 

type VolumeTierMoveDatToRemoteResponse struct {
	Processed           int64   `protobuf:"varint,1,opt,name=processed,proto3" json:"processed,omitempty"`
	ProcessedPercentage float32 `protobuf:"fixed32,2,opt,name=processedPercentage,proto3" json:"processedPercentage,omitempty"`
	// contains filtered or unexported fields
}

func (*VolumeTierMoveDatToRemoteResponse) Descriptor deprecated 

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

Deprecated: Use VolumeTierMoveDatToRemoteResponse.ProtoReflect.Descriptor instead.

func (*VolumeTierMoveDatToRemoteResponse) GetProcessed 

func (x *VolumeTierMoveDatToRemoteResponse) GetProcessed() int64

func (*VolumeTierMoveDatToRemoteResponse) GetProcessedPercentage 

func (x *VolumeTierMoveDatToRemoteResponse) GetProcessedPercentage() float32

func (*VolumeTierMoveDatToRemoteResponse) ProtoMessage 

func (*VolumeTierMoveDatToRemoteResponse) ProtoMessage()

func (*VolumeTierMoveDatToRemoteResponse) ProtoReflect 

func (x *VolumeTierMoveDatToRemoteResponse) ProtoReflect() protoreflect.Message

func (*VolumeTierMoveDatToRemoteResponse) Reset 

func (x *VolumeTierMoveDatToRemoteResponse) Reset()

func (*VolumeTierMoveDatToRemoteResponse) String 

func (x *VolumeTierMoveDatToRemoteResponse) String() string

type VolumeUnmountRequest 

type VolumeUnmountRequest struct {
	VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId,proto3" json:"volume_id,omitempty"`
	// contains filtered or unexported fields
}

func (*VolumeUnmountRequest) Descriptor deprecated 

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

Deprecated: Use VolumeUnmountRequest.ProtoReflect.Descriptor instead.

func (*VolumeUnmountRequest) GetVolumeId 

func (x *VolumeUnmountRequest) GetVolumeId() uint32

func (*VolumeUnmountRequest) ProtoMessage 

func (*VolumeUnmountRequest) ProtoMessage()

func (*VolumeUnmountRequest) ProtoReflect 

func (x *VolumeUnmountRequest) ProtoReflect() protoreflect.Message

func (*VolumeUnmountRequest) Reset 

func (x *VolumeUnmountRequest) Reset()

func (*VolumeUnmountRequest) String 

func (x *VolumeUnmountRequest) String() string

type VolumeUnmountResponse 

type VolumeUnmountResponse struct {
	// contains filtered or unexported fields
}

func (*VolumeUnmountResponse) Descriptor deprecated 

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

Deprecated: Use VolumeUnmountResponse.ProtoReflect.Descriptor instead.

func (*VolumeUnmountResponse) ProtoMessage 

func (*VolumeUnmountResponse) ProtoMessage()

func (*VolumeUnmountResponse) ProtoReflect 

func (x *VolumeUnmountResponse) ProtoReflect() protoreflect.Message

func (*VolumeUnmountResponse) Reset 

func (x *VolumeUnmountResponse) Reset()

func (*VolumeUnmountResponse) String 

func (x *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.