ecs

package
v0.9.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 22, 2026 License: Apache-2.0 Imports: 22 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ListClusters 

func ListClusters(ctx core.ListResourcesContext, resourceType string) ([]core.IntegrationResource, error)

func ListServices 

func ListServices(ctx core.ListResourcesContext, resourceType string) ([]core.IntegrationResource, error)

func ListTaskDefinitions 

func ListTaskDefinitions(ctx core.ListResourcesContext, resourceType string) ([]core.IntegrationResource, error)

func ListTasks 

func ListTasks(ctx core.ListResourcesContext, resourceType string) ([]core.IntegrationResource, error)

Types

type Client 

type Client struct {
	// contains filtered or unexported fields
}

func NewClient 

func NewClient(httpCtx core.HTTPContext, credentials *aws.Credentials, region string) *Client

func (*Client) CreateService 

func (c *Client) CreateService(input CreateServiceInput) (*CreateServiceResponse, error)

func (*Client) DescribeServices 

func (c *Client) DescribeServices(cluster string, services []string) (*DescribeServicesResponse, error)

func (*Client) DescribeTasks 

func (c *Client) DescribeTasks(cluster string, tasks []string) (*DescribeTasksResponse, error)

func (*Client) ExecuteCommand 

func (c *Client) ExecuteCommand(input ExecuteCommandInput) (*ExecuteCommandResponse, error)

func (*Client) ListClusters 

func (c *Client) ListClusters() ([]Cluster, error)

func (*Client) ListServices 

func (c *Client) ListServices(cluster string) ([]string, error)

func (*Client) ListTaskDefinitions 

func (c *Client) ListTaskDefinitions() ([]string, error)

func (*Client) ListTasks 

func (c *Client) ListTasks(cluster string) ([]string, error)

func (*Client) RunTask 

func (c *Client) RunTask(input RunTaskInput) (*RunTaskResponse, error)

func (*Client) StopTask 

func (c *Client) StopTask(cluster string, task string, reason string) (*StopTaskResponse, error)

func (*Client) UpdateService 

func (c *Client) UpdateService(input UpdateServiceInput) (*UpdateServiceResponse, error)

type Cluster 

type Cluster struct {
	ClusterArn  string `json:"clusterArn"`
	ClusterName string `json:"clusterName"`
	Status      string `json:"status"`
}

type CreateService 

type CreateService struct{}

func (*CreateService) Actions 

func (c *CreateService) Actions() []core.Action

func (*CreateService) Cancel 

func (c *CreateService) Cancel(ctx core.ExecutionContext) error

func (*CreateService) Cleanup 

func (c *CreateService) Cleanup(ctx core.SetupContext) error

func (*CreateService) Color 

func (c *CreateService) Color() string

func (*CreateService) Configuration 

func (c *CreateService) Configuration() []configuration.Field

func (*CreateService) Description 

func (c *CreateService) Description() string

func (*CreateService) Documentation 

func (c *CreateService) Documentation() string

func (*CreateService) ExampleOutput 

func (c *CreateService) ExampleOutput() map[string]any

func (*CreateService) Execute 

func (c *CreateService) Execute(ctx core.ExecutionContext) error

func (*CreateService) HandleAction 

func (c *CreateService) HandleAction(ctx core.ActionContext) error

func (*CreateService) HandleWebhook 

func (c *CreateService) HandleWebhook(ctx core.WebhookRequestContext) (int, error)

func (*CreateService) Icon 

func (c *CreateService) Icon() string

func (*CreateService) Label 

func (c *CreateService) Label() string

func (*CreateService) Name 

func (c *CreateService) Name() string

func (*CreateService) OutputChannels 

func (c *CreateService) OutputChannels(configuration any) []core.OutputChannel

func (*CreateService) ProcessQueueItem 

func (c *CreateService) ProcessQueueItem(ctx core.ProcessQueueContext) (*uuid.UUID, error)

