master_pb

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

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

 Go to latest Published: Jul 29, 2022 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_master_proto protoreflect.FileDescriptor
View Source 
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"`
	CreatedAtNs int64  `protobuf:"varint,6,opt,name=created_at_ns,json=createdAtNs,proto3" json:"created_at_ns,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) GetCreatedAtNs 

func (x *ClusterNodeUpdate) GetCreatedAtNs() int64

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) Descriptor() ([]byte, []int)

Deprecated: Use DiskInfo.ProtoReflect.Descriptor instead.

func (*DiskInfo) GetActiveVolumeCount 

func (x *DiskInfo) GetActiveVolumeCount() int64

func (*DiskInfo) GetEcShardInfos 

func (x *DiskInfo) GetEcShardInfos() []*VolumeEcShardInformationMessage

func (*DiskInfo) GetFreeVolumeCount 

func (x *DiskInfo) GetFreeVolumeCount() int64

func (*DiskInfo) GetMaxVolumeCount 

func (x *DiskInfo) GetMaxVolumeCount() int64

func (*DiskInfo) GetRemoteVolumeCount 

func (x *DiskInfo) GetRemoteVolumeCount() int64

func (*DiskInfo) GetType 

func (x *DiskInfo) GetType() string

func (*DiskInfo) GetVolumeCount 

func (x *DiskInfo) GetVolumeCount() int64

func (*DiskInfo) GetVolumeInfos 

func (x *DiskInfo) GetVolumeInfos() []*VolumeInformationMessage

func (*DiskInfo) ProtoMessage 

func (*DiskInfo) ProtoMessage()

func (*DiskInfo) ProtoReflect 

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

func (*DiskInfo) Reset 

func (x *DiskInfo) Reset()

func (*DiskInfo) String 

func (x *DiskInfo) String() string

type Empty 

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

func (*Empty) Descriptor deprecated 

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

Deprecated: Use Empty.ProtoReflect.Descriptor instead.

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) ProtoReflect 

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

func (*Empty) Reset 

func (x *Empty) Reset()

func (*Empty) String 

func (x *Empty) String() string

type 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"`
	LocationUuids   []string                           `protobuf:"bytes,21,rep,name=location_uuids,json=locationUuids,proto3" json:"location_uuids,omitempty"`
	// contains filtered or unexported fields
}

func (*Heartbeat) Descriptor deprecated 

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

Deprecated: Use Heartbeat.ProtoReflect.Descriptor instead.

func (*Heartbeat) GetAdminPort 

func (x *Heartbeat) GetAdminPort() uint32

func (*Heartbeat) GetDataCenter 

func (x *Heartbeat) GetDataCenter() string

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 (x *Heartbeat) GetGrpcPort() uint32

func (*Heartbeat) GetHasNoEcShards 

func (x *Heartbeat) GetHasNoEcShards() bool

func (*Heartbeat) GetHasNoVolumes 

func (x *Heartbeat) GetHasNoVolumes() bool

func (*Heartbeat) GetIp 

func (x *Heartbeat) GetIp() string

func (*Heartbeat) GetLocationUuids 

func (x *Heartbeat) GetLocationUuids() []string

func (*Heartbeat) GetMaxFileKey 

func (x *Heartbeat) GetMaxFileKey() uint64

func (*Heartbeat) GetMaxVolumeCounts 

func (x *Heartbeat) GetMaxVolumeCounts() map[string]uint32

func (*Heartbeat) GetNewEcShards 

func (x *Heartbeat) GetNewEcShards() []*VolumeEcShardInformationMessage

func (*Heartbeat) GetNewVolumes 

func (x *Heartbeat) GetNewVolumes() []*VolumeShortInformationMessage

func (*Heartbeat) GetPort 

func (x *Heartbeat) GetPort() uint32

func (*Heartbeat) GetPublicUrl 

func (x *Heartbeat) GetPublicUrl() string

func (*Heartbeat) GetRack 

func (x *Heartbeat) GetRack() string

func (*Heartbeat) GetVolumes 

func (x *Heartbeat) GetVolumes() []*VolumeInformationMessage

func (*Heartbeat) ProtoMessage 

func (*Heartbeat) ProtoMessage()

func (*Heartbeat) ProtoReflect 

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

func (*Heartbeat) Reset 

func (x *Heartbeat) Reset()

func (*Heartbeat) String 

func (x *Heartbeat) String() string

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"`
	DuplicatedUuids        []string          `protobuf:"bytes,6,rep,name=duplicated_uuids,json=duplicatedUuids,proto3" json:"duplicated_uuids,omitempty"`
	// contains filtered or unexported fields
}

func (*HeartbeatResponse) Descriptor deprecated 

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

Deprecated: Use HeartbeatResponse.ProtoReflect.Descriptor instead.

func (*HeartbeatResponse) GetDuplicatedUuids 

func (x *HeartbeatResponse) GetDuplicatedUuids() []string

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"`
	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"`
	// 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) GetDataCenter 

func (x *KeepConnectedRequest) GetDataCenter() string

func (*KeepConnectedRequest) GetFilerGroup 

func (x *KeepConnectedRequest) GetFilerGroup() string

func (*KeepConnectedRequest) GetRack 

func (x *KeepConnectedRequest) GetRack() 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"`
	IsLeaderOnly bool   `protobuf:"varint,3,opt,name=is_leader_only,json=isLeaderOnly,proto3" json:"is_leader_only,omitempty"`
	Limit        int32  `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,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) GetIsLeaderOnly 

func (x *ListClusterNodesRequest) GetIsLeaderOnly() bool

func (*ListClusterNodesRequest) GetLimit 

func (x *ListClusterNodesRequest) GetLimit() int32

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"`
	CreatedAtNs int64  `protobuf:"varint,4,opt,name=created_at_ns,json=createdAtNs,proto3" json:"created_at_ns,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"`
	// 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) GetCreatedAtNs 

func (x *ListClusterNodesResponse_ClusterNode) GetCreatedAtNs() int64

func (*ListClusterNodesResponse_ClusterNode) GetDataCenter 

func (x *ListClusterNodesResponse_ClusterNode) GetDataCenter() string

func (*ListClusterNodesResponse_ClusterNode) GetIsLeader 

func (x *ListClusterNodesResponse_ClusterNode) GetIsLeader() bool

func (*ListClusterNodesResponse_ClusterNode) GetRack 

func (x *ListClusterNodesResponse_ClusterNode) GetRack() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Location.ProtoReflect.Descriptor instead.

func (*Location) GetGrpcPort 

func (x *Location) GetGrpcPort() uint32

func (*Location) GetPublicUrl 

func (x *Location) GetPublicUrl() string

func (*Location) GetUrl 

func (x *Location) GetUrl() string

func (*Location) ProtoMessage 

func (*Location) ProtoMessage()

func (*Location) ProtoReflect 

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

func (*Location) Reset 

func (x *Location) Reset()

func (*Location) String 

func (x *Location) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use RackInfo.ProtoReflect.Descriptor instead.

func (*RackInfo) GetDataNodeInfos 

func (x *RackInfo) GetDataNodeInfos() []*DataNodeInfo

func (*RackInfo) GetDiskInfos 

func (x *RackInfo) GetDiskInfos() map[string]*DiskInfo

func (*RackInfo) GetId 

func (x *RackInfo) GetId() string

func (*RackInfo) ProtoMessage 

func (*RackInfo) ProtoMessage()

func (*RackInfo) ProtoReflect 

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

func (*RackInfo) Reset 

func (x *RackInfo) Reset()

func (*RackInfo) String 

func (x *RackInfo) String() string

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.