Documentation ¶
Overview ¶
Package pb is a generated protocol buffer package.
It is generated from these files:
seaweed.proto
It has these top-level messages:
Heartbeat HeartbeatResponse VolumeInformationMessage
Index ¶
- func RegisterSeaweedServer(s *grpc.Server, srv SeaweedServer)
- type Heartbeat
- func (*Heartbeat) Descriptor() ([]byte, []int)
- func (m *Heartbeat) GetAdminPort() uint32
- func (m *Heartbeat) GetDataCenter() string
- func (m *Heartbeat) GetIp() string
- func (m *Heartbeat) GetMaxFileKey() uint64
- func (m *Heartbeat) GetMaxVolumeCount() uint32
- func (m *Heartbeat) GetPort() uint32
- func (m *Heartbeat) GetPublicUrl() string
- func (m *Heartbeat) GetRack() string
- func (m *Heartbeat) GetVolumes() []*VolumeInformationMessage
- func (*Heartbeat) ProtoMessage()
- func (m *Heartbeat) Reset()
- func (m *Heartbeat) String() string
- type HeartbeatResponse
- func (*HeartbeatResponse) Descriptor() ([]byte, []int)
- func (m *HeartbeatResponse) GetLeader() string
- func (m *HeartbeatResponse) GetSecretKey() string
- func (m *HeartbeatResponse) GetVolumeSizeLimit() uint64
- func (*HeartbeatResponse) ProtoMessage()
- func (m *HeartbeatResponse) Reset()
- func (m *HeartbeatResponse) String() string
- type SeaweedClient
- type SeaweedServer
- type Seaweed_SendHeartbeatClient
- type Seaweed_SendHeartbeatServer
- type VolumeInformationMessage
- func (*VolumeInformationMessage) Descriptor() ([]byte, []int)
- func (m *VolumeInformationMessage) GetCollection() string
- func (m *VolumeInformationMessage) GetDeleteCount() uint64
- func (m *VolumeInformationMessage) GetDeletedByteCount() uint64
- func (m *VolumeInformationMessage) GetFileCount() uint64
- func (m *VolumeInformationMessage) GetId() uint32
- func (m *VolumeInformationMessage) GetReadOnly() bool
- func (m *VolumeInformationMessage) GetReplicaPlacement() uint32
- func (m *VolumeInformationMessage) GetSize() uint64
- func (m *VolumeInformationMessage) GetTtl() uint32
- func (m *VolumeInformationMessage) GetVersion() uint32
- func (*VolumeInformationMessage) ProtoMessage()
- func (m *VolumeInformationMessage) Reset()
- func (m *VolumeInformationMessage) String() string
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterSeaweedServer ¶
func RegisterSeaweedServer(s *grpc.Server, srv SeaweedServer)
Types ¶
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"` }
func (*Heartbeat) Descriptor ¶
func (*Heartbeat) GetAdminPort ¶
func (*Heartbeat) GetDataCenter ¶
func (*Heartbeat) GetMaxFileKey ¶
func (*Heartbeat) GetMaxVolumeCount ¶
func (*Heartbeat) GetPublicUrl ¶
func (*Heartbeat) GetVolumes ¶
func (m *Heartbeat) GetVolumes() []*VolumeInformationMessage
func (*Heartbeat) ProtoMessage ¶
func (*Heartbeat) ProtoMessage()
type HeartbeatResponse ¶
type HeartbeatResponse struct { VolumeSizeLimit uint64 `protobuf:"varint,1,opt,name=volumeSizeLimit" json:"volumeSizeLimit,omitempty"` SecretKey string `protobuf:"bytes,2,opt,name=secretKey" json:"secretKey,omitempty"` Leader string `protobuf:"bytes,3,opt,name=leader" json:"leader,omitempty"` }
func (*HeartbeatResponse) Descriptor ¶
func (*HeartbeatResponse) Descriptor() ([]byte, []int)
func (*HeartbeatResponse) GetLeader ¶
func (m *HeartbeatResponse) GetLeader() string
func (*HeartbeatResponse) GetSecretKey ¶
func (m *HeartbeatResponse) GetSecretKey() string
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 SeaweedClient ¶
type SeaweedClient interface {
SendHeartbeat(ctx context.Context, opts ...grpc.CallOption) (Seaweed_SendHeartbeatClient, error)
}
func NewSeaweedClient ¶
func NewSeaweedClient(cc *grpc.ClientConn) SeaweedClient
type SeaweedServer ¶
type SeaweedServer interface {
SendHeartbeat(Seaweed_SendHeartbeatServer) error
}
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 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"` }
func (*VolumeInformationMessage) Descriptor ¶
func (*VolumeInformationMessage) Descriptor() ([]byte, []int)
func (*VolumeInformationMessage) GetCollection ¶
func (m *VolumeInformationMessage) GetCollection() string
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) 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
Click to show internal directories.
Click to hide internal directories.