master_pb

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

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_master_proto protoreflect.FileDescriptor

Functions

func RegisterSeaweedServer 

func RegisterSeaweedServer(s *grpc.Server, 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"`
	// 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) 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"`
	Url       string `protobuf:"bytes,2,opt,name=url,proto3" json:"url,omitempty"`
	PublicUrl string `protobuf:"bytes,3,opt,name=public_url,json=publicUrl,proto3" json:"public_url,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"`
	// 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) GetPublicUrl 

func (x *AssignResponse) GetPublicUrl() string

func (*AssignResponse) GetUrl 

func (x *AssignResponse) GetUrl() string

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 Collection 

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

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"`
	VolumeCount       uint64      `protobuf:"varint,2,opt,name=volume_count,json=volumeCount,proto3" json:"volume_count,omitempty"`
	MaxVolumeCount    uint64      `protobuf:"varint,3,opt,name=max_volume_count,json=maxVolumeCount,proto3" json:"max_volume_count,omitempty"`
	FreeVolumeCount   uint64      `protobuf:"varint,4,opt,name=free_volume_count,json=freeVolumeCount,proto3" json:"free_volume_count,omitempty"`
	ActiveVolumeCount uint64      `protobuf:"varint,5,opt,name=active_volume_count,json=activeVolumeCount,proto3" json:"active_volume_count,omitempty"`
	RackInfos         []*RackInfo `protobuf:"bytes,6,rep,name=rack_infos,json=rackInfos,proto3" json:"rack_infos,omitempty"`
	RemoteVolumeCount uint64      `protobuf:"varint,7,opt,name=remote_volume_count,json=remoteVolumeCount,proto3" json:"remote_volume_count,omitempty"`
	// contains filtered or unexported fields
}

func (*DataCenterInfo) Descriptor deprecated 

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

Deprecated: Use DataCenterInfo.ProtoReflect.Descriptor instead.

func (*DataCenterInfo) GetActiveVolumeCount 

func (x *DataCenterInfo) GetActiveVolumeCount() uint64

func (*DataCenterInfo) GetFreeVolumeCount 

func (x *DataCenterInfo) GetFreeVolumeCount() uint64

func (*DataCenterInfo) GetId 

func (x *DataCenterInfo) GetId() string

func (*DataCenterInfo) GetMaxVolumeCount 

func (x *DataCenterInfo) GetMaxVolumeCount() uint64

func (*DataCenterInfo) GetRackInfos 

func (x *DataCenterInfo) GetRackInfos() []*RackInfo

func (*DataCenterInfo) GetRemoteVolumeCount 

func (x *DataCenterInfo) GetRemoteVolumeCount() uint64

func (*DataCenterInfo) GetVolumeCount 

func (x *DataCenterInfo) GetVolumeCount() uint64

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"`
	VolumeCount       uint64                             `protobuf:"varint,2,opt,name=volume_count,json=volumeCount,proto3" json:"volume_count,omitempty"`
	MaxVolumeCount    uint64                             `protobuf:"varint,3,opt,name=max_volume_count,json=maxVolumeCount,proto3" json:"max_volume_count,omitempty"`
	FreeVolumeCount   uint64                             `protobuf:"varint,4,opt,name=free_volume_count,json=freeVolumeCount,proto3" json:"free_volume_count,omitempty"`
	ActiveVolumeCount uint64                             `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 uint64                             `protobuf:"varint,8,opt,name=remote_volume_count,json=remoteVolumeCount,proto3" json:"remote_volume_count,omitempty"`
	// contains filtered or unexported fields
}

volume related

func (*DataNodeInfo) Descriptor deprecated 

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

Deprecated: Use DataNodeInfo.ProtoReflect.Descriptor instead.

func (*DataNodeInfo) GetActiveVolumeCount 

func (x *DataNodeInfo) GetActiveVolumeCount() uint64

func (*DataNodeInfo) GetEcShardInfos 

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

func (*DataNodeInfo) GetFreeVolumeCount 

func (x *DataNodeInfo) GetFreeVolumeCount() uint64

func (*DataNodeInfo) GetId 

func (x *DataNodeInfo) GetId() string

func (*DataNodeInfo) GetMaxVolumeCount 

func (x *DataNodeInfo) GetMaxVolumeCount() uint64

func (*DataNodeInfo) GetRemoteVolumeCount 

func (x *DataNodeInfo) GetRemoteVolumeCount() uint64

func (*DataNodeInfo) GetVolumeCount 

func (x *DataNodeInfo) GetVolumeCount() uint64

func (*DataNodeInfo) GetVolumeInfos 

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

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 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"`
	// contains filtered or unexported fields
}

