1// Code generated by private/model/cli/gen-api/main.go. DO NOT EDIT. 2 3package appstream 4 5import ( 6 "time" 7 8 "github.com/aws/aws-sdk-go/aws" 9 "github.com/aws/aws-sdk-go/aws/request" 10) 11 12// WaitUntilFleetStarted uses the Amazon AppStream API operation 13// DescribeFleets to wait for a condition to be met before returning. 14// If the condition is not met within the max attempt window, an error will 15// be returned. 16func (c *AppStream) WaitUntilFleetStarted(input *DescribeFleetsInput) error { 17 return c.WaitUntilFleetStartedWithContext(aws.BackgroundContext(), input) 18} 19 20// WaitUntilFleetStartedWithContext is an extended version of WaitUntilFleetStarted. 21// With the support for passing in a context and options to configure the 22// Waiter and the underlying request options. 23// 24// The context must be non-nil and will be used for request cancellation. If 25// the context is nil a panic will occur. In the future the SDK may create 26// sub-contexts for http.Requests. See https://golang.org/pkg/context/ 27// for more information on using Contexts. 28func (c *AppStream) WaitUntilFleetStartedWithContext(ctx aws.Context, input *DescribeFleetsInput, opts ...request.WaiterOption) error { 29 w := request.Waiter{ 30 Name: "WaitUntilFleetStarted", 31 MaxAttempts: 40, 32 Delay: request.ConstantWaiterDelay(30 * time.Second), 33 Acceptors: []request.WaiterAcceptor{ 34 { 35 State: request.SuccessWaiterState, 36 Matcher: request.PathAllWaiterMatch, Argument: "Fleets[].State", 37 Expected: "ACTIVE", 38 }, 39 { 40 State: request.FailureWaiterState, 41 Matcher: request.PathAnyWaiterMatch, Argument: "Fleets[].State", 42 Expected: "PENDING_DEACTIVATE", 43 }, 44 { 45 State: request.FailureWaiterState, 46 Matcher: request.PathAnyWaiterMatch, Argument: "Fleets[].State", 47 Expected: "INACTIVE", 48 }, 49 }, 50 Logger: c.Config.Logger, 51 NewRequest: func(opts []request.Option) (*request.Request, error) { 52 var inCpy *DescribeFleetsInput 53 if input != nil { 54 tmp := *input 55 inCpy = &tmp 56 } 57 req, _ := c.DescribeFleetsRequest(inCpy) 58 req.SetContext(ctx) 59 req.ApplyOptions(opts...) 60 return req, nil 61 }, 62 } 63 w.ApplyOptions(opts...) 64 65 return w.WaitWithContext(ctx) 66} 67 68// WaitUntilFleetStopped uses the Amazon AppStream API operation 69// DescribeFleets to wait for a condition to be met before returning. 70// If the condition is not met within the max attempt window, an error will 71// be returned. 72func (c *AppStream) WaitUntilFleetStopped(input *DescribeFleetsInput) error { 73 return c.WaitUntilFleetStoppedWithContext(aws.BackgroundContext(), input) 74} 75 76// WaitUntilFleetStoppedWithContext is an extended version of WaitUntilFleetStopped. 77// With the support for passing in a context and options to configure the 78// Waiter and the underlying request options. 79// 80// The context must be non-nil and will be used for request cancellation. If 81// the context is nil a panic will occur. In the future the SDK may create 82// sub-contexts for http.Requests. See https://golang.org/pkg/context/ 83// for more information on using Contexts. 84func (c *AppStream) WaitUntilFleetStoppedWithContext(ctx aws.Context, input *DescribeFleetsInput, opts ...request.WaiterOption) error { 85 w := request.Waiter{ 86 Name: "WaitUntilFleetStopped", 87 MaxAttempts: 40, 88 Delay: request.ConstantWaiterDelay(30 * time.Second), 89 Acceptors: []request.WaiterAcceptor{ 90 { 91 State: request.SuccessWaiterState, 92 Matcher: request.PathAllWaiterMatch, Argument: "Fleets[].State", 93 Expected: "INACTIVE", 94 }, 95 { 96 State: request.FailureWaiterState, 97 Matcher: request.PathAnyWaiterMatch, Argument: "Fleets[].State", 98 Expected: "PENDING_ACTIVATE", 99 }, 100 { 101 State: request.FailureWaiterState, 102 Matcher: request.PathAnyWaiterMatch, Argument: "Fleets[].State", 103 Expected: "ACTIVE", 104 }, 105 }, 106 Logger: c.Config.Logger, 107 NewRequest: func(opts []request.Option) (*request.Request, error) { 108 var inCpy *DescribeFleetsInput 109 if input != nil { 110 tmp := *input 111 inCpy = &tmp 112 } 113 req, _ := c.DescribeFleetsRequest(inCpy) 114 req.SetContext(ctx) 115 req.ApplyOptions(opts...) 116 return req, nil 117 }, 118 } 119 w.ApplyOptions(opts...) 120 121 return w.WaitWithContext(ctx) 122} 123