automation

package
v0.14.1 Latest Latest
Warning

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

Go to latest
Published: Jul 26, 2022 License: Apache-2.0 Imports: 7 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",
	}
	ClusterOperationState_value = map[string]int32{
		"UNKNOWN_CLUSTER_OPERATION_STATE": 0,
		"CLUSTER_OPERATION_NOT_STARTED":   1,
		"CLUSTER_OPERATION_RUNNING":       2,
		"CLUSTER_OPERATION_DONE":          3,
	}
)

Enum value maps for ClusterOperationState.

View Source
var (
	TaskState_name = map[int32]string{
		0: "UNKNOWN_TASK_STATE",
		1: "NOT_STARTED",
		2: "RUNNING",
		3: "DONE",
	}
	TaskState_value = map[string]int32{
		"UNKNOWN_TASK_STATE": 0,
		"NOT_STARTED":        1,
		"RUNNING":            2,
		"DONE":               3,
	}
)

Enum value maps for TaskState.

View Source
var (
	ErrInvalidLength        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflow          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroup = fmt.Errorf("proto: unexpected end of group")
)
View Source
var File_automation_proto protoreflect.FileDescriptor

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"`
	// contains filtered or unexported fields
}

func (*ClusterOperation) Descriptor deprecated

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

Deprecated: Use ClusterOperation.ProtoReflect.Descriptor instead.

func (*ClusterOperation) GetError

func (x *ClusterOperation) GetError() string

func (*ClusterOperation) GetId

func (x *ClusterOperation) GetId() string

func (*ClusterOperation) GetSerialTasks

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

func (*ClusterOperation) GetState

func (*ClusterOperation) MarshalToSizedBufferVT added in v0.11.0

func (m *ClusterOperation) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ClusterOperation) MarshalToVT added in v0.11.0

func (m *ClusterOperation) MarshalToVT(dAtA []byte) (int, error)

func (*ClusterOperation) MarshalVT added in v0.11.0

func (m *ClusterOperation) MarshalVT() (dAtA []byte, err error)

func (*ClusterOperation) ProtoMessage

func (*ClusterOperation) ProtoMessage()

func (*ClusterOperation) ProtoReflect added in v0.11.0

func (x *ClusterOperation) ProtoReflect() protoreflect.Message

func (*ClusterOperation) Reset

func (x *ClusterOperation) Reset()

func (*ClusterOperation) SizeVT added in v0.11.0

func (m *ClusterOperation) SizeVT() (n int)

func (*ClusterOperation) String

func (x *ClusterOperation) String() string

func (*ClusterOperation) UnmarshalVT added in v0.11.0

func (m *ClusterOperation) UnmarshalVT(dAtA []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) Descriptor added in v0.11.0

func (ClusterOperationState) Enum added in v0.11.0

func (ClusterOperationState) EnumDescriptor deprecated

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

Deprecated: Use ClusterOperationState.Descriptor instead.

func (ClusterOperationState) Number added in v0.11.0

func (ClusterOperationState) String

func (x ClusterOperationState) String() string

func (ClusterOperationState) Type added in v0.11.0

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 */
	// contains filtered or unexported fields
}

func (*EnqueueClusterOperationRequest) Descriptor deprecated

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

Deprecated: Use EnqueueClusterOperationRequest.ProtoReflect.Descriptor instead.

func (*EnqueueClusterOperationRequest) GetName

func (*EnqueueClusterOperationRequest) GetParameters

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

func (*EnqueueClusterOperationRequest) MarshalToSizedBufferVT added in v0.11.0

func (m *EnqueueClusterOperationRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*EnqueueClusterOperationRequest) MarshalToVT added in v0.11.0

func (m *EnqueueClusterOperationRequest) MarshalToVT(dAtA []byte) (int, error)

func (*EnqueueClusterOperationRequest) MarshalVT added in v0.11.0

func (m *EnqueueClusterOperationRequest) MarshalVT() (dAtA []byte, err error)

func (*EnqueueClusterOperationRequest) ProtoMessage

func (*EnqueueClusterOperationRequest) ProtoMessage()

func (*EnqueueClusterOperationRequest) ProtoReflect added in v0.11.0

func (*EnqueueClusterOperationRequest) Reset

func (x *EnqueueClusterOperationRequest) Reset()

func (*EnqueueClusterOperationRequest) SizeVT added in v0.11.0

func (m *EnqueueClusterOperationRequest) SizeVT() (n int)

func (*EnqueueClusterOperationRequest) String

func (*EnqueueClusterOperationRequest) UnmarshalVT added in v0.11.0

func (m *EnqueueClusterOperationRequest) UnmarshalVT(dAtA []byte) error

type EnqueueClusterOperationResponse

type EnqueueClusterOperationResponse struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*EnqueueClusterOperationResponse) Descriptor deprecated

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

Deprecated: Use EnqueueClusterOperationResponse.ProtoReflect.Descriptor instead.

func (*EnqueueClusterOperationResponse) GetId

func (*EnqueueClusterOperationResponse) MarshalToSizedBufferVT added in v0.11.0

func (m *EnqueueClusterOperationResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*EnqueueClusterOperationResponse) MarshalToVT added in v0.11.0

func (m *EnqueueClusterOperationResponse) MarshalToVT(dAtA []byte) (int, error)

func (*EnqueueClusterOperationResponse) MarshalVT added in v0.11.0

func (m *EnqueueClusterOperationResponse) MarshalVT() (dAtA []byte, err error)

func (*EnqueueClusterOperationResponse) ProtoMessage

func (*EnqueueClusterOperationResponse) ProtoMessage()

func (*EnqueueClusterOperationResponse) ProtoReflect added in v0.11.0

func (*EnqueueClusterOperationResponse) Reset

func (*EnqueueClusterOperationResponse) SizeVT added in v0.11.0

func (m *EnqueueClusterOperationResponse) SizeVT() (n int)

func (*EnqueueClusterOperationResponse) String

func (*EnqueueClusterOperationResponse) UnmarshalVT added in v0.11.0

func (m *EnqueueClusterOperationResponse) UnmarshalVT(dAtA []byte) error

type GetClusterOperationDetailsRequest

type GetClusterOperationDetailsRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetClusterOperationDetailsRequest) Descriptor deprecated

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

Deprecated: Use GetClusterOperationDetailsRequest.ProtoReflect.Descriptor instead.

func (*GetClusterOperationDetailsRequest) GetId

func (*GetClusterOperationDetailsRequest) MarshalToSizedBufferVT added in v0.11.0

func (m *GetClusterOperationDetailsRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GetClusterOperationDetailsRequest) MarshalToVT added in v0.11.0

func (m *GetClusterOperationDetailsRequest) MarshalToVT(dAtA []byte) (int, error)

func (*GetClusterOperationDetailsRequest) MarshalVT added in v0.11.0

func (m *GetClusterOperationDetailsRequest) MarshalVT() (dAtA []byte, err error)

func (*GetClusterOperationDetailsRequest) ProtoMessage

func (*GetClusterOperationDetailsRequest) ProtoMessage()

func (*GetClusterOperationDetailsRequest) ProtoReflect added in v0.11.0

func (*GetClusterOperationDetailsRequest) Reset

func (*GetClusterOperationDetailsRequest) SizeVT added in v0.11.0

func (m *GetClusterOperationDetailsRequest) SizeVT() (n int)

func (*GetClusterOperationDetailsRequest) String

func (*GetClusterOperationDetailsRequest) UnmarshalVT added in v0.11.0

func (m *GetClusterOperationDetailsRequest) UnmarshalVT(dAtA []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"`
	// contains filtered or unexported fields
}

func (*GetClusterOperationDetailsResponse) Descriptor deprecated

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

Deprecated: Use GetClusterOperationDetailsResponse.ProtoReflect.Descriptor instead.

func (*GetClusterOperationDetailsResponse) GetClusterOp

func (*GetClusterOperationDetailsResponse) MarshalToSizedBufferVT added in v0.11.0

func (m *GetClusterOperationDetailsResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GetClusterOperationDetailsResponse) MarshalToVT added in v0.11.0

func (m *GetClusterOperationDetailsResponse) MarshalToVT(dAtA []byte) (int, error)

func (*GetClusterOperationDetailsResponse) MarshalVT added in v0.11.0

func (m *GetClusterOperationDetailsResponse) MarshalVT() (dAtA []byte, err error)

func (*GetClusterOperationDetailsResponse) ProtoMessage

func (*GetClusterOperationDetailsResponse) ProtoMessage()

func (*GetClusterOperationDetailsResponse) ProtoReflect added in v0.11.0

func (*GetClusterOperationDetailsResponse) Reset

func (*GetClusterOperationDetailsResponse) SizeVT added in v0.11.0

func (m *GetClusterOperationDetailsResponse) SizeVT() (n int)

func (*GetClusterOperationDetailsResponse) String

func (*GetClusterOperationDetailsResponse) UnmarshalVT added in v0.11.0

func (m *GetClusterOperationDetailsResponse) UnmarshalVT(dAtA []byte) error

type GetClusterOperationStateRequest

type GetClusterOperationStateRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetClusterOperationStateRequest) Descriptor deprecated

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

Deprecated: Use GetClusterOperationStateRequest.ProtoReflect.Descriptor instead.

func (*GetClusterOperationStateRequest) GetId

func (*GetClusterOperationStateRequest) MarshalToSizedBufferVT added in v0.11.0

func (m *GetClusterOperationStateRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GetClusterOperationStateRequest) MarshalToVT added in v0.11.0

func (m *GetClusterOperationStateRequest) MarshalToVT(dAtA []byte) (int, error)

func (*GetClusterOperationStateRequest) MarshalVT added in v0.11.0

func (m *GetClusterOperationStateRequest) MarshalVT() (dAtA []byte, err error)

func (*GetClusterOperationStateRequest) ProtoMessage

func (*GetClusterOperationStateRequest) ProtoMessage()

func (*GetClusterOperationStateRequest) ProtoReflect added in v0.11.0

func (*GetClusterOperationStateRequest) Reset

func (*GetClusterOperationStateRequest) SizeVT added in v0.11.0

func (m *GetClusterOperationStateRequest) SizeVT() (n int)

func (*GetClusterOperationStateRequest) String

func (*GetClusterOperationStateRequest) UnmarshalVT added in v0.11.0

func (m *GetClusterOperationStateRequest) UnmarshalVT(dAtA []byte) error

type GetClusterOperationStateResponse

type GetClusterOperationStateResponse struct {
	State ClusterOperationState `protobuf:"varint,1,opt,name=state,proto3,enum=automation.ClusterOperationState" json:"state,omitempty"`
	// contains filtered or unexported fields
}

func (*GetClusterOperationStateResponse) Descriptor deprecated

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

Deprecated: Use GetClusterOperationStateResponse.ProtoReflect.Descriptor instead.

func (*GetClusterOperationStateResponse) GetState

func (*GetClusterOperationStateResponse) MarshalToSizedBufferVT added in v0.11.0

func (m *GetClusterOperationStateResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GetClusterOperationStateResponse) MarshalToVT added in v0.11.0

func (m *GetClusterOperationStateResponse) MarshalToVT(dAtA []byte) (int, error)

func (*GetClusterOperationStateResponse) MarshalVT added in v0.11.0

func (m *GetClusterOperationStateResponse) MarshalVT() (dAtA []byte, err error)

func (*GetClusterOperationStateResponse) ProtoMessage

func (*GetClusterOperationStateResponse) ProtoMessage()

func (*GetClusterOperationStateResponse) ProtoReflect added in v0.11.0

func (*GetClusterOperationStateResponse) Reset

func (*GetClusterOperationStateResponse) SizeVT added in v0.11.0

func (m *GetClusterOperationStateResponse) SizeVT() (n int)

func (*GetClusterOperationStateResponse) String

func (*GetClusterOperationStateResponse) UnmarshalVT added in v0.11.0

func (m *GetClusterOperationStateResponse) UnmarshalVT(dAtA []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"`
	// contains filtered or unexported fields
}

Task represents a specific task which should be automatically executed.

func (*Task) Descriptor deprecated

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

Deprecated: Use Task.ProtoReflect.Descriptor instead.

func (*Task) GetError

func (x *Task) GetError() string

func (*Task) GetId

func (x *Task) GetId() string

func (*Task) GetName

func (x *Task) GetName() string

func (*Task) GetOutput

func (x *Task) GetOutput() string

func (*Task) GetParameters

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

func (*Task) GetState

func (x *Task) GetState() TaskState

func (*Task) MarshalToSizedBufferVT added in v0.11.0

func (m *Task) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Task) MarshalToVT added in v0.11.0

func (m *Task) MarshalToVT(dAtA []byte) (int, error)

func (*Task) MarshalVT added in v0.11.0

func (m *Task) MarshalVT() (dAtA []byte, err error)

func (*Task) ProtoMessage

func (*Task) ProtoMessage()

func (*Task) ProtoReflect added in v0.11.0

func (x *Task) ProtoReflect() protoreflect.Message

func (*Task) Reset

func (x *Task) Reset()

func (*Task) SizeVT added in v0.11.0

func (m *Task) SizeVT() (n int)

func (*Task) String

func (x *Task) String() string

func (*Task) UnmarshalVT added in v0.11.0

func (m *Task) UnmarshalVT(dAtA []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"`
	// contains filtered or unexported fields
}

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 deprecated

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

Deprecated: Use TaskContainer.ProtoReflect.Descriptor instead.

func (*TaskContainer) GetConcurrency

func (x *TaskContainer) GetConcurrency() int32

func (*TaskContainer) GetParallelTasks

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

func (*TaskContainer) MarshalToSizedBufferVT added in v0.11.0

func (m *TaskContainer) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*TaskContainer) MarshalToVT added in v0.11.0

func (m *TaskContainer) MarshalToVT(dAtA []byte) (int, error)

func (*TaskContainer) MarshalVT added in v0.11.0

func (m *TaskContainer) MarshalVT() (dAtA []byte, err error)

func (*TaskContainer) ProtoMessage

func (*TaskContainer) ProtoMessage()

func (*TaskContainer) ProtoReflect added in v0.11.0

func (x *TaskContainer) ProtoReflect() protoreflect.Message

func (*TaskContainer) Reset

func (x *TaskContainer) Reset()

func (*TaskContainer) SizeVT added in v0.11.0

func (m *TaskContainer) SizeVT() (n int)

func (*TaskContainer) String

func (x *TaskContainer) String() string

func (*TaskContainer) UnmarshalVT added in v0.11.0

func (m *TaskContainer) UnmarshalVT(dAtA []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) Descriptor added in v0.11.0

func (TaskState) Descriptor() protoreflect.EnumDescriptor

func (TaskState) Enum added in v0.11.0

func (x TaskState) Enum() *TaskState

func (TaskState) EnumDescriptor deprecated

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

Deprecated: Use TaskState.Descriptor instead.

func (TaskState) Number added in v0.11.0

func (x TaskState) Number() protoreflect.EnumNumber

func (TaskState) String

func (x TaskState) String() string

func (TaskState) Type added in v0.11.0

Jump to

Keyboard shortcuts

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