jobs

Documentation

Index

• func GetParameterValue[T ParameterType](parameters map[string]interface{}, k parameters_enums.Key) (T, error)
• func RegisterGobDataTypes()
• func SetParameterValue[T ParameterType](parameters map[string]interface{}, k parameters_enums.Key, v T) error
• type Command
• type CompletingJobDtoV1
• type CompletingJobsArgsV1
• type CompletingJobsReplyV1
• type ContextV1
• type JobsCountArgsV1
• type JobsCountArgsV2
• type JobsCountDtoV1
• type Logger
• type ParameterType
• type PendingJobDtoV1
• type PendingJobsArgsV1
• type PendingJobsArgsV2
• type PendingJobsDtoV1
• type Runner
• type UpsertJobHeartbeatArgsV1
• type UpsertJobHeartbeatReplyV1

Functions

func GetParameterValue

func GetParameterValue[T ParameterType](parameters map[string]interface{}, k parameters_enums.Key) (T, error)

func RegisterGobDataTypes

func RegisterGobDataTypes()

func SetParameterValue

func SetParameterValue[T ParameterType](parameters map[string]interface{}, k parameters_enums.Key, v T) error

Types

type Command

type Command interface {
	Runner
}

type CompletingJobDtoV1

type CompletingJobDtoV1 struct {
	Error string
	ID    string
}

type CompletingJobsArgsV1

type CompletingJobsArgsV1 struct {
	types.AuthArgsV1
	Jobs []CompletingJobDtoV1
}

type CompletingJobsReplyV1

type CompletingJobsReplyV1 struct {
	Done bool
}

type ContextV1

type ContextV1 struct {
	OrganizationID string
	EnvironmentID  string
	DeploymentID   string
	BuildID        string
}

type JobsCountArgsV1

type JobsCountArgsV1 struct {
	types.AuthArgsV1
}

type JobsCountArgsV2

type JobsCountArgsV2 struct {
	types.AuthArgsV2
}

type JobsCountDtoV1

type JobsCountDtoV1 struct {
	Count                  int
	RunnerOnTimeoutSeconds int
}

type Logger

type Logger interface {
	Log(messages []string) error
}

type ParameterType

type ParameterType interface {
	int | int64 | string | map[string]string | primitive.A | primitive.D | []string | map[string]interface{} | [][]string | bool
}

type PendingJobDtoV1

type PendingJobDtoV1 struct {
	JobID        string
	CommandEnums []commands_enums.Type
	Parameters   map[string]interface{}
}

PendingJobDtoV1 represents v1 of a pending deployment job from the server

type PendingJobsArgsV1

type PendingJobsArgsV1 struct {
	types.AuthArgsV1
}

PendingJobsArgsV1 represents v1 args to get pending jobs

type PendingJobsArgsV2

type PendingJobsArgsV2 struct {
	types.AuthArgsV2
}

type PendingJobsDtoV1

type PendingJobsDtoV1 struct {
	Jobs []PendingJobDtoV1
}

PendingJobsDtoV1 represents v1 of a deployment jobs from the server

type Runner

type Runner interface {
	Run(parameters map[string]interface{}, logsWriter io.Writer) (map[string]interface{}, error)
}

type UpsertJobHeartbeatArgsV1

type UpsertJobHeartbeatArgsV1 struct {
	types.AuthArgsV1
	JobID string
}

type UpsertJobHeartbeatReplyV1

type UpsertJobHeartbeatReplyV1 struct {
	Stopping bool
}