automation

package
v3.0.0-rc.3+incompatible Latest Latest
Warning

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

Go to latest
Published: Dec 9, 2018 License: Apache-2.0 Imports: 3 Imported by: 0

Documentation

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,proto3" json:"id,omitempty"`
	// TaskContainer are processed sequentially, one at a time.
	SerialTasks []*TaskContainer `protobuf:"bytes,2,rep,name=serial_tasks,json=serialTasks,proto3" 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,proto3,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,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*ClusterOperation) XXX_DiscardUnknown

func (m *ClusterOperation) XXX_DiscardUnknown()

func (*ClusterOperation) XXX_Marshal

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

func (*ClusterOperation) XXX_Merge

func (dst *ClusterOperation) XXX_Merge(src proto.Message)

func (*ClusterOperation) XXX_Size

func (m *ClusterOperation) XXX_Size() int

func (*ClusterOperation) XXX_Unmarshal

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

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,proto3" json:"name,omitempty"`
	Parameters           map[string]string `` /* 161-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

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

func (*EnqueueClusterOperationRequest) XXX_DiscardUnknown

func (m *EnqueueClusterOperationRequest) XXX_DiscardUnknown()

func (*EnqueueClusterOperationRequest) XXX_Marshal

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

func (*EnqueueClusterOperationRequest) XXX_Merge

func (dst *EnqueueClusterOperationRequest) XXX_Merge(src proto.Message)

func (*EnqueueClusterOperationRequest) XXX_Size

func (m *EnqueueClusterOperationRequest) XXX_Size() int

func (*EnqueueClusterOperationRequest) XXX_Unmarshal

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

type EnqueueClusterOperationResponse

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

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

func (*EnqueueClusterOperationResponse) GetId

func (*EnqueueClusterOperationResponse) ProtoMessage

func (*EnqueueClusterOperationResponse) ProtoMessage()

func (*EnqueueClusterOperationResponse) Reset

func (*EnqueueClusterOperationResponse) String

func (*EnqueueClusterOperationResponse) XXX_DiscardUnknown

func (m *EnqueueClusterOperationResponse) XXX_DiscardUnknown()

func (*EnqueueClusterOperationResponse) XXX_Marshal

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

func (*EnqueueClusterOperationResponse) XXX_Merge

func (dst *EnqueueClusterOperationResponse) XXX_Merge(src proto.Message)

func (*EnqueueClusterOperationResponse) XXX_Size

func (m *EnqueueClusterOperationResponse) XXX_Size() int

func (*EnqueueClusterOperationResponse) XXX_Unmarshal

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

type GetClusterOperationDetailsRequest

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

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

func (*GetClusterOperationDetailsRequest) GetId

func (*GetClusterOperationDetailsRequest) ProtoMessage

func (*GetClusterOperationDetailsRequest) ProtoMessage()

func (*GetClusterOperationDetailsRequest) Reset

func (*GetClusterOperationDetailsRequest) String

func (*GetClusterOperationDetailsRequest) XXX_DiscardUnknown

func (m *GetClusterOperationDetailsRequest) XXX_DiscardUnknown()

func (*GetClusterOperationDetailsRequest) XXX_Marshal

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

func (*GetClusterOperationDetailsRequest) XXX_Merge

func (dst *GetClusterOperationDetailsRequest) XXX_Merge(src proto.Message)

func (*GetClusterOperationDetailsRequest) XXX_Size

func (m *GetClusterOperationDetailsRequest) XXX_Size() int

func (*GetClusterOperationDetailsRequest) XXX_Unmarshal

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

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

func (*GetClusterOperationDetailsResponse) Descriptor

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

func (*GetClusterOperationDetailsResponse) GetClusterOp

func (*GetClusterOperationDetailsResponse) ProtoMessage

func (*GetClusterOperationDetailsResponse) ProtoMessage()

func (*GetClusterOperationDetailsResponse) Reset

func (*GetClusterOperationDetailsResponse) String

func (*GetClusterOperationDetailsResponse) XXX_DiscardUnknown

func (m *GetClusterOperationDetailsResponse) XXX_DiscardUnknown()

func (*GetClusterOperationDetailsResponse) XXX_Marshal

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

func (*GetClusterOperationDetailsResponse) XXX_Merge

func (dst *GetClusterOperationDetailsResponse) XXX_Merge(src proto.Message)

func (*GetClusterOperationDetailsResponse) XXX_Size

func (*GetClusterOperationDetailsResponse) XXX_Unmarshal

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

type GetClusterOperationStateRequest

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

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

func (*GetClusterOperationStateRequest) GetId

func (*GetClusterOperationStateRequest) ProtoMessage

func (*GetClusterOperationStateRequest) ProtoMessage()

func (*GetClusterOperationStateRequest) Reset

func (*GetClusterOperationStateRequest) String

func (*GetClusterOperationStateRequest) XXX_DiscardUnknown

func (m *GetClusterOperationStateRequest) XXX_DiscardUnknown()

func (*GetClusterOperationStateRequest) XXX_Marshal

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

func (*GetClusterOperationStateRequest) XXX_Merge

func (dst *GetClusterOperationStateRequest) XXX_Merge(src proto.Message)

func (*GetClusterOperationStateRequest) XXX_Size

func (m *GetClusterOperationStateRequest) XXX_Size() int

func (*GetClusterOperationStateRequest) XXX_Unmarshal

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

type GetClusterOperationStateResponse

type GetClusterOperationStateResponse struct {
	State                ClusterOperationState `protobuf:"varint,1,opt,name=state,proto3,enum=automation.ClusterOperationState" json:"state,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*GetClusterOperationStateResponse) Descriptor

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

func (*GetClusterOperationStateResponse) GetState

func (*GetClusterOperationStateResponse) ProtoMessage

func (*GetClusterOperationStateResponse) ProtoMessage()

func (*GetClusterOperationStateResponse) Reset

func (*GetClusterOperationStateResponse) String

func (*GetClusterOperationStateResponse) XXX_DiscardUnknown

func (m *GetClusterOperationStateResponse) XXX_DiscardUnknown()

func (*GetClusterOperationStateResponse) XXX_Marshal

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

func (*GetClusterOperationStateResponse) XXX_Merge

func (dst *GetClusterOperationStateResponse) XXX_Merge(src proto.Message)

func (*GetClusterOperationStateResponse) XXX_Size

func (m *GetClusterOperationStateResponse) XXX_Size() int

func (*GetClusterOperationStateResponse) XXX_Unmarshal

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

type Task

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

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

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 (dst *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 TaskContainer

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

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

func (*TaskContainer) XXX_DiscardUnknown

func (m *TaskContainer) XXX_DiscardUnknown()

func (*TaskContainer) XXX_Marshal

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

func (*TaskContainer) XXX_Merge

func (dst *TaskContainer) XXX_Merge(src proto.Message)

func (*TaskContainer) XXX_Size

func (m *TaskContainer) XXX_Size() int

func (*TaskContainer) XXX_Unmarshal

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

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