func (*CreateService) Setup 

func (c *CreateService) Setup(ctx core.SetupContext) error

type CreateServiceConfiguration 

type CreateServiceConfiguration struct {
	ServiceMutationConfiguration `mapstructure:",squash"`
	ServiceName                  string `json:"serviceName" mapstructure:"serviceName"`
	SchedulingStrategy           string `json:"schedulingStrategy" mapstructure:"schedulingStrategy"`
	ClientToken                  string `json:"clientToken" mapstructure:"clientToken"`
}

type CreateServiceInput 

type CreateServiceInput struct {
	ServiceName        string
	SchedulingStrategy string
	ClientToken        string
	ServiceMutation    ServiceMutationInput
}

type CreateServiceNodeMetadata 

type CreateServiceNodeMetadata struct {
	Region         string `json:"region" mapstructure:"region"`
	Cluster        string `json:"cluster" mapstructure:"cluster"`
	ServiceName    string `json:"serviceName" mapstructure:"serviceName"`
	TaskDefinition string `json:"taskDefinition" mapstructure:"taskDefinition"`
}

type CreateServiceResponse 

type CreateServiceResponse struct {
	Service Service `json:"service"`
}

type DescribeService 

type DescribeService struct{}

func (*DescribeService) Actions 

func (c *DescribeService) Actions() []core.Action

func (*DescribeService) Cancel 

func (c *DescribeService) Cancel(ctx core.ExecutionContext) error

func (*DescribeService) Cleanup 

func (c *DescribeService) Cleanup(ctx core.SetupContext) error

func (*DescribeService) Color 

func (c *DescribeService) Color() string

func (*DescribeService) Configuration 

func (c *DescribeService) Configuration() []configuration.Field

func (*DescribeService) Description 

func (c *DescribeService) Description() string

func (*DescribeService) Documentation 

func (c *DescribeService) Documentation() string

func (*DescribeService) ExampleOutput 

func (c *DescribeService) ExampleOutput() map[string]any

func (*DescribeService) Execute 

func (c *DescribeService) Execute(ctx core.ExecutionContext) error

func (*DescribeService) HandleAction 

func (c *DescribeService) HandleAction(ctx core.ActionContext) error

func (*DescribeService) HandleWebhook 

func (c *DescribeService) HandleWebhook(ctx core.WebhookRequestContext) (int, error)

func (*DescribeService) Icon 

func (c *DescribeService) Icon() string

func (*DescribeService) Label 

func (c *DescribeService) Label() string

func (*DescribeService) Name 

func (c *DescribeService) Name() string

func (*DescribeService) OutputChannels 

func (c *DescribeService) OutputChannels(configuration any) []core.OutputChannel

func (*DescribeService) ProcessQueueItem 

func (c *DescribeService) ProcessQueueItem(ctx core.ProcessQueueContext) (*uuid.UUID, error)

func (*DescribeService) Setup 

func (c *DescribeService) Setup(ctx core.SetupContext) error

type DescribeServiceConfiguration 

type DescribeServiceConfiguration struct {
	Region  string `json:"region" mapstructure:"region"`
	Cluster string `json:"cluster" mapstructure:"cluster"`
	Service string `json:"service" mapstructure:"service"`
}

type DescribeServicesResponse 

type DescribeServicesResponse struct {
	Services []Service `json:"services"`
	Failures []Failure `json:"failures"`
}

type DescribeTasksResponse 

type DescribeTasksResponse struct {
	Tasks    []Task    `json:"tasks"`
	Failures []Failure `json:"failures"`
}

type ExecuteCommand 

type ExecuteCommand struct{}

func (*ExecuteCommand) Actions 

func (c *ExecuteCommand) Actions() []core.Action

func (*ExecuteCommand) Cancel 

func (c *ExecuteCommand) Cancel(ctx core.ExecutionContext) error

func (*ExecuteCommand) Cleanup 

