sonm

package

Go to main page

Versions in this module

v0

v0.4.31

May 15, 2020

v0.4.30

Aug 2, 2019

Changes in this version

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

type DWHDeal

+ AskTag []byte

+ BidTag []byte

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

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

+ type RemotePTYBannerRequest struct

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

+ func (*RemotePTYBannerRequest) ProtoMessage()

+ func (m *RemotePTYBannerRequest) Reset()

+ func (m *RemotePTYBannerRequest) String() string

+ type RemotePTYBannerResponse struct

+ Banner string

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

+ func (*RemotePTYBannerResponse) ProtoMessage()

+ func (m *RemotePTYBannerResponse) GetBanner() string

+ func (m *RemotePTYBannerResponse) Reset()

+ func (m *RemotePTYBannerResponse) String() string

+ type RemotePTYClient interface

+ Banner func(ctx context.Context, in *RemotePTYBannerRequest, opts ...grpc.CallOption) (*RemotePTYBannerResponse, error)

+ Exec func(ctx context.Context, in *RemotePTYExecRequest, opts ...grpc.CallOption) (RemotePTY_ExecClient, error)

+ func NewRemotePTYClient(cc *grpc.ClientConn) RemotePTYClient

+ type RemotePTYExecRequest struct

+ Args []string

+ Envp []string

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

+ func (*RemotePTYExecRequest) ProtoMessage()

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

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

+ func (m *RemotePTYExecRequest) Reset()

+ func (m *RemotePTYExecRequest) String() string

+ type RemotePTYExecResponseChunk struct

+ Done bool

+ Out []byte

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

+ func (*RemotePTYExecResponseChunk) ProtoMessage()

+ func (m *RemotePTYExecResponseChunk) GetDone() bool

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

+ func (m *RemotePTYExecResponseChunk) Reset()

+ func (m *RemotePTYExecResponseChunk) String() string

+ type RemotePTYServer interface

+ Banner func(context.Context, *RemotePTYBannerRequest) (*RemotePTYBannerResponse, error)

+ Exec func(*RemotePTYExecRequest, RemotePTY_ExecServer) error

+ type RemotePTY_ExecClient interface

+ Recv func() (*RemotePTYExecResponseChunk, error)

+ type RemotePTY_ExecServer interface

+ Send func(*RemotePTYExecResponseChunk) error

v0.4.29

Jul 19, 2019

Changes in this version

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

+ type InitClient interface

+ Mount func(ctx context.Context, in *InitMountRequest, opts ...grpc.CallOption) (*InitMountResponse, error)

+ func NewInitClient(cc *grpc.ClientConn) InitClient

+ type InitMountRequest struct

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

+ func (*InitMountRequest) ProtoMessage()

+ func (m *InitMountRequest) Reset()

+ func (m *InitMountRequest) String() string

+ type InitMountResponse struct

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

+ func (*InitMountResponse) ProtoMessage()

+ func (m *InitMountResponse) Reset()

+ func (m *InitMountResponse) String() string

+ type InitServer interface

+ Mount func(context.Context, *InitMountRequest) (*InitMountResponse, error)

v0.4.28

May 24, 2019

v0.4.27

May 22, 2019

v0.4.26

May 21, 2019

Changes in this version

+ func IsTaskStatusTerminated(status TaskStatusReply_Status) bool

type TaskStatusReply_Status

+ const TaskStatusReply_KILLED_OOM

v0.4.25

Apr 30, 2019

Changes in this version

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

type Benchmarks

+ func (m *Benchmarks) GPUCuckaroo29() uint64

+ func (m *Benchmarks) GPUNVidiaOnly() uint64

+ func (m *Benchmarks) GPURadeonOnly() uint64

type GPUDevice

+ DeviceFiles []string

+ DriverVolumes map[string]string

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

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

type GPUVendorType

+ const GPUVendorType_REMOTE

+ type RemoteGPUDeviceReply struct

+ Devices []*GPUDevice

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

+ func (*RemoteGPUDeviceReply) ProtoMessage()

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

+ func (m *RemoteGPUDeviceReply) Reset()

+ func (m *RemoteGPUDeviceReply) String() string

+ type RemoteGPUDeviceRequest struct

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

+ func (*RemoteGPUDeviceRequest) ProtoMessage()

+ func (m *RemoteGPUDeviceRequest) Reset()

+ func (m *RemoteGPUDeviceRequest) String() string

+ type RemoteGPUTunerClient interface

+ Devices func(ctx context.Context, in *RemoteGPUDeviceRequest, opts ...grpc.CallOption) (*RemoteGPUDeviceReply, error)

+ func NewRemoteGPUTunerClient(cc *grpc.ClientConn) RemoteGPUTunerClient

+ type RemoteGPUTunerServer interface

+ Devices func(context.Context, *RemoteGPUDeviceRequest) (*RemoteGPUDeviceReply, error)

v0.4.22

Feb 1, 2019

Changes in this version

type QOSClient

+ Flush func(ctx context.Context, in *QOSFlushRequest, opts ...grpc.CallOption) (*QOSFlushResponse, error)

+ type QOSFlushRequest struct

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

+ func (*QOSFlushRequest) ProtoMessage()

+ func (m *QOSFlushRequest) Reset()

+ func (m *QOSFlushRequest) String() string

+ type QOSFlushResponse struct

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

+ func (*QOSFlushResponse) ProtoMessage()

+ func (m *QOSFlushResponse) Reset()

+ func (m *QOSFlushResponse) String() string

type QOSServer

+ Flush func(context.Context, *QOSFlushRequest) (*QOSFlushResponse, error)

v0.4.21

Jan 29, 2019

Changes in this version

+ var CapabilityScope_name = map[int32]string

+ var CapabilityScope_value = map[string]int32

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

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

+ type CapabilityScope int32

+ const CapabilityScope_CAPABILITY_INSPECTION

+ const CapabilityScope_CAPABILITY_NONE

+ const CapabilityScope_CAPABILITY_SSH

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

+ func (x CapabilityScope) String() string

+ type ConnectionStat struct

+ Family uint32

+ Fd uint64

+ LocalAddr *SocketAddr

+ Pid int32

+ RemoteAddr *SocketAddr

+ Status string

+ Type uint32

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

+ func (*ConnectionStat) ProtoMessage()

+ func (m *ConnectionStat) GetFamily() uint32

+ func (m *ConnectionStat) GetFd() uint64

+ func (m *ConnectionStat) GetLocalAddr() *SocketAddr

+ func (m *ConnectionStat) GetPid() int32

+ func (m *ConnectionStat) GetRemoteAddr() *SocketAddr

+ func (m *ConnectionStat) GetStatus() string

+ func (m *ConnectionStat) GetType() uint32

+ func (m *ConnectionStat) Reset()

+ func (m *ConnectionStat) String() string

+ type FileStat struct

+ Fd uint64

+ Path string

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

+ func (*FileStat) ProtoMessage()

+ func (m *FileStat) GetFd() uint64

+ func (m *FileStat) GetPath() string

+ func (m *FileStat) Reset()

+ func (m *FileStat) String() string

+ type InspectClient interface

+ Config func(ctx context.Context, in *InspectConfigRequest, opts ...grpc.CallOption) (*InspectConfigResponse, error)

+ DockerInfo func(ctx context.Context, in *InspectDockerInfoRequest, opts ...grpc.CallOption) (*InspectDockerInfoResponse, error)

+ DockerNetwork func(ctx context.Context, in *InspectDockerNetworkRequest, opts ...grpc.CallOption) (*InspectDockerNetworkResponse, error)

+ DockerVolumes func(ctx context.Context, in *InspectDockerVolumesRequest, opts ...grpc.CallOption) (*InspectDockerVolumesResponse, error)

+ HostInfo func(ctx context.Context, in *InspectHostInfoRequest, opts ...grpc.CallOption) (*InspectHostInfoResponse, error)

+ Network func(ctx context.Context, in *InspectNetworkRequest, opts ...grpc.CallOption) (*InspectNetworkResponse, error)

+ OpenFiles func(ctx context.Context, in *InspectOpenFilesRequest, opts ...grpc.CallOption) (*InspectOpenFilesResponse, error)

+ WatchLogs func(ctx context.Context, in *InspectWatchLogsRequest, opts ...grpc.CallOption) (Inspect_WatchLogsClient, error)

+ func NewInspectClient(cc *grpc.ClientConn) InspectClient

+ type InspectConfigRequest struct

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

+ func (*InspectConfigRequest) ProtoMessage()

+ func (m *InspectConfigRequest) Reset()

+ func (m *InspectConfigRequest) String() string

+ type InspectConfigResponse struct

+ Config []byte

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

+ func (*InspectConfigResponse) ProtoMessage()

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

+ func (m *InspectConfigResponse) Reset()

+ func (m *InspectConfigResponse) String() string

+ type InspectDockerInfoRequest struct

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

+ func (*InspectDockerInfoRequest) ProtoMessage()

+ func (m *InspectDockerInfoRequest) Reset()

+ func (m *InspectDockerInfoRequest) String() string

+ type InspectDockerInfoResponse struct

+ Info []byte

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

+ func (*InspectDockerInfoResponse) ProtoMessage()

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

+ func (m *InspectDockerInfoResponse) Reset()

+ func (m *InspectDockerInfoResponse) String() string

+ type InspectDockerNetworkRequest struct

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

+ func (*InspectDockerNetworkRequest) ProtoMessage()

+ func (m *InspectDockerNetworkRequest) Reset()

+ func (m *InspectDockerNetworkRequest) String() string

+ type InspectDockerNetworkResponse struct

+ Info []byte

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

+ func (*InspectDockerNetworkResponse) ProtoMessage()

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

+ func (m *InspectDockerNetworkResponse) Reset()

+ func (m *InspectDockerNetworkResponse) String() string

+ type InspectDockerVolumesRequest struct

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

+ func (*InspectDockerVolumesRequest) ProtoMessage()

+ func (m *InspectDockerVolumesRequest) Reset()

+ func (m *InspectDockerVolumesRequest) String() string

+ type InspectDockerVolumesResponse struct

+ Info []byte

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

+ func (*InspectDockerVolumesResponse) ProtoMessage()

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

+ func (m *InspectDockerVolumesResponse) Reset()

+ func (m *InspectDockerVolumesResponse) String() string

+ type InspectHostInfoRequest struct

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

+ func (*InspectHostInfoRequest) ProtoMessage()

+ func (m *InspectHostInfoRequest) Reset()

+ func (m *InspectHostInfoRequest) String() string

+ type InspectHostInfoResponse struct

+ BootTime uint64

+ HostID string

+ Hostname string

+ KernelVersion string

+ Os string

+ Platform string

+ PlatformFamily string

+ PlatformVersion string

+ ProcessesNumber uint64

+ Uptime uint64

+ VirtualizationRole string

+ VirtualizationSystem string

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

+ func (*InspectHostInfoResponse) ProtoMessage()

+ func (m *InspectHostInfoResponse) GetBootTime() uint64

+ func (m *InspectHostInfoResponse) GetHostID() string

+ func (m *InspectHostInfoResponse) GetHostname() string

+ func (m *InspectHostInfoResponse) GetKernelVersion() string

+ func (m *InspectHostInfoResponse) GetOs() string

+ func (m *InspectHostInfoResponse) GetPlatform() string

+ func (m *InspectHostInfoResponse) GetPlatformFamily() string

+ func (m *InspectHostInfoResponse) GetPlatformVersion() string

+ func (m *InspectHostInfoResponse) GetProcessesNumber() uint64

+ func (m *InspectHostInfoResponse) GetUptime() uint64

+ func (m *InspectHostInfoResponse) GetVirtualizationRole() string

+ func (m *InspectHostInfoResponse) GetVirtualizationSystem() string

+ func (m *InspectHostInfoResponse) Reset()

+ func (m *InspectHostInfoResponse) String() string

+ type InspectNetworkRequest struct

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

+ func (*InspectNetworkRequest) ProtoMessage()

+ func (m *InspectNetworkRequest) Reset()

+ func (m *InspectNetworkRequest) String() string

+ type InspectNetworkResponse struct

+ Connections []*ConnectionStat

+ Interfaces []*InterfaceStat

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

+ func (*InspectNetworkResponse) ProtoMessage()

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

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

+ func (m *InspectNetworkResponse) Reset()

+ func (m *InspectNetworkResponse) String() string

+ type InspectOpenFilesRequest struct

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

+ func (*InspectOpenFilesRequest) ProtoMessage()

+ func (m *InspectOpenFilesRequest) Reset()

+ func (m *InspectOpenFilesRequest) String() string

+ type InspectOpenFilesResponse struct

+ OpenFiles []*FileStat

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

+ func (*InspectOpenFilesResponse) ProtoMessage()

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

+ func (m *InspectOpenFilesResponse) Reset()

+ func (m *InspectOpenFilesResponse) String() string

+ type InspectServer interface

+ Config func(context.Context, *InspectConfigRequest) (*InspectConfigResponse, error)

+ DockerInfo func(context.Context, *InspectDockerInfoRequest) (*InspectDockerInfoResponse, error)

+ DockerNetwork func(context.Context, *InspectDockerNetworkRequest) (*InspectDockerNetworkResponse, error)

+ DockerVolumes func(context.Context, *InspectDockerVolumesRequest) (*InspectDockerVolumesResponse, error)

+ HostInfo func(context.Context, *InspectHostInfoRequest) (*InspectHostInfoResponse, error)

+ Network func(context.Context, *InspectNetworkRequest) (*InspectNetworkResponse, error)

+ OpenFiles func(context.Context, *InspectOpenFilesRequest) (*InspectOpenFilesResponse, error)

+ WatchLogs func(*InspectWatchLogsRequest, Inspect_WatchLogsServer) error

+ type InspectWatchLogsChunk struct

+ Message string

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

+ func (*InspectWatchLogsChunk) ProtoMessage()

+ func (m *InspectWatchLogsChunk) GetMessage() string

+ func (m *InspectWatchLogsChunk) Reset()

+ func (m *InspectWatchLogsChunk) String() string

+ type InspectWatchLogsRequest struct

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

+ func (*InspectWatchLogsRequest) ProtoMessage()

+ func (m *InspectWatchLogsRequest) Reset()

+ func (m *InspectWatchLogsRequest) String() string

+ type Inspect_WatchLogsClient interface

+ Recv func() (*InspectWatchLogsChunk, error)

+ type Inspect_WatchLogsServer interface

+ Send func(*InspectWatchLogsChunk) error

+ type InterfaceStat struct

+ Addrs []string

+ Flags []string

+ HardwareAddr string

+ Mtu int32

+ Name string

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

+ func (*InterfaceStat) ProtoMessage()

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

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

+ func (m *InterfaceStat) GetHardwareAddr() string

+ func (m *InterfaceStat) GetMtu() int32

+ func (m *InterfaceStat) GetName() string

+ func (m *InterfaceStat) Reset()

+ func (m *InterfaceStat) String() string

+ type QOSAddHTBShapingRequest struct

+ LinkAlias string

+ LinkName string

+ RateLimitEgress uint64

+ RateLimitIngress uint64

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

+ func (*QOSAddHTBShapingRequest) ProtoMessage()

+ func (m *QOSAddHTBShapingRequest) GetLinkAlias() string

+ func (m *QOSAddHTBShapingRequest) GetLinkName() string

+ func (m *QOSAddHTBShapingRequest) GetRateLimitEgress() uint64

+ func (m *QOSAddHTBShapingRequest) GetRateLimitIngress() uint64

+ func (m *QOSAddHTBShapingRequest) Reset()

+ func (m *QOSAddHTBShapingRequest) String() string

+ type QOSAddHTBShapingResponse struct

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

+ func (*QOSAddHTBShapingResponse) ProtoMessage()

+ func (m *QOSAddHTBShapingResponse) Reset()

+ func (m *QOSAddHTBShapingResponse) String() string

+ type QOSClient interface

+ AddHTBShaping func(ctx context.Context, in *QOSAddHTBShapingRequest, opts ...grpc.CallOption) (*QOSAddHTBShapingResponse, error)

+ RemoveHTBShaping func(ctx context.Context, in *QOSRemoveHTBShapingRequest, opts ...grpc.CallOption) (*QOSRemoveHTBShapingResponse, error)

+ SetAlias func(ctx context.Context, in *QOSSetAliasRequest, opts ...grpc.CallOption) (*QOSSetAliasResponse, error)

+ func NewQOSClient(cc *grpc.ClientConn) QOSClient

+ type QOSRemoveHTBShapingRequest struct

+ LinkName string

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

+ func (*QOSRemoveHTBShapingRequest) ProtoMessage()

+ func (m *QOSRemoveHTBShapingRequest) GetLinkName() string

+ func (m *QOSRemoveHTBShapingRequest) Reset()

+ func (m *QOSRemoveHTBShapingRequest) String() string

+ type QOSRemoveHTBShapingResponse struct

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

+ func (*QOSRemoveHTBShapingResponse) ProtoMessage()

+ func (m *QOSRemoveHTBShapingResponse) Reset()

+ func (m *QOSRemoveHTBShapingResponse) String() string

+ type QOSServer interface

+ AddHTBShaping func(context.Context, *QOSAddHTBShapingRequest) (*QOSAddHTBShapingResponse, error)

+ RemoveHTBShaping func(context.Context, *QOSRemoveHTBShapingRequest) (*QOSRemoveHTBShapingResponse, error)

+ SetAlias func(context.Context, *QOSSetAliasRequest) (*QOSSetAliasResponse, error)

+ type QOSSetAliasRequest struct

+ LinkAlias string

+ LinkName string

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

+ func (*QOSSetAliasRequest) ProtoMessage()

+ func (m *QOSSetAliasRequest) GetLinkAlias() string

+ func (m *QOSSetAliasRequest) GetLinkName() string

+ func (m *QOSSetAliasRequest) Reset()

+ func (m *QOSSetAliasRequest) String() string

+ type QOSSetAliasResponse struct

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

+ func (*QOSSetAliasResponse) ProtoMessage()

+ func (m *QOSSetAliasResponse) Reset()

+ func (m *QOSSetAliasResponse) String() string

+ type WorkerAddCapabilityRequest struct

+ Scope CapabilityScope

+ Subject *EthAddress

+ Ttl uint32

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

+ func (*WorkerAddCapabilityRequest) ProtoMessage()

+ func (m *WorkerAddCapabilityRequest) GetScope() CapabilityScope

+ func (m *WorkerAddCapabilityRequest) GetSubject() *EthAddress

+ func (m *WorkerAddCapabilityRequest) GetTtl() uint32

+ func (m *WorkerAddCapabilityRequest) Reset()

+ func (m *WorkerAddCapabilityRequest) String() string

+ type WorkerAddCapabilityResponse struct

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

+ func (*WorkerAddCapabilityResponse) ProtoMessage()

+ func (m *WorkerAddCapabilityResponse) Reset()

+ func (m *WorkerAddCapabilityResponse) String() string

type WorkerManagementClient

+ AddCapability func(ctx context.Context, in *WorkerAddCapabilityRequest, opts ...grpc.CallOption) (*WorkerAddCapabilityResponse, error)

+ RemoveCapability func(ctx context.Context, in *WorkerRemoveCapabilityRequest, ...) (*WorkerRemoveCapabilityResponse, error)

type WorkerManagementServer

+ AddCapability func(context.Context, *WorkerAddCapabilityRequest) (*WorkerAddCapabilityResponse, error)

+ RemoveCapability func(context.Context, *WorkerRemoveCapabilityRequest) (*WorkerRemoveCapabilityResponse, error)

+ type WorkerRemoveCapabilityRequest struct

+ Scope CapabilityScope

+ Subject *EthAddress

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

+ func (*WorkerRemoveCapabilityRequest) ProtoMessage()

+ func (m *WorkerRemoveCapabilityRequest) GetScope() CapabilityScope

+ func (m *WorkerRemoveCapabilityRequest) GetSubject() *EthAddress

+ func (m *WorkerRemoveCapabilityRequest) Reset()

+ func (m *WorkerRemoveCapabilityRequest) String() string

+ type WorkerRemoveCapabilityResponse struct

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

+ func (*WorkerRemoveCapabilityResponse) ProtoMessage()

+ func (m *WorkerRemoveCapabilityResponse) Reset()

