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
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
|
// Code generated by smithy-go-codegen DO NOT EDIT.
package qldb
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/aws-sdk-go-v2/service/qldb/types"
"github.com/aws/smithy-go/middleware"
smithyhttp "github.com/aws/smithy-go/transport/http"
"time"
)
// Creates a journal stream for a given Amazon QLDB ledger. The stream captures
// every document revision that is committed to the ledger's journal and delivers
// the data to a specified Amazon Kinesis Data Streams resource.
func (c *Client) StreamJournalToKinesis(ctx context.Context, params *StreamJournalToKinesisInput, optFns ...func(*Options)) (*StreamJournalToKinesisOutput, error) {
if params == nil {
params = &StreamJournalToKinesisInput{}
}
result, metadata, err := c.invokeOperation(ctx, "StreamJournalToKinesis", params, optFns, c.addOperationStreamJournalToKinesisMiddlewares)
if err != nil {
return nil, err
}
out := result.(*StreamJournalToKinesisOutput)
out.ResultMetadata = metadata
return out, nil
}
type StreamJournalToKinesisInput struct {
// The inclusive start date and time from which to start streaming journal data.
// This parameter must be in ISO 8601 date and time format and in Universal
// Coordinated Time (UTC). For example: 2019-06-13T21:36:34Z . The
// InclusiveStartTime cannot be in the future and must be before ExclusiveEndTime .
// If you provide an InclusiveStartTime that is before the ledger's
// CreationDateTime , QLDB effectively defaults it to the ledger's CreationDateTime
// .
//
// This member is required.
InclusiveStartTime *time.Time
// The configuration settings of the Kinesis Data Streams destination for your
// stream request.
//
// This member is required.
KinesisConfiguration *types.KinesisConfiguration
// The name of the ledger.
//
// This member is required.
LedgerName *string
// The Amazon Resource Name (ARN) of the IAM role that grants QLDB permissions for
// a journal stream to write data records to a Kinesis Data Streams resource. To
// pass a role to QLDB when requesting a journal stream, you must have permissions
// to perform the iam:PassRole action on the IAM role resource. This is required
// for all journal stream requests.
//
// This member is required.
RoleArn *string
// The name that you want to assign to the QLDB journal stream. User-defined names
// can help identify and indicate the purpose of a stream. Your stream name must be
// unique among other active streams for a given ledger. Stream names have the same
// naming constraints as ledger names, as defined in Quotas in Amazon QLDB (https://docs.aws.amazon.com/qldb/latest/developerguide/limits.html#limits.naming)
// in the Amazon QLDB Developer Guide.
//
// This member is required.
StreamName *string
// The exclusive date and time that specifies when the stream ends. If you don't
// define this parameter, the stream runs indefinitely until you cancel it. The
// ExclusiveEndTime must be in ISO 8601 date and time format and in Universal
// Coordinated Time (UTC). For example: 2019-06-13T21:36:34Z .
ExclusiveEndTime *time.Time
// The key-value pairs to add as tags to the stream that you want to create. Tag
// keys are case sensitive. Tag values are case sensitive and can be null.
Tags map[string]*string
noSmithyDocumentSerde
}
type StreamJournalToKinesisOutput struct {
// The UUID (represented in Base62-encoded text) that QLDB assigns to each QLDB
// journal stream.
StreamId *string
// Metadata pertaining to the operation's result.
ResultMetadata middleware.Metadata
noSmithyDocumentSerde
}
func (c *Client) addOperationStreamJournalToKinesisMiddlewares(stack *middleware.Stack, options Options) (err error) {
if err := stack.Serialize.Add(&setOperationInputMiddleware{}, middleware.After); err != nil {
return err
}
err = stack.Serialize.Add(&awsRestjson1_serializeOpStreamJournalToKinesis{}, middleware.After)
if err != nil {
return err
}
err = stack.Deserialize.Add(&awsRestjson1_deserializeOpStreamJournalToKinesis{}, middleware.After)
if err != nil {
return err
}
if err := addProtocolFinalizerMiddlewares(stack, options, "StreamJournalToKinesis"); 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 = addOpStreamJournalToKinesisValidationMiddleware(stack); err != nil {
return err
}
if err = stack.Initialize.Add(newServiceMetadataMiddleware_opStreamJournalToKinesis(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_opStreamJournalToKinesis(region string) *awsmiddleware.RegisterServiceMetadata {
return &awsmiddleware.RegisterServiceMetadata{
Region: region,
ServiceID: ServiceID,
OperationName: "StreamJournalToKinesis",
}
}
|
