api

package
v0.0.0-...-3850e5f Latest Latest
Warning

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

 Go to latest Published: Feb 12, 2016 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Overview

Package api is a generated protocol buffer package.

It is generated from these files: 

api.proto

It has these top-level messages: 

Node
Spec
TaskStatus
Task
Job
Update
RegisterNodeRequest
RegisterNodeResponse
UpdateNodeStatusRequest
UpdateNodeStatusResponse
ListNodesRequest
ListNodesResponse
DrainNodeRequest
DrainNodeResponse
CreateTaskRequest
CreateTaskResponse
GetTasksRequest
GetTasksResponse
RemoveTaskRequest
RemoveTaskResponse
ListTasksRequest
ListTasksResponse
CreateJobRequest
CreateJobResponse
GetJobRequest
GetJobResponse
UpdateJobRequest
UpdateJobResponse
RemoveJobRequest
RemoveJobResponse
ListJobsRequest
ListJobsResponse
UpdateTaskStatusRequest
UpdateTaskStatusResponse
WatchTasksRequest
WatchTasksResponse

Index

Constants

This section is empty.

Variables

View Source 
var NodeStatus_name = map[int32]string{
	0: "READY",
	1: "DOWN",
}
View Source 
var NodeStatus_value = map[string]int32{
	"READY": 0,
	"DOWN":  1,
}
View Source 
var TaskStatus_State_name = map[int32]string{
	0:  "NEW",
	1:  "ASSIGNED",
	2:  "PREPARING",
	3:  "READY",
	4:  "STARTING",
	5:  "RUNNING",
	6:  "SHUTDOWN",
	7:  "COMPLETE",
	8:  "FAILED",
	9:  "REJECTED",
	10: "FINALIZE",
	11: "DEAD",
}
View Source 
var TaskStatus_State_value = map[string]int32{
	"NEW":       0,
	"ASSIGNED":  1,
	"PREPARING": 2,
	"READY":     3,
	"STARTING":  4,
	"RUNNING":   5,
	"SHUTDOWN":  6,
	"COMPLETE":  7,
	"FAILED":    8,
	"REJECTED":  9,
	"FINALIZE":  10,
	"DEAD":      11,
}

Functions

func RegisterSwarmServer 

func RegisterSwarmServer(s *grpc.Server, srv SwarmServer)

Types

type CreateJobRequest 

type CreateJobRequest struct {
	Spec *Spec `protobuf:"bytes,1,opt,name=spec" json:"spec,omitempty"`
}

func (*CreateJobRequest) Descriptor 

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

func (*CreateJobRequest) GetSpec 

func (m *CreateJobRequest) GetSpec() *Spec

func (*CreateJobRequest) ProtoMessage 

func (*CreateJobRequest) ProtoMessage()

func (*CreateJobRequest) Reset 

func (m *CreateJobRequest) Reset()

func (*CreateJobRequest) String 

func (m *CreateJobRequest) String() string

type CreateJobResponse 

type CreateJobResponse struct {
	JobId string `protobuf:"bytes,1,opt,name=job_id" json:"job_id,omitempty"`
}

func (*CreateJobResponse) Descriptor 

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

func (*CreateJobResponse) ProtoMessage 

func (*CreateJobResponse) ProtoMessage()

func (*CreateJobResponse) Reset 

func (m *CreateJobResponse) Reset()

func (*CreateJobResponse) String 

func (m *CreateJobResponse) String() string

type CreateTaskRequest 

type CreateTaskRequest struct {
	Spec *Spec `protobuf:"bytes,1,opt,name=spec" json:"spec,omitempty"`
}

func (*CreateTaskRequest) Descriptor 

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

func (*CreateTaskRequest) GetSpec 

func (m *CreateTaskRequest) GetSpec() *Spec

func (*CreateTaskRequest) ProtoMessage 

func (*CreateTaskRequest) ProtoMessage()

func (*CreateTaskRequest) Reset 

func (m *CreateTaskRequest) Reset()

func (*CreateTaskRequest) String 

func (m *CreateTaskRequest) String() string

type CreateTaskResponse 

type CreateTaskResponse struct {
	TaskId string `protobuf:"bytes,1,opt,name=task_id" json:"task_id,omitempty"`
}

func (*CreateTaskResponse) Descriptor 

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

func (*CreateTaskResponse) ProtoMessage 

func (*CreateTaskResponse) ProtoMessage()

func (*CreateTaskResponse) Reset 

func (m *CreateTaskResponse) Reset()

func (*CreateTaskResponse) String 

func (m *CreateTaskResponse) String() string

type DrainNodeRequest 

type DrainNodeRequest struct {
	NodeId string `protobuf:"bytes,1,opt,name=node_id" json:"node_id,omitempty"`
	Drain  bool   `protobuf:"varint,2,opt,name=drain" json:"drain,omitempty"`
}

func (*DrainNodeRequest) Descriptor 

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

func (*DrainNodeRequest) ProtoMessage 

func (*DrainNodeRequest) ProtoMessage()

func (*DrainNodeRequest) Reset 

func (m *DrainNodeRequest) Reset()

func (*DrainNodeRequest) String 

func (m *DrainNodeRequest) String() string

type DrainNodeResponse 

type DrainNodeResponse struct {
}

func (*DrainNodeResponse) Descriptor 

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

func (*DrainNodeResponse) ProtoMessage 

func (*DrainNodeResponse) ProtoMessage()

func (*DrainNodeResponse) Reset 

func (m *DrainNodeResponse) Reset()

func (*DrainNodeResponse) String 

func (m *DrainNodeResponse) String() string

type GetJobRequest 

type GetJobRequest struct {
	JobId string `protobuf:"bytes,1,opt,name=job_id" json:"job_id,omitempty"`
}

func (*GetJobRequest) Descriptor 

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

func (*GetJobRequest) ProtoMessage 

func (*GetJobRequest) ProtoMessage()

func (*GetJobRequest) Reset 

func (m *GetJobRequest) Reset()

func (*GetJobRequest) String 

func (m *GetJobRequest) String() string

type GetJobResponse 

type GetJobResponse struct {
	Job *Job `protobuf:"bytes,1,opt,name=job" json:"job,omitempty"`
}

func (*GetJobResponse) Descriptor 

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

func (*GetJobResponse) GetJob 

func (m *GetJobResponse) GetJob() *Job

func (*GetJobResponse) ProtoMessage 

func (*GetJobResponse) ProtoMessage()

func (*GetJobResponse) Reset 

func (m *GetJobResponse) Reset()

func (*GetJobResponse) String 

func (m *GetJobResponse) String() string

type GetTasksRequest 

type GetTasksRequest struct {
	TaskIds []string `protobuf:"bytes,1,rep,name=task_ids" json:"task_ids,omitempty"`
}

func (*GetTasksRequest) Descriptor 

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

func (*GetTasksRequest) ProtoMessage 

func (*GetTasksRequest) ProtoMessage()

func (*GetTasksRequest) Reset 

func (m *GetTasksRequest) Reset()

func (*GetTasksRequest) String 

func (m *GetTasksRequest) String() string

type GetTasksResponse 

type GetTasksResponse struct {
	Tasks []*Task `protobuf:"bytes,1,rep,name=tasks" json:"tasks,omitempty"`
}

func (*GetTasksResponse) Descriptor 

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

func (*GetTasksResponse) GetTasks 

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

func (*GetTasksResponse) ProtoMessage 

func (*GetTasksResponse) ProtoMessage()

func (*GetTasksResponse) Reset 

func (m *GetTasksResponse) Reset()

func (*GetTasksResponse) String 

func (m *GetTasksResponse) String() string

type Job 

