extecs

package
v2.4.4 Latest Latest
Warning

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

Go to latest
Published: Apr 2, 2025 License: MIT Imports: 28 Imported by: 0

Documentation

Index

Constants

View Source
const LogType = "ECS_SERVICE_EVENTS"

Variables

This section is empty.

Functions

func GetAllEcsServices

func GetAllEcsServices(account *utils.AwsAccess, ecsServiceApi ecsServiceDiscoveryApi, ctx context.Context) ([]discovery_kit_api.Target, error)

func GetAllEcsTasks

func GetAllEcsTasks(ctx context.Context, ecsApi EcsTasksApi, ec2Util taskDiscoveryEc2Util, account *utils.AwsAccess) ([]discovery_kit_api.Target, error)

func NewEcsServiceScaleAction

func NewEcsServiceScaleAction() action_kit_sdk.Action[ServiceScaleState]

func NewEcsTaskFillDiskAction

func NewEcsTaskFillDiskAction() action_kit_sdk.Action[TaskSsmActionState]

func NewEcsTaskStopAction

func NewEcsTaskStopAction() action_kit_sdk.Action[TaskStopState]

func NewEcsTaskStressCpuAction

func NewEcsTaskStressCpuAction() action_kit_sdk.Action[TaskSsmActionState]

func NewEcsTaskStressIoAction

func NewEcsTaskStressIoAction() action_kit_sdk.Action[TaskSsmActionState]

func NewEcsTaskStressMemoryAction

func NewEcsTaskStressMemoryAction() action_kit_sdk.Action[TaskSsmActionState]

Types

type EcsServiceDescriptionPoller

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

func NewServiceDescriptionPoller

func NewServiceDescriptionPoller() *EcsServiceDescriptionPoller

func (EcsServiceDescriptionPoller) AwaitLatest

func (p EcsServiceDescriptionPoller) AwaitLatest(account string, region string, role *string, cluster string, service string) *PollService

func (EcsServiceDescriptionPoller) Latest

func (p EcsServiceDescriptionPoller) Latest(account string, region string, role *string, cluster string, service string) *PollService

func (EcsServiceDescriptionPoller) Register

func (p EcsServiceDescriptionPoller) Register(account string, region string, role *string, cluster string, service string)

func (EcsServiceDescriptionPoller) Start

func (EcsServiceDescriptionPoller) Unregister

func (p EcsServiceDescriptionPoller) Unregister(account string, region string, role *string, cluster string, service string)

type EcsServiceEventLogAction

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

func (EcsServiceEventLogAction) Describe

func (f EcsServiceEventLogAction) Describe() action_kit_api.ActionDescription

func (EcsServiceEventLogAction) NewEmptyState

func (EcsServiceEventLogAction) Prepare

func (f EcsServiceEventLogAction) Prepare(_ context.Context, state *EcsServiceEventLogState, request action_kit_api.PrepareActionRequestBody) (*action_kit_api.PrepareResult, error)

func (EcsServiceEventLogAction) Start

func (f EcsServiceEventLogAction) Start(_ context.Context, state *EcsServiceEventLogState) (*action_kit_api.StartResult, error)

func (EcsServiceEventLogAction) Status

func (f EcsServiceEventLogAction) Status(_ context.Context, state *EcsServiceEventLogState) (*action_kit_api.StatusResult, error)

func (EcsServiceEventLogAction) Stop

func (f EcsServiceEventLogAction) Stop(_ context.Context, state *EcsServiceEventLogState) (*action_kit_api.StopResult, error)

type EcsServiceEventLogState

type EcsServiceEventLogState struct {
	LatestEventTimestamp time.Time
	ServiceArn           string
	ClusterArn           string
	AwsAccount           string
	Region               string
	DiscoveredByRole     *string
}

type EcsServiceTaskCountCheckAction

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

func (EcsServiceTaskCountCheckAction) Describe

func (f EcsServiceTaskCountCheckAction) Describe() action_kit_api.ActionDescription

func (EcsServiceTaskCountCheckAction) NewEmptyState

func (EcsServiceTaskCountCheckAction) Prepare

func (f EcsServiceTaskCountCheckAction) Prepare(_ context.Context, state *EcsServiceTaskCountCheckState, request action_kit_api.PrepareActionRequestBody) (*action_kit_api.PrepareResult, error)

func (EcsServiceTaskCountCheckAction) Start

func (f EcsServiceTaskCountCheckAction) Start(_ context.Context, _ *EcsServiceTaskCountCheckState) (*action_kit_api.StartResult, error)

func (EcsServiceTaskCountCheckAction) Status

func (f EcsServiceTaskCountCheckAction) Status(_ context.Context, state *EcsServiceTaskCountCheckState) (*action_kit_api.StatusResult, error)

func (EcsServiceTaskCountCheckAction) Stop

func (f EcsServiceTaskCountCheckAction) Stop(_ context.Context, state *EcsServiceTaskCountCheckState) (*action_kit_api.StopResult, error)

type EcsServiceTaskCountCheckConfig

type EcsServiceTaskCountCheckConfig struct {
	Duration              int
	RunningCountCheckMode string
}

type EcsServiceTaskCountCheckState

type EcsServiceTaskCountCheckState struct {
	Timeout               time.Time
	RunningCountCheckMode string
	ServiceArn            string
	ClusterArn            string
	AwsAccount            string
	Region                string
	DiscoveredByRole      *string
	InitialRunningCount   int
}

type PollService

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

type ServiceDescriptionPoller

type ServiceDescriptionPoller interface {
	Start(ctx context.Context)
	Register(account string, region string, role *string, cluster string, service string)
	Unregister(account string, region string, role *string, cluster string, service string)
	Latest(account string, region string, role *string, cluster string, service string) *PollService
	AwaitLatest(account string, region string, role *string, cluster string, service string) *PollService
}

type ServiceScaleState

type ServiceScaleState struct {
	Account             string
	Region              string
	DiscoveredByRole    *string
	ServiceName         string
	ClusterArn          string
	DesiredCount        int32
	InitialDesiredCount int32
}

type TaskSsmActionState

type TaskSsmActionState struct {
	Account           string
	Region            string
	DiscoveredByRole  *string
	TaskArn           string
	ManagedInstanceId string
	CommandId         string
	Parameters        map[string][]string
	Comment           string
	CommandEnded      bool
}

type TaskStopState

type TaskStopState struct {
	Account          string
	Region           string
	DiscoveredByRole *string
	TaskArn          string
	ClusterArn       string
}

Jump to

Keyboard shortcuts

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