sonm

package
v0.4.31 Latest Latest
Warning

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

 Go to latest Published: May 15, 2020 License: GPL-3.0 Imports: 30 Imported by: 13

Documentation

Overview

Package sonm is a generated protocol buffer package.

It is generated from these files: 

ask_plan.proto
benchmarks.proto
bigint.proto
capabilities.proto
container.proto
dwh.proto
geoip.proto
gpu_ctl.proto
init.proto
insonmnia.proto
inspect.proto
marketplace.proto
net.proto
node.proto
optimus.proto
pty.proto
relay.proto
rendezvous.proto
tc.proto
timestamp.proto
volume.proto
worker.proto

It has these top-level messages: 

AskPlanCPU
AskPlanGPU
AskPlanRAM
AskPlanStorage
AskPlanNetwork
AskPlanResources
AskPlan
Benchmark
BigInt
CPUDevice
CPU
RAMDevice
RAM
GPUDevice
GPU
NetFlags
Network
StorageDevice
Storage
Registry
ContainerRestartPolicy
NetworkSpec
Container
SortingOption
DealsRequest
DWHDealsReply
DWHDeal
DealConditionsRequest
DealConditionsReply
OrdersRequest
MatchingOrdersRequest
DWHOrdersReply
DWHOrder
DealCondition
DWHWorker
ProfilesRequest
ProfilesReply
Profile
BlacklistRequest
BlacklistReply
BlacklistsContainingUserReply
ValidatorsRequest
ValidatorsReply
DWHValidator
Validator
DealChangeRequestsReply
DealChangeRequest
DealPayment
ChangeRequestsRequest
WorkersRequest
WorkersReply
Certificate
MaxMinUint64
MaxMinBig
MaxMinTimestamp
CmpUint64
BlacklistQuery
DWHStatsReply
OrdersByIDsRequest
GeoIPCountry
GeoIP
RemoteGPUDeviceRequest
RemoteGPUDeviceReply
InitMountRequest
InitMountResponse
Empty
ID
NumericID
EthID
TaskID
Count
CPUUsage
MemoryUsage
NetworkUsage
ResourceUsage
TaskLogsRequest
TaskLogsChunk
Chunk
Progress
Duration
EthAddress
DataSize
DataSizeRate
Price
InspectConfigRequest
InspectConfigResponse
InspectOpenFilesRequest
InspectOpenFilesResponse
FileStat
InspectNetworkRequest
InspectNetworkResponse
InterfaceStat
ConnectionStat
InspectDockerInfoRequest
InspectDockerInfoResponse
InspectDockerNetworkRequest
InspectDockerNetworkResponse
InspectDockerVolumesRequest
InspectDockerVolumesResponse
InspectHostInfoRequest
InspectHostInfoResponse
InspectWatchLogsRequest
InspectWatchLogsChunk
ErrorByID
ErrorByStringID
OrderIDs
GetOrdersReply
Benchmarks
Deal
Order
BidNetwork
BidResources
BidOrder
Addr
SocketAddr
Endpoints
JoinNetworkRequest
TaskListRequest
QuickBuyRequest
DealFinishRequest
DealsFinishRequest
DealsPurgeRequest
DealsReply
OpenDealRequest
WorkerRemoveRequest
WorkerListReply
BalanceReply
TokenTransferRequest
NPPMetricsReply
NamedMetrics
NamedMetric
PredictSupplierRequest
PredictSupplierReply
RemotePTYBannerRequest
RemotePTYBannerResponse
RemotePTYExecRequest
RemotePTYExecResponseChunk
HandshakeRequest
DiscoverResponse
HandshakeResponse
RelayClusterReply
RelayMetrics
NetMetrics
RelayInfo
RelayMeeting
ConnectRequest
PublishRequest
RendezvousReply
RendezvousState
RendezvousMeeting
ResolveMetaReply
QOSSetAliasRequest
QOSSetAliasResponse
QOSAddHTBShapingRequest
QOSAddHTBShapingResponse
QOSRemoveHTBShapingRequest
QOSRemoveHTBShapingResponse
QOSFlushRequest
QOSFlushResponse
Timestamp
Volume
TaskTag
TaskSpec
StartTaskRequest
WorkerJoinNetworkRequest
StartTaskReply
StatusReply
AskPlansReply
TaskListReply
DevicesReply
PullTaskRequest
DealInfoReply
TaskStatusReply
TaskPool
AskPlanPool
SchedulerData
SalesmanData
DebugStateReply
PurgeTasksRequest
WorkerMetricsRequest
WorkerMetricsResponse
WorkerAddCapabilityRequest
WorkerAddCapabilityResponse
WorkerRemoveCapabilityRequest
WorkerRemoveCapabilityResponse

Index

Constants

View Source 
const (
	MinCPUPercent  = 1
	MinRamSize     = 4 * 1 << 20
	MinStorageSize = 64 * 1 << 20
)
View Source 
const (
	MinNetFlagsCount = 3

	NetworkOverlay  = uint64(0x1)
	NetworkOutbound = uint64(0x2)
	NetworkIncoming = uint64(0x4)
)
View Source 
const (
	MinNumBenchmarks = 12
	MinDealDuration  = time.Minute * 10
	MaxTagLength     = 32
)
View Source 
const (
	MetricsKeyDiskFree        = "disk_free"
	MetricsKeyDiskFreePercent = "disk_free_percent"
	MetricsKeyDiskTotal       = "disk_total"
	MetricsKeyRAMFree         = "ram_free"
	MetricsKeyRAMFreePercent  = "ram_free_percent"
	MetricsKeyRAMTotal        = "ram_total"
	MetricsKeyCPUUtilization  = "cpu_utilization"
	MetricsKeyGPUPrefix       = "gpu"
	MetricsKeyGPUTemperature  = "temp"
	MetricsKeyGPUFan          = "fan"
	MetricsKeyGPUPower        = "power"
)
View Source 
const (
	DefaultNPPProtocol = "tcp" // Equals to "tcp+grpc".
)

Variables

View Source 
var AskPlan_Status_name = map[int32]string{
	0: "ACTIVE",
	1: "PENDING_DELETION",
}
View Source 
var AskPlan_Status_value = map[string]int32{
	"ACTIVE":           0,
	"PENDING_DELETION": 1,
}
View Source 
var BlacklistOption_name = map[int32]string{
	0: "WithoutMatching",
	1: "IncludeAndMark",
	2: "OnlyMatching",
}
View Source 
var BlacklistOption_value = map[string]int32{
	"WithoutMatching": 0,
	"IncludeAndMark":  1,
	"OnlyMatching":    2,
}
View Source 
var BlacklistType_name = map[int32]string{
	0: "BLACKLIST_NOBODY",
	1: "BLACKLIST_WORKER",
	2: "BLACKLIST_MASTER",
}
View Source 
var BlacklistType_value = map[string]int32{
	"BLACKLIST_NOBODY": 0,
	"BLACKLIST_WORKER": 1,
	"BLACKLIST_MASTER": 2,
}
View Source 
var CapabilityScope_name = map[int32]string{
	0: "CAPABILITY_NONE",
	1: "CAPABILITY_SSH",
	2: "CAPABILITY_INSPECTION",
}
View Source 
var CapabilityScope_value = map[string]int32{
	"CAPABILITY_NONE":       0,
	"CAPABILITY_SSH":        1,
	"CAPABILITY_INSPECTION": 2,
}
View Source 
var ChangeRequestStatus_name = map[int32]string{
	0: "REQUEST_UNKNOWN",
	1: "REQUEST_CREATED",
	2: "REQUEST_CANCELED",
	3: "REQUEST_REJECTED",
	4: "REQUEST_ACCEPTED",
}
View Source 
var ChangeRequestStatus_value = map[string]int32{
	"REQUEST_UNKNOWN":  0,
	"REQUEST_CREATED":  1,
	"REQUEST_CANCELED": 2,
	"REQUEST_REJECTED": 3,
	"REQUEST_ACCEPTED": 4,
}
View Source 
var CmpOp_name = map[int32]string{
	0: "EQ",
	1: "GTE",
	2: "LTE",
}
View Source 
var CmpOp_value = map[string]int32{
	"EQ":  0,
	"GTE": 1,
	"LTE": 2,
}
View Source 
var DealStatus_name = map[int32]string{
	0: "DEAL_UNKNOWN",
	1: "DEAL_ACCEPTED",
	2: "DEAL_CLOSED",
}
View Source 
var DealStatus_value = map[string]int32{
	"DEAL_UNKNOWN":  0,
	"DEAL_ACCEPTED": 1,
	"DEAL_CLOSED":   2,
}
View Source 
var DeviceType_name = map[int32]string{
	0: "DEV_UNKNOWN",
	1: "DEV_CPU",
	2: "DEV_GPU",
	3: "DEV_RAM",
	4: "DEV_STORAGE",
	5: "DEV_NETWORK_IN",
	6: "DEV_NETWORK_OUT",
}
View Source 
var DeviceType_value = map[string]int32{
	"DEV_UNKNOWN":     0,
	"DEV_CPU":         1,
	"DEV_GPU":         2,
	"DEV_RAM":         3,
	"DEV_STORAGE":     4,
	"DEV_NETWORK_IN":  5,
	"DEV_NETWORK_OUT": 6,
}
View Source 
var GPUVendorType_name = map[int32]string{
	0:   "GPU_UNKNOWN",
	1:   "NVIDIA",
	2:   "RADEON",
	99:  "FAKE",
	100: "REMOTE",
}
View Source 
var GPUVendorType_value = map[string]int32{
	"GPU_UNKNOWN": 0,
	"NVIDIA":      1,
	"RADEON":      2,
	"FAKE":        99,
	"REMOTE":      100,
}
View Source 
var IdentityLevel_name = map[int32]string{
	0: "UNKNOWN",
	1: "ANONYMOUS",
	2: "REGISTERED",
	3: "IDENTIFIED",
	4: "PROFESSIONAL",
}
View Source 
var IdentityLevel_value = map[string]int32{
	"UNKNOWN":      0,
	"ANONYMOUS":    1,
	"REGISTERED":   2,
	"IDENTIFIED":   3,
	"PROFESSIONAL": 4,
}
View Source 
var Nvidias = []uint64{
	4318,
}
View Source 
var OrderStatus_name = map[int32]string{
	0: "ORDER_UNKNOWN",
	1: "ORDER_INACTIVE",
	2: "ORDER_ACTIVE",
}
View Source 
var OrderStatus_value = map[string]int32{
	"ORDER_UNKNOWN":  0,
	"ORDER_INACTIVE": 1,
	"ORDER_ACTIVE":   2,
}
View Source 
var OrderType_name = map[int32]string{
	0: "ANY",
	1: "BID",
	2: "ASK",
}
View Source 
var OrderType_value = map[string]int32{
	"ANY": 0,
	"BID": 1,
	"ASK": 2,
}
View Source 
var PeerType_name = map[int32]string{
	0: "SERVER",
	1: "CLIENT",
	2: "DISCOVER",
}
View Source 
var PeerType_value = map[string]int32{
	"SERVER":   0,
	"CLIENT":   1,
	"DISCOVER": 2,
}
View Source 
var ProfileRole_name = map[int32]string{
	0: "AnyRole",
	1: "Supplier",
	2: "Consumer",
}
View Source 
var ProfileRole_value = map[string]int32{
	"AnyRole":  0,
	"Supplier": 1,
	"Consumer": 2,
}
View Source 
var Radeons = []uint64{
	4098,

	16915456,
}
View Source 
var SortingOrder_name = map[int32]string{
	0: "Asc",
	1: "Desc",
}
View Source 
var SortingOrder_value = map[string]int32{
	"Asc":  0,
	"Desc": 1,
}
View Source 
var SplittingAlgorithm_name = map[int32]string{
	0: "NONE",
	1: "PROPORTIONAL",
	2: "MIN",
	3: "MAX",
}
View Source 
var SplittingAlgorithm_value = map[string]int32{
	"NONE":         0,
	"PROPORTIONAL": 1,
	"MIN":          2,
	"MAX":          3,
}
View Source 
var TaskLogsRequest_Type_name = map[int32]string{
	0: "STDOUT",
	1: "STDERR",
	2: "BOTH",
}
View Source 
var TaskLogsRequest_Type_value = map[string]int32{
	"STDOUT": 0,
	"STDERR": 1,
	"BOTH":   2,
}
View Source 
var TaskStatusReply_Status_name = map[int32]string{
	0: "UNKNOWN",
	1: "SPOOLING",
	2: "SPAWNING",
	3: "RUNNING",
	4: "FINISHED",
	5: "BROKEN",
	6: "KILLED_OOM",
}
View Source 
var TaskStatusReply_Status_value = map[string]int32{
	"UNKNOWN":    0,
	"SPOOLING":   1,
	"SPAWNING":   2,
	"RUNNING":    3,
	"FINISHED":   4,
	"BROKEN":     5,
	"KILLED_OOM": 6,
}

Functions

func CombinedError added in v0.4.10 

func CombinedError(status *ErrorByID) error

func FormatAddrs added in v0.4.20 

func FormatAddrs(addrs ...*Addr) string

func IsTaskStatusTerminated added in v0.4.26 

func IsTaskStatusTerminated(status TaskStatusReply_Status) bool

func NewLogReader added in v0.4.10 

func NewLogReader(client TaskManagement_LogsClient) io.Reader

func RegisterBlacklistServer added in v0.4.1 

func RegisterBlacklistServer(s *grpc.Server, srv BlacklistServer)

func RegisterDWHServer added in v0.4.1 

func RegisterDWHServer(s *grpc.Server, srv DWHServer)

func RegisterDealManagementServer 

func RegisterDealManagementServer(s *grpc.Server, srv DealManagementServer)

func RegisterInitServer added in v0.4.29 

func RegisterInitServer(s *grpc.Server, srv InitServer)

func RegisterInspectServer added in v0.4.21 

func RegisterInspectServer(s *grpc.Server, srv InspectServer)

func RegisterMarketServer 

func RegisterMarketServer(s *grpc.Server, srv MarketServer)

func RegisterMasterManagementServer added in v0.4.1 

func RegisterMasterManagementServer(s *grpc.Server, srv MasterManagementServer)

func RegisterMonitoringServer added in v0.4.11 

func RegisterMonitoringServer(s *grpc.Server, srv MonitoringServer)

func RegisterOrderPredictorServer added in v0.4.10 

func RegisterOrderPredictorServer(s *grpc.Server, srv OrderPredictorServer)

func RegisterProfilesServer added in v0.4.1 

func RegisterProfilesServer(s *grpc.Server, srv ProfilesServer)

func RegisterQOSServer added in v0.4.21 

func RegisterQOSServer(s *grpc.Server, srv QOSServer)

func RegisterRelayServer added in v0.4.1 

func RegisterRelayServer(s *grpc.Server, srv RelayServer)

func RegisterRemoteGPUTunerServer added in v0.4.25 

func RegisterRemoteGPUTunerServer(s *grpc.Server, srv RemoteGPUTunerServer)

func RegisterRemotePTYServer added in v0.4.30 

func RegisterRemotePTYServer(s *grpc.Server, srv RemotePTYServer)

func RegisterRendezvousServer added in v0.4.1 

func RegisterRendezvousServer(s *grpc.Server, srv RendezvousServer)

func RegisterTaskManagementServer 

func RegisterTaskManagementServer(s *grpc.Server, srv TaskManagementServer)

func RegisterTokenManagementServer added in v0.4.1 

func RegisterTokenManagementServer(s *grpc.Server, srv TokenManagementServer)

func RegisterWorkerManagementServer added in v0.4.1 

func RegisterWorkerManagementServer(s *grpc.Server, srv WorkerManagementServer)

func RegisterWorkerServer added in v0.4.1 

func RegisterWorkerServer(s *grpc.Server, srv WorkerServer)

Types

type Addr added in v0.4.1 

type Addr struct {
	// Protocol describes the underlying transport protocol, for example "tcp"
	// or "udp".
	Protocol string      `protobuf:"bytes,1,opt,name=protocol" json:"protocol,omitempty"`
	Addr     *SocketAddr `protobuf:"bytes,2,opt,name=addr" json:"addr,omitempty"`
}

func NewAddr added in v0.4.1 

func NewAddr(addr net.Addr) (*Addr, error)

func TransformNetAddrs added in v0.4.20 

func TransformNetAddrs(addrs []net.Addr) ([]*Addr, error)

func (*Addr) Descriptor added in v0.4.1 

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

func (*Addr) GetAddr added in v0.4.1 

func (m *Addr) GetAddr() *SocketAddr

func (*Addr) GetProtocol added in v0.4.1 

func (m *Addr) GetProtocol() string

func (*Addr) IntoTCP added in v0.4.1 

func (m *Addr) IntoTCP() (net.Addr, error)

func (*Addr) IntoUDP added in v0.4.17 

func (m *Addr) IntoUDP() (*net.UDPAddr, error)

func (*Addr) IsPrivate added in v0.4.1 

func (m *Addr) IsPrivate() bool

IsPrivate returns true if this address can't be reached from the Internet directly.

func (*Addr) IsValid added in v0.4.1 

func (m *Addr) IsValid() bool

func (*Addr) ProtoMessage added in v0.4.1 

func (*Addr) ProtoMessage()

func (*Addr) Reset added in v0.4.1 

func (m *Addr) Reset()

func (*Addr) String added in v0.4.1 

func (m *Addr) String() string

type AskPlan added in v0.4.1 

type AskPlan struct {
	ID                  string            `protobuf:"bytes,1,opt,name=ID" json:"ID,omitempty"`
	OrderID             *BigInt           `protobuf:"bytes,2,opt,name=orderID" json:"orderID,omitempty"`
	DealID              *BigInt           `protobuf:"bytes,3,opt,name=dealID" json:"dealID,omitempty"`
	Duration            *Duration         `protobuf:"bytes,4,opt,name=duration" json:"duration,omitempty"`
	Price               *Price            `protobuf:"bytes,5,opt,name=price" json:"price,omitempty"`
	Blacklist           *EthAddress       `protobuf:"bytes,6,opt,name=blacklist" json:"blacklist,omitempty"`
	Counterparty        *EthAddress       `protobuf:"bytes,7,opt,name=counterparty" json:"counterparty,omitempty"`
	Identity            IdentityLevel     `protobuf:"varint,8,opt,name=identity,enum=sonm.IdentityLevel" json:"identity,omitempty"`
	Tag                 []byte            `protobuf:"bytes,9,opt,name=tag,proto3" json:"tag,omitempty"`
	Resources           *AskPlanResources `protobuf:"bytes,10,opt,name=resources" json:"resources,omitempty"`
	Status              AskPlan_Status    `protobuf:"varint,11,opt,name=status,enum=sonm.AskPlan_Status" json:"status,omitempty"`
	CreateTime          *Timestamp        `protobuf:"bytes,12,opt,name=createTime" json:"createTime,omitempty"`
	LastOrderPlacedTime *Timestamp        `protobuf:"bytes,13,opt,name=lastOrderPlacedTime" json:"lastOrderPlacedTime,omitempty"`
}

func (*AskPlan) Descriptor added in v0.4.1 

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

func (*AskPlan) GetBlacklist added in v0.4.1 

func (m *AskPlan) GetBlacklist() *EthAddress

func (*AskPlan) GetCounterparty added in v0.4.1 

func (m *AskPlan) GetCounterparty() *EthAddress

func (*AskPlan) GetCreateTime added in v0.4.1 

func (m *AskPlan) GetCreateTime() *Timestamp

func (*AskPlan) GetDealID added in v0.4.1 

func (m *AskPlan) GetDealID() *BigInt

func (*AskPlan) GetDuration added in v0.4.1 

func (m *AskPlan) GetDuration() *Duration

func (*AskPlan) GetID added in v0.4.1 

func (m *AskPlan) GetID() string

func (*AskPlan) GetIdentity added in v0.4.1 

func (m *AskPlan) GetIdentity() IdentityLevel

func (*AskPlan) GetLastOrderPlacedTime added in v0.4.1 

func (m *AskPlan) GetLastOrderPlacedTime() *Timestamp

func (*AskPlan) GetOrderID added in v0.4.1 

func (m *AskPlan) GetOrderID() *BigInt

func (*AskPlan) GetPrice added in v0.4.1 

func (m *AskPlan) GetPrice() *Price

func (*AskPlan) GetResources added in v0.4.1 

func (m *AskPlan) GetResources() *AskPlanResources

func (*AskPlan) GetStatus added in v0.4.1 

func (m *AskPlan) GetStatus() AskPlan_Status

func (*AskPlan) GetTag added in v0.4.1 

func (m *AskPlan) GetTag() []byte

func (*AskPlan) IsSpot added in v0.4.13 

func (m *AskPlan) IsSpot() bool

func (*AskPlan) ProtoMessage added in v0.4.1 

func (*AskPlan) ProtoMessage()

func (*AskPlan) Reset added in v0.4.1 

func (m *AskPlan) Reset()

func (*AskPlan) String added in v0.4.1 

func (m *AskPlan) String() string

func (*AskPlan) UnsoldDuration added in v0.4.1 

func (m *AskPlan) UnsoldDuration() time.Duration

func (*AskPlan) Validate added in v0.4.1 

func (m *AskPlan) Validate() error

type AskPlanCPU added in v0.4.1 

type AskPlanCPU struct {
	CorePercents uint64 `protobuf:"varint,1,opt,name=core_percents,json=corePercents" json:"core_percents,omitempty"`
}

func (*AskPlanCPU) Descriptor added in v0.4.1 

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

func (*AskPlanCPU) GetCorePercents added in v0.4.1 

func (m *AskPlanCPU) GetCorePercents() uint64

func (*AskPlanCPU) MarshalYAML added in v0.4.1 

func (c *AskPlanCPU) MarshalYAML() (interface{}, error)

func (*AskPlanCPU) ProtoMessage added in v0.4.1 

func (*AskPlanCPU) ProtoMessage()

func (*AskPlanCPU) Reset added in v0.4.1 

func (m *AskPlanCPU) Reset()

func (*AskPlanCPU) String added in v0.4.1 

func (m *AskPlanCPU) String() string

func (*AskPlanCPU) UnmarshalYAML added in v0.4.1 

func (c *AskPlanCPU) UnmarshalYAML(unmarshal func(interface{}) error) error

type AskPlanGPU added in v0.4.1 

type AskPlanGPU struct {
	Indexes []uint64 `protobuf:"varint,1,rep,packed,name=indexes" json:"indexes,omitempty"`
	Hashes  []string `protobuf:"bytes,2,rep,name=hashes" json:"hashes,omitempty"`
}

func (*AskPlanGPU) Add added in v0.4.1 

func (m *AskPlanGPU) Add(other *AskPlanGPU) error

func (*AskPlanGPU) Contains added in v0.4.1 

func (m *AskPlanGPU) Contains(other *AskPlanGPU) bool

func (*AskPlanGPU) Descriptor added in v0.4.1 

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

func (*AskPlanGPU) GetHashes added in v0.4.1 

func (m *AskPlanGPU) GetHashes() []string

func (*AskPlanGPU) GetIndexes added in v0.4.1 

func (m *AskPlanGPU) GetIndexes() []uint64

func (*AskPlanGPU) Normalize added in v0.4.1 

func (m *AskPlanGPU) Normalize(hasher GPUHasher) error

func (*AskPlanGPU) Normalized added in v0.4.1 

func (m *AskPlanGPU) Normalized() bool

func (*AskPlanGPU) ProtoMessage added in v0.4.1 

func (*AskPlanGPU) ProtoMessage()

func (*AskPlanGPU) Reset added in v0.4.1 

func (m *AskPlanGPU) Reset()

func (*AskPlanGPU) String added in v0.4.1 

func (m *AskPlanGPU) String() string

func (*AskPlanGPU) Sub added in v0.4.1 

func (m *AskPlanGPU) Sub(other *AskPlanGPU) error

func (*AskPlanGPU) SubAtMost added in v0.4.13 

func (m *AskPlanGPU) SubAtMost(other *AskPlanGPU) error

func (*AskPlanGPU) Validate added in v0.4.1 

func (m *AskPlanGPU) Validate() error

type AskPlanHasher added in v0.4.1 

type AskPlanHasher struct {
	*AskPlanResources
}

func (*AskPlanHasher) HashGPU added in v0.4.1 

func (m *AskPlanHasher) HashGPU(indexes []uint64) ([]string, error)

type AskPlanNetwork added in v0.4.1 

type AskPlanNetwork struct {
	ThroughputIn  *DataSizeRate `protobuf:"bytes,1,opt,name=throughputIn" json:"throughputIn,omitempty"`
	ThroughputOut *DataSizeRate `protobuf:"bytes,2,opt,name=throughputOut" json:"throughputOut,omitempty"`
	NetFlags      *NetFlags     `protobuf:"bytes,3,opt,name=netFlags" json:"netFlags,omitempty"`
}

func (*AskPlanNetwork) Descriptor added in v0.4.1 

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

func (*AskPlanNetwork) GetNetFlags added in v0.4.1 

func (m *AskPlanNetwork) GetNetFlags() *NetFlags

func (*AskPlanNetwork) GetThroughputIn added in v0.4.1 

func (m *AskPlanNetwork) GetThroughputIn() *DataSizeRate

func (*AskPlanNetwork) GetThroughputOut added in v0.4.1 

func (m *AskPlanNetwork) GetThroughputOut() *DataSizeRate

func (*AskPlanNetwork) ProtoMessage added in v0.4.1 

func (*AskPlanNetwork) ProtoMessage()

func (*AskPlanNetwork) Reset added in v0.4.1 

func (m *AskPlanNetwork) Reset()

func (*AskPlanNetwork) String added in v0.4.1 

func (m *AskPlanNetwork) String() string

func (*AskPlanNetwork) UnmarshalYAML added in v0.4.1 

func (m *AskPlanNetwork) UnmarshalYAML(unmarshal func(interface{}) error) error

type AskPlanPool added in v0.4.13 

type AskPlanPool struct {
	All          *AskPlanResources   `protobuf:"bytes,1,opt,name=all" json:"all,omitempty"`
	UsedSpot     map[string]*AskPlan `` /* 136-byte string literal not displayed */
	UsedFw       map[string]*AskPlan `` /* 132-byte string literal not displayed */
	CommitedSpot map[string]*AskPlan `` /* 144-byte string literal not displayed */
	CommitedFw   map[string]*AskPlan `` /* 140-byte string literal not displayed */
	EjectedPlans map[string]*AskPlan `` /* 144-byte string literal not displayed */
}

func (*AskPlanPool) Descriptor added in v0.4.13 

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

func (*AskPlanPool) GetAll added in v0.4.13 

func (m *AskPlanPool) GetAll() *AskPlanResources

func (*AskPlanPool) GetCommitedFw added in v0.4.13 

func (m *AskPlanPool) GetCommitedFw() map[string]*AskPlan

func (*AskPlanPool) GetCommitedSpot added in v0.4.13 

func (m *AskPlanPool) GetCommitedSpot() map[string]*AskPlan

func (*AskPlanPool) GetEjectedPlans added in v0.4.13 

func (m *AskPlanPool) GetEjectedPlans() map[string]*AskPlan

func (*AskPlanPool) GetUsedFw added in v0.4.13 

func (m *AskPlanPool) GetUsedFw() map[string]*AskPlan

func (*AskPlanPool) GetUsedSpot added in v0.4.13 

func (m *AskPlanPool) GetUsedSpot() map[string]*AskPlan

func (*AskPlanPool) ProtoMessage added in v0.4.13 

func (*AskPlanPool) ProtoMessage()

func (*AskPlanPool) Reset added in v0.4.13 

func (m *AskPlanPool) Reset()

func (*AskPlanPool) String added in v0.4.13 

func (m *AskPlanPool) String() string

type AskPlanRAM added in v0.4.1 

type AskPlanRAM struct {
	Size *DataSize `protobuf:"bytes,1,opt,name=size" json:"size,omitempty"`
}

func (*AskPlanRAM) Descriptor added in v0.4.1 

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

func (*AskPlanRAM) GetSize added in v0.4.1 

func (m *AskPlanRAM) GetSize() *DataSize

func (*AskPlanRAM) ProtoMessage added in v0.4.1 

func (*AskPlanRAM) ProtoMessage()

func (*AskPlanRAM) Reset added in v0.4.1 

func (m *AskPlanRAM) Reset()

func (*AskPlanRAM) String added in v0.4.1 

func (m *AskPlanRAM) String() string

type AskPlanResources added in v0.4.1 

type AskPlanResources struct {
	CPU     *AskPlanCPU     `protobuf:"bytes,1,opt,name=CPU" json:"CPU,omitempty"`
	RAM     *AskPlanRAM     `protobuf:"bytes,2,opt,name=RAM" json:"RAM,omitempty"`
	Storage *AskPlanStorage `protobuf:"bytes,3,opt,name=storage" json:"storage,omitempty"`
	GPU     *AskPlanGPU     `protobuf:"bytes,4,opt,name=GPU" json:"GPU,omitempty"`
	Network *AskPlanNetwork `protobuf:"bytes,5,opt,name=network" json:"network,omitempty"`
}

func NewEmptyAskPlanResources added in v0.4.1 

func NewEmptyAskPlanResources() *AskPlanResources

func (*AskPlanResources) Add added in v0.4.1 

func (m *AskPlanResources) Add(resources *AskPlanResources) error

func (*AskPlanResources) CPUQuota added in v0.4.1 

func (m *AskPlanResources) CPUQuota() int64

func (*AskPlanResources) CheckContains added in v0.4.1 

func (m *AskPlanResources) CheckContains(resources *AskPlanResources) error

func (*AskPlanResources) Descriptor added in v0.4.1 

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

func (*AskPlanResources) Eq added in v0.4.11 

func (m *AskPlanResources) Eq(resources *AskPlanResources) bool

func (*AskPlanResources) GetCPU added in v0.4.1 

func (m *AskPlanResources) GetCPU() *AskPlanCPU

func (*AskPlanResources) GetGPU added in v0.4.1 

func (m *AskPlanResources) GetGPU() *AskPlanGPU

func (*AskPlanResources) GetNetwork added in v0.4.1 

func (m *AskPlanResources) GetNetwork() *AskPlanNetwork

func (*AskPlanResources) GetRAM added in v0.4.1 

func (m *AskPlanResources) GetRAM() *AskPlanRAM

func (*AskPlanResources) GetStorage added in v0.4.1 

func (m *AskPlanResources) GetStorage() *AskPlanStorage

func (*AskPlanResources) ProtoMessage added in v0.4.1 

func (*AskPlanResources) ProtoMessage()

func (*AskPlanResources) Reset added in v0.4.1 

func (m *AskPlanResources) Reset()

func (*AskPlanResources) String added in v0.4.1 

func (m *AskPlanResources) String() string

func (*AskPlanResources) Sub added in v0.4.1 

func (m *AskPlanResources) Sub(resources *AskPlanResources) error

func (*AskPlanResources) SubAtMost added in v0.4.13 

func (m *AskPlanResources) SubAtMost(resources *AskPlanResources) error

This function substracts as much resources as it can

func (*AskPlanResources) ToCgroupResources added in v0.4.1 

func (m *AskPlanResources) ToCgroupResources() *specs.LinuxResources

func (*AskPlanResources) ToHostConfigResources added in v0.4.1 

func (m *AskPlanResources) ToHostConfigResources(cgroupParent string) container.Resources

type AskPlanStorage added in v0.4.1 

type AskPlanStorage struct {
	Size *DataSize `protobuf:"bytes,1,opt,name=size" json:"size,omitempty"`
}

func (*AskPlanStorage) Descriptor added in v0.4.1 

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

func (*AskPlanStorage) GetSize added in v0.4.1 

func (m *AskPlanStorage) GetSize() *DataSize

func (*AskPlanStorage) ProtoMessage added in v0.4.1 

func (*AskPlanStorage) ProtoMessage()

func (*AskPlanStorage) Reset added in v0.4.1 

func (m *AskPlanStorage) Reset()

func (*AskPlanStorage) String added in v0.4.1 

func (m *AskPlanStorage) String() string

type AskPlan_Status added in v0.4.1 

type AskPlan_Status int32
const (
	AskPlan_ACTIVE           AskPlan_Status = 0
	AskPlan_PENDING_DELETION AskPlan_Status = 1
)

func (AskPlan_Status) EnumDescriptor added in v0.4.1 

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

func (AskPlan_Status) String added in v0.4.1 

func (x AskPlan_Status) String() string

type AskPlansReply added in v0.4.1 

type AskPlansReply struct {
	AskPlans map[string]*AskPlan `` /* 136-byte string literal not displayed */
}

func (*AskPlansReply) Descriptor added in v0.4.1 

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

func (*AskPlansReply) GetAskPlans added in v0.4.1 

func (m *AskPlansReply) GetAskPlans() map[string]*AskPlan

func (*AskPlansReply) ProtoMessage added in v0.4.1 

func (*AskPlansReply) ProtoMessage()

func (*AskPlansReply) Reset added in v0.4.1 

func (m *AskPlansReply) Reset()

func (*AskPlansReply) String added in v0.4.1 

func (m *AskPlansReply) String() string

type BalanceReply added in v0.4.1 

type BalanceReply struct {
	LiveBalance    *BigInt `protobuf:"bytes,1,opt,name=liveBalance" json:"liveBalance,omitempty"`
	SideBalance    *BigInt `protobuf:"bytes,2,opt,name=sideBalance" json:"sideBalance,omitempty"`
	LiveEthBalance *BigInt `protobuf:"bytes,3,opt,name=liveEthBalance" json:"liveEthBalance,omitempty"`
}

func (*BalanceReply) Descriptor added in v0.4.1 

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

func (*BalanceReply) GetLiveBalance added in v0.4.1 

func (m *BalanceReply) GetLiveBalance() *BigInt

func (*BalanceReply) GetLiveEthBalance added in v0.4.5 

func (m *BalanceReply) GetLiveEthBalance() *BigInt

func (*BalanceReply) GetSideBalance added in v0.4.1 

func (m *BalanceReply) GetSideBalance() *BigInt

func (*BalanceReply) ProtoMessage added in v0.4.1 

func (*BalanceReply) ProtoMessage()

func (*BalanceReply) Reset added in v0.4.1 

func (m *BalanceReply) Reset()

func (*BalanceReply) String added in v0.4.1 

func (m *BalanceReply) String() string

type Benchmark added in v0.4.1 

type Benchmark struct {
	ID                 uint64             `protobuf:"varint,1,opt,name=ID" json:"ID,omitempty"`
	Code               string             `protobuf:"bytes,2,opt,name=code" json:"code,omitempty"`
	Type               DeviceType         `protobuf:"varint,3,opt,name=type,enum=sonm.DeviceType" json:"type,omitempty"`
	Description        string             `protobuf:"bytes,4,opt,name=description" json:"description,omitempty"`
	Image              string             `protobuf:"bytes,5,opt,name=image" json:"image,omitempty"`
	Result             uint64             `protobuf:"varint,6,opt,name=result" json:"result,omitempty"`
	SplittingAlgorithm SplittingAlgorithm `protobuf:"varint,7,opt,name=splittingAlgorithm,enum=sonm.SplittingAlgorithm" json:"splittingAlgorithm,omitempty"`
}

Benchmark describes a way to measure hardware performance

func (*Benchmark) Descriptor added in v0.4.1 

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

func (*Benchmark) GetCode added in v0.4.1 

func (m *Benchmark) GetCode() string

func (*Benchmark) GetDescription added in v0.4.1 

func (m *Benchmark) GetDescription() string

func (*Benchmark) GetID added in v0.4.1 

func (m *Benchmark) GetID() uint64

func (*Benchmark) GetImage added in v0.4.1 

func (m *Benchmark) GetImage() string

func (*Benchmark) GetResult added in v0.4.1 

func (m *Benchmark) GetResult() uint64

func (*Benchmark) GetSplittingAlgorithm added in v0.4.1 

func (m *Benchmark) GetSplittingAlgorithm() SplittingAlgorithm

func (*Benchmark) GetType added in v0.4.1 

func (m *Benchmark) GetType() DeviceType

func (*Benchmark) ProtoMessage added in v0.4.1 

func (*Benchmark) ProtoMessage()

func (*Benchmark) Reset added in v0.4.1 

func (m *Benchmark) Reset()

func (*Benchmark) String added in v0.4.1 

func (m *Benchmark) String() string

type Benchmarks added in v0.4.1 

type Benchmarks struct {
	Values []uint64 `protobuf:"varint,1,rep,packed,name=values" json:"values,omitempty"`
}

func NewBenchmarks added in v0.4.1 

func NewBenchmarks(benchmarks []uint64) (*Benchmarks, error)

func (*Benchmarks) CPUCores added in v0.4.1 

func (m *Benchmarks) CPUCores() uint64

func (*Benchmarks) CPUCryptonight added in v0.4.12 

func (m *Benchmarks) CPUCryptonight() uint64

func (*Benchmarks) CPUSysbenchMulti added in v0.4.1 

func (m *Benchmarks) CPUSysbenchMulti() uint64

func (*Benchmarks) CPUSysbenchOne added in v0.4.1 

func (m *Benchmarks) CPUSysbenchOne() uint64

func (*Benchmarks) Descriptor added in v0.4.1 

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

func (*Benchmarks) GPUCashHashrate added in v0.4.1 

func (m *Benchmarks) GPUCashHashrate() uint64

func (*Benchmarks) GPUCount added in v0.4.1 

func (m *Benchmarks) GPUCount() uint64

func (*Benchmarks) GPUCuckaroo29 added in v0.4.25 

func (m *Benchmarks) GPUCuckaroo29() uint64

func (*Benchmarks) GPUEthHashrate added in v0.4.1 

func (m *Benchmarks) GPUEthHashrate() uint64

func (*Benchmarks) GPUMem added in v0.4.1 

func (m *Benchmarks) GPUMem() uint64

func (*Benchmarks) GPUNVidiaOnly added in v0.4.25 

func (m *Benchmarks) GPUNVidiaOnly() uint64

func (*Benchmarks) GPURadeonOnly added in v0.4.25 

func (m *Benchmarks) GPURadeonOnly() uint64

func (*Benchmarks) GPURedshift added in v0.4.1 

func (m *Benchmarks) GPURedshift() uint64

func (*Benchmarks) Get added in v0.4.1 

func (m *Benchmarks) Get(idx int) uint64

func (*Benchmarks) GetNValues added in v0.4.1 

func (m *Benchmarks) GetNValues(targetSize uint64) []uint64

func (*Benchmarks) GetValues added in v0.4.1 

func (m *Benchmarks) GetValues() []uint64

func (*Benchmarks) NetTrafficIn added in v0.4.1 

func (m *Benchmarks) NetTrafficIn() uint64

func (*Benchmarks) NetTrafficOut added in v0.4.1 

func (m *Benchmarks) NetTrafficOut() uint64

func (*Benchmarks) ProtoMessage added in v0.4.1 

func (*Benchmarks) ProtoMessage()

func (*Benchmarks) RAMSize added in v0.4.1 

func (m *Benchmarks) RAMSize() uint64

func (*Benchmarks) Reset added in v0.4.1 

func (m *Benchmarks) Reset()

func (*Benchmarks) SetCPUCores added in v0.4.12 

func (m *Benchmarks) SetCPUCores(v uint64)

func (*Benchmarks) SetGPUCount added in v0.4.12 

func (m *Benchmarks) SetGPUCount(v uint64)

func (*Benchmarks) StorageSize added in v0.4.1 

func (m *Benchmarks) StorageSize() uint64

func (*Benchmarks) String added in v0.4.1 

func (m *Benchmarks) String() string

func (*Benchmarks) ToArray added in v0.4.1 

func (m *Benchmarks) ToArray() []uint64

func (*Benchmarks) Validate added in v0.4.1 

func (m *Benchmarks) Validate() error

type BidNetwork added in v0.4.1 

type BidNetwork struct {
	Overlay  bool `protobuf:"varint,1,opt,name=overlay" json:"overlay,omitempty"`
	Outbound bool `protobuf:"varint,2,opt,name=outbound" json:"outbound,omitempty"`
	Incoming bool `protobuf:"varint,3,opt,name=incoming" json:"incoming,omitempty"`
}

func (*BidNetwork) Descriptor added in v0.4.1 

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

func (*BidNetwork) GetIncoming added in v0.4.1 

func (m *BidNetwork) GetIncoming() bool

func (*BidNetwork) GetOutbound added in v0.4.1 

func (m *BidNetwork) GetOutbound() bool

func (*BidNetwork) GetOverlay added in v0.4.1 

func (m *BidNetwork) GetOverlay() bool

func (*BidNetwork) ProtoMessage added in v0.4.1 

func (*BidNetwork) ProtoMessage()

func (*BidNetwork) Reset added in v0.4.1 

func (m *BidNetwork) Reset()

func (*BidNetwork) String added in v0.4.1 

func (m *BidNetwork) String() string

type BidOrder added in v0.4.1 

type BidOrder struct {
	ID           string        `protobuf:"bytes,1,opt,name=ID" json:"ID,omitempty"`
	Duration     *Duration     `protobuf:"bytes,2,opt,name=duration" json:"duration,omitempty"`
	Price        *Price        `protobuf:"bytes,3,opt,name=price" json:"price,omitempty"`
	Blacklist    *EthAddress   `protobuf:"bytes,4,opt,name=blacklist" json:"blacklist,omitempty"`
	Identity     IdentityLevel `protobuf:"varint,5,opt,name=identity,enum=sonm.IdentityLevel" json:"identity,omitempty"`
	Tag          string        `protobuf:"bytes,6,opt,name=tag" json:"tag,omitempty"`
	Counterparty *EthAddress   `protobuf:"bytes,7,opt,name=Counterparty" json:"Counterparty,omitempty"`
	Resources    *BidResources `protobuf:"bytes,8,opt,name=resources" json:"resources,omitempty"`
}

func (*BidOrder) Descriptor added in v0.4.1 

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

func (*BidOrder) GetBlacklist added in v0.4.1 

func (m *BidOrder) GetBlacklist() *EthAddress

func (*BidOrder) GetCounterparty added in v0.4.1 

func (m *BidOrder) GetCounterparty() *EthAddress

func (*BidOrder) GetDuration added in v0.4.1 

func (m *BidOrder) GetDuration() *Duration

func (*BidOrder) GetID added in v0.4.1 

func (m *BidOrder) GetID() string

func (*BidOrder) GetIdentity added in v0.4.1 

func (m *BidOrder) GetIdentity() IdentityLevel

func (*BidOrder) GetPrice added in v0.4.1 

func (m *BidOrder) GetPrice() *Price

func (*BidOrder) GetResources added in v0.4.1 

func (m *BidOrder) GetResources() *BidResources

func (*BidOrder) GetTag added in v0.4.1 

func (m *BidOrder) GetTag() string

func (*BidOrder) ProtoMessage added in v0.4.1 

func (*BidOrder) ProtoMessage()

func (*BidOrder) Reset added in v0.4.1 

func (m *BidOrder) Reset()

func (*BidOrder) String added in v0.4.1 

func (m *BidOrder) String() string

func (*BidOrder) Validate added in v0.4.1 

func (m *BidOrder) Validate() error

type BidResources added in v0.4.1 

type BidResources struct {
	Network    *BidNetwork       `protobuf:"bytes,1,opt,name=network" json:"network,omitempty"`
	Benchmarks map[string]uint64 `` /* 141-byte string literal not displayed */
}

func (*BidResources) Descriptor added in v0.4.1 

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

func (*BidResources) GetBenchmarks added in v0.4.1 

func (m *BidResources) GetBenchmarks() map[string]uint64

func (*BidResources) GetNetwork added in v0.4.1 

func (m *BidResources) GetNetwork() *BidNetwork

func (*BidResources) ProtoMessage added in v0.4.1 

func (*BidResources) ProtoMessage()

func (*BidResources) Reset added in v0.4.1 

func (m *BidResources) Reset()

func (*BidResources) String added in v0.4.1 

func (m *BidResources) String() string

type BigInt added in v0.3.2 

type BigInt struct {
	Neg bool   `protobuf:"varint,1,opt,name=neg" json:"neg,omitempty"`
	Abs []byte `protobuf:"bytes,2,opt,name=abs,proto3" json:"abs,omitempty"`
}

BigInt represents multi-precision value stored as a big integer.

func NewBigInt added in v0.3.2 

func NewBigInt(v *big.Int) *BigInt

NewBigInt constructs a new value using specified big.Int.

func NewBigIntFromInt added in v0.3.2 

func NewBigIntFromInt(v int64) *BigInt

func NewBigIntFromString added in v0.3.2 

func NewBigIntFromString(s string) (*BigInt, error)

NewBigIntFromString tries to construct a new value from the specified string.

func (*BigInt) Cmp added in v0.3.2 

func (m *BigInt) Cmp(other *BigInt) int

Cmp compares this value with the other one, returning: 

-1 if x <  y
 0 if x == y
+1 if x >  y

func (*BigInt) Descriptor added in v0.3.2 

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

func (*BigInt) GetAbs added in v0.3.2 

func (m *BigInt) GetAbs() []byte

func (*BigInt) GetNeg added in v0.3.2 

func (m *BigInt) GetNeg() bool

func (*BigInt) IsZero added in v0.4.1 

func (m *BigInt) IsZero() bool

func (BigInt) MarshalText added in v0.4.1 

func (m BigInt) MarshalText() (text []byte, err error)

func (*BigInt) PaddedString added in v0.4.1 

func (m *BigInt) PaddedString() string

func (*BigInt) PricePerHour added in v0.4.12 

func (m *BigInt) PricePerHour() string

func (*BigInt) ProtoMessage added in v0.3.2 

func (*BigInt) ProtoMessage()

func (*BigInt) Reset added in v0.3.2 

func (m *BigInt) Reset()

func (*BigInt) String added in v0.3.2 

func (m *BigInt) String() string

func (*BigInt) ToPriceString added in v0.4.1 

func (m *BigInt) ToPriceString() string

func (*BigInt) UnmarshalText added in v0.4.1 

func (m *BigInt) UnmarshalText(text []byte) error

func (*BigInt) Unwrap added in v0.3.2 

func (m *BigInt) Unwrap() *big.Int

Unwrap returns the current price as *big.Int.

type BlacklistClient added in v0.4.1 

type BlacklistClient interface {
	// List addresses into given blacklist
	List(ctx context.Context, in *EthAddress, opts ...grpc.CallOption) (*BlacklistReply, error)
	// Remove removes given address from blacklist
	Remove(ctx context.Context, in *EthAddress, opts ...grpc.CallOption) (*Empty, error)
	// Purge removes all addresses from your blacklist
	Purge(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ErrorByStringID, error)
}

func NewBlacklistClient added in v0.4.1 

func NewBlacklistClient(cc *grpc.ClientConn) BlacklistClient

type BlacklistOption added in v0.4.1 

type BlacklistOption int32
const (
	BlacklistOption_WithoutMatching BlacklistOption = 0
	BlacklistOption_IncludeAndMark  BlacklistOption = 1
	BlacklistOption_OnlyMatching    BlacklistOption = 2
)

func (BlacklistOption) EnumDescriptor added in v0.4.1 

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

func (BlacklistOption) String added in v0.4.1 

func (x BlacklistOption) String() string

type BlacklistQuery added in v0.4.1 

type BlacklistQuery struct {
	OwnerID *EthAddress     `protobuf:"bytes,1,opt,name=ownerID" json:"ownerID,omitempty"`
	Option  BlacklistOption `protobuf:"varint,2,opt,name=option,enum=sonm.BlacklistOption" json:"option,omitempty"`
}

func (*BlacklistQuery) Descriptor added in v0.4.1 

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

func (*BlacklistQuery) GetOption added in v0.4.1 

func (m *BlacklistQuery) GetOption() BlacklistOption

func (*BlacklistQuery) GetOwnerID added in v0.4.1 

func (m *BlacklistQuery) GetOwnerID() *EthAddress

func (*BlacklistQuery) ProtoMessage added in v0.4.1 

func (*BlacklistQuery) ProtoMessage()

func (*BlacklistQuery) Reset added in v0.4.1 

func (m *BlacklistQuery) Reset()

func (*BlacklistQuery) String added in v0.4.1 

func (m *BlacklistQuery) String() string

type BlacklistReply added in v0.4.1 

type BlacklistReply struct {
	OwnerID   *EthAddress `protobuf:"bytes,1,opt,name=ownerID" json:"ownerID,omitempty"`
	Addresses []string    `protobuf:"bytes,2,rep,name=addresses" json:"addresses,omitempty"`
	Count     uint64      `protobuf:"varint,3,opt,name=count" json:"count,omitempty"`
}

func (*BlacklistReply) Descriptor added in v0.4.1 

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

func (*BlacklistReply) GetAddresses added in v0.4.1 

func (m *BlacklistReply) GetAddresses() []string

func (*BlacklistReply) GetCount added in v0.4.1 

func (m *BlacklistReply) GetCount() uint64

func (*BlacklistReply) GetOwnerID added in v0.4.1 

func (m *BlacklistReply) GetOwnerID() *EthAddress

func (*BlacklistReply) ProtoMessage added in v0.4.1 

func (*BlacklistReply) ProtoMessage()

func (*BlacklistReply) Reset added in v0.4.1 

func (m *BlacklistReply) Reset()

func (*BlacklistReply) String added in v0.4.1 

func (m *BlacklistReply) String() string

type BlacklistRequest added in v0.4.1 

type BlacklistRequest struct {
	UserID    *EthAddress `protobuf:"bytes,1,opt,name=userID" json:"userID,omitempty"`
	Limit     uint64      `protobuf:"varint,2,opt,name=limit" json:"limit,omitempty"`
	Offset    uint64      `protobuf:"varint,3,opt,name=offset" json:"offset,omitempty"`
	WithCount bool        `protobuf:"varint,4,opt,name=withCount" json:"withCount,omitempty"`
}

func (*BlacklistRequest) Descriptor added in v0.4.1 

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

func (*BlacklistRequest) GetLimit added in v0.4.1 

func (m *BlacklistRequest) GetLimit() uint64

func (*BlacklistRequest) GetOffset added in v0.4.1 

func (m *BlacklistRequest) GetOffset() uint64

func (*BlacklistRequest) GetUserID added in v0.4.1 

func (m *BlacklistRequest) GetUserID() *EthAddress

func (*BlacklistRequest) GetWithCount added in v0.4.1 

func (m *BlacklistRequest) GetWithCount() bool

func (*BlacklistRequest) ProtoMessage added in v0.4.1 

func (*BlacklistRequest) ProtoMessage()

func (*BlacklistRequest) Reset added in v0.4.1 

func (m *BlacklistRequest) Reset()

func (*BlacklistRequest) String added in v0.4.1 

func (m *BlacklistRequest) String() string

type BlacklistServer added in v0.4.1 

type BlacklistServer interface {
	// List addresses into given blacklist
	List(context.Context, *EthAddress) (*BlacklistReply, error)
	// Remove removes given address from blacklist
	Remove(context.Context, *EthAddress) (*Empty, error)
	// Purge removes all addresses from your blacklist
	Purge(context.Context, *Empty) (*ErrorByStringID, error)
}

type BlacklistType added in v0.4.1 

type BlacklistType int32
const (
	BlacklistType_BLACKLIST_NOBODY BlacklistType = 0
	BlacklistType_BLACKLIST_WORKER BlacklistType = 1
	BlacklistType_BLACKLIST_MASTER BlacklistType = 2
)

func (BlacklistType) EnumDescriptor added in v0.4.1 

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

func (BlacklistType) String added in v0.4.1 

func (x BlacklistType) String() string

type BlacklistsContainingUserReply added in v0.4.1 

type BlacklistsContainingUserReply struct {
	Blacklists []*EthAddress `protobuf:"bytes,1,rep,name=blacklists" json:"blacklists,omitempty"`
	Count      uint64        `protobuf:"varint,2,opt,name=count" json:"count,omitempty"`
}

func (*BlacklistsContainingUserReply) Descriptor added in v0.4.1 

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

func (*BlacklistsContainingUserReply) GetBlacklists added in v0.4.1 

func (m *BlacklistsContainingUserReply) GetBlacklists() []*EthAddress

func (*BlacklistsContainingUserReply) GetCount added in v0.4.1 

func (m *BlacklistsContainingUserReply) GetCount() uint64

func (*BlacklistsContainingUserReply) ProtoMessage added in v0.4.1 

func (*BlacklistsContainingUserReply) ProtoMessage()

func (*BlacklistsContainingUserReply) Reset added in v0.4.1 

func (m *BlacklistsContainingUserReply) Reset()

func (*BlacklistsContainingUserReply) String added in v0.4.1 

func (m *BlacklistsContainingUserReply) String() string

type CPU added in v0.4.1 

type CPU struct {
	Device     *CPUDevice            `protobuf:"bytes,1,opt,name=device" json:"device,omitempty"`
	Benchmarks map[uint64]*Benchmark `` /* 141-byte string literal not displayed */
}

func (*CPU) Descriptor added in v0.4.1 

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

func (*CPU) GetBenchmarks added in v0.4.1 

func (m *CPU) GetBenchmarks() map[uint64]*Benchmark

func (*CPU) GetDevice added in v0.4.1 

func (m *CPU) GetDevice() *CPUDevice

func (*CPU) ProtoMessage added in v0.4.1 

func (*CPU) ProtoMessage()

func (*CPU) Reset added in v0.4.1 

func (m *CPU) Reset()

func (*CPU) String added in v0.4.1 

func (m *CPU) String() string

type CPUDevice 

type CPUDevice struct {
	// ModelName describes full model name.
	// For example "Intel(R) Core(TM) i5-5257U CPU @ 2.70GHz".
	ModelName string `protobuf:"bytes,1,opt,name=modelName" json:"modelName,omitempty"`
	// Cores describes number of cores on a CPU device.
	Cores uint32 `protobuf:"varint,2,opt,name=cores" json:"cores,omitempty"`
	// Sockets describes number of CPU sockets on a host system.
	Sockets uint32 `protobuf:"varint,3,opt,name=sockets" json:"sockets,omitempty"`
}

func (*CPUDevice) Descriptor 

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

func (*CPUDevice) GetCores 

func (m *CPUDevice) GetCores() uint32

func (*CPUDevice) GetModelName 

func (m *CPUDevice) GetModelName() string

func (*CPUDevice) GetSockets added in v0.4.1 

func (m *CPUDevice) GetSockets() uint32

func (*CPUDevice) ProtoMessage 

func (*CPUDevice) ProtoMessage()

func (*CPUDevice) Reset 

func (m *CPUDevice) Reset()

func (*CPUDevice) String 

func (m *CPUDevice) String() string

type CPUUsage 

type CPUUsage struct {
	Total uint64 `protobuf:"varint,1,opt,name=total" json:"total,omitempty"`
}

func (*CPUUsage) Descriptor 

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

func (*CPUUsage) GetTotal 

func (m *CPUUsage) GetTotal() uint64

func (*CPUUsage) ProtoMessage 

func (*CPUUsage) ProtoMessage()

func (*CPUUsage) Reset 

func (m *CPUUsage) Reset()

func (*CPUUsage) String 

func (m *CPUUsage) String() string

type CapabilityScope added in v0.4.21 

type CapabilityScope int32
const (
	CapabilityScope_CAPABILITY_NONE       CapabilityScope = 0
	CapabilityScope_CAPABILITY_SSH        CapabilityScope = 1
	CapabilityScope_CAPABILITY_INSPECTION CapabilityScope = 2
)

func (CapabilityScope) EnumDescriptor added in v0.4.21 

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

func (CapabilityScope) String added in v0.4.21 

func (x CapabilityScope) String() string

type Certificate added in v0.4.1 

type Certificate struct {
	OwnerID       *EthAddress `protobuf:"bytes,1,opt,name=ownerID" json:"ownerID,omitempty"`
	ValidatorID   *EthAddress `protobuf:"bytes,2,opt,name=validatorID" json:"validatorID,omitempty"`
	Attribute     uint64      `protobuf:"varint,3,opt,name=attribute" json:"attribute,omitempty"`
	IdentityLevel uint64      `protobuf:"varint,4,opt,name=identityLevel" json:"identityLevel,omitempty"`
	Value         []byte      `protobuf:"bytes,5,opt,name=value,proto3" json:"value,omitempty"`
	Id            *BigInt     `protobuf:"bytes,6,opt,name=id" json:"id,omitempty"`
}

func (*Certificate) Descriptor added in v0.4.1 

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

func (*Certificate) GetAttribute added in v0.4.1 

func (m *Certificate) GetAttribute() uint64

func (*Certificate) GetAttributeName added in v0.4.1 

func (m *Certificate) GetAttributeName() string

GetAttributeName converts profile cert attr number to human readable name.

func (*Certificate) GetAttributeNameNormalized added in v0.4.1 

func (m *Certificate) GetAttributeNameNormalized() string

GetAttributeNameNormalized returns GetAttributeName with spaces replaced by underscores.

func (*Certificate) GetId added in v0.4.1 

func (m *Certificate) GetId() *BigInt

func (*Certificate) GetIdentityLevel added in v0.4.1 

func (m *Certificate) GetIdentityLevel() uint64

func (*Certificate) GetOwnerID added in v0.4.1 

func (m *Certificate) GetOwnerID() *EthAddress

func (*Certificate) GetValidatorID added in v0.4.1 

func (m *Certificate) GetValidatorID() *EthAddress

func (*Certificate) GetValue added in v0.4.1 

func (m *Certificate) GetValue() []byte

func (*Certificate) ProtoMessage added in v0.4.1 

func (*Certificate) ProtoMessage()

func (*Certificate) Reset added in v0.4.1 

func (m *Certificate) Reset()

func (*Certificate) String added in v0.4.1 

func (m *Certificate) String() string

type ChangeRequestStatus added in v0.4.1 

type ChangeRequestStatus int32
const (
	ChangeRequestStatus_REQUEST_UNKNOWN  ChangeRequestStatus = 0
	ChangeRequestStatus_REQUEST_CREATED  ChangeRequestStatus = 1
	ChangeRequestStatus_REQUEST_CANCELED ChangeRequestStatus = 2
	ChangeRequestStatus_REQUEST_REJECTED ChangeRequestStatus = 3
	ChangeRequestStatus_REQUEST_ACCEPTED ChangeRequestStatus = 4
)

func (ChangeRequestStatus) EnumDescriptor added in v0.4.1 

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

func (ChangeRequestStatus) String added in v0.4.1 

func (x ChangeRequestStatus) String() string

type ChangeRequestsRequest added in v0.4.10 

type ChangeRequestsRequest struct {
	DealID     *BigInt `protobuf:"bytes,1,opt,name=dealID" json:"dealID,omitempty"`
	OnlyActive bool    `protobuf:"varint,2,opt,name=onlyActive" json:"onlyActive,omitempty"`
}

func (*ChangeRequestsRequest) Descriptor added in v0.4.10 

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

func (*ChangeRequestsRequest) GetDealID added in v0.4.10 

func (m *ChangeRequestsRequest) GetDealID() *BigInt

func (*ChangeRequestsRequest) GetOnlyActive added in v0.4.10 

func (m *ChangeRequestsRequest) GetOnlyActive() bool

func (*ChangeRequestsRequest) ProtoMessage added in v0.4.10 

func (*ChangeRequestsRequest) ProtoMessage()

func (*ChangeRequestsRequest) Reset added in v0.4.10 

func (m *ChangeRequestsRequest) Reset()

func (*ChangeRequestsRequest) String added in v0.4.10 

func (m *ChangeRequestsRequest) String() string

type Chunk 

type Chunk struct {
	Chunk []byte `protobuf:"bytes,1,opt,name=chunk,proto3" json:"chunk,omitempty"`
}

func (*Chunk) Descriptor 

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

func (*Chunk) GetChunk 

func (m *Chunk) GetChunk() []byte

func (*Chunk) ProtoMessage 

func (*Chunk) ProtoMessage()

func (*Chunk) Reset 

func (m *Chunk) Reset()

func (*Chunk) String 

func (m *Chunk) String() string

type CmpOp added in v0.4.1 

type CmpOp int32
const (
	CmpOp_EQ  CmpOp = 0
	CmpOp_GTE CmpOp = 1
	CmpOp_LTE CmpOp = 2
)

func (CmpOp) EnumDescriptor added in v0.4.1 

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

func (CmpOp) String added in v0.4.1 

func (x CmpOp) String() string

type CmpUint64 added in v0.4.1 

type CmpUint64 struct {
	Value    uint64 `protobuf:"varint,1,opt,name=value" json:"value,omitempty"`
	Operator CmpOp  `protobuf:"varint,2,opt,name=operator,enum=sonm.CmpOp" json:"operator,omitempty"`
}

func (*CmpUint64) Descriptor added in v0.4.1 

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

func (*CmpUint64) GetOperator added in v0.4.1 

func (m *CmpUint64) GetOperator() CmpOp

func (*CmpUint64) GetValue added in v0.4.1 

func (m *CmpUint64) GetValue() uint64

func (*CmpUint64) ProtoMessage added in v0.4.1 

func (*CmpUint64) ProtoMessage()

func (*CmpUint64) Reset added in v0.4.1 

func (m *CmpUint64) Reset()

func (*CmpUint64) String added in v0.4.1 

func (m *CmpUint64) String() string

type ConnectRequest added in v0.4.1 

