Documentation ¶
Index ¶
- Variables
- func RegisterHubQueryServiceServer(s *grpc.Server, srv HubQueryServiceServer)
- type Host
- func (*Host) Descriptor() ([]byte, []int)
- func (m *Host) GetAge() uint64
- 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) GetDownloadAverage() 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) 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) GetUploadVariance() float32
- func (m *Host) GetUptime() 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 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 ResponseCode
- 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 UnimplementedHubQueryServiceServer
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"` XXX_NoUnkeyedLiteral struct{} `json:"-" pg:"-"` XXX_unrecognized []byte `json:"-" pg:"-"` XXX_sizecache int32 `json:"-" pg:"-"` }
func (*Host) Descriptor ¶
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) GetDownloadAverage ¶ added in v0.1.6
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) GetUploadVariance ¶ added in v0.1.6
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 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) }
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) }
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 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) 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 UnimplementedHubQueryServiceServer ¶ added in v0.1.8
type UnimplementedHubQueryServiceServer struct { }
UnimplementedHubQueryServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedHubQueryServiceServer) GetSettings ¶ added in v0.1.8
func (*UnimplementedHubQueryServiceServer) GetSettings(ctx context.Context, req *SettingsReq) (*SettingsResp, error)
Click to show internal directories.
Click to hide internal directories.