+ func (m *WorkerRemoveCapabilityResponse) String() string

v0.4.20

Dec 14, 2018

Changes in this version

+ func FormatAddrs(addrs ...*Addr) string

type Addr

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

type RAMDevice

+ func (m *RAMDevice) GetFree() uint64

type RendezvousReply

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

v0.4.19

Nov 29, 2018

v0.4.18

Nov 28, 2018

v0.4.17

Nov 28, 2018

Changes in this version

+ const MetricsKeyCPUUtilization

+ const MetricsKeyDiskFree

+ const MetricsKeyDiskFreePercent

+ const MetricsKeyDiskTotal

+ const MetricsKeyGPUFan

+ const MetricsKeyGPUPower

+ const MetricsKeyGPUPrefix

+ const MetricsKeyGPUTemperature

+ const MetricsKeyRAMFree

+ const MetricsKeyRAMFreePercent

+ const MetricsKeyRAMTotal

type Addr

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

type SocketAddr

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

type WorkerManagementClient

+ Metrics func(ctx context.Context, in *WorkerMetricsRequest, opts ...grpc.CallOption) (*WorkerMetricsResponse, error)

type WorkerManagementServer

+ Metrics func(context.Context, *WorkerMetricsRequest) (*WorkerMetricsResponse, error)

+ type WorkerMetricsRequest struct

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

+ func (*WorkerMetricsRequest) ProtoMessage()

+ func (m *WorkerMetricsRequest) Reset()

+ func (m *WorkerMetricsRequest) String() string

+ type WorkerMetricsResponse struct

+ Metrics map[string]float64

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

+ func (*WorkerMetricsResponse) ProtoMessage()

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

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

+ func (m *WorkerMetricsResponse) Reset()

+ func (m *WorkerMetricsResponse) String() string

v0.4.16

Nov 19, 2018

v0.4.15

Nov 16, 2018

Changes in this version

+ type GeoIP struct

+ Country *GeoIPCountry

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

+ func (*GeoIP) ProtoMessage()

+ func (m *GeoIP) GetCountry() *GeoIPCountry

+ func (m *GeoIP) Reset()

+ func (m *GeoIP) String() string

+ type GeoIPCountry struct

+ IsoCode string

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

+ func (*GeoIPCountry) ProtoMessage()

+ func (m *GeoIPCountry) GetIsoCode() string

+ func (m *GeoIPCountry) Reset()

+ func (m *GeoIPCountry) String() string

type NetworkUsage

+ RxBytesRate float64

+ RxDroppedRate float64

+ RxErrorsRate float64

+ RxPacketsRate float64

+ TxBytesRate float64

+ TxDroppedRate float64

+ TxErrorsRate float64

+ TxPacketsRate float64

+ func (m *NetworkUsage) GetRxBytesRate() float64

+ func (m *NetworkUsage) GetRxDroppedRate() float64

+ func (m *NetworkUsage) GetRxErrorsRate() float64

+ func (m *NetworkUsage) GetRxPacketsRate() float64

+ func (m *NetworkUsage) GetTxBytesRate() float64

+ func (m *NetworkUsage) GetTxDroppedRate() float64

+ func (m *NetworkUsage) GetTxErrorsRate() float64

+ func (m *NetworkUsage) GetTxPacketsRate() float64

type PredictSupplierReply

+ OrderIDs []*BigInt

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

type Price

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

type StatusReply

+ Geo *GeoIP

+ func (m *StatusReply) GetGeo() *GeoIP

v0.4.14

Oct 23, 2018

v0.4.13

Oct 18, 2018

Changes in this version

type AskPlan

+ func (m *AskPlan) IsSpot() bool

type AskPlanGPU

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

+ type AskPlanPool struct

+ All *AskPlanResources

+ CommitedFw map[string]*AskPlan

+ CommitedSpot map[string]*AskPlan

+ EjectedPlans map[string]*AskPlan

+ UsedFw map[string]*AskPlan

+ UsedSpot map[string]*AskPlan

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

+ func (*AskPlanPool) ProtoMessage()

+ func (m *AskPlanPool) GetAll() *AskPlanResources

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

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

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

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

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

+ func (m *AskPlanPool) Reset()

+ func (m *AskPlanPool) String() string

type AskPlanResources

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

type BlacklistClient

+ Purge func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ErrorByStringID, error)

type BlacklistServer

+ Purge func(context.Context, *Empty) (*ErrorByStringID, error)

+ type ErrorByStringID struct

+ Response []*ErrorByStringID_Item

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

+ func (*ErrorByStringID) ProtoMessage()

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

+ func (m *ErrorByStringID) Reset()

+ func (m *ErrorByStringID) String() string

+ type ErrorByStringID_Item struct

+ Error string

+ ID string

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

+ func (*ErrorByStringID_Item) ProtoMessage()

+ func (m *ErrorByStringID_Item) GetError() string

+ func (m *ErrorByStringID_Item) GetID() string

+ func (m *ErrorByStringID_Item) Reset()

+ func (m *ErrorByStringID_Item) String() string

type OrderPredictorClient

+ PredictSupplier func(ctx context.Context, in *PredictSupplierRequest, opts ...grpc.CallOption) (*PredictSupplierReply, error)

type OrderPredictorServer

+ PredictSupplier func(context.Context, *PredictSupplierRequest) (*PredictSupplierReply, error)

+ type PredictSupplierReply struct

+ Price *Price

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

+ func (*PredictSupplierReply) ProtoMessage()

+ func (m *PredictSupplierReply) GetPrice() *Price

+ func (m *PredictSupplierReply) Reset()

+ func (m *PredictSupplierReply) String() string

+ type PredictSupplierRequest struct

+ Devices *DevicesReply

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

+ func (*PredictSupplierRequest) ProtoMessage()

+ func (m *PredictSupplierRequest) GetDevices() *DevicesReply

+ func (m *PredictSupplierRequest) Normalize()

+ func (m *PredictSupplierRequest) Reset()

+ func (m *PredictSupplierRequest) String() string

+ func (m *PredictSupplierRequest) Validate() error

+ type PurgeTasksRequest struct

+ DealID *BigInt

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

+ func (*PurgeTasksRequest) ProtoMessage()

+ func (m *PurgeTasksRequest) GetDealID() *BigInt

+ func (m *PurgeTasksRequest) Reset()

+ func (m *PurgeTasksRequest) String() string

type SchedulerData

+ PlanPool *AskPlanPool

+ func (m *SchedulerData) GetPlanPool() *AskPlanPool

+ type TSErrorByStringID struct

+ func NewTSErrorByStringID() *TSErrorByStringID

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

+ func (m *TSErrorByStringID) Unwrap() *ErrorByStringID

+ type TaskPool struct

+ All *AskPlanResources

+ Used map[string]*AskPlanResources

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

+ func (*TaskPool) ProtoMessage()

+ func (m *TaskPool) GetAll() *AskPlanResources

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

+ func (m *TaskPool) Reset()

+ func (m *TaskPool) String() string

type WorkerClient

+ PurgeTasks func(ctx context.Context, in *PurgeTasksRequest, opts ...grpc.CallOption) (*ErrorByStringID, error)

type WorkerManagementClient

+ PurgeAskPlansDetailed func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ErrorByStringID, error)

type WorkerManagementServer

+ PurgeAskPlansDetailed func(context.Context, *Empty) (*ErrorByStringID, error)

type WorkerServer

+ PurgeTasks func(context.Context, *PurgeTasksRequest) (*ErrorByStringID, error)

v0.4.12

Oct 2, 2018

Changes in this version

type Benchmarks

+ func (m *Benchmarks) CPUCryptonight() uint64

+ func (m *Benchmarks) SetCPUCores(v uint64)

+ func (m *Benchmarks) SetGPUCount(v uint64)

type BigInt

+ func (m *BigInt) PricePerHour() string

type DWHClient

+ GetOrdersByIDs func(ctx context.Context, in *OrdersByIDsRequest, opts ...grpc.CallOption) (*DWHOrdersReply, error)

+ GetStats func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*DWHStatsReply, error)

type DWHServer

+ GetOrdersByIDs func(context.Context, *OrdersByIDsRequest) (*DWHOrdersReply, error)

+ GetStats func(context.Context, *Empty) (*DWHStatsReply, error)

+ type DWHStatsReply struct

+ AverageDealDuration uint64

+ CurrentDeals uint64

+ Customers uint64

+ Masters uint64

+ TotalDeals uint64

+ TotalDealsDuration uint64

+ Workers uint64

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

+ func (*DWHStatsReply) ProtoMessage()

+ func (m *DWHStatsReply) GetAverageDealDuration() uint64

+ func (m *DWHStatsReply) GetCurrentDeals() uint64

+ func (m *DWHStatsReply) GetCustomers() uint64

+ func (m *DWHStatsReply) GetMasters() uint64

+ func (m *DWHStatsReply) GetTotalDeals() uint64

+ func (m *DWHStatsReply) GetTotalDealsDuration() uint64

+ func (m *DWHStatsReply) GetWorkers() uint64

+ func (m *DWHStatsReply) Reset()

+ func (m *DWHStatsReply) String() string

+ type OrdersByIDsRequest struct

+ Ids []*BigInt

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

+ func (*OrdersByIDsRequest) ProtoMessage()

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

+ func (m *OrdersByIDsRequest) Reset()

+ func (m *OrdersByIDsRequest) String() string

v0.4.11

Sep 19, 2018

Changes in this version

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

type AskPlanResources

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

type Container

+ PushOnStop bool

+ func (m *Container) GetPushOnStop() bool

+ type MonitoringClient interface

+ MetricsNPP func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*NPPMetricsReply, error)

+ func NewMonitoringClient(cc *grpc.ClientConn) MonitoringClient

+ type MonitoringServer interface

+ MetricsNPP func(context.Context, *Empty) (*NPPMetricsReply, error)

+ type NPPMetricsReply struct

+ Metrics map[string]*NamedMetrics

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

+ func (*NPPMetricsReply) ProtoMessage()

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

+ func (m *NPPMetricsReply) Reset()

+ func (m *NPPMetricsReply) String() string

+ type NamedMetric struct

+ Metric *io_prometheus_client.Metric

+ Name string

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

+ func (*NamedMetric) ProtoMessage()

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

+ func (m *NamedMetric) GetName() string

+ func (m *NamedMetric) Reset()

+ func (m *NamedMetric) String() string

+ type NamedMetrics struct

+ Metrics []*NamedMetric

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

+ func (*NamedMetrics) ProtoMessage()

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

+ func (m *NamedMetrics) Reset()

+ func (m *NamedMetrics) String() string

type StatusReply

+ Admin *EthAddress

+ IsBenchmarkFinished bool

+ IsMasterConfirmed bool

+ Master *EthAddress

+ func (m *StatusReply) GetAdmin() *EthAddress

+ func (m *StatusReply) GetIsBenchmarkFinished() bool

+ func (m *StatusReply) GetIsMasterConfirmed() bool

+ func (m *StatusReply) GetMaster() *EthAddress

v0.4.10

Aug 30, 2018

Changes in this version

+ func CombinedError(status *ErrorByID) error

+ func NewLogReader(client TaskManagement_LogsClient) io.Reader

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

+ type ChangeRequestsRequest struct

+ DealID *BigInt

+ OnlyActive bool

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

+ func (*ChangeRequestsRequest) ProtoMessage()

+ func (m *ChangeRequestsRequest) GetDealID() *BigInt

+ func (m *ChangeRequestsRequest) GetOnlyActive() bool

+ func (m *ChangeRequestsRequest) Reset()

+ func (m *ChangeRequestsRequest) String() string

type DWHClient

+ GetChangeRequests func(ctx context.Context, in *ChangeRequestsRequest, opts ...grpc.CallOption) (*DealChangeRequestsReply, error)

type DWHServer

+ GetChangeRequests func(context.Context, *ChangeRequestsRequest) (*DealChangeRequestsReply, error)

type DealInfoReply

+ PublicIPs []string

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

type DealManagementClient

+ FinishDeals func(ctx context.Context, in *DealsFinishRequest, opts ...grpc.CallOption) (*ErrorByID, error)

+ PurgeDeals func(ctx context.Context, in *DealsPurgeRequest, opts ...grpc.CallOption) (*ErrorByID, error)

type DealManagementServer

+ FinishDeals func(context.Context, *DealsFinishRequest) (*ErrorByID, error)

+ PurgeDeals func(context.Context, *DealsPurgeRequest) (*ErrorByID, error)

+ type DealsFinishRequest struct

+ DealInfo []*DealFinishRequest

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

+ func (*DealsFinishRequest) ProtoMessage()

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

+ func (m *DealsFinishRequest) Reset()

+ func (m *DealsFinishRequest) String() string

+ type DealsPurgeRequest struct

+ BlacklistType BlacklistType

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

+ func (*DealsPurgeRequest) ProtoMessage()

+ func (m *DealsPurgeRequest) GetBlacklistType() BlacklistType

+ func (m *DealsPurgeRequest) Reset()

+ func (m *DealsPurgeRequest) String() string

+ type ErrorByID struct

+ Response []*ErrorByID_Item

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

+ func (*ErrorByID) ProtoMessage()

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

+ func (m *ErrorByID) Reset()

+ func (m *ErrorByID) String() string

+ type ErrorByID_Item struct

+ Error string

+ Id *BigInt

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

+ func (*ErrorByID_Item) ProtoMessage()

+ func (m *ErrorByID_Item) GetError() string

+ func (m *ErrorByID_Item) GetId() *BigInt

+ func (m *ErrorByID_Item) Reset()

+ func (m *ErrorByID_Item) String() string

type MarketClient

+ CancelOrders func(ctx context.Context, in *OrderIDs, opts ...grpc.CallOption) (*ErrorByID, error)

+ PurgeVerbose func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ErrorByID, error)

type MarketServer

+ CancelOrders func(context.Context, *OrderIDs) (*ErrorByID, error)

+ PurgeVerbose func(context.Context, *Empty) (*ErrorByID, error)

+ type OrderIDs struct

+ Ids []*BigInt

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

+ func (*OrderIDs) ProtoMessage()

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

+ func (m *OrderIDs) Reset()

+ func (m *OrderIDs) String() string

+ type OrderPredictorClient interface

+ Predict func(ctx context.Context, in *BidResources, opts ...grpc.CallOption) (*Price, error)

+ func NewOrderPredictorClient(cc *grpc.ClientConn) OrderPredictorClient

+ type OrderPredictorServer interface

+ Predict func(context.Context, *BidResources) (*Price, error)

type RelayClient

+ Info func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*RelayInfo, error)

+ type RelayInfo struct

+ State map[string]*RelayMeeting

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

+ func (*RelayInfo) ProtoMessage()

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

+ func (m *RelayInfo) Reset()

+ func (m *RelayInfo) String() string

+ type RelayMeeting struct

+ Servers map[string]*Addr

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

+ func (*RelayMeeting) ProtoMessage()

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

+ func (m *RelayMeeting) Reset()

+ func (m *RelayMeeting) String() string

type RelayServer

+ Info func(context.Context, *Empty) (*RelayInfo, error)

+ type TSErrorByID struct

+ func NewTSErrorByID() *TSErrorByID

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

+ func (m *TSErrorByID) Unwrap() *ErrorByID

v0.4.9

Aug 15, 2018

Changes in this version

type Deal

+ func (m *Deal) PricePerHour() string

type TokenManagementClient

+ BalanceOf func(ctx context.Context, in *EthAddress, opts ...grpc.CallOption) (*BalanceReply, error)

type TokenManagementServer

+ BalanceOf func(context.Context, *EthAddress) (*BalanceReply, error)

v0.4.8

Aug 7, 2018

Changes in this version

type Order

+ func (m *Order) PricePerHour() string

v0.4.7

Aug 3, 2018

v0.4.6

Aug 1, 2018

Changes in this version

type TaskSpec

+ Tag *TaskTag

+ func (m *TaskSpec) GetTag() *TaskTag

type TaskStatusReply

+ Tag *TaskTag

+ func (m *TaskStatusReply) GetTag() *TaskTag

+ type TaskTag struct

+ Data []byte

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

+ func (*TaskTag) ProtoMessage()

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

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

+ func (m *TaskTag) Reset()

+ func (m *TaskTag) String() string

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

v0.4.5

Jul 24, 2018

Changes in this version

+ const MaxTagLength

type BalanceReply

+ LiveEthBalance *BigInt

+ func (m *BalanceReply) GetLiveEthBalance() *BigInt

type EthAddress

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

type OpenDealRequest

+ Force bool

+ func (m *OpenDealRequest) GetForce() bool

type QuickBuyRequest

+ Force bool

+ func (m *QuickBuyRequest) GetForce() bool

type TokenManagementClient

+ Transfer func(ctx context.Context, in *TokenTransferRequest, opts ...grpc.CallOption) (*Empty, error)

type TokenManagementServer

+ Transfer func(context.Context, *TokenTransferRequest) (*Empty, error)

+ type TokenTransferRequest struct

+ Amount *BigInt

+ To *EthAddress

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

+ func (*TokenTransferRequest) ProtoMessage()

+ func (m *TokenTransferRequest) GetAmount() *BigInt

+ func (m *TokenTransferRequest) GetTo() *EthAddress

+ func (m *TokenTransferRequest) Reset()

+ func (m *TokenTransferRequest) String() string

+ func (m *TokenTransferRequest) Validate() error

v0.4.4

Jul 9, 2018

Changes in this version

type Price

+ func SumPrice(plans []*AskPlan) *Price

v0.4.3

Jul 3, 2018

v0.4.2

Jun 30, 2018

v0.4.1

Jun 30, 2018

Changes in this version

+ const DefaultNPPProtocol

+ const MinCPUPercent

+ const MinDealDuration

+ const MinNetFlagsCount

+ const MinNumBenchmarks

+ const MinRamSize

+ const MinStorageSize

+ const NetworkIncoming

+ const NetworkOutbound

+ const NetworkOverlay

+ var AskPlan_Status_name = map[int32]string

+ var AskPlan_Status_value = map[string]int32

+ var BlacklistOption_name = map[int32]string

+ var BlacklistOption_value = map[string]int32

+ var BlacklistType_name = map[int32]string

+ var BlacklistType_value = map[string]int32

+ var ChangeRequestStatus_name = map[int32]string

+ var ChangeRequestStatus_value = map[string]int32

+ var CmpOp_name = map[int32]string

+ var CmpOp_value = map[string]int32

+ var DeviceType_name = map[int32]string

+ var DeviceType_value = map[string]int32

+ var IdentityLevel_name = map[int32]string

+ var IdentityLevel_value = map[string]int32

+ var Nvidias = []uint64

+ var OrderStatus_name = map[int32]string

+ var OrderStatus_value = map[string]int32

+ var PeerType_name = map[int32]string

+ var PeerType_value = map[string]int32

+ var ProfileRole_name = map[int32]string

+ var ProfileRole_value = map[string]int32

+ var Radeons = []uint64

+ var SortingOrder_name = map[int32]string

+ var SortingOrder_value = map[string]int32

+ var SplittingAlgorithm_name = map[int32]string

+ var SplittingAlgorithm_value = map[string]int32

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

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

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

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

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

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

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

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

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

+ type Addr struct

+ Addr *SocketAddr

+ Protocol string

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

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

+ func (*Addr) ProtoMessage()

+ func (m *Addr) GetAddr() *SocketAddr

+ func (m *Addr) GetProtocol() string

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

+ func (m *Addr) IsPrivate() bool

+ func (m *Addr) IsValid() bool

+ func (m *Addr) Reset()

+ func (m *Addr) String() string

+ type AskPlan struct

+ Blacklist *EthAddress

+ Counterparty *EthAddress

+ CreateTime *Timestamp

+ DealID *BigInt

+ Duration *Duration

+ ID string

+ Identity IdentityLevel

+ LastOrderPlacedTime *Timestamp

+ OrderID *BigInt

+ Price *Price

+ Resources *AskPlanResources

+ Status AskPlan_Status

+ Tag []byte

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

+ func (*AskPlan) ProtoMessage()

+ func (m *AskPlan) GetBlacklist() *EthAddress

+ func (m *AskPlan) GetCounterparty() *EthAddress

+ func (m *AskPlan) GetCreateTime() *Timestamp

