gsadmin/spinifex
1
0
Fork 0
mirror of https://github.com/mulgadc/spinifex.git synced 2026-10-15 09:01:31 +00:00
Code Issues Packages Projects Releases Wiki Activity

refactor: move EC2 capacityreservation action adapters to domains/ec2/awsapi

Browse Source
This commit is contained in:
joshsiv-mulga
2026-10-07 14:23:04 +10:00
parent 5032e24a74
commit d500e3802f
7 changed files with 10 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files
spinifex/gateway/ec2/capacityreservation/CancelCapacityReservation.go → spinifex/domains/ec2/awsapi/capacityreservation/CancelCapacityReservation.go
+1 -1
View File
@@ -1,4 +1,4 @@
package gateway_ec2_capacityreservation
package capacityreservation
import (
"context"
spinifex/gateway/ec2/capacityreservation/CreateCapacityReservation.go → spinifex/domains/ec2/awsapi/capacityreservation/CreateCapacityReservation.go
+1 -1
View File
@@ -1,4 +1,4 @@
package gateway_ec2_capacityreservation
package capacityreservation
import (
"context"
spinifex/gateway/ec2/capacityreservation/DescribeCapacityReservations.go → spinifex/domains/ec2/awsapi/capacityreservation/DescribeCapacityReservations.go
+1 -1
View File
@@ -1,4 +1,4 @@
package gateway_ec2_capacityreservation
package capacityreservation
import (
"context"
spinifex/gateway/ec2/capacityreservation/capacityreservation_test.go → spinifex/domains/ec2/awsapi/capacityreservation/capacityreservation_test.go
+1 -1
View File
@@ -1,4 +1,4 @@
package gateway_ec2_capacityreservation
package capacityreservation
import (
"context"
spinifex/gateway/ec2/capacityreservation/fanout.go → spinifex/domains/ec2/awsapi/capacityreservation/fanout.go
+1 -1
View File
@@ -1,4 +1,4 @@
package gateway_ec2_capacityreservation
package capacityreservation
import (
"context"
spinifex/gateway/ec2/capacityreservation/fanout_test.go → spinifex/domains/ec2/awsapi/capacityreservation/fanout_test.go
+1 -1
View File
@@ -1,4 +1,4 @@
package gateway_ec2_capacityreservation
package capacityreservation
import (
"context"
spinifex/gateway/ec2.go
+4 -4
View File
@@ -14,11 +14,11 @@ import (
"github.com/aws/aws-sdk-go/aws"
"github.com/aws/aws-sdk-go/service/ec2"
ec2accountapi "github.com/mulgadc/spinifex/spinifex/domains/ec2/awsapi/account"
ec2capacityreservationapi "github.com/mulgadc/spinifex/spinifex/domains/ec2/awsapi/capacityreservation"
"github.com/mulgadc/spinifex/spinifex/foundation/aws/errors"
awsxml "github.com/mulgadc/spinifex/spinifex/foundation/aws/xml"
"github.com/mulgadc/spinifex/spinifex/foundation/lifecycle/idempotency"
gateway_ec2 "github.com/mulgadc/spinifex/spinifex/gateway/ec2"
gateway_ec2_capacityreservation "github.com/mulgadc/spinifex/spinifex/gateway/ec2/capacityreservation"
gateway_ec2_eigw "github.com/mulgadc/spinifex/spinifex/gateway/ec2/eigw"
gateway_ec2_eip "github.com/mulgadc/spinifex/spinifex/gateway/ec2/eip"
gateway_ec2_igw "github.com/mulgadc/spinifex/spinifex/gateway/ec2/igw"
@@ -443,13 +443,13 @@ var ec2Actions = map[string]ec2Action{
return gateway_ec2_placementgroup.DescribePlacementGroups(ctx, input, gw.NATSConn, accountID)
}),
"CreateCapacityReservation": ec2IdempotentHandler(func(ctx context.Context, input *ec2.CreateCapacityReservationInput, gw *GatewayConfig, accountID string) (ec2.CreateCapacityReservationOutput, error) {
return gateway_ec2_capacityreservation.CreateCapacityReservation(ctx, input, gw.NATSConn, gw.ExpectedNodes, accountID)
return ec2capacityreservationapi.CreateCapacityReservation(ctx, input, gw.NATSConn, gw.ExpectedNodes, accountID)
}),
"DescribeCapacityReservations": ec2Handler(func(ctx context.Context, input *ec2.DescribeCapacityReservationsInput, gw *GatewayConfig, accountID string) (any, error) {
return gateway_ec2_capacityreservation.DescribeCapacityReservations(ctx, input, gw.NATSConn, gw.ExpectedNodes, accountID)
return ec2capacityreservationapi.DescribeCapacityReservations(ctx, input, gw.NATSConn, gw.ExpectedNodes, accountID)
}),
"CancelCapacityReservation": ec2Handler(func(ctx context.Context, input *ec2.CancelCapacityReservationInput, gw *GatewayConfig, accountID string) (any, error) {
return gateway_ec2_capacityreservation.CancelCapacityReservation(ctx, input, gw.NATSConn, gw.ExpectedNodes, accountID)
return ec2capacityreservationapi.CancelCapacityReservation(ctx, input, gw.NATSConn, gw.ExpectedNodes, accountID)
}),
"CreateLaunchTemplate": ec2Handler(func(ctx context.Context, input *ec2.CreateLaunchTemplateInput, gw *GatewayConfig, accountID string) (any, error) {
return gateway_ec2_launchtemplate.CreateLaunchTemplate(ctx, input, gw.NATSConn, accountID)