type Job struct {
	Id   string `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
	Spec *Spec  `protobuf:"bytes,2,opt,name=spec" json:"spec,omitempty"`
}

func (*Job) Descriptor 

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

func (*Job) GetSpec 

func (m *Job) GetSpec() *Spec

func (*Job) ProtoMessage 

func (*Job) ProtoMessage()

func (*Job) Reset 

func (m *Job) Reset()

func (*Job) String 

func (m *Job) String() string

type ListJobsRequest 

type ListJobsRequest struct {
}

func (*ListJobsRequest) Descriptor 

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

func (*ListJobsRequest) ProtoMessage 

func (*ListJobsRequest) ProtoMessage()

func (*ListJobsRequest) Reset 

func (m *ListJobsRequest) Reset()

func (*ListJobsRequest) String 

func (m *ListJobsRequest) String() string

type ListJobsResponse 

type ListJobsResponse struct {
	Jobs []*Job `protobuf:"bytes,1,rep,name=jobs" json:"jobs,omitempty"`
}

func (*ListJobsResponse) Descriptor 

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

func (*ListJobsResponse) GetJobs 

func (m *ListJobsResponse) GetJobs() []*Job

func (*ListJobsResponse) ProtoMessage 

func (*ListJobsResponse) ProtoMessage()

func (*ListJobsResponse) Reset 

func (m *ListJobsResponse) Reset()

func (*ListJobsResponse) String 

func (m *ListJobsResponse) String() string

type ListNodesRequest 

type ListNodesRequest struct {
}

func (*ListNodesRequest) Descriptor 

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

func (*ListNodesRequest) ProtoMessage 

func (*ListNodesRequest) ProtoMessage()

func (*ListNodesRequest) Reset 

func (m *ListNodesRequest) Reset()

func (*ListNodesRequest) String 

func (m *ListNodesRequest) String() string

type ListNodesResponse 

type ListNodesResponse struct {
	Nodes []*Node `protobuf:"bytes,1,rep,name=nodes" json:"nodes,omitempty"`
}

func (*ListNodesResponse) Descriptor 

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

func (*ListNodesResponse) GetNodes 

func (m *ListNodesResponse) GetNodes() []*Node

func (*ListNodesResponse) ProtoMessage 

func (*ListNodesResponse) ProtoMessage()

func (*ListNodesResponse) Reset 

func (m *ListNodesResponse) Reset()

func (*ListNodesResponse) String 

func (m *ListNodesResponse) String() string

type ListTasksRequest 

type ListTasksRequest struct {
}

func (*ListTasksRequest) Descriptor 

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

func (*ListTasksRequest) ProtoMessage 

func (*ListTasksRequest) ProtoMessage()

func (*ListTasksRequest) Reset 

func (m *ListTasksRequest) Reset()

func (*ListTasksRequest) String 

func (m *ListTasksRequest) String() string

type ListTasksResponse 

type ListTasksResponse struct {
	Tasks []*Task `protobuf:"bytes,1,rep,name=tasks" json:"tasks,omitempty"`
}

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

type Node 

type Node struct {
	Id      string     `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
	Name    string     `protobuf:"bytes,2,opt,name=name" json:"name,omitempty"`
	Ip      string     `protobuf:"bytes,4,opt,name=ip" json:"ip,omitempty"`
	Drained bool       `protobuf:"varint,5,opt,name=drained" json:"drained,omitempty"`
	Status  NodeStatus `protobuf:"varint,3,opt,name=status,enum=api.NodeStatus" json:"status,omitempty"`
}

func (*Node) Descriptor 

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

func (*Node) ProtoMessage 

func (*Node) ProtoMessage()

func (*Node) Reset 

func (m *Node) Reset()

func (*Node) String 

func (m *Node) String() string

type NodeStatus 

type NodeStatus int32
const (
	NodeStatus_READY NodeStatus = 0
	NodeStatus_DOWN  NodeStatus = 1
)

func (NodeStatus) EnumDescriptor 

func (NodeStatus) EnumDescriptor() ([]byte, []int)

func (NodeStatus) String 

func (x NodeStatus) String() string

type RegisterNodeRequest 

type RegisterNodeRequest struct {
	Node *Node `protobuf:"bytes,1,opt,name=node" json:"node,omitempty"`
}

func (*RegisterNodeRequest) Descriptor 

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

func (*RegisterNodeRequest) GetNode 

func (m *RegisterNodeRequest) GetNode() *Node

func (*RegisterNodeRequest) ProtoMessage 

func (*RegisterNodeRequest) ProtoMessage()

func (*RegisterNodeRequest) Reset 

func (m *RegisterNodeRequest) Reset()

func (*RegisterNodeRequest) String 

func (m *RegisterNodeRequest) String() string

type RegisterNodeResponse 

type RegisterNodeResponse struct {
	HeartbeatTtl uint64 `protobuf:"varint,1,opt,name=heartbeat_ttl" json:"heartbeat_ttl,omitempty"`
}

func (*RegisterNodeResponse) Descriptor 

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

func (*RegisterNodeResponse) ProtoMessage 

func (*RegisterNodeResponse) ProtoMessage()

func (*RegisterNodeResponse) Reset 

func (m *RegisterNodeResponse) Reset()

func (*RegisterNodeResponse) String 

func (m *RegisterNodeResponse) String() string

type RemoveJobRequest 

type RemoveJobRequest struct {
	JobId string `protobuf:"bytes,1,opt,name=job_id" json:"job_id,omitempty"`
}

func (*RemoveJobRequest) Descriptor 

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

func (*RemoveJobRequest) ProtoMessage 

func (*RemoveJobRequest) ProtoMessage()

func (*RemoveJobRequest) Reset 

func (m *RemoveJobRequest) Reset()

func (*RemoveJobRequest) String 

func (m *RemoveJobRequest) String() string

type RemoveJobResponse 

type RemoveJobResponse struct {
}

func (*RemoveJobResponse) Descriptor 

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

func (*RemoveJobResponse) ProtoMessage 

func (*RemoveJobResponse) ProtoMessage()

func (*RemoveJobResponse) Reset 

func (m *RemoveJobResponse) Reset()

func (*RemoveJobResponse) String 

func (m *RemoveJobResponse) String() string

type RemoveTaskRequest 

type RemoveTaskRequest struct {
	TaskId string `protobuf:"bytes,1,opt,name=task_id" json:"task_id,omitempty"`
}

func (*RemoveTaskRequest) Descriptor 

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

func (*RemoveTaskRequest) ProtoMessage 

func (*RemoveTaskRequest) ProtoMessage()

func (*RemoveTaskRequest) Reset 

func (m *RemoveTaskRequest) Reset()

func (*RemoveTaskRequest) String 

func (m *RemoveTaskRequest) String() string

type RemoveTaskResponse 

type RemoveTaskResponse struct {
}

func (*RemoveTaskResponse) Descriptor 

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

func (*RemoveTaskResponse) ProtoMessage 

func (*RemoveTaskResponse) ProtoMessage()

func (*RemoveTaskResponse) Reset 

func (m *RemoveTaskResponse) Reset()

func (*RemoveTaskResponse) String 

func (m *RemoveTaskResponse) String() string

type Spec 

type Spec struct {
	Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	// remote specifies a URL to fetch task bundle data. This can either
	// be a git repository or blobster repository.
	Remote     string `protobuf:"bytes,2,opt,name=remote" json:"remote,omitempty"`
	Bundle     string `protobuf:"bytes,3,opt,name=bundle" json:"bundle,omitempty"`
	Entrypoint string `protobuf:"bytes,4,opt,name=entrypoint" json:"entrypoint,omitempty"`
	Instances  int64  `protobuf:"varint,5,opt,name=instances" json:"instances,omitempty"`
}

Spec defines the properties of a Job. As tasks are created, they gain the Job specification.

func (*Spec) Descriptor 

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

func (*Spec) ProtoMessage 

func (*Spec) ProtoMessage()

func (*Spec) Reset 

func (m *Spec) Reset()

func (*Spec) String 

func (m *Spec) String() string

type SwarmClient 

type SwarmClient interface {
	RegisterNode(ctx context.Context, in *RegisterNodeRequest, opts ...grpc.CallOption) (*RegisterNodeResponse, error)
	UpdateNodeStatus(ctx context.Context, in *UpdateNodeStatusRequest, opts ...grpc.CallOption) (*UpdateNodeStatusResponse, error)
	ListNodes(ctx context.Context, in *ListNodesRequest, opts ...grpc.CallOption) (*ListNodesResponse, error)
	DrainNode(ctx context.Context, in *DrainNodeRequest, opts ...grpc.CallOption) (*DrainNodeResponse, error)
	CreateTask(ctx context.Context, in *CreateTaskRequest, opts ...grpc.CallOption) (*CreateTaskResponse, error)
	GetTasks(ctx context.Context, in *GetTasksRequest, opts ...grpc.CallOption) (*GetTasksResponse, error)
	RemoveTask(ctx context.Context, in *RemoveTaskRequest, opts ...grpc.CallOption) (*RemoveTaskResponse, error)
	ListTasks(ctx context.Context, in *ListTasksRequest, opts ...grpc.CallOption) (*ListTasksResponse, error)
	CreateJob(ctx context.Context, in *CreateJobRequest, opts ...grpc.CallOption) (*CreateJobResponse, error)
	GetJob(ctx context.Context, in *GetJobRequest, opts ...grpc.CallOption) (*GetJobResponse, error)
	UpdateJob(ctx context.Context, in *UpdateJobRequest, opts ...grpc.CallOption) (*UpdateJobResponse, error)
	RemoveJob(ctx context.Context, in *RemoveJobRequest, opts ...grpc.CallOption) (*RemoveJobResponse, error)
	ListJobs(ctx context.Context, in *ListJobsRequest, opts ...grpc.CallOption) (*ListJobsResponse, error)
	UpdateTaskStatus(ctx context.Context, in *UpdateTaskStatusRequest, opts ...grpc.CallOption) (*UpdateTaskStatusResponse, error)
	WatchTasks(ctx context.Context, in *WatchTasksRequest, opts ...grpc.CallOption) (Swarm_WatchTasksClient, error)
}

func NewSwarmClient 

func NewSwarmClient(cc *grpc.ClientConn) SwarmClient

type SwarmServer 

type SwarmServer interface {
	RegisterNode(context.Context, *RegisterNodeRequest) (*RegisterNodeResponse, error)
	UpdateNodeStatus(context.Context, *UpdateNodeStatusRequest) (*UpdateNodeStatusResponse, error)
	ListNodes(context.Context, *ListNodesRequest) (*ListNodesResponse, error)
	DrainNode(context.Context, *DrainNodeRequest) (*DrainNodeResponse, error)
	CreateTask(context.Context, *CreateTaskRequest) (*CreateTaskResponse, error)
	GetTasks(context.Context, *GetTasksRequest) (*GetTasksResponse, error)
	RemoveTask(context.Context, *RemoveTaskRequest) (*RemoveTaskResponse, error)
	ListTasks(context.Context, *ListTasksRequest) (*ListTasksResponse, error)
	CreateJob(context.Context, *CreateJobRequest) (*CreateJobResponse, error)
	GetJob(context.Context, *GetJobRequest) (*GetJobResponse, error)
	UpdateJob(context.Context, *UpdateJobRequest) (*UpdateJobResponse, error)
	RemoveJob(context.Context, *RemoveJobRequest) (*RemoveJobResponse, error)
	ListJobs(context.Context, *ListJobsRequest) (*ListJobsResponse, error)
	UpdateTaskStatus(context.Context, *UpdateTaskStatusRequest) (*UpdateTaskStatusResponse, error)
	WatchTasks(*WatchTasksRequest, Swarm_WatchTasksServer) error
}

type Swarm_WatchTasksClient 

type Swarm_WatchTasksClient interface {
	Recv() (*WatchTasksResponse, error)
	grpc.ClientStream
}

type Swarm_WatchTasksServer 

type Swarm_WatchTasksServer interface {
	Send(*WatchTasksResponse) error
	grpc.ServerStream
}

type Task 