+ func (m *AskPlan) GetDealID() *BigInt

+ func (m *AskPlan) GetDuration() *Duration

+ func (m *AskPlan) GetID() string

+ func (m *AskPlan) GetIdentity() IdentityLevel

+ func (m *AskPlan) GetLastOrderPlacedTime() *Timestamp

+ func (m *AskPlan) GetOrderID() *BigInt

+ func (m *AskPlan) GetPrice() *Price

+ func (m *AskPlan) GetResources() *AskPlanResources

+ func (m *AskPlan) GetStatus() AskPlan_Status

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

+ func (m *AskPlan) Reset()

+ func (m *AskPlan) String() string

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

+ func (m *AskPlan) Validate() error

+ type AskPlanCPU struct

+ CorePercents uint64

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

+ func (*AskPlanCPU) ProtoMessage()

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

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

+ func (m *AskPlanCPU) GetCorePercents() uint64

+ func (m *AskPlanCPU) Reset()

+ func (m *AskPlanCPU) String() string

+ type AskPlanGPU struct

+ Hashes []string

+ Indexes []uint64

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

+ func (*AskPlanGPU) ProtoMessage()

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

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

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

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

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

+ func (m *AskPlanGPU) Normalized() bool

+ func (m *AskPlanGPU) Reset()

+ func (m *AskPlanGPU) String() string

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

+ func (m *AskPlanGPU) Validate() error

+ type AskPlanHasher struct

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

+ type AskPlanNetwork struct

+ NetFlags *NetFlags

+ ThroughputIn *DataSizeRate

+ ThroughputOut *DataSizeRate

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

+ func (*AskPlanNetwork) ProtoMessage()

+ func (m *AskPlanNetwork) GetNetFlags() *NetFlags

+ func (m *AskPlanNetwork) GetThroughputIn() *DataSizeRate

+ func (m *AskPlanNetwork) GetThroughputOut() *DataSizeRate

+ func (m *AskPlanNetwork) Reset()

+ func (m *AskPlanNetwork) String() string

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

+ type AskPlanRAM struct

+ Size *DataSize

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

+ func (*AskPlanRAM) ProtoMessage()

+ func (m *AskPlanRAM) GetSize() *DataSize

+ func (m *AskPlanRAM) Reset()

+ func (m *AskPlanRAM) String() string

+ type AskPlanResources struct

+ CPU *AskPlanCPU

+ GPU *AskPlanGPU

+ Network *AskPlanNetwork

+ RAM *AskPlanRAM

+ Storage *AskPlanStorage

+ func NewEmptyAskPlanResources() *AskPlanResources

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

+ func (*AskPlanResources) ProtoMessage()

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

+ func (m *AskPlanResources) CPUQuota() int64

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

+ func (m *AskPlanResources) GetCPU() *AskPlanCPU

+ func (m *AskPlanResources) GetGPU() *AskPlanGPU

+ func (m *AskPlanResources) GetNetwork() *AskPlanNetwork

+ func (m *AskPlanResources) GetRAM() *AskPlanRAM

+ func (m *AskPlanResources) GetStorage() *AskPlanStorage

+ func (m *AskPlanResources) Reset()

+ func (m *AskPlanResources) String() string

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

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

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

+ type AskPlanStorage struct

+ Size *DataSize

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

+ func (*AskPlanStorage) ProtoMessage()

+ func (m *AskPlanStorage) GetSize() *DataSize

+ func (m *AskPlanStorage) Reset()

+ func (m *AskPlanStorage) String() string

+ type AskPlan_Status int32

+ const AskPlan_ACTIVE

+ const AskPlan_PENDING_DELETION

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

+ func (x AskPlan_Status) String() string

+ type AskPlansReply struct

+ AskPlans map[string]*AskPlan

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

+ func (*AskPlansReply) ProtoMessage()

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

+ func (m *AskPlansReply) Reset()

+ func (m *AskPlansReply) String() string

+ type BalanceReply struct

+ LiveBalance *BigInt

+ SideBalance *BigInt

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

+ func (*BalanceReply) ProtoMessage()

+ func (m *BalanceReply) GetLiveBalance() *BigInt

+ func (m *BalanceReply) GetSideBalance() *BigInt

+ func (m *BalanceReply) Reset()

+ func (m *BalanceReply) String() string

+ type Benchmark struct

+ Code string

+ Description string

+ ID uint64

+ Image string

+ Result uint64

+ SplittingAlgorithm SplittingAlgorithm

+ Type DeviceType

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

+ func (*Benchmark) ProtoMessage()

+ func (m *Benchmark) GetCode() string

+ func (m *Benchmark) GetDescription() string

+ func (m *Benchmark) GetID() uint64

+ func (m *Benchmark) GetImage() string

+ func (m *Benchmark) GetResult() uint64

+ func (m *Benchmark) GetSplittingAlgorithm() SplittingAlgorithm

+ func (m *Benchmark) GetType() DeviceType

+ func (m *Benchmark) Reset()

+ func (m *Benchmark) String() string

+ type Benchmarks struct

+ Values []uint64

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

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

+ func (*Benchmarks) ProtoMessage()

+ func (m *Benchmarks) CPUCores() uint64

+ func (m *Benchmarks) CPUSysbenchMulti() uint64

+ func (m *Benchmarks) CPUSysbenchOne() uint64

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

+ func (m *Benchmarks) GPUCashHashrate() uint64

+ func (m *Benchmarks) GPUCount() uint64

+ func (m *Benchmarks) GPUEthHashrate() uint64

+ func (m *Benchmarks) GPUMem() uint64

+ func (m *Benchmarks) GPURedshift() uint64

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

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

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

+ func (m *Benchmarks) NetTrafficIn() uint64

+ func (m *Benchmarks) NetTrafficOut() uint64

+ func (m *Benchmarks) RAMSize() uint64

+ func (m *Benchmarks) Reset()

+ func (m *Benchmarks) StorageSize() uint64

+ func (m *Benchmarks) String() string

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

+ func (m *Benchmarks) Validate() error

+ type BidNetwork struct

+ Incoming bool

+ Outbound bool

+ Overlay bool

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

+ func (*BidNetwork) ProtoMessage()

+ func (m *BidNetwork) GetIncoming() bool

+ func (m *BidNetwork) GetOutbound() bool

+ func (m *BidNetwork) GetOverlay() bool

+ func (m *BidNetwork) Reset()

+ func (m *BidNetwork) String() string

+ type BidOrder struct

+ Blacklist *EthAddress

+ Counterparty *EthAddress

+ Duration *Duration

+ ID string

+ Identity IdentityLevel

+ Price *Price

+ Resources *BidResources

+ Tag string

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

+ func (*BidOrder) ProtoMessage()

+ func (m *BidOrder) GetBlacklist() *EthAddress

+ func (m *BidOrder) GetCounterparty() *EthAddress

+ func (m *BidOrder) GetDuration() *Duration

+ func (m *BidOrder) GetID() string

+ func (m *BidOrder) GetIdentity() IdentityLevel

+ func (m *BidOrder) GetPrice() *Price

+ func (m *BidOrder) GetResources() *BidResources

+ func (m *BidOrder) GetTag() string

+ func (m *BidOrder) Reset()

+ func (m *BidOrder) String() string

+ func (m *BidOrder) Validate() error

+ type BidResources struct

+ Benchmarks map[string]uint64

+ Network *BidNetwork

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

+ func (*BidResources) ProtoMessage()

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

+ func (m *BidResources) GetNetwork() *BidNetwork

+ func (m *BidResources) Reset()

+ func (m *BidResources) String() string

type BigInt

+ func (m *BigInt) IsZero() bool

+ func (m *BigInt) PaddedString() string

+ func (m *BigInt) ToPriceString() string

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

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

+ type BlacklistClient interface

+ List func(ctx context.Context, in *EthAddress, opts ...grpc.CallOption) (*BlacklistReply, error)

+ Remove func(ctx context.Context, in *EthAddress, opts ...grpc.CallOption) (*Empty, error)

+ func NewBlacklistClient(cc *grpc.ClientConn) BlacklistClient

+ type BlacklistOption int32

+ const BlacklistOption_IncludeAndMark

+ const BlacklistOption_OnlyMatching

+ const BlacklistOption_WithoutMatching

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

+ func (x BlacklistOption) String() string

+ type BlacklistQuery struct

+ Option BlacklistOption

+ OwnerID *EthAddress

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

+ func (*BlacklistQuery) ProtoMessage()

+ func (m *BlacklistQuery) GetOption() BlacklistOption

+ func (m *BlacklistQuery) GetOwnerID() *EthAddress

+ func (m *BlacklistQuery) Reset()

+ func (m *BlacklistQuery) String() string

+ type BlacklistReply struct

+ Addresses []string

+ Count uint64

+ OwnerID *EthAddress

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

+ func (*BlacklistReply) ProtoMessage()

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

+ func (m *BlacklistReply) GetCount() uint64

+ func (m *BlacklistReply) GetOwnerID() *EthAddress

+ func (m *BlacklistReply) Reset()

+ func (m *BlacklistReply) String() string

+ type BlacklistRequest struct

+ Limit uint64

+ Offset uint64

+ UserID *EthAddress

+ WithCount bool

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

+ func (*BlacklistRequest) ProtoMessage()

+ func (m *BlacklistRequest) GetLimit() uint64

+ func (m *BlacklistRequest) GetOffset() uint64

+ func (m *BlacklistRequest) GetUserID() *EthAddress

+ func (m *BlacklistRequest) GetWithCount() bool

+ func (m *BlacklistRequest) Reset()

+ func (m *BlacklistRequest) String() string

+ type BlacklistServer interface

+ List func(context.Context, *EthAddress) (*BlacklistReply, error)

+ Remove func(context.Context, *EthAddress) (*Empty, error)

+ type BlacklistType int32

+ const BlacklistType_BLACKLIST_MASTER

+ const BlacklistType_BLACKLIST_NOBODY

+ const BlacklistType_BLACKLIST_WORKER

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

+ func (x BlacklistType) String() string

+ type BlacklistsContainingUserReply struct

+ Blacklists []*EthAddress

+ Count uint64

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

+ func (*BlacklistsContainingUserReply) ProtoMessage()

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

+ func (m *BlacklistsContainingUserReply) GetCount() uint64

+ func (m *BlacklistsContainingUserReply) Reset()

+ func (m *BlacklistsContainingUserReply) String() string

+ type CPU struct

+ Benchmarks map[uint64]*Benchmark

+ Device *CPUDevice

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

+ func (*CPU) ProtoMessage()

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

+ func (m *CPU) GetDevice() *CPUDevice

+ func (m *CPU) Reset()

+ func (m *CPU) String() string

type CPUDevice

+ Sockets uint32

+ func (m *CPUDevice) GetSockets() uint32

+ type Certificate struct

+ Attribute uint64

+ Id *BigInt

+ IdentityLevel uint64

+ OwnerID *EthAddress

+ ValidatorID *EthAddress

+ Value []byte

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

+ func (*Certificate) ProtoMessage()

+ func (m *Certificate) GetAttribute() uint64

+ func (m *Certificate) GetAttributeName() string

+ func (m *Certificate) GetAttributeNameNormalized() string

+ func (m *Certificate) GetId() *BigInt

+ func (m *Certificate) GetIdentityLevel() uint64

+ func (m *Certificate) GetOwnerID() *EthAddress

+ func (m *Certificate) GetValidatorID() *EthAddress

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

+ func (m *Certificate) Reset()

+ func (m *Certificate) String() string

+ type ChangeRequestStatus int32

+ const ChangeRequestStatus_REQUEST_ACCEPTED

+ const ChangeRequestStatus_REQUEST_CANCELED

+ const ChangeRequestStatus_REQUEST_CREATED

+ const ChangeRequestStatus_REQUEST_REJECTED

+ const ChangeRequestStatus_REQUEST_UNKNOWN

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

+ func (x ChangeRequestStatus) String() string

+ type CmpOp int32

+ const CmpOp_EQ

+ const CmpOp_GTE

+ const CmpOp_LTE

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

+ func (x CmpOp) String() string

+ type CmpUint64 struct

+ Operator CmpOp

+ Value uint64

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

+ func (*CmpUint64) ProtoMessage()

+ func (m *CmpUint64) GetOperator() CmpOp

+ func (m *CmpUint64) GetValue() uint64

+ func (m *CmpUint64) Reset()

+ func (m *CmpUint64) String() string

+ type ConnectRequest struct

+ ID []byte

+ PrivateAddrs []*Addr

+ Protocol string

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

+ func (*ConnectRequest) ProtoMessage()

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

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

+ func (m *ConnectRequest) GetProtocol() string

+ func (m *ConnectRequest) Reset()

+ func (m *ConnectRequest) String() string

+ func (m *ConnectRequest) Validate() error

type Container

+ Expose []string

+ Networks []*NetworkSpec

+ RestartPolicy *ContainerRestartPolicy

+ SshKey string

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

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

+ func (m *Container) GetRestartPolicy() *ContainerRestartPolicy

+ func (m *Container) GetSshKey() string

+ func (m *Container) Validate() error

type ContainerRestartPolicy

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

+ type Count struct

+ Count uint64

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

+ func (*Count) ProtoMessage()

+ func (m *Count) GetCount() uint64

+ func (m *Count) Reset()

+ func (m *Count) String() string

+ type DWHClient interface

+ GetBlacklist func(ctx context.Context, in *BlacklistRequest, opts ...grpc.CallOption) (*BlacklistReply, error)

+ GetBlacklistsContainingUser func(ctx context.Context, in *BlacklistRequest, opts ...grpc.CallOption) (*BlacklistsContainingUserReply, error)

+ GetDealChangeRequests func(ctx context.Context, in *BigInt, opts ...grpc.CallOption) (*DealChangeRequestsReply, error)

+ GetDealConditions func(ctx context.Context, in *DealConditionsRequest, opts ...grpc.CallOption) (*DealConditionsReply, error)

+ GetDealDetails func(ctx context.Context, in *BigInt, opts ...grpc.CallOption) (*DWHDeal, error)

+ GetDeals func(ctx context.Context, in *DealsRequest, opts ...grpc.CallOption) (*DWHDealsReply, error)

+ GetMatchingOrders func(ctx context.Context, in *MatchingOrdersRequest, opts ...grpc.CallOption) (*DWHOrdersReply, error)

+ GetOrderDetails func(ctx context.Context, in *BigInt, opts ...grpc.CallOption) (*DWHOrder, error)

+ GetOrders func(ctx context.Context, in *OrdersRequest, opts ...grpc.CallOption) (*DWHOrdersReply, error)

+ GetProfileInfo func(ctx context.Context, in *EthID, opts ...grpc.CallOption) (*Profile, error)

+ GetProfiles func(ctx context.Context, in *ProfilesRequest, opts ...grpc.CallOption) (*ProfilesReply, error)

+ GetValidators func(ctx context.Context, in *ValidatorsRequest, opts ...grpc.CallOption) (*ValidatorsReply, error)

+ GetWorkers func(ctx context.Context, in *WorkersRequest, opts ...grpc.CallOption) (*WorkersReply, error)

+ func NewDWHClient(cc *grpc.ClientConn) DWHClient

+ type DWHDeal struct

+ ActiveChangeRequest bool

+ AskIdentityLevel uint64

+ BidIdentityLevel uint64

+ ConsumerCertificates []byte

+ Deal *Deal

+ Netflags uint64

+ SupplierCertificates []byte

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

+ func (*DWHDeal) ProtoMessage()

+ func (m *DWHDeal) GetActiveChangeRequest() bool

+ func (m *DWHDeal) GetAskIdentityLevel() uint64

+ func (m *DWHDeal) GetBidIdentityLevel() uint64

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

+ func (m *DWHDeal) GetDeal() *Deal

+ func (m *DWHDeal) GetNetflags() uint64

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

+ func (m *DWHDeal) Reset()

+ func (m *DWHDeal) String() string

+ type DWHDealsReply struct

+ Count uint64

+ Deals []*DWHDeal

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

+ func (*DWHDealsReply) ProtoMessage()

+ func (m *DWHDealsReply) GetCount() uint64

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

+ func (m *DWHDealsReply) Reset()

+ func (m *DWHDealsReply) String() string

+ type DWHOrder struct

+ CreatedTS *Timestamp

+ CreatorCertificates []byte

+ CreatorCountry string

+ CreatorIdentityLevel uint64

+ CreatorName string

+ MasterID *EthAddress

+ Order *Order

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

+ func (*DWHOrder) ProtoMessage()

+ func (m *DWHOrder) GetCreatedTS() *Timestamp

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

+ func (m *DWHOrder) GetCreatorCountry() string

+ func (m *DWHOrder) GetCreatorIdentityLevel() uint64

+ func (m *DWHOrder) GetCreatorName() string

+ func (m *DWHOrder) GetMasterID() *EthAddress

+ func (m *DWHOrder) GetOrder() *Order

+ func (m *DWHOrder) Reset()

+ func (m *DWHOrder) String() string

+ type DWHOrdersReply struct

+ Count uint64

+ Orders []*DWHOrder

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

+ func (*DWHOrdersReply) ProtoMessage()

+ func (m *DWHOrdersReply) GetCount() uint64

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

+ func (m *DWHOrdersReply) Reset()

+ func (m *DWHOrdersReply) String() string

+ type DWHServer interface

+ GetBlacklist func(context.Context, *BlacklistRequest) (*BlacklistReply, error)

+ GetBlacklistsContainingUser func(context.Context, *BlacklistRequest) (*BlacklistsContainingUserReply, error)

+ GetDealChangeRequests func(context.Context, *BigInt) (*DealChangeRequestsReply, error)

+ GetDealConditions func(context.Context, *DealConditionsRequest) (*DealConditionsReply, error)

+ GetDealDetails func(context.Context, *BigInt) (*DWHDeal, error)

+ GetDeals func(context.Context, *DealsRequest) (*DWHDealsReply, error)

+ GetMatchingOrders func(context.Context, *MatchingOrdersRequest) (*DWHOrdersReply, error)

+ GetOrderDetails func(context.Context, *BigInt) (*DWHOrder, error)

+ GetOrders func(context.Context, *OrdersRequest) (*DWHOrdersReply, error)

+ GetProfileInfo func(context.Context, *EthID) (*Profile, error)

+ GetProfiles func(context.Context, *ProfilesRequest) (*ProfilesReply, error)

+ GetValidators func(context.Context, *ValidatorsRequest) (*ValidatorsReply, error)

+ GetWorkers func(context.Context, *WorkersRequest) (*WorkersReply, error)

+ type DWHValidator struct

+ Description string

+ Icon string

+ Name string

+ Price *BigInt

+ Url string

+ Validator *Validator

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

+ func (*DWHValidator) ProtoMessage()

+ func (m *DWHValidator) GetDescription() string

+ func (m *DWHValidator) GetIcon() string

+ func (m *DWHValidator) GetName() string

+ func (m *DWHValidator) GetPrice() *BigInt

+ func (m *DWHValidator) GetUrl() string

+ func (m *DWHValidator) GetValidator() *Validator

+ func (m *DWHValidator) Reset()

+ func (m *DWHValidator) String() string

+ type DWHWorker struct

+ Confirmed bool

+ MasterID *EthAddress

+ SlaveID *EthAddress

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

+ func (*DWHWorker) ProtoMessage()

+ func (m *DWHWorker) GetConfirmed() bool

+ func (m *DWHWorker) GetMasterID() *EthAddress

+ func (m *DWHWorker) GetSlaveID() *EthAddress

+ func (m *DWHWorker) Reset()

+ func (m *DWHWorker) String() string

+ type DataSize struct

+ Bytes uint64

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

+ func (*DataSize) ProtoMessage()

+ func (m *DataSize) GetBytes() uint64

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

+ func (m *DataSize) Reset()

+ func (m *DataSize) String() string

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

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

+ type DataSizeRate struct

+ BitsPerSecond uint64

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

+ func (*DataSizeRate) ProtoMessage()

+ func (m *DataSizeRate) GetBitsPerSecond() uint64

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

+ func (m *DataSizeRate) Reset()

+ func (m *DataSizeRate) String() string

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

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

type Deal

+ AskID *BigInt

+ Benchmarks *Benchmarks

+ BidID *BigInt

+ BlockedBalance *BigInt

