Package com.amazonaws.kinesisvideo.java.service

Class CachedInfoMultiAuthServiceCallbacksImpl

java.lang.Object

com.amazonaws.kinesisvideo.internal.service.DefaultServiceCallbacksImpl

com.amazonaws.kinesisvideo.java.service.CachedInfoMultiAuthServiceCallbacksImpl

All Implemented Interfaces:

ServiceCallbacks

public class CachedInfoMultiAuthServiceCallbacksImpl
extends DefaultServiceCallbacksImpl

Field Summary

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

configuration, executor, kinesisVideoProducer, kinesisVideoServiceClient, log

Constructor Summary

Constructors

Constructor	Description
CachedInfoMultiAuthServiceCallbacksImpl(org.apache.logging.log4j.Logger log, ScheduledExecutorService executor, KinesisVideoClientConfiguration configuration, KinesisVideoServiceClient kinesisVideoServiceClient)

Method Summary

Modifier and Type	Method	Description
void	addCredentialsProviderToCache(String streamName, com.amazonaws.auth.AWSCredentialsProvider credentialsProvider)
void	addStreamInfoToCache(String streamName, com.amazonaws.services.kinesisvideo.model.DescribeStreamResult streamInfo)
void	addStreamingEndpointToCache(String streamName, String endpoint)
void	addTagInfoToCache(String streamName, Tag[] tags)
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	initialize(KinesisVideoProducer kinesisVideoProducer)	Initializes the object
boolean	isInitialized()	Returns whether the object is initialized
void	removeStreamFromCache(String streamName)
void	tagResource(String resourceArn, Tag[] tagsUnused, 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, notifyCallResult, putStream, removeStream

Methods inherited from class java.lang.Object

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

Constructor Detail

CachedInfoMultiAuthServiceCallbacksImpl

public CachedInfoMultiAuthServiceCallbacksImpl(@Nonnull
                                               org.apache.logging.log4j.Logger log,
                                               @Nonnull
                                               ScheduledExecutorService executor,
                                               @Nonnull
                                               KinesisVideoClientConfiguration configuration,
                                               @Nonnull
                                               KinesisVideoServiceClient kinesisVideoServiceClient)

Method Detail

initialize

public void initialize(@Nonnull
                       KinesisVideoProducer kinesisVideoProducer)

Initializes the object

Specified by:

initialize in interface ServiceCallbacks

Overrides:

initialize in class DefaultServiceCallbacksImpl

Parameters:

kinesisVideoProducer - Reference to KinesisVideoProducer for the eventing.

isInitialized

public boolean isInitialized()

Description copied from interface: ServiceCallbacks

Returns whether the object is initialized

Specified by:

isInitialized in interface ServiceCallbacks

Overrides:

isInitialized in class DefaultServiceCallbacksImpl

Returns:

whether the object is initialized

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[] tagsUnused,
                        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

tagsUnused - - 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

addStreamInfoToCache

public void addStreamInfoToCache(String streamName,
                                 com.amazonaws.services.kinesisvideo.model.DescribeStreamResult streamInfo)

addTagInfoToCache

public void addTagInfoToCache(String streamName,
                              Tag[] tags)

addStreamingEndpointToCache

public void addStreamingEndpointToCache(String streamName,
                                        String endpoint)

addCredentialsProviderToCache

public void addCredentialsProviderToCache(String streamName,
                                          com.amazonaws.auth.AWSCredentialsProvider credentialsProvider)

removeStreamFromCache

public void removeStreamFromCache(String streamName)