internal/aws-sdk-go-v2/service/snowballdevice/api_op_SetAlertSubscription.go (120 lines of code) (raw):

// Code generated by smithy-go-codegen DO NOT EDIT. package snowballdevice import ( "context" "fmt" awsmiddleware "github.com/aws/aws-sdk-go-v2/aws/middleware" "github.com/aws/aws-sdk-go-v2/aws/signer/v4" "github.com/aws/eks-anywhere/internal/aws-sdk-go-v2/service/snowballdevice/types" "github.com/aws/smithy-go/middleware" smithyhttp "github.com/aws/smithy-go/transport/http" ) func (c *Client) SetAlertSubscription(ctx context.Context, params *SetAlertSubscriptionInput, optFns ...func(*Options)) (*SetAlertSubscriptionOutput, error) { if params == nil { params = &SetAlertSubscriptionInput{} } result, metadata, err := c.invokeOperation(ctx, "SetAlertSubscription", params, optFns, c.addOperationSetAlertSubscriptionMiddlewares) if err != nil { return nil, err } out := result.(*SetAlertSubscriptionOutput) out.ResultMetadata = metadata return out, nil } type SetAlertSubscriptionInput struct { // This member is required. Name *string // This member is required. Namespace *string // This member is required. State types.AlertSubscriptionState Channels []types.AlertSubscriptionChannel noSmithyDocumentSerde } type SetAlertSubscriptionOutput struct { Name *string Namespace *string Subscription *types.AlertSubscription // Metadata pertaining to the operation's result. ResultMetadata middleware.Metadata noSmithyDocumentSerde } func (c *Client) addOperationSetAlertSubscriptionMiddlewares(stack *middleware.Stack, options Options) (err error) { if err := stack.Serialize.Add(&setOperationInputMiddleware{}, middleware.After); err != nil { return err } err = stack.Serialize.Add(&awsAwsjson11_serializeOpSetAlertSubscription{}, middleware.After) if err != nil { return err } err = stack.Deserialize.Add(&awsAwsjson11_deserializeOpSetAlertSubscription{}, middleware.After) if err != nil { return err } if err := addProtocolFinalizerMiddlewares(stack, options, "SetAlertSubscription"); err != nil { return fmt.Errorf("add protocol finalizers: %v", err) } if err = addlegacyEndpointContextSetter(stack, options); err != nil { return err } if err = addSetLoggerMiddleware(stack, options); err != nil { return err } if err = awsmiddleware.AddClientRequestIDMiddleware(stack); err != nil { return err } if err = smithyhttp.AddComputeContentLengthMiddleware(stack); err != nil { return err } if err = addResolveEndpointMiddleware(stack, options); err != nil { return err } if err = v4.AddComputePayloadSHA256Middleware(stack); err != nil { return err } if err = addRetryMiddlewares(stack, options); err != nil { return err } if err = awsmiddleware.AddRawResponseToMetadata(stack); err != nil { return err } if err = awsmiddleware.AddRecordResponseTiming(stack); err != nil { return err } if err = addClientUserAgent(stack, options); err != nil { return err } if err = smithyhttp.AddErrorCloseResponseBodyMiddleware(stack); err != nil { return err } if err = smithyhttp.AddCloseResponseBodyMiddleware(stack); err != nil { return err } if err = addSetLegacyContextSigningOptionsMiddleware(stack); err != nil { return err } if err = addOpSetAlertSubscriptionValidationMiddleware(stack); err != nil { return err } if err = stack.Initialize.Add(newServiceMetadataMiddleware_opSetAlertSubscription(options.Region), middleware.Before); err != nil { return err } if err = awsmiddleware.AddRecursionDetection(stack); err != nil { return err } if err = addRequestIDRetrieverMiddleware(stack); err != nil { return err } if err = addResponseErrorMiddleware(stack); err != nil { return err } if err = addRequestResponseLogging(stack, options); err != nil { return err } if err = addDisableHTTPSMiddleware(stack, options); err != nil { return err } return nil } func newServiceMetadataMiddleware_opSetAlertSubscription(region string) *awsmiddleware.RegisterServiceMetadata { return &awsmiddleware.RegisterServiceMetadata{ Region: region, ServiceID: ServiceID, OperationName: "SetAlertSubscription", } }