Documentation ¶
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
- func (m *Heartbeat) XXX_DiscardUnknown()
- func (m *Heartbeat) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Heartbeat) XXX_Merge(src proto.Message)
- func (m *Heartbeat) XXX_Size() int
- func (m *Heartbeat) XXX_Unmarshal(b []byte) error
- 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
- func (m *HeartbeatResponse) XXX_DiscardUnknown()
- func (m *HeartbeatResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *HeartbeatResponse) XXX_Merge(src proto.Message)
- func (m *HeartbeatResponse) XXX_Size() int
- func (m *HeartbeatResponse) XXX_Unmarshal(b []byte) error
- type SeaweedClient
- type SeaweedServer
- type Seaweed_SendHeartbeatClient
- type Seaweed_SendHeartbeatServer
- type UnimplementedSeaweedServer
- 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
- func (m *VolumeInformationMessage) XXX_DiscardUnknown()
- func (m *VolumeInformationMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *VolumeInformationMessage) XXX_Merge(src proto.Message)
- func (m *VolumeInformationMessage) XXX_Size() int
- func (m *VolumeInformationMessage) XXX_Unmarshal(b []byte) error
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,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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
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()
func (*Heartbeat) XXX_DiscardUnknown ¶
func (m *Heartbeat) XXX_DiscardUnknown()
func (*Heartbeat) XXX_Marshal ¶
func (*Heartbeat) XXX_Unmarshal ¶
type HeartbeatResponse ¶
type HeartbeatResponse struct { VolumeSizeLimit uint64 `protobuf:"varint,1,opt,name=volumeSizeLimit,proto3" json:"volumeSizeLimit,omitempty"` SecretKey string `protobuf:"bytes,2,opt,name=secretKey,proto3" json:"secretKey,omitempty"` Leader string `protobuf:"bytes,3,opt,name=leader,proto3" json:"leader,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
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
func (*HeartbeatResponse) XXX_DiscardUnknown ¶
func (m *HeartbeatResponse) XXX_DiscardUnknown()
func (*HeartbeatResponse) XXX_Marshal ¶
func (m *HeartbeatResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*HeartbeatResponse) XXX_Merge ¶
func (m *HeartbeatResponse) XXX_Merge(src proto.Message)
func (*HeartbeatResponse) XXX_Size ¶
func (m *HeartbeatResponse) XXX_Size() int
func (*HeartbeatResponse) XXX_Unmarshal ¶
func (m *HeartbeatResponse) XXX_Unmarshal(b []byte) error
type SeaweedClient ¶
type SeaweedClient interface {
SendHeartbeat(ctx context.Context, opts ...grpc.CallOption) (Seaweed_SendHeartbeatClient, 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.ClientConn) SeaweedClient
type SeaweedServer ¶
type SeaweedServer interface {
SendHeartbeat(Seaweed_SendHeartbeatServer) error
}
SeaweedServer is the server API for Seaweed service.
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 UnimplementedSeaweedServer ¶
type UnimplementedSeaweedServer struct { }
UnimplementedSeaweedServer can be embedded to have forward compatible implementations.
func (*UnimplementedSeaweedServer) SendHeartbeat ¶
func (*UnimplementedSeaweedServer) SendHeartbeat(srv Seaweed_SendHeartbeatServer) error
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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
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
func (*VolumeInformationMessage) XXX_DiscardUnknown ¶
func (m *VolumeInformationMessage) XXX_DiscardUnknown()
func (*VolumeInformationMessage) XXX_Marshal ¶
func (m *VolumeInformationMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*VolumeInformationMessage) XXX_Merge ¶
func (m *VolumeInformationMessage) XXX_Merge(src proto.Message)
func (*VolumeInformationMessage) XXX_Size ¶
func (m *VolumeInformationMessage) XXX_Size() int
func (*VolumeInformationMessage) XXX_Unmarshal ¶
func (m *VolumeInformationMessage) XXX_Unmarshal(b []byte) error
Click to show internal directories.
Click to hide internal directories.