worker.pb.go

// Code generated by protoc-gen-go. DO NOT EDIT.
// source: worker.proto

package sonm

import proto "github.com/golang/protobuf/proto"
import fmt "fmt"
import math "math"

import (
	context "golang.org/x/net/context"
	grpc "google.golang.org/grpc"
)

// Reference imports to suppress errors if they are not otherwise used.
var _ = proto.Marshal
var _ = fmt.Errorf
var _ = math.Inf

type CapabilityScope int32

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

var CapabilityScope_name = map[int32]string{
	0: "CAPABILITY_NONE",
	1: "CAPABILITY_SSH",
	2: "CAPABILITY_INSPECTION",
}
var CapabilityScope_value = map[string]int32{
	"CAPABILITY_NONE":       0,
	"CAPABILITY_SSH":        1,
	"CAPABILITY_INSPECTION": 2,
}

func (x CapabilityScope) String() string {
	return proto.EnumName(CapabilityScope_name, int32(x))
}
func (CapabilityScope) EnumDescriptor() ([]byte, []int) { return fileDescriptor21, []int{0} }

type TaskStatusReply_Status int32

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

var TaskStatusReply_Status_name = map[int32]string{
	0: "UNKNOWN",
	1: "SPOOLING",
	2: "SPAWNING",
	3: "RUNNING",
	4: "FINISHED",
	5: "BROKEN",
	6: "KILLED_OOM",
}
var TaskStatusReply_Status_value = map[string]int32{
	"UNKNOWN":    0,
	"SPOOLING":   1,
	"SPAWNING":   2,
	"RUNNING":    3,
	"FINISHED":   4,
	"BROKEN":     5,
	"KILLED_OOM": 6,
}

func (x TaskStatusReply_Status) String() string {
	return proto.EnumName(TaskStatusReply_Status_name, int32(x))
}
func (TaskStatusReply_Status) EnumDescriptor() ([]byte, []int) { return fileDescriptor21, []int{11, 0} }

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

func (m *TaskTag) Reset()                    { *m = TaskTag{} }
func (m *TaskTag) String() string            { return proto.CompactTextString(m) }
func (*TaskTag) ProtoMessage()               {}
func (*TaskTag) Descriptor() ([]byte, []int) { return fileDescriptor21, []int{0} }

func (m *TaskTag) GetData() []byte {
	if m != nil {
		return m.Data
	}
	return nil
}

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

func (m *TaskSpec) Reset()                    { *m = TaskSpec{} }
func (m *TaskSpec) String() string            { return proto.CompactTextString(m) }
func (*TaskSpec) ProtoMessage()               {}
func (*TaskSpec) Descriptor() ([]byte, []int) { return fileDescriptor21, []int{1} }

func (m *TaskSpec) GetContainer() *Container {
	if m != nil {
		return m.Container
	}
	return nil
}

func (m *TaskSpec) GetRegistry() *Registry {
	if m != nil {
		return m.Registry
	}
	return nil
}

func (m *TaskSpec) GetResources() *AskPlanResources {
	if m != nil {
		return m.Resources
	}
	return nil
}

func (m *TaskSpec) GetTag() *TaskTag {
	if m != nil {
		return m.Tag
	}
	return nil
}

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

func (m *StartTaskRequest) Reset()                    { *m = StartTaskRequest{} }
func (m *StartTaskRequest) String() string            { return proto.CompactTextString(m) }
func (*StartTaskRequest) ProtoMessage()               {}
func (*StartTaskRequest) Descriptor() ([]byte, []int) { return fileDescriptor21, []int{2} }

func (m *StartTaskRequest) GetDealID() *BigInt {
	if m != nil {
		return m.DealID
	}
	return nil
}

func (m *StartTaskRequest) GetSpec() *TaskSpec {
	if m != nil {
		return m.Spec
	}
	return nil
}

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

func (m *WorkerJoinNetworkRequest) Reset()                    { *m = WorkerJoinNetworkRequest{} }
func (m *WorkerJoinNetworkRequest) String() string            { return proto.CompactTextString(m) }
func (*WorkerJoinNetworkRequest) ProtoMessage()               {}
func (*WorkerJoinNetworkRequest) Descriptor() ([]byte, []int) { return fileDescriptor21, []int{3} }

func (m *WorkerJoinNetworkRequest) GetTaskID() string {
	if m != nil {
		return m.TaskID
	}
	return ""
}

func (m *WorkerJoinNetworkRequest) GetNetworkID() string {
	if m != nil {
		return m.NetworkID
	}
	return ""
}

type StartTaskReply struct {
	Id         string                `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
	PortMap    map[string]*Endpoints `protobuf:"bytes,2,rep,name=portMap" json:"portMap,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
	NetworkIDs []string              `protobuf:"bytes,3,rep,name=networkIDs" json:"networkIDs,omitempty"`
}

func (m *StartTaskReply) Reset()                    { *m = StartTaskReply{} }
func (m *StartTaskReply) String() string            { return proto.CompactTextString(m) }
func (*StartTaskReply) ProtoMessage()               {}
func (*StartTaskReply) Descriptor() ([]byte, []int) { return fileDescriptor21, []int{4} }

func (m *StartTaskReply) GetId() string {
	if m != nil {
		return m.Id
	}
	return ""
}

func (m *StartTaskReply) GetPortMap() map[string]*Endpoints {
	if m != nil {
		return m.PortMap
	}
	return nil
}

func (m *StartTaskReply) GetNetworkIDs() []string {
	if m != nil {
		return m.NetworkIDs
	}
	return nil
}

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

func (m *StatusReply) Reset()                    { *m = StatusReply{} }
func (m *StatusReply) String() string            { return proto.CompactTextString(m) }
func (*StatusReply) ProtoMessage()               {}
func (*StatusReply) Descriptor() ([]byte, []int) { return fileDescriptor21, []int{5} }

func (m *StatusReply) GetUptime() uint64 {
	if m != nil {
		return m.Uptime
	}
	return 0
}

func (m *StatusReply) GetVersion() string {
	if m != nil {
		return m.Version
	}
	return ""
}

func (m *StatusReply) GetPlatform() string {
	if m != nil {
		return m.Platform
	}
	return ""
}

func (m *StatusReply) GetEthAddr() string {
	if m != nil {
		return m.EthAddr
	}
	return ""
}

func (m *StatusReply) GetTaskCount() uint32 {
	if m != nil {
		return m.TaskCount
	}
	return 0
}

func (m *StatusReply) GetDWHStatus() string {
	if m != nil {
		return m.DWHStatus
	}
	return ""
}

func (m *StatusReply) GetRendezvousStatus() string {
	if m != nil {
		return m.RendezvousStatus
	}
	return ""
}

func (m *StatusReply) GetMaster() *EthAddress {
	if m != nil {
		return m.Master
	}
	return nil
}

func (m *StatusReply) GetAdmin() *EthAddress {
	if m != nil {
		return m.Admin
	}
	return nil
}

func (m *StatusReply) GetIsMasterConfirmed() bool {
	if m != nil {
		return m.IsMasterConfirmed
	}
	return false
}

func (m *StatusReply) GetIsBenchmarkFinished() bool {
	if m != nil {
		return m.IsBenchmarkFinished
	}
	return false
}

func (m *StatusReply) GetGeo() *GeoIP {
	if m != nil {
		return m.Geo
	}
	return nil
}

type AskPlansReply struct {
	AskPlans map[string]*AskPlan `protobuf:"bytes,1,rep,name=askPlans" json:"askPlans,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
}

func (m *AskPlansReply) Reset()                    { *m = AskPlansReply{} }
func (m *AskPlansReply) String() string            { return proto.CompactTextString(m) }
func (*AskPlansReply) ProtoMessage()               {}
func (*AskPlansReply) Descriptor() ([]byte, []int) { return fileDescriptor21, []int{6} }

func (m *AskPlansReply) GetAskPlans() map[string]*AskPlan {
	if m != nil {
		return m.AskPlans
	}
	return nil
}

type TaskListReply struct {
	Info map[string]*TaskStatusReply `protobuf:"bytes,1,rep,name=info" json:"info,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
}

func (m *TaskListReply) Reset()                    { *m = TaskListReply{} }
func (m *TaskListReply) String() string            { return proto.CompactTextString(m) }
func (*TaskListReply) ProtoMessage()               {}
func (*TaskListReply) Descriptor() ([]byte, []int) { return fileDescriptor21, []int{7} }

func (m *TaskListReply) GetInfo() map[string]*TaskStatusReply {
	if m != nil {
		return m.Info
	}
	return nil
}

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

func (m *DevicesReply) Reset()                    { *m = DevicesReply{} }
func (m *DevicesReply) String() string            { return proto.CompactTextString(m) }
func (*DevicesReply) ProtoMessage()               {}
func (*DevicesReply) Descriptor() ([]byte, []int) { return fileDescriptor21, []int{8} }

func (m *DevicesReply) GetCPU() *CPU {
	if m != nil {
		return m.CPU
	}
	return nil
}

func (m *DevicesReply) GetGPUs() []*GPU {
	if m != nil {
		return m.GPUs
	}
	return nil
}

func (m *DevicesReply) GetRAM() *RAM {
	if m != nil {
		return m.RAM
	}
	return nil
}

func (m *DevicesReply) GetNetwork() *Network {
	if m != nil {
		return m.Network
	}
	return nil
}

func (m *DevicesReply) GetStorage() *Storage {
	if m != nil {
		return m.Storage
	}
	return nil
}

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

func (m *PullTaskRequest) Reset()                    { *m = PullTaskRequest{} }
func (m *PullTaskRequest) String() string            { return proto.CompactTextString(m) }
func (*PullTaskRequest) ProtoMessage()               {}
func (*PullTaskRequest) Descriptor() ([]byte, []int) { return fileDescriptor21, []int{9} }

