automation

package
v2.1.0-rc.1+incompatible Latest Latest
Warning

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

Go to latest
Published: Apr 6, 2017 License: BSD-3-Clause Imports: 3 Imported by: 0

Documentation

Overview

Package automation is a generated protocol buffer package.

It is generated from these files:

automation.proto

It has these top-level messages:

ClusterOperation
TaskContainer
Task
EnqueueClusterOperationRequest
EnqueueClusterOperationResponse
GetClusterOperationStateRequest
GetClusterOperationStateResponse
GetClusterOperationDetailsRequest
GetClusterOperationDetailsResponse

Index

Constants

This section is empty.

Variables

View Source
var ClusterOperationState_name = map[int32]string{
	0: "UNKNOWN_CLUSTER_OPERATION_STATE",
	1: "CLUSTER_OPERATION_NOT_STARTED",
	2: "CLUSTER_OPERATION_RUNNING",
	3: "CLUSTER_OPERATION_DONE",
}
View Source
var ClusterOperationState_value = map[string]int32{
	"UNKNOWN_CLUSTER_OPERATION_STATE": 0,
	"CLUSTER_OPERATION_NOT_STARTED":   1,
	"CLUSTER_OPERATION_RUNNING":       2,
	"CLUSTER_OPERATION_DONE":          3,
}
View Source
var TaskState_name = map[int32]string{
	0: "UNKNOWN_TASK_STATE",
	1: "NOT_STARTED",
	2: "RUNNING",
	3: "DONE",
}
View Source
var TaskState_value = map[string]int32{
	"UNKNOWN_TASK_STATE": 0,
	"NOT_STARTED":        1,
	"RUNNING":            2,
	"DONE":               3,
}

Functions

This section is empty.

Types

type ClusterOperation

type ClusterOperation struct {
	Id string `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
	// TaskContainer are processed sequentially, one at a time.
	SerialTasks []*TaskContainer `protobuf:"bytes,2,rep,name=serial_tasks,json=serialTasks" json:"serial_tasks,omitempty"`
	// Cached value. This has to be re-evaluated e.g. after a checkpoint load because running tasks may have already finished.
	State ClusterOperationState `protobuf:"varint,3,opt,name=state,enum=automation.ClusterOperationState" json:"state,omitempty"`
	// Error of the first task which failed. Set after state advanced to CLUSTER_OPERATION_DONE. If empty, all tasks succeeded. Cached value, see state above.
	Error string `protobuf:"bytes,4,opt,name=error" json:"error,omitempty"`
}

func (*ClusterOperation) Descriptor

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

func (*ClusterOperation) GetError

func (m *ClusterOperation) GetError() string

func (*ClusterOperation) GetId

func (m *ClusterOperation) GetId() string

func (*ClusterOperation) GetSerialTasks

func (m *ClusterOperation) GetSerialTasks() []*TaskContainer

func (*ClusterOperation) GetState

func (*ClusterOperation) ProtoMessage

func (*ClusterOperation) ProtoMessage()

func (*ClusterOperation) Reset

func (m *ClusterOperation) Reset()

func (*ClusterOperation) String

func (m *ClusterOperation) String() string

type ClusterOperationState

type ClusterOperationState int32
const (
	ClusterOperationState_UNKNOWN_CLUSTER_OPERATION_STATE ClusterOperationState = 0
	ClusterOperationState_CLUSTER_OPERATION_NOT_STARTED   ClusterOperationState = 1
	ClusterOperationState_CLUSTER_OPERATION_RUNNING       ClusterOperationState = 2
	ClusterOperationState_CLUSTER_OPERATION_DONE          ClusterOperationState = 3
)

func (ClusterOperationState) EnumDescriptor

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

func (ClusterOperationState) String

func (x ClusterOperationState) String() string

type EnqueueClusterOperationRequest

type EnqueueClusterOperationRequest struct {
	Name       string            `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	Parameters map[string]string `` /* 140-byte string literal not displayed */
}

func (*EnqueueClusterOperationRequest) Descriptor

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

func (*EnqueueClusterOperationRequest) GetName

func (*EnqueueClusterOperationRequest) GetParameters

func (m *EnqueueClusterOperationRequest) GetParameters() map[string]string

func (*EnqueueClusterOperationRequest) ProtoMessage

func (*EnqueueClusterOperationRequest) ProtoMessage()

func (*EnqueueClusterOperationRequest) Reset

func (m *EnqueueClusterOperationRequest) Reset()

func (*EnqueueClusterOperationRequest) String

type EnqueueClusterOperationResponse