func (*GetMasterConfigurationResponse) Descriptor deprecated 

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

Deprecated: Use GetMasterConfigurationResponse.ProtoReflect.Descriptor instead.

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) 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"`
	MaxVolumeCount uint32                      `protobuf:"varint,4,opt,name=max_volume_count,json=maxVolumeCount,proto3" json:"max_volume_count,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"`
	// 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) GetHasNoEcShards 

func (x *Heartbeat) GetHasNoEcShards() bool

func (*Heartbeat) GetHasNoVolumes 

func (x *Heartbeat) GetHasNoVolumes() bool

func (*Heartbeat) GetIp 

func (x *Heartbeat) GetIp() string

func (*Heartbeat) GetMaxFileKey 

func (x *Heartbeat) GetMaxFileKey() uint64

func (*Heartbeat) GetMaxVolumeCount 

func (x *Heartbeat) GetMaxVolumeCount() 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"`
	// 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 {
	Name     string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	GrpcPort uint32 `protobuf:"varint,2,opt,name=grpc_port,json=grpcPort,proto3" json:"grpc_port,omitempty"`
	// contains filtered or unexported fields
}

func (*KeepConnectedRequest) Descriptor deprecated 

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

Deprecated: Use KeepConnectedRequest.ProtoReflect.Descriptor instead.

func (*KeepConnectedRequest) GetGrpcPort 

func (x *KeepConnectedRequest) GetGrpcPort() uint32

func (*KeepConnectedRequest) GetName 

func (x *KeepConnectedRequest) GetName() 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 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"`
	// contains filtered or unexported fields
}

func (*LeaseAdminTokenRequest) Descriptor deprecated 

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

Deprecated: Use LeaseAdminTokenRequest.ProtoReflect.Descriptor instead.

func (*LeaseAdminTokenRequest) GetLockName 

func (x *LeaseAdminTokenRequest) GetLockName() 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 ListMasterClientsRequest 

type ListMasterClientsRequest struct {
	ClientType string `protobuf:"bytes,1,opt,name=client_type,json=clientType,proto3" json:"client_type,omitempty"`
	// contains filtered or unexported fields
}

func (*ListMasterClientsRequest) Descriptor deprecated 

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

Deprecated: Use ListMasterClientsRequest.ProtoReflect.Descriptor instead.

func (*ListMasterClientsRequest) GetClientType 

func (x *ListMasterClientsRequest) GetClientType() string

func (*ListMasterClientsRequest) ProtoMessage 

func (*ListMasterClientsRequest) ProtoMessage()

func (*ListMasterClientsRequest) ProtoReflect 

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

func (*ListMasterClientsRequest) Reset 

func (x *ListMasterClientsRequest) Reset()

func (*ListMasterClientsRequest) String 

func (x *ListMasterClientsRequest) String() string

type ListMasterClientsResponse 

type ListMasterClientsResponse struct {
	GrpcAddresses []string `protobuf:"bytes,1,rep,name=grpc_addresses,json=grpcAddresses,proto3" json:"grpc_addresses,omitempty"`
	// contains filtered or unexported fields
}

func (*ListMasterClientsResponse) Descriptor deprecated 

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

Deprecated: Use ListMasterClientsResponse.ProtoReflect.Descriptor instead.

func (*ListMasterClientsResponse) GetGrpcAddresses 

func (x *ListMasterClientsResponse) GetGrpcAddresses() []string

func (*ListMasterClientsResponse) ProtoMessage 

func (*ListMasterClientsResponse) ProtoMessage()

func (*ListMasterClientsResponse) ProtoReflect 

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

func (*ListMasterClientsResponse) Reset 

func (x *ListMasterClientsResponse) Reset()

func (*ListMasterClientsResponse) String 

func (x *ListMasterClientsResponse) 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"`
	// contains filtered or unexported fields
}

func (*Location) Descriptor deprecated 

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

