sonm

package
v0.4.6 Latest Latest
Warning

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

 Go to latest Published: Aug 1, 2018 License: GPL-3.0 Imports: 30 Imported by: 16

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
insonmnia.proto
marketplace.proto
net.proto
node.proto
relay.proto
rendezvous.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
WorkersRequest
WorkersReply
Certificate
MaxMinUint64
MaxMinBig
MaxMinTimestamp
CmpUint64
BlacklistQuery
Empty
ID
NumericID
EthID
TaskID
Count
CPUUsage
MemoryUsage
NetworkUsage
ResourceUsage
TaskLogsRequest
TaskLogsChunk
Chunk
Progress
Duration
EthAddress
DataSize
DataSizeRate
Price
GetOrdersReply
Benchmarks
Deal
Order
BidNetwork
BidResources
BidOrder
Addr
SocketAddr
Endpoints
JoinNetworkRequest
TaskListRequest
QuickBuyRequest
DealFinishRequest
DealsReply
OpenDealRequest
WorkerRemoveRequest
WorkerListReply
BalanceReply
TokenTransferRequest
HandshakeRequest
DiscoverResponse
HandshakeResponse
RelayClusterReply
RelayMetrics
NetMetrics
ConnectRequest
PublishRequest
RendezvousReply
RendezvousState
RendezvousMeeting
ResolveMetaReply
Timestamp
Volume
TaskTag
TaskSpec
StartTaskRequest
WorkerJoinNetworkRequest
StartTaskReply
StatusReply
AskPlansReply
TaskListReply
DevicesReply
PullTaskRequest
DealInfoReply
TaskStatusReply
ResourcePool
SchedulerData
SalesmanData
DebugStateReply

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 (
	DefaultNPPProtocol = "tcp"
)

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 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",
}
View Source 
var GPUVendorType_value = map[string]int32{
	"GPU_UNKNOWN": 0,
	"NVIDIA":      1,
	"RADEON":      2,
	"FAKE":        99,
}
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",
}
View Source 
var TaskStatusReply_Status_value = map[string]int32{
	"UNKNOWN":  0,
	"SPOOLING": 1,
	"SPAWNING": 2,
	"RUNNING":  3,
	"FINISHED": 4,
	"BROKEN":   5,
}

Functions

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 RegisterMarketServer 

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

func RegisterMasterManagementServer added in v0.4.1 

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

func RegisterProfilesServer added in v0.4.1 

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

func RegisterRelayServer added in v0.4.1 

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

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 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 (*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) 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) 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) 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 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) 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) 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) 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) Contains added in v0.4.1 

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

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

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

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 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 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 network 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 describres 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 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.
	Expose []string `protobuf:"bytes,10,rep,name=expose" json:"expose,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) 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)
	GetDealChangeRequests(ctx context.Context, in *BigInt, opts ...grpc.CallOption) (*DealChangeRequestsReply, error)
	GetWorkers(ctx context.Context, in *WorkersRequest, opts ...grpc.CallOption) (*WorkersReply, 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"`
}

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) GetBidIdentityLevel added in v0.4.1 

func (m *DWHDeal) GetBidIdentityLevel() uint64

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)
	GetDealChangeRequests(context.Context, *BigInt) (*DealChangeRequestsReply, error)
	GetWorkers(context.Context, *WorkersRequest) (*WorkersReply, error)
}

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

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) 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
	Finish(ctx context.Context, in *DealFinishRequest, opts ...grpc.CallOption) (*Empty, 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
	Finish(context.Context, *DealFinishRequest) (*Empty, 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 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 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 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"`
}

func (*GPUDevice) Descriptor 

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

func (*GPUDevice) FillHashID added in v0.4.1 

func (m *GPUDevice) FillHashID()

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

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 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 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
	CancelOrder(ctx context.Context, in *ID, opts ...grpc.CallOption) (*Empty, error)
	// Purge remove all active orders from marketplace
	Purge(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, 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
	CancelOrder(context.Context, *ID) (*Empty, error)
	// Purge remove all active orders from marketplace
	Purge(context.Context, *Empty) (*Empty, 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 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"`
}

func (*NetworkUsage) Descriptor 

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

func (*NetworkUsage) GetRxBytes 

func (m *NetworkUsage) GetRxBytes() uint64

func (*NetworkUsage) GetRxDropped 

func (m *NetworkUsage) GetRxDropped() uint64

func (*NetworkUsage) GetRxErrors 

func (m *NetworkUsage) GetRxErrors() uint64

func (*NetworkUsage) GetRxPackets 

func (m *NetworkUsage) GetRxPackets() uint64

func (*NetworkUsage) GetTxBytes 

func (m *NetworkUsage) GetTxBytes() uint64

func (*NetworkUsage) GetTxDropped 

func (m *NetworkUsage) GetTxDropped() uint64

func (*NetworkUsage) GetTxErrors 

func (m *NetworkUsage) GetTxErrors() uint64

func (*NetworkUsage) GetTxPackets 

func (m *NetworkUsage) GetTxPackets() uint64

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) 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 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 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 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) 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 network 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 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     uint64 `protobuf:"varint,1,opt,name=total" json:"total,omitempty"`
	Available uint64 `protobuf:"varint,2,opt,name=available" json:"available,omitempty"`
}

func (*RAMDevice) Descriptor 

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

func (*RAMDevice) GetAvailable added in v0.4.1 

func (m *RAMDevice) GetAvailable() uint64

func (*RAMDevice) GetTotal 

func (m *RAMDevice) GetTotal() 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)
}

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

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) 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 ResourcePool added in v0.4.1 

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

func (*ResourcePool) Descriptor added in v0.4.1 

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

func (*ResourcePool) GetAll added in v0.4.1 

func (m *ResourcePool) GetAll() *AskPlanResources

func (*ResourcePool) GetUsed added in v0.4.1 

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

func (*ResourcePool) ProtoMessage added in v0.4.1 

func (*ResourcePool) ProtoMessage()

func (*ResourcePool) Reset added in v0.4.1 

func (m *ResourcePool) Reset()

func (*ResourcePool) String added in v0.4.1 

func (m *ResourcePool) 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 */
	MainPool      *ResourcePool            `protobuf:"bytes,2,opt,name=mainPool" json:"mainPool,omitempty"`
	AskPlanPools  map[string]*ResourcePool `` /* 144-byte string literal not displayed */
}

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]*ResourcePool

func (*SchedulerData) GetMainPool added in v0.4.1 

func (m *SchedulerData) GetMainPool() *ResourcePool

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

func (*StatusReply) Descriptor added in v0.4.1 

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

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

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.
	TestTokens(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error)
	// Balance provide account balance for live- and side- chains.
	Balance(ctx context.Context, in *Empty, 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.
	TestTokens(context.Context, *Empty) (*Empty, error)
	// Balance provide account balance for live- and side- chains.
	Balance(context.Context, *Empty) (*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 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)
	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.
	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
	PurgeAskPlans(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, 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)
}

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.
	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
	PurgeAskPlans(context.Context, *Empty) (*Empty, 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)
}

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

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.