func (m *PullTaskRequest) GetDealId() string {
	if m != nil {
		return m.DealId
	}
	return ""
}

func (m *PullTaskRequest) GetTaskId() string {
	if m != nil {
		return m.TaskId
	}
	return ""
}

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

func (m *DealInfoReply) Reset()                    { *m = DealInfoReply{} }
func (m *DealInfoReply) String() string            { return proto.CompactTextString(m) }
func (*DealInfoReply) ProtoMessage()               {}
func (*DealInfoReply) Descriptor() ([]byte, []int) { return fileDescriptor21, []int{10} }

func (m *DealInfoReply) GetDeal() *Deal {
	if m != nil {
		return m.Deal
	}
	return nil
}

func (m *DealInfoReply) GetRunning() map[string]*TaskStatusReply {
	if m != nil {
		return m.Running
	}
	return nil
}

func (m *DealInfoReply) GetCompleted() map[string]*TaskStatusReply {
	if m != nil {
		return m.Completed
	}
	return nil
}

func (m *DealInfoReply) GetResources() *AskPlanResources {
	if m != nil {
		return m.Resources
	}
	return nil
}

func (m *DealInfoReply) GetPublicIPs() []string {
	if m != nil {
		return m.PublicIPs
	}
	return nil
}

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

func (m *TaskStatusReply) Reset()                    { *m = TaskStatusReply{} }
func (m *TaskStatusReply) String() string            { return proto.CompactTextString(m) }
func (*TaskStatusReply) ProtoMessage()               {}
func (*TaskStatusReply) Descriptor() ([]byte, []int) { return fileDescriptor21, []int{11} }

func (m *TaskStatusReply) GetStatus() TaskStatusReply_Status {
	if m != nil {
		return m.Status
	}
	return TaskStatusReply_UNKNOWN
}

func (m *TaskStatusReply) GetImageName() string {
	if m != nil {
		return m.ImageName
	}
	return ""
}

func (m *TaskStatusReply) GetPortMap() map[string]*Endpoints {
	if m != nil {
		return m.PortMap
	}
	return nil
}

func (m *TaskStatusReply) GetUptime() uint64 {
	if m != nil {
		return m.Uptime
	}
	return 0
}

func (m *TaskStatusReply) GetUsage() *ResourceUsage {
	if m != nil {
		return m.Usage
	}
	return nil
}

func (m *TaskStatusReply) GetAllocatedResources() *AskPlanResources {
	if m != nil {
		return m.AllocatedResources
	}
	return nil
}

func (m *TaskStatusReply) GetTag() *TaskTag {
	if m != nil {
		return m.Tag
	}
	return nil
}

type TaskPool struct {
	All  *AskPlanResources            `protobuf:"bytes,1,opt,name=all" json:"all,omitempty"`
	Used map[string]*AskPlanResources `protobuf:"bytes,2,rep,name=used" json:"used,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
}

func (m *TaskPool) Reset()                    { *m = TaskPool{} }
func (m *TaskPool) String() string            { return proto.CompactTextString(m) }
func (*TaskPool) ProtoMessage()               {}
func (*TaskPool) Descriptor() ([]byte, []int) { return fileDescriptor21, []int{12} }

func (m *TaskPool) GetAll() *AskPlanResources {
	if m != nil {
		return m.All
	}
	return nil
}

func (m *TaskPool) GetUsed() map[string]*AskPlanResources {
	if m != nil {
		return m.Used
	}
	return nil
}

type AskPlanPool struct {
	All          *AskPlanResources   `protobuf:"bytes,1,opt,name=all" json:"all,omitempty"`
	UsedSpot     map[string]*AskPlan `protobuf:"bytes,2,rep,name=usedSpot" json:"usedSpot,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
	UsedFw       map[string]*AskPlan `protobuf:"bytes,3,rep,name=usedFw" json:"usedFw,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
	CommitedSpot map[string]*AskPlan `protobuf:"bytes,4,rep,name=commitedSpot" json:"commitedSpot,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
	CommitedFw   map[string]*AskPlan `protobuf:"bytes,5,rep,name=commitedFw" json:"commitedFw,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
	EjectedPlans map[string]*AskPlan `protobuf:"bytes,6,rep,name=ejectedPlans" json:"ejectedPlans,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
}

func (m *AskPlanPool) Reset()                    { *m = AskPlanPool{} }
func (m *AskPlanPool) String() string            { return proto.CompactTextString(m) }
func (*AskPlanPool) ProtoMessage()               {}
func (*AskPlanPool) Descriptor() ([]byte, []int) { return fileDescriptor21, []int{13} }

func (m *AskPlanPool) GetAll() *AskPlanResources {
	if m != nil {
		return m.All
	}
	return nil
}

func (m *AskPlanPool) GetUsedSpot() map[string]*AskPlan {
	if m != nil {
		return m.UsedSpot
	}
	return nil
}

func (m *AskPlanPool) GetUsedFw() map[string]*AskPlan {
	if m != nil {
		return m.UsedFw
	}
	return nil
}

func (m *AskPlanPool) GetCommitedSpot() map[string]*AskPlan {
	if m != nil {
		return m.CommitedSpot
	}
	return nil
}

func (m *AskPlanPool) GetCommitedFw() map[string]*AskPlan {
	if m != nil {
		return m.CommitedFw
	}
	return nil
}

func (m *AskPlanPool) GetEjectedPlans() map[string]*AskPlan {
	if m != nil {
		return m.EjectedPlans
	}
	return nil
}

type SchedulerData struct {
	TaskToAskPlan map[string]string    `protobuf:"bytes,1,rep,name=taskToAskPlan" json:"taskToAskPlan,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
	AskPlanPools  map[string]*TaskPool `protobuf:"bytes,3,rep,name=askPlanPools" json:"askPlanPools,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
	PlanPool      *AskPlanPool         `protobuf:"bytes,4,opt,name=planPool" json:"planPool,omitempty"`
}

func (m *SchedulerData) Reset()                    { *m = SchedulerData{} }
func (m *SchedulerData) String() string            { return proto.CompactTextString(m) }
func (*SchedulerData) ProtoMessage()               {}
func (*SchedulerData) Descriptor() ([]byte, []int) { return fileDescriptor21, []int{14} }

func (m *SchedulerData) GetTaskToAskPlan() map[string]string {
	if m != nil {
		return m.TaskToAskPlan
	}
	return nil
}

func (m *SchedulerData) GetAskPlanPools() map[string]*TaskPool {
	if m != nil {
		return m.AskPlanPools
	}
	return nil
}

func (m *SchedulerData) GetPlanPool() *AskPlanPool {
	if m != nil {
		return m.PlanPool
	}
	return nil
}

type SalesmanData struct {
	AskPlanCGroups map[string]string `protobuf:"bytes,2,rep,name=askPlanCGroups" json:"askPlanCGroups,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
	Deals          map[string]*Deal  `protobuf:"bytes,3,rep,name=deals" json:"deals,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
	Orders         map[string]*Order `protobuf:"bytes,4,rep,name=orders" json:"orders,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
}

func (m *SalesmanData) Reset()                    { *m = SalesmanData{} }
func (m *SalesmanData) String() string            { return proto.CompactTextString(m) }
func (*SalesmanData) ProtoMessage()               {}
func (*SalesmanData) Descriptor() ([]byte, []int) { return fileDescriptor21, []int{15} }

func (m *SalesmanData) GetAskPlanCGroups() map[string]string {
	if m != nil {
		return m.AskPlanCGroups
	}
	return nil
}

func (m *SalesmanData) GetDeals() map[string]*Deal {
	if m != nil {
		return m.Deals
	}
	return nil
}

func (m *SalesmanData) GetOrders() map[string]*Order {
	if m != nil {
		return m.Orders
	}
	return nil
}

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

func (m *DebugStateReply) Reset()                    { *m = DebugStateReply{} }
func (m *DebugStateReply) String() string            { return proto.CompactTextString(m) }
func (*DebugStateReply) ProtoMessage()               {}
func (*DebugStateReply) Descriptor() ([]byte, []int) { return fileDescriptor21, []int{16} }

func (m *DebugStateReply) GetSchedulerData() *SchedulerData {
	if m != nil {
		return m.SchedulerData
	}
	return nil
}

func (m *DebugStateReply) GetSalesmanData() *SalesmanData {
	if m != nil {
		return m.SalesmanData
	}
	return nil
}

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

func (m *PurgeTasksRequest) Reset()                    { *m = PurgeTasksRequest{} }
func (m *PurgeTasksRequest) String() string            { return proto.CompactTextString(m) }
func (*PurgeTasksRequest) ProtoMessage()               {}
func (*PurgeTasksRequest) Descriptor() ([]byte, []int) { return fileDescriptor21, []int{17} }

func (m *PurgeTasksRequest) GetDealID() *BigInt {
	if m != nil {
		return m.DealID
	}
	return nil
}

type WorkerMetricsRequest struct {
}

func (m *WorkerMetricsRequest) Reset()                    { *m = WorkerMetricsRequest{} }
func (m *WorkerMetricsRequest) String() string            { return proto.CompactTextString(m) }
func (*WorkerMetricsRequest) ProtoMessage()               {}
func (*WorkerMetricsRequest) Descriptor() ([]byte, []int) { return fileDescriptor21, []int{18} }

type WorkerMetricsResponse struct {
	Metrics map[string]float64 `protobuf:"bytes,1,rep,name=metrics" json:"metrics,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"fixed64,2,opt,name=value"`
}

func (m *WorkerMetricsResponse) Reset()                    { *m = WorkerMetricsResponse{} }
func (m *WorkerMetricsResponse) String() string            { return proto.CompactTextString(m) }
func (*WorkerMetricsResponse) ProtoMessage()               {}
func (*WorkerMetricsResponse) Descriptor() ([]byte, []int) { return fileDescriptor21, []int{19} }

func (m *WorkerMetricsResponse) GetMetrics() map[string]float64 {
	if m != nil {
		return m.Metrics
	}
	return nil
}

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

func (m *WorkerAddCapabilityRequest) Reset()                    { *m = WorkerAddCapabilityRequest{} }
func (m *WorkerAddCapabilityRequest) String() string            { return proto.CompactTextString(m) }
func (*WorkerAddCapabilityRequest) ProtoMessage()               {}
func (*WorkerAddCapabilityRequest) Descriptor() ([]byte, []int) { return fileDescriptor21, []int{20} }

func (m *WorkerAddCapabilityRequest) GetSubject() *EthAddress {
	if m != nil {
		return m.Subject
	}
	return nil
}

func (m *WorkerAddCapabilityRequest) GetScope() CapabilityScope {
	if m != nil {
		return m.Scope
	}
	return CapabilityScope_CAPABILITY_NONE
}

func (m *WorkerAddCapabilityRequest) GetTtl() uint32 {
	if m != nil {
		return m.Ttl
	}
	return 0
}

type WorkerAddCapabilityResponse struct {
}

func (m *WorkerAddCapabilityResponse) Reset()                    { *m = WorkerAddCapabilityResponse{} }
func (m *WorkerAddCapabilityResponse) String() string            { return proto.CompactTextString(m) }
func (*WorkerAddCapabilityResponse) ProtoMessage()               {}
func (*WorkerAddCapabilityResponse) Descriptor() ([]byte, []int) { return fileDescriptor21, []int{21} }

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

func (m *WorkerRemoveCapabilityRequest) Reset()                    { *m = WorkerRemoveCapabilityRequest{} }
func (m *WorkerRemoveCapabilityRequest) String() string            { return proto.CompactTextString(m) }
func (*WorkerRemoveCapabilityRequest) ProtoMessage()               {}
func (*WorkerRemoveCapabilityRequest) Descriptor() ([]byte, []int) { return fileDescriptor21, []int{22} }

func (m *WorkerRemoveCapabilityRequest) GetSubject() *EthAddress {
	if m != nil {
		return m.Subject
	}
	return nil
}

func (m *WorkerRemoveCapabilityRequest) GetScope() CapabilityScope {
	if m != nil {
		return m.Scope
	}
	return CapabilityScope_CAPABILITY_NONE
}

type WorkerRemoveCapabilityResponse struct {
}

func (m *WorkerRemoveCapabilityResponse) Reset()         { *m = WorkerRemoveCapabilityResponse{} }
func (m *WorkerRemoveCapabilityResponse) String() string { return proto.CompactTextString(m) }
func (*WorkerRemoveCapabilityResponse) ProtoMessage()    {}
func (*WorkerRemoveCapabilityResponse) Descriptor() ([]byte, []int) {
	return fileDescriptor21, []int{23}
}

func init() {
	proto.RegisterType((*TaskTag)(nil), "sonm.TaskTag")
	proto.RegisterType((*TaskSpec)(nil), "sonm.TaskSpec")
	proto.RegisterType((*StartTaskRequest)(nil), "sonm.StartTaskRequest")
	proto.RegisterType((*WorkerJoinNetworkRequest)(nil), "sonm.WorkerJoinNetworkRequest")
	proto.RegisterType((*StartTaskReply)(nil), "sonm.StartTaskReply")
	proto.RegisterType((*StatusReply)(nil), "sonm.StatusReply")
	proto.RegisterType((*AskPlansReply)(nil), "sonm.AskPlansReply")
	proto.RegisterType((*TaskListReply)(nil), "sonm.TaskListReply")
	proto.RegisterType((*DevicesReply)(nil), "sonm.DevicesReply")
	proto.RegisterType((*PullTaskRequest)(nil), "sonm.PullTaskRequest")
	proto.RegisterType((*DealInfoReply)(nil), "sonm.DealInfoReply")
	proto.RegisterType((*TaskStatusReply)(nil), "sonm.TaskStatusReply")
	proto.RegisterType((*TaskPool)(nil), "sonm.TaskPool")
	proto.RegisterType((*AskPlanPool)(nil), "sonm.AskPlanPool")
	proto.RegisterType((*SchedulerData)(nil), "sonm.SchedulerData")
	proto.RegisterType((*SalesmanData)(nil), "sonm.SalesmanData")
	proto.RegisterType((*DebugStateReply)(nil), "sonm.DebugStateReply")
	proto.RegisterType((*PurgeTasksRequest)(nil), "sonm.PurgeTasksRequest")
	proto.RegisterType((*WorkerMetricsRequest)(nil), "sonm.WorkerMetricsRequest")
	proto.RegisterType((*WorkerMetricsResponse)(nil), "sonm.WorkerMetricsResponse")
	proto.RegisterType((*WorkerAddCapabilityRequest)(nil), "sonm.WorkerAddCapabilityRequest")
	proto.RegisterType((*WorkerAddCapabilityResponse)(nil), "sonm.WorkerAddCapabilityResponse")
	proto.RegisterType((*WorkerRemoveCapabilityRequest)(nil), "sonm.WorkerRemoveCapabilityRequest")
	proto.RegisterType((*WorkerRemoveCapabilityResponse)(nil), "sonm.WorkerRemoveCapabilityResponse")
	proto.RegisterEnum("sonm.CapabilityScope", CapabilityScope_name, CapabilityScope_value)
	proto.RegisterEnum("sonm.TaskStatusReply_Status", TaskStatusReply_Status_name, TaskStatusReply_Status_value)
}

// Reference imports to suppress errors if they are not otherwise used.
var _ context.Context
var _ grpc.ClientConn

// This is a compile-time assertion to ensure that this generated file
// is compatible with the grpc package it is being compiled against.
const _ = grpc.SupportPackageIsVersion4

// Client API for WorkerManagement service

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

type workerManagementClient struct {
	cc *grpc.ClientConn
}

func NewWorkerManagementClient(cc *grpc.ClientConn) WorkerManagementClient {
	return &workerManagementClient{cc}
}

func (c *workerManagementClient) Status(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*StatusReply, error) {
	out := new(StatusReply)
	err := grpc.Invoke(ctx, "/sonm.WorkerManagement/Status", in, out, c.cc, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *workerManagementClient) Devices(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*DevicesReply, error) {
	out := new(DevicesReply)
	err := grpc.Invoke(ctx, "/sonm.WorkerManagement/Devices", in, out, c.cc, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *workerManagementClient) FreeDevices(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*DevicesReply, error) {
	out := new(DevicesReply)
	err := grpc.Invoke(ctx, "/sonm.WorkerManagement/FreeDevices", in, out, c.cc, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *workerManagementClient) Tasks(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*TaskListReply, error) {
	out := new(TaskListReply)
	err := grpc.Invoke(ctx, "/sonm.WorkerManagement/Tasks", in, out, c.cc, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *workerManagementClient) AskPlans(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*AskPlansReply, error) {
	out := new(AskPlansReply)
	err := grpc.Invoke(ctx, "/sonm.WorkerManagement/AskPlans", in, out, c.cc, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *workerManagementClient) CreateAskPlan(ctx context.Context, in *AskPlan, opts ...grpc.CallOption) (*ID, error) {
	out := new(ID)
	err := grpc.Invoke(ctx, "/sonm.WorkerManagement/CreateAskPlan", in, out, c.cc, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *workerManagementClient) RemoveAskPlan(ctx context.Context, in *ID, opts ...grpc.CallOption) (*Empty, error) {
	out := new(Empty)
	err := grpc.Invoke(ctx, "/sonm.WorkerManagement/RemoveAskPlan", in, out, c.cc, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *workerManagementClient) PurgeAskPlans(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error) {
	out := new(Empty)
	err := grpc.Invoke(ctx, "/sonm.WorkerManagement/PurgeAskPlans", in, out, c.cc, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *workerManagementClient) PurgeAskPlansDetailed(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ErrorByStringID, error) {
	out := new(ErrorByStringID)
	err := grpc.Invoke(ctx, "/sonm.WorkerManagement/PurgeAskPlansDetailed", in, out, c.cc, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *workerManagementClient) ScheduleMaintenance(ctx context.Context, in *Timestamp, opts ...grpc.CallOption) (*Empty, error) {
	out := new(Empty)
	err := grpc.Invoke(ctx, "/sonm.WorkerManagement/ScheduleMaintenance", in, out, c.cc, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *workerManagementClient) NextMaintenance(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Timestamp, error) {
	out := new(Timestamp)
	err := grpc.Invoke(ctx, "/sonm.WorkerManagement/NextMaintenance", in, out, c.cc, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *workerManagementClient) DebugState(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*DebugStateReply, error) {
	out := new(DebugStateReply)
	err := grpc.Invoke(ctx, "/sonm.WorkerManagement/DebugState", in, out, c.cc, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *workerManagementClient) RemoveBenchmark(ctx context.Context, in *NumericID, opts ...grpc.CallOption) (*Empty, error) {
	out := new(Empty)
	err := grpc.Invoke(ctx, "/sonm.WorkerManagement/RemoveBenchmark", in, out, c.cc, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *workerManagementClient) PurgeBenchmarks(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error) {
	out := new(Empty)
	err := grpc.Invoke(ctx, "/sonm.WorkerManagement/PurgeBenchmarks", in, out, c.cc, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *workerManagementClient) Metrics(ctx context.Context, in *WorkerMetricsRequest, opts ...grpc.CallOption) (*WorkerMetricsResponse, error) {
	out := new(WorkerMetricsResponse)
	err := grpc.Invoke(ctx, "/sonm.WorkerManagement/Metrics", in, out, c.cc, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *workerManagementClient) AddCapability(ctx context.Context, in *WorkerAddCapabilityRequest, opts ...grpc.CallOption) (*WorkerAddCapabilityResponse, error) {
	out := new(WorkerAddCapabilityResponse)
	err := grpc.Invoke(ctx, "/sonm.WorkerManagement/AddCapability", in, out, c.cc, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *workerManagementClient) RemoveCapability(ctx context.Context, in *WorkerRemoveCapabilityRequest, opts ...grpc.CallOption) (*WorkerRemoveCapabilityResponse, error) {
	out := new(WorkerRemoveCapabilityResponse)
	err := grpc.Invoke(ctx, "/sonm.WorkerManagement/RemoveCapability", in, out, c.cc, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

// Server API for WorkerManagement service

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

func RegisterWorkerManagementServer(s *grpc.Server, srv WorkerManagementServer) {
	s.RegisterService(&_WorkerManagement_serviceDesc, srv)
}

func _WorkerManagement_Status_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(Empty)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(WorkerManagementServer).Status(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/sonm.WorkerManagement/Status",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(WorkerManagementServer).Status(ctx, req.(*Empty))
	}
	return interceptor(ctx, in, info, handler)
}

func _WorkerManagement_Devices_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(Empty)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(WorkerManagementServer).Devices(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/sonm.WorkerManagement/Devices",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(WorkerManagementServer).Devices(ctx, req.(*Empty))
	}
	return interceptor(ctx, in, info, handler)
}

func _WorkerManagement_FreeDevices_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(Empty)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(WorkerManagementServer).FreeDevices(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/sonm.WorkerManagement/FreeDevices",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(WorkerManagementServer).FreeDevices(ctx, req.(*Empty))
	}
	return interceptor(ctx, in, info, handler)
}

func _WorkerManagement_Tasks_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(Empty)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(WorkerManagementServer).Tasks(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/sonm.WorkerManagement/Tasks",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(WorkerManagementServer).Tasks(ctx, req.(*Empty))
	}
	return interceptor(ctx, in, info, handler)
}

func _WorkerManagement_AskPlans_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(Empty)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(WorkerManagementServer).AskPlans(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/sonm.WorkerManagement/AskPlans",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(WorkerManagementServer).AskPlans(ctx, req.(*Empty))
	}
	return interceptor(ctx, in, info, handler)
}

func _WorkerManagement_CreateAskPlan_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(AskPlan)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(WorkerManagementServer).CreateAskPlan(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/sonm.WorkerManagement/CreateAskPlan",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(WorkerManagementServer).CreateAskPlan(ctx, req.(*AskPlan))
	}
	return interceptor(ctx, in, info, handler)
}

func _WorkerManagement_RemoveAskPlan_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ID)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(WorkerManagementServer).RemoveAskPlan(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/sonm.WorkerManagement/RemoveAskPlan",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(WorkerManagementServer).RemoveAskPlan(ctx, req.(*ID))
	}
	return interceptor(ctx, in, info, handler)
}

func _WorkerManagement_PurgeAskPlans_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(Empty)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(WorkerManagementServer).PurgeAskPlans(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/sonm.WorkerManagement/PurgeAskPlans",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(WorkerManagementServer).PurgeAskPlans(ctx, req.(*Empty))
	}
	return interceptor(ctx, in, info, handler)
}

func _WorkerManagement_PurgeAskPlansDetailed_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(Empty)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(WorkerManagementServer).PurgeAskPlansDetailed(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/sonm.WorkerManagement/PurgeAskPlansDetailed",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(WorkerManagementServer).PurgeAskPlansDetailed(ctx, req.(*Empty))
	}
	return interceptor(ctx, in, info, handler)
}

func _WorkerManagement_ScheduleMaintenance_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(Timestamp)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(WorkerManagementServer).ScheduleMaintenance(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/sonm.WorkerManagement/ScheduleMaintenance",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(WorkerManagementServer).ScheduleMaintenance(ctx, req.(*Timestamp))
	}
	return interceptor(ctx, in, info, handler)
}

func _WorkerManagement_NextMaintenance_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(Empty)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(WorkerManagementServer).NextMaintenance(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/sonm.WorkerManagement/NextMaintenance",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(WorkerManagementServer).NextMaintenance(ctx, req.(*Empty))
	}
	return interceptor(ctx, in, info, handler)
}

func _WorkerManagement_DebugState_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(Empty)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(WorkerManagementServer).DebugState(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/sonm.WorkerManagement/DebugState",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(WorkerManagementServer).DebugState(ctx, req.(*Empty))
	}
	return interceptor(ctx, in, info, handler)
}

func _WorkerManagement_RemoveBenchmark_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(NumericID)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(WorkerManagementServer).RemoveBenchmark(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/sonm.WorkerManagement/RemoveBenchmark",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(WorkerManagementServer).RemoveBenchmark(ctx, req.(*NumericID))
	}
	return interceptor(ctx, in, info, handler)
}

func _WorkerManagement_PurgeBenchmarks_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(Empty)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(WorkerManagementServer).PurgeBenchmarks(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/sonm.WorkerManagement/PurgeBenchmarks",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(WorkerManagementServer).PurgeBenchmarks(ctx, req.(*Empty))
	}
	return interceptor(ctx, in, info, handler)
}

func _WorkerManagement_Metrics_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(WorkerMetricsRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(WorkerManagementServer).Metrics(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/sonm.WorkerManagement/Metrics",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(WorkerManagementServer).Metrics(ctx, req.(*WorkerMetricsRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _WorkerManagement_AddCapability_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(WorkerAddCapabilityRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(WorkerManagementServer).AddCapability(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/sonm.WorkerManagement/AddCapability",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(WorkerManagementServer).AddCapability(ctx, req.(*WorkerAddCapabilityRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _WorkerManagement_RemoveCapability_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(WorkerRemoveCapabilityRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(WorkerManagementServer).RemoveCapability(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/sonm.WorkerManagement/RemoveCapability",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(WorkerManagementServer).RemoveCapability(ctx, req.(*WorkerRemoveCapabilityRequest))
	}
	return interceptor(ctx, in, info, handler)
}

var _WorkerManagement_serviceDesc = grpc.ServiceDesc{
	ServiceName: "sonm.WorkerManagement",
	HandlerType: (*WorkerManagementServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Status",
			Handler:    _WorkerManagement_Status_Handler,
		},
		{
			MethodName: "Devices",
			Handler:    _WorkerManagement_Devices_Handler,
		},
		{
			MethodName: "FreeDevices",
			Handler:    _WorkerManagement_FreeDevices_Handler,
		},
		{
			MethodName: "Tasks",
			Handler:    _WorkerManagement_Tasks_Handler,
		},
		{
			MethodName: "AskPlans",
			Handler:    _WorkerManagement_AskPlans_Handler,
		},
		{
			MethodName: "CreateAskPlan",
			Handler:    _WorkerManagement_CreateAskPlan_Handler,
		},
		{
			MethodName: "RemoveAskPlan",
			Handler:    _WorkerManagement_RemoveAskPlan_Handler,
		},
		{
			MethodName: "PurgeAskPlans",
			Handler:    _WorkerManagement_PurgeAskPlans_Handler,
		},
		{
			MethodName: "PurgeAskPlansDetailed",
			Handler:    _WorkerManagement_PurgeAskPlansDetailed_Handler,
		},
		{
			MethodName: "ScheduleMaintenance",
			Handler:    _WorkerManagement_ScheduleMaintenance_Handler,
		},
		{
			MethodName: "NextMaintenance",
			Handler:    _WorkerManagement_NextMaintenance_Handler,
		},
		{
			MethodName: "DebugState",
			Handler:    _WorkerManagement_DebugState_Handler,
		},
		{
			MethodName: "RemoveBenchmark",
			Handler:    _WorkerManagement_RemoveBenchmark_Handler,
		},
		{
			MethodName: "PurgeBenchmarks",
			Handler:    _WorkerManagement_PurgeBenchmarks_Handler,
		},
		{
			MethodName: "Metrics",
			Handler:    _WorkerManagement_Metrics_Handler,
		},
		{
			MethodName: "AddCapability",
			Handler:    _WorkerManagement_AddCapability_Handler,
		},
		{
			MethodName: "RemoveCapability",
			Handler:    _WorkerManagement_RemoveCapability_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "worker.proto",
}

// Client API for Worker service

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

type workerClient struct {
	cc *grpc.ClientConn
}

func NewWorkerClient(cc *grpc.ClientConn) WorkerClient {
	return &workerClient{cc}
}

func (c *workerClient) PushTask(ctx context.Context, opts ...grpc.CallOption) (Worker_PushTaskClient, error) {
	stream, err := grpc.NewClientStream(ctx, &_Worker_serviceDesc.Streams[0], c.cc, "/sonm.Worker/PushTask", opts...)
	if err != nil {
		return nil, err
	}
	x := &workerPushTaskClient{stream}
	return x, nil
}

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

type workerPushTaskClient struct {
	grpc.ClientStream
}

func (x *workerPushTaskClient) Send(m *Chunk) error {
	return x.ClientStream.SendMsg(m)
}

func (x *workerPushTaskClient) Recv() (*Progress, error) {
	m := new(Progress)
	if err := x.ClientStream.RecvMsg(m); err != nil {
		return nil, err
	}
	return m, nil
}

func (c *workerClient) PullTask(ctx context.Context, in *PullTaskRequest, opts ...grpc.CallOption) (Worker_PullTaskClient, error) {
	stream, err := grpc.NewClientStream(ctx, &_Worker_serviceDesc.Streams[1], c.cc, "/sonm.Worker/PullTask", opts...)
	if err != nil {
		return nil, err
	}
	x := &workerPullTaskClient{stream}
	if err := x.ClientStream.SendMsg(in); err != nil {
		return nil, err
	}
	if err := x.ClientStream.CloseSend(); err != nil {
		return nil, err
	}
	return x, nil
}

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

type workerPullTaskClient struct {
	grpc.ClientStream
}

func (x *workerPullTaskClient) Recv() (*Chunk, error) {
	m := new(Chunk)
	if err := x.ClientStream.RecvMsg(m); err != nil {
		return nil, err
	}
	return m, nil
}

func (c *workerClient) StartTask(ctx context.Context, in *StartTaskRequest, opts ...grpc.CallOption) (*StartTaskReply, error) {
	out := new(StartTaskReply)
	err := grpc.Invoke(ctx, "/sonm.Worker/StartTask", in, out, c.cc, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *workerClient) StopTask(ctx context.Context, in *ID, opts ...grpc.CallOption) (*Empty, error) {
	out := new(Empty)
	err := grpc.Invoke(ctx, "/sonm.Worker/StopTask", in, out, c.cc, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *workerClient) PurgeTasks(ctx context.Context, in *PurgeTasksRequest, opts ...grpc.CallOption) (*ErrorByStringID, error) {
	out := new(ErrorByStringID)
	err := grpc.Invoke(ctx, "/sonm.Worker/PurgeTasks", in, out, c.cc, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *workerClient) TaskStatus(ctx context.Context, in *ID, opts ...grpc.CallOption) (*TaskStatusReply, error) {
	out := new(TaskStatusReply)
	err := grpc.Invoke(ctx, "/sonm.Worker/TaskStatus", in, out, c.cc, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *workerClient) JoinNetwork(ctx context.Context, in *WorkerJoinNetworkRequest, opts ...grpc.CallOption) (*NetworkSpec, error) {
	out := new(NetworkSpec)
	err := grpc.Invoke(ctx, "/sonm.Worker/JoinNetwork", in, out, c.cc, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

func (c *workerClient) TaskLogs(ctx context.Context, in *TaskLogsRequest, opts ...grpc.CallOption) (Worker_TaskLogsClient, error) {
	stream, err := grpc.NewClientStream(ctx, &_Worker_serviceDesc.Streams[2], c.cc, "/sonm.Worker/TaskLogs", opts...)
	if err != nil {
		return nil, err
	}
	x := &workerTaskLogsClient{stream}
	if err := x.ClientStream.SendMsg(in); err != nil {
		return nil, err
	}
	if err := x.ClientStream.CloseSend(); err != nil {
		return nil, err
	}
	return x, nil
}

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

type workerTaskLogsClient struct {
	grpc.ClientStream
}

func (x *workerTaskLogsClient) Recv() (*TaskLogsChunk, error) {
	m := new(TaskLogsChunk)
	if err := x.ClientStream.RecvMsg(m); err != nil {
		return nil, err
	}
	return m, nil
}

func (c *workerClient) GetDealInfo(ctx context.Context, in *ID, opts ...grpc.CallOption) (*DealInfoReply, error) {
	out := new(DealInfoReply)
	err := grpc.Invoke(ctx, "/sonm.Worker/GetDealInfo", in, out, c.cc, opts...)
	if err != nil {
		return nil, err
	}
	return out, nil
}

// Server API for Worker service

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

func RegisterWorkerServer(s *grpc.Server, srv WorkerServer) {
	s.RegisterService(&_Worker_serviceDesc, srv)
}

func _Worker_PushTask_Handler(srv interface{}, stream grpc.ServerStream) error {
	return srv.(WorkerServer).PushTask(&workerPushTaskServer{stream})
}

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

type workerPushTaskServer struct {
	grpc.ServerStream
}

func (x *workerPushTaskServer) Send(m *Progress) error {
	return x.ServerStream.SendMsg(m)
}

func (x *workerPushTaskServer) Recv() (*Chunk, error) {
	m := new(Chunk)
	if err := x.ServerStream.RecvMsg(m); err != nil {
		return nil, err
	}
	return m, nil
}

func _Worker_PullTask_Handler(srv interface{}, stream grpc.ServerStream) error {
	m := new(PullTaskRequest)
	if err := stream.RecvMsg(m); err != nil {
		return err
	}
	return srv.(WorkerServer).PullTask(m, &workerPullTaskServer{stream})
}

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

type workerPullTaskServer struct {
	grpc.ServerStream
}

func (x *workerPullTaskServer) Send(m *Chunk) error {
	return x.ServerStream.SendMsg(m)
}

func _Worker_StartTask_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(StartTaskRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(WorkerServer).StartTask(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/sonm.Worker/StartTask",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(WorkerServer).StartTask(ctx, req.(*StartTaskRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _Worker_StopTask_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ID)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(WorkerServer).StopTask(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/sonm.Worker/StopTask",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(WorkerServer).StopTask(ctx, req.(*ID))
	}
	return interceptor(ctx, in, info, handler)
}

func _Worker_PurgeTasks_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(PurgeTasksRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(WorkerServer).PurgeTasks(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/sonm.Worker/PurgeTasks",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(WorkerServer).PurgeTasks(ctx, req.(*PurgeTasksRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _Worker_TaskStatus_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ID)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(WorkerServer).TaskStatus(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/sonm.Worker/TaskStatus",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(WorkerServer).TaskStatus(ctx, req.(*ID))
	}
	return interceptor(ctx, in, info, handler)
}

func _Worker_JoinNetwork_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(WorkerJoinNetworkRequest)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(WorkerServer).JoinNetwork(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/sonm.Worker/JoinNetwork",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(WorkerServer).JoinNetwork(ctx, req.(*WorkerJoinNetworkRequest))
	}
	return interceptor(ctx, in, info, handler)
}

func _Worker_TaskLogs_Handler(srv interface{}, stream grpc.ServerStream) error {
	m := new(TaskLogsRequest)
	if err := stream.RecvMsg(m); err != nil {
		return err
	}
	return srv.(WorkerServer).TaskLogs(m, &workerTaskLogsServer{stream})
}

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

type workerTaskLogsServer struct {
	grpc.ServerStream
}

func (x *workerTaskLogsServer) Send(m *TaskLogsChunk) error {
	return x.ServerStream.SendMsg(m)
}

func _Worker_GetDealInfo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
	in := new(ID)
	if err := dec(in); err != nil {
		return nil, err
	}
	if interceptor == nil {
		return srv.(WorkerServer).GetDealInfo(ctx, in)
	}
	info := &grpc.UnaryServerInfo{
		Server:     srv,
		FullMethod: "/sonm.Worker/GetDealInfo",
	}
	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
		return srv.(WorkerServer).GetDealInfo(ctx, req.(*ID))
	}
	return interceptor(ctx, in, info, handler)
}

var _Worker_serviceDesc = grpc.ServiceDesc{
	ServiceName: "sonm.Worker",
	HandlerType: (*WorkerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "StartTask",
			Handler:    _Worker_StartTask_Handler,
		},
		{
			MethodName: "StopTask",
			Handler:    _Worker_StopTask_Handler,
		},
		{
			MethodName: "PurgeTasks",
			Handler:    _Worker_PurgeTasks_Handler,
		},
		{
			MethodName: "TaskStatus",
			Handler:    _Worker_TaskStatus_Handler,
		},
		{
			MethodName: "JoinNetwork",
			Handler:    _Worker_JoinNetwork_Handler,
		},
		{
			MethodName: "GetDealInfo",
			Handler:    _Worker_GetDealInfo_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "PushTask",
			Handler:       _Worker_PushTask_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "PullTask",
			Handler:       _Worker_PullTask_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "TaskLogs",
			Handler:       _Worker_TaskLogs_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "worker.proto",
}

func init() { proto.RegisterFile("worker.proto", fileDescriptor21) }

var fileDescriptor21 = []byte{
	// 2281 bytes of a gzipped FileDescriptorProto
	0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xbc, 0x59, 0xdb, 0x6e, 0x1b, 0xc9,
	0xd1, 0x26, 0x45, 0x8a, 0x87, 0xe2, 0x51, 0x2d, 0x5b, 0x3f, 0xff, 0xb1, 0xe5, 0x95, 0xc7, 0xde,
	0x8d, 0xe2, 0xb5, 0x69, 0xaf, 0xf6, 0x80, 0xac, 0x9d, 0x0d, 0x96, 0x22, 0x25, 0x99, 0xb6, 0x44,
	0x32, 0x43, 0x29, 0x46, 0x82, 0x00, 0x46, 0x8b, 0x6c, 0x53, 0x13, 0x91, 0x33, 0x93, 0xe9, 0xa6,
	0xbd, 0xca, 0x75, 0x90, 0xdc, 0xe7, 0x26, 0x40, 0x90, 0x17, 0xc8, 0x4d, 0x6e, 0x72, 0x15, 0x60,
	0x9f, 0x20, 0x0f, 0x13, 0xe4, 0x11, 0x82, 0x3e, 0xcd, 0x81, 0x1c, 0x3a, 0x31, 0x6c, 0xe4, 0x8e,
	0x5d, 0xf5, 0x7d, 0xd5, 0xd5, 0xd5, 0xd5, 0x55, 0x3d, 0x4d, 0x28, 0xbf, 0x71, 0xfd, 0x4b, 0xe2,
	0x37, 0x3d, 0xdf, 0x65, 0x2e, 0xca, 0x52, 0xd7, 0x99, 0x19, 0x55, 0x4c, 0x2f, 0x5f, 0x7a, 0x53,
	0xec, 0x48, 0xa9, 0x51, 0x3e, 0xb7, 0x27, 0xb6, 0xc3, 0xd4, 0x08, 0x8d, 0xb0, 0x87, 0xcf, 0xed,
	0xa9, 0xcd, 0x6c, 0x42, 0x95, 0xac, 0x36, 0x72, 0x1d, 0x86, 0x6d, 0x47, 0x1b, 0x32, 0x4a, 0x13,
	0xe2, 0xda, 0x9e, 0xd6, 0xda, 0x0e, 0xb7, 0xeb, 0xd8, 0x58, 0x09, 0x36, 0x66, 0xd8, 0xbf, 0x24,
	0xcc, 0x9b, 0xe2, 0x11, 0x51, 0xa2, 0xa2, 0x43, 0xf4, 0x04, 0x35, 0x66, 0xcf, 0x08, 0x65, 0x78,
	0xa6, 0xf8, 0xe6, 0x36, 0xe4, 0x4f, 0x31, 0xbd, 0x3c, 0xc5, 0x13, 0x84, 0x20, 0x3b, 0xc6, 0x0c,
	0x37, 0xd2, 0x3b, 0xe9, 0xdd, 0xb2, 0x25, 0x7e, 0x9b, 0xdf, 0xa7, 0xa1, 0xc0, 0xf5, 0x43, 0x8f,
	0x8c, 0xd0, 0x03, 0x28, 0x06, 0xbe, 0x08, 0x54, 0x69, 0xaf, 0xd6, 0xe4, 0xb3, 0x37, 0xdb, 0x5a,
	0x6c, 0x85, 0x08, 0x74, 0x0f, 0x0a, 0x3e, 0x99, 0xd8, 0x94, 0xf9, 0x57, 0x8d, 0x35, 0x81, 0xae,
	0x4a, 0xb4, 0xa5, 0xa4, 0x56, 0xa0, 0x47, 0x5f, 0x40, 0xd1, 0x27, 0xd4, 0x9d, 0xfb, 0x23, 0x42,
	0x1b, 0x19, 0x01, 0xde, 0x92, 0xe0, 0x16, 0xbd, 0x1c, 0x4c, 0xb1, 0x63, 0x69, 0xad, 0x15, 0x02,
	0xd1, 0x47, 0x90, 0x61, 0x78, 0xd2, 0xc8, 0x0a, 0x7c, 0x45, 0xe2, 0xd5, 0x6a, 0x2c, 0xae, 0x31,
	0x7f, 0x09, 0xf5, 0x21, 0xc3, 0x3e, 0xe3, 0x42, 0x8b, 0xfc, 0x7a, 0x4e, 0x28, 0x43, 0x77, 0x21,
	0x37, 0x26, 0x78, 0xda, 0xed, 0xa8, 0x25, 0x94, 0x25, 0x6f, 0xdf, 0x9e, 0x74, 0x1d, 0x66, 0x29,
	0x1d, 0x32, 0x21, 0x4b, 0x3d, 0x32, 0x8a, 0x3b, 0xae, 0x23, 0x61, 0x09, 0x9d, 0x39, 0x80, 0xc6,
	0x0b, 0xb1, 0xc3, 0xcf, 0x5c, 0xdb, 0xe9, 0x11, 0xc6, 0xb7, 0x5b, 0xcf, 0xb2, 0x05, 0x39, 0x86,
	0xe9, 0xa5, 0x9a, 0xa5, 0x68, 0xa9, 0x11, 0xba, 0x09, 0x7c, 0x37, 0x38, 0xb2, 0xdb, 0x11, 0xc6,
	0x8b, 0x56, 0x28, 0x30, 0xff, 0x91, 0x86, 0x6a, 0xc4, 0x61, 0x6f, 0x7a, 0x85, 0xaa, 0xb0, 0x66,
	0x8f, 0x95, 0x91, 0x35, 0x7b, 0x8c, 0x9e, 0x40, 0xde, 0x73, 0x7d, 0x76, 0x82, 0xbd, 0xc6, 0xda,
	0x4e, 0x66, 0xb7, 0xb4, 0x77, 0x5b, 0xfa, 0x16, 0xa7, 0x35, 0x07, 0x12, 0x73, 0xe0, 0xf0, 0x38,
	0x6b, 0x06, 0xba, 0x05, 0x10, 0x4c, 0xc6, 0xe3, 0x9c, 0xd9, 0x2d, 0x5a, 0x11, 0x89, 0xf1, 0x1c,
	0xca, 0x51, 0x22, 0xaa, 0x43, 0xe6, 0x92, 0x5c, 0xa9, 0xd9, 0xf9, 0x4f, 0xf4, 0x31, 0xac, 0xbf,
	0xc6, 0xd3, 0x39, 0x51, 0x81, 0x51, 0xfb, 0x7f, 0xe0, 0x8c, 0x3d, 0xd7, 0x76, 0x18, 0xb5, 0xa4,
	0xf6, 0xf1, 0xda, 0x8f, 0xd2, 0xe6, 0x5f, 0x33, 0x50, 0x1a, 0x32, 0xcc, 0xe6, 0x54, 0xae, 0x64,
	0x0b, 0x72, 0x73, 0x8f, 0xe7, 0x9f, 0xb0, 0x97, 0xb5, 0xd4, 0x08, 0x35, 0x20, 0xff, 0x9a, 0xf8,
	0xd4, 0x76, 0x1d, 0x15, 0x10, 0x3d, 0x44, 0x06, 0x14, 0xbc, 0x29, 0x66, 0xaf, 0x5c, 0x7f, 0x26,
	0x92, 0xa2, 0x68, 0x05, 0x63, 0xce, 0x22, 0xec, 0xa2, 0x35, 0x1e, 0xfb, 0x62, 0xff, 0x8b, 0x96,
	0x1e, 0xf2, 0x10, 0xf3, 0x60, 0xb7, 0xdd, 0xb9, 0xc3, 0x1a, 0xeb, 0x3b, 0xe9, 0xdd, 0x8a, 0x15,
	0x0a, 0xb8, 0xb6, 0xf3, 0xe2, 0xa9, 0xf4, 0xab, 0x91, 0x93, 0x1b, 0x10, 0x08, 0xd0, 0x3d, 0xa8,
	0xfb, 0xc4, 0x19, 0x93, 0xdf, 0xbc, 0x76, 0xe7, 0x54, 0x81, 0xf2, 0x02, 0xb4, 0x24, 0x47, 0xbb,
	0x90, 0x9b, 0x61, 0xca, 0x88, 0xdf, 0x28, 0x88, 0x58, 0xd4, 0x55, 0x2c, 0xa4, 0x1b, 0x84, 0x52,
	0x4b, 0xe9, 0xd1, 0x27, 0xb0, 0x8e, 0xc7, 0x33, 0xdb, 0x69, 0x14, 0x57, 0x00, 0xa5, 0x1a, 0xdd,
	0x87, 0x0d, 0x9b, 0x9e, 0x08, 0x4e, 0xdb, 0x75, 0x5e, 0xd9, 0xfe, 0x8c, 0x8c, 0x1b, 0xb0, 0x93,
	0xde, 0x2d, 0x58, 0xcb, 0x0a, 0xf4, 0x08, 0x36, 0x6d, 0xba, 0x4f, 0x9c, 0xd1, 0x05, 0x3f, 0xf2,
	0x87, 0xb6, 0x63, 0xd3, 0x0b, 0x32, 0x6e, 0x94, 0x04, 0x3e, 0x49, 0x85, 0xb6, 0x21, 0x33, 0x21,
	0x6e, 0xa3, 0x2c, 0xbc, 0x28, 0x49, 0x2f, 0x8e, 0x88, 0xdb, 0x1d, 0x58, 0x5c, 0x6e, 0xfe, 0x29,
	0x0d, 0x15, 0x75, 0xdc, 0xd4, 0x96, 0x7d, 0x03, 0x05, 0xac, 0x04, 0x8d, 0x74, 0x34, 0xdb, 0x62,
	0xb0, 0x60, 0x24, 0xb3, 0x2d, 0xa0, 0x18, 0xcf, 0x42, 0x7b, 0xab, 0xf2, 0xe9, 0x4e, 0x3c, 0x9f,
	0x2a, 0xf1, 0x43, 0x1f, 0xc9, 0xa6, 0x3f, 0xa4, 0xa1, 0xc2, 0xd3, 0xfb, 0xd8, 0xa6, 0x4c, 0x3a,
	0xf7, 0x19, 0x64, 0x6d, 0xe7, 0x95, 0xab, 0x1c, 0xdb, 0x0e, 0x8f, 0x68, 0x00, 0x69, 0x76, 0x9d,
	0x57, 0xae, 0x74, 0x4a, 0x40, 0x8d, 0x1e, 0x14, 0x03, 0x51, 0x82, 0x33, 0x9f, 0xc6, 0x9d, 0xb9,
	0x1e, 0x39, 0xf5, 0x61, 0x1e, 0x47, 0x9d, 0xfa, 0x7b, 0x1a, 0xca, 0x1d, 0xf2, 0xda, 0xe6, 0x75,
	0x49, 0xf8, 0x74, 0x03, 0x32, 0xed, 0xc1, 0x99, 0xaa, 0x2c, 0x45, 0x55, 0x1c, 0x07, 0x67, 0x16,
	0x97, 0xa2, 0x6d, 0xc8, 0x1e, 0x0d, 0xce, 0xa8, 0x3a, 0xb7, 0x4a, 0x7b, 0x34, 0x38, 0xb3, 0x84,
	0x98, 0x73, 0xad, 0xd6, 0x89, 0xaa, 0x7e, 0x4a, 0x6b, 0xb5, 0x4e, 0x2c, 0x2e, 0x45, 0x3f, 0x80,
	0xbc, 0x3a, 0xa7, 0xf1, 0x72, 0xa7, 0xcb, 0x8e, 0xd6, 0x72, 0x20, 0x65, 0xae, 0x8f, 0x27, 0x44,
	0xe4, 0x7e, 0x00, 0x1c, 0x4a, 0xa1, 0xa5, 0xb5, 0x66, 0x0b, 0x6a, 0x83, 0xf9, 0x74, 0x1a, 0x2d,
	0x8d, 0x5b, 0xaa, 0x34, 0xea, 0x7a, 0xa3, 0x46, 0x41, 0x31, 0x1b, 0xab, 0x03, 0xaa, 0x46, 0xe6,
	0x5f, 0x32, 0x50, 0xe9, 0x70, 0x88, 0xf3, 0xca, 0x95, 0xeb, 0xbf, 0x05, 0x59, 0xce, 0x51, 0x01,
	0x00, 0x39, 0x35, 0x87, 0x58, 0x42, 0x8e, 0x1e, 0x43, 0xde, 0x9f, 0x3b, 0x8e, 0xed, 0x4c, 0x54,
	0x14, 0x76, 0x42, 0x48, 0x60, 0xa5, 0x69, 0x49, 0x88, 0x2a, 0x5e, 0x8a, 0x80, 0xbe, 0xe5, 0xed,
	0x67, 0xe6, 0x4d, 0x09, 0x23, 0x63, 0x51, 0xbb, 0x4a, 0x7b, 0x66, 0x12, 0xbb, 0xad, 0x41, 0x92,
	0x1f, 0x92, 0xe2, 0x5d, 0x26, 0xfb, 0xdf, 0x76, 0x99, 0x9b, 0x50, 0xf4, 0xe6, 0xe7, 0x53, 0x7b,
	0xd4, 0x1d, 0xd0, 0xc6, 0xba, 0xa8, 0x99, 0xa1, 0xc0, 0xf8, 0x29, 0x94, 0xa3, 0xee, 0x7e, 0x80,
	0xac, 0x32, 0x86, 0x50, 0x8d, 0xaf, 0xe1, 0x43, 0xa4, 0xea, 0xef, 0xb2, 0x50, 0x5b, 0x50, 0xa3,
	0x2f, 0x20, 0x47, 0x65, 0x8d, 0xe3, 0x96, 0xab, 0x7b, 0x37, 0x13, 0xad, 0x34, 0xd5, 0x6f, 0x85,
	0xe5, 0xf1, 0xb0, 0x67, 0x78, 0x42, 0x7a, 0x78, 0x46, 0x74, 0x0b, 0x0b, 0x04, 0xe8, 0xc7, 0x61,
	0x7f, 0x8a, 0xed, 0xd1, 0xa2, 0xd1, 0xe4, 0x06, 0x15, 0xf6, 0x88, 0x6c, 0xac, 0x47, 0xfc, 0x10,
	0xd6, 0xe7, 0x34, 0xcc, 0xe9, 0x4d, 0x7d, 0x91, 0x90, 0x7b, 0x74, 0xc6, 0x55, 0x96, 0x44, 0xa0,
	0x43, 0x40, 0x78, 0x3a, 0x75, 0x47, 0x98, 0x91, 0x71, 0xb0, 0x9f, 0xa2, 0xd2, 0xaf, 0xde, 0xed,
	0x04, 0x86, 0xbe, 0x5c, 0xe4, 0x57, 0x5d, 0x2e, 0x3e, 0x6c, 0xb3, 0xbc, 0x80, 0x9c, 0x6a, 0x2b,
	0x25, 0xc8, 0x9f, 0xf5, 0x9e, 0xf7, 0xfa, 0x2f, 0x7a, 0xf5, 0x14, 0x2a, 0x43, 0x61, 0x38, 0xe8,
	0xf7, 0x8f, 0xbb, 0xbd, 0xa3, 0x7a, 0x5a, 0x8e, 0x5a, 0x2f, 0x7a, 0x7c, 0xb4, 0xc6, 0x81, 0xd6,
	0x59, 0x4f, 0x0c, 0x32, 0x5c, 0x75, 0xd8, 0xed, 0x75, 0x87, 0x4f, 0x0f, 0x3a, 0xf5, 0x2c, 0x02,
	0xc8, 0xed, 0x5b, 0xfd, 0xe7, 0x07, 0xbd, 0xfa, 0x3a, 0xaa, 0x02, 0x3c, 0xef, 0x1e, 0x1f, 0x1f,
	0x74, 0x5e, 0xf6, 0xfb, 0x27, 0xf5, 0x9c, 0xf9, 0x37, 0x75, 0xa5, 0x1b, 0xb8, 0xee, 0x14, 0xed,
	0x42, 0x06, 0x4f, 0xf5, 0x71, 0x5d, 0x15, 0x1d, 0x0e, 0x41, 0xf7, 0x21, 0x3b, 0xa7, 0x64, 0xac,
	0x8e, 0x6d, 0x23, 0x8c, 0x07, 0xb7, 0xd3, 0x3c, 0xa3, 0xfa, 0xb8, 0x09, 0x94, 0xd1, 0x87, 0x62,
	0x20, 0x4a, 0x08, 0xcc, 0xfd, 0x78, 0x60, 0x56, 0x4d, 0x1c, 0x89, 0xcf, 0x6f, 0x73, 0x50, 0x52,
	0xfa, 0x77, 0x74, 0xfc, 0x09, 0x14, 0xb8, 0x4b, 0x43, 0xcf, 0x65, 0xca, 0xf9, 0x8f, 0x62, 0xf0,
	0xc0, 0x7f, 0x8e, 0x50, 0x1d, 0x4c, 0x13, 0xd0, 0x97, 0x90, 0xe3, 0xbf, 0x0f, 0xdf, 0xa8, 0x64,
	0xde, 0x4e, 0xa6, 0x1e, 0xbe, 0x91, 0x44, 0x05, 0x46, 0x47, 0x50, 0x1e, 0xb9, 0xb3, 0x99, 0xcd,
	0xd4, 0xbc, 0x59, 0x41, 0xbe, 0xb3, 0x4c, 0x6e, 0x47, 0x50, 0xd2, 0x44, 0x8c, 0x88, 0x5a, 0x00,
	0x7a, 0x7c, 0xf8, 0x46, 0x14, 0x9f, 0xc5, 0x16, 0x1c, 0x33, 0xa3, 0xfd, 0x88, 0x90, 0xb8, 0x2f,
	0xe4, 0x57, 0x64, 0xc4, 0xc8, 0x58, 0xf6, 0xf1, 0xdc, 0x2a, 0x5f, 0x0e, 0x22, 0x28, 0xe5, 0x4b,
	0x94, 0xc8, 0xbb, 0x79, 0x2c, 0x4c, 0xef, 0xd1, 0xcd, 0x8d, 0xa7, 0x50, 0x8a, 0xc4, 0xed, 0x7d,
	0x2c, 0xf5, 0x60, 0x63, 0x29, 0x88, 0xef, 0x63, 0xef, 0x18, 0x6a, 0x0b, 0xd1, 0x7c, 0x4f, 0xef,
	0x96, 0xc2, 0xfa, 0x3e, 0xb7, 0xa0, 0x7f, 0xad, 0x41, 0x65, 0x38, 0xba, 0x20, 0xe3, 0xf9, 0x94,
	0xf8, 0x1d, 0xcc, 0x30, 0x3a, 0x86, 0x0a, 0xef, 0xc6, 0xa7, 0xae, 0x42, 0xab, 0xeb, 0xd0, 0x27,
	0xaa, 0xeb, 0x47, 0xb1, 0xb2, 0x7c, 0x69, 0xa0, 0xdc, 0xe2, 0x38, 0x19, 0x75, 0xa1, 0x8c, 0xc3,
	0x94, 0xa0, 0x2a, 0xeb, 0x3f, 0x4e, 0x32, 0x16, 0x49, 0x1d, 0x9d, 0x2e, 0x51, 0x2a, 0x7a, 0x20,
	0x2e, 0xef, 0x62, 0xa0, 0x7a, 0xed, 0xc6, 0x52, 0xce, 0x59, 0x01, 0xc4, 0xf8, 0x16, 0xd0, 0xb2,
	0x7b, 0x09, 0xa1, 0xba, 0x16, 0x0d, 0x55, 0x31, 0x1a, 0xeb, 0x3e, 0x6c, 0x2c, 0xf9, 0x94, 0x60,
	0xe0, 0x6e, 0x3c, 0xd6, 0xd5, 0x78, 0x25, 0x8b, 0x18, 0x7c, 0x96, 0x2d, 0xac, 0xd5, 0x33, 0xe6,
	0x9f, 0x33, 0x50, 0x1e, 0xe2, 0x29, 0xa1, 0x33, 0xec, 0x88, 0x88, 0xf7, 0xa0, 0xaa, 0x16, 0xda,
	0x3e, 0xf2, 0xdd, 0xb9, 0xa7, 0x2f, 0x74, 0x3a, 0xe4, 0x11, 0xac, 0x5e, 0xab, 0x02, 0xca, 0x30,
	0x2d, 0xb0, 0xd1, 0xe7, 0xb0, 0xce, 0xef, 0x46, 0x34, 0x5e, 0x62, 0x62, 0x66, 0xf8, 0x05, 0x47,
	0xb1, 0x25, 0x16, 0x7d, 0x05, 0x39, 0xd7, 0x1f, 0x13, 0x9f, 0xaa, 0xda, 0x72, 0x2b, 0x81, 0xd5,
	0x17, 0x00, 0x55, 0x99, 0x24, 0xda, 0x68, 0xc1, 0x66, 0x82, 0x4f, 0xef, 0x14, 0xe7, 0x0e, 0x40,
	0xe8, 0x4f, 0x02, 0x73, 0x27, 0x1e, 0xe0, 0xe8, 0x25, 0x30, 0x62, 0xe5, 0x10, 0x4a, 0x11, 0xff,
	0x12, 0xcc, 0xdc, 0x8e, 0x9b, 0x51, 0x9f, 0x2b, 0x82, 0x13, 0x6b, 0x0c, 0x69, 0xa8, 0x75, 0xc8,
	0xf9, 0x7c, 0xc2, 0xdb, 0x27, 0x91, 0xf7, 0x9a, 0xaf, 0xa1, 0x42, 0xa3, 0xb9, 0xaa, 0xda, 0xc4,
	0x66, 0x42, 0x1a, 0x5b, 0x71, 0x24, 0xfa, 0x0a, 0xca, 0x34, 0x12, 0x43, 0x35, 0x39, 0x5a, 0x8e,
	0xae, 0x15, 0xc3, 0x99, 0x5f, 0xc3, 0xc6, 0x60, 0xee, 0x4f, 0x08, 0xcf, 0x23, 0xfa, 0x4e, 0x4f,
	0x0d, 0xe6, 0x16, 0x5c, 0x93, 0xcf, 0x08, 0x27, 0x84, 0xf9, 0xf6, 0x48, 0xb3, 0xcd, 0x3f, 0xa6,
	0xe1, 0xfa, 0x82, 0x82, 0x7a, 0xae, 0x43, 0x09, 0xda, 0x87, 0xfc, 0x4c, 0x8a, 0xd4, 0x69, 0xdf,
	0x95, 0x86, 0x13, 0xd1, 0x4d, 0x35, 0x56, 0x37, 0x2d, 0x45, 0x34, 0x1e, 0x43, 0x39, 0xaa, 0xf8,
	0x4f, 0x19, 0x90, 0x8e, 0xc6, 0xfc, 0xf7, 0x69, 0x30, 0xe4, 0x5c, 0xad, 0xf1, 0xb8, 0xad, 0x9f,
	0xac, 0xae, 0xf4, 0xb2, 0xef, 0x41, 0x9e, 0xce, 0xcf, 0x79, 0xd9, 0x53, 0xeb, 0x5e, 0xfe, 0xe0,
	0xd5, 0x00, 0x7e, 0x8f, 0xa5, 0x23, 0xd7, 0x93, 0x93, 0x54, 0xf5, 0x3d, 0x36, 0xb4, 0x39, 0xe4,
	0x4a, 0x4b, 0x62, 0xb8, 0x8f, 0x8c, 0x4d, 0xc5, 0x17, 0x52, 0xc5, 0xe2, 0x3f, 0xcd, 0x6d, 0xb8,
	0x91, 0xe8, 0x88, 0x5c, 0xba, 0xf9, 0x1d, 0x6c, 0x4b, 0xb5, 0x45, 0x66, 0xee, 0x6b, 0xf2, 0xbf,
	0x73, 0xd5, 0xdc, 0x81, 0x5b, 0xab, 0x66, 0x96, 0xbe, 0xdd, 0x3b, 0x83, 0xda, 0x02, 0x17, 0x6d,
	0x42, 0xad, 0xdd, 0x1a, 0xb4, 0xf6, 0xbb, 0xc7, 0xdd, 0xd3, 0x9f, 0xbf, 0xec, 0xf5, 0x7b, 0x07,
	0xf5, 0x14, 0x42, 0x50, 0x8d, 0x08, 0x87, 0xc3, 0xa7, 0xf5, 0x34, 0xfa, 0x7f, 0xb8, 0x1e, 0x91,
	0x75, 0x7b, 0xc3, 0xc1, 0x41, 0xfb, 0xb4, 0xdb, 0xef, 0xd5, 0xd7, 0xf6, 0xbe, 0xcf, 0x43, 0x5d,
	0xe5, 0x01, 0x76, 0xf0, 0x84, 0xcc, 0x88, 0xc3, 0x97, 0x19, 0xdc, 0x2e, 0xd5, 0xfa, 0x66, 0x1e,
	0xbb, 0x32, 0x36, 0x82, 0xa7, 0x23, 0x7d, 0x2d, 0x37, 0x53, 0xe8, 0x3e, 0xe4, 0xd5, 0x27, 0x6d,
	0x1c, 0x8c, 0xf4, 0x39, 0x0e, 0x3f, 0x77, 0xcd, 0x14, 0x7a, 0x04, 0xa5, 0x43, 0x9f, 0x90, 0x77,
	0x60, 0x7c, 0x0a, 0xeb, 0xe2, 0x90, 0xc4, 0xb1, 0x9b, 0x09, 0x9f, 0xef, 0x66, 0x0a, 0x35, 0xa1,
	0xa0, 0x5f, 0x10, 0x12, 0xf1, 0xb1, 0x77, 0x08, 0x33, 0x85, 0xee, 0x41, 0xa5, 0xed, 0x13, 0xcc,
	0x88, 0x6e, 0x68, 0xf1, 0x56, 0x6a, 0x14, 0xe4, 0xb0, 0xdb, 0x31, 0x53, 0x68, 0x17, 0x2a, 0x72,
	0x73, 0x34, 0x36, 0x50, 0x1a, 0xd1, 0xa9, 0x84, 0xcb, 0x15, 0x71, 0xb8, 0x93, 0x5d, 0x59, 0x00,
	0x7f, 0x03, 0xd7, 0x63, 0xe0, 0x0e, 0x61, 0xd8, 0x9e, 0x92, 0x71, 0x9c, 0xa4, 0xb2, 0xe7, 0xc0,
	0xf7, 0x5d, 0x7f, 0xff, 0x6a, 0xc8, 0x7c, 0xdb, 0x99, 0x08, 0xaf, 0xbe, 0x84, 0x4d, 0x5d, 0xa0,
	0x4e, 0xb0, 0xed, 0x30, 0xe2, 0x60, 0x67, 0x44, 0x90, 0xfa, 0x76, 0x38, 0xd5, 0xcf, 0xb7, 0x8b,
	0xb3, 0x7e, 0x06, 0xb5, 0x1e, 0xf9, 0x8e, 0x45, 0x29, 0xb1, 0xf9, 0x16, 0xf9, 0x66, 0x0a, 0xed,
	0xf1, 0x3a, 0xae, 0x0b, 0x67, 0xa2, 0x77, 0x0b, 0x75, 0x55, 0x4e, 0x23, 0x63, 0x16, 0x3c, 0x2e,
	0x69, 0xcf, 0x7a, 0xf3, 0x19, 0xf1, 0xed, 0xd1, 0x72, 0xf0, 0x1e, 0x40, 0x4d, 0xc4, 0x23, 0x60,
	0xbc, 0x3d, 0x7c, 0x1d, 0xc8, 0xab, 0xba, 0x84, 0x8c, 0xc4, 0xaa, 0x26, 0x0e, 0xae, 0x71, 0xe3,
	0x2d, 0x15, 0xcf, 0x4c, 0xa1, 0x9f, 0x41, 0x25, 0x56, 0x11, 0xd0, 0x4e, 0x14, 0x9f, 0x54, 0xb5,
	0x8c, 0xdb, 0x6f, 0x41, 0x04, 0x76, 0x5f, 0x42, 0x7d, 0xf1, 0x40, 0xa3, 0x3b, 0x51, 0xe2, 0x8a,
	0x42, 0x63, 0xdc, 0x7d, 0x3b, 0x48, 0x4f, 0xb0, 0xf7, 0xcf, 0x0c, 0xe4, 0x24, 0x88, 0x5f, 0xa0,
	0x06, 0x73, 0x7a, 0xc1, 0x8f, 0x84, 0x8e, 0x58, 0xfb, 0x62, 0xee, 0x5c, 0x1a, 0xea, 0xca, 0x32,
	0xf0, 0xdd, 0x09, 0xaf, 0x50, 0x66, 0x6a, 0x37, 0xfd, 0x28, 0x8d, 0xf6, 0x38, 0x5c, 0xbe, 0xe7,
	0x20, 0xb5, 0x7f, 0x0b, 0xef, 0x3b, 0x46, 0xd4, 0x8a, 0x99, 0x7a, 0x94, 0x46, 0x4f, 0xa0, 0x18,
	0xbc, 0x1b, 0xa3, 0xad, 0xa5, 0x87, 0x64, 0xc9, 0xba, 0x96, 0xf4, 0xc0, 0x6c, 0xa6, 0xd0, 0x1d,
	0x28, 0x0c, 0x99, 0xeb, 0x09, 0xee, 0xca, 0xa3, 0xf3, 0x13, 0x80, 0xb0, 0x2f, 0xa2, 0xff, 0xd3,
	0x7e, 0x2d, 0x74, 0xca, 0xd5, 0xc7, 0xe1, 0x21, 0x40, 0xf8, 0x72, 0x10, 0x99, 0x26, 0xf9, 0xc1,
	0xc3, 0x4c, 0xa1, 0x7d, 0x28, 0x45, 0x9e, 0xe3, 0xd1, 0xad, 0x68, 0xdc, 0x97, 0xdf, 0xe9, 0x75,
	0x09, 0x54, 0xd2, 0xa1, 0x47, 0x46, 0x66, 0x0a, 0x3d, 0x96, 0x5f, 0xc8, 0xc7, 0xee, 0x84, 0xa2,
	0xc8, 0x44, 0x7c, 0xac, 0x79, 0x9b, 0x71, 0x71, 0x18, 0xd2, 0x26, 0x94, 0x8e, 0x08, 0xd3, 0x2f,
	0x52, 0x11, 0x8f, 0x37, 0x13, 0xde, 0xaa, 0xcc, 0xd4, 0xfe, 0xdd, 0x5f, 0x98, 0x13, 0x9b, 0x5d,
	0xcc, 0xcf, 0x9b, 0x23, 0x77, 0xf6, 0x90, 0x43, 0x1e, 0xd8, 0xee, 0xc3, 0x91, 0xeb, 0x93, 0x87,
	0xe2, 0x1f, 0x9a, 0x27, 0x5c, 0x74, 0x9e, 0x13, 0xbf, 0x3f, 0xff, 0x77, 0x00, 0x00, 0x00, 0xff,
	0xff, 0x7f, 0x48, 0x86, 0xd7, 0x53, 0x1a, 0x00, 0x00,
}