Deprecated: Use Location.ProtoReflect.Descriptor instead.

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 {
	VolumeIds  []string `protobuf:"bytes,1,rep,name=volume_ids,json=volumeIds,proto3" json:"volume_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) GetVolumeIds 

func (x *LookupVolumeRequest) GetVolumeIds() []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 {
	VolumeId  string      `protobuf:"bytes,1,opt,name=volume_id,json=volumeId,proto3" json:"volume_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"`
	// 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) GetError 

func (x *LookupVolumeResponse_VolumeIdLocation) GetError() string

func (*LookupVolumeResponse_VolumeIdLocation) GetLocations 

func (x *LookupVolumeResponse_VolumeIdLocation) GetLocations() []*Location

func (*LookupVolumeResponse_VolumeIdLocation) GetVolumeId 

func (x *LookupVolumeResponse_VolumeIdLocation) GetVolumeId() 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 RackInfo 

type RackInfo struct {
	Id                string          `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	VolumeCount       uint64          `protobuf:"varint,2,opt,name=volume_count,json=volumeCount,proto3" json:"volume_count,omitempty"`
	MaxVolumeCount    uint64          `protobuf:"varint,3,opt,name=max_volume_count,json=maxVolumeCount,proto3" json:"max_volume_count,omitempty"`
	FreeVolumeCount   uint64          `protobuf:"varint,4,opt,name=free_volume_count,json=freeVolumeCount,proto3" json:"free_volume_count,omitempty"`
	ActiveVolumeCount uint64          `protobuf:"varint,5,opt,name=active_volume_count,json=activeVolumeCount,proto3" json:"active_volume_count,omitempty"`
	DataNodeInfos     []*DataNodeInfo `protobuf:"bytes,6,rep,name=data_node_infos,json=dataNodeInfos,proto3" json:"data_node_infos,omitempty"`
	RemoteVolumeCount uint64          `protobuf:"varint,7,opt,name=remote_volume_count,json=remoteVolumeCount,proto3" json:"remote_volume_count,omitempty"`
	// contains filtered or unexported fields
}

func (*RackInfo) Descriptor deprecated 

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

Deprecated: Use RackInfo.ProtoReflect.Descriptor instead.

func (*RackInfo) GetActiveVolumeCount 

func (x *RackInfo) GetActiveVolumeCount() uint64

func (*RackInfo) GetDataNodeInfos 

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

func (*RackInfo) GetFreeVolumeCount 

func (x *RackInfo) GetFreeVolumeCount() uint64

func (*RackInfo) GetId 

func (x *RackInfo) GetId() string

func (*RackInfo) GetMaxVolumeCount 

func (x *RackInfo) GetMaxVolumeCount() uint64

func (*RackInfo) GetRemoteVolumeCount 

func (x *RackInfo) GetRemoteVolumeCount() uint64

func (*RackInfo) GetVolumeCount 

func (x *RackInfo) GetVolumeCount() uint64

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 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)
	GetMasterConfiguration(ctx context.Context, in *GetMasterConfigurationRequest, opts ...grpc.CallOption) (*GetMasterConfigurationResponse, error)
	ListMasterClients(ctx context.Context, in *ListMasterClientsRequest, opts ...grpc.CallOption) (*ListMasterClientsResponse, error)
	LeaseAdminToken(ctx context.Context, in *LeaseAdminTokenRequest, opts ...grpc.CallOption) (*LeaseAdminTokenResponse, error)
	ReleaseAdminToken(ctx context.Context, in *ReleaseAdminTokenRequest, opts ...grpc.CallOption) (*ReleaseAdminTokenResponse, error)
}

SeaweedClient is the client API for Seaweed service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#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)
	GetMasterConfiguration(context.Context, *GetMasterConfigurationRequest) (*GetMasterConfigurationResponse, error)
	ListMasterClients(context.Context, *ListMasterClientsRequest) (*ListMasterClientsResponse, error)
	LeaseAdminToken(context.Context, *LeaseAdminTokenRequest) (*LeaseAdminTokenResponse, error)
	ReleaseAdminToken(context.Context, *ReleaseAdminTokenRequest) (*ReleaseAdminTokenResponse, error)
}

SeaweedServer is the server API for Seaweed service.

type Seaweed_KeepConnectedClient 

type Seaweed_KeepConnectedClient interface {
	Send(*KeepConnectedRequest) error
	Recv() (*VolumeLocation, error)
	grpc.ClientStream
}

type Seaweed_KeepConnectedServer 

type Seaweed_KeepConnectedServer interface {
	Send(*VolumeLocation) 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"`
	// 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) 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 {
	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"`
	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) GetCollection 

func (x *StatisticsResponse) GetCollection() string

func (*StatisticsResponse) GetFileCount 

func (x *StatisticsResponse) GetFileCount() uint64

func (*StatisticsResponse) GetReplication 

func (x *StatisticsResponse) GetReplication() string

func (*StatisticsResponse) GetTotalSize 

func (x *StatisticsResponse) GetTotalSize() uint64

func (*StatisticsResponse) GetTtl 

func (x *StatisticsResponse) GetTtl() string

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 StorageType 

type StorageType struct {
	Replication string `protobuf:"bytes,1,opt,name=replication,proto3" json:"replication,omitempty"`
	Ttl         string `protobuf:"bytes,2,opt,name=ttl,proto3" json:"ttl,omitempty"`
	// contains filtered or unexported fields
}

func (*StorageType) Descriptor deprecated 

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

Deprecated: Use StorageType.ProtoReflect.Descriptor instead.

func (*StorageType) GetReplication 

func (x *StorageType) GetReplication() string

func (*StorageType) GetTtl 

func (x *StorageType) GetTtl() string

func (*StorageType) ProtoMessage 

func (*StorageType) ProtoMessage()

func (*StorageType) ProtoReflect 

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

func (*StorageType) Reset 

func (x *StorageType) Reset()

func (*StorageType) String 

func (x *StorageType) 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"`
	VolumeCount       uint64            `protobuf:"varint,2,opt,name=volume_count,json=volumeCount,proto3" json:"volume_count,omitempty"`
	MaxVolumeCount    uint64            `protobuf:"varint,3,opt,name=max_volume_count,json=maxVolumeCount,proto3" json:"max_volume_count,omitempty"`
	FreeVolumeCount   uint64            `protobuf:"varint,4,opt,name=free_volume_count,json=freeVolumeCount,proto3" json:"free_volume_count,omitempty"`
	ActiveVolumeCount uint64            `protobuf:"varint,5,opt,name=active_volume_count,json=activeVolumeCount,proto3" json:"active_volume_count,omitempty"`
	DataCenterInfos   []*DataCenterInfo `protobuf:"bytes,6,rep,name=data_center_infos,json=dataCenterInfos,proto3" json:"data_center_infos,omitempty"`
	RemoteVolumeCount uint64            `protobuf:"varint,7,opt,name=remote_volume_count,json=remoteVolumeCount,proto3" json:"remote_volume_count,omitempty"`
	// contains filtered or unexported fields
}

func (*TopologyInfo) Descriptor deprecated 

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

Deprecated: Use TopologyInfo.ProtoReflect.Descriptor instead.

func (*TopologyInfo) GetActiveVolumeCount 

func (x *TopologyInfo) GetActiveVolumeCount() uint64

func (*TopologyInfo) GetDataCenterInfos 

func (x *TopologyInfo) GetDataCenterInfos() []*DataCenterInfo

func (*TopologyInfo) GetFreeVolumeCount 

func (x *TopologyInfo) GetFreeVolumeCount() uint64

func (*TopologyInfo) GetId 

func (x *TopologyInfo) GetId() string

func (*TopologyInfo) GetMaxVolumeCount 

func (x *TopologyInfo) GetMaxVolumeCount() uint64

func (*TopologyInfo) GetRemoteVolumeCount 

func (x *TopologyInfo) GetRemoteVolumeCount() uint64

func (*TopologyInfo) GetVolumeCount 

func (x *TopologyInfo) GetVolumeCount() uint64

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 can 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) ListMasterClients 

func (*UnimplementedSeaweedServer) ListMasterClients(context.Context, *ListMasterClientsRequest) (*ListMasterClientsResponse, 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) 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) VolumeList 

func (*UnimplementedSeaweedServer) VolumeList(context.Context, *VolumeListRequest) (*VolumeListResponse, error)

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"`
	// 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) 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"`
	// 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) 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
	// contains filtered or unexported fields
}

func (*VolumeLocation) Descriptor deprecated 

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

Deprecated: Use VolumeLocation.ProtoReflect.Descriptor instead.

func (*VolumeLocation) GetDeletedVids 

func (x *VolumeLocation) GetDeletedVids() []uint32

func (*VolumeLocation) GetLeader 

func (x *VolumeLocation) GetLeader() string

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