master_pb

package
v0.0.0-...-d8c34b0 Latest Latest
Warning

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

 Go to latest Published: Sep 12, 2019 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Overview

Package master_pb is a generated protocol buffer package.

It is generated from these files: 

master.proto

It has these top-level messages: 

Heartbeat
HeartbeatResponse
VolumeInformationMessage
VolumeShortInformationMessage
VolumeEcShardInformationMessage
Empty
SuperBlockExtra
KeepConnectedRequest
VolumeLocation
LookupVolumeRequest
LookupVolumeResponse
Location
AssignRequest
AssignResponse
StatisticsRequest
StatisticsResponse
StorageType
Collection
CollectionListRequest
CollectionListResponse
CollectionDeleteRequest
CollectionDeleteResponse
DataNodeInfo
RackInfo
DataCenterInfo
TopologyInfo
VolumeListRequest
VolumeListResponse
LookupEcVolumeRequest
LookupEcVolumeResponse
GetMasterConfigurationRequest
GetMasterConfigurationResponse

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterSeaweedServer 

func RegisterSeaweedServer(s *grpc.Server, srv SeaweedServer)

Types

type AssignRequest 

type AssignRequest struct {
	Count              uint64 `protobuf:"varint,1,opt,name=count" json:"count,omitempty"`
	Replication        string `protobuf:"bytes,2,opt,name=replication" json:"replication,omitempty"`
	Collection         string `protobuf:"bytes,3,opt,name=collection" json:"collection,omitempty"`
	Ttl                string `protobuf:"bytes,4,opt,name=ttl" json:"ttl,omitempty"`
	DataCenter         string `protobuf:"bytes,5,opt,name=data_center,json=dataCenter" json:"data_center,omitempty"`
	Rack               string `protobuf:"bytes,6,opt,name=rack" json:"rack,omitempty"`
	DataNode           string `protobuf:"bytes,7,opt,name=data_node,json=dataNode" json:"data_node,omitempty"`
	MemoryMapMaxSizeMB uint32 `protobuf:"varint,8,opt,name=memorymapmaxsizemb" json:"memorymapmaxsizemb,omitempty"`
}

func (*AssignRequest) Descriptor 

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

func (*AssignRequest) GetCollection 

func (m *AssignRequest) GetCollection() string

func (*AssignRequest) GetCount 

func (m *AssignRequest) GetCount() uint64

func (*AssignRequest) GetDataCenter 

func (m *AssignRequest) GetDataCenter() string

func (*AssignRequest) GetDataNode 

func (m *AssignRequest) GetDataNode() string

func (*AssignRequest) GetMemoryMapMaxSizeMB 

func (m *AssignRequest) GetMemoryMapMaxSizeMB() uint32

func (*AssignRequest) GetRack 

func (m *AssignRequest) GetRack() string

func (*AssignRequest) GetReplication 

func (m *AssignRequest) GetReplication() string

func (*AssignRequest) GetTtl 

func (m *AssignRequest) GetTtl() string

func (*AssignRequest) ProtoMessage 

func (*AssignRequest) ProtoMessage()

func (*AssignRequest) Reset 

func (m *AssignRequest) Reset()

func (*AssignRequest) String 

func (m *AssignRequest) String() string

type AssignResponse 

type AssignResponse struct {
	Fid       string `protobuf:"bytes,1,opt,name=fid" json:"fid,omitempty"`
	Url       string `protobuf:"bytes,2,opt,name=url" json:"url,omitempty"`
	PublicUrl string `protobuf:"bytes,3,opt,name=public_url,json=publicUrl" json:"public_url,omitempty"`
	Count     uint64 `protobuf:"varint,4,opt,name=count" json:"count,omitempty"`
	Error     string `protobuf:"bytes,5,opt,name=error" json:"error,omitempty"`
	Auth      string `protobuf:"bytes,6,opt,name=auth" json:"auth,omitempty"`
}

func (*AssignResponse) Descriptor 

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

func (*AssignResponse) GetAuth 

func (m *AssignResponse) GetAuth() string

func (*AssignResponse) GetCount 

func (m *AssignResponse) GetCount() uint64

func (*AssignResponse) GetError 

func (m *AssignResponse) GetError() string

func (*AssignResponse) GetFid 

func (m *AssignResponse) GetFid() string

func (*AssignResponse) GetPublicUrl 

func (m *AssignResponse) GetPublicUrl() string

func (*AssignResponse) GetUrl 

func (m *AssignResponse) GetUrl() string

func (*AssignResponse) ProtoMessage 

func (*AssignResponse) ProtoMessage()

func (*AssignResponse) Reset 

func (m *AssignResponse) Reset()

func (*AssignResponse) String 

func (m *AssignResponse) String() string

type Collection 

type Collection struct {
	Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
}

func (*Collection) Descriptor 

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

func (*Collection) GetName 

func (m *Collection) GetName() string

func (*Collection) ProtoMessage 

func (*Collection) ProtoMessage()

func (*Collection) Reset 

func (m *Collection) Reset()

func (*Collection) String 

func (m *Collection) String() string

type CollectionDeleteRequest 

type CollectionDeleteRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
}

func (*CollectionDeleteRequest) Descriptor 

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

func (*CollectionDeleteRequest) GetName 

func (m *CollectionDeleteRequest) GetName() string

func (*CollectionDeleteRequest) ProtoMessage 

func (*CollectionDeleteRequest) ProtoMessage()

func (*CollectionDeleteRequest) Reset 

func (m *CollectionDeleteRequest) Reset()

func (*CollectionDeleteRequest) String 

func (m *CollectionDeleteRequest) String() string

