/
api_op_StopActivityStream.go
136 lines (109 loc) · 4.02 KB
/
api_op_StopActivityStream.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
// Code generated by private/model/cli/gen-api/main.go. DO NOT EDIT.
package rds
import (
"context"
"github.com/aws/aws-sdk-go-v2/aws"
"github.com/aws/aws-sdk-go-v2/internal/awsutil"
)
type StopActivityStreamInput struct {
_ struct{} `type:"structure"`
// Specifies whether or not the database activity stream is to stop as soon
// as possible, regardless of the maintenance window for the database.
ApplyImmediately *bool `type:"boolean"`
// The Amazon Resource Name (ARN) of the DB cluster for the database activity
// stream. For example, arn:aws:rds:us-east-1:12345667890:cluster:das-cluster.
//
// ResourceArn is a required field
ResourceArn *string `type:"string" required:"true"`
}
// String returns the string representation
func (s StopActivityStreamInput) String() string {
return awsutil.Prettify(s)
}
// Validate inspects the fields of the type to determine if they are valid.
func (s *StopActivityStreamInput) Validate() error {
invalidParams := aws.ErrInvalidParams{Context: "StopActivityStreamInput"}
if s.ResourceArn == nil {
invalidParams.Add(aws.NewErrParamRequired("ResourceArn"))
}
if invalidParams.Len() > 0 {
return invalidParams
}
return nil
}
type StopActivityStreamOutput struct {
_ struct{} `type:"structure"`
// The name of the Amazon Kinesis data stream used for the database activity
// stream.
KinesisStreamName *string `type:"string"`
// The AWS KMS key identifier used for encrypting messages in the database activity
// stream.
KmsKeyId *string `type:"string"`
// The status of the database activity stream.
Status ActivityStreamStatus `type:"string" enum:"true"`
}
// String returns the string representation
func (s StopActivityStreamOutput) String() string {
return awsutil.Prettify(s)
}
const opStopActivityStream = "StopActivityStream"
// StopActivityStreamRequest returns a request value for making API operation for
// Amazon Relational Database Service.
//
// Stops a database activity stream that was started using the AWS console,
// the start-activity-stream AWS CLI command, or the StartActivityStream action.
//
// For more information, see Database Activity Streams (https://docs.aws.amazon.com/AmazonRDS/latest/AuroraUserGuide/DBActivityStreams.html)
// in the Amazon Aurora User Guide.
//
// // Example sending a request using StopActivityStreamRequest.
// req := client.StopActivityStreamRequest(params)
// resp, err := req.Send(context.TODO())
// if err == nil {
// fmt.Println(resp)
// }
//
// Please also see https://docs.aws.amazon.com/goto/WebAPI/rds-2014-10-31/StopActivityStream
func (c *Client) StopActivityStreamRequest(input *StopActivityStreamInput) StopActivityStreamRequest {
op := &aws.Operation{
Name: opStopActivityStream,
HTTPMethod: "POST",
HTTPPath: "/",
}
if input == nil {
input = &StopActivityStreamInput{}
}
req := c.newRequest(op, input, &StopActivityStreamOutput{})
return StopActivityStreamRequest{Request: req, Input: input, Copy: c.StopActivityStreamRequest}
}
// StopActivityStreamRequest is the request type for the
// StopActivityStream API operation.
type StopActivityStreamRequest struct {
*aws.Request
Input *StopActivityStreamInput
Copy func(*StopActivityStreamInput) StopActivityStreamRequest
}
// Send marshals and sends the StopActivityStream API request.
func (r StopActivityStreamRequest) Send(ctx context.Context) (*StopActivityStreamResponse, error) {
r.Request.SetContext(ctx)
err := r.Request.Send()
if err != nil {
return nil, err
}
resp := &StopActivityStreamResponse{
StopActivityStreamOutput: r.Request.Data.(*StopActivityStreamOutput),
response: &aws.Response{Request: r.Request},
}
return resp, nil
}
// StopActivityStreamResponse is the response type for the
// StopActivityStream API operation.
type StopActivityStreamResponse struct {
*StopActivityStreamOutput
response *aws.Response
}
// SDKResponseMetdata returns the response metadata for the
// StopActivityStream request.
func (r *StopActivityStreamResponse) SDKResponseMetdata() *aws.Response {
return r.response
}