Documentation ¶
Index ¶
- Variables
- func RegisterSeaweedServer(s grpc.ServiceRegistrar, srv SeaweedServer)
- type AssignRequest
- func (*AssignRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AssignRequest) GetCollection() string
- func (x *AssignRequest) GetCount() uint64
- func (x *AssignRequest) GetDataCenter() string
- func (x *AssignRequest) GetDataNode() string
- func (x *AssignRequest) GetDiskType() string
- func (x *AssignRequest) GetMemoryMapMaxSizeMb() uint32
- func (x *AssignRequest) GetRack() string
- func (x *AssignRequest) GetReplication() string
- func (x *AssignRequest) GetTtl() string
- func (x *AssignRequest) GetWritableVolumeCount() uint32
- func (*AssignRequest) ProtoMessage()
- func (x *AssignRequest) ProtoReflect() protoreflect.Message
- func (x *AssignRequest) Reset()
- func (x *AssignRequest) String() string
- type AssignResponse
- func (*AssignResponse) Descriptor() ([]byte, []int)deprecated
- func (x *AssignResponse) GetAuth() string
- func (x *AssignResponse) GetCount() uint64
- func (x *AssignResponse) GetError() string
- func (x *AssignResponse) GetFid() string
- func (x *AssignResponse) GetLocation() *Location
- func (x *AssignResponse) GetReplicas() []*Location
- func (*AssignResponse) ProtoMessage()
- func (x *AssignResponse) ProtoReflect() protoreflect.Message
- func (x *AssignResponse) Reset()
- func (x *AssignResponse) String() string
- type ClusterNodeUpdate
- func (*ClusterNodeUpdate) Descriptor() ([]byte, []int)deprecated
- func (x *ClusterNodeUpdate) GetAddress() string
- func (x *ClusterNodeUpdate) GetFilerGroup() string
- func (x *ClusterNodeUpdate) GetIsAdd() bool
- func (x *ClusterNodeUpdate) GetIsLeader() bool
- func (x *ClusterNodeUpdate) GetNodeType() string
- func (*ClusterNodeUpdate) ProtoMessage()
- func (x *ClusterNodeUpdate) ProtoReflect() protoreflect.Message
- func (x *ClusterNodeUpdate) Reset()
- func (x *ClusterNodeUpdate) String() string
- type Collection
- type CollectionDeleteRequest
- func (*CollectionDeleteRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CollectionDeleteRequest) GetName() string
- func (*CollectionDeleteRequest) ProtoMessage()
- func (x *CollectionDeleteRequest) ProtoReflect() protoreflect.Message
- func (x *CollectionDeleteRequest) Reset()
- func (x *CollectionDeleteRequest) String() string
- type CollectionDeleteResponse
- type CollectionListRequest
- func (*CollectionListRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CollectionListRequest) GetIncludeEcVolumes() bool
- func (x *CollectionListRequest) GetIncludeNormalVolumes() bool
- func (*CollectionListRequest) ProtoMessage()
- func (x *CollectionListRequest) ProtoReflect() protoreflect.Message
- func (x *CollectionListRequest) Reset()
- func (x *CollectionListRequest) String() string
- type CollectionListResponse
- func (*CollectionListResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CollectionListResponse) GetCollections() []*Collection
- func (*CollectionListResponse) ProtoMessage()
- func (x *CollectionListResponse) ProtoReflect() protoreflect.Message
- func (x *CollectionListResponse) Reset()
- func (x *CollectionListResponse) String() string
- type DataCenterInfo
- func (*DataCenterInfo) Descriptor() ([]byte, []int)deprecated
- func (x *DataCenterInfo) GetDiskInfos() map[string]*DiskInfo
- func (x *DataCenterInfo) GetId() string
- func (x *DataCenterInfo) GetRackInfos() []*RackInfo
- func (*DataCenterInfo) ProtoMessage()
- func (x *DataCenterInfo) ProtoReflect() protoreflect.Message
- func (x *DataCenterInfo) Reset()
- func (x *DataCenterInfo) String() string
- type DataNodeInfo
- func (*DataNodeInfo) Descriptor() ([]byte, []int)deprecated
- func (x *DataNodeInfo) GetDiskInfos() map[string]*DiskInfo
- func (x *DataNodeInfo) GetGrpcPort() uint32
- func (x *DataNodeInfo) GetId() string
- func (*DataNodeInfo) ProtoMessage()
- func (x *DataNodeInfo) ProtoReflect() protoreflect.Message
- func (x *DataNodeInfo) Reset()
- func (x *DataNodeInfo) String() string
- type DiskInfo
- func (*DiskInfo) Descriptor() ([]byte, []int)deprecated
- func (x *DiskInfo) GetActiveVolumeCount() int64
- func (x *DiskInfo) GetEcShardInfos() []*VolumeEcShardInformationMessage
- func (x *DiskInfo) GetFreeVolumeCount() int64
- func (x *DiskInfo) GetMaxVolumeCount() int64
- func (x *DiskInfo) GetRemoteVolumeCount() int64
- func (x *DiskInfo) GetType() string
- func (x *DiskInfo) GetVolumeCount() int64
- func (x *DiskInfo) GetVolumeInfos() []*VolumeInformationMessage
- func (*DiskInfo) ProtoMessage()
- func (x *DiskInfo) ProtoReflect() protoreflect.Message
- func (x *DiskInfo) Reset()
- func (x *DiskInfo) String() string
- type Empty
- type GetMasterConfigurationRequest
- func (*GetMasterConfigurationRequest) Descriptor() ([]byte, []int)deprecated
- func (*GetMasterConfigurationRequest) ProtoMessage()
- func (x *GetMasterConfigurationRequest) ProtoReflect() protoreflect.Message
- func (x *GetMasterConfigurationRequest) Reset()
- func (x *GetMasterConfigurationRequest) String() string
- type GetMasterConfigurationResponse
- func (*GetMasterConfigurationResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetMasterConfigurationResponse) GetDefaultReplication() string
- func (x *GetMasterConfigurationResponse) GetLeader() string
- func (x *GetMasterConfigurationResponse) GetMetricsAddress() string
- func (x *GetMasterConfigurationResponse) GetMetricsIntervalSeconds() uint32
- func (x *GetMasterConfigurationResponse) GetStorageBackends() []*StorageBackend
- func (x *GetMasterConfigurationResponse) GetVolumePreallocate() bool
- func (x *GetMasterConfigurationResponse) GetVolumeSizeLimitMB() uint32
- func (*GetMasterConfigurationResponse) ProtoMessage()
- func (x *GetMasterConfigurationResponse) ProtoReflect() protoreflect.Message
- func (x *GetMasterConfigurationResponse) Reset()
- func (x *GetMasterConfigurationResponse) String() string
- type Heartbeat
- func (*Heartbeat) Descriptor() ([]byte, []int)deprecated
- func (x *Heartbeat) GetAdminPort() uint32
- func (x *Heartbeat) GetDataCenter() string
- func (x *Heartbeat) GetDeletedEcShards() []*VolumeEcShardInformationMessage
- func (x *Heartbeat) GetDeletedVolumes() []*VolumeShortInformationMessage
- func (x *Heartbeat) GetEcShards() []*VolumeEcShardInformationMessage
- func (x *Heartbeat) GetGrpcPort() uint32
- func (x *Heartbeat) GetHasNoEcShards() bool
- func (x *Heartbeat) GetHasNoVolumes() bool
- func (x *Heartbeat) GetIp() string
- func (x *Heartbeat) GetMaxFileKey() uint64
- func (x *Heartbeat) GetMaxVolumeCounts() map[string]uint32
- func (x *Heartbeat) GetNewEcShards() []*VolumeEcShardInformationMessage
- func (x *Heartbeat) GetNewVolumes() []*VolumeShortInformationMessage
- func (x *Heartbeat) GetPort() uint32
- func (x *Heartbeat) GetPublicUrl() string
- func (x *Heartbeat) GetRack() string
- func (x *Heartbeat) GetVolumes() []*VolumeInformationMessage
- func (*Heartbeat) ProtoMessage()
- func (x *Heartbeat) ProtoReflect() protoreflect.Message
- func (x *Heartbeat) Reset()
- func (x *Heartbeat) String() string
- type HeartbeatResponse
- func (*HeartbeatResponse) Descriptor() ([]byte, []int)deprecated
- func (x *HeartbeatResponse) GetLeader() string
- func (x *HeartbeatResponse) GetMetricsAddress() string
- func (x *HeartbeatResponse) GetMetricsIntervalSeconds() uint32
- func (x *HeartbeatResponse) GetStorageBackends() []*StorageBackend
- func (x *HeartbeatResponse) GetVolumeSizeLimit() uint64
- func (*HeartbeatResponse) ProtoMessage()
- func (x *HeartbeatResponse) ProtoReflect() protoreflect.Message
- func (x *HeartbeatResponse) Reset()
- func (x *HeartbeatResponse) String() string
- type KeepConnectedRequest
- func (*KeepConnectedRequest) Descriptor() ([]byte, []int)deprecated
- func (x *KeepConnectedRequest) GetClientAddress() string
- func (x *KeepConnectedRequest) GetClientType() string
- func (x *KeepConnectedRequest) GetFilerGroup() string
- func (x *KeepConnectedRequest) GetVersion() string
- func (*KeepConnectedRequest) ProtoMessage()
- func (x *KeepConnectedRequest) ProtoReflect() protoreflect.Message
- func (x *KeepConnectedRequest) Reset()
- func (x *KeepConnectedRequest) String() string
- type KeepConnectedResponse
- func (*KeepConnectedResponse) Descriptor() ([]byte, []int)deprecated
- func (x *KeepConnectedResponse) GetClusterNodeUpdate() *ClusterNodeUpdate
- func (x *KeepConnectedResponse) GetVolumeLocation() *VolumeLocation
- func (*KeepConnectedResponse) ProtoMessage()
- func (x *KeepConnectedResponse) ProtoReflect() protoreflect.Message
- func (x *KeepConnectedResponse) Reset()
- func (x *KeepConnectedResponse) String() string
- type LeaseAdminTokenRequest
- func (*LeaseAdminTokenRequest) Descriptor() ([]byte, []int)deprecated
- func (x *LeaseAdminTokenRequest) GetClientName() string
- func (x *LeaseAdminTokenRequest) GetLockName() string
- func (x *LeaseAdminTokenRequest) GetMessage() string
- func (x *LeaseAdminTokenRequest) GetPreviousLockTime() int64
- func (x *LeaseAdminTokenRequest) GetPreviousToken() int64
- func (*LeaseAdminTokenRequest) ProtoMessage()
- func (x *LeaseAdminTokenRequest) ProtoReflect() protoreflect.Message
- func (x *LeaseAdminTokenRequest) Reset()
- func (x *LeaseAdminTokenRequest) String() string
- type LeaseAdminTokenResponse
- func (*LeaseAdminTokenResponse) Descriptor() ([]byte, []int)deprecated
- func (x *LeaseAdminTokenResponse) GetLockTsNs() int64
- func (x *LeaseAdminTokenResponse) GetToken() int64
- func (*LeaseAdminTokenResponse) ProtoMessage()
- func (x *LeaseAdminTokenResponse) ProtoReflect() protoreflect.Message
- func (x *LeaseAdminTokenResponse) Reset()
- func (x *LeaseAdminTokenResponse) String() string
- type ListClusterNodesRequest
- func (*ListClusterNodesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListClusterNodesRequest) GetClientType() string
- func (x *ListClusterNodesRequest) GetFilerGroup() string
- func (*ListClusterNodesRequest) ProtoMessage()
- func (x *ListClusterNodesRequest) ProtoReflect() protoreflect.Message
- func (x *ListClusterNodesRequest) Reset()
- func (x *ListClusterNodesRequest) String() string
- type ListClusterNodesResponse
- func (*ListClusterNodesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListClusterNodesResponse) GetClusterNodes() []*ListClusterNodesResponse_ClusterNode
- func (*ListClusterNodesResponse) ProtoMessage()
- func (x *ListClusterNodesResponse) ProtoReflect() protoreflect.Message
- func (x *ListClusterNodesResponse) Reset()
- func (x *ListClusterNodesResponse) String() string
- type ListClusterNodesResponse_ClusterNode
- func (*ListClusterNodesResponse_ClusterNode) Descriptor() ([]byte, []int)deprecated
- func (x *ListClusterNodesResponse_ClusterNode) GetAddress() string
- func (x *ListClusterNodesResponse_ClusterNode) GetIsLeader() bool
- func (x *ListClusterNodesResponse_ClusterNode) GetVersion() string
- func (*ListClusterNodesResponse_ClusterNode) ProtoMessage()
- func (x *ListClusterNodesResponse_ClusterNode) ProtoReflect() protoreflect.Message
- func (x *ListClusterNodesResponse_ClusterNode) Reset()
- func (x *ListClusterNodesResponse_ClusterNode) String() string
- type Location
- func (*Location) Descriptor() ([]byte, []int)deprecated
- func (x *Location) GetGrpcPort() uint32
- func (x *Location) GetPublicUrl() string
- func (x *Location) GetUrl() string
- func (*Location) ProtoMessage()
- func (x *Location) ProtoReflect() protoreflect.Message
- func (x *Location) Reset()
- func (x *Location) String() string
- type LookupEcVolumeRequest
- func (*LookupEcVolumeRequest) Descriptor() ([]byte, []int)deprecated
- func (x *LookupEcVolumeRequest) GetVolumeId() uint32
- func (*LookupEcVolumeRequest) ProtoMessage()
- func (x *LookupEcVolumeRequest) ProtoReflect() protoreflect.Message
- func (x *LookupEcVolumeRequest) Reset()
- func (x *LookupEcVolumeRequest) String() string
- type LookupEcVolumeResponse
- func (*LookupEcVolumeResponse) Descriptor() ([]byte, []int)deprecated
- func (x *LookupEcVolumeResponse) GetShardIdLocations() []*LookupEcVolumeResponse_EcShardIdLocation
- func (x *LookupEcVolumeResponse) GetVolumeId() uint32
- func (*LookupEcVolumeResponse) ProtoMessage()
- func (x *LookupEcVolumeResponse) ProtoReflect() protoreflect.Message
- func (x *LookupEcVolumeResponse) Reset()
- func (x *LookupEcVolumeResponse) String() string
- type LookupEcVolumeResponse_EcShardIdLocation
- func (*LookupEcVolumeResponse_EcShardIdLocation) Descriptor() ([]byte, []int)deprecated
- func (x *LookupEcVolumeResponse_EcShardIdLocation) GetLocations() []*Location
- func (x *LookupEcVolumeResponse_EcShardIdLocation) GetShardId() uint32
- func (*LookupEcVolumeResponse_EcShardIdLocation) ProtoMessage()
- func (x *LookupEcVolumeResponse_EcShardIdLocation) ProtoReflect() protoreflect.Message
- func (x *LookupEcVolumeResponse_EcShardIdLocation) Reset()
- func (x *LookupEcVolumeResponse_EcShardIdLocation) String() string
- type LookupVolumeRequest
- func (*LookupVolumeRequest) Descriptor() ([]byte, []int)deprecated
- func (x *LookupVolumeRequest) GetCollection() string
- func (x *LookupVolumeRequest) GetVolumeOrFileIds() []string
- func (*LookupVolumeRequest) ProtoMessage()
- func (x *LookupVolumeRequest) ProtoReflect() protoreflect.Message
- func (x *LookupVolumeRequest) Reset()
- func (x *LookupVolumeRequest) String() string
- type LookupVolumeResponse
- func (*LookupVolumeResponse) Descriptor() ([]byte, []int)deprecated
- func (x *LookupVolumeResponse) GetVolumeIdLocations() []*LookupVolumeResponse_VolumeIdLocation
- func (*LookupVolumeResponse) ProtoMessage()
- func (x *LookupVolumeResponse) ProtoReflect() protoreflect.Message
- func (x *LookupVolumeResponse) Reset()
- func (x *LookupVolumeResponse) String() string
- type LookupVolumeResponse_VolumeIdLocation
- func (*LookupVolumeResponse_VolumeIdLocation) Descriptor() ([]byte, []int)deprecated
- func (x *LookupVolumeResponse_VolumeIdLocation) GetAuth() string
- func (x *LookupVolumeResponse_VolumeIdLocation) GetError() string
- func (x *LookupVolumeResponse_VolumeIdLocation) GetLocations() []*Location
- func (x *LookupVolumeResponse_VolumeIdLocation) GetVolumeOrFileId() string
- func (*LookupVolumeResponse_VolumeIdLocation) ProtoMessage()
- func (x *LookupVolumeResponse_VolumeIdLocation) ProtoReflect() protoreflect.Message
- func (x *LookupVolumeResponse_VolumeIdLocation) Reset()
- func (x *LookupVolumeResponse_VolumeIdLocation) String() string
- type PingRequest
- func (*PingRequest) Descriptor() ([]byte, []int)deprecated
- func (x *PingRequest) GetTarget() string
- func (x *PingRequest) GetTargetType() string
- func (*PingRequest) ProtoMessage()
- func (x *PingRequest) ProtoReflect() protoreflect.Message
- func (x *PingRequest) Reset()
- func (x *PingRequest) String() string
- type PingResponse
- func (*PingResponse) Descriptor() ([]byte, []int)deprecated
- func (x *PingResponse) GetRemoteTimeNs() int64
- func (x *PingResponse) GetStartTimeNs() int64
- func (x *PingResponse) GetStopTimeNs() int64
- func (*PingResponse) ProtoMessage()
- func (x *PingResponse) ProtoReflect() protoreflect.Message
- func (x *PingResponse) Reset()
- func (x *PingResponse) String() string
- type RackInfo
- func (*RackInfo) Descriptor() ([]byte, []int)deprecated
- func (x *RackInfo) GetDataNodeInfos() []*DataNodeInfo
- func (x *RackInfo) GetDiskInfos() map[string]*DiskInfo
- func (x *RackInfo) GetId() string
- func (*RackInfo) ProtoMessage()
- func (x *RackInfo) ProtoReflect() protoreflect.Message
- func (x *RackInfo) Reset()
- func (x *RackInfo) String() string
- type RaftAddServerRequest
- func (*RaftAddServerRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RaftAddServerRequest) GetAddress() string
- func (x *RaftAddServerRequest) GetId() string
- func (x *RaftAddServerRequest) GetVoter() bool
- func (*RaftAddServerRequest) ProtoMessage()
- func (x *RaftAddServerRequest) ProtoReflect() protoreflect.Message
- func (x *RaftAddServerRequest) Reset()
- func (x *RaftAddServerRequest) String() string
- type RaftAddServerResponse
- type RaftListClusterServersRequest
- func (*RaftListClusterServersRequest) Descriptor() ([]byte, []int)deprecated
- func (*RaftListClusterServersRequest) ProtoMessage()
- func (x *RaftListClusterServersRequest) ProtoReflect() protoreflect.Message
- func (x *RaftListClusterServersRequest) Reset()
- func (x *RaftListClusterServersRequest) String() string
- type RaftListClusterServersResponse
- func (*RaftListClusterServersResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RaftListClusterServersResponse) GetClusterServers() []*RaftListClusterServersResponse_ClusterServers
- func (*RaftListClusterServersResponse) ProtoMessage()
- func (x *RaftListClusterServersResponse) ProtoReflect() protoreflect.Message
- func (x *RaftListClusterServersResponse) Reset()
- func (x *RaftListClusterServersResponse) String() string
- type RaftListClusterServersResponse_ClusterServers
- func (*RaftListClusterServersResponse_ClusterServers) Descriptor() ([]byte, []int)deprecated
- func (x *RaftListClusterServersResponse_ClusterServers) GetAddress() string
- func (x *RaftListClusterServersResponse_ClusterServers) GetId() string
- func (x *RaftListClusterServersResponse_ClusterServers) GetSuffrage() string
- func (*RaftListClusterServersResponse_ClusterServers) ProtoMessage()
- func (x *RaftListClusterServersResponse_ClusterServers) ProtoReflect() protoreflect.Message
- func (x *RaftListClusterServersResponse_ClusterServers) Reset()
- func (x *RaftListClusterServersResponse_ClusterServers) String() string
- type RaftRemoveServerRequest
- func (*RaftRemoveServerRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RaftRemoveServerRequest) GetForce() bool
- func (x *RaftRemoveServerRequest) GetId() string
- func (*RaftRemoveServerRequest) ProtoMessage()
- func (x *RaftRemoveServerRequest) ProtoReflect() protoreflect.Message
- func (x *RaftRemoveServerRequest) Reset()
- func (x *RaftRemoveServerRequest) String() string
- type RaftRemoveServerResponse
- type ReleaseAdminTokenRequest
- func (*ReleaseAdminTokenRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ReleaseAdminTokenRequest) GetLockName() string
- func (x *ReleaseAdminTokenRequest) GetPreviousLockTime() int64
- func (x *ReleaseAdminTokenRequest) GetPreviousToken() int64
- func (*ReleaseAdminTokenRequest) ProtoMessage()
- func (x *ReleaseAdminTokenRequest) ProtoReflect() protoreflect.Message
- func (x *ReleaseAdminTokenRequest) Reset()
- func (x *ReleaseAdminTokenRequest) String() string
- type ReleaseAdminTokenResponse
- type SeaweedClient
- type SeaweedServer
- type Seaweed_KeepConnectedClient
- type Seaweed_KeepConnectedServer
- type Seaweed_SendHeartbeatClient
- type Seaweed_SendHeartbeatServer
- type StatisticsRequest
- func (*StatisticsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StatisticsRequest) GetCollection() string
- func (x *StatisticsRequest) GetDiskType() string
- func (x *StatisticsRequest) GetReplication() string
- func (x *StatisticsRequest) GetTtl() string
- func (*StatisticsRequest) ProtoMessage()
- func (x *StatisticsRequest) ProtoReflect() protoreflect.Message
- func (x *StatisticsRequest) Reset()
- func (x *StatisticsRequest) String() string
- type StatisticsResponse
- func (*StatisticsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *StatisticsResponse) GetFileCount() uint64
- func (x *StatisticsResponse) GetTotalSize() uint64
- func (x *StatisticsResponse) GetUsedSize() uint64
- func (*StatisticsResponse) ProtoMessage()
- func (x *StatisticsResponse) ProtoReflect() protoreflect.Message
- func (x *StatisticsResponse) Reset()
- func (x *StatisticsResponse) String() string
- type StorageBackend
- func (*StorageBackend) Descriptor() ([]byte, []int)deprecated
- func (x *StorageBackend) GetId() string
- func (x *StorageBackend) GetProperties() map[string]string
- func (x *StorageBackend) GetType() string
- func (*StorageBackend) ProtoMessage()
- func (x *StorageBackend) ProtoReflect() protoreflect.Message
- func (x *StorageBackend) Reset()
- func (x *StorageBackend) String() string
- type SuperBlockExtra
- func (*SuperBlockExtra) Descriptor() ([]byte, []int)deprecated
- func (x *SuperBlockExtra) GetErasureCoding() *SuperBlockExtra_ErasureCoding
- func (*SuperBlockExtra) ProtoMessage()
- func (x *SuperBlockExtra) ProtoReflect() protoreflect.Message
- func (x *SuperBlockExtra) Reset()
- func (x *SuperBlockExtra) String() string
- type SuperBlockExtra_ErasureCoding
- func (*SuperBlockExtra_ErasureCoding) Descriptor() ([]byte, []int)deprecated
- func (x *SuperBlockExtra_ErasureCoding) GetData() uint32
- func (x *SuperBlockExtra_ErasureCoding) GetParity() uint32
- func (x *SuperBlockExtra_ErasureCoding) GetVolumeIds() []uint32
- func (*SuperBlockExtra_ErasureCoding) ProtoMessage()
- func (x *SuperBlockExtra_ErasureCoding) ProtoReflect() protoreflect.Message
- func (x *SuperBlockExtra_ErasureCoding) Reset()
- func (x *SuperBlockExtra_ErasureCoding) String() string
- type TopologyInfo
- func (*TopologyInfo) Descriptor() ([]byte, []int)deprecated
- func (x *TopologyInfo) GetDataCenterInfos() []*DataCenterInfo
- func (x *TopologyInfo) GetDiskInfos() map[string]*DiskInfo
- func (x *TopologyInfo) GetId() string
- func (*TopologyInfo) ProtoMessage()
- func (x *TopologyInfo) ProtoReflect() protoreflect.Message
- func (x *TopologyInfo) Reset()
- func (x *TopologyInfo) String() string
- type UnimplementedSeaweedServer
- func (UnimplementedSeaweedServer) Assign(context.Context, *AssignRequest) (*AssignResponse, error)
- func (UnimplementedSeaweedServer) CollectionDelete(context.Context, *CollectionDeleteRequest) (*CollectionDeleteResponse, error)
- func (UnimplementedSeaweedServer) CollectionList(context.Context, *CollectionListRequest) (*CollectionListResponse, error)
- func (UnimplementedSeaweedServer) GetMasterConfiguration(context.Context, *GetMasterConfigurationRequest) (*GetMasterConfigurationResponse, error)
- func (UnimplementedSeaweedServer) KeepConnected(Seaweed_KeepConnectedServer) error
- func (UnimplementedSeaweedServer) LeaseAdminToken(context.Context, *LeaseAdminTokenRequest) (*LeaseAdminTokenResponse, error)
- func (UnimplementedSeaweedServer) ListClusterNodes(context.Context, *ListClusterNodesRequest) (*ListClusterNodesResponse, error)
- func (UnimplementedSeaweedServer) LookupEcVolume(context.Context, *LookupEcVolumeRequest) (*LookupEcVolumeResponse, error)
- func (UnimplementedSeaweedServer) LookupVolume(context.Context, *LookupVolumeRequest) (*LookupVolumeResponse, error)
- func (UnimplementedSeaweedServer) Ping(context.Context, *PingRequest) (*PingResponse, error)
- func (UnimplementedSeaweedServer) RaftAddServer(context.Context, *RaftAddServerRequest) (*RaftAddServerResponse, error)
- func (UnimplementedSeaweedServer) RaftListClusterServers(context.Context, *RaftListClusterServersRequest) (*RaftListClusterServersResponse, error)
- func (UnimplementedSeaweedServer) RaftRemoveServer(context.Context, *RaftRemoveServerRequest) (*RaftRemoveServerResponse, error)
- func (UnimplementedSeaweedServer) ReleaseAdminToken(context.Context, *ReleaseAdminTokenRequest) (*ReleaseAdminTokenResponse, error)
- func (UnimplementedSeaweedServer) SendHeartbeat(Seaweed_SendHeartbeatServer) error
- func (UnimplementedSeaweedServer) Statistics(context.Context, *StatisticsRequest) (*StatisticsResponse, error)
- func (UnimplementedSeaweedServer) VacuumVolume(context.Context, *VacuumVolumeRequest) (*VacuumVolumeResponse, error)
- func (UnimplementedSeaweedServer) VolumeList(context.Context, *VolumeListRequest) (*VolumeListResponse, error)
- type UnsafeSeaweedServer
- type VacuumVolumeRequest
- func (*VacuumVolumeRequest) Descriptor() ([]byte, []int)deprecated
- func (x *VacuumVolumeRequest) GetCollection() string
- func (x *VacuumVolumeRequest) GetGarbageThreshold() float32
- func (x *VacuumVolumeRequest) GetVolumeId() uint32
- func (*VacuumVolumeRequest) ProtoMessage()
- func (x *VacuumVolumeRequest) ProtoReflect() protoreflect.Message
- func (x *VacuumVolumeRequest) Reset()
- func (x *VacuumVolumeRequest) String() string
- type VacuumVolumeResponse
- type VolumeEcShardInformationMessage
- func (*VolumeEcShardInformationMessage) Descriptor() ([]byte, []int)deprecated
- func (x *VolumeEcShardInformationMessage) GetCollection() string
- func (x *VolumeEcShardInformationMessage) GetDiskType() string
- func (x *VolumeEcShardInformationMessage) GetEcIndexBits() uint32
- func (x *VolumeEcShardInformationMessage) GetId() uint32
- func (*VolumeEcShardInformationMessage) ProtoMessage()
- func (x *VolumeEcShardInformationMessage) ProtoReflect() protoreflect.Message
- func (x *VolumeEcShardInformationMessage) Reset()
- func (x *VolumeEcShardInformationMessage) String() string
- type VolumeInformationMessage
- func (*VolumeInformationMessage) Descriptor() ([]byte, []int)deprecated
- func (x *VolumeInformationMessage) GetCollection() string
- func (x *VolumeInformationMessage) GetCompactRevision() uint32
- func (x *VolumeInformationMessage) GetDeleteCount() uint64
- func (x *VolumeInformationMessage) GetDeletedByteCount() uint64
- func (x *VolumeInformationMessage) GetDiskType() string
- func (x *VolumeInformationMessage) GetFileCount() uint64
- func (x *VolumeInformationMessage) GetId() uint32
- func (x *VolumeInformationMessage) GetModifiedAtSecond() int64
- func (x *VolumeInformationMessage) GetReadOnly() bool
- func (x *VolumeInformationMessage) GetRemoteStorageKey() string
- func (x *VolumeInformationMessage) GetRemoteStorageName() string
- func (x *VolumeInformationMessage) GetReplicaPlacement() uint32
- func (x *VolumeInformationMessage) GetSize() uint64
- func (x *VolumeInformationMessage) GetTtl() uint32
- func (x *VolumeInformationMessage) GetVersion() uint32
- func (*VolumeInformationMessage) ProtoMessage()
- func (x *VolumeInformationMessage) ProtoReflect() protoreflect.Message
- func (x *VolumeInformationMessage) Reset()
- func (x *VolumeInformationMessage) String() string
- type VolumeListRequest
- type VolumeListResponse
- func (*VolumeListResponse) Descriptor() ([]byte, []int)deprecated
- func (x *VolumeListResponse) GetTopologyInfo() *TopologyInfo
- func (x *VolumeListResponse) GetVolumeSizeLimitMb() uint64
- func (*VolumeListResponse) ProtoMessage()
- func (x *VolumeListResponse) ProtoReflect() protoreflect.Message
- func (x *VolumeListResponse) Reset()
- func (x *VolumeListResponse) String() string
- type VolumeLocation
- func (*VolumeLocation) Descriptor() ([]byte, []int)deprecated
- func (x *VolumeLocation) GetDataCenter() string
- func (x *VolumeLocation) GetDeletedEcVids() []uint32
- func (x *VolumeLocation) GetDeletedVids() []uint32
- func (x *VolumeLocation) GetGrpcPort() uint32
- func (x *VolumeLocation) GetLeader() string
- func (x *VolumeLocation) GetNewEcVids() []uint32
- func (x *VolumeLocation) GetNewVids() []uint32
- func (x *VolumeLocation) GetPublicUrl() string
- func (x *VolumeLocation) GetUrl() string
- func (*VolumeLocation) ProtoMessage()
- func (x *VolumeLocation) ProtoReflect() protoreflect.Message
- func (x *VolumeLocation) Reset()
- func (x *VolumeLocation) String() string
- type VolumeShortInformationMessage
- func (*VolumeShortInformationMessage) Descriptor() ([]byte, []int)deprecated
- func (x *VolumeShortInformationMessage) GetCollection() string
- func (x *VolumeShortInformationMessage) GetDiskType() string
- func (x *VolumeShortInformationMessage) GetId() uint32
- func (x *VolumeShortInformationMessage) GetReplicaPlacement() uint32
- func (x *VolumeShortInformationMessage) GetTtl() uint32
- func (x *VolumeShortInformationMessage) GetVersion() uint32
- func (*VolumeShortInformationMessage) ProtoMessage()
- func (x *VolumeShortInformationMessage) ProtoReflect() protoreflect.Message
- func (x *VolumeShortInformationMessage) Reset()
- func (x *VolumeShortInformationMessage) String() string
Constants ¶
This section is empty.
Variables ¶
var File_master_proto protoreflect.FileDescriptor
var Seaweed_ServiceDesc = grpc.ServiceDesc{ ServiceName: "master_pb.Seaweed", HandlerType: (*SeaweedServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "LookupVolume", Handler: _Seaweed_LookupVolume_Handler, }, { MethodName: "Assign", Handler: _Seaweed_Assign_Handler, }, { MethodName: "Statistics", Handler: _Seaweed_Statistics_Handler, }, { MethodName: "CollectionList", Handler: _Seaweed_CollectionList_Handler, }, { MethodName: "CollectionDelete", Handler: _Seaweed_CollectionDelete_Handler, }, { MethodName: "VolumeList", Handler: _Seaweed_VolumeList_Handler, }, { MethodName: "LookupEcVolume", Handler: _Seaweed_LookupEcVolume_Handler, }, { MethodName: "VacuumVolume", Handler: _Seaweed_VacuumVolume_Handler, }, { MethodName: "GetMasterConfiguration", Handler: _Seaweed_GetMasterConfiguration_Handler, }, { MethodName: "ListClusterNodes", Handler: _Seaweed_ListClusterNodes_Handler, }, { MethodName: "LeaseAdminToken", Handler: _Seaweed_LeaseAdminToken_Handler, }, { MethodName: "ReleaseAdminToken", Handler: _Seaweed_ReleaseAdminToken_Handler, }, { MethodName: "Ping", Handler: _Seaweed_Ping_Handler, }, { MethodName: "RaftListClusterServers", Handler: _Seaweed_RaftListClusterServers_Handler, }, { MethodName: "RaftAddServer", Handler: _Seaweed_RaftAddServer_Handler, }, { MethodName: "RaftRemoveServer", Handler: _Seaweed_RaftRemoveServer_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "SendHeartbeat", Handler: _Seaweed_SendHeartbeat_Handler, ServerStreams: true, ClientStreams: true, }, { StreamName: "KeepConnected", Handler: _Seaweed_KeepConnected_Handler, ServerStreams: true, ClientStreams: true, }, }, Metadata: "master.proto", }
Seaweed_ServiceDesc is the grpc.ServiceDesc for Seaweed service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterSeaweedServer ¶
func RegisterSeaweedServer(s grpc.ServiceRegistrar, srv SeaweedServer)
Types ¶
type AssignRequest ¶
type AssignRequest struct { Count uint64 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"` Replication string `protobuf:"bytes,2,opt,name=replication,proto3" json:"replication,omitempty"` Collection string `protobuf:"bytes,3,opt,name=collection,proto3" json:"collection,omitempty"` Ttl string `protobuf:"bytes,4,opt,name=ttl,proto3" json:"ttl,omitempty"` DataCenter string `protobuf:"bytes,5,opt,name=data_center,json=dataCenter,proto3" json:"data_center,omitempty"` Rack string `protobuf:"bytes,6,opt,name=rack,proto3" json:"rack,omitempty"` DataNode string `protobuf:"bytes,7,opt,name=data_node,json=dataNode,proto3" json:"data_node,omitempty"` MemoryMapMaxSizeMb uint32 `protobuf:"varint,8,opt,name=memory_map_max_size_mb,json=memoryMapMaxSizeMb,proto3" json:"memory_map_max_size_mb,omitempty"` WritableVolumeCount uint32 `protobuf:"varint,9,opt,name=Writable_volume_count,json=WritableVolumeCount,proto3" json:"Writable_volume_count,omitempty"` DiskType string `protobuf:"bytes,10,opt,name=disk_type,json=diskType,proto3" json:"disk_type,omitempty"` // contains filtered or unexported fields }
func (*AssignRequest) Descriptor
deprecated
func (*AssignRequest) Descriptor() ([]byte, []int)
Deprecated: Use AssignRequest.ProtoReflect.Descriptor instead.
func (*AssignRequest) GetCollection ¶
func (x *AssignRequest) GetCollection() string
func (*AssignRequest) GetCount ¶
func (x *AssignRequest) GetCount() uint64
func (*AssignRequest) GetDataCenter ¶
func (x *AssignRequest) GetDataCenter() string
func (*AssignRequest) GetDataNode ¶
func (x *AssignRequest) GetDataNode() string
func (*AssignRequest) GetDiskType ¶
func (x *AssignRequest) GetDiskType() string
func (*AssignRequest) GetMemoryMapMaxSizeMb ¶
func (x *AssignRequest) GetMemoryMapMaxSizeMb() uint32
func (*AssignRequest) GetRack ¶
func (x *AssignRequest) GetRack() string
func (*AssignRequest) GetReplication ¶
func (x *AssignRequest) GetReplication() string
func (*AssignRequest) GetTtl ¶
func (x *AssignRequest) GetTtl() string
func (*AssignRequest) GetWritableVolumeCount ¶
func (x *AssignRequest) GetWritableVolumeCount() uint32
func (*AssignRequest) ProtoMessage ¶
func (*AssignRequest) ProtoMessage()
func (*AssignRequest) ProtoReflect ¶
func (x *AssignRequest) ProtoReflect() protoreflect.Message
func (*AssignRequest) Reset ¶
func (x *AssignRequest) Reset()
func (*AssignRequest) String ¶
func (x *AssignRequest) String() string
type AssignResponse ¶
type AssignResponse struct { Fid string `protobuf:"bytes,1,opt,name=fid,proto3" json:"fid,omitempty"` Count uint64 `protobuf:"varint,4,opt,name=count,proto3" json:"count,omitempty"` Error string `protobuf:"bytes,5,opt,name=error,proto3" json:"error,omitempty"` Auth string `protobuf:"bytes,6,opt,name=auth,proto3" json:"auth,omitempty"` Replicas []*Location `protobuf:"bytes,7,rep,name=replicas,proto3" json:"replicas,omitempty"` Location *Location `protobuf:"bytes,8,opt,name=location,proto3" json:"location,omitempty"` // contains filtered or unexported fields }
func (*AssignResponse) Descriptor
deprecated
func (*AssignResponse) Descriptor() ([]byte, []int)
Deprecated: Use AssignResponse.ProtoReflect.Descriptor instead.
func (*AssignResponse) GetAuth ¶
func (x *AssignResponse) GetAuth() string
func (*AssignResponse) GetCount ¶
func (x *AssignResponse) GetCount() uint64
func (*AssignResponse) GetError ¶
func (x *AssignResponse) GetError() string
func (*AssignResponse) GetFid ¶
func (x *AssignResponse) GetFid() string
func (*AssignResponse) GetLocation ¶
func (x *AssignResponse) GetLocation() *Location
func (*AssignResponse) GetReplicas ¶
func (x *AssignResponse) GetReplicas() []*Location
func (*AssignResponse) ProtoMessage ¶
func (*AssignResponse) ProtoMessage()
func (*AssignResponse) ProtoReflect ¶
func (x *AssignResponse) ProtoReflect() protoreflect.Message
func (*AssignResponse) Reset ¶
func (x *AssignResponse) Reset()
func (*AssignResponse) String ¶
func (x *AssignResponse) String() string
type ClusterNodeUpdate ¶
type ClusterNodeUpdate struct { NodeType string `protobuf:"bytes,1,opt,name=node_type,json=nodeType,proto3" json:"node_type,omitempty"` Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"` IsLeader bool `protobuf:"varint,3,opt,name=is_leader,json=isLeader,proto3" json:"is_leader,omitempty"` IsAdd bool `protobuf:"varint,4,opt,name=is_add,json=isAdd,proto3" json:"is_add,omitempty"` FilerGroup string `protobuf:"bytes,5,opt,name=filer_group,json=filerGroup,proto3" json:"filer_group,omitempty"` // contains filtered or unexported fields }
func (*ClusterNodeUpdate) Descriptor
deprecated
func (*ClusterNodeUpdate) Descriptor() ([]byte, []int)
Deprecated: Use ClusterNodeUpdate.ProtoReflect.Descriptor instead.
func (*ClusterNodeUpdate) GetAddress ¶
func (x *ClusterNodeUpdate) GetAddress() string
func (*ClusterNodeUpdate) GetFilerGroup ¶
func (x *ClusterNodeUpdate) GetFilerGroup() string
func (*ClusterNodeUpdate) GetIsAdd ¶
func (x *ClusterNodeUpdate) GetIsAdd() bool
func (*ClusterNodeUpdate) GetIsLeader ¶
func (x *ClusterNodeUpdate) GetIsLeader() bool
func (*ClusterNodeUpdate) GetNodeType ¶
func (x *ClusterNodeUpdate) GetNodeType() string
func (*ClusterNodeUpdate) ProtoMessage ¶
func (*ClusterNodeUpdate) ProtoMessage()
func (*ClusterNodeUpdate) ProtoReflect ¶
func (x *ClusterNodeUpdate) ProtoReflect() protoreflect.Message
func (*ClusterNodeUpdate) Reset ¶
func (x *ClusterNodeUpdate) Reset()
func (*ClusterNodeUpdate) String ¶
func (x *ClusterNodeUpdate) String() string
type Collection ¶
type Collection struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
collection related
func (*Collection) Descriptor
deprecated
func (*Collection) Descriptor() ([]byte, []int)
Deprecated: Use Collection.ProtoReflect.Descriptor instead.
func (*Collection) GetName ¶
func (x *Collection) GetName() string
func (*Collection) ProtoMessage ¶
func (*Collection) ProtoMessage()
func (*Collection) ProtoReflect ¶
func (x *Collection) ProtoReflect() protoreflect.Message
func (*Collection) Reset ¶
func (x *Collection) Reset()
func (*Collection) String ¶
func (x *Collection) String() string
type CollectionDeleteRequest ¶
type CollectionDeleteRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
func (*CollectionDeleteRequest) Descriptor
deprecated
func (*CollectionDeleteRequest) Descriptor() ([]byte, []int)
Deprecated: Use CollectionDeleteRequest.ProtoReflect.Descriptor instead.
func (*CollectionDeleteRequest) GetName ¶
func (x *CollectionDeleteRequest) GetName() string
func (*CollectionDeleteRequest) ProtoMessage ¶
func (*CollectionDeleteRequest) ProtoMessage()
func (*CollectionDeleteRequest) ProtoReflect ¶
func (x *CollectionDeleteRequest) ProtoReflect() protoreflect.Message
func (*CollectionDeleteRequest) Reset ¶
func (x *CollectionDeleteRequest) Reset()
func (*CollectionDeleteRequest) String ¶
func (x *CollectionDeleteRequest) String() string
type CollectionDeleteResponse ¶
type CollectionDeleteResponse struct {
// contains filtered or unexported fields
}
func (*CollectionDeleteResponse) Descriptor
deprecated
func (*CollectionDeleteResponse) Descriptor() ([]byte, []int)
Deprecated: Use CollectionDeleteResponse.ProtoReflect.Descriptor instead.
func (*CollectionDeleteResponse) ProtoMessage ¶
func (*CollectionDeleteResponse) ProtoMessage()
func (*CollectionDeleteResponse) ProtoReflect ¶
func (x *CollectionDeleteResponse) ProtoReflect() protoreflect.Message
func (*CollectionDeleteResponse) Reset ¶
func (x *CollectionDeleteResponse) Reset()
func (*CollectionDeleteResponse) String ¶
func (x *CollectionDeleteResponse) String() string
type CollectionListRequest ¶
type CollectionListRequest struct { IncludeNormalVolumes bool `protobuf:"varint,1,opt,name=include_normal_volumes,json=includeNormalVolumes,proto3" json:"include_normal_volumes,omitempty"` IncludeEcVolumes bool `protobuf:"varint,2,opt,name=include_ec_volumes,json=includeEcVolumes,proto3" json:"include_ec_volumes,omitempty"` // contains filtered or unexported fields }
func (*CollectionListRequest) Descriptor
deprecated
func (*CollectionListRequest) Descriptor() ([]byte, []int)
Deprecated: Use CollectionListRequest.ProtoReflect.Descriptor instead.
func (*CollectionListRequest) GetIncludeEcVolumes ¶
func (x *CollectionListRequest) GetIncludeEcVolumes() bool
func (*CollectionListRequest) GetIncludeNormalVolumes ¶
func (x *CollectionListRequest) GetIncludeNormalVolumes() bool
func (*CollectionListRequest) ProtoMessage ¶
func (*CollectionListRequest) ProtoMessage()
func (*CollectionListRequest) ProtoReflect ¶
func (x *CollectionListRequest) ProtoReflect() protoreflect.Message
func (*CollectionListRequest) Reset ¶
func (x *CollectionListRequest) Reset()
func (*CollectionListRequest) String ¶
func (x *CollectionListRequest) String() string
type CollectionListResponse ¶
type CollectionListResponse struct { Collections []*Collection `protobuf:"bytes,1,rep,name=collections,proto3" json:"collections,omitempty"` // contains filtered or unexported fields }
func (*CollectionListResponse) Descriptor
deprecated
func (*CollectionListResponse) Descriptor() ([]byte, []int)
Deprecated: Use CollectionListResponse.ProtoReflect.Descriptor instead.
func (*CollectionListResponse) GetCollections ¶
func (x *CollectionListResponse) GetCollections() []*Collection
func (*CollectionListResponse) ProtoMessage ¶
func (*CollectionListResponse) ProtoMessage()
func (*CollectionListResponse) ProtoReflect ¶
func (x *CollectionListResponse) ProtoReflect() protoreflect.Message
func (*CollectionListResponse) Reset ¶
func (x *CollectionListResponse) Reset()
func (*CollectionListResponse) String ¶
func (x *CollectionListResponse) String() string
type DataCenterInfo ¶
type DataCenterInfo struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` RackInfos []*RackInfo `protobuf:"bytes,2,rep,name=rack_infos,json=rackInfos,proto3" json:"rack_infos,omitempty"` DiskInfos map[string]*DiskInfo `` /* 159-byte string literal not displayed */ // contains filtered or unexported fields }
func (*DataCenterInfo) Descriptor
deprecated
func (*DataCenterInfo) Descriptor() ([]byte, []int)
Deprecated: Use DataCenterInfo.ProtoReflect.Descriptor instead.
func (*DataCenterInfo) GetDiskInfos ¶
func (x *DataCenterInfo) GetDiskInfos() map[string]*DiskInfo
func (*DataCenterInfo) GetId ¶
func (x *DataCenterInfo) GetId() string
func (*DataCenterInfo) GetRackInfos ¶
func (x *DataCenterInfo) GetRackInfos() []*RackInfo
func (*DataCenterInfo) ProtoMessage ¶
func (*DataCenterInfo) ProtoMessage()
func (*DataCenterInfo) ProtoReflect ¶
func (x *DataCenterInfo) ProtoReflect() protoreflect.Message
func (*DataCenterInfo) Reset ¶
func (x *DataCenterInfo) Reset()
func (*DataCenterInfo) String ¶
func (x *DataCenterInfo) String() string
type DataNodeInfo ¶
type DataNodeInfo struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` DiskInfos map[string]*DiskInfo `` /* 159-byte string literal not displayed */ GrpcPort uint32 `protobuf:"varint,3,opt,name=grpc_port,json=grpcPort,proto3" json:"grpc_port,omitempty"` // contains filtered or unexported fields }
func (*DataNodeInfo) Descriptor
deprecated
func (*DataNodeInfo) Descriptor() ([]byte, []int)
Deprecated: Use DataNodeInfo.ProtoReflect.Descriptor instead.
func (*DataNodeInfo) GetDiskInfos ¶
func (x *DataNodeInfo) GetDiskInfos() map[string]*DiskInfo
func (*DataNodeInfo) GetGrpcPort ¶
func (x *DataNodeInfo) GetGrpcPort() uint32
func (*DataNodeInfo) GetId ¶
func (x *DataNodeInfo) GetId() string
func (*DataNodeInfo) ProtoMessage ¶
func (*DataNodeInfo) ProtoMessage()
func (*DataNodeInfo) ProtoReflect ¶
func (x *DataNodeInfo) ProtoReflect() protoreflect.Message
func (*DataNodeInfo) Reset ¶
func (x *DataNodeInfo) Reset()
func (*DataNodeInfo) String ¶
func (x *DataNodeInfo) String() string
type DiskInfo ¶
type DiskInfo struct { Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"` VolumeCount int64 `protobuf:"varint,2,opt,name=volume_count,json=volumeCount,proto3" json:"volume_count,omitempty"` MaxVolumeCount int64 `protobuf:"varint,3,opt,name=max_volume_count,json=maxVolumeCount,proto3" json:"max_volume_count,omitempty"` FreeVolumeCount int64 `protobuf:"varint,4,opt,name=free_volume_count,json=freeVolumeCount,proto3" json:"free_volume_count,omitempty"` ActiveVolumeCount int64 `protobuf:"varint,5,opt,name=active_volume_count,json=activeVolumeCount,proto3" json:"active_volume_count,omitempty"` VolumeInfos []*VolumeInformationMessage `protobuf:"bytes,6,rep,name=volume_infos,json=volumeInfos,proto3" json:"volume_infos,omitempty"` EcShardInfos []*VolumeEcShardInformationMessage `protobuf:"bytes,7,rep,name=ec_shard_infos,json=ecShardInfos,proto3" json:"ec_shard_infos,omitempty"` RemoteVolumeCount int64 `protobuf:"varint,8,opt,name=remote_volume_count,json=remoteVolumeCount,proto3" json:"remote_volume_count,omitempty"` // contains filtered or unexported fields }
volume related
func (*DiskInfo) Descriptor
deprecated
func (*DiskInfo) GetActiveVolumeCount ¶
func (*DiskInfo) GetEcShardInfos ¶
func (x *DiskInfo) GetEcShardInfos() []*VolumeEcShardInformationMessage
func (*DiskInfo) GetFreeVolumeCount ¶
func (*DiskInfo) GetMaxVolumeCount ¶
func (*DiskInfo) GetRemoteVolumeCount ¶
func (*DiskInfo) GetVolumeCount ¶
func (*DiskInfo) GetVolumeInfos ¶
func (x *DiskInfo) GetVolumeInfos() []*VolumeInformationMessage
func (*DiskInfo) ProtoMessage ¶
func (*DiskInfo) ProtoMessage()
func (*DiskInfo) ProtoReflect ¶
func (x *DiskInfo) ProtoReflect() protoreflect.Message
type Empty ¶
type Empty struct {
// contains filtered or unexported fields
}
func (*Empty) Descriptor
deprecated
func (*Empty) ProtoMessage ¶
func (*Empty) ProtoMessage()
func (*Empty) ProtoReflect ¶
func (x *Empty) ProtoReflect() protoreflect.Message
type GetMasterConfigurationRequest ¶
type GetMasterConfigurationRequest struct {
// contains filtered or unexported fields
}
func (*GetMasterConfigurationRequest) Descriptor
deprecated
func (*GetMasterConfigurationRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetMasterConfigurationRequest.ProtoReflect.Descriptor instead.
func (*GetMasterConfigurationRequest) ProtoMessage ¶
func (*GetMasterConfigurationRequest) ProtoMessage()
func (*GetMasterConfigurationRequest) ProtoReflect ¶
func (x *GetMasterConfigurationRequest) ProtoReflect() protoreflect.Message
func (*GetMasterConfigurationRequest) Reset ¶
func (x *GetMasterConfigurationRequest) Reset()
func (*GetMasterConfigurationRequest) String ¶
func (x *GetMasterConfigurationRequest) String() string
type GetMasterConfigurationResponse ¶
type GetMasterConfigurationResponse struct { MetricsAddress string `protobuf:"bytes,1,opt,name=metrics_address,json=metricsAddress,proto3" json:"metrics_address,omitempty"` MetricsIntervalSeconds uint32 `` /* 130-byte string literal not displayed */ StorageBackends []*StorageBackend `protobuf:"bytes,3,rep,name=storage_backends,json=storageBackends,proto3" json:"storage_backends,omitempty"` DefaultReplication string `protobuf:"bytes,4,opt,name=default_replication,json=defaultReplication,proto3" json:"default_replication,omitempty"` Leader string `protobuf:"bytes,5,opt,name=leader,proto3" json:"leader,omitempty"` VolumeSizeLimitMB uint32 `protobuf:"varint,6,opt,name=volume_size_limit_m_b,json=volumeSizeLimitMB,proto3" json:"volume_size_limit_m_b,omitempty"` VolumePreallocate bool `protobuf:"varint,7,opt,name=volume_preallocate,json=volumePreallocate,proto3" json:"volume_preallocate,omitempty"` // contains filtered or unexported fields }
func (*GetMasterConfigurationResponse) Descriptor
deprecated
func (*GetMasterConfigurationResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetMasterConfigurationResponse.ProtoReflect.Descriptor instead.
func (*GetMasterConfigurationResponse) GetDefaultReplication ¶
func (x *GetMasterConfigurationResponse) GetDefaultReplication() string
func (*GetMasterConfigurationResponse) GetLeader ¶
func (x *GetMasterConfigurationResponse) GetLeader() string
func (*GetMasterConfigurationResponse) GetMetricsAddress ¶
func (x *GetMasterConfigurationResponse) GetMetricsAddress() string
func (*GetMasterConfigurationResponse) GetMetricsIntervalSeconds ¶
func (x *GetMasterConfigurationResponse) GetMetricsIntervalSeconds() uint32
func (*GetMasterConfigurationResponse) GetStorageBackends ¶
func (x *GetMasterConfigurationResponse) GetStorageBackends() []*StorageBackend
func (*GetMasterConfigurationResponse) GetVolumePreallocate ¶
func (x *GetMasterConfigurationResponse) GetVolumePreallocate() bool
func (*GetMasterConfigurationResponse) GetVolumeSizeLimitMB ¶
func (x *GetMasterConfigurationResponse) GetVolumeSizeLimitMB() uint32
func (*GetMasterConfigurationResponse) ProtoMessage ¶
func (*GetMasterConfigurationResponse) ProtoMessage()
func (*GetMasterConfigurationResponse) ProtoReflect ¶
func (x *GetMasterConfigurationResponse) ProtoReflect() protoreflect.Message
func (*GetMasterConfigurationResponse) Reset ¶
func (x *GetMasterConfigurationResponse) Reset()
func (*GetMasterConfigurationResponse) String ¶
func (x *GetMasterConfigurationResponse) String() string
type Heartbeat ¶
type Heartbeat struct { Ip string `protobuf:"bytes,1,opt,name=ip,proto3" json:"ip,omitempty"` Port uint32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"` PublicUrl string `protobuf:"bytes,3,opt,name=public_url,json=publicUrl,proto3" json:"public_url,omitempty"` MaxFileKey uint64 `protobuf:"varint,5,opt,name=max_file_key,json=maxFileKey,proto3" json:"max_file_key,omitempty"` DataCenter string `protobuf:"bytes,6,opt,name=data_center,json=dataCenter,proto3" json:"data_center,omitempty"` Rack string `protobuf:"bytes,7,opt,name=rack,proto3" json:"rack,omitempty"` AdminPort uint32 `protobuf:"varint,8,opt,name=admin_port,json=adminPort,proto3" json:"admin_port,omitempty"` Volumes []*VolumeInformationMessage `protobuf:"bytes,9,rep,name=volumes,proto3" json:"volumes,omitempty"` // delta volumes NewVolumes []*VolumeShortInformationMessage `protobuf:"bytes,10,rep,name=new_volumes,json=newVolumes,proto3" json:"new_volumes,omitempty"` DeletedVolumes []*VolumeShortInformationMessage `protobuf:"bytes,11,rep,name=deleted_volumes,json=deletedVolumes,proto3" json:"deleted_volumes,omitempty"` HasNoVolumes bool `protobuf:"varint,12,opt,name=has_no_volumes,json=hasNoVolumes,proto3" json:"has_no_volumes,omitempty"` // erasure coding EcShards []*VolumeEcShardInformationMessage `protobuf:"bytes,16,rep,name=ec_shards,json=ecShards,proto3" json:"ec_shards,omitempty"` // delta erasure coding shards NewEcShards []*VolumeEcShardInformationMessage `protobuf:"bytes,17,rep,name=new_ec_shards,json=newEcShards,proto3" json:"new_ec_shards,omitempty"` DeletedEcShards []*VolumeEcShardInformationMessage `protobuf:"bytes,18,rep,name=deleted_ec_shards,json=deletedEcShards,proto3" json:"deleted_ec_shards,omitempty"` HasNoEcShards bool `protobuf:"varint,19,opt,name=has_no_ec_shards,json=hasNoEcShards,proto3" json:"has_no_ec_shards,omitempty"` MaxVolumeCounts map[string]uint32 `` /* 197-byte string literal not displayed */ GrpcPort uint32 `protobuf:"varint,20,opt,name=grpc_port,json=grpcPort,proto3" json:"grpc_port,omitempty"` // contains filtered or unexported fields }
func (*Heartbeat) Descriptor
deprecated
func (*Heartbeat) GetAdminPort ¶
func (*Heartbeat) GetDataCenter ¶
func (*Heartbeat) GetDeletedEcShards ¶
func (x *Heartbeat) GetDeletedEcShards() []*VolumeEcShardInformationMessage
func (*Heartbeat) GetDeletedVolumes ¶
func (x *Heartbeat) GetDeletedVolumes() []*VolumeShortInformationMessage
func (*Heartbeat) GetEcShards ¶
func (x *Heartbeat) GetEcShards() []*VolumeEcShardInformationMessage
func (*Heartbeat) GetGrpcPort ¶
func (*Heartbeat) GetHasNoEcShards ¶
func (*Heartbeat) GetHasNoVolumes ¶
func (*Heartbeat) GetMaxFileKey ¶
func (*Heartbeat) GetMaxVolumeCounts ¶
func (*Heartbeat) GetNewEcShards ¶
func (x *Heartbeat) GetNewEcShards() []*VolumeEcShardInformationMessage
func (*Heartbeat) GetNewVolumes ¶
func (x *Heartbeat) GetNewVolumes() []*VolumeShortInformationMessage
func (*Heartbeat) GetPublicUrl ¶
func (*Heartbeat) GetVolumes ¶
func (x *Heartbeat) GetVolumes() []*VolumeInformationMessage
func (*Heartbeat) ProtoMessage ¶
func (*Heartbeat) ProtoMessage()
func (*Heartbeat) ProtoReflect ¶
func (x *Heartbeat) ProtoReflect() protoreflect.Message
type HeartbeatResponse ¶
type HeartbeatResponse struct { VolumeSizeLimit uint64 `protobuf:"varint,1,opt,name=volume_size_limit,json=volumeSizeLimit,proto3" json:"volume_size_limit,omitempty"` Leader string `protobuf:"bytes,2,opt,name=leader,proto3" json:"leader,omitempty"` MetricsAddress string `protobuf:"bytes,3,opt,name=metrics_address,json=metricsAddress,proto3" json:"metrics_address,omitempty"` MetricsIntervalSeconds uint32 `` /* 130-byte string literal not displayed */ StorageBackends []*StorageBackend `protobuf:"bytes,5,rep,name=storage_backends,json=storageBackends,proto3" json:"storage_backends,omitempty"` // contains filtered or unexported fields }
func (*HeartbeatResponse) Descriptor
deprecated
func (*HeartbeatResponse) Descriptor() ([]byte, []int)
Deprecated: Use HeartbeatResponse.ProtoReflect.Descriptor instead.
func (*HeartbeatResponse) GetLeader ¶
func (x *HeartbeatResponse) GetLeader() string
func (*HeartbeatResponse) GetMetricsAddress ¶
func (x *HeartbeatResponse) GetMetricsAddress() string
func (*HeartbeatResponse) GetMetricsIntervalSeconds ¶
func (x *HeartbeatResponse) GetMetricsIntervalSeconds() uint32
func (*HeartbeatResponse) GetStorageBackends ¶
func (x *HeartbeatResponse) GetStorageBackends() []*StorageBackend
func (*HeartbeatResponse) GetVolumeSizeLimit ¶
func (x *HeartbeatResponse) GetVolumeSizeLimit() uint64
func (*HeartbeatResponse) ProtoMessage ¶
func (*HeartbeatResponse) ProtoMessage()
func (*HeartbeatResponse) ProtoReflect ¶
func (x *HeartbeatResponse) ProtoReflect() protoreflect.Message
func (*HeartbeatResponse) Reset ¶
func (x *HeartbeatResponse) Reset()
func (*HeartbeatResponse) String ¶
func (x *HeartbeatResponse) String() string
type KeepConnectedRequest ¶
type KeepConnectedRequest struct { ClientType string `protobuf:"bytes,1,opt,name=client_type,json=clientType,proto3" json:"client_type,omitempty"` ClientAddress string `protobuf:"bytes,3,opt,name=client_address,json=clientAddress,proto3" json:"client_address,omitempty"` Version string `protobuf:"bytes,4,opt,name=version,proto3" json:"version,omitempty"` FilerGroup string `protobuf:"bytes,5,opt,name=filer_group,json=filerGroup,proto3" json:"filer_group,omitempty"` // contains filtered or unexported fields }
func (*KeepConnectedRequest) Descriptor
deprecated
func (*KeepConnectedRequest) Descriptor() ([]byte, []int)
Deprecated: Use KeepConnectedRequest.ProtoReflect.Descriptor instead.
func (*KeepConnectedRequest) GetClientAddress ¶
func (x *KeepConnectedRequest) GetClientAddress() string
func (*KeepConnectedRequest) GetClientType ¶
func (x *KeepConnectedRequest) GetClientType() string
func (*KeepConnectedRequest) GetFilerGroup ¶
func (x *KeepConnectedRequest) GetFilerGroup() string
func (*KeepConnectedRequest) GetVersion ¶
func (x *KeepConnectedRequest) GetVersion() string
func (*KeepConnectedRequest) ProtoMessage ¶
func (*KeepConnectedRequest) ProtoMessage()
func (*KeepConnectedRequest) ProtoReflect ¶
func (x *KeepConnectedRequest) ProtoReflect() protoreflect.Message
func (*KeepConnectedRequest) Reset ¶
func (x *KeepConnectedRequest) Reset()
func (*KeepConnectedRequest) String ¶
func (x *KeepConnectedRequest) String() string
type KeepConnectedResponse ¶
type KeepConnectedResponse struct { VolumeLocation *VolumeLocation `protobuf:"bytes,1,opt,name=volume_location,json=volumeLocation,proto3" json:"volume_location,omitempty"` ClusterNodeUpdate *ClusterNodeUpdate `protobuf:"bytes,2,opt,name=cluster_node_update,json=clusterNodeUpdate,proto3" json:"cluster_node_update,omitempty"` // contains filtered or unexported fields }
func (*KeepConnectedResponse) Descriptor
deprecated
func (*KeepConnectedResponse) Descriptor() ([]byte, []int)
Deprecated: Use KeepConnectedResponse.ProtoReflect.Descriptor instead.
func (*KeepConnectedResponse) GetClusterNodeUpdate ¶
func (x *KeepConnectedResponse) GetClusterNodeUpdate() *ClusterNodeUpdate
func (*KeepConnectedResponse) GetVolumeLocation ¶
func (x *KeepConnectedResponse) GetVolumeLocation() *VolumeLocation
func (*KeepConnectedResponse) ProtoMessage ¶
func (*KeepConnectedResponse) ProtoMessage()
func (*KeepConnectedResponse) ProtoReflect ¶
func (x *KeepConnectedResponse) ProtoReflect() protoreflect.Message
func (*KeepConnectedResponse) Reset ¶
func (x *KeepConnectedResponse) Reset()
func (*KeepConnectedResponse) String ¶
func (x *KeepConnectedResponse) String() string
type LeaseAdminTokenRequest ¶
type LeaseAdminTokenRequest struct { PreviousToken int64 `protobuf:"varint,1,opt,name=previous_token,json=previousToken,proto3" json:"previous_token,omitempty"` PreviousLockTime int64 `protobuf:"varint,2,opt,name=previous_lock_time,json=previousLockTime,proto3" json:"previous_lock_time,omitempty"` LockName string `protobuf:"bytes,3,opt,name=lock_name,json=lockName,proto3" json:"lock_name,omitempty"` ClientName string `protobuf:"bytes,4,opt,name=client_name,json=clientName,proto3" json:"client_name,omitempty"` Message string `protobuf:"bytes,5,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
func (*LeaseAdminTokenRequest) Descriptor
deprecated
func (*LeaseAdminTokenRequest) Descriptor() ([]byte, []int)
Deprecated: Use LeaseAdminTokenRequest.ProtoReflect.Descriptor instead.
func (*LeaseAdminTokenRequest) GetClientName ¶
func (x *LeaseAdminTokenRequest) GetClientName() string
func (*LeaseAdminTokenRequest) GetLockName ¶
func (x *LeaseAdminTokenRequest) GetLockName() string
func (*LeaseAdminTokenRequest) GetMessage ¶
func (x *LeaseAdminTokenRequest) GetMessage() string
func (*LeaseAdminTokenRequest) GetPreviousLockTime ¶
func (x *LeaseAdminTokenRequest) GetPreviousLockTime() int64
func (*LeaseAdminTokenRequest) GetPreviousToken ¶
func (x *LeaseAdminTokenRequest) GetPreviousToken() int64
func (*LeaseAdminTokenRequest) ProtoMessage ¶
func (*LeaseAdminTokenRequest) ProtoMessage()
func (*LeaseAdminTokenRequest) ProtoReflect ¶
func (x *LeaseAdminTokenRequest) ProtoReflect() protoreflect.Message
func (*LeaseAdminTokenRequest) Reset ¶
func (x *LeaseAdminTokenRequest) Reset()
func (*LeaseAdminTokenRequest) String ¶
func (x *LeaseAdminTokenRequest) String() string
type LeaseAdminTokenResponse ¶
type LeaseAdminTokenResponse struct { Token int64 `protobuf:"varint,1,opt,name=token,proto3" json:"token,omitempty"` LockTsNs int64 `protobuf:"varint,2,opt,name=lock_ts_ns,json=lockTsNs,proto3" json:"lock_ts_ns,omitempty"` // contains filtered or unexported fields }
func (*LeaseAdminTokenResponse) Descriptor
deprecated
func (*LeaseAdminTokenResponse) Descriptor() ([]byte, []int)
Deprecated: Use LeaseAdminTokenResponse.ProtoReflect.Descriptor instead.
func (*LeaseAdminTokenResponse) GetLockTsNs ¶
func (x *LeaseAdminTokenResponse) GetLockTsNs() int64
func (*LeaseAdminTokenResponse) GetToken ¶
func (x *LeaseAdminTokenResponse) GetToken() int64
func (*LeaseAdminTokenResponse) ProtoMessage ¶
func (*LeaseAdminTokenResponse) ProtoMessage()
func (*LeaseAdminTokenResponse) ProtoReflect ¶
func (x *LeaseAdminTokenResponse) ProtoReflect() protoreflect.Message
func (*LeaseAdminTokenResponse) Reset ¶
func (x *LeaseAdminTokenResponse) Reset()
func (*LeaseAdminTokenResponse) String ¶
func (x *LeaseAdminTokenResponse) String() string
type ListClusterNodesRequest ¶
type ListClusterNodesRequest struct { ClientType string `protobuf:"bytes,1,opt,name=client_type,json=clientType,proto3" json:"client_type,omitempty"` FilerGroup string `protobuf:"bytes,2,opt,name=filer_group,json=filerGroup,proto3" json:"filer_group,omitempty"` // contains filtered or unexported fields }
func (*ListClusterNodesRequest) Descriptor
deprecated
func (*ListClusterNodesRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListClusterNodesRequest.ProtoReflect.Descriptor instead.
func (*ListClusterNodesRequest) GetClientType ¶
func (x *ListClusterNodesRequest) GetClientType() string
func (*ListClusterNodesRequest) GetFilerGroup ¶
func (x *ListClusterNodesRequest) GetFilerGroup() string
func (*ListClusterNodesRequest) ProtoMessage ¶
func (*ListClusterNodesRequest) ProtoMessage()
func (*ListClusterNodesRequest) ProtoReflect ¶
func (x *ListClusterNodesRequest) ProtoReflect() protoreflect.Message
func (*ListClusterNodesRequest) Reset ¶
func (x *ListClusterNodesRequest) Reset()
func (*ListClusterNodesRequest) String ¶
func (x *ListClusterNodesRequest) String() string
type ListClusterNodesResponse ¶
type ListClusterNodesResponse struct { ClusterNodes []*ListClusterNodesResponse_ClusterNode `protobuf:"bytes,1,rep,name=cluster_nodes,json=clusterNodes,proto3" json:"cluster_nodes,omitempty"` // contains filtered or unexported fields }
func (*ListClusterNodesResponse) Descriptor
deprecated
func (*ListClusterNodesResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListClusterNodesResponse.ProtoReflect.Descriptor instead.
func (*ListClusterNodesResponse) GetClusterNodes ¶
func (x *ListClusterNodesResponse) GetClusterNodes() []*ListClusterNodesResponse_ClusterNode
func (*ListClusterNodesResponse) ProtoMessage ¶
func (*ListClusterNodesResponse) ProtoMessage()
func (*ListClusterNodesResponse) ProtoReflect ¶
func (x *ListClusterNodesResponse) ProtoReflect() protoreflect.Message
func (*ListClusterNodesResponse) Reset ¶
func (x *ListClusterNodesResponse) Reset()
func (*ListClusterNodesResponse) String ¶
func (x *ListClusterNodesResponse) String() string
type ListClusterNodesResponse_ClusterNode ¶
type ListClusterNodesResponse_ClusterNode struct { Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"` Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"` IsLeader bool `protobuf:"varint,3,opt,name=is_leader,json=isLeader,proto3" json:"is_leader,omitempty"` // contains filtered or unexported fields }
func (*ListClusterNodesResponse_ClusterNode) Descriptor
deprecated
func (*ListClusterNodesResponse_ClusterNode) Descriptor() ([]byte, []int)
Deprecated: Use ListClusterNodesResponse_ClusterNode.ProtoReflect.Descriptor instead.
func (*ListClusterNodesResponse_ClusterNode) GetAddress ¶
func (x *ListClusterNodesResponse_ClusterNode) GetAddress() string
func (*ListClusterNodesResponse_ClusterNode) GetIsLeader ¶
func (x *ListClusterNodesResponse_ClusterNode) GetIsLeader() bool
func (*ListClusterNodesResponse_ClusterNode) GetVersion ¶
func (x *ListClusterNodesResponse_ClusterNode) GetVersion() string
func (*ListClusterNodesResponse_ClusterNode) ProtoMessage ¶
func (*ListClusterNodesResponse_ClusterNode) ProtoMessage()
func (*ListClusterNodesResponse_ClusterNode) ProtoReflect ¶
func (x *ListClusterNodesResponse_ClusterNode) ProtoReflect() protoreflect.Message
func (*ListClusterNodesResponse_ClusterNode) Reset ¶
func (x *ListClusterNodesResponse_ClusterNode) Reset()
func (*ListClusterNodesResponse_ClusterNode) String ¶
func (x *ListClusterNodesResponse_ClusterNode) String() string
type Location ¶
type Location 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 uint32 `protobuf:"varint,3,opt,name=grpc_port,json=grpcPort,proto3" json:"grpc_port,omitempty"` // contains filtered or unexported fields }
func (*Location) Descriptor
deprecated
func (*Location) GetGrpcPort ¶
func (*Location) GetPublicUrl ¶
func (*Location) ProtoMessage ¶
func (*Location) ProtoMessage()
func (*Location) ProtoReflect ¶
func (x *Location) ProtoReflect() protoreflect.Message
type LookupEcVolumeRequest ¶
type LookupEcVolumeRequest struct { VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId,proto3" json:"volume_id,omitempty"` // contains filtered or unexported fields }
func (*LookupEcVolumeRequest) Descriptor
deprecated
func (*LookupEcVolumeRequest) Descriptor() ([]byte, []int)
Deprecated: Use LookupEcVolumeRequest.ProtoReflect.Descriptor instead.
func (*LookupEcVolumeRequest) GetVolumeId ¶
func (x *LookupEcVolumeRequest) GetVolumeId() uint32
func (*LookupEcVolumeRequest) ProtoMessage ¶
func (*LookupEcVolumeRequest) ProtoMessage()
func (*LookupEcVolumeRequest) ProtoReflect ¶
func (x *LookupEcVolumeRequest) ProtoReflect() protoreflect.Message
func (*LookupEcVolumeRequest) Reset ¶
func (x *LookupEcVolumeRequest) Reset()
func (*LookupEcVolumeRequest) String ¶
func (x *LookupEcVolumeRequest) String() string
type LookupEcVolumeResponse ¶
type LookupEcVolumeResponse struct { VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId,proto3" json:"volume_id,omitempty"` ShardIdLocations []*LookupEcVolumeResponse_EcShardIdLocation `protobuf:"bytes,2,rep,name=shard_id_locations,json=shardIdLocations,proto3" json:"shard_id_locations,omitempty"` // contains filtered or unexported fields }
func (*LookupEcVolumeResponse) Descriptor
deprecated
func (*LookupEcVolumeResponse) Descriptor() ([]byte, []int)
Deprecated: Use LookupEcVolumeResponse.ProtoReflect.Descriptor instead.
func (*LookupEcVolumeResponse) GetShardIdLocations ¶
func (x *LookupEcVolumeResponse) GetShardIdLocations() []*LookupEcVolumeResponse_EcShardIdLocation
func (*LookupEcVolumeResponse) GetVolumeId ¶
func (x *LookupEcVolumeResponse) GetVolumeId() uint32
func (*LookupEcVolumeResponse) ProtoMessage ¶
func (*LookupEcVolumeResponse) ProtoMessage()
func (*LookupEcVolumeResponse) ProtoReflect ¶
func (x *LookupEcVolumeResponse) ProtoReflect() protoreflect.Message
func (*LookupEcVolumeResponse) Reset ¶
func (x *LookupEcVolumeResponse) Reset()
func (*LookupEcVolumeResponse) String ¶
func (x *LookupEcVolumeResponse) String() string
type LookupEcVolumeResponse_EcShardIdLocation ¶
type LookupEcVolumeResponse_EcShardIdLocation struct { ShardId uint32 `protobuf:"varint,1,opt,name=shard_id,json=shardId,proto3" json:"shard_id,omitempty"` Locations []*Location `protobuf:"bytes,2,rep,name=locations,proto3" json:"locations,omitempty"` // contains filtered or unexported fields }
func (*LookupEcVolumeResponse_EcShardIdLocation) Descriptor
deprecated
func (*LookupEcVolumeResponse_EcShardIdLocation) Descriptor() ([]byte, []int)
Deprecated: Use LookupEcVolumeResponse_EcShardIdLocation.ProtoReflect.Descriptor instead.
func (*LookupEcVolumeResponse_EcShardIdLocation) GetLocations ¶
func (x *LookupEcVolumeResponse_EcShardIdLocation) GetLocations() []*Location
func (*LookupEcVolumeResponse_EcShardIdLocation) GetShardId ¶
func (x *LookupEcVolumeResponse_EcShardIdLocation) GetShardId() uint32
func (*LookupEcVolumeResponse_EcShardIdLocation) ProtoMessage ¶
func (*LookupEcVolumeResponse_EcShardIdLocation) ProtoMessage()
func (*LookupEcVolumeResponse_EcShardIdLocation) ProtoReflect ¶
func (x *LookupEcVolumeResponse_EcShardIdLocation) ProtoReflect() protoreflect.Message
func (*LookupEcVolumeResponse_EcShardIdLocation) Reset ¶
func (x *LookupEcVolumeResponse_EcShardIdLocation) Reset()
func (*LookupEcVolumeResponse_EcShardIdLocation) String ¶
func (x *LookupEcVolumeResponse_EcShardIdLocation) String() string
type LookupVolumeRequest ¶
type LookupVolumeRequest struct { VolumeOrFileIds []string `protobuf:"bytes,1,rep,name=volume_or_file_ids,json=volumeOrFileIds,proto3" json:"volume_or_file_ids,omitempty"` Collection string `protobuf:"bytes,2,opt,name=collection,proto3" json:"collection,omitempty"` // optional, a bit faster if provided. // contains filtered or unexported fields }
func (*LookupVolumeRequest) Descriptor
deprecated
func (*LookupVolumeRequest) Descriptor() ([]byte, []int)
Deprecated: Use LookupVolumeRequest.ProtoReflect.Descriptor instead.
func (*LookupVolumeRequest) GetCollection ¶
func (x *LookupVolumeRequest) GetCollection() string
func (*LookupVolumeRequest) GetVolumeOrFileIds ¶
func (x *LookupVolumeRequest) GetVolumeOrFileIds() []string
func (*LookupVolumeRequest) ProtoMessage ¶
func (*LookupVolumeRequest) ProtoMessage()
func (*LookupVolumeRequest) ProtoReflect ¶
func (x *LookupVolumeRequest) ProtoReflect() protoreflect.Message
func (*LookupVolumeRequest) Reset ¶
func (x *LookupVolumeRequest) Reset()
func (*LookupVolumeRequest) String ¶
func (x *LookupVolumeRequest) String() string
type LookupVolumeResponse ¶
type LookupVolumeResponse struct { VolumeIdLocations []*LookupVolumeResponse_VolumeIdLocation `protobuf:"bytes,1,rep,name=volume_id_locations,json=volumeIdLocations,proto3" json:"volume_id_locations,omitempty"` // contains filtered or unexported fields }
func (*LookupVolumeResponse) Descriptor
deprecated
func (*LookupVolumeResponse) Descriptor() ([]byte, []int)
Deprecated: Use LookupVolumeResponse.ProtoReflect.Descriptor instead.
func (*LookupVolumeResponse) GetVolumeIdLocations ¶
func (x *LookupVolumeResponse) GetVolumeIdLocations() []*LookupVolumeResponse_VolumeIdLocation
func (*LookupVolumeResponse) ProtoMessage ¶
func (*LookupVolumeResponse) ProtoMessage()
func (*LookupVolumeResponse) ProtoReflect ¶
func (x *LookupVolumeResponse) ProtoReflect() protoreflect.Message
func (*LookupVolumeResponse) Reset ¶
func (x *LookupVolumeResponse) Reset()
func (*LookupVolumeResponse) String ¶
func (x *LookupVolumeResponse) String() string
type LookupVolumeResponse_VolumeIdLocation ¶
type LookupVolumeResponse_VolumeIdLocation struct { VolumeOrFileId string `protobuf:"bytes,1,opt,name=volume_or_file_id,json=volumeOrFileId,proto3" json:"volume_or_file_id,omitempty"` Locations []*Location `protobuf:"bytes,2,rep,name=locations,proto3" json:"locations,omitempty"` Error string `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"` Auth string `protobuf:"bytes,4,opt,name=auth,proto3" json:"auth,omitempty"` // contains filtered or unexported fields }
func (*LookupVolumeResponse_VolumeIdLocation) Descriptor
deprecated
func (*LookupVolumeResponse_VolumeIdLocation) Descriptor() ([]byte, []int)
Deprecated: Use LookupVolumeResponse_VolumeIdLocation.ProtoReflect.Descriptor instead.
func (*LookupVolumeResponse_VolumeIdLocation) GetAuth ¶
func (x *LookupVolumeResponse_VolumeIdLocation) GetAuth() string
func (*LookupVolumeResponse_VolumeIdLocation) GetError ¶
func (x *LookupVolumeResponse_VolumeIdLocation) GetError() string
func (*LookupVolumeResponse_VolumeIdLocation) GetLocations ¶
func (x *LookupVolumeResponse_VolumeIdLocation) GetLocations() []*Location
func (*LookupVolumeResponse_VolumeIdLocation) GetVolumeOrFileId ¶
func (x *LookupVolumeResponse_VolumeIdLocation) GetVolumeOrFileId() string
func (*LookupVolumeResponse_VolumeIdLocation) ProtoMessage ¶
func (*LookupVolumeResponse_VolumeIdLocation) ProtoMessage()
func (*LookupVolumeResponse_VolumeIdLocation) ProtoReflect ¶
func (x *LookupVolumeResponse_VolumeIdLocation) ProtoReflect() protoreflect.Message
func (*LookupVolumeResponse_VolumeIdLocation) Reset ¶
func (x *LookupVolumeResponse_VolumeIdLocation) Reset()
func (*LookupVolumeResponse_VolumeIdLocation) String ¶
func (x *LookupVolumeResponse_VolumeIdLocation) 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 RackInfo ¶
type RackInfo struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` DataNodeInfos []*DataNodeInfo `protobuf:"bytes,2,rep,name=data_node_infos,json=dataNodeInfos,proto3" json:"data_node_infos,omitempty"` DiskInfos map[string]*DiskInfo `` /* 159-byte string literal not displayed */ // contains filtered or unexported fields }
func (*RackInfo) Descriptor
deprecated
func (*RackInfo) GetDataNodeInfos ¶
func (x *RackInfo) GetDataNodeInfos() []*DataNodeInfo
func (*RackInfo) GetDiskInfos ¶
func (*RackInfo) ProtoMessage ¶
func (*RackInfo) ProtoMessage()
func (*RackInfo) ProtoReflect ¶
func (x *RackInfo) ProtoReflect() protoreflect.Message
type RaftAddServerRequest ¶
type RaftAddServerRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"` Voter bool `protobuf:"varint,3,opt,name=voter,proto3" json:"voter,omitempty"` // contains filtered or unexported fields }
func (*RaftAddServerRequest) Descriptor
deprecated
func (*RaftAddServerRequest) Descriptor() ([]byte, []int)
Deprecated: Use RaftAddServerRequest.ProtoReflect.Descriptor instead.
func (*RaftAddServerRequest) GetAddress ¶
func (x *RaftAddServerRequest) GetAddress() string
func (*RaftAddServerRequest) GetId ¶
func (x *RaftAddServerRequest) GetId() string
func (*RaftAddServerRequest) GetVoter ¶
func (x *RaftAddServerRequest) GetVoter() bool
func (*RaftAddServerRequest) ProtoMessage ¶
func (*RaftAddServerRequest) ProtoMessage()
func (*RaftAddServerRequest) ProtoReflect ¶
func (x *RaftAddServerRequest) ProtoReflect() protoreflect.Message
func (*RaftAddServerRequest) Reset ¶
func (x *RaftAddServerRequest) Reset()
func (*RaftAddServerRequest) String ¶
func (x *RaftAddServerRequest) String() string
type RaftAddServerResponse ¶
type RaftAddServerResponse struct {
// contains filtered or unexported fields
}
func (*RaftAddServerResponse) Descriptor
deprecated
func (*RaftAddServerResponse) Descriptor() ([]byte, []int)
Deprecated: Use RaftAddServerResponse.ProtoReflect.Descriptor instead.
func (*RaftAddServerResponse) ProtoMessage ¶
func (*RaftAddServerResponse) ProtoMessage()
func (*RaftAddServerResponse) ProtoReflect ¶
func (x *RaftAddServerResponse) ProtoReflect() protoreflect.Message
func (*RaftAddServerResponse) Reset ¶
func (x *RaftAddServerResponse) Reset()
func (*RaftAddServerResponse) String ¶
func (x *RaftAddServerResponse) String() string
type RaftListClusterServersRequest ¶
type RaftListClusterServersRequest struct {
// contains filtered or unexported fields
}
func (*RaftListClusterServersRequest) Descriptor
deprecated
func (*RaftListClusterServersRequest) Descriptor() ([]byte, []int)
Deprecated: Use RaftListClusterServersRequest.ProtoReflect.Descriptor instead.
func (*RaftListClusterServersRequest) ProtoMessage ¶
func (*RaftListClusterServersRequest) ProtoMessage()
func (*RaftListClusterServersRequest) ProtoReflect ¶
func (x *RaftListClusterServersRequest) ProtoReflect() protoreflect.Message
func (*RaftListClusterServersRequest) Reset ¶
func (x *RaftListClusterServersRequest) Reset()
func (*RaftListClusterServersRequest) String ¶
func (x *RaftListClusterServersRequest) String() string
type RaftListClusterServersResponse ¶
type RaftListClusterServersResponse struct { ClusterServers []*RaftListClusterServersResponse_ClusterServers `protobuf:"bytes,1,rep,name=cluster_servers,json=clusterServers,proto3" json:"cluster_servers,omitempty"` // contains filtered or unexported fields }
func (*RaftListClusterServersResponse) Descriptor
deprecated
func (*RaftListClusterServersResponse) Descriptor() ([]byte, []int)
Deprecated: Use RaftListClusterServersResponse.ProtoReflect.Descriptor instead.
func (*RaftListClusterServersResponse) GetClusterServers ¶
func (x *RaftListClusterServersResponse) GetClusterServers() []*RaftListClusterServersResponse_ClusterServers
func (*RaftListClusterServersResponse) ProtoMessage ¶
func (*RaftListClusterServersResponse) ProtoMessage()
func (*RaftListClusterServersResponse) ProtoReflect ¶
func (x *RaftListClusterServersResponse) ProtoReflect() protoreflect.Message
func (*RaftListClusterServersResponse) Reset ¶
func (x *RaftListClusterServersResponse) Reset()
func (*RaftListClusterServersResponse) String ¶
func (x *RaftListClusterServersResponse) String() string
type RaftListClusterServersResponse_ClusterServers ¶
type RaftListClusterServersResponse_ClusterServers struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"` Suffrage string `protobuf:"bytes,3,opt,name=suffrage,proto3" json:"suffrage,omitempty"` // // contains filtered or unexported fields }
func (*RaftListClusterServersResponse_ClusterServers) Descriptor
deprecated
func (*RaftListClusterServersResponse_ClusterServers) Descriptor() ([]byte, []int)
Deprecated: Use RaftListClusterServersResponse_ClusterServers.ProtoReflect.Descriptor instead.
func (*RaftListClusterServersResponse_ClusterServers) GetAddress ¶
func (x *RaftListClusterServersResponse_ClusterServers) GetAddress() string
func (*RaftListClusterServersResponse_ClusterServers) GetId ¶
func (x *RaftListClusterServersResponse_ClusterServers) GetId() string
func (*RaftListClusterServersResponse_ClusterServers) GetSuffrage ¶
func (x *RaftListClusterServersResponse_ClusterServers) GetSuffrage() string
func (*RaftListClusterServersResponse_ClusterServers) ProtoMessage ¶
func (*RaftListClusterServersResponse_ClusterServers) ProtoMessage()
func (*RaftListClusterServersResponse_ClusterServers) ProtoReflect ¶
func (x *RaftListClusterServersResponse_ClusterServers) ProtoReflect() protoreflect.Message
func (*RaftListClusterServersResponse_ClusterServers) Reset ¶
func (x *RaftListClusterServersResponse_ClusterServers) Reset()
func (*RaftListClusterServersResponse_ClusterServers) String ¶
func (x *RaftListClusterServersResponse_ClusterServers) String() string
type RaftRemoveServerRequest ¶
type RaftRemoveServerRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Force bool `protobuf:"varint,2,opt,name=force,proto3" json:"force,omitempty"` // contains filtered or unexported fields }
func (*RaftRemoveServerRequest) Descriptor
deprecated
func (*RaftRemoveServerRequest) Descriptor() ([]byte, []int)
Deprecated: Use RaftRemoveServerRequest.ProtoReflect.Descriptor instead.
func (*RaftRemoveServerRequest) GetForce ¶
func (x *RaftRemoveServerRequest) GetForce() bool
func (*RaftRemoveServerRequest) GetId ¶
func (x *RaftRemoveServerRequest) GetId() string
func (*RaftRemoveServerRequest) ProtoMessage ¶
func (*RaftRemoveServerRequest) ProtoMessage()
func (*RaftRemoveServerRequest) ProtoReflect ¶
func (x *RaftRemoveServerRequest) ProtoReflect() protoreflect.Message
func (*RaftRemoveServerRequest) Reset ¶
func (x *RaftRemoveServerRequest) Reset()
func (*RaftRemoveServerRequest) String ¶
func (x *RaftRemoveServerRequest) String() string
type RaftRemoveServerResponse ¶
type RaftRemoveServerResponse struct {
// contains filtered or unexported fields
}
func (*RaftRemoveServerResponse) Descriptor
deprecated
func (*RaftRemoveServerResponse) Descriptor() ([]byte, []int)
Deprecated: Use RaftRemoveServerResponse.ProtoReflect.Descriptor instead.
func (*RaftRemoveServerResponse) ProtoMessage ¶
func (*RaftRemoveServerResponse) ProtoMessage()
func (*RaftRemoveServerResponse) ProtoReflect ¶
func (x *RaftRemoveServerResponse) ProtoReflect() protoreflect.Message
func (*RaftRemoveServerResponse) Reset ¶
func (x *RaftRemoveServerResponse) Reset()
func (*RaftRemoveServerResponse) String ¶
func (x *RaftRemoveServerResponse) String() string
type ReleaseAdminTokenRequest ¶
type ReleaseAdminTokenRequest struct { PreviousToken int64 `protobuf:"varint,1,opt,name=previous_token,json=previousToken,proto3" json:"previous_token,omitempty"` PreviousLockTime int64 `protobuf:"varint,2,opt,name=previous_lock_time,json=previousLockTime,proto3" json:"previous_lock_time,omitempty"` LockName string `protobuf:"bytes,3,opt,name=lock_name,json=lockName,proto3" json:"lock_name,omitempty"` // contains filtered or unexported fields }
func (*ReleaseAdminTokenRequest) Descriptor
deprecated
func (*ReleaseAdminTokenRequest) Descriptor() ([]byte, []int)
Deprecated: Use ReleaseAdminTokenRequest.ProtoReflect.Descriptor instead.
func (*ReleaseAdminTokenRequest) GetLockName ¶
func (x *ReleaseAdminTokenRequest) GetLockName() string
func (*ReleaseAdminTokenRequest) GetPreviousLockTime ¶
func (x *ReleaseAdminTokenRequest) GetPreviousLockTime() int64
func (*ReleaseAdminTokenRequest) GetPreviousToken ¶
func (x *ReleaseAdminTokenRequest) GetPreviousToken() int64
func (*ReleaseAdminTokenRequest) ProtoMessage ¶
func (*ReleaseAdminTokenRequest) ProtoMessage()
func (*ReleaseAdminTokenRequest) ProtoReflect ¶
func (x *ReleaseAdminTokenRequest) ProtoReflect() protoreflect.Message
func (*ReleaseAdminTokenRequest) Reset ¶
func (x *ReleaseAdminTokenRequest) Reset()
func (*ReleaseAdminTokenRequest) String ¶
func (x *ReleaseAdminTokenRequest) String() string
type ReleaseAdminTokenResponse ¶
type ReleaseAdminTokenResponse struct {
// contains filtered or unexported fields
}
func (*ReleaseAdminTokenResponse) Descriptor
deprecated
func (*ReleaseAdminTokenResponse) Descriptor() ([]byte, []int)
Deprecated: Use ReleaseAdminTokenResponse.ProtoReflect.Descriptor instead.
func (*ReleaseAdminTokenResponse) ProtoMessage ¶
func (*ReleaseAdminTokenResponse) ProtoMessage()
func (*ReleaseAdminTokenResponse) ProtoReflect ¶
func (x *ReleaseAdminTokenResponse) ProtoReflect() protoreflect.Message
func (*ReleaseAdminTokenResponse) Reset ¶
func (x *ReleaseAdminTokenResponse) Reset()
func (*ReleaseAdminTokenResponse) String ¶
func (x *ReleaseAdminTokenResponse) String() string
type SeaweedClient ¶
type SeaweedClient interface { SendHeartbeat(ctx context.Context, opts ...grpc.CallOption) (Seaweed_SendHeartbeatClient, error) KeepConnected(ctx context.Context, opts ...grpc.CallOption) (Seaweed_KeepConnectedClient, error) LookupVolume(ctx context.Context, in *LookupVolumeRequest, opts ...grpc.CallOption) (*LookupVolumeResponse, error) Assign(ctx context.Context, in *AssignRequest, opts ...grpc.CallOption) (*AssignResponse, error) Statistics(ctx context.Context, in *StatisticsRequest, opts ...grpc.CallOption) (*StatisticsResponse, error) CollectionList(ctx context.Context, in *CollectionListRequest, opts ...grpc.CallOption) (*CollectionListResponse, error) CollectionDelete(ctx context.Context, in *CollectionDeleteRequest, opts ...grpc.CallOption) (*CollectionDeleteResponse, error) VolumeList(ctx context.Context, in *VolumeListRequest, opts ...grpc.CallOption) (*VolumeListResponse, error) LookupEcVolume(ctx context.Context, in *LookupEcVolumeRequest, opts ...grpc.CallOption) (*LookupEcVolumeResponse, error) VacuumVolume(ctx context.Context, in *VacuumVolumeRequest, opts ...grpc.CallOption) (*VacuumVolumeResponse, error) GetMasterConfiguration(ctx context.Context, in *GetMasterConfigurationRequest, opts ...grpc.CallOption) (*GetMasterConfigurationResponse, error) ListClusterNodes(ctx context.Context, in *ListClusterNodesRequest, opts ...grpc.CallOption) (*ListClusterNodesResponse, error) LeaseAdminToken(ctx context.Context, in *LeaseAdminTokenRequest, opts ...grpc.CallOption) (*LeaseAdminTokenResponse, error) ReleaseAdminToken(ctx context.Context, in *ReleaseAdminTokenRequest, opts ...grpc.CallOption) (*ReleaseAdminTokenResponse, error) Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingResponse, error) RaftListClusterServers(ctx context.Context, in *RaftListClusterServersRequest, opts ...grpc.CallOption) (*RaftListClusterServersResponse, error) RaftAddServer(ctx context.Context, in *RaftAddServerRequest, opts ...grpc.CallOption) (*RaftAddServerResponse, error) RaftRemoveServer(ctx context.Context, in *RaftRemoveServerRequest, opts ...grpc.CallOption) (*RaftRemoveServerResponse, error) }
SeaweedClient is the client API for Seaweed service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewSeaweedClient ¶
func NewSeaweedClient(cc grpc.ClientConnInterface) SeaweedClient
type SeaweedServer ¶
type SeaweedServer interface { SendHeartbeat(Seaweed_SendHeartbeatServer) error KeepConnected(Seaweed_KeepConnectedServer) error LookupVolume(context.Context, *LookupVolumeRequest) (*LookupVolumeResponse, error) Assign(context.Context, *AssignRequest) (*AssignResponse, error) Statistics(context.Context, *StatisticsRequest) (*StatisticsResponse, error) CollectionList(context.Context, *CollectionListRequest) (*CollectionListResponse, error) CollectionDelete(context.Context, *CollectionDeleteRequest) (*CollectionDeleteResponse, error) VolumeList(context.Context, *VolumeListRequest) (*VolumeListResponse, error) LookupEcVolume(context.Context, *LookupEcVolumeRequest) (*LookupEcVolumeResponse, error) VacuumVolume(context.Context, *VacuumVolumeRequest) (*VacuumVolumeResponse, error) GetMasterConfiguration(context.Context, *GetMasterConfigurationRequest) (*GetMasterConfigurationResponse, error) ListClusterNodes(context.Context, *ListClusterNodesRequest) (*ListClusterNodesResponse, error) LeaseAdminToken(context.Context, *LeaseAdminTokenRequest) (*LeaseAdminTokenResponse, error) ReleaseAdminToken(context.Context, *ReleaseAdminTokenRequest) (*ReleaseAdminTokenResponse, error) Ping(context.Context, *PingRequest) (*PingResponse, error) RaftListClusterServers(context.Context, *RaftListClusterServersRequest) (*RaftListClusterServersResponse, error) RaftAddServer(context.Context, *RaftAddServerRequest) (*RaftAddServerResponse, error) RaftRemoveServer(context.Context, *RaftRemoveServerRequest) (*RaftRemoveServerResponse, error) // contains filtered or unexported methods }
SeaweedServer is the server API for Seaweed service. All implementations must embed UnimplementedSeaweedServer for forward compatibility
type Seaweed_KeepConnectedClient ¶
type Seaweed_KeepConnectedClient interface { Send(*KeepConnectedRequest) error Recv() (*KeepConnectedResponse, error) grpc.ClientStream }
type Seaweed_KeepConnectedServer ¶
type Seaweed_KeepConnectedServer interface { Send(*KeepConnectedResponse) error Recv() (*KeepConnectedRequest, error) grpc.ServerStream }
type Seaweed_SendHeartbeatClient ¶
type Seaweed_SendHeartbeatClient interface { Send(*Heartbeat) error Recv() (*HeartbeatResponse, error) grpc.ClientStream }
type Seaweed_SendHeartbeatServer ¶
type Seaweed_SendHeartbeatServer interface { Send(*HeartbeatResponse) error Recv() (*Heartbeat, error) grpc.ServerStream }
type StatisticsRequest ¶
type StatisticsRequest struct { Replication string `protobuf:"bytes,1,opt,name=replication,proto3" json:"replication,omitempty"` Collection string `protobuf:"bytes,2,opt,name=collection,proto3" json:"collection,omitempty"` Ttl string `protobuf:"bytes,3,opt,name=ttl,proto3" json:"ttl,omitempty"` DiskType string `protobuf:"bytes,4,opt,name=disk_type,json=diskType,proto3" json:"disk_type,omitempty"` // contains filtered or unexported fields }
func (*StatisticsRequest) Descriptor
deprecated
func (*StatisticsRequest) Descriptor() ([]byte, []int)
Deprecated: Use StatisticsRequest.ProtoReflect.Descriptor instead.
func (*StatisticsRequest) GetCollection ¶
func (x *StatisticsRequest) GetCollection() string
func (*StatisticsRequest) GetDiskType ¶
func (x *StatisticsRequest) GetDiskType() string
func (*StatisticsRequest) GetReplication ¶
func (x *StatisticsRequest) GetReplication() string
func (*StatisticsRequest) GetTtl ¶
func (x *StatisticsRequest) GetTtl() string
func (*StatisticsRequest) ProtoMessage ¶
func (*StatisticsRequest) ProtoMessage()
func (*StatisticsRequest) ProtoReflect ¶
func (x *StatisticsRequest) ProtoReflect() protoreflect.Message
func (*StatisticsRequest) Reset ¶
func (x *StatisticsRequest) Reset()
func (*StatisticsRequest) String ¶
func (x *StatisticsRequest) String() string
type StatisticsResponse ¶
type StatisticsResponse struct { TotalSize uint64 `protobuf:"varint,4,opt,name=total_size,json=totalSize,proto3" json:"total_size,omitempty"` UsedSize uint64 `protobuf:"varint,5,opt,name=used_size,json=usedSize,proto3" json:"used_size,omitempty"` FileCount uint64 `protobuf:"varint,6,opt,name=file_count,json=fileCount,proto3" json:"file_count,omitempty"` // contains filtered or unexported fields }
func (*StatisticsResponse) Descriptor
deprecated
func (*StatisticsResponse) Descriptor() ([]byte, []int)
Deprecated: Use StatisticsResponse.ProtoReflect.Descriptor instead.
func (*StatisticsResponse) GetFileCount ¶
func (x *StatisticsResponse) GetFileCount() uint64
func (*StatisticsResponse) GetTotalSize ¶
func (x *StatisticsResponse) GetTotalSize() uint64
func (*StatisticsResponse) GetUsedSize ¶
func (x *StatisticsResponse) GetUsedSize() uint64
func (*StatisticsResponse) ProtoMessage ¶
func (*StatisticsResponse) ProtoMessage()
func (*StatisticsResponse) ProtoReflect ¶
func (x *StatisticsResponse) ProtoReflect() protoreflect.Message
func (*StatisticsResponse) Reset ¶
func (x *StatisticsResponse) Reset()
func (*StatisticsResponse) String ¶
func (x *StatisticsResponse) String() string
type StorageBackend ¶
type StorageBackend struct { Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"` Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"` Properties map[string]string `` /* 161-byte string literal not displayed */ // contains filtered or unexported fields }
func (*StorageBackend) Descriptor
deprecated
func (*StorageBackend) Descriptor() ([]byte, []int)
Deprecated: Use StorageBackend.ProtoReflect.Descriptor instead.
func (*StorageBackend) GetId ¶
func (x *StorageBackend) GetId() string
func (*StorageBackend) GetProperties ¶
func (x *StorageBackend) GetProperties() map[string]string
func (*StorageBackend) GetType ¶
func (x *StorageBackend) GetType() string
func (*StorageBackend) ProtoMessage ¶
func (*StorageBackend) ProtoMessage()
func (*StorageBackend) ProtoReflect ¶
func (x *StorageBackend) ProtoReflect() protoreflect.Message
func (*StorageBackend) Reset ¶
func (x *StorageBackend) Reset()
func (*StorageBackend) String ¶
func (x *StorageBackend) String() string
type SuperBlockExtra ¶
type SuperBlockExtra struct { ErasureCoding *SuperBlockExtra_ErasureCoding `protobuf:"bytes,1,opt,name=erasure_coding,json=erasureCoding,proto3" json:"erasure_coding,omitempty"` // contains filtered or unexported fields }
func (*SuperBlockExtra) Descriptor
deprecated
func (*SuperBlockExtra) Descriptor() ([]byte, []int)
Deprecated: Use SuperBlockExtra.ProtoReflect.Descriptor instead.
func (*SuperBlockExtra) GetErasureCoding ¶
func (x *SuperBlockExtra) GetErasureCoding() *SuperBlockExtra_ErasureCoding
func (*SuperBlockExtra) ProtoMessage ¶
func (*SuperBlockExtra) ProtoMessage()
func (*SuperBlockExtra) ProtoReflect ¶
func (x *SuperBlockExtra) ProtoReflect() protoreflect.Message
func (*SuperBlockExtra) Reset ¶
func (x *SuperBlockExtra) Reset()
func (*SuperBlockExtra) String ¶
func (x *SuperBlockExtra) String() string
type SuperBlockExtra_ErasureCoding ¶
type SuperBlockExtra_ErasureCoding struct { Data uint32 `protobuf:"varint,1,opt,name=data,proto3" json:"data,omitempty"` Parity uint32 `protobuf:"varint,2,opt,name=parity,proto3" json:"parity,omitempty"` VolumeIds []uint32 `protobuf:"varint,3,rep,packed,name=volume_ids,json=volumeIds,proto3" json:"volume_ids,omitempty"` // contains filtered or unexported fields }
func (*SuperBlockExtra_ErasureCoding) Descriptor
deprecated
func (*SuperBlockExtra_ErasureCoding) Descriptor() ([]byte, []int)
Deprecated: Use SuperBlockExtra_ErasureCoding.ProtoReflect.Descriptor instead.
func (*SuperBlockExtra_ErasureCoding) GetData ¶
func (x *SuperBlockExtra_ErasureCoding) GetData() uint32
func (*SuperBlockExtra_ErasureCoding) GetParity ¶
func (x *SuperBlockExtra_ErasureCoding) GetParity() uint32
func (*SuperBlockExtra_ErasureCoding) GetVolumeIds ¶
func (x *SuperBlockExtra_ErasureCoding) GetVolumeIds() []uint32
func (*SuperBlockExtra_ErasureCoding) ProtoMessage ¶
func (*SuperBlockExtra_ErasureCoding) ProtoMessage()
func (*SuperBlockExtra_ErasureCoding) ProtoReflect ¶
func (x *SuperBlockExtra_ErasureCoding) ProtoReflect() protoreflect.Message
func (*SuperBlockExtra_ErasureCoding) Reset ¶
func (x *SuperBlockExtra_ErasureCoding) Reset()
func (*SuperBlockExtra_ErasureCoding) String ¶
func (x *SuperBlockExtra_ErasureCoding) String() string
type TopologyInfo ¶
type TopologyInfo struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` DataCenterInfos []*DataCenterInfo `protobuf:"bytes,2,rep,name=data_center_infos,json=dataCenterInfos,proto3" json:"data_center_infos,omitempty"` DiskInfos map[string]*DiskInfo `` /* 159-byte string literal not displayed */ // contains filtered or unexported fields }
func (*TopologyInfo) Descriptor
deprecated
func (*TopologyInfo) Descriptor() ([]byte, []int)
Deprecated: Use TopologyInfo.ProtoReflect.Descriptor instead.
func (*TopologyInfo) GetDataCenterInfos ¶
func (x *TopologyInfo) GetDataCenterInfos() []*DataCenterInfo
func (*TopologyInfo) GetDiskInfos ¶
func (x *TopologyInfo) GetDiskInfos() map[string]*DiskInfo
func (*TopologyInfo) GetId ¶
func (x *TopologyInfo) GetId() string
func (*TopologyInfo) ProtoMessage ¶
func (*TopologyInfo) ProtoMessage()
func (*TopologyInfo) ProtoReflect ¶
func (x *TopologyInfo) ProtoReflect() protoreflect.Message
func (*TopologyInfo) Reset ¶
func (x *TopologyInfo) Reset()
func (*TopologyInfo) String ¶
func (x *TopologyInfo) String() string
type UnimplementedSeaweedServer ¶
type UnimplementedSeaweedServer struct { }
UnimplementedSeaweedServer must be embedded to have forward compatible implementations.
func (UnimplementedSeaweedServer) Assign ¶
func (UnimplementedSeaweedServer) Assign(context.Context, *AssignRequest) (*AssignResponse, error)
func (UnimplementedSeaweedServer) CollectionDelete ¶
func (UnimplementedSeaweedServer) CollectionDelete(context.Context, *CollectionDeleteRequest) (*CollectionDeleteResponse, error)
func (UnimplementedSeaweedServer) CollectionList ¶
func (UnimplementedSeaweedServer) CollectionList(context.Context, *CollectionListRequest) (*CollectionListResponse, error)
func (UnimplementedSeaweedServer) GetMasterConfiguration ¶
func (UnimplementedSeaweedServer) GetMasterConfiguration(context.Context, *GetMasterConfigurationRequest) (*GetMasterConfigurationResponse, error)
func (UnimplementedSeaweedServer) KeepConnected ¶
func (UnimplementedSeaweedServer) KeepConnected(Seaweed_KeepConnectedServer) error
func (UnimplementedSeaweedServer) LeaseAdminToken ¶
func (UnimplementedSeaweedServer) LeaseAdminToken(context.Context, *LeaseAdminTokenRequest) (*LeaseAdminTokenResponse, error)
func (UnimplementedSeaweedServer) ListClusterNodes ¶
func (UnimplementedSeaweedServer) ListClusterNodes(context.Context, *ListClusterNodesRequest) (*ListClusterNodesResponse, error)
func (UnimplementedSeaweedServer) LookupEcVolume ¶
func (UnimplementedSeaweedServer) LookupEcVolume(context.Context, *LookupEcVolumeRequest) (*LookupEcVolumeResponse, error)
func (UnimplementedSeaweedServer) LookupVolume ¶
func (UnimplementedSeaweedServer) LookupVolume(context.Context, *LookupVolumeRequest) (*LookupVolumeResponse, error)
func (UnimplementedSeaweedServer) Ping ¶
func (UnimplementedSeaweedServer) Ping(context.Context, *PingRequest) (*PingResponse, error)
func (UnimplementedSeaweedServer) RaftAddServer ¶
func (UnimplementedSeaweedServer) RaftAddServer(context.Context, *RaftAddServerRequest) (*RaftAddServerResponse, error)
func (UnimplementedSeaweedServer) RaftListClusterServers ¶
func (UnimplementedSeaweedServer) RaftListClusterServers(context.Context, *RaftListClusterServersRequest) (*RaftListClusterServersResponse, error)
func (UnimplementedSeaweedServer) RaftRemoveServer ¶
func (UnimplementedSeaweedServer) RaftRemoveServer(context.Context, *RaftRemoveServerRequest) (*RaftRemoveServerResponse, error)
func (UnimplementedSeaweedServer) ReleaseAdminToken ¶
func (UnimplementedSeaweedServer) ReleaseAdminToken(context.Context, *ReleaseAdminTokenRequest) (*ReleaseAdminTokenResponse, error)
func (UnimplementedSeaweedServer) SendHeartbeat ¶
func (UnimplementedSeaweedServer) SendHeartbeat(Seaweed_SendHeartbeatServer) error
func (UnimplementedSeaweedServer) Statistics ¶
func (UnimplementedSeaweedServer) Statistics(context.Context, *StatisticsRequest) (*StatisticsResponse, error)
func (UnimplementedSeaweedServer) VacuumVolume ¶
func (UnimplementedSeaweedServer) VacuumVolume(context.Context, *VacuumVolumeRequest) (*VacuumVolumeResponse, error)
func (UnimplementedSeaweedServer) VolumeList ¶
func (UnimplementedSeaweedServer) VolumeList(context.Context, *VolumeListRequest) (*VolumeListResponse, error)
type UnsafeSeaweedServer ¶
type UnsafeSeaweedServer interface {
// contains filtered or unexported methods
}
UnsafeSeaweedServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SeaweedServer will result in compilation errors.
type VacuumVolumeRequest ¶
type VacuumVolumeRequest struct { GarbageThreshold float32 `protobuf:"fixed32,1,opt,name=garbage_threshold,json=garbageThreshold,proto3" json:"garbage_threshold,omitempty"` VolumeId uint32 `protobuf:"varint,2,opt,name=volume_id,json=volumeId,proto3" json:"volume_id,omitempty"` Collection string `protobuf:"bytes,3,opt,name=collection,proto3" json:"collection,omitempty"` // contains filtered or unexported fields }
func (*VacuumVolumeRequest) Descriptor
deprecated
func (*VacuumVolumeRequest) Descriptor() ([]byte, []int)
Deprecated: Use VacuumVolumeRequest.ProtoReflect.Descriptor instead.
func (*VacuumVolumeRequest) GetCollection ¶
func (x *VacuumVolumeRequest) GetCollection() string
func (*VacuumVolumeRequest) GetGarbageThreshold ¶
func (x *VacuumVolumeRequest) GetGarbageThreshold() float32
func (*VacuumVolumeRequest) GetVolumeId ¶
func (x *VacuumVolumeRequest) GetVolumeId() uint32
func (*VacuumVolumeRequest) ProtoMessage ¶
func (*VacuumVolumeRequest) ProtoMessage()
func (*VacuumVolumeRequest) ProtoReflect ¶
func (x *VacuumVolumeRequest) ProtoReflect() protoreflect.Message
func (*VacuumVolumeRequest) Reset ¶
func (x *VacuumVolumeRequest) Reset()
func (*VacuumVolumeRequest) String ¶
func (x *VacuumVolumeRequest) String() string
type VacuumVolumeResponse ¶
type VacuumVolumeResponse struct {
// contains filtered or unexported fields
}
func (*VacuumVolumeResponse) Descriptor
deprecated
func (*VacuumVolumeResponse) Descriptor() ([]byte, []int)
Deprecated: Use VacuumVolumeResponse.ProtoReflect.Descriptor instead.
func (*VacuumVolumeResponse) ProtoMessage ¶
func (*VacuumVolumeResponse) ProtoMessage()
func (*VacuumVolumeResponse) ProtoReflect ¶
func (x *VacuumVolumeResponse) ProtoReflect() protoreflect.Message
func (*VacuumVolumeResponse) Reset ¶
func (x *VacuumVolumeResponse) Reset()
func (*VacuumVolumeResponse) String ¶
func (x *VacuumVolumeResponse) String() string
type VolumeEcShardInformationMessage ¶
type VolumeEcShardInformationMessage struct { Id uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Collection string `protobuf:"bytes,2,opt,name=collection,proto3" json:"collection,omitempty"` EcIndexBits uint32 `protobuf:"varint,3,opt,name=ec_index_bits,json=ecIndexBits,proto3" json:"ec_index_bits,omitempty"` DiskType string `protobuf:"bytes,4,opt,name=disk_type,json=diskType,proto3" json:"disk_type,omitempty"` // contains filtered or unexported fields }
func (*VolumeEcShardInformationMessage) Descriptor
deprecated
func (*VolumeEcShardInformationMessage) Descriptor() ([]byte, []int)
Deprecated: Use VolumeEcShardInformationMessage.ProtoReflect.Descriptor instead.
func (*VolumeEcShardInformationMessage) GetCollection ¶
func (x *VolumeEcShardInformationMessage) GetCollection() string
func (*VolumeEcShardInformationMessage) GetDiskType ¶
func (x *VolumeEcShardInformationMessage) GetDiskType() string
func (*VolumeEcShardInformationMessage) GetEcIndexBits ¶
func (x *VolumeEcShardInformationMessage) GetEcIndexBits() uint32
func (*VolumeEcShardInformationMessage) GetId ¶
func (x *VolumeEcShardInformationMessage) GetId() uint32
func (*VolumeEcShardInformationMessage) ProtoMessage ¶
func (*VolumeEcShardInformationMessage) ProtoMessage()
func (*VolumeEcShardInformationMessage) ProtoReflect ¶
func (x *VolumeEcShardInformationMessage) ProtoReflect() protoreflect.Message
func (*VolumeEcShardInformationMessage) Reset ¶
func (x *VolumeEcShardInformationMessage) Reset()
func (*VolumeEcShardInformationMessage) String ¶
func (x *VolumeEcShardInformationMessage) String() string
type VolumeInformationMessage ¶
type VolumeInformationMessage struct { Id uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Size uint64 `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"` Collection string `protobuf:"bytes,3,opt,name=collection,proto3" json:"collection,omitempty"` FileCount uint64 `protobuf:"varint,4,opt,name=file_count,json=fileCount,proto3" json:"file_count,omitempty"` DeleteCount uint64 `protobuf:"varint,5,opt,name=delete_count,json=deleteCount,proto3" json:"delete_count,omitempty"` DeletedByteCount uint64 `protobuf:"varint,6,opt,name=deleted_byte_count,json=deletedByteCount,proto3" json:"deleted_byte_count,omitempty"` ReadOnly bool `protobuf:"varint,7,opt,name=read_only,json=readOnly,proto3" json:"read_only,omitempty"` ReplicaPlacement uint32 `protobuf:"varint,8,opt,name=replica_placement,json=replicaPlacement,proto3" json:"replica_placement,omitempty"` Version uint32 `protobuf:"varint,9,opt,name=version,proto3" json:"version,omitempty"` Ttl uint32 `protobuf:"varint,10,opt,name=ttl,proto3" json:"ttl,omitempty"` CompactRevision uint32 `protobuf:"varint,11,opt,name=compact_revision,json=compactRevision,proto3" json:"compact_revision,omitempty"` ModifiedAtSecond int64 `protobuf:"varint,12,opt,name=modified_at_second,json=modifiedAtSecond,proto3" json:"modified_at_second,omitempty"` RemoteStorageName string `protobuf:"bytes,13,opt,name=remote_storage_name,json=remoteStorageName,proto3" json:"remote_storage_name,omitempty"` RemoteStorageKey string `protobuf:"bytes,14,opt,name=remote_storage_key,json=remoteStorageKey,proto3" json:"remote_storage_key,omitempty"` DiskType string `protobuf:"bytes,15,opt,name=disk_type,json=diskType,proto3" json:"disk_type,omitempty"` // contains filtered or unexported fields }
func (*VolumeInformationMessage) Descriptor
deprecated
func (*VolumeInformationMessage) Descriptor() ([]byte, []int)
Deprecated: Use VolumeInformationMessage.ProtoReflect.Descriptor instead.
func (*VolumeInformationMessage) GetCollection ¶
func (x *VolumeInformationMessage) GetCollection() string
func (*VolumeInformationMessage) GetCompactRevision ¶
func (x *VolumeInformationMessage) GetCompactRevision() uint32
func (*VolumeInformationMessage) GetDeleteCount ¶
func (x *VolumeInformationMessage) GetDeleteCount() uint64
func (*VolumeInformationMessage) GetDeletedByteCount ¶
func (x *VolumeInformationMessage) GetDeletedByteCount() uint64
func (*VolumeInformationMessage) GetDiskType ¶
func (x *VolumeInformationMessage) GetDiskType() string
func (*VolumeInformationMessage) GetFileCount ¶
func (x *VolumeInformationMessage) GetFileCount() uint64
func (*VolumeInformationMessage) GetId ¶
func (x *VolumeInformationMessage) GetId() uint32
func (*VolumeInformationMessage) GetModifiedAtSecond ¶
func (x *VolumeInformationMessage) GetModifiedAtSecond() int64
func (*VolumeInformationMessage) GetReadOnly ¶
func (x *VolumeInformationMessage) GetReadOnly() bool
func (*VolumeInformationMessage) GetRemoteStorageKey ¶
func (x *VolumeInformationMessage) GetRemoteStorageKey() string
func (*VolumeInformationMessage) GetRemoteStorageName ¶
func (x *VolumeInformationMessage) GetRemoteStorageName() string
func (*VolumeInformationMessage) GetReplicaPlacement ¶
func (x *VolumeInformationMessage) GetReplicaPlacement() uint32
func (*VolumeInformationMessage) GetSize ¶
func (x *VolumeInformationMessage) GetSize() uint64
func (*VolumeInformationMessage) GetTtl ¶
func (x *VolumeInformationMessage) GetTtl() uint32
func (*VolumeInformationMessage) GetVersion ¶
func (x *VolumeInformationMessage) GetVersion() uint32
func (*VolumeInformationMessage) ProtoMessage ¶
func (*VolumeInformationMessage) ProtoMessage()
func (*VolumeInformationMessage) ProtoReflect ¶
func (x *VolumeInformationMessage) ProtoReflect() protoreflect.Message
func (*VolumeInformationMessage) Reset ¶
func (x *VolumeInformationMessage) Reset()
func (*VolumeInformationMessage) String ¶
func (x *VolumeInformationMessage) String() string
type VolumeListRequest ¶
type VolumeListRequest struct {
// contains filtered or unexported fields
}
func (*VolumeListRequest) Descriptor
deprecated
func (*VolumeListRequest) Descriptor() ([]byte, []int)
Deprecated: Use VolumeListRequest.ProtoReflect.Descriptor instead.
func (*VolumeListRequest) ProtoMessage ¶
func (*VolumeListRequest) ProtoMessage()
func (*VolumeListRequest) ProtoReflect ¶
func (x *VolumeListRequest) ProtoReflect() protoreflect.Message
func (*VolumeListRequest) Reset ¶
func (x *VolumeListRequest) Reset()
func (*VolumeListRequest) String ¶
func (x *VolumeListRequest) String() string
type VolumeListResponse ¶
type VolumeListResponse struct { TopologyInfo *TopologyInfo `protobuf:"bytes,1,opt,name=topology_info,json=topologyInfo,proto3" json:"topology_info,omitempty"` VolumeSizeLimitMb uint64 `protobuf:"varint,2,opt,name=volume_size_limit_mb,json=volumeSizeLimitMb,proto3" json:"volume_size_limit_mb,omitempty"` // contains filtered or unexported fields }
func (*VolumeListResponse) Descriptor
deprecated
func (*VolumeListResponse) Descriptor() ([]byte, []int)
Deprecated: Use VolumeListResponse.ProtoReflect.Descriptor instead.
func (*VolumeListResponse) GetTopologyInfo ¶
func (x *VolumeListResponse) GetTopologyInfo() *TopologyInfo
func (*VolumeListResponse) GetVolumeSizeLimitMb ¶
func (x *VolumeListResponse) GetVolumeSizeLimitMb() uint64
func (*VolumeListResponse) ProtoMessage ¶
func (*VolumeListResponse) ProtoMessage()
func (*VolumeListResponse) ProtoReflect ¶
func (x *VolumeListResponse) ProtoReflect() protoreflect.Message
func (*VolumeListResponse) Reset ¶
func (x *VolumeListResponse) Reset()
func (*VolumeListResponse) String ¶
func (x *VolumeListResponse) String() string
type VolumeLocation ¶
type VolumeLocation 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"` NewVids []uint32 `protobuf:"varint,3,rep,packed,name=new_vids,json=newVids,proto3" json:"new_vids,omitempty"` DeletedVids []uint32 `protobuf:"varint,4,rep,packed,name=deleted_vids,json=deletedVids,proto3" json:"deleted_vids,omitempty"` Leader string `protobuf:"bytes,5,opt,name=leader,proto3" json:"leader,omitempty"` // optional when leader is not itself DataCenter string `protobuf:"bytes,6,opt,name=data_center,json=dataCenter,proto3" json:"data_center,omitempty"` // optional when DataCenter is in use GrpcPort uint32 `protobuf:"varint,7,opt,name=grpc_port,json=grpcPort,proto3" json:"grpc_port,omitempty"` NewEcVids []uint32 `protobuf:"varint,8,rep,packed,name=new_ec_vids,json=newEcVids,proto3" json:"new_ec_vids,omitempty"` DeletedEcVids []uint32 `protobuf:"varint,9,rep,packed,name=deleted_ec_vids,json=deletedEcVids,proto3" json:"deleted_ec_vids,omitempty"` // contains filtered or unexported fields }
func (*VolumeLocation) Descriptor
deprecated
func (*VolumeLocation) Descriptor() ([]byte, []int)
Deprecated: Use VolumeLocation.ProtoReflect.Descriptor instead.
func (*VolumeLocation) GetDataCenter ¶
func (x *VolumeLocation) GetDataCenter() string
func (*VolumeLocation) GetDeletedEcVids ¶
func (x *VolumeLocation) GetDeletedEcVids() []uint32
func (*VolumeLocation) GetDeletedVids ¶
func (x *VolumeLocation) GetDeletedVids() []uint32
func (*VolumeLocation) GetGrpcPort ¶
func (x *VolumeLocation) GetGrpcPort() uint32
func (*VolumeLocation) GetLeader ¶
func (x *VolumeLocation) GetLeader() string
func (*VolumeLocation) GetNewEcVids ¶
func (x *VolumeLocation) GetNewEcVids() []uint32
func (*VolumeLocation) GetNewVids ¶
func (x *VolumeLocation) GetNewVids() []uint32
func (*VolumeLocation) GetPublicUrl ¶
func (x *VolumeLocation) GetPublicUrl() string
func (*VolumeLocation) GetUrl ¶
func (x *VolumeLocation) GetUrl() string
func (*VolumeLocation) ProtoMessage ¶
func (*VolumeLocation) ProtoMessage()
func (*VolumeLocation) ProtoReflect ¶
func (x *VolumeLocation) ProtoReflect() protoreflect.Message
func (*VolumeLocation) Reset ¶
func (x *VolumeLocation) Reset()
func (*VolumeLocation) String ¶
func (x *VolumeLocation) String() string
type VolumeShortInformationMessage ¶
type VolumeShortInformationMessage struct { Id uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Collection string `protobuf:"bytes,3,opt,name=collection,proto3" json:"collection,omitempty"` ReplicaPlacement uint32 `protobuf:"varint,8,opt,name=replica_placement,json=replicaPlacement,proto3" json:"replica_placement,omitempty"` Version uint32 `protobuf:"varint,9,opt,name=version,proto3" json:"version,omitempty"` Ttl uint32 `protobuf:"varint,10,opt,name=ttl,proto3" json:"ttl,omitempty"` DiskType string `protobuf:"bytes,15,opt,name=disk_type,json=diskType,proto3" json:"disk_type,omitempty"` // contains filtered or unexported fields }
func (*VolumeShortInformationMessage) Descriptor
deprecated
func (*VolumeShortInformationMessage) Descriptor() ([]byte, []int)
Deprecated: Use VolumeShortInformationMessage.ProtoReflect.Descriptor instead.
func (*VolumeShortInformationMessage) GetCollection ¶
func (x *VolumeShortInformationMessage) GetCollection() string
func (*VolumeShortInformationMessage) GetDiskType ¶
func (x *VolumeShortInformationMessage) GetDiskType() string
func (*VolumeShortInformationMessage) GetId ¶
func (x *VolumeShortInformationMessage) GetId() uint32
func (*VolumeShortInformationMessage) GetReplicaPlacement ¶
func (x *VolumeShortInformationMessage) GetReplicaPlacement() uint32
func (*VolumeShortInformationMessage) GetTtl ¶
func (x *VolumeShortInformationMessage) GetTtl() uint32
func (*VolumeShortInformationMessage) GetVersion ¶
func (x *VolumeShortInformationMessage) GetVersion() uint32
func (*VolumeShortInformationMessage) ProtoMessage ¶
func (*VolumeShortInformationMessage) ProtoMessage()
func (*VolumeShortInformationMessage) ProtoReflect ¶
func (x *VolumeShortInformationMessage) ProtoReflect() protoreflect.Message
func (*VolumeShortInformationMessage) Reset ¶
func (x *VolumeShortInformationMessage) Reset()
func (*VolumeShortInformationMessage) String ¶
func (x *VolumeShortInformationMessage) String() string