+ ConsumerID *EthAddress

+ Duration uint64

+ LastBillTS *Timestamp

+ MasterID *EthAddress

+ TotalPayout *BigInt

+ func (m *Deal) GetAskID() *BigInt

+ func (m *Deal) GetBenchmarks() *Benchmarks

+ func (m *Deal) GetBidID() *BigInt

+ func (m *Deal) GetBlockedBalance() *BigInt

+ func (m *Deal) GetConsumerID() *EthAddress

+ func (m *Deal) GetDuration() uint64

+ func (m *Deal) GetLastBillTS() *Timestamp

+ func (m *Deal) GetMasterID() *EthAddress

+ func (m *Deal) GetTotalPayout() *BigInt

+ func (m *Deal) GetTypeName() string

+ func (m *Deal) IsSpot() bool

+ func (m *Deal) TotalPrice() string

+ type DealChangeRequest struct

+ CreatedTS *Timestamp

+ DealID *BigInt

+ Duration uint64

+ Id *BigInt

+ Price *BigInt

+ RequestType OrderType

+ Status ChangeRequestStatus

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

+ func (*DealChangeRequest) ProtoMessage()

+ func (m *DealChangeRequest) GetCreatedTS() *Timestamp

+ func (m *DealChangeRequest) GetDealID() *BigInt

+ func (m *DealChangeRequest) GetDuration() uint64

+ func (m *DealChangeRequest) GetId() *BigInt

+ func (m *DealChangeRequest) GetPrice() *BigInt

+ func (m *DealChangeRequest) GetRequestType() OrderType

+ func (m *DealChangeRequest) GetStatus() ChangeRequestStatus

+ func (m *DealChangeRequest) Reset()

+ func (m *DealChangeRequest) String() string

+ type DealChangeRequestsReply struct

+ Requests []*DealChangeRequest

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

+ func (*DealChangeRequestsReply) ProtoMessage()

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

+ func (m *DealChangeRequestsReply) Reset()

+ func (m *DealChangeRequestsReply) String() string

+ type DealCondition struct

+ ConsumerID *EthAddress

+ DealID *BigInt

+ Duration uint64

+ EndTime *Timestamp

+ Id uint64

+ MasterID *EthAddress

+ Price *BigInt

+ StartTime *Timestamp

+ SupplierID *EthAddress

+ TotalPayout *BigInt

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

+ func (*DealCondition) ProtoMessage()

+ func (m *DealCondition) GetConsumerID() *EthAddress

+ func (m *DealCondition) GetDealID() *BigInt

+ func (m *DealCondition) GetDuration() uint64

+ func (m *DealCondition) GetEndTime() *Timestamp

+ func (m *DealCondition) GetId() uint64

+ func (m *DealCondition) GetMasterID() *EthAddress

+ func (m *DealCondition) GetPrice() *BigInt

+ func (m *DealCondition) GetStartTime() *Timestamp

+ func (m *DealCondition) GetSupplierID() *EthAddress

+ func (m *DealCondition) GetTotalPayout() *BigInt

+ func (m *DealCondition) Reset()

+ func (m *DealCondition) String() string

+ type DealConditionsReply struct

+ Conditions []*DealCondition

+ Count uint64

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

+ func (*DealConditionsReply) ProtoMessage()

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

+ func (m *DealConditionsReply) GetCount() uint64

+ func (m *DealConditionsReply) Reset()

+ func (m *DealConditionsReply) String() string

+ type DealConditionsRequest struct

+ DealID *BigInt

+ Limit uint64

+ Offset uint64

+ Sortings []*SortingOption

+ WithCount bool

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

+ func (*DealConditionsRequest) ProtoMessage()

+ func (m *DealConditionsRequest) GetDealID() *BigInt

+ func (m *DealConditionsRequest) GetLimit() uint64

+ func (m *DealConditionsRequest) GetOffset() uint64

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

+ func (m *DealConditionsRequest) GetWithCount() bool

+ func (m *DealConditionsRequest) Reset()

+ func (m *DealConditionsRequest) String() string

+ type DealFinishRequest struct

+ BlacklistType BlacklistType

+ Id *BigInt

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

+ func (*DealFinishRequest) ProtoMessage()

+ func (m *DealFinishRequest) GetBlacklistType() BlacklistType

+ func (m *DealFinishRequest) GetId() *BigInt

+ func (m *DealFinishRequest) Reset()

+ func (m *DealFinishRequest) String() string

type DealInfoReply

+ Deal *Deal

+ Resources *AskPlanResources

+ func (m *DealInfoReply) GetDeal() *Deal

+ func (m *DealInfoReply) GetResources() *AskPlanResources

type DealManagementClient

+ ApproveChangeRequest func(ctx context.Context, in *BigInt, opts ...grpc.CallOption) (*Empty, error)

+ CancelChangeRequest func(ctx context.Context, in *BigInt, opts ...grpc.CallOption) (*Empty, error)

+ ChangeRequestsList func(ctx context.Context, in *BigInt, opts ...grpc.CallOption) (*DealChangeRequestsReply, error)

+ CreateChangeRequest func(ctx context.Context, in *DealChangeRequest, opts ...grpc.CallOption) (*BigInt, error)

+ Open func(ctx context.Context, in *OpenDealRequest, opts ...grpc.CallOption) (*Deal, error)

+ QuickBuy func(ctx context.Context, in *QuickBuyRequest, opts ...grpc.CallOption) (*DealInfoReply, error)

type DealManagementServer

+ ApproveChangeRequest func(context.Context, *BigInt) (*Empty, error)

+ CancelChangeRequest func(context.Context, *BigInt) (*Empty, error)

+ ChangeRequestsList func(context.Context, *BigInt) (*DealChangeRequestsReply, error)

+ CreateChangeRequest func(context.Context, *DealChangeRequest) (*BigInt, error)

+ Open func(context.Context, *OpenDealRequest) (*Deal, error)

+ QuickBuy func(context.Context, *QuickBuyRequest) (*DealInfoReply, error)

+ type DealPayment struct

+ DealID *BigInt

+ PayedAmount *BigInt

+ PaymentTS *Timestamp

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

+ func (*DealPayment) ProtoMessage()

+ func (m *DealPayment) GetDealID() *BigInt

+ func (m *DealPayment) GetPayedAmount() *BigInt

+ func (m *DealPayment) GetPaymentTS() *Timestamp

+ func (m *DealPayment) Reset()

+ func (m *DealPayment) String() string

type DealStatus

+ const DealStatus_DEAL_ACCEPTED

+ const DealStatus_DEAL_CLOSED

+ const DealStatus_DEAL_UNKNOWN

+ type DealsReply struct

+ Deal []*Deal

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

+ func (*DealsReply) ProtoMessage()

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

+ func (m *DealsReply) Reset()

+ func (m *DealsReply) String() string

+ type DealsRequest struct

+ AnyUserID *EthAddress

+ AskID *BigInt

+ AskIdentityLevel IdentityLevel

+ Benchmarks map[uint64]*MaxMinUint64

+ BidID *BigInt

+ BidIdentityLevel IdentityLevel

+ ConsumerID *EthAddress

+ Duration *MaxMinUint64

+ Limit uint64

+ MasterID *EthAddress

+ Netflags *CmpUint64

+ Offset uint64

+ Price *MaxMinBig

+ Sortings []*SortingOption

+ Status DealStatus

+ SupplierID *EthAddress

+ WithCount bool

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

+ func (*DealsRequest) ProtoMessage()

+ func (m *DealsRequest) GetAnyUserID() *EthAddress

+ func (m *DealsRequest) GetAskID() *BigInt

+ func (m *DealsRequest) GetAskIdentityLevel() IdentityLevel

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

+ func (m *DealsRequest) GetBidID() *BigInt

+ func (m *DealsRequest) GetBidIdentityLevel() IdentityLevel

+ func (m *DealsRequest) GetConsumerID() *EthAddress

+ func (m *DealsRequest) GetDuration() *MaxMinUint64

+ func (m *DealsRequest) GetLimit() uint64

+ func (m *DealsRequest) GetMasterID() *EthAddress

+ func (m *DealsRequest) GetNetflags() *CmpUint64

+ func (m *DealsRequest) GetOffset() uint64

+ func (m *DealsRequest) GetPrice() *MaxMinBig

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

+ func (m *DealsRequest) GetStatus() DealStatus

+ func (m *DealsRequest) GetSupplierID() *EthAddress

+ func (m *DealsRequest) GetWithCount() bool

+ func (m *DealsRequest) Reset()

+ func (m *DealsRequest) String() string

+ type DebugStateReply struct

+ SalesmanData *SalesmanData

+ SchedulerData *SchedulerData

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

+ func (*DebugStateReply) ProtoMessage()

+ func (m *DebugStateReply) GetSalesmanData() *SalesmanData

+ func (m *DebugStateReply) GetSchedulerData() *SchedulerData

+ func (m *DebugStateReply) Reset()

+ func (m *DebugStateReply) String() string

+ type DeviceType int32

+ const DeviceType_DEV_CPU

+ const DeviceType_DEV_GPU

+ const DeviceType_DEV_NETWORK_IN

+ const DeviceType_DEV_NETWORK_OUT

+ const DeviceType_DEV_RAM

+ const DeviceType_DEV_STORAGE

+ const DeviceType_DEV_UNKNOWN

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

+ func (x DeviceType) String() string

type DevicesReply

+ CPU *CPU

+ Network *Network

+ RAM *RAM

+ Storage *Storage

+ func (m *DevicesReply) GetCPU() *CPU

+ func (m *DevicesReply) GetNetwork() *Network

+ func (m *DevicesReply) GetRAM() *RAM

+ func (m *DevicesReply) GetStorage() *Storage

+ type DiscoverResponse struct

+ Addr string

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

+ func (*DiscoverResponse) ProtoMessage()

+ func (m *DiscoverResponse) GetAddr() string

+ func (m *DiscoverResponse) Reset()

+ func (m *DiscoverResponse) String() string

+ type Duration struct

+ Nanoseconds int64

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

+ func (*Duration) ProtoMessage()

+ func (m *Duration) GetNanoseconds() int64

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

+ func (m *Duration) Reset()

+ func (m *Duration) String() string

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

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

+ type EthAddress struct

+ Address []byte

+ func NewEthAddress(addr common.Address) *EthAddress

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

+ func (*EthAddress) ProtoMessage()

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

+ func (m *EthAddress) IsZero() bool

+ func (m *EthAddress) Reset()

+ func (m *EthAddress) String() string

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

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

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

+ type EthID struct

+ Id *EthAddress

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

+ func (*EthID) ProtoMessage()

+ func (m *EthID) GetId() *EthAddress

+ func (m *EthID) Reset()

+ func (m *EthID) String() string

+ type GPU struct

+ Benchmarks map[uint64]*Benchmark

+ Device *GPUDevice

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

+ func (*GPU) ProtoMessage()

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

+ func (m *GPU) GetDevice() *GPUDevice

+ func (m *GPU) Reset()

+ func (m *GPU) String() string

type GPUDevice

+ DeviceID uint64

+ DeviceName string

+ Hash string

+ ID string

+ MajorNumber uint64

+ Memory uint64

+ MinorNumber uint64

+ VendorID uint64

+ func (m *GPUDevice) FillHashID()

+ func (m *GPUDevice) GetDeviceID() uint64

+ func (m *GPUDevice) GetDeviceName() string

+ func (m *GPUDevice) GetHash() string

+ func (m *GPUDevice) GetID() string

+ func (m *GPUDevice) GetMajorNumber() uint64

+ func (m *GPUDevice) GetMemory() uint64

+ func (m *GPUDevice) GetMinorNumber() uint64

+ func (m *GPUDevice) GetVendorID() uint64

+ func (m *GPUDevice) StorageKey() string

+ type GPUHasher interface

+ HashGPU func(indexes []uint64) (hashes []string, err error)

type GPUVendorType

+ const GPUVendorType_FAKE

+ func TypeFromVendorID(v uint64) GPUVendorType

+ type HandshakeRequest struct

+ Addr []byte

+ PeerType PeerType

+ Protocol string

+ Sign []byte

+ UUID string

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

+ func (*HandshakeRequest) ProtoMessage()

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

+ func (m *HandshakeRequest) GetPeerType() PeerType

+ func (m *HandshakeRequest) GetProtocol() string

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

+ func (m *HandshakeRequest) GetUUID() string

+ func (m *HandshakeRequest) HasUUID() bool

+ func (m *HandshakeRequest) Reset()

+ func (m *HandshakeRequest) String() string

+ func (m *HandshakeRequest) Validate() error

+ type HandshakeResponse struct

+ Description string

+ Error int32

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

+ func (*HandshakeResponse) ProtoMessage()

+ func (m *HandshakeResponse) GetDescription() string

+ func (m *HandshakeResponse) GetError() int32

+ func (m *HandshakeResponse) Reset()

+ func (m *HandshakeResponse) String() string

+ type IdentityLevel int32

+ const IdentityLevel_ANONYMOUS

+ const IdentityLevel_IDENTIFIED

+ const IdentityLevel_PROFESSIONAL

+ const IdentityLevel_REGISTERED

+ const IdentityLevel_UNKNOWN

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

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

+ func (x IdentityLevel) String() string

+ type JoinNetworkRequest struct

+ NetworkID string

+ TaskID *TaskID

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

+ func (*JoinNetworkRequest) ProtoMessage()

+ func (m *JoinNetworkRequest) GetNetworkID() string

+ func (m *JoinNetworkRequest) GetTaskID() *TaskID

+ func (m *JoinNetworkRequest) Reset()

+ func (m *JoinNetworkRequest) String() string

type MarketClient

+ Purge func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error)

type MarketServer

+ Purge func(context.Context, *Empty) (*Empty, error)

+ type MasterManagementClient interface

+ WorkerConfirm func(ctx context.Context, in *EthAddress, opts ...grpc.CallOption) (*Empty, error)

+ WorkerRemove func(ctx context.Context, in *WorkerRemoveRequest, opts ...grpc.CallOption) (*Empty, error)

+ WorkersList func(ctx context.Context, in *EthAddress, opts ...grpc.CallOption) (*WorkerListReply, error)

+ func NewMasterManagementClient(cc *grpc.ClientConn) MasterManagementClient

+ type MasterManagementServer interface

+ WorkerConfirm func(context.Context, *EthAddress) (*Empty, error)

+ WorkerRemove func(context.Context, *WorkerRemoveRequest) (*Empty, error)

+ WorkersList func(context.Context, *EthAddress) (*WorkerListReply, error)

+ type MatchingOrdersRequest struct

+ Id *BigInt

+ Limit uint64

+ Offset uint64

+ WithCount bool

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

+ func (*MatchingOrdersRequest) ProtoMessage()

+ func (m *MatchingOrdersRequest) GetId() *BigInt

+ func (m *MatchingOrdersRequest) GetLimit() uint64

+ func (m *MatchingOrdersRequest) GetOffset() uint64

+ func (m *MatchingOrdersRequest) GetWithCount() bool

+ func (m *MatchingOrdersRequest) Reset()

+ func (m *MatchingOrdersRequest) String() string

+ type MaxMinBig struct

+ Max *BigInt

+ Min *BigInt

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

+ func (*MaxMinBig) ProtoMessage()

+ func (m *MaxMinBig) GetMax() *BigInt

+ func (m *MaxMinBig) GetMin() *BigInt

+ func (m *MaxMinBig) Reset()

+ func (m *MaxMinBig) String() string

+ type MaxMinTimestamp struct

+ Max *Timestamp

+ Min *Timestamp

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

+ func (*MaxMinTimestamp) ProtoMessage()

+ func (m *MaxMinTimestamp) GetMax() *Timestamp

+ func (m *MaxMinTimestamp) GetMin() *Timestamp

+ func (m *MaxMinTimestamp) Reset()

+ func (m *MaxMinTimestamp) String() string

+ type MaxMinUint64 struct

+ Max uint64

+ Min uint64

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

+ func (*MaxMinUint64) ProtoMessage()

+ func (m *MaxMinUint64) GetMax() uint64

+ func (m *MaxMinUint64) GetMin() uint64

+ func (m *MaxMinUint64) Reset()

+ func (m *MaxMinUint64) String() string

+ type NetFlags struct

+ Flags uint64

+ func NetFlagsFromBoolSlice(from []bool) *NetFlags

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

+ func (*NetFlags) ProtoMessage()

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

+ func (m *NetFlags) GetFlags() uint64

+ func (m *NetFlags) GetIncoming() bool

+ func (m *NetFlags) GetOutbound() bool

+ func (m *NetFlags) GetOverlay() bool

+ func (m *NetFlags) Reset()

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

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

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

+ func (m *NetFlags) String() string

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

+ type NetMetrics struct

+ RxBytes uint64

+ TxBytes uint64

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

+ func (*NetMetrics) ProtoMessage()

+ func (m *NetMetrics) GetRxBytes() uint64

+ func (m *NetMetrics) GetTxBytes() uint64

+ func (m *NetMetrics) Reset()

+ func (m *NetMetrics) String() string

+ type Network struct

+ BenchmarksIn map[uint64]*Benchmark

+ BenchmarksOut map[uint64]*Benchmark

+ In uint64

+ NetFlags *NetFlags

+ Out uint64

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

+ func (*Network) ProtoMessage()

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

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

+ func (m *Network) GetIn() uint64

+ func (m *Network) GetNetFlags() *NetFlags

+ func (m *Network) GetOut() uint64

+ func (m *Network) HardwareHash() string

+ func (m *Network) Reset()

+ func (m *Network) String() string

+ type NetworkSpec struct

+ Addr string

+ Options map[string]string

+ Subnet string

+ Type string

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

+ func (*NetworkSpec) ProtoMessage()

+ func (m *NetworkSpec) GetAddr() string

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

+ func (m *NetworkSpec) GetSubnet() string

+ func (m *NetworkSpec) GetType() string

+ func (m *NetworkSpec) Reset()

+ func (m *NetworkSpec) String() string

+ type NumericID struct

+ Id uint64

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

+ func (*NumericID) ProtoMessage()

+ func (m *NumericID) GetId() uint64

+ func (m *NumericID) Reset()

+ func (m *NumericID) String() string

+ type OpenDealRequest struct

+ AskID *BigInt

+ BidID *BigInt

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

+ func (*OpenDealRequest) ProtoMessage()

+ func (m *OpenDealRequest) GetAskID() *BigInt

+ func (m *OpenDealRequest) GetBidID() *BigInt

+ func (m *OpenDealRequest) Reset()

+ func (m *OpenDealRequest) String() string

type Order

+ AuthorID *EthAddress

+ Benchmarks *Benchmarks

+ Blacklist string

+ CounterpartyID *EthAddress

+ DealID *BigInt

+ Duration uint64

+ FrozenSum *BigInt

+ IdentityLevel IdentityLevel

+ Netflags *NetFlags

+ OrderStatus OrderStatus

+ Tag []byte

+ func (m *Order) GetAuthorID() *EthAddress

+ func (m *Order) GetBenchmarks() *Benchmarks

+ func (m *Order) GetBlacklist() string

+ func (m *Order) GetCounterpartyID() *EthAddress

+ func (m *Order) GetDealID() *BigInt

+ func (m *Order) GetFrozenSum() *BigInt

+ func (m *Order) GetIdentityLevel() IdentityLevel

+ func (m *Order) GetNetflags() *NetFlags

+ func (m *Order) GetOrderStatus() OrderStatus

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

+ func (m *Order) TotalPrice() string

+ type OrderStatus int32

+ const OrderStatus_ORDER_ACTIVE

+ const OrderStatus_ORDER_INACTIVE

+ const OrderStatus_ORDER_UNKNOWN

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

+ func (x OrderStatus) String() string

+ type OrdersRequest struct

+ AuthorID *EthAddress

+ Benchmarks map[uint64]*MaxMinUint64

+ CounterpartyID []*EthAddress

+ CreatedTS *MaxMinTimestamp

+ CreatorIdentityLevel []IdentityLevel

+ DealID *BigInt

+ Duration *MaxMinUint64

+ Limit uint64

+ MasterID *EthAddress

+ Netflags *CmpUint64

+ Offset uint64

+ Price *MaxMinBig

+ SenderIDs []*EthAddress

+ Sortings []*SortingOption

+ Status OrderStatus

+ Type OrderType

+ WithCount bool

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

+ func (*OrdersRequest) ProtoMessage()

+ func (m *OrdersRequest) GetAuthorID() *EthAddress

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

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

+ func (m *OrdersRequest) GetCreatedTS() *MaxMinTimestamp

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

+ func (m *OrdersRequest) GetDealID() *BigInt

+ func (m *OrdersRequest) GetDuration() *MaxMinUint64

+ func (m *OrdersRequest) GetLimit() uint64

+ func (m *OrdersRequest) GetMasterID() *EthAddress

+ func (m *OrdersRequest) GetNetflags() *CmpUint64

+ func (m *OrdersRequest) GetOffset() uint64

+ func (m *OrdersRequest) GetPrice() *MaxMinBig

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

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

+ func (m *OrdersRequest) GetStatus() OrderStatus

+ func (m *OrdersRequest) GetType() OrderType

+ func (m *OrdersRequest) GetWithCount() bool

+ func (m *OrdersRequest) Reset()

+ func (m *OrdersRequest) String() string

+ type PeerType int32

+ const PeerType_CLIENT

+ const PeerType_DISCOVER

+ const PeerType_SERVER

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

+ func (x PeerType) String() string

+ type Price struct

+ PerSecond *BigInt

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

+ func (*Price) ProtoMessage()

+ func (m *Price) GetPerSecond() *BigInt

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

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

+ func (m *Price) Reset()

+ func (m *Price) String() string

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

+ type Profile struct

+ ActiveAsks uint64

+ ActiveBids uint64

+ Certificates string

+ Country string

+ IdentityLevel uint64

+ IsBlacklisted bool

+ IsCorporation bool

+ IsProfessional bool

+ Name string

+ UserID *EthAddress

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

+ func (*Profile) ProtoMessage()

+ func (m *Profile) GetActiveAsks() uint64

+ func (m *Profile) GetActiveBids() uint64

+ func (m *Profile) GetCertificates() string

+ func (m *Profile) GetCountry() string

+ func (m *Profile) GetIdentityLevel() uint64

+ func (m *Profile) GetIsBlacklisted() bool

+ func (m *Profile) GetIsCorporation() bool

+ func (m *Profile) GetIsProfessional() bool

+ func (m *Profile) GetName() string

+ func (m *Profile) GetUserID() *EthAddress

+ func (m *Profile) Reset()

+ func (m *Profile) String() string

+ type ProfileRole int32

+ const ProfileRole_AnyRole

+ const ProfileRole_Consumer

+ const ProfileRole_Supplier

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

+ func (x ProfileRole) String() string

+ type ProfilesClient interface

+ List func(ctx context.Context, in *ProfilesRequest, opts ...grpc.CallOption) (*ProfilesReply, error)

+ RemoveAttribute func(ctx context.Context, in *BigInt, opts ...grpc.CallOption) (*Empty, error)

+ Status func(ctx context.Context, in *EthID, opts ...grpc.CallOption) (*Profile, error)

+ func NewProfilesClient(cc *grpc.ClientConn) ProfilesClient

+ type ProfilesReply struct

+ Count uint64

+ Profiles []*Profile

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

+ func (*ProfilesReply) ProtoMessage()

+ func (m *ProfilesReply) GetCount() uint64

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

+ func (m *ProfilesReply) Reset()

+ func (m *ProfilesReply) String() string

+ type ProfilesRequest struct

+ BlacklistQuery *BlacklistQuery

+ Country []string

+ Identifier string

+ IdentityLevel IdentityLevel

+ Limit uint64

+ Offset uint64

+ Role ProfileRole

+ Sortings []*SortingOption

+ WithCount bool

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

+ func (*ProfilesRequest) ProtoMessage()

+ func (m *ProfilesRequest) GetBlacklistQuery() *BlacklistQuery

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

+ func (m *ProfilesRequest) GetIdentifier() string

+ func (m *ProfilesRequest) GetIdentityLevel() IdentityLevel

+ func (m *ProfilesRequest) GetLimit() uint64

+ func (m *ProfilesRequest) GetOffset() uint64

+ func (m *ProfilesRequest) GetRole() ProfileRole

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

+ func (m *ProfilesRequest) GetWithCount() bool

+ func (m *ProfilesRequest) Reset()

+ func (m *ProfilesRequest) String() string

+ type ProfilesServer interface

+ List func(context.Context, *ProfilesRequest) (*ProfilesReply, error)

+ RemoveAttribute func(context.Context, *BigInt) (*Empty, error)

+ Status func(context.Context, *EthID) (*Profile, error)

+ type PublishRequest struct

+ PrivateAddrs []*Addr

+ Protocol string

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

+ func (*PublishRequest) ProtoMessage()

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

+ func (m *PublishRequest) GetProtocol() string

+ func (m *PublishRequest) Reset()

+ func (m *PublishRequest) String() string

+ func (m *PublishRequest) Validate() error

+ type QuickBuyRequest struct

+ AskID *BigInt

+ Duration *Duration

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

+ func (*QuickBuyRequest) ProtoMessage()

+ func (m *QuickBuyRequest) GetAskID() *BigInt

+ func (m *QuickBuyRequest) GetDuration() *Duration

+ func (m *QuickBuyRequest) Reset()

+ func (m *QuickBuyRequest) String() string

+ type RAM struct

+ Benchmarks map[uint64]*Benchmark

+ Device *RAMDevice

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

+ func (*RAM) ProtoMessage()

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

+ func (m *RAM) GetDevice() *RAMDevice

+ func (m *RAM) Reset()

+ func (m *RAM) String() string

type RAMDevice

+ Available uint64

+ func (m *RAMDevice) GetAvailable() uint64

+ func (m *RAMDevice) HardwareHash() string

+ type Registry struct

+ Password string

+ Username string

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

+ func (*Registry) ProtoMessage()

+ func (m *Registry) Auth() string

+ func (m *Registry) GetPassword() string

+ func (m *Registry) GetUsername() string

+ func (m *Registry) Reset()

+ func (m *Registry) String() string

+ type RelayClient interface

+ Cluster func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*RelayClusterReply, error)

+ Metrics func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*RelayMetrics, error)

+ func NewRelayClient(cc *grpc.ClientConn) RelayClient

+ type RelayClusterReply struct

+ Members []string

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

+ func (*RelayClusterReply) ProtoMessage()

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

+ func (m *RelayClusterReply) Reset()

+ func (m *RelayClusterReply) String() string

+ type RelayMetrics struct

+ ConnCurrent uint64

+ Net map[string]*NetMetrics

+ Uptime uint64

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

+ func (*RelayMetrics) ProtoMessage()

+ func (m *RelayMetrics) GetConnCurrent() uint64

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

+ func (m *RelayMetrics) GetUptime() uint64

+ func (m *RelayMetrics) Reset()

+ func (m *RelayMetrics) String() string

+ type RelayServer interface

+ Cluster func(context.Context, *Empty) (*RelayClusterReply, error)

+ Metrics func(context.Context, *Empty) (*RelayMetrics, error)

+ type RendezvousClient interface

+ Info func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*RendezvousState, error)

+ Publish func(ctx context.Context, in *PublishRequest, opts ...grpc.CallOption) (*RendezvousReply, error)

+ Resolve func(ctx context.Context, in *ConnectRequest, opts ...grpc.CallOption) (*RendezvousReply, error)

+ ResolveAll func(ctx context.Context, in *ID, opts ...grpc.CallOption) (*ResolveMetaReply, error)

+ func NewRendezvousClient(cc *grpc.ClientConn) RendezvousClient

+ type RendezvousMeeting struct

+ Clients map[string]*RendezvousReply

+ Servers map[string]*RendezvousReply

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

+ func (*RendezvousMeeting) ProtoMessage()

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

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

+ func (m *RendezvousMeeting) Reset()

+ func (m *RendezvousMeeting) String() string

+ type RendezvousReply struct

+ PrivateAddrs []*Addr

+ PublicAddr *Addr

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

+ func (*RendezvousReply) ProtoMessage()

+ func (m *RendezvousReply) Empty() bool

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

+ func (m *RendezvousReply) GetPublicAddr() *Addr

+ func (m *RendezvousReply) Reset()

+ func (m *RendezvousReply) String() string

+ type RendezvousServer interface

+ Info func(context.Context, *Empty) (*RendezvousState, error)

+ Publish func(context.Context, *PublishRequest) (*RendezvousReply, error)

+ Resolve func(context.Context, *ConnectRequest) (*RendezvousReply, error)

+ ResolveAll func(context.Context, *ID) (*ResolveMetaReply, error)

+ type RendezvousState struct

+ State map[string]*RendezvousMeeting

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

+ func (*RendezvousState) ProtoMessage()

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

+ func (m *RendezvousState) Reset()

+ func (m *RendezvousState) String() string

+ type ResolveMetaReply struct

+ IDs []string

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

+ func (*ResolveMetaReply) ProtoMessage()

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

+ func (m *ResolveMetaReply) Reset()

+ func (m *ResolveMetaReply) String() string

+ type ResourcePool struct

+ All *AskPlanResources

+ Used map[string]*AskPlanResources

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

+ func (*ResourcePool) ProtoMessage()

+ func (m *ResourcePool) GetAll() *AskPlanResources

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

+ func (m *ResourcePool) Reset()

+ func (m *ResourcePool) String() string

+ type SalesmanData struct

+ AskPlanCGroups map[string]string

+ Deals map[string]*Deal

+ Orders map[string]*Order

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

+ func (*SalesmanData) ProtoMessage()

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

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

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

+ func (m *SalesmanData) Reset()

+ func (m *SalesmanData) String() string

+ type SchedulerData struct

+ AskPlanPools map[string]*ResourcePool

+ MainPool *ResourcePool

+ TaskToAskPlan map[string]string

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

+ func (*SchedulerData) ProtoMessage()

+ func (m *SchedulerData) GetAskPlanPools() map[string]*ResourcePool

+ func (m *SchedulerData) GetMainPool() *ResourcePool

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

+ func (m *SchedulerData) Reset()

+ func (m *SchedulerData) String() string

type SocketAddr

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

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

+ func (m *SocketAddr) IsPrivate() bool

+ type SortingOption struct

+ Field string

+ Order SortingOrder

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

+ func (*SortingOption) ProtoMessage()

+ func (m *SortingOption) GetField() string

+ func (m *SortingOption) GetOrder() SortingOrder

+ func (m *SortingOption) Reset()

+ func (m *SortingOption) String() string

+ type SortingOrder int32

+ const SortingOrder_Asc

+ const SortingOrder_Desc

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

+ func (x SortingOrder) String() string

+ type SplittingAlgorithm int32

+ const SplittingAlgorithm_MAX

+ const SplittingAlgorithm_MIN

+ const SplittingAlgorithm_NONE

+ const SplittingAlgorithm_PROPORTIONAL

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

+ func (x SplittingAlgorithm) String() string

+ type StartTaskReply struct

+ Id string

+ NetworkIDs []string

+ PortMap map[string]*Endpoints

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

+ func (*StartTaskReply) ProtoMessage()

+ func (m *StartTaskReply) GetId() string

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

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

+ func (m *StartTaskReply) Reset()

+ func (m *StartTaskReply) String() string

+ type StartTaskRequest struct

+ DealID *BigInt

+ Spec *TaskSpec

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

+ func (*StartTaskRequest) ProtoMessage()

+ func (m *StartTaskRequest) GetDealID() *BigInt

+ func (m *StartTaskRequest) GetSpec() *TaskSpec

+ func (m *StartTaskRequest) Reset()

+ func (m *StartTaskRequest) String() string

+ func (m *StartTaskRequest) Validate() error

+ type StatusReply struct

+ DWHStatus string

+ EthAddr string

+ Platform string

+ RendezvousStatus string

+ TaskCount uint32

+ Uptime uint64

+ Version string

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

+ func (*StatusReply) ProtoMessage()

+ func (m *StatusReply) GetDWHStatus() string

+ func (m *StatusReply) GetEthAddr() string

+ func (m *StatusReply) GetPlatform() string

+ func (m *StatusReply) GetRendezvousStatus() string

+ func (m *StatusReply) GetTaskCount() uint32

+ func (m *StatusReply) GetUptime() uint64

+ func (m *StatusReply) GetVersion() string

+ func (m *StatusReply) Reset()

+ func (m *StatusReply) String() string

+ type Storage struct

+ Benchmarks map[uint64]*Benchmark

+ Device *StorageDevice

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

+ func (*Storage) ProtoMessage()

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

+ func (m *Storage) GetDevice() *StorageDevice

+ func (m *Storage) Reset()

+ func (m *Storage) String() string

+ type StorageDevice struct

+ BytesAvailable uint64

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

+ func (*StorageDevice) ProtoMessage()

+ func (m *StorageDevice) GetBytesAvailable() uint64

+ func (m *StorageDevice) HardwareHash() string

+ func (m *StorageDevice) Reset()

+ func (m *StorageDevice) String() string

type TaskID

+ DealID *BigInt

+ func (m *TaskID) GetDealID() *BigInt

type TaskListRequest

+ DealID *BigInt

+ func (m *TaskListRequest) GetDealID() *BigInt

type TaskLogsRequest

+ DealID *BigInt

+ func (m *TaskLogsRequest) GetDealID() *BigInt

type TaskManagementClient

+ JoinNetwork func(ctx context.Context, in *JoinNetworkRequest, opts ...grpc.CallOption) (*NetworkSpec, error)

type TaskManagementServer

+ JoinNetwork func(context.Context, *JoinNetworkRequest) (*NetworkSpec, error)

+ type TaskSpec struct

+ Container *Container

+ Registry *Registry

+ Resources *AskPlanResources

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

+ func (*TaskSpec) ProtoMessage()

+ func (m *TaskSpec) GetContainer() *Container

+ func (m *TaskSpec) GetRegistry() *Registry

+ func (m *TaskSpec) GetResources() *AskPlanResources

+ func (m *TaskSpec) Reset()

+ func (m *TaskSpec) String() string

+ func (m *TaskSpec) Validate() error

type TaskStatusReply

+ AllocatedResources *AskPlanResources

+ PortMap map[string]*Endpoints

+ func (m *TaskStatusReply) GetAllocatedResources() *AskPlanResources

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

type Timestamp

+ func CurrentTimestamp() *Timestamp

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

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

+ type TokenManagementClient interface

+ Balance func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*BalanceReply, error)

+ Deposit func(ctx context.Context, in *BigInt, opts ...grpc.CallOption) (*Empty, error)

+ MarketAllowance func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*BigInt, error)

+ TestTokens func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error)

+ Withdraw func(ctx context.Context, in *BigInt, opts ...grpc.CallOption) (*Empty, error)

+ func NewTokenManagementClient(cc *grpc.ClientConn) TokenManagementClient

+ type TokenManagementServer interface

+ Balance func(context.Context, *Empty) (*BalanceReply, error)

+ Deposit func(context.Context, *BigInt) (*Empty, error)

+ MarketAllowance func(context.Context, *Empty) (*BigInt, error)

+ TestTokens func(context.Context, *Empty) (*Empty, error)

+ Withdraw func(context.Context, *BigInt) (*Empty, error)

+ type Validator struct

+ Id *EthAddress

+ Level uint64

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

+ func (*Validator) ProtoMessage()

+ func (m *Validator) GetId() *EthAddress

+ func (m *Validator) GetLevel() uint64

+ func (m *Validator) Reset()

+ func (m *Validator) String() string

+ type ValidatorsReply struct

+ Count uint64

+ Validators []*DWHValidator

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

+ func (*ValidatorsReply) ProtoMessage()

+ func (m *ValidatorsReply) GetCount() uint64

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

+ func (m *ValidatorsReply) Reset()

+ func (m *ValidatorsReply) String() string

+ type ValidatorsRequest struct

+ Limit uint64

+ Offset uint64

+ Sortings []*SortingOption

+ ValidatorLevel *CmpUint64

+ WithCount bool

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

+ func (*ValidatorsRequest) ProtoMessage()

+ func (m *ValidatorsRequest) GetLimit() uint64

+ func (m *ValidatorsRequest) GetOffset() uint64

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

+ func (m *ValidatorsRequest) GetValidatorLevel() *CmpUint64

+ func (m *ValidatorsRequest) GetWithCount() bool

+ func (m *ValidatorsRequest) Reset()

+ func (m *ValidatorsRequest) String() string

type Volume

+ Options map[string]string

+ Type string

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

+ func (m *Volume) GetType() string

+ type WorkerClient interface

+ GetDealInfo func(ctx context.Context, in *ID, opts ...grpc.CallOption) (*DealInfoReply, error)

+ JoinNetwork func(ctx context.Context, in *WorkerJoinNetworkRequest, opts ...grpc.CallOption) (*NetworkSpec, error)

+ PullTask func(ctx context.Context, in *PullTaskRequest, opts ...grpc.CallOption) (Worker_PullTaskClient, error)

+ PushTask func(ctx context.Context, opts ...grpc.CallOption) (Worker_PushTaskClient, error)

+ StartTask func(ctx context.Context, in *StartTaskRequest, opts ...grpc.CallOption) (*StartTaskReply, error)

+ StopTask func(ctx context.Context, in *ID, opts ...grpc.CallOption) (*Empty, error)

+ TaskLogs func(ctx context.Context, in *TaskLogsRequest, opts ...grpc.CallOption) (Worker_TaskLogsClient, error)

+ TaskStatus func(ctx context.Context, in *ID, opts ...grpc.CallOption) (*TaskStatusReply, error)

+ func NewWorkerClient(cc *grpc.ClientConn) WorkerClient

+ type WorkerJoinNetworkRequest struct

+ NetworkID string

+ TaskID string

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

+ func (*WorkerJoinNetworkRequest) ProtoMessage()

+ func (m *WorkerJoinNetworkRequest) GetNetworkID() string

+ func (m *WorkerJoinNetworkRequest) GetTaskID() string

+ func (m *WorkerJoinNetworkRequest) Reset()

+ func (m *WorkerJoinNetworkRequest) String() string

+ type WorkerListReply struct

+ Workers []*DWHWorker

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

+ func (*WorkerListReply) ProtoMessage()

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

+ func (m *WorkerListReply) Reset()

+ func (m *WorkerListReply) String() string

+ type WorkerManagementClient interface

+ AskPlans func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*AskPlansReply, error)

+ CreateAskPlan func(ctx context.Context, in *AskPlan, opts ...grpc.CallOption) (*ID, error)

+ DebugState func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*DebugStateReply, error)

+ Devices func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*DevicesReply, error)

+ FreeDevices func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*DevicesReply, error)

+ NextMaintenance func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Timestamp, error)

+ PurgeAskPlans func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error)

+ PurgeBenchmarks func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error)

+ RemoveAskPlan func(ctx context.Context, in *ID, opts ...grpc.CallOption) (*Empty, error)

+ RemoveBenchmark func(ctx context.Context, in *NumericID, opts ...grpc.CallOption) (*Empty, error)

+ ScheduleMaintenance func(ctx context.Context, in *Timestamp, opts ...grpc.CallOption) (*Empty, error)

+ Status func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*StatusReply, error)

+ Tasks func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*TaskListReply, error)

+ func NewWorkerManagementClient(cc *grpc.ClientConn) WorkerManagementClient

+ type WorkerManagementServer interface

+ AskPlans func(context.Context, *Empty) (*AskPlansReply, error)

+ CreateAskPlan func(context.Context, *AskPlan) (*ID, error)

+ DebugState func(context.Context, *Empty) (*DebugStateReply, error)

+ Devices func(context.Context, *Empty) (*DevicesReply, error)

+ FreeDevices func(context.Context, *Empty) (*DevicesReply, error)

+ NextMaintenance func(context.Context, *Empty) (*Timestamp, error)

+ PurgeAskPlans func(context.Context, *Empty) (*Empty, error)

+ PurgeBenchmarks func(context.Context, *Empty) (*Empty, error)

+ RemoveAskPlan func(context.Context, *ID) (*Empty, error)

+ RemoveBenchmark func(context.Context, *NumericID) (*Empty, error)

+ ScheduleMaintenance func(context.Context, *Timestamp) (*Empty, error)

+ Status func(context.Context, *Empty) (*StatusReply, error)

+ Tasks func(context.Context, *Empty) (*TaskListReply, error)

