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 (*FetchAndWriteNeedleRequest) GetReplicas

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 (*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 (*FetchAndWriteNeedleRequest_Replica) ProtoMessage

func (*FetchAndWriteNeedleRequest_Replica) ProtoMessage()

func (*FetchAndWriteNeedleRequest_Replica) ProtoReflect

func (*FetchAndWriteNeedleRequest_Replica) Reset

func (*FetchAndWriteNeedleRequest_Replica) 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 (*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 (*QueryRequest_InputSerialization) GetJsonInput

func (*QueryRequest_InputSerialization) GetParquetInput

func (*QueryRequest_InputSerialization) ProtoMessage

func (*QueryRequest_InputSerialization) ProtoMessage()

func (*QueryRequest_InputSerialization) ProtoReflect

func (*QueryRequest_InputSerialization) Reset

func (*QueryRequest_InputSerialization) 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 (*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) ProtoReflect

func (*QueryRequest_InputSerialization_CSVInput) Reset

func (*QueryRequest_InputSerialization_CSVInput) 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 (*QueryRequest_InputSerialization_JSONInput) ProtoMessage

func (*QueryRequest_InputSerialization_JSONInput) ProtoReflect

func (*QueryRequest_InputSerialization_JSONInput) Reset

func (*QueryRequest_InputSerialization_JSONInput) String

type QueryRequest_InputSerialization_ParquetInput

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

func (*QueryRequest_InputSerialization_ParquetInput) Descriptor deprecated

Deprecated: Use QueryRequest_InputSerialization_ParquetInput.ProtoReflect.Descriptor instead.

func (*QueryRequest_InputSerialization_ParquetInput) ProtoMessage

func (*QueryRequest_InputSerialization_ParquetInput) ProtoReflect

func (*QueryRequest_InputSerialization_ParquetInput) Reset

func (*QueryRequest_InputSerialization_ParquetInput) 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 (*QueryRequest_OutputSerialization) GetJsonOutput

func (*QueryRequest_OutputSerialization) ProtoMessage

func (*QueryRequest_OutputSerialization) ProtoMessage()

func (*QueryRequest_OutputSerialization) ProtoReflect

func (*QueryRequest_OutputSerialization) Reset

func (*QueryRequest_OutputSerialization) 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

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 (*QueryRequest_OutputSerialization_CSVOutput) GetRecordDelimiter

func (x *QueryRequest_OutputSerialization_CSVOutput) GetRecordDelimiter() string

func (*QueryRequest_OutputSerialization_CSVOutput) ProtoMessage

func (*QueryRequest_OutputSerialization_CSVOutput) ProtoReflect

func (*QueryRequest_OutputSerialization_CSVOutput) Reset

func (*QueryRequest_OutputSerialization_CSVOutput) 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

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

func (*QueryRequest_OutputSerialization_JSONOutput) Reset

func (*QueryRequest_OutputSerialization_JSONOutput) 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 (*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 (*ReadVolumeFileStatusResponse) Reset

func (x *ReadVolumeFileStatusResponse) Reset()

func (*ReadVolumeFileStatusResponse) 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) BatchDelete

func (UnimplementedVolumeServerServer) CopyFile

func (UnimplementedVolumeServerServer) DeleteCollection

func (UnimplementedVolumeServerServer) Ping

func (UnimplementedVolumeServerServer) Query

func (UnimplementedVolumeServerServer) ReadAllNeedles

func (UnimplementedVolumeServerServer) ReadNeedleBlob

func (UnimplementedVolumeServerServer) VacuumVolumeCheck

func (UnimplementedVolumeServerServer) VacuumVolumeCommit

func (UnimplementedVolumeServerServer) VolumeConfigure

func (UnimplementedVolumeServerServer) VolumeCopy

func (UnimplementedVolumeServerServer) VolumeDelete

func (UnimplementedVolumeServerServer) VolumeEcBlobDelete

func (UnimplementedVolumeServerServer) VolumeEcShardsCopy

func (UnimplementedVolumeServerServer) VolumeMarkReadonly

func (UnimplementedVolumeServerServer) VolumeMarkWritable

func (UnimplementedVolumeServerServer) VolumeMount

func (UnimplementedVolumeServerServer) VolumeNeedleStatus

func (UnimplementedVolumeServerServer) VolumeServerLeave

func (UnimplementedVolumeServerServer) VolumeServerStatus

func (UnimplementedVolumeServerServer) VolumeStatus

func (UnimplementedVolumeServerServer) VolumeSyncStatus

func (UnimplementedVolumeServerServer) VolumeTailReceiver

func (UnimplementedVolumeServerServer) VolumeUnmount

func (UnimplementedVolumeServerServer) WriteNeedleBlob

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 (*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 (*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 (*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 (*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 (*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 (*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 (*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 (*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 (*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 (*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 (*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 (*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 (*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 (*VolumeEcShardsDeleteResponse) Reset

func (x *VolumeEcShardsDeleteResponse) Reset()

func (*VolumeEcShardsDeleteResponse) 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 (*VolumeEcShardsGenerateRequest) Reset

func (x *VolumeEcShardsGenerateRequest) Reset()

func (*VolumeEcShardsGenerateRequest) 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 (*VolumeEcShardsGenerateResponse) Reset

func (x *VolumeEcShardsGenerateResponse) Reset()

func (*VolumeEcShardsGenerateResponse) 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 (*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 (*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 (*VolumeEcShardsRebuildRequest) Reset

func (x *VolumeEcShardsRebuildRequest) Reset()

func (*VolumeEcShardsRebuildRequest) 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 (*VolumeEcShardsRebuildResponse) Reset

func (x *VolumeEcShardsRebuildResponse) Reset()

func (*VolumeEcShardsRebuildResponse) 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 (*VolumeEcShardsToVolumeRequest) Reset

func (x *VolumeEcShardsToVolumeRequest) Reset()

func (*VolumeEcShardsToVolumeRequest) 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 (*VolumeEcShardsToVolumeResponse) Reset

func (x *VolumeEcShardsToVolumeResponse) Reset()

func (*VolumeEcShardsToVolumeResponse) 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 (*VolumeEcShardsUnmountRequest) Reset

func (x *VolumeEcShardsUnmountRequest) Reset()

func (*VolumeEcShardsUnmountRequest) 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 (*VolumeEcShardsUnmountResponse) Reset

func (x *VolumeEcShardsUnmountResponse) Reset()

func (*VolumeEcShardsUnmountResponse) 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 (*VolumeIncrementalCopyRequest) Reset

func (x *VolumeIncrementalCopyRequest) Reset()

func (*VolumeIncrementalCopyRequest) 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 (*VolumeIncrementalCopyResponse) Reset

func (x *VolumeIncrementalCopyResponse) Reset()

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

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 (*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 (*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 (*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 (*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 (*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 (*VolumeTierMoveDatFromRemoteRequest) Reset

func (*VolumeTierMoveDatFromRemoteRequest) 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 (*VolumeTierMoveDatFromRemoteResponse) Reset

func (*VolumeTierMoveDatFromRemoteResponse) 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 (*VolumeTierMoveDatToRemoteRequest) Reset

func (*VolumeTierMoveDatToRemoteRequest) 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 (*VolumeTierMoveDatToRemoteResponse) Reset

func (*VolumeTierMoveDatToRemoteResponse) 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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL