automation

package
v0.0.13-beta02 Latest Latest
Warning

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

 Go to latest Published: Jun 2, 2023 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 (m *ClusterOperation) GetState() ClusterOperationState

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 (m *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 (m *EnqueueClusterOperationRequest) GetName() string

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 (m *EnqueueClusterOperationRequest) String() 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 (m *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 (m *EnqueueClusterOperationResponse) GetId() string

func (*EnqueueClusterOperationResponse) ProtoMessage 

func (*EnqueueClusterOperationResponse) ProtoMessage()

func (*EnqueueClusterOperationResponse) Reset 

func (m *EnqueueClusterOperationResponse) Reset()

func (*EnqueueClusterOperationResponse) String 

func (m *EnqueueClusterOperationResponse) String() 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 (m *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 (m *GetClusterOperationDetailsRequest) GetId() string

func (*GetClusterOperationDetailsRequest) ProtoMessage 

func (*GetClusterOperationDetailsRequest) ProtoMessage()

func (*GetClusterOperationDetailsRequest) Reset 

func (m *GetClusterOperationDetailsRequest) Reset()

func (*GetClusterOperationDetailsRequest) String 

func (m *GetClusterOperationDetailsRequest) String() 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 (m *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 (m *GetClusterOperationDetailsResponse) GetClusterOp() *ClusterOperation

func (*GetClusterOperationDetailsResponse) ProtoMessage 

func (*GetClusterOperationDetailsResponse) ProtoMessage()

func (*GetClusterOperationDetailsResponse) Reset 

func (m *GetClusterOperationDetailsResponse) Reset()

func (*GetClusterOperationDetailsResponse) String 

func (m *GetClusterOperationDetailsResponse) String() 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 (m *GetClusterOperationDetailsResponse) XXX_Merge(src proto.Message)

func (*GetClusterOperationDetailsResponse) XXX_Size 

func (m *GetClusterOperationDetailsResponse) XXX_Size() int

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 (m *GetClusterOperationStateRequest) GetId() string

func (*GetClusterOperationStateRequest) ProtoMessage 

func (*GetClusterOperationStateRequest) ProtoMessage()

func (*GetClusterOperationStateRequest) Reset 

func (m *GetClusterOperationStateRequest) Reset()

func (*GetClusterOperationStateRequest) String 

func (m *GetClusterOperationStateRequest) String() 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 (m *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 (m *GetClusterOperationStateResponse) GetState() ClusterOperationState

func (*GetClusterOperationStateResponse) ProtoMessage 

func (*GetClusterOperationStateResponse) ProtoMessage()

func (*GetClusterOperationStateResponse) Reset 

func (m *GetClusterOperationStateResponse) Reset()

func (*GetClusterOperationStateResponse) String 

func (m *GetClusterOperationStateResponse) String() 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 (m *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 (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 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 (m *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

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.