func (c *ExecuteCommand) Cleanup(ctx core.SetupContext) error

func (*ExecuteCommand) Color 

func (c *ExecuteCommand) Color() string

func (*ExecuteCommand) Configuration 

func (c *ExecuteCommand) Configuration() []configuration.Field

func (*ExecuteCommand) Description 

func (c *ExecuteCommand) Description() string

func (*ExecuteCommand) Documentation 

func (c *ExecuteCommand) Documentation() string

func (*ExecuteCommand) ExampleOutput 

func (c *ExecuteCommand) ExampleOutput() map[string]any

func (*ExecuteCommand) Execute 

func (c *ExecuteCommand) Execute(ctx core.ExecutionContext) error

func (*ExecuteCommand) HandleAction 

func (c *ExecuteCommand) HandleAction(ctx core.ActionContext) error

func (*ExecuteCommand) HandleWebhook 

func (c *ExecuteCommand) HandleWebhook(ctx core.WebhookRequestContext) (int, error)

func (*ExecuteCommand) Icon 

func (c *ExecuteCommand) Icon() string

func (*ExecuteCommand) Label 

func (c *ExecuteCommand) Label() string

func (*ExecuteCommand) Name 

func (c *ExecuteCommand) Name() string

func (*ExecuteCommand) OutputChannels 

func (c *ExecuteCommand) OutputChannels(configuration any) []core.OutputChannel

func (*ExecuteCommand) ProcessQueueItem 

func (c *ExecuteCommand) ProcessQueueItem(ctx core.ProcessQueueContext) (*uuid.UUID, error)

func (*ExecuteCommand) Setup 

func (c *ExecuteCommand) Setup(ctx core.SetupContext) error

type ExecuteCommandConfiguration 

type ExecuteCommandConfiguration struct {
	Region      string `json:"region" mapstructure:"region"`
	Cluster     string `json:"cluster" mapstructure:"cluster"`
	Task        string `json:"task" mapstructure:"task"`
	Container   string `json:"container" mapstructure:"container"`
	Command     string `json:"command" mapstructure:"command"`
	Interactive bool   `json:"interactive" mapstructure:"interactive"`
}

type ExecuteCommandInput 

type ExecuteCommandInput struct {
	Cluster     string
	Task        string
	Container   string
	Command     string
	Interactive bool
}

type ExecuteCommandNodeMetadata 

type ExecuteCommandNodeMetadata struct {
	Region  string `json:"region" mapstructure:"region"`
	Cluster string `json:"cluster" mapstructure:"cluster"`
	Task    string `json:"task" mapstructure:"task"`
}

type ExecuteCommandResponse 

type ExecuteCommandResponse struct {
	ClusterArn    string                `json:"clusterArn"`
	ContainerArn  string                `json:"containerArn"`
	ContainerName string                `json:"containerName"`
	Interactive   bool                  `json:"interactive"`
	Session       ExecuteCommandSession `json:"session"`
	TaskArn       string                `json:"taskArn"`
}

type ExecuteCommandSession 

type ExecuteCommandSession struct {
	SessionID  string `json:"sessionId"`
	StreamURL  string `json:"streamUrl"`
	TokenValue string `json:"tokenValue"`
}

type Failure 

type Failure struct {
	Arn    string `json:"arn"`
	Reason string `json:"reason"`
	Detail string `json:"detail"`
}

type RunTask 

type RunTask struct{}

func (*RunTask) Actions 

func (c *RunTask) Actions() []core.Action

func (*RunTask) Cancel 

func (c *RunTask) Cancel(ctx core.ExecutionContext) error

func (*RunTask) Cleanup 

func (c *RunTask) Cleanup(ctx core.SetupContext) error

func (*RunTask) Color 

func (c *RunTask) Color() string

func (*RunTask) Configuration 

func (c *RunTask) Configuration() []configuration.Field

func (*RunTask) Description 

