batch

Documentation

Index

• func RetrieveMessageFromS3(filename string, messagesBucketName string, isDebug bool) ([]byte, error)
• func SubmitJob(batchJob BatchJob) error
• type BatchJob
• type BatchJobMessageType
• type BatchJobQueue

Functions

func RetrieveMessageFromS3

func RetrieveMessageFromS3(filename string, messagesBucketName string, isDebug bool) ([]byte, error)

func SubmitJob

func SubmitJob(batchJob BatchJob) error

Types

type BatchJob

type BatchJob struct {
	Name               *string
	Job                any
	FullJobDefinition  string
	FullJobQueue       string
	MessagesBucketName string
	IsDebug            bool
}

type BatchJobMessageType

type BatchJobMessageType string

const (
	JobDefinition = "batch-job-definition" // The job definition name on aws

	BatchJobMessageTypeS3 BatchJobMessageType = "s3"
)

type BatchJobQueue

type BatchJobQueue string

const (
	BatchJobQueueLow    BatchJobQueue = "batch-job-queue-low"
	BatchJobQueueMedium BatchJobQueue = "batch-job-queue-medium"
	BatchJobQueueHigh   BatchJobQueue = "batch-job-queue-high"
)

Queue names are the same as the batch Job queue names in aws