Versions in this module Expand all Collapse all v1 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 ErrAccountSettingNotFound = awserr.New("AccountSettingNotFoundException", awserr.ErrNotFound) + var ErrCapacityProviderAlreadyExists = awserr.New("CapacityProviderAlreadyExistsException", awserr.ErrAlreadyExists) + var ErrCapacityProviderNotFound = awserr.New("CapacityProviderNotFoundException", awserr.ErrNotFound) + var ErrClient = awserr.New("ClientException", awserr.ErrInvalidParameter) + var ErrClusterAlreadyExists = awserr.New("ClusterAlreadyExistsException", awserr.ErrAlreadyExists) + var ErrClusterNotFound = awserr.New("ClusterNotFoundException", awserr.ErrNotFound) + var ErrContainerInstanceNotFound = awserr.New("ContainerInstanceNotFoundException", awserr.ErrNotFound) + var ErrDaemonAlreadyExists = awserr.New("ResourceInUseException", awserr.ErrAlreadyExists) + var ErrDaemonNotActive = awserr.New("DaemonNotActiveException", awserr.ErrConflict) + var ErrDaemonNotFound = awserr.New("DaemonNotFoundException", awserr.ErrNotFound) + var ErrDaemonTaskDefinitionNotFound = awserr.New("ClientException", awserr.ErrNotFound) + var ErrExpressGatewayServiceAlreadyExists = awserr.New("ExpressGatewayServiceAlreadyExistsException", awserr.ErrAlreadyExists) + var ErrExpressGatewayServiceNotFound = awserr.New("ExpressGatewayServiceNotFoundException", awserr.ErrNotFound) + var ErrInvalidParameter = awserr.New("InvalidParameterException", awserr.ErrInvalidParameter) + var ErrNilAppContext = errors.New("AppContext is required") + var ErrServiceAlreadyExists = awserr.New("ServiceAlreadyExistsException", awserr.ErrAlreadyExists) + var ErrServiceDeploymentNotFound = awserr.New("ServiceDeploymentNotFoundException", awserr.ErrNotFound) + var ErrServiceNotFound = awserr.New("ServiceNotFoundException", awserr.ErrNotFound) + var ErrTaskDefinitionNotFound = awserr.New("TaskDefinitionNotFoundException", awserr.ErrNotFound) + var ErrTaskNotFound = awserr.New("TaskNotFoundException", awserr.ErrNotFound) + var ErrTaskSetNotFound = awserr.New("TaskSetNotFoundException", awserr.ErrNotFound) + type AccountSetting struct + Name string + PrincipalArn string + Value string + type AttachmentStateChange struct + AttachmentArn string + Status string + type Attribute struct + Name string + TargetID string + TargetType string + Value string + type AutoScalingGroupProvider struct + AutoScalingGroupArn string + ManagedDraining string + ManagedScaling *ManagedScaling + ManagedTerminationProtection string + type AwsvpcConfiguration struct + AssignPublicIP string + SecurityGroups []string + Subnets []string + type Backend interface + ContinueServiceDeployment func(serviceDeploymentArn, hookID, action string) (*ServiceDeployment, error) + CreateCapacityProvider func(input CreateCapacityProviderInput) (*CapacityProvider, error) + CreateCluster func(input CreateClusterInput) (*Cluster, error) + CreateDaemon func(input CreateDaemonInput) (*Daemon, error) + CreateExpressGatewayService func(input CreateExpressGatewayServiceInput) (*ExpressGatewayService, error) + CreateService func(input CreateServiceInput) (*Service, error) + CreateTaskSet func(input CreateTaskSetInput) (*TaskSet, error) + DeleteAccountSetting func(name, principalArn string) (*AccountSetting, error) + DeleteAttributes func(cluster string, attrs []Attribute) ([]Attribute, error) + DeleteCapacityProvider func(nameOrArn string) (*CapacityProvider, error) + DeleteCluster func(clusterName string) (*Cluster, error) + DeleteDaemon func(daemonArn string) (*Daemon, error) + DeleteDaemonTaskDefinition func(familyOrArn string) (*DaemonTaskDefinition, error) + DeleteExpressGatewayService func(serviceArn string) (*ExpressGatewayService, error) + DeleteService func(cluster, serviceName string) (*Service, error) + DeleteTaskDefinitions func(taskDefinitionArns []string) ([]TaskDefinition, []Failure, error) + DeleteTaskSet func(cluster, service, taskSet string) (*TaskSet, error) + DeregisterContainerInstance func(cluster, containerInstance string, force bool) (*ContainerInstance, error) + DeregisterTaskDefinition func(taskDefinitionArn string) (*TaskDefinition, error) + DescribeCapacityProviders func(nameOrArns []string) ([]CapacityProvider, []Failure, error) + DescribeClusters func(clusterNames []string) ([]Cluster, []Failure, error) + DescribeContainerInstances func(cluster string, containerInstances []string) ([]ContainerInstance, []Failure, error) + DescribeDaemon func(daemonArn string) (*Daemon, error) + DescribeDaemonDeployments func(arns []string) ([]DaemonDeployment, []Failure, error) + DescribeDaemonRevisions func(arns []string) ([]DaemonRevision, []Failure, error) + DescribeDaemonTaskDefinition func(familyOrArn string) (*DaemonTaskDefinition, error) + DescribeExpressGatewayService func(serviceArn string) (*ExpressGatewayService, error) + DescribeServiceDeployments func(serviceDeploymentArns []string) ([]ServiceDeployment, []Failure, error) + DescribeServiceRevisions func(arns []string) ([]ServiceRevision, []Failure) + DescribeServices func(cluster string, serviceNames []string) ([]Service, []Failure, error) + DescribeTaskDefinition func(family string) (*TaskDefinition, error) + DescribeTaskSets func(cluster, service string, taskSets []string) ([]TaskSet, error) + DescribeTasks func(cluster string, taskArns []string) ([]Task, []Failure, error) + DiscoverPollEndpoint func() (endpoint, serviceConnectEndpoint, telemetryEndpoint string) + ExecuteCommand func(cluster, task, container, command string, interactive bool) (*ExecuteCommandOutput, error) + GetRegion func() string + GetTaskProtection func(cluster string, taskArns []string) ([]TaskProtection, []Failure, error) + ListAccountSettings func(name, principalArn string) ([]AccountSetting, error) + ListAttributes func(cluster, targetType, attributeName, targetID string) ([]Attribute, error) + ListClusters func() ([]Cluster, error) + ListContainerInstances func(cluster, status string) ([]string, error) + ListDaemonDeployments func(input ListDaemonDeploymentsInput) ([]DaemonDeployment, error) + ListDaemonTaskDefinitions func(input ListDaemonTaskDefinitionsInput) ([]DaemonTaskDefinition, error) + ListDaemons func(input ListDaemonsInput) ([]Daemon, error) + ListServiceDeployments func(cluster, service string) ([]string, error) + ListServices func(cluster, launchType, schedulingStrategy string) ([]string, error) + ListServicesByNamespace func(cluster, namespace string) ([]string, error) + ListTagsForResource func(resourceArn string) ([]Tag, error) + ListTaskDefinitionFamilies func(familyPrefix, status string) ([]string, error) + ListTaskDefinitions func(familyPrefix string) ([]string, error) + ListTaskDefinitionsFiltered func(input ListTaskDefinitionsInput) ([]string, error) + ListTasks func(cluster string) ([]string, error) + ListTasksFiltered func(input ListTasksInput) ([]string, error) + PutAccountSetting func(name, value, principalArn string) (*AccountSetting, error) + PutAccountSettingDefault func(name, value string) (*AccountSetting, error) + PutAttributes func(cluster string, attrs []Attribute) ([]Attribute, error) + PutClusterCapacityProviders func(cluster string, capacityProviders []string, ...) (*Cluster, error) + RegisterContainerInstance func(cluster, ec2InstanceID string) (*ContainerInstance, error) + RegisterDaemonTaskDefinition func(input RegisterDaemonTaskDefinitionInput) (*DaemonTaskDefinition, error) + RegisterTaskDefinition func(input RegisterTaskDefinitionInput) (*TaskDefinition, error) + RunTask func(input RunTaskInput) ([]Task, error) + StartTask func(input StartTaskInput) ([]Task, error) + StopServiceDeployment func(serviceDeploymentArn string) (*ServiceDeployment, error) + StopTask func(cluster, taskArn, reason string) (*Task, error) + SubmitAttachmentStateChanges func(cluster string, attachments []AttachmentStateChange) error + SubmitContainerStateChange func(input SubmitContainerStateChangeInput) error + SubmitTaskStateChange func(input SubmitTaskStateChangeInput) error + TagResource func(resourceArn string, tags []Tag) error + UntagResource func(resourceArn string, tagKeys []string) error + UpdateCapacityProvider func(input UpdateCapacityProviderInput) (*CapacityProvider, error) + UpdateCluster func(input UpdateClusterInput) (*Cluster, error) + UpdateClusterSettings func(cluster string, settings []ClusterSetting) (*Cluster, error) + UpdateContainerAgent func(cluster, containerInstance string) (*ContainerInstance, error) + UpdateContainerInstancesState func(cluster string, containerInstances []string, status string) ([]ContainerInstance, error) + UpdateDaemon func(input UpdateDaemonInput) (*Daemon, error) + UpdateExpressGatewayService func(input UpdateExpressGatewayServiceInput) (*ExpressGatewayService, error) + UpdateService func(input UpdateServiceInput) (*Service, error) + UpdateServicePrimaryTaskSet func(cluster, service, primaryTaskSet string) (*TaskSet, error) + UpdateTaskProtection func(cluster string, taskArns []string, protectionEnabled bool, ...) ([]TaskProtection, []Failure, error) + UpdateTaskSet func(cluster, service, taskSet string, scale TaskSetScale) (*TaskSet, error) + type CapacityProvider struct + AutoScalingGroupProvider *AutoScalingGroupProvider + CapacityProviderArn string + CreatedAt time.Time + Name string + Status string + Tags []Tag + UpdateStatus string + UpdateStatusReason string + type CapacityProviderStrategyItem struct + Base int + CapacityProvider string + Weight int + type Cluster struct + ActiveServicesCount int + CapacityProviders []string + ClusterArn string + ClusterName string + CreatedAt time.Time + DefaultCapacityProviderStrategy []CapacityProviderStrategyItem + PendingTasksCount int + RegisteredContainerInstancesCount int + RunningTasksCount int + Settings []ClusterSetting + Status string + type ClusterSetting struct + Name string + Value string + type Container struct + CPU string + ContainerArn string + ExitCode *int + HealthStatus string + Image string + ImageDigest string + LastStatus string + Memory string + MemoryReservation string + Name string + NetworkBindings []NetworkBinding + NetworkInterfaces []NetworkInterface + Reason string + RuntimeID string + TaskArn string + type ContainerDefinition struct + CPU int + Command []string + DependsOn []ContainerDependency + DisableNetworking bool + EntryPoint []string + Environment []KeyValuePair + EnvironmentFiles []EnvironmentFile + Essential bool + FirelensConfiguration *FirelensConfiguration + HealthCheck *HealthCheck + Image string + LogConfiguration *LogConfiguration + Memory int + MemoryReservation int + MountPoints []MountPoint + Name string + PortMappings []PortMapping + Privileged bool + ReadonlyRootFilesystem bool + RepositoryCredentials *RepositoryCredentials + ResourceRequirements []ResourceRequirement + Secrets []SecretReference + VolumesFrom []VolumeFrom + type ContainerDependency struct + Condition string + ContainerName string + type ContainerInstance struct + AgentConnected bool + AgentUpdateStatus string + ClusterArn string + ContainerInstanceArn string + EC2InstanceID string + PendingTasksCount int + RegisteredAt time.Time + RunningTasksCount int + Status string + Version int64 + type ContainerOverride struct + CPU *int + Command []string + Environment []KeyValuePair + Memory *int + Name string + Secrets []SecretReference + type ContainerStateChangeItem struct + ContainerName string + ExitCode *int + ImageDigest string + NetworkBindings []NetworkBinding + Reason string + RuntimeID string + type CreateCapacityProviderInput struct + AutoScalingGroupProvider *AutoScalingGroupProvider + Name string + Tags []Tag + type CreateClusterInput struct + CapacityProviders []string + ClusterName string + DefaultCapacityProviderStrategy []CapacityProviderStrategyItem + Settings []ClusterSetting + Tags []Tag + type CreateDaemonInput struct + CapacityProviderArns []string + ClusterArn string + DaemonName string + DaemonTaskDefinitionArn string + DeploymentConfiguration *DaemonDeploymentConfiguration + EnableECSManagedTags bool + EnableExecuteCommand bool + PropagateTags string + Tags []Tag + type CreateExpressGatewayServiceInput struct + Cluster string + ExecutionRoleArn string + InfrastructureRoleArn string + ServiceName string + Tags []Tag + type CreateServiceInput struct + CapacityProviderStrategy []CapacityProviderStrategyItem + Cluster string + DeploymentConfiguration *DeploymentConfiguration + DeploymentController *DeploymentController + DesiredCount int + EnableExecuteCommand bool + LaunchType string + LoadBalancers []LoadBalancer + NetworkConfiguration *NetworkConfiguration + PlacementConstraints []PlacementConstraint + PlacementStrategy []PlacementStrategy + PropagateTags string + SchedulingStrategy string + ServiceConnectConfiguration *ServiceConnectConfiguration + ServiceName string + ServiceRegistries []ServiceRegistry + Tags []Tag + TaskDefinition string + type CreateTaskSetInput struct + Cluster string + ExternalID string + LaunchType string + LoadBalancers []LoadBalancer + NetworkConfiguration *NetworkConfiguration + PlatformVersion string + Scale *TaskSetScale + Service string + ServiceRegistries []ServiceRegistry + TaskDefinition string + type Daemon struct + CapacityProviderArns []string + ClusterArn string + CreatedAt time.Time + CurrentDaemonRevisionArn string + DaemonArn string + DaemonName string + DaemonTaskDefinitionArn string + DeploymentArn string + DeploymentConfiguration *DaemonDeploymentConfiguration + EnableECSManagedTags bool + EnableExecuteCommand bool + PropagateTags string + Status string + Tags []Tag + UpdatedAt time.Time + type DaemonAlarmConfiguration struct + AlarmNames []string + Enable bool + type DaemonContainerDefinition struct + CPU int + Command []string + DependsOn []ContainerDependency + EntryPoint []string + Environment []KeyValuePair + EnvironmentFiles []EnvironmentFile + Essential bool + FirelensConfiguration *FirelensConfiguration + HealthCheck *HealthCheck + Image string + Interactive bool + LogConfiguration *LogConfiguration + Memory int + MemoryReservation int + MountPoints []MountPoint + Name string + Privileged bool + PseudoTerminal bool + ReadonlyRootFilesystem bool + RepositoryCredentials *RepositoryCredentials + Secrets []SecretReference + StartTimeout int + StopTimeout int + User string + WorkingDirectory string + type DaemonDeployment struct + ClusterArn string + CreatedAt time.Time + DaemonArn string + DaemonDeploymentArn string + DeploymentConfiguration *DaemonDeploymentConfiguration + FinishedAt *time.Time + StartedAt *time.Time + Status string + StatusReason string + TargetDaemonRevisionArn string + type DaemonDeploymentConfiguration struct + Alarms *DaemonAlarmConfiguration + BakeTimeInMinutes int + DrainPercent float64 + type DaemonRevision struct + ClusterArn string + CreatedAt time.Time + DaemonArn string + DaemonRevisionArn string + DaemonTaskDefinitionArn string + EnableECSManagedTags bool + EnableExecuteCommand bool + PropagateTags string + type DaemonTaskDefinition struct + CPU string + ContainerDefinitions []DaemonContainerDefinition + DaemonTaskDefinitionArn string + DeleteRequestedAt *time.Time + ExecutionRoleArn string + Family string + Memory string + RegisteredAt time.Time + RegisteredBy string + Revision int + Status string + TaskRoleArn string + Volumes []DaemonVolume + type DaemonVolume struct + Host *HostVolumeProperties + Name string + type Deployment struct + CreatedAt *float64 + DesiredCount int + FailedTasks int + ID string + LaunchType string + PendingCount int + PlatformVersion string + RolloutState string + RolloutStateReason string + RunningCount int + ServiceRevisionArn string + Status string + TaskDefinition string + UpdatedAt *float64 + type DeploymentAlarms struct + AlarmNames []string + Enable bool + Rollback bool + type DeploymentCircuitBreaker struct + Enable bool + Rollback bool + type DeploymentConfiguration struct + DeploymentCircuitBreaker *DeploymentCircuitBreaker + MaximumPercent *int + MinimumHealthyPercent *int + type DeploymentController struct + Type string + type EFSAuthorizationConfig struct + AccessPointID string + IAM string + type EFSVolumeConfiguration struct + AuthorizationConfig *EFSAuthorizationConfig + FileSystemID string + RootDirectory string + TransitEncryption string + type ELBTarget struct + ID string + Port int + type ELBv2TargetRegistrar interface + DeregisterTargets func(ctx context.Context, targetGroupARN string, targets []ELBTarget) error + RegisterTargets func(ctx context.Context, targetGroupARN string, targets []ELBTarget) error + type EnvironmentFile struct + Type string + Value string + type EphemeralStorage struct + SizeInGiB int + type ExecuteCommandOutput struct + ClusterArn string + ContainerArn string + ContainerName string + Interactive bool + Session Session + TaskArn string + type ExpressGatewayService struct + Cluster string + CreatedAt time.Time + ExecutionRoleArn string + InfrastructureRoleArn string + ServiceArn string + ServiceName string + Status string + Tags []Tag + type Failure struct + Arn string + Detail string + Reason string + type FirelensConfiguration struct + Options map[string]string + Type string + type Handler struct + Backend Backend + func NewHandler(backend Backend) *Handler + func (h *Handler) ChaosOperations() []string + func (h *Handler) ChaosRegions() []string + func (h *Handler) ChaosServiceName() string + func (h *Handler) ExecuteFISAction(_ context.Context, action service.FISActionExecution) error + func (h *Handler) ExtractOperation(c *echo.Context) string + func (h *Handler) ExtractResource(c *echo.Context) string + func (h *Handler) FISActions() []service.FISActionDefinition + func (h *Handler) GetSupportedOperations() []string + func (h *Handler) Handler() echo.HandlerFunc + func (h *Handler) MatchPriority() int + func (h *Handler) Name() string + func (h *Handler) Purge(ctx context.Context, cutoff time.Time) + func (h *Handler) Reset() + func (h *Handler) Restore(ctx context.Context, data []byte) error + func (h *Handler) RouteMatcher() service.Matcher + func (h *Handler) Snapshot(ctx context.Context) []byte + type HealthCheck struct + Command []string + Interval int + Retries int + StartPeriod int + Timeout int + type HostVolumeProperties struct + SourcePath string + type InMemoryBackend struct + func NewInMemoryBackend(accountID, region string, runner TaskRunner) *InMemoryBackend + func (b *InMemoryBackend) AddAccountSettingInternal(_ string, setting *AccountSetting) + func (b *InMemoryBackend) AddAttributeInternal(cluster string, attr *Attribute) + func (b *InMemoryBackend) AddCapacityProviderInternal(cp *CapacityProvider) + func (b *InMemoryBackend) AddServiceDeploymentInternal(sd *ServiceDeployment) + func (b *InMemoryBackend) ContinueServiceDeployment(serviceDeploymentArn, hookID, action string) (*ServiceDeployment, error) + func (b *InMemoryBackend) CountRunningTasksForService(clusterName, serviceName string) int + func (b *InMemoryBackend) CreateCapacityProvider(input CreateCapacityProviderInput) (*CapacityProvider, error) + func (b *InMemoryBackend) CreateCluster(input CreateClusterInput) (*Cluster, error) + func (b *InMemoryBackend) CreateDaemon(input CreateDaemonInput) (*Daemon, error) + func (b *InMemoryBackend) CreateExpressGatewayService(input CreateExpressGatewayServiceInput) (*ExpressGatewayService, error) + func (b *InMemoryBackend) CreateService(input CreateServiceInput) (*Service, error) + func (b *InMemoryBackend) CreateTaskSet(input CreateTaskSetInput) (*TaskSet, error) + func (b *InMemoryBackend) DeleteAccountSetting(name, principalArn string) (*AccountSetting, error) + func (b *InMemoryBackend) DeleteAttributes(cluster string, attrs []Attribute) ([]Attribute, error) + func (b *InMemoryBackend) DeleteCapacityProvider(nameOrArn string) (*CapacityProvider, error) + func (b *InMemoryBackend) DeleteCluster(clusterName string) (*Cluster, error) + func (b *InMemoryBackend) DeleteDaemon(daemonArn string) (*Daemon, error) + func (b *InMemoryBackend) DeleteDaemonTaskDefinition(familyOrArn string) (*DaemonTaskDefinition, error) + func (b *InMemoryBackend) DeleteExpressGatewayService(serviceArn string) (*ExpressGatewayService, error) + func (b *InMemoryBackend) DeleteService(cluster, serviceName string) (*Service, error) + func (b *InMemoryBackend) DeleteTaskDefinitions(taskDefinitionArns []string) ([]TaskDefinition, []Failure, error) + func (b *InMemoryBackend) DeleteTaskSet(cluster, service, taskSet string) (*TaskSet, error) + func (b *InMemoryBackend) DeregisterContainerInstance(cluster, containerInstance string, force bool) (*ContainerInstance, error) + func (b *InMemoryBackend) DeregisterTaskDefinition(taskDefinitionArn string) (*TaskDefinition, error) + func (b *InMemoryBackend) DescribeCapacityProviders(nameOrArns []string) ([]CapacityProvider, []Failure, error) + func (b *InMemoryBackend) DescribeClusters(clusterNames []string) ([]Cluster, []Failure, error) + func (b *InMemoryBackend) DescribeContainerInstances(cluster string, containerInstances []string) ([]ContainerInstance, []Failure, error) + func (b *InMemoryBackend) DescribeDaemon(daemonArn string) (*Daemon, error) + func (b *InMemoryBackend) DescribeDaemonDeployments(arns []string) ([]DaemonDeployment, []Failure, error) + func (b *InMemoryBackend) DescribeDaemonRevisions(arns []string) ([]DaemonRevision, []Failure, error) + func (b *InMemoryBackend) DescribeDaemonTaskDefinition(familyOrArn string) (*DaemonTaskDefinition, error) + func (b *InMemoryBackend) DescribeExpressGatewayService(serviceArn string) (*ExpressGatewayService, error) + func (b *InMemoryBackend) DescribeServiceDeployments(serviceDeploymentArns []string) ([]ServiceDeployment, []Failure, error) + func (b *InMemoryBackend) DescribeServiceRevisions(arns []string) ([]ServiceRevision, []Failure) + func (b *InMemoryBackend) DescribeServices(cluster string, serviceNames []string) ([]Service, []Failure, error) + func (b *InMemoryBackend) DescribeTaskDefinition(familyOrArn string) (*TaskDefinition, error) + func (b *InMemoryBackend) DescribeTaskSets(cluster, service string, taskSets []string) ([]TaskSet, error) + func (b *InMemoryBackend) DescribeTasks(cluster string, taskArns []string) ([]Task, []Failure, error) + func (b *InMemoryBackend) DiscoverPollEndpoint() (string, string, string) + func (b *InMemoryBackend) ExecuteCommand(cluster, task, container, command string, interactive bool) (*ExecuteCommandOutput, error) + func (b *InMemoryBackend) GetRegion() string + func (b *InMemoryBackend) GetTaskProtection(cluster string, taskArns []string) ([]TaskProtection, []Failure, error) + func (b *InMemoryBackend) ListAccountSettings(name, principalArn string) ([]AccountSetting, error) + func (b *InMemoryBackend) ListAttributes(cluster, targetType, attributeName, targetID string) ([]Attribute, error) + func (b *InMemoryBackend) ListClusters() ([]Cluster, error) + func (b *InMemoryBackend) ListContainerInstances(cluster, status string) ([]string, error) + func (b *InMemoryBackend) ListDaemonDeployments(input ListDaemonDeploymentsInput) ([]DaemonDeployment, error) + func (b *InMemoryBackend) ListDaemonTaskDefinitions(input ListDaemonTaskDefinitionsInput) ([]DaemonTaskDefinition, error) + func (b *InMemoryBackend) ListDaemons(input ListDaemonsInput) ([]Daemon, error) + func (b *InMemoryBackend) ListServiceDeployments(cluster, service string) ([]string, error) + func (b *InMemoryBackend) ListServices(cluster, launchType, schedulingStrategy string) ([]string, error) + func (b *InMemoryBackend) ListServicesByNamespace(cluster, namespace string) ([]string, error) + func (b *InMemoryBackend) ListTagsForResource(resourceArn string) ([]Tag, error) + func (b *InMemoryBackend) ListTaskDefinitionFamilies(familyPrefix, status string) ([]string, error) + func (b *InMemoryBackend) ListTaskDefinitions(familyPrefix string) ([]string, error) + func (b *InMemoryBackend) ListTaskDefinitionsFiltered(input ListTaskDefinitionsInput) ([]string, error) + func (b *InMemoryBackend) ListTasks(cluster string) ([]string, error) + func (b *InMemoryBackend) ListTasksFiltered(input ListTasksInput) ([]string, error) + func (b *InMemoryBackend) Purge(_ context.Context, cutoff time.Time) + func (b *InMemoryBackend) PutAccountSetting(name, value, principalArn string) (*AccountSetting, error) + func (b *InMemoryBackend) PutAccountSettingDefault(name, value string) (*AccountSetting, error) + func (b *InMemoryBackend) PutAttributes(cluster string, attrs []Attribute) ([]Attribute, error) + func (b *InMemoryBackend) PutClusterCapacityProviders(cluster string, capacityProviders []string, ...) (*Cluster, error) + func (b *InMemoryBackend) RegisterClusterDeleteHook(fn func(clusterName string)) + func (b *InMemoryBackend) RegisterContainerInstance(cluster, ec2InstanceID string) (*ContainerInstance, error) + func (b *InMemoryBackend) RegisterDaemonTaskDefinition(input RegisterDaemonTaskDefinitionInput) (*DaemonTaskDefinition, error) + func (b *InMemoryBackend) RegisterTaskDefinition(input RegisterTaskDefinitionInput) (*TaskDefinition, error) + func (b *InMemoryBackend) Reset() + func (b *InMemoryBackend) Restore(ctx context.Context, data []byte) error + func (b *InMemoryBackend) RunTask(input RunTaskInput) ([]Task, error) + func (b *InMemoryBackend) SFNRunTask(_ context.Context, input map[string]any) (any, error) + func (b *InMemoryBackend) SetELBv2Registrar(r ELBv2TargetRegistrar) + func (b *InMemoryBackend) SetStartDelay(d time.Duration) + func (b *InMemoryBackend) SetStopDelay(d time.Duration) + func (b *InMemoryBackend) Snapshot(ctx context.Context) []byte + func (b *InMemoryBackend) StartTask(input StartTaskInput) ([]Task, error) + func (b *InMemoryBackend) StartTaskForService(clusterName, serviceName, taskDefinitionArn string) error + func (b *InMemoryBackend) StopOldestServiceTask(clusterName, serviceName string) error + func (b *InMemoryBackend) StopServiceDeployment(serviceDeploymentArn string) (*ServiceDeployment, error) + func (b *InMemoryBackend) StopTask(cluster, taskArn, reason string) (*Task, error) + func (b *InMemoryBackend) SubmitAttachmentStateChanges(cluster string, attachments []AttachmentStateChange) error + func (b *InMemoryBackend) SubmitContainerStateChange(input SubmitContainerStateChangeInput) error + func (b *InMemoryBackend) SubmitTaskStateChange(input SubmitTaskStateChangeInput) error + func (b *InMemoryBackend) TagResource(resourceArn string, tags []Tag) error + func (b *InMemoryBackend) UntagResource(resourceArn string, tagKeys []string) error + func (b *InMemoryBackend) UpdateCapacityProvider(input UpdateCapacityProviderInput) (*CapacityProvider, error) + func (b *InMemoryBackend) UpdateCluster(input UpdateClusterInput) (*Cluster, error) + func (b *InMemoryBackend) UpdateClusterSettings(cluster string, settings []ClusterSetting) (*Cluster, error) + func (b *InMemoryBackend) UpdateContainerAgent(cluster, containerInstance string) (*ContainerInstance, error) + func (b *InMemoryBackend) UpdateContainerInstancesState(cluster string, containerInstances []string, status string) ([]ContainerInstance, error) + func (b *InMemoryBackend) UpdateDaemon(input UpdateDaemonInput) (*Daemon, error) + func (b *InMemoryBackend) UpdateExpressGatewayService(input UpdateExpressGatewayServiceInput) (*ExpressGatewayService, error) + func (b *InMemoryBackend) UpdateService(input UpdateServiceInput) (*Service, error) + func (b *InMemoryBackend) UpdateServicePrimaryTaskSet(cluster, service, primaryTaskSet string) (*TaskSet, error) + func (b *InMemoryBackend) UpdateTaskProtection(cluster string, taskArns []string, protectionEnabled bool, ...) ([]TaskProtection, []Failure, error) + func (b *InMemoryBackend) UpdateTaskSet(cluster, service, taskSet string, scale TaskSetScale) (*TaskSet, error) + type InferenceAccelerator struct + DeviceName string + DeviceType string + type Janitor struct + Backend *InMemoryBackend + Interval time.Duration + TaskTimeout time.Duration + func NewJanitor(backend *InMemoryBackend, interval time.Duration) *Janitor + func (j *Janitor) Run(ctx context.Context) + func (j *Janitor) SetTaskTTL(d time.Duration) + func (j *Janitor) SweepOnce(ctx context.Context) + type KeyValuePair struct + Name string + Value string + type ListDaemonDeploymentsInput struct + DaemonArn string + Status []string + type ListDaemonTaskDefinitionsInput struct + Family string + FamilyPrefix string + Status string + type ListDaemonsInput struct + CapacityProviderArns []string + ClusterArn string + type ListTaskDefinitionsInput struct + FamilyPrefix string + Status string + type ListTasksInput struct + Cluster string + ContainerInstance string + DesiredStatus string + Family string + LaunchType string + ServiceName string + StartedBy string + type LoadBalancer struct + ContainerName string + ContainerPort int + LoadBalancerName string + TargetGroupArn string + type LogConfiguration struct + LogDriver string + Options map[string]string + SecretOptions []SecretOption + type ManagedScaling struct + InstanceWarmupPeriod int + MaximumScalingStepSize int + MinimumScalingStepSize int + Status string + TargetCapacityPercent int + TargetCapacityUtilization int + type MountPoint struct + ContainerPath string + ReadOnly bool + SourceVolume string + type NetworkBinding struct + BindIP string + ContainerPort int + HostPort int + Protocol string + type NetworkConfiguration struct + AwsvpcConfiguration *AwsvpcConfiguration + type NetworkInterface struct + AttachmentID string + Ipv6Address string + PrivateIpv4Address string + type PlacementConstraint struct + Expression string + Type string + type PlacementStrategy struct + Field string + Type string + type PortMapping struct + AppProtocol string + ContainerPort int + ContainerPortRange string + HostPort int + Name string + Protocol string + type Provider struct + func (p *Provider) Init(appCtx *service.AppContext) (service.Registerable, error) + func (p *Provider) Name() string + type Reconciler struct + func NewReconciler(backend *InMemoryBackend) *Reconciler + func (r *Reconciler) EvictCluster(clusterName string) + func (r *Reconciler) RunOnce(ctx context.Context) + func (r *Reconciler) SemCount() int + func (r *Reconciler) Start(ctx context.Context) + type RegisterDaemonTaskDefinitionInput struct + CPU string + ContainerDefinitions []DaemonContainerDefinition + ExecutionRoleArn string + Family string + Memory string + Tags []Tag + TaskRoleArn string + Volumes []DaemonVolume + type RegisterTaskDefinitionInput struct + CPU string + ContainerDefinitions []ContainerDefinition + EphemeralStorage *EphemeralStorage + ExecutionRoleArn string + Family string + InferenceAccelerators []InferenceAccelerator + Memory string + NetworkMode string + PlacementConstraints []PlacementConstraint + PlatformFamily string + RequiresCompatibilities []string + RuntimePlatform *RuntimePlatform + Tags []Tag + TaskRoleArn string + Volumes []Volume + type RepositoryCredentials struct + CredentialsParameter string + type ResourceRequirement struct + Type string + Value string + type RunTaskInput struct + Cluster string + Count int + EnableECSManagedTags bool + EnableExecuteCommand bool + Group string + LaunchType string + NetworkConfiguration *NetworkConfiguration + Overrides *TaskOverride + PlacementConstraints []PlacementConstraint + PlacementStrategy []PlacementStrategy + PlatformVersion string + PropagateTags string + StartedBy string + Tags []Tag + TaskDefinition string + type RuntimePlatform struct + CPUArchitecture string + OperatingSystemFamily string + type SecretOption struct + Name string + ValueFrom string + type SecretReference struct + Name string + ValueFrom string + type Service struct + CapacityProviderStrategy []CapacityProviderStrategyItem + ClusterArn string + CreatedAt time.Time + DeploymentConfiguration *DeploymentConfiguration + DeploymentController *DeploymentController + Deployments []Deployment + DesiredCount int + EnableExecuteCommand bool + LaunchType string + LoadBalancers []LoadBalancer + NetworkConfiguration *NetworkConfiguration + PendingCount int + PlacementConstraints []PlacementConstraint + PlacementStrategy []PlacementStrategy + PropagateTags string + RunningCount int + SchedulingStrategy string + ServiceArn string + ServiceConnectConfiguration *ServiceConnectConfiguration + ServiceName string + ServiceRegistries []ServiceRegistry + Status string + Tags []Tag + TaskDefinition string + type ServiceConnectClientAlias struct + DNSName string + Port int + type ServiceConnectConfiguration struct + Enabled bool + Namespace string + Services []ServiceConnectService + type ServiceConnectService struct + ClientAliases []ServiceConnectClientAlias + DiscoveryName string + PortName string + type ServiceDeployment struct + ClusterArn string + CreatedAt *time.Time + ServiceArn string + ServiceDeploymentArn string + Status string + StatusReason string + UpdatedAt *time.Time + type ServiceRegistry struct + ContainerName string + ContainerPort int + Port int + RegistryArn string + type ServiceRevision struct + CapacityProviderStrategy []CapacityProviderStrategyItem + ClusterArn string + CreatedAt *float64 + LaunchType string + LoadBalancers []LoadBalancer + NetworkConfiguration *NetworkConfiguration + PlatformVersion string + ServiceArn string + ServiceConnectConfiguration *ServiceConnectConfiguration + ServiceRegistries []ServiceRegistry + ServiceRevisionArn string + TaskDefinition string + type Session struct + SessionID string + StreamURL string + TokenValue string + type Snapshottable interface + Restore func(context.Context, []byte) error + Snapshot func(ctx context.Context) []byte + type StartTaskInput struct + Cluster string + ContainerInstances []string + Group string + StartedBy string + TaskDefinition string + type SubmitContainerStateChangeInput struct + Cluster string + ContainerName string + ExitCode *int + NetworkBindings []NetworkBinding + Reason string + RuntimeID string + Status string + Task string + type SubmitTaskStateChangeInput struct + Attachments []AttachmentStateChange + Cluster string + Containers []ContainerStateChangeItem + Reason string + Status string + Task string + type Tag struct + Key string + Value string + type Task struct + Attachments []TaskAttachment + ClusterArn string + Connectivity string + ConnectivityAt *time.Time + ContainerInstanceArn string + Containers []Container + DesiredStatus string + EnableExecuteCommand bool + Group string + LastStatus string + LaunchType string + NetworkConfiguration *NetworkConfiguration + Overrides *TaskOverride + PlatformFamily string + PlatformVersion string + PropagateTags string + RuntimeID string + StartedAt *time.Time + StartedBy string + StoppedAt *time.Time + StoppedReason string + Tags []Tag + TaskArn string + TaskDefinitionArn string + TaskRoleArn string + type TaskAttachment struct + Details []KeyValuePair + ID string + Status string + Type string + type TaskDefinition struct + CPU string + ContainerDefinitions []ContainerDefinition + EphemeralStorage *EphemeralStorage + ExecutionRoleArn string + Family string + InferenceAccelerators []InferenceAccelerator + Memory string + NetworkMode string + PlacementConstraints []PlacementConstraint + PlatformFamily string + RegisteredAt time.Time + RequiresCompatibilities []string + Revision int + RuntimePlatform *RuntimePlatform + Status string + TaskDefinitionArn string + TaskRoleArn string + Volumes []Volume + type TaskOverride struct + CPU string + ContainerOverrides []ContainerOverride + ExecutionRoleArn string + Memory string + TaskRoleArn string + type TaskProtection struct + ExpirationDate *time.Time + ProtectionEnabled bool + TaskArn string + type TaskRunner interface + RunTask func(task *Task, td *TaskDefinition) error + StopTask func(task *Task) error + func NewDockerRunner(ctx context.Context) (TaskRunner, error) + func NewNoopRunner() TaskRunner + type TaskSet struct + ClusterArn string + CreatedAt time.Time + ExternalID string + ID string + LaunchType string + LoadBalancers []LoadBalancer + NetworkConfiguration *NetworkConfiguration + PlatformVersion string + Scale TaskSetScale + ServiceArn string + ServiceRegistries []ServiceRegistry + StabilityStatus string + StabilityStatusAt time.Time + Status string + TaskDefinition string + TaskSetArn string + UpdatedAt time.Time + type TaskSetScale struct + Unit string + Value float64 + type UpdateCapacityProviderInput struct + AutoScalingGroupProvider *AutoScalingGroupProvider + Name string + Status string + Tags []Tag + type UpdateClusterInput struct + CapacityProviders []string + Cluster string + DefaultCapacityProviderStrategy []CapacityProviderStrategyItem + Settings []ClusterSetting + type UpdateDaemonInput struct + CapacityProviderArns []string + DaemonArn string + DaemonTaskDefinitionArn string + DeploymentConfiguration *DaemonDeploymentConfiguration + EnableECSManagedTags bool + EnableExecuteCommand bool + PropagateTags string + type UpdateExpressGatewayServiceInput struct + ExecutionRoleArn string + InfrastructureRoleArn string + ServiceArn string + type UpdateServiceInput struct + CapacityProviderStrategy []CapacityProviderStrategyItem + Cluster string + DeploymentConfiguration *DeploymentConfiguration + DesiredCount *int + EnableExecuteCommand *bool + LoadBalancers []LoadBalancer + NetworkConfiguration *NetworkConfiguration + PlacementConstraints []PlacementConstraint + PlacementStrategy []PlacementStrategy + PropagateTags string + Service string + ServiceConnectConfiguration *ServiceConnectConfiguration + TaskDefinition string + type Volume struct + ConfiguredAtLaunch bool + EFSVolumeConfiguration *EFSVolumeConfiguration + Host *HostVolumeProperties + Name string + type VolumeFrom struct + ReadOnly bool + SourceContainer string
Go to main page