sonm

type AddSlotRequest struct {
	// Miner ID.
	ID string `protobuf:"bytes,1,opt,name=ID" json:"ID,omitempty"`
	// Slot destription.
	Slot *Slot `protobuf:"bytes,2,opt,name=slot" json:"slot,omitempty"`
}

type AnnounceRequest struct {
	// todo: remove repeated
	IpAddr []string `protobuf:"bytes,2,rep,name=ipAddr" json:"ipAddr,omitempty"`
}

type AvailableResources struct {
	NumCPUs            int64  `protobuf:"varint,1,opt,name=numCPUs" json:"numCPUs,omitempty"`
	NumGPUs            int64  `protobuf:"varint,2,opt,name=numGPUs" json:"numGPUs,omitempty"`
	Memory             uint64 `protobuf:"varint,3,opt,name=memory" json:"memory,omitempty"`
	CPUPeriod          int64  `protobuf:"varint,4,opt,name=CPUPeriod" json:"CPUPeriod,omitempty"`
	CPUQuota           int64  `protobuf:"varint,5,opt,name=CPUQuota" json:"CPUQuota,omitempty"`
	CPURealtimePeriod  int64  `protobuf:"varint,6,opt,name=CPURealtimePeriod" json:"CPURealtimePeriod,omitempty"`
	CPURealtimeRuntime int64  `protobuf:"varint,7,opt,name=CPURealtimeRuntime" json:"CPURealtimeRuntime,omitempty"`
	CpusetCpus         string `protobuf:"bytes,8,opt,name=CpusetCpus" json:"CpusetCpus,omitempty"`
	CpusetMems         string `protobuf:"bytes,9,opt,name=CpusetMems" json:"CpusetMems,omitempty"`
	DiskQuota          int64  `protobuf:"varint,10,opt,name=DiskQuota" json:"DiskQuota,omitempty"`
	KernelMemory       int64  `protobuf:"varint,11,opt,name=KernelMemory" json:"KernelMemory,omitempty"`
	MemoryReservation  int64  `protobuf:"varint,12,opt,name=MemoryReservation" json:"MemoryReservation,omitempty"`
	MemorySwap         int64  `protobuf:"varint,13,opt,name=MemorySwap" json:"MemorySwap,omitempty"`
	PidsLimit          int64  `protobuf:"varint,14,opt,name=PidsLimit" json:"PidsLimit,omitempty"`
	Cgroup             string `protobuf:"bytes,15,opt,name=cgroup" json:"cgroup,omitempty"`
	CgroupParent       string `protobuf:"bytes,16,opt,name=cgroupParent" json:"cgroupParent,omitempty"`
}

type CPUDevice struct {
	// Num describes the CPU number on a board.
	Num int32 `protobuf:"varint,1,opt,name=num" json:"num,omitempty"`
	// VendorId describes vendor id as a string, for example "GenuineIntel".
	VendorId string `protobuf:"bytes,2,opt,name=vendorId" json:"vendorId,omitempty"`
	// Model describes model.
	Model string `protobuf:"bytes,3,opt,name=model" json:"model,omitempty"`
	// ModelName describes full model name.
	// For example "Intel(R) Core(TM) i5-5257U CPU @ 2.70GHz".
	ModelName string `protobuf:"bytes,4,opt,name=modelName" json:"modelName,omitempty"`
	// Cores describes number of cores on a CPU device.
	Cores int32 `protobuf:"varint,5,opt,name=cores" json:"cores,omitempty"`
	// Maximum configured clock frequency of the device in MHz.
	ClockFrequency float64 `protobuf:"fixed64,6,opt,name=clockFrequency" json:"clockFrequency,omitempty"`
	// CacheSize shows CPU cache size.
	CacheSize int32 `protobuf:"varint,7,opt,name=cacheSize" json:"cacheSize,omitempty"`
	// Stepping describes CPU stepping level.
	Stepping int32 `protobuf:"varint,8,opt,name=stepping" json:"stepping,omitempty"`
	// Flags describes supported extensions on a CPU.
	Flags []string `protobuf:"bytes,9,rep,name=flags" json:"flags,omitempty"`
}

type CPUDeviceInfo struct {
	// Miners where such device exists.
	Miners []string `protobuf:"bytes,1,rep,name=miners" json:"miners,omitempty"`
	// Its properties.
	Device *CPUDevice `protobuf:"bytes,2,opt,name=device" json:"device,omitempty"`
}

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

type Capabilities struct {
	Cpu []*CPUDevice `protobuf:"bytes,1,rep,name=cpu" json:"cpu,omitempty"`
	Mem *RAMDevice   `protobuf:"bytes,2,opt,name=mem" json:"mem,omitempty"`
	Gpu []*GPUDevice `protobuf:"bytes,3,rep,name=gpu" json:"gpu,omitempty"`
}

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

type CompletedTask struct {
	Id      *ID        `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
	Image   string     `protobuf:"bytes,2,opt,name=image" json:"image,omitempty"`
	EndTime *Timestamp `protobuf:"bytes,3,opt,name=endTime" json:"endTime,omitempty"`
}

type ContainerRestartPolicy struct {
	Name              string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	MaximumRetryCount uint32 `protobuf:"varint,2,opt,name=maximumRetryCount" json:"maximumRetryCount,omitempty"`
}

type Deal struct {
	BuyerID           string     `protobuf:"bytes,1,opt,name=BuyerID" json:"BuyerID,omitempty"`
	SupplierID        string     `protobuf:"bytes,2,opt,name=SupplierID" json:"SupplierID,omitempty"`
	Status            DealStatus `protobuf:"varint,3,opt,name=status,enum=sonm.DealStatus" json:"status,omitempty"`
	Price             string     `protobuf:"bytes,4,opt,name=price" json:"price,omitempty"`
	StartTime         *Timestamp `protobuf:"bytes,5,opt,name=startTime" json:"startTime,omitempty"`
	EndTime           *Timestamp `protobuf:"bytes,6,opt,name=endTime" json:"endTime,omitempty"`
	SpecificationHash string     `protobuf:"bytes,7,opt,name=SpecificationHash" json:"SpecificationHash,omitempty"`
	WorkTime          uint64     `protobuf:"varint,8,opt,name=workTime" json:"workTime,omitempty"`
	Id                string     `protobuf:"bytes,9,opt,name=id" json:"id,omitempty"`
}

type DealInfoReply struct {
	Id    *ID    `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
	Order *Order `protobuf:"bytes,2,opt,name=order" json:"order,omitempty"`
	// List of currently running task IDs. More detailed info can be obtained
	// using "TaskStatus" method.
	TasksRunning []*ID `protobuf:"bytes,3,rep,name=tasksRunning" json:"tasksRunning,omitempty"`
	// List of completed tasks.
	TasksCompleted []*CompletedTask `protobuf:"bytes,4,rep,name=tasksCompleted" json:"tasksCompleted,omitempty"`
}

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

type DealListRequest struct {
	Owner  string     `protobuf:"bytes,1,opt,name=owner" json:"owner,omitempty"`
	Status DealStatus `protobuf:"varint,2,opt,name=status,enum=sonm.DealStatus" json:"status,omitempty"`
}

type DealManagementClient interface {
	// List produces a list of all deals made by client with given ID
	List(ctx context.Context, in *DealListRequest, opts ...grpc.CallOption) (*DealListReply, error)
	// Status produces a detailed info about deal with given ID
	Status(ctx context.Context, in *ID, opts ...grpc.CallOption) (*Deal, error)
	// Finish finishes a deal with given ID
	Finish(ctx context.Context, in *ID, opts ...grpc.CallOption) (*Empty, error)
}

type DealManagementServer interface {
	// List produces a list of all deals made by client with given ID
	List(context.Context, *DealListRequest) (*DealListReply, error)
	// Status produces a detailed info about deal with given ID
	Status(context.Context, *ID) (*Deal, error)
	// Finish finishes a deal with given ID
	Finish(context.Context, *ID) (*Empty, error)
}

type DealRequest struct {
	BidId    string `protobuf:"bytes,1,opt,name=bidId" json:"bidId,omitempty"`
	AskId    string `protobuf:"bytes,2,opt,name=askId" json:"askId,omitempty"`
	SpecHash string `protobuf:"bytes,4,opt,name=specHash" json:"specHash,omitempty"`
}

type DealStatus int32

type DevicesReply struct {
	// CPU unique ID -> Info.
	CPUs map[string]*CPUDeviceInfo `` /* 128-byte string literal not displayed */
	// GPU unique ID -> Info.
	GPUs map[string]*GPUDeviceInfo `` /* 128-byte string literal not displayed */
}

type DiscoverHubRequest struct {
	Endpoint string `protobuf:"bytes,1,opt,name=endpoint" json:"endpoint,omitempty"`
}

type Empty struct {
}

type GPUCount int32

