Wala shell

Advanced PHP File Manager

Server IP: 127.0.0.1 | PHP Version: 8.3.30 | Domains Hosted: 54

Name	Size	Last Modified	Actions
📁 ..	-	2025-05-25 12:27
📄 api.go // Code generated by private/model/cli/gen-api/main.go. DO NOT EDIT. package kinesisvideoarchivedmedia import ( "fmt" "io" "time" "github.com/aws/aws-sdk-go/aws" "github.com/aws/aws-sdk-go/aws/awsutil" "github.com/aws/aws-sdk-go/aws/request" "github.com/aws/aws-sdk-go/private/protocol" ) const opGetClip = "GetClip" // GetClipRequest generates a "aws/request.Request" representing the // client's request for the GetClip operation. The "output" return // value will be populated with the request's response once the request completes // successfully. // // Use "Send" method on the returned Request to send the API call to the service. // the "output" return value is not valid until after Send returns without error. // // See GetClip for more information on using the GetClip // API call, and error handling. // // This method is useful when you want to inject custom logic or configuration // into the SDK's request lifecycle. Such as custom headers, or retry logic. // // // Example sending a request using the GetClipRequest method. // req, resp := client.GetClipRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // // See also, https://docs.aws.amazon.com/goto/WebAPI/kinesis-video-archived-media-2017-09-30/GetClip func (c KinesisVideoArchivedMedia) GetClipRequest(input GetClipInput) (req request.Request, output GetClipOutput) { op := &request.Operation{ Name: opGetClip, HTTPMethod: "POST", HTTPPath: "/getClip", } if input == nil { input = &GetClipInput{} } output = &GetClipOutput{} req = c.newRequest(op, input, output) return } // GetClip API operation for Amazon Kinesis Video Streams Archived Media. // // Downloads an MP4 file (clip) containing the archived, on-demand media from // the specified video stream over the specified time range. // // Both the StreamName and the StreamARN parameters are optional, but you must // specify either the StreamName or the StreamARN when invoking this API operation. // // As a prerequisite to using GetCLip API, you must obtain an endpoint using // GetDataEndpoint, specifying GET_CLIP for the APIName parameter. // // An Amazon Kinesis video stream has the following requirements for providing // data through MP4: // // - The media must contain h.264 or h.265 encoded video and, optionally, // AAC or G.711 encoded audio. Specifically, the codec ID of track 1 should // be V_MPEG/ISO/AVC (for h.264) or V_MPEGH/ISO/HEVC (for H.265). Optionally, // the codec ID of track 2 should be A_AAC (for AAC) or A_MS/ACM (for G.711). // // - Data retention must be greater than 0. // // - The video track of each fragment must contain codec private data in // the Advanced Video Coding (AVC) for H.264 format and HEVC for H.265 format. // For more information, see MPEG-4 specification ISO/IEC 14496-15 (https://www.iso.org/standard/55980.html). // For information about adapting stream data to a given format, see NAL // Adaptation Flags (http://docs.aws.amazon.com/kinesisvideostreams/latest/dg/producer-reference-nal.html). // // - The audio track (if present) of each fragment must contain codec private // data in the AAC format (AAC specification ISO/IEC 13818-7 (https://www.iso.org/standard/43345.html)) // or the MS Wave format (http://www-mmsp.ece.mcgill.ca/Documents/AudioFormats/WAVE/WAVE.html). // // You can monitor the amount of outgoing data by monitoring the GetClip.OutgoingBytes // Amazon CloudWatch metric. For information about using CloudWatch to monitor // Kinesis Video Streams, see Monitoring Kinesis Video Streams (http://docs.aws.amazon.com/kinesisvideostreams/latest/dg/monitoring.html). // For pricing information, see Amazon Kinesis Video Streams Pricing (https://aws.amazon.com/kinesis/video-streams/pricing/) // and Amazon Web Services Pricing (https://aws.amazon.com/pricing/). Charges // for outgoing Amazon Web Services data apply. // // Returns awserr.Error for service API and SDK errors. Use runtime type assertions // with awserr.Error's Code and Message methods to get detailed information about // the error. // // See the AWS API reference guide for Amazon Kinesis Video Streams Archived Media's // API operation GetClip for usage and error information. // // Returned Error Types: // // - ResourceNotFoundException // GetImages will throw this error when Kinesis Video Streams can't find the // stream that you specified. // // GetHLSStreamingSessionURL and GetDASHStreamingSessionURL throw this error // if a session with a PlaybackMode of ON_DEMAND or LIVE_REPLAYis requested // for a stream that has no fragments within the requested time range, or if // a session with a PlaybackMode of LIVE is requested for a stream that has // no fragments within the last 30 seconds. // // - InvalidArgumentException // A specified parameter exceeds its restrictions, is not supported, or can't // be used. // // - ClientLimitExceededException // Kinesis Video Streams has throttled the request because you have exceeded // a limit. Try making the call later. For information about limits, see Kinesis // Video Streams Limits (http://docs.aws.amazon.com/kinesisvideostreams/latest/dg/limits.html). // // - NotAuthorizedException // Status Code: 403, The caller is not authorized to perform an operation on // the given stream, or the token has expired. // // - UnsupportedStreamMediaTypeException // The type of the media (for example, h.264 or h.265 video or ACC or G.711 // audio) could not be determined from the codec IDs of the tracks in the first // fragment for a playback session. The codec ID for track 1 should be V_MPEG/ISO/AVC // and, optionally, the codec ID for track 2 should be A_AAC. // // - MissingCodecPrivateDataException // No codec private data was found in at least one of tracks of the video stream. // // - InvalidCodecPrivateDataException // The codec private data in at least one of the tracks of the video stream // is not valid for this operation. // // - InvalidMediaFrameException // One or more frames in the requested clip could not be parsed based on the // specified codec. // // - NoDataRetentionException // GetImages was requested for a stream that does not retain data (that is, // has a DataRetentionInHours of 0). // // See also, https://docs.aws.amazon.com/goto/WebAPI/kinesis-video-archived-media-2017-09-30/GetClip func (c KinesisVideoArchivedMedia) GetClip(input GetClipInput) (GetClipOutput, error) { req, out := c.GetClipRequest(input) return out, req.Send() } // GetClipWithContext is the same as GetClip with the addition of // the ability to pass a context and additional request options. // // See GetClip for details on how to use this API operation. // // The context must be non-nil and will be used for request cancellation. If // the context is nil a panic will occur. In the future the SDK may create // sub-contexts for http.Requests. See https://golang.org/pkg/context/ // for more information on using Contexts. func (c KinesisVideoArchivedMedia) GetClipWithContext(ctx aws.Context, input GetClipInput, opts ...request.Option) (GetClipOutput, error) { req, out := c.GetClipRequest(input) req.SetContext(ctx) req.ApplyOptions(opts...) return out, req.Send() } const opGetDASHStreamingSessionURL = "GetDASHStreamingSessionURL" // GetDASHStreamingSessionURLRequest generates a "aws/request.Request" representing the // client's request for the GetDASHStreamingSessionURL operation. The "output" return // value will be populated with the request's response once the request completes // successfully. // // Use "Send" method on the returned Request to send the API call to the service. // the "output" return value is not valid until after Send returns without error. // // See GetDASHStreamingSessionURL for more information on using the GetDASHStreamingSessionURL // API call, and error handling. // // This method is useful when you want to inject custom logic or configuration // into the SDK's request lifecycle. Such as custom headers, or retry logic. // // // Example sending a request using the GetDASHStreamingSessionURLRequest method. // req, resp := client.GetDASHStreamingSessionURLRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // // See also, https://docs.aws.amazon.com/goto/WebAPI/kinesis-video-archived-media-2017-09-30/GetDASHStreamingSessionURL func (c KinesisVideoArchivedMedia) GetDASHStreamingSessionURLRequest(input GetDASHStreamingSessionURLInput) (req request.Request, output GetDASHStreamingSessionURLOutput) { op := &request.Operation{ Name: opGetDASHStreamingSessionURL, HTTPMethod: "POST", HTTPPath: "/getDASHStreamingSessionURL", } if input == nil { input = &GetDASHStreamingSessionURLInput{} } output = &GetDASHStreamingSessionURLOutput{} req = c.newRequest(op, input, output) return } // GetDASHStreamingSessionURL API operation for Amazon Kinesis Video Streams Archived Media. // // Retrieves an MPEG Dynamic Adaptive Streaming over HTTP (DASH) URL for the // stream. You can then open the URL in a media player to view the stream contents. // // Both the StreamName and the StreamARN parameters are optional, but you must // specify either the StreamName or the StreamARN when invoking this API operation. // // An Amazon Kinesis video stream has the following requirements for providing // data through MPEG-DASH: // // - The media must contain h.264 or h.265 encoded video and, optionally, // AAC or G.711 encoded audio. Specifically, the codec ID of track 1 should // be V_MPEG/ISO/AVC (for h.264) or V_MPEGH/ISO/HEVC (for H.265). Optionally, // the codec ID of track 2 should be A_AAC (for AAC) or A_MS/ACM (for G.711). // // - Data retention must be greater than 0. // // - The video track of each fragment must contain codec private data in // the Advanced Video Coding (AVC) for H.264 format and HEVC for H.265 format. // For more information, see MPEG-4 specification ISO/IEC 14496-15 (https://www.iso.org/standard/55980.html). // For information about adapting stream data to a given format, see NAL // Adaptation Flags (http://docs.aws.amazon.com/kinesisvideostreams/latest/dg/producer-reference-nal.html). // // - The audio track (if present) of each fragment must contain codec private // data in the AAC format (AAC specification ISO/IEC 13818-7 (https://www.iso.org/standard/43345.html)) // or the MS Wave format (http://www-mmsp.ece.mcgill.ca/Documents/AudioFormats/WAVE/WAVE.html). // // The following procedure shows how to use MPEG-DASH with Kinesis Video Streams: // // Get an endpoint using GetDataEndpoint (http://docs.aws.amazon.com/kinesisvideostreams/latest/dg/API_GetDataEndpoint.html), // specifying GET_DASH_STREAMING_SESSION_URL for the APIName parameter. // // Retrieve the MPEG-DASH URL using GetDASHStreamingSessionURL. Kinesis Video // Streams creates an MPEG-DASH streaming session to be used for accessing content // in a stream using the MPEG-DASH protocol. GetDASHStreamingSessionURL returns // an authenticated URL (that includes an encrypted session token) for the session's // MPEG-DASH manifest (the root resource needed for streaming with MPEG-DASH). // // Don't share or store this token where an unauthorized entity can access it. // The token provides access to the content of the stream. Safeguard the token // with the same measures that you use with your Amazon Web Services credentials. // // The media that is made available through the manifest consists only of the // requested stream, time range, and format. No other media data (such as frames // outside the requested window or alternate bitrates) is made available. // // Provide the URL (containing the encrypted session token) for the MPEG-DASH // manifest to a media player that supports the MPEG-DASH protocol. Kinesis // Video Streams makes the initialization fragment and media fragments available // through the manifest URL. The initialization fragment contains the codec // private data for the stream, and other data needed to set up the video or // audio decoder and renderer. The media fragments contain encoded video frames // or encoded audio samples. // // The media player receives the authenticated URL and requests stream metadata // and media data normally. When the media player requests data, it calls the // following actions: // // - GetDASHManifest: Retrieves an MPEG DASH manifest, which contains the // metadata for the media that you want to playback. // // - GetMP4InitFragment: Retrieves the MP4 initialization fragment. The media // player typically loads the initialization fragment before loading any // media fragments. This fragment contains the "fytp" and "moov" MP4 atoms, // and the child atoms that are needed to initialize the media player decoder. // The initialization fragment does not correspond to a fragment in a Kinesis // video stream. It contains only the codec private data for the stream and // respective track, which the media player needs to decode the media frames. // // - GetMP4MediaFragment: Retrieves MP4 media fragments. These fragments // contain the "moof" and "mdat" MP4 atoms and their child atoms, containing // the encoded fragment's media frames and their timestamps. After the first // media fragment is made available in a streaming session, any fragments // that don't contain the same codec private data cause an error to be returned // when those different media fragments are loaded. Therefore, the codec // private data should not change between fragments in a session. This also // means that the session fails if the fragments in a stream change from // having only video to having both audio and video. Data retrieved with // this action is billable. See Pricing (https://aws.amazon.com/kinesis/video-streams/pricing/) // for details. // // For restrictions that apply to MPEG-DASH sessions, see Kinesis Video Streams // Limits (http://docs.aws.amazon.com/kinesisvideostreams/latest/dg/limits.html). // // You can monitor the amount of data that the media player consumes by monitoring // the GetMP4MediaFragment.OutgoingBytes Amazon CloudWatch metric. For information // about using CloudWatch to monitor Kinesis Video Streams, see Monitoring Kinesis // Video Streams (http://docs.aws.amazon.com/kinesisvideostreams/latest/dg/monitoring.html). // For pricing information, see Amazon Kinesis Video Streams Pricing (https://aws.amazon.com/kinesis/video-streams/pricing/) // and Amazon Web Services Pricing (https://aws.amazon.com/pricing/). Charges // for both HLS sessions and outgoing Amazon Web Services data apply. // // For more information about HLS, see HTTP Live Streaming (https://developer.apple.com/streaming/) // on the Apple Developer site (https://developer.apple.com). // // If an error is thrown after invoking a Kinesis Video Streams archived media // API, in addition to the HTTP status code and the response body, it includes // the following pieces of information: // // - x-amz-ErrorType HTTP header – contains a more specific error type // in addition to what the HTTP status code provides. // // - x-amz-RequestId HTTP header – if you want to report an issue to Amazon // Web Services the support team can better diagnose the problem if given // the Request Id. // // Both the HTTP status code and the ErrorType header can be utilized to make // programmatic decisions about whether errors are retry-able and under what // conditions, as well as provide information on what actions the client programmer // might need to take in order to successfully try again. // // For more information, see the Errors section at the bottom of this topic, // as well as Common Errors (https://docs.aws.amazon.com/kinesisvideostreams/latest/dg/CommonErrors.html). // // Returns awserr.Error for service API and SDK errors. Use runtime type assertions // with awserr.Error's Code and Message methods to get detailed information about // the error. // // See the AWS API reference guide for Amazon Kinesis Video Streams Archived Media's // API operation GetDASHStreamingSessionURL for usage and error information. // // Returned Error Types: // // - ResourceNotFoundException // GetImages will throw this error when Kinesis Video Streams can't find the // stream that you specified. // // GetHLSStreamingSessionURL and GetDASHStreamingSessionURL throw this error // if a session with a PlaybackMode of ON_DEMAND or LIVE_REPLAYis requested // for a stream that has no fragments within the requested time range, or if // a session with a PlaybackMode of LIVE is requested for a stream that has // no fragments within the last 30 seconds. // // - InvalidArgumentException // A specified parameter exceeds its restrictions, is not supported, or can't // be used. // // - ClientLimitExceededException // Kinesis Video Streams has throttled the request because you have exceeded // a limit. Try making the call later. For information about limits, see Kinesis // Video Streams Limits (http://docs.aws.amazon.com/kinesisvideostreams/latest/dg/limits.html). // // - NotAuthorizedException // Status Code: 403, The caller is not authorized to perform an operation on // the given stream, or the token has expired. // // - UnsupportedStreamMediaTypeException // The type of the media (for example, h.264 or h.265 video or ACC or G.711 // audio) could not be determined from the codec IDs of the tracks in the first // fragment for a playback session. The codec ID for track 1 should be V_MPEG/ISO/AVC // and, optionally, the codec ID for track 2 should be A_AAC. // // - NoDataRetentionException // GetImages was requested for a stream that does not retain data (that is, // has a DataRetentionInHours of 0). // // - MissingCodecPrivateDataException // No codec private data was found in at least one of tracks of the video stream. // // - InvalidCodecPrivateDataException // The codec private data in at least one of the tracks of the video stream // is not valid for this operation. // // See also, https://docs.aws.amazon.com/goto/WebAPI/kinesis-video-archived-media-2017-09-30/GetDASHStreamingSessionURL func (c KinesisVideoArchivedMedia) GetDASHStreamingSessionURL(input GetDASHStreamingSessionURLInput) (GetDASHStreamingSessionURLOutput, error) { req, out := c.GetDASHStreamingSessionURLRequest(input) return out, req.Send() } // GetDASHStreamingSessionURLWithContext is the same as GetDASHStreamingSessionURL with the addition of // the ability to pass a context and additional request options. // // See GetDASHStreamingSessionURL for details on how to use this API operation. // // The context must be non-nil and will be used for request cancellation. If // the context is nil a panic will occur. In the future the SDK may create // sub-contexts for http.Requests. See https://golang.org/pkg/context/ // for more information on using Contexts. func (c KinesisVideoArchivedMedia) GetDASHStreamingSessionURLWithContext(ctx aws.Context, input GetDASHStreamingSessionURLInput, opts ...request.Option) (GetDASHStreamingSessionURLOutput, error) { req, out := c.GetDASHStreamingSessionURLRequest(input) req.SetContext(ctx) req.ApplyOptions(opts...) return out, req.Send() } const opGetHLSStreamingSessionURL = "GetHLSStreamingSessionURL" // GetHLSStreamingSessionURLRequest generates a "aws/request.Request" representing the // client's request for the GetHLSStreamingSessionURL operation. The "output" return // value will be populated with the request's response once the request completes // successfully. // // Use "Send" method on the returned Request to send the API call to the service. // the "output" return value is not valid until after Send returns without error. // // See GetHLSStreamingSessionURL for more information on using the GetHLSStreamingSessionURL // API call, and error handling. // // This method is useful when you want to inject custom logic or configuration // into the SDK's request lifecycle. Such as custom headers, or retry logic. // // // Example sending a request using the GetHLSStreamingSessionURLRequest method. // req, resp := client.GetHLSStreamingSessionURLRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // // See also, https://docs.aws.amazon.com/goto/WebAPI/kinesis-video-archived-media-2017-09-30/GetHLSStreamingSessionURL func (c KinesisVideoArchivedMedia) GetHLSStreamingSessionURLRequest(input GetHLSStreamingSessionURLInput) (req request.Request, output GetHLSStreamingSessionURLOutput) { op := &request.Operation{ Name: opGetHLSStreamingSessionURL, HTTPMethod: "POST", HTTPPath: "/getHLSStreamingSessionURL", } if input == nil { input = &GetHLSStreamingSessionURLInput{} } output = &GetHLSStreamingSessionURLOutput{} req = c.newRequest(op, input, output) return } // GetHLSStreamingSessionURL API operation for Amazon Kinesis Video Streams Archived Media. // // Retrieves an HTTP Live Streaming (HLS) URL for the stream. You can then open // the URL in a browser or media player to view the stream contents. // // Both the StreamName and the StreamARN parameters are optional, but you must // specify either the StreamName or the StreamARN when invoking this API operation. // // An Amazon Kinesis video stream has the following requirements for providing // data through HLS: // // - For streaming video, the media must contain H.264 or H.265 encoded video // and, optionally, AAC encoded audio. Specifically, the codec ID of track // 1 should be V_MPEG/ISO/AVC (for H.264) or V_MPEG/ISO/HEVC (for H.265). // Optionally, the codec ID of track 2 should be A_AAC. For audio only streaming, // the codec ID of track 1 should be A_AAC. // // - Data retention must be greater than 0. // // - The video track of each fragment must contain codec private data in // the Advanced Video Coding (AVC) for H.264 format or HEVC for H.265 format // (MPEG-4 specification ISO/IEC 14496-15 (https://www.iso.org/standard/55980.html)). // For information about adapting stream data to a given format, see NAL // Adaptation Flags (http://docs.aws.amazon.com/kinesisvideostreams/latest/dg/producer-reference-nal.html). // // - The audio track (if present) of each fragment must contain codec private // data in the AAC format (AAC specification ISO/IEC 13818-7 (https://www.iso.org/standard/43345.html)). // // Kinesis Video Streams HLS sessions contain fragments in the fragmented MPEG-4 // form (also called fMP4 or CMAF) or the MPEG-2 form (also called TS chunks, // which the HLS specification also supports). For more information about HLS // fragment types, see the HLS specification (https://tools.ietf.org/html/draft-pantos-http-live-streaming-23). // // The following procedure shows how to use HLS with Kinesis Video Streams: // // Get an endpoint using GetDataEndpoint (http://docs.aws.amazon.com/kinesisvideostreams/latest/dg/API_GetDataEndpoint.html), // specifying GET_HLS_STREAMING_SESSION_URL for the APIName parameter. // // Retrieve the HLS URL using GetHLSStreamingSessionURL. Kinesis Video Streams // creates an HLS streaming session to be used for accessing content in a stream // using the HLS protocol. GetHLSStreamingSessionURL returns an authenticated // URL (that includes an encrypted session token) for the session's HLS master // playlist (the root resource needed for streaming with HLS). // // Don't share or store this token where an unauthorized entity could access // it. The token provides access to the content of the stream. Safeguard the // token with the same measures that you would use with your Amazon Web Services // credentials. // // The media that is made available through the playlist consists only of the // requested stream, time range, and format. No other media data (such as frames // outside the requested window or alternate bitrates) is made available. // // Provide the URL (containing the encrypted session token) for the HLS master // playlist to a media player that supports the HLS protocol. Kinesis Video // Streams makes the HLS media playlist, initialization fragment, and media // fragments available through the master playlist URL. The initialization fragment // contains the codec private data for the stream, and other data needed to // set up the video or audio decoder and renderer. The media fragments contain // H.264-encoded video frames or AAC-encoded audio samples. // // The media player receives the authenticated URL and requests stream metadata // and media data normally. When the media player requests data, it calls the // following actions: // // - GetHLSMasterPlaylist: Retrieves an HLS master playlist, which contains // a URL for the GetHLSMediaPlaylist action for each track, and additional // metadata for the media player, including estimated bitrate and resolution. // // - GetHLSMediaPlaylist: Retrieves an HLS media playlist, which contains // a URL to access the MP4 initialization fragment with the GetMP4InitFragment // action, and URLs to access the MP4 media fragments with the GetMP4MediaFragment // actions. The HLS media playlist also contains metadata about the stream // that the player needs to play it, such as whether the PlaybackMode is // LIVE or ON_DEMAND. The HLS media playlist is typically static for sessions // with a PlaybackType of ON_DEMAND. The HLS media playlist is continually // updated with new fragments for sessions with a PlaybackType of LIVE. There // is a distinct HLS media playlist for the video track and the audio track // (if applicable) that contains MP4 media URLs for the specific track. // // - GetMP4InitFragment: Retrieves the MP4 initialization fragment. The media // player typically loads the initialization fragment before loading any // media fragments. This fragment contains the "fytp" and "moov" MP4 atoms, // and the child atoms that are needed to initialize the media player decoder. // The initialization fragment does not correspond to a fragment in a Kinesis // video stream. It contains only the codec private data for the stream and // respective track, which the media player needs to decode the media frames. // // - GetMP4MediaFragment: Retrieves MP4 media fragments. These fragments // contain the "moof" and "mdat" MP4 atoms and their child atoms, containing // the encoded fragment's media frames and their timestamps. For the HLS // streaming session, in-track codec private data (CPD) changes are supported. // After the first media fragment is made available in a streaming session, // fragments can contain CPD changes for each track. Therefore, the fragments // in a session can have a different resolution, bit rate, or other information // in the CPD without interrupting playback. However, any change made in // the track number or track codec format can return an error when those // different media fragments are loaded. For example, streaming will fail // if the fragments in the stream change from having only video to having // both audio and video, or if an AAC audio track is changed to an ALAW audio // track. For each streaming session, only 500 CPD changes are allowed. Data // retrieved with this action is billable. For information, see Pricing (https://aws.amazon.com/kinesis/video-streams/pricing/). // // - GetTSFragment: Retrieves MPEG TS fragments containing both initialization // and media data for all tracks in the stream. If the ContainerFormat is // MPEG_TS, this API is used instead of GetMP4InitFragment and GetMP4MediaFragment // to retrieve stream media. Data retrieved with this action is billable. // For more information, see Kinesis Video Streams pricing (https://aws.amazon.com/kinesis/video-streams/pricing/). // // A streaming session URL must not be shared between players. The service might // throttle a session if multiple media players are sharing it. For connection // limits, see Kinesis Video Streams Limits (http://docs.aws.amazon.com/kinesisvideostreams/latest/dg/limits.html). // // You can monitor the amount of data that the media player consumes by monitoring // the GetMP4MediaFragment.OutgoingBytes Amazon CloudWatch metric. For information // about using CloudWatch to monitor Kinesis Video Streams, see Monitoring Kinesis // Video Streams (http://docs.aws.amazon.com/kinesisvideostreams/latest/dg/monitoring.html). // For pricing information, see Amazon Kinesis Video Streams Pricing (https://aws.amazon.com/kinesis/video-streams/pricing/) // and Amazon Web Services Pricing (https://aws.amazon.com/pricing/). Charges // for both HLS sessions and outgoing Amazon Web Services data apply. // // For more information about HLS, see HTTP Live Streaming (https://developer.apple.com/streaming/) // on the Apple Developer site (https://developer.apple.com). // // If an error is thrown after invoking a Kinesis Video Streams archived media // API, in addition to the HTTP status code and the response body, it includes // the following pieces of information: // // - x-amz-ErrorType HTTP header – contains a more specific error type // in addition to what the HTTP status code provides. // // - x-amz-RequestId HTTP header – if you want to report an issue to Amazon // Web Services, the support team can better diagnose the problem if given // the Request Id. // // Both the HTTP status code and the ErrorType header can be utilized to make // programmatic decisions about whether errors are retry-able and under what // conditions, as well as provide information on what actions the client programmer // might need to take in order to successfully try again. // // For more information, see the Errors section at the bottom of this topic, // as well as Common Errors (https://docs.aws.amazon.com/kinesisvideostreams/latest/dg/CommonErrors.html). // // Returns awserr.Error for service API and SDK errors. Use runtime type assertions // with awserr.Error's Code and Message methods to get detailed information about // the error. // // See the AWS API reference guide for Amazon Kinesis Video Streams Archived Media's // API operation GetHLSStreamingSessionURL for usage and error information. // // Returned Error Types: // // - ResourceNotFoundException // GetImages will throw this error when Kinesis Video Streams can't find the // stream that you specified. // // GetHLSStreamingSessionURL and GetDASHStreamingSessionURL throw this error // if a session with a PlaybackMode of ON_DEMAND or LIVE_REPLAYis requested // for a stream that has no fragments within the requested time range, or if // a session with a PlaybackMode of LIVE is requested for a stream that has // no fragments within the last 30 seconds. // // - InvalidArgumentException // A specified parameter exceeds its restrictions, is not supported, or can't // be used. // // - ClientLimitExceededException // Kinesis Video Streams has throttled the request because you have exceeded // a limit. Try making the call later. For information about limits, see Kinesis // Video Streams Limits (http://docs.aws.amazon.com/kinesisvideostreams/latest/dg/limits.html). // // - NotAuthorizedException // Status Code: 403, The caller is not authorized to perform an operation on // the given stream, or the token has expired. // // - UnsupportedStreamMediaTypeException // The type of the media (for example, h.264 or h.265 video or ACC or G.711 // audio) could not be determined from the codec IDs of the tracks in the first // fragment for a playback session. The codec ID for track 1 should be V_MPEG/ISO/AVC // and, optionally, the codec ID for track 2 should be A_AAC. // // - NoDataRetentionException // GetImages was requested for a stream that does not retain data (that is, // has a DataRetentionInHours of 0). // // - MissingCodecPrivateDataException // No codec private data was found in at least one of tracks of the video stream. // // - InvalidCodecPrivateDataException // The codec private data in at least one of the tracks of the video stream // is not valid for this operation. // // See also, https://docs.aws.amazon.com/goto/WebAPI/kinesis-video-archived-media-2017-09-30/GetHLSStreamingSessionURL func (c KinesisVideoArchivedMedia) GetHLSStreamingSessionURL(input GetHLSStreamingSessionURLInput) (GetHLSStreamingSessionURLOutput, error) { req, out := c.GetHLSStreamingSessionURLRequest(input) return out, req.Send() } // GetHLSStreamingSessionURLWithContext is the same as GetHLSStreamingSessionURL with the addition of // the ability to pass a context and additional request options. // // See GetHLSStreamingSessionURL for details on how to use this API operation. // // The context must be non-nil and will be used for request cancellation. If // the context is nil a panic will occur. In the future the SDK may create // sub-contexts for http.Requests. See https://golang.org/pkg/context/ // for more information on using Contexts. func (c KinesisVideoArchivedMedia) GetHLSStreamingSessionURLWithContext(ctx aws.Context, input GetHLSStreamingSessionURLInput, opts ...request.Option) (GetHLSStreamingSessionURLOutput, error) { req, out := c.GetHLSStreamingSessionURLRequest(input) req.SetContext(ctx) req.ApplyOptions(opts...) return out, req.Send() } const opGetImages = "GetImages" // GetImagesRequest generates a "aws/request.Request" representing the // client's request for the GetImages operation. The "output" return // value will be populated with the request's response once the request completes // successfully. // // Use "Send" method on the returned Request to send the API call to the service. // the "output" return value is not valid until after Send returns without error. // // See GetImages for more information on using the GetImages // API call, and error handling. // // This method is useful when you want to inject custom logic or configuration // into the SDK's request lifecycle. Such as custom headers, or retry logic. // // // Example sending a request using the GetImagesRequest method. // req, resp := client.GetImagesRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // // See also, https://docs.aws.amazon.com/goto/WebAPI/kinesis-video-archived-media-2017-09-30/GetImages func (c KinesisVideoArchivedMedia) GetImagesRequest(input GetImagesInput) (req request.Request, output GetImagesOutput) { op := &request.Operation{ Name: opGetImages, HTTPMethod: "POST", HTTPPath: "/getImages", Paginator: &request.Paginator{ InputTokens: []string{"NextToken"}, OutputTokens: []string{"NextToken"}, LimitToken: "MaxResults", TruncationToken: "", }, } if input == nil { input = &GetImagesInput{} } output = &GetImagesOutput{} req = c.newRequest(op, input, output) return } // GetImages API operation for Amazon Kinesis Video Streams Archived Media. // // Retrieves a list of images corresponding to each timestamp for a given time // range, sampling interval, and image format configuration. // // Returns awserr.Error for service API and SDK errors. Use runtime type assertions // with awserr.Error's Code and Message methods to get detailed information about // the error. // // See the AWS API reference guide for Amazon Kinesis Video Streams Archived Media's // API operation GetImages for usage and error information. // // Returned Error Types: // // - ResourceNotFoundException // GetImages will throw this error when Kinesis Video Streams can't find the // stream that you specified. // // GetHLSStreamingSessionURL and GetDASHStreamingSessionURL throw this error // if a session with a PlaybackMode of ON_DEMAND or LIVE_REPLAYis requested // for a stream that has no fragments within the requested time range, or if // a session with a PlaybackMode of LIVE is requested for a stream that has // no fragments within the last 30 seconds. // // - InvalidArgumentException // A specified parameter exceeds its restrictions, is not supported, or can't // be used. // // - ClientLimitExceededException // Kinesis Video Streams has throttled the request because you have exceeded // a limit. Try making the call later. For information about limits, see Kinesis // Video Streams Limits (http://docs.aws.amazon.com/kinesisvideostreams/latest/dg/limits.html). // // - NotAuthorizedException // Status Code: 403, The caller is not authorized to perform an operation on // the given stream, or the token has expired. // // - NoDataRetentionException // GetImages was requested for a stream that does not retain data (that is, // has a DataRetentionInHours of 0). // // See also, https://docs.aws.amazon.com/goto/WebAPI/kinesis-video-archived-media-2017-09-30/GetImages func (c KinesisVideoArchivedMedia) GetImages(input GetImagesInput) (GetImagesOutput, error) { req, out := c.GetImagesRequest(input) return out, req.Send() } // GetImagesWithContext is the same as GetImages with the addition of // the ability to pass a context and additional request options. // // See GetImages for details on how to use this API operation. // // The context must be non-nil and will be used for request cancellation. If // the context is nil a panic will occur. In the future the SDK may create // sub-contexts for http.Requests. See https://golang.org/pkg/context/ // for more information on using Contexts. func (c KinesisVideoArchivedMedia) GetImagesWithContext(ctx aws.Context, input GetImagesInput, opts ...request.Option) (GetImagesOutput, error) { req, out := c.GetImagesRequest(input) req.SetContext(ctx) req.ApplyOptions(opts...) return out, req.Send() } // GetImagesPages iterates over the pages of a GetImages operation, // calling the "fn" function with the response data for each page. To stop // iterating, return false from the fn function. // // See GetImages method for more information on how to use this operation. // // Note: This operation can generate multiple requests to a service. // // // Example iterating over at most 3 pages of a GetImages operation. // pageNum := 0 // err := client.GetImagesPages(params, // func(page kinesisvideoarchivedmedia.GetImagesOutput, lastPage bool) bool { // pageNum++ // fmt.Println(page) // return pageNum <= 3 // }) func (c KinesisVideoArchivedMedia) GetImagesPages(input GetImagesInput, fn func(GetImagesOutput, bool) bool) error { return c.GetImagesPagesWithContext(aws.BackgroundContext(), input, fn) } // GetImagesPagesWithContext same as GetImagesPages except // it takes a Context and allows setting request options on the pages. // // The context must be non-nil and will be used for request cancellation. If // the context is nil a panic will occur. In the future the SDK may create // sub-contexts for http.Requests. See https://golang.org/pkg/context/ // for more information on using Contexts. func (c KinesisVideoArchivedMedia) GetImagesPagesWithContext(ctx aws.Context, input GetImagesInput, fn func(GetImagesOutput, bool) bool, opts ...request.Option) error { p := request.Pagination{ NewRequest: func() (request.Request, error) { var inCpy GetImagesInput if input != nil { tmp := input inCpy = &tmp } req, _ := c.GetImagesRequest(inCpy) req.SetContext(ctx) req.ApplyOptions(opts...) return req, nil }, } for p.Next() { if !fn(p.Page().(GetImagesOutput), !p.HasNextPage()) { break } } return p.Err() } const opGetMediaForFragmentList = "GetMediaForFragmentList" // GetMediaForFragmentListRequest generates a "aws/request.Request" representing the // client's request for the GetMediaForFragmentList operation. The "output" return // value will be populated with the request's response once the request completes // successfully. // // Use "Send" method on the returned Request to send the API call to the service. // the "output" return value is not valid until after Send returns without error. // // See GetMediaForFragmentList for more information on using the GetMediaForFragmentList // API call, and error handling. // // This method is useful when you want to inject custom logic or configuration // into the SDK's request lifecycle. Such as custom headers, or retry logic. // // // Example sending a request using the GetMediaForFragmentListRequest method. // req, resp := client.GetMediaForFragmentListRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // // See also, https://docs.aws.amazon.com/goto/WebAPI/kinesis-video-archived-media-2017-09-30/GetMediaForFragmentList func (c KinesisVideoArchivedMedia) GetMediaForFragmentListRequest(input GetMediaForFragmentListInput) (req request.Request, output GetMediaForFragmentListOutput) { op := &request.Operation{ Name: opGetMediaForFragmentList, HTTPMethod: "POST", HTTPPath: "/getMediaForFragmentList", } if input == nil { input = &GetMediaForFragmentListInput{} } output = &GetMediaForFragmentListOutput{} req = c.newRequest(op, input, output) return } // GetMediaForFragmentList API operation for Amazon Kinesis Video Streams Archived Media. // // Gets media for a list of fragments (specified by fragment number) from the // archived data in an Amazon Kinesis video stream. // // You must first call the GetDataEndpoint API to get an endpoint. Then send // the GetMediaForFragmentList requests to this endpoint using the --endpoint-url // parameter (https://docs.aws.amazon.com/cli/latest/reference/). // // For limits, see Kinesis Video Streams Limits (http://docs.aws.amazon.com/kinesisvideostreams/latest/dg/limits.html). // // If an error is thrown after invoking a Kinesis Video Streams archived media // API, in addition to the HTTP status code and the response body, it includes // the following pieces of information: // // - x-amz-ErrorType HTTP header – contains a more specific error type // in addition to what the HTTP status code provides. // // - x-amz-RequestId HTTP header – if you want to report an issue to Amazon // Web Services, the support team can better diagnose the problem if given // the Request Id. // // Both the HTTP status code and the ErrorType header can be utilized to make // programmatic decisions about whether errors are retry-able and under what // conditions, as well as provide information on what actions the client programmer // might need to take in order to successfully try again. // // For more information, see the Errors section at the bottom of this topic, // as well as Common Errors (https://docs.aws.amazon.com/kinesisvideostreams/latest/dg/CommonErrors.html). // // Returns awserr.Error for service API and SDK errors. Use runtime type assertions // with awserr.Error's Code and Message methods to get detailed information about // the error. // // See the AWS API reference guide for Amazon Kinesis Video Streams Archived Media's // API operation GetMediaForFragmentList for usage and error information. // // Returned Error Types: // // - ResourceNotFoundException // GetImages will throw this error when Kinesis Video Streams can't find the // stream that you specified. // // GetHLSStreamingSessionURL and GetDASHStreamingSessionURL throw this error // if a session with a PlaybackMode of ON_DEMAND or LIVE_REPLAYis requested // for a stream that has no fragments within the requested time range, or if // a session with a PlaybackMode of LIVE is requested for a stream that has // no fragments within the last 30 seconds. // // - InvalidArgumentException // A specified parameter exceeds its restrictions, is not supported, or can't // be used. // // - ClientLimitExceededException // Kinesis Video Streams has throttled the request because you have exceeded // a limit. Try making the call later. For information about limits, see Kinesis // Video Streams Limits (http://docs.aws.amazon.com/kinesisvideostreams/latest/dg/limits.html). // // - NotAuthorizedException // Status Code: 403, The caller is not authorized to perform an operation on // the given stream, or the token has expired. // // See also, https://docs.aws.amazon.com/goto/WebAPI/kinesis-video-archived-media-2017-09-30/GetMediaForFragmentList func (c KinesisVideoArchivedMedia) GetMediaForFragmentList(input GetMediaForFragmentListInput) (GetMediaForFragmentListOutput, error) { req, out := c.GetMediaForFragmentListRequest(input) return out, req.Send() } // GetMediaForFragmentListWithContext is the same as GetMediaForFragmentList with the addition of // the ability to pass a context and additional request options. // // See GetMediaForFragmentList for details on how to use this API operation. // // The context must be non-nil and will be used for request cancellation. If // the context is nil a panic will occur. In the future the SDK may create // sub-contexts for http.Requests. See https://golang.org/pkg/context/ // for more information on using Contexts. func (c KinesisVideoArchivedMedia) GetMediaForFragmentListWithContext(ctx aws.Context, input GetMediaForFragmentListInput, opts ...request.Option) (GetMediaForFragmentListOutput, error) { req, out := c.GetMediaForFragmentListRequest(input) req.SetContext(ctx) req.ApplyOptions(opts...) return out, req.Send() } const opListFragments = "ListFragments" // ListFragmentsRequest generates a "aws/request.Request" representing the // client's request for the ListFragments operation. The "output" return // value will be populated with the request's response once the request completes // successfully. // // Use "Send" method on the returned Request to send the API call to the service. // the "output" return value is not valid until after Send returns without error. // // See ListFragments for more information on using the ListFragments // API call, and error handling. // // This method is useful when you want to inject custom logic or configuration // into the SDK's request lifecycle. Such as custom headers, or retry logic. // // // Example sending a request using the ListFragmentsRequest method. // req, resp := client.ListFragmentsRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // // See also, https://docs.aws.amazon.com/goto/WebAPI/kinesis-video-archived-media-2017-09-30/ListFragments func (c KinesisVideoArchivedMedia) ListFragmentsRequest(input ListFragmentsInput) (req request.Request, output ListFragmentsOutput) { op := &request.Operation{ Name: opListFragments, HTTPMethod: "POST", HTTPPath: "/listFragments", Paginator: &request.Paginator{ InputTokens: []string{"NextToken"}, OutputTokens: []string{"NextToken"}, LimitToken: "MaxResults", TruncationToken: "", }, } if input == nil { input = &ListFragmentsInput{} } output = &ListFragmentsOutput{} req = c.newRequest(op, input, output) return } // ListFragments API operation for Amazon Kinesis Video Streams Archived Media. // // Returns a list of Fragment objects from the specified stream and timestamp // range within the archived data. // // Listing fragments is eventually consistent. This means that even if the producer // receives an acknowledgment that a fragment is persisted, the result might // not be returned immediately from a request to ListFragments. However, results // are typically available in less than one second. // // You must first call the GetDataEndpoint API to get an endpoint. Then send // the ListFragments requests to this endpoint using the --endpoint-url parameter // (https://docs.aws.amazon.com/cli/latest/reference/). // // If an error is thrown after invoking a Kinesis Video Streams archived media // API, in addition to the HTTP status code and the response body, it includes // the following pieces of information: // // - x-amz-ErrorType HTTP header – contains a more specific error type // in addition to what the HTTP status code provides. // // - x-amz-RequestId HTTP header – if you want to report an issue to Amazon // Web Services, the support team can better diagnose the problem if given // the Request Id. // // Both the HTTP status code and the ErrorType header can be utilized to make // programmatic decisions about whether errors are retry-able and under what // conditions, as well as provide information on what actions the client programmer // might need to take in order to successfully try again. // // For more information, see the Errors section at the bottom of this topic, // as well as Common Errors (https://docs.aws.amazon.com/kinesisvideostreams/latest/dg/CommonErrors.html). // // Returns awserr.Error for service API and SDK errors. Use runtime type assertions // with awserr.Error's Code and Message methods to get detailed information about // the error. // // See the AWS API reference guide for Amazon Kinesis Video Streams Archived Media's // API operation ListFragments for usage and error information. // // Returned Error Types: // // - ResourceNotFoundException // GetImages will throw this error when Kinesis Video Streams can't find the // stream that you specified. // // GetHLSStreamingSessionURL and GetDASHStreamingSessionURL throw this error // if a session with a PlaybackMode of ON_DEMAND or LIVE_REPLAYis requested // for a stream that has no fragments within the requested time range, or if // a session with a PlaybackMode of LIVE is requested for a stream that has // no fragments within the last 30 seconds. // // - InvalidArgumentException // A specified parameter exceeds its restrictions, is not supported, or can't // be used. // // - ClientLimitExceededException // Kinesis Video Streams has throttled the request because you have exceeded // a limit. Try making the call later. For information about limits, see Kinesis // Video Streams Limits (http://docs.aws.amazon.com/kinesisvideostreams/latest/dg/limits.html). // // - NotAuthorizedException // Status Code: 403, The caller is not authorized to perform an operation on // the given stream, or the token has expired. // // See also, https://docs.aws.amazon.com/goto/WebAPI/kinesis-video-archived-media-2017-09-30/ListFragments func (c KinesisVideoArchivedMedia) ListFragments(input ListFragmentsInput) (ListFragmentsOutput, error) { req, out := c.ListFragmentsRequest(input) return out, req.Send() } // ListFragmentsWithContext is the same as ListFragments with the addition of // the ability to pass a context and additional request options. // // See ListFragments for details on how to use this API operation. // // The context must be non-nil and will be used for request cancellation. If // the context is nil a panic will occur. In the future the SDK may create // sub-contexts for http.Requests. See https://golang.org/pkg/context/ // for more information on using Contexts. func (c KinesisVideoArchivedMedia) ListFragmentsWithContext(ctx aws.Context, input ListFragmentsInput, opts ...request.Option) (ListFragmentsOutput, error) { req, out := c.ListFragmentsRequest(input) req.SetContext(ctx) req.ApplyOptions(opts...) return out, req.Send() } // ListFragmentsPages iterates over the pages of a ListFragments operation, // calling the "fn" function with the response data for each page. To stop // iterating, return false from the fn function. // // See ListFragments method for more information on how to use this operation. // // Note: This operation can generate multiple requests to a service. // // // Example iterating over at most 3 pages of a ListFragments operation. // pageNum := 0 // err := client.ListFragmentsPages(params, // func(page kinesisvideoarchivedmedia.ListFragmentsOutput, lastPage bool) bool { // pageNum++ // fmt.Println(page) // return pageNum <= 3 // }) func (c KinesisVideoArchivedMedia) ListFragmentsPages(input ListFragmentsInput, fn func(ListFragmentsOutput, bool) bool) error { return c.ListFragmentsPagesWithContext(aws.BackgroundContext(), input, fn) } // ListFragmentsPagesWithContext same as ListFragmentsPages except // it takes a Context and allows setting request options on the pages. // // The context must be non-nil and will be used for request cancellation. If // the context is nil a panic will occur. In the future the SDK may create // sub-contexts for http.Requests. See https://golang.org/pkg/context/ // for more information on using Contexts. func (c KinesisVideoArchivedMedia) ListFragmentsPagesWithContext(ctx aws.Context, input ListFragmentsInput, fn func(ListFragmentsOutput, bool) bool, opts ...request.Option) error { p := request.Pagination{ NewRequest: func() (request.Request, error) { var inCpy ListFragmentsInput if input != nil { tmp := input inCpy = &tmp } req, _ := c.ListFragmentsRequest(inCpy) req.SetContext(ctx) req.ApplyOptions(opts...) return req, nil }, } for p.Next() { if !fn(p.Page().(ListFragmentsOutput), !p.HasNextPage()) { break } } return p.Err() } // Kinesis Video Streams has throttled the request because you have exceeded // a limit. Try making the call later. For information about limits, see Kinesis // Video Streams Limits (http://docs.aws.amazon.com/kinesisvideostreams/latest/dg/limits.html). type ClientLimitExceededException struct { _ struct{} `type:"structure"` RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"` Message_ string `locationName:"Message" type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ClientLimitExceededException) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ClientLimitExceededException) GoString() string { return s.String() } func newErrorClientLimitExceededException(v protocol.ResponseMetadata) error { return &ClientLimitExceededException{ RespMetadata: v, } } // Code returns the exception type name. func (s ClientLimitExceededException) Code() string { return "ClientLimitExceededException" } // Message returns the exception's message. func (s ClientLimitExceededException) Message() string { if s.Message_ != nil { return s.Message_ } return "" } // OrigErr always returns nil, satisfies awserr.Error interface. func (s ClientLimitExceededException) OrigErr() error { return nil } func (s ClientLimitExceededException) Error() string { return fmt.Sprintf("%s: %s", s.Code(), s.Message()) } // Status code returns the HTTP status code for the request's response error. func (s ClientLimitExceededException) StatusCode() int { return s.RespMetadata.StatusCode } // RequestID returns the service's response RequestID for request. func (s ClientLimitExceededException) RequestID() string { return s.RespMetadata.RequestID } // Describes the timestamp range and timestamp origin of a range of fragments. // // Fragments that have duplicate producer timestamps are deduplicated. This // means that if producers are producing a stream of fragments with producer // timestamps that are approximately equal to the true clock time, the clip // will contain all of the fragments within the requested timestamp range. If // some fragments are ingested within the same time range and very different // points in time, only the oldest ingested collection of fragments are returned. type ClipFragmentSelector struct { _ struct{} `type:"structure"` // The origin of the timestamps to use (Server or Producer). // // FragmentSelectorType is a required field FragmentSelectorType string `type:"string" required:"true" enum:"ClipFragmentSelectorType"` // The range of timestamps to return. // // TimestampRange is a required field TimestampRange ClipTimestampRange `type:"structure" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ClipFragmentSelector) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ClipFragmentSelector) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s ClipFragmentSelector) Validate() error { invalidParams := request.ErrInvalidParams{Context: "ClipFragmentSelector"} if s.FragmentSelectorType == nil { invalidParams.Add(request.NewErrParamRequired("FragmentSelectorType")) } if s.TimestampRange == nil { invalidParams.Add(request.NewErrParamRequired("TimestampRange")) } if s.TimestampRange != nil { if err := s.TimestampRange.Validate(); err != nil { invalidParams.AddNested("TimestampRange", err.(request.ErrInvalidParams)) } } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetFragmentSelectorType sets the FragmentSelectorType field's value. func (s ClipFragmentSelector) SetFragmentSelectorType(v string) ClipFragmentSelector { s.FragmentSelectorType = &v return s } // SetTimestampRange sets the TimestampRange field's value. func (s ClipFragmentSelector) SetTimestampRange(v ClipTimestampRange) ClipFragmentSelector { s.TimestampRange = v return s } // The range of timestamps for which to return fragments. type ClipTimestampRange struct { _ struct{} `type:"structure"` // The end of the timestamp range for the requested media. // // This value must be within 24 hours of the specified StartTimestamp, and it // must be later than the StartTimestamp value. If FragmentSelectorType for // the request is SERVER_TIMESTAMP, this value must be in the past. // // This value is inclusive. The EndTimestamp is compared to the (starting) timestamp // of the fragment. Fragments that start before the EndTimestamp value and continue // past it are included in the session. // // EndTimestamp is a required field EndTimestamp time.Time `type:"timestamp" required:"true"` // The starting timestamp in the range of timestamps for which to return fragments. // // Only fragments that start exactly at or after StartTimestamp are included // in the session. Fragments that start before StartTimestamp and continue past // it aren't included in the session. If FragmentSelectorType is SERVER_TIMESTAMP, // the StartTimestamp must be later than the stream head. // // StartTimestamp is a required field StartTimestamp time.Time `type:"timestamp" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ClipTimestampRange) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ClipTimestampRange) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s ClipTimestampRange) Validate() error { invalidParams := request.ErrInvalidParams{Context: "ClipTimestampRange"} if s.EndTimestamp == nil { invalidParams.Add(request.NewErrParamRequired("EndTimestamp")) } if s.StartTimestamp == nil { invalidParams.Add(request.NewErrParamRequired("StartTimestamp")) } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetEndTimestamp sets the EndTimestamp field's value. func (s ClipTimestampRange) SetEndTimestamp(v time.Time) ClipTimestampRange { s.EndTimestamp = &v return s } // SetStartTimestamp sets the StartTimestamp field's value. func (s ClipTimestampRange) SetStartTimestamp(v time.Time) ClipTimestampRange { s.StartTimestamp = &v return s } // Contains the range of timestamps for the requested media, and the source // of the timestamps. type DASHFragmentSelector struct { _ struct{} `type:"structure"` // The source of the timestamps for the requested media. // // When FragmentSelectorType is set to PRODUCER_TIMESTAMP and GetDASHStreamingSessionURLInput$PlaybackMode // is ON_DEMAND or LIVE_REPLAY, the first fragment ingested with a producer // timestamp within the specified FragmentSelector$TimestampRange is included // in the media playlist. In addition, the fragments with producer timestamps // within the TimestampRange ingested immediately following the first fragment // (up to the GetDASHStreamingSessionURLInput$MaxManifestFragmentResults value) // are included. // // Fragments that have duplicate producer timestamps are deduplicated. This // means that if producers are producing a stream of fragments with producer // timestamps that are approximately equal to the true clock time, the MPEG-DASH // manifest will contain all of the fragments within the requested timestamp // range. If some fragments are ingested within the same time range and very // different points in time, only the oldest ingested collection of fragments // are returned. // // When FragmentSelectorType is set to PRODUCER_TIMESTAMP and GetDASHStreamingSessionURLInput$PlaybackMode // is LIVE, the producer timestamps are used in the MP4 fragments and for deduplication. // But the most recently ingested fragments based on server timestamps are included // in the MPEG-DASH manifest. This means that even if fragments ingested in // the past have producer timestamps with values now, they are not included // in the HLS media playlist. // // The default is SERVER_TIMESTAMP. FragmentSelectorType string `type:"string" enum:"DASHFragmentSelectorType"` // The start and end of the timestamp range for the requested media. // // This value should not be present if PlaybackType is LIVE. TimestampRange DASHTimestampRange `type:"structure"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s DASHFragmentSelector) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s DASHFragmentSelector) GoString() string { return s.String() } // SetFragmentSelectorType sets the FragmentSelectorType field's value. func (s DASHFragmentSelector) SetFragmentSelectorType(v string) DASHFragmentSelector { s.FragmentSelectorType = &v return s } // SetTimestampRange sets the TimestampRange field's value. func (s DASHFragmentSelector) SetTimestampRange(v DASHTimestampRange) DASHFragmentSelector { s.TimestampRange = v return s } // The start and end of the timestamp range for the requested media. // // This value should not be present if PlaybackType is LIVE. // // The values in DASHimestampRange are inclusive. Fragments that start exactly // at or after the start time are included in the session. Fragments that start // before the start time and continue past it are not included in the session. type DASHTimestampRange struct { _ struct{} `type:"structure"` // The end of the timestamp range for the requested media. This value must be // within 24 hours of the specified StartTimestamp, and it must be later than // the StartTimestamp value. // // If FragmentSelectorType for the request is SERVER_TIMESTAMP, this value must // be in the past. // // The EndTimestamp value is required for ON_DEMAND mode, but optional for LIVE_REPLAY // mode. If the EndTimestamp is not set for LIVE_REPLAY mode then the session // will continue to include newly ingested fragments until the session expires. // // This value is inclusive. The EndTimestamp is compared to the (starting) timestamp // of the fragment. Fragments that start before the EndTimestamp value and continue // past it are included in the session. EndTimestamp time.Time `type:"timestamp"` // The start of the timestamp range for the requested media. // // If the DASHTimestampRange value is specified, the StartTimestamp value is // required. // // Only fragments that start exactly at or after StartTimestamp are included // in the session. Fragments that start before StartTimestamp and continue past // it aren't included in the session. If FragmentSelectorType is SERVER_TIMESTAMP, // the StartTimestamp must be later than the stream head. StartTimestamp time.Time `type:"timestamp"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s DASHTimestampRange) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s DASHTimestampRange) GoString() string { return s.String() } // SetEndTimestamp sets the EndTimestamp field's value. func (s DASHTimestampRange) SetEndTimestamp(v time.Time) DASHTimestampRange { s.EndTimestamp = &v return s } // SetStartTimestamp sets the StartTimestamp field's value. func (s DASHTimestampRange) SetStartTimestamp(v time.Time) DASHTimestampRange { s.StartTimestamp = &v return s } // Represents a segment of video or other time-delimited data. type Fragment struct { _ struct{} `type:"structure"` // The playback duration or other time value associated with the fragment. FragmentLengthInMilliseconds int64 `type:"long"` // The unique identifier of the fragment. This value monotonically increases // based on the ingestion order. FragmentNumber string `min:"1" type:"string"` // The total fragment size, including information about the fragment and contained // media data. FragmentSizeInBytes int64 `type:"long"` // The timestamp from the producer corresponding to the fragment. ProducerTimestamp time.Time `type:"timestamp"` // The timestamp from the Amazon Web Services server corresponding to the fragment. ServerTimestamp time.Time `type:"timestamp"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s Fragment) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s Fragment) GoString() string { return s.String() } // SetFragmentLengthInMilliseconds sets the FragmentLengthInMilliseconds field's value. func (s Fragment) SetFragmentLengthInMilliseconds(v int64) Fragment { s.FragmentLengthInMilliseconds = &v return s } // SetFragmentNumber sets the FragmentNumber field's value. func (s Fragment) SetFragmentNumber(v string) Fragment { s.FragmentNumber = &v return s } // SetFragmentSizeInBytes sets the FragmentSizeInBytes field's value. func (s Fragment) SetFragmentSizeInBytes(v int64) Fragment { s.FragmentSizeInBytes = &v return s } // SetProducerTimestamp sets the ProducerTimestamp field's value. func (s Fragment) SetProducerTimestamp(v time.Time) Fragment { s.ProducerTimestamp = &v return s } // SetServerTimestamp sets the ServerTimestamp field's value. func (s Fragment) SetServerTimestamp(v time.Time) Fragment { s.ServerTimestamp = &v return s } // Describes the timestamp range and timestamp origin of a range of fragments. // // Only fragments with a start timestamp greater than or equal to the given // start time and less than or equal to the end time are returned. For example, // if a stream contains fragments with the following start timestamps: // // - 00:00:00 // // - 00:00:02 // // - 00:00:04 // // - 00:00:06 // // A fragment selector range with a start time of 00:00:01 and end time of 00:00:04 // would return the fragments with start times of 00:00:02 and 00:00:04. type FragmentSelector struct { _ struct{} `type:"structure"` // The origin of the timestamps to use (Server or Producer). // // FragmentSelectorType is a required field FragmentSelectorType string `type:"string" required:"true" enum:"FragmentSelectorType"` // The range of timestamps to return. // // TimestampRange is a required field TimestampRange TimestampRange `type:"structure" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s FragmentSelector) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s FragmentSelector) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s FragmentSelector) Validate() error { invalidParams := request.ErrInvalidParams{Context: "FragmentSelector"} if s.FragmentSelectorType == nil { invalidParams.Add(request.NewErrParamRequired("FragmentSelectorType")) } if s.TimestampRange == nil { invalidParams.Add(request.NewErrParamRequired("TimestampRange")) } if s.TimestampRange != nil { if err := s.TimestampRange.Validate(); err != nil { invalidParams.AddNested("TimestampRange", err.(request.ErrInvalidParams)) } } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetFragmentSelectorType sets the FragmentSelectorType field's value. func (s FragmentSelector) SetFragmentSelectorType(v string) FragmentSelector { s.FragmentSelectorType = &v return s } // SetTimestampRange sets the TimestampRange field's value. func (s FragmentSelector) SetTimestampRange(v TimestampRange) FragmentSelector { s.TimestampRange = v return s } type GetClipInput struct { _ struct{} `type:"structure"` // The time range of the requested clip and the source of the timestamps. // // ClipFragmentSelector is a required field ClipFragmentSelector ClipFragmentSelector `type:"structure" required:"true"` // The Amazon Resource Name (ARN) of the stream for which to retrieve the media // clip. // // You must specify either the StreamName or the StreamARN. StreamARN string `min:"1" type:"string"` // The name of the stream for which to retrieve the media clip. // // You must specify either the StreamName or the StreamARN. StreamName string `min:"1" type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s GetClipInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s GetClipInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s GetClipInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "GetClipInput"} if s.ClipFragmentSelector == nil { invalidParams.Add(request.NewErrParamRequired("ClipFragmentSelector")) } if s.StreamARN != nil && len(s.StreamARN) < 1 { invalidParams.Add(request.NewErrParamMinLen("StreamARN", 1)) } if s.StreamName != nil && len(s.StreamName) < 1 { invalidParams.Add(request.NewErrParamMinLen("StreamName", 1)) } if s.ClipFragmentSelector != nil { if err := s.ClipFragmentSelector.Validate(); err != nil { invalidParams.AddNested("ClipFragmentSelector", err.(request.ErrInvalidParams)) } } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetClipFragmentSelector sets the ClipFragmentSelector field's value. func (s GetClipInput) SetClipFragmentSelector(v ClipFragmentSelector) GetClipInput { s.ClipFragmentSelector = v return s } // SetStreamARN sets the StreamARN field's value. func (s GetClipInput) SetStreamARN(v string) GetClipInput { s.StreamARN = &v return s } // SetStreamName sets the StreamName field's value. func (s GetClipInput) SetStreamName(v string) GetClipInput { s.StreamName = &v return s } type GetClipOutput struct { _ struct{} `type:"structure" payload:"Payload"` // The content type of the media in the requested clip. ContentType string `location:"header" locationName:"Content-Type" min:"1" type:"string"` // Traditional MP4 file that contains the media clip from the specified video // stream. The output will contain the first 100 MB or the first 200 fragments // from the specified start timestamp. For more information, see Kinesis Video // Streams Limits (https://docs.aws.amazon.com/kinesisvideostreams/latest/dg/limits.html). Payload io.ReadCloser `type:"blob"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s GetClipOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s GetClipOutput) GoString() string { return s.String() } // SetContentType sets the ContentType field's value. func (s GetClipOutput) SetContentType(v string) GetClipOutput { s.ContentType = &v return s } // SetPayload sets the Payload field's value. func (s GetClipOutput) SetPayload(v io.ReadCloser) GetClipOutput { s.Payload = v return s } type GetDASHStreamingSessionURLInput struct { _ struct{} `type:"structure"` // The time range of the requested fragment and the source of the timestamps. // // This parameter is required if PlaybackMode is ON_DEMAND or LIVE_REPLAY. This // parameter is optional if PlaybackMode is LIVE. If PlaybackMode is LIVE, the // FragmentSelectorType can be set, but the TimestampRange should not be set. // If PlaybackMode is ON_DEMAND or LIVE_REPLAY, both FragmentSelectorType and // TimestampRange must be set. DASHFragmentSelector DASHFragmentSelector `type:"structure"` // Fragments are identified in the manifest file based on their sequence number // in the session. If DisplayFragmentNumber is set to ALWAYS, the Kinesis Video // Streams fragment number is added to each S element in the manifest file with // the attribute name “kvs:fn”. These fragment numbers can be used for logging // or for use with other APIs (e.g. GetMedia and GetMediaForFragmentList). A // custom MPEG-DASH media player is necessary to leverage these this custom // attribute. // // The default value is NEVER. DisplayFragmentNumber string `type:"string" enum:"DASHDisplayFragmentNumber"` // Per the MPEG-DASH specification, the wall-clock time of fragments in the // manifest file can be derived using attributes in the manifest itself. However, // typically, MPEG-DASH compatible media players do not properly handle gaps // in the media timeline. Kinesis Video Streams adjusts the media timeline in // the manifest file to enable playback of media with discontinuities. Therefore, // the wall-clock time derived from the manifest file may be inaccurate. If // DisplayFragmentTimestamp is set to ALWAYS, the accurate fragment timestamp // is added to each S element in the manifest file with the attribute name “kvs:ts”. // A custom MPEG-DASH media player is necessary to leverage this custom attribute. // // The default value is NEVER. When DASHFragmentSelector is SERVER_TIMESTAMP, // the timestamps will be the server start timestamps. Similarly, when DASHFragmentSelector // is PRODUCER_TIMESTAMP, the timestamps will be the producer start timestamps. DisplayFragmentTimestamp string `type:"string" enum:"DASHDisplayFragmentTimestamp"` // The time in seconds until the requested session expires. This value can be // between 300 (5 minutes) and 43200 (12 hours). // // When a session expires, no new calls to GetDashManifest, GetMP4InitFragment, // or GetMP4MediaFragment can be made for that session. // // The default is 300 (5 minutes). Expires int64 `min:"300" type:"integer"` // The maximum number of fragments that are returned in the MPEG-DASH manifest. // // When the PlaybackMode is LIVE, the most recent fragments are returned up // to this value. When the PlaybackMode is ON_DEMAND, the oldest fragments are // returned, up to this maximum number. // // When there are a higher number of fragments available in a live MPEG-DASH // manifest, video players often buffer content before starting playback. Increasing // the buffer size increases the playback latency, but it decreases the likelihood // that rebuffering will occur during playback. We recommend that a live MPEG-DASH // manifest have a minimum of 3 fragments and a maximum of 10 fragments. // // The default is 5 fragments if PlaybackMode is LIVE or LIVE_REPLAY, and 1,000 // if PlaybackMode is ON_DEMAND. // // The maximum value of 1,000 fragments corresponds to more than 16 minutes // of video on streams with 1-second fragments, and more than 2 1/2 hours of // video on streams with 10-second fragments. MaxManifestFragmentResults int64 `min:"1" type:"long"` // Whether to retrieve live, live replay, or archived, on-demand data. // // Features of the three types of sessions include the following: // // * LIVE : For sessions of this type, the MPEG-DASH manifest is continually // updated with the latest fragments as they become available. We recommend // that the media player retrieve a new manifest on a one-second interval. // When this type of session is played in a media player, the user interface // typically displays a "live" notification, with no scrubber control for // choosing the position in the playback window to display. In LIVE mode, // the newest available fragments are included in an MPEG-DASH manifest, // even if there is a gap between fragments (that is, if a fragment is missing). // A gap like this might cause a media player to halt or cause a jump in // playback. In this mode, fragments are not added to the MPEG-DASH manifest // if they are older than the newest fragment in the playlist. If the missing // fragment becomes available after a subsequent fragment is added to the // manifest, the older fragment is not added, and the gap is not filled. // // * LIVE_REPLAY : For sessions of this type, the MPEG-DASH manifest is updated // similarly to how it is updated for LIVE mode except that it starts by // including fragments from a given start time. Instead of fragments being // added as they are ingested, fragments are added as the duration of the // next fragment elapses. For example, if the fragments in the session are // two seconds long, then a new fragment is added to the manifest every two // seconds. This mode is useful to be able to start playback from when an // event is detected and continue live streaming media that has not yet been // ingested as of the time of the session creation. This mode is also useful // to stream previously archived media without being limited by the 1,000 // fragment limit in the ON_DEMAND mode. // // * ON_DEMAND : For sessions of this type, the MPEG-DASH manifest contains // all the fragments for the session, up to the number that is specified // in MaxManifestFragmentResults. The manifest must be retrieved only once // for each session. When this type of session is played in a media player, // the user interface typically displays a scrubber control for choosing // the position in the playback window to display. // // In all playback modes, if FragmentSelectorType is PRODUCER_TIMESTAMP, and // if there are multiple fragments with the same start timestamp, the fragment // that has the larger fragment number (that is, the newer fragment) is included // in the MPEG-DASH manifest. The other fragments are not included. Fragments // that have different timestamps but have overlapping durations are still included // in the MPEG-DASH manifest. This can lead to unexpected behavior in the media // player. // // The default is LIVE. PlaybackMode string `type:"string" enum:"DASHPlaybackMode"` // The Amazon Resource Name (ARN) of the stream for which to retrieve the MPEG-DASH // manifest URL. // // You must specify either the StreamName or the StreamARN. StreamARN string `min:"1" type:"string"` // The name of the stream for which to retrieve the MPEG-DASH manifest URL. // // You must specify either the StreamName or the StreamARN. StreamName string `min:"1" type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s GetDASHStreamingSessionURLInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s GetDASHStreamingSessionURLInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s GetDASHStreamingSessionURLInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "GetDASHStreamingSessionURLInput"} if s.Expires != nil && s.Expires < 300 { invalidParams.Add(request.NewErrParamMinValue("Expires", 300)) } if s.MaxManifestFragmentResults != nil && s.MaxManifestFragmentResults < 1 { invalidParams.Add(request.NewErrParamMinValue("MaxManifestFragmentResults", 1)) } if s.StreamARN != nil && len(s.StreamARN) < 1 { invalidParams.Add(request.NewErrParamMinLen("StreamARN", 1)) } if s.StreamName != nil && len(s.StreamName) < 1 { invalidParams.Add(request.NewErrParamMinLen("StreamName", 1)) } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetDASHFragmentSelector sets the DASHFragmentSelector field's value. func (s GetDASHStreamingSessionURLInput) SetDASHFragmentSelector(v DASHFragmentSelector) GetDASHStreamingSessionURLInput { s.DASHFragmentSelector = v return s } // SetDisplayFragmentNumber sets the DisplayFragmentNumber field's value. func (s GetDASHStreamingSessionURLInput) SetDisplayFragmentNumber(v string) GetDASHStreamingSessionURLInput { s.DisplayFragmentNumber = &v return s } // SetDisplayFragmentTimestamp sets the DisplayFragmentTimestamp field's value. func (s GetDASHStreamingSessionURLInput) SetDisplayFragmentTimestamp(v string) GetDASHStreamingSessionURLInput { s.DisplayFragmentTimestamp = &v return s } // SetExpires sets the Expires field's value. func (s GetDASHStreamingSessionURLInput) SetExpires(v int64) GetDASHStreamingSessionURLInput { s.Expires = &v return s } // SetMaxManifestFragmentResults sets the MaxManifestFragmentResults field's value. func (s GetDASHStreamingSessionURLInput) SetMaxManifestFragmentResults(v int64) GetDASHStreamingSessionURLInput { s.MaxManifestFragmentResults = &v return s } // SetPlaybackMode sets the PlaybackMode field's value. func (s GetDASHStreamingSessionURLInput) SetPlaybackMode(v string) GetDASHStreamingSessionURLInput { s.PlaybackMode = &v return s } // SetStreamARN sets the StreamARN field's value. func (s GetDASHStreamingSessionURLInput) SetStreamARN(v string) GetDASHStreamingSessionURLInput { s.StreamARN = &v return s } // SetStreamName sets the StreamName field's value. func (s GetDASHStreamingSessionURLInput) SetStreamName(v string) GetDASHStreamingSessionURLInput { s.StreamName = &v return s } type GetDASHStreamingSessionURLOutput struct { _ struct{} `type:"structure"` // The URL (containing the session token) that a media player can use to retrieve // the MPEG-DASH manifest. DASHStreamingSessionURL string `type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s GetDASHStreamingSessionURLOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s GetDASHStreamingSessionURLOutput) GoString() string { return s.String() } // SetDASHStreamingSessionURL sets the DASHStreamingSessionURL field's value. func (s GetDASHStreamingSessionURLOutput) SetDASHStreamingSessionURL(v string) GetDASHStreamingSessionURLOutput { s.DASHStreamingSessionURL = &v return s } type GetHLSStreamingSessionURLInput struct { _ struct{} `type:"structure"` // Specifies which format should be used for packaging the media. Specifying // the FRAGMENTED_MP4 container format packages the media into MP4 fragments // (fMP4 or CMAF). This is the recommended packaging because there is minimal // packaging overhead. The other container format option is MPEG_TS. HLS has // supported MPEG TS chunks since it was released and is sometimes the only // supported packaging on older HLS players. MPEG TS typically has a 5-25 percent // packaging overhead. This means MPEG TS typically requires 5-25 percent more // bandwidth and cost than fMP4. // // The default is FRAGMENTED_MP4. ContainerFormat string `type:"string" enum:"ContainerFormat"` // Specifies when flags marking discontinuities between fragments are added // to the media playlists. // // Media players typically build a timeline of media content to play, based // on the timestamps of each fragment. This means that if there is any overlap // or gap between fragments (as is typical if HLSFragmentSelector is set to // SERVER_TIMESTAMP), the media player timeline will also have small gaps between // fragments in some places, and will overwrite frames in other places. Gaps // in the media player timeline can cause playback to stall and overlaps can // cause playback to be jittery. When there are discontinuity flags between // fragments, the media player is expected to reset the timeline, resulting // in the next fragment being played immediately after the previous fragment. // // The following modes are supported: // // ALWAYS: a discontinuity marker is placed between every fragment in the // HLS media playlist. It is recommended to use a value of ALWAYS if the // fragment timestamps are not accurate. // // * NEVER: no discontinuity markers are placed anywhere. It is recommended // to use a value of NEVER to ensure the media player timeline most accurately // maps to the producer timestamps. // // * ON_DISCONTINUITY: a discontinuity marker is placed between fragments // that have a gap or overlap of more than 50 milliseconds. For most playback // scenarios, it is recommended to use a value of ON_DISCONTINUITY so that // the media player timeline is only reset when there is a significant issue // with the media timeline (e.g. a missing fragment). // // The default is ALWAYS when HLSFragmentSelector is set to SERVER_TIMESTAMP, // and NEVER when it is set to PRODUCER_TIMESTAMP. DiscontinuityMode string `type:"string" enum:"HLSDiscontinuityMode"` // Specifies when the fragment start timestamps should be included in the HLS // media playlist. Typically, media players report the playhead position as // a time relative to the start of the first fragment in the playback session. // However, when the start timestamps are included in the HLS media playlist, // some media players might report the current playhead as an absolute time // based on the fragment timestamps. This can be useful for creating a playback // experience that shows viewers the wall-clock time of the media. // // The default is NEVER. When HLSFragmentSelector is SERVER_TIMESTAMP, the timestamps // will be the server start timestamps. Similarly, when HLSFragmentSelector // is PRODUCER_TIMESTAMP, the timestamps will be the producer start timestamps. DisplayFragmentTimestamp string `type:"string" enum:"HLSDisplayFragmentTimestamp"` // The time in seconds until the requested session expires. This value can be // between 300 (5 minutes) and 43200 (12 hours). // // When a session expires, no new calls to GetHLSMasterPlaylist, GetHLSMediaPlaylist, // GetMP4InitFragment, GetMP4MediaFragment, or GetTSFragment can be made for // that session. // // The default is 300 (5 minutes). Expires int64 `min:"300" type:"integer"` // The time range of the requested fragment and the source of the timestamps. // // This parameter is required if PlaybackMode is ON_DEMAND or LIVE_REPLAY. This // parameter is optional if PlaybackMode is LIVE. If PlaybackMode is LIVE, the // FragmentSelectorType can be set, but the TimestampRange should not be set. // If PlaybackMode is ON_DEMAND or LIVE_REPLAY, both FragmentSelectorType and // TimestampRange must be set. HLSFragmentSelector HLSFragmentSelector `type:"structure"` // The maximum number of fragments that are returned in the HLS media playlists. // // When the PlaybackMode is LIVE, the most recent fragments are returned up // to this value. When the PlaybackMode is ON_DEMAND, the oldest fragments are // returned, up to this maximum number. // // When there are a higher number of fragments available in a live HLS media // playlist, video players often buffer content before starting playback. Increasing // the buffer size increases the playback latency, but it decreases the likelihood // that rebuffering will occur during playback. We recommend that a live HLS // media playlist have a minimum of 3 fragments and a maximum of 10 fragments. // // The default is 5 fragments if PlaybackMode is LIVE or LIVE_REPLAY, and 1,000 // if PlaybackMode is ON_DEMAND. // // The maximum value of 5,000 fragments corresponds to more than 80 minutes // of video on streams with 1-second fragments, and more than 13 hours of video // on streams with 10-second fragments. MaxMediaPlaylistFragmentResults int64 `min:"1" type:"long"` // Whether to retrieve live, live replay, or archived, on-demand data. // // Features of the three types of sessions include the following: // // LIVE : For sessions of this type, the HLS media playlist is continually // updated with the latest fragments as they become available. We recommend // that the media player retrieve a new playlist on a one-second interval. // When this type of session is played in a media player, the user interface // typically displays a "live" notification, with no scrubber control for // choosing the position in the playback window to display. In LIVE mode, // the newest available fragments are included in an HLS media playlist, // even if there is a gap between fragments (that is, if a fragment is missing). // A gap like this might cause a media player to halt or cause a jump in // playback. In this mode, fragments are not added to the HLS media playlist // if they are older than the newest fragment in the playlist. If the missing // fragment becomes available after a subsequent fragment is added to the // playlist, the older fragment is not added, and the gap is not filled. // // * LIVE_REPLAY : For sessions of this type, the HLS media playlist is updated // similarly to how it is updated for LIVE mode except that it starts by // including fragments from a given start time. Instead of fragments being // added as they are ingested, fragments are added as the duration of the // next fragment elapses. For example, if the fragments in the session are // two seconds long, then a new fragment is added to the media playlist every // two seconds. This mode is useful to be able to start playback from when // an event is detected and continue live streaming media that has not yet // been ingested as of the time of the session creation. This mode is also // useful to stream previously archived media without being limited by the // 1,000 fragment limit in the ON_DEMAND mode. // // * ON_DEMAND : For sessions of this type, the HLS media playlist contains // all the fragments for the session, up to the number that is specified // in MaxMediaPlaylistFragmentResults. The playlist must be retrieved only // once for each session. When this type of session is played in a media // player, the user interface typically displays a scrubber control for choosing // the position in the playback window to display. // // In all playback modes, if FragmentSelectorType is PRODUCER_TIMESTAMP, and // if there are multiple fragments with the same start timestamp, the fragment // that has the largest fragment number (that is, the newest fragment) is included // in the HLS media playlist. The other fragments are not included. Fragments // that have different timestamps but have overlapping durations are still included // in the HLS media playlist. This can lead to unexpected behavior in the media // player. // // The default is LIVE. PlaybackMode string `type:"string" enum:"HLSPlaybackMode"` // The Amazon Resource Name (ARN) of the stream for which to retrieve the HLS // master playlist URL. // // You must specify either the StreamName or the StreamARN. StreamARN string `min:"1" type:"string"` // The name of the stream for which to retrieve the HLS master playlist URL. // // You must specify either the StreamName or the StreamARN. StreamName string `min:"1" type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s GetHLSStreamingSessionURLInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s GetHLSStreamingSessionURLInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s GetHLSStreamingSessionURLInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "GetHLSStreamingSessionURLInput"} if s.Expires != nil && s.Expires < 300 { invalidParams.Add(request.NewErrParamMinValue("Expires", 300)) } if s.MaxMediaPlaylistFragmentResults != nil && s.MaxMediaPlaylistFragmentResults < 1 { invalidParams.Add(request.NewErrParamMinValue("MaxMediaPlaylistFragmentResults", 1)) } if s.StreamARN != nil && len(s.StreamARN) < 1 { invalidParams.Add(request.NewErrParamMinLen("StreamARN", 1)) } if s.StreamName != nil && len(s.StreamName) < 1 { invalidParams.Add(request.NewErrParamMinLen("StreamName", 1)) } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetContainerFormat sets the ContainerFormat field's value. func (s GetHLSStreamingSessionURLInput) SetContainerFormat(v string) GetHLSStreamingSessionURLInput { s.ContainerFormat = &v return s } // SetDiscontinuityMode sets the DiscontinuityMode field's value. func (s GetHLSStreamingSessionURLInput) SetDiscontinuityMode(v string) GetHLSStreamingSessionURLInput { s.DiscontinuityMode = &v return s } // SetDisplayFragmentTimestamp sets the DisplayFragmentTimestamp field's value. func (s GetHLSStreamingSessionURLInput) SetDisplayFragmentTimestamp(v string) GetHLSStreamingSessionURLInput { s.DisplayFragmentTimestamp = &v return s } // SetExpires sets the Expires field's value. func (s GetHLSStreamingSessionURLInput) SetExpires(v int64) GetHLSStreamingSessionURLInput { s.Expires = &v return s } // SetHLSFragmentSelector sets the HLSFragmentSelector field's value. func (s GetHLSStreamingSessionURLInput) SetHLSFragmentSelector(v HLSFragmentSelector) GetHLSStreamingSessionURLInput { s.HLSFragmentSelector = v return s } // SetMaxMediaPlaylistFragmentResults sets the MaxMediaPlaylistFragmentResults field's value. func (s GetHLSStreamingSessionURLInput) SetMaxMediaPlaylistFragmentResults(v int64) GetHLSStreamingSessionURLInput { s.MaxMediaPlaylistFragmentResults = &v return s } // SetPlaybackMode sets the PlaybackMode field's value. func (s GetHLSStreamingSessionURLInput) SetPlaybackMode(v string) GetHLSStreamingSessionURLInput { s.PlaybackMode = &v return s } // SetStreamARN sets the StreamARN field's value. func (s GetHLSStreamingSessionURLInput) SetStreamARN(v string) GetHLSStreamingSessionURLInput { s.StreamARN = &v return s } // SetStreamName sets the StreamName field's value. func (s GetHLSStreamingSessionURLInput) SetStreamName(v string) GetHLSStreamingSessionURLInput { s.StreamName = &v return s } type GetHLSStreamingSessionURLOutput struct { _ struct{} `type:"structure"` // The URL (containing the session token) that a media player can use to retrieve // the HLS master playlist. HLSStreamingSessionURL string `type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s GetHLSStreamingSessionURLOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s GetHLSStreamingSessionURLOutput) GoString() string { return s.String() } // SetHLSStreamingSessionURL sets the HLSStreamingSessionURL field's value. func (s GetHLSStreamingSessionURLOutput) SetHLSStreamingSessionURL(v string) GetHLSStreamingSessionURLOutput { s.HLSStreamingSessionURL = &v return s } type GetImagesInput struct { _ struct{} `type:"structure"` // The end timestamp for the range of images to be generated. If the time range // between StartTimestamp and EndTimestamp is more than 300 seconds above StartTimestamp, // you will receive an IllegalArgumentException. // // EndTimestamp is a required field EndTimestamp time.Time `type:"timestamp" required:"true"` // The format that will be used to encode the image. // // Format is a required field Format string `type:"string" required:"true" enum:"Format"` // The list of a key-value pair structure that contains extra parameters that // can be applied when the image is generated. The FormatConfig key is the JPEGQuality, // which indicates the JPEG quality key to be used to generate the image. The // FormatConfig value accepts ints from 1 to 100. If the value is 1, the image // will be generated with less quality and the best compression. If the value // is 100, the image will be generated with the best quality and less compression. // If no value is provided, the default value of the JPEGQuality key will be // set to 80. FormatConfig map[string]string `min:"1" type:"map"` // The height of the output image that is used in conjunction with the WidthPixels // parameter. When both HeightPixels and WidthPixels parameters are provided, // the image will be stretched to fit the specified aspect ratio. If only the // HeightPixels parameter is provided, its original aspect ratio will be used // to calculate the WidthPixels ratio. If neither parameter is provided, the // original image size will be returned. HeightPixels int64 `min:"1" type:"integer"` // The origin of the Server or Producer timestamps to use to generate the images. // // ImageSelectorType is a required field ImageSelectorType string `type:"string" required:"true" enum:"ImageSelectorType"` // The maximum number of images to be returned by the API. // // The default limit is 25 images per API response. Providing a MaxResults greater // than this value will result in a page size of 25. Any additional results // will be paginated. MaxResults int64 `min:"1" type:"long"` // A token that specifies where to start paginating the next set of Images. // This is the GetImages:NextToken from a previously truncated response. NextToken string `min:"1" type:"string"` // The time interval in milliseconds (ms) at which the images need to be generated // from the stream. The minimum value that can be provided is 200 ms (5 images // per second). If the timestamp range is less than the sampling interval, the // image from the startTimestamp will be returned if available. SamplingInterval int64 `type:"integer"` // The starting point from which the images should be generated. This StartTimestamp // must be within an inclusive range of timestamps for an image to be returned. // // StartTimestamp is a required field StartTimestamp time.Time `type:"timestamp" required:"true"` // The Amazon Resource Name (ARN) of the stream from which to retrieve the images. // You must specify either the StreamName or the StreamARN. StreamARN string `min:"1" type:"string"` // The name of the stream from which to retrieve the images. You must specify // either the StreamName or the StreamARN. StreamName string `min:"1" type:"string"` // The width of the output image that is used in conjunction with the HeightPixels // parameter. When both WidthPixels and HeightPixels parameters are provided, // the image will be stretched to fit the specified aspect ratio. If only the // WidthPixels parameter is provided or if only the HeightPixels is provided, // a ValidationException will be thrown. If neither parameter is provided, the // original image size from the stream will be returned. WidthPixels int64 `min:"1" type:"integer"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s GetImagesInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s GetImagesInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s GetImagesInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "GetImagesInput"} if s.EndTimestamp == nil { invalidParams.Add(request.NewErrParamRequired("EndTimestamp")) } if s.Format == nil { invalidParams.Add(request.NewErrParamRequired("Format")) } if s.FormatConfig != nil && len(s.FormatConfig) < 1 { invalidParams.Add(request.NewErrParamMinLen("FormatConfig", 1)) } if s.HeightPixels != nil && s.HeightPixels < 1 { invalidParams.Add(request.NewErrParamMinValue("HeightPixels", 1)) } if s.ImageSelectorType == nil { invalidParams.Add(request.NewErrParamRequired("ImageSelectorType")) } if s.MaxResults != nil && s.MaxResults < 1 { invalidParams.Add(request.NewErrParamMinValue("MaxResults", 1)) } if s.NextToken != nil && len(s.NextToken) < 1 { invalidParams.Add(request.NewErrParamMinLen("NextToken", 1)) } if s.StartTimestamp == nil { invalidParams.Add(request.NewErrParamRequired("StartTimestamp")) } if s.StreamARN != nil && len(s.StreamARN) < 1 { invalidParams.Add(request.NewErrParamMinLen("StreamARN", 1)) } if s.StreamName != nil && len(s.StreamName) < 1 { invalidParams.Add(request.NewErrParamMinLen("StreamName", 1)) } if s.WidthPixels != nil && s.WidthPixels < 1 { invalidParams.Add(request.NewErrParamMinValue("WidthPixels", 1)) } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetEndTimestamp sets the EndTimestamp field's value. func (s GetImagesInput) SetEndTimestamp(v time.Time) GetImagesInput { s.EndTimestamp = &v return s } // SetFormat sets the Format field's value. func (s GetImagesInput) SetFormat(v string) GetImagesInput { s.Format = &v return s } // SetFormatConfig sets the FormatConfig field's value. func (s GetImagesInput) SetFormatConfig(v map[string]string) GetImagesInput { s.FormatConfig = v return s } // SetHeightPixels sets the HeightPixels field's value. func (s GetImagesInput) SetHeightPixels(v int64) GetImagesInput { s.HeightPixels = &v return s } // SetImageSelectorType sets the ImageSelectorType field's value. func (s GetImagesInput) SetImageSelectorType(v string) GetImagesInput { s.ImageSelectorType = &v return s } // SetMaxResults sets the MaxResults field's value. func (s GetImagesInput) SetMaxResults(v int64) GetImagesInput { s.MaxResults = &v return s } // SetNextToken sets the NextToken field's value. func (s GetImagesInput) SetNextToken(v string) GetImagesInput { s.NextToken = &v return s } // SetSamplingInterval sets the SamplingInterval field's value. func (s GetImagesInput) SetSamplingInterval(v int64) GetImagesInput { s.SamplingInterval = &v return s } // SetStartTimestamp sets the StartTimestamp field's value. func (s GetImagesInput) SetStartTimestamp(v time.Time) GetImagesInput { s.StartTimestamp = &v return s } // SetStreamARN sets the StreamARN field's value. func (s GetImagesInput) SetStreamARN(v string) GetImagesInput { s.StreamARN = &v return s } // SetStreamName sets the StreamName field's value. func (s GetImagesInput) SetStreamName(v string) GetImagesInput { s.StreamName = &v return s } // SetWidthPixels sets the WidthPixels field's value. func (s GetImagesInput) SetWidthPixels(v int64) GetImagesInput { s.WidthPixels = &v return s } type GetImagesOutput struct { _ struct{} `type:"structure"` // The list of images generated from the video stream. If there is no media // available for the given timestamp, the NO_MEDIA error will be listed in the // output. If an error occurs while the image is being generated, the MEDIA_ERROR // will be listed in the output as the cause of the missing image. Images []Image `type:"list"` // The encrypted token that was used in the request to get more images. NextToken string `min:"1" type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s GetImagesOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s GetImagesOutput) GoString() string { return s.String() } // SetImages sets the Images field's value. func (s GetImagesOutput) SetImages(v []Image) GetImagesOutput { s.Images = v return s } // SetNextToken sets the NextToken field's value. func (s GetImagesOutput) SetNextToken(v string) GetImagesOutput { s.NextToken = &v return s } type GetMediaForFragmentListInput struct { _ struct{} `type:"structure"` // A list of the numbers of fragments for which to retrieve media. You retrieve // these values with ListFragments. // // Fragments is a required field Fragments []string `min:"1" type:"list" required:"true"` // The Amazon Resource Name (ARN) of the stream from which to retrieve fragment // media. Specify either this parameter or the StreamName parameter. StreamARN string `min:"1" type:"string"` // The name of the stream from which to retrieve fragment media. Specify either // this parameter or the StreamARN parameter. StreamName string `min:"1" type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s GetMediaForFragmentListInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s GetMediaForFragmentListInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s GetMediaForFragmentListInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "GetMediaForFragmentListInput"} if s.Fragments == nil { invalidParams.Add(request.NewErrParamRequired("Fragments")) } if s.Fragments != nil && len(s.Fragments) < 1 { invalidParams.Add(request.NewErrParamMinLen("Fragments", 1)) } if s.StreamARN != nil && len(s.StreamARN) < 1 { invalidParams.Add(request.NewErrParamMinLen("StreamARN", 1)) } if s.StreamName != nil && len(s.StreamName) < 1 { invalidParams.Add(request.NewErrParamMinLen("StreamName", 1)) } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetFragments sets the Fragments field's value. func (s GetMediaForFragmentListInput) SetFragments(v []string) GetMediaForFragmentListInput { s.Fragments = v return s } // SetStreamARN sets the StreamARN field's value. func (s GetMediaForFragmentListInput) SetStreamARN(v string) GetMediaForFragmentListInput { s.StreamARN = &v return s } // SetStreamName sets the StreamName field's value. func (s GetMediaForFragmentListInput) SetStreamName(v string) GetMediaForFragmentListInput { s.StreamName = &v return s } type GetMediaForFragmentListOutput struct { _ struct{} `type:"structure" payload:"Payload"` // The content type of the requested media. ContentType string `location:"header" locationName:"Content-Type" min:"1" type:"string"` // The payload that Kinesis Video Streams returns is a sequence of chunks from // the specified stream. For information about the chunks, see PutMedia (http://docs.aws.amazon.com/kinesisvideostreams/latest/dg/API_dataplane_PutMedia.html). // The chunks that Kinesis Video Streams returns in the GetMediaForFragmentList // call also include the following additional Matroska (MKV) tags: // // AWS_KINESISVIDEO_FRAGMENT_NUMBER - Fragment number returned in the chunk. // // * AWS_KINESISVIDEO_SERVER_SIDE_TIMESTAMP - Server-side timestamp of the // fragment. // // * AWS_KINESISVIDEO_PRODUCER_SIDE_TIMESTAMP - Producer-side timestamp of // the fragment. // // The following tags will be included if an exception occurs: // // * AWS_KINESISVIDEO_FRAGMENT_NUMBER - The number of the fragment that threw // the exception // // * AWS_KINESISVIDEO_EXCEPTION_ERROR_CODE - The integer code of the // // * AWS_KINESISVIDEO_EXCEPTION_MESSAGE - A text description of the exception Payload io.ReadCloser `type:"blob"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s GetMediaForFragmentListOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s GetMediaForFragmentListOutput) GoString() string { return s.String() } // SetContentType sets the ContentType field's value. func (s GetMediaForFragmentListOutput) SetContentType(v string) GetMediaForFragmentListOutput { s.ContentType = &v return s } // SetPayload sets the Payload field's value. func (s GetMediaForFragmentListOutput) SetPayload(v io.ReadCloser) GetMediaForFragmentListOutput { s.Payload = v return s } // Contains the range of timestamps for the requested media, and the source // of the timestamps. type HLSFragmentSelector struct { _ struct{} `type:"structure"` // The source of the timestamps for the requested media. // // When FragmentSelectorType is set to PRODUCER_TIMESTAMP and GetHLSStreamingSessionURLInput$PlaybackMode // is ON_DEMAND or LIVE_REPLAY, the first fragment ingested with a producer // timestamp within the specified FragmentSelector$TimestampRange is included // in the media playlist. In addition, the fragments with producer timestamps // within the TimestampRange ingested immediately following the first fragment // (up to the GetHLSStreamingSessionURLInput$MaxMediaPlaylistFragmentResults // value) are included. // // Fragments that have duplicate producer timestamps are deduplicated. This // means that if producers are producing a stream of fragments with producer // timestamps that are approximately equal to the true clock time, the HLS media // playlists will contain all of the fragments within the requested timestamp // range. If some fragments are ingested within the same time range and very // different points in time, only the oldest ingested collection of fragments // are returned. // // When FragmentSelectorType is set to PRODUCER_TIMESTAMP and GetHLSStreamingSessionURLInput$PlaybackMode // is LIVE, the producer timestamps are used in the MP4 fragments and for deduplication. // But the most recently ingested fragments based on server timestamps are included // in the HLS media playlist. This means that even if fragments ingested in // the past have producer timestamps with values now, they are not included // in the HLS media playlist. // // The default is SERVER_TIMESTAMP. FragmentSelectorType string `type:"string" enum:"HLSFragmentSelectorType"` // The start and end of the timestamp range for the requested media. // // This value should not be present if PlaybackType is LIVE. TimestampRange HLSTimestampRange `type:"structure"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s HLSFragmentSelector) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s HLSFragmentSelector) GoString() string { return s.String() } // SetFragmentSelectorType sets the FragmentSelectorType field's value. func (s HLSFragmentSelector) SetFragmentSelectorType(v string) HLSFragmentSelector { s.FragmentSelectorType = &v return s } // SetTimestampRange sets the TimestampRange field's value. func (s HLSFragmentSelector) SetTimestampRange(v HLSTimestampRange) HLSFragmentSelector { s.TimestampRange = v return s } // The start and end of the timestamp range for the requested media. // // This value should not be present if PlaybackType is LIVE. type HLSTimestampRange struct { _ struct{} `type:"structure"` // The end of the timestamp range for the requested media. This value must be // within 24 hours of the specified StartTimestamp, and it must be later than // the StartTimestamp value. // // If FragmentSelectorType for the request is SERVER_TIMESTAMP, this value must // be in the past. // // The EndTimestamp value is required for ON_DEMAND mode, but optional for LIVE_REPLAY // mode. If the EndTimestamp is not set for LIVE_REPLAY mode then the session // will continue to include newly ingested fragments until the session expires. // // This value is inclusive. The EndTimestamp is compared to the (starting) timestamp // of the fragment. Fragments that start before the EndTimestamp value and continue // past it are included in the session. EndTimestamp time.Time `type:"timestamp"` // The start of the timestamp range for the requested media. // // If the HLSTimestampRange value is specified, the StartTimestamp value is // required. // // Only fragments that start exactly at or after StartTimestamp are included // in the session. Fragments that start before StartTimestamp and continue past // it aren't included in the session. If FragmentSelectorType is SERVER_TIMESTAMP, // the StartTimestamp must be later than the stream head. StartTimestamp time.Time `type:"timestamp"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s HLSTimestampRange) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s HLSTimestampRange) GoString() string { return s.String() } // SetEndTimestamp sets the EndTimestamp field's value. func (s HLSTimestampRange) SetEndTimestamp(v time.Time) HLSTimestampRange { s.EndTimestamp = &v return s } // SetStartTimestamp sets the StartTimestamp field's value. func (s HLSTimestampRange) SetStartTimestamp(v time.Time) HLSTimestampRange { s.StartTimestamp = &v return s } // A structure that contains the Timestamp, Error, and ImageContent. type Image struct { _ struct{} `type:"structure"` // The error message shown when the image for the provided timestamp was not // extracted due to a non-tryable error. An error will be returned if: // // There is no media that exists for the specified Timestamp. // // * The media for the specified time does not allow an image to be extracted. // In this case the media is audio only, or the incorrect media has been // ingested. Error string `type:"string" enum:"ImageError"` // An attribute of the Image object that is Base64 encoded. ImageContent string `min:"1" type:"string"` // An attribute of the Image object that is used to extract an image from the // video stream. This field is used to manage gaps on images or to better understand // the pagination window. TimeStamp time.Time `type:"timestamp"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s Image) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s Image) GoString() string { return s.String() } // SetError sets the Error field's value. func (s Image) SetError(v string) Image { s.Error = &v return s } // SetImageContent sets the ImageContent field's value. func (s Image) SetImageContent(v string) Image { s.ImageContent = &v return s } // SetTimeStamp sets the TimeStamp field's value. func (s Image) SetTimeStamp(v time.Time) Image { s.TimeStamp = &v return s } // A specified parameter exceeds its restrictions, is not supported, or can't // be used. type InvalidArgumentException struct { _ struct{} `type:"structure"` RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"` Message_ string `locationName:"Message" type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s InvalidArgumentException) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s InvalidArgumentException) GoString() string { return s.String() } func newErrorInvalidArgumentException(v protocol.ResponseMetadata) error { return &InvalidArgumentException{ RespMetadata: v, } } // Code returns the exception type name. func (s InvalidArgumentException) Code() string { return "InvalidArgumentException" } // Message returns the exception's message. func (s InvalidArgumentException) Message() string { if s.Message_ != nil { return s.Message_ } return "" } // OrigErr always returns nil, satisfies awserr.Error interface. func (s InvalidArgumentException) OrigErr() error { return nil } func (s InvalidArgumentException) Error() string { return fmt.Sprintf("%s: %s", s.Code(), s.Message()) } // Status code returns the HTTP status code for the request's response error. func (s InvalidArgumentException) StatusCode() int { return s.RespMetadata.StatusCode } // RequestID returns the service's response RequestID for request. func (s InvalidArgumentException) RequestID() string { return s.RespMetadata.RequestID } // The codec private data in at least one of the tracks of the video stream // is not valid for this operation. type InvalidCodecPrivateDataException struct { _ struct{} `type:"structure"` RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"` Message_ string `locationName:"Message" type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s InvalidCodecPrivateDataException) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s InvalidCodecPrivateDataException) GoString() string { return s.String() } func newErrorInvalidCodecPrivateDataException(v protocol.ResponseMetadata) error { return &InvalidCodecPrivateDataException{ RespMetadata: v, } } // Code returns the exception type name. func (s InvalidCodecPrivateDataException) Code() string { return "InvalidCodecPrivateDataException" } // Message returns the exception's message. func (s InvalidCodecPrivateDataException) Message() string { if s.Message_ != nil { return s.Message_ } return "" } // OrigErr always returns nil, satisfies awserr.Error interface. func (s InvalidCodecPrivateDataException) OrigErr() error { return nil } func (s InvalidCodecPrivateDataException) Error() string { return fmt.Sprintf("%s: %s", s.Code(), s.Message()) } // Status code returns the HTTP status code for the request's response error. func (s InvalidCodecPrivateDataException) StatusCode() int { return s.RespMetadata.StatusCode } // RequestID returns the service's response RequestID for request. func (s InvalidCodecPrivateDataException) RequestID() string { return s.RespMetadata.RequestID } // One or more frames in the requested clip could not be parsed based on the // specified codec. type InvalidMediaFrameException struct { _ struct{} `type:"structure"` RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"` Message_ string `locationName:"Message" type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s InvalidMediaFrameException) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s InvalidMediaFrameException) GoString() string { return s.String() } func newErrorInvalidMediaFrameException(v protocol.ResponseMetadata) error { return &InvalidMediaFrameException{ RespMetadata: v, } } // Code returns the exception type name. func (s InvalidMediaFrameException) Code() string { return "InvalidMediaFrameException" } // Message returns the exception's message. func (s InvalidMediaFrameException) Message() string { if s.Message_ != nil { return s.Message_ } return "" } // OrigErr always returns nil, satisfies awserr.Error interface. func (s InvalidMediaFrameException) OrigErr() error { return nil } func (s InvalidMediaFrameException) Error() string { return fmt.Sprintf("%s: %s", s.Code(), s.Message()) } // Status code returns the HTTP status code for the request's response error. func (s InvalidMediaFrameException) StatusCode() int { return s.RespMetadata.StatusCode } // RequestID returns the service's response RequestID for request. func (s InvalidMediaFrameException) RequestID() string { return s.RespMetadata.RequestID } type ListFragmentsInput struct { _ struct{} `type:"structure"` // Describes the timestamp range and timestamp origin for the range of fragments // to return. // // This is only required when the NextToken isn't passed in the API. FragmentSelector FragmentSelector `type:"structure"` // The total number of fragments to return. If the total number of fragments // available is more than the value specified in max-results, then a ListFragmentsOutput$NextToken // is provided in the output that you can use to resume pagination. MaxResults int64 `min:"1" type:"long"` // A token to specify where to start paginating. This is the ListFragmentsOutput$NextToken // from a previously truncated response. NextToken string `min:"1" type:"string"` // The Amazon Resource Name (ARN) of the stream from which to retrieve a fragment // list. Specify either this parameter or the StreamName parameter. StreamARN string `min:"1" type:"string"` // The name of the stream from which to retrieve a fragment list. Specify either // this parameter or the StreamARN parameter. StreamName string `min:"1" type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ListFragmentsInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ListFragmentsInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s ListFragmentsInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "ListFragmentsInput"} if s.MaxResults != nil && s.MaxResults < 1 { invalidParams.Add(request.NewErrParamMinValue("MaxResults", 1)) } if s.NextToken != nil && len(s.NextToken) < 1 { invalidParams.Add(request.NewErrParamMinLen("NextToken", 1)) } if s.StreamARN != nil && len(s.StreamARN) < 1 { invalidParams.Add(request.NewErrParamMinLen("StreamARN", 1)) } if s.StreamName != nil && len(s.StreamName) < 1 { invalidParams.Add(request.NewErrParamMinLen("StreamName", 1)) } if s.FragmentSelector != nil { if err := s.FragmentSelector.Validate(); err != nil { invalidParams.AddNested("FragmentSelector", err.(request.ErrInvalidParams)) } } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetFragmentSelector sets the FragmentSelector field's value. func (s ListFragmentsInput) SetFragmentSelector(v FragmentSelector) ListFragmentsInput { s.FragmentSelector = v return s } // SetMaxResults sets the MaxResults field's value. func (s ListFragmentsInput) SetMaxResults(v int64) ListFragmentsInput { s.MaxResults = &v return s } // SetNextToken sets the NextToken field's value. func (s ListFragmentsInput) SetNextToken(v string) ListFragmentsInput { s.NextToken = &v return s } // SetStreamARN sets the StreamARN field's value. func (s ListFragmentsInput) SetStreamARN(v string) ListFragmentsInput { s.StreamARN = &v return s } // SetStreamName sets the StreamName field's value. func (s ListFragmentsInput) SetStreamName(v string) ListFragmentsInput { s.StreamName = &v return s } type ListFragmentsOutput struct { _ struct{} `type:"structure"` // A list of archived Fragment objects from the stream that meet the selector // criteria. Results are in no specific order, even across pages. Fragments []Fragment `type:"list"` // If the returned list is truncated, the operation returns this token to use // to retrieve the next page of results. This value is null when there are no // more results to return. NextToken string `min:"1" type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ListFragmentsOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ListFragmentsOutput) GoString() string { return s.String() } // SetFragments sets the Fragments field's value. func (s ListFragmentsOutput) SetFragments(v []Fragment) ListFragmentsOutput { s.Fragments = v return s } // SetNextToken sets the NextToken field's value. func (s ListFragmentsOutput) SetNextToken(v string) ListFragmentsOutput { s.NextToken = &v return s } // No codec private data was found in at least one of tracks of the video stream. type MissingCodecPrivateDataException struct { _ struct{} `type:"structure"` RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"` Message_ string `locationName:"Message" type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s MissingCodecPrivateDataException) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s MissingCodecPrivateDataException) GoString() string { return s.String() } func newErrorMissingCodecPrivateDataException(v protocol.ResponseMetadata) error { return &MissingCodecPrivateDataException{ RespMetadata: v, } } // Code returns the exception type name. func (s MissingCodecPrivateDataException) Code() string { return "MissingCodecPrivateDataException" } // Message returns the exception's message. func (s MissingCodecPrivateDataException) Message() string { if s.Message_ != nil { return s.Message_ } return "" } // OrigErr always returns nil, satisfies awserr.Error interface. func (s MissingCodecPrivateDataException) OrigErr() error { return nil } func (s MissingCodecPrivateDataException) Error() string { return fmt.Sprintf("%s: %s", s.Code(), s.Message()) } // Status code returns the HTTP status code for the request's response error. func (s MissingCodecPrivateDataException) StatusCode() int { return s.RespMetadata.StatusCode } // RequestID returns the service's response RequestID for request. func (s MissingCodecPrivateDataException) RequestID() string { return s.RespMetadata.RequestID } // GetImages was requested for a stream that does not retain data (that is, // has a DataRetentionInHours of 0). type NoDataRetentionException struct { _ struct{} `type:"structure"` RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"` Message_ string `locationName:"Message" type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s NoDataRetentionException) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s NoDataRetentionException) GoString() string { return s.String() } func newErrorNoDataRetentionException(v protocol.ResponseMetadata) error { return &NoDataRetentionException{ RespMetadata: v, } } // Code returns the exception type name. func (s NoDataRetentionException) Code() string { return "NoDataRetentionException" } // Message returns the exception's message. func (s NoDataRetentionException) Message() string { if s.Message_ != nil { return s.Message_ } return "" } // OrigErr always returns nil, satisfies awserr.Error interface. func (s NoDataRetentionException) OrigErr() error { return nil } func (s NoDataRetentionException) Error() string { return fmt.Sprintf("%s: %s", s.Code(), s.Message()) } // Status code returns the HTTP status code for the request's response error. func (s NoDataRetentionException) StatusCode() int { return s.RespMetadata.StatusCode } // RequestID returns the service's response RequestID for request. func (s NoDataRetentionException) RequestID() string { return s.RespMetadata.RequestID } // Status Code: 403, The caller is not authorized to perform an operation on // the given stream, or the token has expired. type NotAuthorizedException struct { _ struct{} `type:"structure"` RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"` Message_ string `locationName:"Message" type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s NotAuthorizedException) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s NotAuthorizedException) GoString() string { return s.String() } func newErrorNotAuthorizedException(v protocol.ResponseMetadata) error { return &NotAuthorizedException{ RespMetadata: v, } } // Code returns the exception type name. func (s NotAuthorizedException) Code() string { return "NotAuthorizedException" } // Message returns the exception's message. func (s NotAuthorizedException) Message() string { if s.Message_ != nil { return s.Message_ } return "" } // OrigErr always returns nil, satisfies awserr.Error interface. func (s NotAuthorizedException) OrigErr() error { return nil } func (s NotAuthorizedException) Error() string { return fmt.Sprintf("%s: %s", s.Code(), s.Message()) } // Status code returns the HTTP status code for the request's response error. func (s NotAuthorizedException) StatusCode() int { return s.RespMetadata.StatusCode } // RequestID returns the service's response RequestID for request. func (s NotAuthorizedException) RequestID() string { return s.RespMetadata.RequestID } // GetImages will throw this error when Kinesis Video Streams can't find the // stream that you specified. // // GetHLSStreamingSessionURL and GetDASHStreamingSessionURL throw this error // if a session with a PlaybackMode of ON_DEMAND or LIVE_REPLAYis requested // for a stream that has no fragments within the requested time range, or if // a session with a PlaybackMode of LIVE is requested for a stream that has // no fragments within the last 30 seconds. type ResourceNotFoundException struct { _ struct{} `type:"structure"` RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"` Message_ string `locationName:"Message" type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ResourceNotFoundException) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s ResourceNotFoundException) GoString() string { return s.String() } func newErrorResourceNotFoundException(v protocol.ResponseMetadata) error { return &ResourceNotFoundException{ RespMetadata: v, } } // Code returns the exception type name. func (s ResourceNotFoundException) Code() string { return "ResourceNotFoundException" } // Message returns the exception's message. func (s ResourceNotFoundException) Message() string { if s.Message_ != nil { return s.Message_ } return "" } // OrigErr always returns nil, satisfies awserr.Error interface. func (s ResourceNotFoundException) OrigErr() error { return nil } func (s ResourceNotFoundException) Error() string { return fmt.Sprintf("%s: %s", s.Code(), s.Message()) } // Status code returns the HTTP status code for the request's response error. func (s ResourceNotFoundException) StatusCode() int { return s.RespMetadata.StatusCode } // RequestID returns the service's response RequestID for request. func (s ResourceNotFoundException) RequestID() string { return s.RespMetadata.RequestID } // The range of timestamps for which to return fragments. type TimestampRange struct { _ struct{} `type:"structure"` // The ending timestamp in the range of timestamps for which to return fragments. // // EndTimestamp is a required field EndTimestamp time.Time `type:"timestamp" required:"true"` // The starting timestamp in the range of timestamps for which to return fragments. // // StartTimestamp is a required field StartTimestamp time.Time `type:"timestamp" required:"true"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s TimestampRange) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s TimestampRange) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s TimestampRange) Validate() error { invalidParams := request.ErrInvalidParams{Context: "TimestampRange"} if s.EndTimestamp == nil { invalidParams.Add(request.NewErrParamRequired("EndTimestamp")) } if s.StartTimestamp == nil { invalidParams.Add(request.NewErrParamRequired("StartTimestamp")) } if invalidParams.Len() > 0 { return invalidParams } return nil } // SetEndTimestamp sets the EndTimestamp field's value. func (s TimestampRange) SetEndTimestamp(v time.Time) TimestampRange { s.EndTimestamp = &v return s } // SetStartTimestamp sets the StartTimestamp field's value. func (s TimestampRange) SetStartTimestamp(v time.Time) TimestampRange { s.StartTimestamp = &v return s } // The type of the media (for example, h.264 or h.265 video or ACC or G.711 // audio) could not be determined from the codec IDs of the tracks in the first // fragment for a playback session. The codec ID for track 1 should be V_MPEG/ISO/AVC // and, optionally, the codec ID for track 2 should be A_AAC. type UnsupportedStreamMediaTypeException struct { _ struct{} `type:"structure"` RespMetadata protocol.ResponseMetadata `json:"-" xml:"-"` Message_ string `locationName:"Message" type:"string"` } // String returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s UnsupportedStreamMediaTypeException) String() string { return awsutil.Prettify(s) } // GoString returns the string representation. // // API parameter values that are decorated as "sensitive" in the API will not // be included in the string output. The member name will be present, but the // value will be replaced with "sensitive". func (s UnsupportedStreamMediaTypeException) GoString() string { return s.String() } func newErrorUnsupportedStreamMediaTypeException(v protocol.ResponseMetadata) error { return &UnsupportedStreamMediaTypeException{ RespMetadata: v, } } // Code returns the exception type name. func (s UnsupportedStreamMediaTypeException) Code() string { return "UnsupportedStreamMediaTypeException" } // Message returns the exception's message. func (s UnsupportedStreamMediaTypeException) Message() string { if s.Message_ != nil { return s.Message_ } return "" } // OrigErr always returns nil, satisfies awserr.Error interface. func (s UnsupportedStreamMediaTypeException) OrigErr() error { return nil } func (s UnsupportedStreamMediaTypeException) Error() string { return fmt.Sprintf("%s: %s", s.Code(), s.Message()) } // Status code returns the HTTP status code for the request's response error. func (s UnsupportedStreamMediaTypeException) StatusCode() int { return s.RespMetadata.StatusCode } // RequestID returns the service's response RequestID for request. func (s UnsupportedStreamMediaTypeException) RequestID() string { return s.RespMetadata.RequestID } const ( // ClipFragmentSelectorTypeProducerTimestamp is a ClipFragmentSelectorType enum value ClipFragmentSelectorTypeProducerTimestamp = "PRODUCER_TIMESTAMP" // ClipFragmentSelectorTypeServerTimestamp is a ClipFragmentSelectorType enum value ClipFragmentSelectorTypeServerTimestamp = "SERVER_TIMESTAMP" ) // ClipFragmentSelectorType_Values returns all elements of the ClipFragmentSelectorType enum func ClipFragmentSelectorType_Values() []string { return []string{ ClipFragmentSelectorTypeProducerTimestamp, ClipFragmentSelectorTypeServerTimestamp, } } const ( // ContainerFormatFragmentedMp4 is a ContainerFormat enum value ContainerFormatFragmentedMp4 = "FRAGMENTED_MP4" // ContainerFormatMpegTs is a ContainerFormat enum value ContainerFormatMpegTs = "MPEG_TS" ) // ContainerFormat_Values returns all elements of the ContainerFormat enum func ContainerFormat_Values() []string { return []string{ ContainerFormatFragmentedMp4, ContainerFormatMpegTs, } } const ( // DASHDisplayFragmentNumberAlways is a DASHDisplayFragmentNumber enum value DASHDisplayFragmentNumberAlways = "ALWAYS" // DASHDisplayFragmentNumberNever is a DASHDisplayFragmentNumber enum value DASHDisplayFragmentNumberNever = "NEVER" ) // DASHDisplayFragmentNumber_Values returns all elements of the DASHDisplayFragmentNumber enum func DASHDisplayFragmentNumber_Values() []string { return []string{ DASHDisplayFragmentNumberAlways, DASHDisplayFragmentNumberNever, } } const ( // DASHDisplayFragmentTimestampAlways is a DASHDisplayFragmentTimestamp enum value DASHDisplayFragmentTimestampAlways = "ALWAYS" // DASHDisplayFragmentTimestampNever is a DASHDisplayFragmentTimestamp enum value DASHDisplayFragmentTimestampNever = "NEVER" ) // DASHDisplayFragmentTimestamp_Values returns all elements of the DASHDisplayFragmentTimestamp enum func DASHDisplayFragmentTimestamp_Values() []string { return []string{ DASHDisplayFragmentTimestampAlways, DASHDisplayFragmentTimestampNever, } } const ( // DASHFragmentSelectorTypeProducerTimestamp is a DASHFragmentSelectorType enum value DASHFragmentSelectorTypeProducerTimestamp = "PRODUCER_TIMESTAMP" // DASHFragmentSelectorTypeServerTimestamp is a DASHFragmentSelectorType enum value DASHFragmentSelectorTypeServerTimestamp = "SERVER_TIMESTAMP" ) // DASHFragmentSelectorType_Values returns all elements of the DASHFragmentSelectorType enum func DASHFragmentSelectorType_Values() []string { return []string{ DASHFragmentSelectorTypeProducerTimestamp, DASHFragmentSelectorTypeServerTimestamp, } } const ( // DASHPlaybackModeLive is a DASHPlaybackMode enum value DASHPlaybackModeLive = "LIVE" // DASHPlaybackModeLiveReplay is a DASHPlaybackMode enum value DASHPlaybackModeLiveReplay = "LIVE_REPLAY" // DASHPlaybackModeOnDemand is a DASHPlaybackMode enum value DASHPlaybackModeOnDemand = "ON_DEMAND" ) // DASHPlaybackMode_Values returns all elements of the DASHPlaybackMode enum func DASHPlaybackMode_Values() []string { return []string{ DASHPlaybackModeLive, DASHPlaybackModeLiveReplay, DASHPlaybackModeOnDemand, } } const ( // FormatJpeg is a Format enum value FormatJpeg = "JPEG" // FormatPng is a Format enum value FormatPng = "PNG" ) // Format_Values returns all elements of the Format enum func Format_Values() []string { return []string{ FormatJpeg, FormatPng, } } const ( // FormatConfigKeyJpegquality is a FormatConfigKey enum value FormatConfigKeyJpegquality = "JPEGQuality" ) // FormatConfigKey_Values returns all elements of the FormatConfigKey enum func FormatConfigKey_Values() []string { return []string{ FormatConfigKeyJpegquality, } } const ( // FragmentSelectorTypeProducerTimestamp is a FragmentSelectorType enum value FragmentSelectorTypeProducerTimestamp = "PRODUCER_TIMESTAMP" // FragmentSelectorTypeServerTimestamp is a FragmentSelectorType enum value FragmentSelectorTypeServerTimestamp = "SERVER_TIMESTAMP" ) // FragmentSelectorType_Values returns all elements of the FragmentSelectorType enum func FragmentSelectorType_Values() []string { return []string{ FragmentSelectorTypeProducerTimestamp, FragmentSelectorTypeServerTimestamp, } } const ( // HLSDiscontinuityModeAlways is a HLSDiscontinuityMode enum value HLSDiscontinuityModeAlways = "ALWAYS" // HLSDiscontinuityModeNever is a HLSDiscontinuityMode enum value HLSDiscontinuityModeNever = "NEVER" // HLSDiscontinuityModeOnDiscontinuity is a HLSDiscontinuityMode enum value HLSDiscontinuityModeOnDiscontinuity = "ON_DISCONTINUITY" ) // HLSDiscontinuityMode_Values returns all elements of the HLSDiscontinuityMode enum func HLSDiscontinuityMode_Values() []string { return []string{ HLSDiscontinuityModeAlways, HLSDiscontinuityModeNever, HLSDiscontinuityModeOnDiscontinuity, } } const ( // HLSDisplayFragmentTimestampAlways is a HLSDisplayFragmentTimestamp enum value HLSDisplayFragmentTimestampAlways = "ALWAYS" // HLSDisplayFragmentTimestampNever is a HLSDisplayFragmentTimestamp enum value HLSDisplayFragmentTimestampNever = "NEVER" ) // HLSDisplayFragmentTimestamp_Values returns all elements of the HLSDisplayFragmentTimestamp enum func HLSDisplayFragmentTimestamp_Values() []string { return []string{ HLSDisplayFragmentTimestampAlways, HLSDisplayFragmentTimestampNever, } } const ( // HLSFragmentSelectorTypeProducerTimestamp is a HLSFragmentSelectorType enum value HLSFragmentSelectorTypeProducerTimestamp = "PRODUCER_TIMESTAMP" // HLSFragmentSelectorTypeServerTimestamp is a HLSFragmentSelectorType enum value HLSFragmentSelectorTypeServerTimestamp = "SERVER_TIMESTAMP" ) // HLSFragmentSelectorType_Values returns all elements of the HLSFragmentSelectorType enum func HLSFragmentSelectorType_Values() []string { return []string{ HLSFragmentSelectorTypeProducerTimestamp, HLSFragmentSelectorTypeServerTimestamp, } } const ( // HLSPlaybackModeLive is a HLSPlaybackMode enum value HLSPlaybackModeLive = "LIVE" // HLSPlaybackModeLiveReplay is a HLSPlaybackMode enum value HLSPlaybackModeLiveReplay = "LIVE_REPLAY" // HLSPlaybackModeOnDemand is a HLSPlaybackMode enum value HLSPlaybackModeOnDemand = "ON_DEMAND" ) // HLSPlaybackMode_Values returns all elements of the HLSPlaybackMode enum func HLSPlaybackMode_Values() []string { return []string{ HLSPlaybackModeLive, HLSPlaybackModeLiveReplay, HLSPlaybackModeOnDemand, } } const ( // ImageErrorNoMedia is a ImageError enum value ImageErrorNoMedia = "NO_MEDIA" // ImageErrorMediaError is a ImageError enum value ImageErrorMediaError = "MEDIA_ERROR" ) // ImageError_Values returns all elements of the ImageError enum func ImageError_Values() []string { return []string{ ImageErrorNoMedia, ImageErrorMediaError, } } const ( // ImageSelectorTypeProducerTimestamp is a ImageSelectorType enum value ImageSelectorTypeProducerTimestamp = "PRODUCER_TIMESTAMP" // ImageSelectorTypeServerTimestamp is a ImageSelectorType enum value ImageSelectorTypeServerTimestamp = "SERVER_TIMESTAMP" ) // ImageSelectorType_Values returns all elements of the ImageSelectorType enum func ImageSelectorType_Values() []string { return []string{ ImageSelectorTypeProducerTimestamp, ImageSelectorTypeServerTimestamp, } }	149.84 KB	2025-05-25 12:27
📄 doc.go // Code generated by private/model/cli/gen-api/main.go. DO NOT EDIT. // Package kinesisvideoarchivedmedia provides the client and types for making API // requests to Amazon Kinesis Video Streams Archived Media. // // See https://docs.aws.amazon.com/goto/WebAPI/kinesis-video-archived-media-2017-09-30 for more information on this service. // // See kinesisvideoarchivedmedia package documentation for more information. // https://docs.aws.amazon.com/sdk-for-go/api/service/kinesisvideoarchivedmedia/ // // # Using the Client // // To contact Amazon Kinesis Video Streams Archived Media with the SDK use the New function to create // a new service client. With that client you can make API requests to the service. // These clients are safe to use concurrently. // // See the SDK's documentation for more information on how to use the SDK. // https://docs.aws.amazon.com/sdk-for-go/api/ // // See aws.Config documentation for more information on configuring SDK clients. // https://docs.aws.amazon.com/sdk-for-go/api/aws/#Config // // See the Amazon Kinesis Video Streams Archived Media client KinesisVideoArchivedMedia for more // information on creating client for this service. // https://docs.aws.amazon.com/sdk-for-go/api/service/kinesisvideoarchivedmedia/#New package kinesisvideoarchivedmedia	1.27 KB	2025-05-25 12:27
📄 errors.go // Code generated by private/model/cli/gen-api/main.go. DO NOT EDIT. package kinesisvideoarchivedmedia import ( "github.com/aws/aws-sdk-go/private/protocol" ) const ( // ErrCodeClientLimitExceededException for service response error code // "ClientLimitExceededException". // // Kinesis Video Streams has throttled the request because you have exceeded // a limit. Try making the call later. For information about limits, see Kinesis // Video Streams Limits (http://docs.aws.amazon.com/kinesisvideostreams/latest/dg/limits.html). ErrCodeClientLimitExceededException = "ClientLimitExceededException" // ErrCodeInvalidArgumentException for service response error code // "InvalidArgumentException". // // A specified parameter exceeds its restrictions, is not supported, or can't // be used. ErrCodeInvalidArgumentException = "InvalidArgumentException" // ErrCodeInvalidCodecPrivateDataException for service response error code // "InvalidCodecPrivateDataException". // // The codec private data in at least one of the tracks of the video stream // is not valid for this operation. ErrCodeInvalidCodecPrivateDataException = "InvalidCodecPrivateDataException" // ErrCodeInvalidMediaFrameException for service response error code // "InvalidMediaFrameException". // // One or more frames in the requested clip could not be parsed based on the // specified codec. ErrCodeInvalidMediaFrameException = "InvalidMediaFrameException" // ErrCodeMissingCodecPrivateDataException for service response error code // "MissingCodecPrivateDataException". // // No codec private data was found in at least one of tracks of the video stream. ErrCodeMissingCodecPrivateDataException = "MissingCodecPrivateDataException" // ErrCodeNoDataRetentionException for service response error code // "NoDataRetentionException". // // GetImages was requested for a stream that does not retain data (that is, // has a DataRetentionInHours of 0). ErrCodeNoDataRetentionException = "NoDataRetentionException" // ErrCodeNotAuthorizedException for service response error code // "NotAuthorizedException". // // Status Code: 403, The caller is not authorized to perform an operation on // the given stream, or the token has expired. ErrCodeNotAuthorizedException = "NotAuthorizedException" // ErrCodeResourceNotFoundException for service response error code // "ResourceNotFoundException". // // GetImages will throw this error when Kinesis Video Streams can't find the // stream that you specified. // // GetHLSStreamingSessionURL and GetDASHStreamingSessionURL throw this error // if a session with a PlaybackMode of ON_DEMAND or LIVE_REPLAYis requested // for a stream that has no fragments within the requested time range, or if // a session with a PlaybackMode of LIVE is requested for a stream that has // no fragments within the last 30 seconds. ErrCodeResourceNotFoundException = "ResourceNotFoundException" // ErrCodeUnsupportedStreamMediaTypeException for service response error code // "UnsupportedStreamMediaTypeException". // // The type of the media (for example, h.264 or h.265 video or ACC or G.711 // audio) could not be determined from the codec IDs of the tracks in the first // fragment for a playback session. The codec ID for track 1 should be V_MPEG/ISO/AVC // and, optionally, the codec ID for track 2 should be A_AAC. ErrCodeUnsupportedStreamMediaTypeException = "UnsupportedStreamMediaTypeException" ) var exceptionFromCode = map[string]func(protocol.ResponseMetadata) error{ "ClientLimitExceededException": newErrorClientLimitExceededException, "InvalidArgumentException": newErrorInvalidArgumentException, "InvalidCodecPrivateDataException": newErrorInvalidCodecPrivateDataException, "InvalidMediaFrameException": newErrorInvalidMediaFrameException, "MissingCodecPrivateDataException": newErrorMissingCodecPrivateDataException, "NoDataRetentionException": newErrorNoDataRetentionException, "NotAuthorizedException": newErrorNotAuthorizedException, "ResourceNotFoundException": newErrorResourceNotFoundException, "UnsupportedStreamMediaTypeException": newErrorUnsupportedStreamMediaTypeException, }	4.14 KB	2025-05-25 12:27
📁 kinesisvideoarchivedmediaiface	-	2025-05-25 12:27
📄 service.go // Code generated by private/model/cli/gen-api/main.go. DO NOT EDIT. package kinesisvideoarchivedmedia import ( "github.com/aws/aws-sdk-go/aws" "github.com/aws/aws-sdk-go/aws/client" "github.com/aws/aws-sdk-go/aws/client/metadata" "github.com/aws/aws-sdk-go/aws/request" "github.com/aws/aws-sdk-go/aws/signer/v4" "github.com/aws/aws-sdk-go/private/protocol" "github.com/aws/aws-sdk-go/private/protocol/restjson" ) // KinesisVideoArchivedMedia provides the API operation methods for making requests to // Amazon Kinesis Video Streams Archived Media. See this package's package overview docs // for details on the service. // // KinesisVideoArchivedMedia methods are safe to use concurrently. It is not safe to // modify mutate any of the struct's properties though. type KinesisVideoArchivedMedia struct { client.Client } // Used for custom client initialization logic var initClient func(client.Client) // Used for custom request initialization logic var initRequest func(request.Request) // Service information constants const ( ServiceName = "kinesisvideo" // Name of service. EndpointsID = ServiceName // ID to lookup a service endpoint with. ServiceID = "Kinesis Video Archived Media" // ServiceID is a unique identifier of a specific service. ) // New creates a new instance of the KinesisVideoArchivedMedia client with a session. // If additional configuration is needed for the client instance use the optional // aws.Config parameter to add your extra config. // // Example: // // mySession := session.Must(session.NewSession()) // // // Create a KinesisVideoArchivedMedia client from just a session. // svc := kinesisvideoarchivedmedia.New(mySession) // // // Create a KinesisVideoArchivedMedia client with additional configuration // svc := kinesisvideoarchivedmedia.New(mySession, aws.NewConfig().WithRegion("us-west-2")) func New(p client.ConfigProvider, cfgs ...aws.Config) KinesisVideoArchivedMedia { c := p.ClientConfig(EndpointsID, cfgs...) if c.SigningNameDerived \|\| len(c.SigningName) == 0 { c.SigningName = EndpointsID // No Fallback } return newClient(c.Config, c.Handlers, c.PartitionID, c.Endpoint, c.SigningRegion, c.SigningName, c.ResolvedRegion) } // newClient creates, initializes and returns a new service client instance. func newClient(cfg aws.Config, handlers request.Handlers, partitionID, endpoint, signingRegion, signingName, resolvedRegion string) KinesisVideoArchivedMedia { svc := &KinesisVideoArchivedMedia{ Client: client.New( cfg, metadata.ClientInfo{ ServiceName: ServiceName, ServiceID: ServiceID, SigningName: signingName, SigningRegion: signingRegion, PartitionID: partitionID, Endpoint: endpoint, APIVersion: "2017-09-30", ResolvedRegion: resolvedRegion, }, handlers, ), } // Handlers svc.Handlers.Sign.PushBackNamed(v4.SignRequestHandler) svc.Handlers.Build.PushBackNamed(restjson.BuildHandler) svc.Handlers.Unmarshal.PushBackNamed(restjson.UnmarshalHandler) svc.Handlers.UnmarshalMeta.PushBackNamed(restjson.UnmarshalMetaHandler) svc.Handlers.UnmarshalError.PushBackNamed( protocol.NewUnmarshalErrorHandler(restjson.NewUnmarshalTypedError(exceptionFromCode)).NamedHandler(), ) // Run custom client initialization if present if initClient != nil { initClient(svc.Client) } return svc } // newRequest creates a new request for a KinesisVideoArchivedMedia operation and runs any // custom request initialization. func (c KinesisVideoArchivedMedia) newRequest(op request.Operation, params, data interface{}) request.Request { req := c.NewRequest(op, params, data) // Run custom request initialization if present if initRequest != nil { initRequest(req) } return req }	3.7 KB	2025-05-25 12:27

Terminal