type EnqueueClusterOperationResponse struct {
	Id string `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
}

func (*EnqueueClusterOperationResponse) Descriptor

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

func (*EnqueueClusterOperationResponse) GetId

func (*EnqueueClusterOperationResponse) ProtoMessage

func (*EnqueueClusterOperationResponse) ProtoMessage()

func (*EnqueueClusterOperationResponse) Reset

func (*EnqueueClusterOperationResponse) String

type GetClusterOperationDetailsRequest

type GetClusterOperationDetailsRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
}

func (*GetClusterOperationDetailsRequest) Descriptor

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

func (*GetClusterOperationDetailsRequest) GetId

func (*GetClusterOperationDetailsRequest) ProtoMessage

func (*GetClusterOperationDetailsRequest) ProtoMessage()

func (*GetClusterOperationDetailsRequest) Reset

func (*GetClusterOperationDetailsRequest) String

type GetClusterOperationDetailsResponse

type GetClusterOperationDetailsResponse struct {
	// Full snapshot of the execution e.g. including output of each task.
	ClusterOp *ClusterOperation `protobuf:"bytes,2,opt,name=cluster_op,json=clusterOp" json:"cluster_op,omitempty"`
}

func (*GetClusterOperationDetailsResponse) Descriptor

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

func (*GetClusterOperationDetailsResponse) GetClusterOp

func (*GetClusterOperationDetailsResponse) ProtoMessage

func (*GetClusterOperationDetailsResponse) ProtoMessage()

func (*GetClusterOperationDetailsResponse) Reset

func (*GetClusterOperationDetailsResponse) String

type GetClusterOperationStateRequest

type GetClusterOperationStateRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
}

func (*GetClusterOperationStateRequest) Descriptor

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

func (*GetClusterOperationStateRequest) GetId

func (*GetClusterOperationStateRequest) ProtoMessage

func (*GetClusterOperationStateRequest) ProtoMessage()

func (*GetClusterOperationStateRequest) Reset

func (*GetClusterOperationStateRequest) String

type GetClusterOperationStateResponse

type GetClusterOperationStateResponse struct {
	State ClusterOperationState `protobuf:"varint,1,opt,name=state,enum=automation.ClusterOperationState" json:"state,omitempty"`
}

func (*GetClusterOperationStateResponse) Descriptor

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

func (*GetClusterOperationStateResponse) GetState

func (*GetClusterOperationStateResponse) ProtoMessage

func (*GetClusterOperationStateResponse) ProtoMessage()

func (*GetClusterOperationStateResponse) Reset

func (*GetClusterOperationStateResponse) String

type Task

type Task struct {
	// Task specification.
	Name       string            `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	Parameters map[string]string `` /* 140-byte string literal not displayed */
	// Runtime data.
	Id    string    `protobuf:"bytes,3,opt,name=id" json:"id,omitempty"`
	State TaskState `protobuf:"varint,4,opt,name=state,enum=automation.TaskState" json:"state,omitempty"`
	// Set after state advanced to DONE.
	Output string `protobuf:"bytes,5,opt,name=output" json:"output,omitempty"`
	// Set after state advanced to DONE. If empty, the task did succeed.
	Error string `protobuf:"bytes,6,opt,name=error" json:"error,omitempty"`
}

Task represents a specific task which should be automatically executed.

func (*Task) Descriptor

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

func (*Task) GetError

func (m *Task) GetError() string

func (*Task) GetId

func (m *Task) GetId() string

func (*Task) GetName

func (m *Task) GetName() string

func (*Task) GetOutput

func (m *Task) GetOutput() string

func (*Task) GetParameters

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

func (*Task) GetState

func (m *Task) GetState() TaskState

func (*Task) ProtoMessage

func (*Task) ProtoMessage()

func (*Task) Reset

func (m *Task) Reset()

func (*Task) String

func (m *Task) String() string

type TaskContainer

type TaskContainer struct {
	ParallelTasks []*Task `protobuf:"bytes,1,rep,name=parallel_tasks,json=parallelTasks" json:"parallel_tasks,omitempty"`
	Concurrency   int32   `protobuf:"varint,2,opt,name=concurrency" json:"concurrency,omitempty"`
}

TaskContainer holds one or more task which may be executed in parallel. "concurrency", if > 0, limits the amount of concurrently executed tasks.

func (*TaskContainer) Descriptor

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

func (*TaskContainer) GetConcurrency

func (m *TaskContainer) GetConcurrency() int32

func (*TaskContainer) GetParallelTasks

func (m *TaskContainer) GetParallelTasks() []*Task

func (*TaskContainer) ProtoMessage

func (*TaskContainer) ProtoMessage()

func (*TaskContainer) Reset

func (m *TaskContainer) Reset()

func (*TaskContainer) String

func (m *TaskContainer) String() string

type TaskState

type TaskState int32
const (
	TaskState_UNKNOWN_TASK_STATE TaskState = 0
	TaskState_NOT_STARTED        TaskState = 1
	TaskState_RUNNING            TaskState = 2
	TaskState_DONE               TaskState = 3
)

func (TaskState) EnumDescriptor

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

func (TaskState) String

func (x TaskState) String() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL