Documentation
¶
Index ¶
- Constants
- func GetAllEcsServices(account *utils.AwsAccess, ecsServiceApi ecsServiceDiscoveryApi, ...) ([]discovery_kit_api.Target, error)
- func GetAllEcsTasks(ctx context.Context, ecsApi EcsTasksApi, ec2Util taskDiscoveryEc2Util, ...) ([]discovery_kit_api.Target, error)
- func NewEcsServiceDiscovery(ctx context.Context) discovery_kit_sdk.TargetDiscovery
- func NewEcsServiceEventLogAction(poller ServiceDescriptionPoller) action_kit_sdk.Action[EcsServiceEventLogState]
- func NewEcsServiceScaleAction() action_kit_sdk.Action[ServiceScaleState]
- func NewEcsServiceTaskCountCheckAction(poller ServiceDescriptionPoller) action_kit_sdk.Action[EcsServiceTaskCountCheckState]
- func NewEcsTaskDiscovery(ctx context.Context) discovery_kit_sdk.TargetDiscovery
- func NewEcsTaskFillDiskAction() action_kit_sdk.Action[TaskSsmActionState]
- func NewEcsTaskStopAction() action_kit_sdk.Action[TaskStopState]
- func NewEcsTaskStressCpuAction() action_kit_sdk.Action[TaskSsmActionState]
- func NewEcsTaskStressIoAction() action_kit_sdk.Action[TaskSsmActionState]
- func NewEcsTaskStressMemoryAction() action_kit_sdk.Action[TaskSsmActionState]
- type EcsServiceDescriptionPoller
- func (p EcsServiceDescriptionPoller) AwaitLatest(account string, region string, role *string, cluster string, service string) *PollService
- func (p EcsServiceDescriptionPoller) Latest(account string, region string, role *string, cluster string, service string) *PollService
- func (p EcsServiceDescriptionPoller) Register(account string, region string, role *string, cluster string, service string)
- func (p EcsServiceDescriptionPoller) Start(ctx context.Context)
- func (p EcsServiceDescriptionPoller) Unregister(account string, region string, role *string, cluster string, service string)
- type EcsServiceEventLogAction
- func (f EcsServiceEventLogAction) Describe() action_kit_api.ActionDescription
- func (f EcsServiceEventLogAction) NewEmptyState() EcsServiceEventLogState
- func (f EcsServiceEventLogAction) Prepare(_ context.Context, state *EcsServiceEventLogState, ...) (*action_kit_api.PrepareResult, error)
- func (f EcsServiceEventLogAction) Start(_ context.Context, state *EcsServiceEventLogState) (*action_kit_api.StartResult, error)
- func (f EcsServiceEventLogAction) Status(_ context.Context, state *EcsServiceEventLogState) (*action_kit_api.StatusResult, error)
- func (f EcsServiceEventLogAction) Stop(_ context.Context, state *EcsServiceEventLogState) (*action_kit_api.StopResult, error)
- type EcsServiceEventLogState
- type EcsServiceTaskCountCheckAction
- func (f EcsServiceTaskCountCheckAction) Describe() action_kit_api.ActionDescription
- func (f EcsServiceTaskCountCheckAction) NewEmptyState() EcsServiceTaskCountCheckState
- func (f EcsServiceTaskCountCheckAction) Prepare(_ context.Context, state *EcsServiceTaskCountCheckState, ...) (*action_kit_api.PrepareResult, error)
- func (f EcsServiceTaskCountCheckAction) Start(_ context.Context, _ *EcsServiceTaskCountCheckState) (*action_kit_api.StartResult, error)
- func (f EcsServiceTaskCountCheckAction) Status(_ context.Context, state *EcsServiceTaskCountCheckState) (*action_kit_api.StatusResult, error)
- func (f EcsServiceTaskCountCheckAction) Stop(_ context.Context, state *EcsServiceTaskCountCheckState) (*action_kit_api.StopResult, error)
- type EcsServiceTaskCountCheckConfig
- type EcsServiceTaskCountCheckState
- type EcsTasksApi
- type PollService
- type ServiceDescriptionPoller
- type ServiceScaleState
- type TaskSsmActionState
- type TaskStopState
Constants ¶
View Source
const LogType = "ECS_SERVICE_EVENTS"
Variables ¶
This section is empty.
Functions ¶
func GetAllEcsServices ¶
func GetAllEcsTasks ¶
func GetAllEcsTasks(ctx context.Context, ecsApi EcsTasksApi, ec2Util taskDiscoveryEc2Util, account *utils.AwsAccess) ([]discovery_kit_api.Target, error)
func NewEcsServiceDiscovery ¶
func NewEcsServiceDiscovery(ctx context.Context) discovery_kit_sdk.TargetDiscovery
func NewEcsServiceEventLogAction ¶
func NewEcsServiceEventLogAction(poller ServiceDescriptionPoller) action_kit_sdk.Action[EcsServiceEventLogState]
func NewEcsServiceScaleAction ¶
func NewEcsServiceScaleAction() action_kit_sdk.Action[ServiceScaleState]
func NewEcsServiceTaskCountCheckAction ¶
func NewEcsServiceTaskCountCheckAction(poller ServiceDescriptionPoller) action_kit_sdk.Action[EcsServiceTaskCountCheckState]
func NewEcsTaskDiscovery ¶
func NewEcsTaskDiscovery(ctx context.Context) discovery_kit_sdk.TargetDiscovery
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) Start ¶
func (p EcsServiceDescriptionPoller) Start(ctx context.Context)
func (EcsServiceDescriptionPoller) Unregister ¶
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 (f EcsServiceEventLogAction) NewEmptyState() EcsServiceEventLogState
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 EcsServiceTaskCountCheckAction ¶
type EcsServiceTaskCountCheckAction struct {
// contains filtered or unexported fields
}
func (EcsServiceTaskCountCheckAction) Describe ¶
func (f EcsServiceTaskCountCheckAction) Describe() action_kit_api.ActionDescription
func (EcsServiceTaskCountCheckAction) NewEmptyState ¶
func (f EcsServiceTaskCountCheckAction) NewEmptyState() EcsServiceTaskCountCheckState
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 EcsTasksApi ¶
type EcsTasksApi interface { ecs.ListTasksAPIClient ecs.DescribeTasksAPIClient ecs.ListClustersAPIClient }
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 TaskSsmActionState ¶
Source Files
¶
Click to show internal directories.
Click to hide internal directories.