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 PendingJobForSaasDtoV1
• type PendingJobsArgsV1
• type PendingJobsArgsV2
• type PendingJobsDtoV1
• type PendingJobsForSaasArgsV1
• type PendingJobsForSaasDtoV1
• type Runner
• type SaasJobsCountArgsV1
• type SaasJobsCountDtoV1
• type UpdateJobOutputArgsV1
• type UpdateJobOutputDtoV1
• type UpdateJobOutputReplyV1
• 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 PendingJobForSaasDtoV1

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

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 PendingJobsForSaasArgsV1

type PendingJobsForSaasArgsV1 struct {
	types.AuthArgsV2
}

type PendingJobsForSaasDtoV1

type PendingJobsForSaasDtoV1 struct {
	Jobs []PendingJobForSaasDtoV1
}

type Runner

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

type SaasJobsCountArgsV1

type SaasJobsCountArgsV1 struct {
	types.AuthArgsV2
}

type SaasJobsCountDtoV1

type SaasJobsCountDtoV1 struct {
	Count                  int
	RunnerOnTimeoutSeconds int
}

type UpdateJobOutputArgsV1

type UpdateJobOutputArgsV1 struct {
	types.AuthArgsV1
	Jobs []UpdateJobOutputDtoV1
}

type UpdateJobOutputDtoV1

type UpdateJobOutputDtoV1 struct {
	ID     string
	Output string
}

type UpdateJobOutputReplyV1

type UpdateJobOutputReplyV1 struct {
	Done bool
}

type UpsertJobHeartbeatArgsV1

type UpsertJobHeartbeatArgsV1 struct {
	types.AuthArgsV1
	JobID string
}

type UpsertJobHeartbeatReplyV1

type UpsertJobHeartbeatReplyV1 struct {
	Stopping bool
}