go-vitess.v1: gopkg.in/src-d/go-vitess.v1/vt/proto/automation Index | Files

package automation

import "gopkg.in/src-d/go-vitess.v1/vt/proto/automation"

Index

Package Files

automation.pb.go

Variables

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

type ClusterOperation Uses

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 Uses

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

func (*ClusterOperation) GetError Uses

func (m *ClusterOperation) GetError() string

func (*ClusterOperation) GetId Uses

func (m *ClusterOperation) GetId() string

func (*ClusterOperation) GetSerialTasks Uses

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

func (*ClusterOperation) GetState Uses

func (m *ClusterOperation) GetState() ClusterOperationState

func (*ClusterOperation) ProtoMessage Uses

func (*ClusterOperation) ProtoMessage()

func (*ClusterOperation) Reset Uses

func (m *ClusterOperation) Reset()

func (*ClusterOperation) String Uses

func (m *ClusterOperation) String() string

func (*ClusterOperation) XXX_DiscardUnknown Uses

func (m *ClusterOperation) XXX_DiscardUnknown()

func (*ClusterOperation) XXX_Marshal Uses

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

func (*ClusterOperation) XXX_Merge Uses

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

func (*ClusterOperation) XXX_Size Uses

func (m *ClusterOperation) XXX_Size() int

func (*ClusterOperation) XXX_Unmarshal Uses

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

type ClusterOperationState Uses

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 Uses

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

func (ClusterOperationState) String Uses

func (x ClusterOperationState) String() string

type EnqueueClusterOperationRequest Uses

type EnqueueClusterOperationRequest struct {
    Name                 string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
    Parameters           map[string]string `protobuf:"bytes,2,rep,name=parameters,proto3" json:"parameters,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
    XXX_NoUnkeyedLiteral struct{}          `json:"-"`
    XXX_unrecognized     []byte            `json:"-"`
    XXX_sizecache        int32             `json:"-"`
}

func (*EnqueueClusterOperationRequest) Descriptor Uses

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

func (*EnqueueClusterOperationRequest) GetName Uses

func (m *EnqueueClusterOperationRequest) GetName() string

func (*EnqueueClusterOperationRequest) GetParameters Uses

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

func (*EnqueueClusterOperationRequest) ProtoMessage Uses

func (*EnqueueClusterOperationRequest) ProtoMessage()

func (*EnqueueClusterOperationRequest) Reset Uses

func (m *EnqueueClusterOperationRequest) Reset()

func (*EnqueueClusterOperationRequest) String Uses

func (m *EnqueueClusterOperationRequest) String() string

func (*EnqueueClusterOperationRequest) XXX_DiscardUnknown Uses

func (m *EnqueueClusterOperationRequest) XXX_DiscardUnknown()

func (*EnqueueClusterOperationRequest) XXX_Marshal Uses

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

func (*EnqueueClusterOperationRequest) XXX_Merge Uses

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

func (*EnqueueClusterOperationRequest) XXX_Size Uses

func (m *EnqueueClusterOperationRequest) XXX_Size() int

func (*EnqueueClusterOperationRequest) XXX_Unmarshal Uses

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

type EnqueueClusterOperationResponse Uses

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 Uses

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

func (*EnqueueClusterOperationResponse) GetId Uses

func (m *EnqueueClusterOperationResponse) GetId() string

func (*EnqueueClusterOperationResponse) ProtoMessage Uses

func (*EnqueueClusterOperationResponse) ProtoMessage()

func (*EnqueueClusterOperationResponse) Reset Uses

func (m *EnqueueClusterOperationResponse) Reset()

func (*EnqueueClusterOperationResponse) String Uses

func (m *EnqueueClusterOperationResponse) String() string

func (*EnqueueClusterOperationResponse) XXX_DiscardUnknown Uses

func (m *EnqueueClusterOperationResponse) XXX_DiscardUnknown()

func (*EnqueueClusterOperationResponse) XXX_Marshal Uses

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

func (*EnqueueClusterOperationResponse) XXX_Merge Uses

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

func (*EnqueueClusterOperationResponse) XXX_Size Uses

func (m *EnqueueClusterOperationResponse) XXX_Size() int

func (*EnqueueClusterOperationResponse) XXX_Unmarshal Uses

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

type GetClusterOperationDetailsRequest Uses

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 Uses

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

func (*GetClusterOperationDetailsRequest) GetId Uses

func (m *GetClusterOperationDetailsRequest) GetId() string

func (*GetClusterOperationDetailsRequest) ProtoMessage Uses

func (*GetClusterOperationDetailsRequest) ProtoMessage()

func (*GetClusterOperationDetailsRequest) Reset Uses

func (m *GetClusterOperationDetailsRequest) Reset()

func (*GetClusterOperationDetailsRequest) String Uses

func (m *GetClusterOperationDetailsRequest) String() string

func (*GetClusterOperationDetailsRequest) XXX_DiscardUnknown Uses

func (m *GetClusterOperationDetailsRequest) XXX_DiscardUnknown()

func (*GetClusterOperationDetailsRequest) XXX_Marshal Uses

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

func (*GetClusterOperationDetailsRequest) XXX_Merge Uses

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

func (*GetClusterOperationDetailsRequest) XXX_Size Uses

func (m *GetClusterOperationDetailsRequest) XXX_Size() int

func (*GetClusterOperationDetailsRequest) XXX_Unmarshal Uses

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

type GetClusterOperationDetailsResponse Uses

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 Uses

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

func (*GetClusterOperationDetailsResponse) GetClusterOp Uses

func (m *GetClusterOperationDetailsResponse) GetClusterOp() *ClusterOperation

func (*GetClusterOperationDetailsResponse) ProtoMessage Uses

func (*GetClusterOperationDetailsResponse) ProtoMessage()

func (*GetClusterOperationDetailsResponse) Reset Uses

func (m *GetClusterOperationDetailsResponse) Reset()

func (*GetClusterOperationDetailsResponse) String Uses

func (m *GetClusterOperationDetailsResponse) String() string

func (*GetClusterOperationDetailsResponse) XXX_DiscardUnknown Uses

func (m *GetClusterOperationDetailsResponse) XXX_DiscardUnknown()

func (*GetClusterOperationDetailsResponse) XXX_Marshal Uses

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

func (*GetClusterOperationDetailsResponse) XXX_Merge Uses

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

func (*GetClusterOperationDetailsResponse) XXX_Size Uses

func (m *GetClusterOperationDetailsResponse) XXX_Size() int

func (*GetClusterOperationDetailsResponse) XXX_Unmarshal Uses

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

type GetClusterOperationStateRequest Uses

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 Uses

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

func (*GetClusterOperationStateRequest) GetId Uses

func (m *GetClusterOperationStateRequest) GetId() string

func (*GetClusterOperationStateRequest) ProtoMessage Uses

func (*GetClusterOperationStateRequest) ProtoMessage()

func (*GetClusterOperationStateRequest) Reset Uses

func (m *GetClusterOperationStateRequest) Reset()

func (*GetClusterOperationStateRequest) String Uses

func (m *GetClusterOperationStateRequest) String() string

func (*GetClusterOperationStateRequest) XXX_DiscardUnknown Uses

func (m *GetClusterOperationStateRequest) XXX_DiscardUnknown()

func (*GetClusterOperationStateRequest) XXX_Marshal Uses

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

func (*GetClusterOperationStateRequest) XXX_Merge Uses

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

func (*GetClusterOperationStateRequest) XXX_Size Uses

func (m *GetClusterOperationStateRequest) XXX_Size() int

func (*GetClusterOperationStateRequest) XXX_Unmarshal Uses

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

type GetClusterOperationStateResponse Uses

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 Uses

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

func (*GetClusterOperationStateResponse) GetState Uses

func (m *GetClusterOperationStateResponse) GetState() ClusterOperationState

func (*GetClusterOperationStateResponse) ProtoMessage Uses

func (*GetClusterOperationStateResponse) ProtoMessage()

func (*GetClusterOperationStateResponse) Reset Uses

func (m *GetClusterOperationStateResponse) Reset()

func (*GetClusterOperationStateResponse) String Uses

func (m *GetClusterOperationStateResponse) String() string

func (*GetClusterOperationStateResponse) XXX_DiscardUnknown Uses

func (m *GetClusterOperationStateResponse) XXX_DiscardUnknown()

func (*GetClusterOperationStateResponse) XXX_Marshal Uses

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

func (*GetClusterOperationStateResponse) XXX_Merge Uses

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

func (*GetClusterOperationStateResponse) XXX_Size Uses

func (m *GetClusterOperationStateResponse) XXX_Size() int

func (*GetClusterOperationStateResponse) XXX_Unmarshal Uses

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

type Task Uses

type Task struct {
    // Task specification.
    Name       string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
    Parameters map[string]string `protobuf:"bytes,2,rep,name=parameters,proto3" json:"parameters,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
    // 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 Uses

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

func (*Task) GetError Uses

func (m *Task) GetError() string

func (*Task) GetId Uses

func (m *Task) GetId() string

func (*Task) GetName Uses

func (m *Task) GetName() string

func (*Task) GetOutput Uses

func (m *Task) GetOutput() string

func (*Task) GetParameters Uses

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

func (*Task) GetState Uses

func (m *Task) GetState() TaskState

func (*Task) ProtoMessage Uses

func (*Task) ProtoMessage()

func (*Task) Reset Uses

func (m *Task) Reset()

func (*Task) String Uses

func (m *Task) String() string

func (*Task) XXX_DiscardUnknown Uses

func (m *Task) XXX_DiscardUnknown()

func (*Task) XXX_Marshal Uses

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

func (*Task) XXX_Merge Uses

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

func (*Task) XXX_Size Uses

func (m *Task) XXX_Size() int

func (*Task) XXX_Unmarshal Uses

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

type TaskContainer Uses

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 Uses

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

func (*TaskContainer) GetConcurrency Uses

func (m *TaskContainer) GetConcurrency() int32

func (*TaskContainer) GetParallelTasks Uses

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

func (*TaskContainer) ProtoMessage Uses

func (*TaskContainer) ProtoMessage()

func (*TaskContainer) Reset Uses

func (m *TaskContainer) Reset()

func (*TaskContainer) String Uses

func (m *TaskContainer) String() string

func (*TaskContainer) XXX_DiscardUnknown Uses

func (m *TaskContainer) XXX_DiscardUnknown()

func (*TaskContainer) XXX_Marshal Uses

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

func (*TaskContainer) XXX_Merge Uses

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

func (*TaskContainer) XXX_Size Uses

func (m *TaskContainer) XXX_Size() int

func (*TaskContainer) XXX_Unmarshal Uses

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

type TaskState Uses

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 Uses

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

func (TaskState) String Uses

func (x TaskState) String() string

Package automation imports 3 packages (graph) and is imported by 3 packages. Updated 2019-06-13. Refresh now. Tools for package owners.