Versions in this module Expand all Collapse all v0 v0.3.0 Dec 25, 2017 Changes in this version + func Root(c config.Config) *cobra.Command + func WithWalletPerRPCCredentials() grpc.DialOption + type DealsInteractor interface + FinishDeal func(id string) error + List func(from string, status pb.DealStatus) ([]*pb.Deal, error) + Status func(id string) (*pb.Deal, error) + func NewDealsInteractor(addr string, timeout time.Duration) (DealsInteractor, error) + type NodeHubInteractor interface + CreateAskPlan func(req *pb.InsertSlotRequest) (*pb.ID, error) + DeregisterWorker func(id string) (*pb.Empty, error) + DevicesList func() (*pb.DevicesReply, error) + GetAskPlans func() (*pb.SlotsReply, error) + GetDeviceProperties func(id string) (*pb.GetDevicePropertiesReply, error) + GetRegisteredWorkers func() (*pb.GetRegisteredWorkersReply, error) + RegisterWorker func(id string) (*pb.Empty, error) + RemoveAskPlan func(id string) (*pb.Empty, error) + SetDeviceProperties func(ID string, properties map[string]float64) (*pb.Empty, error) + Status func() (*pb.HubStatusReply, error) + TaskList func() (*pb.TaskListReply, error) + TaskStatus func(id string) (*pb.TaskStatusReply, error) + WorkerStatus func(id string) (*pb.InfoReply, error) + WorkersList func() (*pb.ListReply, error) + func NewHubInteractor(addr string, timeout time.Duration) (NodeHubInteractor, error) + type NodeMarketInteractor interface + CancelOrder func(id string) error + CreateOrder func(order *pb.Order) (*pb.Order, error) + GetOrderByID func(id string) (*pb.Order, error) + GetOrders func(slot *structs.Slot, orderType pb.OrderType, count uint64) ([]*pb.Order, error) + GetProcessing func() (*pb.GetProcessingReply, error) + func NewMarketInteractor(addr string, timeout time.Duration) (NodeMarketInteractor, error) + type TasksInteractor interface + ImagePull func(dealID, taskID string) (pb.Hub_PullTaskClient, error) + ImagePush func(ctx context.Context) (pb.Hub_PushTaskClient, error) + List func(hubAddr string) (*pb.TaskListReply, error) + Logs func(ctx context.Context, req *pb.TaskLogsRequest) (pb.TaskManagement_LogsClient, error) + Start func(req *pb.HubStartTaskRequest) (*pb.HubStartTaskReply, error) + Status func(id, hub string) (*pb.TaskStatusReply, error) + Stop func(id, hub string) (*pb.Empty, error) + func NewTasksInteractor(addr string, timeout time.Duration, opts ...grpc.DialOption) (TasksInteractor, error)
Go to main page