Skip to content

Commit

Permalink
fix: include public API changes to misk-aws
Browse files Browse the repository at this point in the history
  • Loading branch information
hamdanjaveed committed Apr 15, 2024
1 parent 6b0bdca commit 8e32fde
Showing 1 changed file with 66 additions and 0 deletions.
66 changes: 66 additions & 0 deletions misk-aws/api/misk-aws.api
Original file line number Diff line number Diff line change
Expand Up @@ -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 <init> ()V
public fun <init> (Ljava/util/Map;)V
Expand Down Expand Up @@ -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 <init> ()V
public fun <init> (Ljava/lang/String;)V
Expand Down Expand Up @@ -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 <init> (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 <init> (Lwisp/lease/LeaseManager;Lmisk/feature/FeatureFlags;)V
Expand All @@ -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 <init> (Ljava/lang/String;)V
public fun deadLetterQueueFor (Lmisk/jobqueue/QueueName;)Lmisk/jobqueue/QueueName;
Expand Down

0 comments on commit 8e32fde

Please sign in to comment.