/
api_op_DeleteChannel.go
192 lines (160 loc) · 5.26 KB
/
api_op_DeleteChannel.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
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
187
188
189
190
191
192
// Code generated by smithy-go-codegen DO NOT EDIT.
package medialive
import (
"context"
"fmt"
awsmiddleware "github.com/aws/aws-sdk-go-v2/aws/middleware"
"github.com/aws/aws-sdk-go-v2/service/medialive/types"
"github.com/aws/smithy-go/middleware"
smithyhttp "github.com/aws/smithy-go/transport/http"
)
// Starts deletion of channel. The associated outputs are also deleted.
func (c *Client) DeleteChannel(ctx context.Context, params *DeleteChannelInput, optFns ...func(*Options)) (*DeleteChannelOutput, error) {
if params == nil {
params = &DeleteChannelInput{}
}
result, metadata, err := c.invokeOperation(ctx, "DeleteChannel", params, optFns, c.addOperationDeleteChannelMiddlewares)
if err != nil {
return nil, err
}
out := result.(*DeleteChannelOutput)
out.ResultMetadata = metadata
return out, nil
}
// Placeholder documentation for DeleteChannelRequest
type DeleteChannelInput struct {
// Unique ID of the channel.
//
// This member is required.
ChannelId *string
noSmithyDocumentSerde
}
// Placeholder documentation for DeleteChannelResponse
type DeleteChannelOutput struct {
// The unique arn of the channel.
Arn *string
// Specification of CDI inputs for this channel
CdiInputSpecification *types.CdiInputSpecification
// The class for this channel. STANDARD for a channel with two pipelines or
// SINGLE_PIPELINE for a channel with one pipeline.
ChannelClass types.ChannelClass
// A list of destinations of the channel. For UDP outputs, there is one
// destination per output. For other types (HLS, for example), there is one
// destination per packager.
Destinations []types.OutputDestination
// The endpoints where outgoing connections initiate from
EgressEndpoints []types.ChannelEgressEndpoint
// Encoder Settings
EncoderSettings *types.EncoderSettings
// The unique id of the channel.
Id *string
// List of input attachments for channel.
InputAttachments []types.InputAttachment
// Specification of network and file inputs for this channel
InputSpecification *types.InputSpecification
// The log level being written to CloudWatch Logs.
LogLevel types.LogLevel
// Maintenance settings for this channel.
Maintenance *types.MaintenanceStatus
// The name of the channel. (user-mutable)
Name *string
// Runtime details for the pipelines of a running channel.
PipelineDetails []types.PipelineDetail
// The number of currently healthy pipelines.
PipelinesRunningCount *int32
// The Amazon Resource Name (ARN) of the role assumed when running the Channel.
RoleArn *string
// Placeholder documentation for ChannelState
State types.ChannelState
// A collection of key-value pairs.
Tags map[string]string
// Settings for VPC output
Vpc *types.VpcOutputSettingsDescription
// Metadata pertaining to the operation's result.
ResultMetadata middleware.Metadata
noSmithyDocumentSerde
}
func (c *Client) addOperationDeleteChannelMiddlewares(stack *middleware.Stack, options Options) (err error) {
if err := stack.Serialize.Add(&setOperationInputMiddleware{}, middleware.After); err != nil {
return err
}
err = stack.Serialize.Add(&awsRestjson1_serializeOpDeleteChannel{}, middleware.After)
if err != nil {
return err
}
err = stack.Deserialize.Add(&awsRestjson1_deserializeOpDeleteChannel{}, middleware.After)
if err != nil {
return err
}
if err := addProtocolFinalizerMiddlewares(stack, options, "DeleteChannel"); 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 = addClientRequestID(stack); err != nil {
return err
}
if err = addComputeContentLength(stack); err != nil {
return err
}
if err = addResolveEndpointMiddleware(stack, options); err != nil {
return err
}
if err = addComputePayloadSHA256(stack); err != nil {
return err
}
if err = addRetry(stack, options); err != nil {
return err
}
if err = addRawResponseToMetadata(stack); err != nil {
return err
}
if err = 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 = addOpDeleteChannelValidationMiddleware(stack); err != nil {
return err
}
if err = stack.Initialize.Add(newServiceMetadataMiddleware_opDeleteChannel(options.Region), middleware.Before); err != nil {
return err
}
if err = 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_opDeleteChannel(region string) *awsmiddleware.RegisterServiceMetadata {
return &awsmiddleware.RegisterServiceMetadata{
Region: region,
ServiceID: ServiceID,
OperationName: "DeleteChannel",
}
}