batch

package

Go to main page

Versions in this module

v1

v1.3.0

Aug 3, 2026

v1.2.0

Aug 3, 2026

Changes in this version

+ type CapacityLimit struct

+ CapacityUnit string

+ MaxCapacity int32

+ type ContainerDetail struct

+ Command []string

+ Environment []KeyValuePair

+ EphemeralStorage *EphemeralStorage

+ ExecutionRoleArn string

+ ExitCode *int32

+ FargatePlatformConfiguration *FargatePlatformConfiguration

+ Image string

+ InstanceType string

+ JobRoleArn string

+ LinuxParameters *LinuxParameters

+ LogConfiguration *LogConfiguration

+ LogStreamName string

+ Memory int32

+ MountPoints []MountPoint

+ NetworkConfiguration *NetworkConfiguration

+ Privileged bool

+ ReadonlyRootFilesystem bool

+ Reason string

+ RepositoryCredentials *RepositoryCredentials

+ ResourceRequirements []ResourceRequirement

+ RuntimePlatform *RuntimePlatform

+ Secrets []Secret

+ Ulimits []Ulimit

+ User string

+ Vcpus int32

+ Volumes []Volume

type FrontOfQueue

+ LastUpdatedAt int64

type InMemoryBackend

+ func (b *InMemoryBackend) CreateQuotaShare(ctx context.Context, name, jobQueue string, ...) (*QuotaShare, error)

+ func (b *InMemoryBackend) DeleteQuotaShare(ctx context.Context, quotaShareARN string) error

+ func (b *InMemoryBackend) DescribeQuotaShare(ctx context.Context, quotaShareARN string) (*QuotaShare, error)

+ func (b *InMemoryBackend) ListQuotaShares(ctx context.Context, jobQueue string) ([]*QuotaShare, error)

+ func (b *InMemoryBackend) TaggedResources() []TaggedEntry

+ func (b *InMemoryBackend) UpdateQuotaShare(ctx context.Context, quotaShareARN string, ...) (*QuotaShare, error)

+ func (b *InMemoryBackend) UpdateServiceJob(ctx context.Context, jobID string, schedulingPriority int32) (*ServiceJob, error)

type Job

+ Container *ContainerDetail

+ IsCancelled bool

+ IsTerminated bool

+ PlatformCapabilities []string

type JobDefinition

+ RetryStrategy *RetryStrategy

type JobQueue

+ JobQueueType string

+ ServiceEnvironmentOrder []ServiceEnvironmentOrder

+ type QuotaShare struct

+ CapacityLimits []QuotaShareCapacityLimit

+ JobQueueArn string

+ PreemptionConfiguration *QuotaSharePreemptionConfiguration

+ QuotaShareArn string

+ QuotaShareName string

+ ResourceSharingConfiguration *QuotaShareResourceSharingConfiguration

+ State string

+ Status string

+ Tags map[string]string

+ type QuotaShareCapacityLimit struct

+ CapacityUnit string

+ MaxCapacity int32

+ type QuotaSharePreemptionConfiguration struct

+ InSharePreemption string

+ type QuotaShareResourceSharingConfiguration struct

+ BorrowLimit int32

+ Strategy string

type ServiceEnvironment

+ CapacityLimits []CapacityLimit

+ type ServiceEnvironmentOrder struct

+ Order int32

+ ServiceEnvironment string

type ServiceJob

+ IsTerminated bool

+ JobArn string

+ JobID string

+ JobName string

+ JobQueue string

+ RetryStrategy *ServiceJobRetryStrategy

+ ScheduledAt *int64

+ SchedulingPriority int32

+ ServiceJobType string

+ ServiceRequestPayload string

+ ShareIdentifier string

+ TimeoutConfig *ServiceJobTimeout

+ type ServiceJobEvaluateOnExit struct

+ Action string

+ OnStatusReason string

+ type ServiceJobRetryStrategy struct

+ Attempts int32

+ EvaluateOnExit []ServiceJobEvaluateOnExit

+ type ServiceJobTimeout struct

+ AttemptDurationSeconds int32

+ type TaggedEntry struct

+ ARN string

+ Tags map[string]string

v1.1.4

Jul 20, 2026

v1.1.3

Jul 20, 2026

v1.1.2

Jul 20, 2026

v1.1.1

Jul 20, 2026

v1.1.0

Jul 19, 2026

Changes in this version

+ var ErrAlreadyExists = awserr.New("ClientException", awserr.ErrAlreadyExists)

