volume_server_pb

package
v0.0.0-...-5c6c1e7 Latest Latest
Warning

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

 Go to latest Published: Jul 29, 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
View Source 
var VolumeServer_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "volume_server_pb.VolumeServer",
	HandlerType: (*VolumeServerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "BatchDelete",
			Handler:    _VolumeServer_BatchDelete_Handler,
		},
		{
			MethodName: "VacuumVolumeCheck",
			Handler:    _VolumeServer_VacuumVolumeCheck_Handler,
		},
		{
			MethodName: "VacuumVolumeCommit",
			Handler:    _VolumeServer_VacuumVolumeCommit_Handler,
		},
		{
			MethodName: "VacuumVolumeCleanup",
			Handler:    _VolumeServer_VacuumVolumeCleanup_Handler,
		},
		{
			MethodName: "DeleteCollection",
			Handler:    _VolumeServer_DeleteCollection_Handler,
		},
		{
			MethodName: "AllocateVolume",
			Handler:    _VolumeServer_AllocateVolume_Handler,
		},
		{
			MethodName: "VolumeSyncStatus",
			Handler:    _VolumeServer_VolumeSyncStatus_Handler,
		},
		{
			MethodName: "VolumeMount",
			Handler:    _VolumeServer_VolumeMount_Handler,
		},
		{
			MethodName: "VolumeUnmount",
			Handler:    _VolumeServer_VolumeUnmount_Handler,
		},
		{
			MethodName: "VolumeDelete",
			Handler:    _VolumeServer_VolumeDelete_Handler,
		},
		{
			MethodName: "VolumeMarkReadonly",
			Handler:    _VolumeServer_VolumeMarkReadonly_Handler,
		},
		{
			MethodName: "VolumeMarkWritable",
			Handler:    _VolumeServer_VolumeMarkWritable_Handler,
		},
		{
			MethodName: "VolumeConfigure",
			Handler:    _VolumeServer_VolumeConfigure_Handler,
		},
		{
			MethodName: "VolumeStatus",
			Handler:    _VolumeServer_VolumeStatus_Handler,
		},
		{
			MethodName: "ReadVolumeFileStatus",
			Handler:    _VolumeServer_ReadVolumeFileStatus_Handler,
		},
		{
			MethodName: "ReadNeedleBlob",
			Handler:    _VolumeServer_ReadNeedleBlob_Handler,
		},
		{
			MethodName: "WriteNeedleBlob",
			Handler:    _VolumeServer_WriteNeedleBlob_Handler,
		},
		{
			MethodName: "VolumeTailReceiver",
			Handler:    _VolumeServer_VolumeTailReceiver_Handler,
		},
		{
			MethodName: "VolumeEcShardsGenerate",
			Handler:    _VolumeServer_VolumeEcShardsGenerate_Handler,
		},
		{
			MethodName: "VolumeEcShardsRebuild",
			Handler:    _VolumeServer_VolumeEcShardsRebuild_Handler,
		},
		{
			MethodName: "VolumeEcShardsCopy",
			Handler:    _VolumeServer_VolumeEcShardsCopy_Handler,
		},
		{
			MethodName: "VolumeEcShardsDelete",
			Handler:    _VolumeServer_VolumeEcShardsDelete_Handler,
		},
		{
			MethodName: "VolumeEcShardsMount",
			Handler:    _VolumeServer_VolumeEcShardsMount_Handler,
		},
		{
			MethodName: "VolumeEcShardsUnmount",
			Handler:    _VolumeServer_VolumeEcShardsUnmount_Handler,
		},
		{
			MethodName: "VolumeEcBlobDelete",
			Handler:    _VolumeServer_VolumeEcBlobDelete_Handler,
		},
		{
			MethodName: "VolumeEcShardsToVolume",
			Handler:    _VolumeServer_VolumeEcShardsToVolume_Handler,
		},
		{
			MethodName: "VolumeServerStatus",
			Handler:    _VolumeServer_VolumeServerStatus_Handler,
		},
		{
			MethodName: "VolumeServerLeave",
			Handler:    _VolumeServer_VolumeServerLeave_Handler,
		},
		{
			MethodName: "FetchAndWriteNeedle",
			Handler:    _VolumeServer_FetchAndWriteNeedle_Handler,
		},
		{
			MethodName: "VolumeNeedleStatus",
			Handler:    _VolumeServer_VolumeNeedleStatus_Handler,
		},
		{
			MethodName: "Ping",
			Handler:    _VolumeServer_Ping_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "VacuumVolumeCompact",
			Handler:       _VolumeServer_VacuumVolumeCompact_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "VolumeIncrementalCopy",
			Handler:       _VolumeServer_VolumeIncrementalCopy_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "VolumeCopy",
			Handler:       _VolumeServer_VolumeCopy_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "CopyFile",
			Handler:       _VolumeServer_CopyFile_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "ReadAllNeedles",
			Handler:       _VolumeServer_ReadAllNeedles_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "VolumeTailSender",
			Handler:       _VolumeServer_VolumeTailSender_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "VolumeEcShardRead",
			Handler:       _VolumeServer_VolumeEcShardRead_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "VolumeTierMoveDatToRemote",
			Handler:       _VolumeServer_VolumeTierMoveDatToRemote_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "VolumeTierMoveDatFromRemote",
			Handler:       _VolumeServer_VolumeTierMoveDatFromRemote_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "Query",
			Handler:       _VolumeServer_Query_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "volume_server.proto",
}

VolumeServer_ServiceDesc is the grpc.ServiceDesc for VolumeServer service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterVolumeServerServer 

func RegisterVolumeServerServer(s grpc.ServiceRegistrar, 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"`
	DiskType           string `protobuf:"bytes,7,opt,name=disk_type,json=diskType,proto3" json:"disk_type,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) GetDiskType 

func (x *AllocateVolumeRequest) GetDiskType() 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"`
	ModifiedTsNs int64  `protobuf:"varint,2,opt,name=modified_ts_ns,json=modifiedTsNs,proto3" json:"modified_ts_ns,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) GetModifiedTsNs 

func (x *CopyFileResponse) GetModifiedTsNs() int64

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"`
	DiskType    string  `protobuf:"bytes,7,opt,name=disk_type,json=diskType,proto3" json:"disk_type,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) GetDiskType 

func (x *DiskStatus) GetDiskType() 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 FetchAndWriteNeedleRequest 

type FetchAndWriteNeedleRequest 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"`
	Cookie   uint32                                `protobuf:"varint,3,opt,name=cookie,proto3" json:"cookie,omitempty"`
	Offset   int64                                 `protobuf:"varint,4,opt,name=offset,proto3" json:"offset,omitempty"`
	Size     int64                                 `protobuf:"varint,5,opt,name=size,proto3" json:"size,omitempty"`
	Replicas []*FetchAndWriteNeedleRequest_Replica `protobuf:"bytes,6,rep,name=replicas,proto3" json:"replicas,omitempty"`
	Auth     string                                `protobuf:"bytes,7,opt,name=auth,proto3" json:"auth,omitempty"`
	// remote conf
	RemoteConf     *remote_pb.RemoteConf            `protobuf:"bytes,15,opt,name=remote_conf,json=remoteConf,proto3" json:"remote_conf,omitempty"`
	RemoteLocation *remote_pb.RemoteStorageLocation `protobuf:"bytes,16,opt,name=remote_location,json=remoteLocation,proto3" json:"remote_location,omitempty"`
	// contains filtered or unexported fields
}

remote storage

func (*FetchAndWriteNeedleRequest) Descriptor deprecated 

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

Deprecated: Use FetchAndWriteNeedleRequest.ProtoReflect.Descriptor instead.

func (*FetchAndWriteNeedleRequest) GetAuth 

func (x *FetchAndWriteNeedleRequest) GetAuth() string

func (*FetchAndWriteNeedleRequest) GetCookie 

func (x *FetchAndWriteNeedleRequest) GetCookie() uint32

func (*FetchAndWriteNeedleRequest) GetNeedleId 

func (x *FetchAndWriteNeedleRequest) GetNeedleId() uint64

func (*FetchAndWriteNeedleRequest) GetOffset 

func (x *FetchAndWriteNeedleRequest) GetOffset() int64

func (*FetchAndWriteNeedleRequest) GetRemoteConf 

func (x *FetchAndWriteNeedleRequest) GetRemoteConf() *remote_pb.RemoteConf

func (*FetchAndWriteNeedleRequest) GetRemoteLocation 

func (x *FetchAndWriteNeedleRequest) GetRemoteLocation() *remote_pb.RemoteStorageLocation

func (*FetchAndWriteNeedleRequest) GetReplicas 

func (x *FetchAndWriteNeedleRequest) GetReplicas() []*FetchAndWriteNeedleRequest_Replica

func (*FetchAndWriteNeedleRequest) GetSize 

func (x *FetchAndWriteNeedleRequest) GetSize() int64

func (*FetchAndWriteNeedleRequest) GetVolumeId 

func (x *FetchAndWriteNeedleRequest) GetVolumeId() uint32

func (*FetchAndWriteNeedleRequest) ProtoMessage 

func (*FetchAndWriteNeedleRequest) ProtoMessage()

func (*FetchAndWriteNeedleRequest) ProtoReflect 

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

func (*FetchAndWriteNeedleRequest) Reset 

func (x *FetchAndWriteNeedleRequest) Reset()

func (*FetchAndWriteNeedleRequest) String 

func (x *FetchAndWriteNeedleRequest) String() string

type FetchAndWriteNeedleRequest_Replica 

type FetchAndWriteNeedleRequest_Replica struct {
	Url       string `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	PublicUrl string `protobuf:"bytes,2,opt,name=public_url,json=publicUrl,proto3" json:"public_url,omitempty"`
	GrpcPort  int32  `protobuf:"varint,3,opt,name=grpc_port,json=grpcPort,proto3" json:"grpc_port,omitempty"`
	// contains filtered or unexported fields
}

func (*FetchAndWriteNeedleRequest_Replica) Descriptor deprecated 

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

Deprecated: Use FetchAndWriteNeedleRequest_Replica.ProtoReflect.Descriptor instead.

func (*FetchAndWriteNeedleRequest_Replica) GetGrpcPort 

func (x *FetchAndWriteNeedleRequest_Replica) GetGrpcPort() int32

func (*FetchAndWriteNeedleRequest_Replica) GetPublicUrl 

func (x *FetchAndWriteNeedleRequest_Replica) GetPublicUrl() string

func (*FetchAndWriteNeedleRequest_Replica) GetUrl 

func (x *FetchAndWriteNeedleRequest_Replica) GetUrl() string

func (*FetchAndWriteNeedleRequest_Replica) ProtoMessage 

func (*FetchAndWriteNeedleRequest_Replica) ProtoMessage()

func (*FetchAndWriteNeedleRequest_Replica) ProtoReflect 

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

func (*FetchAndWriteNeedleRequest_Replica) Reset 

func (x *FetchAndWriteNeedleRequest_Replica) Reset()

func (*FetchAndWriteNeedleRequest_Replica) String 

func (x *FetchAndWriteNeedleRequest_Replica) String() string

type FetchAndWriteNeedleResponse 

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

func (*FetchAndWriteNeedleResponse) Descriptor deprecated 

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

Deprecated: Use FetchAndWriteNeedleResponse.ProtoReflect.Descriptor instead.

func (*FetchAndWriteNeedleResponse) ProtoMessage 

func (*FetchAndWriteNeedleResponse) ProtoMessage()

func (*FetchAndWriteNeedleResponse) ProtoReflect 

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

func (*FetchAndWriteNeedleResponse) Reset 

func (x *FetchAndWriteNeedleResponse) Reset()

func (*FetchAndWriteNeedleResponse) String 

func (x *FetchAndWriteNeedleResponse) 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 PingRequest 

type PingRequest struct {
	Target     string `protobuf:"bytes,1,opt,name=target,proto3" json:"target,omitempty"` // default to ping itself
	TargetType string `protobuf:"bytes,2,opt,name=target_type,json=targetType,proto3" json:"target_type,omitempty"`
	// contains filtered or unexported fields
}

func (*PingRequest) Descriptor deprecated 

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

Deprecated: Use PingRequest.ProtoReflect.Descriptor instead.

func (*PingRequest) GetTarget 

func (x *PingRequest) GetTarget() string

func (*PingRequest) GetTargetType 

func (x *PingRequest) GetTargetType() string

func (*PingRequest) ProtoMessage 

func (*PingRequest) ProtoMessage()

func (*PingRequest) ProtoReflect 

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

func (*PingRequest) Reset 

func (x *PingRequest) Reset()

func (*PingRequest) String 

func (x *PingRequest) String() string

type PingResponse 

type PingResponse struct {
	StartTimeNs  int64 `protobuf:"varint,1,opt,name=start_time_ns,json=startTimeNs,proto3" json:"start_time_ns,omitempty"`
	RemoteTimeNs int64 `protobuf:"varint,2,opt,name=remote_time_ns,json=remoteTimeNs,proto3" json:"remote_time_ns,omitempty"`
	StopTimeNs   int64 `protobuf:"varint,3,opt,name=stop_time_ns,json=stopTimeNs,proto3" json:"stop_time_ns,omitempty"`
	// contains filtered or unexported fields
}

func (*PingResponse) Descriptor deprecated 

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

Deprecated: Use PingResponse.ProtoReflect.Descriptor instead.

func (*PingResponse) GetRemoteTimeNs 

func (x *PingResponse) GetRemoteTimeNs() int64

func (*PingResponse) GetStartTimeNs 

func (x *PingResponse) GetStartTimeNs() int64

func (*PingResponse) GetStopTimeNs 

func (x *PingResponse) GetStopTimeNs() int64

func (*PingResponse) ProtoMessage 

func (*PingResponse) ProtoMessage()

func (*PingResponse) ProtoReflect 

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

func (*PingResponse) Reset 

func (x *PingResponse) Reset()

func (*PingResponse) String 

func (x *PingResponse) 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 ReadAllNeedlesRequest 

type ReadAllNeedlesRequest struct {
	VolumeIds []uint32 `protobuf:"varint,1,rep,packed,name=volume_ids,json=volumeIds,proto3" json:"volume_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadAllNeedlesRequest) Descriptor deprecated 

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

Deprecated: Use ReadAllNeedlesRequest.ProtoReflect.Descriptor instead.

func (*ReadAllNeedlesRequest) GetVolumeIds 

func (x *ReadAllNeedlesRequest) GetVolumeIds() []uint32

func (*ReadAllNeedlesRequest) ProtoMessage 

func (*ReadAllNeedlesRequest) ProtoMessage()

func (*ReadAllNeedlesRequest) ProtoReflect 

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

func (*ReadAllNeedlesRequest) Reset 

func (x *ReadAllNeedlesRequest) Reset()

func (*ReadAllNeedlesRequest) String 

func (x *ReadAllNeedlesRequest) String() string

type ReadAllNeedlesResponse 

type ReadAllNeedlesResponse 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"`
	Cookie     uint32 `protobuf:"varint,3,opt,name=cookie,proto3" json:"cookie,omitempty"`
	NeedleBlob []byte `protobuf:"bytes,5,opt,name=needle_blob,json=needleBlob,proto3" json:"needle_blob,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadAllNeedlesResponse) Descriptor deprecated 

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

Deprecated: Use ReadAllNeedlesResponse.ProtoReflect.Descriptor instead.

func (*ReadAllNeedlesResponse) GetCookie 

func (x *ReadAllNeedlesResponse) GetCookie() uint32

func (*ReadAllNeedlesResponse) GetNeedleBlob 

func (x *ReadAllNeedlesResponse) GetNeedleBlob() []byte

func (*ReadAllNeedlesResponse) GetNeedleId 

func (x *ReadAllNeedlesResponse) GetNeedleId() uint64

func (*ReadAllNeedlesResponse) GetVolumeId 

func (x *ReadAllNeedlesResponse) GetVolumeId() uint32

func (*ReadAllNeedlesResponse) ProtoMessage 

func (*ReadAllNeedlesResponse) ProtoMessage()

func (*ReadAllNeedlesResponse) ProtoReflect 

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

func (*ReadAllNeedlesResponse) Reset 

func (x *ReadAllNeedlesResponse) Reset()

func (*ReadAllNeedlesResponse) String 

func (x *ReadAllNeedlesResponse) String() string

type ReadNeedleBlobRequest 

type ReadNeedleBlobRequest 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"`
	Offset   int64  `protobuf:"varint,3,opt,name=offset,proto3" json:"offset,omitempty"` // actual offset
	Size     int32  `protobuf:"varint,4,opt,name=size,proto3" json:"size,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadNeedleBlobRequest) Descriptor deprecated 

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

Deprecated: Use ReadNeedleBlobRequest.ProtoReflect.Descriptor instead.

func (*ReadNeedleBlobRequest) GetNeedleId 

func (x *ReadNeedleBlobRequest) GetNeedleId() uint64

func (*ReadNeedleBlobRequest) GetOffset 

func (x *ReadNeedleBlobRequest) GetOffset() int64

func (*ReadNeedleBlobRequest) GetSize 

func (x *ReadNeedleBlobRequest) GetSize() int32

func (*ReadNeedleBlobRequest) GetVolumeId 

func (x *ReadNeedleBlobRequest) GetVolumeId() uint32

func (*ReadNeedleBlobRequest) ProtoMessage 

func (*ReadNeedleBlobRequest) ProtoMessage()

func (*ReadNeedleBlobRequest) ProtoReflect 

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

func (*ReadNeedleBlobRequest) Reset 

func (x *ReadNeedleBlobRequest) Reset()

func (*ReadNeedleBlobRequest) String 

func (x *ReadNeedleBlobRequest) String() string

type ReadNeedleBlobResponse 

type ReadNeedleBlobResponse struct {
	NeedleBlob []byte `protobuf:"bytes,1,opt,name=needle_blob,json=needleBlob,proto3" json:"needle_blob,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadNeedleBlobResponse) Descriptor deprecated 

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

Deprecated: Use ReadNeedleBlobResponse.ProtoReflect.Descriptor instead.

func (*ReadNeedleBlobResponse) GetNeedleBlob 

func (x *ReadNeedleBlobResponse) GetNeedleBlob() []byte

func (*ReadNeedleBlobResponse) ProtoMessage 

func (*ReadNeedleBlobResponse) ProtoMessage()

func (*ReadNeedleBlobResponse) ProtoReflect 

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

func (*ReadNeedleBlobResponse) Reset 

func (x *ReadNeedleBlobResponse) Reset()

func (*ReadNeedleBlobResponse) String 

func (x *ReadNeedleBlobResponse) 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"`
	DiskType                string `protobuf:"bytes,9,opt,name=disk_type,json=diskType,proto3" json:"disk_type,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) GetDiskType 

func (x *ReadVolumeFileStatusResponse) GetDiskType() string

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 must 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) FetchAndWriteNeedle 

func (UnimplementedVolumeServerServer) FetchAndWriteNeedle(context.Context, *FetchAndWriteNeedleRequest) (*FetchAndWriteNeedleResponse, error)

func (UnimplementedVolumeServerServer) Ping 

func (UnimplementedVolumeServerServer) Ping(context.Context, *PingRequest) (*PingResponse, error)

func (UnimplementedVolumeServerServer) Query 

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

func (UnimplementedVolumeServerServer) ReadAllNeedles 

func (UnimplementedVolumeServerServer) ReadAllNeedles(*ReadAllNeedlesRequest, VolumeServer_ReadAllNeedlesServer) error

func (UnimplementedVolumeServerServer) ReadNeedleBlob 

func (UnimplementedVolumeServerServer) ReadNeedleBlob(context.Context, *ReadNeedleBlobRequest) (*ReadNeedleBlobResponse, 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(*VacuumVolumeCompactRequest, VolumeServer_VacuumVolumeCompactServer) error

func (UnimplementedVolumeServerServer) VolumeConfigure 

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

func (UnimplementedVolumeServerServer) VolumeCopy 

func (UnimplementedVolumeServerServer) VolumeCopy(*VolumeCopyRequest, VolumeServer_VolumeCopyServer) 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)

func (UnimplementedVolumeServerServer) WriteNeedleBlob 

func (UnimplementedVolumeServerServer) WriteNeedleBlob(context.Context, *WriteNeedleBlobRequest) (*WriteNeedleBlobResponse, error)

type UnsafeVolumeServerServer 

type UnsafeVolumeServerServer interface {
	// contains filtered or unexported methods
}

UnsafeVolumeServerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to VolumeServerServer will result in compilation errors.

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 {
	ProcessedBytes int64 `protobuf:"varint,1,opt,name=processed_bytes,json=processedBytes,proto3" json:"processed_bytes,omitempty"`
	// contains filtered or unexported fields
}

func (*VacuumVolumeCompactResponse) Descriptor deprecated 

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

Deprecated: Use VacuumVolumeCompactResponse.ProtoReflect.Descriptor instead.

func (*VacuumVolumeCompactResponse) GetProcessedBytes 

func (x *VacuumVolumeCompactResponse) GetProcessedBytes() int64

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"`
	DiskType       string `protobuf:"bytes,6,opt,name=disk_type,json=diskType,proto3" json:"disk_type,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) GetDiskType 

func (x *VolumeCopyRequest) GetDiskType() 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"`
	ProcessedBytes int64  `protobuf:"varint,2,opt,name=processed_bytes,json=processedBytes,proto3" json:"processed_bytes,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) GetProcessedBytes 

func (x *VolumeCopyResponse) GetProcessedBytes() int64

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) (VolumeServer_VacuumVolumeCompactClient, 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) (VolumeServer_VolumeCopyClient, error)
	ReadVolumeFileStatus(ctx context.Context, in *ReadVolumeFileStatusRequest, opts ...grpc.CallOption) (*ReadVolumeFileStatusResponse, error)
	CopyFile(ctx context.Context, in *CopyFileRequest, opts ...grpc.CallOption) (VolumeServer_CopyFileClient, error)
	ReadNeedleBlob(ctx context.Context, in *ReadNeedleBlobRequest, opts ...grpc.CallOption) (*ReadNeedleBlobResponse, error)
	WriteNeedleBlob(ctx context.Context, in *WriteNeedleBlobRequest, opts ...grpc.CallOption) (*WriteNeedleBlobResponse, error)
	ReadAllNeedles(ctx context.Context, in *ReadAllNeedlesRequest, opts ...grpc.CallOption) (VolumeServer_ReadAllNeedlesClient, 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)
	// remote storage
	FetchAndWriteNeedle(ctx context.Context, in *FetchAndWriteNeedleRequest, opts ...grpc.CallOption) (*FetchAndWriteNeedleResponse, 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)
	Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingResponse, error)
}

VolumeServerClient is the client API for VolumeServer service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#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(*VacuumVolumeCompactRequest, VolumeServer_VacuumVolumeCompactServer) 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(*VolumeCopyRequest, VolumeServer_VolumeCopyServer) error
	ReadVolumeFileStatus(context.Context, *ReadVolumeFileStatusRequest) (*ReadVolumeFileStatusResponse, error)
	CopyFile(*CopyFileRequest, VolumeServer_CopyFileServer) error
	ReadNeedleBlob(context.Context, *ReadNeedleBlobRequest) (*ReadNeedleBlobResponse, error)
	WriteNeedleBlob(context.Context, *WriteNeedleBlobRequest) (*WriteNeedleBlobResponse, error)
	ReadAllNeedles(*ReadAllNeedlesRequest, VolumeServer_ReadAllNeedlesServer) 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)
	// remote storage
	FetchAndWriteNeedle(context.Context, *FetchAndWriteNeedleRequest) (*FetchAndWriteNeedleResponse, error)
	// <experimental> query
	Query(*QueryRequest, VolumeServer_QueryServer) error
	VolumeNeedleStatus(context.Context, *VolumeNeedleStatusRequest) (*VolumeNeedleStatusResponse, error)
	Ping(context.Context, *PingRequest) (*PingResponse, error)
	// contains filtered or unexported methods
}

VolumeServerServer is the server API for VolumeServer service. All implementations must embed UnimplementedVolumeServerServer for forward compatibility

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"`
	Version      string        `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	DataCenter   string        `protobuf:"bytes,4,opt,name=data_center,json=dataCenter,proto3" json:"data_center,omitempty"`
	Rack         string        `protobuf:"bytes,5,opt,name=rack,proto3" json:"rack,omitempty"`
	// contains filtered or unexported fields
}

func (*VolumeServerStatusResponse) Descriptor deprecated 

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

Deprecated: Use VolumeServerStatusResponse.ProtoReflect.Descriptor instead.

func (*VolumeServerStatusResponse) GetDataCenter 

func (x *VolumeServerStatusResponse) GetDataCenter() string

func (*VolumeServerStatusResponse) GetDiskStatuses 

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

func (*VolumeServerStatusResponse) GetMemoryStatus 

func (x *VolumeServerStatusResponse) GetMemoryStatus() *MemStatus

func (*VolumeServerStatusResponse) GetRack 

func (x *VolumeServerStatusResponse) GetRack() string

func (*VolumeServerStatusResponse) GetVersion 

func (x *VolumeServerStatusResponse) GetVersion() string

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_ReadAllNeedlesClient 

type VolumeServer_ReadAllNeedlesClient interface {
	Recv() (*ReadAllNeedlesResponse, error)
	grpc.ClientStream
}

type VolumeServer_ReadAllNeedlesServer 

type VolumeServer_ReadAllNeedlesServer interface {
	Send(*ReadAllNeedlesResponse) error
	grpc.ServerStream
}

type VolumeServer_VacuumVolumeCompactClient 

type VolumeServer_VacuumVolumeCompactClient interface {
	Recv() (*VacuumVolumeCompactResponse, error)
	grpc.ClientStream
}

type VolumeServer_VacuumVolumeCompactServer 

type VolumeServer_VacuumVolumeCompactServer interface {
	Send(*VacuumVolumeCompactResponse) error
	grpc.ServerStream
}

type VolumeServer_VolumeCopyClient 

type VolumeServer_VolumeCopyClient interface {
	Recv() (*VolumeCopyResponse, error)
	grpc.ClientStream
}

type VolumeServer_VolumeCopyServer 

type VolumeServer_VolumeCopyServer interface {
	Send(*VolumeCopyResponse) 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
}

tiered storage

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

type WriteNeedleBlobRequest 

type WriteNeedleBlobRequest 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"`
	Size       int32  `protobuf:"varint,3,opt,name=size,proto3" json:"size,omitempty"`
	NeedleBlob []byte `protobuf:"bytes,4,opt,name=needle_blob,json=needleBlob,proto3" json:"needle_blob,omitempty"`
	// contains filtered or unexported fields
}

func (*WriteNeedleBlobRequest) Descriptor deprecated 

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

Deprecated: Use WriteNeedleBlobRequest.ProtoReflect.Descriptor instead.

func (*WriteNeedleBlobRequest) GetNeedleBlob 

func (x *WriteNeedleBlobRequest) GetNeedleBlob() []byte

func (*WriteNeedleBlobRequest) GetNeedleId 

func (x *WriteNeedleBlobRequest) GetNeedleId() uint64

func (*WriteNeedleBlobRequest) GetSize 

func (x *WriteNeedleBlobRequest) GetSize() int32

func (*WriteNeedleBlobRequest) GetVolumeId 

func (x *WriteNeedleBlobRequest) GetVolumeId() uint32

func (*WriteNeedleBlobRequest) ProtoMessage 

func (*WriteNeedleBlobRequest) ProtoMessage()

func (*WriteNeedleBlobRequest) ProtoReflect 

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

func (*WriteNeedleBlobRequest) Reset 

func (x *WriteNeedleBlobRequest) Reset()

func (*WriteNeedleBlobRequest) String 

func (x *WriteNeedleBlobRequest) String() string

type WriteNeedleBlobResponse 

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

func (*WriteNeedleBlobResponse) Descriptor deprecated 

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

Deprecated: Use WriteNeedleBlobResponse.ProtoReflect.Descriptor instead.

func (*WriteNeedleBlobResponse) ProtoMessage 

func (*WriteNeedleBlobResponse) ProtoMessage()

func (*WriteNeedleBlobResponse) ProtoReflect 

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

func (*WriteNeedleBlobResponse) Reset 

func (x *WriteNeedleBlobResponse) Reset()

func (*WriteNeedleBlobResponse) String 

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