hub

package
v0.8.12-pre3 Latest Latest
Warning

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

 Go to latest Published: Oct 18, 2022 License: MIT Imports: 16 Imported by: 5

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthHub        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowHub          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupHub = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var HostsReq_Mode_name = map[int32]string{
	0: "SCORE",
	1: "GEO",
	2: "REP",
	3: "PRICE",
	4: "SPEED",
	5: "TESTNET",
}
View Source 
var HostsReq_Mode_value = map[string]int32{
	"SCORE":   0,
	"GEO":     1,
	"REP":     2,
	"PRICE":   3,
	"SPEED":   4,
	"TESTNET": 5,
}
View Source 
var HubRouter_name = map[int32]string{
	0: "V1",
	1: "NONE",
	2: "V2",
	3: "ALL",
}
View Source 
var HubRouter_value = map[string]int32{
	"V1":   0,
	"NONE": 1,
	"V2":   2,
	"ALL":  3,
}
View Source 
var RecycleReq_ESIndex_name = map[int32]string{
	0: "NODES",
	1: "NETWORK",
	2: "TESTNET_NODES",
}
View Source 
var RecycleReq_ESIndex_value = map[string]int32{
	"NODES":         0,
	"NETWORK":       1,
	"TESTNET_NODES": 2,
}
View Source 
var ResponseCode_name = map[int32]string{
	0:  "SUCCESS",
	1:  "SIGNATURE_FORMAT_ERROR",
	2:  "COMPUTE_ADDRESS_ERROR",
	3:  "TIMEOUT_ERROR",
	20: "OTHER_ERROR",
}
View Source 
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) Descriptor() ([]byte, []int)

func (*Candidate) GetDownloadAverage added in v0.4.0 

func (m *Candidate) GetDownloadAverage() float32

func (*Candidate) GetDownloadVariance added in v0.4.0 

func (m *Candidate) GetDownloadVariance() float32

func (*Candidate) GetHeartBeats added in v0.4.0 

func (m *Candidate) GetHeartBeats() uint64

func (*Candidate) GetNodeId added in v0.4.0 

func (m *Candidate) GetNodeId() string

func (*Candidate) GetUploadAverage added in v0.4.0 

func (m *Candidate) GetUploadAverage() float32

func (*Candidate) GetUploadVariance added in v0.4.0 

func (m *Candidate) GetUploadVariance() float32

func (*Candidate) Marshal added in v0.4.0 

func (m *Candidate) Marshal() (dAtA []byte, err error)

func (*Candidate) MarshalTo added in v0.4.0 

func (m *Candidate) MarshalTo(dAtA []byte) (int, error)

func (*Candidate) MarshalToSizedBuffer added in v0.4.0 

func (m *Candidate) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Candidate) ProtoMessage added in v0.4.0 

func (*Candidate) ProtoMessage()

func (*Candidate) Reset added in v0.4.0 

func (m *Candidate) Reset()

func (*Candidate) Size added in v0.4.0 

func (m *Candidate) Size() (n int)

func (*Candidate) String added in v0.4.0 

func (m *Candidate) String() string

func (*Candidate) Unmarshal added in v0.4.0 

func (m *Candidate) Unmarshal(dAtA []byte) error

func (*Candidate) XXX_DiscardUnknown added in v0.4.0 

func (m *Candidate) XXX_DiscardUnknown()

func (*Candidate) XXX_Marshal added in v0.4.0 

func (m *Candidate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Candidate) XXX_Merge added in v0.4.0 

func (m *Candidate) XXX_Merge(src proto.Message)

func (*Candidate) XXX_MessageName added in v0.4.0 

func (*Candidate) XXX_MessageName() string

func (*Candidate) XXX_Size added in v0.4.0 

func (m *Candidate) XXX_Size() int

func (*Candidate) XXX_Unmarshal added in v0.4.0 

func (m *Candidate) XXX_Unmarshal(b []byte) error

type Host 