type ConnectRequest struct {
	// ID describes an unique ID of a target. Mainly it's an ETH address.
	ID []byte `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	// Protocol describes the application protocol the peer wants to resolve.
	Protocol string `protobuf:"bytes,2,opt,name=protocol" json:"protocol,omitempty"`
	// PrivateAddrs describes source private addresses.
	PrivateAddrs []*Addr `protobuf:"bytes,3,rep,name=privateAddrs" json:"privateAddrs,omitempty"`
}

ConnectRequest describes a connection request to a remote target, possibly located under the NAT.

func (*ConnectRequest) Descriptor added in v0.4.1 

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

func (*ConnectRequest) GetID added in v0.4.1 

func (m *ConnectRequest) GetID() []byte

func (*ConnectRequest) GetPrivateAddrs added in v0.4.1 

func (m *ConnectRequest) GetPrivateAddrs() []*Addr

func (*ConnectRequest) GetProtocol added in v0.4.1 

func (m *ConnectRequest) GetProtocol() string

func (*ConnectRequest) ProtoMessage added in v0.4.1 

func (*ConnectRequest) ProtoMessage()

func (*ConnectRequest) Reset added in v0.4.1 

func (m *ConnectRequest) Reset()

func (*ConnectRequest) String added in v0.4.1 

func (m *ConnectRequest) String() string

func (*ConnectRequest) Validate added in v0.4.1 

func (m *ConnectRequest) Validate() error

type ConnectionStat added in v0.4.21 

type ConnectionStat struct {
	// Fd shows the file descriptor number.
	Fd         uint64      `protobuf:"varint,1,opt,name=fd" json:"fd,omitempty"`
	Family     uint32      `protobuf:"varint,2,opt,name=family" json:"family,omitempty"`
	Type       uint32      `protobuf:"varint,3,opt,name=type" json:"type,omitempty"`
	LocalAddr  *SocketAddr `protobuf:"bytes,4,opt,name=localAddr" json:"localAddr,omitempty"`
	RemoteAddr *SocketAddr `protobuf:"bytes,5,opt,name=remoteAddr" json:"remoteAddr,omitempty"`
	Status     string      `protobuf:"bytes,6,opt,name=status" json:"status,omitempty"`
	Pid        int32       `protobuf:"varint,7,opt,name=pid" json:"pid,omitempty"`
}

func (*ConnectionStat) Descriptor added in v0.4.21 

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

func (*ConnectionStat) GetFamily added in v0.4.21 

func (m *ConnectionStat) GetFamily() uint32

func (*ConnectionStat) GetFd added in v0.4.21 

func (m *ConnectionStat) GetFd() uint64

func (*ConnectionStat) GetLocalAddr added in v0.4.21 

func (m *ConnectionStat) GetLocalAddr() *SocketAddr

func (*ConnectionStat) GetPid added in v0.4.21 

func (m *ConnectionStat) GetPid() int32

func (*ConnectionStat) GetRemoteAddr added in v0.4.21 

func (m *ConnectionStat) GetRemoteAddr() *SocketAddr

func (*ConnectionStat) GetStatus added in v0.4.21 

func (m *ConnectionStat) GetStatus() string

func (*ConnectionStat) GetType added in v0.4.21 

func (m *ConnectionStat) GetType() uint32

func (*ConnectionStat) ProtoMessage added in v0.4.21 

func (*ConnectionStat) ProtoMessage()

func (*ConnectionStat) Reset added in v0.4.21 

func (m *ConnectionStat) Reset()

func (*ConnectionStat) String added in v0.4.21 

func (m *ConnectionStat) String() string

type Container added in v0.3.2 

type Container struct {
	// Image describes a Docker image name. Required.
	Image string `protobuf:"bytes,1,opt,name=image" json:"image,omitempty"`
	// SSH public key used to attach to the container.
	SshKey string `protobuf:"bytes,2,opt,name=sshKey" json:"sshKey,omitempty"`
	// CommitOnStop points whether a container should commit when stopped.
	// Committed containers can be fetched later while there is an active
	// deal.
	CommitOnStop bool `protobuf:"varint,3,opt,name=commitOnStop" json:"commitOnStop,omitempty"`
	// Env describes environment variables forwarded into the container.
	Env map[string]string `` /* 126-byte string literal not displayed */
	// Volumes describes network volumes that are used to be mounted inside
	// the container.
	// Mapping from the volume type (cifs, nfs, etc.) to its settings.
	Volumes map[string]*Volume `` /* 134-byte string literal not displayed */
	// Mounts describes mount points from the volume name to the container.
	Mounts   []string       `protobuf:"bytes,6,rep,name=mounts" json:"mounts,omitempty"`
	Networks []*NetworkSpec `protobuf:"bytes,7,rep,name=networks" json:"networks,omitempty"`
	// ContainerRestartPolicy describes the restart policies of the container.
	RestartPolicy *ContainerRestartPolicy `protobuf:"bytes,8,opt,name=restartPolicy" json:"restartPolicy,omitempty"`
	// Expose controls how container ports are exposed.
	// Format is "public_ip:public_port:private_port/protocol"
	// Protocol can be "tcp", "udp", "sctp".
	// If the "protocol" parameter is ommited "tcp" is implied.
	// If the "public_ip" parameter is ommited then the port is being exposed on all available ips.
	Expose []string `protobuf:"bytes,10,rep,name=expose" json:"expose,omitempty"`
	// Push the committed image to remote repository (works only if CommitOnStop is set to `true`).
	PushOnStop bool `protobuf:"varint,11,opt,name=pushOnStop" json:"pushOnStop,omitempty"`
}

func (*Container) Descriptor added in v0.3.2 

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

func (*Container) GetCommitOnStop added in v0.3.2 

func (m *Container) GetCommitOnStop() bool

func (*Container) GetEnv added in v0.3.2 

func (m *Container) GetEnv() map[string]string

func (*Container) GetExpose added in v0.4.1 

func (m *Container) GetExpose() []string

func (*Container) GetImage added in v0.3.2 

func (m *Container) GetImage() string

func (*Container) GetMounts added in v0.3.2 

func (m *Container) GetMounts() []string

func (*Container) GetNetworks added in v0.4.1 

func (m *Container) GetNetworks() []*NetworkSpec

func (*Container) GetPushOnStop added in v0.4.11 

func (m *Container) GetPushOnStop() bool

func (*Container) GetRestartPolicy added in v0.4.1 

func (m *Container) GetRestartPolicy() *ContainerRestartPolicy

func (*Container) GetSshKey added in v0.4.1 

func (m *Container) GetSshKey() string

func (*Container) GetVolumes added in v0.3.2 

func (m *Container) GetVolumes() map[string]*Volume

func (*Container) ProtoMessage added in v0.3.2 

func (*Container) ProtoMessage()

func (*Container) Reset added in v0.3.2 

func (m *Container) Reset()

func (*Container) String added in v0.3.2 

func (m *Container) String() string

func (*Container) Validate added in v0.4.1 

func (m *Container) Validate() error

type ContainerRestartPolicy 

type ContainerRestartPolicy struct {
	// Name can be either "always" to always restart or "on-failure" to restart
	// only when the container exit code is non-zero. If on-failure is used,
	// MaximumRetryCount controls the number of times to retry before giving up.
	// The default is not to restart.
	Name              string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	MaximumRetryCount uint32 `protobuf:"varint,2,opt,name=maximumRetryCount" json:"maximumRetryCount,omitempty"`
}

ContainerRestartPolicy represents the restart policies of the container.

func (*ContainerRestartPolicy) Descriptor 

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

func (*ContainerRestartPolicy) GetMaximumRetryCount 

func (m *ContainerRestartPolicy) GetMaximumRetryCount() uint32

func (*ContainerRestartPolicy) GetName 

func (m *ContainerRestartPolicy) GetName() string

func (*ContainerRestartPolicy) ProtoMessage 

func (*ContainerRestartPolicy) ProtoMessage()

func (*ContainerRestartPolicy) Reset 

func (m *ContainerRestartPolicy) Reset()

func (*ContainerRestartPolicy) String 

func (m *ContainerRestartPolicy) String() string

func (*ContainerRestartPolicy) Unwrap added in v0.4.1 

func (m *ContainerRestartPolicy) Unwrap() container.RestartPolicy

type Count added in v0.4.1 

type Count struct {
	Count uint64 `protobuf:"varint,1,opt,name=count" json:"count,omitempty"`
}

func (*Count) Descriptor added in v0.4.1 

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

func (*Count) GetCount added in v0.4.1 

func (m *Count) GetCount() uint64

func (*Count) ProtoMessage added in v0.4.1 

func (*Count) ProtoMessage()

func (*Count) Reset added in v0.4.1 

func (m *Count) Reset()

func (*Count) String added in v0.4.1 

func (m *Count) String() string

type DWHClient added in v0.4.1 

type DWHClient interface {
	GetDeals(ctx context.Context, in *DealsRequest, opts ...grpc.CallOption) (*DWHDealsReply, error)
	GetDealDetails(ctx context.Context, in *BigInt, opts ...grpc.CallOption) (*DWHDeal, error)
	GetDealConditions(ctx context.Context, in *DealConditionsRequest, opts ...grpc.CallOption) (*DealConditionsReply, error)
	GetOrders(ctx context.Context, in *OrdersRequest, opts ...grpc.CallOption) (*DWHOrdersReply, error)
	GetMatchingOrders(ctx context.Context, in *MatchingOrdersRequest, opts ...grpc.CallOption) (*DWHOrdersReply, error)
	GetOrderDetails(ctx context.Context, in *BigInt, opts ...grpc.CallOption) (*DWHOrder, error)
	GetProfiles(ctx context.Context, in *ProfilesRequest, opts ...grpc.CallOption) (*ProfilesReply, error)
	GetProfileInfo(ctx context.Context, in *EthID, opts ...grpc.CallOption) (*Profile, error)
	GetBlacklist(ctx context.Context, in *BlacklistRequest, opts ...grpc.CallOption) (*BlacklistReply, error)
	GetBlacklistsContainingUser(ctx context.Context, in *BlacklistRequest, opts ...grpc.CallOption) (*BlacklistsContainingUserReply, error)
	GetValidators(ctx context.Context, in *ValidatorsRequest, opts ...grpc.CallOption) (*ValidatorsReply, error)
	// Deprecated: use GetChangeRequests.
	GetDealChangeRequests(ctx context.Context, in *BigInt, opts ...grpc.CallOption) (*DealChangeRequestsReply, error)
	GetChangeRequests(ctx context.Context, in *ChangeRequestsRequest, opts ...grpc.CallOption) (*DealChangeRequestsReply, error)
	GetWorkers(ctx context.Context, in *WorkersRequest, opts ...grpc.CallOption) (*WorkersReply, error)
	GetStats(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*DWHStatsReply, error)
	GetOrdersByIDs(ctx context.Context, in *OrdersByIDsRequest, opts ...grpc.CallOption) (*DWHOrdersReply, error)
}

func NewDWHClient added in v0.4.1 

func NewDWHClient(cc *grpc.ClientConn) DWHClient

type DWHDeal added in v0.4.1 

type DWHDeal struct {
	Deal                 *Deal  `protobuf:"bytes,1,opt,name=deal" json:"deal,omitempty"`
	Netflags             uint64 `protobuf:"varint,2,opt,name=netflags" json:"netflags,omitempty"`
	AskIdentityLevel     uint64 `protobuf:"varint,3,opt,name=askIdentityLevel" json:"askIdentityLevel,omitempty"`
	BidIdentityLevel     uint64 `protobuf:"varint,4,opt,name=bidIdentityLevel" json:"bidIdentityLevel,omitempty"`
	SupplierCertificates []byte `protobuf:"bytes,5,opt,name=supplierCertificates,proto3" json:"supplierCertificates,omitempty"`
	ConsumerCertificates []byte `protobuf:"bytes,6,opt,name=consumerCertificates,proto3" json:"consumerCertificates,omitempty"`
	ActiveChangeRequest  bool   `protobuf:"varint,7,opt,name=activeChangeRequest" json:"activeChangeRequest,omitempty"`
	AskTag               []byte `protobuf:"bytes,8,opt,name=askTag,proto3" json:"askTag,omitempty"`
	BidTag               []byte `protobuf:"bytes,9,opt,name=bidTag,proto3" json:"bidTag,omitempty"`
}

func (*DWHDeal) Descriptor added in v0.4.1 

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

func (*DWHDeal) GetActiveChangeRequest added in v0.4.1 

func (m *DWHDeal) GetActiveChangeRequest() bool

func (*DWHDeal) GetAskIdentityLevel added in v0.4.1 

func (m *DWHDeal) GetAskIdentityLevel() uint64

func (*DWHDeal) GetAskTag added in v0.4.30 

func (m *DWHDeal) GetAskTag() []byte

func (*DWHDeal) GetBidIdentityLevel added in v0.4.1 

func (m *DWHDeal) GetBidIdentityLevel() uint64

func (*DWHDeal) GetBidTag added in v0.4.30 

func (m *DWHDeal) GetBidTag() []byte

func (*DWHDeal) GetConsumerCertificates added in v0.4.1 

func (m *DWHDeal) GetConsumerCertificates() []byte

func (*DWHDeal) GetDeal added in v0.4.1 

func (m *DWHDeal) GetDeal() *Deal

func (*DWHDeal) GetNetflags added in v0.4.1 

func (m *DWHDeal) GetNetflags() uint64

func (*DWHDeal) GetSupplierCertificates added in v0.4.1 

func (m *DWHDeal) GetSupplierCertificates() []byte

func (*DWHDeal) ProtoMessage added in v0.4.1 

func (*DWHDeal) ProtoMessage()

func (*DWHDeal) Reset added in v0.4.1 

func (m *DWHDeal) Reset()

func (*DWHDeal) String added in v0.4.1 

func (m *DWHDeal) String() string

type DWHDealsReply added in v0.4.1 

type DWHDealsReply struct {
	Deals []*DWHDeal `protobuf:"bytes,1,rep,name=deals" json:"deals,omitempty"`
	Count uint64     `protobuf:"varint,2,opt,name=count" json:"count,omitempty"`
}

func (*DWHDealsReply) Descriptor added in v0.4.1 

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

func (*DWHDealsReply) GetCount added in v0.4.1 

func (m *DWHDealsReply) GetCount() uint64

func (*DWHDealsReply) GetDeals added in v0.4.1 

func (m *DWHDealsReply) GetDeals() []*DWHDeal

func (*DWHDealsReply) ProtoMessage added in v0.4.1 

func (*DWHDealsReply) ProtoMessage()

func (*DWHDealsReply) Reset added in v0.4.1 

func (m *DWHDealsReply) Reset()

func (*DWHDealsReply) String added in v0.4.1 

func (m *DWHDealsReply) String() string

type DWHOrder added in v0.4.1 

type DWHOrder struct {
	Order                *Order      `protobuf:"bytes,1,opt,name=order" json:"order,omitempty"`
	CreatorIdentityLevel uint64      `protobuf:"varint,2,opt,name=creatorIdentityLevel" json:"creatorIdentityLevel,omitempty"`
	CreatorName          string      `protobuf:"bytes,3,opt,name=creatorName" json:"creatorName,omitempty"`
	CreatorCountry       string      `protobuf:"bytes,4,opt,name=creatorCountry" json:"creatorCountry,omitempty"`
	CreatorCertificates  []byte      `protobuf:"bytes,5,opt,name=creatorCertificates,proto3" json:"creatorCertificates,omitempty"`
	CreatedTS            *Timestamp  `protobuf:"bytes,6,opt,name=CreatedTS" json:"CreatedTS,omitempty"`
	MasterID             *EthAddress `protobuf:"bytes,7,opt,name=masterID" json:"masterID,omitempty"`
}

func (*DWHOrder) Descriptor added in v0.4.1 

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

func (*DWHOrder) GetCreatedTS added in v0.4.1 

func (m *DWHOrder) GetCreatedTS() *Timestamp

func (*DWHOrder) GetCreatorCertificates added in v0.4.1 

func (m *DWHOrder) GetCreatorCertificates() []byte

func (*DWHOrder) GetCreatorCountry added in v0.4.1 

func (m *DWHOrder) GetCreatorCountry() string

func (*DWHOrder) GetCreatorIdentityLevel added in v0.4.1 

func (m *DWHOrder) GetCreatorIdentityLevel() uint64

func (*DWHOrder) GetCreatorName added in v0.4.1 

func (m *DWHOrder) GetCreatorName() string

func (*DWHOrder) GetMasterID added in v0.4.1 

func (m *DWHOrder) GetMasterID() *EthAddress

func (*DWHOrder) GetOrder added in v0.4.1 

func (m *DWHOrder) GetOrder() *Order

func (*DWHOrder) ProtoMessage added in v0.4.1 

func (*DWHOrder) ProtoMessage()

func (*DWHOrder) Reset added in v0.4.1 

func (m *DWHOrder) Reset()

func (*DWHOrder) String added in v0.4.1 

func (m *DWHOrder) String() string

type DWHOrdersReply added in v0.4.1 

type DWHOrdersReply struct {
	Orders []*DWHOrder `protobuf:"bytes,1,rep,name=orders" json:"orders,omitempty"`
	Count  uint64      `protobuf:"varint,2,opt,name=count" json:"count,omitempty"`
}

func (*DWHOrdersReply) Descriptor added in v0.4.1 

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

func (*DWHOrdersReply) GetCount added in v0.4.1 

func (m *DWHOrdersReply) GetCount() uint64

func (*DWHOrdersReply) GetOrders added in v0.4.1 

func (m *DWHOrdersReply) GetOrders() []*DWHOrder

func (*DWHOrdersReply) ProtoMessage added in v0.4.1 

func (*DWHOrdersReply) ProtoMessage()

func (*DWHOrdersReply) Reset added in v0.4.1 

func (m *DWHOrdersReply) Reset()

func (*DWHOrdersReply) String added in v0.4.1 

func (m *DWHOrdersReply) String() string

type DWHServer added in v0.4.1 

type DWHServer interface {
	GetDeals(context.Context, *DealsRequest) (*DWHDealsReply, error)
	GetDealDetails(context.Context, *BigInt) (*DWHDeal, error)
	GetDealConditions(context.Context, *DealConditionsRequest) (*DealConditionsReply, error)
	GetOrders(context.Context, *OrdersRequest) (*DWHOrdersReply, error)
	GetMatchingOrders(context.Context, *MatchingOrdersRequest) (*DWHOrdersReply, error)
	GetOrderDetails(context.Context, *BigInt) (*DWHOrder, error)
	GetProfiles(context.Context, *ProfilesRequest) (*ProfilesReply, error)
	GetProfileInfo(context.Context, *EthID) (*Profile, error)
	GetBlacklist(context.Context, *BlacklistRequest) (*BlacklistReply, error)
	GetBlacklistsContainingUser(context.Context, *BlacklistRequest) (*BlacklistsContainingUserReply, error)
	GetValidators(context.Context, *ValidatorsRequest) (*ValidatorsReply, error)
	// Deprecated: use GetChangeRequests.
	GetDealChangeRequests(context.Context, *BigInt) (*DealChangeRequestsReply, error)
	GetChangeRequests(context.Context, *ChangeRequestsRequest) (*DealChangeRequestsReply, error)
	GetWorkers(context.Context, *WorkersRequest) (*WorkersReply, error)
	GetStats(context.Context, *Empty) (*DWHStatsReply, error)
	GetOrdersByIDs(context.Context, *OrdersByIDsRequest) (*DWHOrdersReply, error)
}

type DWHStatsReply added in v0.4.12 

type DWHStatsReply struct {
	CurrentDeals        uint64 `protobuf:"varint,1,opt,name=currentDeals" json:"currentDeals,omitempty"`
	TotalDeals          uint64 `protobuf:"varint,2,opt,name=totalDeals" json:"totalDeals,omitempty"`
	TotalDealsDuration  uint64 `protobuf:"varint,3,opt,name=totalDealsDuration" json:"totalDealsDuration,omitempty"`
	AverageDealDuration uint64 `protobuf:"varint,4,opt,name=averageDealDuration" json:"averageDealDuration,omitempty"`
	Workers             uint64 `protobuf:"varint,5,opt,name=workers" json:"workers,omitempty"`
	Masters             uint64 `protobuf:"varint,6,opt,name=masters" json:"masters,omitempty"`
	Customers           uint64 `protobuf:"varint,7,opt,name=customers" json:"customers,omitempty"`
}

func (*DWHStatsReply) Descriptor added in v0.4.12 

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

func (*DWHStatsReply) GetAverageDealDuration added in v0.4.12 

func (m *DWHStatsReply) GetAverageDealDuration() uint64

func (*DWHStatsReply) GetCurrentDeals added in v0.4.12 

func (m *DWHStatsReply) GetCurrentDeals() uint64

func (*DWHStatsReply) GetCustomers added in v0.4.12 

func (m *DWHStatsReply) GetCustomers() uint64

func (*DWHStatsReply) GetMasters added in v0.4.12 

func (m *DWHStatsReply) GetMasters() uint64

func (*DWHStatsReply) GetTotalDeals added in v0.4.12 

func (m *DWHStatsReply) GetTotalDeals() uint64

func (*DWHStatsReply) GetTotalDealsDuration added in v0.4.12 

func (m *DWHStatsReply) GetTotalDealsDuration() uint64

func (*DWHStatsReply) GetWorkers added in v0.4.12 

func (m *DWHStatsReply) GetWorkers() uint64

func (*DWHStatsReply) ProtoMessage added in v0.4.12 

func (*DWHStatsReply) ProtoMessage()

func (*DWHStatsReply) Reset added in v0.4.12 

func (m *DWHStatsReply) Reset()

func (*DWHStatsReply) String added in v0.4.12 

func (m *DWHStatsReply) String() string

type DWHValidator added in v0.4.1 

type DWHValidator struct {
	Validator   *Validator `protobuf:"bytes,1,opt,name=validator" json:"validator,omitempty"`
	Name        string     `protobuf:"bytes,2,opt,name=name" json:"name,omitempty"`
	Icon        string     `protobuf:"bytes,3,opt,name=icon" json:"icon,omitempty"`
	Url         string     `protobuf:"bytes,4,opt,name=url" json:"url,omitempty"`
	Description string     `protobuf:"bytes,5,opt,name=description" json:"description,omitempty"`
	Price       *BigInt    `protobuf:"bytes,6,opt,name=price" json:"price,omitempty"`
}

func (*DWHValidator) Descriptor added in v0.4.1 

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

func (*DWHValidator) GetDescription added in v0.4.1 

func (m *DWHValidator) GetDescription() string

func (*DWHValidator) GetIcon added in v0.4.1 

func (m *DWHValidator) GetIcon() string

func (*DWHValidator) GetName added in v0.4.1 

func (m *DWHValidator) GetName() string

func (*DWHValidator) GetPrice added in v0.4.1 

func (m *DWHValidator) GetPrice() *BigInt

func (*DWHValidator) GetUrl added in v0.4.1 

func (m *DWHValidator) GetUrl() string

func (*DWHValidator) GetValidator added in v0.4.1 

func (m *DWHValidator) GetValidator() *Validator

func (*DWHValidator) ProtoMessage added in v0.4.1 

func (*DWHValidator) ProtoMessage()

func (*DWHValidator) Reset added in v0.4.1 

func (m *DWHValidator) Reset()

func (*DWHValidator) String added in v0.4.1 

func (m *DWHValidator) String() string

type DWHWorker added in v0.4.1 

type DWHWorker struct {
	MasterID  *EthAddress `protobuf:"bytes,1,opt,name=masterID" json:"masterID,omitempty"`
	SlaveID   *EthAddress `protobuf:"bytes,2,opt,name=slaveID" json:"slaveID,omitempty"`
	Confirmed bool        `protobuf:"varint,3,opt,name=confirmed" json:"confirmed,omitempty"`
}

func (*DWHWorker) Descriptor added in v0.4.1 

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

func (*DWHWorker) GetConfirmed added in v0.4.1 

func (m *DWHWorker) GetConfirmed() bool

func (*DWHWorker) GetMasterID added in v0.4.1 

func (m *DWHWorker) GetMasterID() *EthAddress

func (*DWHWorker) GetSlaveID added in v0.4.1 

func (m *DWHWorker) GetSlaveID() *EthAddress

func (*DWHWorker) ProtoMessage added in v0.4.1 

func (*DWHWorker) ProtoMessage()

func (*DWHWorker) Reset added in v0.4.1 

func (m *DWHWorker) Reset()

func (*DWHWorker) String added in v0.4.1 

func (m *DWHWorker) String() string

type DataSize added in v0.4.1 

type DataSize struct {
	Bytes uint64 `protobuf:"varint,1,opt,name=bytes" json:"bytes,omitempty"`
}

func (*DataSize) Descriptor added in v0.4.1 

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

func (*DataSize) GetBytes added in v0.4.1 

func (m *DataSize) GetBytes() uint64

func (*DataSize) MarshalYAML added in v0.4.1 

func (m *DataSize) MarshalYAML() (interface{}, error)

func (*DataSize) ProtoMessage added in v0.4.1 

func (*DataSize) ProtoMessage()

func (*DataSize) Reset added in v0.4.1 

func (m *DataSize) Reset()

func (*DataSize) String added in v0.4.1 

func (m *DataSize) String() string

func (*DataSize) UnmarshalYAML added in v0.4.1 

func (m *DataSize) UnmarshalYAML(unmarshal func(interface{}) error) error

func (*DataSize) Unwrap added in v0.4.1 

func (m *DataSize) Unwrap() datasize.ByteSize

type DataSizeRate added in v0.4.1 

type DataSizeRate struct {
	BitsPerSecond uint64 `protobuf:"varint,1,opt,name=bitsPerSecond" json:"bitsPerSecond,omitempty"`
}

func (*DataSizeRate) Descriptor added in v0.4.1 

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

func (*DataSizeRate) GetBitsPerSecond added in v0.4.1 

func (m *DataSizeRate) GetBitsPerSecond() uint64

func (*DataSizeRate) MarshalYAML added in v0.4.1 

func (m *DataSizeRate) MarshalYAML() (interface{}, error)

func (*DataSizeRate) ProtoMessage added in v0.4.1 

func (*DataSizeRate) ProtoMessage()

func (*DataSizeRate) Reset added in v0.4.1 

func (m *DataSizeRate) Reset()

func (*DataSizeRate) String added in v0.4.1 

func (m *DataSizeRate) String() string

func (*DataSizeRate) UnmarshalYAML added in v0.4.1 

func (m *DataSizeRate) UnmarshalYAML(unmarshal func(interface{}) error) error

func (*DataSizeRate) Unwrap added in v0.4.1 

func (m *DataSizeRate) Unwrap() datasize.BitRate

type Deal 

type Deal struct {
	Id             *BigInt     `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
	Benchmarks     *Benchmarks `protobuf:"bytes,2,opt,name=benchmarks" json:"benchmarks,omitempty"`
	SupplierID     *EthAddress `protobuf:"bytes,3,opt,name=supplierID" json:"supplierID,omitempty"`
	ConsumerID     *EthAddress `protobuf:"bytes,4,opt,name=consumerID" json:"consumerID,omitempty"`
	MasterID       *EthAddress `protobuf:"bytes,5,opt,name=masterID" json:"masterID,omitempty"`
	AskID          *BigInt     `protobuf:"bytes,6,opt,name=askID" json:"askID,omitempty"`
	BidID          *BigInt     `protobuf:"bytes,7,opt,name=bidID" json:"bidID,omitempty"`
	Duration       uint64      `protobuf:"varint,8,opt,name=duration" json:"duration,omitempty"`
	Price          *BigInt     `protobuf:"bytes,9,opt,name=price" json:"price,omitempty"`
	StartTime      *Timestamp  `protobuf:"bytes,10,opt,name=startTime" json:"startTime,omitempty"`
	EndTime        *Timestamp  `protobuf:"bytes,11,opt,name=endTime" json:"endTime,omitempty"`
	Status         DealStatus  `protobuf:"varint,12,opt,name=status,enum=sonm.DealStatus" json:"status,omitempty"`
	BlockedBalance *BigInt     `protobuf:"bytes,13,opt,name=blockedBalance" json:"blockedBalance,omitempty"`
	TotalPayout    *BigInt     `protobuf:"bytes,14,opt,name=totalPayout" json:"totalPayout,omitempty"`
	LastBillTS     *Timestamp  `protobuf:"bytes,15,opt,name=lastBillTS" json:"lastBillTS,omitempty"`
}

func (*Deal) Descriptor 

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

func (*Deal) GetAskID added in v0.4.1 

func (m *Deal) GetAskID() *BigInt

func (*Deal) GetBenchmarks added in v0.4.1 

func (m *Deal) GetBenchmarks() *Benchmarks

func (*Deal) GetBidID added in v0.4.1 

func (m *Deal) GetBidID() *BigInt

func (*Deal) GetBlockedBalance added in v0.4.1 

func (m *Deal) GetBlockedBalance() *BigInt

func (*Deal) GetConsumerID added in v0.4.1 

func (m *Deal) GetConsumerID() *EthAddress

func (*Deal) GetDuration added in v0.4.1 

func (m *Deal) GetDuration() uint64

func (*Deal) GetEndTime 

func (m *Deal) GetEndTime() *Timestamp

func (*Deal) GetId 

func (m *Deal) GetId() *BigInt

func (*Deal) GetLastBillTS added in v0.4.1 

func (m *Deal) GetLastBillTS() *Timestamp

func (*Deal) GetMasterID added in v0.4.1 

func (m *Deal) GetMasterID() *EthAddress

func (*Deal) GetPrice 

func (m *Deal) GetPrice() *BigInt

func (*Deal) GetStartTime 

func (m *Deal) GetStartTime() *Timestamp

func (*Deal) GetStatus 

func (m *Deal) GetStatus() DealStatus

func (*Deal) GetSupplierID 

func (m *Deal) GetSupplierID() *EthAddress

func (*Deal) GetTotalPayout added in v0.4.1 

func (m *Deal) GetTotalPayout() *BigInt

func (*Deal) GetTypeName added in v0.4.1 

func (m *Deal) GetTypeName() string

func (*Deal) IsSpot added in v0.4.1 

func (m *Deal) IsSpot() bool

func (*Deal) PricePerHour added in v0.4.9 

func (m *Deal) PricePerHour() string

func (*Deal) ProtoMessage 

func (*Deal) ProtoMessage()

func (*Deal) Reset 

func (m *Deal) Reset()

func (*Deal) String 

func (m *Deal) String() string

func (*Deal) TotalPrice added in v0.4.1 

func (m *Deal) TotalPrice() string

type DealChangeRequest added in v0.4.1 

type DealChangeRequest struct {
	Id          *BigInt             `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
	DealID      *BigInt             `protobuf:"bytes,2,opt,name=dealID" json:"dealID,omitempty"`
	RequestType OrderType           `protobuf:"varint,3,opt,name=requestType,enum=sonm.OrderType" json:"requestType,omitempty"`
	Duration    uint64              `protobuf:"varint,4,opt,name=duration" json:"duration,omitempty"`
	Price       *BigInt             `protobuf:"bytes,5,opt,name=price" json:"price,omitempty"`
	Status      ChangeRequestStatus `protobuf:"varint,6,opt,name=status,enum=sonm.ChangeRequestStatus" json:"status,omitempty"`
	CreatedTS   *Timestamp          `protobuf:"bytes,7,opt,name=createdTS" json:"createdTS,omitempty"`
}

func (*DealChangeRequest) Descriptor added in v0.4.1 

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

func (*DealChangeRequest) GetCreatedTS added in v0.4.1 

func (m *DealChangeRequest) GetCreatedTS() *Timestamp

func (*DealChangeRequest) GetDealID added in v0.4.1 

func (m *DealChangeRequest) GetDealID() *BigInt

func (*DealChangeRequest) GetDuration added in v0.4.1 

func (m *DealChangeRequest) GetDuration() uint64

func (*DealChangeRequest) GetId added in v0.4.1 

func (m *DealChangeRequest) GetId() *BigInt

func (*DealChangeRequest) GetPrice added in v0.4.1 

func (m *DealChangeRequest) GetPrice() *BigInt

func (*DealChangeRequest) GetRequestType added in v0.4.1 

func (m *DealChangeRequest) GetRequestType() OrderType

func (*DealChangeRequest) GetStatus added in v0.4.1 

func (m *DealChangeRequest) GetStatus() ChangeRequestStatus

func (*DealChangeRequest) ProtoMessage added in v0.4.1 

func (*DealChangeRequest) ProtoMessage()

func (*DealChangeRequest) Reset added in v0.4.1 

func (m *DealChangeRequest) Reset()

func (*DealChangeRequest) String added in v0.4.1 

func (m *DealChangeRequest) String() string

type DealChangeRequestsReply added in v0.4.1 

type DealChangeRequestsReply struct {
	Requests []*DealChangeRequest `protobuf:"bytes,1,rep,name=requests" json:"requests,omitempty"`
}

func (*DealChangeRequestsReply) Descriptor added in v0.4.1 

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

func (*DealChangeRequestsReply) GetRequests added in v0.4.1 

func (m *DealChangeRequestsReply) GetRequests() []*DealChangeRequest

func (*DealChangeRequestsReply) ProtoMessage added in v0.4.1 

func (*DealChangeRequestsReply) ProtoMessage()

func (*DealChangeRequestsReply) Reset added in v0.4.1 

func (m *DealChangeRequestsReply) Reset()

func (*DealChangeRequestsReply) String added in v0.4.1 

func (m *DealChangeRequestsReply) String() string

type DealCondition added in v0.4.1 

type DealCondition struct {
	Id          uint64      `protobuf:"varint,1,opt,name=id" json:"id,omitempty"`
	SupplierID  *EthAddress `protobuf:"bytes,2,opt,name=supplierID" json:"supplierID,omitempty"`
	ConsumerID  *EthAddress `protobuf:"bytes,3,opt,name=consumerID" json:"consumerID,omitempty"`
	MasterID    *EthAddress `protobuf:"bytes,4,opt,name=masterID" json:"masterID,omitempty"`
	Duration    uint64      `protobuf:"varint,5,opt,name=duration" json:"duration,omitempty"`
	Price       *BigInt     `protobuf:"bytes,6,opt,name=price" json:"price,omitempty"`
	StartTime   *Timestamp  `protobuf:"bytes,7,opt,name=startTime" json:"startTime,omitempty"`
	EndTime     *Timestamp  `protobuf:"bytes,8,opt,name=endTime" json:"endTime,omitempty"`
	TotalPayout *BigInt     `protobuf:"bytes,9,opt,name=totalPayout" json:"totalPayout,omitempty"`
	DealID      *BigInt     `protobuf:"bytes,10,opt,name=dealID" json:"dealID,omitempty"`
}

func (*DealCondition) Descriptor added in v0.4.1 

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

func (*DealCondition) GetConsumerID added in v0.4.1 

func (m *DealCondition) GetConsumerID() *EthAddress

func (*DealCondition) GetDealID added in v0.4.1 

func (m *DealCondition) GetDealID() *BigInt

func (*DealCondition) GetDuration added in v0.4.1 

func (m *DealCondition) GetDuration() uint64

func (*DealCondition) GetEndTime added in v0.4.1 

func (m *DealCondition) GetEndTime() *Timestamp

func (*DealCondition) GetId added in v0.4.1 

func (m *DealCondition) GetId() uint64

func (*DealCondition) GetMasterID added in v0.4.1 

func (m *DealCondition) GetMasterID() *EthAddress

func (*DealCondition) GetPrice added in v0.4.1 

func (m *DealCondition) GetPrice() *BigInt

func (*DealCondition) GetStartTime added in v0.4.1 

func (m *DealCondition) GetStartTime() *Timestamp

func (*DealCondition) GetSupplierID added in v0.4.1 

func (m *DealCondition) GetSupplierID() *EthAddress

func (*DealCondition) GetTotalPayout added in v0.4.1 

func (m *DealCondition) GetTotalPayout() *BigInt

func (*DealCondition) ProtoMessage added in v0.4.1 

func (*DealCondition) ProtoMessage()

func (*DealCondition) Reset added in v0.4.1 

func (m *DealCondition) Reset()

func (*DealCondition) String added in v0.4.1 

func (m *DealCondition) String() string

type DealConditionsReply added in v0.4.1 

type DealConditionsReply struct {
	Conditions []*DealCondition `protobuf:"bytes,1,rep,name=conditions" json:"conditions,omitempty"`
	Count      uint64           `protobuf:"varint,2,opt,name=count" json:"count,omitempty"`
}

func (*DealConditionsReply) Descriptor added in v0.4.1 

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

func (*DealConditionsReply) GetConditions added in v0.4.1 

func (m *DealConditionsReply) GetConditions() []*DealCondition

func (*DealConditionsReply) GetCount added in v0.4.1 

func (m *DealConditionsReply) GetCount() uint64

func (*DealConditionsReply) ProtoMessage added in v0.4.1 

func (*DealConditionsReply) ProtoMessage()

func (*DealConditionsReply) Reset added in v0.4.1 

func (m *DealConditionsReply) Reset()

func (*DealConditionsReply) String added in v0.4.1 

func (m *DealConditionsReply) String() string

type DealConditionsRequest added in v0.4.1 

type DealConditionsRequest struct {
	DealID    *BigInt          `protobuf:"bytes,1,opt,name=dealID" json:"dealID,omitempty"`
	Limit     uint64           `protobuf:"varint,2,opt,name=limit" json:"limit,omitempty"`
	Offset    uint64           `protobuf:"varint,3,opt,name=offset" json:"offset,omitempty"`
	Sortings  []*SortingOption `protobuf:"bytes,4,rep,name=sortings" json:"sortings,omitempty"`
	WithCount bool             `protobuf:"varint,5,opt,name=withCount" json:"withCount,omitempty"`
}

func (*DealConditionsRequest) Descriptor added in v0.4.1 

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

func (*DealConditionsRequest) GetDealID added in v0.4.1 

func (m *DealConditionsRequest) GetDealID() *BigInt

func (*DealConditionsRequest) GetLimit added in v0.4.1 

func (m *DealConditionsRequest) GetLimit() uint64

func (*DealConditionsRequest) GetOffset added in v0.4.1 

func (m *DealConditionsRequest) GetOffset() uint64

func (*DealConditionsRequest) GetSortings added in v0.4.1 

func (m *DealConditionsRequest) GetSortings() []*SortingOption

func (*DealConditionsRequest) GetWithCount added in v0.4.1 

func (m *DealConditionsRequest) GetWithCount() bool

func (*DealConditionsRequest) ProtoMessage added in v0.4.1 

func (*DealConditionsRequest) ProtoMessage()

func (*DealConditionsRequest) Reset added in v0.4.1 

func (m *DealConditionsRequest) Reset()

func (*DealConditionsRequest) String added in v0.4.1 

func (m *DealConditionsRequest) String() string

type DealFinishRequest added in v0.4.1 

type DealFinishRequest struct {
	Id            *BigInt       `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
	BlacklistType BlacklistType `protobuf:"varint,2,opt,name=blacklistType,enum=sonm.BlacklistType" json:"blacklistType,omitempty"`
}

func (*DealFinishRequest) Descriptor added in v0.4.1 

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

func (*DealFinishRequest) GetBlacklistType added in v0.4.1 

func (m *DealFinishRequest) GetBlacklistType() BlacklistType

func (*DealFinishRequest) GetId added in v0.4.1 

func (m *DealFinishRequest) GetId() *BigInt

func (*DealFinishRequest) ProtoMessage added in v0.4.1 

func (*DealFinishRequest) ProtoMessage()

func (*DealFinishRequest) Reset added in v0.4.1 

func (m *DealFinishRequest) Reset()

func (*DealFinishRequest) String added in v0.4.1 

func (m *DealFinishRequest) String() string

type DealInfoReply 

type DealInfoReply struct {
	Deal *Deal `protobuf:"bytes,1,opt,name=deal" json:"deal,omitempty"`
	// List of currently running tasks.
	Running map[string]*TaskStatusReply `` /* 134-byte string literal not displayed */
	// List of completed tasks.
	Completed map[string]*TaskStatusReply `` /* 138-byte string literal not displayed */
	// Resources is a real resources (cores, ram bytes, GPU devices, etc)
	// allocated on a worker for this deal.
	Resources *AskPlanResources `protobuf:"bytes,4,opt,name=resources" json:"resources,omitempty"`
	PublicIPs []string          `protobuf:"bytes,5,rep,name=publicIPs" json:"publicIPs,omitempty"`
}

func (*DealInfoReply) Descriptor 

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

func (*DealInfoReply) GetCompleted added in v0.3.2 

func (m *DealInfoReply) GetCompleted() map[string]*TaskStatusReply

func (*DealInfoReply) GetDeal added in v0.4.1 

func (m *DealInfoReply) GetDeal() *Deal

func (*DealInfoReply) GetPublicIPs added in v0.4.10 

func (m *DealInfoReply) GetPublicIPs() []string

func (*DealInfoReply) GetResources added in v0.4.1 

func (m *DealInfoReply) GetResources() *AskPlanResources

func (*DealInfoReply) GetRunning added in v0.3.2 

func (m *DealInfoReply) GetRunning() map[string]*TaskStatusReply

func (*DealInfoReply) ProtoMessage 

func (*DealInfoReply) ProtoMessage()

func (*DealInfoReply) Reset 

func (m *DealInfoReply) Reset()

func (*DealInfoReply) String 

func (m *DealInfoReply) String() string

type DealManagementClient 

type DealManagementClient interface {
	// List produces a list of all deals made by client with given ID
	List(ctx context.Context, in *Count, opts ...grpc.CallOption) (*DealsReply, error)
	// Status produces a detailed info about deal with given ID.
	Status(ctx context.Context, in *BigInt, opts ...grpc.CallOption) (*DealInfoReply, error)
	// Finish finishes a deal with given ID
	// Deprecated: use FinishDeals instead
	Finish(ctx context.Context, in *DealFinishRequest, opts ...grpc.CallOption) (*Empty, error)
	// FinishDeals finishes deals with given IDs
	FinishDeals(ctx context.Context, in *DealsFinishRequest, opts ...grpc.CallOption) (*ErrorByID, error)
	// PurgeDeals finishes all deals where client acts as a consumer
	PurgeDeals(ctx context.Context, in *DealsPurgeRequest, opts ...grpc.CallOption) (*ErrorByID, error)
	// Open tries to open deal between two orders
	Open(ctx context.Context, in *OpenDealRequest, opts ...grpc.CallOption) (*Deal, error)
	// ChangeRequestsList return change requests for given deal
	ChangeRequestsList(ctx context.Context, in *BigInt, opts ...grpc.CallOption) (*DealChangeRequestsReply, error)
	// CreateChangeRequest creates new change request for deal
	CreateChangeRequest(ctx context.Context, in *DealChangeRequest, opts ...grpc.CallOption) (*BigInt, error)
	// ApproveChangeRequest approves change request by their ID
	ApproveChangeRequest(ctx context.Context, in *BigInt, opts ...grpc.CallOption) (*Empty, error)
	// CancelChangeRequest removes pending change request
	CancelChangeRequest(ctx context.Context, in *BigInt, opts ...grpc.CallOption) (*Empty, error)
	// QuickBuy places BID order with the same parameters as given ASK order have,
	// then opens deal with this two orders.
	QuickBuy(ctx context.Context, in *QuickBuyRequest, opts ...grpc.CallOption) (*DealInfoReply, error)
}

func NewDealManagementClient 

func NewDealManagementClient(cc *grpc.ClientConn) DealManagementClient

type DealManagementServer 

type DealManagementServer interface {
	// List produces a list of all deals made by client with given ID
	List(context.Context, *Count) (*DealsReply, error)
	// Status produces a detailed info about deal with given ID.
	Status(context.Context, *BigInt) (*DealInfoReply, error)
	// Finish finishes a deal with given ID
	// Deprecated: use FinishDeals instead
	Finish(context.Context, *DealFinishRequest) (*Empty, error)
	// FinishDeals finishes deals with given IDs
	FinishDeals(context.Context, *DealsFinishRequest) (*ErrorByID, error)
	// PurgeDeals finishes all deals where client acts as a consumer
	PurgeDeals(context.Context, *DealsPurgeRequest) (*ErrorByID, error)
	// Open tries to open deal between two orders
	Open(context.Context, *OpenDealRequest) (*Deal, error)
	// ChangeRequestsList return change requests for given deal
	ChangeRequestsList(context.Context, *BigInt) (*DealChangeRequestsReply, error)
	// CreateChangeRequest creates new change request for deal
	CreateChangeRequest(context.Context, *DealChangeRequest) (*BigInt, error)
	// ApproveChangeRequest approves change request by their ID
	ApproveChangeRequest(context.Context, *BigInt) (*Empty, error)
	// CancelChangeRequest removes pending change request
	CancelChangeRequest(context.Context, *BigInt) (*Empty, error)
	// QuickBuy places BID order with the same parameters as given ASK order have,
	// then opens deal with this two orders.
	QuickBuy(context.Context, *QuickBuyRequest) (*DealInfoReply, error)
}

type DealPayment added in v0.4.1 

type DealPayment struct {
	DealID      *BigInt    `protobuf:"bytes,1,opt,name=dealID" json:"dealID,omitempty"`
	PayedAmount *BigInt    `protobuf:"bytes,2,opt,name=payedAmount" json:"payedAmount,omitempty"`
	PaymentTS   *Timestamp `protobuf:"bytes,3,opt,name=paymentTS" json:"paymentTS,omitempty"`
}

func (*DealPayment) Descriptor added in v0.4.1 

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

func (*DealPayment) GetDealID added in v0.4.1 

func (m *DealPayment) GetDealID() *BigInt

func (*DealPayment) GetPayedAmount added in v0.4.1 

func (m *DealPayment) GetPayedAmount() *BigInt

func (*DealPayment) GetPaymentTS added in v0.4.1 

func (m *DealPayment) GetPaymentTS() *Timestamp

func (*DealPayment) ProtoMessage added in v0.4.1 

func (*DealPayment) ProtoMessage()

func (*DealPayment) Reset added in v0.4.1 

func (m *DealPayment) Reset()

func (*DealPayment) String added in v0.4.1 

func (m *DealPayment) String() string

type DealStatus 

type DealStatus int32
const (
	DealStatus_DEAL_UNKNOWN  DealStatus = 0
	DealStatus_DEAL_ACCEPTED DealStatus = 1
	DealStatus_DEAL_CLOSED   DealStatus = 2
)

func (DealStatus) EnumDescriptor 

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

func (DealStatus) String 

func (x DealStatus) String() string

type DealsFinishRequest added in v0.4.10 

type DealsFinishRequest struct {
	DealInfo []*DealFinishRequest `protobuf:"bytes,1,rep,name=dealInfo" json:"dealInfo,omitempty"`
}

func (*DealsFinishRequest) Descriptor added in v0.4.10 

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

func (*DealsFinishRequest) GetDealInfo added in v0.4.10 

func (m *DealsFinishRequest) GetDealInfo() []*DealFinishRequest

func (*DealsFinishRequest) ProtoMessage added in v0.4.10 

func (*DealsFinishRequest) ProtoMessage()

func (*DealsFinishRequest) Reset added in v0.4.10 

func (m *DealsFinishRequest) Reset()

func (*DealsFinishRequest) String added in v0.4.10 

func (m *DealsFinishRequest) String() string

type DealsPurgeRequest added in v0.4.10 

type DealsPurgeRequest struct {
	BlacklistType BlacklistType `protobuf:"varint,1,opt,name=blacklistType,enum=sonm.BlacklistType" json:"blacklistType,omitempty"`
}

func (*DealsPurgeRequest) Descriptor added in v0.4.10 

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

func (*DealsPurgeRequest) GetBlacklistType added in v0.4.10 

func (m *DealsPurgeRequest) GetBlacklistType() BlacklistType

func (*DealsPurgeRequest) ProtoMessage added in v0.4.10 

func (*DealsPurgeRequest) ProtoMessage()

func (*DealsPurgeRequest) Reset added in v0.4.10 

func (m *DealsPurgeRequest) Reset()

func (*DealsPurgeRequest) String added in v0.4.10 

func (m *DealsPurgeRequest) String() string

type DealsReply added in v0.4.1 

type DealsReply struct {
	Deal []*Deal `protobuf:"bytes,1,rep,name=deal" json:"deal,omitempty"`
}

func (*DealsReply) Descriptor added in v0.4.1 

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

func (*DealsReply) GetDeal added in v0.4.1 

func (m *DealsReply) GetDeal() []*Deal

func (*DealsReply) ProtoMessage added in v0.4.1 

func (*DealsReply) ProtoMessage()

func (*DealsReply) Reset added in v0.4.1 

func (m *DealsReply) Reset()

func (*DealsReply) String added in v0.4.1 

func (m *DealsReply) String() string

type DealsRequest added in v0.4.1 

