api

package
v0.0.0-...-d60fe65 Latest Latest
Warning

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

 Go to latest Published: Nov 18, 2019 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 ListTasksRequest 

type ListTasksRequest 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 (*ListTasksRequest) Descriptor 

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

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                []*TaskSpec `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() []*TaskSpec

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 {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListWorkersRequest) Descriptor 

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

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              []*WorkerSpec `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() []*WorkerSpec

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 *TaskSpec, opts ...grpc.CallOption) (*TaskResponse, error)
	GetTask(ctx context.Context, in *TaskSpec, opts ...grpc.CallOption) (*TaskSpec, error)
	ListTasks(ctx context.Context, in *ListTasksRequest, opts ...grpc.CallOption) (*ListTasksResponse, error)
	DeleteTask(ctx context.Context, in *TaskSpec, opts ...grpc.CallOption) (*TaskResponse, error)
	GetWorker(ctx context.Context, in *WorkerSpec, opts ...grpc.CallOption) (*WorkerSpec, 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, *TaskSpec) (*TaskResponse, error)
	GetTask(context.Context, *TaskSpec) (*TaskSpec, error)
	ListTasks(context.Context, *ListTasksRequest) (*ListTasksResponse, error)
	DeleteTask(context.Context, *TaskSpec) (*TaskResponse, error)
	GetWorker(context.Context, *WorkerSpec) (*WorkerSpec, error)
	ListWorkers(context.Context, *ListWorkersRequest) (*ListWorkersResponse, error)
}

ManagerServiceServer is the server API for ManagerService service.

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

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 TaskSpec 

type TaskSpec struct {
	Id                   string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Limits               map[string]uint64 `` /* 154-byte string literal not displayed */
	RequiredLabels       map[string]string `` /* 191-byte string literal not displayed */
	AssignedWorker       string            `protobuf:"bytes,4,opt,name=assigned_worker,json=assignedWorker,proto3" json:"assigned_worker,omitempty"`
	Version              int32             `protobuf:"varint,5,opt,name=version,proto3" json:"version,omitempty"`
	Payload              []byte            `protobuf:"bytes,6,opt,name=payload,proto3" json:"payload,omitempty"`
	CreationTime         int64             `protobuf:"varint,7,opt,name=creation_time,json=creationTime,proto3" json:"creation_time,omitempty"`
	Status               *TaskStatus       `protobuf:"bytes,8,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*TaskSpec) Descriptor 

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

func (*TaskSpec) GetAssignedWorker 

func (m *TaskSpec) GetAssignedWorker() string

func (*TaskSpec) GetCreationTime 

func (m *TaskSpec) GetCreationTime() int64

func (*TaskSpec) GetId 

func (m *TaskSpec) GetId() string

func (*TaskSpec) GetLimits 

func (m *TaskSpec) GetLimits() map[string]uint64

func (*TaskSpec) GetPayload 

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

func (*TaskSpec) GetRequiredLabels 

func (m *TaskSpec) GetRequiredLabels() map[string]string

func (*TaskSpec) GetStatus 

func (m *TaskSpec) GetStatus() *TaskStatus

func (*TaskSpec) GetVersion 

func (m *TaskSpec) GetVersion() int32

func (*TaskSpec) ProtoMessage 

func (*TaskSpec) ProtoMessage()

func (*TaskSpec) Reset 

func (m *TaskSpec) Reset()

func (*TaskSpec) String 

func (m *TaskSpec) String() string

func (*TaskSpec) XXX_DiscardUnknown 

func (m *TaskSpec) XXX_DiscardUnknown()

func (*TaskSpec) XXX_Marshal 

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

func (*TaskSpec) XXX_Merge 

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

func (*TaskSpec) XXX_Size 

func (m *TaskSpec) XXX_Size() int

func (*TaskSpec) XXX_Unmarshal 

func (m *TaskSpec) 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 *TaskSpec) (*TaskResponse, error)

func (*UnimplementedManagerServiceServer) DeleteTask 

func (*UnimplementedManagerServiceServer) DeleteTask(ctx context.Context, req *TaskSpec) (*TaskResponse, error)

func (*UnimplementedManagerServiceServer) GetTask 

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

func (*UnimplementedManagerServiceServer) GetWorker 

func (*UnimplementedManagerServiceServer) GetWorker(ctx context.Context, req *WorkerSpec) (*WorkerSpec, 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 WorkerSpec 

type WorkerSpec 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 */
	Version              int32             `protobuf:"varint,5,opt,name=version,proto3" json:"version,omitempty"`
	Payload              []byte            `protobuf:"bytes,6,opt,name=payload,proto3" json:"payload,omitempty"`
	Status               *WorkerStatus     `protobuf:"bytes,7,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*WorkerSpec) Descriptor 

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

func (*WorkerSpec) GetClusterId 

func (m *WorkerSpec) GetClusterId() string

func (*WorkerSpec) GetId 

func (m *WorkerSpec) GetId() string

func (*WorkerSpec) GetLabels 

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

func (*WorkerSpec) GetPayload 

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

func (*WorkerSpec) GetQuotas 

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

func (*WorkerSpec) GetStatus 

func (m *WorkerSpec) GetStatus() *WorkerStatus

func (*WorkerSpec) GetVersion 

func (m *WorkerSpec) GetVersion() int32

func (*WorkerSpec) ProtoMessage 

func (*WorkerSpec) ProtoMessage()

func (*WorkerSpec) Reset 

func (m *WorkerSpec) Reset()

func (*WorkerSpec) String 

func (m *WorkerSpec) String() string

func (*WorkerSpec) XXX_DiscardUnknown 

func (m *WorkerSpec) XXX_DiscardUnknown()

func (*WorkerSpec) XXX_Marshal 

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

func (*WorkerSpec) XXX_Merge 

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

func (*WorkerSpec) XXX_Size 

func (m *WorkerSpec) XXX_Size() int

func (*WorkerSpec) XXX_Unmarshal 

func (m *WorkerSpec) 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.