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 NewEcsTaskNetworkBlockholePortAction() action_kit_sdk.Action[TaskSsmActionState]
- func NewEcsTaskNetworkDelayAction() action_kit_sdk.Action[TaskSsmActionState]
- func NewEcsTaskNetworkDnsAction() action_kit_sdk.Action[TaskSsmActionState]
- func NewEcsTaskNetworkLossAction() action_kit_sdk.Action[TaskSsmActionState]
- func NewEcsTaskStopAction() action_kit_sdk.Action[TaskStopState]
- func NewEcsTaskStopProcessAction() action_kit_sdk.Action[TaskSsmActionState]
- 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 HeartbeatConfig
- 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 NewEcsTaskNetworkBlockholePortAction ¶ added in v2.4.5
func NewEcsTaskNetworkBlockholePortAction() action_kit_sdk.Action[TaskSsmActionState]
func NewEcsTaskNetworkDelayAction ¶ added in v2.4.5
func NewEcsTaskNetworkDelayAction() action_kit_sdk.Action[TaskSsmActionState]
func NewEcsTaskNetworkDnsAction ¶ added in v2.4.5
func NewEcsTaskNetworkDnsAction() action_kit_sdk.Action[TaskSsmActionState]
func NewEcsTaskNetworkLossAction ¶ added in v2.4.5
func NewEcsTaskNetworkLossAction() action_kit_sdk.Action[TaskSsmActionState]
func NewEcsTaskStopAction ¶
func NewEcsTaskStopAction() action_kit_sdk.Action[TaskStopState]
func NewEcsTaskStopProcessAction ¶ added in v2.4.5
func NewEcsTaskStopProcessAction() action_kit_sdk.Action[TaskSsmActionState]
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 HeartbeatConfig ¶ added in v2.4.6
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
¶
- common.go
- common_fis_action_state.go
- service_attack_scale.go
- service_description_poller.go
- service_discovery.go
- service_event_log.go
- service_task_count_check.go
- task_attack_ssm.go
- task_attack_ssm_cpu.go
- task_attack_ssm_fill_disk.go
- task_attack_ssm_io.go
- task_attack_ssm_memory.go
- task_attack_ssm_network_blackhole_port.go
- task_attack_ssm_network_delay.go
- task_attack_ssm_network_dns.go
- task_attack_ssm_network_loss.go
- task_attack_ssm_stop_process.go
- task_attack_stop.go
- task_discovery.go
Click to show internal directories.
Click to hide internal directories.