type CollectionDeleteResponse 

type CollectionDeleteResponse struct {
}

func (*CollectionDeleteResponse) Descriptor 

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

func (*CollectionDeleteResponse) ProtoMessage 

func (*CollectionDeleteResponse) ProtoMessage()

func (*CollectionDeleteResponse) Reset 

func (m *CollectionDeleteResponse) Reset()

func (*CollectionDeleteResponse) String 

func (m *CollectionDeleteResponse) String() string

type CollectionListRequest 

type CollectionListRequest struct {
	IncludeNormalVolumes bool `protobuf:"varint,1,opt,name=include_normal_volumes,json=includeNormalVolumes" json:"include_normal_volumes,omitempty"`
	IncludeEcVolumes     bool `protobuf:"varint,2,opt,name=include_ec_volumes,json=includeEcVolumes" json:"include_ec_volumes,omitempty"`
}

func (*CollectionListRequest) Descriptor 

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

func (*CollectionListRequest) GetIncludeEcVolumes 

func (m *CollectionListRequest) GetIncludeEcVolumes() bool

func (*CollectionListRequest) GetIncludeNormalVolumes 

func (m *CollectionListRequest) GetIncludeNormalVolumes() bool

func (*CollectionListRequest) ProtoMessage 

func (*CollectionListRequest) ProtoMessage()

func (*CollectionListRequest) Reset 

func (m *CollectionListRequest) Reset()

func (*CollectionListRequest) String 

func (m *CollectionListRequest) String() string

type CollectionListResponse 

type CollectionListResponse struct {
	Collections []*Collection `protobuf:"bytes,1,rep,name=collections" json:"collections,omitempty"`
}

func (*CollectionListResponse) Descriptor 

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

func (*CollectionListResponse) GetCollections 

func (m *CollectionListResponse) GetCollections() []*Collection

func (*CollectionListResponse) ProtoMessage 

func (*CollectionListResponse) ProtoMessage()

func (*CollectionListResponse) Reset 

func (m *CollectionListResponse) Reset()

func (*CollectionListResponse) String 

func (m *CollectionListResponse) String() string

type DataCenterInfo 

type DataCenterInfo struct {
	Id                string      `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
	VolumeCount       uint64      `protobuf:"varint,2,opt,name=volume_count,json=volumeCount" json:"volume_count,omitempty"`
	MaxVolumeCount    uint64      `protobuf:"varint,3,opt,name=max_volume_count,json=maxVolumeCount" json:"max_volume_count,omitempty"`
	FreeVolumeCount   uint64      `protobuf:"varint,4,opt,name=free_volume_count,json=freeVolumeCount" json:"free_volume_count,omitempty"`
	ActiveVolumeCount uint64      `protobuf:"varint,5,opt,name=active_volume_count,json=activeVolumeCount" json:"active_volume_count,omitempty"`
	RackInfos         []*RackInfo `protobuf:"bytes,6,rep,name=rack_infos,json=rackInfos" json:"rack_infos,omitempty"`
}

func (*DataCenterInfo) Descriptor 

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

func (*DataCenterInfo) GetActiveVolumeCount 

func (m *DataCenterInfo) GetActiveVolumeCount() uint64

func (*DataCenterInfo) GetFreeVolumeCount 

func (m *DataCenterInfo) GetFreeVolumeCount() uint64

func (*DataCenterInfo) GetId 

func (m *DataCenterInfo) GetId() string

func (*DataCenterInfo) GetMaxVolumeCount 

func (m *DataCenterInfo) GetMaxVolumeCount() uint64

func (*DataCenterInfo) GetRackInfos 

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

func (*DataCenterInfo) GetVolumeCount 

func (m *DataCenterInfo) GetVolumeCount() uint64

func (*DataCenterInfo) ProtoMessage 

func (*DataCenterInfo) ProtoMessage()

func (*DataCenterInfo) Reset 

func (m *DataCenterInfo) Reset()

func (*DataCenterInfo) String 

func (m *DataCenterInfo) String() string

type DataNodeInfo 

type DataNodeInfo struct {
	Id                string                             `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
	VolumeCount       uint64                             `protobuf:"varint,2,opt,name=volume_count,json=volumeCount" json:"volume_count,omitempty"`
	MaxVolumeCount    uint64                             `protobuf:"varint,3,opt,name=max_volume_count,json=maxVolumeCount" json:"max_volume_count,omitempty"`
	FreeVolumeCount   uint64                             `protobuf:"varint,4,opt,name=free_volume_count,json=freeVolumeCount" json:"free_volume_count,omitempty"`
	ActiveVolumeCount uint64                             `protobuf:"varint,5,opt,name=active_volume_count,json=activeVolumeCount" json:"active_volume_count,omitempty"`
	VolumeInfos       []*VolumeInformationMessage        `protobuf:"bytes,6,rep,name=volume_infos,json=volumeInfos" json:"volume_infos,omitempty"`
	EcShardInfos      []*VolumeEcShardInformationMessage `protobuf:"bytes,7,rep,name=ec_shard_infos,json=ecShardInfos" json:"ec_shard_infos,omitempty"`
}

volume related

func (*DataNodeInfo) Descriptor 

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

func (*DataNodeInfo) GetActiveVolumeCount 

func (m *DataNodeInfo) GetActiveVolumeCount() uint64

func (*DataNodeInfo) GetEcShardInfos 

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

func (*DataNodeInfo) GetFreeVolumeCount 

func (m *DataNodeInfo) GetFreeVolumeCount() uint64

func (*DataNodeInfo) GetId 

func (m *DataNodeInfo) GetId() string