type Host struct {
	NodeId                      string    `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id" 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" pg:"region"`
	BtfsVersion                 string    `protobuf:"bytes,5,opt,name=btfs_version,json=btfsVersion,proto3" json:"btfs_version" pg:"btfs_version"`
	Score                       float32   `protobuf:"fixed32,6,opt,name=score,proto3" json:"score" pg:"score"`
	HeartBeats                  uint64    `protobuf:"varint,7,opt,name=heart_beats,json=heartBeats,proto3" json:"heart_beats" pg:"heart_beats"`
	Uptime                      float32   `protobuf:"fixed32,8,opt,name=uptime,proto3" json:"uptime" pg:"uptime"`
	Age                         uint64    `protobuf:"varint,9,opt,name=age,proto3" json:"age" pg:"age"`
	Reputation                  float32   `protobuf:"fixed32,10,opt,name=reputation,proto3" json:"reputation" pg:"reputation"`
	UploadAverage               float32   `protobuf:"fixed32,11,opt,name=upload_average,json=uploadAverage,proto3" json:"upload_average" pg:"upload_average"`
	UploadVariance              float32   `protobuf:"fixed32,12,opt,name=upload_variance,json=uploadVariance,proto3" json:"upload_variance" pg:"upload_variance"`
	DownloadAverage             float32   `protobuf:"fixed32,13,opt,name=download_average,json=downloadAverage,proto3" json:"download_average" pg:"download_average"`
	DownloadVariance            float32   `protobuf:"fixed32,14,opt,name=download_variance,json=downloadVariance,proto3" json:"download_variance" pg:"download_variance"`
	Location                    Location  `protobuf:"bytes,15,opt,name=location,proto3" json:"location" pg:"location"`
	StorageVolumeCap            float32   `` /* 128-byte string literal not displayed */
	StorageVolumeLeft           float32   `` /* 132-byte string literal not displayed */
	StorageTimeMin              uint64    `protobuf:"varint,18,opt,name=storage_time_min,json=storageTimeMin,proto3" json:"storage_time_min" pg:"storage_time_min"`
	StoragePriceAsk             uint64    `protobuf:"varint,19,opt,name=storage_price_ask,json=storagePriceAsk,proto3" json:"storage_price_ask" pg:"storage_price_ask"`
	StoragePriceEst             uint64    `protobuf:"varint,20,opt,name=storage_price_est,json=storagePriceEst,proto3" json:"storage_price_est" pg:"storage_price_est"`
	BandwidthLimit              float64   `protobuf:"fixed64,21,opt,name=bandwidth_limit,json=bandwidthLimit,proto3" json:"bandwidth_limit" pg:"bandwidth_limit"`
	BandwidthPriceAsk           uint64    `` /* 131-byte string literal not displayed */
	BandwidthPriceEst           uint64    `` /* 131-byte string literal not displayed */
	CollateralStake             uint64    `protobuf:"varint,24,opt,name=collateral_stake,json=collateralStake,proto3" json:"collateral_stake" pg:"collateral_stake"`
	CollateralLost              uint64    `protobuf:"varint,25,opt,name=collateral_lost,json=collateralLost,proto3" json:"collateral_lost" pg:"collateral_lost"`
	CollateralBurn              uint64    `protobuf:"varint,26,opt,name=collateral_burn,json=collateralBurn,proto3" json:"collateral_burn" pg:"collateral_burn"`
	CountryShort                string    `protobuf:"bytes,27,opt,name=country_short,json=countryShort,proto3" json:"country_short" 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" pg:"discovery"`
	UptimeScore                 float32         `protobuf:"fixed32,30,opt,name=uptime_score,json=uptimeScore,proto3" json:"uptime_score" pg:"uptime_score"`
	AgeScore                    float32         `protobuf:"fixed32,31,opt,name=age_score,json=ageScore,proto3" json:"age_score" pg:"age_score"`
	VersionScore                float32         `protobuf:"fixed32,32,opt,name=version_score,json=versionScore,proto3" json:"version_score" pg:"version_score"`
	UploadSpeedScore            float32         `` /* 128-byte string literal not displayed */
	DownloadSpeedScore          float32         `` /* 136-byte string literal not displayed */
	Roles                       []node.NodeRole `protobuf:"varint,35,rep,packed,name=roles,proto3,enum=node.NodeRole" json:"roles" pg:"roles,array"`
	ActiveTimestamp             time.Time       `` /* 127-byte string literal not displayed */
	ActiveScore                 float32         `protobuf:"fixed32,37,opt,name=active_score,json=activeScore,proto3" json:"active_score" pg:"active_score"`
	Inactive                    uint64          `protobuf:"varint,38,opt,name=inactive,proto3" json:"inactive" pg:"inactive"`
	ReportStatusTimestamp       time.Time       `` /* 154-byte string literal not displayed */
	XXX_NoUnkeyedLiteral        struct{}        `json:"-" pg:"-"`
	XXX_unrecognized            []byte          `json:"-" pg:"-"`
	XXX_sizecache               int32           `json:"-" pg:"-"`
}

func (*Host) Descriptor 

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

func (*Host) GetActiveScore added in v0.8.10 

func (m *Host) GetActiveScore() float32

func (*Host) GetActiveTimestamp added in v0.8.10 

func (m *Host) GetActiveTimestamp() time.Time

func (*Host) GetAge 

func (m *Host) GetAge() uint64

func (*Host) GetAgeScore added in v0.5.20 

func (m *Host) GetAgeScore() float32

func (*Host) GetBandwidthLimit added in v0.1.6 

func (m *Host) GetBandwidthLimit() float64

func (*Host) GetBandwidthPriceAsk added in v0.1.6 

func (m *Host) GetBandwidthPriceAsk() uint64

func (*Host) GetBandwidthPriceEst added in v0.1.6 

func (m *Host) GetBandwidthPriceEst() uint64

func (*Host) GetBtfsVersion 

func (m *Host) GetBtfsVersion() string

func (*Host) GetCollateralBurn added in v0.1.6 

func (m *Host) GetCollateralBurn() uint64

func (*Host) GetCollateralLost added in v0.1.6 

func (m *Host) GetCollateralLost() uint64

func (*Host) GetCollateralStake added in v0.1.6 

