com.amazonaws.mobileconnectors.kinesisvideo.service

Class KinesisVideoAndroidServiceClient

java.lang.Object

com.amazonaws.mobileconnectors.kinesisvideo.service.KinesisVideoAndroidServiceClient

All Implemented Interfaces:

com.amazonaws.kinesisvideo.internal.producer.client.KinesisVideoServiceClient

public final class KinesisVideoAndroidServiceClient
extends java.lang.Object
implements com.amazonaws.kinesisvideo.internal.producer.client.KinesisVideoServiceClient

Constructor Summary

Constructors

Constructor and Description
KinesisVideoAndroidServiceClient(Log log)

Method Summary

Modifier and Type	Method and Description
java.lang.String	createStream(java.lang.String streamName, java.lang.String deviceName, java.lang.String contentType, java.lang.String kmsKeyId, long retentionPeriodInHours, long timeoutInMillis, KinesisVideoCredentialsProvider credentialsProvider) Create a stream on KinesisVideo frontend
void	deleteStream(java.lang.String streamName, java.lang.String version, java.util.Date creationTime, long timeoutInMillis, KinesisVideoCredentialsProvider credentialsProvider) Delete stream with name and version
StreamDescription	describeStream(java.lang.String streamName, long timeoutInMillis, KinesisVideoCredentialsProvider credentialsProvider) Describe the status of a stream
static AWSKinesisVideo	getAwsKinesisVideoClient(AWSCredentialsProvider credentialsProvider, Region region, java.lang.String endpoint, int timeoutInMillis)
java.lang.String	getDataEndpoint(java.lang.String streamName, java.lang.String apiName, long timeoutInMillis, KinesisVideoCredentialsProvider credentialsProvider) Get data endpoint to be used by PutMedia for the specified stream.
void	initialize(KinesisVideoClientConfiguration kinesisVideoClientConfiguration) Initialize with the network configuration.
void	putMedia(java.lang.String streamName, java.lang.String containerType, long streamStartTimeInMillis, boolean absoluteFragmentTimes, boolean ackRequired, java.lang.String dataEndpoint, long timeoutInMillis, KinesisVideoCredentialsProvider credentialsProvider, java.io.InputStream dataInputStream, Consumer<java.io.InputStream> acksConsumer, Consumer<java.lang.Exception> completionCallback) Puts media as a long-running operation.
void	tagStream(java.lang.String streamArn, java.util.Map<java.lang.String,java.lang.String> tags, long timeoutInMillis, KinesisVideoCredentialsProvider credentialsProvider) Tag a stream of a specified ARN with a list of tags.

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

KinesisVideoAndroidServiceClient

public KinesisVideoAndroidServiceClient(Log log)

Method Detail

getAwsKinesisVideoClient

public static AWSKinesisVideo getAwsKinesisVideoClient(AWSCredentialsProvider credentialsProvider,
                                                       Region region,
                                                       java.lang.String endpoint,
                                                       int timeoutInMillis)
                                                throws KinesisVideoException

Throws:

KinesisVideoException

initialize

public void initialize(KinesisVideoClientConfiguration kinesisVideoClientConfiguration)
                throws KinesisVideoException

Description copied from interface: com.amazonaws.kinesisvideo.internal.producer.client.KinesisVideoServiceClient

Initialize with the network configuration.

Specified by:

initialize in interface com.amazonaws.kinesisvideo.internal.producer.client.KinesisVideoServiceClient

Parameters:

kinesisVideoClientConfiguration - - Client configuration to initialize with

Throws:

KinesisVideoException

createStream

public java.lang.String createStream(java.lang.String streamName,
                                     java.lang.String deviceName,
                                     java.lang.String contentType,
                                     java.lang.String kmsKeyId,
                                     long retentionPeriodInHours,
                                     long timeoutInMillis,
                                     KinesisVideoCredentialsProvider credentialsProvider)
                              throws KinesisVideoException

Description copied from interface: com.amazonaws.kinesisvideo.internal.producer.client.KinesisVideoServiceClient

Create a stream on KinesisVideo frontend

Specified by:

createStream in interface com.amazonaws.kinesisvideo.internal.producer.client.KinesisVideoServiceClient

Parameters:

streamName - - Name of stream to create

deviceName - - Device name of stream to create

contentType - - Content type of stream to create

kmsKeyId - - KMS Key Id

retentionPeriodInHours - - Stream retention period in hours

timeoutInMillis - - Timeout in milliseconds

credentialsProvider - - Credentials to use

Returns:

StreamArn of stream just created

Throws:

KinesisVideoException

describeStream

public StreamDescription describeStream(java.lang.String streamName,
                                        long timeoutInMillis,
                                        KinesisVideoCredentialsProvider credentialsProvider)
                                 throws KinesisVideoException

Description copied from interface: com.amazonaws.kinesisvideo.internal.producer.client.KinesisVideoServiceClient

Describe the status of a stream

Specified by:

describeStream in interface com.amazonaws.kinesisvideo.internal.producer.client.KinesisVideoServiceClient

Parameters:

streamName - - Name of stream to describe

timeoutInMillis - - Timeout in milliseconds

credentialsProvider - - Credentials to use

Returns:

Stream description

Throws:

KinesisVideoException

deleteStream

public void deleteStream(java.lang.String streamName,
                         java.lang.String version,
                         java.util.Date creationTime,
                         long timeoutInMillis,
                         KinesisVideoCredentialsProvider credentialsProvider)
                  throws KinesisVideoException

Description copied from interface: com.amazonaws.kinesisvideo.internal.producer.client.KinesisVideoServiceClient

Delete stream with name and version

Specified by:

deleteStream in interface com.amazonaws.kinesisvideo.internal.producer.client.KinesisVideoServiceClient

Parameters:

streamName - - Name of stream to delete

version - - Version of stream to delete

creationTime - - Creation time of stream to delete

timeoutInMillis - - Timeout in milliseconds

credentialsProvider - - Credentials to use

Throws:

KinesisVideoException

tagStream

public void tagStream(java.lang.String streamArn,
                      java.util.Map<java.lang.String,java.lang.String> tags,
                      long timeoutInMillis,
                      KinesisVideoCredentialsProvider credentialsProvider)
               throws KinesisVideoException

Description copied from interface: com.amazonaws.kinesisvideo.internal.producer.client.KinesisVideoServiceClient

Tag a stream of a specified ARN with a list of tags.

Specified by:

tagStream in interface com.amazonaws.kinesisvideo.internal.producer.client.KinesisVideoServiceClient

Parameters:

streamArn - - ARN of the stream to be tagged

tags - - Map of key-value pair

timeoutInMillis - - Timeout in milliseconds

credentialsProvider - - Credentials to use

Throws:

KinesisVideoException

getDataEndpoint

public java.lang.String getDataEndpoint(java.lang.String streamName,
                                        java.lang.String apiName,
                                        long timeoutInMillis,
                                        KinesisVideoCredentialsProvider credentialsProvider)
                                 throws KinesisVideoException

Description copied from interface: com.amazonaws.kinesisvideo.internal.producer.client.KinesisVideoServiceClient

Get data endpoint to be used by PutMedia for the specified stream.

Specified by:

getDataEndpoint in interface com.amazonaws.kinesisvideo.internal.producer.client.KinesisVideoServiceClient

Parameters:

streamName - - Name of the stream

apiName - - Api name to call

timeoutInMillis - - Timeout in milliseconds

credentialsProvider - - Credentials to use

Returns:

endpoint to which PutMedia API is sent

Throws:

KinesisVideoException

putMedia

public void putMedia(java.lang.String streamName,
                     java.lang.String containerType,
                     long streamStartTimeInMillis,
                     boolean absoluteFragmentTimes,
                     boolean ackRequired,
                     java.lang.String dataEndpoint,
                     long timeoutInMillis,
                     KinesisVideoCredentialsProvider credentialsProvider,
                     java.io.InputStream dataInputStream,
                     Consumer<java.io.InputStream> acksConsumer,
                     Consumer<java.lang.Exception> completionCallback)
              throws KinesisVideoException

Description copied from interface: com.amazonaws.kinesisvideo.internal.producer.client.KinesisVideoServiceClient

Puts media as a long-running operation.

NOTE: The call will be 'prompt' and will return the IO streams which will be used for the actual streaming.

Specified by:

putMedia in interface com.amazonaws.kinesisvideo.internal.producer.client.KinesisVideoServiceClient

Parameters:

streamName - - Name of the stream

containerType - - Container type

streamStartTimeInMillis - - Stream start time

absoluteFragmentTimes - - Whether to use absolute fragment times

ackRequired - - Whether acks are required

dataEndpoint - - The data endpoint to use

timeoutInMillis - - Timeout in milliseconds

credentialsProvider - - Credentials to use

dataInputStream - - Data InputStream

acksConsumer - - Consumer of the ACK input stream

completionCallback - - Consumer of an Exception for reporting stream termination

Throws:

KinesisVideoException