func (*DataNodeInfo) GetMaxVolumeCount 

func (m *DataNodeInfo) GetMaxVolumeCount() uint64

func (*DataNodeInfo) GetVolumeCount 

func (m *DataNodeInfo) GetVolumeCount() uint64

func (*DataNodeInfo) GetVolumeInfos 

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

func (*DataNodeInfo) ProtoMessage 

func (*DataNodeInfo) ProtoMessage()

func (*DataNodeInfo) Reset 

func (m *DataNodeInfo) Reset()

func (*DataNodeInfo) String 

func (m *DataNodeInfo) String() string

type Empty 

type Empty struct {
}

func (*Empty) Descriptor 

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

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) Reset 

func (m *Empty) Reset()

func (*Empty) String 

func (m *Empty) String() string

type GetMasterConfigurationRequest 

type GetMasterConfigurationRequest struct {
}

func (*GetMasterConfigurationRequest) Descriptor 

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

func (*GetMasterConfigurationRequest) ProtoMessage 

func (*GetMasterConfigurationRequest) ProtoMessage()

func (*GetMasterConfigurationRequest) Reset 

func (m *GetMasterConfigurationRequest) Reset()

func (*GetMasterConfigurationRequest) String 

func (m *GetMasterConfigurationRequest) String() string

type GetMasterConfigurationResponse 

type GetMasterConfigurationResponse struct {
	MetricsAddress         string `protobuf:"bytes,1,opt,name=metrics_address,json=metricsAddress" json:"metrics_address,omitempty"`
	MetricsIntervalSeconds uint32 `protobuf:"varint,2,opt,name=metrics_interval_seconds,json=metricsIntervalSeconds" json:"metrics_interval_seconds,omitempty"`
}

func (*GetMasterConfigurationResponse) Descriptor 

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

func (*GetMasterConfigurationResponse) GetMetricsAddress 

func (m *GetMasterConfigurationResponse) GetMetricsAddress() string

func (*GetMasterConfigurationResponse) GetMetricsIntervalSeconds 

func (m *GetMasterConfigurationResponse) GetMetricsIntervalSeconds() uint32

func (*GetMasterConfigurationResponse) ProtoMessage 

func (*GetMasterConfigurationResponse) ProtoMessage()

func (*GetMasterConfigurationResponse) Reset 

func (m *GetMasterConfigurationResponse) Reset()

func (*GetMasterConfigurationResponse) String 

func (m *GetMasterConfigurationResponse) String() string

type Heartbeat 

type Heartbeat struct {
	Ip             string                      `protobuf:"bytes,1,opt,name=ip" json:"ip,omitempty"`
	Port           uint32                      `protobuf:"varint,2,opt,name=port" json:"port,omitempty"`
	PublicUrl      string                      `protobuf:"bytes,3,opt,name=public_url,json=publicUrl" json:"public_url,omitempty"`
	MaxVolumeCount uint32                      `protobuf:"varint,4,opt,name=max_volume_count,json=maxVolumeCount" json:"max_volume_count,omitempty"`
	MaxFileKey     uint64                      `protobuf:"varint,5,opt,name=max_file_key,json=maxFileKey" json:"max_file_key,omitempty"`
	DataCenter     string                      `protobuf:"bytes,6,opt,name=data_center,json=dataCenter" json:"data_center,omitempty"`
	Rack           string                      `protobuf:"bytes,7,opt,name=rack" json:"rack,omitempty"`
	AdminPort      uint32                      `protobuf:"varint,8,opt,name=admin_port,json=adminPort" json:"admin_port,omitempty"`
	Volumes        []*VolumeInformationMessage `protobuf:"bytes,9,rep,name=volumes" json:"volumes,omitempty"`
	// delta volumes
	NewVolumes     []*VolumeShortInformationMessage `protobuf:"bytes,10,rep,name=new_volumes,json=newVolumes" json:"new_volumes,omitempty"`
	DeletedVolumes []*VolumeShortInformationMessage `protobuf:"bytes,11,rep,name=deleted_volumes,json=deletedVolumes" json:"deleted_volumes,omitempty"`
	HasNoVolumes   bool                             `protobuf:"varint,12,opt,name=has_no_volumes,json=hasNoVolumes" json:"has_no_volumes,omitempty"`
	// erasure coding
	EcShards []*VolumeEcShardInformationMessage `protobuf:"bytes,16,rep,name=ec_shards,json=ecShards" json:"ec_shards,omitempty"`
	// delta erasure coding shards
	NewEcShards     []*VolumeEcShardInformationMessage `protobuf:"bytes,17,rep,name=new_ec_shards,json=newEcShards" json:"new_ec_shards,omitempty"`
	DeletedEcShards []*VolumeEcShardInformationMessage `protobuf:"bytes,18,rep,name=deleted_ec_shards,json=deletedEcShards" json:"deleted_ec_shards,omitempty"`
	HasNoEcShards   bool                               `protobuf:"varint,19,opt,name=has_no_ec_shards,json=hasNoEcShards" json:"has_no_ec_shards,omitempty"`
}

func (*Heartbeat) Descriptor 

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

func (*Heartbeat) GetAdminPort 

func (m *Heartbeat) GetAdminPort() uint32

func (*Heartbeat) GetDataCenter 

func (m *Heartbeat) GetDataCenter() string

func (*Heartbeat) GetDeletedEcShards 

func (m *Heartbeat) GetDeletedEcShards() []*VolumeEcShardInformationMessage

func (*Heartbeat) GetDeletedVolumes 

func (m *Heartbeat) GetDeletedVolumes() []*VolumeShortInformationMessage