func (c *RunTask) Description() string

func (*RunTask) Documentation 

func (c *RunTask) Documentation() string

func (*RunTask) ExampleOutput 

func (c *RunTask) ExampleOutput() map[string]any

func (*RunTask) Execute 

func (c *RunTask) Execute(ctx core.ExecutionContext) error

func (*RunTask) HandleAction 

func (c *RunTask) HandleAction(ctx core.ActionContext) error

func (*RunTask) HandleWebhook 

func (c *RunTask) HandleWebhook(ctx core.WebhookRequestContext) (int, error)

func (*RunTask) Icon 

func (c *RunTask) Icon() string

func (*RunTask) Label 

func (c *RunTask) Label() string

func (*RunTask) Name 

func (c *RunTask) Name() string

func (*RunTask) OnIntegrationMessage 

func (c *RunTask) OnIntegrationMessage(ctx core.IntegrationMessageContext) error

func (*RunTask) OutputChannels 

func (c *RunTask) OutputChannels(configuration any) []core.OutputChannel

func (*RunTask) ProcessQueueItem 

func (c *RunTask) ProcessQueueItem(ctx core.ProcessQueueContext) (*uuid.UUID, error)

func (*RunTask) Setup 

func (c *RunTask) Setup(ctx core.SetupContext) error

type RunTaskAwsvpcConfiguration 

type RunTaskAwsvpcConfiguration struct {
	Subnets        []string `json:"subnets,omitempty" mapstructure:"subnets"`
	SecurityGroups []string `json:"securityGroups,omitempty" mapstructure:"securityGroups"`
	AssignPublicIP string   `json:"assignPublicIp,omitempty" mapstructure:"assignPublicIp"`
}

type RunTaskCapacityProviderStrategyItem 

type RunTaskCapacityProviderStrategyItem struct {
	CapacityProvider string `json:"capacityProvider" mapstructure:"capacityProvider"`
	Weight           int    `json:"weight,omitempty" mapstructure:"weight"`
	Base             int    `json:"base,omitempty" mapstructure:"base"`
}

type RunTaskConfiguration 

type RunTaskConfiguration struct {
	Region               string                                `json:"region" mapstructure:"region"`
	Cluster              string                                `json:"cluster" mapstructure:"cluster"`
	TaskDefinition       string                                `json:"taskDefinition" mapstructure:"taskDefinition"`
	Count                int                                   `json:"count" mapstructure:"count"`
	LaunchType           string                                `json:"launchType" mapstructure:"launchType"`
	CapacityProvider     []RunTaskCapacityProviderStrategyItem `json:"capacityProviderStrategy" mapstructure:"capacityProviderStrategy"`
	Group                string                                `json:"group" mapstructure:"group"`
	StartedBy            string                                `json:"startedBy" mapstructure:"startedBy"`
	PlatformVersion      string                                `json:"platformVersion" mapstructure:"platformVersion"`
	EnableExecuteCommand bool                                  `json:"enableExecuteCommand" mapstructure:"enableExecuteCommand"`
	NetworkConfiguration RunTaskNetworkConfiguration           `json:"networkConfiguration,omitempty" mapstructure:"networkConfiguration"`
	Overrides            RunTaskOverrides                      `json:"overrides,omitempty" mapstructure:"overrides"`
	TimeoutSeconds       int                                   `json:"timeoutSeconds" mapstructure:"timeoutSeconds"`
}

type RunTaskContainerEnvironment 

type RunTaskContainerEnvironment struct {
	Name  string `json:"name" mapstructure:"name"`
	Value string `json:"value" mapstructure:"value"`
}

type RunTaskContainerOverride 