+ type WorkerRemoveRequest struct

+ Master *EthAddress

+ Worker *EthAddress

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

+ func (*WorkerRemoveRequest) ProtoMessage()

+ func (m *WorkerRemoveRequest) GetMaster() *EthAddress

+ func (m *WorkerRemoveRequest) GetWorker() *EthAddress

+ func (m *WorkerRemoveRequest) Reset()

+ func (m *WorkerRemoveRequest) String() string

+ type WorkerServer interface

+ GetDealInfo func(context.Context, *ID) (*DealInfoReply, error)

+ JoinNetwork func(context.Context, *WorkerJoinNetworkRequest) (*NetworkSpec, error)

+ PullTask func(*PullTaskRequest, Worker_PullTaskServer) error

+ PushTask func(Worker_PushTaskServer) error

+ StartTask func(context.Context, *StartTaskRequest) (*StartTaskReply, error)

+ StopTask func(context.Context, *ID) (*Empty, error)

+ TaskLogs func(*TaskLogsRequest, Worker_TaskLogsServer) error

+ TaskStatus func(context.Context, *ID) (*TaskStatusReply, error)

+ type Worker_PullTaskClient interface

+ Recv func() (*Chunk, error)

+ type Worker_PullTaskServer interface

+ Send func(*Chunk) error

+ type Worker_PushTaskClient interface

+ Recv func() (*Progress, error)

+ Send func(*Chunk) error

+ type Worker_PushTaskServer interface

+ Recv func() (*Chunk, error)

+ Send func(*Progress) error

+ type Worker_TaskLogsClient interface

+ Recv func() (*TaskLogsChunk, error)

+ type Worker_TaskLogsServer interface

+ Send func(*TaskLogsChunk) error

+ type WorkersReply struct

+ Count uint64

+ Workers []*DWHWorker

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

+ func (*WorkersReply) ProtoMessage()

+ func (m *WorkersReply) GetCount() uint64

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

+ func (m *WorkersReply) Reset()

+ func (m *WorkersReply) String() string

+ type WorkersRequest struct

+ Limit uint64

+ MasterID *EthAddress

+ Offset uint64

+ WithCount bool

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

+ func (*WorkersRequest) ProtoMessage()

+ func (m *WorkersRequest) GetLimit() uint64

+ func (m *WorkersRequest) GetMasterID() *EthAddress

+ func (m *WorkersRequest) GetOffset() uint64

+ func (m *WorkersRequest) GetWithCount() bool

+ func (m *WorkersRequest) Reset()

+ func (m *WorkersRequest) String() string

v0.4.0-rc1

Jun 22, 2018

v0.4.0-alpha3

Jun 8, 2018

v0.4.0-alpha2

Jun 4, 2018

v0.4.0-alpha1

May 30, 2018

v0.3.5

Mar 1, 2018

v0.3.3

Feb 9, 2018

v0.3.2

Feb 9, 2018

Changes in this version

+ var GPUVendorType_name = map[int32]string

+ var GPUVendorType_value = map[string]int32

+ var ResolveRequest_EndpointType_name = map[int32]string

+ var ResolveRequest_EndpointType_value = map[string]int32

type AnnounceRequest

+ ClientEndpoints []string

+ WorkerEndpoints []string

+ func (m *AnnounceRequest) GetClientEndpoints() []string

+ func (m *AnnounceRequest) GetWorkerEndpoints() []string

+ type ApproveDealRequest struct

+ AskID string

+ BidID string

+ DealID *BigInt

+ func (*ApproveDealRequest) Descriptor() ([]byte, []int)

+ func (*ApproveDealRequest) ProtoMessage()

+ func (m *ApproveDealRequest) GetAskID() string

+ func (m *ApproveDealRequest) GetBidID() string

+ func (m *ApproveDealRequest) GetDealID() *BigInt

+ func (m *ApproveDealRequest) Reset()

+ func (m *ApproveDealRequest) String() string

+ type BigInt struct

+ Abs []byte

+ Neg bool

+ func NewBigInt(v *big.Int) *BigInt

+ func NewBigIntFromInt(v int64) *BigInt

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

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

+ func (*BigInt) ProtoMessage()

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

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

+ func (m *BigInt) GetNeg() bool

+ func (m *BigInt) Reset()

+ func (m *BigInt) String() string

+ func (m *BigInt) UnmarshalJSON(data []byte) error

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

+ func (m BigInt) MarshalJSON() ([]byte, error)

+ type Container struct

+ Auth string

+ CommitOnStop bool

+ Env map[string]string

+ Image string

+ Mounts []string

+ PublicKeyData string

+ Registry string

+ Volumes map[string]*Volume

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

+ func (*Container) ProtoMessage()

+ func (m *Container) GetAuth() string

+ func (m *Container) GetCommitOnStop() bool

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

+ func (m *Container) GetImage() string

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

+ func (m *Container) GetPublicKeyData() string

+ func (m *Container) GetRegistry() string

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

+ func (m *Container) Reset()

+ func (m *Container) String() string

type DealInfoReply

+ Completed *StatusMapReply

+ Running *StatusMapReply

+ func (m *DealInfoReply) GetCompleted() *StatusMapReply

+ func (m *DealInfoReply) GetRunning() *StatusMapReply

+ type DealStatusReply struct

+ Deal *Deal

+ Info *DealInfoReply

+ func (*DealStatusReply) Descriptor() ([]byte, []int)

+ func (*DealStatusReply) ProtoMessage()

+ func (m *DealStatusReply) GetDeal() *Deal

+ func (m *DealStatusReply) GetInfo() *DealInfoReply

+ func (m *DealStatusReply) Reset()

+ func (m *DealStatusReply) String() string

+ type Endpoints struct

+ Endpoints []*SocketAddr

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

+ func (*Endpoints) ProtoMessage()

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

+ func (m *Endpoints) Reset()

+ func (m *Endpoints) String() string

type GPUDevice

+ VendorType GPUVendorType

+ func (m *GPUDevice) GetVendorType() GPUVendorType

+ type GPUVendorType int32

+ const GPUVendorType_GPU_UNKNOWN

+ const GPUVendorType_NVIDIA

+ const GPUVendorType_RADEON

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

+ func (x GPUVendorType) String() string

type HubClient

+ ApproveDeal func(ctx context.Context, in *ApproveDealRequest, opts ...grpc.CallOption) (*Empty, error)

type HubServer

+ ApproveDeal func(context.Context, *ApproveDealRequest) (*Empty, error)

type HubStartTaskRequest

+ Container *Container

+ func (m *HubStartTaskRequest) GetContainer() *Container

type InsertSlotRequest

+ PricePerSecond *BigInt

+ func (m *InsertSlotRequest) GetPricePerSecond() *BigInt

type MarketClient

+ TouchOrders func(ctx context.Context, in *TouchOrdersRequest, opts ...grpc.CallOption) (*Empty, error)

type MarketServer

+ TouchOrders func(context.Context, *TouchOrdersRequest) (*Empty, error)

type MinerStartReply

+ PortMap map[string]*Endpoints

+ func (m *MinerStartReply) GetPortMap() map[string]*Endpoints

type MinerStartRequest

+ Container *Container

+ func (m *MinerStartRequest) GetContainer() *Container

type NATType

+ func NewNATType(nat stun.NATType) NATType

type Order

+ PricePerSecond *BigInt

+ func (m *Order) GetDuration() time.Duration

+ func (m *Order) GetPricePerSecond() *BigInt

type ResolveReply

+ Endpoints []string

+ func (m *ResolveReply) GetEndpoints() []string

type ResolveRequest

+ EndpointType ResolveRequest_EndpointType

+ func (m *ResolveRequest) GetEndpointType() ResolveRequest_EndpointType

+ type ResolveRequest_EndpointType int32

+ const ResolveRequest_ANY

+ const ResolveRequest_CLIENT

+ const ResolveRequest_WORKER

+ func (ResolveRequest_EndpointType) EnumDescriptor() ([]byte, []int)

+ func (x ResolveRequest_EndpointType) String() string

type Timestamp

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

+ type TouchOrdersRequest struct

+ IDs []string

+ func (*TouchOrdersRequest) Descriptor() ([]byte, []int)

+ func (*TouchOrdersRequest) ProtoMessage()

+ func (m *TouchOrdersRequest) GetIDs() []string

+ func (m *TouchOrdersRequest) Reset()

+ func (m *TouchOrdersRequest) String() string

+ type Volume struct

+ Driver string

+ Settings map[string]string

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

+ func (*Volume) ProtoMessage()

+ func (m *Volume) GetDriver() string

+ func (m *Volume) GetSettings() map[string]string

+ func (m *Volume) Reset()

+ func (m *Volume) String() string

v0.3.0

Dec 25, 2017

Changes in this version

+ var DealStatus_name = map[int32]string

+ var DealStatus_value = map[string]int32

+ var GPUCount_name = map[int32]string

+ var GPUCount_value = map[string]int32

+ var NATType_name = map[int32]string

+ var NATType_value = map[string]int32

+ var NetworkType_name = map[int32]string

+ var NetworkType_value = map[string]int32

+ var OrderType_name = map[int32]string

+ var OrderType_value = map[string]int32

+ var TaskLogsRequest_Type_name = map[int32]string

+ var TaskLogsRequest_Type_value = map[string]int32

+ var TaskStatusReply_Status_name = map[int32]string

+ var TaskStatusReply_Status_value = map[string]int32

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

+ func RegisterHubManagementServer(s *grpc.Server, srv HubManagementServer)

+ func RegisterHubServer(s *grpc.Server, srv HubServer)

+ func RegisterLocatorServer(s *grpc.Server, srv LocatorServer)

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

+ func RegisterMinerServer(s *grpc.Server, srv MinerServer)

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

+ type AddSlotRequest struct

+ ID string

+ Slot *Slot

+ func (*AddSlotRequest) Descriptor() ([]byte, []int)

+ func (*AddSlotRequest) ProtoMessage()

+ func (m *AddSlotRequest) GetID() string

+ func (m *AddSlotRequest) GetSlot() *Slot

+ func (m *AddSlotRequest) Reset()

+ func (m *AddSlotRequest) String() string

+ type AnnounceRequest struct

+ IpAddr []string

+ func (*AnnounceRequest) Descriptor() ([]byte, []int)

+ func (*AnnounceRequest) ProtoMessage()

+ func (m *AnnounceRequest) GetIpAddr() []string

+ func (m *AnnounceRequest) Reset()

+ func (m *AnnounceRequest) String() string

+ type AvailableResources struct

+ CPUPeriod int64

+ CPUQuota int64

+ CPURealtimePeriod int64

+ CPURealtimeRuntime int64

+ Cgroup string

+ CgroupParent string

+ CpusetCpus string

+ CpusetMems string

+ DiskQuota int64

+ KernelMemory int64

+ Memory uint64

+ MemoryReservation int64

+ MemorySwap int64

+ NumCPUs int64

+ NumGPUs int64

+ PidsLimit int64

+ func (*AvailableResources) Descriptor() ([]byte, []int)

+ func (*AvailableResources) ProtoMessage()

+ func (m *AvailableResources) GetCPUPeriod() int64

+ func (m *AvailableResources) GetCPUQuota() int64

+ func (m *AvailableResources) GetCPURealtimePeriod() int64

+ func (m *AvailableResources) GetCPURealtimeRuntime() int64

+ func (m *AvailableResources) GetCgroup() string

+ func (m *AvailableResources) GetCgroupParent() string

+ func (m *AvailableResources) GetCpusetCpus() string

+ func (m *AvailableResources) GetCpusetMems() string

+ func (m *AvailableResources) GetDiskQuota() int64

+ func (m *AvailableResources) GetKernelMemory() int64

+ func (m *AvailableResources) GetMemory() uint64

+ func (m *AvailableResources) GetMemoryReservation() int64

+ func (m *AvailableResources) GetMemorySwap() int64

+ func (m *AvailableResources) GetNumCPUs() int64

+ func (m *AvailableResources) GetNumGPUs() int64

+ func (m *AvailableResources) GetPidsLimit() int64

+ func (m *AvailableResources) Reset()

+ func (m *AvailableResources) String() string

+ type CPUDevice struct

+ CacheSize int32

+ ClockFrequency float64

+ Cores int32

+ Flags []string

+ Model string

+ ModelName string

+ Num int32

+ Stepping int32

+ VendorId string

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

+ func (*CPUDevice) ProtoMessage()

+ func (m *CPUDevice) GetCacheSize() int32

+ func (m *CPUDevice) GetClockFrequency() float64

+ func (m *CPUDevice) GetCores() int32

+ func (m *CPUDevice) GetFlags() []string

+ func (m *CPUDevice) GetModel() string

+ func (m *CPUDevice) GetModelName() string

+ func (m *CPUDevice) GetNum() int32

+ func (m *CPUDevice) GetStepping() int32

+ func (m *CPUDevice) GetVendorId() string

+ func (m *CPUDevice) Reset()

+ func (m *CPUDevice) String() string

+ type CPUDeviceInfo struct

+ Device *CPUDevice

+ Miners []string

+ func (*CPUDeviceInfo) Descriptor() ([]byte, []int)

+ func (*CPUDeviceInfo) ProtoMessage()

+ func (m *CPUDeviceInfo) GetDevice() *CPUDevice

+ func (m *CPUDeviceInfo) GetMiners() []string

+ func (m *CPUDeviceInfo) Reset()

+ func (m *CPUDeviceInfo) String() string

+ type CPUUsage struct

+ Total uint64

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

+ func (*CPUUsage) ProtoMessage()

+ func (m *CPUUsage) GetTotal() uint64

+ func (m *CPUUsage) Reset()

+ func (m *CPUUsage) String() string

+ type Capabilities struct

+ Cpu []*CPUDevice

+ Gpu []*GPUDevice

+ Mem *RAMDevice

+ func (*Capabilities) Descriptor() ([]byte, []int)

+ func (*Capabilities) ProtoMessage()

+ func (m *Capabilities) GetCpu() []*CPUDevice

+ func (m *Capabilities) GetGpu() []*GPUDevice

+ func (m *Capabilities) GetMem() *RAMDevice

+ func (m *Capabilities) Reset()

+ func (m *Capabilities) String() string

+ type Chunk struct

+ Chunk []byte

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

+ func (*Chunk) ProtoMessage()

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

+ func (m *Chunk) Reset()

+ func (m *Chunk) String() string

+ type CompletedTask struct

+ EndTime *Timestamp

+ Id *ID

+ Image string

+ func (*CompletedTask) Descriptor() ([]byte, []int)

+ func (*CompletedTask) ProtoMessage()

+ func (m *CompletedTask) GetEndTime() *Timestamp

+ func (m *CompletedTask) GetId() *ID

+ func (m *CompletedTask) GetImage() string

+ func (m *CompletedTask) Reset()

+ func (m *CompletedTask) String() string

+ type ContainerRestartPolicy struct

+ MaximumRetryCount uint32

+ Name string

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

+ func (*ContainerRestartPolicy) ProtoMessage()

+ func (m *ContainerRestartPolicy) GetMaximumRetryCount() uint32

+ func (m *ContainerRestartPolicy) GetName() string

+ func (m *ContainerRestartPolicy) Reset()

+ func (m *ContainerRestartPolicy) String() string

+ type Deal struct

+ BuyerID string

+ EndTime *Timestamp

+ Id string

+ Price string

+ SpecificationHash string

+ StartTime *Timestamp

+ Status DealStatus

+ SupplierID string

+ WorkTime uint64

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

+ func (*Deal) ProtoMessage()

+ func (m *Deal) GetBuyerID() string

+ func (m *Deal) GetEndTime() *Timestamp

+ func (m *Deal) GetId() string

+ func (m *Deal) GetPrice() string

+ func (m *Deal) GetSpecificationHash() string

+ func (m *Deal) GetStartTime() *Timestamp

+ func (m *Deal) GetStatus() DealStatus

+ func (m *Deal) GetSupplierID() string

+ func (m *Deal) GetWorkTime() uint64

+ func (m *Deal) Reset()

+ func (m *Deal) String() string

+ type DealInfoReply struct

+ Id *ID

+ Order *Order

+ TasksCompleted []*CompletedTask

+ TasksRunning []*ID

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

+ func (*DealInfoReply) ProtoMessage()

+ func (m *DealInfoReply) GetId() *ID

+ func (m *DealInfoReply) GetOrder() *Order

+ func (m *DealInfoReply) GetTasksCompleted() []*CompletedTask

+ func (m *DealInfoReply) GetTasksRunning() []*ID

+ func (m *DealInfoReply) Reset()

+ func (m *DealInfoReply) String() string

+ type DealListReply struct

+ Deal []*Deal

+ func (*DealListReply) Descriptor() ([]byte, []int)

+ func (*DealListReply) ProtoMessage()

+ func (m *DealListReply) GetDeal() []*Deal

+ func (m *DealListReply) Reset()

+ func (m *DealListReply) String() string

+ type DealListRequest struct

+ Owner string

+ Status DealStatus

+ func (*DealListRequest) Descriptor() ([]byte, []int)

+ func (*DealListRequest) ProtoMessage()

+ func (m *DealListRequest) GetOwner() string

+ func (m *DealListRequest) GetStatus() DealStatus

+ func (m *DealListRequest) Reset()

+ func (m *DealListRequest) String() string

+ type DealManagementClient interface

+ Finish func(ctx context.Context, in *ID, opts ...grpc.CallOption) (*Empty, error)

+ List func(ctx context.Context, in *DealListRequest, opts ...grpc.CallOption) (*DealListReply, error)

+ Status func(ctx context.Context, in *ID, opts ...grpc.CallOption) (*Deal, error)

+ func NewDealManagementClient(cc *grpc.ClientConn) DealManagementClient

+ type DealManagementServer interface

+ Finish func(context.Context, *ID) (*Empty, error)

+ List func(context.Context, *DealListRequest) (*DealListReply, error)

+ Status func(context.Context, *ID) (*Deal, error)

+ type DealRequest struct

+ AskId string

+ BidId string

+ SpecHash string

+ func (*DealRequest) Descriptor() ([]byte, []int)

+ func (*DealRequest) ProtoMessage()

+ func (m *DealRequest) GetAskId() string

+ func (m *DealRequest) GetBidId() string

+ func (m *DealRequest) GetSpecHash() string

+ func (m *DealRequest) Reset()

+ func (m *DealRequest) String() string

+ type DealStatus int32

+ const DealStatus_ACCEPTED

+ const DealStatus_ANY_STATUS

+ const DealStatus_CLOSED

+ const DealStatus_PENDING

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

+ func (x DealStatus) String() string

+ type DevicesReply struct

+ CPUs map[string]*CPUDeviceInfo

+ GPUs map[string]*GPUDeviceInfo

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

+ func (*DevicesReply) ProtoMessage()

+ func (m *DevicesReply) GetCPUs() map[string]*CPUDeviceInfo

+ func (m *DevicesReply) GetGPUs() map[string]*GPUDeviceInfo

+ func (m *DevicesReply) Reset()

+ func (m *DevicesReply) String() string

+ type DiscoverHubRequest struct

+ Endpoint string

+ func (*DiscoverHubRequest) Descriptor() ([]byte, []int)

+ func (*DiscoverHubRequest) ProtoMessage()

+ func (m *DiscoverHubRequest) GetEndpoint() string

+ func (m *DiscoverHubRequest) Reset()

+ func (m *DiscoverHubRequest) String() string

+ type Empty struct

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

+ func (*Empty) ProtoMessage()

+ func (m *Empty) Reset()

+ func (m *Empty) String() string

+ type GPUCount int32

+ const GPUCount_MULTIPLE_GPU

+ const GPUCount_NO_GPU

+ const GPUCount_SINGLE_GPU

+ func (GPUCount) EnumDescriptor() ([]byte, []int)

+ func (x GPUCount) String() string

+ type GPUDevice struct

+ MaxClockFrequency uint64

+ MaxMemorySize uint64

+ Name string

+ OpenCLDeviceVersionMajor int32

+ OpenCLDeviceVersionMinor int32

+ VendorId uint64

+ VendorName string

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

+ func (*GPUDevice) ProtoMessage()

+ func (m *GPUDevice) GetMaxClockFrequency() uint64

+ func (m *GPUDevice) GetMaxMemorySize() uint64

+ func (m *GPUDevice) GetName() string

+ func (m *GPUDevice) GetOpenCLDeviceVersionMajor() int32

+ func (m *GPUDevice) GetOpenCLDeviceVersionMinor() int32

+ func (m *GPUDevice) GetVendorId() uint64

+ func (m *GPUDevice) GetVendorName() string

+ func (m *GPUDevice) Reset()

+ func (m *GPUDevice) String() string

+ type GPUDeviceInfo struct

+ Device *GPUDevice

+ Miners []string

+ func (*GPUDeviceInfo) Descriptor() ([]byte, []int)

+ func (*GPUDeviceInfo) ProtoMessage()

+ func (m *GPUDeviceInfo) GetDevice() *GPUDevice

+ func (m *GPUDeviceInfo) GetMiners() []string

+ func (m *GPUDeviceInfo) Reset()

+ func (m *GPUDeviceInfo) String() string

+ type Geo struct

+ City string

+ Country string

+ Lat float32

+ Lon float32

+ func (*Geo) Descriptor() ([]byte, []int)

+ func (*Geo) ProtoMessage()

+ func (m *Geo) GetCity() string

+ func (m *Geo) GetCountry() string

+ func (m *Geo) GetLat() float32

+ func (m *Geo) GetLon() float32

+ func (m *Geo) Reset()

+ func (m *Geo) String() string

+ type GetAllSlotsReply struct

+ Slots map[string]*GetAllSlotsReply_SlotList

+ func (*GetAllSlotsReply) Descriptor() ([]byte, []int)

+ func (*GetAllSlotsReply) ProtoMessage()

+ func (m *GetAllSlotsReply) GetSlots() map[string]*GetAllSlotsReply_SlotList

+ func (m *GetAllSlotsReply) Reset()

+ func (m *GetAllSlotsReply) String() string

+ type GetAllSlotsReply_SlotList struct

+ Slot []*Slot

+ func (*GetAllSlotsReply_SlotList) Descriptor() ([]byte, []int)

+ func (*GetAllSlotsReply_SlotList) ProtoMessage()

+ func (m *GetAllSlotsReply_SlotList) GetSlot() []*Slot

+ func (m *GetAllSlotsReply_SlotList) Reset()

+ func (m *GetAllSlotsReply_SlotList) String() string

+ type GetDevicePropertiesReply struct

+ Properties map[string]float64

+ func (*GetDevicePropertiesReply) Descriptor() ([]byte, []int)

+ func (*GetDevicePropertiesReply) ProtoMessage()

+ func (m *GetDevicePropertiesReply) GetProperties() map[string]float64

+ func (m *GetDevicePropertiesReply) Reset()

+ func (m *GetDevicePropertiesReply) String() string

+ type GetOrdersReply struct

+ Orders []*Order

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

+ func (*GetOrdersReply) ProtoMessage()

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

+ func (m *GetOrdersReply) Reset()

+ func (m *GetOrdersReply) String() string

+ type GetOrdersRequest struct

+ Count uint64

+ Order *Order

+ func (*GetOrdersRequest) Descriptor() ([]byte, []int)

+ func (*GetOrdersRequest) ProtoMessage()

+ func (m *GetOrdersRequest) GetCount() uint64

+ func (m *GetOrdersRequest) GetOrder() *Order

+ func (m *GetOrdersRequest) Reset()

+ func (m *GetOrdersRequest) String() string

+ type GetProcessingReply struct

+ Orders map[string]*GetProcessingReply_ProcessedOrder

+ func (*GetProcessingReply) Descriptor() ([]byte, []int)

+ func (*GetProcessingReply) ProtoMessage()

+ func (m *GetProcessingReply) GetOrders() map[string]*GetProcessingReply_ProcessedOrder

+ func (m *GetProcessingReply) Reset()

+ func (m *GetProcessingReply) String() string

+ type GetProcessingReply_ProcessedOrder struct

+ Extra string

+ Id string

+ Status uint32

+ Timestamp *Timestamp

+ func (*GetProcessingReply_ProcessedOrder) Descriptor() ([]byte, []int)

+ func (*GetProcessingReply_ProcessedOrder) ProtoMessage()

+ func (m *GetProcessingReply_ProcessedOrder) GetExtra() string

+ func (m *GetProcessingReply_ProcessedOrder) GetId() string

+ func (m *GetProcessingReply_ProcessedOrder) GetStatus() uint32

+ func (m *GetProcessingReply_ProcessedOrder) GetTimestamp() *Timestamp

+ func (m *GetProcessingReply_ProcessedOrder) Reset()

+ func (m *GetProcessingReply_ProcessedOrder) String() string

+ type GetRegisteredWorkersReply struct

+ Ids []*ID

+ func (*GetRegisteredWorkersReply) Descriptor() ([]byte, []int)

+ func (*GetRegisteredWorkersReply) ProtoMessage()

+ func (m *GetRegisteredWorkersReply) GetIds() []*ID

+ func (m *GetRegisteredWorkersReply) Reset()

+ func (m *GetRegisteredWorkersReply) String() string

+ type HubClient interface

+ DeregisterWorker func(ctx context.Context, in *ID, opts ...grpc.CallOption) (*Empty, error)

+ Devices func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*DevicesReply, error)

+ DiscoverHub func(ctx context.Context, in *DiscoverHubRequest, opts ...grpc.CallOption) (*Empty, error)

+ GetDealInfo func(ctx context.Context, in *ID, opts ...grpc.CallOption) (*DealInfoReply, error)

+ GetDeviceProperties func(ctx context.Context, in *ID, opts ...grpc.CallOption) (*GetDevicePropertiesReply, error)

+ GetRegisteredWorkers func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*GetRegisteredWorkersReply, error)

+ Info func(ctx context.Context, in *ID, opts ...grpc.CallOption) (*InfoReply, error)

+ InsertSlot func(ctx context.Context, in *InsertSlotRequest, opts ...grpc.CallOption) (*ID, error)

+ List func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ListReply, error)

+ MinerDevices func(ctx context.Context, in *ID, opts ...grpc.CallOption) (*DevicesReply, error)

+ MinerStatus func(ctx context.Context, in *ID, opts ...grpc.CallOption) (*StatusMapReply, error)

+ Ping func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*PingReply, error)

+ ProposeDeal func(ctx context.Context, in *DealRequest, opts ...grpc.CallOption) (*Empty, error)

+ PullTask func(ctx context.Context, in *PullTaskRequest, opts ...grpc.CallOption) (Hub_PullTaskClient, error)

+ PushTask func(ctx context.Context, opts ...grpc.CallOption) (Hub_PushTaskClient, error)

+ RegisterWorker func(ctx context.Context, in *ID, opts ...grpc.CallOption) (*Empty, error)

+ RemoveSlot func(ctx context.Context, in *ID, opts ...grpc.CallOption) (*Empty, error)

+ SetDeviceProperties func(ctx context.Context, in *SetDevicePropertiesRequest, opts ...grpc.CallOption) (*Empty, error)

+ Slots func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*SlotsReply, error)

+ StartTask func(ctx context.Context, in *HubStartTaskRequest, opts ...grpc.CallOption) (*HubStartTaskReply, error)

+ Status func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*HubStatusReply, error)

+ StopTask func(ctx context.Context, in *ID, opts ...grpc.CallOption) (*Empty, error)

+ TaskList func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*TaskListReply, error)

+ TaskLogs func(ctx context.Context, in *TaskLogsRequest, opts ...grpc.CallOption) (Hub_TaskLogsClient, error)

+ TaskStatus func(ctx context.Context, in *ID, opts ...grpc.CallOption) (*TaskStatusReply, error)

+ func NewHubClient(cc *grpc.ClientConn) HubClient

+ type HubManagementClient interface

+ CreateAskPlan func(ctx context.Context, in *InsertSlotRequest, opts ...grpc.CallOption) (*ID, error)

+ DeregisterWorker func(ctx context.Context, in *ID, opts ...grpc.CallOption) (*Empty, error)

+ DeviceList func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*DevicesReply, error)

+ GetAskPlans func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*SlotsReply, error)

+ GetDeviceProperties func(ctx context.Context, in *ID, opts ...grpc.CallOption) (*GetDevicePropertiesReply, error)

+ GetRegisteredWorkers func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*GetRegisteredWorkersReply, error)

+ RegisterWorker func(ctx context.Context, in *ID, opts ...grpc.CallOption) (*Empty, error)

+ RemoveAskPlan func(ctx context.Context, in *ID, opts ...grpc.CallOption) (*Empty, error)

+ SetDeviceProperties func(ctx context.Context, in *SetDevicePropertiesRequest, opts ...grpc.CallOption) (*Empty, error)

+ Status func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*HubStatusReply, error)

+ TaskList func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*TaskListReply, error)

+ TaskStatus func(ctx context.Context, in *ID, opts ...grpc.CallOption) (*TaskStatusReply, error)

+ WorkerStatus func(ctx context.Context, in *ID, opts ...grpc.CallOption) (*InfoReply, error)

+ WorkersList func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ListReply, error)

+ func NewHubManagementClient(cc *grpc.ClientConn) HubManagementClient

+ type HubManagementServer interface

+ CreateAskPlan func(context.Context, *InsertSlotRequest) (*ID, error)

+ DeregisterWorker func(context.Context, *ID) (*Empty, error)

+ DeviceList func(context.Context, *Empty) (*DevicesReply, error)

+ GetAskPlans func(context.Context, *Empty) (*SlotsReply, error)

+ GetDeviceProperties func(context.Context, *ID) (*GetDevicePropertiesReply, error)

+ GetRegisteredWorkers func(context.Context, *Empty) (*GetRegisteredWorkersReply, error)

+ RegisterWorker func(context.Context, *ID) (*Empty, error)

+ RemoveAskPlan func(context.Context, *ID) (*Empty, error)

+ SetDeviceProperties func(context.Context, *SetDevicePropertiesRequest) (*Empty, error)

+ Status func(context.Context, *Empty) (*HubStatusReply, error)

+ TaskList func(context.Context, *Empty) (*TaskListReply, error)

+ TaskStatus func(context.Context, *ID) (*TaskStatusReply, error)

+ WorkerStatus func(context.Context, *ID) (*InfoReply, error)

+ WorkersList func(context.Context, *Empty) (*ListReply, error)

+ type HubServer interface

+ DeregisterWorker func(context.Context, *ID) (*Empty, error)

+ Devices func(context.Context, *Empty) (*DevicesReply, error)

+ DiscoverHub func(context.Context, *DiscoverHubRequest) (*Empty, error)

+ GetDealInfo func(context.Context, *ID) (*DealInfoReply, error)

+ GetDeviceProperties func(context.Context, *ID) (*GetDevicePropertiesReply, error)

+ GetRegisteredWorkers func(context.Context, *Empty) (*GetRegisteredWorkersReply, error)

+ Info func(context.Context, *ID) (*InfoReply, error)

+ InsertSlot func(context.Context, *InsertSlotRequest) (*ID, error)

+ List func(context.Context, *Empty) (*ListReply, error)

+ MinerDevices func(context.Context, *ID) (*DevicesReply, error)

+ MinerStatus func(context.Context, *ID) (*StatusMapReply, error)

+ Ping func(context.Context, *Empty) (*PingReply, error)

+ ProposeDeal func(context.Context, *DealRequest) (*Empty, error)

+ PullTask func(*PullTaskRequest, Hub_PullTaskServer) error

+ PushTask func(Hub_PushTaskServer) error

+ RegisterWorker func(context.Context, *ID) (*Empty, error)

+ RemoveSlot func(context.Context, *ID) (*Empty, error)

+ SetDeviceProperties func(context.Context, *SetDevicePropertiesRequest) (*Empty, error)

+ Slots func(context.Context, *Empty) (*SlotsReply, error)

+ StartTask func(context.Context, *HubStartTaskRequest) (*HubStartTaskReply, error)

+ Status func(context.Context, *Empty) (*HubStatusReply, error)

+ StopTask func(context.Context, *ID) (*Empty, error)

+ TaskList func(context.Context, *Empty) (*TaskListReply, error)

+ TaskLogs func(*TaskLogsRequest, Hub_TaskLogsServer) error

+ TaskStatus func(context.Context, *ID) (*TaskStatusReply, error)

+ type HubStartTaskReply struct

+ Endpoint []string

+ HubAddr string

+ Id string

+ func (*HubStartTaskReply) Descriptor() ([]byte, []int)

+ func (*HubStartTaskReply) ProtoMessage()

+ func (m *HubStartTaskReply) GetEndpoint() []string

+ func (m *HubStartTaskReply) GetHubAddr() string

+ func (m *HubStartTaskReply) GetId() string

+ func (m *HubStartTaskReply) Reset()

+ func (m *HubStartTaskReply) String() string

+ type HubStartTaskRequest struct

+ Auth string

+ CommitOnStop bool

+ Deal *Deal

+ Env map[string]string

+ Image string

+ PublicKeyData string

+ Registry string

+ func (*HubStartTaskRequest) Descriptor() ([]byte, []int)

+ func (*HubStartTaskRequest) ProtoMessage()

+ func (m *HubStartTaskRequest) GetAuth() string

+ func (m *HubStartTaskRequest) GetCommitOnStop() bool

+ func (m *HubStartTaskRequest) GetDeal() *Deal

+ func (m *HubStartTaskRequest) GetEnv() map[string]string

+ func (m *HubStartTaskRequest) GetImage() string

+ func (m *HubStartTaskRequest) GetPublicKeyData() string

+ func (m *HubStartTaskRequest) GetRegistry() string

+ func (m *HubStartTaskRequest) Reset()

+ func (m *HubStartTaskRequest) String() string

+ type HubStatusReply struct

+ EthAddr string

+ MinerCount uint64

+ Platform string

+ Uptime uint64

+ Version string

+ func (*HubStatusReply) Descriptor() ([]byte, []int)

+ func (*HubStatusReply) ProtoMessage()

+ func (m *HubStatusReply) GetEthAddr() string

+ func (m *HubStatusReply) GetMinerCount() uint64

+ func (m *HubStatusReply) GetPlatform() string

+ func (m *HubStatusReply) GetUptime() uint64

+ func (m *HubStatusReply) GetVersion() string

+ func (m *HubStatusReply) Reset()

+ func (m *HubStatusReply) String() string

+ type Hub_PullTaskClient interface

+ Recv func() (*Chunk, error)

+ type Hub_PullTaskServer interface

+ Send func(*Chunk) error

+ type Hub_PushTaskClient interface

+ Recv func() (*Progress, error)

+ Send func(*Chunk) error

+ type Hub_PushTaskServer interface

+ Recv func() (*Chunk, error)

+ Send func(*Progress) error

+ type Hub_TaskLogsClient interface

+ Recv func() (*TaskLogsChunk, error)

+ type Hub_TaskLogsServer interface

+ Send func(*TaskLogsChunk) error

+ type ID struct

+ Id string

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

+ func (*ID) ProtoMessage()

+ func (m *ID) GetId() string

+ func (m *ID) Reset()

+ func (m *ID) String() string

+ type InfoReply struct

+ Capabilities *Capabilities

+ Name string

+ Usage map[string]*ResourceUsage

+ func (*InfoReply) Descriptor() ([]byte, []int)

+ func (*InfoReply) ProtoMessage()

+ func (m *InfoReply) GetCapabilities() *Capabilities

+ func (m *InfoReply) GetName() string

+ func (m *InfoReply) GetUsage() map[string]*ResourceUsage

+ func (m *InfoReply) Reset()

+ func (m *InfoReply) String() string

+ type InsertSlotRequest struct

+ BuyerID string

+ Price string

+ Slot *Slot

+ func (*InsertSlotRequest) Descriptor() ([]byte, []int)

+ func (*InsertSlotRequest) ProtoMessage()

+ func (m *InsertSlotRequest) GetBuyerID() string

+ func (m *InsertSlotRequest) GetPrice() string

+ func (m *InsertSlotRequest) GetSlot() *Slot

+ func (m *InsertSlotRequest) Reset()

+ func (m *InsertSlotRequest) String() string

+ type ListReply struct

+ Info map[string]*ListReply_ListValue

+ func (*ListReply) Descriptor() ([]byte, []int)

+ func (*ListReply) ProtoMessage()

+ func (m *ListReply) GetInfo() map[string]*ListReply_ListValue

+ func (m *ListReply) Reset()

+ func (m *ListReply) String() string

+ type ListReply_ListValue struct

+ Values []string

+ func (*ListReply_ListValue) Descriptor() ([]byte, []int)

+ func (*ListReply_ListValue) ProtoMessage()

+ func (m *ListReply_ListValue) GetValues() []string

+ func (m *ListReply_ListValue) Reset()

+ func (m *ListReply_ListValue) String() string

+ type LocatorClient interface

+ Announce func(ctx context.Context, in *AnnounceRequest, opts ...grpc.CallOption) (*Empty, error)

+ Resolve func(ctx context.Context, in *ResolveRequest, opts ...grpc.CallOption) (*ResolveReply, error)

+ func NewLocatorClient(cc *grpc.ClientConn) LocatorClient

+ type LocatorServer interface

+ Announce func(context.Context, *AnnounceRequest) (*Empty, error)

+ Resolve func(context.Context, *ResolveRequest) (*ResolveReply, error)

+ type MarketClient interface

+ CancelOrder func(ctx context.Context, in *Order, opts ...grpc.CallOption) (*Empty, error)

+ CreateOrder func(ctx context.Context, in *Order, opts ...grpc.CallOption) (*Order, error)

+ GetOrderByID func(ctx context.Context, in *ID, opts ...grpc.CallOption) (*Order, error)

+ GetOrders func(ctx context.Context, in *GetOrdersRequest, opts ...grpc.CallOption) (*GetOrdersReply, error)

+ GetProcessing func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*GetProcessingReply, error)

+ func NewMarketClient(cc *grpc.ClientConn) MarketClient

+ type MarketServer interface

+ CancelOrder func(context.Context, *Order) (*Empty, error)

+ CreateOrder func(context.Context, *Order) (*Order, error)

+ GetOrderByID func(context.Context, *ID) (*Order, error)

+ GetOrders func(context.Context, *GetOrdersRequest) (*GetOrdersReply, error)

+ GetProcessing func(context.Context, *Empty) (*GetProcessingReply, error)

+ type MemoryUsage struct

+ MaxUsage uint64

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

+ func (*MemoryUsage) ProtoMessage()

+ func (m *MemoryUsage) GetMaxUsage() uint64

+ func (m *MemoryUsage) Reset()

+ func (m *MemoryUsage) String() string

+ type MinerClient interface

+ DiscoverHub func(ctx context.Context, in *DiscoverHubRequest, opts ...grpc.CallOption) (*Empty, error)

+ Handshake func(ctx context.Context, in *MinerHandshakeRequest, opts ...grpc.CallOption) (*MinerHandshakeReply, error)

+ Info func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*InfoReply, error)

+ Load func(ctx context.Context, opts ...grpc.CallOption) (Miner_LoadClient, error)

+ Ping func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*PingReply, error)

+ Save func(ctx context.Context, in *SaveRequest, opts ...grpc.CallOption) (Miner_SaveClient, error)

+ Start func(ctx context.Context, in *MinerStartRequest, opts ...grpc.CallOption) (*MinerStartReply, error)

+ Stop func(ctx context.Context, in *ID, opts ...grpc.CallOption) (*Empty, error)

+ TaskDetails func(ctx context.Context, in *ID, opts ...grpc.CallOption) (*TaskStatusReply, error)

+ TaskLogs func(ctx context.Context, in *TaskLogsRequest, opts ...grpc.CallOption) (Miner_TaskLogsClient, error)

+ TasksStatus func(ctx context.Context, opts ...grpc.CallOption) (Miner_TasksStatusClient, error)

+ func NewMinerClient(cc *grpc.ClientConn) MinerClient

+ type MinerHandshakeReply struct

+ Capabilities *Capabilities

+ Miner string

+ NatType NATType

+ func (*MinerHandshakeReply) Descriptor() ([]byte, []int)

+ func (*MinerHandshakeReply) ProtoMessage()

+ func (m *MinerHandshakeReply) GetCapabilities() *Capabilities

+ func (m *MinerHandshakeReply) GetMiner() string