func (*Heartbeat) GetEcShards 

func (m *Heartbeat) GetEcShards() []*VolumeEcShardInformationMessage

func (*Heartbeat) GetHasNoEcShards 

func (m *Heartbeat) GetHasNoEcShards() bool

func (*Heartbeat) GetHasNoVolumes 

func (m *Heartbeat) GetHasNoVolumes() bool

func (*Heartbeat) GetIp 

func (m *Heartbeat) GetIp() string

func (*Heartbeat) GetMaxFileKey 

func (m *Heartbeat) GetMaxFileKey() uint64

func (*Heartbeat) GetMaxVolumeCount 

func (m *Heartbeat) GetMaxVolumeCount() uint32

func (*Heartbeat) GetNewEcShards 

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

func (*Heartbeat) GetNewVolumes 

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

func (*Heartbeat) GetPort 

func (m *Heartbeat) GetPort() uint32

func (*Heartbeat) GetPublicUrl 

func (m *Heartbeat) GetPublicUrl() string

func (*Heartbeat) GetRack 

func (m *Heartbeat) GetRack() string

func (*Heartbeat) GetVolumes 

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

func (*Heartbeat) ProtoMessage 

func (*Heartbeat) ProtoMessage()

func (*Heartbeat) Reset 

func (m *Heartbeat) Reset()

func (*Heartbeat) String 

func (m *Heartbeat) String() string

type HeartbeatResponse 

type HeartbeatResponse struct {
	VolumeSizeLimit        uint64 `protobuf:"varint,1,opt,name=volume_size_limit,json=volumeSizeLimit" json:"volume_size_limit,omitempty"`
	Leader                 string `protobuf:"bytes,2,opt,name=leader" json:"leader,omitempty"`
	MetricsAddress         string `protobuf:"bytes,3,opt,name=metrics_address,json=metricsAddress" json:"metrics_address,omitempty"`
	MetricsIntervalSeconds uint32 `protobuf:"varint,4,opt,name=metrics_interval_seconds,json=metricsIntervalSeconds" json:"metrics_interval_seconds,omitempty"`
}

func (*HeartbeatResponse) Descriptor 

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

func (*HeartbeatResponse) GetLeader 

func (m *HeartbeatResponse) GetLeader() string

func (*HeartbeatResponse) GetMetricsAddress 

func (m *HeartbeatResponse) GetMetricsAddress() string

func (*HeartbeatResponse) GetMetricsIntervalSeconds 

func (m *HeartbeatResponse) GetMetricsIntervalSeconds() uint32

func (*HeartbeatResponse) GetVolumeSizeLimit 

func (m *HeartbeatResponse) GetVolumeSizeLimit() uint64

func (*HeartbeatResponse) ProtoMessage 

func (*HeartbeatResponse) ProtoMessage()

func (*HeartbeatResponse) Reset 

func (m *HeartbeatResponse) Reset()

func (*HeartbeatResponse) String 

func (m *HeartbeatResponse) String() string

type KeepConnectedRequest 

type KeepConnectedRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
}

func (*KeepConnectedRequest) Descriptor 

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

func (*KeepConnectedRequest) GetName 

func (m *KeepConnectedRequest) GetName() string

func (*KeepConnectedRequest) ProtoMessage 

func (*KeepConnectedRequest) ProtoMessage()

func (*KeepConnectedRequest) Reset 

func (m *KeepConnectedRequest) Reset()

func (*KeepConnectedRequest) String 

func (m *KeepConnectedRequest) String() string

type Location 

type Location struct {
	Url       string `protobuf:"bytes,1,opt,name=url" json:"url,omitempty"`
	PublicUrl string `protobuf:"bytes,2,opt,name=public_url,json=publicUrl" json:"public_url,omitempty"`
}

func (*Location) Descriptor 

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

func (*Location) GetPublicUrl 

func (m *Location) GetPublicUrl() string

func (*Location) GetUrl 

func (m *Location) GetUrl() string

func (*Location) ProtoMessage 

func (*Location) ProtoMessage()

func (*Location) Reset 

func (m *Location) Reset()

func (*Location) String 

func (m *Location) String() string

type LookupEcVolumeRequest 

type LookupEcVolumeRequest struct {
	VolumeId uint32 `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
}

func (*LookupEcVolumeRequest) Descriptor 

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

func (*LookupEcVolumeRequest) GetVolumeId 

func (m *LookupEcVolumeRequest) GetVolumeId() uint32

func (*LookupEcVolumeRequest) ProtoMessage 

func (*LookupEcVolumeRequest) ProtoMessage()

func (*LookupEcVolumeRequest) Reset 

func (m *LookupEcVolumeRequest) Reset()

func (*LookupEcVolumeRequest) String 

func (m *LookupEcVolumeRequest) String() string

type LookupEcVolumeResponse 

type LookupEcVolumeResponse struct {
	VolumeId         uint32                                      `protobuf:"varint,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
	ShardIdLocations []*LookupEcVolumeResponse_EcShardIdLocation `protobuf:"bytes,2,rep,name=shard_id_locations,json=shardIdLocations" json:"shard_id_locations,omitempty"`
}

func (*LookupEcVolumeResponse) Descriptor 

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

func (*LookupEcVolumeResponse) GetShardIdLocations 

func (m *LookupEcVolumeResponse) GetShardIdLocations() []*LookupEcVolumeResponse_EcShardIdLocation

func (*LookupEcVolumeResponse) GetVolumeId 

func (m *LookupEcVolumeResponse) GetVolumeId() uint32

func (*LookupEcVolumeResponse) ProtoMessage 