type Task struct {
	Id     string      `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
	JobId  string      `protobuf:"bytes,2,opt,name=job_id" json:"job_id,omitempty"`
	NodeId string      `protobuf:"bytes,3,opt,name=node_id" json:"node_id,omitempty"`
	Spec   *Spec       `protobuf:"bytes,4,opt,name=spec" json:"spec,omitempty"`
	Status *TaskStatus `protobuf:"bytes,5,opt,name=status" json:"status,omitempty"`
	// Networking state
	NetId      string   `protobuf:"bytes,6,opt,name=net_id" json:"net_id,omitempty"`
	EpId       string   `protobuf:"bytes,7,opt,name=ep_id" json:"ep_id,omitempty"`
	Ip         string   `protobuf:"bytes,8,opt,name=ip" json:"ip,omitempty"`
	Gateway    string   `protobuf:"bytes,9,opt,name=gateway" json:"gateway,omitempty"`
	DriverInfo []string `protobuf:"bytes,10,rep,name=driver_info" json:"driver_info,omitempty"`
}

func (*Task) Descriptor 

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

func (*Task) GetSpec 

func (m *Task) GetSpec() *Spec

func (*Task) GetStatus 

func (m *Task) GetStatus() *TaskStatus

func (*Task) ProtoMessage 

func (*Task) ProtoMessage()

func (*Task) Reset 

func (m *Task) Reset()

func (*Task) String 

func (m *Task) String() string

type TaskStatus 

type TaskStatus struct {
	State   TaskStatus_State `protobuf:"varint,2,opt,name=state,enum=api.TaskStatus_State" json:"state,omitempty"`
	Message string           `protobuf:"bytes,3,opt,name=message" json:"message,omitempty"`
}

func (*TaskStatus) Descriptor 

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

func (*TaskStatus) ProtoMessage 

func (*TaskStatus) ProtoMessage()

func (*TaskStatus) Reset 

func (m *TaskStatus) Reset()

func (*TaskStatus) String 

func (m *TaskStatus) String() string

type TaskStatus_State 

type TaskStatus_State int32
const (
	TaskStatus_NEW       TaskStatus_State = 0
	TaskStatus_ASSIGNED  TaskStatus_State = 1
	TaskStatus_PREPARING TaskStatus_State = 2
	TaskStatus_READY     TaskStatus_State = 3
	TaskStatus_STARTING  TaskStatus_State = 4
	TaskStatus_RUNNING   TaskStatus_State = 5
	TaskStatus_SHUTDOWN  TaskStatus_State = 6
	TaskStatus_COMPLETE  TaskStatus_State = 7
	TaskStatus_FAILED    TaskStatus_State = 8
	TaskStatus_REJECTED  TaskStatus_State = 9
	TaskStatus_FINALIZE  TaskStatus_State = 10
	TaskStatus_DEAD      TaskStatus_State = 11
)

func (TaskStatus_State) EnumDescriptor 

func (TaskStatus_State) EnumDescriptor() ([]byte, []int)

func (TaskStatus_State) String 

func (x TaskStatus_State) String() string

type Update 

type Update struct {
	// Types that are valid to be assigned to Update:
	//	*Update_UpdateNode
	//	*Update_UpdateTask
	//	*Update_UpdateJob
	//	*Update_DeleteNode
	//	*Update_DeleteTask
	//	*Update_DeleteJob
	Update isUpdate_Update `protobuf_oneof:"update"`
}

func (*Update) Descriptor 

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

func (*Update) GetDeleteJob 

func (m *Update) GetDeleteJob() string

func (*Update) GetDeleteNode 

func (m *Update) GetDeleteNode() string

func (*Update) GetDeleteTask 

func (m *Update) GetDeleteTask() string

func (*Update) GetUpdate 

func (m *Update) GetUpdate() isUpdate_Update

func (*Update) GetUpdateJob 

func (m *Update) GetUpdateJob() *Job

func (*Update) GetUpdateNode 

func (m *Update) GetUpdateNode() *Node

func (*Update) GetUpdateTask 

func (m *Update) GetUpdateTask() *Task

func (*Update) ProtoMessage 

func (*Update) ProtoMessage()

func (*Update) Reset 

func (m *Update) Reset()

func (*Update) String 

func (m *Update) String() string

func (*Update) XXX_OneofFuncs 

func (*Update) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type UpdateJobRequest 

type UpdateJobRequest struct {
	JobId string `protobuf:"bytes,1,opt,name=job_id" json:"job_id,omitempty"`
	Spec  *Spec  `protobuf:"bytes,2,opt,name=spec" json:"spec,omitempty"`
}

func (*UpdateJobRequest) Descriptor 

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

func (*UpdateJobRequest) GetSpec 

func (m *UpdateJobRequest) GetSpec() *Spec

func (*UpdateJobRequest) ProtoMessage 

func (*UpdateJobRequest) ProtoMessage()

func (*UpdateJobRequest) Reset 

func (m *UpdateJobRequest) Reset()

func (*UpdateJobRequest) String 

func (m *UpdateJobRequest) String() string

type UpdateJobResponse 

type UpdateJobResponse struct {
}

func (*UpdateJobResponse) Descriptor 

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

func (*UpdateJobResponse) ProtoMessage 

func (*UpdateJobResponse) ProtoMessage()

func (*UpdateJobResponse) Reset 

func (m *UpdateJobResponse) Reset()

func (*UpdateJobResponse) String 

func (m *UpdateJobResponse) String() string

type UpdateNodeStatusRequest 

type UpdateNodeStatusRequest struct {
	NodeId string     `protobuf:"bytes,1,opt,name=node_id" json:"node_id,omitempty"`
	Status NodeStatus `protobuf:"varint,2,opt,name=status,enum=api.NodeStatus" json:"status,omitempty"`
}

func (*UpdateNodeStatusRequest) Descriptor 

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

func (*UpdateNodeStatusRequest) ProtoMessage 

func (*UpdateNodeStatusRequest) ProtoMessage()

func (*UpdateNodeStatusRequest) Reset 

func (m *UpdateNodeStatusRequest) Reset()

func (*UpdateNodeStatusRequest) String 

func (m *UpdateNodeStatusRequest) String() string

type UpdateNodeStatusResponse 

type UpdateNodeStatusResponse struct {
	HeartbeatTtl uint64 `protobuf:"varint,1,opt,name=heartbeat_ttl" json:"heartbeat_ttl,omitempty"`
}

func (*UpdateNodeStatusResponse) Descriptor 

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

func (*UpdateNodeStatusResponse) ProtoMessage 

func (*UpdateNodeStatusResponse) ProtoMessage()

func (*UpdateNodeStatusResponse) Reset 

func (m *UpdateNodeStatusResponse) Reset()

func (*UpdateNodeStatusResponse) String 

func (m *UpdateNodeStatusResponse) String() string

type UpdateTaskStatusRequest 

type UpdateTaskStatusRequest struct {
	// Tasks should contain all statuses for running tasks. Only the status
	// field must be set. The spec is not required.
	Tasks []*Task `protobuf:"bytes,1,rep,name=tasks" json:"tasks,omitempty"`
}

func (*UpdateTaskStatusRequest) Descriptor 

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

func (*UpdateTaskStatusRequest) GetTasks 

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

func (*UpdateTaskStatusRequest) ProtoMessage 

func (*UpdateTaskStatusRequest) ProtoMessage()

func (*UpdateTaskStatusRequest) Reset 

func (m *UpdateTaskStatusRequest) Reset()

func (*UpdateTaskStatusRequest) String 

func (m *UpdateTaskStatusRequest) String() string

type UpdateTaskStatusResponse 

type UpdateTaskStatusResponse struct {
}

func (*UpdateTaskStatusResponse) Descriptor 

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

func (*UpdateTaskStatusResponse) ProtoMessage 

func (*UpdateTaskStatusResponse) ProtoMessage()

func (*UpdateTaskStatusResponse) Reset 

func (m *UpdateTaskStatusResponse) Reset()

func (*UpdateTaskStatusResponse) String 

func (m *UpdateTaskStatusResponse) String() string

type Update_DeleteJob 

type Update_DeleteJob struct {
	DeleteJob string `protobuf:"bytes,8,opt,name=deleteJob,oneof"`
}

type Update_DeleteNode 

type Update_DeleteNode struct {
	DeleteNode string `protobuf:"bytes,5,opt,name=deleteNode,oneof"`
}

type Update_DeleteTask 

type Update_DeleteTask struct {
	DeleteTask string `protobuf:"bytes,6,opt,name=deleteTask,oneof"`
}

type Update_UpdateJob 

type Update_UpdateJob struct {
	UpdateJob *Job `protobuf:"bytes,4,opt,name=updateJob,oneof"`
}

type Update_UpdateNode 

type Update_UpdateNode struct {
	UpdateNode *Node `protobuf:"bytes,1,opt,name=updateNode,oneof"`
}

type Update_UpdateTask 

type Update_UpdateTask struct {
	UpdateTask *Task `protobuf:"bytes,2,opt,name=updateTask,oneof"`
}

type WatchTasksRequest 

type WatchTasksRequest struct {
	NodeId string `protobuf:"bytes,1,opt,name=node_id" json:"node_id,omitempty"`
}

func (*WatchTasksRequest) Descriptor 

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

func (*WatchTasksRequest) ProtoMessage 

func (*WatchTasksRequest) ProtoMessage()

func (*WatchTasksRequest) Reset 

func (m *WatchTasksRequest) Reset()

func (*WatchTasksRequest) String 

func (m *WatchTasksRequest) String() string

type WatchTasksResponse 

type WatchTasksResponse struct {
	// Tasks is the set of tasks that should be running on the node.
	// Tasks outside of this set running on the node should be terminated.
	Tasks []*Task `protobuf:"bytes,1,rep,name=tasks" json:"tasks,omitempty"`
}

func (*WatchTasksResponse) Descriptor 

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

func (*WatchTasksResponse) GetTasks 

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

func (*WatchTasksResponse) ProtoMessage 

func (*WatchTasksResponse) ProtoMessage()

func (*WatchTasksResponse) Reset 

func (m *WatchTasksResponse) Reset()

func (*WatchTasksResponse) String 

func (m *WatchTasksResponse) String() string

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.