Documentation ¶
Index ¶
- Variables
- func RegisterHubParseServiceServer(s *grpc.Server, srv HubParseServiceServer)
- func RegisterHubQueryServiceServer(s *grpc.Server, srv HubQueryServiceServer)
- type Candidate
- func (*Candidate) Descriptor() ([]byte, []int)
- func (m *Candidate) GetDownloadAverage() float32
- func (m *Candidate) GetDownloadVariance() float32
- func (m *Candidate) GetHeartBeats() uint64
- func (m *Candidate) GetNodeId() string
- func (m *Candidate) GetUploadAverage() float32
- func (m *Candidate) GetUploadVariance() float32
- func (m *Candidate) Marshal() (dAtA []byte, err error)
- func (m *Candidate) MarshalTo(dAtA []byte) (int, error)
- func (m *Candidate) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Candidate) ProtoMessage()
- func (m *Candidate) Reset()
- func (m *Candidate) Size() (n int)
- func (m *Candidate) String() string
- func (m *Candidate) Unmarshal(dAtA []byte) error
- func (m *Candidate) XXX_DiscardUnknown()
- func (m *Candidate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Candidate) XXX_Merge(src proto.Message)
- func (*Candidate) XXX_MessageName() string
- func (m *Candidate) XXX_Size() int
- func (m *Candidate) XXX_Unmarshal(b []byte) error
- type Host
- func (*Host) Descriptor() ([]byte, []int)
- func (m *Host) GetAge() uint64
- func (m *Host) GetAgeScore() float32
- func (m *Host) GetBandwidthLimit() float64
- func (m *Host) GetBandwidthPriceAsk() uint64
- func (m *Host) GetBandwidthPriceEst() uint64
- func (m *Host) GetBtfsVersion() string
- func (m *Host) GetCollateralBurn() uint64
- func (m *Host) GetCollateralLost() uint64
- func (m *Host) GetCollateralStake() uint64
- func (m *Host) GetCountryShort() string
- func (m *Host) GetCreateTimestamp() time.Time
- func (m *Host) GetDiscovery() float32
- func (m *Host) GetDownloadAverage() float32
- func (m *Host) GetDownloadSpeedScore() float32
- func (m *Host) GetDownloadVariance() float32
- func (m *Host) GetHeartBeats() uint64
- func (m *Host) GetLocation() Location
- func (m *Host) GetNodeId() string
- func (m *Host) GetRegion() string
- func (m *Host) GetReputation() float32
- func (m *Host) GetRoles() []node.NodeRole
- func (m *Host) GetScore() float32
- func (m *Host) GetStoragePriceAsk() uint64
- func (m *Host) GetStoragePriceEst() uint64
- func (m *Host) GetStorageTimeMin() uint64
- func (m *Host) GetStorageVolumeCap() float32
- func (m *Host) GetStorageVolumeLeft() float32
- func (m *Host) GetUpdateTimestamp() time.Time
- func (m *Host) GetUploadAverage() float32
- func (m *Host) GetUploadSpeedScore() float32
- func (m *Host) GetUploadVariance() float32
- func (m *Host) GetUptime() float32
- func (m *Host) GetUptimeScore() float32
- func (m *Host) GetVersionScore() float32
- func (m *Host) Marshal() (dAtA []byte, err error)
- func (m *Host) MarshalTo(dAtA []byte) (int, error)
- func (m *Host) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Host) ProtoMessage()
- func (m *Host) Reset()
- func (m *Host) Size() (n int)
- func (m *Host) String() string
- func (m *Host) Unmarshal(dAtA []byte) error
- func (m *Host) XXX_DiscardUnknown()
- func (m *Host) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Host) XXX_Merge(src proto.Message)
- func (*Host) XXX_MessageName() string
- func (m *Host) XXX_Size() int
- func (m *Host) XXX_Unmarshal(b []byte) error
- type HostsData
- func (*HostsData) Descriptor() ([]byte, []int)
- func (m *HostsData) GetHosts() []*Host
- func (m *HostsData) Marshal() (dAtA []byte, err error)
- func (m *HostsData) MarshalTo(dAtA []byte) (int, error)
- func (m *HostsData) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*HostsData) ProtoMessage()
- func (m *HostsData) Reset()
- func (m *HostsData) Size() (n int)
- func (m *HostsData) String() string
- func (m *HostsData) Unmarshal(dAtA []byte) error
- func (m *HostsData) XXX_DiscardUnknown()
- func (m *HostsData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *HostsData) XXX_Merge(src proto.Message)
- func (*HostsData) XXX_MessageName() string
- func (m *HostsData) XXX_Size() int
- func (m *HostsData) XXX_Unmarshal(b []byte) error
- type HostsReq
- func (*HostsReq) Descriptor() ([]byte, []int)
- func (m *HostsReq) GetId() string
- func (m *HostsReq) GetMode() HostsReq_Mode
- func (m *HostsReq) GetRespSize() int32
- func (m *HostsReq) Marshal() (dAtA []byte, err error)
- func (m *HostsReq) MarshalTo(dAtA []byte) (int, error)
- func (m *HostsReq) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*HostsReq) ProtoMessage()
- func (m *HostsReq) Reset()
- func (m *HostsReq) Size() (n int)
- func (m *HostsReq) String() string
- func (m *HostsReq) Unmarshal(dAtA []byte) error
- func (m *HostsReq) XXX_DiscardUnknown()
- func (m *HostsReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *HostsReq) XXX_Merge(src proto.Message)
- func (*HostsReq) XXX_MessageName() string
- func (m *HostsReq) XXX_Size() int
- func (m *HostsReq) XXX_Unmarshal(b []byte) error
- type HostsReq_Mode
- type HostsResp
- func (*HostsResp) Descriptor() ([]byte, []int)
- func (m *HostsResp) GetCode() ResponseCode
- func (m *HostsResp) GetHosts() *HostsData
- func (m *HostsResp) GetMessage() string
- func (m *HostsResp) GetMode() string
- func (m *HostsResp) GetRespSize() int32
- func (m *HostsResp) GetResponseTime() time.Time
- func (m *HostsResp) Marshal() (dAtA []byte, err error)
- func (m *HostsResp) MarshalTo(dAtA []byte) (int, error)
- func (m *HostsResp) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*HostsResp) ProtoMessage()
- func (m *HostsResp) Reset()
- func (m *HostsResp) Size() (n int)
- func (m *HostsResp) String() string
- func (m *HostsResp) Unmarshal(dAtA []byte) error
- func (m *HostsResp) XXX_DiscardUnknown()
- func (m *HostsResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *HostsResp) XXX_Merge(src proto.Message)
- func (*HostsResp) XXX_MessageName() string
- func (m *HostsResp) XXX_Size() int
- func (m *HostsResp) XXX_Unmarshal(b []byte) error
- type HubParseServiceClient
- type HubParseServiceServer
- type HubQueryServiceClient
- type HubQueryServiceServer
- type Location
- func (*Location) Descriptor() ([]byte, []int)
- func (m *Location) GetLat() float64
- func (m *Location) GetLon() float64
- func (m *Location) Marshal() (dAtA []byte, err error)
- func (m *Location) MarshalTo(dAtA []byte) (int, error)
- func (m *Location) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Location) ProtoMessage()
- func (m *Location) Reset()
- func (m *Location) Size() (n int)
- func (m *Location) String() string
- func (m *Location) Unmarshal(dAtA []byte) error
- func (m *Location) XXX_DiscardUnknown()
- func (m *Location) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Location) XXX_Merge(src proto.Message)
- func (*Location) XXX_MessageName() string
- func (m *Location) XXX_Size() int
- func (m *Location) XXX_Unmarshal(b []byte) error
- type NodesReq
- func (*NodesReq) Descriptor() ([]byte, []int)
- func (m *NodesReq) GetNodeId() []string
- func (m *NodesReq) GetRequesterId() string
- func (m *NodesReq) GetSignature() []byte
- func (m *NodesReq) Marshal() (dAtA []byte, err error)
- func (m *NodesReq) MarshalTo(dAtA []byte) (int, error)
- func (m *NodesReq) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*NodesReq) ProtoMessage()
- func (m *NodesReq) Reset()
- func (m *NodesReq) Size() (n int)
- func (m *NodesReq) String() string
- func (m *NodesReq) Unmarshal(dAtA []byte) error
- func (m *NodesReq) XXX_DiscardUnknown()
- func (m *NodesReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NodesReq) XXX_Merge(src proto.Message)
- func (*NodesReq) XXX_MessageName() string
- func (m *NodesReq) XXX_Size() int
- func (m *NodesReq) XXX_Unmarshal(b []byte) error
- type ParseReq
- func (*ParseReq) Descriptor() ([]byte, []int)
- func (m *ParseReq) GetCandidates() []*Candidate
- func (m *ParseReq) Marshal() (dAtA []byte, err error)
- func (m *ParseReq) MarshalTo(dAtA []byte) (int, error)
- func (m *ParseReq) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ParseReq) ProtoMessage()
- func (m *ParseReq) Reset()
- func (m *ParseReq) Size() (n int)
- func (m *ParseReq) String() string
- func (m *ParseReq) Unmarshal(dAtA []byte) error
- func (m *ParseReq) XXX_DiscardUnknown()
- func (m *ParseReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ParseReq) XXX_Merge(src proto.Message)
- func (*ParseReq) XXX_MessageName() string
- func (m *ParseReq) XXX_Size() int
- func (m *ParseReq) XXX_Unmarshal(b []byte) error
- type ParseResp
- func (*ParseResp) Descriptor() ([]byte, []int)
- func (m *ParseResp) GetCode() ResponseCode
- func (m *ParseResp) GetMessage() string
- func (m *ParseResp) GetResponseTime() time.Time
- func (m *ParseResp) Marshal() (dAtA []byte, err error)
- func (m *ParseResp) MarshalTo(dAtA []byte) (int, error)
- func (m *ParseResp) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ParseResp) ProtoMessage()
- func (m *ParseResp) Reset()
- func (m *ParseResp) Size() (n int)
- func (m *ParseResp) String() string
- func (m *ParseResp) Unmarshal(dAtA []byte) error
- func (m *ParseResp) XXX_DiscardUnknown()
- func (m *ParseResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ParseResp) XXX_Merge(src proto.Message)
- func (*ParseResp) XXX_MessageName() string
- func (m *ParseResp) XXX_Size() int
- func (m *ParseResp) XXX_Unmarshal(b []byte) error
- type RecycleReq
- func (*RecycleReq) Descriptor() ([]byte, []int)
- func (m *RecycleReq) GetEsIndex() RecycleReq_ESIndex
- func (m *RecycleReq) GetTimeScopeInHours() int64
- func (m *RecycleReq) Marshal() (dAtA []byte, err error)
- func (m *RecycleReq) MarshalTo(dAtA []byte) (int, error)
- func (m *RecycleReq) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*RecycleReq) ProtoMessage()
- func (m *RecycleReq) Reset()
- func (m *RecycleReq) Size() (n int)
- func (m *RecycleReq) String() string
- func (m *RecycleReq) Unmarshal(dAtA []byte) error
- func (m *RecycleReq) XXX_DiscardUnknown()
- func (m *RecycleReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RecycleReq) XXX_Merge(src proto.Message)
- func (*RecycleReq) XXX_MessageName() string
- func (m *RecycleReq) XXX_Size() int
- func (m *RecycleReq) XXX_Unmarshal(b []byte) error
- type RecycleReq_ESIndex
- type ResponseCode
- type RolesHostsReq
- func (*RolesHostsReq) Descriptor() ([]byte, []int)
- func (m *RolesHostsReq) GetId() string
- func (m *RolesHostsReq) GetRespSize() int32
- func (m *RolesHostsReq) GetRole() node.NodeRole
- func (m *RolesHostsReq) Marshal() (dAtA []byte, err error)
- func (m *RolesHostsReq) MarshalTo(dAtA []byte) (int, error)
- func (m *RolesHostsReq) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*RolesHostsReq) ProtoMessage()
- func (m *RolesHostsReq) Reset()
- func (m *RolesHostsReq) Size() (n int)
- func (m *RolesHostsReq) String() string
- func (m *RolesHostsReq) Unmarshal(dAtA []byte) error
- func (m *RolesHostsReq) XXX_DiscardUnknown()
- func (m *RolesHostsReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RolesHostsReq) XXX_Merge(src proto.Message)
- func (*RolesHostsReq) XXX_MessageName() string
- func (m *RolesHostsReq) XXX_Size() int
- func (m *RolesHostsReq) XXX_Unmarshal(b []byte) error
- type SettingsData
- func (*SettingsData) Descriptor() ([]byte, []int)
- func (m *SettingsData) GetBandwidthLimit() float64
- func (m *SettingsData) GetBandwidthPriceAsk() float64
- func (m *SettingsData) GetCollateralStake() float64
- func (m *SettingsData) GetStoragePriceAsk() float64
- func (m *SettingsData) GetStorageTimeMin() float64
- func (m *SettingsData) Marshal() (dAtA []byte, err error)
- func (m *SettingsData) MarshalTo(dAtA []byte) (int, error)
- func (m *SettingsData) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SettingsData) ProtoMessage()
- func (m *SettingsData) Reset()
- func (m *SettingsData) Size() (n int)
- func (m *SettingsData) String() string
- func (m *SettingsData) Unmarshal(dAtA []byte) error
- func (m *SettingsData) XXX_DiscardUnknown()
- func (m *SettingsData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SettingsData) XXX_Merge(src proto.Message)
- func (*SettingsData) XXX_MessageName() string
- func (m *SettingsData) XXX_Size() int
- func (m *SettingsData) XXX_Unmarshal(b []byte) error
- type SettingsReq
- func (*SettingsReq) Descriptor() ([]byte, []int)
- func (m *SettingsReq) GetId() string
- func (m *SettingsReq) GetRespSize() int32
- func (m *SettingsReq) Marshal() (dAtA []byte, err error)
- func (m *SettingsReq) MarshalTo(dAtA []byte) (int, error)
- func (m *SettingsReq) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SettingsReq) ProtoMessage()
- func (m *SettingsReq) Reset()
- func (m *SettingsReq) Size() (n int)
- func (m *SettingsReq) String() string
- func (m *SettingsReq) Unmarshal(dAtA []byte) error
- func (m *SettingsReq) XXX_DiscardUnknown()
- func (m *SettingsReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SettingsReq) XXX_Merge(src proto.Message)
- func (*SettingsReq) XXX_MessageName() string
- func (m *SettingsReq) XXX_Size() int
- func (m *SettingsReq) XXX_Unmarshal(b []byte) error
- type SettingsResp
- func (*SettingsResp) Descriptor() ([]byte, []int)
- func (m *SettingsResp) GetCode() ResponseCode
- func (m *SettingsResp) GetMessage() string
- func (m *SettingsResp) GetResponseTime() time.Time
- func (m *SettingsResp) GetSettingsData() *SettingsData
- func (m *SettingsResp) Marshal() (dAtA []byte, err error)
- func (m *SettingsResp) MarshalTo(dAtA []byte) (int, error)
- func (m *SettingsResp) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SettingsResp) ProtoMessage()
- func (m *SettingsResp) Reset()
- func (m *SettingsResp) Size() (n int)
- func (m *SettingsResp) String() string
- func (m *SettingsResp) Unmarshal(dAtA []byte) error
- func (m *SettingsResp) XXX_DiscardUnknown()
- func (m *SettingsResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SettingsResp) XXX_Merge(src proto.Message)
- func (*SettingsResp) XXX_MessageName() string
- func (m *SettingsResp) XXX_Size() int
- func (m *SettingsResp) XXX_Unmarshal(b []byte) error
- type StatsReq
- func (*StatsReq) Descriptor() ([]byte, []int)
- func (m *StatsReq) GetId() string
- func (m *StatsReq) Marshal() (dAtA []byte, err error)
- func (m *StatsReq) MarshalTo(dAtA []byte) (int, error)
- func (m *StatsReq) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*StatsReq) ProtoMessage()
- func (m *StatsReq) Reset()
- func (m *StatsReq) Size() (n int)
- func (m *StatsReq) String() string
- func (m *StatsReq) Unmarshal(dAtA []byte) error
- func (m *StatsReq) XXX_DiscardUnknown()
- func (m *StatsReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StatsReq) XXX_Merge(src proto.Message)
- func (*StatsReq) XXX_MessageName() string
- func (m *StatsReq) XXX_Size() int
- func (m *StatsReq) XXX_Unmarshal(b []byte) error
- type StatsResp
- func (*StatsResp) Descriptor() ([]byte, []int)
- func (m *StatsResp) GetCode() ResponseCode
- func (m *StatsResp) GetMessage() string
- func (m *StatsResp) GetResponseTime() time.Time
- func (m *StatsResp) Marshal() (dAtA []byte, err error)
- func (m *StatsResp) MarshalTo(dAtA []byte) (int, error)
- func (m *StatsResp) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*StatsResp) ProtoMessage()
- func (m *StatsResp) Reset()
- func (m *StatsResp) Size() (n int)
- func (m *StatsResp) String() string
- func (m *StatsResp) Unmarshal(dAtA []byte) error
- func (m *StatsResp) XXX_DiscardUnknown()
- func (m *StatsResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StatsResp) XXX_Merge(src proto.Message)
- func (*StatsResp) XXX_MessageName() string
- func (m *StatsResp) XXX_Size() int
- func (m *StatsResp) XXX_Unmarshal(b []byte) error
- type UnimplementedHubParseServiceServer
- func (*UnimplementedHubParseServiceServer) Recycle(ctx context.Context, req *RecycleReq) (*ParseResp, error)
- func (*UnimplementedHubParseServiceServer) UpdateBtfsScan(ctx context.Context, req *ParseReq) (*ParseResp, error)
- func (*UnimplementedHubParseServiceServer) UpdateDiscovery(ctx context.Context, req *ParseReq) (*ParseResp, error)
- func (*UnimplementedHubParseServiceServer) UpdateNetwork(ctx context.Context, req *ParseReq) (*ParseResp, error)
- func (*UnimplementedHubParseServiceServer) UpdateScore(ctx context.Context, req *ParseReq) (*ParseResp, error)
- type UnimplementedHubQueryServiceServer
- func (*UnimplementedHubQueryServiceServer) GetHosts(ctx context.Context, req *HostsReq) (*HostsResp, error)
- func (*UnimplementedHubQueryServiceServer) GetHostsByRoles(ctx context.Context, req *RolesHostsReq) (*HostsResp, error)
- func (*UnimplementedHubQueryServiceServer) GetSettings(ctx context.Context, req *SettingsReq) (*SettingsResp, error)
- func (*UnimplementedHubQueryServiceServer) GetStats(ctx context.Context, req *StatsReq) (*StatsResp, error)
- func (*UnimplementedHubQueryServiceServer) QueryNodes(ctx context.Context, req *NodesReq) (*HostsResp, error)
Constants ¶
This section is empty.
Variables ¶
var ( ErrInvalidLengthHub = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowHub = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupHub = fmt.Errorf("proto: unexpected end of group") )
var HostsReq_Mode_name = map[int32]string{
0: "SCORE",
1: "GEO",
2: "REP",
3: "PRICE",
4: "SPEED",
5: "TESTNET",
}
var HostsReq_Mode_value = map[string]int32{
"SCORE": 0,
"GEO": 1,
"REP": 2,
"PRICE": 3,
"SPEED": 4,
"TESTNET": 5,
}
var RecycleReq_ESIndex_name = map[int32]string{
0: "NODES",
1: "NETWORK",
2: "TESTNET_NODES",
}
var RecycleReq_ESIndex_value = map[string]int32{
"NODES": 0,
"NETWORK": 1,
"TESTNET_NODES": 2,
}
var ResponseCode_name = map[int32]string{
0: "SUCCESS",
1: "SIGNATURE_FORMAT_ERROR",
2: "COMPUTE_ADDRESS_ERROR",
3: "TIMEOUT_ERROR",
20: "OTHER_ERROR",
}
var ResponseCode_value = map[string]int32{
"SUCCESS": 0,
"SIGNATURE_FORMAT_ERROR": 1,
"COMPUTE_ADDRESS_ERROR": 2,
"TIMEOUT_ERROR": 3,
"OTHER_ERROR": 20,
}
Functions ¶
func RegisterHubParseServiceServer ¶ added in v0.4.0
func RegisterHubParseServiceServer(s *grpc.Server, srv HubParseServiceServer)
func RegisterHubQueryServiceServer ¶ added in v0.1.8
func RegisterHubQueryServiceServer(s *grpc.Server, srv HubQueryServiceServer)
Types ¶
type Candidate ¶ added in v0.4.0
type Candidate struct { NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty" pg:"node_id"` HeartBeats uint64 `protobuf:"varint,2,opt,name=heart_beats,json=heartBeats,proto3" json:"heart_beats,omitempty" pg:"heart_beats"` UploadAverage float32 `protobuf:"fixed32,3,opt,name=upload_average,json=uploadAverage,proto3" json:"upload_average,omitempty" pg:"upload_average"` UploadVariance float32 `` /* 126-byte string literal not displayed */ DownloadAverage float32 `` /* 130-byte string literal not displayed */ DownloadVariance float32 `` /* 134-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-" pg:"-"` XXX_unrecognized []byte `json:"-" pg:"-"` XXX_sizecache int32 `json:"-" pg:"-"` }
func (*Candidate) Descriptor ¶ added in v0.4.0
func (*Candidate) GetDownloadAverage ¶ added in v0.4.0
func (*Candidate) GetDownloadVariance ¶ added in v0.4.0
func (*Candidate) GetHeartBeats ¶ added in v0.4.0
func (*Candidate) GetUploadAverage ¶ added in v0.4.0
func (*Candidate) GetUploadVariance ¶ added in v0.4.0
func (*Candidate) MarshalToSizedBuffer ¶ added in v0.4.0
func (*Candidate) ProtoMessage ¶ added in v0.4.0
func (*Candidate) ProtoMessage()
func (*Candidate) XXX_DiscardUnknown ¶ added in v0.4.0
func (m *Candidate) XXX_DiscardUnknown()
func (*Candidate) XXX_Marshal ¶ added in v0.4.0
func (*Candidate) XXX_MessageName ¶ added in v0.4.0
func (*Candidate) XXX_Unmarshal ¶ added in v0.4.0
type Host ¶
type Host struct { NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty" pg:"node_id"` CreateTimestamp time.Time `` /* 126-byte string literal not displayed */ UpdateTimestamp time.Time `` /* 126-byte string literal not displayed */ Region string `protobuf:"bytes,4,opt,name=region,proto3" json:"region,omitempty" pg:"region"` BtfsVersion string `protobuf:"bytes,5,opt,name=btfs_version,json=btfsVersion,proto3" json:"btfs_version,omitempty" pg:"btfs_version"` Score float32 `protobuf:"fixed32,6,opt,name=score,proto3" json:"score,omitempty" pg:"score"` HeartBeats uint64 `protobuf:"varint,7,opt,name=heart_beats,json=heartBeats,proto3" json:"heart_beats,omitempty" pg:"heart_beats"` Uptime float32 `protobuf:"fixed32,8,opt,name=uptime,proto3" json:"uptime,omitempty" pg:"uptime"` Age uint64 `protobuf:"varint,9,opt,name=age,proto3" json:"age,omitempty" pg:"age"` Reputation float32 `protobuf:"fixed32,10,opt,name=reputation,proto3" json:"reputation,omitempty" pg:"reputation"` UploadAverage float32 `protobuf:"fixed32,11,opt,name=upload_average,json=uploadAverage,proto3" json:"upload_average,omitempty" pg:"upload_average"` UploadVariance float32 `` /* 127-byte string literal not displayed */ DownloadAverage float32 `` /* 131-byte string literal not displayed */ DownloadVariance float32 `` /* 135-byte string literal not displayed */ Location Location `protobuf:"bytes,15,opt,name=location,proto3" json:"location" pg:"location"` StorageVolumeCap float32 `` /* 138-byte string literal not displayed */ StorageVolumeLeft float32 `` /* 142-byte string literal not displayed */ StorageTimeMin uint64 `` /* 129-byte string literal not displayed */ StoragePriceAsk uint64 `` /* 133-byte string literal not displayed */ StoragePriceEst uint64 `` /* 133-byte string literal not displayed */ BandwidthLimit float64 `` /* 127-byte string literal not displayed */ BandwidthPriceAsk uint64 `` /* 141-byte string literal not displayed */ BandwidthPriceEst uint64 `` /* 141-byte string literal not displayed */ CollateralStake uint64 `` /* 130-byte string literal not displayed */ CollateralLost uint64 `` /* 126-byte string literal not displayed */ CollateralBurn uint64 `` /* 126-byte string literal not displayed */ CountryShort string `protobuf:"bytes,27,opt,name=country_short,json=countryShort,proto3" json:"country_short,omitempty" pg:"country_short"` node.Node_ExperimentalFlags `protobuf:"bytes,28,opt,name=flg,proto3,embedded=flg" json:"flg" pg:"flg"` Discovery float32 `protobuf:"fixed32,29,opt,name=discovery,proto3" json:"discovery,omitempty" pg:"discovery"` UptimeScore float32 `protobuf:"fixed32,30,opt,name=uptime_score,json=uptimeScore,proto3" json:"uptime_score,omitempty" pg:"uptime_score"` AgeScore float32 `protobuf:"fixed32,31,opt,name=age_score,json=ageScore,proto3" json:"age_score,omitempty" pg:"age_score"` VersionScore float32 `protobuf:"fixed32,32,opt,name=version_score,json=versionScore,proto3" json:"version_score,omitempty" pg:"version_score"` UploadSpeedScore float32 `` /* 138-byte string literal not displayed */ DownloadSpeedScore float32 `` /* 146-byte string literal not displayed */ Roles []node.NodeRole `protobuf:"varint,35,rep,packed,name=roles,proto3,enum=node.NodeRole" json:"roles,omitempty" pg:"roles,array"` XXX_NoUnkeyedLiteral struct{} `json:"-" pg:"-"` XXX_unrecognized []byte `json:"-" pg:"-"` XXX_sizecache int32 `json:"-" pg:"-"` }
func (*Host) Descriptor ¶
func (*Host) GetAgeScore ¶ added in v0.5.20
func (*Host) GetBandwidthLimit ¶ added in v0.1.6
func (*Host) GetBandwidthPriceAsk ¶ added in v0.1.6
func (*Host) GetBandwidthPriceEst ¶ added in v0.1.6
func (*Host) GetBtfsVersion ¶
func (*Host) GetCollateralBurn ¶ added in v0.1.6
func (*Host) GetCollateralLost ¶ added in v0.1.6
func (*Host) GetCollateralStake ¶ added in v0.1.6
func (*Host) GetCountryShort ¶ added in v0.1.14
func (*Host) GetCreateTimestamp ¶ added in v0.1.6
func (*Host) GetDiscovery ¶ added in v0.2.23
func (*Host) GetDownloadAverage ¶ added in v0.1.6
func (*Host) GetDownloadSpeedScore ¶ added in v0.5.20
func (*Host) GetDownloadVariance ¶ added in v0.1.6
func (*Host) GetHeartBeats ¶
func (*Host) GetLocation ¶
func (*Host) GetReputation ¶
func (*Host) GetStoragePriceAsk ¶ added in v0.1.6
func (*Host) GetStoragePriceEst ¶ added in v0.1.6
func (*Host) GetStorageTimeMin ¶ added in v0.1.6
func (*Host) GetStorageVolumeCap ¶ added in v0.1.6
func (*Host) GetStorageVolumeLeft ¶ added in v0.1.6
func (*Host) GetUpdateTimestamp ¶ added in v0.1.6
func (*Host) GetUploadAverage ¶ added in v0.1.6
func (*Host) GetUploadSpeedScore ¶ added in v0.5.20
func (*Host) GetUploadVariance ¶ added in v0.1.6
func (*Host) GetUptimeScore ¶ added in v0.5.20
func (*Host) GetVersionScore ¶ added in v0.5.20
func (*Host) ProtoMessage ¶
func (*Host) ProtoMessage()
func (*Host) XXX_DiscardUnknown ¶
func (m *Host) XXX_DiscardUnknown()
func (*Host) XXX_MessageName ¶
func (*Host) XXX_Unmarshal ¶
type HostsData ¶
type HostsData struct { Hosts []*Host `protobuf:"bytes,1,rep,name=hosts,proto3" json:"hosts,omitempty" pg:"hosts"` XXX_NoUnkeyedLiteral struct{} `json:"-" pg:"-"` XXX_unrecognized []byte `json:"-" pg:"-"` XXX_sizecache int32 `json:"-" pg:"-"` }
func (*HostsData) Descriptor ¶
func (*HostsData) MarshalToSizedBuffer ¶
func (*HostsData) ProtoMessage ¶
func (*HostsData) ProtoMessage()
func (*HostsData) XXX_DiscardUnknown ¶
func (m *HostsData) XXX_DiscardUnknown()
func (*HostsData) XXX_Marshal ¶
func (*HostsData) XXX_MessageName ¶
func (*HostsData) XXX_Unmarshal ¶
type HostsReq ¶
type HostsReq struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty" pg:"id"` RespSize int32 `protobuf:"varint,2,opt,name=resp_size,json=respSize,proto3" json:"resp_size,omitempty" pg:"resp_size"` Mode HostsReq_Mode `protobuf:"varint,3,opt,name=mode,proto3,enum=hub.HostsReq_Mode" json:"mode,omitempty" pg:"mode"` XXX_NoUnkeyedLiteral struct{} `json:"-" pg:"-"` XXX_unrecognized []byte `json:"-" pg:"-"` XXX_sizecache int32 `json:"-" pg:"-"` }
func (*HostsReq) Descriptor ¶
func (*HostsReq) GetMode ¶ added in v0.2.8
func (m *HostsReq) GetMode() HostsReq_Mode
func (*HostsReq) GetRespSize ¶
func (*HostsReq) MarshalToSizedBuffer ¶
func (*HostsReq) ProtoMessage ¶
func (*HostsReq) ProtoMessage()
func (*HostsReq) XXX_DiscardUnknown ¶
func (m *HostsReq) XXX_DiscardUnknown()
func (*HostsReq) XXX_Marshal ¶
func (*HostsReq) XXX_MessageName ¶
func (*HostsReq) XXX_Unmarshal ¶
type HostsReq_Mode ¶ added in v0.2.8
type HostsReq_Mode int32
const ( HostsReq_SCORE HostsReq_Mode = 0 HostsReq_GEO HostsReq_Mode = 1 HostsReq_REP HostsReq_Mode = 2 HostsReq_PRICE HostsReq_Mode = 3 HostsReq_SPEED HostsReq_Mode = 4 HostsReq_TESTNET HostsReq_Mode = 5 )
func (HostsReq_Mode) EnumDescriptor ¶ added in v0.2.8
func (HostsReq_Mode) EnumDescriptor() ([]byte, []int)
func (HostsReq_Mode) String ¶ added in v0.2.8
func (x HostsReq_Mode) String() string
type HostsResp ¶
type HostsResp struct { Code ResponseCode `protobuf:"varint,1,opt,name=code,proto3,enum=hub.ResponseCode" json:"code,omitempty" pg:"code"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty" pg:"message"` Hosts *HostsData `protobuf:"bytes,3,opt,name=hosts,proto3" json:"hosts,omitempty" pg:"hosts"` RespSize int32 `protobuf:"varint,4,opt,name=resp_size,json=respSize,proto3" json:"resp_size,omitempty" pg:"resp_size"` Mode string `protobuf:"bytes,5,opt,name=mode,proto3" json:"mode,omitempty" pg:"mode"` ResponseTime time.Time `protobuf:"bytes,6,opt,name=response_time,json=responseTime,proto3,stdtime" json:"response_time" pg:"response_time"` XXX_NoUnkeyedLiteral struct{} `json:"-" pg:"-"` XXX_unrecognized []byte `json:"-" pg:"-"` XXX_sizecache int32 `json:"-" pg:"-"` }
func (*HostsResp) Descriptor ¶
func (*HostsResp) GetCode ¶
func (m *HostsResp) GetCode() ResponseCode
func (*HostsResp) GetMessage ¶
func (*HostsResp) GetRespSize ¶
func (*HostsResp) GetResponseTime ¶
func (*HostsResp) MarshalToSizedBuffer ¶
func (*HostsResp) ProtoMessage ¶
func (*HostsResp) ProtoMessage()
func (*HostsResp) XXX_DiscardUnknown ¶
func (m *HostsResp) XXX_DiscardUnknown()
func (*HostsResp) XXX_Marshal ¶
func (*HostsResp) XXX_MessageName ¶
func (*HostsResp) XXX_Unmarshal ¶
type HubParseServiceClient ¶ added in v0.4.0
type HubParseServiceClient interface { UpdateDiscovery(ctx context.Context, in *ParseReq, opts ...grpc.CallOption) (*ParseResp, error) UpdateScore(ctx context.Context, in *ParseReq, opts ...grpc.CallOption) (*ParseResp, error) UpdateNetwork(ctx context.Context, in *ParseReq, opts ...grpc.CallOption) (*ParseResp, error) Recycle(ctx context.Context, in *RecycleReq, opts ...grpc.CallOption) (*ParseResp, error) UpdateBtfsScan(ctx context.Context, in *ParseReq, opts ...grpc.CallOption) (*ParseResp, error) }
HubParseServiceClient is the client API for HubParseService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewHubParseServiceClient ¶ added in v0.4.0
func NewHubParseServiceClient(cc *grpc.ClientConn) HubParseServiceClient
type HubParseServiceServer ¶ added in v0.4.0
type HubParseServiceServer interface { UpdateDiscovery(context.Context, *ParseReq) (*ParseResp, error) UpdateScore(context.Context, *ParseReq) (*ParseResp, error) UpdateNetwork(context.Context, *ParseReq) (*ParseResp, error) Recycle(context.Context, *RecycleReq) (*ParseResp, error) UpdateBtfsScan(context.Context, *ParseReq) (*ParseResp, error) }
HubParseServiceServer is the server API for HubParseService service.
type HubQueryServiceClient ¶ added in v0.1.8
type HubQueryServiceClient interface { GetSettings(ctx context.Context, in *SettingsReq, opts ...grpc.CallOption) (*SettingsResp, error) GetHosts(ctx context.Context, in *HostsReq, opts ...grpc.CallOption) (*HostsResp, error) GetStats(ctx context.Context, in *StatsReq, opts ...grpc.CallOption) (*StatsResp, error) QueryNodes(ctx context.Context, in *NodesReq, opts ...grpc.CallOption) (*HostsResp, error) GetHostsByRoles(ctx context.Context, in *RolesHostsReq, opts ...grpc.CallOption) (*HostsResp, error) }
HubQueryServiceClient is the client API for HubQueryService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewHubQueryServiceClient ¶ added in v0.1.8
func NewHubQueryServiceClient(cc *grpc.ClientConn) HubQueryServiceClient
type HubQueryServiceServer ¶ added in v0.1.8
type HubQueryServiceServer interface { GetSettings(context.Context, *SettingsReq) (*SettingsResp, error) GetHosts(context.Context, *HostsReq) (*HostsResp, error) GetStats(context.Context, *StatsReq) (*StatsResp, error) QueryNodes(context.Context, *NodesReq) (*HostsResp, error) GetHostsByRoles(context.Context, *RolesHostsReq) (*HostsResp, error) }
HubQueryServiceServer is the server API for HubQueryService service.
type Location ¶
type Location struct { Lat float64 `protobuf:"fixed64,1,opt,name=lat,proto3" json:"lat,omitempty" pg:"lat"` Lon float64 `protobuf:"fixed64,2,opt,name=lon,proto3" json:"lon,omitempty" pg:"lon"` XXX_NoUnkeyedLiteral struct{} `json:"-" pg:"-"` XXX_unrecognized []byte `json:"-" pg:"-"` XXX_sizecache int32 `json:"-" pg:"-"` }
func (*Location) Descriptor ¶
func (*Location) MarshalToSizedBuffer ¶
func (*Location) ProtoMessage ¶
func (*Location) ProtoMessage()
func (*Location) XXX_DiscardUnknown ¶
func (m *Location) XXX_DiscardUnknown()
func (*Location) XXX_Marshal ¶
func (*Location) XXX_MessageName ¶
func (*Location) XXX_Unmarshal ¶
type NodesReq ¶ added in v0.4.4
type NodesReq struct { NodeId []string `protobuf:"bytes,1,rep,name=node_id,json=nodeId,proto3" json:"node_id,omitempty" pg:"node_id"` RequesterId string `protobuf:"bytes,2,opt,name=requester_id,json=requesterId,proto3" json:"requester_id,omitempty" pg:"requester_id"` Signature []byte `protobuf:"bytes,3,opt,name=signature,proto3" json:"signature,omitempty" pg:"signature"` XXX_NoUnkeyedLiteral struct{} `json:"-" pg:"-"` XXX_unrecognized []byte `json:"-" pg:"-"` XXX_sizecache int32 `json:"-" pg:"-"` }
func (*NodesReq) Descriptor ¶ added in v0.4.4
func (*NodesReq) GetRequesterId ¶ added in v0.4.4
func (*NodesReq) GetSignature ¶ added in v0.4.4
func (*NodesReq) MarshalToSizedBuffer ¶ added in v0.4.4
func (*NodesReq) ProtoMessage ¶ added in v0.4.4
func (*NodesReq) ProtoMessage()
func (*NodesReq) XXX_DiscardUnknown ¶ added in v0.4.4
func (m *NodesReq) XXX_DiscardUnknown()
func (*NodesReq) XXX_Marshal ¶ added in v0.4.4
func (*NodesReq) XXX_MessageName ¶ added in v0.4.4
func (*NodesReq) XXX_Unmarshal ¶ added in v0.4.4
type ParseReq ¶ added in v0.4.0
type ParseReq struct { Candidates []*Candidate `protobuf:"bytes,1,rep,name=candidates,proto3" json:"candidates,omitempty" pg:"candidates"` XXX_NoUnkeyedLiteral struct{} `json:"-" pg:"-"` XXX_unrecognized []byte `json:"-" pg:"-"` XXX_sizecache int32 `json:"-" pg:"-"` }
func (*ParseReq) Descriptor ¶ added in v0.4.0
func (*ParseReq) GetCandidates ¶ added in v0.4.0
func (*ParseReq) MarshalToSizedBuffer ¶ added in v0.4.0
func (*ParseReq) ProtoMessage ¶ added in v0.4.0
func (*ParseReq) ProtoMessage()
func (*ParseReq) XXX_DiscardUnknown ¶ added in v0.4.0
func (m *ParseReq) XXX_DiscardUnknown()
func (*ParseReq) XXX_Marshal ¶ added in v0.4.0
func (*ParseReq) XXX_MessageName ¶ added in v0.4.0
func (*ParseReq) XXX_Unmarshal ¶ added in v0.4.0
type ParseResp ¶ added in v0.4.0
type ParseResp struct { Code ResponseCode `protobuf:"varint,1,opt,name=code,proto3,enum=hub.ResponseCode" json:"code,omitempty" pg:"code"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty" pg:"message"` ResponseTime time.Time `protobuf:"bytes,3,opt,name=response_time,json=responseTime,proto3,stdtime" json:"response_time" pg:"response_time"` XXX_NoUnkeyedLiteral struct{} `json:"-" pg:"-"` XXX_unrecognized []byte `json:"-" pg:"-"` XXX_sizecache int32 `json:"-" pg:"-"` }
func (*ParseResp) Descriptor ¶ added in v0.4.0
func (*ParseResp) GetCode ¶ added in v0.4.0
func (m *ParseResp) GetCode() ResponseCode
func (*ParseResp) GetMessage ¶ added in v0.4.0
func (*ParseResp) GetResponseTime ¶ added in v0.4.0
func (*ParseResp) MarshalToSizedBuffer ¶ added in v0.4.0
func (*ParseResp) ProtoMessage ¶ added in v0.4.0
func (*ParseResp) ProtoMessage()
func (*ParseResp) XXX_DiscardUnknown ¶ added in v0.4.0
func (m *ParseResp) XXX_DiscardUnknown()
func (*ParseResp) XXX_Marshal ¶ added in v0.4.0
func (*ParseResp) XXX_MessageName ¶ added in v0.4.0
func (*ParseResp) XXX_Unmarshal ¶ added in v0.4.0
type RecycleReq ¶ added in v0.4.0
type RecycleReq struct { EsIndex RecycleReq_ESIndex `protobuf:"varint,1,opt,name=es_index,json=esIndex,proto3,enum=hub.RecycleReq_ESIndex" json:"es_index,omitempty" pg:"es_index"` TimeScopeInHours int64 `` /* 139-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-" pg:"-"` XXX_unrecognized []byte `json:"-" pg:"-"` XXX_sizecache int32 `json:"-" pg:"-"` }
func (*RecycleReq) Descriptor ¶ added in v0.4.0
func (*RecycleReq) Descriptor() ([]byte, []int)
func (*RecycleReq) GetEsIndex ¶ added in v0.4.0
func (m *RecycleReq) GetEsIndex() RecycleReq_ESIndex
func (*RecycleReq) GetTimeScopeInHours ¶ added in v0.5.3
func (m *RecycleReq) GetTimeScopeInHours() int64
func (*RecycleReq) Marshal ¶ added in v0.4.0
func (m *RecycleReq) Marshal() (dAtA []byte, err error)
func (*RecycleReq) MarshalTo ¶ added in v0.4.0
func (m *RecycleReq) MarshalTo(dAtA []byte) (int, error)
func (*RecycleReq) MarshalToSizedBuffer ¶ added in v0.4.0
func (m *RecycleReq) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*RecycleReq) ProtoMessage ¶ added in v0.4.0
func (*RecycleReq) ProtoMessage()
func (*RecycleReq) Reset ¶ added in v0.4.0
func (m *RecycleReq) Reset()
func (*RecycleReq) Size ¶ added in v0.4.0
func (m *RecycleReq) Size() (n int)
func (*RecycleReq) String ¶ added in v0.4.0
func (m *RecycleReq) String() string
func (*RecycleReq) Unmarshal ¶ added in v0.4.0
func (m *RecycleReq) Unmarshal(dAtA []byte) error
func (*RecycleReq) XXX_DiscardUnknown ¶ added in v0.4.0
func (m *RecycleReq) XXX_DiscardUnknown()
func (*RecycleReq) XXX_Marshal ¶ added in v0.4.0
func (m *RecycleReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RecycleReq) XXX_Merge ¶ added in v0.4.0
func (m *RecycleReq) XXX_Merge(src proto.Message)
func (*RecycleReq) XXX_MessageName ¶ added in v0.4.0
func (*RecycleReq) XXX_MessageName() string
func (*RecycleReq) XXX_Size ¶ added in v0.4.0
func (m *RecycleReq) XXX_Size() int
func (*RecycleReq) XXX_Unmarshal ¶ added in v0.4.0
func (m *RecycleReq) XXX_Unmarshal(b []byte) error
type RecycleReq_ESIndex ¶ added in v0.4.0
type RecycleReq_ESIndex int32
const ( RecycleReq_NODES RecycleReq_ESIndex = 0 RecycleReq_NETWORK RecycleReq_ESIndex = 1 RecycleReq_TESTNET_NODES RecycleReq_ESIndex = 2 )
func (RecycleReq_ESIndex) EnumDescriptor ¶ added in v0.4.0
func (RecycleReq_ESIndex) EnumDescriptor() ([]byte, []int)
func (RecycleReq_ESIndex) String ¶ added in v0.4.0
func (x RecycleReq_ESIndex) String() string
type ResponseCode ¶
type ResponseCode int32
const ( ResponseCode_SUCCESS ResponseCode = 0 ResponseCode_SIGNATURE_FORMAT_ERROR ResponseCode = 1 ResponseCode_COMPUTE_ADDRESS_ERROR ResponseCode = 2 ResponseCode_TIMEOUT_ERROR ResponseCode = 3 ResponseCode_OTHER_ERROR ResponseCode = 20 )
func (ResponseCode) EnumDescriptor ¶
func (ResponseCode) EnumDescriptor() ([]byte, []int)
func (ResponseCode) String ¶
func (x ResponseCode) String() string
type RolesHostsReq ¶ added in v0.5.22
type RolesHostsReq struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty" pg:"id"` RespSize int32 `protobuf:"varint,2,opt,name=resp_size,json=respSize,proto3" json:"resp_size,omitempty" pg:"resp_size"` Role node.NodeRole `protobuf:"varint,3,opt,name=role,proto3,enum=node.NodeRole" json:"role,omitempty" pg:"role"` XXX_NoUnkeyedLiteral struct{} `json:"-" pg:"-"` XXX_unrecognized []byte `json:"-" pg:"-"` XXX_sizecache int32 `json:"-" pg:"-"` }
func (*RolesHostsReq) Descriptor ¶ added in v0.5.22
func (*RolesHostsReq) Descriptor() ([]byte, []int)
func (*RolesHostsReq) GetId ¶ added in v0.5.22
func (m *RolesHostsReq) GetId() string
func (*RolesHostsReq) GetRespSize ¶ added in v0.5.22
func (m *RolesHostsReq) GetRespSize() int32
func (*RolesHostsReq) GetRole ¶ added in v0.5.22
func (m *RolesHostsReq) GetRole() node.NodeRole
func (*RolesHostsReq) Marshal ¶ added in v0.5.22
func (m *RolesHostsReq) Marshal() (dAtA []byte, err error)
func (*RolesHostsReq) MarshalTo ¶ added in v0.5.22
func (m *RolesHostsReq) MarshalTo(dAtA []byte) (int, error)
func (*RolesHostsReq) MarshalToSizedBuffer ¶ added in v0.5.22
func (m *RolesHostsReq) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*RolesHostsReq) ProtoMessage ¶ added in v0.5.22
func (*RolesHostsReq) ProtoMessage()
func (*RolesHostsReq) Reset ¶ added in v0.5.22
func (m *RolesHostsReq) Reset()
func (*RolesHostsReq) Size ¶ added in v0.5.22
func (m *RolesHostsReq) Size() (n int)
func (*RolesHostsReq) String ¶ added in v0.5.22
func (m *RolesHostsReq) String() string
func (*RolesHostsReq) Unmarshal ¶ added in v0.5.22
func (m *RolesHostsReq) Unmarshal(dAtA []byte) error
func (*RolesHostsReq) XXX_DiscardUnknown ¶ added in v0.5.22
func (m *RolesHostsReq) XXX_DiscardUnknown()
func (*RolesHostsReq) XXX_Marshal ¶ added in v0.5.22
func (m *RolesHostsReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RolesHostsReq) XXX_Merge ¶ added in v0.5.22
func (m *RolesHostsReq) XXX_Merge(src proto.Message)
func (*RolesHostsReq) XXX_MessageName ¶ added in v0.5.22
func (*RolesHostsReq) XXX_MessageName() string
func (*RolesHostsReq) XXX_Size ¶ added in v0.5.22
func (m *RolesHostsReq) XXX_Size() int
func (*RolesHostsReq) XXX_Unmarshal ¶ added in v0.5.22
func (m *RolesHostsReq) XXX_Unmarshal(b []byte) error
type SettingsData ¶
type SettingsData struct { StoragePriceAsk float64 `` /* 133-byte string literal not displayed */ BandwidthPriceAsk float64 `` /* 141-byte string literal not displayed */ StorageTimeMin float64 `` /* 129-byte string literal not displayed */ BandwidthLimit float64 `` /* 126-byte string literal not displayed */ CollateralStake float64 `` /* 130-byte string literal not displayed */ XXX_NoUnkeyedLiteral struct{} `json:"-" pg:"-"` XXX_unrecognized []byte `json:"-" pg:"-"` XXX_sizecache int32 `json:"-" pg:"-"` }
func (*SettingsData) Descriptor ¶
func (*SettingsData) Descriptor() ([]byte, []int)
func (*SettingsData) GetBandwidthLimit ¶
func (m *SettingsData) GetBandwidthLimit() float64
func (*SettingsData) GetBandwidthPriceAsk ¶
func (m *SettingsData) GetBandwidthPriceAsk() float64
func (*SettingsData) GetCollateralStake ¶
func (m *SettingsData) GetCollateralStake() float64
func (*SettingsData) GetStoragePriceAsk ¶
func (m *SettingsData) GetStoragePriceAsk() float64
func (*SettingsData) GetStorageTimeMin ¶
func (m *SettingsData) GetStorageTimeMin() float64
func (*SettingsData) Marshal ¶
func (m *SettingsData) Marshal() (dAtA []byte, err error)
func (*SettingsData) MarshalToSizedBuffer ¶
func (m *SettingsData) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SettingsData) ProtoMessage ¶
func (*SettingsData) ProtoMessage()
func (*SettingsData) Reset ¶
func (m *SettingsData) Reset()
func (*SettingsData) Size ¶
func (m *SettingsData) Size() (n int)
func (*SettingsData) String ¶
func (m *SettingsData) String() string
func (*SettingsData) Unmarshal ¶
func (m *SettingsData) Unmarshal(dAtA []byte) error
func (*SettingsData) XXX_DiscardUnknown ¶
func (m *SettingsData) XXX_DiscardUnknown()
func (*SettingsData) XXX_Marshal ¶
func (m *SettingsData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SettingsData) XXX_Merge ¶
func (m *SettingsData) XXX_Merge(src proto.Message)
func (*SettingsData) XXX_MessageName ¶
func (*SettingsData) XXX_MessageName() string
func (*SettingsData) XXX_Size ¶
func (m *SettingsData) XXX_Size() int
func (*SettingsData) XXX_Unmarshal ¶
func (m *SettingsData) XXX_Unmarshal(b []byte) error
type SettingsReq ¶
type SettingsReq struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty" pg:"id"` RespSize int32 `protobuf:"varint,2,opt,name=resp_size,json=respSize,proto3" json:"resp_size,omitempty" pg:"resp_size"` XXX_NoUnkeyedLiteral struct{} `json:"-" pg:"-"` XXX_unrecognized []byte `json:"-" pg:"-"` XXX_sizecache int32 `json:"-" pg:"-"` }
func (*SettingsReq) Descriptor ¶
func (*SettingsReq) Descriptor() ([]byte, []int)
func (*SettingsReq) GetId ¶
func (m *SettingsReq) GetId() string
func (*SettingsReq) GetRespSize ¶
func (m *SettingsReq) GetRespSize() int32
func (*SettingsReq) Marshal ¶
func (m *SettingsReq) Marshal() (dAtA []byte, err error)
func (*SettingsReq) MarshalToSizedBuffer ¶
func (m *SettingsReq) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SettingsReq) ProtoMessage ¶
func (*SettingsReq) ProtoMessage()
func (*SettingsReq) Reset ¶
func (m *SettingsReq) Reset()
func (*SettingsReq) Size ¶
func (m *SettingsReq) Size() (n int)
func (*SettingsReq) String ¶
func (m *SettingsReq) String() string
func (*SettingsReq) Unmarshal ¶
func (m *SettingsReq) Unmarshal(dAtA []byte) error
func (*SettingsReq) XXX_DiscardUnknown ¶
func (m *SettingsReq) XXX_DiscardUnknown()
func (*SettingsReq) XXX_Marshal ¶
func (m *SettingsReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SettingsReq) XXX_Merge ¶
func (m *SettingsReq) XXX_Merge(src proto.Message)
func (*SettingsReq) XXX_MessageName ¶
func (*SettingsReq) XXX_MessageName() string
func (*SettingsReq) XXX_Size ¶
func (m *SettingsReq) XXX_Size() int
func (*SettingsReq) XXX_Unmarshal ¶
func (m *SettingsReq) XXX_Unmarshal(b []byte) error
type SettingsResp ¶
type SettingsResp struct { Code ResponseCode `protobuf:"varint,1,opt,name=code,proto3,enum=hub.ResponseCode" json:"code,omitempty" pg:"code"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty" pg:"message"` ResponseTime time.Time `protobuf:"bytes,3,opt,name=response_time,json=responseTime,proto3,stdtime" json:"response_time" pg:"response_time"` SettingsData *SettingsData `protobuf:"bytes,4,opt,name=settings_data,json=settingsData,proto3" json:"settings_data,omitempty" pg:"settings_data"` XXX_NoUnkeyedLiteral struct{} `json:"-" pg:"-"` XXX_unrecognized []byte `json:"-" pg:"-"` XXX_sizecache int32 `json:"-" pg:"-"` }
func (*SettingsResp) Descriptor ¶
func (*SettingsResp) Descriptor() ([]byte, []int)
func (*SettingsResp) GetCode ¶
func (m *SettingsResp) GetCode() ResponseCode
func (*SettingsResp) GetMessage ¶
func (m *SettingsResp) GetMessage() string
func (*SettingsResp) GetResponseTime ¶
func (m *SettingsResp) GetResponseTime() time.Time
func (*SettingsResp) GetSettingsData ¶
func (m *SettingsResp) GetSettingsData() *SettingsData
func (*SettingsResp) Marshal ¶
func (m *SettingsResp) Marshal() (dAtA []byte, err error)
func (*SettingsResp) MarshalToSizedBuffer ¶
func (m *SettingsResp) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SettingsResp) ProtoMessage ¶
func (*SettingsResp) ProtoMessage()
func (*SettingsResp) Reset ¶
func (m *SettingsResp) Reset()
func (*SettingsResp) Size ¶
func (m *SettingsResp) Size() (n int)
func (*SettingsResp) String ¶
func (m *SettingsResp) String() string
func (*SettingsResp) Unmarshal ¶
func (m *SettingsResp) Unmarshal(dAtA []byte) error
func (*SettingsResp) XXX_DiscardUnknown ¶
func (m *SettingsResp) XXX_DiscardUnknown()
func (*SettingsResp) XXX_Marshal ¶
func (m *SettingsResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SettingsResp) XXX_Merge ¶
func (m *SettingsResp) XXX_Merge(src proto.Message)
func (*SettingsResp) XXX_MessageName ¶
func (*SettingsResp) XXX_MessageName() string
func (*SettingsResp) XXX_Size ¶
func (m *SettingsResp) XXX_Size() int
func (*SettingsResp) XXX_Unmarshal ¶
func (m *SettingsResp) XXX_Unmarshal(b []byte) error
type StatsReq ¶ added in v0.2.27
type StatsReq struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty" pg:"id"` XXX_NoUnkeyedLiteral struct{} `json:"-" pg:"-"` XXX_unrecognized []byte `json:"-" pg:"-"` XXX_sizecache int32 `json:"-" pg:"-"` }
func (*StatsReq) Descriptor ¶ added in v0.2.27
func (*StatsReq) MarshalToSizedBuffer ¶ added in v0.2.27
func (*StatsReq) ProtoMessage ¶ added in v0.2.27
func (*StatsReq) ProtoMessage()
func (*StatsReq) XXX_DiscardUnknown ¶ added in v0.2.27
func (m *StatsReq) XXX_DiscardUnknown()
func (*StatsReq) XXX_Marshal ¶ added in v0.2.27
func (*StatsReq) XXX_MessageName ¶ added in v0.2.27
func (*StatsReq) XXX_Unmarshal ¶ added in v0.2.27
type StatsResp ¶ added in v0.2.27
type StatsResp struct { Code ResponseCode `protobuf:"varint,1,opt,name=code,proto3,enum=hub.ResponseCode" json:"code,omitempty" pg:"code"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty" pg:"message"` ResponseTime time.Time `protobuf:"bytes,3,opt,name=response_time,json=responseTime,proto3,stdtime" json:"response_time" pg:"response_time"` node.StorageStat_HostStats `protobuf:"bytes,4,opt,name=stats,proto3,embedded=stats" json:"stats" pg:"stats"` XXX_NoUnkeyedLiteral struct{} `json:"-" pg:"-"` XXX_unrecognized []byte `json:"-" pg:"-"` XXX_sizecache int32 `json:"-" pg:"-"` }
func (*StatsResp) Descriptor ¶ added in v0.2.27
func (*StatsResp) GetCode ¶ added in v0.2.27
func (m *StatsResp) GetCode() ResponseCode
func (*StatsResp) GetMessage ¶ added in v0.2.27
func (*StatsResp) GetResponseTime ¶ added in v0.2.27
func (*StatsResp) MarshalToSizedBuffer ¶ added in v0.2.27
func (*StatsResp) ProtoMessage ¶ added in v0.2.27
func (*StatsResp) ProtoMessage()
func (*StatsResp) XXX_DiscardUnknown ¶ added in v0.2.27
func (m *StatsResp) XXX_DiscardUnknown()
func (*StatsResp) XXX_Marshal ¶ added in v0.2.27
func (*StatsResp) XXX_MessageName ¶ added in v0.2.27
func (*StatsResp) XXX_Unmarshal ¶ added in v0.2.27
type UnimplementedHubParseServiceServer ¶ added in v0.4.0
type UnimplementedHubParseServiceServer struct { }
UnimplementedHubParseServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedHubParseServiceServer) Recycle ¶ added in v0.4.0
func (*UnimplementedHubParseServiceServer) Recycle(ctx context.Context, req *RecycleReq) (*ParseResp, error)
func (*UnimplementedHubParseServiceServer) UpdateBtfsScan ¶ added in v0.7.5
func (*UnimplementedHubParseServiceServer) UpdateDiscovery ¶ added in v0.4.0
func (*UnimplementedHubParseServiceServer) UpdateNetwork ¶ added in v0.4.0
func (*UnimplementedHubParseServiceServer) UpdateScore ¶ added in v0.4.0
type UnimplementedHubQueryServiceServer ¶ added in v0.1.8
type UnimplementedHubQueryServiceServer struct { }
UnimplementedHubQueryServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedHubQueryServiceServer) GetHostsByRoles ¶ added in v0.5.22
func (*UnimplementedHubQueryServiceServer) GetHostsByRoles(ctx context.Context, req *RolesHostsReq) (*HostsResp, error)
func (*UnimplementedHubQueryServiceServer) GetSettings ¶ added in v0.1.8
func (*UnimplementedHubQueryServiceServer) GetSettings(ctx context.Context, req *SettingsReq) (*SettingsResp, error)