diff --git a/misk-aws/api/misk-aws.api b/misk-aws/api/misk-aws.api index bb57330f3f9..bc5cef9393e 100644 --- a/misk-aws/api/misk-aws.api +++ b/misk-aws/api/misk-aws.api @@ -56,6 +56,9 @@ public final class misk/jobqueue/sqs/AwsSqsJobHandlerModule$Companion { public static synthetic fun create$default (Lmisk/jobqueue/sqs/AwsSqsJobHandlerModule$Companion;Lmisk/jobqueue/QueueName;Lkotlin/reflect/KClass;ZLjava/util/List;ILjava/lang/Object;)Lmisk/jobqueue/sqs/AwsSqsJobHandlerModule; } +public final class misk/jobqueue/sqs/AwsSqsJobHandlerSubscriptionService : com/google/common/util/concurrent/AbstractIdleService { +} + public final class misk/jobqueue/sqs/AwsSqsJobQueueConfig : wisp/config/Config { public fun ()V public fun (Ljava/util/Map;)V @@ -104,6 +107,16 @@ public final class misk/jobqueue/sqs/AwsSqsJobReceiverPolicy : java/lang/Enum { public static fun values ()[Lmisk/jobqueue/sqs/AwsSqsJobReceiverPolicy; } +public final class misk/jobqueue/sqs/AwsSqsQueueAttributeImporter { + public static final field Companion Lmisk/jobqueue/sqs/AwsSqsQueueAttributeImporter$Companion; + public final fun getRunning ()Ljava/util/concurrent/atomic/AtomicBoolean; + public final fun import (Lmisk/jobqueue/QueueName;)V + public final fun shutDown ()V +} + +public final class misk/jobqueue/sqs/AwsSqsQueueAttributeImporter$Companion { +} + public final class misk/jobqueue/sqs/AwsSqsQueueConfig { public fun ()V public fun (Ljava/lang/String;)V @@ -187,12 +200,38 @@ public final class misk/jobqueue/sqs/FlaggedBufferedSqsClient$Companion { public final fun getFEATURE ()Lmisk/feature/Feature; } +public final class misk/jobqueue/sqs/QueueResolver { + public static final field Companion Lmisk/jobqueue/sqs/QueueResolver$Companion; + public final fun getDeadLetter (Lmisk/jobqueue/QueueName;)Lmisk/jobqueue/sqs/ResolvedQueue; + public final fun getForReceiving (Lmisk/jobqueue/QueueName;)Lmisk/jobqueue/sqs/ResolvedQueue; + public final fun getForSending (Lmisk/jobqueue/QueueName;)Lmisk/jobqueue/sqs/ResolvedQueue; +} + +public final class misk/jobqueue/sqs/QueueResolver$Companion { + public final fun getLog ()Lmu/KLogger; +} + public final class misk/jobqueue/sqs/QueueResolverKt { public static final fun getParentQueue (Lmisk/jobqueue/QueueName;)Lmisk/jobqueue/QueueName; public static final fun getRetryQueue (Lmisk/jobqueue/QueueName;)Lmisk/jobqueue/QueueName; public static final fun isRetryQueue (Lmisk/jobqueue/QueueName;)Z } +public final class misk/jobqueue/sqs/ResolvedQueue { + public final fun call (Lkotlin/jvm/functions/Function1;)Ljava/lang/Object; + public final fun getAccountId ()Lmisk/cloud/aws/AwsAccountId; + public final fun getClient ()Lcom/amazonaws/services/sqs/AmazonSQS; + public final fun getName ()Lmisk/jobqueue/QueueName; + public final fun getQueueName ()Ljava/lang/String; + public final fun getRegion ()Lmisk/cloud/aws/AwsRegion; + public final fun getSqsQueueName ()Lmisk/jobqueue/QueueName; + public final fun getUrl ()Ljava/lang/String; +} + +public final class misk/jobqueue/sqs/ResolvedQueue$SQSException : java/lang/RuntimeException { + public fun (Lcom/amazonaws/AmazonClientException;Lmisk/jobqueue/sqs/ResolvedQueue;)V +} + public final class misk/jobqueue/sqs/SqsConsumerAllocator { public static final field Companion Lmisk/jobqueue/sqs/SqsConsumerAllocator$Companion; public fun (Lwisp/lease/LeaseManager;Lmisk/feature/FeatureFlags;)V @@ -203,6 +242,33 @@ public final class misk/jobqueue/sqs/SqsConsumerAllocator$Companion { public final fun leaseName (Lmisk/jobqueue/QueueName;I)Ljava/lang/String; } +public final class misk/jobqueue/sqs/SqsJobConsumer : misk/jobqueue/JobConsumer { + public static final field Companion Lmisk/jobqueue/sqs/SqsJobConsumer$Companion; + public final fun shutDown ()V + public fun subscribe (Lmisk/jobqueue/QueueName;Lmisk/jobqueue/JobHandler;)V + public fun unsubscribe (Lmisk/jobqueue/QueueName;)V +} + +public final class misk/jobqueue/sqs/SqsJobConsumer$Companion { +} + +public final class misk/jobqueue/sqs/SqsMetrics { + public final fun getHandlerDispatchTime ()Lmisk/metrics/Histogram; + public final fun getHandlerFailures ()Lio/prometheus/client/Counter; + public final fun getJobEnqueueFailures ()Lio/prometheus/client/Counter; + public final fun getJobsAcknowledged ()Lio/prometheus/client/Counter; + public final fun getJobsDeadLettered ()Lio/prometheus/client/Counter; + public final fun getJobsEnqueued ()Lio/prometheus/client/Counter; + public final fun getJobsReceived ()Lio/prometheus/client/Counter; + public final fun getQueueProcessingLag ()Lmisk/metrics/Histogram; + public final fun getSqsApproxNumberOfMessages ()Lio/prometheus/client/Gauge; + public final fun getSqsApproxNumberOfMessagesNotVisible ()Lio/prometheus/client/Gauge; + public final fun getSqsDeleteTime ()Lmisk/metrics/Histogram; + public final fun getSqsReceiveTime ()Lmisk/metrics/Histogram; + public final fun getSqsSendTime ()Lmisk/metrics/Histogram; + public final fun getVisibilityTime ()Lio/prometheus/client/Gauge; +} + public final class misk/jobqueue/sqs/StaticDeadLetterQueueProvider : misk/jobqueue/sqs/DeadLetterQueueProvider { public fun (Ljava/lang/String;)V public fun deadLetterQueueFor (Lmisk/jobqueue/QueueName;)Lmisk/jobqueue/QueueName;