automation

package
v0.16.0-rc1 Latest Latest
Warning

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

 Go to latest Published: Feb 8, 2023 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 (x *ClusterOperation) GetState() ClusterOperationState

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) Descriptor() protoreflect.EnumDescriptor

func (ClusterOperationState) Enum added in v0.11.0 

func (x ClusterOperationState) Enum() *ClusterOperationState

func (ClusterOperationState) EnumDescriptor deprecated 

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

Deprecated: Use ClusterOperationState.Descriptor instead.

func (ClusterOperationState) Number added in v0.11.0 

func (x ClusterOperationState) Number() protoreflect.EnumNumber

func (ClusterOperationState) String 

func (x ClusterOperationState) String() string

func (ClusterOperationState) Type added in v0.11.0 

func (ClusterOperationState) Type() protoreflect.EnumType

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

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 (x *EnqueueClusterOperationRequest) ProtoReflect() protoreflect.Message

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

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 (x *EnqueueClusterOperationResponse) ProtoReflect() protoreflect.Message

func (*EnqueueClusterOperationResponse) Reset 

func (x *EnqueueClusterOperationResponse) Reset()

func (*EnqueueClusterOperationResponse) SizeVT added in v0.11.0 

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

func (*EnqueueClusterOperationResponse) String 

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

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 (x *GetClusterOperationDetailsRequest) ProtoReflect() protoreflect.Message

func (*GetClusterOperationDetailsRequest) Reset 

func (x *GetClusterOperationDetailsRequest) Reset()

func (*GetClusterOperationDetailsRequest) SizeVT added in v0.11.0 

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

func (*GetClusterOperationDetailsRequest) String 

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

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 (x *GetClusterOperationDetailsResponse) ProtoReflect() protoreflect.Message

func (*GetClusterOperationDetailsResponse) Reset 

func (x *GetClusterOperationDetailsResponse) Reset()

func (*GetClusterOperationDetailsResponse) SizeVT added in v0.11.0 

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

func (*GetClusterOperationDetailsResponse) String 

func (x *GetClusterOperationDetailsResponse) String() 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 (x *GetClusterOperationStateRequest) GetId() string

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 (x *GetClusterOperationStateRequest) ProtoReflect() protoreflect.Message

func (*GetClusterOperationStateRequest) Reset 

func (x *GetClusterOperationStateRequest) Reset()

func (*GetClusterOperationStateRequest) SizeVT added in v0.11.0 

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

func (*GetClusterOperationStateRequest) String 

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

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 (x *GetClusterOperationStateResponse) ProtoReflect() protoreflect.Message

func (*GetClusterOperationStateResponse) Reset 

func (x *GetClusterOperationStateResponse) Reset()

func (*GetClusterOperationStateResponse) SizeVT added in v0.11.0 

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

func (*GetClusterOperationStateResponse) String 

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

func (TaskState) Type() protoreflect.EnumType

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.