type RunTaskContainerOverride struct {
	Name              string                        `json:"name,omitempty" mapstructure:"name"`
	Command           []string                      `json:"command,omitempty" mapstructure:"command"`
	Environment       []RunTaskContainerEnvironment `json:"environment,omitempty" mapstructure:"environment"`
	CPU               int                           `json:"cpu,omitempty" mapstructure:"cpu"`
	Memory            int                           `json:"memory,omitempty" mapstructure:"memory"`
	MemoryReservation int                           `json:"memoryReservation,omitempty" mapstructure:"memoryReservation"`
}

func (RunTaskContainerOverride) ToMap 

func (o RunTaskContainerOverride) ToMap() map[string]any

type RunTaskExecutionMetadata 

type RunTaskExecutionMetadata struct {
	Region         string   `json:"region" mapstructure:"region"`
	Cluster        string   `json:"cluster" mapstructure:"cluster"`
	TaskARNs       []string `json:"taskArns" mapstructure:"taskArns"`
	TimeoutSeconds int      `json:"timeoutSeconds" mapstructure:"timeoutSeconds"`
	StartedAt      string   `json:"startedAt" mapstructure:"startedAt"`
	DeadlineAt     string   `json:"deadlineAt" mapstructure:"deadlineAt"`
}

type RunTaskInput 

type RunTaskInput struct {
	Cluster              string
	TaskDefinition       string
	Count                int
	LaunchType           string
	CapacityProvider     []RunTaskCapacityProviderStrategyItem
	Group                string
	StartedBy            string
	PlatformVersion      string
	EnableExecuteCommand bool
	NetworkConfiguration RunTaskNetworkConfiguration
	Overrides            RunTaskOverrides
}

type RunTaskNetworkConfiguration 

type RunTaskNetworkConfiguration struct {
	AwsvpcConfiguration *RunTaskAwsvpcConfiguration `json:"awsvpcConfiguration,omitempty" mapstructure:"awsvpcConfiguration"`
}

func (RunTaskNetworkConfiguration) ToMap 

func (c RunTaskNetworkConfiguration) ToMap() map[string]any

type RunTaskNodeMetadata 

type RunTaskNodeMetadata struct {
	Region         string `json:"region" mapstructure:"region"`
	SubscriptionID string `json:"subscriptionId" mapstructure:"subscriptionId"`
}

type RunTaskOverrides 

type RunTaskOverrides struct {
	ContainerOverrides []RunTaskContainerOverride `json:"containerOverrides,omitempty" mapstructure:"containerOverrides"`
}

func (RunTaskOverrides) ToMap 

func (o RunTaskOverrides) ToMap() map[string]any

type RunTaskResponse 

type RunTaskResponse struct {
	Tasks    []Task    `json:"tasks"`
	Failures []Failure `json:"failures"`
}

type RunTaskStateChangeDetail 

type RunTaskStateChangeDetail struct {
	TaskARN string `json:"taskArn" mapstructure:"taskArn"`
}

type Service 

type Service struct {
	ServiceArn      string              `json:"serviceArn"`
	ServiceName     string              `json:"serviceName"`
	ClusterArn      string              `json:"clusterArn"`
	Status          string              `json:"status"`
	TaskDefinition  string              `json:"taskDefinition"`
	DesiredCount    int                 `json:"desiredCount"`
	RunningCount    int                 `json:"runningCount"`
	PendingCount    int                 `json:"pendingCount"`
	LaunchType      string              `json:"launchType"`
	PlatformVersion string              `json:"platformVersion"`
	Scheduling      string              `json:"schedulingStrategy"`
	CreatedAt       common.FloatTime    `json:"createdAt,omitempty"`
	Deployments     []ServiceDeployment `json:"deployments"`
	Events          []ServiceEvent      `json:"events"`
	TaskSets        []ServiceTaskSet    `json:"taskSets"`
	NetworkConfig   any                 `json:"networkConfiguration,omitempty"`
	PropagateTags   string              `json:"propagateTags"`
	EnableExec      bool                `json:"enableExecuteCommand"`
}

type ServiceDeployment 

type ServiceDeployment struct {
	ID             string           `json:"id"`
	Status         string           `json:"status"`
	TaskDefinition string           `json:"taskDefinition"`
	DesiredCount   int              `json:"desiredCount"`
	PendingCount   int              `json:"pendingCount"`
	RunningCount   int              `json:"runningCount"`
	CreatedAt      common.FloatTime `json:"createdAt,omitempty"`
	UpdatedAt      common.FloatTime `json:"updatedAt,omitempty"`
}

type ServiceEvent 

type ServiceEvent struct {
	ID        string           `json:"id"`
	CreatedAt common.FloatTime `json:"createdAt,omitempty"`
	Message   string           `json:"message"`
}

type ServiceMutationConfiguration 

type ServiceMutationConfiguration struct {
	Region                            string                                `json:"region" mapstructure:"region"`
	Cluster                           string                                `json:"cluster" mapstructure:"cluster"`
	TaskDefinition                    string                                `json:"taskDefinition" mapstructure:"taskDefinition"`
	DesiredCount                      *int                                  `json:"desiredCount" mapstructure:"desiredCount"`
	LaunchType                        string                                `json:"launchType" mapstructure:"launchType"`
	CapacityProviderStrategy          []RunTaskCapacityProviderStrategyItem `json:"capacityProviderStrategy" mapstructure:"capacityProviderStrategy"`
	PlatformVersion                   string                                `json:"platformVersion" mapstructure:"platformVersion"`
	EnableExecuteCommand              *bool                                 `json:"enableExecuteCommand" mapstructure:"enableExecuteCommand"`
	NetworkConfiguration              RunTaskNetworkConfiguration           `json:"networkConfiguration" mapstructure:"networkConfiguration"`
	DeploymentConfiguration           map[string]any                        `json:"deploymentConfiguration" mapstructure:"deploymentConfiguration"`
	HealthCheckGracePeriodSeconds     *int                                  `json:"healthCheckGracePeriodSeconds" mapstructure:"healthCheckGracePeriodSeconds"`
	ServiceRegistries                 []map[string]any                      `json:"serviceRegistries" mapstructure:"serviceRegistries"`
	LoadBalancers                     []map[string]any                      `json:"loadBalancers" mapstructure:"loadBalancers"`
	PlacementConstraints              []map[string]any                      `json:"placementConstraints" mapstructure:"placementConstraints"`
	PlacementStrategy                 []map[string]any                      `json:"placementStrategy" mapstructure:"placementStrategy"`
	ServiceConnectConfiguration       map[string]any                        `json:"serviceConnectConfiguration" mapstructure:"serviceConnectConfiguration"`
	VolumeConfigurations              []map[string]any                      `json:"volumeConfigurations" mapstructure:"volumeConfigurations"`
	VpcLatticeConfigurations          []map[string]any                      `json:"vpcLatticeConfigurations" mapstructure:"vpcLatticeConfigurations"`
	AvailabilityZoneRebalancing       string                                `json:"availabilityZoneRebalancing" mapstructure:"availabilityZoneRebalancing"`
	EnableECSManagedTags              *bool                                 `json:"enableECSManagedTags" mapstructure:"enableECSManagedTags"`
	PropagateTags                     string                                `json:"propagateTags" mapstructure:"propagateTags"`
	Tags                              []common.Tag                          `json:"tags" mapstructure:"tags"`
	ForceNewDeployment                *bool                                 `json:"forceNewDeployment" mapstructure:"forceNewDeployment"`
	AdditionalCreateOrUpdateArguments map[string]any                        `json:"additionalCreateOrUpdateArguments" mapstructure:"additionalCreateOrUpdateArguments"`
}

type ServiceMutationInput 