func (m *Host) GetCollateralStake() uint64

func (*Host) GetCountryShort added in v0.1.14 

func (m *Host) GetCountryShort() string

func (*Host) GetCreateTimestamp added in v0.1.6 

func (m *Host) GetCreateTimestamp() time.Time

func (*Host) GetDiscovery added in v0.2.23 

func (m *Host) GetDiscovery() float32

func (*Host) GetDownloadAverage added in v0.1.6 

func (m *Host) GetDownloadAverage() float32

func (*Host) GetDownloadSpeedScore added in v0.5.20 

func (m *Host) GetDownloadSpeedScore() float32

func (*Host) GetDownloadVariance added in v0.1.6 

func (m *Host) GetDownloadVariance() float32

func (*Host) GetHeartBeats 

func (m *Host) GetHeartBeats() uint64

func (*Host) GetInactive added in v0.8.10 

func (m *Host) GetInactive() uint64

func (*Host) GetLocation 

func (m *Host) GetLocation() Location

func (*Host) GetNodeId 

func (m *Host) GetNodeId() string

func (*Host) GetRegion 

func (m *Host) GetRegion() string

func (*Host) GetReportStatusTimestamp added in v0.8.12 

func (m *Host) GetReportStatusTimestamp() time.Time

func (*Host) GetReputation 

func (m *Host) GetReputation() float32

func (*Host) GetRoles added in v0.5.22 

func (m *Host) GetRoles() []node.NodeRole

func (*Host) GetScore 

func (m *Host) GetScore() float32

func (*Host) GetStoragePriceAsk added in v0.1.6 

func (m *Host) GetStoragePriceAsk() uint64

func (*Host) GetStoragePriceEst added in v0.1.6 

func (m *Host) GetStoragePriceEst() uint64

func (*Host) GetStorageTimeMin added in v0.1.6 

func (m *Host) GetStorageTimeMin() uint64

func (*Host) GetStorageVolumeCap added in v0.1.6 

func (m *Host) GetStorageVolumeCap() float32

func (*Host) GetStorageVolumeLeft added in v0.1.6 

func (m *Host) GetStorageVolumeLeft() float32

func (*Host) GetUpdateTimestamp added in v0.1.6 

func (m *Host) GetUpdateTimestamp() time.Time

func (*Host) GetUploadAverage added in v0.1.6 

func (m *Host) GetUploadAverage() float32

func (*Host) GetUploadSpeedScore added in v0.5.20 

func (m *Host) GetUploadSpeedScore() float32

func (*Host) GetUploadVariance added in v0.1.6 

func (m *Host) GetUploadVariance() float32

func (*Host) GetUptime 

func (m *Host) GetUptime() float32

func (*Host) GetUptimeScore added in v0.5.20 

func (m *Host) GetUptimeScore() float32

func (*Host) GetVersionScore added in v0.5.20 

func (m *Host) GetVersionScore() float32

func (*Host) Marshal 

func (m *Host) Marshal() (dAtA []byte, err error)

func (*Host) MarshalTo 

func (m *Host) MarshalTo(dAtA []byte) (int, error)

func (*Host) MarshalToSizedBuffer 

func (m *Host) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Host) ProtoMessage 

func (*Host) ProtoMessage()

func (*Host) Reset 

func (m *Host) Reset()

func (*Host) Size 

func (m *Host) Size() (n int)

func (*Host) String 

func (m *Host) String() string

func (*Host) Unmarshal 

func (m *Host) Unmarshal(dAtA []byte) error

func (*Host) XXX_DiscardUnknown 

func (m *Host) XXX_DiscardUnknown()

func (*Host) XXX_Marshal 

func (m *Host) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Host) XXX_Merge 

func (m *Host) XXX_Merge(src proto.Message)

func (*Host) XXX_MessageName 

func (*Host) XXX_MessageName() string

func (*Host) XXX_Size 

func (m *Host) XXX_Size() int

func (*Host) XXX_Unmarshal 

func (m *Host) XXX_Unmarshal(b []byte) error

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) Descriptor() ([]byte, []int)

func (*HostsData) GetHosts 

func (m *HostsData) GetHosts() []*Host

func (*HostsData) Marshal 

func (m *HostsData) Marshal() (dAtA []byte, err error)

func (*HostsData) MarshalTo 

func (m *HostsData) MarshalTo(dAtA []byte) (int, error)

func (*HostsData) MarshalToSizedBuffer 

func (m *HostsData) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*HostsData) ProtoMessage 

func (*HostsData) ProtoMessage()

func (*HostsData) Reset 

func (m *HostsData) Reset()

func (*HostsData) Size 

func (m *HostsData) Size() (n int)

func (*HostsData) String 

func (m *HostsData) String() string

func (*HostsData) Unmarshal 

func (m *HostsData) Unmarshal(dAtA []byte) error

func (*HostsData) XXX_DiscardUnknown 

func (m *HostsData) XXX_DiscardUnknown()

func (*HostsData) XXX_Marshal 

func (m *HostsData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HostsData) XXX_Merge 

func (m *HostsData) XXX_Merge(src proto.Message)

func (*HostsData) XXX_MessageName 

func (*HostsData) XXX_MessageName() string

func (*HostsData) XXX_Size 

func (m *HostsData) XXX_Size() int

func (*HostsData) XXX_Unmarshal 

func (m *HostsData) XXX_Unmarshal(b []byte) error

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"`
	Version              string        `protobuf:"bytes,4,opt,name=version,proto3" json:"version,omitempty" pg:"version"`
	NewVersion           HubRouter     `` /* 128-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}      `json:"-" pg:"-"`
	XXX_unrecognized     []byte        `json:"-" pg:"-"`
	XXX_sizecache        int32         `json:"-" pg:"-"`
}

func (*HostsReq) Descriptor 

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

func (*HostsReq) GetId 

func (m *HostsReq) GetId() string

func (*HostsReq) GetMode added in v0.2.8 

func (m *HostsReq) GetMode() HostsReq_Mode

func (*HostsReq) GetNewVersion added in v0.8.10 

func (m *HostsReq) GetNewVersion() HubRouter

func (*HostsReq) GetRespSize 

func (m *HostsReq) GetRespSize() int32

func (*HostsReq) GetVersion added in v0.8.6 

func (m *HostsReq) GetVersion() string

func (*HostsReq) Marshal 

func (m *HostsReq) Marshal() (dAtA []byte, err error)

func (*HostsReq) MarshalTo 

func (m *HostsReq) MarshalTo(dAtA []byte) (int, error)

func (*HostsReq) MarshalToSizedBuffer 

func (m *HostsReq) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*HostsReq) ProtoMessage 

func (*HostsReq) ProtoMessage()

func (*HostsReq) Reset 

func (m *HostsReq) Reset()

func (*HostsReq) Size 

func (m *HostsReq) Size() (n int)

func (*HostsReq) String 

func (m *HostsReq) String() string

func (*HostsReq) Unmarshal 

func (m *HostsReq) Unmarshal(dAtA []byte) error

func (*HostsReq) XXX_DiscardUnknown 

func (m *HostsReq) XXX_DiscardUnknown()

func (*HostsReq) XXX_Marshal 

func (m *HostsReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HostsReq) XXX_Merge 

func (m *HostsReq) XXX_Merge(src proto.Message)

func (*HostsReq) XXX_MessageName 

func (*HostsReq) XXX_MessageName() string

func (*HostsReq) XXX_Size 

func (m *HostsReq) XXX_Size() int

func (*HostsReq) XXX_Unmarshal 

func (m *HostsReq) XXX_Unmarshal(b []byte) error

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) Descriptor() ([]byte, []int)

func (*HostsResp) GetCode 

func (m *HostsResp) GetCode() ResponseCode

func (*HostsResp) GetHosts 

func (m *HostsResp) GetHosts() *HostsData

func (*HostsResp) GetMessage 

func (m *HostsResp) GetMessage() string

func (*HostsResp) GetMode 

func (m *HostsResp) GetMode() string

func (*HostsResp) GetRespSize 

func (m *HostsResp) GetRespSize() int32

func (*HostsResp) GetResponseTime 

func (m *HostsResp) GetResponseTime() time.Time

func (*HostsResp) Marshal 

func (m *HostsResp) Marshal() (dAtA []byte, err error)

func (*HostsResp) MarshalTo 

func (m *HostsResp) MarshalTo(dAtA []byte) (int, error)

func (*HostsResp) MarshalToSizedBuffer 

func (m *HostsResp) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*HostsResp) ProtoMessage 

func (*HostsResp) ProtoMessage()

func (*HostsResp) Reset 

func (m *HostsResp) Reset()

func (*HostsResp) Size 

func (m *HostsResp) Size() (n int)

func (*HostsResp) String 

func (m *HostsResp) String() string

func (*HostsResp) Unmarshal 

func (m *HostsResp) Unmarshal(dAtA []byte) error

func (*HostsResp) XXX_DiscardUnknown 

func (m *HostsResp) XXX_DiscardUnknown()

func (*HostsResp) XXX_Marshal 

func (m *HostsResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HostsResp) XXX_Merge 

func (m *HostsResp) XXX_Merge(src proto.Message)

func (*HostsResp) XXX_MessageName 

func (*HostsResp) XXX_MessageName() string

func (*HostsResp) XXX_Size 

func (m *HostsResp) XXX_Size() int

func (*HostsResp) XXX_Unmarshal 

func (m *HostsResp) XXX_Unmarshal(b []byte) error

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)
	UpdateScoreHistory(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)
	UpdateScoreHistory(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)
	GetScoreDistribution(ctx context.Context, in *ScoreDisReq, opts ...grpc.CallOption) (*ScoreDisResp, 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)
	GetScoreDistribution(context.Context, *ScoreDisReq) (*ScoreDisResp, error)
}

HubQueryServiceServer is the server API for HubQueryService service.

type HubRouter added in v0.8.10 

type HubRouter int32
const (
	HubRouter_V1   HubRouter = 0
	HubRouter_NONE HubRouter = 1
	HubRouter_V2   HubRouter = 2
	HubRouter_ALL  HubRouter = 3
)

func (HubRouter) EnumDescriptor added in v0.8.10 

func (HubRouter) EnumDescriptor() ([]byte, []int)

func (HubRouter) String added in v0.8.10 

func (x HubRouter) String() string

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) Descriptor() ([]byte, []int)

func (*Location) GetLat 

func (m *Location) GetLat() float64

func (*Location) GetLon 

func (m *Location) GetLon() float64

func (*Location) Marshal 

func (m *Location) Marshal() (dAtA []byte, err error)

func (*Location) MarshalTo 

func (m *Location) MarshalTo(dAtA []byte) (int, error)

func (*Location) MarshalToSizedBuffer 

func (m *Location) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Location) ProtoMessage 

func (*Location) ProtoMessage()

func (*Location) Reset 

func (m *Location) Reset()

func (*Location) Size 

func (m *Location) Size() (n int)

func (*Location) String 

func (m *Location) String() string

func (*Location) Unmarshal 

func (m *Location) Unmarshal(dAtA []byte) error

func (*Location) XXX_DiscardUnknown 

func (m *Location) XXX_DiscardUnknown()

func (*Location) XXX_Marshal 

func (m *Location) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Location) XXX_Merge 

func (m *Location) XXX_Merge(src proto.Message)

func (*Location) XXX_MessageName 

func (*Location) XXX_MessageName() string

func (*Location) XXX_Size 

func (m *Location) XXX_Size() int

func (*Location) XXX_Unmarshal 

func (m *Location) XXX_Unmarshal(b []byte) error

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"`
	NewVersion           HubRouter `` /* 128-byte string literal not displayed */
	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) Descriptor() ([]byte, []int)

func (*NodesReq) GetNewVersion added in v0.8.10 

func (m *NodesReq) GetNewVersion() HubRouter

func (*NodesReq) GetNodeId added in v0.4.4 

func (m *NodesReq) GetNodeId() []string

func (*NodesReq) GetRequesterId added in v0.4.4 

func (m *NodesReq) GetRequesterId() string

func (*NodesReq) GetSignature added in v0.4.4 

func (m *NodesReq) GetSignature() []byte

func (*NodesReq) Marshal added in v0.4.4 

func (m *NodesReq) Marshal() (dAtA []byte, err error)

func (*NodesReq) MarshalTo added in v0.4.4 

func (m *NodesReq) MarshalTo(dAtA []byte) (int, error)

func (*NodesReq) MarshalToSizedBuffer added in v0.4.4 

func (m *NodesReq) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*NodesReq) ProtoMessage added in v0.4.4 

func (*NodesReq) ProtoMessage()

func (*NodesReq) Reset added in v0.4.4 

func (m *NodesReq) Reset()

func (*NodesReq) Size added in v0.4.4 

func (m *NodesReq) Size() (n int)

func (*NodesReq) String added in v0.4.4 

func (m *NodesReq) String() string

func (*NodesReq) Unmarshal added in v0.4.4 

func (m *NodesReq) Unmarshal(dAtA []byte) error

func (*NodesReq) XXX_DiscardUnknown added in v0.4.4 

func (m *NodesReq) XXX_DiscardUnknown()

func (*NodesReq) XXX_Marshal added in v0.4.4 

func (m *NodesReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NodesReq) XXX_Merge added in v0.4.4 

func (m *NodesReq) XXX_Merge(src proto.Message)

func (*NodesReq) XXX_MessageName added in v0.4.4 

func (*NodesReq) XXX_MessageName() string

func (*NodesReq) XXX_Size added in v0.4.4 

func (m *NodesReq) XXX_Size() int

func (*NodesReq) XXX_Unmarshal added in v0.4.4 

func (m *NodesReq) XXX_Unmarshal(b []byte) error

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) Descriptor() ([]byte, []int)

func (*ParseReq) GetCandidates added in v0.4.0 

func (m *ParseReq) GetCandidates() []*Candidate

func (*ParseReq) Marshal added in v0.4.0 

func (m *ParseReq) Marshal() (dAtA []byte, err error)

func (*ParseReq) MarshalTo added in v0.4.0 

func (m *ParseReq) MarshalTo(dAtA []byte) (int, error)

func (*ParseReq) MarshalToSizedBuffer added in v0.4.0 

func (m *ParseReq) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ParseReq) ProtoMessage added in v0.4.0 

func (*ParseReq) ProtoMessage()

func (*ParseReq) Reset added in v0.4.0 

func (m *ParseReq) Reset()

func (*ParseReq) Size added in v0.4.0 

func (m *ParseReq) Size() (n int)

func (*ParseReq) String added in v0.4.0 

func (m *ParseReq) String() string

func (*ParseReq) Unmarshal added in v0.4.0 

func (m *ParseReq) Unmarshal(dAtA []byte) error

func (*ParseReq) XXX_DiscardUnknown added in v0.4.0 

func (m *ParseReq) XXX_DiscardUnknown()

func (*ParseReq) XXX_Marshal added in v0.4.0 

func (m *ParseReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ParseReq) XXX_Merge added in v0.4.0 

func (m *ParseReq) XXX_Merge(src proto.Message)

func (*ParseReq) XXX_MessageName added in v0.4.0 

func (*ParseReq) XXX_MessageName() string

func (*ParseReq) XXX_Size added in v0.4.0 

func (m *ParseReq) XXX_Size() int

func (*ParseReq) XXX_Unmarshal added in v0.4.0 

func (m *ParseReq) XXX_Unmarshal(b []byte) error

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) Descriptor() ([]byte, []int)

func (*ParseResp) GetCode added in v0.4.0 

func (m *ParseResp) GetCode() ResponseCode

func (*ParseResp) GetMessage added in v0.4.0 

func (m *ParseResp) GetMessage() string

func (*ParseResp) GetResponseTime added in v0.4.0 

func (m *ParseResp) GetResponseTime() time.Time

func (*ParseResp) Marshal added in v0.4.0 

func (m *ParseResp) Marshal() (dAtA []byte, err error)

func (*ParseResp) MarshalTo added in v0.4.0 

func (m *ParseResp) MarshalTo(dAtA []byte) (int, error)

func (*ParseResp) MarshalToSizedBuffer added in v0.4.0 

func (m *ParseResp) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ParseResp) ProtoMessage added in v0.4.0 

func (*ParseResp) ProtoMessage()

func (*ParseResp) Reset added in v0.4.0 

func (m *ParseResp) Reset()

func (*ParseResp) Size added in v0.4.0 

func (m *ParseResp) Size() (n int)

func (*ParseResp) String added in v0.4.0 

func (m *ParseResp) String() string

func (*ParseResp) Unmarshal added in v0.4.0 

func (m *ParseResp) Unmarshal(dAtA []byte) error

func (*ParseResp) XXX_DiscardUnknown added in v0.4.0 

func (m *ParseResp) XXX_DiscardUnknown()

func (*ParseResp) XXX_Marshal added in v0.4.0 

func (m *ParseResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ParseResp) XXX_Merge added in v0.4.0 

func (m *ParseResp) XXX_Merge(src proto.Message)

func (*ParseResp) XXX_MessageName added in v0.4.0 

func (*ParseResp) XXX_MessageName() string

func (*ParseResp) XXX_Size added in v0.4.0 

func (m *ParseResp) XXX_Size() int

func (*ParseResp) XXX_Unmarshal added in v0.4.0 

func (m *ParseResp) XXX_Unmarshal(b []byte) error

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"`
	NewVersion           HubRouter     `` /* 128-byte string literal not displayed */
	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) GetNewVersion added in v0.8.10 

func (m *RolesHostsReq) GetNewVersion() HubRouter

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 ScoreDisReq added in v0.8.12 