type GPUDevice struct {
	// Name describes full GPU device name.
	Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	// VendorId describes vendor id.
	VendorId uint64 `protobuf:"varint,2,opt,name=vendorId" json:"vendorId,omitempty"`
	// VendorName describes vendor name, for example "NVIDIA" or "AMD".
	VendorName string `protobuf:"bytes,3,opt,name=vendorName" json:"vendorName,omitempty"`
	// Total maximum memory size the device can hold.
	MaxMemorySize uint64 `protobuf:"varint,4,opt,name=maxMemorySize" json:"maxMemorySize,omitempty"`
	// Maximum configured clock frequency of the device in MHz.
	MaxClockFrequency uint64 `protobuf:"varint,5,opt,name=maxClockFrequency" json:"maxClockFrequency,omitempty"`
	// OpenCL major version.
	OpenCLDeviceVersionMajor int32 `protobuf:"varint,6,opt,name=openCLDeviceVersionMajor" json:"openCLDeviceVersionMajor,omitempty"`
	// OpenCL minor version.
	OpenCLDeviceVersionMinor int32 `protobuf:"varint,7,opt,name=openCLDeviceVersionMinor" json:"openCLDeviceVersionMinor,omitempty"`
}

type GPUDeviceInfo struct {
	// Miners where such device exists.
	Miners []string `protobuf:"bytes,1,rep,name=miners" json:"miners,omitempty"`
	// Its properties.
	Device *GPUDevice `protobuf:"bytes,2,opt,name=device" json:"device,omitempty"`
}

type Geo struct {
	Country string  `protobuf:"bytes,1,opt,name=country" json:"country,omitempty"`
	City    string  `protobuf:"bytes,2,opt,name=city" json:"city,omitempty"`
	Lat     float32 `protobuf:"fixed32,3,opt,name=lat" json:"lat,omitempty"`
	Lon     float32 `protobuf:"fixed32,4,opt,name=lon" json:"lon,omitempty"`
}

type GetAllSlotsReply struct {
	Slots map[string]*GetAllSlotsReply_SlotList `` /* 130-byte string literal not displayed */
}

type GetAllSlotsReply_SlotList struct {
	Slot []*Slot `protobuf:"bytes,1,rep,name=slot" json:"slot,omitempty"`
}

type GetDevicePropertiesReply struct {
	Properties map[string]float64 `` /* 142-byte string literal not displayed */
}

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

type GetOrdersRequest struct {
	// Order keeps slot and type for searching
	Order *Order `protobuf:"bytes,1,opt,name=order" json:"order,omitempty"`
	// Count describe how namy results must be returned (order by price)
	Count uint64 `protobuf:"varint,2,opt,name=count" json:"count,omitempty"`
}

type GetProcessingReply struct {
	Orders map[string]*GetProcessingReply_ProcessedOrder `` /* 132-byte string literal not displayed */
}

type GetProcessingReply_ProcessedOrder struct {
	Id        string     `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
	Status    uint32     `protobuf:"varint,2,opt,name=status" json:"status,omitempty"`
	Timestamp *Timestamp `protobuf:"bytes,3,opt,name=timestamp" json:"timestamp,omitempty"`
	Extra     string     `protobuf:"bytes,4,opt,name=extra" json:"extra,omitempty"`
}

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

type HubClient interface {
	// Ping should be used as Healthcheck for Hub
	Ping(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*PingReply, error)
	// Status returns internal hub statistic
	Status(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*HubStatusReply, error)
	// List returns a list for connected Workers
	List(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ListReply, error)
	// Info returns info about given Worker
	Info(ctx context.Context, in *ID, opts ...grpc.CallOption) (*InfoReply, error)
	// TaskList returns info about all Tasks on all Workers on the Hub
	TaskList(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*TaskListReply, error)
	PushTask(ctx context.Context, opts ...grpc.CallOption) (Hub_PushTaskClient, error)
	PullTask(ctx context.Context, in *PullTaskRequest, opts ...grpc.CallOption) (Hub_PullTaskClient, error)
	// StartTask schedules the task associcated with a deal on some miner.
	StartTask(ctx context.Context, in *HubStartTaskRequest, opts ...grpc.CallOption) (*HubStartTaskReply, error)
	StopTask(ctx context.Context, in *ID, opts ...grpc.CallOption) (*Empty, error)
	TaskStatus(ctx context.Context, in *ID, opts ...grpc.CallOption) (*TaskStatusReply, error)
	MinerStatus(ctx context.Context, in *ID, opts ...grpc.CallOption) (*StatusMapReply, error)
	TaskLogs(ctx context.Context, in *TaskLogsRequest, opts ...grpc.CallOption) (Hub_TaskLogsClient, error)
	ProposeDeal(ctx context.Context, in *DealRequest, opts ...grpc.CallOption) (*Empty, error)
	// Note: currently used for testing pusposes.
	GetDealInfo(ctx context.Context, in *ID, opts ...grpc.CallOption) (*DealInfoReply, error)
	DiscoverHub(ctx context.Context, in *DiscoverHubRequest, opts ...grpc.CallOption) (*Empty, error)
	// Devices returns list of all available devices that this Hub awares of
	// with tieir full description.
	Devices(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*DevicesReply, error)
	// MinerDevices returns a list of all available devices for given miner ID.
	MinerDevices(ctx context.Context, in *ID, opts ...grpc.CallOption) (*DevicesReply, error)
	// GetDeviceProperties allows to obtain previously assigned resource
	// properties for a given device.
	GetDeviceProperties(ctx context.Context, in *ID, opts ...grpc.CallOption) (*GetDevicePropertiesReply, error)
	// SetDeviceProperties method allows to specify additional resource
	// properties for a device specified by its ID.
	// This may include GPU's capability to execute a well-known work such as
	// Ethereum mining etc.
	// Note, that this method overrides all previously specified properties.
	SetDeviceProperties(ctx context.Context, in *SetDevicePropertiesRequest, opts ...grpc.CallOption) (*Empty, error)
	// GetRegisteredWorkers returns a list of Worker IDs that
	// allowed to connect to the Hub.
	GetRegisteredWorkers(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*GetRegisteredWorkersReply, error)
	// RegisterWorker adds Worker credentials to be able for them to connect
	// to a Hub.
	RegisterWorker(ctx context.Context, in *ID, opts ...grpc.CallOption) (*Empty, error)
	// DeregisterWorkers removed Worker credentials denying them to connect to
	// a Hub.
	DeregisterWorker(ctx context.Context, in *ID, opts ...grpc.CallOption) (*Empty, error)
	// GetSlots allows to obtain previously assigned slots for the Hub.
	Slots(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*SlotsReply, error)
	// AddSlot allows to assign a new slot.
	// This method can fail if either there are no such resources found or it
	// has been previourly assigned.
	InsertSlot(ctx context.Context, in *InsertSlotRequest, opts ...grpc.CallOption) (*ID, error)
	// RemoveSlot removes the speified slot if fully matches.
	RemoveSlot(ctx context.Context, in *ID, opts ...grpc.CallOption) (*Empty, error)
}

type HubManagementClient interface {
	// Status produse a detailed info about Hub
	Status(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*HubStatusReply, error)
	// WorkersList prouces a list of connected Workers
	WorkersList(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ListReply, error)
	// WorkersStatus produces a detailed info about a Worker with given ID
	WorkerStatus(ctx context.Context, in *ID, opts ...grpc.CallOption) (*InfoReply, error)
	// GetRegisteredWorkers produce a list of Workers IDs allowed
	// to connect to this hub
	GetRegisteredWorkers(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*GetRegisteredWorkersReply, error)
	// RegisterWorkers allows Worker with given ID connect to Hub
	RegisterWorker(ctx context.Context, in *ID, opts ...grpc.CallOption) (*Empty, error)
	// DeregisterWorkers deny Worker with given ID connect to Hub
	DeregisterWorker(ctx context.Context, in *ID, opts ...grpc.CallOption) (*Empty, error)
	// Devices returns list of all available devices that this Hub awares of
	// with tieir full description.
	DeviceList(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*DevicesReply, error)
	// GetDeviceProperties allows to obtain previously assigned resource
	// properties for a given device.
	GetDeviceProperties(ctx context.Context, in *ID, opts ...grpc.CallOption) (*GetDevicePropertiesReply, error)
	// SetDeviceProperties method allows to specify additional resource
	// properties for a device specified by its ID.
	// This may include GPU's capability to execute a well-known work such as
	// Ethereum mining etc.
	SetDeviceProperties(ctx context.Context, in *SetDevicePropertiesRequest, opts ...grpc.CallOption) (*Empty, error)
	// GetAskPlans allows to obtain previously assigned Ask Plans from for a given worker.
	GetAskPlans(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*SlotsReply, error)
	// CreateAskPlan allows to create rules
	// for creating Ask orders on Marketplace
	CreateAskPlan(ctx context.Context, in *InsertSlotRequest, 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)
	// List produces a list of all running tasks on the Hub
	TaskList(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*TaskListReply, error)
	// Status produces a detailed info about task on the Hub
	TaskStatus(ctx context.Context, in *ID, opts ...grpc.CallOption) (*TaskStatusReply, error)
}

type HubManagementServer interface {
	// Status produse a detailed info about Hub
	Status(context.Context, *Empty) (*HubStatusReply, error)
	// WorkersList prouces a list of connected Workers
	WorkersList(context.Context, *Empty) (*ListReply, error)
	// WorkersStatus produces a detailed info about a Worker with given ID
	WorkerStatus(context.Context, *ID) (*InfoReply, error)
	// GetRegisteredWorkers produce a list of Workers IDs allowed
	// to connect to this hub
	GetRegisteredWorkers(context.Context, *Empty) (*GetRegisteredWorkersReply, error)
	// RegisterWorkers allows Worker with given ID connect to Hub
	RegisterWorker(context.Context, *ID) (*Empty, error)
	// DeregisterWorkers deny Worker with given ID connect to Hub
	DeregisterWorker(context.Context, *ID) (*Empty, error)
	// Devices returns list of all available devices that this Hub awares of
	// with tieir full description.
	DeviceList(context.Context, *Empty) (*DevicesReply, error)
	// GetDeviceProperties allows to obtain previously assigned resource
	// properties for a given device.
	GetDeviceProperties(context.Context, *ID) (*GetDevicePropertiesReply, error)
	// SetDeviceProperties method allows to specify additional resource
	// properties for a device specified by its ID.
	// This may include GPU's capability to execute a well-known work such as
	// Ethereum mining etc.
	SetDeviceProperties(context.Context, *SetDevicePropertiesRequest) (*Empty, error)
	// GetAskPlans allows to obtain previously assigned Ask Plans from for a given worker.
	GetAskPlans(context.Context, *Empty) (*SlotsReply, error)
	// CreateAskPlan allows to create rules
	// for creating Ask orders on Marketplace
	CreateAskPlan(context.Context, *InsertSlotRequest) (*ID, error)
	// RemoveAskPlan allows to remove rules
	// for creating Ask orders on Marketplace
	RemoveAskPlan(context.Context, *ID) (*Empty, error)
	// List produces a list of all running tasks on the Hub
	TaskList(context.Context, *Empty) (*TaskListReply, error)
	// Status produces a detailed info about task on the Hub
	TaskStatus(context.Context, *ID) (*TaskStatusReply, error)
}

type HubServer interface {
	// Ping should be used as Healthcheck for Hub
	Ping(context.Context, *Empty) (*PingReply, error)
	// Status returns internal hub statistic
	Status(context.Context, *Empty) (*HubStatusReply, error)
	// List returns a list for connected Workers
	List(context.Context, *Empty) (*ListReply, error)
	// Info returns info about given Worker
	Info(context.Context, *ID) (*InfoReply, error)
	// TaskList returns info about all Tasks on all Workers on the Hub
	TaskList(context.Context, *Empty) (*TaskListReply, error)
	PushTask(Hub_PushTaskServer) error
	PullTask(*PullTaskRequest, Hub_PullTaskServer) error
	// StartTask schedules the task associcated with a deal on some miner.
	StartTask(context.Context, *HubStartTaskRequest) (*HubStartTaskReply, error)
	StopTask(context.Context, *ID) (*Empty, error)
	TaskStatus(context.Context, *ID) (*TaskStatusReply, error)
	MinerStatus(context.Context, *ID) (*StatusMapReply, error)
	TaskLogs(*TaskLogsRequest, Hub_TaskLogsServer) error
	ProposeDeal(context.Context, *DealRequest) (*Empty, error)
	// Note: currently used for testing pusposes.
	GetDealInfo(context.Context, *ID) (*DealInfoReply, error)
	DiscoverHub(context.Context, *DiscoverHubRequest) (*Empty, error)
	// Devices returns list of all available devices that this Hub awares of
	// with tieir full description.
	Devices(context.Context, *Empty) (*DevicesReply, error)
	// MinerDevices returns a list of all available devices for given miner ID.
	MinerDevices(context.Context, *ID) (*DevicesReply, error)
	// GetDeviceProperties allows to obtain previously assigned resource
	// properties for a given device.
	GetDeviceProperties(context.Context, *ID) (*GetDevicePropertiesReply, error)
	// SetDeviceProperties method allows to specify additional resource
	// properties for a device specified by its ID.
	// This may include GPU's capability to execute a well-known work such as
	// Ethereum mining etc.
	// Note, that this method overrides all previously specified properties.
	SetDeviceProperties(context.Context, *SetDevicePropertiesRequest) (*Empty, error)
	// GetRegisteredWorkers returns a list of Worker IDs that
	// allowed to connect to the Hub.
	GetRegisteredWorkers(context.Context, *Empty) (*GetRegisteredWorkersReply, error)
	// RegisterWorker adds Worker credentials to be able for them to connect
	// to a Hub.
	RegisterWorker(context.Context, *ID) (*Empty, error)
	// DeregisterWorkers removed Worker credentials denying them to connect to
	// a Hub.
	DeregisterWorker(context.Context, *ID) (*Empty, error)
	// GetSlots allows to obtain previously assigned slots for the Hub.
	Slots(context.Context, *Empty) (*SlotsReply, error)
	// AddSlot allows to assign a new slot.
	// This method can fail if either there are no such resources found or it
	// has been previourly assigned.
	InsertSlot(context.Context, *InsertSlotRequest) (*ID, error)
	// RemoveSlot removes the speified slot if fully matches.
	RemoveSlot(context.Context, *ID) (*Empty, error)
}

type HubStartTaskReply struct {
	Id       string   `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
	Endpoint []string `protobuf:"bytes,2,rep,name=endpoint" json:"endpoint,omitempty"`
	HubAddr  string   `protobuf:"bytes,3,opt,name=hubAddr" json:"hubAddr,omitempty"`
}

type HubStartTaskRequest struct {
	// Deal points to the deal associated with workers where the task should be
	// started.
	Deal     *Deal  `protobuf:"bytes,1,opt,name=deal" json:"deal,omitempty"`
	Registry string `protobuf:"bytes,2,opt,name=registry" json:"registry,omitempty"`
	// Image specifies a Docker image name.
	Image         string            `protobuf:"bytes,3,opt,name=image" json:"image,omitempty"`
	Auth          string            `protobuf:"bytes,4,opt,name=auth" json:"auth,omitempty"`
	PublicKeyData string            `protobuf:"bytes,5,opt,name=PublicKeyData" json:"PublicKeyData,omitempty"`
	CommitOnStop  bool              `protobuf:"varint,6,opt,name=commitOnStop" json:"commitOnStop,omitempty"`
	Env           map[string]string `` /* 126-byte string literal not displayed */
}

type HubStatusReply struct {
	MinerCount uint64 `protobuf:"varint,1,opt,name=minerCount" json:"minerCount,omitempty"`
	Uptime     uint64 `protobuf:"varint,2,opt,name=uptime" json:"uptime,omitempty"`
	Version    string `protobuf:"bytes,3,opt,name=version" json:"version,omitempty"`
	Platform   string `protobuf:"bytes,4,opt,name=platform" json:"platform,omitempty"`
	EthAddr    string `protobuf:"bytes,5,opt,name=ethAddr" json:"ethAddr,omitempty"`
}

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

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

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

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

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

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

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

type InfoReply struct {
	Usage        map[string]*ResourceUsage `` /* 130-byte string literal not displayed */
	Name         string                    `protobuf:"bytes,2,opt,name=name" json:"name,omitempty"`
	Capabilities *Capabilities             `protobuf:"bytes,3,opt,name=capabilities" json:"capabilities,omitempty"`
}

type InsertSlotRequest struct {
	Slot    *Slot  `protobuf:"bytes,1,opt,name=slot" json:"slot,omitempty"`
	Price   string `protobuf:"bytes,2,opt,name=price" json:"price,omitempty"`
	BuyerID string `protobuf:"bytes,3,opt,name=buyerID" json:"buyerID,omitempty"`
}

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

type ListReply_ListValue struct {
	Values []string `protobuf:"bytes,1,rep,name=values" json:"values,omitempty"`
}

type LocatorClient interface {
	Announce(ctx context.Context, in *AnnounceRequest, opts ...grpc.CallOption) (*Empty, error)
	Resolve(ctx context.Context, in *ResolveRequest, opts ...grpc.CallOption) (*ResolveReply, error)
}

type LocatorServer interface {
	Announce(context.Context, *AnnounceRequest) (*Empty, error)
	Resolve(context.Context, *ResolveRequest) (*ResolveReply, error)
}

type MarketClient interface {
	GetOrders(ctx context.Context, in *GetOrdersRequest, opts ...grpc.CallOption) (*GetOrdersReply, error)
	GetOrderByID(ctx context.Context, in *ID, opts ...grpc.CallOption) (*Order, error)
	CreateOrder(ctx context.Context, in *Order, opts ...grpc.CallOption) (*Order, error)
	CancelOrder(ctx context.Context, in *Order, opts ...grpc.CallOption) (*Empty, error)
	// GetProcessing returns currently processing orders
	// not required in Marketplace service
	// must be implemented on Node
	GetProcessing(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*GetProcessingReply, error)
}

type MarketServer interface {
	GetOrders(context.Context, *GetOrdersRequest) (*GetOrdersReply, error)
	GetOrderByID(context.Context, *ID) (*Order, error)
	CreateOrder(context.Context, *Order) (*Order, error)
	CancelOrder(context.Context, *Order) (*Empty, error)
	// GetProcessing returns currently processing orders
	// not required in Marketplace service
	// must be implemented on Node
	GetProcessing(context.Context, *Empty) (*GetProcessingReply, error)
}

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

type MinerClient interface {
	Ping(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*PingReply, error)
	Info(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*InfoReply, error)
	Handshake(ctx context.Context, in *MinerHandshakeRequest, opts ...grpc.CallOption) (*MinerHandshakeReply, error)
	Save(ctx context.Context, in *SaveRequest, opts ...grpc.CallOption) (Miner_SaveClient, error)
	Load(ctx context.Context, opts ...grpc.CallOption) (Miner_LoadClient, error)
	Start(ctx context.Context, in *MinerStartRequest, opts ...grpc.CallOption) (*MinerStartReply, error)
	Stop(ctx context.Context, in *ID, opts ...grpc.CallOption) (*Empty, error)
	TasksStatus(ctx context.Context, opts ...grpc.CallOption) (Miner_TasksStatusClient, error)
	TaskDetails(ctx context.Context, in *ID, opts ...grpc.CallOption) (*TaskStatusReply, error)
	TaskLogs(ctx context.Context, in *TaskLogsRequest, opts ...grpc.CallOption) (Miner_TaskLogsClient, error)
	DiscoverHub(ctx context.Context, in *DiscoverHubRequest, opts ...grpc.CallOption) (*Empty, error)
}

type MinerHandshakeReply struct {
	Miner        string        `protobuf:"bytes,1,opt,name=miner" json:"miner,omitempty"`
	Capabilities *Capabilities `protobuf:"bytes,2,opt,name=capabilities" json:"capabilities,omitempty"`
	NatType      NATType       `protobuf:"varint,3,opt,name=natType,enum=sonm.NATType" json:"natType,omitempty"`
}

type MinerHandshakeRequest struct {
	Hub   string      `protobuf:"bytes,1,opt,name=hub" json:"hub,omitempty"`
	Tasks []*TaskInfo `protobuf:"bytes,2,rep,name=tasks" json:"tasks,omitempty"`
}

type MinerServer interface {
	Ping(context.Context, *Empty) (*PingReply, error)
	Info(context.Context, *Empty) (*InfoReply, error)
	Handshake(context.Context, *MinerHandshakeRequest) (*MinerHandshakeReply, error)
	Save(*SaveRequest, Miner_SaveServer) error
	Load(Miner_LoadServer) error
	Start(context.Context, *MinerStartRequest) (*MinerStartReply, error)
	Stop(context.Context, *ID) (*Empty, error)
	TasksStatus(Miner_TasksStatusServer) error
	TaskDetails(context.Context, *ID) (*TaskStatusReply, error)
	TaskLogs(*TaskLogsRequest, Miner_TaskLogsServer) error
	DiscoverHub(context.Context, *DiscoverHubRequest) (*Empty, error)
}

type MinerStartReply struct {
	Container string   `protobuf:"bytes,1,opt,name=container" json:"container,omitempty"`
	Routes    []*Route `protobuf:"bytes,2,rep,name=routes" json:"routes,omitempty"`
}

type MinerStartRequest struct {
	Id            string                    `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
	Registry      string                    `protobuf:"bytes,2,opt,name=registry" json:"registry,omitempty"`
	Image         string                    `protobuf:"bytes,3,opt,name=image" json:"image,omitempty"`
	Auth          string                    `protobuf:"bytes,4,opt,name=auth" json:"auth,omitempty"`
	RestartPolicy *ContainerRestartPolicy   `protobuf:"bytes,5,opt,name=restartPolicy" json:"restartPolicy,omitempty"`
	Resources     *TaskResourceRequirements `protobuf:"bytes,6,opt,name=resources" json:"resources,omitempty"`
	PublicKeyData string                    `protobuf:"bytes,7,opt,name=PublicKeyData" json:"PublicKeyData,omitempty"`
	CommitOnStop  bool                      `protobuf:"varint,8,opt,name=commitOnStop" json:"commitOnStop,omitempty"`
	Env           map[string]string         `` /* 126-byte string literal not displayed */
	// OrderId describes an unique order identifier.
	// It is here for proper resource allocation and limitation.
	OrderId string `protobuf:"bytes,10,opt,name=orderId" json:"orderId,omitempty"`
}

type MinerStatusMapRequest struct {
}

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

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

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

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

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

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

type Miner_TasksStatusClient interface {
	Send(*MinerStatusMapRequest) error
	Recv() (*StatusMapReply, error)
	grpc.ClientStream
}

type Miner_TasksStatusServer interface {
	Send(*StatusMapReply) error
	Recv() (*MinerStatusMapRequest, error)
	grpc.ServerStream
}

type NATType int32

type NetworkType int32

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

type Order struct {
	// Order ID, UUIDv4
	Id string `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
	// Buyer's EtherumID
	ByuerID string `protobuf:"bytes,2,opt,name=byuerID" json:"byuerID,omitempty"`
	// Supplier's is EtherumID
	SupplierID string `protobuf:"bytes,3,opt,name=supplierID" json:"supplierID,omitempty"`
	// Order price
	Price string `protobuf:"bytes,4,opt,name=price" json:"price,omitempty"`
	// Order type (Bid or Ask)
	OrderType OrderType `protobuf:"varint,5,opt,name=orderType,enum=sonm.OrderType" json:"orderType,omitempty"`
	// Slot describe resource requiements
	Slot *Slot `protobuf:"bytes,6,opt,name=slot" json:"slot,omitempty"`
}

type OrderType int32

type PingReply struct {
	Status string `protobuf:"bytes,1,opt,name=status" json:"status,omitempty"`
}

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

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

type RAMDevice struct {
	Total uint64 `protobuf:"varint,1,opt,name=total" json:"total,omitempty"`
	Used  uint64 `protobuf:"varint,2,opt,name=used" json:"used,omitempty"`
}

type RemoveSlotRequest struct {
	ID   string `protobuf:"bytes,1,opt,name=ID" json:"ID,omitempty"`
	Slot *Slot  `protobuf:"bytes,2,opt,name=slot" json:"slot,omitempty"`
}

type ResolveReply struct {
	IpAddr []string `protobuf:"bytes,1,rep,name=ipAddr" json:"ipAddr,omitempty"`
}

type ResolveRequest struct {
	EthAddr string `protobuf:"bytes,1,opt,name=ethAddr" json:"ethAddr,omitempty"`
}

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 */
}

type Resources struct {
	// CPU core count
	CpuCores uint64 `protobuf:"varint,1,opt,name=cpuCores" json:"cpuCores,omitempty"`
	// RAM, in bytes
	RamBytes uint64 `protobuf:"varint,2,opt,name=ramBytes" json:"ramBytes,omitempty"`
	// GPU devices count
	GpuCount GPUCount `protobuf:"varint,3,opt,name=gpuCount,enum=sonm.GPUCount" json:"gpuCount,omitempty"`
	// todo: discuss
	// storage volume, in Megabytes
	Storage uint64 `protobuf:"varint,4,opt,name=storage" json:"storage,omitempty"`
	// Inbound network traffic (the higher value), in bytes
	NetTrafficIn uint64 `protobuf:"varint,5,opt,name=netTrafficIn" json:"netTrafficIn,omitempty"`
	// Outbound network traffic (the higher value), in bytes
	NetTrafficOut uint64 `protobuf:"varint,6,opt,name=netTrafficOut" json:"netTrafficOut,omitempty"`
	// Allowed network connections
	NetworkType NetworkType `protobuf:"varint,7,opt,name=networkType,enum=sonm.NetworkType" json:"networkType,omitempty"`
	// Other properties/benchmarks. The higher means better.
	Properties map[string]float64 `` /* 142-byte string literal not displayed */
}

type Route struct {
	Port     string      `protobuf:"bytes,1,opt,name=port" json:"port,omitempty"`
	Endpoint *SocketAddr `protobuf:"bytes,2,opt,name=endpoint" json:"endpoint,omitempty"`
}

type SaveRequest struct {
	ImageID string `protobuf:"bytes,1,opt,name=imageID" json:"imageID,omitempty"`
}

type SetDevicePropertiesRequest struct {
	// Device identifier.
	ID string `protobuf:"bytes,1,opt,name=ID" json:"ID,omitempty"`
	// Its properties.
	Properties map[string]float64 `` /* 142-byte string literal not displayed */
}

type Slot struct {
	// Buyer’s rating. Got from Buyer’s profile for BID orders rating_supplier.
	BuyerRating int64 `protobuf:"varint,1,opt,name=buyerRating" json:"buyerRating,omitempty"`
	// Supplier’s rating. Got from Supplier’s profile for ASK orders.
	SupplierRating int64 `protobuf:"varint,2,opt,name=supplierRating" json:"supplierRating,omitempty"`
	// Geo represent Worker's position
	Geo *Geo `protobuf:"bytes,3,opt,name=geo" json:"geo,omitempty"`
	// Hardware resources requirements
	Resources *Resources `protobuf:"bytes,4,opt,name=resources" json:"resources,omitempty"`
	// Duration is resource rent duration in seconds
	Duration uint64 `protobuf:"varint,5,opt,name=duration" json:"duration,omitempty"`
}