func (*LookupEcVolumeResponse) ProtoMessage()

func (*LookupEcVolumeResponse) Reset 

func (m *LookupEcVolumeResponse) Reset()

func (*LookupEcVolumeResponse) String 

func (m *LookupEcVolumeResponse) String() string

type LookupEcVolumeResponse_EcShardIdLocation 

type LookupEcVolumeResponse_EcShardIdLocation struct {
	ShardId   uint32      `protobuf:"varint,1,opt,name=shard_id,json=shardId" json:"shard_id,omitempty"`
	Locations []*Location `protobuf:"bytes,2,rep,name=locations" json:"locations,omitempty"`
}

func (*LookupEcVolumeResponse_EcShardIdLocation) Descriptor 

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

func (*LookupEcVolumeResponse_EcShardIdLocation) GetLocations 

func (m *LookupEcVolumeResponse_EcShardIdLocation) GetLocations() []*Location

func (*LookupEcVolumeResponse_EcShardIdLocation) GetShardId 

func (m *LookupEcVolumeResponse_EcShardIdLocation) GetShardId() uint32

func (*LookupEcVolumeResponse_EcShardIdLocation) ProtoMessage 

func (*LookupEcVolumeResponse_EcShardIdLocation) ProtoMessage()

func (*LookupEcVolumeResponse_EcShardIdLocation) Reset 

func (m *LookupEcVolumeResponse_EcShardIdLocation) Reset()

func (*LookupEcVolumeResponse_EcShardIdLocation) String 

func (m *LookupEcVolumeResponse_EcShardIdLocation) String() string

type LookupVolumeRequest 

type LookupVolumeRequest struct {
	VolumeIds  []string `protobuf:"bytes,1,rep,name=volume_ids,json=volumeIds" json:"volume_ids,omitempty"`
	Collection string   `protobuf:"bytes,2,opt,name=collection" json:"collection,omitempty"`
}

func (*LookupVolumeRequest) Descriptor 

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

func (*LookupVolumeRequest) GetCollection 

func (m *LookupVolumeRequest) GetCollection() string

func (*LookupVolumeRequest) GetVolumeIds 

func (m *LookupVolumeRequest) GetVolumeIds() []string

func (*LookupVolumeRequest) ProtoMessage 

func (*LookupVolumeRequest) ProtoMessage()

func (*LookupVolumeRequest) Reset 

func (m *LookupVolumeRequest) Reset()

func (*LookupVolumeRequest) String 

func (m *LookupVolumeRequest) String() string

type LookupVolumeResponse 

type LookupVolumeResponse struct {
	VolumeIdLocations []*LookupVolumeResponse_VolumeIdLocation `protobuf:"bytes,1,rep,name=volume_id_locations,json=volumeIdLocations" json:"volume_id_locations,omitempty"`
}

func (*LookupVolumeResponse) Descriptor 

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

func (*LookupVolumeResponse) GetVolumeIdLocations 

func (m *LookupVolumeResponse) GetVolumeIdLocations() []*LookupVolumeResponse_VolumeIdLocation

func (*LookupVolumeResponse) ProtoMessage 

func (*LookupVolumeResponse) ProtoMessage()

func (*LookupVolumeResponse) Reset 

func (m *LookupVolumeResponse) Reset()

func (*LookupVolumeResponse) String 

func (m *LookupVolumeResponse) String() string

type LookupVolumeResponse_VolumeIdLocation 

type LookupVolumeResponse_VolumeIdLocation struct {
	VolumeId  string      `protobuf:"bytes,1,opt,name=volume_id,json=volumeId" json:"volume_id,omitempty"`
	Locations []*Location `protobuf:"bytes,2,rep,name=locations" json:"locations,omitempty"`
	Error     string      `protobuf:"bytes,3,opt,name=error" json:"error,omitempty"`
}

func (*LookupVolumeResponse_VolumeIdLocation) Descriptor 

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

func (*LookupVolumeResponse_VolumeIdLocation) GetError 

func (m *LookupVolumeResponse_VolumeIdLocation) GetError() string

func (*LookupVolumeResponse_VolumeIdLocation) GetLocations 

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

func (*LookupVolumeResponse_VolumeIdLocation) GetVolumeId 

func (m *LookupVolumeResponse_VolumeIdLocation) GetVolumeId() string

func (*LookupVolumeResponse_VolumeIdLocation) ProtoMessage 

func (*LookupVolumeResponse_VolumeIdLocation) ProtoMessage()

func (*LookupVolumeResponse_VolumeIdLocation) Reset 

func (m *LookupVolumeResponse_VolumeIdLocation) Reset()

func (*LookupVolumeResponse_VolumeIdLocation) String 

func (m *LookupVolumeResponse_VolumeIdLocation) String() string

type RackInfo 

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

func (*RackInfo) Descriptor 

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

func (*RackInfo) GetActiveVolumeCount 

func (m *RackInfo) GetActiveVolumeCount() uint64

func (*RackInfo) GetDataNodeInfos 

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

func (*RackInfo) GetFreeVolumeCount 

func (m *RackInfo) GetFreeVolumeCount() uint64

func (*RackInfo) GetId 

func (m *RackInfo) GetId() string

func (*RackInfo) GetMaxVolumeCount 

func (m *RackInfo) GetMaxVolumeCount() uint64

func (*RackInfo) GetVolumeCount 

func (m *RackInfo) GetVolumeCount() uint64

func (*RackInfo) ProtoMessage 

func (*RackInfo) ProtoMessage()

func (*RackInfo) Reset 

func (m *RackInfo) Reset()

func (*RackInfo) String 

func (m *RackInfo) 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)
}

func NewSeaweedClient 

func NewSeaweedClient(cc *grpc.ClientConn) 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)
}

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" json:"replication,omitempty"`
	Collection  string `protobuf:"bytes,2,opt,name=collection" json:"collection,omitempty"`
	Ttl         string `protobuf:"bytes,3,opt,name=ttl" json:"ttl,omitempty"`
}

func (*StatisticsRequest) Descriptor 

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

func (*StatisticsRequest) GetCollection 

func (m *StatisticsRequest) GetCollection() string

func (*StatisticsRequest) GetReplication 

func (m *StatisticsRequest) GetReplication() string

func (*StatisticsRequest) GetTtl 

func (m *StatisticsRequest) GetTtl() string

func (*StatisticsRequest) ProtoMessage 

func (*StatisticsRequest) ProtoMessage()

func (*StatisticsRequest) Reset 

func (m *StatisticsRequest) Reset()

func (*StatisticsRequest) String 

func (m *StatisticsRequest) String() string

type StatisticsResponse 

type StatisticsResponse struct {
	Replication string `protobuf:"bytes,1,opt,name=replication" json:"replication,omitempty"`
	Collection  string `protobuf:"bytes,2,opt,name=collection" json:"collection,omitempty"`
	Ttl         string `protobuf:"bytes,3,opt,name=ttl" json:"ttl,omitempty"`
	TotalSize   uint64 `protobuf:"varint,4,opt,name=total_size,json=totalSize" json:"total_size,omitempty"`
	UsedSize    uint64 `protobuf:"varint,5,opt,name=used_size,json=usedSize" json:"used_size,omitempty"`
	FileCount   uint64 `protobuf:"varint,6,opt,name=file_count,json=fileCount" json:"file_count,omitempty"`
}

func (*StatisticsResponse) Descriptor 

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

func (*StatisticsResponse) GetCollection 

func (m *StatisticsResponse) GetCollection() string

func (*StatisticsResponse) GetFileCount 

func (m *StatisticsResponse) GetFileCount() uint64

func (*StatisticsResponse) GetReplication 

func (m *StatisticsResponse) GetReplication() string

func (*StatisticsResponse) GetTotalSize 

func (m *StatisticsResponse) GetTotalSize() uint64

func (*StatisticsResponse) GetTtl 

func (m *StatisticsResponse) GetTtl() string

func (*StatisticsResponse) GetUsedSize 

func (m *StatisticsResponse) GetUsedSize() uint64

func (*StatisticsResponse) ProtoMessage 

func (*StatisticsResponse) ProtoMessage()

func (*StatisticsResponse) Reset 

func (m *StatisticsResponse) Reset()

func (*StatisticsResponse) String 

func (m *StatisticsResponse) String() string

type StorageType 

type StorageType struct {
	Replication string `protobuf:"bytes,1,opt,name=replication" json:"replication,omitempty"`
	Ttl         string `protobuf:"bytes,2,opt,name=ttl" json:"ttl,omitempty"`
}

func (*StorageType) Descriptor 

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

func (*StorageType) GetReplication 

func (m *StorageType) GetReplication() string

func (*StorageType) GetTtl 

func (m *StorageType) GetTtl() string

func (*StorageType) ProtoMessage 

func (*StorageType) ProtoMessage()

func (*StorageType) Reset 

func (m *StorageType) Reset()

func (*StorageType) String 

func (m *StorageType) String() string

type SuperBlockExtra 

type SuperBlockExtra struct {
	ErasureCoding *SuperBlockExtra_ErasureCoding `protobuf:"bytes,1,opt,name=erasure_coding,json=erasureCoding" json:"erasure_coding,omitempty"`
}

func (*SuperBlockExtra) Descriptor 

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

func (*SuperBlockExtra) GetErasureCoding 

func (m *SuperBlockExtra) GetErasureCoding() *SuperBlockExtra_ErasureCoding

func (*SuperBlockExtra) ProtoMessage 

func (*SuperBlockExtra) ProtoMessage()

func (*SuperBlockExtra) Reset 

func (m *SuperBlockExtra) Reset()

func (*SuperBlockExtra) String 

func (m *SuperBlockExtra) String() string

type SuperBlockExtra_ErasureCoding 

type SuperBlockExtra_ErasureCoding struct {
	Data      uint32   `protobuf:"varint,1,opt,name=data" json:"data,omitempty"`
	Parity    uint32   `protobuf:"varint,2,opt,name=parity" json:"parity,omitempty"`
	VolumeIds []uint32 `protobuf:"varint,3,rep,packed,name=volume_ids,json=volumeIds" json:"volume_ids,omitempty"`
}

func (*SuperBlockExtra_ErasureCoding) Descriptor 

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

func (*SuperBlockExtra_ErasureCoding) GetData 

func (m *SuperBlockExtra_ErasureCoding) GetData() uint32

func (*SuperBlockExtra_ErasureCoding) GetParity 

func (m *SuperBlockExtra_ErasureCoding) GetParity() uint32

func (*SuperBlockExtra_ErasureCoding) GetVolumeIds 

func (m *SuperBlockExtra_ErasureCoding) GetVolumeIds() []uint32

func (*SuperBlockExtra_ErasureCoding) ProtoMessage 

func (*SuperBlockExtra_ErasureCoding) ProtoMessage()

func (*SuperBlockExtra_ErasureCoding) Reset 

func (m *SuperBlockExtra_ErasureCoding) Reset()

func (*SuperBlockExtra_ErasureCoding) String 

func (m *SuperBlockExtra_ErasureCoding) String() string

type TopologyInfo 

type TopologyInfo struct {
	Id                string            `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
	VolumeCount       uint64            `protobuf:"varint,2,opt,name=volume_count,json=volumeCount" json:"volume_count,omitempty"`
	MaxVolumeCount    uint64            `protobuf:"varint,3,opt,name=max_volume_count,json=maxVolumeCount" json:"max_volume_count,omitempty"`
	FreeVolumeCount   uint64            `protobuf:"varint,4,opt,name=free_volume_count,json=freeVolumeCount" json:"free_volume_count,omitempty"`
	ActiveVolumeCount uint64            `protobuf:"varint,5,opt,name=active_volume_count,json=activeVolumeCount" json:"active_volume_count,omitempty"`
	DataCenterInfos   []*DataCenterInfo `protobuf:"bytes,6,rep,name=data_center_infos,json=dataCenterInfos" json:"data_center_infos,omitempty"`
}

func (*TopologyInfo) Descriptor 

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

func (*TopologyInfo) GetActiveVolumeCount 

func (m *TopologyInfo) GetActiveVolumeCount() uint64

func (*TopologyInfo) GetDataCenterInfos 

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

func (*TopologyInfo) GetFreeVolumeCount 

func (m *TopologyInfo) GetFreeVolumeCount() uint64

func (*TopologyInfo) GetId 

func (m *TopologyInfo) GetId() string

func (*TopologyInfo) GetMaxVolumeCount 

func (m *TopologyInfo) GetMaxVolumeCount() uint64

func (*TopologyInfo) GetVolumeCount 

func (m *TopologyInfo) GetVolumeCount() uint64

func (*TopologyInfo) ProtoMessage 

func (*TopologyInfo) ProtoMessage()

func (*TopologyInfo) Reset 

func (m *TopologyInfo) Reset()

func (*TopologyInfo) String 

func (m *TopologyInfo) String() string

type VolumeEcShardInformationMessage 

type VolumeEcShardInformationMessage struct {
	Id          uint32 `protobuf:"varint,1,opt,name=id" json:"id,omitempty"`
	Collection  string `protobuf:"bytes,2,opt,name=collection" json:"collection,omitempty"`
	EcIndexBits uint32 `protobuf:"varint,3,opt,name=ec_index_bits,json=ecIndexBits" json:"ec_index_bits,omitempty"`
}

func (*VolumeEcShardInformationMessage) Descriptor 

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

func (*VolumeEcShardInformationMessage) GetCollection 

func (m *VolumeEcShardInformationMessage) GetCollection() string

func (*VolumeEcShardInformationMessage) GetEcIndexBits 

func (m *VolumeEcShardInformationMessage) GetEcIndexBits() uint32

func (*VolumeEcShardInformationMessage) GetId 

func (m *VolumeEcShardInformationMessage) GetId() uint32

func (*VolumeEcShardInformationMessage) ProtoMessage 

func (*VolumeEcShardInformationMessage) ProtoMessage()

func (*VolumeEcShardInformationMessage) Reset 

func (m *VolumeEcShardInformationMessage) Reset()

func (*VolumeEcShardInformationMessage) String 

func (m *VolumeEcShardInformationMessage) String() string

type VolumeInformationMessage 

type VolumeInformationMessage struct {
	Id               uint32 `protobuf:"varint,1,opt,name=id" json:"id,omitempty"`
	Size             uint64 `protobuf:"varint,2,opt,name=size" json:"size,omitempty"`
	Collection       string `protobuf:"bytes,3,opt,name=collection" json:"collection,omitempty"`
	FileCount        uint64 `protobuf:"varint,4,opt,name=file_count,json=fileCount" json:"file_count,omitempty"`
	DeleteCount      uint64 `protobuf:"varint,5,opt,name=delete_count,json=deleteCount" json:"delete_count,omitempty"`
	DeletedByteCount uint64 `protobuf:"varint,6,opt,name=deleted_byte_count,json=deletedByteCount" json:"deleted_byte_count,omitempty"`
	ReadOnly         bool   `protobuf:"varint,7,opt,name=read_only,json=readOnly" json:"read_only,omitempty"`
	ReplicaPlacement uint32 `protobuf:"varint,8,opt,name=replica_placement,json=replicaPlacement" json:"replica_placement,omitempty"`
	Version          uint32 `protobuf:"varint,9,opt,name=version" json:"version,omitempty"`
	Ttl              uint32 `protobuf:"varint,10,opt,name=ttl" json:"ttl,omitempty"`
	CompactRevision  uint32 `protobuf:"varint,11,opt,name=compact_revision,json=compactRevision" json:"compact_revision,omitempty"`
	ModifiedAtSecond int64  `protobuf:"varint,12,opt,name=modified_at_second,json=modifiedAtSecond" json:"modified_at_second,omitempty"`
}

func (*VolumeInformationMessage) Descriptor 

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

func (*VolumeInformationMessage) GetCollection 

func (m *VolumeInformationMessage) GetCollection() string

func (*VolumeInformationMessage) GetCompactRevision 

func (m *VolumeInformationMessage) GetCompactRevision() uint32

func (*VolumeInformationMessage) GetDeleteCount 

func (m *VolumeInformationMessage) GetDeleteCount() uint64

func (*VolumeInformationMessage) GetDeletedByteCount 

func (m *VolumeInformationMessage) GetDeletedByteCount() uint64

func (*VolumeInformationMessage) GetFileCount 

func (m *VolumeInformationMessage) GetFileCount() uint64

func (*VolumeInformationMessage) GetId 

func (m *VolumeInformationMessage) GetId() uint32

func (*VolumeInformationMessage) GetModifiedAtSecond 

func (m *VolumeInformationMessage) GetModifiedAtSecond() int64

func (*VolumeInformationMessage) GetReadOnly 

func (m *VolumeInformationMessage) GetReadOnly() bool

func (*VolumeInformationMessage) GetReplicaPlacement 

func (m *VolumeInformationMessage) GetReplicaPlacement() uint32

func (*VolumeInformationMessage) GetSize 

func (m *VolumeInformationMessage) GetSize() uint64

func (*VolumeInformationMessage) GetTtl 

func (m *VolumeInformationMessage) GetTtl() uint32

func (*VolumeInformationMessage) GetVersion 

func (m *VolumeInformationMessage) GetVersion() uint32

func (*VolumeInformationMessage) ProtoMessage 

func (*VolumeInformationMessage) ProtoMessage()

func (*VolumeInformationMessage) Reset 

func (m *VolumeInformationMessage) Reset()

func (*VolumeInformationMessage) String 

func (m *VolumeInformationMessage) String() string

type VolumeListRequest 

type VolumeListRequest struct {
}

func (*VolumeListRequest) Descriptor 

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

func (*VolumeListRequest) ProtoMessage 

func (*VolumeListRequest) ProtoMessage()

func (*VolumeListRequest) Reset 

func (m *VolumeListRequest) Reset()

func (*VolumeListRequest) String 

func (m *VolumeListRequest) String() string

type VolumeListResponse 

type VolumeListResponse struct {
	TopologyInfo      *TopologyInfo `protobuf:"bytes,1,opt,name=topology_info,json=topologyInfo" json:"topology_info,omitempty"`
	VolumeSizeLimitMb uint64        `protobuf:"varint,2,opt,name=volume_size_limit_mb,json=volumeSizeLimitMb" json:"volume_size_limit_mb,omitempty"`
}

func (*VolumeListResponse) Descriptor 

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

func (*VolumeListResponse) GetTopologyInfo 

func (m *VolumeListResponse) GetTopologyInfo() *TopologyInfo

func (*VolumeListResponse) GetVolumeSizeLimitMb 

func (m *VolumeListResponse) GetVolumeSizeLimitMb() uint64

func (*VolumeListResponse) ProtoMessage 

func (*VolumeListResponse) ProtoMessage()

func (*VolumeListResponse) Reset 

func (m *VolumeListResponse) Reset()

func (*VolumeListResponse) String 

func (m *VolumeListResponse) String() string

type VolumeLocation 

type VolumeLocation struct {
	Url         string   `protobuf:"bytes,1,opt,name=url" json:"url,omitempty"`
	PublicUrl   string   `protobuf:"bytes,2,opt,name=public_url,json=publicUrl" json:"public_url,omitempty"`
	NewVids     []uint32 `protobuf:"varint,3,rep,packed,name=new_vids,json=newVids" json:"new_vids,omitempty"`
	DeletedVids []uint32 `protobuf:"varint,4,rep,packed,name=deleted_vids,json=deletedVids" json:"deleted_vids,omitempty"`
	Leader      string   `protobuf:"bytes,5,opt,name=leader" json:"leader,omitempty"`
}

func (*VolumeLocation) Descriptor 

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

func (*VolumeLocation) GetDeletedVids 

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

func (*VolumeLocation) GetLeader 

func (m *VolumeLocation) GetLeader() string

func (*VolumeLocation) GetNewVids 

func (m *VolumeLocation) GetNewVids() []uint32

func (*VolumeLocation) GetPublicUrl 

func (m *VolumeLocation) GetPublicUrl() string

func (*VolumeLocation) GetUrl 

func (m *VolumeLocation) GetUrl() string

func (*VolumeLocation) ProtoMessage 

func (*VolumeLocation) ProtoMessage()

func (*VolumeLocation) Reset 

func (m *VolumeLocation) Reset()

func (*VolumeLocation) String 

func (m *VolumeLocation) String() string

type VolumeShortInformationMessage 

type VolumeShortInformationMessage struct {
	Id               uint32 `protobuf:"varint,1,opt,name=id" json:"id,omitempty"`
	Collection       string `protobuf:"bytes,3,opt,name=collection" json:"collection,omitempty"`
	ReplicaPlacement uint32 `protobuf:"varint,8,opt,name=replica_placement,json=replicaPlacement" json:"replica_placement,omitempty"`
	Version          uint32 `protobuf:"varint,9,opt,name=version" json:"version,omitempty"`
	Ttl              uint32 `protobuf:"varint,10,opt,name=ttl" json:"ttl,omitempty"`
}

func (*VolumeShortInformationMessage) Descriptor 

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

func (*VolumeShortInformationMessage) GetCollection 

func (m *VolumeShortInformationMessage) GetCollection() string

func (*VolumeShortInformationMessage) GetId 

func (m *VolumeShortInformationMessage) GetId() uint32

func (*VolumeShortInformationMessage) GetReplicaPlacement 

func (m *VolumeShortInformationMessage) GetReplicaPlacement() uint32

func (*VolumeShortInformationMessage) GetTtl 

func (m *VolumeShortInformationMessage) GetTtl() uint32

func (*VolumeShortInformationMessage) GetVersion 

func (m *VolumeShortInformationMessage) GetVersion() uint32

func (*VolumeShortInformationMessage) ProtoMessage 

func (*VolumeShortInformationMessage) ProtoMessage()

func (*VolumeShortInformationMessage) Reset 

func (m *VolumeShortInformationMessage) Reset()

func (*VolumeShortInformationMessage) String 

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