type ScoreDisReq struct {
	NewVersion           HubRouter `` /* 128-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}  `json:"-" pg:"-"`
	XXX_unrecognized     []byte    `json:"-" pg:"-"`
	XXX_sizecache        int32     `json:"-" pg:"-"`
}

func (*ScoreDisReq) Descriptor added in v0.8.12 

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

func (*ScoreDisReq) GetNewVersion added in v0.8.12 

func (m *ScoreDisReq) GetNewVersion() HubRouter

func (*ScoreDisReq) Marshal added in v0.8.12 

func (m *ScoreDisReq) Marshal() (dAtA []byte, err error)

func (*ScoreDisReq) MarshalTo added in v0.8.12 

func (m *ScoreDisReq) MarshalTo(dAtA []byte) (int, error)

func (*ScoreDisReq) MarshalToSizedBuffer added in v0.8.12 

func (m *ScoreDisReq) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ScoreDisReq) ProtoMessage added in v0.8.12 

func (*ScoreDisReq) ProtoMessage()

func (*ScoreDisReq) Reset added in v0.8.12 

func (m *ScoreDisReq) Reset()

func (*ScoreDisReq) Size added in v0.8.12 

func (m *ScoreDisReq) Size() (n int)

func (*ScoreDisReq) String added in v0.8.12 

func (m *ScoreDisReq) String() string

func (*ScoreDisReq) Unmarshal added in v0.8.12 

func (m *ScoreDisReq) Unmarshal(dAtA []byte) error

func (*ScoreDisReq) XXX_DiscardUnknown added in v0.8.12 

func (m *ScoreDisReq) XXX_DiscardUnknown()

func (*ScoreDisReq) XXX_Marshal added in v0.8.12 

func (m *ScoreDisReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ScoreDisReq) XXX_Merge added in v0.8.12 

func (m *ScoreDisReq) XXX_Merge(src proto.Message)

func (*ScoreDisReq) XXX_MessageName added in v0.8.12 

func (*ScoreDisReq) XXX_MessageName() string

func (*ScoreDisReq) XXX_Size added in v0.8.12 

func (m *ScoreDisReq) XXX_Size() int

func (*ScoreDisReq) XXX_Unmarshal added in v0.8.12 

func (m *ScoreDisReq) XXX_Unmarshal(b []byte) error

type ScoreDisResp added in v0.8.12 

type ScoreDisResp 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"`
	Level1               int32        `protobuf:"varint,3,opt,name=level1,proto3" json:"level1,omitempty" pg:"level1"`
	Level2               int32        `protobuf:"varint,4,opt,name=level2,proto3" json:"level2,omitempty" pg:"level2"`
	Level3               int32        `protobuf:"varint,5,opt,name=level3,proto3" json:"level3,omitempty" pg:"level3"`
	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 (*ScoreDisResp) Descriptor added in v0.8.12 

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

func (*ScoreDisResp) GetCode added in v0.8.12 

func (m *ScoreDisResp) GetCode() ResponseCode

func (*ScoreDisResp) GetLevel1 added in v0.8.12 

func (m *ScoreDisResp) GetLevel1() int32

func (*ScoreDisResp) GetLevel2 added in v0.8.12 

func (m *ScoreDisResp) GetLevel2() int32

func (*ScoreDisResp) GetLevel3 added in v0.8.12 

func (m *ScoreDisResp) GetLevel3() int32

func (*ScoreDisResp) GetMessage added in v0.8.12 

func (m *ScoreDisResp) GetMessage() string

func (*ScoreDisResp) GetResponseTime added in v0.8.12 

func (m *ScoreDisResp) GetResponseTime() time.Time

func (*ScoreDisResp) Marshal added in v0.8.12 

func (m *ScoreDisResp) Marshal() (dAtA []byte, err error)

func (*ScoreDisResp) MarshalTo added in v0.8.12 

func (m *ScoreDisResp) MarshalTo(dAtA []byte) (int, error)

func (*ScoreDisResp) MarshalToSizedBuffer added in v0.8.12 

func (m *ScoreDisResp) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ScoreDisResp) ProtoMessage added in v0.8.12 

func (*ScoreDisResp) ProtoMessage()

func (*ScoreDisResp) Reset added in v0.8.12 

func (m *ScoreDisResp) Reset()

func (*ScoreDisResp) Size added in v0.8.12 

func (m *ScoreDisResp) Size() (n int)

func (*ScoreDisResp) String added in v0.8.12 

func (m *ScoreDisResp) String() string

func (*ScoreDisResp) Unmarshal added in v0.8.12 

func (m *ScoreDisResp) Unmarshal(dAtA []byte) error

func (*ScoreDisResp) XXX_DiscardUnknown added in v0.8.12 

func (m *ScoreDisResp) XXX_DiscardUnknown()

func (*ScoreDisResp) XXX_Marshal added in v0.8.12 

func (m *ScoreDisResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ScoreDisResp) XXX_Merge added in v0.8.12 

func (m *ScoreDisResp) XXX_Merge(src proto.Message)

func (*ScoreDisResp) XXX_MessageName added in v0.8.12 

func (*ScoreDisResp) XXX_MessageName() string

func (*ScoreDisResp) XXX_Size added in v0.8.12 

func (m *ScoreDisResp) XXX_Size() int

func (*ScoreDisResp) XXX_Unmarshal added in v0.8.12 

func (m *ScoreDisResp) 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) MarshalTo 

func (m *SettingsData) MarshalTo(dAtA []byte) (int, 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"`
	NewVersion           HubRouter `` /* 128-byte string literal not displayed */
	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) GetNewVersion added in v0.8.10 

func (m *SettingsReq) GetNewVersion() HubRouter

func (*SettingsReq) GetRespSize 

func (m *SettingsReq) GetRespSize() int32

func (*SettingsReq) Marshal 

func (m *SettingsReq) Marshal() (dAtA []byte, err error)

func (*SettingsReq) MarshalTo 

func (m *SettingsReq) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *SettingsResp) MarshalTo(dAtA []byte) (int, 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"`
	NewVersion           HubRouter `` /* 128-byte string literal not displayed */
	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) Descriptor() ([]byte, []int)

func (*StatsReq) GetId added in v0.2.27 

func (m *StatsReq) GetId() string

func (*StatsReq) GetNewVersion added in v0.8.10 

func (m *StatsReq) GetNewVersion() HubRouter

func (*StatsReq) Marshal added in v0.2.27 

func (m *StatsReq) Marshal() (dAtA []byte, err error)

func (*StatsReq) MarshalTo added in v0.2.27 

func (m *StatsReq) MarshalTo(dAtA []byte) (int, error)

func (*StatsReq) MarshalToSizedBuffer added in v0.2.27 

func (m *StatsReq) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StatsReq) ProtoMessage added in v0.2.27 

func (*StatsReq) ProtoMessage()

func (*StatsReq) Reset added in v0.2.27 

func (m *StatsReq) Reset()

func (*StatsReq) Size added in v0.2.27 

func (m *StatsReq) Size() (n int)

func (*StatsReq) String added in v0.2.27 

func (m *StatsReq) String() string

func (*StatsReq) Unmarshal added in v0.2.27 

func (m *StatsReq) Unmarshal(dAtA []byte) error

func (*StatsReq) XXX_DiscardUnknown added in v0.2.27 

func (m *StatsReq) XXX_DiscardUnknown()

func (*StatsReq) XXX_Marshal added in v0.2.27 

func (m *StatsReq) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StatsReq) XXX_Merge added in v0.2.27 

func (m *StatsReq) XXX_Merge(src proto.Message)

func (*StatsReq) XXX_MessageName added in v0.2.27 

func (*StatsReq) XXX_MessageName() string

func (*StatsReq) XXX_Size added in v0.2.27 

func (m *StatsReq) XXX_Size() int

func (*StatsReq) XXX_Unmarshal added in v0.2.27 

func (m *StatsReq) XXX_Unmarshal(b []byte) error

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) Descriptor() ([]byte, []int)

func (*StatsResp) GetCode added in v0.2.27 

func (m *StatsResp) GetCode() ResponseCode

func (*StatsResp) GetMessage added in v0.2.27 

func (m *StatsResp) GetMessage() string

func (*StatsResp) GetResponseTime added in v0.2.27 

func (m *StatsResp) GetResponseTime() time.Time

func (*StatsResp) Marshal added in v0.2.27 

func (m *StatsResp) Marshal() (dAtA []byte, err error)

func (*StatsResp) MarshalTo added in v0.2.27 

func (m *StatsResp) MarshalTo(dAtA []byte) (int, error)

func (*StatsResp) MarshalToSizedBuffer added in v0.2.27 

func (m *StatsResp) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StatsResp) ProtoMessage added in v0.2.27 

func (*StatsResp) ProtoMessage()

func (*StatsResp) Reset added in v0.2.27 

func (m *StatsResp) Reset()

func (*StatsResp) Size added in v0.2.27 

func (m *StatsResp) Size() (n int)

func (*StatsResp) String added in v0.2.27 

func (m *StatsResp) String() string

func (*StatsResp) Unmarshal added in v0.2.27 

func (m *StatsResp) Unmarshal(dAtA []byte) error

func (*StatsResp) XXX_DiscardUnknown added in v0.2.27 

func (m *StatsResp) XXX_DiscardUnknown()

func (*StatsResp) XXX_Marshal added in v0.2.27 

func (m *StatsResp) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StatsResp) XXX_Merge added in v0.2.27 

func (m *StatsResp) XXX_Merge(src proto.Message)

func (*StatsResp) XXX_MessageName added in v0.2.27 

func (*StatsResp) XXX_MessageName() string

func (*StatsResp) XXX_Size added in v0.2.27 

func (m *StatsResp) XXX_Size() int

func (*StatsResp) XXX_Unmarshal added in v0.2.27 

func (m *StatsResp) XXX_Unmarshal(b []byte) error

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) UpdateBtfsScan(ctx context.Context, req *ParseReq) (*ParseResp, error)

func (*UnimplementedHubParseServiceServer) UpdateDiscovery added in v0.4.0 

func (*UnimplementedHubParseServiceServer) UpdateDiscovery(ctx context.Context, req *ParseReq) (*ParseResp, error)

func (*UnimplementedHubParseServiceServer) UpdateNetwork added in v0.4.0 

func (*UnimplementedHubParseServiceServer) UpdateNetwork(ctx context.Context, req *ParseReq) (*ParseResp, error)

func (*UnimplementedHubParseServiceServer) UpdateScore added in v0.4.0 

func (*UnimplementedHubParseServiceServer) UpdateScore(ctx context.Context, req *ParseReq) (*ParseResp, error)

func (*UnimplementedHubParseServiceServer) UpdateScoreHistory added in v0.7.15 

func (*UnimplementedHubParseServiceServer) UpdateScoreHistory(ctx context.Context, req *ParseReq) (*ParseResp, error)

type UnimplementedHubQueryServiceServer added in v0.1.8 

type UnimplementedHubQueryServiceServer struct {
}

UnimplementedHubQueryServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedHubQueryServiceServer) GetHosts added in v0.1.8 

func (*UnimplementedHubQueryServiceServer) GetHosts(ctx context.Context, req *HostsReq) (*HostsResp, error)

func (*UnimplementedHubQueryServiceServer) GetHostsByRoles added in v0.5.22 

func (*UnimplementedHubQueryServiceServer) GetHostsByRoles(ctx context.Context, req *RolesHostsReq) (*HostsResp, error)

func (*UnimplementedHubQueryServiceServer) GetScoreDistribution added in v0.8.12 

func (*UnimplementedHubQueryServiceServer) GetScoreDistribution(ctx context.Context, req *ScoreDisReq) (*ScoreDisResp, error)

func (*UnimplementedHubQueryServiceServer) GetSettings added in v0.1.8 

func (*UnimplementedHubQueryServiceServer) GetSettings(ctx context.Context, req *SettingsReq) (*SettingsResp, error)

func (*UnimplementedHubQueryServiceServer) GetStats added in v0.2.27 

func (*UnimplementedHubQueryServiceServer) GetStats(ctx context.Context, req *StatsReq) (*StatsResp, error)

func (*UnimplementedHubQueryServiceServer) QueryNodes added in v0.4.4 

func (*UnimplementedHubQueryServiceServer) QueryNodes(ctx context.Context, req *NodesReq) (*HostsResp, error)

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.