type ServiceMutationInput struct {
	Cluster                           string
	TaskDefinition                    string
	DesiredCount                      *int
	LaunchType                        string
	CapacityProviderStrategy          []RunTaskCapacityProviderStrategyItem
	PlatformVersion                   string
	EnableExecuteCommand              *bool
	NetworkConfiguration              RunTaskNetworkConfiguration
	DeploymentConfiguration           map[string]any
	ServiceRegistries                 []map[string]any
	LoadBalancers                     []map[string]any
	PlacementConstraints              []map[string]any
	PlacementStrategy                 []map[string]any
	ServiceConnectConfiguration       map[string]any
	VolumeConfigurations              []map[string]any
	VpcLatticeConfigurations          []map[string]any
	AvailabilityZoneRebalancing       string
	HealthCheckGracePeriodSeconds     *int
	EnableECSManagedTags              *bool
	PropagateTags                     string
	Tags                              []common.Tag
	ForceNewDeployment                *bool
	AdditionalCreateOrUpdateArguments map[string]any
}

type ServiceTaskSet 

type ServiceTaskSet struct {
	ID                   string           `json:"id"`
	TaskSetArn           string           `json:"taskSetArn"`
	Status               string           `json:"status"`
	TaskDefinition       string           `json:"taskDefinition"`
	ServiceArn           string           `json:"serviceArn"`
	ClusterArn           string           `json:"clusterArn"`
	LaunchType           string           `json:"launchType"`
	PlatformVersion      string           `json:"platformVersion"`
	ComputedDesiredCount int              `json:"computedDesiredCount"`
	PendingCount         int              `json:"pendingCount"`
	RunningCount         int              `json:"runningCount"`
	CreatedAt            common.FloatTime `json:"createdAt,omitempty"`
	UpdatedAt            common.FloatTime `json:"updatedAt,omitempty"`
}

type StopTask 

type StopTask struct{}

func (*StopTask) Actions 

func (c *StopTask) Actions() []core.Action

func (*StopTask) Cancel 

func (c *StopTask) Cancel(ctx core.ExecutionContext) error

func (*StopTask) Cleanup 

func (c *StopTask) Cleanup(ctx core.SetupContext) error

func (*StopTask) Color 

func (c *StopTask) Color() string

func (*StopTask) Configuration 

func (c *StopTask) Configuration() []configuration.Field

func (*StopTask) Description 

func (c *StopTask) Description() string

func (*StopTask) Documentation 

func (c *StopTask) Documentation() string

func (*StopTask) ExampleOutput 

func (c *StopTask) ExampleOutput() map[string]any

func (*StopTask) Execute 

func (c *StopTask) Execute(ctx core.ExecutionContext) error

func (*StopTask) HandleAction 

func (c *StopTask) HandleAction(ctx core.ActionContext) error

func (*StopTask) HandleWebhook 

func (c *StopTask) HandleWebhook(ctx core.WebhookRequestContext) (int, error)

func (*StopTask) Icon 

func (c *StopTask) Icon() string

func (*StopTask) Label 

func (c *StopTask) Label() string

func (*StopTask) Name 

func (c *StopTask) Name() string

func (*StopTask) OnIntegrationMessage 

func (c *StopTask) OnIntegrationMessage(ctx core.IntegrationMessageContext) error

func (*StopTask) OutputChannels 

func (c *StopTask) OutputChannels(configuration any) []core.OutputChannel

func (*StopTask) ProcessQueueItem 

func (c *StopTask) ProcessQueueItem(ctx core.ProcessQueueContext) (*uuid.UUID, error)

func (*StopTask) Setup 

func (c *StopTask) Setup(ctx core.SetupContext) error

type StopTaskConfiguration 

type StopTaskConfiguration struct {
	Region  string `json:"region" mapstructure:"region"`
	Cluster string `json:"cluster" mapstructure:"cluster"`
	Task    string `json:"task" mapstructure:"task"`
	Reason  string `json:"reason" mapstructure:"reason"`
}

type StopTaskExecutionMetadata 