+ var ErrNotFound = awserr.New("ClientException", awserr.ErrNotFound)

+ var ErrValidation = awserr.New("ClientException", awserr.ErrInvalidParameter)

+ type ArrayProperties struct

+ Index int32

+ Size int32

+ StatusSummary map[string]int32

+ type ComputeEnvironment struct

+ ComputeEnvironmentArn string

+ ComputeEnvironmentName string

+ ComputeResources *ComputeResources

+ EksConfiguration *EksConfiguration

+ ServiceRole string

+ State string

+ Status string

+ StatusReason string

+ Tags map[string]string

+ Type string

+ UpdatePolicy *UpdatePolicy

+ type ComputeEnvironmentOrder struct

+ ComputeEnvironment string

+ Order int32

+ type ComputeResources struct

+ AllocationStrategy string

+ BidPercentage int32

+ DesiredvCpus int32

+ Ec2Configuration []Ec2Configuration

+ Ec2KeyPair string

+ ImageID string

+ InstanceRole string

+ InstanceTypes []string

+ LaunchTemplate *LaunchTemplate

+ MaxvCpus int32

+ MinvCpus int32

+ PlacementGroup string

+ SecurityGroupIDs []string

+ SpotIamFleetRole string

+ Subnets []string

+ Tags map[string]string

+ Type string

+ type ConfigProvider interface

+ GetBatchSettings func() Settings

+ type ConsumableResource struct

+ AvailableQuantity int64

+ ConsumableResourceArn string

+ ConsumableResourceName string

+ CreatedAt int64

+ InUseQuantity int64

+ ResourceType string

+ Tags map[string]string

+ TotalQuantity int64

+ type ConsumableResourceProperties struct

+ ConsumableResourceList []ConsumableResourceProperty

+ type ConsumableResourceProperty struct

+ ConsumableResource string

+ Quantity float64

+ type ContainerOverrides struct

+ Command []string

+ Environment []KeyValuePair

+ InstanceType string

+ ResourceRequirements []ResourceRequirement

+ type ContainerProperties struct

+ Command []string

+ Environment []KeyValuePair

+ EphemeralStorage *EphemeralStorage

+ ExecutionRoleArn string

+ FargatePlatformConfiguration *FargatePlatformConfiguration

+ Image string

+ InstanceType string

+ JobRoleArn string

+ LinuxParameters *LinuxParameters

+ LogConfiguration *LogConfiguration

+ Memory int32

+ MountPoints []MountPoint

+ NetworkConfiguration *NetworkConfiguration

+ Privileged bool

+ ReadonlyRootFilesystem bool

+ RepositoryCredentials *RepositoryCredentials

+ ResourceRequirements []ResourceRequirement

+ RuntimePlatform *RuntimePlatform

+ Secrets []Secret

+ Ulimits []Ulimit

+ User string

+ Vcpus int32

+ Volumes []Volume

+ type Device struct

+ ContainerPath string

+ HostPath string

+ Permissions []string

+ type Ec2Configuration struct

+ ImageIDOverride string

+ ImageKubernetesVersion string

+ ImageType string

+ type EksConfiguration struct

+ EksClusterArn string

+ KubernetesNamespace string

+ type EksContainer struct

+ Args []string

+ Command []string

+ Env []EksContainerEnv

+ Image string

+ Name string

+ Resources *EksContainerResources

+ SecurityContext *EksSecurityContext

+ VolumeMounts []EksVolumeMount

+ type EksContainerEnv struct

+ Name string

+ Value string

+ type EksContainerResources struct

+ Limits map[string]string

+ Requests map[string]string

+ type EksEmptyDir struct

+ Medium string

+ SizeLimit string

+ type EksHostPath struct

+ Path string

+ type EksMetadata struct

+ Annotations map[string]string

+ Labels map[string]string

+ type EksPodProperties struct

+ Containers []EksContainer

+ DNSPolicy string

+ HostNetwork bool

+ InitContainers []EksContainer

+ Metadata *EksMetadata

+ ServiceAccountName string

+ Volumes []EksVolume

+ type EksProperties struct

+ PodProperties *EksPodProperties

+ type EksSecret struct

+ Optional bool

+ SecretName string

+ type EksSecurityContext struct

+ AllowPrivilegeEscalation bool

+ Privileged bool

+ ReadOnlyRootFilesystem bool

+ RunAsGroup *int64

+ RunAsNonRoot bool

+ RunAsUser *int64

+ type EksVolume struct

+ EmptyDir *EksEmptyDir

+ HostPath *EksHostPath

+ Name string

+ Secret *EksSecret

+ type EksVolumeMount struct

+ MountPath string

+ Name string

+ ReadOnly bool

+ type EphemeralStorage struct

+ SizeInGiB int32

+ type EvaluateOnExit struct

+ Action string

+ OnExitCode string

+ OnReason string

+ OnStatusReason string

+ type FairsharePolicy struct

+ ComputeReservation int32

+ ShareDecaySeconds int32

+ ShareDistribution []ShareDistribution

+ type FargatePlatformConfiguration struct

+ PlatformVersion string

+ type FrontOfQueue struct

+ Jobs []FrontOfQueueJob

+ Timestamp float64

+ type FrontOfQueueJob struct

+ EarliestTimeAtPosition float64

+ JobArn string

+ type Handler struct

+ Backend *InMemoryBackend

+ func NewHandler(backend *InMemoryBackend) *Handler

+ func (h *Handler) ChaosOperations() []string

+ func (h *Handler) ChaosRegions() []string

+ func (h *Handler) ChaosServiceName() string

+ func (h *Handler) ExtractOperation(c *echo.Context) string

+ func (h *Handler) ExtractResource(c *echo.Context) string

+ func (h *Handler) GetSupportedOperations() []string

+ func (h *Handler) Handler() echo.HandlerFunc

+ func (h *Handler) MatchPriority() int

+ func (h *Handler) Name() string

+ func (h *Handler) Restore(ctx context.Context, data []byte) error

+ func (h *Handler) RouteMatcher() service.Matcher

+ func (h *Handler) Snapshot(ctx context.Context) []byte

+ func (h *Handler) StartWorker(ctx context.Context) error

+ func (h *Handler) WithJanitor(interval, inactiveJobDefTTL, completedJobTTL time.Duration, ...) *Handler

+ type HostVolume struct

+ SourcePath string

+ type InMemoryBackend struct

+ func NewInMemoryBackend(accountID, region string) *InMemoryBackend

+ func (b *InMemoryBackend) CancelJob(ctx context.Context, idOrARN, reason string) error

+ func (b *InMemoryBackend) CreateComputeEnvironment(ctx context.Context, name, ceType, state string, tags map[string]string, ...) (*ComputeEnvironment, error)

+ func (b *InMemoryBackend) CreateConsumableResource(ctx context.Context, name, resourceType string, totalQuantity int64, ...) (*ConsumableResource, error)

+ func (b *InMemoryBackend) CreateJobQueue(ctx context.Context, name string, priority int32, state string, ...) (*JobQueue, error)

+ func (b *InMemoryBackend) CreateSchedulingPolicy(ctx context.Context, name string, tags map[string]string, ...) (*SchedulingPolicy, error)

+ func (b *InMemoryBackend) CreateServiceEnvironment(ctx context.Context, name, envType, state string, tags map[string]string) (*ServiceEnvironment, error)

+ func (b *InMemoryBackend) DeleteComputeEnvironment(ctx context.Context, nameOrARN string) error

+ func (b *InMemoryBackend) DeleteConsumableResource(ctx context.Context, nameOrARN string) error

+ func (b *InMemoryBackend) DeleteJobQueue(ctx context.Context, nameOrARN string) error

+ func (b *InMemoryBackend) DeleteSchedulingPolicy(ctx context.Context, policyARN string) error

+ func (b *InMemoryBackend) DeleteServiceEnvironment(ctx context.Context, nameOrARN string) error

+ func (b *InMemoryBackend) DeregisterJobDefinition(ctx context.Context, arnOrNameRev string) error

+ func (b *InMemoryBackend) DescribeComputeEnvironments(ctx context.Context, names []string, maxResults int32, nextToken string) ([]*ComputeEnvironment, string)

+ func (b *InMemoryBackend) DescribeConsumableResource(ctx context.Context, nameOrARN string) (*ConsumableResource, error)

+ func (b *InMemoryBackend) DescribeJobDefinitions(ctx context.Context, names []string, status, jobDefinitionName string, ...) ([]*JobDefinition, string)

+ func (b *InMemoryBackend) DescribeJobQueues(ctx context.Context, names []string, maxResults int32, nextToken string) ([]*JobQueue, string)

+ func (b *InMemoryBackend) DescribeJobs(ctx context.Context, jobIDs []string) []*Job

