api

package
v0.0.0-...-fb670e6 Latest Latest
Warning

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

 Go to latest Published: May 15, 2020 License: MIT Imports: 14 Imported by: 0

Documentation

Overview

Package api is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterManagerServiceHandler 

func RegisterManagerServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterManagerServiceHandler registers the http handlers for service ManagerService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterManagerServiceHandlerClient 

func RegisterManagerServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ManagerServiceClient) error

RegisterManagerServiceHandlerClient registers the http handlers for service ManagerService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "ManagerServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "ManagerServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "ManagerServiceClient" to call the correct interceptors.

func RegisterManagerServiceHandlerFromEndpoint 

func RegisterManagerServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterManagerServiceHandlerFromEndpoint is same as RegisterManagerServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterManagerServiceHandlerServer 

func RegisterManagerServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ManagerServiceServer) error

RegisterManagerServiceHandlerServer registers the http handlers for service ManagerService to "mux". UnaryRPC :call ManagerServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.

func RegisterManagerServiceServer 

func RegisterManagerServiceServer(s *grpc.Server, srv ManagerServiceServer)

Types

type AddTaskRequest 

type AddTaskRequest struct {
	Task                 *Task    `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AddTaskRequest) Descriptor 

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

func (*AddTaskRequest) GetTask 

func (m *AddTaskRequest) GetTask() *Task

func (*AddTaskRequest) ProtoMessage 

func (*AddTaskRequest) ProtoMessage()

func (*AddTaskRequest) Reset 

func (m *AddTaskRequest) Reset()

func (*AddTaskRequest) String 

func (m *AddTaskRequest) String() string

func (*AddTaskRequest) XXX_DiscardUnknown 

func (m *AddTaskRequest) XXX_DiscardUnknown()

func (*AddTaskRequest) XXX_Marshal 

func (m *AddTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AddTaskRequest) XXX_Merge 

func (m *AddTaskRequest) XXX_Merge(src proto.Message)

func (*AddTaskRequest) XXX_Size 

func (m *AddTaskRequest) XXX_Size() int

func (*AddTaskRequest) XXX_Unmarshal 

func (m *AddTaskRequest) XXX_Unmarshal(b []byte) error

type AddTaskResponse 

type AddTaskResponse struct {
	WorkerId             string   `protobuf:"bytes,1,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AddTaskResponse) Descriptor 

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

func (*AddTaskResponse) GetWorkerId 

func (m *AddTaskResponse) GetWorkerId() string

func (*AddTaskResponse) ProtoMessage 

func (*AddTaskResponse) ProtoMessage()

func (*AddTaskResponse) Reset 

func (m *AddTaskResponse) Reset()

func (*AddTaskResponse) String 

func (m *AddTaskResponse) String() string

func (*AddTaskResponse) XXX_DiscardUnknown 

func (m *AddTaskResponse) XXX_DiscardUnknown()

func (*AddTaskResponse) XXX_Marshal 

func (m *AddTaskResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AddTaskResponse) XXX_Merge 

func (m *AddTaskResponse) XXX_Merge(src proto.Message)

func (*AddTaskResponse) XXX_Size 

func (m *AddTaskResponse) XXX_Size() int

func (*AddTaskResponse) XXX_Unmarshal 

func (m *AddTaskResponse) XXX_Unmarshal(b []byte) error

type DeleteTaskRequest 

type DeleteTaskRequest struct {
	Uuid                 string   `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteTaskRequest) Descriptor 

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

func (*DeleteTaskRequest) GetUuid 

func (m *DeleteTaskRequest) GetUuid() string

func (*DeleteTaskRequest) ProtoMessage 

func (*DeleteTaskRequest) ProtoMessage()

func (*DeleteTaskRequest) Reset 

func (m *DeleteTaskRequest) Reset()

func (*DeleteTaskRequest) String 

func (m *DeleteTaskRequest) String() string

func (*DeleteTaskRequest) XXX_DiscardUnknown 

func (m *DeleteTaskRequest) XXX_DiscardUnknown()

func (*DeleteTaskRequest) XXX_Marshal 

func (m *DeleteTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteTaskRequest) XXX_Merge 

func (m *DeleteTaskRequest) XXX_Merge(src proto.Message)

func (*DeleteTaskRequest) XXX_Size 

func (m *DeleteTaskRequest) XXX_Size() int

func (*DeleteTaskRequest) XXX_Unmarshal 

func (m *DeleteTaskRequest) XXX_Unmarshal(b []byte) error

type DeleteTaskResponse 

type DeleteTaskResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteTaskResponse) Descriptor 

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

func (*DeleteTaskResponse) ProtoMessage 

func (*DeleteTaskResponse) ProtoMessage()

func (*DeleteTaskResponse) Reset 

func (m *DeleteTaskResponse) Reset()

func (*DeleteTaskResponse) String 

func (m *DeleteTaskResponse) String() string

func (*DeleteTaskResponse) XXX_DiscardUnknown 

func (m *DeleteTaskResponse) XXX_DiscardUnknown()

func (*DeleteTaskResponse) XXX_Marshal 

func (m *DeleteTaskResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteTaskResponse) XXX_Merge 

func (m *DeleteTaskResponse) XXX_Merge(src proto.Message)

func (*DeleteTaskResponse) XXX_Size 

func (m *DeleteTaskResponse) XXX_Size() int

func (*DeleteTaskResponse) XXX_Unmarshal 

func (m *DeleteTaskResponse) XXX_Unmarshal(b []byte) error

type GetTaskRequest 

type GetTaskRequest struct {
	Uuid                 string   `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetTaskRequest) Descriptor 

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

func (*GetTaskRequest) GetUuid 

func (m *GetTaskRequest) GetUuid() string

func (*GetTaskRequest) ProtoMessage 

func (*GetTaskRequest) ProtoMessage()

func (*GetTaskRequest) Reset 

func (m *GetTaskRequest) Reset()

func (*GetTaskRequest) String 

func (m *GetTaskRequest) String() string

func (*GetTaskRequest) XXX_DiscardUnknown 

func (m *GetTaskRequest) XXX_DiscardUnknown()

func (*GetTaskRequest) XXX_Marshal 

func (m *GetTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetTaskRequest) XXX_Merge 

func (m *GetTaskRequest) XXX_Merge(src proto.Message)

func (*GetTaskRequest) XXX_Size 

func (m *GetTaskRequest) XXX_Size() int

func (*GetTaskRequest) XXX_Unmarshal 

func (m *GetTaskRequest) XXX_Unmarshal(b []byte) error

type GetTaskResponse 

type GetTaskResponse struct {
	Task                 *Task    `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetTaskResponse) Descriptor 

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

func (*GetTaskResponse) GetTask 

func (m *GetTaskResponse) GetTask() *Task

func (*GetTaskResponse) ProtoMessage 

func (*GetTaskResponse) ProtoMessage()

func (*GetTaskResponse) Reset 

func (m *GetTaskResponse) Reset()

func (*GetTaskResponse) String 

func (m *GetTaskResponse) String() string

func (*GetTaskResponse) XXX_DiscardUnknown 

func (m *GetTaskResponse) XXX_DiscardUnknown()

func (*GetTaskResponse) XXX_Marshal 

func (m *GetTaskResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetTaskResponse) XXX_Merge 

func (m *GetTaskResponse) XXX_Merge(src proto.Message)

func (*GetTaskResponse) XXX_Size 

func (m *GetTaskResponse) XXX_Size() int

func (*GetTaskResponse) XXX_Unmarshal 

func (m *GetTaskResponse) XXX_Unmarshal(b []byte) error

type GetWorkerRequest 

type GetWorkerRequest struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetWorkerRequest) Descriptor 

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

func (*GetWorkerRequest) GetId 

func (m *GetWorkerRequest) GetId() string

func (*GetWorkerRequest) ProtoMessage 

func (*GetWorkerRequest) ProtoMessage()

func (*GetWorkerRequest) Reset 

func (m *GetWorkerRequest) Reset()

func (*GetWorkerRequest) String 

func (m *GetWorkerRequest) String() string

func (*GetWorkerRequest) XXX_DiscardUnknown 

func (m *GetWorkerRequest) XXX_DiscardUnknown()

func (*GetWorkerRequest) XXX_Marshal 

func (m *GetWorkerRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetWorkerRequest) XXX_Merge 

func (m *GetWorkerRequest) XXX_Merge(src proto.Message)

func (*GetWorkerRequest) XXX_Size 

func (m *GetWorkerRequest) XXX_Size() int

func (*GetWorkerRequest) XXX_Unmarshal 

func (m *GetWorkerRequest) XXX_Unmarshal(b []byte) error

type GetWorkerResponse 

type GetWorkerResponse struct {
	Worker               *Worker  `protobuf:"bytes,1,opt,name=worker,proto3" json:"worker,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetWorkerResponse) Descriptor 

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

func (*GetWorkerResponse) GetWorker 

func (m *GetWorkerResponse) GetWorker() *Worker

func (*GetWorkerResponse) ProtoMessage 

func (*GetWorkerResponse) ProtoMessage()

func (*GetWorkerResponse) Reset 

func (m *GetWorkerResponse) Reset()

func (*GetWorkerResponse) String 

func (m *GetWorkerResponse) String() string

func (*GetWorkerResponse) XXX_DiscardUnknown 

func (m *GetWorkerResponse) XXX_DiscardUnknown()

func (*GetWorkerResponse) XXX_Marshal 

func (m *GetWorkerResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetWorkerResponse) XXX_Merge 

func (m *GetWorkerResponse) XXX_Merge(src proto.Message)

func (*GetWorkerResponse) XXX_Size 

func (m *GetWorkerResponse) XXX_Size() int

func (*GetWorkerResponse) XXX_Unmarshal 

func (m *GetWorkerResponse) XXX_Unmarshal(b []byte) error

type ListTasksRequest 

type ListTasksRequest struct {
	WorkerId             string   `protobuf:"bytes,1,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	Offset               int32    `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	Limit                int32    `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	Total                int32    `protobuf:"varint,4,opt,name=total,proto3" json:"total,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListTasksRequest) Descriptor 

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

func (*ListTasksRequest) GetLimit 

func (m *ListTasksRequest) GetLimit() int32

func (*ListTasksRequest) GetOffset 

func (m *ListTasksRequest) GetOffset() int32

func (*ListTasksRequest) GetTotal 

func (m *ListTasksRequest) GetTotal() int32

func (*ListTasksRequest) GetWorkerId 

func (m *ListTasksRequest) GetWorkerId() string

func (*ListTasksRequest) ProtoMessage 

func (*ListTasksRequest) ProtoMessage()

func (*ListTasksRequest) Reset 

func (m *ListTasksRequest) Reset()

func (*ListTasksRequest) String 

func (m *ListTasksRequest) String() string

func (*ListTasksRequest) XXX_DiscardUnknown 

func (m *ListTasksRequest) XXX_DiscardUnknown()

func (*ListTasksRequest) XXX_Marshal 

func (m *ListTasksRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListTasksRequest) XXX_Merge 

func (m *ListTasksRequest) XXX_Merge(src proto.Message)

func (*ListTasksRequest) XXX_Size 

func (m *ListTasksRequest) XXX_Size() int

func (*ListTasksRequest) XXX_Unmarshal 

func (m *ListTasksRequest) XXX_Unmarshal(b []byte) error

type ListTasksResponse 

type ListTasksResponse struct {
	Tasks                []*Task  `protobuf:"bytes,1,rep,name=tasks,proto3" json:"tasks,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListTasksResponse) Descriptor 

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

func (*ListTasksResponse) GetTasks 

func (m *ListTasksResponse) GetTasks() []*Task

func (*ListTasksResponse) ProtoMessage 

func (*ListTasksResponse) ProtoMessage()

func (*ListTasksResponse) Reset 

func (m *ListTasksResponse) Reset()

func (*ListTasksResponse) String 

func (m *ListTasksResponse) String() string

func (*ListTasksResponse) XXX_DiscardUnknown 

func (m *ListTasksResponse) XXX_DiscardUnknown()

func (*ListTasksResponse) XXX_Marshal 

func (m *ListTasksResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListTasksResponse) XXX_Merge 

func (m *ListTasksResponse) XXX_Merge(src proto.Message)

func (*ListTasksResponse) XXX_Size 

func (m *ListTasksResponse) XXX_Size() int

func (*ListTasksResponse) XXX_Unmarshal 

func (m *ListTasksResponse) XXX_Unmarshal(b []byte) error

type ListWorkersRequest 

type ListWorkersRequest struct {
	Offset               int32    `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"`
	Limit                int32    `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	Total                int32    `protobuf:"varint,3,opt,name=total,proto3" json:"total,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListWorkersRequest) Descriptor 

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

func (*ListWorkersRequest) GetLimit 

func (m *ListWorkersRequest) GetLimit() int32

func (*ListWorkersRequest) GetOffset 

func (m *ListWorkersRequest) GetOffset() int32

func (*ListWorkersRequest) GetTotal 

func (m *ListWorkersRequest) GetTotal() int32

func (*ListWorkersRequest) ProtoMessage 

func (*ListWorkersRequest) ProtoMessage()

func (*ListWorkersRequest) Reset 

func (m *ListWorkersRequest) Reset()

func (*ListWorkersRequest) String 

func (m *ListWorkersRequest) String() string

func (*ListWorkersRequest) XXX_DiscardUnknown 

func (m *ListWorkersRequest) XXX_DiscardUnknown()

func (*ListWorkersRequest) XXX_Marshal 

func (m *ListWorkersRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListWorkersRequest) XXX_Merge 

func (m *ListWorkersRequest) XXX_Merge(src proto.Message)

func (*ListWorkersRequest) XXX_Size 

func (m *ListWorkersRequest) XXX_Size() int

func (*ListWorkersRequest) XXX_Unmarshal 

func (m *ListWorkersRequest) XXX_Unmarshal(b []byte) error

type ListWorkersResponse 

type ListWorkersResponse struct {
	Workers              []*Worker `protobuf:"bytes,1,rep,name=workers,proto3" json:"workers,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*ListWorkersResponse) Descriptor 

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

func (*ListWorkersResponse) GetWorkers 

func (m *ListWorkersResponse) GetWorkers() []*Worker

func (*ListWorkersResponse) ProtoMessage 

func (*ListWorkersResponse) ProtoMessage()

func (*ListWorkersResponse) Reset 

func (m *ListWorkersResponse) Reset()

func (*ListWorkersResponse) String 

func (m *ListWorkersResponse) String() string

func (*ListWorkersResponse) XXX_DiscardUnknown 

func (m *ListWorkersResponse) XXX_DiscardUnknown()

func (*ListWorkersResponse) XXX_Marshal 

func (m *ListWorkersResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListWorkersResponse) XXX_Merge 

func (m *ListWorkersResponse) XXX_Merge(src proto.Message)

func (*ListWorkersResponse) XXX_Size 

func (m *ListWorkersResponse) XXX_Size() int

func (*ListWorkersResponse) XXX_Unmarshal 

func (m *ListWorkersResponse) XXX_Unmarshal(b []byte) error

type ManagerServiceClient 

type ManagerServiceClient interface {
	AddTask(ctx context.Context, in *AddTaskRequest, opts ...grpc.CallOption) (*AddTaskResponse, error)
	GetTask(ctx context.Context, in *GetTaskRequest, opts ...grpc.CallOption) (*GetTaskResponse, error)
	ListTasks(ctx context.Context, in *ListTasksRequest, opts ...grpc.CallOption) (*ListTasksResponse, error)
	DeleteTask(ctx context.Context, in *DeleteTaskRequest, opts ...grpc.CallOption) (*DeleteTaskResponse, error)
	GetWorker(ctx context.Context, in *GetWorkerRequest, opts ...grpc.CallOption) (*GetWorkerResponse, error)
	ListWorkers(ctx context.Context, in *ListWorkersRequest, opts ...grpc.CallOption) (*ListWorkersResponse, error)
}

ManagerServiceClient is the client API for ManagerService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewManagerServiceClient 

func NewManagerServiceClient(cc *grpc.ClientConn) ManagerServiceClient

type ManagerServiceServer 

type ManagerServiceServer interface {
	AddTask(context.Context, *AddTaskRequest) (*AddTaskResponse, error)
	GetTask(context.Context, *GetTaskRequest) (*GetTaskResponse, error)
	ListTasks(context.Context, *ListTasksRequest) (*ListTasksResponse, error)
	DeleteTask(context.Context, *DeleteTaskRequest) (*DeleteTaskResponse, error)
	GetWorker(context.Context, *GetWorkerRequest) (*GetWorkerResponse, error)
	ListWorkers(context.Context, *ListWorkersRequest) (*ListWorkersResponse, error)
}

ManagerServiceServer is the server API for ManagerService service.

type Task 

type Task struct {
	Uuid                 string            `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	Requests             map[string]uint64 `` /* 158-byte string literal not displayed */
	Labels               map[string]string `` /* 153-byte string literal not displayed */
	AssignedWorker       string            `protobuf:"bytes,4,opt,name=assigned_worker,json=assignedWorker,proto3" json:"assigned_worker,omitempty"`
	Status               *TaskStatus       `protobuf:"bytes,5,opt,name=status,proto3" json:"status,omitempty"`
	CreationTime         int64             `protobuf:"varint,6,opt,name=creation_time,json=creationTime,proto3" json:"creation_time,omitempty"`
	Version              int32             `protobuf:"varint,7,opt,name=version,proto3" json:"version,omitempty"`
	Payload              []byte            `protobuf:"bytes,8,opt,name=payload,proto3" json:"payload,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*Task) Descriptor 

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

func (*Task) GetAssignedWorker 

func (m *Task) GetAssignedWorker() string

func (*Task) GetCreationTime 

func (m *Task) GetCreationTime() int64

func (*Task) GetLabels 

func (m *Task) GetLabels() map[string]string

func (*Task) GetPayload 

func (m *Task) GetPayload() []byte

func (*Task) GetRequests 

func (m *Task) GetRequests() map[string]uint64

func (*Task) GetStatus 

func (m *Task) GetStatus() *TaskStatus

func (*Task) GetUuid 

func (m *Task) GetUuid() string

func (*Task) GetVersion 

func (m *Task) GetVersion() int32

func (*Task) ProtoMessage 

func (*Task) ProtoMessage()

func (*Task) Reset 

func (m *Task) Reset()

func (*Task) String 

func (m *Task) String() string

func (*Task) XXX_DiscardUnknown 

func (m *Task) XXX_DiscardUnknown()

func (*Task) XXX_Marshal 

func (m *Task) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Task) XXX_Merge 

func (m *Task) XXX_Merge(src proto.Message)

func (*Task) XXX_Size 

func (m *Task) XXX_Size() int

func (*Task) XXX_Unmarshal 

func (m *Task) XXX_Unmarshal(b []byte) error

type TaskResponse 

type TaskResponse struct {
	WorkerId             string   `protobuf:"bytes,1,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

---------- request + response ----------

func (*TaskResponse) Descriptor 

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

func (*TaskResponse) GetWorkerId 

func (m *TaskResponse) GetWorkerId() string

func (*TaskResponse) ProtoMessage 

func (*TaskResponse) ProtoMessage()

func (*TaskResponse) Reset 

func (m *TaskResponse) Reset()

func (*TaskResponse) String 

func (m *TaskResponse) String() string

func (*TaskResponse) XXX_DiscardUnknown 

func (m *TaskResponse) XXX_DiscardUnknown()

func (*TaskResponse) XXX_Marshal 

func (m *TaskResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaskResponse) XXX_Merge 

func (m *TaskResponse) XXX_Merge(src proto.Message)

func (*TaskResponse) XXX_Size 

func (m *TaskResponse) XXX_Size() int

func (*TaskResponse) XXX_Unmarshal 

func (m *TaskResponse) XXX_Unmarshal(b []byte) error

type TaskStatus 

type TaskStatus struct {
	Version              int32    `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
	Payload              []byte   `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TaskStatus) Descriptor 

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

func (*TaskStatus) GetPayload 

func (m *TaskStatus) GetPayload() []byte

func (*TaskStatus) GetVersion 

func (m *TaskStatus) GetVersion() int32

func (*TaskStatus) ProtoMessage 

func (*TaskStatus) ProtoMessage()

func (*TaskStatus) Reset 

func (m *TaskStatus) Reset()

func (*TaskStatus) String 

func (m *TaskStatus) String() string

func (*TaskStatus) XXX_DiscardUnknown 

func (m *TaskStatus) XXX_DiscardUnknown()

func (*TaskStatus) XXX_Marshal 

func (m *TaskStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaskStatus) XXX_Merge 

func (m *TaskStatus) XXX_Merge(src proto.Message)

func (*TaskStatus) XXX_Size 

func (m *TaskStatus) XXX_Size() int

func (*TaskStatus) XXX_Unmarshal 

func (m *TaskStatus) XXX_Unmarshal(b []byte) error

type UnimplementedManagerServiceServer 

type UnimplementedManagerServiceServer struct {
}

UnimplementedManagerServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedManagerServiceServer) AddTask 

func (*UnimplementedManagerServiceServer) AddTask(ctx context.Context, req *AddTaskRequest) (*AddTaskResponse, error)

func (*UnimplementedManagerServiceServer) DeleteTask 

func (*UnimplementedManagerServiceServer) DeleteTask(ctx context.Context, req *DeleteTaskRequest) (*DeleteTaskResponse, error)

func (*UnimplementedManagerServiceServer) GetTask 

func (*UnimplementedManagerServiceServer) GetTask(ctx context.Context, req *GetTaskRequest) (*GetTaskResponse, error)

func (*UnimplementedManagerServiceServer) GetWorker 

func (*UnimplementedManagerServiceServer) GetWorker(ctx context.Context, req *GetWorkerRequest) (*GetWorkerResponse, error)

func (*UnimplementedManagerServiceServer) ListTasks 

func (*UnimplementedManagerServiceServer) ListTasks(ctx context.Context, req *ListTasksRequest) (*ListTasksResponse, error)

func (*UnimplementedManagerServiceServer) ListWorkers 

func (*UnimplementedManagerServiceServer) ListWorkers(ctx context.Context, req *ListWorkersRequest) (*ListWorkersResponse, error)

type Worker 

type Worker struct {
	ClusterId            string            `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Id                   string            `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Quotas               map[string]uint64 `` /* 154-byte string literal not displayed */
	Labels               map[string]string `` /* 153-byte string literal not displayed */
	Status               *WorkerStatus     `protobuf:"bytes,5,opt,name=status,proto3" json:"status,omitempty"`
	Version              int32             `protobuf:"varint,6,opt,name=version,proto3" json:"version,omitempty"`
	Payload              []byte            `protobuf:"bytes,7,opt,name=payload,proto3" json:"payload,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*Worker) Descriptor 

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

func (*Worker) GetClusterId 

func (m *Worker) GetClusterId() string

func (*Worker) GetId 

func (m *Worker) GetId() string

func (*Worker) GetLabels 

func (m *Worker) GetLabels() map[string]string

func (*Worker) GetPayload 

func (m *Worker) GetPayload() []byte

func (*Worker) GetQuotas 

func (m *Worker) GetQuotas() map[string]uint64

func (*Worker) GetStatus 

func (m *Worker) GetStatus() *WorkerStatus

func (*Worker) GetVersion 

func (m *Worker) GetVersion() int32

func (*Worker) ProtoMessage 

func (*Worker) ProtoMessage()

func (*Worker) Reset 

func (m *Worker) Reset()

func (*Worker) String 

func (m *Worker) String() string

func (*Worker) XXX_DiscardUnknown 

func (m *Worker) XXX_DiscardUnknown()

func (*Worker) XXX_Marshal 

func (m *Worker) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Worker) XXX_Merge 

func (m *Worker) XXX_Merge(src proto.Message)

func (*Worker) XXX_Size 

func (m *Worker) XXX_Size() int

func (*Worker) XXX_Unmarshal 

func (m *Worker) XXX_Unmarshal(b []byte) error

type WorkerStatus 

type WorkerStatus struct {
	Quotas               map[string]uint64 `` /* 154-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*WorkerStatus) Descriptor 

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

func (*WorkerStatus) GetQuotas 

func (m *WorkerStatus) GetQuotas() map[string]uint64

func (*WorkerStatus) ProtoMessage 

func (*WorkerStatus) ProtoMessage()

func (*WorkerStatus) Reset 

func (m *WorkerStatus) Reset()

func (*WorkerStatus) String 

func (m *WorkerStatus) String() string

func (*WorkerStatus) XXX_DiscardUnknown 

func (m *WorkerStatus) XXX_DiscardUnknown()

func (*WorkerStatus) XXX_Marshal 

func (m *WorkerStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WorkerStatus) XXX_Merge 

func (m *WorkerStatus) XXX_Merge(src proto.Message)

func (*WorkerStatus) XXX_Size 

func (m *WorkerStatus) XXX_Size() int

func (*WorkerStatus) XXX_Unmarshal 

func (m *WorkerStatus) XXX_Unmarshal(b []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.