+ func (m *MinerHandshakeReply) GetNatType() NATType

+ func (m *MinerHandshakeReply) Reset()

+ func (m *MinerHandshakeReply) String() string

+ type MinerHandshakeRequest struct

+ Hub string

+ Tasks []*TaskInfo

+ func (*MinerHandshakeRequest) Descriptor() ([]byte, []int)

+ func (*MinerHandshakeRequest) ProtoMessage()

+ func (m *MinerHandshakeRequest) GetHub() string

+ func (m *MinerHandshakeRequest) GetTasks() []*TaskInfo

+ func (m *MinerHandshakeRequest) Reset()

+ func (m *MinerHandshakeRequest) String() string

+ type MinerServer interface

+ DiscoverHub func(context.Context, *DiscoverHubRequest) (*Empty, error)

+ Handshake func(context.Context, *MinerHandshakeRequest) (*MinerHandshakeReply, error)

+ Info func(context.Context, *Empty) (*InfoReply, error)

+ Load func(Miner_LoadServer) error

+ Ping func(context.Context, *Empty) (*PingReply, error)

+ Save func(*SaveRequest, Miner_SaveServer) error

+ Start func(context.Context, *MinerStartRequest) (*MinerStartReply, error)

+ Stop func(context.Context, *ID) (*Empty, error)

+ TaskDetails func(context.Context, *ID) (*TaskStatusReply, error)

+ TaskLogs func(*TaskLogsRequest, Miner_TaskLogsServer) error

+ TasksStatus func(Miner_TasksStatusServer) error

+ type MinerStartReply struct

+ Container string

+ Routes []*Route

+ func (*MinerStartReply) Descriptor() ([]byte, []int)

+ func (*MinerStartReply) ProtoMessage()

+ func (m *MinerStartReply) GetContainer() string

+ func (m *MinerStartReply) GetRoutes() []*Route

+ func (m *MinerStartReply) Reset()

+ func (m *MinerStartReply) String() string

+ type MinerStartRequest struct

+ Auth string

+ CommitOnStop bool

+ Env map[string]string

+ Id string

+ Image string

+ OrderId string

+ PublicKeyData string

+ Registry string

+ Resources *TaskResourceRequirements

+ RestartPolicy *ContainerRestartPolicy

+ func (*MinerStartRequest) Descriptor() ([]byte, []int)

+ func (*MinerStartRequest) ProtoMessage()

+ func (m *MinerStartRequest) GetAuth() string

+ func (m *MinerStartRequest) GetCommitOnStop() bool

+ func (m *MinerStartRequest) GetEnv() map[string]string

+ func (m *MinerStartRequest) GetId() string

+ func (m *MinerStartRequest) GetImage() string

+ func (m *MinerStartRequest) GetOrderId() string

+ func (m *MinerStartRequest) GetPublicKeyData() string

+ func (m *MinerStartRequest) GetRegistry() string

+ func (m *MinerStartRequest) GetResources() *TaskResourceRequirements

+ func (m *MinerStartRequest) GetRestartPolicy() *ContainerRestartPolicy

+ func (m *MinerStartRequest) Reset()

+ func (m *MinerStartRequest) String() string

+ type MinerStatusMapRequest struct

+ func (*MinerStatusMapRequest) Descriptor() ([]byte, []int)

+ func (*MinerStatusMapRequest) ProtoMessage()

+ func (m *MinerStatusMapRequest) Reset()

+ func (m *MinerStatusMapRequest) String() string

+ type Miner_LoadClient interface

+ Recv func() (*Progress, error)

+ Send func(*Chunk) error

+ type Miner_LoadServer interface

+ Recv func() (*Chunk, error)

+ Send func(*Progress) error

+ type Miner_SaveClient interface

+ Recv func() (*Chunk, error)

+ type Miner_SaveServer interface

+ Send func(*Chunk) error

+ type Miner_TaskLogsClient interface

+ Recv func() (*TaskLogsChunk, error)

+ type Miner_TaskLogsServer interface

+ Send func(*TaskLogsChunk) error

+ type Miner_TasksStatusClient interface

+ Recv func() (*StatusMapReply, error)

+ Send func(*MinerStatusMapRequest) error

+ type Miner_TasksStatusServer interface

+ Recv func() (*MinerStatusMapRequest, error)

+ Send func(*StatusMapReply) error

+ type NATType int32

+ const NATType_BLOCKED

+ const NATType_FULL

+ const NATType_NONE

+ const NATType_PORT_RESTRICTED

+ const NATType_RESTRICTED

+ const NATType_SYMMETRIC

+ const NATType_SYMMETRIC_UDP_FIREWALL

+ const NATType_UNKNOWN

+ func (NATType) EnumDescriptor() ([]byte, []int)

+ func (x NATType) String() string

+ type NetworkType int32

+ const NetworkType_INCOMING

+ const NetworkType_NO_NETWORK

+ const NetworkType_OUTBOUND

+ func (NetworkType) EnumDescriptor() ([]byte, []int)

+ func (x NetworkType) String() string

+ type NetworkUsage struct

+ RxBytes uint64

+ RxDropped uint64

+ RxErrors uint64

+ RxPackets uint64

+ TxBytes uint64

+ TxDropped uint64

+ TxErrors uint64

+ TxPackets uint64

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

+ func (*NetworkUsage) ProtoMessage()

+ func (m *NetworkUsage) GetRxBytes() uint64

+ func (m *NetworkUsage) GetRxDropped() uint64

+ func (m *NetworkUsage) GetRxErrors() uint64

+ func (m *NetworkUsage) GetRxPackets() uint64

+ func (m *NetworkUsage) GetTxBytes() uint64

+ func (m *NetworkUsage) GetTxDropped() uint64

+ func (m *NetworkUsage) GetTxErrors() uint64

+ func (m *NetworkUsage) GetTxPackets() uint64

+ func (m *NetworkUsage) Reset()

+ func (m *NetworkUsage) String() string

+ type Order struct

+ ByuerID string

+ Id string

+ OrderType OrderType

+ Price string

+ Slot *Slot

+ SupplierID string

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

+ func (*Order) ProtoMessage()

+ func (m *Order) GetByuerID() string

+ func (m *Order) GetId() string

+ func (m *Order) GetOrderType() OrderType

+ func (m *Order) GetPrice() string

+ func (m *Order) GetSlot() *Slot

+ func (m *Order) GetSupplierID() string

+ func (m *Order) Reset()

+ func (m *Order) String() string

+ type OrderType int32

+ const OrderType_ANY

+ const OrderType_ASK

+ const OrderType_BID

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

+ func (x OrderType) String() string

+ type PingReply struct

+ Status string

+ func (*PingReply) Descriptor() ([]byte, []int)

+ func (*PingReply) ProtoMessage()

+ func (m *PingReply) GetStatus() string

+ func (m *PingReply) Reset()

+ func (m *PingReply) String() string

+ type Progress struct

+ Size int64

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

+ func (*Progress) ProtoMessage()

+ func (m *Progress) GetSize() int64

+ func (m *Progress) Reset()

+ func (m *Progress) String() string

+ type PullTaskRequest struct

+ DealId string

+ TaskId string

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

+ func (*PullTaskRequest) ProtoMessage()

+ func (m *PullTaskRequest) GetDealId() string

+ func (m *PullTaskRequest) GetTaskId() string

+ func (m *PullTaskRequest) Reset()

+ func (m *PullTaskRequest) String() string

+ type RAMDevice struct

+ Total uint64

+ Used uint64

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

+ func (*RAMDevice) ProtoMessage()

+ func (m *RAMDevice) GetTotal() uint64

+ func (m *RAMDevice) GetUsed() uint64

+ func (m *RAMDevice) Reset()

+ func (m *RAMDevice) String() string

+ type RemoveSlotRequest struct

+ ID string

+ Slot *Slot

+ func (*RemoveSlotRequest) Descriptor() ([]byte, []int)

+ func (*RemoveSlotRequest) ProtoMessage()

+ func (m *RemoveSlotRequest) GetID() string

+ func (m *RemoveSlotRequest) GetSlot() *Slot

+ func (m *RemoveSlotRequest) Reset()

+ func (m *RemoveSlotRequest) String() string

+ type ResolveReply struct

+ IpAddr []string

+ func (*ResolveReply) Descriptor() ([]byte, []int)

+ func (*ResolveReply) ProtoMessage()

+ func (m *ResolveReply) GetIpAddr() []string

+ func (m *ResolveReply) Reset()

+ func (m *ResolveReply) String() string

+ type ResolveRequest struct

+ EthAddr string

+ func (*ResolveRequest) Descriptor() ([]byte, []int)

+ func (*ResolveRequest) ProtoMessage()

+ func (m *ResolveRequest) GetEthAddr() string

+ func (m *ResolveRequest) Reset()

+ func (m *ResolveRequest) String() string

+ type ResourceUsage struct

+ Cpu *CPUUsage

+ Memory *MemoryUsage

+ Network map[string]*NetworkUsage

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

+ func (*ResourceUsage) ProtoMessage()

+ func (m *ResourceUsage) GetCpu() *CPUUsage

+ func (m *ResourceUsage) GetMemory() *MemoryUsage

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

+ func (m *ResourceUsage) Reset()

+ func (m *ResourceUsage) String() string

+ type Resources struct

+ CpuCores uint64

+ GpuCount GPUCount

+ NetTrafficIn uint64

+ NetTrafficOut uint64

+ NetworkType NetworkType

+ Properties map[string]float64

+ RamBytes uint64

+ Storage uint64

+ func (*Resources) Descriptor() ([]byte, []int)

+ func (*Resources) ProtoMessage()

+ func (m *Resources) GetCpuCores() uint64

+ func (m *Resources) GetGpuCount() GPUCount

+ func (m *Resources) GetNetTrafficIn() uint64

+ func (m *Resources) GetNetTrafficOut() uint64

+ func (m *Resources) GetNetworkType() NetworkType

+ func (m *Resources) GetProperties() map[string]float64

+ func (m *Resources) GetRamBytes() uint64

+ func (m *Resources) GetStorage() uint64

+ func (m *Resources) Reset()

+ func (m *Resources) String() string

+ type Route struct

+ Endpoint *SocketAddr

+ Port string

+ func (*Route) Descriptor() ([]byte, []int)

+ func (*Route) ProtoMessage()

+ func (m *Route) GetEndpoint() *SocketAddr

+ func (m *Route) GetPort() string

+ func (m *Route) Reset()

+ func (m *Route) String() string

+ type SaveRequest struct

+ ImageID string

+ func (*SaveRequest) Descriptor() ([]byte, []int)

+ func (*SaveRequest) ProtoMessage()

+ func (m *SaveRequest) GetImageID() string

+ func (m *SaveRequest) Reset()

+ func (m *SaveRequest) String() string

+ type SetDevicePropertiesRequest struct

+ ID string

+ Properties map[string]float64

+ func (*SetDevicePropertiesRequest) Descriptor() ([]byte, []int)

+ func (*SetDevicePropertiesRequest) ProtoMessage()

+ func (m *SetDevicePropertiesRequest) GetID() string

+ func (m *SetDevicePropertiesRequest) GetProperties() map[string]float64

+ func (m *SetDevicePropertiesRequest) Reset()

+ func (m *SetDevicePropertiesRequest) String() string

+ type Slot struct

+ BuyerRating int64

+ Duration uint64

+ Geo *Geo

+ Resources *Resources

+ SupplierRating int64

+ func (*Slot) Descriptor() ([]byte, []int)

+ func (*Slot) ProtoMessage()

+ func (m *Slot) GetBuyerRating() int64

+ func (m *Slot) GetDuration() uint64

+ func (m *Slot) GetGeo() *Geo

+ func (m *Slot) GetResources() *Resources

+ func (m *Slot) GetSupplierRating() int64

+ func (m *Slot) Reset()

+ func (m *Slot) String() string

+ type SlotsReply struct

+ Slots map[string]*Slot

+ func (*SlotsReply) Descriptor() ([]byte, []int)

+ func (*SlotsReply) ProtoMessage()

+ func (m *SlotsReply) GetSlots() map[string]*Slot

+ func (m *SlotsReply) Reset()

+ func (m *SlotsReply) String() string

+ type SocketAddr struct

+ Addr string

+ Port uint32

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

+ func (*SocketAddr) ProtoMessage()

+ func (m *SocketAddr) GetAddr() string

+ func (m *SocketAddr) GetPort() uint32

+ func (m *SocketAddr) Reset()

+ func (m *SocketAddr) String() string

+ type StatusMapReply struct

+ Statuses map[string]*TaskStatusReply

+ func (*StatusMapReply) Descriptor() ([]byte, []int)

+ func (*StatusMapReply) ProtoMessage()

+ func (m *StatusMapReply) GetStatuses() map[string]*TaskStatusReply

+ func (m *StatusMapReply) Reset()

+ func (m *StatusMapReply) String() string

+ type TaskID struct

+ HubAddr string

+ Id string

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

+ func (*TaskID) ProtoMessage()

+ func (m *TaskID) GetHubAddr() string

+ func (m *TaskID) GetId() string

+ func (m *TaskID) Reset()

+ func (m *TaskID) String() string

+ type TaskInfo struct

+ Reply *MinerStartReply

+ Request *MinerStartRequest

+ func (*TaskInfo) Descriptor() ([]byte, []int)

+ func (*TaskInfo) ProtoMessage()

+ func (m *TaskInfo) GetReply() *MinerStartReply

+ func (m *TaskInfo) GetRequest() *MinerStartRequest

+ func (m *TaskInfo) Reset()

+ func (m *TaskInfo) String() string

+ type TaskListReply struct

+ Info map[string]*TaskListReply_TaskInfo

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

+ func (*TaskListReply) ProtoMessage()

+ func (m *TaskListReply) GetInfo() map[string]*TaskListReply_TaskInfo

+ func (m *TaskListReply) Reset()

+ func (m *TaskListReply) String() string

+ type TaskListReply_TaskInfo struct

+ Tasks map[string]*TaskStatusReply

+ func (*TaskListReply_TaskInfo) Descriptor() ([]byte, []int)

+ func (*TaskListReply_TaskInfo) ProtoMessage()

+ func (m *TaskListReply_TaskInfo) GetTasks() map[string]*TaskStatusReply

+ func (m *TaskListReply_TaskInfo) Reset()

+ func (m *TaskListReply_TaskInfo) String() string

+ type TaskListRequest struct

+ HubID string

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

+ func (*TaskListRequest) ProtoMessage()

+ func (m *TaskListRequest) GetHubID() string

+ func (m *TaskListRequest) Reset()

+ func (m *TaskListRequest) String() string

+ type TaskLogsChunk struct

+ Data []byte

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

+ func (*TaskLogsChunk) ProtoMessage()

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

+ func (m *TaskLogsChunk) Reset()

+ func (m *TaskLogsChunk) String() string

+ type TaskLogsRequest struct

+ AddTimestamps bool

+ Details bool

+ Follow bool

+ HubAddr string

+ Id string

+ Since string

+ Tail string

+ Type TaskLogsRequest_Type

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

+ func (*TaskLogsRequest) ProtoMessage()

+ func (m *TaskLogsRequest) GetAddTimestamps() bool

+ func (m *TaskLogsRequest) GetDetails() bool

+ func (m *TaskLogsRequest) GetFollow() bool

+ func (m *TaskLogsRequest) GetHubAddr() string

+ func (m *TaskLogsRequest) GetId() string

+ func (m *TaskLogsRequest) GetSince() string

+ func (m *TaskLogsRequest) GetTail() string

+ func (m *TaskLogsRequest) GetType() TaskLogsRequest_Type

+ func (m *TaskLogsRequest) Reset()

+ func (m *TaskLogsRequest) String() string

+ type TaskLogsRequest_Type int32

+ const TaskLogsRequest_BOTH

+ const TaskLogsRequest_STDERR

+ const TaskLogsRequest_STDOUT

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

+ func (x TaskLogsRequest_Type) String() string

+ type TaskManagementClient interface

+ List func(ctx context.Context, in *TaskListRequest, opts ...grpc.CallOption) (*TaskListReply, error)

+ Logs func(ctx context.Context, in *TaskLogsRequest, opts ...grpc.CallOption) (TaskManagement_LogsClient, error)

+ PullTask func(ctx context.Context, in *PullTaskRequest, opts ...grpc.CallOption) (TaskManagement_PullTaskClient, error)

+ PushTask func(ctx context.Context, opts ...grpc.CallOption) (TaskManagement_PushTaskClient, error)

+ Start func(ctx context.Context, in *HubStartTaskRequest, opts ...grpc.CallOption) (*HubStartTaskReply, error)

+ Status func(ctx context.Context, in *TaskID, opts ...grpc.CallOption) (*TaskStatusReply, error)

+ Stop func(ctx context.Context, in *TaskID, opts ...grpc.CallOption) (*Empty, error)

+ func NewTaskManagementClient(cc *grpc.ClientConn) TaskManagementClient

+ type TaskManagementServer interface

+ List func(context.Context, *TaskListRequest) (*TaskListReply, error)

+ Logs func(*TaskLogsRequest, TaskManagement_LogsServer) error

+ PullTask func(*PullTaskRequest, TaskManagement_PullTaskServer) error

+ PushTask func(TaskManagement_PushTaskServer) error

+ Start func(context.Context, *HubStartTaskRequest) (*HubStartTaskReply, error)

+ Status func(context.Context, *TaskID) (*TaskStatusReply, error)

+ Stop func(context.Context, *TaskID) (*Empty, error)

+ type TaskManagement_LogsClient interface

+ Recv func() (*TaskLogsChunk, error)

+ type TaskManagement_LogsServer interface

+ Send func(*TaskLogsChunk) error

+ type TaskManagement_PullTaskClient interface

+ Recv func() (*Chunk, error)

+ type TaskManagement_PullTaskServer interface

+ Send func(*Chunk) error

+ type TaskManagement_PushTaskClient interface

+ Recv func() (*Progress, error)

+ Send func(*Chunk) error

+ type TaskManagement_PushTaskServer interface

+ Recv func() (*Chunk, error)

+ Send func(*Progress) error

+ type TaskResourceRequirements struct

+ CPUCores uint64

+ GPUSupport GPUCount

+ MaxMemory int64

+ func (*TaskResourceRequirements) Descriptor() ([]byte, []int)

+ func (*TaskResourceRequirements) ProtoMessage()

+ func (m *TaskResourceRequirements) GetCPUCores() uint64

+ func (m *TaskResourceRequirements) GetGPUSupport() GPUCount

+ func (m *TaskResourceRequirements) GetMaxMemory() int64

+ func (m *TaskResourceRequirements) Reset()

+ func (m *TaskResourceRequirements) String() string

+ type TaskStatusReply struct

+ AvailableResources *AvailableResources

+ ImageName string

+ MinerID string

+ Ports string

+ Status TaskStatusReply_Status

+ Uptime uint64

+ Usage *ResourceUsage

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

+ func (*TaskStatusReply) ProtoMessage()

+ func (m *TaskStatusReply) GetAvailableResources() *AvailableResources

+ func (m *TaskStatusReply) GetImageName() string

+ func (m *TaskStatusReply) GetMinerID() string

+ func (m *TaskStatusReply) GetPorts() string

+ func (m *TaskStatusReply) GetStatus() TaskStatusReply_Status

+ func (m *TaskStatusReply) GetUptime() uint64

+ func (m *TaskStatusReply) GetUsage() *ResourceUsage

+ func (m *TaskStatusReply) Reset()

+ func (m *TaskStatusReply) String() string

+ type TaskStatusReply_Status int32

+ const TaskStatusReply_BROKEN

+ const TaskStatusReply_FINISHED

+ const TaskStatusReply_RUNNING

+ const TaskStatusReply_SPAWNING

+ const TaskStatusReply_SPOOLING

+ const TaskStatusReply_UNKNOWN

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

+ func (x TaskStatusReply_Status) String() string

+ type Timestamp struct

+ Nanos int32

+ Seconds int64

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

+ func (*Timestamp) ProtoMessage()

+ func (m *Timestamp) GetNanos() int32

+ func (m *Timestamp) GetSeconds() int64

+ func (m *Timestamp) Reset()

+ func (m *Timestamp) String() string

v0.2.1

Aug 4, 2017

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL