bhpb

package
v0.0.3 Latest Latest
Warning

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

 Go to latest Published: Jan 7, 2020 License: MIT Imports: 7 Imported by: 0

Documentation

Overview

Package bhpb is a generated protocol buffer package.

It is generated from these files: 

types.proto

It has these top-level messages: 

Error
Label
Env
Node
NodeConfig
NodeProvider
NodeInfo
Addr
NodeCapacity
NodeProperty
NodeStatus
NodeAssignedProperties
NodeJobStatus
Owner
JobSpec
WorkloadSpec
NodeAssignmentSpec
NodeSelectorSpec
StagePipelineSpec
StageSpec
TaskPipelineSpec
TaskSpec
StopperSpec
ShellSpec
ExecSpec
Port
DockerSpec
ReadySpec
Job
StagePipeline
Stage
NodeStage
TaskPipeline
Task
AssignedNode
JobPlan
StagePipelinePlan
StagePlan
TaskPipelinePlan
TaskPlan
Ping
Pong
EmptyReq
NodeInfoReq
NodeInfoRes
RegisterAgentReq
RegisterAgentRes
ListAgentReq
ListAgentRes
AgentHeartbeatReq
AgentHeartbeatRes
SubmitJobReq
SubmitJobRes
JobStatusReq
JobStatusRes

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthTypes = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTypes   = fmt.Errorf("proto: integer overflow")
)
View Source 
var DockerAction_name = map[int32]string{
	0: "UNKNOWN",
	1: "PULL",
	2: "RUN",
}
View Source 
var DockerAction_value = map[string]int32{
	"UNKNOWN": 0,
	"PULL":    1,
	"RUN":     2,
}
View Source 
var ErrorCode_name = map[int32]string{
	0: "UNKNOWN_ERROR",
	1: "ALREADY_EXISTS",
	2: "NOT_FOUND",
	3: "INVALID_CONFIG",
	4: "PERMISSION_DENIED",
	5: "STORE_ERROR",
}
View Source 
var ErrorCode_value = map[string]int32{
	"UNKNOWN_ERROR":     0,
	"ALREADY_EXISTS":    1,
	"NOT_FOUND":         2,
	"INVALID_CONFIG":    3,
	"PERMISSION_DENIED": 4,
	"STORE_ERROR":       5,
}
View Source 
var ErrorSource_name = map[int32]string{
	0: "UNKNOWN_SOURCE",
	1: "SOURCE_CENTRAL",
	2: "SOURCE_AGENT",
	3: "SOURCE_META_STORE",
	4: "SOURCE_TS_STORE",
}
View Source 
var ErrorSource_value = map[string]int32{
	"UNKNOWN_SOURCE":    0,
	"SOURCE_CENTRAL":    1,
	"SOURCE_AGENT":      2,
	"SOURCE_META_STORE": 3,
	"SOURCE_TS_STORE":   4,
}
View Source 
var JobStatus_name = map[int32]string{
	0: "UNKNOWN_JOB_STATUS",
	1: "JOB_QUEUED",
	2: "JOB_RUNNING",
	3: "JOB_FINISHED",
	4: "JOB_ABORTED",
}
View Source 
var JobStatus_value = map[string]int32{
	"UNKNOWN_JOB_STATUS": 0,
	"JOB_QUEUED":         1,
	"JOB_RUNNING":        2,
	"JOB_FINISHED":       3,
	"JOB_ABORTED":        4,
}
View Source 
var NodeJobState_name = map[int32]string{
	0: "UNKNOWN_NODE_JOB_STATE",
	1: "NODE_JOB_RUNNING",
	2: "NODE_JOB_FINISHED",
	3: "NODE_JOB_ERROR",
	4: "NODE_JOB_WAITING_INSTRUCTION",
	5: "NODE_JOB_REPORTING",
	6: "NODE_JOB_CLEANUP",
}
View Source 
var NodeJobState_value = map[string]int32{
	"UNKNOWN_NODE_JOB_STATE":       0,
	"NODE_JOB_RUNNING":             1,
	"NODE_JOB_FINISHED":            2,
	"NODE_JOB_ERROR":               3,
	"NODE_JOB_WAITING_INSTRUCTION": 4,
	"NODE_JOB_REPORTING":           5,
	"NODE_JOB_CLEANUP":             6,
}
View Source 
var NodeState_name = map[int32]string{
	0: "UNKNOWN_NODE_STATE",
	1: "NODE_FINDING_CENTRAL",
	2: "NODE_IDLE",
	3: "NODE_RUNNING_JOB",
}
View Source 
var NodeState_value = map[string]int32{
	"UNKNOWN_NODE_STATE":   0,
	"NODE_FINDING_CENTRAL": 1,
	"NODE_IDLE":            2,
	"NODE_RUNNING_JOB":     3,
}
View Source 
var OwnerType_name = map[int32]string{
	0: "UNKNOWN_OWNER",
	1: "USER",
	2: "ORG",
}
View Source 
var OwnerType_value = map[string]int32{
	"UNKNOWN_OWNER": 0,
	"USER":          1,
	"ORG":           2,
}
View Source 
var Provider_name = map[int32]string{
	0: "UNKNOWN_PROVIDER",
	1: "LOCAL_PROVIDER",
	2: "VAGRANT_PROVIDER",
	3: "ALI_PROVIDER",
	4: "AWS_PROVIDER",
	5: "AZURE_PROVIDER",
	6: "GCP_PROVIDER",
	7: "PACKET_PROVIDER",
}
View Source 
var Provider_value = map[string]int32{
	"UNKNOWN_PROVIDER": 0,
	"LOCAL_PROVIDER":   1,
	"VAGRANT_PROVIDER": 2,
	"ALI_PROVIDER":     3,
	"AWS_PROVIDER":     4,
	"AZURE_PROVIDER":   5,
	"GCP_PROVIDER":     6,
	"PACKET_PROVIDER":  7,
}
View Source 
var Role_name = map[int32]string{
	0: "UNKNOWN_ROLE",
	1: "ANY",
	2: "CENTRAL",
	3: "LOADER",
	4: "DATABASE",
}
View Source 
var Role_value = map[string]int32{
	"UNKNOWN_ROLE": 0,
	"ANY":          1,
	"CENTRAL":      2,
	"LOADER":       3,
	"DATABASE":     4,
}
View Source 
var ScheduleFail_name = map[int32]string{
	0: "UNKNOWN_SCHEDULE_FAIL",
	1: "IDLE_ROLE_NO_MATCH",
	2: "BUSY_DATABASE",
}
View Source 
var ScheduleFail_value = map[string]int32{
	"UNKNOWN_SCHEDULE_FAIL": 0,
	"IDLE_ROLE_NO_MATCH":    1,
	"BUSY_DATABASE":         2,
}
View Source 
var ScheduleSuccess_name = map[int32]string{
	0: "UNKNOWN_SCHEDULE_SUCCESS",
	1: "IDLE_EXACT_ROLE_MATCH",
	2: "IDLE_ANY_ROLE_MATCH",
}
View Source 
var ScheduleSuccess_value = map[string]int32{
	"UNKNOWN_SCHEDULE_SUCCESS": 0,
	"IDLE_EXACT_ROLE_MATCH":    1,
	"IDLE_ANY_ROLE_MATCH":      2,
}
View Source 
var StagePipelineStatus_name = map[int32]string{
	0: "UNKNOWN_STAGE_PIPELINE_STATUS",
	1: "STAGE_PIPELINE_QUEUED",
	2: "STAGE_PIPELINE_RUNNING",
	3: "STAGE_PIPELINE_FINISHED",
	4: "STAGE_PIPELINE_BACKGROUND",
}
View Source 
var StagePipelineStatus_value = map[string]int32{
	"UNKNOWN_STAGE_PIPELINE_STATUS": 0,
	"STAGE_PIPELINE_QUEUED":         1,
	"STAGE_PIPELINE_RUNNING":        2,
	"STAGE_PIPELINE_FINISHED":       3,
	"STAGE_PIPELINE_BACKGROUND":     4,
}
View Source 
var TaskDriver_name = map[int32]string{
	0: "UNKNOWN_TASKDRIVER",
	1: "STOPPER",
	2: "SHELL",
	3: "EXEC",
	4: "DOCKER",
}
View Source 
var TaskDriver_value = map[string]int32{
	"UNKNOWN_TASKDRIVER": 0,
	"STOPPER":            1,
	"SHELL":              2,
	"EXEC":               3,
	"DOCKER":             4,
}
View Source 
var TaskPipelineStatus_name = map[int32]string{
	0: "UNKNOWN_TASK_PIPELINE_STATUS",
	1: "TASK_PIPELINE_QUEUED",
	2: "TASK_PIPELINE_RUNNING",
	3: "TASK_PIPELINE_FINISHED",
	4: "TASK_PIPELINE_BACKGROUND",
}
View Source 
var TaskPipelineStatus_value = map[string]int32{
	"UNKNOWN_TASK_PIPELINE_STATUS": 0,
	"TASK_PIPELINE_QUEUED":         1,
	"TASK_PIPELINE_RUNNING":        2,
	"TASK_PIPELINE_FINISHED":       3,
	"TASK_PIPELINE_BACKGROUND":     4,
}
View Source 
var TaskStatus_name = map[int32]string{
	0: "UNKNOWN_TASK_STATUS",
	1: "TASK_QUEUED",
	2: "TASK_RUNNING",
	3: "TASK_BACKGROUND",
	4: "TASK_FINISHED",
	5: "TASK_ABORTED",
}
View Source 
var TaskStatus_value = map[string]int32{
	"UNKNOWN_TASK_STATUS": 0,
	"TASK_QUEUED":         1,
	"TASK_RUNNING":        2,
	"TASK_BACKGROUND":     3,
	"TASK_FINISHED":       4,
	"TASK_ABORTED":        5,
}

Functions

func IsAlreadyExist 

func IsAlreadyExist(err error) bool

func IsInvalidConfig 

func IsInvalidConfig(err error) bool

func IsNotFound 

func IsNotFound(err error) bool

func IsStoreError 

func IsStoreError(err error) bool

Types

type Addr 

type Addr struct {
	// set when node start or obtain from remoteAddr
	// TODO: this is a workaround because I don't know how a client can know its ip without calling external service
	// TODO: https://github.com/benchhub/benchhub/issues/18 track this
	// hashicorp has https://github.com/hashicorp/go-sockaddr for consul
	Ip string `protobuf:"bytes,1,opt,name=ip,proto3" json:"ip,omitempty"`
	// addr grpc server listens on i.e. :6081, from node config file
	BindAddr string `protobuf:"bytes,2,opt,name=bindAddr,proto3" json:"bindAddr,omitempty"`
	// remoteAddr that other node sees when this node communicate, the ip is accurate, but the port is random, not the listen port
	RemoteAddr string `protobuf:"bytes,3,opt,name=remoteAddr,proto3" json:"remoteAddr,omitempty"`
}

func (*Addr) Descriptor 

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

func (*Addr) Marshal 

func (m *Addr) Marshal() (dAtA []byte, err error)

func (*Addr) MarshalTo 

func (m *Addr) MarshalTo(dAtA []byte) (int, error)

func (*Addr) ProtoMessage 

func (*Addr) ProtoMessage()

func (*Addr) Reset 

func (m *Addr) Reset()

func (*Addr) Size 

func (m *Addr) Size() (n int)

func (*Addr) String 

func (m *Addr) String() string

func (*Addr) Unmarshal 

func (m *Addr) Unmarshal(dAtA []byte) error

type AgentHeartbeatReq 

type AgentHeartbeatReq struct {
	Id     string     `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Status NodeStatus `protobuf:"bytes,2,opt,name=status" json:"status"`
}

func (*AgentHeartbeatReq) Descriptor 

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

func (*AgentHeartbeatReq) Marshal 

func (m *AgentHeartbeatReq) Marshal() (dAtA []byte, err error)

func (*AgentHeartbeatReq) MarshalTo 

func (m *AgentHeartbeatReq) MarshalTo(dAtA []byte) (int, error)

func (*AgentHeartbeatReq) ProtoMessage 

func (*AgentHeartbeatReq) ProtoMessage()

func (*AgentHeartbeatReq) Reset 

func (m *AgentHeartbeatReq) Reset()

func (*AgentHeartbeatReq) Size 

func (m *AgentHeartbeatReq) Size() (n int)

func (*AgentHeartbeatReq) String 

func (m *AgentHeartbeatReq) String() string

func (*AgentHeartbeatReq) Unmarshal 

func (m *AgentHeartbeatReq) Unmarshal(dAtA []byte) error

type AgentHeartbeatRes 

type AgentHeartbeatRes struct {
	//    Job job = 1 [(gogoproto.nullable) = false];
	Error *Error `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
}

func (*AgentHeartbeatRes) Descriptor 

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

func (*AgentHeartbeatRes) Marshal 

func (m *AgentHeartbeatRes) Marshal() (dAtA []byte, err error)

func (*AgentHeartbeatRes) MarshalTo 

func (m *AgentHeartbeatRes) MarshalTo(dAtA []byte) (int, error)

func (*AgentHeartbeatRes) ProtoMessage 

func (*AgentHeartbeatRes) ProtoMessage()

func (*AgentHeartbeatRes) Reset 

func (m *AgentHeartbeatRes) Reset()

func (*AgentHeartbeatRes) Size 

func (m *AgentHeartbeatRes) Size() (n int)

func (*AgentHeartbeatRes) String 

func (m *AgentHeartbeatRes) String() string

func (*AgentHeartbeatRes) Unmarshal 

func (m *AgentHeartbeatRes) Unmarshal(dAtA []byte) error

type AssignedNode 

type AssignedNode struct {
	Node NodeInfo           `protobuf:"bytes,1,opt,name=node" json:"node"`
	Spec NodeAssignmentSpec `protobuf:"bytes,2,opt,name=spec" json:"spec"`
}

--------------------------- 

<job scheduler>

---------------------------

func (*AssignedNode) Descriptor 

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

func (*AssignedNode) Marshal 

func (m *AssignedNode) Marshal() (dAtA []byte, err error)

func (*AssignedNode) MarshalTo 

func (m *AssignedNode) MarshalTo(dAtA []byte) (int, error)

func (*AssignedNode) ProtoMessage 

func (*AssignedNode) ProtoMessage()

func (*AssignedNode) Reset 

func (m *AssignedNode) Reset()

func (*AssignedNode) Size 

func (m *AssignedNode) Size() (n int)

func (*AssignedNode) String 

func (m *AssignedNode) String() string

func (*AssignedNode) Unmarshal 

func (m *AssignedNode) Unmarshal(dAtA []byte) error

type DockerAction 

type DockerAction int32
const (
	DockerAction_UNKNOWN DockerAction = 0
	DockerAction_PULL    DockerAction = 1
	DockerAction_RUN     DockerAction = 2
)

func (DockerAction) EnumDescriptor 

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

func (DockerAction) String 

func (x DockerAction) String() string

type DockerSpec 

type DockerSpec struct {
	Image  string       `protobuf:"bytes,1,opt,name=image,proto3" json:"image,omitempty"`
	Action DockerAction `protobuf:"varint,2,opt,name=action,proto3,enum=bh.DockerAction" json:"action,omitempty"`
	Ports  []Port       `protobuf:"bytes,3,rep,name=ports" json:"ports"`
}

func (*DockerSpec) Descriptor 

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

func (*DockerSpec) Marshal 

func (m *DockerSpec) Marshal() (dAtA []byte, err error)

func (*DockerSpec) MarshalTo 

func (m *DockerSpec) MarshalTo(dAtA []byte) (int, error)

func (*DockerSpec) ProtoMessage 

func (*DockerSpec) ProtoMessage()

func (*DockerSpec) Reset 

func (m *DockerSpec) Reset()

func (*DockerSpec) Size 

func (m *DockerSpec) Size() (n int)

func (*DockerSpec) String 

func (m *DockerSpec) String() string

func (*DockerSpec) Unmarshal 

func (m *DockerSpec) Unmarshal(dAtA []byte) error

type EmptyReq 

type EmptyReq struct {
}

func (*EmptyReq) Descriptor 

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

func (*EmptyReq) Marshal 

func (m *EmptyReq) Marshal() (dAtA []byte, err error)

func (*EmptyReq) MarshalTo 

func (m *EmptyReq) MarshalTo(dAtA []byte) (int, error)

func (*EmptyReq) ProtoMessage 

func (*EmptyReq) ProtoMessage()

func (*EmptyReq) Reset 

func (m *EmptyReq) Reset()

func (*EmptyReq) Size 

func (m *EmptyReq) Size() (n int)

func (*EmptyReq) String 

func (m *EmptyReq) String() string

func (*EmptyReq) Unmarshal 

func (m *EmptyReq) Unmarshal(dAtA []byte) error

type Env 

type Env struct {
	K string `protobuf:"bytes,1,opt,name=k,proto3" json:"k,omitempty"`
	V string `protobuf:"bytes,2,opt,name=v,proto3" json:"v,omitempty"`
}

func (*Env) Descriptor 

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

func (*Env) Marshal 

func (m *Env) Marshal() (dAtA []byte, err error)

func (*Env) MarshalTo 

func (m *Env) MarshalTo(dAtA []byte) (int, error)

func (*Env) ProtoMessage 

func (*Env) ProtoMessage()

func (*Env) Reset 

func (m *Env) Reset()

func (*Env) Size 

func (m *Env) Size() (n int)

func (*Env) String 

func (m *Env) String() string

func (*Env) Unmarshal 

func (m *Env) Unmarshal(dAtA []byte) error

type Error 

type Error struct {
	Code    ErrorCode   `protobuf:"varint,1,opt,name=code,proto3,enum=bh.ErrorCode" json:"code,omitempty"`
	Source  ErrorSource `protobuf:"varint,2,opt,name=source,proto3,enum=bh.ErrorSource" json:"source,omitempty"`
	Message string      `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	NodeId  string      `protobuf:"bytes,4,opt,name=nodeId,proto3" json:"nodeId,omitempty"`
}

func ToError 

func ToError(err error) *Error

func (*Error) Descriptor 

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

func (*Error) Error 

func (m *Error) Error() string

func (*Error) Marshal 

func (m *Error) Marshal() (dAtA []byte, err error)

func (*Error) MarshalTo 

func (m *Error) MarshalTo(dAtA []byte) (int, error)

func (*Error) ProtoMessage 

func (*Error) ProtoMessage()

func (*Error) Reset 

func (m *Error) Reset()

func (*Error) Size 

func (m *Error) Size() (n int)

func (*Error) String 

func (m *Error) String() string

func (*Error) Unmarshal 

func (m *Error) Unmarshal(dAtA []byte) error

type ErrorCode 

type ErrorCode int32
const (
	ErrorCode_UNKNOWN_ERROR     ErrorCode = 0
	ErrorCode_ALREADY_EXISTS    ErrorCode = 1
	ErrorCode_NOT_FOUND         ErrorCode = 2
	ErrorCode_INVALID_CONFIG    ErrorCode = 3
	ErrorCode_PERMISSION_DENIED ErrorCode = 4
	ErrorCode_STORE_ERROR       ErrorCode = 5
)

func GetErrorCode 

func GetErrorCode(err error) ErrorCode

func (ErrorCode) EnumDescriptor 

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

func (ErrorCode) String 

func (x ErrorCode) String() string

type ErrorSource 

type ErrorSource int32
const (
	ErrorSource_UNKNOWN_SOURCE    ErrorSource = 0
	ErrorSource_SOURCE_CENTRAL    ErrorSource = 1
	ErrorSource_SOURCE_AGENT      ErrorSource = 2
	ErrorSource_SOURCE_META_STORE ErrorSource = 3
	ErrorSource_SOURCE_TS_STORE   ErrorSource = 4
)

func (ErrorSource) EnumDescriptor 

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

func (ErrorSource) String 

func (x ErrorSource) String() string

type ExecSpec 

type ExecSpec struct {
	Command string   `protobuf:"bytes,1,opt,name=command,proto3" json:"command,omitempty"`
	Args    []string `protobuf:"bytes,2,rep,name=args" json:"args,omitempty"`
}

func (*ExecSpec) Descriptor 

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

func (*ExecSpec) Marshal 

func (m *ExecSpec) Marshal() (dAtA []byte, err error)

func (*ExecSpec) MarshalTo 

func (m *ExecSpec) MarshalTo(dAtA []byte) (int, error)

func (*ExecSpec) ProtoMessage 

func (*ExecSpec) ProtoMessage()

func (*ExecSpec) Reset 

func (m *ExecSpec) Reset()

func (*ExecSpec) Size 

func (m *ExecSpec) Size() (n int)

func (*ExecSpec) String 

func (m *ExecSpec) String() string

func (*ExecSpec) Unmarshal 

func (m *ExecSpec) Unmarshal(dAtA []byte) error

type Job 

type Job struct {
	Id               string          `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	RawSpec          string          `protobuf:"bytes,2,opt,name=rawSpec,proto3" json:"rawSpec,omitempty"`
	Spec             *JobSpec        `protobuf:"bytes,3,opt,name=spec" json:"spec,omitempty"`
	CreateTime       int64           `protobuf:"varint,4,opt,name=createTime,proto3" json:"createTime,omitempty"`
	StartTime        int64           `protobuf:"varint,5,opt,name=startTime,proto3" json:"startTime,omitempty"`
	StopTime         int64           `protobuf:"varint,6,opt,name=stopTime,proto3" json:"stopTime,omitempty"`
	Status           JobStatus       `protobuf:"varint,7,opt,name=status,proto3,enum=bh.JobStatus" json:"status,omitempty"`
	CurrentPipeline  int64           `protobuf:"varint,8,opt,name=currentPipeline,proto3" json:"currentPipeline,omitempty"`
	ForegroundStages []int64         `protobuf:"varint,9,rep,packed,name=foregroundStages" json:"foregroundStages,omitempty"`
	BackgroundStages []int64         `protobuf:"varint,10,rep,packed,name=backgroundStages" json:"backgroundStages,omitempty"`
	FinishedStages   []int64         `protobuf:"varint,11,rep,packed,name=finishedStages" json:"finishedStages,omitempty"`
	Pipelines        []StagePipeline `protobuf:"bytes,12,rep,name=pipelines" json:"pipelines"`
	Stages           []Stage         `protobuf:"bytes,13,rep,name=stages" json:"stages"`
}

TODO: the whole job store part will be changed ...

func (*Job) Descriptor 

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

func (*Job) Marshal 

func (m *Job) Marshal() (dAtA []byte, err error)

func (*Job) MarshalTo 

func (m *Job) MarshalTo(dAtA []byte) (int, error)

func (*Job) ProtoMessage 

func (*Job) ProtoMessage()

func (*Job) Reset 

func (m *Job) Reset()

func (*Job) Size 

func (m *Job) Size() (n int)

func (*Job) String 

func (m *Job) String() string

func (*Job) Unmarshal 

func (m *Job) Unmarshal(dAtA []byte) error

type JobPlan 

type JobPlan struct {
	Pipelines []StagePipelinePlan `protobuf:"bytes,1,rep,name=pipelines" json:"pipelines"`
}

--------------------------- 

<job plan>

---------------------------

func (*JobPlan) Descriptor 

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

func (*JobPlan) Marshal 

func (m *JobPlan) Marshal() (dAtA []byte, err error)

func (*JobPlan) MarshalTo 

func (m *JobPlan) MarshalTo(dAtA []byte) (int, error)

func (*JobPlan) ProtoMessage 

func (*JobPlan) ProtoMessage()

func (*JobPlan) Reset 

func (m *JobPlan) Reset()

func (*JobPlan) Size 

func (m *JobPlan) Size() (n int)

func (*JobPlan) String 

func (m *JobPlan) String() string

func (*JobPlan) Unmarshal 

func (m *JobPlan) Unmarshal(dAtA []byte) error

type JobSpec 

type JobSpec struct {
	Id              string               `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name            string               `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Owner           Owner                `protobuf:"bytes,3,opt,name=owner" json:"owner"`
	Workload        WorkloadSpec         `protobuf:"bytes,4,opt,name=workload" json:"workload"`
	NodeAssignments []NodeAssignmentSpec `protobuf:"bytes,5,rep,name=nodeAssignments" json:"nodeAssignments" yaml:"nodeAssignments"`
	Pipelines       []StagePipelineSpec  `protobuf:"bytes,6,rep,name=pipelines" json:"pipelines"`
	Stages          []StageSpec          `protobuf:"bytes,7,rep,name=stages" json:"stages"`
}

func (*JobSpec) Descriptor 

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

func (*JobSpec) Marshal 

func (m *JobSpec) Marshal() (dAtA []byte, err error)

func (*JobSpec) MarshalTo 

func (m *JobSpec) MarshalTo(dAtA []byte) (int, error)

func (*JobSpec) ProtoMessage 

func (*JobSpec) ProtoMessage()

func (*JobSpec) Reset 

func (m *JobSpec) Reset()

func (*JobSpec) Size 

func (m *JobSpec) Size() (n int)

func (*JobSpec) String 

func (m *JobSpec) String() string

func (*JobSpec) Unmarshal 

func (m *JobSpec) Unmarshal(dAtA []byte) error

type JobStatus 

type JobStatus int32
const (
	JobStatus_UNKNOWN_JOB_STATUS JobStatus = 0
	JobStatus_JOB_QUEUED         JobStatus = 1
	JobStatus_JOB_RUNNING        JobStatus = 2
	JobStatus_JOB_FINISHED       JobStatus = 3
	JobStatus_JOB_ABORTED        JobStatus = 4
)

func (JobStatus) EnumDescriptor 

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

func (JobStatus) String 

func (x JobStatus) String() string

type JobStatusReq 

type JobStatusReq struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
}

func (*JobStatusReq) Descriptor 

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

func (*JobStatusReq) Marshal 

func (m *JobStatusReq) Marshal() (dAtA []byte, err error)

func (*JobStatusReq) MarshalTo 

func (m *JobStatusReq) MarshalTo(dAtA []byte) (int, error)

func (*JobStatusReq) ProtoMessage 

func (*JobStatusReq) ProtoMessage()

func (*JobStatusReq) Reset 

func (m *JobStatusReq) Reset()

func (*JobStatusReq) Size 

func (m *JobStatusReq) Size() (n int)

func (*JobStatusReq) String 

func (m *JobStatusReq) String() string

func (*JobStatusReq) Unmarshal 

func (m *JobStatusReq) Unmarshal(dAtA []byte) error

type JobStatusRes 

type JobStatusRes struct {
}

func (*JobStatusRes) Descriptor 

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

func (*JobStatusRes) Marshal 

func (m *JobStatusRes) Marshal() (dAtA []byte, err error)

func (*JobStatusRes) MarshalTo 

func (m *JobStatusRes) MarshalTo(dAtA []byte) (int, error)

func (*JobStatusRes) ProtoMessage 

func (*JobStatusRes) ProtoMessage()

func (*JobStatusRes) Reset 

func (m *JobStatusRes) Reset()

func (*JobStatusRes) Size 

func (m *JobStatusRes) Size() (n int)

func (*JobStatusRes) String 

func (m *JobStatusRes) String() string

func (*JobStatusRes) Unmarshal 

func (m *JobStatusRes) Unmarshal(dAtA []byte) error

type Label 

type Label struct {
	K string `protobuf:"bytes,1,opt,name=k,proto3" json:"k,omitempty"`
	V string `protobuf:"bytes,2,opt,name=v,proto3" json:"v,omitempty"`
}

func (*Label) Descriptor 

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

func (*Label) Marshal 

func (m *Label) Marshal() (dAtA []byte, err error)

func (*Label) MarshalTo 

func (m *Label) MarshalTo(dAtA []byte) (int, error)

func (*Label) ProtoMessage 

func (*Label) ProtoMessage()

func (*Label) Reset 

func (m *Label) Reset()

func (*Label) Size 

func (m *Label) Size() (n int)

func (*Label) String 

func (m *Label) String() string

func (*Label) Unmarshal 

func (m *Label) Unmarshal(dAtA []byte) error

type ListAgentReq 

type ListAgentReq struct {
}

func (*ListAgentReq) Descriptor 

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

func (*ListAgentReq) Marshal 

func (m *ListAgentReq) Marshal() (dAtA []byte, err error)

func (*ListAgentReq) MarshalTo 

func (m *ListAgentReq) MarshalTo(dAtA []byte) (int, error)

func (*ListAgentReq) ProtoMessage 

func (*ListAgentReq) ProtoMessage()

func (*ListAgentReq) Reset 

func (m *ListAgentReq) Reset()

func (*ListAgentReq) Size 

func (m *ListAgentReq) Size() (n int)

func (*ListAgentReq) String 

func (m *ListAgentReq) String() string

func (*ListAgentReq) Unmarshal 

func (m *ListAgentReq) Unmarshal(dAtA []byte) error

type ListAgentRes 

type ListAgentRes struct {
	Agents []Node `protobuf:"bytes,1,rep,name=agents" json:"agents"`
}

func (*ListAgentRes) Descriptor 

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

func (*ListAgentRes) Marshal 

func (m *ListAgentRes) Marshal() (dAtA []byte, err error)

func (*ListAgentRes) MarshalTo 

func (m *ListAgentRes) MarshalTo(dAtA []byte) (int, error)

func (*ListAgentRes) ProtoMessage 

func (*ListAgentRes) ProtoMessage()

func (*ListAgentRes) Reset 

func (m *ListAgentRes) Reset()

func (*ListAgentRes) Size 

func (m *ListAgentRes) Size() (n int)

func (*ListAgentRes) String 

func (m *ListAgentRes) String() string

func (*ListAgentRes) Unmarshal 

func (m *ListAgentRes) Unmarshal(dAtA []byte) error

type Node 

type Node struct {
	Info   NodeInfo   `protobuf:"bytes,1,opt,name=info" json:"info"`
	Status NodeStatus `protobuf:"bytes,2,opt,name=status" json:"status"`
}

func (*Node) Descriptor 

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

func (*Node) Marshal 

func (m *Node) Marshal() (dAtA []byte, err error)

func (*Node) MarshalTo 

func (m *Node) MarshalTo(dAtA []byte) (int, error)

func (*Node) ProtoMessage 

func (*Node) ProtoMessage()

func (*Node) Reset 

func (m *Node) Reset()

func (*Node) Size 

func (m *Node) Size() (n int)

func (*Node) String 

func (m *Node) String() string

func (*Node) Unmarshal 

func (m *Node) Unmarshal(dAtA []byte) error

type NodeAssignedProperties 

type NodeAssignedProperties struct {
	// uinque name in current job, used to refer assigned node in rest of the config
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// role in current job, could be different from role in configuration file
	// i.e. a Any node can become a Database or Loader node
	// values: database, loader
	Role Role `protobuf:"varint,2,opt,name=role,proto3,enum=bh.Role" json:"role,omitempty"`
}

func (*NodeAssignedProperties) Descriptor 

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

func (*NodeAssignedProperties) Marshal 

func (m *NodeAssignedProperties) Marshal() (dAtA []byte, err error)

func (*NodeAssignedProperties) MarshalTo 

func (m *NodeAssignedProperties) MarshalTo(dAtA []byte) (int, error)

func (*NodeAssignedProperties) ProtoMessage 

func (*NodeAssignedProperties) ProtoMessage()

func (*NodeAssignedProperties) Reset 

func (m *NodeAssignedProperties) Reset()

func (*NodeAssignedProperties) Size 

func (m *NodeAssignedProperties) Size() (n int)

func (*NodeAssignedProperties) String 

func (m *NodeAssignedProperties) String() string

func (*NodeAssignedProperties) Unmarshal 

func (m *NodeAssignedProperties) Unmarshal(dAtA []byte) error

type NodeAssignmentSpec 

type NodeAssignmentSpec struct {
	// select by name, role, label, resource
	// TODO: label and resource are not used in current implementation
	Selectors []NodeSelectorSpec `protobuf:"bytes,1,rep,name=selectors" json:"selectors"`
	// properties assigned to selected node, visiable to this job only
	Properties NodeAssignedProperties `protobuf:"bytes,2,opt,name=properties" json:"properties"`
}

func (*NodeAssignmentSpec) Descriptor 

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

func (*NodeAssignmentSpec) Marshal 

func (m *NodeAssignmentSpec) Marshal() (dAtA []byte, err error)

func (*NodeAssignmentSpec) MarshalTo 

func (m *NodeAssignmentSpec) MarshalTo(dAtA []byte) (int, error)

func (*NodeAssignmentSpec) ProtoMessage 

func (*NodeAssignmentSpec) ProtoMessage()

func (*NodeAssignmentSpec) Reset 

func (m *NodeAssignmentSpec) Reset()

func (*NodeAssignmentSpec) Size 

func (m *NodeAssignmentSpec) Size() (n int)

func (*NodeAssignmentSpec) String 

func (m *NodeAssignmentSpec) String() string

func (*NodeAssignmentSpec) Unmarshal 

func (m *NodeAssignmentSpec) Unmarshal(dAtA []byte) error

type NodeCapacity 

type NodeCapacity struct {
	// number of cpu cores
	Cores int32 `protobuf:"varint,1,opt,name=cores,proto3" json:"cores,omitempty"`
	// free memory in MB
	MemoryFree int32 `protobuf:"varint,2,opt,name=memoryFree,proto3" json:"memoryFree,omitempty"`
	// total memory in MB
	MemoryTotal int32 `protobuf:"varint,3,opt,name=memoryTotal,proto3" json:"memoryTotal,omitempty"`
	// free disk space in MB
	DiskFree int32 `protobuf:"varint,4,opt,name=diskFree,proto3" json:"diskFree,omitempty"`
	// total disk space in MB
	DiskTotal int32 `protobuf:"varint,5,opt,name=diskTotal,proto3" json:"diskTotal,omitempty"`
}

func (*NodeCapacity) Descriptor 

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

func (*NodeCapacity) Marshal 

func (m *NodeCapacity) Marshal() (dAtA []byte, err error)

func (*NodeCapacity) MarshalTo 

func (m *NodeCapacity) MarshalTo(dAtA []byte) (int, error)

func (*NodeCapacity) ProtoMessage 

func (*NodeCapacity) ProtoMessage()

func (*NodeCapacity) Reset 

func (m *NodeCapacity) Reset()

func (*NodeCapacity) Size 

func (m *NodeCapacity) Size() (n int)

func (*NodeCapacity) String 

func (m *NodeCapacity) String() string

func (*NodeCapacity) Unmarshal 

func (m *NodeCapacity) Unmarshal(dAtA []byte) error

type NodeConfig 

type NodeConfig struct {
	Role     Role         `protobuf:"varint,1,opt,name=role,proto3,enum=bh.Role" json:"role,omitempty"`
	Provider NodeProvider `protobuf:"bytes,2,opt,name=provider" json:"provider"`
	Labels   []Label      `protobuf:"bytes,3,rep,name=labels" json:"labels"`
}

--------------------------- 

<node config>

---------------------------

func (*NodeConfig) Descriptor 

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

func (*NodeConfig) Marshal 

func (m *NodeConfig) Marshal() (dAtA []byte, err error)

func (*NodeConfig) MarshalTo 

func (m *NodeConfig) MarshalTo(dAtA []byte) (int, error)

func (*NodeConfig) ProtoMessage 

func (*NodeConfig) ProtoMessage()

func (*NodeConfig) Reset 

func (m *NodeConfig) Reset()

func (*NodeConfig) Size 

func (m *NodeConfig) Size() (n int)

func (*NodeConfig) String 

func (m *NodeConfig) String() string

func (*NodeConfig) Unmarshal 

func (m *NodeConfig) Unmarshal(dAtA []byte) error

type NodeInfo 

type NodeInfo struct {
	// self generated uid, used through a node agent's lifetime, change after process restart
	// https://github.com/benchhub/benchhub/issues/17
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// node addr, bindAddr is from config, remoteAddr is from other nodes
	Addr Addr `protobuf:"bytes,2,opt,name=addr" json:"addr"`
	// config from configuration file, could be generated by provision tools
	Config NodeConfig `protobuf:"bytes,3,opt,name=config" json:"config"`
	// capacity snapshot taken when the node agent starts
	Capacity NodeCapacity `protobuf:"bytes,4,opt,name=capacity" json:"capacity"`
	// properties like host name, boot time
	Property NodeProperty `protobuf:"bytes,5,opt,name=property" json:"property"`
}

NodeInfo is provided to central when agent register

func (*NodeInfo) Descriptor 

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

func (*NodeInfo) Marshal 

func (m *NodeInfo) Marshal() (dAtA []byte, err error)

func (*NodeInfo) MarshalTo 

func (m *NodeInfo) MarshalTo(dAtA []byte) (int, error)

func (*NodeInfo) ProtoMessage 

func (*NodeInfo) ProtoMessage()

func (*NodeInfo) Reset 

func (m *NodeInfo) Reset()

func (*NodeInfo) Size 

func (m *NodeInfo) Size() (n int)

func (*NodeInfo) String 

func (m *NodeInfo) String() string

func (*NodeInfo) Unmarshal 

func (m *NodeInfo) Unmarshal(dAtA []byte) error

type NodeInfoReq 

type NodeInfoReq struct {
}

func (*NodeInfoReq) Descriptor 

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

func (*NodeInfoReq) Marshal 

func (m *NodeInfoReq) Marshal() (dAtA []byte, err error)

func (*NodeInfoReq) MarshalTo 

func (m *NodeInfoReq) MarshalTo(dAtA []byte) (int, error)

func (*NodeInfoReq) ProtoMessage 

func (*NodeInfoReq) ProtoMessage()

func (*NodeInfoReq) Reset 

func (m *NodeInfoReq) Reset()

func (*NodeInfoReq) Size 

func (m *NodeInfoReq) Size() (n int)

func (*NodeInfoReq) String 

func (m *NodeInfoReq) String() string

func (*NodeInfoReq) Unmarshal 

func (m *NodeInfoReq) Unmarshal(dAtA []byte) error

type NodeInfoRes 

type NodeInfoRes struct {
	Node NodeInfo `protobuf:"bytes,1,opt,name=node" json:"node"`
}

func (*NodeInfoRes) Descriptor 

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

func (*NodeInfoRes) Marshal 

func (m *NodeInfoRes) Marshal() (dAtA []byte, err error)

func (*NodeInfoRes) MarshalTo 

func (m *NodeInfoRes) MarshalTo(dAtA []byte) (int, error)

func (*NodeInfoRes) ProtoMessage 

func (*NodeInfoRes) ProtoMessage()

func (*NodeInfoRes) Reset 

func (m *NodeInfoRes) Reset()

func (*NodeInfoRes) Size 

func (m *NodeInfoRes) Size() (n int)

func (*NodeInfoRes) String 

func (m *NodeInfoRes) String() string

func (*NodeInfoRes) Unmarshal 

func (m *NodeInfoRes) Unmarshal(dAtA []byte) error

type NodeJobState 

type NodeJobState int32
const (
	NodeJobState_UNKNOWN_NODE_JOB_STATE       NodeJobState = 0
	NodeJobState_NODE_JOB_RUNNING             NodeJobState = 1
	NodeJobState_NODE_JOB_FINISHED            NodeJobState = 2
	NodeJobState_NODE_JOB_ERROR               NodeJobState = 3
	NodeJobState_NODE_JOB_WAITING_INSTRUCTION NodeJobState = 4
	NodeJobState_NODE_JOB_REPORTING           NodeJobState = 5
	NodeJobState_NODE_JOB_CLEANUP             NodeJobState = 6
)

func (NodeJobState) EnumDescriptor 

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

func (NodeJobState) String 

func (x NodeJobState) String() string

type NodeJobStatus 

type NodeJobStatus struct {
	// properties assigned to node in NodeAssignmentSpec
	Properties NodeAssignedProperties `protobuf:"bytes,1,opt,name=properties" json:"properties"`
	// TODO: status of one job on a single node, it is different from global job status because it does not contains node
	State NodeJobState `protobuf:"varint,3,opt,name=state,proto3,enum=bh.NodeJobState" json:"state,omitempty"`
}

func (*NodeJobStatus) Descriptor 

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

func (*NodeJobStatus) Marshal 

func (m *NodeJobStatus) Marshal() (dAtA []byte, err error)

func (*NodeJobStatus) MarshalTo 

func (m *NodeJobStatus) MarshalTo(dAtA []byte) (int, error)

func (*NodeJobStatus) ProtoMessage 

func (*NodeJobStatus) ProtoMessage()

func (*NodeJobStatus) Reset 

func (m *NodeJobStatus) Reset()

func (*NodeJobStatus) Size 

func (m *NodeJobStatus) Size() (n int)

func (*NodeJobStatus) String 

func (m *NodeJobStatus) String() string

func (*NodeJobStatus) Unmarshal 

func (m *NodeJobStatus) Unmarshal(dAtA []byte) error

type NodeProperty 

type NodeProperty struct {
	// agent process start, unix ts in second
	StartTime int64 `protobuf:"varint,1,opt,name=startTime,proto3" json:"startTime,omitempty"`
	// machine boot, unix ts in second
	BootTime int64 `protobuf:"varint,2,opt,name=bootTime,proto3" json:"bootTime,omitempty"`
	// hostname
	Host string `protobuf:"bytes,3,opt,name=host,proto3" json:"host,omitempty"`
}

func (*NodeProperty) Descriptor 

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

func (*NodeProperty) Marshal 

func (m *NodeProperty) Marshal() (dAtA []byte, err error)

func (*NodeProperty) MarshalTo 

func (m *NodeProperty) MarshalTo(dAtA []byte) (int, error)

func (*NodeProperty) ProtoMessage 

func (*NodeProperty) ProtoMessage()

func (*NodeProperty) Reset 

func (m *NodeProperty) Reset()

func (*NodeProperty) Size 

func (m *NodeProperty) Size() (n int)

func (*NodeProperty) String 

func (m *NodeProperty) String() string

func (*NodeProperty) Unmarshal 

func (m *NodeProperty) Unmarshal(dAtA []byte) error

type NodeProvider 

type NodeProvider struct {
	Name     string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Region   string `protobuf:"bytes,2,opt,name=region,proto3" json:"region,omitempty"`
	Instance string `protobuf:"bytes,3,opt,name=instance,proto3" json:"instance,omitempty"`
}

TODO: use provider enum

func (*NodeProvider) Descriptor 

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

func (*NodeProvider) Marshal 

func (m *NodeProvider) Marshal() (dAtA []byte, err error)

func (*NodeProvider) MarshalTo 

func (m *NodeProvider) MarshalTo(dAtA []byte) (int, error)

func (*NodeProvider) ProtoMessage 

func (*NodeProvider) ProtoMessage()

func (*NodeProvider) Reset 

func (m *NodeProvider) Reset()

func (*NodeProvider) Size 

func (m *NodeProvider) Size() (n int)

func (*NodeProvider) String 

func (m *NodeProvider) String() string

func (*NodeProvider) Unmarshal 

func (m *NodeProvider) Unmarshal(dAtA []byte) error

type NodeSelectorSpec 

type NodeSelectorSpec struct {
	// all is shortcut for select all nodes in order to install global packages, i.e. tldr
	All bool `protobuf:"varint,1,opt,name=all,proto3" json:"all,omitempty"`
	// none is shortcut for stages like stopper, where central tell all the nodes to stop long running tasks
	None   bool    `protobuf:"varint,2,opt,name=none,proto3" json:"none,omitempty"`
	Name   string  `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Role   Role    `protobuf:"varint,4,opt,name=role,proto3,enum=bh.Role" json:"role,omitempty"`
	Labels []Label `protobuf:"bytes,5,rep,name=labels" json:"labels"`
}

func (*NodeSelectorSpec) Descriptor 

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

func (*NodeSelectorSpec) Marshal 

func (m *NodeSelectorSpec) Marshal() (dAtA []byte, err error)

func (*NodeSelectorSpec) MarshalTo 

func (m *NodeSelectorSpec) MarshalTo(dAtA []byte) (int, error)

func (*NodeSelectorSpec) ProtoMessage 

func (*NodeSelectorSpec) ProtoMessage()

func (*NodeSelectorSpec) Reset 

func (m *NodeSelectorSpec) Reset()

func (*NodeSelectorSpec) Size 

func (m *NodeSelectorSpec) Size() (n int)

func (*NodeSelectorSpec) String 

func (m *NodeSelectorSpec) String() string

func (*NodeSelectorSpec) Unmarshal 

func (m *NodeSelectorSpec) Unmarshal(dAtA []byte) error

type NodeStage 

type NodeStage struct {
	Id        string         `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name      string         `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Role      Role           `protobuf:"varint,3,opt,name=role,proto3,enum=bh.Role" json:"role,omitempty"`
	Info      NodeInfo       `protobuf:"bytes,4,opt,name=info" json:"info"`
	Pipelines []TaskPipeline `protobuf:"bytes,5,rep,name=pipelines" json:"pipelines"`
	Tasks     []Task         `protobuf:"bytes,6,rep,name=tasks" json:"tasks"`
}

func (*NodeStage) Descriptor 

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

func (*NodeStage) Marshal 

func (m *NodeStage) Marshal() (dAtA []byte, err error)

func (*NodeStage) MarshalTo 

func (m *NodeStage) MarshalTo(dAtA []byte) (int, error)

func (*NodeStage) ProtoMessage 

func (*NodeStage) ProtoMessage()

func (*NodeStage) Reset 

func (m *NodeStage) Reset()

func (*NodeStage) Size 

func (m *NodeStage) Size() (n int)

func (*NodeStage) String 

func (m *NodeStage) String() string

func (*NodeStage) Unmarshal 

func (m *NodeStage) Unmarshal(dAtA []byte) error

type NodeState 

type NodeState int32
const (
	NodeState_UNKNOWN_NODE_STATE   NodeState = 0
	NodeState_NODE_FINDING_CENTRAL NodeState = 1
	NodeState_NODE_IDLE            NodeState = 2
	NodeState_NODE_RUNNING_JOB     NodeState = 3
)

func (NodeState) EnumDescriptor 

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

func (NodeState) String 

func (x NodeState) String() string

type NodeStatus 

type NodeStatus struct {
	State NodeState       `protobuf:"varint,1,opt,name=state,proto3,enum=bh.NodeState" json:"state,omitempty"`
	Jobs  []NodeJobStatus `protobuf:"bytes,2,rep,name=jobs" json:"jobs"`
}

func (*NodeStatus) Descriptor 

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

func (*NodeStatus) Marshal 

func (m *NodeStatus) Marshal() (dAtA []byte, err error)

func (*NodeStatus) MarshalTo 

func (m *NodeStatus) MarshalTo(dAtA []byte) (int, error)

func (*NodeStatus) ProtoMessage 

func (*NodeStatus) ProtoMessage()

func (*NodeStatus) Reset 

func (m *NodeStatus) Reset()

func (*NodeStatus) Size 

func (m *NodeStatus) Size() (n int)

func (*NodeStatus) String 

func (m *NodeStatus) String() string

func (*NodeStatus) Unmarshal 

func (m *NodeStatus) Unmarshal(dAtA []byte) error

type Owner 

type Owner struct {
	Id   string    `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name string    `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Type OwnerType `protobuf:"varint,3,opt,name=type,proto3,enum=bh.OwnerType" json:"type,omitempty"`
}

func (*Owner) Descriptor 

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

func (*Owner) Marshal 

func (m *Owner) Marshal() (dAtA []byte, err error)

func (*Owner) MarshalTo 

func (m *Owner) MarshalTo(dAtA []byte) (int, error)

func (*Owner) ProtoMessage 

func (*Owner) ProtoMessage()

func (*Owner) Reset 

func (m *Owner) Reset()

func (*Owner) Size 

func (m *Owner) Size() (n int)

func (*Owner) String 

func (m *Owner) String() string

func (*Owner) Unmarshal 

func (m *Owner) Unmarshal(dAtA []byte) error

type OwnerType 

type OwnerType int32
const (
	OwnerType_UNKNOWN_OWNER OwnerType = 0
	OwnerType_USER          OwnerType = 1
	OwnerType_ORG           OwnerType = 2
)

func (OwnerType) EnumDescriptor 

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

func (OwnerType) String 

func (x OwnerType) String() string

func (*OwnerType) UnmarshalJSON 

func (x *OwnerType) UnmarshalJSON(b []byte) error

Deprecated used by github.com/ghodss/yaml because it it convert yaml to json

func (*OwnerType) UnmarshalYAML 

func (x *OwnerType) UnmarshalYAML(unmarshal func(interface{}) error) error

type Ping 

type Ping struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
}

--------------------------- 

<common rpc>

---------------------------

func (*Ping) Descriptor 

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

func (*Ping) Marshal 

func (m *Ping) Marshal() (dAtA []byte, err error)

func (*Ping) MarshalTo 

func (m *Ping) MarshalTo(dAtA []byte) (int, error)

func (*Ping) ProtoMessage 

func (*Ping) ProtoMessage()

func (*Ping) Reset 

func (m *Ping) Reset()

func (*Ping) Size 

func (m *Ping) Size() (n int)

func (*Ping) String 

func (m *Ping) String() string

func (*Ping) Unmarshal 

func (m *Ping) Unmarshal(dAtA []byte) error

type Pong 

type Pong struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
}

func (*Pong) Descriptor 

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

func (*Pong) Marshal 

func (m *Pong) Marshal() (dAtA []byte, err error)

func (*Pong) MarshalTo 

func (m *Pong) MarshalTo(dAtA []byte) (int, error)

func (*Pong) ProtoMessage 

func (*Pong) ProtoMessage()

func (*Pong) Reset 

func (m *Pong) Reset()

func (*Pong) Size 

func (m *Pong) Size() (n int)

func (*Pong) String 

func (m *Pong) String() string

func (*Pong) Unmarshal 

func (m *Pong) Unmarshal(dAtA []byte) error

type Port 

type Port struct {
	Guest int32 `protobuf:"varint,1,opt,name=guest,proto3" json:"guest,omitempty"`
	Host  int32 `protobuf:"varint,2,opt,name=host,proto3" json:"host,omitempty"`
}

func (*Port) Descriptor 

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

func (*Port) Marshal 

func (m *Port) Marshal() (dAtA []byte, err error)

func (*Port) MarshalTo 

func (m *Port) MarshalTo(dAtA []byte) (int, error)

func (*Port) ProtoMessage 

func (*Port) ProtoMessage()

func (*Port) Reset 

func (m *Port) Reset()

func (*Port) Size 

func (m *Port) Size() (n int)

func (*Port) String 

func (m *Port) String() string

func (*Port) Unmarshal 

func (m *Port) Unmarshal(dAtA []byte) error

type Provider 

type Provider int32
const (
	Provider_UNKNOWN_PROVIDER Provider = 0
	Provider_LOCAL_PROVIDER   Provider = 1
	Provider_VAGRANT_PROVIDER Provider = 2
	Provider_ALI_PROVIDER     Provider = 3
	Provider_AWS_PROVIDER     Provider = 4
	Provider_AZURE_PROVIDER   Provider = 5
	Provider_GCP_PROVIDER     Provider = 6
	Provider_PACKET_PROVIDER  Provider = 7
)

func (Provider) EnumDescriptor 

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

func (Provider) String 

func (x Provider) String() string

type ReadySpec 

type ReadySpec struct {
	// at least one task, MUST NOT have long running task
	Tasks []TaskSpec `protobuf:"bytes,1,rep,name=tasks" json:"tasks"`
}

func (*ReadySpec) Descriptor 

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

func (*ReadySpec) Marshal 

func (m *ReadySpec) Marshal() (dAtA []byte, err error)

func (*ReadySpec) MarshalTo 

func (m *ReadySpec) MarshalTo(dAtA []byte) (int, error)

func (*ReadySpec) ProtoMessage 

func (*ReadySpec) ProtoMessage()

func (*ReadySpec) Reset 

func (m *ReadySpec) Reset()

func (*ReadySpec) Size 

func (m *ReadySpec) Size() (n int)

func (*ReadySpec) String 

func (m *ReadySpec) String() string

func (*ReadySpec) Unmarshal 

func (m *ReadySpec) Unmarshal(dAtA []byte) error

type RegisterAgentReq 

type RegisterAgentReq struct {
	Node NodeInfo `protobuf:"bytes,1,opt,name=node" json:"node"`
}

--------------------------- 

<node rpc>

---------------------------

func (*RegisterAgentReq) Descriptor 

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

func (*RegisterAgentReq) Marshal 

func (m *RegisterAgentReq) Marshal() (dAtA []byte, err error)

func (*RegisterAgentReq) MarshalTo 

func (m *RegisterAgentReq) MarshalTo(dAtA []byte) (int, error)

func (*RegisterAgentReq) ProtoMessage 

func (*RegisterAgentReq) ProtoMessage()

func (*RegisterAgentReq) Reset 

func (m *RegisterAgentReq) Reset()

func (*RegisterAgentReq) Size 

func (m *RegisterAgentReq) Size() (n int)

func (*RegisterAgentReq) String 

func (m *RegisterAgentReq) String() string

func (*RegisterAgentReq) Unmarshal 

func (m *RegisterAgentReq) Unmarshal(dAtA []byte) error

type RegisterAgentRes 

type RegisterAgentRes struct {
	Error   *Error   `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	Id      string   `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Node    NodeInfo `protobuf:"bytes,3,opt,name=node" json:"node"`
	Central NodeInfo `protobuf:"bytes,4,opt,name=central" json:"central"`
}

func (*RegisterAgentRes) Descriptor 

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

func (*RegisterAgentRes) Marshal 

func (m *RegisterAgentRes) Marshal() (dAtA []byte, err error)

func (*RegisterAgentRes) MarshalTo 

func (m *RegisterAgentRes) MarshalTo(dAtA []byte) (int, error)

func (*RegisterAgentRes) ProtoMessage 

func (*RegisterAgentRes) ProtoMessage()

func (*RegisterAgentRes) Reset 

func (m *RegisterAgentRes) Reset()

func (*RegisterAgentRes) Size 

func (m *RegisterAgentRes) Size() (n int)

func (*RegisterAgentRes) String 

func (m *RegisterAgentRes) String() string

func (*RegisterAgentRes) Unmarshal 

func (m *RegisterAgentRes) Unmarshal(dAtA []byte) error

type Role 

type Role int32
const (
	Role_UNKNOWN_ROLE Role = 0
	Role_ANY          Role = 1
	Role_CENTRAL      Role = 2
	Role_LOADER       Role = 3
	Role_DATABASE     Role = 4
)

func (Role) EnumDescriptor 

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

func (Role) String 

func (x Role) String() string

func (*Role) UnmarshalYAML 

func (x *Role) UnmarshalYAML(unmarshal func(interface{}) error) error

type ScheduleFail 

type ScheduleFail int32
const (
	ScheduleFail_UNKNOWN_SCHEDULE_FAIL ScheduleFail = 0
	ScheduleFail_IDLE_ROLE_NO_MATCH    ScheduleFail = 1
	ScheduleFail_BUSY_DATABASE         ScheduleFail = 2
)

func (ScheduleFail) EnumDescriptor 

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

func (ScheduleFail) String 

func (x ScheduleFail) String() string

type ScheduleSuccess 

type ScheduleSuccess int32
const (
	ScheduleSuccess_UNKNOWN_SCHEDULE_SUCCESS ScheduleSuccess = 0
	ScheduleSuccess_IDLE_EXACT_ROLE_MATCH    ScheduleSuccess = 1
	ScheduleSuccess_IDLE_ANY_ROLE_MATCH      ScheduleSuccess = 2
)

func (ScheduleSuccess) EnumDescriptor 

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

func (ScheduleSuccess) String 

func (x ScheduleSuccess) String() string

type ShellSpec 

type ShellSpec struct {
	Command string `protobuf:"bytes,1,opt,name=command,proto3" json:"command,omitempty"`
}

func (*ShellSpec) Descriptor 

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

func (*ShellSpec) Marshal 

func (m *ShellSpec) Marshal() (dAtA []byte, err error)

func (*ShellSpec) MarshalTo 

func (m *ShellSpec) MarshalTo(dAtA []byte) (int, error)

func (*ShellSpec) ProtoMessage 

func (*ShellSpec) ProtoMessage()

func (*ShellSpec) Reset 

func (m *ShellSpec) Reset()

func (*ShellSpec) Size 

func (m *ShellSpec) Size() (n int)

func (*ShellSpec) String 

func (m *ShellSpec) String() string

func (*ShellSpec) Unmarshal 

func (m *ShellSpec) Unmarshal(dAtA []byte) error

type Stage 

type Stage struct {
	Index    int64       `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
	Pipeline int64       `protobuf:"varint,2,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	Spec     StageSpec   `protobuf:"bytes,3,opt,name=spec" json:"spec"`
	Nodes    []NodeStage `protobuf:"bytes,4,rep,name=nodes" json:"nodes"`
}

func (*Stage) Descriptor 

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

func (*Stage) Marshal 

func (m *Stage) Marshal() (dAtA []byte, err error)

func (*Stage) MarshalTo 

func (m *Stage) MarshalTo(dAtA []byte) (int, error)

func (*Stage) ProtoMessage 

func (*Stage) ProtoMessage()

func (*Stage) Reset 

func (m *Stage) Reset()

func (*Stage) Size 

func (m *Stage) Size() (n int)

func (*Stage) String 

func (m *Stage) String() string

func (*Stage) Unmarshal 

func (m *Stage) Unmarshal(dAtA []byte) error

type StagePipeline 

type StagePipeline struct {
	Status StagePipelineStatus `protobuf:"varint,1,opt,name=status,proto3,enum=bh.StagePipelineStatus" json:"status,omitempty"`
	Stages []int64             `protobuf:"varint,2,rep,packed,name=stages" json:"stages,omitempty"`
}

func (*StagePipeline) Descriptor 

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

func (*StagePipeline) Marshal 

func (m *StagePipeline) Marshal() (dAtA []byte, err error)

func (*StagePipeline) MarshalTo 

func (m *StagePipeline) MarshalTo(dAtA []byte) (int, error)

func (*StagePipeline) ProtoMessage 

func (*StagePipeline) ProtoMessage()

func (*StagePipeline) Reset 

func (m *StagePipeline) Reset()

func (*StagePipeline) Size 

func (m *StagePipeline) Size() (n int)

func (*StagePipeline) String 

func (m *StagePipeline) String() string

func (*StagePipeline) Unmarshal 

func (m *StagePipeline) Unmarshal(dAtA []byte) error

type StagePipelinePlan 

type StagePipelinePlan struct {
	Name   string      `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Stages []StagePlan `protobuf:"bytes,2,rep,name=stages" json:"stages"`
}

func (*StagePipelinePlan) Descriptor 

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

func (*StagePipelinePlan) Marshal 

func (m *StagePipelinePlan) Marshal() (dAtA []byte, err error)

func (*StagePipelinePlan) MarshalTo 

func (m *StagePipelinePlan) MarshalTo(dAtA []byte) (int, error)

func (*StagePipelinePlan) ProtoMessage 

func (*StagePipelinePlan) ProtoMessage()

func (*StagePipelinePlan) Reset 

func (m *StagePipelinePlan) Reset()

func (*StagePipelinePlan) Size 

func (m *StagePipelinePlan) Size() (n int)

func (*StagePipelinePlan) String 

func (m *StagePipelinePlan) String() string

func (*StagePipelinePlan) Unmarshal 

func (m *StagePipelinePlan) Unmarshal(dAtA []byte) error

type StagePipelineSpec 

type StagePipelineSpec struct {
	Name   string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Stages []string `protobuf:"bytes,2,rep,name=stages" json:"stages,omitempty"`
}

func (*StagePipelineSpec) Descriptor 

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

func (*StagePipelineSpec) Marshal 

func (m *StagePipelineSpec) Marshal() (dAtA []byte, err error)

func (*StagePipelineSpec) MarshalTo 

func (m *StagePipelineSpec) MarshalTo(dAtA []byte) (int, error)

func (*StagePipelineSpec) ProtoMessage 

func (*StagePipelineSpec) ProtoMessage()

func (*StagePipelineSpec) Reset 

func (m *StagePipelineSpec) Reset()

func (*StagePipelineSpec) Size 

func (m *StagePipelineSpec) Size() (n int)

func (*StagePipelineSpec) String 

func (m *StagePipelineSpec) String() string

func (*StagePipelineSpec) Unmarshal 

func (m *StagePipelineSpec) Unmarshal(dAtA []byte) error

type StagePipelineStatus 

type StagePipelineStatus int32
const (
	StagePipelineStatus_UNKNOWN_STAGE_PIPELINE_STATUS StagePipelineStatus = 0
	StagePipelineStatus_STAGE_PIPELINE_QUEUED         StagePipelineStatus = 1
	StagePipelineStatus_STAGE_PIPELINE_RUNNING        StagePipelineStatus = 2
	StagePipelineStatus_STAGE_PIPELINE_FINISHED       StagePipelineStatus = 3
	StagePipelineStatus_STAGE_PIPELINE_BACKGROUND     StagePipelineStatus = 4
)

func (StagePipelineStatus) EnumDescriptor 

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

func (StagePipelineStatus) String 

func (x StagePipelineStatus) String() string

type StagePlan 

type StagePlan struct {
	Name      string             `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Nodes     []AssignedNode     `protobuf:"bytes,2,rep,name=nodes" json:"nodes"`
	Pipelines []TaskPipelinePlan `protobuf:"bytes,3,rep,name=pipelines" json:"pipelines"`
}

TODO: maybe stage plan should contains the original spec

func (*StagePlan) Descriptor 

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

func (*StagePlan) Marshal 

func (m *StagePlan) Marshal() (dAtA []byte, err error)

func (*StagePlan) MarshalTo 

func (m *StagePlan) MarshalTo(dAtA []byte) (int, error)

func (*StagePlan) ProtoMessage 

func (*StagePlan) ProtoMessage()

func (*StagePlan) Reset 

func (m *StagePlan) Reset()

func (*StagePlan) Size 

func (m *StagePlan) Size() (n int)

func (*StagePlan) String 

func (m *StagePlan) String() string

func (*StagePlan) Unmarshal 

func (m *StagePlan) Unmarshal(dAtA []byte) error

type StageSpec 

type StageSpec struct {
	// unqiue in job, used by rest of the config
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// if true, there MUST be one task that is background
	Background bool `protobuf:"varint,2,opt,name=background,proto3" json:"background,omitempty"`
	// selct by name, role, the relation between multiple selector is OR, NOT AND
	Selectors []NodeSelectorSpec `protobuf:"bytes,3,rep,name=selectors" json:"selectors"`
	Pipelines []TaskPipelineSpec `protobuf:"bytes,4,rep,name=pipelines" json:"pipelines"`
	Tasks     []TaskSpec         `protobuf:"bytes,5,rep,name=tasks" json:"tasks"`
}

func (*StageSpec) Descriptor 

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

func (*StageSpec) Marshal 

func (m *StageSpec) Marshal() (dAtA []byte, err error)

func (*StageSpec) MarshalTo 

func (m *StageSpec) MarshalTo(dAtA []byte) (int, error)

func (*StageSpec) ProtoMessage 

func (*StageSpec) ProtoMessage()

func (*StageSpec) Reset 

func (m *StageSpec) Reset()

func (*StageSpec) Size 

func (m *StageSpec) Size() (n int)

func (*StageSpec) String 

func (m *StageSpec) String() string

func (*StageSpec) Unmarshal 

func (m *StageSpec) Unmarshal(dAtA []byte) error

type StopperSpec 

type StopperSpec struct {
	Stage string `protobuf:"bytes,1,opt,name=stage,proto3" json:"stage,omitempty"`
	Task  string `protobuf:"bytes,2,opt,name=task,proto3" json:"task,omitempty"`
	All   bool   `protobuf:"varint,3,opt,name=all,proto3" json:"all,omitempty"`
}

func (*StopperSpec) Descriptor 

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

func (*StopperSpec) Marshal 

func (m *StopperSpec) Marshal() (dAtA []byte, err error)

func (*StopperSpec) MarshalTo 

func (m *StopperSpec) MarshalTo(dAtA []byte) (int, error)

func (*StopperSpec) ProtoMessage 

func (*StopperSpec) ProtoMessage()

func (*StopperSpec) Reset 

func (m *StopperSpec) Reset()

func (*StopperSpec) Size 

func (m *StopperSpec) Size() (n int)

func (*StopperSpec) String 

func (m *StopperSpec) String() string

func (*StopperSpec) Unmarshal 

func (m *StopperSpec) Unmarshal(dAtA []byte) error

type SubmitJobReq 

type SubmitJobReq struct {
	User string `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
	Spec string `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"`
}

--------------------------- 

<job rpc>

---------------------------

func (*SubmitJobReq) Descriptor 

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

func (*SubmitJobReq) Marshal 

func (m *SubmitJobReq) Marshal() (dAtA []byte, err error)

func (*SubmitJobReq) MarshalTo 

func (m *SubmitJobReq) MarshalTo(dAtA []byte) (int, error)

func (*SubmitJobReq) ProtoMessage 

func (*SubmitJobReq) ProtoMessage()

func (*SubmitJobReq) Reset 

func (m *SubmitJobReq) Reset()

func (*SubmitJobReq) Size 

func (m *SubmitJobReq) Size() (n int)

func (*SubmitJobReq) String 

func (m *SubmitJobReq) String() string

func (*SubmitJobReq) Unmarshal 

func (m *SubmitJobReq) Unmarshal(dAtA []byte) error

type SubmitJobRes 

type SubmitJobRes struct {
	Error *Error `protobuf:"bytes,1,opt,name=error" json:"error,omitempty"`
	Id    string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
}

func (*SubmitJobRes) Descriptor 

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

func (*SubmitJobRes) Marshal 

func (m *SubmitJobRes) Marshal() (dAtA []byte, err error)

func (*SubmitJobRes) MarshalTo 

func (m *SubmitJobRes) MarshalTo(dAtA []byte) (int, error)

func (*SubmitJobRes) ProtoMessage 

func (*SubmitJobRes) ProtoMessage()

func (*SubmitJobRes) Reset 

func (m *SubmitJobRes) Reset()

func (*SubmitJobRes) Size 

func (m *SubmitJobRes) Size() (n int)

func (*SubmitJobRes) String 

func (m *SubmitJobRes) String() string

func (*SubmitJobRes) Unmarshal 

func (m *SubmitJobRes) Unmarshal(dAtA []byte) error

type Task 

type Task struct {
	Status    TaskStatus `protobuf:"varint,1,opt,name=status,proto3,enum=bh.TaskStatus" json:"status,omitempty"`
	StartTime int64      `protobuf:"varint,2,opt,name=startTime,proto3" json:"startTime,omitempty"`
	ReadyTime int64      `protobuf:"varint,3,opt,name=readyTime,proto3" json:"readyTime,omitempty"`
	StopTime  int64      `protobuf:"varint,4,opt,name=stopTime,proto3" json:"stopTime,omitempty"`
}

func (*Task) Descriptor 

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

func (*Task) Marshal 

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

func (*Task) MarshalTo 

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

func (*Task) ProtoMessage 

func (*Task) ProtoMessage()

func (*Task) Reset 

func (m *Task) Reset()

func (*Task) Size 

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

func (*Task) String 

func (m *Task) String() string

func (*Task) Unmarshal 

func (m *Task) Unmarshal(dAtA []byte) error

type TaskDriver 

type TaskDriver int32
const (
	TaskDriver_UNKNOWN_TASKDRIVER TaskDriver = 0
	TaskDriver_STOPPER            TaskDriver = 1
	TaskDriver_SHELL              TaskDriver = 2
	TaskDriver_EXEC               TaskDriver = 3
	TaskDriver_DOCKER             TaskDriver = 4
)

func (TaskDriver) EnumDescriptor 

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

func (TaskDriver) String 

func (x TaskDriver) String() string

func (*TaskDriver) UnmarshalYAML 

func (x *TaskDriver) UnmarshalYAML(unmarshal func(interface{}) error) error

type TaskPipeline 

type TaskPipeline struct {
	Status TaskPipelineStatus `protobuf:"varint,1,opt,name=status,proto3,enum=bh.TaskPipelineStatus" json:"status,omitempty"`
	Tasks  []int64            `protobuf:"varint,2,rep,packed,name=tasks" json:"tasks,omitempty"`
}

func (*TaskPipeline) Descriptor 

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

func (*TaskPipeline) Marshal 

func (m *TaskPipeline) Marshal() (dAtA []byte, err error)

func (*TaskPipeline) MarshalTo 

func (m *TaskPipeline) MarshalTo(dAtA []byte) (int, error)

func (*TaskPipeline) ProtoMessage 

func (*TaskPipeline) ProtoMessage()

func (*TaskPipeline) Reset 

func (m *TaskPipeline) Reset()

func (*TaskPipeline) Size 

func (m *TaskPipeline) Size() (n int)

func (*TaskPipeline) String 

func (m *TaskPipeline) String() string

func (*TaskPipeline) Unmarshal 

func (m *TaskPipeline) Unmarshal(dAtA []byte) error

type TaskPipelinePlan 

type TaskPipelinePlan struct {
	Name  string     `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Tasks []TaskPlan `protobuf:"bytes,2,rep,name=tasks" json:"tasks"`
}

func (*TaskPipelinePlan) Descriptor 

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

func (*TaskPipelinePlan) Marshal 

func (m *TaskPipelinePlan) Marshal() (dAtA []byte, err error)

func (*TaskPipelinePlan) MarshalTo 

func (m *TaskPipelinePlan) MarshalTo(dAtA []byte) (int, error)

func (*TaskPipelinePlan) ProtoMessage 

func (*TaskPipelinePlan) ProtoMessage()

func (*TaskPipelinePlan) Reset 

func (m *TaskPipelinePlan) Reset()

func (*TaskPipelinePlan) Size 

func (m *TaskPipelinePlan) Size() (n int)

func (*TaskPipelinePlan) String 

func (m *TaskPipelinePlan) String() string

func (*TaskPipelinePlan) Unmarshal 

func (m *TaskPipelinePlan) Unmarshal(dAtA []byte) error

type TaskPipelineSpec 

type TaskPipelineSpec struct {
	Name  string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Tasks []string `protobuf:"bytes,2,rep,name=tasks" json:"tasks,omitempty"`
}

func (*TaskPipelineSpec) Descriptor 

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

func (*TaskPipelineSpec) Marshal 

func (m *TaskPipelineSpec) Marshal() (dAtA []byte, err error)

func (*TaskPipelineSpec) MarshalTo 

func (m *TaskPipelineSpec) MarshalTo(dAtA []byte) (int, error)

func (*TaskPipelineSpec) ProtoMessage 

func (*TaskPipelineSpec) ProtoMessage()

func (*TaskPipelineSpec) Reset 

func (m *TaskPipelineSpec) Reset()

func (*TaskPipelineSpec) Size 

func (m *TaskPipelineSpec) Size() (n int)

func (*TaskPipelineSpec) String 

func (m *TaskPipelineSpec) String() string

func (*TaskPipelineSpec) Unmarshal 

func (m *TaskPipelineSpec) Unmarshal(dAtA []byte) error

type TaskPipelineStatus 

type TaskPipelineStatus int32
const (
	TaskPipelineStatus_UNKNOWN_TASK_PIPELINE_STATUS TaskPipelineStatus = 0
	TaskPipelineStatus_TASK_PIPELINE_QUEUED         TaskPipelineStatus = 1
	TaskPipelineStatus_TASK_PIPELINE_RUNNING        TaskPipelineStatus = 2
	TaskPipelineStatus_TASK_PIPELINE_FINISHED       TaskPipelineStatus = 3
	TaskPipelineStatus_TASK_PIPELINE_BACKGROUND     TaskPipelineStatus = 4
)

func (TaskPipelineStatus) EnumDescriptor 

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

func (TaskPipelineStatus) String 

func (x TaskPipelineStatus) String() string

type TaskPlan 

type TaskPlan struct {
	Spec TaskSpec `protobuf:"bytes,1,opt,name=spec" json:"spec"`
}

func (*TaskPlan) Descriptor 

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

func (*TaskPlan) Marshal 

func (m *TaskPlan) Marshal() (dAtA []byte, err error)

func (*TaskPlan) MarshalTo 

func (m *TaskPlan) MarshalTo(dAtA []byte) (int, error)

func (*TaskPlan) ProtoMessage 

func (*TaskPlan) ProtoMessage()

func (*TaskPlan) Reset 

func (m *TaskPlan) Reset()

func (*TaskPlan) Size 

func (m *TaskPlan) Size() (n int)

func (*TaskPlan) String 

func (m *TaskPlan) String() string

func (*TaskPlan) Unmarshal 

func (m *TaskPlan) Unmarshal(dAtA []byte) error

type TaskSpec 

type TaskSpec struct {
	// unique in stage, MUST be specified if pipeline is used or is a background process
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// the stage contains this background task MUST also be background
	Background bool       `protobuf:"varint,2,opt,name=background,proto3" json:"background,omitempty"`
	Driver     TaskDriver `protobuf:"varint,3,opt,name=driver,proto3,enum=bh.TaskDriver" json:"driver,omitempty"`
	Env        []*Env     `protobuf:"bytes,4,rep,name=env" json:"env,omitempty"`
	// NOTE: we intentionly don't use [(gogoproto.nullable) = false], so we can check nil to see if config match driver
	Stopper *StopperSpec `protobuf:"bytes,5,opt,name=stopper" json:"stopper,omitempty"`
	Shell   *ShellSpec   `protobuf:"bytes,6,opt,name=shell" json:"shell,omitempty"`
	Exec    *ExecSpec    `protobuf:"bytes,7,opt,name=exec" json:"exec,omitempty"`
	Docker  *DockerSpec  `protobuf:"bytes,8,opt,name=docker" json:"docker,omitempty"`
	// readiness check for long running task
	Ready ReadySpec `protobuf:"bytes,9,opt,name=ready" json:"ready"`
}

func (*TaskSpec) Descriptor 

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

func (*TaskSpec) Marshal 

func (m *TaskSpec) Marshal() (dAtA []byte, err error)

func (*TaskSpec) MarshalTo 

func (m *TaskSpec) MarshalTo(dAtA []byte) (int, error)

func (*TaskSpec) ProtoMessage 

func (*TaskSpec) ProtoMessage()

func (*TaskSpec) Reset 

func (m *TaskSpec) Reset()

func (*TaskSpec) Size 

func (m *TaskSpec) Size() (n int)

func (*TaskSpec) String 

func (m *TaskSpec) String() string

func (*TaskSpec) Unmarshal 

func (m *TaskSpec) Unmarshal(dAtA []byte) error

type TaskStatus 

type TaskStatus int32
const (
	TaskStatus_UNKNOWN_TASK_STATUS TaskStatus = 0
	TaskStatus_TASK_QUEUED         TaskStatus = 1
	TaskStatus_TASK_RUNNING        TaskStatus = 2
	TaskStatus_TASK_BACKGROUND     TaskStatus = 3
	TaskStatus_TASK_FINISHED       TaskStatus = 4
	TaskStatus_TASK_ABORTED        TaskStatus = 5
)

func (TaskStatus) EnumDescriptor 

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

func (TaskStatus) String 

func (x TaskStatus) String() string

type WorkloadSpec 

type WorkloadSpec struct {
	Framework        string `protobuf:"bytes,1,opt,name=framework,proto3" json:"framework,omitempty"`
	FrameworkVersion string `protobuf:"bytes,2,opt,name=frameworkVersion,proto3" json:"frameworkVersion,omitempty" yaml:"frameworkVersion"`
	Database         string `protobuf:"bytes,3,opt,name=database,proto3" json:"database,omitempty"`
	DatabaseVersion  string `protobuf:"bytes,4,opt,name=databaseVersion,proto3" json:"databaseVersion,omitempty" yaml:"databaseVersion"`
}

TODO: this is not used

func (*WorkloadSpec) Descriptor 

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

func (*WorkloadSpec) Marshal 

func (m *WorkloadSpec) Marshal() (dAtA []byte, err error)

func (*WorkloadSpec) MarshalTo 

func (m *WorkloadSpec) MarshalTo(dAtA []byte) (int, error)

func (*WorkloadSpec) ProtoMessage 

func (*WorkloadSpec) ProtoMessage()

func (*WorkloadSpec) Reset 

func (m *WorkloadSpec) Reset()

func (*WorkloadSpec) Size 

func (m *WorkloadSpec) Size() (n int)

func (*WorkloadSpec) String 

func (m *WorkloadSpec) String() string

func (*WorkloadSpec) Unmarshal 

func (m *WorkloadSpec) Unmarshal(dAtA []byte) error

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.