type DealsRequest struct {
	Status           DealStatus               `protobuf:"varint,1,opt,name=status,enum=sonm.DealStatus" json:"status,omitempty"`
	SupplierID       *EthAddress              `protobuf:"bytes,2,opt,name=supplierID" json:"supplierID,omitempty"`
	ConsumerID       *EthAddress              `protobuf:"bytes,3,opt,name=consumerID" json:"consumerID,omitempty"`
	MasterID         *EthAddress              `protobuf:"bytes,4,opt,name=masterID" json:"masterID,omitempty"`
	AskID            *BigInt                  `protobuf:"bytes,5,opt,name=askID" json:"askID,omitempty"`
	BidID            *BigInt                  `protobuf:"bytes,6,opt,name=bidID" json:"bidID,omitempty"`
	Duration         *MaxMinUint64            `protobuf:"bytes,7,opt,name=duration" json:"duration,omitempty"`
	Price            *MaxMinBig               `protobuf:"bytes,8,opt,name=price" json:"price,omitempty"`
	Netflags         *CmpUint64               `protobuf:"bytes,9,opt,name=netflags" json:"netflags,omitempty"`
	AskIdentityLevel IdentityLevel            `protobuf:"varint,10,opt,name=askIdentityLevel,enum=sonm.IdentityLevel" json:"askIdentityLevel,omitempty"`
	BidIdentityLevel IdentityLevel            `protobuf:"varint,11,opt,name=bidIdentityLevel,enum=sonm.IdentityLevel" json:"bidIdentityLevel,omitempty"`
	Benchmarks       map[uint64]*MaxMinUint64 `` /* 142-byte string literal not displayed */
	Limit            uint64                   `protobuf:"varint,13,opt,name=limit" json:"limit,omitempty"`
	Offset           uint64                   `protobuf:"varint,14,opt,name=offset" json:"offset,omitempty"`
	Sortings         []*SortingOption         `protobuf:"bytes,15,rep,name=sortings" json:"sortings,omitempty"`
	WithCount        bool                     `protobuf:"varint,16,opt,name=withCount" json:"withCount,omitempty"`
	// If provided, supplierID, consumerID, and masterID fields are ignored.
	// Any of the above IDs must match the provided value.
	AnyUserID *EthAddress `protobuf:"bytes,17,opt,name=anyUserID" json:"anyUserID,omitempty"`
}

func (*DealsRequest) Descriptor added in v0.4.1 

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

func (*DealsRequest) GetAnyUserID added in v0.4.1 

func (m *DealsRequest) GetAnyUserID() *EthAddress

func (*DealsRequest) GetAskID added in v0.4.1 

func (m *DealsRequest) GetAskID() *BigInt

func (*DealsRequest) GetAskIdentityLevel added in v0.4.1 

func (m *DealsRequest) GetAskIdentityLevel() IdentityLevel

func (*DealsRequest) GetBenchmarks added in v0.4.1 

func (m *DealsRequest) GetBenchmarks() map[uint64]*MaxMinUint64

func (*DealsRequest) GetBidID added in v0.4.1 

func (m *DealsRequest) GetBidID() *BigInt

func (*DealsRequest) GetBidIdentityLevel added in v0.4.1 

func (m *DealsRequest) GetBidIdentityLevel() IdentityLevel

func (*DealsRequest) GetConsumerID added in v0.4.1 

func (m *DealsRequest) GetConsumerID() *EthAddress

func (*DealsRequest) GetDuration added in v0.4.1 

func (m *DealsRequest) GetDuration() *MaxMinUint64

func (*DealsRequest) GetLimit added in v0.4.1 

func (m *DealsRequest) GetLimit() uint64

func (*DealsRequest) GetMasterID added in v0.4.1 

func (m *DealsRequest) GetMasterID() *EthAddress

func (*DealsRequest) GetNetflags added in v0.4.1 

func (m *DealsRequest) GetNetflags() *CmpUint64

func (*DealsRequest) GetOffset added in v0.4.1 

func (m *DealsRequest) GetOffset() uint64

func (*DealsRequest) GetPrice added in v0.4.1 

func (m *DealsRequest) GetPrice() *MaxMinBig

func (*DealsRequest) GetSortings added in v0.4.1 

func (m *DealsRequest) GetSortings() []*SortingOption

func (*DealsRequest) GetStatus added in v0.4.1 

func (m *DealsRequest) GetStatus() DealStatus

func (*DealsRequest) GetSupplierID added in v0.4.1 

func (m *DealsRequest) GetSupplierID() *EthAddress

func (*DealsRequest) GetWithCount added in v0.4.1 

func (m *DealsRequest) GetWithCount() bool

func (*DealsRequest) ProtoMessage added in v0.4.1 

func (*DealsRequest) ProtoMessage()

func (*DealsRequest) Reset added in v0.4.1 

func (m *DealsRequest) Reset()

func (*DealsRequest) String added in v0.4.1 

func (m *DealsRequest) String() string

type DebugStateReply added in v0.4.1 

type DebugStateReply struct {
	SchedulerData *SchedulerData `protobuf:"bytes,1,opt,name=schedulerData" json:"schedulerData,omitempty"`
	SalesmanData  *SalesmanData  `protobuf:"bytes,2,opt,name=salesmanData" json:"salesmanData,omitempty"`
}

func (*DebugStateReply) Descriptor added in v0.4.1 

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

func (*DebugStateReply) GetSalesmanData added in v0.4.1 

func (m *DebugStateReply) GetSalesmanData() *SalesmanData

func (*DebugStateReply) GetSchedulerData added in v0.4.1 

func (m *DebugStateReply) GetSchedulerData() *SchedulerData

func (*DebugStateReply) ProtoMessage added in v0.4.1 

func (*DebugStateReply) ProtoMessage()

func (*DebugStateReply) Reset added in v0.4.1 

func (m *DebugStateReply) Reset()

func (*DebugStateReply) String added in v0.4.1 

func (m *DebugStateReply) String() string

type DeviceType added in v0.4.1 

type DeviceType int32

BenchmarkType describes hardware group for which this benchmark is applicable 

const (
	DeviceType_DEV_UNKNOWN     DeviceType = 0
	DeviceType_DEV_CPU         DeviceType = 1
	DeviceType_DEV_GPU         DeviceType = 2
	DeviceType_DEV_RAM         DeviceType = 3
	DeviceType_DEV_STORAGE     DeviceType = 4
	DeviceType_DEV_NETWORK_IN  DeviceType = 5
	DeviceType_DEV_NETWORK_OUT DeviceType = 6
)

func (DeviceType) EnumDescriptor added in v0.4.1 

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

func (DeviceType) String added in v0.4.1 

func (x DeviceType) String() string

type DevicesReply 

type DevicesReply struct {
	CPU     *CPU     `protobuf:"bytes,1,opt,name=CPU" json:"CPU,omitempty"`
	GPUs    []*GPU   `protobuf:"bytes,2,rep,name=GPUs" json:"GPUs,omitempty"`
	RAM     *RAM     `protobuf:"bytes,3,opt,name=RAM" json:"RAM,omitempty"`
	Network *Network `protobuf:"bytes,4,opt,name=network" json:"network,omitempty"`
	Storage *Storage `protobuf:"bytes,5,opt,name=storage" json:"storage,omitempty"`
}

func (*DevicesReply) Descriptor 

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

func (*DevicesReply) GetCPU added in v0.4.1 

func (m *DevicesReply) GetCPU() *CPU

func (*DevicesReply) GetGPUs 

func (m *DevicesReply) GetGPUs() []*GPU

func (*DevicesReply) GetNetwork added in v0.4.1 

func (m *DevicesReply) GetNetwork() *Network

func (*DevicesReply) GetRAM added in v0.4.1 

func (m *DevicesReply) GetRAM() *RAM

func (*DevicesReply) GetStorage added in v0.4.1 

func (m *DevicesReply) GetStorage() *Storage

func (*DevicesReply) ProtoMessage 

func (*DevicesReply) ProtoMessage()

func (*DevicesReply) Reset 

func (m *DevicesReply) Reset()

func (*DevicesReply) String 

func (m *DevicesReply) String() string

type DiscoverResponse added in v0.4.1 

type DiscoverResponse struct {
	// Addr represents network address in form "host:port".
	Addr string `protobuf:"bytes,1,opt,name=addr" json:"addr,omitempty"`
}

func (*DiscoverResponse) Descriptor added in v0.4.1 

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

func (*DiscoverResponse) GetAddr added in v0.4.1 

func (m *DiscoverResponse) GetAddr() string

func (*DiscoverResponse) ProtoMessage added in v0.4.1 

func (*DiscoverResponse) ProtoMessage()

func (*DiscoverResponse) Reset added in v0.4.1 

func (m *DiscoverResponse) Reset()

func (*DiscoverResponse) String added in v0.4.1 

func (m *DiscoverResponse) String() string

type Duration added in v0.4.1 

type Duration struct {
	Nanoseconds int64 `protobuf:"varint,1,opt,name=nanoseconds" json:"nanoseconds,omitempty"`
}

func (*Duration) Descriptor added in v0.4.1 

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

func (*Duration) GetNanoseconds added in v0.4.1 

func (m *Duration) GetNanoseconds() int64

func (*Duration) MarshalYAML added in v0.4.1 

func (m *Duration) MarshalYAML() (interface{}, error)

func (*Duration) ProtoMessage added in v0.4.1 

func (*Duration) ProtoMessage()

func (*Duration) Reset added in v0.4.1 

func (m *Duration) Reset()

func (*Duration) String added in v0.4.1 

func (m *Duration) String() string

func (*Duration) UnmarshalYAML added in v0.4.1 

func (m *Duration) UnmarshalYAML(unmarshal func(interface{}) error) error

func (*Duration) Unwrap added in v0.4.1 

func (m *Duration) Unwrap() time.Duration

type Empty 

type Empty struct {
}

func (*Empty) Descriptor 

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

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) Reset 

func (m *Empty) Reset()

func (*Empty) String 

func (m *Empty) String() string

type Endpoints added in v0.3.2 

type Endpoints struct {
	Endpoints []*SocketAddr `protobuf:"bytes,1,rep,name=endpoints" json:"endpoints,omitempty"`
}

func (*Endpoints) Descriptor added in v0.3.2 

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

func (*Endpoints) GetEndpoints added in v0.3.2 

func (m *Endpoints) GetEndpoints() []*SocketAddr

func (*Endpoints) ProtoMessage added in v0.3.2 

func (*Endpoints) ProtoMessage()

func (*Endpoints) Reset added in v0.3.2 

func (m *Endpoints) Reset()

func (*Endpoints) String added in v0.3.2 

func (m *Endpoints) String() string

type ErrorByID added in v0.4.10 

type ErrorByID struct {
	Response []*ErrorByID_Item `protobuf:"bytes,1,rep,name=response" json:"response,omitempty"`
}

func (*ErrorByID) Descriptor added in v0.4.10 

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

func (*ErrorByID) GetResponse added in v0.4.10 

func (m *ErrorByID) GetResponse() []*ErrorByID_Item

func (*ErrorByID) ProtoMessage added in v0.4.10 

func (*ErrorByID) ProtoMessage()

func (*ErrorByID) Reset added in v0.4.10 

func (m *ErrorByID) Reset()

func (*ErrorByID) String added in v0.4.10 

func (m *ErrorByID) String() string

type ErrorByID_Item added in v0.4.10 

type ErrorByID_Item struct {
	Id    *BigInt `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
	Error string  `protobuf:"bytes,3,opt,name=error" json:"error,omitempty"`
}

func (*ErrorByID_Item) Descriptor added in v0.4.10 

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

func (*ErrorByID_Item) GetError added in v0.4.10 

func (m *ErrorByID_Item) GetError() string

func (*ErrorByID_Item) GetId added in v0.4.10 

func (m *ErrorByID_Item) GetId() *BigInt

func (*ErrorByID_Item) ProtoMessage added in v0.4.10 

func (*ErrorByID_Item) ProtoMessage()

func (*ErrorByID_Item) Reset added in v0.4.10 

func (m *ErrorByID_Item) Reset()

func (*ErrorByID_Item) String added in v0.4.10 

func (m *ErrorByID_Item) String() string

type ErrorByStringID added in v0.4.13 

type ErrorByStringID struct {
	Response []*ErrorByStringID_Item `protobuf:"bytes,1,rep,name=response" json:"response,omitempty"`
}

func (*ErrorByStringID) Descriptor added in v0.4.13 

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

func (*ErrorByStringID) GetResponse added in v0.4.13 

func (m *ErrorByStringID) GetResponse() []*ErrorByStringID_Item

func (*ErrorByStringID) ProtoMessage added in v0.4.13 

func (*ErrorByStringID) ProtoMessage()

func (*ErrorByStringID) Reset added in v0.4.13 

func (m *ErrorByStringID) Reset()

func (*ErrorByStringID) String added in v0.4.13 

func (m *ErrorByStringID) String() string

type ErrorByStringID_Item added in v0.4.13 

type ErrorByStringID_Item struct {
	ID    string `protobuf:"bytes,1,opt,name=ID" json:"ID,omitempty"`
	Error string `protobuf:"bytes,2,opt,name=error" json:"error,omitempty"`
}

func (*ErrorByStringID_Item) Descriptor added in v0.4.13 

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

func (*ErrorByStringID_Item) GetError added in v0.4.13 

func (m *ErrorByStringID_Item) GetError() string

func (*ErrorByStringID_Item) GetID added in v0.4.13 

func (m *ErrorByStringID_Item) GetID() string

func (*ErrorByStringID_Item) ProtoMessage added in v0.4.13 

func (*ErrorByStringID_Item) ProtoMessage()

func (*ErrorByStringID_Item) Reset added in v0.4.13 

func (m *ErrorByStringID_Item) Reset()

func (*ErrorByStringID_Item) String added in v0.4.13 

func (m *ErrorByStringID_Item) String() string

type EthAddress added in v0.4.1 

type EthAddress struct {
	Address []byte `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
}

func NewEthAddress added in v0.4.1 

func NewEthAddress(addr common.Address) *EthAddress

func NewEthAddressFromHex added in v0.4.5 

func NewEthAddressFromHex(hexAddr string) (*EthAddress, error)

func (*EthAddress) Descriptor added in v0.4.1 

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

func (*EthAddress) GetAddress added in v0.4.1 

func (m *EthAddress) GetAddress() []byte

func (*EthAddress) IsZero added in v0.4.1 

func (m *EthAddress) IsZero() bool

func (EthAddress) MarshalText added in v0.4.1 

func (m EthAddress) MarshalText() ([]byte, error)

func (*EthAddress) ProtoMessage added in v0.4.1 

func (*EthAddress) ProtoMessage()

func (*EthAddress) Reset added in v0.4.1 

func (m *EthAddress) Reset()

func (*EthAddress) String added in v0.4.1 

func (m *EthAddress) String() string

func (*EthAddress) UnmarshalText added in v0.4.1 

func (m *EthAddress) UnmarshalText(text []byte) error

func (*EthAddress) Unwrap added in v0.4.1 

func (m *EthAddress) Unwrap() common.Address

type EthID added in v0.4.1 

type EthID struct {
	Id *EthAddress `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
}

func (*EthID) Descriptor added in v0.4.1 

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

func (*EthID) GetId added in v0.4.1 

func (m *EthID) GetId() *EthAddress

func (*EthID) ProtoMessage added in v0.4.1 

func (*EthID) ProtoMessage()

func (*EthID) Reset added in v0.4.1 

func (m *EthID) Reset()

func (*EthID) String added in v0.4.1 

func (m *EthID) String() string

type FileStat added in v0.4.21 

type FileStat struct {
	// Fd shows the file descriptor number.
	Fd uint64 `protobuf:"varint,1,opt,name=fd" json:"fd,omitempty"`
	// Path shows either real path on the filesystem or its description if the
	// file is not a real file, i.e. a socket for example.
	Path string `protobuf:"bytes,2,opt,name=path" json:"path,omitempty"`
}

func (*FileStat) Descriptor added in v0.4.21 

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

func (*FileStat) GetFd added in v0.4.21 

func (m *FileStat) GetFd() uint64

func (*FileStat) GetPath added in v0.4.21 

func (m *FileStat) GetPath() string

func (*FileStat) ProtoMessage added in v0.4.21 

func (*FileStat) ProtoMessage()

func (*FileStat) Reset added in v0.4.21 

func (m *FileStat) Reset()

func (*FileStat) String added in v0.4.21 

func (m *FileStat) String() string

type GPU added in v0.4.1 

type GPU struct {
	Device     *GPUDevice            `protobuf:"bytes,1,opt,name=device" json:"device,omitempty"`
	Benchmarks map[uint64]*Benchmark `` /* 141-byte string literal not displayed */
}

func (*GPU) Descriptor added in v0.4.1 

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

func (*GPU) GetBenchmarks added in v0.4.1 

func (m *GPU) GetBenchmarks() map[uint64]*Benchmark

func (*GPU) GetDevice added in v0.4.1 

func (m *GPU) GetDevice() *GPUDevice

func (*GPU) ProtoMessage added in v0.4.1 

func (*GPU) ProtoMessage()

func (*GPU) Reset added in v0.4.1 

func (m *GPU) Reset()

func (*GPU) String added in v0.4.1 

func (m *GPU) String() string

type GPUDevice 

type GPUDevice struct {
	// ID returns unique device ID on workers machine,
	// typically PCI bus ID
	ID string `protobuf:"bytes,1,opt,name=ID" json:"ID,omitempty"`
	// VendorID returns an unique device vendor identifier
	VendorID uint64 `protobuf:"varint,2,opt,name=vendorID" json:"vendorID,omitempty"`
	// VendorName returns GPU vendor name.
	VendorName string `protobuf:"bytes,3,opt,name=vendorName" json:"vendorName,omitempty"`
	// DeviceID returns device ID (e.g.: NVidia)
	DeviceID uint64 `protobuf:"varint,5,opt,name=deviceID" json:"deviceID,omitempty"`
	// DeviceName returns device name, (e.g.: 1080Ti)
	DeviceName string `protobuf:"bytes,6,opt,name=deviceName" json:"deviceName,omitempty"`
	// MajorNumber returns device's major number
	MajorNumber uint64 `protobuf:"varint,7,opt,name=majorNumber" json:"majorNumber,omitempty"`
	// MinorNumber returns device's minor number
	MinorNumber uint64 `protobuf:"varint,8,opt,name=minorNumber" json:"minorNumber,omitempty"`
	// Memory is amount of vmem for device, in bytes
	Memory uint64 `protobuf:"varint,9,opt,name=Memory" json:"Memory,omitempty"`
	// Hash string built from device parameters
	Hash string `protobuf:"bytes,10,opt,name=hash" json:"hash,omitempty"`
	// DeviceFiles is something like "/dev/nvidia0",
	// "/dev/nvidiactl", "/dev/dri/card0" and so on.
	// This devices should be attached to a container.
	DeviceFiles []string `protobuf:"bytes,11,rep,name=deviceFiles" json:"deviceFiles,omitempty"`
	// DriverVolumes maps volume name into
	// "hostPath:containerPath" pair.
	// Applicable to nvidia drivers.
	DriverVolumes map[string]string `` /* 147-byte string literal not displayed */
}

func (*GPUDevice) Descriptor 

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

func (*GPUDevice) FillHashID added in v0.4.1 

func (m *GPUDevice) FillHashID()

func (*GPUDevice) GetDeviceFiles added in v0.4.25 

func (m *GPUDevice) GetDeviceFiles() []string

func (*GPUDevice) GetDeviceID added in v0.4.1 

func (m *GPUDevice) GetDeviceID() uint64

func (*GPUDevice) GetDeviceName added in v0.4.1 

func (m *GPUDevice) GetDeviceName() string

func (*GPUDevice) GetDriverVolumes added in v0.4.25 

func (m *GPUDevice) GetDriverVolumes() map[string]string

func (*GPUDevice) GetHash added in v0.4.1 

func (m *GPUDevice) GetHash() string

func (*GPUDevice) GetID added in v0.4.1 

func (m *GPUDevice) GetID() string

func (*GPUDevice) GetMajorNumber added in v0.4.1 

func (m *GPUDevice) GetMajorNumber() uint64

func (*GPUDevice) GetMemory added in v0.4.1 

func (m *GPUDevice) GetMemory() uint64

func (*GPUDevice) GetMinorNumber added in v0.4.1 

func (m *GPUDevice) GetMinorNumber() uint64

func (*GPUDevice) GetVendorID added in v0.4.1 

func (m *GPUDevice) GetVendorID() uint64

func (*GPUDevice) GetVendorName 

func (m *GPUDevice) GetVendorName() string

func (*GPUDevice) ProtoMessage 

func (*GPUDevice) ProtoMessage()

func (*GPUDevice) Reset 

func (m *GPUDevice) Reset()

func (*GPUDevice) StorageKey added in v0.4.1 

func (m *GPUDevice) StorageKey() string

func (*GPUDevice) String 

func (m *GPUDevice) String() string

func (*GPUDevice) VendorType added in v0.3.2 

func (m *GPUDevice) VendorType() GPUVendorType

VendorType returns GPU vendor type.

type GPUHasher added in v0.4.1 

type GPUHasher interface {
	HashGPU(indexes []uint64) (hashes []string, err error)
}

type GPUVendorType added in v0.3.2 

type GPUVendorType int32
const (
	GPUVendorType_GPU_UNKNOWN GPUVendorType = 0
	GPUVendorType_NVIDIA      GPUVendorType = 1
	GPUVendorType_RADEON      GPUVendorType = 2
	GPUVendorType_FAKE        GPUVendorType = 99
	GPUVendorType_REMOTE      GPUVendorType = 100
)

func TypeFromVendorID added in v0.4.1 

func TypeFromVendorID(v uint64) GPUVendorType

func (GPUVendorType) EnumDescriptor added in v0.3.2 

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

func (GPUVendorType) String added in v0.3.2 

func (x GPUVendorType) String() string

type GeoIP added in v0.4.15 

type GeoIP struct {
	Country *GeoIPCountry `protobuf:"bytes,1,opt,name=country" json:"country,omitempty"`
}

func (*GeoIP) Descriptor added in v0.4.15 

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

func (*GeoIP) GetCountry added in v0.4.15 

func (m *GeoIP) GetCountry() *GeoIPCountry

func (*GeoIP) ProtoMessage added in v0.4.15 

func (*GeoIP) ProtoMessage()

func (*GeoIP) Reset added in v0.4.15 

func (m *GeoIP) Reset()

func (*GeoIP) String added in v0.4.15 

func (m *GeoIP) String() string

type GeoIPCountry added in v0.4.15 

type GeoIPCountry struct {
	IsoCode string `protobuf:"bytes,1,opt,name=IsoCode" json:"IsoCode,omitempty"`
}

func (*GeoIPCountry) Descriptor added in v0.4.15 

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

func (*GeoIPCountry) GetIsoCode added in v0.4.15 

func (m *GeoIPCountry) GetIsoCode() string

func (*GeoIPCountry) ProtoMessage added in v0.4.15 

func (*GeoIPCountry) ProtoMessage()

func (*GeoIPCountry) Reset added in v0.4.15 

func (m *GeoIPCountry) Reset()

func (*GeoIPCountry) String added in v0.4.15 

func (m *GeoIPCountry) String() string

type GetOrdersReply 

type GetOrdersReply struct {
	Orders []*Order `protobuf:"bytes,1,rep,name=orders" json:"orders,omitempty"`
}

func (*GetOrdersReply) Descriptor 

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

func (*GetOrdersReply) GetOrders 

func (m *GetOrdersReply) GetOrders() []*Order

func (*GetOrdersReply) ProtoMessage 

func (*GetOrdersReply) ProtoMessage()

func (*GetOrdersReply) Reset 

func (m *GetOrdersReply) Reset()

func (*GetOrdersReply) String 

func (m *GetOrdersReply) String() string

type HandshakeRequest added in v0.4.1 

type HandshakeRequest struct {
	// PeerType describes a peer's source.
	PeerType PeerType `protobuf:"varint,1,opt,name=peerType,enum=sonm.PeerType" json:"peerType,omitempty"`
	// Addr represents a common Ethereum address both peers are connecting
	// around.
	// In case of servers it's their own id. Must be signed. In case of
	// clients - it's the target server id.
	//
	// In case of discovery requests this field has special meaning.
	// Both client and server must discover the same relay server to be able to
	// meet each other. At this stage there is no parameter verification.
	// It is done in the Handshake method.
	Addr []byte `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr,omitempty"`
	// Signature for ETH address.
	// Should be empty for clients.
	Sign []byte `protobuf:"bytes,3,opt,name=sign,proto3" json:"sign,omitempty"`
	// Optional connection id.
	// It is used when a client wants to connect to a specific server avoiding
	// random select.
	// Should be empty for servers.
	UUID string `protobuf:"bytes,4,opt,name=UUID" json:"UUID,omitempty"`
	// Protocol describes the network protocol the peer wants to publish or to
	// resolve.
	Protocol string `protobuf:"bytes,5,opt,name=protocol" json:"protocol,omitempty"`
}

func (*HandshakeRequest) Descriptor added in v0.4.1 

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

func (*HandshakeRequest) GetAddr added in v0.4.1 

func (m *HandshakeRequest) GetAddr() []byte

func (*HandshakeRequest) GetPeerType added in v0.4.1 

func (m *HandshakeRequest) GetPeerType() PeerType

func (*HandshakeRequest) GetProtocol added in v0.4.1 

func (m *HandshakeRequest) GetProtocol() string

func (*HandshakeRequest) GetSign added in v0.4.1 

func (m *HandshakeRequest) GetSign() []byte

func (*HandshakeRequest) GetUUID added in v0.4.1 

func (m *HandshakeRequest) GetUUID() string

func (*HandshakeRequest) HasUUID added in v0.4.1 

func (m *HandshakeRequest) HasUUID() bool

HasUUID returns true if a request has UUID provided.

func (*HandshakeRequest) ProtoMessage added in v0.4.1 

func (*HandshakeRequest) ProtoMessage()

func (*HandshakeRequest) Reset added in v0.4.1 

func (m *HandshakeRequest) Reset()

func (*HandshakeRequest) String added in v0.4.1 

func (m *HandshakeRequest) String() string

func (*HandshakeRequest) Validate added in v0.4.1 

func (m *HandshakeRequest) Validate() error

Validate validates the incoming handshake request.

type HandshakeResponse added in v0.4.1 

type HandshakeResponse struct {
	// Error describes an error number.
	// Zero value means that there is no error.
	Error int32 `protobuf:"varint,1,opt,name=error" json:"error,omitempty"`
	// Description describes an error above.
	Description string `protobuf:"bytes,2,opt,name=description" json:"description,omitempty"`
}

func (*HandshakeResponse) Descriptor added in v0.4.1 

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

func (*HandshakeResponse) GetDescription added in v0.4.1 

func (m *HandshakeResponse) GetDescription() string

func (*HandshakeResponse) GetError added in v0.4.1 

func (m *HandshakeResponse) GetError() int32

func (*HandshakeResponse) ProtoMessage added in v0.4.1 

func (*HandshakeResponse) ProtoMessage()

func (*HandshakeResponse) Reset added in v0.4.1 

func (m *HandshakeResponse) Reset()

func (*HandshakeResponse) String added in v0.4.1 

func (m *HandshakeResponse) String() string

type ID 

type ID struct {
	Id string `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
}

func (*ID) Descriptor 

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

func (*ID) GetId 

func (m *ID) GetId() string

func (*ID) ProtoMessage 

func (*ID) ProtoMessage()

func (*ID) Reset 

func (m *ID) Reset()

func (*ID) String 

func (m *ID) String() string

type IdentityLevel added in v0.4.1 

type IdentityLevel int32
const (
	IdentityLevel_UNKNOWN      IdentityLevel = 0
	IdentityLevel_ANONYMOUS    IdentityLevel = 1
	IdentityLevel_REGISTERED   IdentityLevel = 2
	IdentityLevel_IDENTIFIED   IdentityLevel = 3
	IdentityLevel_PROFESSIONAL IdentityLevel = 4
)

func (IdentityLevel) EnumDescriptor added in v0.4.1 

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

func (IdentityLevel) String added in v0.4.1 

func (x IdentityLevel) String() string

func (*IdentityLevel) UnmarshalYAML added in v0.4.1 

func (m *IdentityLevel) UnmarshalYAML(unmarshal func(interface{}) error) error

type InitClient added in v0.4.29 

type InitClient interface {
	Mount(ctx context.Context, in *InitMountRequest, opts ...grpc.CallOption) (*InitMountResponse, error)
}

func NewInitClient added in v0.4.29 

func NewInitClient(cc *grpc.ClientConn) InitClient

type InitMountRequest added in v0.4.29 

type InitMountRequest struct {
}

func (*InitMountRequest) Descriptor added in v0.4.29 

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

func (*InitMountRequest) ProtoMessage added in v0.4.29 

func (*InitMountRequest) ProtoMessage()

func (*InitMountRequest) Reset added in v0.4.29 

func (m *InitMountRequest) Reset()

func (*InitMountRequest) String added in v0.4.29 

func (m *InitMountRequest) String() string

type InitMountResponse added in v0.4.29 

type InitMountResponse struct {
}

func (*InitMountResponse) Descriptor added in v0.4.29 

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

func (*InitMountResponse) ProtoMessage added in v0.4.29 

func (*InitMountResponse) ProtoMessage()

func (*InitMountResponse) Reset added in v0.4.29 

func (m *InitMountResponse) Reset()

func (*InitMountResponse) String added in v0.4.29 

func (m *InitMountResponse) String() string

type InitServer added in v0.4.29 

type InitServer interface {
	Mount(context.Context, *InitMountRequest) (*InitMountResponse, error)
}

type InspectClient added in v0.4.21 

type InspectClient interface {
	// Config returns the inspected server's configuration.
	Config(ctx context.Context, in *InspectConfigRequest, opts ...grpc.CallOption) (*InspectConfigResponse, error)
	// OpenFiles returns the list of open files of the inspected process.
	OpenFiles(ctx context.Context, in *InspectOpenFilesRequest, opts ...grpc.CallOption) (*InspectOpenFilesResponse, error)
	// Network returns host's network configuration and open connections of
	// the inspected process.
	Network(ctx context.Context, in *InspectNetworkRequest, opts ...grpc.CallOption) (*InspectNetworkResponse, error)
	// HostInfo returns information about inspected host.
	HostInfo(ctx context.Context, in *InspectHostInfoRequest, opts ...grpc.CallOption) (*InspectHostInfoResponse, error)
	// DockerInfo returns information about Docker on the inspected host.
	DockerInfo(ctx context.Context, in *InspectDockerInfoRequest, opts ...grpc.CallOption) (*InspectDockerInfoResponse, error)
	// DockerNetwork returns information about Docker network on the inspected
	// host.
	DockerNetwork(ctx context.Context, in *InspectDockerNetworkRequest, opts ...grpc.CallOption) (*InspectDockerNetworkResponse, error)
	// DockerVolumes returns information about Docker volumes on the inspected
	// host.
	DockerVolumes(ctx context.Context, in *InspectDockerVolumesRequest, opts ...grpc.CallOption) (*InspectDockerVolumesResponse, error)
	// WatchLogs subscribes for logs of the inspected process.
	WatchLogs(ctx context.Context, in *InspectWatchLogsRequest, opts ...grpc.CallOption) (Inspect_WatchLogsClient, error)
}

func NewInspectClient added in v0.4.21 

func NewInspectClient(cc *grpc.ClientConn) InspectClient

type InspectConfigRequest added in v0.4.21 

type InspectConfigRequest struct {
}

func (*InspectConfigRequest) Descriptor added in v0.4.21 

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

func (*InspectConfigRequest) ProtoMessage added in v0.4.21 

func (*InspectConfigRequest) ProtoMessage()

func (*InspectConfigRequest) Reset added in v0.4.21 

func (m *InspectConfigRequest) Reset()

func (*InspectConfigRequest) String added in v0.4.21 

func (m *InspectConfigRequest) String() string

type InspectConfigResponse added in v0.4.21 

type InspectConfigResponse struct {
	// Config represents JSON encoded configuration of the inspected entity.
	Config []byte `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
}

func (*InspectConfigResponse) Descriptor added in v0.4.21 

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

func (*InspectConfigResponse) GetConfig added in v0.4.21 

func (m *InspectConfigResponse) GetConfig() []byte

func (*InspectConfigResponse) ProtoMessage added in v0.4.21 

func (*InspectConfigResponse) ProtoMessage()

func (*InspectConfigResponse) Reset added in v0.4.21 

func (m *InspectConfigResponse) Reset()

func (*InspectConfigResponse) String added in v0.4.21 

func (m *InspectConfigResponse) String() string

type InspectDockerInfoRequest added in v0.4.21 

type InspectDockerInfoRequest struct {
}

func (*InspectDockerInfoRequest) Descriptor added in v0.4.21 

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

func (*InspectDockerInfoRequest) ProtoMessage added in v0.4.21 

func (*InspectDockerInfoRequest) ProtoMessage()

func (*InspectDockerInfoRequest) Reset added in v0.4.21 

func (m *InspectDockerInfoRequest) Reset()

func (*InspectDockerInfoRequest) String added in v0.4.21 

func (m *InspectDockerInfoRequest) String() string

type InspectDockerInfoResponse added in v0.4.21 

type InspectDockerInfoResponse struct {
	Info []byte `protobuf:"bytes,1,opt,name=info,proto3" json:"info,omitempty"`
}

func (*InspectDockerInfoResponse) Descriptor added in v0.4.21 

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

func (*InspectDockerInfoResponse) GetInfo added in v0.4.21 

func (m *InspectDockerInfoResponse) GetInfo() []byte

func (*InspectDockerInfoResponse) ProtoMessage added in v0.4.21 

func (*InspectDockerInfoResponse) ProtoMessage()

func (*InspectDockerInfoResponse) Reset added in v0.4.21 

func (m *InspectDockerInfoResponse) Reset()

func (*InspectDockerInfoResponse) String added in v0.4.21 

func (m *InspectDockerInfoResponse) String() string

type InspectDockerNetworkRequest added in v0.4.21 

type InspectDockerNetworkRequest struct {
}

func (*InspectDockerNetworkRequest) Descriptor added in v0.4.21 

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

func (*InspectDockerNetworkRequest) ProtoMessage added in v0.4.21 

func (*InspectDockerNetworkRequest) ProtoMessage()

func (*InspectDockerNetworkRequest) Reset added in v0.4.21 

func (m *InspectDockerNetworkRequest) Reset()

func (*InspectDockerNetworkRequest) String added in v0.4.21 

func (m *InspectDockerNetworkRequest) String() string

type InspectDockerNetworkResponse added in v0.4.21 

type InspectDockerNetworkResponse struct {
	Info []byte `protobuf:"bytes,1,opt,name=info,proto3" json:"info,omitempty"`
}

func (*InspectDockerNetworkResponse) Descriptor added in v0.4.21 

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

func (*InspectDockerNetworkResponse) GetInfo added in v0.4.21 

func (m *InspectDockerNetworkResponse) GetInfo() []byte

func (*InspectDockerNetworkResponse) ProtoMessage added in v0.4.21 

func (*InspectDockerNetworkResponse) ProtoMessage()

func (*InspectDockerNetworkResponse) Reset added in v0.4.21 

func (m *InspectDockerNetworkResponse) Reset()

func (*InspectDockerNetworkResponse) String added in v0.4.21 

func (m *InspectDockerNetworkResponse) String() string

type InspectDockerVolumesRequest added in v0.4.21 

type InspectDockerVolumesRequest struct {
}

func (*InspectDockerVolumesRequest) Descriptor added in v0.4.21 

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

func (*InspectDockerVolumesRequest) ProtoMessage added in v0.4.21 

func (*InspectDockerVolumesRequest) ProtoMessage()

func (*InspectDockerVolumesRequest) Reset added in v0.4.21 

func (m *InspectDockerVolumesRequest) Reset()

func (*InspectDockerVolumesRequest) String added in v0.4.21 

func (m *InspectDockerVolumesRequest) String() string

type InspectDockerVolumesResponse added in v0.4.21 

type InspectDockerVolumesResponse struct {
	Info []byte `protobuf:"bytes,1,opt,name=info,proto3" json:"info,omitempty"`
}

func (*InspectDockerVolumesResponse) Descriptor added in v0.4.21 

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

func (*InspectDockerVolumesResponse) GetInfo added in v0.4.21 

func (m *InspectDockerVolumesResponse) GetInfo() []byte

func (*InspectDockerVolumesResponse) ProtoMessage added in v0.4.21 

func (*InspectDockerVolumesResponse) ProtoMessage()

func (*InspectDockerVolumesResponse) Reset added in v0.4.21 

func (m *InspectDockerVolumesResponse) Reset()

func (*InspectDockerVolumesResponse) String added in v0.4.21 

func (m *InspectDockerVolumesResponse) String() string

type InspectHostInfoRequest added in v0.4.21 

type InspectHostInfoRequest struct {
}

func (*InspectHostInfoRequest) Descriptor added in v0.4.21 

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

func (*InspectHostInfoRequest) ProtoMessage added in v0.4.21 

func (*InspectHostInfoRequest) ProtoMessage()

func (*InspectHostInfoRequest) Reset added in v0.4.21 

func (m *InspectHostInfoRequest) Reset()

func (*InspectHostInfoRequest) String added in v0.4.21 

func (m *InspectHostInfoRequest) String() string

type InspectHostInfoResponse added in v0.4.21 

type InspectHostInfoResponse struct {
	Hostname             string `protobuf:"bytes,1,opt,name=hostname" json:"hostname,omitempty"`
	Uptime               uint64 `protobuf:"varint,2,opt,name=uptime" json:"uptime,omitempty"`
	BootTime             uint64 `protobuf:"varint,3,opt,name=bootTime" json:"bootTime,omitempty"`
	ProcessesNumber      uint64 `protobuf:"varint,4,opt,name=processesNumber" json:"processesNumber,omitempty"`
	Os                   string `protobuf:"bytes,5,opt,name=os" json:"os,omitempty"`
	Platform             string `protobuf:"bytes,6,opt,name=platform" json:"platform,omitempty"`
	PlatformFamily       string `protobuf:"bytes,7,opt,name=platformFamily" json:"platformFamily,omitempty"`
	PlatformVersion      string `protobuf:"bytes,8,opt,name=platformVersion" json:"platformVersion,omitempty"`
	KernelVersion        string `protobuf:"bytes,9,opt,name=kernelVersion" json:"kernelVersion,omitempty"`
	VirtualizationSystem string `protobuf:"bytes,10,opt,name=virtualizationSystem" json:"virtualizationSystem,omitempty"`
	VirtualizationRole   string `protobuf:"bytes,11,opt,name=virtualizationRole" json:"virtualizationRole,omitempty"`
	HostID               string `protobuf:"bytes,12,opt,name=hostID" json:"hostID,omitempty"`
}

func (*InspectHostInfoResponse) Descriptor added in v0.4.21 

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

func (*InspectHostInfoResponse) GetBootTime added in v0.4.21 

func (m *InspectHostInfoResponse) GetBootTime() uint64

func (*InspectHostInfoResponse) GetHostID added in v0.4.21 

func (m *InspectHostInfoResponse) GetHostID() string

func (*InspectHostInfoResponse) GetHostname added in v0.4.21 

func (m *InspectHostInfoResponse) GetHostname() string

func (*InspectHostInfoResponse) GetKernelVersion added in v0.4.21 

func (m *InspectHostInfoResponse) GetKernelVersion() string

func (*InspectHostInfoResponse) GetOs added in v0.4.21 

func (m *InspectHostInfoResponse) GetOs() string

func (*InspectHostInfoResponse) GetPlatform added in v0.4.21 

func (m *InspectHostInfoResponse) GetPlatform() string

func (*InspectHostInfoResponse) GetPlatformFamily added in v0.4.21 

func (m *InspectHostInfoResponse) GetPlatformFamily() string

func (*InspectHostInfoResponse) GetPlatformVersion added in v0.4.21 

func (m *InspectHostInfoResponse) GetPlatformVersion() string

func (*InspectHostInfoResponse) GetProcessesNumber added in v0.4.21 

func (m *InspectHostInfoResponse) GetProcessesNumber() uint64

func (*InspectHostInfoResponse) GetUptime added in v0.4.21 

func (m *InspectHostInfoResponse) GetUptime() uint64

func (*InspectHostInfoResponse) GetVirtualizationRole added in v0.4.21 

func (m *InspectHostInfoResponse) GetVirtualizationRole() string

func (*InspectHostInfoResponse) GetVirtualizationSystem added in v0.4.21 

func (m *InspectHostInfoResponse) GetVirtualizationSystem() string

func (*InspectHostInfoResponse) ProtoMessage added in v0.4.21 

func (*InspectHostInfoResponse) ProtoMessage()

func (*InspectHostInfoResponse) Reset added in v0.4.21 

func (m *InspectHostInfoResponse) Reset()

func (*InspectHostInfoResponse) String added in v0.4.21 

func (m *InspectHostInfoResponse) String() string

type InspectNetworkRequest added in v0.4.21 

type InspectNetworkRequest struct {
}

func (*InspectNetworkRequest) Descriptor added in v0.4.21 

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

func (*InspectNetworkRequest) ProtoMessage added in v0.4.21 

func (*InspectNetworkRequest) ProtoMessage()

func (*InspectNetworkRequest) Reset added in v0.4.21 

func (m *InspectNetworkRequest) Reset()

func (*InspectNetworkRequest) String added in v0.4.21 

func (m *InspectNetworkRequest) String() string

type InspectNetworkResponse added in v0.4.21 

type InspectNetworkResponse struct {
	Interfaces  []*InterfaceStat  `protobuf:"bytes,1,rep,name=interfaces" json:"interfaces,omitempty"`
	Connections []*ConnectionStat `protobuf:"bytes,2,rep,name=connections" json:"connections,omitempty"`
}

func (*InspectNetworkResponse) Descriptor added in v0.4.21 

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

func (*InspectNetworkResponse) GetConnections added in v0.4.21 

func (m *InspectNetworkResponse) GetConnections() []*ConnectionStat

func (*InspectNetworkResponse) GetInterfaces added in v0.4.21 

func (m *InspectNetworkResponse) GetInterfaces() []*InterfaceStat

func (*InspectNetworkResponse) ProtoMessage added in v0.4.21 

func (*InspectNetworkResponse) ProtoMessage()

func (*InspectNetworkResponse) Reset added in v0.4.21 

func (m *InspectNetworkResponse) Reset()

func (*InspectNetworkResponse) String added in v0.4.21 

func (m *InspectNetworkResponse) String() string

type InspectOpenFilesRequest added in v0.4.21 

type InspectOpenFilesRequest struct {
}

func (*InspectOpenFilesRequest) Descriptor added in v0.4.21 

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

func (*InspectOpenFilesRequest) ProtoMessage added in v0.4.21 

func (*InspectOpenFilesRequest) ProtoMessage()

func (*InspectOpenFilesRequest) Reset added in v0.4.21 

func (m *InspectOpenFilesRequest) Reset()

func (*InspectOpenFilesRequest) String added in v0.4.21 

func (m *InspectOpenFilesRequest) String() string

type InspectOpenFilesResponse added in v0.4.21 

type InspectOpenFilesResponse struct {
	OpenFiles []*FileStat `protobuf:"bytes,1,rep,name=openFiles" json:"openFiles,omitempty"`
}

func (*InspectOpenFilesResponse) Descriptor added in v0.4.21 

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

func (*InspectOpenFilesResponse) GetOpenFiles added in v0.4.21 

func (m *InspectOpenFilesResponse) GetOpenFiles() []*FileStat

func (*InspectOpenFilesResponse) ProtoMessage added in v0.4.21 

func (*InspectOpenFilesResponse) ProtoMessage()

func (*InspectOpenFilesResponse) Reset added in v0.4.21 

func (m *InspectOpenFilesResponse) Reset()

func (*InspectOpenFilesResponse) String added in v0.4.21 

func (m *InspectOpenFilesResponse) String() string

type InspectServer added in v0.4.21 

type InspectServer interface {
	// Config returns the inspected server's configuration.
	Config(context.Context, *InspectConfigRequest) (*InspectConfigResponse, error)
	// OpenFiles returns the list of open files of the inspected process.
	OpenFiles(context.Context, *InspectOpenFilesRequest) (*InspectOpenFilesResponse, error)
	// Network returns host's network configuration and open connections of
	// the inspected process.
	Network(context.Context, *InspectNetworkRequest) (*InspectNetworkResponse, error)
	// HostInfo returns information about inspected host.
	HostInfo(context.Context, *InspectHostInfoRequest) (*InspectHostInfoResponse, error)
	// DockerInfo returns information about Docker on the inspected host.
	DockerInfo(context.Context, *InspectDockerInfoRequest) (*InspectDockerInfoResponse, error)
	// DockerNetwork returns information about Docker network on the inspected
	// host.
	DockerNetwork(context.Context, *InspectDockerNetworkRequest) (*InspectDockerNetworkResponse, error)
	// DockerVolumes returns information about Docker volumes on the inspected
	// host.
	DockerVolumes(context.Context, *InspectDockerVolumesRequest) (*InspectDockerVolumesResponse, error)
	// WatchLogs subscribes for logs of the inspected process.
	WatchLogs(*InspectWatchLogsRequest, Inspect_WatchLogsServer) error
}

type InspectWatchLogsChunk added in v0.4.21 

type InspectWatchLogsChunk struct {
	Message string `protobuf:"bytes,1,opt,name=message" json:"message,omitempty"`
}

func (*InspectWatchLogsChunk) Descriptor added in v0.4.21 

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

func (*InspectWatchLogsChunk) GetMessage added in v0.4.21 

func (m *InspectWatchLogsChunk) GetMessage() string

func (*InspectWatchLogsChunk) ProtoMessage added in v0.4.21 

func (*InspectWatchLogsChunk) ProtoMessage()

func (*InspectWatchLogsChunk) Reset added in v0.4.21 

func (m *InspectWatchLogsChunk) Reset()

func (*InspectWatchLogsChunk) String added in v0.4.21 

func (m *InspectWatchLogsChunk) String() string

type InspectWatchLogsRequest added in v0.4.21 

type InspectWatchLogsRequest struct {
}

func (*InspectWatchLogsRequest) Descriptor added in v0.4.21 

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

func (*InspectWatchLogsRequest) ProtoMessage added in v0.4.21 

func (*InspectWatchLogsRequest) ProtoMessage()

func (*InspectWatchLogsRequest) Reset added in v0.4.21 

func (m *InspectWatchLogsRequest) Reset()

func (*InspectWatchLogsRequest) String added in v0.4.21 

func (m *InspectWatchLogsRequest) String() string

type Inspect_WatchLogsClient added in v0.4.21 

type Inspect_WatchLogsClient interface {
	Recv() (*InspectWatchLogsChunk, error)
	grpc.ClientStream
}

type Inspect_WatchLogsServer added in v0.4.21 

type Inspect_WatchLogsServer interface {
	Send(*InspectWatchLogsChunk) error
	grpc.ServerStream
}

type InterfaceStat added in v0.4.21 

type InterfaceStat struct {
	// MTU represents the maximum transmission unit.
	Mtu int32 `protobuf:"varint,1,opt,name=mtu" json:"mtu,omitempty"`
	// Name represents the network interface name, for example "en0", "lo0", "eth0.100".
	Name string `protobuf:"bytes,2,opt,name=name" json:"name,omitempty"`
	// HardwareAddr is the interface address in IEEE MAC-48, EUI-48 and EUI-64 form.
	HardwareAddr string `protobuf:"bytes,3,opt,name=hardwareAddr" json:"hardwareAddr,omitempty"`
	// Flags provides additional interface info, like FlagUp, FlagLoopback, FlagMulticast.
	Flags []string `protobuf:"bytes,4,rep,name=flags" json:"flags,omitempty"`
	// Addrs represents IP addresses and its subnet assigned to this interface.
	Addrs []string `protobuf:"bytes,5,rep,name=addrs" json:"addrs,omitempty"`
}

func (*InterfaceStat) Descriptor added in v0.4.21 

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

func (*InterfaceStat) GetAddrs added in v0.4.21 

func (m *InterfaceStat) GetAddrs() []string

func (*InterfaceStat) GetFlags added in v0.4.21 

func (m *InterfaceStat) GetFlags() []string

func (*InterfaceStat) GetHardwareAddr added in v0.4.21 

func (m *InterfaceStat) GetHardwareAddr() string

func (*InterfaceStat) GetMtu added in v0.4.21 

func (m *InterfaceStat) GetMtu() int32

func (*InterfaceStat) GetName added in v0.4.21 

func (m *InterfaceStat) GetName() string

func (*InterfaceStat) ProtoMessage added in v0.4.21 

func (*InterfaceStat) ProtoMessage()

func (*InterfaceStat) Reset added in v0.4.21 

func (m *InterfaceStat) Reset()

func (*InterfaceStat) String added in v0.4.21 

func (m *InterfaceStat) String() string

type JoinNetworkRequest added in v0.4.1 

type JoinNetworkRequest struct {
	TaskID    *TaskID `protobuf:"bytes,1,opt,name=taskID" json:"taskID,omitempty"`
	NetworkID string  `protobuf:"bytes,2,opt,name=NetworkID" json:"NetworkID,omitempty"`
}

func (*JoinNetworkRequest) Descriptor added in v0.4.1 

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

func (*JoinNetworkRequest) GetNetworkID added in v0.4.1 

func (m *JoinNetworkRequest) GetNetworkID() string

func (*JoinNetworkRequest) GetTaskID added in v0.4.1 

func (m *JoinNetworkRequest) GetTaskID() *TaskID

func (*JoinNetworkRequest) ProtoMessage added in v0.4.1 

func (*JoinNetworkRequest) ProtoMessage()

func (*JoinNetworkRequest) Reset added in v0.4.1 

func (m *JoinNetworkRequest) Reset()

func (*JoinNetworkRequest) String added in v0.4.1 

func (m *JoinNetworkRequest) String() string

type MarketClient 

type MarketClient interface {
	// GetOrders returns orders by given filter parameters.
	// Note that set of filters may be changed in the closest future.
	GetOrders(ctx context.Context, in *Count, opts ...grpc.CallOption) (*GetOrdersReply, error)
	// CreateOrder places new order on the Marketplace.
	// Note that current impl of Node API prevents you from
	// creating ASKs orders.
	CreateOrder(ctx context.Context, in *BidOrder, opts ...grpc.CallOption) (*Order, error)
	// GetOrderByID returns order by given ID.
	// If order save an `inactive` status returns error instead.
	// TODO: get rid of string ID #1237
	GetOrderByID(ctx context.Context, in *ID, opts ...grpc.CallOption) (*Order, error)
	// CancelOrder removes active order from the Marketplace.
	// TODO: get rid of string ID #1237
	// Deprecated: use CancelOrders instead
	CancelOrder(ctx context.Context, in *ID, opts ...grpc.CallOption) (*Empty, error)
	// CancelOrders removes specified orders from the Marketplace.
	CancelOrders(ctx context.Context, in *OrderIDs, opts ...grpc.CallOption) (*ErrorByID, error)
	// Purge remove all active orders from marketplace
	// Deprecated: use PurgeVerbose
	Purge(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error)
	// PurgeVerbose remove all active orders from marketplace and return detailed status on each order
	PurgeVerbose(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ErrorByID, error)
}

func NewMarketClient 

func NewMarketClient(cc *grpc.ClientConn) MarketClient

type MarketServer 

type MarketServer interface {
	// GetOrders returns orders by given filter parameters.
	// Note that set of filters may be changed in the closest future.
	GetOrders(context.Context, *Count) (*GetOrdersReply, error)
	// CreateOrder places new order on the Marketplace.
	// Note that current impl of Node API prevents you from
	// creating ASKs orders.
	CreateOrder(context.Context, *BidOrder) (*Order, error)
	// GetOrderByID returns order by given ID.
	// If order save an `inactive` status returns error instead.
	// TODO: get rid of string ID #1237
	GetOrderByID(context.Context, *ID) (*Order, error)
	// CancelOrder removes active order from the Marketplace.
	// TODO: get rid of string ID #1237
	// Deprecated: use CancelOrders instead
	CancelOrder(context.Context, *ID) (*Empty, error)
	// CancelOrders removes specified orders from the Marketplace.
	CancelOrders(context.Context, *OrderIDs) (*ErrorByID, error)
	// Purge remove all active orders from marketplace
	// Deprecated: use PurgeVerbose
	Purge(context.Context, *Empty) (*Empty, error)
	// PurgeVerbose remove all active orders from marketplace and return detailed status on each order
	PurgeVerbose(context.Context, *Empty) (*ErrorByID, error)
}

type MasterManagementClient added in v0.4.1 

type MasterManagementClient interface {
	// WorkersList returns worker's list for current master address.
	// List includes already registred workers and pending unapproved requests.
	WorkersList(ctx context.Context, in *EthAddress, opts ...grpc.CallOption) (*WorkerListReply, error)
	// WorkerConfirm (as master) confirms incoming request for given Worker address.
	WorkerConfirm(ctx context.Context, in *EthAddress, opts ...grpc.CallOption) (*Empty, error)
	// WorkerRemove (as master) unbinds given Worker address from Master address.
	WorkerRemove(ctx context.Context, in *WorkerRemoveRequest, opts ...grpc.CallOption) (*Empty, error)
}

func NewMasterManagementClient added in v0.4.1 

func NewMasterManagementClient(cc *grpc.ClientConn) MasterManagementClient

type MasterManagementServer added in v0.4.1 

type MasterManagementServer interface {
	// WorkersList returns worker's list for current master address.
	// List includes already registred workers and pending unapproved requests.
	WorkersList(context.Context, *EthAddress) (*WorkerListReply, error)
	// WorkerConfirm (as master) confirms incoming request for given Worker address.
	WorkerConfirm(context.Context, *EthAddress) (*Empty, error)
	// WorkerRemove (as master) unbinds given Worker address from Master address.
	WorkerRemove(context.Context, *WorkerRemoveRequest) (*Empty, error)
}

type MatchingOrdersRequest added in v0.4.1 

type MatchingOrdersRequest struct {
	Id        *BigInt `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
	Limit     uint64  `protobuf:"varint,2,opt,name=limit" json:"limit,omitempty"`
	Offset    uint64  `protobuf:"varint,3,opt,name=offset" json:"offset,omitempty"`
	WithCount bool    `protobuf:"varint,4,opt,name=withCount" json:"withCount,omitempty"`
}

func (*MatchingOrdersRequest) Descriptor added in v0.4.1 

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

func (*MatchingOrdersRequest) GetId added in v0.4.1 

func (m *MatchingOrdersRequest) GetId() *BigInt

func (*MatchingOrdersRequest) GetLimit added in v0.4.1 

func (m *MatchingOrdersRequest) GetLimit() uint64

func (*MatchingOrdersRequest) GetOffset added in v0.4.1 

func (m *MatchingOrdersRequest) GetOffset() uint64

func (*MatchingOrdersRequest) GetWithCount added in v0.4.1 

func (m *MatchingOrdersRequest) GetWithCount() bool

func (*MatchingOrdersRequest) ProtoMessage added in v0.4.1 

func (*MatchingOrdersRequest) ProtoMessage()

func (*MatchingOrdersRequest) Reset added in v0.4.1 

func (m *MatchingOrdersRequest) Reset()

func (*MatchingOrdersRequest) String added in v0.4.1 

func (m *MatchingOrdersRequest) String() string

type MaxMinBig added in v0.4.1 

type MaxMinBig struct {
	Max *BigInt `protobuf:"bytes,1,opt,name=max" json:"max,omitempty"`
	Min *BigInt `protobuf:"bytes,2,opt,name=min" json:"min,omitempty"`
}

func (*MaxMinBig) Descriptor added in v0.4.1 

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

func (*MaxMinBig) GetMax added in v0.4.1 

func (m *MaxMinBig) GetMax() *BigInt

func (*MaxMinBig) GetMin added in v0.4.1 

func (m *MaxMinBig) GetMin() *BigInt

func (*MaxMinBig) ProtoMessage added in v0.4.1 

func (*MaxMinBig) ProtoMessage()

func (*MaxMinBig) Reset added in v0.4.1 

func (m *MaxMinBig) Reset()

func (*MaxMinBig) String added in v0.4.1 

func (m *MaxMinBig) String() string

type MaxMinTimestamp added in v0.4.1 

type MaxMinTimestamp struct {
	Max *Timestamp `protobuf:"bytes,1,opt,name=max" json:"max,omitempty"`
	Min *Timestamp `protobuf:"bytes,2,opt,name=min" json:"min,omitempty"`
}

func (*MaxMinTimestamp) Descriptor added in v0.4.1 

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

func (*MaxMinTimestamp) GetMax added in v0.4.1 

func (m *MaxMinTimestamp) GetMax() *Timestamp

func (*MaxMinTimestamp) GetMin added in v0.4.1 

func (m *MaxMinTimestamp) GetMin() *Timestamp

func (*MaxMinTimestamp) ProtoMessage added in v0.4.1 

func (*MaxMinTimestamp) ProtoMessage()

func (*MaxMinTimestamp) Reset added in v0.4.1 

func (m *MaxMinTimestamp) Reset()

func (*MaxMinTimestamp) String added in v0.4.1 

func (m *MaxMinTimestamp) String() string

type MaxMinUint64 added in v0.4.1 

type MaxMinUint64 struct {
	Max uint64 `protobuf:"varint,1,opt,name=max" json:"max,omitempty"`
	Min uint64 `protobuf:"varint,2,opt,name=min" json:"min,omitempty"`
}

func (*MaxMinUint64) Descriptor added in v0.4.1 

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

func (*MaxMinUint64) GetMax added in v0.4.1 

func (m *MaxMinUint64) GetMax() uint64

func (*MaxMinUint64) GetMin added in v0.4.1 

func (m *MaxMinUint64) GetMin() uint64

func (*MaxMinUint64) ProtoMessage added in v0.4.1 

func (*MaxMinUint64) ProtoMessage()

func (*MaxMinUint64) Reset added in v0.4.1 

func (m *MaxMinUint64) Reset()

func (*MaxMinUint64) String added in v0.4.1 

func (m *MaxMinUint64) String() string

type MemoryUsage 

type MemoryUsage struct {
	MaxUsage uint64 `protobuf:"varint,1,opt,name=maxUsage" json:"maxUsage,omitempty"`
}

func (*MemoryUsage) Descriptor 

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

func (*MemoryUsage) GetMaxUsage 

func (m *MemoryUsage) GetMaxUsage() uint64

func (*MemoryUsage) ProtoMessage 

func (*MemoryUsage) ProtoMessage()

func (*MemoryUsage) Reset 

func (m *MemoryUsage) Reset()

func (*MemoryUsage) String 

func (m *MemoryUsage) String() string

type MonitoringClient added in v0.4.11 

type MonitoringClient interface {
	MetricsNPP(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*NPPMetricsReply, error)
}

func NewMonitoringClient added in v0.4.11 

func NewMonitoringClient(cc *grpc.ClientConn) MonitoringClient

type MonitoringServer added in v0.4.11 

type MonitoringServer interface {
	MetricsNPP(context.Context, *Empty) (*NPPMetricsReply, error)
}

type NPPMetricsReply added in v0.4.11 

type NPPMetricsReply struct {
	Metrics map[string]*NamedMetrics `` /* 134-byte string literal not displayed */
}

func (*NPPMetricsReply) Descriptor added in v0.4.11 

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

func (*NPPMetricsReply) GetMetrics added in v0.4.11 

func (m *NPPMetricsReply) GetMetrics() map[string]*NamedMetrics

func (*NPPMetricsReply) ProtoMessage added in v0.4.11 

func (*NPPMetricsReply) ProtoMessage()

func (*NPPMetricsReply) Reset added in v0.4.11 

func (m *NPPMetricsReply) Reset()

func (*NPPMetricsReply) String added in v0.4.11 

func (m *NPPMetricsReply) String() string

type NamedMetric added in v0.4.11 

type NamedMetric struct {
	Name   string                       `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	Metric *io_prometheus_client.Metric `protobuf:"bytes,2,opt,name=metric" json:"metric,omitempty"`
}

func (*NamedMetric) Descriptor added in v0.4.11 

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

func (*NamedMetric) GetMetric added in v0.4.11 

func (m *NamedMetric) GetMetric() *io_prometheus_client.Metric

func (*NamedMetric) GetName added in v0.4.11 

func (m *NamedMetric) GetName() string

func (*NamedMetric) ProtoMessage added in v0.4.11 

func (*NamedMetric) ProtoMessage()

func (*NamedMetric) Reset added in v0.4.11 

func (m *NamedMetric) Reset()

func (*NamedMetric) String added in v0.4.11 

func (m *NamedMetric) String() string

type NamedMetrics added in v0.4.11 

type NamedMetrics struct {
	Metrics []*NamedMetric `protobuf:"bytes,1,rep,name=metrics" json:"metrics,omitempty"`
}

func (*NamedMetrics) Descriptor added in v0.4.11 

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

func (*NamedMetrics) GetMetrics added in v0.4.11 

func (m *NamedMetrics) GetMetrics() []*NamedMetric

func (*NamedMetrics) ProtoMessage added in v0.4.11 

func (*NamedMetrics) ProtoMessage()

func (*NamedMetrics) Reset added in v0.4.11 

func (m *NamedMetrics) Reset()

func (*NamedMetrics) String added in v0.4.11 

func (m *NamedMetrics) String() string

type NetFlags added in v0.4.1 

type NetFlags struct {
	Flags uint64 `protobuf:"varint,1,opt,name=flags" json:"flags,omitempty"`
}

func NetFlagsFromBoolSlice added in v0.4.1 

func NetFlagsFromBoolSlice(from []bool) *NetFlags

func (*NetFlags) ConverseImplication added in v0.4.1 

func (m *NetFlags) ConverseImplication(cmp *NetFlags) bool

func (*NetFlags) Descriptor added in v0.4.1 

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

func (*NetFlags) GetFlags added in v0.4.1 

func (m *NetFlags) GetFlags() uint64

func (*NetFlags) GetIncoming added in v0.4.1 

func (m *NetFlags) GetIncoming() bool

func (*NetFlags) GetOutbound added in v0.4.1 

func (m *NetFlags) GetOutbound() bool

func (*NetFlags) GetOverlay added in v0.4.1 

func (m *NetFlags) GetOverlay() bool

func (*NetFlags) ProtoMessage added in v0.4.1 

func (*NetFlags) ProtoMessage()

func (*NetFlags) Reset added in v0.4.1 

func (m *NetFlags) Reset()

func (*NetFlags) SetIncoming added in v0.4.1 

func (m *NetFlags) SetIncoming(value bool) *NetFlags

func (*NetFlags) SetOutbound added in v0.4.1 

func (m *NetFlags) SetOutbound(value bool) *NetFlags

func (*NetFlags) SetOverlay added in v0.4.1 

func (m *NetFlags) SetOverlay(value bool) *NetFlags

func (*NetFlags) String added in v0.4.1 

func (m *NetFlags) String() string

func (*NetFlags) ToBoolSlice added in v0.4.1 

func (m *NetFlags) ToBoolSlice() []bool

type NetMetrics added in v0.4.1 

type NetMetrics struct {
	TxBytes uint64 `protobuf:"varint,1,opt,name=txBytes" json:"txBytes,omitempty"`
	RxBytes uint64 `protobuf:"varint,2,opt,name=rxBytes" json:"rxBytes,omitempty"`
}

func (*NetMetrics) Descriptor added in v0.4.1 

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

func (*NetMetrics) GetRxBytes added in v0.4.1 

func (m *NetMetrics) GetRxBytes() uint64

func (*NetMetrics) GetTxBytes added in v0.4.1 

func (m *NetMetrics) GetTxBytes() uint64

func (*NetMetrics) ProtoMessage added in v0.4.1 

func (*NetMetrics) ProtoMessage()

func (*NetMetrics) Reset added in v0.4.1 

func (m *NetMetrics) Reset()

func (*NetMetrics) String added in v0.4.1 

func (m *NetMetrics) String() string

type Network added in v0.4.1 

type Network struct {
	In            uint64                `protobuf:"varint,1,opt,name=in" json:"in,omitempty"`
	Out           uint64                `protobuf:"varint,2,opt,name=out" json:"out,omitempty"`
	NetFlags      *NetFlags             `protobuf:"bytes,3,opt,name=netFlags" json:"netFlags,omitempty"`
	BenchmarksIn  map[uint64]*Benchmark `` /* 145-byte string literal not displayed */
	BenchmarksOut map[uint64]*Benchmark `` /* 147-byte string literal not displayed */
}

func (*Network) Descriptor added in v0.4.1 

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

func (*Network) GetBenchmarksIn added in v0.4.1 

func (m *Network) GetBenchmarksIn() map[uint64]*Benchmark

func (*Network) GetBenchmarksOut added in v0.4.1 

func (m *Network) GetBenchmarksOut() map[uint64]*Benchmark

func (*Network) GetIn added in v0.4.1 

func (m *Network) GetIn() uint64

func (*Network) GetNetFlags added in v0.4.1 

func (m *Network) GetNetFlags() *NetFlags

func (*Network) GetOut added in v0.4.1 

func (m *Network) GetOut() uint64

func (*Network) HardwareHash added in v0.4.1 

func (m *Network) HardwareHash() string

func (*Network) ProtoMessage added in v0.4.1 

func (*Network) ProtoMessage()

func (*Network) Reset added in v0.4.1 

func (m *Network) Reset()

func (*Network) String added in v0.4.1 

func (m *Network) String() string

type NetworkSpec added in v0.4.1 

type NetworkSpec struct {
	Type    string            `protobuf:"bytes,1,opt,name=type" json:"type,omitempty"`
	Options map[string]string `` /* 134-byte string literal not displayed */
	Subnet  string            `protobuf:"bytes,3,opt,name=subnet" json:"subnet,omitempty"`
	Addr    string            `protobuf:"bytes,4,opt,name=addr" json:"addr,omitempty"`
}

func (*NetworkSpec) Descriptor added in v0.4.1 

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

func (*NetworkSpec) GetAddr added in v0.4.1 

func (m *NetworkSpec) GetAddr() string

func (*NetworkSpec) GetOptions added in v0.4.1 

func (m *NetworkSpec) GetOptions() map[string]string

func (*NetworkSpec) GetSubnet added in v0.4.1 

func (m *NetworkSpec) GetSubnet() string

func (*NetworkSpec) GetType added in v0.4.1 

func (m *NetworkSpec) GetType() string

func (*NetworkSpec) ProtoMessage added in v0.4.1 

func (*NetworkSpec) ProtoMessage()

func (*NetworkSpec) Reset added in v0.4.1 

func (m *NetworkSpec) Reset()

func (*NetworkSpec) String added in v0.4.1 

func (m *NetworkSpec) String() string

type NetworkUsage 

type NetworkUsage struct {
	TxBytes       uint64  `protobuf:"varint,1,opt,name=txBytes" json:"txBytes,omitempty"`
	RxBytes       uint64  `protobuf:"varint,2,opt,name=rxBytes" json:"rxBytes,omitempty"`
	TxPackets     uint64  `protobuf:"varint,3,opt,name=txPackets" json:"txPackets,omitempty"`
	RxPackets     uint64  `protobuf:"varint,4,opt,name=rxPackets" json:"rxPackets,omitempty"`
	TxErrors      uint64  `protobuf:"varint,5,opt,name=txErrors" json:"txErrors,omitempty"`
	RxErrors      uint64  `protobuf:"varint,6,opt,name=rxErrors" json:"rxErrors,omitempty"`
	TxDropped     uint64  `protobuf:"varint,7,opt,name=txDropped" json:"txDropped,omitempty"`
	RxDropped     uint64  `protobuf:"varint,8,opt,name=rxDropped" json:"rxDropped,omitempty"`
	TxBytesRate   float64 `protobuf:"fixed64,9,opt,name=txBytesRate" json:"txBytesRate,omitempty"`
	RxBytesRate   float64 `protobuf:"fixed64,10,opt,name=rxBytesRate" json:"rxBytesRate,omitempty"`
	TxPacketsRate float64 `protobuf:"fixed64,11,opt,name=txPacketsRate" json:"txPacketsRate,omitempty"`
	RxPacketsRate float64 `protobuf:"fixed64,12,opt,name=rxPacketsRate" json:"rxPacketsRate,omitempty"`
	TxErrorsRate  float64 `protobuf:"fixed64,13,opt,name=txErrorsRate" json:"txErrorsRate,omitempty"`
	RxErrorsRate  float64 `protobuf:"fixed64,14,opt,name=rxErrorsRate" json:"rxErrorsRate,omitempty"`
	TxDroppedRate float64 `protobuf:"fixed64,15,opt,name=txDroppedRate" json:"txDroppedRate,omitempty"`
	RxDroppedRate float64 `protobuf:"fixed64,16,opt,name=rxDroppedRate" json:"rxDroppedRate,omitempty"`
}

func (*NetworkUsage) Descriptor 

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

func (*NetworkUsage) GetRxBytes 

func (m *NetworkUsage) GetRxBytes() uint64

func (*NetworkUsage) GetRxBytesRate added in v0.4.15 

func (m *NetworkUsage) GetRxBytesRate() float64

func (*NetworkUsage) GetRxDropped 

func (m *NetworkUsage) GetRxDropped() uint64

func (*NetworkUsage) GetRxDroppedRate added in v0.4.15 

func (m *NetworkUsage) GetRxDroppedRate() float64

func (*NetworkUsage) GetRxErrors 

func (m *NetworkUsage) GetRxErrors() uint64

func (*NetworkUsage) GetRxErrorsRate added in v0.4.15 

func (m *NetworkUsage) GetRxErrorsRate() float64

func (*NetworkUsage) GetRxPackets 

func (m *NetworkUsage) GetRxPackets() uint64

func (*NetworkUsage) GetRxPacketsRate added in v0.4.15 

func (m *NetworkUsage) GetRxPacketsRate() float64

func (*NetworkUsage) GetTxBytes 

func (m *NetworkUsage) GetTxBytes() uint64

func (*NetworkUsage) GetTxBytesRate added in v0.4.15 

func (m *NetworkUsage) GetTxBytesRate() float64

func (*NetworkUsage) GetTxDropped 

func (m *NetworkUsage) GetTxDropped() uint64

func (*NetworkUsage) GetTxDroppedRate added in v0.4.15 

func (m *NetworkUsage) GetTxDroppedRate() float64

func (*NetworkUsage) GetTxErrors 

func (m *NetworkUsage) GetTxErrors() uint64

func (*NetworkUsage) GetTxErrorsRate added in v0.4.15 

func (m *NetworkUsage) GetTxErrorsRate() float64

func (*NetworkUsage) GetTxPackets 

func (m *NetworkUsage) GetTxPackets() uint64

func (*NetworkUsage) GetTxPacketsRate added in v0.4.15 

func (m *NetworkUsage) GetTxPacketsRate() float64

func (*NetworkUsage) ProtoMessage 

func (*NetworkUsage) ProtoMessage()

func (*NetworkUsage) Reset 

func (m *NetworkUsage) Reset()

func (*NetworkUsage) String 

func (m *NetworkUsage) String() string

type NumericID added in v0.4.1 

type NumericID struct {
	Id uint64 `protobuf:"varint,1,opt,name=id" json:"id,omitempty"`
}

func (*NumericID) Descriptor added in v0.4.1 

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

func (*NumericID) GetId added in v0.4.1 

func (m *NumericID) GetId() uint64

func (*NumericID) ProtoMessage added in v0.4.1 

func (*NumericID) ProtoMessage()

func (*NumericID) Reset added in v0.4.1 

func (m *NumericID) Reset()

func (*NumericID) String added in v0.4.1 

func (m *NumericID) String() string

type OpenDealRequest added in v0.4.1 

type OpenDealRequest struct {
	BidID *BigInt `protobuf:"bytes,1,opt,name=bidID" json:"bidID,omitempty"`
	AskID *BigInt `protobuf:"bytes,2,opt,name=askID" json:"askID,omitempty"`
	Force bool    `protobuf:"varint,3,opt,name=force" json:"force,omitempty"`
}

func (*OpenDealRequest) Descriptor added in v0.4.1 

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

func (*OpenDealRequest) GetAskID added in v0.4.1 

func (m *OpenDealRequest) GetAskID() *BigInt

func (*OpenDealRequest) GetBidID added in v0.4.1 

func (m *OpenDealRequest) GetBidID() *BigInt

func (*OpenDealRequest) GetForce added in v0.4.5 

func (m *OpenDealRequest) GetForce() bool

func (*OpenDealRequest) ProtoMessage added in v0.4.1 

func (*OpenDealRequest) ProtoMessage()

func (*OpenDealRequest) Reset added in v0.4.1 

func (m *OpenDealRequest) Reset()

func (*OpenDealRequest) String added in v0.4.1 

func (m *OpenDealRequest) String() string

type Order 

type Order struct {
	Id             *BigInt       `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
	DealID         *BigInt       `protobuf:"bytes,2,opt,name=dealID" json:"dealID,omitempty"`
	OrderType      OrderType     `protobuf:"varint,3,opt,name=orderType,enum=sonm.OrderType" json:"orderType,omitempty"`
	OrderStatus    OrderStatus   `protobuf:"varint,4,opt,name=orderStatus,enum=sonm.OrderStatus" json:"orderStatus,omitempty"`
	AuthorID       *EthAddress   `protobuf:"bytes,5,opt,name=authorID" json:"authorID,omitempty"`
	CounterpartyID *EthAddress   `protobuf:"bytes,6,opt,name=counterpartyID" json:"counterpartyID,omitempty"`
	Duration       uint64        `protobuf:"varint,7,opt,name=duration" json:"duration,omitempty"`
	Price          *BigInt       `protobuf:"bytes,8,opt,name=price" json:"price,omitempty"`
	Netflags       *NetFlags     `protobuf:"bytes,9,opt,name=netflags" json:"netflags,omitempty"`
	IdentityLevel  IdentityLevel `protobuf:"varint,10,opt,name=identityLevel,enum=sonm.IdentityLevel" json:"identityLevel,omitempty"`
	Blacklist      string        `protobuf:"bytes,11,opt,name=blacklist" json:"blacklist,omitempty"`
	Tag            []byte        `protobuf:"bytes,12,opt,name=tag,proto3" json:"tag,omitempty"`
	Benchmarks     *Benchmarks   `protobuf:"bytes,13,opt,name=benchmarks" json:"benchmarks,omitempty"`
	FrozenSum      *BigInt       `protobuf:"bytes,14,opt,name=frozenSum" json:"frozenSum,omitempty"`
}

func (*Order) Descriptor 

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

func (*Order) GetAuthorID added in v0.4.1 

func (m *Order) GetAuthorID() *EthAddress

func (*Order) GetBenchmarks added in v0.4.1 

func (m *Order) GetBenchmarks() *Benchmarks

func (*Order) GetBlacklist added in v0.4.1 

func (m *Order) GetBlacklist() string

func (*Order) GetCounterpartyID added in v0.4.1 

func (m *Order) GetCounterpartyID() *EthAddress

func (*Order) GetDealID added in v0.4.1 

func (m *Order) GetDealID() *BigInt

func (*Order) GetDuration added in v0.3.2 

func (m *Order) GetDuration() uint64

func (*Order) GetFrozenSum added in v0.4.1 

func (m *Order) GetFrozenSum() *BigInt

func (*Order) GetId 

func (m *Order) GetId() *BigInt

func (*Order) GetIdentityLevel added in v0.4.1 

func (m *Order) GetIdentityLevel() IdentityLevel

func (*Order) GetNetflags added in v0.4.1 

func (m *Order) GetNetflags() *NetFlags

func (*Order) GetOrderStatus added in v0.4.1 

func (m *Order) GetOrderStatus() OrderStatus

func (*Order) GetOrderType 

func (m *Order) GetOrderType() OrderType

func (*Order) GetPrice 

func (m *Order) GetPrice() *BigInt

func (*Order) GetTag added in v0.4.1 

func (m *Order) GetTag() []byte

func (*Order) PricePerHour added in v0.4.8 

func (m *Order) PricePerHour() string

func (*Order) ProtoMessage 

func (*Order) ProtoMessage()

func (*Order) Reset 

func (m *Order) Reset()

func (*Order) String 

func (m *Order) String() string

func (*Order) TotalPrice added in v0.4.1 

func (m *Order) TotalPrice() string

type OrderIDs added in v0.4.10 

type OrderIDs struct {
	Ids []*BigInt `protobuf:"bytes,1,rep,name=ids" json:"ids,omitempty"`
}

func (*OrderIDs) Descriptor added in v0.4.10 

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

func (*OrderIDs) GetIds added in v0.4.10 

func (m *OrderIDs) GetIds() []*BigInt

func (*OrderIDs) ProtoMessage added in v0.4.10 

func (*OrderIDs) ProtoMessage()

func (*OrderIDs) Reset added in v0.4.10 

func (m *OrderIDs) Reset()

func (*OrderIDs) String added in v0.4.10 

func (m *OrderIDs) String() string

type OrderPredictorClient added in v0.4.10 

type OrderPredictorClient interface {
	Predict(ctx context.Context, in *BidResources, opts ...grpc.CallOption) (*Price, error)
	PredictSupplier(ctx context.Context, in *PredictSupplierRequest, opts ...grpc.CallOption) (*PredictSupplierReply, error)
}

func NewOrderPredictorClient added in v0.4.10 

func NewOrderPredictorClient(cc *grpc.ClientConn) OrderPredictorClient

type OrderPredictorServer added in v0.4.10 

type OrderPredictorServer interface {
	Predict(context.Context, *BidResources) (*Price, error)
	PredictSupplier(context.Context, *PredictSupplierRequest) (*PredictSupplierReply, error)
}

type OrderStatus added in v0.4.1 

type OrderStatus int32
const (
	OrderStatus_ORDER_UNKNOWN  OrderStatus = 0
	OrderStatus_ORDER_INACTIVE OrderStatus = 1
	OrderStatus_ORDER_ACTIVE   OrderStatus = 2
)

func (OrderStatus) EnumDescriptor added in v0.4.1 

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

func (OrderStatus) String added in v0.4.1 

func (x OrderStatus) String() string

type OrderType 

type OrderType int32
const (
	OrderType_ANY OrderType = 0
	OrderType_BID OrderType = 1
	OrderType_ASK OrderType = 2
)

func (OrderType) EnumDescriptor 

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

func (OrderType) String 

func (x OrderType) String() string

type OrdersByIDsRequest added in v0.4.12 

type OrdersByIDsRequest struct {
	Ids []*BigInt `protobuf:"bytes,1,rep,name=ids" json:"ids,omitempty"`
}

func (*OrdersByIDsRequest) Descriptor added in v0.4.12 

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

func (*OrdersByIDsRequest) GetIds added in v0.4.12 

func (m *OrdersByIDsRequest) GetIds() []*BigInt

func (*OrdersByIDsRequest) ProtoMessage added in v0.4.12 

func (*OrdersByIDsRequest) ProtoMessage()

func (*OrdersByIDsRequest) Reset added in v0.4.12 

func (m *OrdersByIDsRequest) Reset()

func (*OrdersByIDsRequest) String added in v0.4.12 

func (m *OrdersByIDsRequest) String() string

type OrdersRequest added in v0.4.1 

type OrdersRequest struct {
	DealID   *BigInt     `protobuf:"bytes,1,opt,name=dealID" json:"dealID,omitempty"`
	Type     OrderType   `protobuf:"varint,2,opt,name=type,enum=sonm.OrderType" json:"type,omitempty"`
	Status   OrderStatus `protobuf:"varint,3,opt,name=status,enum=sonm.OrderStatus" json:"status,omitempty"`
	AuthorID *EthAddress `protobuf:"bytes,4,opt,name=authorID" json:"authorID,omitempty"`
	// No values passed returns all orders, empty address (common.Address{}.Hex()) returns orders
	// with CounterpartyID not set. To get a list of all orders that suit you, pass an empty address
	// and your own address.
	CounterpartyID       []*EthAddress            `protobuf:"bytes,5,rep,name=counterpartyID" json:"counterpartyID,omitempty"`
	Duration             *MaxMinUint64            `protobuf:"bytes,6,opt,name=duration" json:"duration,omitempty"`
	Price                *MaxMinBig               `protobuf:"bytes,9,opt,name=price" json:"price,omitempty"`
	Netflags             *CmpUint64               `protobuf:"bytes,11,opt,name=netflags" json:"netflags,omitempty"`
	CreatorIdentityLevel []IdentityLevel          `protobuf:"varint,12,rep,packed,name=creatorIdentityLevel,enum=sonm.IdentityLevel" json:"creatorIdentityLevel,omitempty"`
	Benchmarks           map[uint64]*MaxMinUint64 `` /* 142-byte string literal not displayed */
	CreatedTS            *MaxMinTimestamp         `protobuf:"bytes,14,opt,name=createdTS" json:"createdTS,omitempty"`
	Limit                uint64                   `protobuf:"varint,15,opt,name=limit" json:"limit,omitempty"`
	Offset               uint64                   `protobuf:"varint,16,opt,name=offset" json:"offset,omitempty"`
	Sortings             []*SortingOption         `protobuf:"bytes,17,rep,name=sortings" json:"sortings,omitempty"`
	WithCount            bool                     `protobuf:"varint,18,opt,name=withCount" json:"withCount,omitempty"`
	MasterID             *EthAddress              `protobuf:"bytes,19,opt,name=masterID" json:"masterID,omitempty"`
	// IDs associated with sender.
	SenderIDs []*EthAddress `protobuf:"bytes,20,rep,name=senderIDs" json:"senderIDs,omitempty"`
}

func (*OrdersRequest) Descriptor added in v0.4.1 

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

func (*OrdersRequest) GetAuthorID added in v0.4.1 

func (m *OrdersRequest) GetAuthorID() *EthAddress

func (*OrdersRequest) GetBenchmarks added in v0.4.1 

func (m *OrdersRequest) GetBenchmarks() map[uint64]*MaxMinUint64

func (*OrdersRequest) GetCounterpartyID added in v0.4.1 

func (m *OrdersRequest) GetCounterpartyID() []*EthAddress

func (*OrdersRequest) GetCreatedTS added in v0.4.1 

func (m *OrdersRequest) GetCreatedTS() *MaxMinTimestamp

func (*OrdersRequest) GetCreatorIdentityLevel added in v0.4.1 

func (m *OrdersRequest) GetCreatorIdentityLevel() []IdentityLevel

func (*OrdersRequest) GetDealID added in v0.4.1 

func (m *OrdersRequest) GetDealID() *BigInt

func (*OrdersRequest) GetDuration added in v0.4.1 

func (m *OrdersRequest) GetDuration() *MaxMinUint64

func (*OrdersRequest) GetLimit added in v0.4.1 

func (m *OrdersRequest) GetLimit() uint64

func (*OrdersRequest) GetMasterID added in v0.4.1 

func (m *OrdersRequest) GetMasterID() *EthAddress

func (*OrdersRequest) GetNetflags added in v0.4.1 

func (m *OrdersRequest) GetNetflags() *CmpUint64

func (*OrdersRequest) GetOffset added in v0.4.1 

func (m *OrdersRequest) GetOffset() uint64

func (*OrdersRequest) GetPrice added in v0.4.1 

func (m *OrdersRequest) GetPrice() *MaxMinBig

func (*OrdersRequest) GetSenderIDs added in v0.4.1 

func (m *OrdersRequest) GetSenderIDs() []*EthAddress

func (*OrdersRequest) GetSortings added in v0.4.1 

func (m *OrdersRequest) GetSortings() []*SortingOption

func (*OrdersRequest) GetStatus added in v0.4.1 

func (m *OrdersRequest) GetStatus() OrderStatus

func (*OrdersRequest) GetType added in v0.4.1 

func (m *OrdersRequest) GetType() OrderType

func (*OrdersRequest) GetWithCount added in v0.4.1 

func (m *OrdersRequest) GetWithCount() bool

func (*OrdersRequest) ProtoMessage added in v0.4.1 

func (*OrdersRequest) ProtoMessage()

func (*OrdersRequest) Reset added in v0.4.1 

func (m *OrdersRequest) Reset()

func (*OrdersRequest) String added in v0.4.1 

func (m *OrdersRequest) String() string

type PeerType added in v0.4.1 

type PeerType int32
const (
	PeerType_SERVER   PeerType = 0
	PeerType_CLIENT   PeerType = 1
	PeerType_DISCOVER PeerType = 2
)

func (PeerType) EnumDescriptor added in v0.4.1 

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

func (PeerType) String added in v0.4.1 

func (x PeerType) String() string

type PredictSupplierReply added in v0.4.13 

type PredictSupplierReply struct {
	Price    *Price    `protobuf:"bytes,1,opt,name=price" json:"price,omitempty"`
	OrderIDs []*BigInt `protobuf:"bytes,2,rep,name=orderIDs" json:"orderIDs,omitempty"`
}

func (*PredictSupplierReply) Descriptor added in v0.4.13 

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

func (*PredictSupplierReply) GetOrderIDs added in v0.4.15 

func (m *PredictSupplierReply) GetOrderIDs() []*BigInt

func (*PredictSupplierReply) GetPrice added in v0.4.13 

func (m *PredictSupplierReply) GetPrice() *Price

func (*PredictSupplierReply) ProtoMessage added in v0.4.13 

func (*PredictSupplierReply) ProtoMessage()

func (*PredictSupplierReply) Reset added in v0.4.13 

func (m *PredictSupplierReply) Reset()

func (*PredictSupplierReply) String added in v0.4.13 

func (m *PredictSupplierReply) String() string

type PredictSupplierRequest added in v0.4.13 

type PredictSupplierRequest struct {
	Devices *DevicesReply `protobuf:"bytes,1,opt,name=devices" json:"devices,omitempty"`
}

func (*PredictSupplierRequest) Descriptor added in v0.4.13 

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

func (*PredictSupplierRequest) GetDevices added in v0.4.13 

func (m *PredictSupplierRequest) GetDevices() *DevicesReply

func (*PredictSupplierRequest) Normalize added in v0.4.13 

func (m *PredictSupplierRequest) Normalize()

func (*PredictSupplierRequest) ProtoMessage added in v0.4.13 

func (*PredictSupplierRequest) ProtoMessage()

func (*PredictSupplierRequest) Reset added in v0.4.13 

func (m *PredictSupplierRequest) Reset()

func (*PredictSupplierRequest) String added in v0.4.13 

func (m *PredictSupplierRequest) String() string

func (*PredictSupplierRequest) Validate added in v0.4.13 

func (m *PredictSupplierRequest) Validate() error

type Price added in v0.4.1 

type Price struct {
	PerSecond *BigInt `protobuf:"bytes,1,opt,name=perSecond" json:"perSecond,omitempty"`
}

func SumPrice added in v0.4.4 

func SumPrice(plans []*AskPlan) *Price

func (*Price) Add added in v0.4.15 

func (m *Price) Add(other *Price) *Price

func (*Price) Descriptor added in v0.4.1 

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

func (*Price) GetPerSecond added in v0.4.1 

func (m *Price) GetPerSecond() *BigInt

func (*Price) LoadFromString added in v0.4.1 

func (m *Price) LoadFromString(v string) error

func (*Price) MarshalYAML added in v0.4.1 

func (m *Price) MarshalYAML() (interface{}, error)

func (*Price) ProtoMessage added in v0.4.1 

func (*Price) ProtoMessage()

func (*Price) Reset added in v0.4.1 

func (m *Price) Reset()

func (*Price) String added in v0.4.1 

func (m *Price) String() string

func (*Price) UnmarshalYAML added in v0.4.1 

func (m *Price) UnmarshalYAML(unmarshal func(interface{}) error) error

type Profile added in v0.4.1 

type Profile struct {
	UserID         *EthAddress `protobuf:"bytes,1,opt,name=UserID" json:"UserID,omitempty"`
	IdentityLevel  uint64      `protobuf:"varint,2,opt,name=IdentityLevel" json:"IdentityLevel,omitempty"`
	Name           string      `protobuf:"bytes,3,opt,name=Name" json:"Name,omitempty"`
	Country        string      `protobuf:"bytes,4,opt,name=Country" json:"Country,omitempty"`
	IsCorporation  bool        `protobuf:"varint,5,opt,name=IsCorporation" json:"IsCorporation,omitempty"`
	IsProfessional bool        `protobuf:"varint,6,opt,name=IsProfessional" json:"IsProfessional,omitempty"`
	Certificates   string      `protobuf:"bytes,7,opt,name=Certificates" json:"Certificates,omitempty"`
	ActiveAsks     uint64      `protobuf:"varint,8,opt,name=activeAsks" json:"activeAsks,omitempty"`
	ActiveBids     uint64      `protobuf:"varint,9,opt,name=activeBids" json:"activeBids,omitempty"`
	IsBlacklisted  bool        `protobuf:"varint,10,opt,name=isBlacklisted" json:"isBlacklisted,omitempty"`
}

func (*Profile) Descriptor added in v0.4.1 

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

func (*Profile) GetActiveAsks added in v0.4.1 

func (m *Profile) GetActiveAsks() uint64

func (*Profile) GetActiveBids added in v0.4.1 

func (m *Profile) GetActiveBids() uint64

func (*Profile) GetCertificates added in v0.4.1 

func (m *Profile) GetCertificates() string

func (*Profile) GetCountry added in v0.4.1 

func (m *Profile) GetCountry() string

func (*Profile) GetIdentityLevel added in v0.4.1 

func (m *Profile) GetIdentityLevel() uint64

func (*Profile) GetIsBlacklisted added in v0.4.1 

func (m *Profile) GetIsBlacklisted() bool

func (*Profile) GetIsCorporation added in v0.4.1 

func (m *Profile) GetIsCorporation() bool

func (*Profile) GetIsProfessional added in v0.4.1 

func (m *Profile) GetIsProfessional() bool

func (*Profile) GetName added in v0.4.1 

func (m *Profile) GetName() string

func (*Profile) GetUserID added in v0.4.1 

func (m *Profile) GetUserID() *EthAddress

func (*Profile) ProtoMessage added in v0.4.1 

func (*Profile) ProtoMessage()

func (*Profile) Reset added in v0.4.1 

func (m *Profile) Reset()

func (*Profile) String added in v0.4.1 

func (m *Profile) String() string

type ProfileRole added in v0.4.1 

type ProfileRole int32
const (
	ProfileRole_AnyRole  ProfileRole = 0
	ProfileRole_Supplier ProfileRole = 1
	ProfileRole_Consumer ProfileRole = 2
)

func (ProfileRole) EnumDescriptor added in v0.4.1 

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

func (ProfileRole) String added in v0.4.1 

func (x ProfileRole) String() string

type ProfilesClient added in v0.4.1 

type ProfilesClient interface {
	// List allows searching for profiles
	List(ctx context.Context, in *ProfilesRequest, opts ...grpc.CallOption) (*ProfilesReply, error)
	// Status shows detailed info about given profile
	Status(ctx context.Context, in *EthID, opts ...grpc.CallOption) (*Profile, error)
	// RemoveAttribute allows to remove profile attributes
	// for the user's own profile
	RemoveAttribute(ctx context.Context, in *BigInt, opts ...grpc.CallOption) (*Empty, error)
}

func NewProfilesClient added in v0.4.1 

func NewProfilesClient(cc *grpc.ClientConn) ProfilesClient

type ProfilesReply added in v0.4.1 

type ProfilesReply struct {
	Profiles []*Profile `protobuf:"bytes,1,rep,name=profiles" json:"profiles,omitempty"`
	Count    uint64     `protobuf:"varint,2,opt,name=count" json:"count,omitempty"`
}

func (*ProfilesReply) Descriptor added in v0.4.1 

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

func (*ProfilesReply) GetCount added in v0.4.1 

func (m *ProfilesReply) GetCount() uint64

func (*ProfilesReply) GetProfiles added in v0.4.1 

func (m *ProfilesReply) GetProfiles() []*Profile

func (*ProfilesReply) ProtoMessage added in v0.4.1 

func (*ProfilesReply) ProtoMessage()

func (*ProfilesReply) Reset added in v0.4.1 

func (m *ProfilesReply) Reset()

func (*ProfilesReply) String added in v0.4.1 

func (m *ProfilesReply) String() string

type ProfilesRequest added in v0.4.1 

type ProfilesRequest struct {
	Role          ProfileRole   `protobuf:"varint,1,opt,name=role,enum=sonm.ProfileRole" json:"role,omitempty"`
	IdentityLevel IdentityLevel `protobuf:"varint,2,opt,name=identityLevel,enum=sonm.IdentityLevel" json:"identityLevel,omitempty"`
	Country       []string      `protobuf:"bytes,3,rep,name=country" json:"country,omitempty"`
	// This value is LIKE-matched against both profile Name and UserID (case insensitive).
	Identifier     string           `protobuf:"bytes,4,opt,name=identifier" json:"identifier,omitempty"`
	BlacklistQuery *BlacklistQuery  `protobuf:"bytes,5,opt,name=blacklistQuery" json:"blacklistQuery,omitempty"`
	Limit          uint64           `protobuf:"varint,6,opt,name=limit" json:"limit,omitempty"`
	Offset         uint64           `protobuf:"varint,7,opt,name=offset" json:"offset,omitempty"`
	Sortings       []*SortingOption `protobuf:"bytes,8,rep,name=sortings" json:"sortings,omitempty"`
	WithCount      bool             `protobuf:"varint,9,opt,name=withCount" json:"withCount,omitempty"`
}

func (*ProfilesRequest) Descriptor added in v0.4.1 

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

func (*ProfilesRequest) GetBlacklistQuery added in v0.4.1 

func (m *ProfilesRequest) GetBlacklistQuery() *BlacklistQuery

func (*ProfilesRequest) GetCountry added in v0.4.1 

func (m *ProfilesRequest) GetCountry() []string

func (*ProfilesRequest) GetIdentifier added in v0.4.1 

func (m *ProfilesRequest) GetIdentifier() string

func (*ProfilesRequest) GetIdentityLevel added in v0.4.1 

func (m *ProfilesRequest) GetIdentityLevel() IdentityLevel

func (*ProfilesRequest) GetLimit added in v0.4.1 

func (m *ProfilesRequest) GetLimit() uint64

func (*ProfilesRequest) GetOffset added in v0.4.1 

func (m *ProfilesRequest) GetOffset() uint64

func (*ProfilesRequest) GetRole added in v0.4.1 

func (m *ProfilesRequest) GetRole() ProfileRole

func (*ProfilesRequest) GetSortings added in v0.4.1 

func (m *ProfilesRequest) GetSortings() []*SortingOption

func (*ProfilesRequest) GetWithCount added in v0.4.1 

func (m *ProfilesRequest) GetWithCount() bool

func (*ProfilesRequest) ProtoMessage added in v0.4.1 

func (*ProfilesRequest) ProtoMessage()

func (*ProfilesRequest) Reset added in v0.4.1 

func (m *ProfilesRequest) Reset()

func (*ProfilesRequest) String added in v0.4.1 

func (m *ProfilesRequest) String() string

type ProfilesServer added in v0.4.1 

type ProfilesServer interface {
	// List allows searching for profiles
	List(context.Context, *ProfilesRequest) (*ProfilesReply, error)
	// Status shows detailed info about given profile
	Status(context.Context, *EthID) (*Profile, error)
	// RemoveAttribute allows to remove profile attributes
	// for the user's own profile
	RemoveAttribute(context.Context, *BigInt) (*Empty, error)
}

type Progress 

type Progress struct {
	Size int64 `protobuf:"varint,1,opt,name=size" json:"size,omitempty"`
}

func (*Progress) Descriptor 

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

func (*Progress) GetSize 

func (m *Progress) GetSize() int64

func (*Progress) ProtoMessage 

func (*Progress) ProtoMessage()

func (*Progress) Reset 

func (m *Progress) Reset()

func (*Progress) String 

func (m *Progress) String() string

type PublishRequest added in v0.4.1 

type PublishRequest struct {
	// Protocol describes the application protocol the peer wants to publish.
	Protocol string `protobuf:"bytes,1,opt,name=protocol" json:"protocol,omitempty"`
	// PrivateAddrs describes source private addresses.
	PrivateAddrs []*Addr `protobuf:"bytes,2,rep,name=privateAddrs" json:"privateAddrs,omitempty"`
}

func (*PublishRequest) Descriptor added in v0.4.1 

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

func (*PublishRequest) GetPrivateAddrs added in v0.4.1 

func (m *PublishRequest) GetPrivateAddrs() []*Addr

func (*PublishRequest) GetProtocol added in v0.4.1 

func (m *PublishRequest) GetProtocol() string

func (*PublishRequest) ProtoMessage added in v0.4.1 

func (*PublishRequest) ProtoMessage()

func (*PublishRequest) Reset added in v0.4.1 

func (m *PublishRequest) Reset()

func (*PublishRequest) String added in v0.4.1 

func (m *PublishRequest) String() string

func (*PublishRequest) Validate added in v0.4.1 

func (m *PublishRequest) Validate() error

type PullTaskRequest 

type PullTaskRequest struct {
	DealId string `protobuf:"bytes,1,opt,name=dealId" json:"dealId,omitempty"`
	TaskId string `protobuf:"bytes,2,opt,name=taskId" json:"taskId,omitempty"`
}

func (*PullTaskRequest) Descriptor 

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

func (*PullTaskRequest) GetDealId 

func (m *PullTaskRequest) GetDealId() string

func (*PullTaskRequest) GetTaskId 

func (m *PullTaskRequest) GetTaskId() string

func (*PullTaskRequest) ProtoMessage 

func (*PullTaskRequest) ProtoMessage()

func (*PullTaskRequest) Reset 

func (m *PullTaskRequest) Reset()

func (*PullTaskRequest) String 

func (m *PullTaskRequest) String() string

type PurgeTasksRequest added in v0.4.13 

type PurgeTasksRequest struct {
	DealID *BigInt `protobuf:"bytes,1,opt,name=dealID" json:"dealID,omitempty"`
}

func (*PurgeTasksRequest) Descriptor added in v0.4.13 

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

func (*PurgeTasksRequest) GetDealID added in v0.4.13 

func (m *PurgeTasksRequest) GetDealID() *BigInt

func (*PurgeTasksRequest) ProtoMessage added in v0.4.13 

func (*PurgeTasksRequest) ProtoMessage()

func (*PurgeTasksRequest) Reset added in v0.4.13 

func (m *PurgeTasksRequest) Reset()

func (*PurgeTasksRequest) String added in v0.4.13 

func (m *PurgeTasksRequest) String() string

type QOSAddHTBShapingRequest added in v0.4.21 

type QOSAddHTBShapingRequest struct {
	LinkName         string `protobuf:"bytes,1,opt,name=linkName" json:"linkName,omitempty"`
	LinkAlias        string `protobuf:"bytes,2,opt,name=linkAlias" json:"linkAlias,omitempty"`
	RateLimitEgress  uint64 `protobuf:"varint,3,opt,name=rateLimitEgress" json:"rateLimitEgress,omitempty"`
	RateLimitIngress uint64 `protobuf:"varint,4,opt,name=rateLimitIngress" json:"rateLimitIngress,omitempty"`
}

func (*QOSAddHTBShapingRequest) Descriptor added in v0.4.21 

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

func (*QOSAddHTBShapingRequest) GetLinkAlias added in v0.4.21 

func (m *QOSAddHTBShapingRequest) GetLinkAlias() string

func (*QOSAddHTBShapingRequest) GetLinkName added in v0.4.21 

func (m *QOSAddHTBShapingRequest) GetLinkName() string

func (*QOSAddHTBShapingRequest) GetRateLimitEgress added in v0.4.21 

func (m *QOSAddHTBShapingRequest) GetRateLimitEgress() uint64

func (*QOSAddHTBShapingRequest) GetRateLimitIngress added in v0.4.21 

func (m *QOSAddHTBShapingRequest) GetRateLimitIngress() uint64

func (*QOSAddHTBShapingRequest) ProtoMessage added in v0.4.21 

func (*QOSAddHTBShapingRequest) ProtoMessage()

func (*QOSAddHTBShapingRequest) Reset added in v0.4.21 

func (m *QOSAddHTBShapingRequest) Reset()

func (*QOSAddHTBShapingRequest) String added in v0.4.21 

func (m *QOSAddHTBShapingRequest) String() string

type QOSAddHTBShapingResponse added in v0.4.21 

type QOSAddHTBShapingResponse struct {
}

func (*QOSAddHTBShapingResponse) Descriptor added in v0.4.21 

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

func (*QOSAddHTBShapingResponse) ProtoMessage added in v0.4.21 

func (*QOSAddHTBShapingResponse) ProtoMessage()

func (*QOSAddHTBShapingResponse) Reset added in v0.4.21 

func (m *QOSAddHTBShapingResponse) Reset()

func (*QOSAddHTBShapingResponse) String added in v0.4.21 

func (m *QOSAddHTBShapingResponse) String() string

type QOSClient added in v0.4.21 

type QOSClient interface {
	SetAlias(ctx context.Context, in *QOSSetAliasRequest, opts ...grpc.CallOption) (*QOSSetAliasResponse, error)
	AddHTBShaping(ctx context.Context, in *QOSAddHTBShapingRequest, opts ...grpc.CallOption) (*QOSAddHTBShapingResponse, error)
	RemoveHTBShaping(ctx context.Context, in *QOSRemoveHTBShapingRequest, opts ...grpc.CallOption) (*QOSRemoveHTBShapingResponse, error)
	// Flush completely resets
	Flush(ctx context.Context, in *QOSFlushRequest, opts ...grpc.CallOption) (*QOSFlushResponse, error)
}

func NewQOSClient added in v0.4.21 

func NewQOSClient(cc *grpc.ClientConn) QOSClient

type QOSFlushRequest added in v0.4.22 

type QOSFlushRequest struct {
}

func (*QOSFlushRequest) Descriptor added in v0.4.22 

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

func (*QOSFlushRequest) ProtoMessage added in v0.4.22 

func (*QOSFlushRequest) ProtoMessage()

func (*QOSFlushRequest) Reset added in v0.4.22 

func (m *QOSFlushRequest) Reset()

func (*QOSFlushRequest) String added in v0.4.22 

func (m *QOSFlushRequest) String() string

type QOSFlushResponse added in v0.4.22 

type QOSFlushResponse struct {
}

func (*QOSFlushResponse) Descriptor added in v0.4.22 

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

func (*QOSFlushResponse) ProtoMessage added in v0.4.22 

func (*QOSFlushResponse) ProtoMessage()

func (*QOSFlushResponse) Reset added in v0.4.22 

func (m *QOSFlushResponse) Reset()

func (*QOSFlushResponse) String added in v0.4.22 

func (m *QOSFlushResponse) String() string

type QOSRemoveHTBShapingRequest added in v0.4.21 

type QOSRemoveHTBShapingRequest struct {
	LinkName string `protobuf:"bytes,1,opt,name=linkName" json:"linkName,omitempty"`
}

func (*QOSRemoveHTBShapingRequest) Descriptor added in v0.4.21 

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

func (*QOSRemoveHTBShapingRequest) GetLinkName added in v0.4.21 

func (m *QOSRemoveHTBShapingRequest) GetLinkName() string

func (*QOSRemoveHTBShapingRequest) ProtoMessage added in v0.4.21 

func (*QOSRemoveHTBShapingRequest) ProtoMessage()

func (*QOSRemoveHTBShapingRequest) Reset added in v0.4.21 

func (m *QOSRemoveHTBShapingRequest) Reset()

func (*QOSRemoveHTBShapingRequest) String added in v0.4.21 

func (m *QOSRemoveHTBShapingRequest) String() string

type QOSRemoveHTBShapingResponse added in v0.4.21 

type QOSRemoveHTBShapingResponse struct {
}

func (*QOSRemoveHTBShapingResponse) Descriptor added in v0.4.21 

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

func (*QOSRemoveHTBShapingResponse) ProtoMessage added in v0.4.21 

func (*QOSRemoveHTBShapingResponse) ProtoMessage()

func (*QOSRemoveHTBShapingResponse) Reset added in v0.4.21 

func (m *QOSRemoveHTBShapingResponse) Reset()

func (*QOSRemoveHTBShapingResponse) String added in v0.4.21 

func (m *QOSRemoveHTBShapingResponse) String() string

type QOSServer added in v0.4.21 

type QOSServer interface {
	SetAlias(context.Context, *QOSSetAliasRequest) (*QOSSetAliasResponse, error)
	AddHTBShaping(context.Context, *QOSAddHTBShapingRequest) (*QOSAddHTBShapingResponse, error)
	RemoveHTBShaping(context.Context, *QOSRemoveHTBShapingRequest) (*QOSRemoveHTBShapingResponse, error)
	// Flush completely resets
	Flush(context.Context, *QOSFlushRequest) (*QOSFlushResponse, error)
}

type QOSSetAliasRequest added in v0.4.21 

type QOSSetAliasRequest struct {
	LinkName  string `protobuf:"bytes,1,opt,name=linkName" json:"linkName,omitempty"`
	LinkAlias string `protobuf:"bytes,2,opt,name=linkAlias" json:"linkAlias,omitempty"`
}

func (*QOSSetAliasRequest) Descriptor added in v0.4.21 

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

func (*QOSSetAliasRequest) GetLinkAlias added in v0.4.21 

func (m *QOSSetAliasRequest) GetLinkAlias() string

func (*QOSSetAliasRequest) GetLinkName added in v0.4.21 

func (m *QOSSetAliasRequest) GetLinkName() string

func (*QOSSetAliasRequest) ProtoMessage added in v0.4.21 

func (*QOSSetAliasRequest) ProtoMessage()

func (*QOSSetAliasRequest) Reset added in v0.4.21 

func (m *QOSSetAliasRequest) Reset()

func (*QOSSetAliasRequest) String added in v0.4.21 

func (m *QOSSetAliasRequest) String() string

type QOSSetAliasResponse added in v0.4.21 

type QOSSetAliasResponse struct {
}

func (*QOSSetAliasResponse) Descriptor added in v0.4.21 

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

func (*QOSSetAliasResponse) ProtoMessage added in v0.4.21 

func (*QOSSetAliasResponse) ProtoMessage()

func (*QOSSetAliasResponse) Reset added in v0.4.21 

func (m *QOSSetAliasResponse) Reset()

func (*QOSSetAliasResponse) String added in v0.4.21 

func (m *QOSSetAliasResponse) String() string

type QuickBuyRequest added in v0.4.1 

type QuickBuyRequest struct {
	AskID    *BigInt   `protobuf:"bytes,1,opt,name=askID" json:"askID,omitempty"`
	Duration *Duration `protobuf:"bytes,2,opt,name=duration" json:"duration,omitempty"`
	Force    bool      `protobuf:"varint,3,opt,name=force" json:"force,omitempty"`
}

func (*QuickBuyRequest) Descriptor added in v0.4.1 

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

func (*QuickBuyRequest) GetAskID added in v0.4.1 

func (m *QuickBuyRequest) GetAskID() *BigInt

func (*QuickBuyRequest) GetDuration added in v0.4.1 

func (m *QuickBuyRequest) GetDuration() *Duration

func (*QuickBuyRequest) GetForce added in v0.4.5 

func (m *QuickBuyRequest) GetForce() bool

func (*QuickBuyRequest) ProtoMessage added in v0.4.1 

func (*QuickBuyRequest) ProtoMessage()

func (*QuickBuyRequest) Reset added in v0.4.1 

func (m *QuickBuyRequest) Reset()

func (*QuickBuyRequest) String added in v0.4.1 

func (m *QuickBuyRequest) String() string

type RAM added in v0.4.1 

type RAM struct {
	Device     *RAMDevice            `protobuf:"bytes,1,opt,name=device" json:"device,omitempty"`
	Benchmarks map[uint64]*Benchmark `` /* 141-byte string literal not displayed */
}

func (*RAM) Descriptor added in v0.4.1 

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

func (*RAM) GetBenchmarks added in v0.4.1 

func (m *RAM) GetBenchmarks() map[uint64]*Benchmark

func (*RAM) GetDevice added in v0.4.1 

func (m *RAM) GetDevice() *RAMDevice

func (*RAM) ProtoMessage added in v0.4.1 

func (*RAM) ProtoMessage()

func (*RAM) Reset added in v0.4.1 

func (m *RAM) Reset()

func (*RAM) String added in v0.4.1 

func (m *RAM) String() string

type RAMDevice 

type RAMDevice struct {
	// Total amount of RAM on machine
	Total uint64 `protobuf:"varint,1,opt,name=total" json:"total,omitempty"`
	// Available amount of RAM for task scheduling
	Available uint64 `protobuf:"varint,2,opt,name=available" json:"available,omitempty"`
	// Used amount of RAM on machine
	Used uint64 `protobuf:"varint,3,opt,name=used" json:"used,omitempty"`
}

func (*RAMDevice) Descriptor 

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

func (*RAMDevice) GetAvailable added in v0.4.1 

func (m *RAMDevice) GetAvailable() uint64

func (*RAMDevice) GetFree added in v0.4.20 

func (m *RAMDevice) GetFree() uint64

func (*RAMDevice) GetTotal 

func (m *RAMDevice) GetTotal() uint64

func (*RAMDevice) GetUsed 

func (m *RAMDevice) GetUsed() uint64

func (*RAMDevice) HardwareHash added in v0.4.1 

func (m *RAMDevice) HardwareHash() string

func (*RAMDevice) ProtoMessage 

func (*RAMDevice) ProtoMessage()

func (*RAMDevice) Reset 

func (m *RAMDevice) Reset()

func (*RAMDevice) String 

func (m *RAMDevice) String() string

type Registry added in v0.4.1 

type Registry struct {
	Username string `protobuf:"bytes,1,opt,name=username" json:"username,omitempty"`
	Password string `protobuf:"bytes,2,opt,name=password" json:"password,omitempty"`
}

func (*Registry) Auth added in v0.4.1 

func (m *Registry) Auth() string

func (*Registry) Descriptor added in v0.4.1 

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

func (*Registry) GetPassword added in v0.4.1 

func (m *Registry) GetPassword() string

func (*Registry) GetUsername added in v0.4.1 

func (m *Registry) GetUsername() string

func (*Registry) ProtoMessage added in v0.4.1 

func (*Registry) ProtoMessage()

func (*Registry) Reset added in v0.4.1 

func (m *Registry) Reset()

func (*Registry) String added in v0.4.1 

func (m *Registry) String() string

type RelayClient added in v0.4.1 

type RelayClient interface {
	Cluster(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*RelayClusterReply, error)
	Metrics(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*RelayMetrics, error)
	Info(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*RelayInfo, error)
}

func NewRelayClient added in v0.4.1 

func NewRelayClient(cc *grpc.ClientConn) RelayClient

type RelayClusterReply added in v0.4.1 

type RelayClusterReply struct {
	Members []string `protobuf:"bytes,1,rep,name=members" json:"members,omitempty"`
}

func (*RelayClusterReply) Descriptor added in v0.4.1 

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

func (*RelayClusterReply) GetMembers added in v0.4.1 

func (m *RelayClusterReply) GetMembers() []string

func (*RelayClusterReply) ProtoMessage added in v0.4.1 

func (*RelayClusterReply) ProtoMessage()

func (*RelayClusterReply) Reset added in v0.4.1 

func (m *RelayClusterReply) Reset()

func (*RelayClusterReply) String added in v0.4.1 

func (m *RelayClusterReply) String() string

type RelayInfo added in v0.4.10 

type RelayInfo struct {
	State map[string]*RelayMeeting `` /* 130-byte string literal not displayed */
}

RelayInfo is a response returned from Info handle.

func (*RelayInfo) Descriptor added in v0.4.10 

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

func (*RelayInfo) GetState added in v0.4.10 

func (m *RelayInfo) GetState() map[string]*RelayMeeting

func (*RelayInfo) ProtoMessage added in v0.4.10 

func (*RelayInfo) ProtoMessage()

func (*RelayInfo) Reset added in v0.4.10 

func (m *RelayInfo) Reset()

func (*RelayInfo) String added in v0.4.10 

func (m *RelayInfo) String() string

type RelayMeeting added in v0.4.10 

type RelayMeeting struct {
	Servers map[string]*Addr `` /* 134-byte string literal not displayed */
}

RelayMeeting represents relay point.

func (*RelayMeeting) Descriptor added in v0.4.10 

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

func (*RelayMeeting) GetServers added in v0.4.10 

func (m *RelayMeeting) GetServers() map[string]*Addr

func (*RelayMeeting) ProtoMessage added in v0.4.10 

func (*RelayMeeting) ProtoMessage()

func (*RelayMeeting) Reset added in v0.4.10 

func (m *RelayMeeting) Reset()

func (*RelayMeeting) String added in v0.4.10 

func (m *RelayMeeting) String() string

type RelayMetrics added in v0.4.1 

type RelayMetrics struct {
	ConnCurrent uint64                 `protobuf:"varint,1,opt,name=connCurrent" json:"connCurrent,omitempty"`
	Net         map[string]*NetMetrics `` /* 126-byte string literal not displayed */
	Uptime      uint64                 `protobuf:"varint,3,opt,name=uptime" json:"uptime,omitempty"`
}

func (*RelayMetrics) Descriptor added in v0.4.1 

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

func (*RelayMetrics) GetConnCurrent added in v0.4.1 

func (m *RelayMetrics) GetConnCurrent() uint64

func (*RelayMetrics) GetNet added in v0.4.1 

func (m *RelayMetrics) GetNet() map[string]*NetMetrics

func (*RelayMetrics) GetUptime added in v0.4.1 

func (m *RelayMetrics) GetUptime() uint64

func (*RelayMetrics) ProtoMessage added in v0.4.1 

func (*RelayMetrics) ProtoMessage()

func (*RelayMetrics) Reset added in v0.4.1 

func (m *RelayMetrics) Reset()

func (*RelayMetrics) String added in v0.4.1 

func (m *RelayMetrics) String() string

type RelayServer added in v0.4.1 

type RelayServer interface {
	Cluster(context.Context, *Empty) (*RelayClusterReply, error)
	Metrics(context.Context, *Empty) (*RelayMetrics, error)
	Info(context.Context, *Empty) (*RelayInfo, error)
}

type RemoteGPUDeviceReply added in v0.4.25 

type RemoteGPUDeviceReply struct {
	Devices []*GPUDevice `protobuf:"bytes,1,rep,name=devices" json:"devices,omitempty"`
}

func (*RemoteGPUDeviceReply) Descriptor added in v0.4.25 

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

func (*RemoteGPUDeviceReply) GetDevices added in v0.4.25 

func (m *RemoteGPUDeviceReply) GetDevices() []*GPUDevice

func (*RemoteGPUDeviceReply) ProtoMessage added in v0.4.25 

func (*RemoteGPUDeviceReply) ProtoMessage()

func (*RemoteGPUDeviceReply) Reset added in v0.4.25 

func (m *RemoteGPUDeviceReply) Reset()

func (*RemoteGPUDeviceReply) String added in v0.4.25 

func (m *RemoteGPUDeviceReply) String() string

type RemoteGPUDeviceRequest added in v0.4.25 

type RemoteGPUDeviceRequest struct {
}

func (*RemoteGPUDeviceRequest) Descriptor added in v0.4.25 

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

func (*RemoteGPUDeviceRequest) ProtoMessage added in v0.4.25 

func (*RemoteGPUDeviceRequest) ProtoMessage()

func (*RemoteGPUDeviceRequest) Reset added in v0.4.25 

func (m *RemoteGPUDeviceRequest) Reset()

func (*RemoteGPUDeviceRequest) String added in v0.4.25 

func (m *RemoteGPUDeviceRequest) String() string

type RemoteGPUTunerClient added in v0.4.25 

type RemoteGPUTunerClient interface {
	Devices(ctx context.Context, in *RemoteGPUDeviceRequest, opts ...grpc.CallOption) (*RemoteGPUDeviceReply, error)
}

func NewRemoteGPUTunerClient added in v0.4.25 

func NewRemoteGPUTunerClient(cc *grpc.ClientConn) RemoteGPUTunerClient

type RemoteGPUTunerServer added in v0.4.25 

type RemoteGPUTunerServer interface {
	Devices(context.Context, *RemoteGPUDeviceRequest) (*RemoteGPUDeviceReply, error)
}

type RemotePTYBannerRequest added in v0.4.30 

type RemotePTYBannerRequest struct {
}

func (*RemotePTYBannerRequest) Descriptor added in v0.4.30 

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

func (*RemotePTYBannerRequest) ProtoMessage added in v0.4.30 

func (*RemotePTYBannerRequest) ProtoMessage()

func (*RemotePTYBannerRequest) Reset added in v0.4.30 

func (m *RemotePTYBannerRequest) Reset()

func (*RemotePTYBannerRequest) String added in v0.4.30 

func (m *RemotePTYBannerRequest) String() string

type RemotePTYBannerResponse added in v0.4.30 

type RemotePTYBannerResponse struct {
	Banner string `protobuf:"bytes,1,opt,name=banner" json:"banner,omitempty"`
}

func (*RemotePTYBannerResponse) Descriptor added in v0.4.30 

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

func (*RemotePTYBannerResponse) GetBanner added in v0.4.30 

func (m *RemotePTYBannerResponse) GetBanner() string

func (*RemotePTYBannerResponse) ProtoMessage added in v0.4.30 

func (*RemotePTYBannerResponse) ProtoMessage()

func (*RemotePTYBannerResponse) Reset added in v0.4.30 

func (m *RemotePTYBannerResponse) Reset()

func (*RemotePTYBannerResponse) String added in v0.4.30 

func (m *RemotePTYBannerResponse) String() string

type RemotePTYClient added in v0.4.30 

type RemotePTYClient interface {
	Banner(ctx context.Context, in *RemotePTYBannerRequest, opts ...grpc.CallOption) (*RemotePTYBannerResponse, error)
	Exec(ctx context.Context, in *RemotePTYExecRequest, opts ...grpc.CallOption) (RemotePTY_ExecClient, error)
}

func NewRemotePTYClient added in v0.4.30 

func NewRemotePTYClient(cc *grpc.ClientConn) RemotePTYClient

type RemotePTYExecRequest added in v0.4.30 

type RemotePTYExecRequest struct {
	Args []string `protobuf:"bytes,1,rep,name=args" json:"args,omitempty"`
	Envp []string `protobuf:"bytes,2,rep,name=envp" json:"envp,omitempty"`
}

func (*RemotePTYExecRequest) Descriptor added in v0.4.30 

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

func (*RemotePTYExecRequest) GetArgs added in v0.4.30 

func (m *RemotePTYExecRequest) GetArgs() []string

func (*RemotePTYExecRequest) GetEnvp added in v0.4.30 

func (m *RemotePTYExecRequest) GetEnvp() []string

func (*RemotePTYExecRequest) ProtoMessage added in v0.4.30 

func (*RemotePTYExecRequest) ProtoMessage()

func (*RemotePTYExecRequest) Reset added in v0.4.30 

func (m *RemotePTYExecRequest) Reset()

func (*RemotePTYExecRequest) String added in v0.4.30 

func (m *RemotePTYExecRequest) String() string

type RemotePTYExecResponseChunk added in v0.4.30 

type RemotePTYExecResponseChunk struct {
	Out  []byte `protobuf:"bytes,1,opt,name=out,proto3" json:"out,omitempty"`
	Done bool   `protobuf:"varint,2,opt,name=done" json:"done,omitempty"`
}

func (*RemotePTYExecResponseChunk) Descriptor added in v0.4.30 

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

func (*RemotePTYExecResponseChunk) GetDone added in v0.4.30 

func (m *RemotePTYExecResponseChunk) GetDone() bool

func (*RemotePTYExecResponseChunk) GetOut added in v0.4.30 

func (m *RemotePTYExecResponseChunk) GetOut() []byte

func (*RemotePTYExecResponseChunk) ProtoMessage added in v0.4.30 

func (*RemotePTYExecResponseChunk) ProtoMessage()

func (*RemotePTYExecResponseChunk) Reset added in v0.4.30 

func (m *RemotePTYExecResponseChunk) Reset()

func (*RemotePTYExecResponseChunk) String added in v0.4.30 

func (m *RemotePTYExecResponseChunk) String() string

type RemotePTYServer added in v0.4.30 

type RemotePTYServer interface {
	Banner(context.Context, *RemotePTYBannerRequest) (*RemotePTYBannerResponse, error)
	Exec(*RemotePTYExecRequest, RemotePTY_ExecServer) error
}

type RemotePTY_ExecClient added in v0.4.30 

type RemotePTY_ExecClient interface {
	Recv() (*RemotePTYExecResponseChunk, error)
	grpc.ClientStream
}

type RemotePTY_ExecServer added in v0.4.30 

type RemotePTY_ExecServer interface {
	Send(*RemotePTYExecResponseChunk) error
	grpc.ServerStream
}

type RendezvousClient added in v0.4.1 

type RendezvousClient interface {
	// Resolve resolves the remote peer addresses.
	Resolve(ctx context.Context, in *ConnectRequest, opts ...grpc.CallOption) (*RendezvousReply, error)
	// ResolveAll resolves remote servers using the specified peer ID,
	// returning the list of unique id's of these servets.
	//
	// Such UUIDs can be used for establishing aimed connection with all
	// servers under the same ID without randomization games.
	ResolveAll(ctx context.Context, in *ID, opts ...grpc.CallOption) (*ResolveMetaReply, error)
	// Publish allows to publish the caller server's endpoints.
	//
	// While published the server can be located using the ID extracted from
	// the transport credentials.
	Publish(ctx context.Context, in *PublishRequest, opts ...grpc.CallOption) (*RendezvousReply, error)
	// Info returns server's internal state.
	Info(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*RendezvousState, error)
}

func NewRendezvousClient added in v0.4.1 

func NewRendezvousClient(cc *grpc.ClientConn) RendezvousClient

type RendezvousMeeting added in v0.4.1 

type RendezvousMeeting struct {
	Clients map[string]*RendezvousReply `` /* 134-byte string literal not displayed */
	Servers map[string]*RendezvousReply `` /* 134-byte string literal not displayed */
}

RendezvousMeeting represents rendezvous point.

func (*RendezvousMeeting) Descriptor added in v0.4.1 

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

func (*RendezvousMeeting) GetClients added in v0.4.1 

func (m *RendezvousMeeting) GetClients() map[string]*RendezvousReply

func (*RendezvousMeeting) GetServers added in v0.4.1 

func (m *RendezvousMeeting) GetServers() map[string]*RendezvousReply

func (*RendezvousMeeting) ProtoMessage added in v0.4.1 

func (*RendezvousMeeting) ProtoMessage()

func (*RendezvousMeeting) Reset added in v0.4.1 

func (m *RendezvousMeeting) Reset()

func (*RendezvousMeeting) String added in v0.4.1 

func (m *RendezvousMeeting) String() string

type RendezvousReply added in v0.4.1 

type RendezvousReply struct {
	// PublicAddr is a public network address of a target.
	PublicAddr *Addr `protobuf:"bytes,1,opt,name=publicAddr" json:"publicAddr,omitempty"`
	// PrivateAddrs describes private network addresses of a target.
	//
	// These addresses should be used to perform an initial connection
	// attempt for cases where both peers are located under the same NAT.
	PrivateAddrs []*Addr `protobuf:"bytes,2,rep,name=privateAddrs" json:"privateAddrs,omitempty"`
}

RendezvousReply describes a rendezvous point reply.

func (*RendezvousReply) Descriptor added in v0.4.1 

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

func (*RendezvousReply) Empty added in v0.4.1 

func (m *RendezvousReply) Empty() bool

func (*RendezvousReply) GetAddresses added in v0.4.20 

func (m *RendezvousReply) GetAddresses() []*Addr

func (*RendezvousReply) GetPrivateAddrs added in v0.4.1 

func (m *RendezvousReply) GetPrivateAddrs() []*Addr

func (*RendezvousReply) GetPublicAddr added in v0.4.1 

func (m *RendezvousReply) GetPublicAddr() *Addr

func (*RendezvousReply) ProtoMessage added in v0.4.1 

func (*RendezvousReply) ProtoMessage()

func (*RendezvousReply) Reset added in v0.4.1 

func (m *RendezvousReply) Reset()

func (*RendezvousReply) String added in v0.4.1 

func (m *RendezvousReply) String() string

type RendezvousServer added in v0.4.1 

type RendezvousServer interface {
	// Resolve resolves the remote peer addresses.
	Resolve(context.Context, *ConnectRequest) (*RendezvousReply, error)
	// ResolveAll resolves remote servers using the specified peer ID,
	// returning the list of unique id's of these servets.
	//
	// Such UUIDs can be used for establishing aimed connection with all
	// servers under the same ID without randomization games.
	ResolveAll(context.Context, *ID) (*ResolveMetaReply, error)
	// Publish allows to publish the caller server's endpoints.
	//
	// While published the server can be located using the ID extracted from
	// the transport credentials.
	Publish(context.Context, *PublishRequest) (*RendezvousReply, error)
	// Info returns server's internal state.
	Info(context.Context, *Empty) (*RendezvousState, error)
}

type RendezvousState added in v0.4.1 

type RendezvousState struct {
	State map[string]*RendezvousMeeting `` /* 130-byte string literal not displayed */
}

RendezvousState is a response returned from Info handle.

func (*RendezvousState) Descriptor added in v0.4.1 

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

func (*RendezvousState) GetState added in v0.4.1 

func (m *RendezvousState) GetState() map[string]*RendezvousMeeting

func (*RendezvousState) ProtoMessage added in v0.4.1 

func (*RendezvousState) ProtoMessage()

func (*RendezvousState) Reset added in v0.4.1 

func (m *RendezvousState) Reset()

func (*RendezvousState) String added in v0.4.1 

func (m *RendezvousState) String() string

type ResolveMetaReply added in v0.4.1 

type ResolveMetaReply struct {
	IDs []string `protobuf:"bytes,1,rep,name=IDs" json:"IDs,omitempty"`
}

func (*ResolveMetaReply) Descriptor added in v0.4.1 

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

func (*ResolveMetaReply) GetIDs added in v0.4.1 

func (m *ResolveMetaReply) GetIDs() []string

func (*ResolveMetaReply) ProtoMessage added in v0.4.1 

func (*ResolveMetaReply) ProtoMessage()

func (*ResolveMetaReply) Reset added in v0.4.1 

func (m *ResolveMetaReply) Reset()

func (*ResolveMetaReply) String added in v0.4.1 

func (m *ResolveMetaReply) String() string

type ResourceUsage 

type ResourceUsage struct {
	Cpu     *CPUUsage                `protobuf:"bytes,1,opt,name=cpu" json:"cpu,omitempty"`
	Memory  *MemoryUsage             `protobuf:"bytes,2,opt,name=memory" json:"memory,omitempty"`
	Network map[string]*NetworkUsage `` /* 134-byte string literal not displayed */
}

func (*ResourceUsage) Descriptor 

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

func (*ResourceUsage) GetCpu 

func (m *ResourceUsage) GetCpu() *CPUUsage

func (*ResourceUsage) GetMemory 

func (m *ResourceUsage) GetMemory() *MemoryUsage

func (*ResourceUsage) GetNetwork 

func (m *ResourceUsage) GetNetwork() map[string]*NetworkUsage

func (*ResourceUsage) ProtoMessage 

func (*ResourceUsage) ProtoMessage()

func (*ResourceUsage) Reset 

func (m *ResourceUsage) Reset()

func (*ResourceUsage) String 

func (m *ResourceUsage) String() string

type SalesmanData added in v0.4.1 

type SalesmanData struct {
	AskPlanCGroups map[string]string `` /* 148-byte string literal not displayed */
	Deals          map[string]*Deal  `` /* 130-byte string literal not displayed */
	Orders         map[string]*Order `` /* 132-byte string literal not displayed */
}

func (*SalesmanData) Descriptor added in v0.4.1 

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

func (*SalesmanData) GetAskPlanCGroups added in v0.4.1 

func (m *SalesmanData) GetAskPlanCGroups() map[string]string

func (*SalesmanData) GetDeals added in v0.4.1 

func (m *SalesmanData) GetDeals() map[string]*Deal

func (*SalesmanData) GetOrders added in v0.4.1 

func (m *SalesmanData) GetOrders() map[string]*Order

func (*SalesmanData) ProtoMessage added in v0.4.1 

func (*SalesmanData) ProtoMessage()

func (*SalesmanData) Reset added in v0.4.1 

func (m *SalesmanData) Reset()

func (*SalesmanData) String added in v0.4.1 

func (m *SalesmanData) String() string

type SchedulerData added in v0.4.1 

type SchedulerData struct {
	TaskToAskPlan map[string]string    `` /* 146-byte string literal not displayed */
	AskPlanPools  map[string]*TaskPool `` /* 144-byte string literal not displayed */
	PlanPool      *AskPlanPool         `protobuf:"bytes,4,opt,name=planPool" json:"planPool,omitempty"`
}

func (*SchedulerData) Descriptor added in v0.4.1 

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

func (*SchedulerData) GetAskPlanPools added in v0.4.1 

func (m *SchedulerData) GetAskPlanPools() map[string]*TaskPool

func (*SchedulerData) GetPlanPool added in v0.4.13 

func (m *SchedulerData) GetPlanPool() *AskPlanPool

func (*SchedulerData) GetTaskToAskPlan added in v0.4.1 

func (m *SchedulerData) GetTaskToAskPlan() map[string]string

func (*SchedulerData) ProtoMessage added in v0.4.1 

func (*SchedulerData) ProtoMessage()

func (*SchedulerData) Reset added in v0.4.1 

func (m *SchedulerData) Reset()

func (*SchedulerData) String added in v0.4.1 

func (m *SchedulerData) String() string

type SocketAddr 

type SocketAddr struct {
	// Addr describes an IP address.
	Addr string `protobuf:"bytes,1,opt,name=addr" json:"addr,omitempty"`
	// Port describes a port number.
	// Actually an `uint16` here. Protobuf is so clear and handy.
	Port uint32 `protobuf:"varint,2,opt,name=port" json:"port,omitempty"`
}

func NewSocketAddr added in v0.4.1 

func NewSocketAddr(endpoint string) (*SocketAddr, error)

func (*SocketAddr) Descriptor 

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

func (*SocketAddr) GetAddr 

func (m *SocketAddr) GetAddr() string

func (*SocketAddr) GetPort 

func (m *SocketAddr) GetPort() uint32

func (*SocketAddr) IntoTCP added in v0.4.1 

func (m *SocketAddr) IntoTCP() (net.Addr, error)

func (*SocketAddr) IntoUDP added in v0.4.17 

func (m *SocketAddr) IntoUDP() (*net.UDPAddr, error)

func (*SocketAddr) IsPrivate added in v0.4.1 

func (m *SocketAddr) IsPrivate() bool

IsPrivate returns true if this address can't be reached from the Internet directly.

func (*SocketAddr) ProtoMessage 

func (*SocketAddr) ProtoMessage()

func (*SocketAddr) Reset 

func (m *SocketAddr) Reset()

func (*SocketAddr) String 

func (m *SocketAddr) String() string

type SortingOption added in v0.4.1 

type SortingOption struct {
	Field string       `protobuf:"bytes,1,opt,name=field" json:"field,omitempty"`
	Order SortingOrder `protobuf:"varint,2,opt,name=order,enum=sonm.SortingOrder" json:"order,omitempty"`
}

func (*SortingOption) Descriptor added in v0.4.1 

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

func (*SortingOption) GetField added in v0.4.1 

func (m *SortingOption) GetField() string

func (*SortingOption) GetOrder added in v0.4.1 

func (m *SortingOption) GetOrder() SortingOrder

func (*SortingOption) ProtoMessage added in v0.4.1 

func (*SortingOption) ProtoMessage()

func (*SortingOption) Reset added in v0.4.1 

func (m *SortingOption) Reset()

func (*SortingOption) String added in v0.4.1 

func (m *SortingOption) String() string

type SortingOrder added in v0.4.1 

type SortingOrder int32
const (
	SortingOrder_Asc  SortingOrder = 0
	SortingOrder_Desc SortingOrder = 1
)

func (SortingOrder) EnumDescriptor added in v0.4.1 

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

func (SortingOrder) String added in v0.4.1 

func (x SortingOrder) String() string

type SplittingAlgorithm added in v0.4.1 

type SplittingAlgorithm int32

SplittingAlgorithm describes how a benchmark is mapped to a device. 

const (
	SplittingAlgorithm_NONE         SplittingAlgorithm = 0
	SplittingAlgorithm_PROPORTIONAL SplittingAlgorithm = 1
	SplittingAlgorithm_MIN          SplittingAlgorithm = 2
	SplittingAlgorithm_MAX          SplittingAlgorithm = 3
)

func (SplittingAlgorithm) EnumDescriptor added in v0.4.1 

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

func (SplittingAlgorithm) String added in v0.4.1 

func (x SplittingAlgorithm) String() string

type StartTaskReply added in v0.4.1 

type StartTaskReply struct {
	Id         string                `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
	PortMap    map[string]*Endpoints `` /* 134-byte string literal not displayed */
	NetworkIDs []string              `protobuf:"bytes,3,rep,name=networkIDs" json:"networkIDs,omitempty"`
}

func (*StartTaskReply) Descriptor added in v0.4.1 

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

func (*StartTaskReply) GetId added in v0.4.1 

func (m *StartTaskReply) GetId() string

func (*StartTaskReply) GetNetworkIDs added in v0.4.1 

func (m *StartTaskReply) GetNetworkIDs() []string

func (*StartTaskReply) GetPortMap added in v0.4.1 

func (m *StartTaskReply) GetPortMap() map[string]*Endpoints

func (*StartTaskReply) ProtoMessage added in v0.4.1 

func (*StartTaskReply) ProtoMessage()

func (*StartTaskReply) Reset added in v0.4.1 

func (m *StartTaskReply) Reset()

func (*StartTaskReply) String added in v0.4.1 

func (m *StartTaskReply) String() string

type StartTaskRequest added in v0.4.1 

type StartTaskRequest struct {
	// Deal points to the deal associated with workers where the task should be
	// started.
	DealID *BigInt   `protobuf:"bytes,1,opt,name=dealID" json:"dealID,omitempty"`
	Spec   *TaskSpec `protobuf:"bytes,2,opt,name=spec" json:"spec,omitempty"`
}

func (*StartTaskRequest) Descriptor added in v0.4.1 

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

func (*StartTaskRequest) GetDealID added in v0.4.1 

func (m *StartTaskRequest) GetDealID() *BigInt

func (*StartTaskRequest) GetSpec added in v0.4.1 

func (m *StartTaskRequest) GetSpec() *TaskSpec

func (*StartTaskRequest) ProtoMessage added in v0.4.1 

func (*StartTaskRequest) ProtoMessage()

func (*StartTaskRequest) Reset added in v0.4.1 

func (m *StartTaskRequest) Reset()

func (*StartTaskRequest) String added in v0.4.1 

func (m *StartTaskRequest) String() string

func (*StartTaskRequest) Validate added in v0.4.1 

func (m *StartTaskRequest) Validate() error

type StatusReply added in v0.4.1 

type StatusReply struct {
	Uptime              uint64      `protobuf:"varint,1,opt,name=uptime" json:"uptime,omitempty"`
	Version             string      `protobuf:"bytes,2,opt,name=version" json:"version,omitempty"`
	Platform            string      `protobuf:"bytes,3,opt,name=platform" json:"platform,omitempty"`
	EthAddr             string      `protobuf:"bytes,4,opt,name=ethAddr" json:"ethAddr,omitempty"`
	TaskCount           uint32      `protobuf:"varint,5,opt,name=taskCount" json:"taskCount,omitempty"`
	DWHStatus           string      `protobuf:"bytes,6,opt,name=DWHStatus" json:"DWHStatus,omitempty"`
	RendezvousStatus    string      `protobuf:"bytes,7,opt,name=rendezvousStatus" json:"rendezvousStatus,omitempty"`
	Master              *EthAddress `protobuf:"bytes,8,opt,name=master" json:"master,omitempty"`
	Admin               *EthAddress `protobuf:"bytes,9,opt,name=admin" json:"admin,omitempty"`
	IsMasterConfirmed   bool        `protobuf:"varint,10,opt,name=isMasterConfirmed" json:"isMasterConfirmed,omitempty"`
	IsBenchmarkFinished bool        `protobuf:"varint,11,opt,name=isBenchmarkFinished" json:"isBenchmarkFinished,omitempty"`
	Geo                 *GeoIP      `protobuf:"bytes,12,opt,name=geo" json:"geo,omitempty"`
}

func (*StatusReply) Descriptor added in v0.4.1 

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

func (*StatusReply) GetAdmin added in v0.4.11 

func (m *StatusReply) GetAdmin() *EthAddress

func (*StatusReply) GetDWHStatus added in v0.4.1 

func (m *StatusReply) GetDWHStatus() string

func (*StatusReply) GetEthAddr added in v0.4.1 

func (m *StatusReply) GetEthAddr() string

func (*StatusReply) GetGeo added in v0.4.15 

func (m *StatusReply) GetGeo() *GeoIP

func (*StatusReply) GetIsBenchmarkFinished added in v0.4.11 

func (m *StatusReply) GetIsBenchmarkFinished() bool

func (*StatusReply) GetIsMasterConfirmed added in v0.4.11 

func (m *StatusReply) GetIsMasterConfirmed() bool

func (*StatusReply) GetMaster added in v0.4.11 

func (m *StatusReply) GetMaster() *EthAddress

func (*StatusReply) GetPlatform added in v0.4.1 

func (m *StatusReply) GetPlatform() string

func (*StatusReply) GetRendezvousStatus added in v0.4.1 

func (m *StatusReply) GetRendezvousStatus() string

func (*StatusReply) GetTaskCount added in v0.4.1 

func (m *StatusReply) GetTaskCount() uint32

func (*StatusReply) GetUptime added in v0.4.1 

func (m *StatusReply) GetUptime() uint64

func (*StatusReply) GetVersion added in v0.4.1 

func (m *StatusReply) GetVersion() string

func (*StatusReply) ProtoMessage added in v0.4.1 

func (*StatusReply) ProtoMessage()

func (*StatusReply) Reset added in v0.4.1 

func (m *StatusReply) Reset()

func (*StatusReply) String added in v0.4.1 

func (m *StatusReply) String() string

type Storage added in v0.4.1 

type Storage struct {
	Device     *StorageDevice        `protobuf:"bytes,1,opt,name=device" json:"device,omitempty"`
	Benchmarks map[uint64]*Benchmark `` /* 141-byte string literal not displayed */
}

func (*Storage) Descriptor added in v0.4.1 

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

func (*Storage) GetBenchmarks added in v0.4.1 

func (m *Storage) GetBenchmarks() map[uint64]*Benchmark

func (*Storage) GetDevice added in v0.4.1 

func (m *Storage) GetDevice() *StorageDevice

func (*Storage) ProtoMessage added in v0.4.1 

func (*Storage) ProtoMessage()

func (*Storage) Reset added in v0.4.1 

func (m *Storage) Reset()

func (*Storage) String added in v0.4.1 

func (m *Storage) String() string

type StorageDevice added in v0.4.1 

type StorageDevice struct {
	BytesAvailable uint64 `protobuf:"varint,1,opt,name=bytesAvailable" json:"bytesAvailable,omitempty"`
}

func (*StorageDevice) Descriptor added in v0.4.1 

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

func (*StorageDevice) GetBytesAvailable added in v0.4.1 

func (m *StorageDevice) GetBytesAvailable() uint64

func (*StorageDevice) HardwareHash added in v0.4.1 

func (m *StorageDevice) HardwareHash() string

func (*StorageDevice) ProtoMessage added in v0.4.1 

func (*StorageDevice) ProtoMessage()

func (*StorageDevice) Reset added in v0.4.1 

func (m *StorageDevice) Reset()

func (*StorageDevice) String added in v0.4.1 

func (m *StorageDevice) String() string

type TSErrorByID added in v0.4.10 

type TSErrorByID struct {
	// contains filtered or unexported fields
}

func NewTSErrorByID added in v0.4.10 

func NewTSErrorByID() *TSErrorByID

func (*TSErrorByID) Append added in v0.4.10 

func (m *TSErrorByID) Append(id *BigInt, err error)

func (*TSErrorByID) Unwrap added in v0.4.10 

func (m *TSErrorByID) Unwrap() *ErrorByID

type TSErrorByStringID added in v0.4.13 

type TSErrorByStringID struct {
	// contains filtered or unexported fields
}

func NewTSErrorByStringID added in v0.4.13 

func NewTSErrorByStringID() *TSErrorByStringID

func (*TSErrorByStringID) Append added in v0.4.13 

func (m *TSErrorByStringID) Append(id string, err error)

func (*TSErrorByStringID) Unwrap added in v0.4.13 

func (m *TSErrorByStringID) Unwrap() *ErrorByStringID

type TaskID 

type TaskID struct {
	// Id is task ID itself
	Id     string  `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
	DealID *BigInt `protobuf:"bytes,2,opt,name=dealID" json:"dealID,omitempty"`
}

func (*TaskID) Descriptor 

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

func (*TaskID) GetDealID added in v0.4.1 

func (m *TaskID) GetDealID() *BigInt

func (*TaskID) GetId 

func (m *TaskID) GetId() string

func (*TaskID) ProtoMessage 

func (*TaskID) ProtoMessage()

func (*TaskID) Reset 

func (m *TaskID) Reset()

func (*TaskID) String 

func (m *TaskID) String() string

type TaskListReply 

type TaskListReply struct {
	Info map[string]*TaskStatusReply `` /* 128-byte string literal not displayed */
}

func (*TaskListReply) Descriptor 

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

func (*TaskListReply) GetInfo 

func (m *TaskListReply) GetInfo() map[string]*TaskStatusReply

func (*TaskListReply) ProtoMessage 

func (*TaskListReply) ProtoMessage()

func (*TaskListReply) Reset 

func (m *TaskListReply) Reset()

func (*TaskListReply) String 

func (m *TaskListReply) String() string

type TaskListRequest 

type TaskListRequest struct {
	DealID *BigInt `protobuf:"bytes,1,opt,name=dealID" json:"dealID,omitempty"`
}

func (*TaskListRequest) Descriptor 

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

func (*TaskListRequest) GetDealID added in v0.4.1 

func (m *TaskListRequest) GetDealID() *BigInt

func (*TaskListRequest) ProtoMessage 

func (*TaskListRequest) ProtoMessage()

func (*TaskListRequest) Reset 

func (m *TaskListRequest) Reset()

func (*TaskListRequest) String 

func (m *TaskListRequest) String() string

type TaskLogsChunk 

type TaskLogsChunk struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
}

func (*TaskLogsChunk) Descriptor 

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

func (*TaskLogsChunk) GetData 

func (m *TaskLogsChunk) GetData() []byte

func (*TaskLogsChunk) ProtoMessage 

func (*TaskLogsChunk) ProtoMessage()

func (*TaskLogsChunk) Reset 

func (m *TaskLogsChunk) Reset()

func (*TaskLogsChunk) String 

func (m *TaskLogsChunk) String() string

type TaskLogsRequest 

type TaskLogsRequest struct {
	Type          TaskLogsRequest_Type `protobuf:"varint,1,opt,name=type,enum=sonm.TaskLogsRequest_Type" json:"type,omitempty"`
	Id            string               `protobuf:"bytes,2,opt,name=id" json:"id,omitempty"`
	Since         string               `protobuf:"bytes,3,opt,name=since" json:"since,omitempty"`
	AddTimestamps bool                 `protobuf:"varint,4,opt,name=addTimestamps" json:"addTimestamps,omitempty"`
	Follow        bool                 `protobuf:"varint,5,opt,name=Follow" json:"Follow,omitempty"`
	Tail          string               `protobuf:"bytes,6,opt,name=Tail" json:"Tail,omitempty"`
	Details       bool                 `protobuf:"varint,7,opt,name=Details" json:"Details,omitempty"`
	DealID        *BigInt              `protobuf:"bytes,8,opt,name=dealID" json:"dealID,omitempty"`
}

func (*TaskLogsRequest) Descriptor 

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

func (*TaskLogsRequest) GetAddTimestamps 

func (m *TaskLogsRequest) GetAddTimestamps() bool

func (*TaskLogsRequest) GetDealID added in v0.4.1 

func (m *TaskLogsRequest) GetDealID() *BigInt

func (*TaskLogsRequest) GetDetails 

func (m *TaskLogsRequest) GetDetails() bool

func (*TaskLogsRequest) GetFollow 

func (m *TaskLogsRequest) GetFollow() bool

func (*TaskLogsRequest) GetId 

func (m *TaskLogsRequest) GetId() string

func (*TaskLogsRequest) GetSince 

func (m *TaskLogsRequest) GetSince() string

func (*TaskLogsRequest) GetTail 

func (m *TaskLogsRequest) GetTail() string

func (*TaskLogsRequest) GetType 

func (m *TaskLogsRequest) GetType() TaskLogsRequest_Type

func (*TaskLogsRequest) ProtoMessage 

func (*TaskLogsRequest) ProtoMessage()

func (*TaskLogsRequest) Reset 

func (m *TaskLogsRequest) Reset()

func (*TaskLogsRequest) String 

func (m *TaskLogsRequest) String() string

type TaskLogsRequest_Type 

type TaskLogsRequest_Type int32
const (
	TaskLogsRequest_STDOUT TaskLogsRequest_Type = 0
	TaskLogsRequest_STDERR TaskLogsRequest_Type = 1
	TaskLogsRequest_BOTH   TaskLogsRequest_Type = 2
)

func (TaskLogsRequest_Type) EnumDescriptor 

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

func (TaskLogsRequest_Type) String 

func (x TaskLogsRequest_Type) String() string

type TaskManagementClient 

type TaskManagementClient interface {
	// List produces a list of all tasks running on different SONM nodes
	List(ctx context.Context, in *TaskListRequest, opts ...grpc.CallOption) (*TaskListReply, error)
	// PushTask pushes image to Worker
	PushTask(ctx context.Context, opts ...grpc.CallOption) (TaskManagement_PushTaskClient, error)
	// Start starts a task on given resource
	Start(ctx context.Context, in *StartTaskRequest, opts ...grpc.CallOption) (*StartTaskReply, error)
	// JoinNetwork provides network specs to join specified task
	JoinNetwork(ctx context.Context, in *JoinNetworkRequest, opts ...grpc.CallOption) (*NetworkSpec, error)
	// Status produces a task status by their ID
	Status(ctx context.Context, in *TaskID, opts ...grpc.CallOption) (*TaskStatusReply, error)
	// Logs retrieves a task log (stdin/stderr) from given task
	Logs(ctx context.Context, in *TaskLogsRequest, opts ...grpc.CallOption) (TaskManagement_LogsClient, error)
	// Stop stops a task by their ID
	Stop(ctx context.Context, in *TaskID, opts ...grpc.CallOption) (*Empty, error)
	// PullTask pulls task image back
	PullTask(ctx context.Context, in *PullTaskRequest, opts ...grpc.CallOption) (TaskManagement_PullTaskClient, error)
}

func NewTaskManagementClient 

func NewTaskManagementClient(cc *grpc.ClientConn) TaskManagementClient

type TaskManagementServer 

type TaskManagementServer interface {
	// List produces a list of all tasks running on different SONM nodes
	List(context.Context, *TaskListRequest) (*TaskListReply, error)
	// PushTask pushes image to Worker
	PushTask(TaskManagement_PushTaskServer) error
	// Start starts a task on given resource
	Start(context.Context, *StartTaskRequest) (*StartTaskReply, error)
	// JoinNetwork provides network specs to join specified task
	JoinNetwork(context.Context, *JoinNetworkRequest) (*NetworkSpec, error)
	// Status produces a task status by their ID
	Status(context.Context, *TaskID) (*TaskStatusReply, error)
	// Logs retrieves a task log (stdin/stderr) from given task
	Logs(*TaskLogsRequest, TaskManagement_LogsServer) error
	// Stop stops a task by their ID
	Stop(context.Context, *TaskID) (*Empty, error)
	// PullTask pulls task image back
	PullTask(*PullTaskRequest, TaskManagement_PullTaskServer) error
}

type TaskManagement_LogsClient 

type TaskManagement_LogsClient interface {
	Recv() (*TaskLogsChunk, error)
	grpc.ClientStream
}

type TaskManagement_LogsServer 

type TaskManagement_LogsServer interface {
	Send(*TaskLogsChunk) error
	grpc.ServerStream
}

type TaskManagement_PullTaskClient 

type TaskManagement_PullTaskClient interface {
	Recv() (*Chunk, error)
	grpc.ClientStream
}

type TaskManagement_PullTaskServer 

type TaskManagement_PullTaskServer interface {
	Send(*Chunk) error
	grpc.ServerStream
}

type TaskManagement_PushTaskClient 

type TaskManagement_PushTaskClient interface {
	Send(*Chunk) error
	Recv() (*Progress, error)
	grpc.ClientStream
}

type TaskManagement_PushTaskServer 

type TaskManagement_PushTaskServer interface {
	Send(*Progress) error
	Recv() (*Chunk, error)
	grpc.ServerStream
}

type TaskPool added in v0.4.13 

type TaskPool struct {
	All  *AskPlanResources            `protobuf:"bytes,1,opt,name=all" json:"all,omitempty"`
	Used map[string]*AskPlanResources `` /* 128-byte string literal not displayed */
}

func (*TaskPool) Descriptor added in v0.4.13 

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

func (*TaskPool) GetAll added in v0.4.13 

func (m *TaskPool) GetAll() *AskPlanResources

func (*TaskPool) GetUsed added in v0.4.13 

func (m *TaskPool) GetUsed() map[string]*AskPlanResources

func (*TaskPool) ProtoMessage added in v0.4.13 

func (*TaskPool) ProtoMessage()

func (*TaskPool) Reset added in v0.4.13 

func (m *TaskPool) Reset()

func (*TaskPool) String added in v0.4.13 

func (m *TaskPool) String() string

type TaskSpec added in v0.4.1 

type TaskSpec struct {
	// Container describes container settings.
	Container *Container        `protobuf:"bytes,1,opt,name=container" json:"container,omitempty"`
	Registry  *Registry         `protobuf:"bytes,2,opt,name=registry" json:"registry,omitempty"`
	Resources *AskPlanResources `protobuf:"bytes,3,opt,name=resources" json:"resources,omitempty"`
	Tag       *TaskTag          `protobuf:"bytes,4,opt,name=tag" json:"tag,omitempty"`
}

func (*TaskSpec) Descriptor added in v0.4.1 

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

func (*TaskSpec) GetContainer added in v0.4.1 

func (m *TaskSpec) GetContainer() *Container

func (*TaskSpec) GetRegistry added in v0.4.1 

func (m *TaskSpec) GetRegistry() *Registry

func (*TaskSpec) GetResources added in v0.4.1 

func (m *TaskSpec) GetResources() *AskPlanResources

func (*TaskSpec) GetTag added in v0.4.6 

func (m *TaskSpec) GetTag() *TaskTag

func (*TaskSpec) ProtoMessage added in v0.4.1 

func (*TaskSpec) ProtoMessage()

func (*TaskSpec) Reset added in v0.4.1 

func (m *TaskSpec) Reset()

func (*TaskSpec) String added in v0.4.1 

func (m *TaskSpec) String() string

func (*TaskSpec) Validate added in v0.4.1 

func (m *TaskSpec) Validate() error

type TaskStatusReply 

type TaskStatusReply struct {
	Status    TaskStatusReply_Status `protobuf:"varint,1,opt,name=status,enum=sonm.TaskStatusReply_Status" json:"status,omitempty"`
	ImageName string                 `protobuf:"bytes,2,opt,name=imageName" json:"imageName,omitempty"`
	PortMap   map[string]*Endpoints  `` /* 134-byte string literal not displayed */
	Uptime    uint64                 `protobuf:"varint,4,opt,name=uptime" json:"uptime,omitempty"`
	Usage     *ResourceUsage         `protobuf:"bytes,5,opt,name=usage" json:"usage,omitempty"`
	// TODO: looks like we need to use TaskSpec here
	AllocatedResources *AskPlanResources `protobuf:"bytes,6,opt,name=allocatedResources" json:"allocatedResources,omitempty"`
	Tag                *TaskTag          `protobuf:"bytes,7,opt,name=tag" json:"tag,omitempty"`
}

func (*TaskStatusReply) Descriptor 

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

func (*TaskStatusReply) GetAllocatedResources added in v0.4.1 

func (m *TaskStatusReply) GetAllocatedResources() *AskPlanResources

func (*TaskStatusReply) GetImageName 

func (m *TaskStatusReply) GetImageName() string

func (*TaskStatusReply) GetPortMap added in v0.4.1 

func (m *TaskStatusReply) GetPortMap() map[string]*Endpoints

func (*TaskStatusReply) GetStatus 

func (m *TaskStatusReply) GetStatus() TaskStatusReply_Status

func (*TaskStatusReply) GetTag added in v0.4.6 

func (m *TaskStatusReply) GetTag() *TaskTag

func (*TaskStatusReply) GetUptime 

func (m *TaskStatusReply) GetUptime() uint64

func (*TaskStatusReply) GetUsage 

func (m *TaskStatusReply) GetUsage() *ResourceUsage

func (*TaskStatusReply) ProtoMessage 

func (*TaskStatusReply) ProtoMessage()

func (*TaskStatusReply) Reset 

func (m *TaskStatusReply) Reset()

func (*TaskStatusReply) String 

func (m *TaskStatusReply) String() string

type TaskStatusReply_Status 

type TaskStatusReply_Status int32
const (
	TaskStatusReply_UNKNOWN    TaskStatusReply_Status = 0
	TaskStatusReply_SPOOLING   TaskStatusReply_Status = 1
	TaskStatusReply_SPAWNING   TaskStatusReply_Status = 2
	TaskStatusReply_RUNNING    TaskStatusReply_Status = 3
	TaskStatusReply_FINISHED   TaskStatusReply_Status = 4
	TaskStatusReply_BROKEN     TaskStatusReply_Status = 5
	TaskStatusReply_KILLED_OOM TaskStatusReply_Status = 6
)

func (TaskStatusReply_Status) EnumDescriptor 

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

func (TaskStatusReply_Status) String 

func (x TaskStatusReply_Status) String() string

type TaskTag added in v0.4.6 

type TaskTag struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
}

func (*TaskTag) Descriptor added in v0.4.6 

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

func (*TaskTag) GetData added in v0.4.6 

func (m *TaskTag) GetData() []byte

func (*TaskTag) MarshalYAML added in v0.4.6 

func (m *TaskTag) MarshalYAML() (interface{}, error)

func (*TaskTag) ProtoMessage added in v0.4.6 

func (*TaskTag) ProtoMessage()

func (*TaskTag) Reset added in v0.4.6 

func (m *TaskTag) Reset()

func (*TaskTag) String added in v0.4.6 

func (m *TaskTag) String() string

func (*TaskTag) UnmarshalYAML added in v0.4.6 

func (m *TaskTag) UnmarshalYAML(unmarshal func(interface{}) error) error

type Timestamp 

type Timestamp struct {
	// Represents seconds of UTC time since Unix epoch 1970-01-01T00:00:00Z.
	// Must be from 0001-01-01T00:00:00Z to 9999-12-31T23:59:59Z inclusive.
	Seconds int64 `protobuf:"varint,1,opt,name=seconds" json:"seconds,omitempty"`
	// Non-negative fractions of a second at nanosecond resolution. Negative
	// second values with fractions must still have non-negative nanos values
	// that count forward in time. Must be from 0 to 999'999'999
	// inclusive.
	Nanos int32 `protobuf:"varint,2,opt,name=nanos" json:"nanos,omitempty"`
}

func CurrentTimestamp added in v0.4.1 

func CurrentTimestamp() *Timestamp

func (*Timestamp) Descriptor 

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

func (*Timestamp) GetNanos 

func (m *Timestamp) GetNanos() int32

func (*Timestamp) GetSeconds 

func (m *Timestamp) GetSeconds() int64

func (Timestamp) MarshalText added in v0.4.1 

func (m Timestamp) MarshalText() (text []byte, err error)

func (*Timestamp) ProtoMessage 

func (*Timestamp) ProtoMessage()

func (*Timestamp) Reset 

func (m *Timestamp) Reset()

func (*Timestamp) String 

func (m *Timestamp) String() string

func (*Timestamp) Unix added in v0.3.2 

func (m *Timestamp) Unix() time.Time

Unix returns the local time.Time corresponding to the given Unix time since January 1, 1970 UTC.

func (*Timestamp) UnmarshalText added in v0.4.1 

func (m *Timestamp) UnmarshalText(text []byte) error

type TokenManagementClient added in v0.4.1 

type TokenManagementClient interface {
	// TestTokens increases balance for some amount of test tokens
	// into live-chian ethereum network.
	// Deprecated: currently we do not use custom token with this possibility
	TestTokens(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error)
	// Balance provide account balance for live- and side- chains.
	// Deprecated: use BalanceOf method instead.
	Balance(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*BalanceReply, error)
	// BalanceOf provide account balance of specified address.
	BalanceOf(ctx context.Context, in *EthAddress, opts ...grpc.CallOption) (*BalanceReply, error)
	// Deposit transfers funds from masterchain to sidechain
	Deposit(ctx context.Context, in *BigInt, opts ...grpc.CallOption) (*Empty, error)
	// Withdraw transfers funds from sidechain to masterchain
	Withdraw(ctx context.Context, in *BigInt, opts ...grpc.CallOption) (*Empty, error)
	// MarketAllowance returns current allowance for BC market
	MarketAllowance(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*BigInt, error)
	// Transfer transfers funds from one sidechain account to another.
	Transfer(ctx context.Context, in *TokenTransferRequest, opts ...grpc.CallOption) (*Empty, error)
}

func NewTokenManagementClient added in v0.4.1 

func NewTokenManagementClient(cc *grpc.ClientConn) TokenManagementClient

type TokenManagementServer added in v0.4.1 

type TokenManagementServer interface {
	// TestTokens increases balance for some amount of test tokens
	// into live-chian ethereum network.
	// Deprecated: currently we do not use custom token with this possibility
	TestTokens(context.Context, *Empty) (*Empty, error)
	// Balance provide account balance for live- and side- chains.
	// Deprecated: use BalanceOf method instead.
	Balance(context.Context, *Empty) (*BalanceReply, error)
	// BalanceOf provide account balance of specified address.
	BalanceOf(context.Context, *EthAddress) (*BalanceReply, error)
	// Deposit transfers funds from masterchain to sidechain
	Deposit(context.Context, *BigInt) (*Empty, error)
	// Withdraw transfers funds from sidechain to masterchain
	Withdraw(context.Context, *BigInt) (*Empty, error)
	// MarketAllowance returns current allowance for BC market
	MarketAllowance(context.Context, *Empty) (*BigInt, error)
	// Transfer transfers funds from one sidechain account to another.
	Transfer(context.Context, *TokenTransferRequest) (*Empty, error)
}

type TokenTransferRequest added in v0.4.5 

type TokenTransferRequest struct {
	To     *EthAddress `protobuf:"bytes,1,opt,name=to" json:"to,omitempty"`
	Amount *BigInt     `protobuf:"bytes,2,opt,name=amount" json:"amount,omitempty"`
}

func (*TokenTransferRequest) Descriptor added in v0.4.5 

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

func (*TokenTransferRequest) GetAmount added in v0.4.5 

func (m *TokenTransferRequest) GetAmount() *BigInt

func (*TokenTransferRequest) GetTo added in v0.4.5 

func (m *TokenTransferRequest) GetTo() *EthAddress

func (*TokenTransferRequest) ProtoMessage added in v0.4.5 

func (*TokenTransferRequest) ProtoMessage()

func (*TokenTransferRequest) Reset added in v0.4.5 

func (m *TokenTransferRequest) Reset()

func (*TokenTransferRequest) String added in v0.4.5 

func (m *TokenTransferRequest) String() string

func (*TokenTransferRequest) Validate added in v0.4.5 

func (m *TokenTransferRequest) Validate() error

type Validator added in v0.4.1 

type Validator struct {
	Id    *EthAddress `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
	Level uint64      `protobuf:"varint,2,opt,name=level" json:"level,omitempty"`
}

func (*Validator) Descriptor added in v0.4.1 

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

func (*Validator) GetId added in v0.4.1 

func (m *Validator) GetId() *EthAddress

func (*Validator) GetLevel added in v0.4.1 

func (m *Validator) GetLevel() uint64

func (*Validator) ProtoMessage added in v0.4.1 

func (*Validator) ProtoMessage()

func (*Validator) Reset added in v0.4.1 

func (m *Validator) Reset()

func (*Validator) String added in v0.4.1 

func (m *Validator) String() string

type ValidatorsReply added in v0.4.1 

type ValidatorsReply struct {
	Validators []*DWHValidator `protobuf:"bytes,1,rep,name=validators" json:"validators,omitempty"`
	Count      uint64          `protobuf:"varint,2,opt,name=count" json:"count,omitempty"`
}

func (*ValidatorsReply) Descriptor added in v0.4.1 

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

func (*ValidatorsReply) GetCount added in v0.4.1 

func (m *ValidatorsReply) GetCount() uint64

func (*ValidatorsReply) GetValidators added in v0.4.1 

func (m *ValidatorsReply) GetValidators() []*DWHValidator

func (*ValidatorsReply) ProtoMessage added in v0.4.1 

func (*ValidatorsReply) ProtoMessage()

func (*ValidatorsReply) Reset added in v0.4.1 

func (m *ValidatorsReply) Reset()

func (*ValidatorsReply) String added in v0.4.1 

func (m *ValidatorsReply) String() string

type ValidatorsRequest added in v0.4.1 

type ValidatorsRequest struct {
	ValidatorLevel *CmpUint64       `protobuf:"bytes,1,opt,name=validatorLevel" json:"validatorLevel,omitempty"`
	Limit          uint64           `protobuf:"varint,2,opt,name=limit" json:"limit,omitempty"`
	Offset         uint64           `protobuf:"varint,3,opt,name=offset" json:"offset,omitempty"`
	Sortings       []*SortingOption `protobuf:"bytes,4,rep,name=sortings" json:"sortings,omitempty"`
	WithCount      bool             `protobuf:"varint,5,opt,name=withCount" json:"withCount,omitempty"`
}

func (*ValidatorsRequest) Descriptor added in v0.4.1 

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

func (*ValidatorsRequest) GetLimit added in v0.4.1 

func (m *ValidatorsRequest) GetLimit() uint64

func (*ValidatorsRequest) GetOffset added in v0.4.1 

func (m *ValidatorsRequest) GetOffset() uint64

func (*ValidatorsRequest) GetSortings added in v0.4.1 

func (m *ValidatorsRequest) GetSortings() []*SortingOption

func (*ValidatorsRequest) GetValidatorLevel added in v0.4.1 

func (m *ValidatorsRequest) GetValidatorLevel() *CmpUint64

func (*ValidatorsRequest) GetWithCount added in v0.4.1 

func (m *ValidatorsRequest) GetWithCount() bool

func (*ValidatorsRequest) ProtoMessage added in v0.4.1 

func (*ValidatorsRequest) ProtoMessage()

func (*ValidatorsRequest) Reset added in v0.4.1 

func (m *ValidatorsRequest) Reset()

func (*ValidatorsRequest) String added in v0.4.1 

func (m *ValidatorsRequest) String() string

type Volume added in v0.3.2 

type Volume struct {
	// Type describes a volume driver.
	Type string `protobuf:"bytes,1,opt,name=type" json:"type,omitempty"`
	// Options describes a place for your volume settings.
	Options map[string]string `` /* 134-byte string literal not displayed */
}

Volume describes volume settings.

func (*Volume) Descriptor added in v0.3.2 

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

func (*Volume) GetOptions added in v0.4.1 

func (m *Volume) GetOptions() map[string]string

func (*Volume) GetType added in v0.4.1 

func (m *Volume) GetType() string

func (*Volume) ProtoMessage added in v0.3.2 

func (*Volume) ProtoMessage()

func (*Volume) Reset added in v0.3.2 

func (m *Volume) Reset()

func (*Volume) String added in v0.3.2 

func (m *Volume) String() string

type WorkerAddCapabilityRequest added in v0.4.21 

type WorkerAddCapabilityRequest struct {
	// Subject is the ETH address of a subject whose capabilities are extended.
	Subject *EthAddress `protobuf:"bytes,1,opt,name=subject" json:"subject,omitempty"`
	// Scope shows the capability scope.
	Scope CapabilityScope `protobuf:"varint,2,opt,name=scope,enum=sonm.CapabilityScope" json:"scope,omitempty"`
	// TTL represents the capability TTL in seconds.
	Ttl uint32 `protobuf:"varint,3,opt,name=ttl" json:"ttl,omitempty"`
}

func (*WorkerAddCapabilityRequest) Descriptor added in v0.4.21 

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

func (*WorkerAddCapabilityRequest) GetScope added in v0.4.21 

func (m *WorkerAddCapabilityRequest) GetScope() CapabilityScope

func (*WorkerAddCapabilityRequest) GetSubject added in v0.4.21 

func (m *WorkerAddCapabilityRequest) GetSubject() *EthAddress

func (*WorkerAddCapabilityRequest) GetTtl added in v0.4.21 

func (m *WorkerAddCapabilityRequest) GetTtl() uint32

func (*WorkerAddCapabilityRequest) ProtoMessage added in v0.4.21 

func (*WorkerAddCapabilityRequest) ProtoMessage()

func (*WorkerAddCapabilityRequest) Reset added in v0.4.21 

func (m *WorkerAddCapabilityRequest) Reset()

func (*WorkerAddCapabilityRequest) String added in v0.4.21 

func (m *WorkerAddCapabilityRequest) String() string

type WorkerAddCapabilityResponse added in v0.4.21 

type WorkerAddCapabilityResponse struct {
}

func (*WorkerAddCapabilityResponse) Descriptor added in v0.4.21 

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

func (*WorkerAddCapabilityResponse) ProtoMessage added in v0.4.21 

func (*WorkerAddCapabilityResponse) ProtoMessage()

func (*WorkerAddCapabilityResponse) Reset added in v0.4.21 

func (m *WorkerAddCapabilityResponse) Reset()

func (*WorkerAddCapabilityResponse) String added in v0.4.21 

func (m *WorkerAddCapabilityResponse) String() string

type WorkerClient added in v0.4.1 

type WorkerClient interface {
	PushTask(ctx context.Context, opts ...grpc.CallOption) (Worker_PushTaskClient, error)
	PullTask(ctx context.Context, in *PullTaskRequest, opts ...grpc.CallOption) (Worker_PullTaskClient, error)
	// StartTask schedules the task associcated with a deal.
	StartTask(ctx context.Context, in *StartTaskRequest, opts ...grpc.CallOption) (*StartTaskReply, error)
	StopTask(ctx context.Context, in *ID, opts ...grpc.CallOption) (*Empty, error)
	// PurgeTasks stops all tasks by given deal
	PurgeTasks(ctx context.Context, in *PurgeTasksRequest, opts ...grpc.CallOption) (*ErrorByStringID, error)
	TaskStatus(ctx context.Context, in *ID, opts ...grpc.CallOption) (*TaskStatusReply, error)
	JoinNetwork(ctx context.Context, in *WorkerJoinNetworkRequest, opts ...grpc.CallOption) (*NetworkSpec, error)
	TaskLogs(ctx context.Context, in *TaskLogsRequest, opts ...grpc.CallOption) (Worker_TaskLogsClient, error)
	// Note: currently used for testing pusposes.
	GetDealInfo(ctx context.Context, in *ID, opts ...grpc.CallOption) (*DealInfoReply, error)
}

func NewWorkerClient added in v0.4.1 

func NewWorkerClient(cc *grpc.ClientConn) WorkerClient

type WorkerJoinNetworkRequest added in v0.4.1 

type WorkerJoinNetworkRequest struct {
	TaskID    string `protobuf:"bytes,1,opt,name=taskID" json:"taskID,omitempty"`
	NetworkID string `protobuf:"bytes,2,opt,name=networkID" json:"networkID,omitempty"`
}

func (*WorkerJoinNetworkRequest) Descriptor added in v0.4.1 

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

func (*WorkerJoinNetworkRequest) GetNetworkID added in v0.4.1 

func (m *WorkerJoinNetworkRequest) GetNetworkID() string

func (*WorkerJoinNetworkRequest) GetTaskID added in v0.4.1 

func (m *WorkerJoinNetworkRequest) GetTaskID() string

func (*WorkerJoinNetworkRequest) ProtoMessage added in v0.4.1 

func (*WorkerJoinNetworkRequest) ProtoMessage()

func (*WorkerJoinNetworkRequest) Reset added in v0.4.1 

func (m *WorkerJoinNetworkRequest) Reset()

func (*WorkerJoinNetworkRequest) String added in v0.4.1 

func (m *WorkerJoinNetworkRequest) String() string

type WorkerListReply added in v0.4.1 

type WorkerListReply struct {
	Workers []*DWHWorker `protobuf:"bytes,1,rep,name=workers" json:"workers,omitempty"`
}

func (*WorkerListReply) Descriptor added in v0.4.1 

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

func (*WorkerListReply) GetWorkers added in v0.4.1 

func (m *WorkerListReply) GetWorkers() []*DWHWorker

func (*WorkerListReply) ProtoMessage added in v0.4.1 

func (*WorkerListReply) ProtoMessage()

func (*WorkerListReply) Reset added in v0.4.1 

func (m *WorkerListReply) Reset()

func (*WorkerListReply) String added in v0.4.1 

func (m *WorkerListReply) String() string

type WorkerManagementClient added in v0.4.1 

type WorkerManagementClient interface {
	// Status produse a detailed info about worker
	Status(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*StatusReply, error)
	// Devices provides detailed information about device
	// and show benchmark results.
	Devices(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*DevicesReply, error)
	// FreeDevices provides information about unallocated resources
	// that can be turned into ask-plans.
	// Deprecated: no longer usable.
	FreeDevices(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*DevicesReply, error)
	// Tasks produces a list of all running tasks on the worker
	Tasks(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*TaskListReply, error)
	// AskPlans allows to obtain previously assigned Ask Plans from for a given worker.
	AskPlans(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*AskPlansReply, error)
	// CreateAskPlan allows to create rules
	// for creating Ask orders on Marketplace
	CreateAskPlan(ctx context.Context, in *AskPlan, opts ...grpc.CallOption) (*ID, error)
	// RemoveAskPlan allows to remove rules
	// for creating Ask orders on Marketplace
	RemoveAskPlan(ctx context.Context, in *ID, opts ...grpc.CallOption) (*Empty, error)
	// PurgeAskPlans removes all ask-plans
	// Deprecated: use PurgeAsksPlansDetailed instead
	PurgeAskPlans(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error)
	// PurgeAsksPlansDetailed removes all ask-plans in sync manner and returns error for each ask-plan (if it's present)
	PurgeAskPlansDetailed(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ErrorByStringID, error)
	// Schedule maintenance for worker: it will attempt to close all deals till that time point
	ScheduleMaintenance(ctx context.Context, in *Timestamp, opts ...grpc.CallOption) (*Empty, error)
	// Get next planned maintenance
	NextMaintenance(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Timestamp, error)
	// Get useful debugging info - scheduler state and salesman state
	DebugState(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*DebugStateReply, error)
	// Remove benchmark cached value by specified benchmark ID
	RemoveBenchmark(ctx context.Context, in *NumericID, opts ...grpc.CallOption) (*Empty, error)
	// Schedule full rebenchmarking on next restart
	PurgeBenchmarks(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error)
	// Metrics returns hardware metrics for this worker.
	Metrics(ctx context.Context, in *WorkerMetricsRequest, opts ...grpc.CallOption) (*WorkerMetricsResponse, error)
	// AddCapability allows to temporary provide admin capabilities to another subject.
	AddCapability(ctx context.Context, in *WorkerAddCapabilityRequest, opts ...grpc.CallOption) (*WorkerAddCapabilityResponse, error)
	// RemoveCapability allows to revoke provided admin capabilities from another subject.
	RemoveCapability(ctx context.Context, in *WorkerRemoveCapabilityRequest, opts ...grpc.CallOption) (*WorkerRemoveCapabilityResponse, error)
}

func NewWorkerManagementClient added in v0.4.1 

func NewWorkerManagementClient(cc *grpc.ClientConn) WorkerManagementClient

type WorkerManagementServer added in v0.4.1 

type WorkerManagementServer interface {
	// Status produse a detailed info about worker
	Status(context.Context, *Empty) (*StatusReply, error)
	// Devices provides detailed information about device
	// and show benchmark results.
	Devices(context.Context, *Empty) (*DevicesReply, error)
	// FreeDevices provides information about unallocated resources
	// that can be turned into ask-plans.
	// Deprecated: no longer usable.
	FreeDevices(context.Context, *Empty) (*DevicesReply, error)
	// Tasks produces a list of all running tasks on the worker
	Tasks(context.Context, *Empty) (*TaskListReply, error)
	// AskPlans allows to obtain previously assigned Ask Plans from for a given worker.
	AskPlans(context.Context, *Empty) (*AskPlansReply, error)
	// CreateAskPlan allows to create rules
	// for creating Ask orders on Marketplace
	CreateAskPlan(context.Context, *AskPlan) (*ID, error)
	// RemoveAskPlan allows to remove rules
	// for creating Ask orders on Marketplace
	RemoveAskPlan(context.Context, *ID) (*Empty, error)
	// PurgeAskPlans removes all ask-plans
	// Deprecated: use PurgeAsksPlansDetailed instead
	PurgeAskPlans(context.Context, *Empty) (*Empty, error)
	// PurgeAsksPlansDetailed removes all ask-plans in sync manner and returns error for each ask-plan (if it's present)
	PurgeAskPlansDetailed(context.Context, *Empty) (*ErrorByStringID, error)
	// Schedule maintenance for worker: it will attempt to close all deals till that time point
	ScheduleMaintenance(context.Context, *Timestamp) (*Empty, error)
	// Get next planned maintenance
	NextMaintenance(context.Context, *Empty) (*Timestamp, error)
	// Get useful debugging info - scheduler state and salesman state
	DebugState(context.Context, *Empty) (*DebugStateReply, error)
	// Remove benchmark cached value by specified benchmark ID
	RemoveBenchmark(context.Context, *NumericID) (*Empty, error)
	// Schedule full rebenchmarking on next restart
	PurgeBenchmarks(context.Context, *Empty) (*Empty, error)
	// Metrics returns hardware metrics for this worker.
	Metrics(context.Context, *WorkerMetricsRequest) (*WorkerMetricsResponse, error)
	// AddCapability allows to temporary provide admin capabilities to another subject.
	AddCapability(context.Context, *WorkerAddCapabilityRequest) (*WorkerAddCapabilityResponse, error)
	// RemoveCapability allows to revoke provided admin capabilities from another subject.
	RemoveCapability(context.Context, *WorkerRemoveCapabilityRequest) (*WorkerRemoveCapabilityResponse, error)
}

type WorkerMetricsRequest added in v0.4.17 

type WorkerMetricsRequest struct {
}

func (*WorkerMetricsRequest) Descriptor added in v0.4.17 

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

func (*WorkerMetricsRequest) ProtoMessage added in v0.4.17 

func (*WorkerMetricsRequest) ProtoMessage()

func (*WorkerMetricsRequest) Reset added in v0.4.17 

func (m *WorkerMetricsRequest) Reset()

func (*WorkerMetricsRequest) String added in v0.4.17 

func (m *WorkerMetricsRequest) String() string

type WorkerMetricsResponse added in v0.4.17 

type WorkerMetricsResponse struct {
	Metrics map[string]float64 `` /* 136-byte string literal not displayed */
}

func (*WorkerMetricsResponse) Append added in v0.4.17 

func (m *WorkerMetricsResponse) Append(x ...map[string]float64) *WorkerMetricsResponse

func (*WorkerMetricsResponse) Descriptor added in v0.4.17 

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

func (*WorkerMetricsResponse) GetMetrics added in v0.4.17 

func (m *WorkerMetricsResponse) GetMetrics() map[string]float64

func (*WorkerMetricsResponse) ProtoMessage added in v0.4.17 

func (*WorkerMetricsResponse) ProtoMessage()

func (*WorkerMetricsResponse) Reset added in v0.4.17 

func (m *WorkerMetricsResponse) Reset()

func (*WorkerMetricsResponse) String added in v0.4.17 

func (m *WorkerMetricsResponse) String() string

type WorkerRemoveCapabilityRequest added in v0.4.21 

type WorkerRemoveCapabilityRequest struct {
	// Subject is the ETH address of a subject whose capabilities are removed.
	Subject *EthAddress `protobuf:"bytes,1,opt,name=subject" json:"subject,omitempty"`
	// Scope shows the capability scope.
	Scope CapabilityScope `protobuf:"varint,2,opt,name=scope,enum=sonm.CapabilityScope" json:"scope,omitempty"`
}

func (*WorkerRemoveCapabilityRequest) Descriptor added in v0.4.21 

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

func (*WorkerRemoveCapabilityRequest) GetScope added in v0.4.21 

func (m *WorkerRemoveCapabilityRequest) GetScope() CapabilityScope

func (*WorkerRemoveCapabilityRequest) GetSubject added in v0.4.21 

func (m *WorkerRemoveCapabilityRequest) GetSubject() *EthAddress

func (*WorkerRemoveCapabilityRequest) ProtoMessage added in v0.4.21 

func (*WorkerRemoveCapabilityRequest) ProtoMessage()

func (*WorkerRemoveCapabilityRequest) Reset added in v0.4.21 

func (m *WorkerRemoveCapabilityRequest) Reset()

func (*WorkerRemoveCapabilityRequest) String added in v0.4.21 

func (m *WorkerRemoveCapabilityRequest) String() string

type WorkerRemoveCapabilityResponse added in v0.4.21 

type WorkerRemoveCapabilityResponse struct {
}

func (*WorkerRemoveCapabilityResponse) Descriptor added in v0.4.21 

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

func (*WorkerRemoveCapabilityResponse) ProtoMessage added in v0.4.21 

func (*WorkerRemoveCapabilityResponse) ProtoMessage()

func (*WorkerRemoveCapabilityResponse) Reset added in v0.4.21 

func (m *WorkerRemoveCapabilityResponse) Reset()

func (*WorkerRemoveCapabilityResponse) String added in v0.4.21 

func (m *WorkerRemoveCapabilityResponse) String() string

type WorkerRemoveRequest added in v0.4.1 

type WorkerRemoveRequest struct {
	Master *EthAddress `protobuf:"bytes,1,opt,name=master" json:"master,omitempty"`
	Worker *EthAddress `protobuf:"bytes,2,opt,name=worker" json:"worker,omitempty"`
}

func (*WorkerRemoveRequest) Descriptor added in v0.4.1 

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

func (*WorkerRemoveRequest) GetMaster added in v0.4.1 

func (m *WorkerRemoveRequest) GetMaster() *EthAddress

func (*WorkerRemoveRequest) GetWorker added in v0.4.1 

func (m *WorkerRemoveRequest) GetWorker() *EthAddress

func (*WorkerRemoveRequest) ProtoMessage added in v0.4.1 

func (*WorkerRemoveRequest) ProtoMessage()

func (*WorkerRemoveRequest) Reset added in v0.4.1 

func (m *WorkerRemoveRequest) Reset()

func (*WorkerRemoveRequest) String added in v0.4.1 

func (m *WorkerRemoveRequest) String() string

type WorkerServer added in v0.4.1 

type WorkerServer interface {
	PushTask(Worker_PushTaskServer) error
	PullTask(*PullTaskRequest, Worker_PullTaskServer) error
	// StartTask schedules the task associcated with a deal.
	StartTask(context.Context, *StartTaskRequest) (*StartTaskReply, error)
	StopTask(context.Context, *ID) (*Empty, error)
	// PurgeTasks stops all tasks by given deal
	PurgeTasks(context.Context, *PurgeTasksRequest) (*ErrorByStringID, error)
	TaskStatus(context.Context, *ID) (*TaskStatusReply, error)
	JoinNetwork(context.Context, *WorkerJoinNetworkRequest) (*NetworkSpec, error)
	TaskLogs(*TaskLogsRequest, Worker_TaskLogsServer) error
	// Note: currently used for testing pusposes.
	GetDealInfo(context.Context, *ID) (*DealInfoReply, error)
}

type Worker_PullTaskClient added in v0.4.1 

type Worker_PullTaskClient interface {
	Recv() (*Chunk, error)
	grpc.ClientStream
}

type Worker_PullTaskServer added in v0.4.1 

type Worker_PullTaskServer interface {
	Send(*Chunk) error
	grpc.ServerStream
}

type Worker_PushTaskClient added in v0.4.1 

type Worker_PushTaskClient interface {
	Send(*Chunk) error
	Recv() (*Progress, error)
	grpc.ClientStream
}

type Worker_PushTaskServer added in v0.4.1 

type Worker_PushTaskServer interface {
	Send(*Progress) error
	Recv() (*Chunk, error)
	grpc.ServerStream
}

type Worker_TaskLogsClient added in v0.4.1 

type Worker_TaskLogsClient interface {
	Recv() (*TaskLogsChunk, error)
	grpc.ClientStream
}

type Worker_TaskLogsServer added in v0.4.1 

type Worker_TaskLogsServer interface {
	Send(*TaskLogsChunk) error
	grpc.ServerStream
}

type WorkersReply added in v0.4.1 

type WorkersReply struct {
	Workers []*DWHWorker `protobuf:"bytes,1,rep,name=workers" json:"workers,omitempty"`
	Count   uint64       `protobuf:"varint,2,opt,name=count" json:"count,omitempty"`
}

func (*WorkersReply) Descriptor added in v0.4.1 

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

func (*WorkersReply) GetCount added in v0.4.1 

func (m *WorkersReply) GetCount() uint64

func (*WorkersReply) GetWorkers added in v0.4.1 

func (m *WorkersReply) GetWorkers() []*DWHWorker

func (*WorkersReply) ProtoMessage added in v0.4.1 

func (*WorkersReply) ProtoMessage()

func (*WorkersReply) Reset added in v0.4.1 

func (m *WorkersReply) Reset()

func (*WorkersReply) String added in v0.4.1 

func (m *WorkersReply) String() string

type WorkersRequest added in v0.4.1 

type WorkersRequest struct {
	MasterID  *EthAddress `protobuf:"bytes,1,opt,name=MasterID" json:"MasterID,omitempty"`
	Limit     uint64      `protobuf:"varint,2,opt,name=limit" json:"limit,omitempty"`
	Offset    uint64      `protobuf:"varint,3,opt,name=offset" json:"offset,omitempty"`
	WithCount bool        `protobuf:"varint,4,opt,name=withCount" json:"withCount,omitempty"`
}

func (*WorkersRequest) Descriptor added in v0.4.1 

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

func (*WorkersRequest) GetLimit added in v0.4.1 

func (m *WorkersRequest) GetLimit() uint64

func (*WorkersRequest) GetMasterID added in v0.4.1 

func (m *WorkersRequest) GetMasterID() *EthAddress

func (*WorkersRequest) GetOffset added in v0.4.1 

func (m *WorkersRequest) GetOffset() uint64

func (*WorkersRequest) GetWithCount added in v0.4.1 

func (m *WorkersRequest) GetWithCount() bool

func (*WorkersRequest) ProtoMessage added in v0.4.1 

func (*WorkersRequest) ProtoMessage()

func (*WorkersRequest) Reset added in v0.4.1 

func (m *WorkersRequest) Reset()

func (*WorkersRequest) String added in v0.4.1 

func (m *WorkersRequest) String() string

Source Files

View all Source files

Directories

Path Synopsis
github.com
prometheus/client_model/go

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.