hub

package
v0.3.6 Latest Latest
Warning

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

 Go to latest Published: Apr 7, 2020 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 ResponseCode_name = map[int32]string{
	0:  "SUCCESS",
	1:  "SIGNATURE_FORMAT_ERROR",
	2:  "COMPUTE_ADDRESS_ERROR",
	20: "OTHER_ERROR",
}
View Source 
var ResponseCode_value = map[string]int32{
	"SUCCESS":                0,
	"SIGNATURE_FORMAT_ERROR": 1,
	"COMPUTE_ADDRESS_ERROR":  2,
	"OTHER_ERROR":            20,
}

Functions

func RegisterHubQueryServiceServer added in v0.1.8 

func RegisterHubQueryServiceServer(s *grpc.Server, srv HubQueryServiceServer)

Types

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"`
	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) GetAge 

func (m *Host) GetAge() uint64

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) GetDownloadVariance added in v0.1.6 

func (m *Host) GetDownloadVariance() float32

func (*Host) GetHeartBeats 

func (m *Host) GetHeartBeats() 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) GetReputation 

func (m *Host) GetReputation() float32

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) GetUploadVariance added in v0.1.6 

func (m *Host) GetUploadVariance() float32

func (*Host) GetUptime 

func (m *Host) GetUptime() 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"`
	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) GetRespSize 

func (m *HostsReq) GetRespSize() int32

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 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)
}

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)
}

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) 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 ResponseCode 

type ResponseCode int32
const (
	ResponseCode_SUCCESS                ResponseCode = 0
	ResponseCode_SIGNATURE_FORMAT_ERROR ResponseCode = 1
	ResponseCode_COMPUTE_ADDRESS_ERROR  ResponseCode = 2
	ResponseCode_OTHER_ERROR            ResponseCode = 20
)

func (ResponseCode) EnumDescriptor 

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

func (ResponseCode) String 

func (x ResponseCode) String() string

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"`
	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) 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"`
	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) 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"`
	Uptime               float32      `protobuf:"fixed32,3,opt,name=uptime,proto3" json:"uptime,omitempty" pg:"uptime"`
	Score                float32      `protobuf:"fixed32,4,opt,name=score,proto3" json:"score,omitempty" pg:"score"`
	ResponseTime         time.Time    `protobuf:"bytes,5,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 (*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) GetScore added in v0.2.27 

func (m *StatsResp) GetScore() float32

func (*StatsResp) GetUptime added in v0.2.27 

func (m *StatsResp) GetUptime() float32

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 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) 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)

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.