type StopTaskExecutionMetadata struct {
	Region  string `json:"region" mapstructure:"region"`
	Cluster string `json:"cluster" mapstructure:"cluster"`
	TaskARN string `json:"taskArn" mapstructure:"taskArn"`
}

type StopTaskNodeMetadata 

type StopTaskNodeMetadata struct {
	Region         string `json:"region" mapstructure:"region"`
	SubscriptionID string `json:"subscriptionId" mapstructure:"subscriptionId"`
}

type StopTaskResponse 

type StopTaskResponse struct {
	Task Task `json:"task"`
}

type StopTaskStateChangeDetail 

type StopTaskStateChangeDetail struct {
	TaskARN    string `json:"taskArn" mapstructure:"taskArn"`
	LastStatus string `json:"lastStatus" mapstructure:"lastStatus"`
}

type Task 

type Task struct {
	TaskArn           string           `json:"taskArn"`
	ClusterArn        string           `json:"clusterArn"`
	TaskDefinitionArn string           `json:"taskDefinitionArn"`
	LastStatus        string           `json:"lastStatus"`
	DesiredStatus     string           `json:"desiredStatus"`
	StoppedReason     string           `json:"stoppedReason"`
	LaunchType        string           `json:"launchType"`
	PlatformVersion   string           `json:"platformVersion"`
	Group             string           `json:"group"`
	StartedBy         string           `json:"startedBy"`
	CreatedAt         common.FloatTime `json:"createdAt,omitempty"`
}

type UpdateService 

type UpdateService struct{}

func (*UpdateService) Actions 

func (c *UpdateService) Actions() []core.Action

func (*UpdateService) Cancel 

func (c *UpdateService) Cancel(ctx core.ExecutionContext) error

func (*UpdateService) Cleanup 

func (c *UpdateService) Cleanup(ctx core.SetupContext) error

func (*UpdateService) Color 

func (c *UpdateService) Color() string

func (*UpdateService) Configuration 

func (c *UpdateService) Configuration() []configuration.Field

func (*UpdateService) Description 

func (c *UpdateService) Description() string

func (*UpdateService) Documentation 

func (c *UpdateService) Documentation() string

func (*UpdateService) ExampleOutput 

func (c *UpdateService) ExampleOutput() map[string]any

func (*UpdateService) Execute 

func (c *UpdateService) Execute(ctx core.ExecutionContext) error

func (*UpdateService) HandleAction 

func (c *UpdateService) HandleAction(ctx core.ActionContext) error

func (*UpdateService) HandleWebhook 

func (c *UpdateService) HandleWebhook(ctx core.WebhookRequestContext) (int, error)

func (*UpdateService) Icon 

func (c *UpdateService) Icon() string

func (*UpdateService) Label 

func (c *UpdateService) Label() string

func (*UpdateService) Name 

func (c *UpdateService) Name() string

func (*UpdateService) OutputChannels 

func (c *UpdateService) OutputChannels(configuration any) []core.OutputChannel

func (*UpdateService) ProcessQueueItem 

func (c *UpdateService) ProcessQueueItem(ctx core.ProcessQueueContext) (*uuid.UUID, error)

func (*UpdateService) Setup 

func (c *UpdateService) Setup(ctx core.SetupContext) error

type UpdateServiceConfiguration 

type UpdateServiceConfiguration struct {
	ServiceMutationConfiguration `mapstructure:",squash"`
	Service                      string `json:"service" mapstructure:"service"`
}

type UpdateServiceInput 

type UpdateServiceInput struct {
	Service         string
	ServiceMutation ServiceMutationInput
}

type UpdateServiceNodeMetadata 

type UpdateServiceNodeMetadata struct {
	Region  string `json:"region" mapstructure:"region"`
	Cluster string `json:"cluster" mapstructure:"cluster"`
	Service string `json:"service" mapstructure:"service"`
}

type UpdateServiceResponse 

type UpdateServiceResponse struct {
	Service Service `json:"service"`
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.