+ func (b *InMemoryBackend) DescribeSchedulingPolicies(ctx context.Context, arns []string) []*SchedulingPolicy

+ func (b *InMemoryBackend) DescribeServiceEnvironments(ctx context.Context, names []string) []*ServiceEnvironment

+ func (b *InMemoryBackend) DescribeServiceJob(ctx context.Context, serviceJobID string) (*ServiceJob, error)

+ func (b *InMemoryBackend) GetJobQueueSnapshot(ctx context.Context, jobQueue string) (*JobQueueSnapshot, error)

+ func (b *InMemoryBackend) ListConsumableResources(ctx context.Context) []*ConsumableResource

+ func (b *InMemoryBackend) ListJobs(ctx context.Context, queue, status, nextToken string, maxResults int32) ([]*Job, string, error)

+ func (b *InMemoryBackend) ListJobsByConsumableResource(ctx context.Context, consumableResource string) ([]*Job, error)

+ func (b *InMemoryBackend) ListSchedulingPolicies(ctx context.Context) []*SchedulingPolicy

+ func (b *InMemoryBackend) ListServiceJobs(ctx context.Context, serviceEnv string) ([]*ServiceJob, error)

+ func (b *InMemoryBackend) ListTagsForResource(ctx context.Context, resourceARN string) (map[string]string, error)

+ func (b *InMemoryBackend) Region() string

+ func (b *InMemoryBackend) RegisterJobDefinition(ctx context.Context, name, defType string, tags map[string]string, ...) (*JobDefinition, error)

+ func (b *InMemoryBackend) Reset()

+ func (b *InMemoryBackend) Restore(ctx context.Context, data []byte) error

+ func (b *InMemoryBackend) Snapshot(ctx context.Context) []byte

+ func (b *InMemoryBackend) SubmitJob(ctx context.Context, name, queue, jobDefinition string, tags map[string]string, ...) (*Job, error)

+ func (b *InMemoryBackend) SubmitServiceJob(ctx context.Context, name, serviceEnv string, tags map[string]string) (*ServiceJob, error)

+ func (b *InMemoryBackend) TagResource(ctx context.Context, resourceARN string, tags map[string]string) error

+ func (b *InMemoryBackend) TerminateJob(ctx context.Context, idOrARN, reason string) error

+ func (b *InMemoryBackend) TerminateServiceJob(ctx context.Context, serviceJobID, reason string) error

+ func (b *InMemoryBackend) UntagResource(ctx context.Context, resourceARN string, tagKeys []string) error

+ func (b *InMemoryBackend) UpdateComputeEnvironment(ctx context.Context, nameOrARN, state, serviceRole string, ...) (*ComputeEnvironment, error)

+ func (b *InMemoryBackend) UpdateConsumableResource(ctx context.Context, nameOrARN, operation string, quantity int64) (*ConsumableResource, error)

+ func (b *InMemoryBackend) UpdateJobQueue(ctx context.Context, nameOrARN string, priority *int32, state string, ...) (*JobQueue, error)

+ func (b *InMemoryBackend) UpdateSchedulingPolicy(ctx context.Context, policyARN string, fairsharePolicy *FairsharePolicy) error

+ func (b *InMemoryBackend) UpdateServiceEnvironment(ctx context.Context, nameOrARN, state string) (*ServiceEnvironment, error)

+ type Janitor struct

+ Backend *InMemoryBackend

+ CompletedJobTTL time.Duration

+ InactiveJobDefTTL time.Duration

+ Interval time.Duration

+ TaskTimeout time.Duration

+ func NewJanitor(backend *InMemoryBackend, ...) *Janitor

+ func (j *Janitor) Run(ctx context.Context)

+ func (j *Janitor) SweepOnce(ctx context.Context)

+ type Job struct

+ ArrayProperties *ArrayProperties

+ Attempts []JobAttempt

+ ConsumableResourceProperties *ConsumableResourceProperties

+ ContainerOverrides *ContainerOverrides

+ CreatedAt int64

+ DependsOn []JobDependency

+ JobARN string

+ JobDefinition string

+ JobID string

+ JobName string

+ JobQueue string

+ Parameters map[string]string

+ PropagateTags bool

+ RetryStrategy *RetryStrategy

+ SchedulingPriorityOverride int32

+ ShareIdentifier string

+ StartedAt *int64

+ Status string

+ StatusReason string

+ StoppedAt *int64

+ Tags map[string]string

+ Timeout *JobTimeout

+ type JobAttempt struct

+ Container *JobAttemptContainer

+ StartedAt *int64

+ StatusReason string

+ StoppedAt *int64

+ type JobAttemptContainer struct

+ ExitCode int32

+ LogStreamName string

+ Reason string

+ type JobDefinition struct

+ ConsumableResourceProperties *ConsumableResourceProperties

+ ContainerProperties *ContainerProperties

+ DeregisteredAt *time.Time

+ EksProperties *EksProperties

+ JobDefinitionArn string

+ JobDefinitionName string

+ NodeProperties *NodeProperties

+ Parameters map[string]string

+ PlatformCapabilities []string

+ PropagateTags bool

+ Revision int32

+ RuntimePlatform *RuntimePlatform

+ SchedulingPriority int32

+ Status string

+ Tags map[string]string

+ Timeout *JobTimeout

+ Type string

+ type JobDependency struct

+ JobID string

+ Type string

+ type JobQueue struct

+ ComputeEnvironmentOrder []ComputeEnvironmentOrder

+ JobQueueArn string

+ JobQueueName string

+ JobStateTimeLimitActions []JobStateTimeLimitAction

+ Priority int32

+ SchedulingPolicyArn string

+ State string

+ Status string

+ StatusReason string

+ Tags map[string]string

+ type JobQueueSnapshot struct

+ FrontOfQueue *FrontOfQueue

+ type JobStateTimeLimitAction struct

+ Action string

+ MaxTimeSeconds int32

+ Reason string

+ State string

+ type JobTimeout struct

+ AttemptDurationSeconds int32

+ type KeyValuePair struct

+ Name string

+ Value string

+ type LaunchTemplate struct

+ LaunchTemplateID string

+ LaunchTemplateName string

+ Overrides []LaunchTemplateOverride

+ Version string

+ type LaunchTemplateOverride struct

+ LaunchTemplateID string

+ LaunchTemplateName string

+ TargetInstanceTypes []string

+ Version string

+ type LinuxParameters struct

+ Devices []Device

+ InitProcessEnabled bool

+ MaxSwap int32

+ SharedMemorySize int32

+ Swappiness int32

+ Tmpfs []Tmpfs

+ type LogConfiguration struct

+ LogDriver string

+ Options map[string]string

+ type MountPoint struct

+ ContainerPath string

+ ReadOnly bool

+ SourceVolume string

+ type NetworkConfiguration struct

+ AssignPublicIP string

+ type NodeProperties struct

+ MainNode int32

+ NodeRangeProperties []NodeRangeProperty

+ NumNodes int32

+ type NodeRangeProperty struct

+ ContainerProperties *ContainerProperties

+ TargetNodes string

+ type Provider struct

+ func (p *Provider) Init(ctx *service.AppContext) (service.Registerable, error)

+ func (p *Provider) Name() string

+ type RepositoryCredentials struct

+ CredentialsParameter string

+ type ResourceRequirement struct

+ Type string

+ Value string

+ type RetryStrategy struct

+ Attempts int32

+ EvaluateOnExit []EvaluateOnExit

+ type RuntimePlatform struct

+ CPUArchitecture string

+ OperatingSystemFamily string

+ type SchedulingPolicy struct

+ Arn string

+ FairsharePolicy *FairsharePolicy

+ Name string

+ Tags map[string]string

+ type Secret struct

+ Name string

+ ValueFrom string

+ type ServiceEnvironment struct

+ ServiceEnvironmentArn string

+ ServiceEnvironmentName string

+ ServiceEnvironmentType string

+ State string

+ Status string

+ Tags map[string]string

+ type ServiceJob struct

+ CreatedAt int64

+ ServiceEnvironment string

+ ServiceJobArn string

+ ServiceJobID string

+ ServiceJobName string

+ StartedAt *int64

+ Status string

+ StatusReason string

+ StoppedAt *int64

+ Tags map[string]string

+ type Settings struct

+ CompletedJobTTL time.Duration

+ InactiveJobDefTTL time.Duration

+ JanitorInterval time.Duration

+ type ShareDistribution struct

+ ShareIdentifier string

+ WeightFactor float32

+ type Tmpfs struct

+ ContainerPath string

+ MountOptions []string

+ Size int32

+ type Ulimit struct

+ HardLimit int32

+ Name string

+ SoftLimit int32

+ type UpdatePolicy struct

+ JobExecutionTimeoutMinutes int64

+ TerminateJobsOnUpdate bool

+ type Volume struct

+ Host *HostVolume

+ Name string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL