Package com.amazonaws.kinesisvideo.java.service

Class MultiAuthServiceCallbacksImpl

java.lang.Object

com.amazonaws.kinesisvideo.internal.service.DefaultServiceCallbacksImpl

com.amazonaws.kinesisvideo.java.service.MultiAuthServiceCallbacksImpl

All Implemented Interfaces:

ServiceCallbacks

public class MultiAuthServiceCallbacksImpl
extends DefaultServiceCallbacksImpl

Field Summary

Fields

Modifier and Type	Field	Description
protected Function<StreamInfo,com.amazonaws.auth.AWSCredentialsProvider>	credentialsProviderFn	Given a StreamInfo object, determine which credentials to use.

Fields inherited from class com.amazonaws.kinesisvideo.internal.service.DefaultServiceCallbacksImpl

configuration, executor, kinesisVideoProducer, kinesisVideoServiceClient, log

Constructor Summary

Constructors

Constructor	Description
MultiAuthServiceCallbacksImpl(ScheduledExecutorService executor, KinesisVideoClientConfiguration configuration, KinesisVideoServiceClient kinesisVideoServiceClient, Function<StreamInfo,com.amazonaws.auth.AWSCredentialsProvider> credentialsProviderFn)

Method Summary

Modifier and Type	Method	Description
void	createStream(String deviceName, String streamName, String contentType, String kmsKeyId, long retentionPeriod, long callAfter, long timeout, byte[] authData, int authType, KinesisVideoProducerStream stream)	Asynchronous call to create stream with the specified parameters.
void	describeStream(String streamName, long callAfter, long timeout, byte[] authData, int authType, long streamHandle, KinesisVideoProducerStream stream)	Asynchronous call to describe stream with the specified parameters.
void	getStreamingEndpoint(String streamName, String apiName, long callAfter, long timeout, byte[] authData, int authType, long streamHandle, KinesisVideoProducerStream stream)	Asynchronous call to get streaming endpoint with the specified parameters.
void	getStreamingToken(String streamName, long callAfter, long timeout, byte[] authData, int authType, long streamHandle, KinesisVideoProducerStream stream)	Asynchronous call to get streaming token
void	tagResource(String resourceArn, Tag[] tags, long callAfter, long timeout, byte[] authData, int authType, long streamHandle, KinesisVideoProducerStream stream)	Asynchronous call to tag resource API

Methods inherited from class com.amazonaws.kinesisvideo.internal.service.DefaultServiceCallbacksImpl

addStream, createDevice, deviceCertToToken, free, getCredentialsProvider, getStatusCodeFromException, initialize, isInitialized, notifyCallResult, putStream, removeStream

Methods inherited from class java.lang.Object

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

Field Detail

credentialsProviderFn

protected Function<StreamInfo,com.amazonaws.auth.AWSCredentialsProvider> credentialsProviderFn

Given a StreamInfo object, determine which credentials to use.

Constructor Detail

MultiAuthServiceCallbacksImpl

public MultiAuthServiceCallbacksImpl(@Nonnull
                                     ScheduledExecutorService executor,
                                     @Nonnull
                                     KinesisVideoClientConfiguration configuration,
                                     @Nonnull
                                     KinesisVideoServiceClient kinesisVideoServiceClient,
                                     @Nonnull
                                     Function<StreamInfo,com.amazonaws.auth.AWSCredentialsProvider> credentialsProviderFn)

Parameters:

credentialsProviderFn - Used to determine which AWS credentials to use per stream. You can extend StreamInfo and add additional metadata for your business logic.

Method Detail

createStream

public void createStream(@Nonnull
                         String deviceName,
                         @Nonnull
                         String streamName,
                         @Nonnull
                         String contentType,
                         @Nullable
                         String kmsKeyId,
                         long retentionPeriod,
                         long callAfter,
                         long timeout,
                         @Nullable
                         byte[] authData,
                         int authType,
                         KinesisVideoProducerStream stream)
                  throws ProducerException

Description copied from interface: ServiceCallbacks

Asynchronous call to create stream with the specified parameters. PIC will attempt to schedule stream creation if the ServiceCallbacks.describeStream(String, long, long, byte[], int, long, KinesisVideoProducerStream) posts a KinesisVideoProducer.describeStreamResult(KinesisVideoProducerStream, long, StreamDescription, int) of 404 (Resource Not Found). This call will be skipped if StreamInfo.isAllowStreamCreation() is not allowed.

This method will notify PIC the success or failure of the operation via KinesisVideoProducer.createStreamResult(KinesisVideoProducerStream, String, int).

Specified by:

createStream in interface ServiceCallbacks

Overrides:

createStream in class DefaultServiceCallbacksImpl

Parameters:

deviceName - - Device name

streamName - - Stream name

contentType - - Stream content type

kmsKeyId - - KMS Key Id

retentionPeriod - - Stream retention period - 100ns

callAfter - - Call after this time - 100ns

timeout - - Time out for the call - 100ns

authData - - Authentication bits

authType - - Authentication type - this is the AUTH_INFO_TYPE defined in /src/client/Include.h

stream - - stream object for the result event callback

Throws:

ProducerException

See Also:

CreateStream API

describeStream

public void describeStream(@Nonnull
                           String streamName,
                           long callAfter,
                           long timeout,
                           @Nullable
                           byte[] authData,
                           int authType,
                           long streamHandle,
                           KinesisVideoProducerStream stream)
                    throws ProducerException

Description copied from interface: ServiceCallbacks

Asynchronous call to describe stream with the specified parameters.

This method will notify PIC the success or failure of the operation via KinesisVideoProducer.describeStreamResult(KinesisVideoProducerStream, long, StreamDescription, int)

Specified by:

describeStream in interface ServiceCallbacks

Overrides:

describeStream in class DefaultServiceCallbacksImpl

Parameters:

streamName - - Stream name

callAfter - - Call after this time - 100ns

timeout - - Time out for the call - 100ns

authData - - Authentication bits

authType - - Authentication type - this is the AUTH_INFO_TYPE defined in /src/client/Include.h

streamHandle - - stream handle returned by PIC

stream - - stream object for the result event callback

Throws:

ProducerException

See Also:

DescribeStream API

getStreamingEndpoint

public void getStreamingEndpoint(@Nonnull
                                 String streamName,
                                 @Nonnull
                                 String apiName,
                                 long callAfter,
                                 long timeout,
                                 @Nullable
                                 byte[] authData,
                                 int authType,
                                 long streamHandle,
                                 KinesisVideoProducerStream stream)
                          throws ProducerException

Description copied from interface: ServiceCallbacks

Asynchronous call to get streaming endpoint with the specified parameters.

This method will notify PIC the success or failure of the operation via KinesisVideoProducer.getStreamingEndpointResult(KinesisVideoProducerStream, long, String, int).

Specified by:

getStreamingEndpoint in interface ServiceCallbacks

Overrides:

getStreamingEndpoint in class DefaultServiceCallbacksImpl

Parameters:

streamName - - Stream name

apiName - - API name to call

callAfter - - Call after this time - 100ns

timeout - - Time out for the call - 100ns

authData - - Authentication bits

authType - - Authentication type - this is the AUTH_INFO_TYPE defined in /src/client/Include.h

streamHandle - - stream handle returned by PIC

stream - - stream object for the result event callback

Throws:

ProducerException

See Also:

GetDataEndpoint API

getStreamingToken

public void getStreamingToken(@Nonnull
                              String streamName,
                              long callAfter,
                              long timeout,
                              @Nullable
                              byte[] authData,
                              int authType,
                              long streamHandle,
                              KinesisVideoProducerStream stream)
                       throws ProducerException

Description copied from interface: ServiceCallbacks

Asynchronous call to get streaming token

Specified by:

getStreamingToken in interface ServiceCallbacks

Overrides:

getStreamingToken in class DefaultServiceCallbacksImpl

Parameters:

streamName - - Stream name

callAfter - - Call after this time - 100ns

timeout - - Time out for the call - 100ns

authData - - Authentication bits

authType - - Authentication type - this is the AUTH_INFO_TYPE defined in /src/client/Include.h

streamHandle - - stream handle returned by PIC

stream - - stream object for the result event callback

Throws:

ProducerException

tagResource

public void tagResource(@Nonnull
                        String resourceArn,
                        @Nullable
                        Tag[] tags,
                        long callAfter,
                        long timeout,
                        @Nullable
                        byte[] authData,
                        int authType,
                        long streamHandle,
                        KinesisVideoProducerStream stream)
                 throws ProducerException

Description copied from interface: ServiceCallbacks

Asynchronous call to tag resource API

Specified by:

tagResource in interface ServiceCallbacks

Overrides:

tagResource in class DefaultServiceCallbacksImpl

Parameters:

resourceArn - - Resource ARN

tags - - Tags to apply

callAfter - - Call after this time - 100ns

timeout - - Time out for the call - 100ns

authData - - Authentication bits

authType - - Authentication type - this is the AUTH_INFO_TYPE defined in /src/client/Include.h

streamHandle - - stream handle returned by PIC

stream - - stream object for the result event callback

Throws:

ProducerException