Index (javadoc 3.0.0 API)

A B C D E F G H I J L M N O P R S T U V

A

ack() - Method in class io.micronaut.gcp.pubsub.bind.DefaultPubSubAcknowledgement
AcknowledgementSubscriber - Class in io.micronaut.gcp.pubsub.subscriber
AcknowledgementSubscriber() - Constructor for class io.micronaut.gcp.pubsub.subscriber.AcknowledgementSubscriber
Animal - Class in io.micronaut.gcp.pubsub.support
Animal - Class in io.micronaut.gcp.pubsub.support
Animal(String) - Constructor for class io.micronaut.gcp.pubsub.support.Animal
Animal() - Constructor for class io.micronaut.gcp.pubsub.support.Animal
AnimalClient - Interface in io.micronaut.gcp.pubsub.quickstart
AnimalListener - Class in io.micronaut.gcp.pubsub.quickstart
AnimalListener() - Constructor for class io.micronaut.gcp.pubsub.quickstart.AnimalListener
AnimalService - Class in io.micronaut.gcp.pubsub.quickstart
AnimalService(AnimalClient) - Constructor for class io.micronaut.gcp.pubsub.quickstart.AnimalService
argumentType() - Method in class io.micronaut.gcp.pubsub.bind.PubSubAcknowledgementBinder

B

batchSend(Animal) - Method in interface io.micronaut.gcp.pubsub.publisher.CustomConfigurationClient
bind(ArgumentConversionContext<Object>, PubSubConsumerState) - Method in class io.micronaut.gcp.pubsub.bind.MessagePublishTimeAnnotationBinder
bind(ArgumentConversionContext<Acknowledgement>, PubSubConsumerState) - Method in class io.micronaut.gcp.pubsub.bind.PubSubAcknowledgementBinder
bind(ArgumentConversionContext<Object>, PubSubConsumerState) - Method in class io.micronaut.gcp.pubsub.bind.PubSubBodyBinder
bind(ArgumentConversionContext<Object>, PubSubConsumerState) - Method in class io.micronaut.gcp.pubsub.bind.PubSubDefaultArgumentBinder
bind(ArgumentConversionContext<Object>, PubSubConsumerState) - Method in class io.micronaut.gcp.pubsub.bind.PubSubHeaderBinder
bind(ArgumentConversionContext<Object>, PubSubConsumerState) - Method in class io.micronaut.gcp.pubsub.bind.PubSubMessageIdBinder
braveTracerConfigurationBeanCreatedEventListener() - Method in class io.micronaut.gcp.tracing.zipkin.StackdriverSenderFactory: A BeanCreatedEventListener that modifies the brave trace configuration for Stackdriver compatibility.

C

close() - Method in class io.micronaut.gcp.http.client.GoogleAuthFilter
close() - Method in class io.micronaut.gcp.pubsub.bind.DefaultSubscriberFactory
ContentTypeSubscriber - Class in io.micronaut.gcp.pubsub.subscriber
ContentTypeSubscriber() - Constructor for class io.micronaut.gcp.pubsub.subscriber.ContentTypeSubscriber
createPublisher(PublisherFactoryConfig) - Method in class io.micronaut.gcp.pubsub.support.DefaultPublisherFactory: Creates and caches a publisher for a given topic.
createPublisher(PublisherFactoryConfig) - Method in interface io.micronaut.gcp.pubsub.support.PublisherFactory
createSubscriber(SubscriberFactoryConfig) - Method in class io.micronaut.gcp.pubsub.bind.DefaultSubscriberFactory
createSubscriber(SubscriberFactoryConfig) - Method in interface io.micronaut.gcp.pubsub.bind.SubscriberFactory: Creates an SubscriberInterface implementation and register the receiver to it.
credentialsProvider(GoogleCredentials) - Method in class io.micronaut.gcp.pubsub.support.PubSubConfigurationFactory: Returns a default CredentialsProvider, allows users to override it and provide their own implementation.
CustomBindingSubscriber - Class in io.micronaut.gcp.pubsub.bind
CustomBindingSubscriber() - Constructor for class io.micronaut.gcp.pubsub.bind.CustomBindingSubscriber
CustomConfigurationClient - Interface in io.micronaut.gcp.pubsub.publisher
CustomConfigurationSubscriber - Class in io.micronaut.gcp.pubsub.subscriber
CustomConfigurationSubscriber() - Constructor for class io.micronaut.gcp.pubsub.subscriber.CustomConfigurationSubscriber
CustomHeadersClient - Interface in io.micronaut.gcp.pubsub.publisher
CustomHeaderSubscriber - Class in io.micronaut.gcp.pubsub.subscriber
CustomHeaderSubscriber() - Constructor for class io.micronaut.gcp.pubsub.subscriber.CustomHeaderSubscriber
CustomReturnClient - Interface in io.micronaut.gcp.pubsub.publisher
CustomSerDesClient - Interface in io.micronaut.gcp.pubsub.publisher

D

DEFAULT_SCOPES - Static variable in class io.micronaut.gcp.credentials.GoogleCredentialsConfiguration: The default scopes.
defaultGoogleCredentials() - Method in class io.micronaut.gcp.credentials.GoogleCredentialsFactory: Method used to return the default GoogleCredentials and provide it as a bean.
DefaultPublisherFactory - Class in io.micronaut.gcp.pubsub.support: The default PublisherFactory implementation.
DefaultPublisherFactory(TransportChannelProvider, CredentialsProvider, BeanContext) - Constructor for class io.micronaut.gcp.pubsub.support.DefaultPublisherFactory
DefaultPubSubAcknowledgement - Class in io.micronaut.gcp.pubsub.bind: Defaul implementation of Acknowledgement contract.
DefaultPubSubAcknowledgement(AckReplyConsumer) - Constructor for class io.micronaut.gcp.pubsub.bind.DefaultPubSubAcknowledgement
DefaultPubSubMessageReceiverExceptionHandler - Class in io.micronaut.gcp.pubsub.exception: Handles any exception on beans of type PubSubListener that do not implement PubSubMessageReceiverExceptionHandler interface.
DefaultPubSubMessageReceiverExceptionHandler() - Constructor for class io.micronaut.gcp.pubsub.exception.DefaultPubSubMessageReceiverExceptionHandler
DefaultPubSubMessageSerDesRegistry - Class in io.micronaut.gcp.pubsub.serdes: Default implementation of a PubSubMessageSerDesRegistry.
DefaultPubSubMessageSerDesRegistry(PubSubMessageSerDes[]) - Constructor for class io.micronaut.gcp.pubsub.serdes.DefaultPubSubMessageSerDesRegistry
DefaultSubscriberFactory - Class in io.micronaut.gcp.pubsub.bind: Default implementation of SubscriberFactory.
DefaultSubscriberFactory(TransportChannelProvider, CredentialsProvider, BeanContext) - Constructor for class io.micronaut.gcp.pubsub.bind.DefaultSubscriberFactory
deserialize(byte[], Argument<?>) - Method in class io.micronaut.gcp.pubsub.serdes.JavaMessageSerDes
deserialize(byte[], Argument<?>) - Method in class io.micronaut.gcp.pubsub.serdes.JsonPubSubMessageSerDes
deserialize(byte[], Argument<?>) - Method in interface io.micronaut.gcp.pubsub.serdes.PubSubMessageSerDes: Deserializes data into a target type.
doFilter(MutableHttpRequest<?>, ClientFilterChain) - Method in class io.micronaut.gcp.http.client.GoogleAuthFilter

E

ErrorHandlingSubscriber - Class in io.micronaut.gcp.pubsub.subscriber
ErrorHandlingSubscriber() - Constructor for class io.micronaut.gcp.pubsub.subscriber.ErrorHandlingSubscriber

F

find(String) - Method in class io.micronaut.gcp.pubsub.serdes.DefaultPubSubMessageSerDesRegistry
find(MediaType) - Method in interface io.micronaut.gcp.pubsub.serdes.PubSubMessageSerDesRegistry: Retrieves the appropriate PubSubMessageSerDes for the provided contentType.
find(String) - Method in interface io.micronaut.gcp.pubsub.serdes.PubSubMessageSerDesRegistry: Retrieves the appropriate PubSubMessageSerDes for the provided contentType.
findArgumentBinder(Argument<T>, PubSubConsumerState) - Method in class io.micronaut.gcp.pubsub.bind.PubSubBinderRegistry

G

get(CharSequence, ArgumentConversionContext<T>) - Method in class io.micronaut.gcp.pubsub.bind.PubSubAttributesConvertibleValues
getAckReplyConsumer() - Method in class io.micronaut.gcp.pubsub.bind.PubSubConsumerState
getAnnotationType() - Method in class io.micronaut.gcp.pubsub.bind.MessagePublishTimeAnnotationBinder
getAnnotationType() - Method in class io.micronaut.gcp.pubsub.bind.PubSubBodyBinder
getAnnotationType() - Method in class io.micronaut.gcp.pubsub.bind.PubSubHeaderBinder
getAnnotationType() - Method in class io.micronaut.gcp.pubsub.bind.PubSubMessageIdBinder
getBatchingSettings() - Method in class io.micronaut.gcp.pubsub.configuration.PublisherConfigurationProperties: Controls message publishing batch.
getBody(Argument<T>) - Method in interface io.micronaut.gcp.function.http.GoogleHttpResponse
getBodyArgument() - Method in class io.micronaut.gcp.pubsub.support.PubSubPublisherState
getBodyAsText() - Method in interface io.micronaut.gcp.function.http.GoogleHttpResponse
getConfiguration() - Method in class io.micronaut.gcp.pubsub.support.PubSubPublisherState
getContentType() - Method in class io.micronaut.gcp.pubsub.bind.PubSubConsumerState
getContentType() - Method in class io.micronaut.gcp.pubsub.support.PubSubPublisherState
getDefaultExecutor() - Method in class io.micronaut.gcp.pubsub.bind.SubscriberFactoryConfig
getDefaultExecutor() - Method in class io.micronaut.gcp.pubsub.support.PublisherFactoryConfig
getEncodedKey() - Method in class io.micronaut.gcp.credentials.GoogleCredentialsConfiguration: The Base64 encoded service account key content.
getExecutor() - Method in class io.micronaut.gcp.pubsub.configuration.PublisherConfigurationProperties
getExecutor() - Method in class io.micronaut.gcp.pubsub.configuration.SubscriberConfigurationProperties
getFlowControlSettings() - Method in class io.micronaut.gcp.pubsub.configuration.PublisherConfigurationProperties: Flow Control settings.
getFlowControlSettings() - Method in class io.micronaut.gcp.pubsub.configuration.SubscriberConfigurationProperties: Flow Control settings.
getHeaders() - Method in class io.micronaut.gcp.UserAgentHeaderProvider: Returns the "User-Agent" header whose value should be added to the google-cloud-java REST API calls.
getHttpHeaders() - Method in interface io.micronaut.gcp.function.http.GoogleHttpResponse
getKeepAliveIntervalMinutes() - Method in class io.micronaut.gcp.pubsub.configuration.PubSubConfigurationProperties: How often to ping the server to keep the channel alive.
getListener() - Method in exception io.micronaut.gcp.pubsub.exception.PubSubMessageReceiverException
getLocation() - Method in class io.micronaut.gcp.credentials.GoogleCredentialsConfiguration: The location of the service account credential key file.
getMaxAckExtensionPeriod() - Method in class io.micronaut.gcp.pubsub.configuration.SubscriberConfigurationProperties: Set the maximum period a message ack deadline will be extended.
getMaxDurationPerAckExtension() - Method in class io.micronaut.gcp.pubsub.configuration.SubscriberConfigurationProperties
getMessage() - Method in interface io.micronaut.gcp.function.http.GoogleHttpResponse
getName() - Method in class io.micronaut.gcp.pubsub.configuration.PublisherConfigurationProperties
getName() - Method in class io.micronaut.gcp.pubsub.configuration.SubscriberConfigurationProperties
getName() - Method in class io.micronaut.gcp.pubsub.support.Animal
getParallelPullCount() - Method in class io.micronaut.gcp.pubsub.configuration.SubscriberConfigurationProperties
getProjectId() - Method in class io.micronaut.gcp.GoogleCloudConfiguration: Returns the Google project ID for the project.
getPublisherConfiguration() - Method in class io.micronaut.gcp.pubsub.support.PublisherFactoryConfig
getPublishingExecutor() - Method in class io.micronaut.gcp.pubsub.configuration.PubSubConfigurationProperties
getPubsubMessage() - Method in class io.micronaut.gcp.pubsub.bind.PubSubConsumerState
getReceiver() - Method in class io.micronaut.gcp.pubsub.bind.SubscriberFactoryConfig
getRetrySettings() - Method in class io.micronaut.gcp.pubsub.configuration.PublisherConfigurationProperties: Retry policies.
getScopes() - Method in class io.micronaut.gcp.credentials.GoogleCredentialsConfiguration: The scopes to use.
getState() - Method in exception io.micronaut.gcp.pubsub.exception.PubSubMessageReceiverException
getStaticMessageAttributes() - Method in class io.micronaut.gcp.pubsub.support.PubSubPublisherState
getStatus() - Method in interface io.micronaut.gcp.function.http.GoogleHttpResponse
getStatusCode() - Method in interface io.micronaut.gcp.function.http.GoogleHttpResponse
getSubscriberConfiguration() - Method in class io.micronaut.gcp.pubsub.bind.SubscriberFactoryConfig
getSubscribingExecutor() - Method in class io.micronaut.gcp.pubsub.configuration.PubSubConfigurationProperties
getSubscriptionName() - Method in class io.micronaut.gcp.pubsub.bind.PubSubConsumerState
getSubscriptionName() - Method in class io.micronaut.gcp.pubsub.bind.SubscriberFactoryConfig
getTopicName() - Method in class io.micronaut.gcp.pubsub.support.PublisherFactoryConfig
getTopicName() - Method in class io.micronaut.gcp.pubsub.support.PubSubPublisherState
getUserAgent() - Method in class io.micronaut.gcp.UserAgentHeaderProvider: Returns the "User-Agent" header value which should be added to the google-cloud-java REST API calls.
GoogleAuthFilter - Class in io.micronaut.gcp.http.client: A filter that allows service to service communication in GCP (https://cloud.google.com/run/docs/authenticating/service-to-service).
GoogleAuthFilter() - Constructor for class io.micronaut.gcp.http.client.GoogleAuthFilter: Default constructor.
GoogleCloudConfiguration - Class in io.micronaut.gcp: General Google cloud configuration.
GoogleCloudConfiguration() - Constructor for class io.micronaut.gcp.GoogleCloudConfiguration
GoogleCredentialsConfiguration - Class in io.micronaut.gcp.credentials: Configuration for the Google credentials.
GoogleCredentialsConfiguration() - Constructor for class io.micronaut.gcp.credentials.GoogleCredentialsConfiguration
GoogleCredentialsFactory - Class in io.micronaut.gcp.credentials: A factory for creating GoogleCredentials.
GoogleCredentialsFactory(GoogleCredentialsConfiguration) - Constructor for class io.micronaut.gcp.credentials.GoogleCredentialsFactory: Default constructor.
GoogleFunctionInitializer - Class in io.micronaut.gcp.function: Extended version of FunctionInitializer that configures the GCP environment.
GoogleFunctionInitializer() - Constructor for class io.micronaut.gcp.function.GoogleFunctionInitializer
GoogleHttpResponse - Interface in io.micronaut.gcp.function.http: Extended interface used for testing.
GoogleJacksonConfiguration - Class in io.micronaut.gcp.function.http.jackson: Disables module scan for Jackson which is slow in function context.
GoogleJacksonConfiguration() - Constructor for class io.micronaut.gcp.function.http.jackson.GoogleJacksonConfiguration

H

handle(PubSubMessageReceiverException) - Method in class io.micronaut.gcp.pubsub.exception.DefaultPubSubMessageReceiverExceptionHandler
handle(PubSubMessageReceiverException) - Method in class io.micronaut.gcp.pubsub.subscriber.ErrorHandlingSubscriber
hasProjectId() - Method in class io.micronaut.gcp.GoogleCloudConfiguration: Whether a project id is configured.
HttpFunction - Class in io.micronaut.gcp.function.http: Entry point into the Micronaut + GCP integration.
HttpFunction() - Constructor for class io.micronaut.gcp.function.http.HttpFunction: Default constructor.

I

intercept(MethodInvocationContext<Object, Object>) - Method in class io.micronaut.gcp.pubsub.intercept.PubSubClientIntroductionAdvice
invoke(HttpRequest) - Method in class io.micronaut.gcp.function.http.HttpFunction: Invoke the function directly with the given request object.
invoke(HttpMethod, String) - Method in class io.micronaut.gcp.function.http.HttpFunction: Invoke the function directly with the given request object.
invoke(HttpMethod, String, Object) - Method in class io.micronaut.gcp.function.http.HttpFunction: Invoke the function directly with the given request object.
invoke(HttpRequest<?>) - Method in class io.micronaut.gcp.function.http.HttpFunction: Invoke the function directly with the given request object.
io.micronaut.gcp - package io.micronaut.gcp
io.micronaut.gcp.condition - package io.micronaut.gcp.condition
io.micronaut.gcp.credentials - package io.micronaut.gcp.credentials
io.micronaut.gcp.function - package io.micronaut.gcp.function
io.micronaut.gcp.function.http - package io.micronaut.gcp.function.http
io.micronaut.gcp.function.http.jackson - package io.micronaut.gcp.function.http.jackson
io.micronaut.gcp.http.client - package io.micronaut.gcp.http.client
io.micronaut.gcp.pubsub.annotation - package io.micronaut.gcp.pubsub.annotation: Annotation classes for PubSub support.
io.micronaut.gcp.pubsub.bind - package io.micronaut.gcp.pubsub.bind: Contains binders @see TypeArgumentBinder and consumer classes for PubSub support.
io.micronaut.gcp.pubsub.client - package io.micronaut.gcp.pubsub.client
io.micronaut.gcp.pubsub.configuration - package io.micronaut.gcp.pubsub.configuration: Configuration properties classes.
io.micronaut.gcp.pubsub.exception - package io.micronaut.gcp.pubsub.exception: Exception classes for PubSub support.
io.micronaut.gcp.pubsub.intercept - package io.micronaut.gcp.pubsub.intercept: AOP interceptors for @PubSubClient and PubSubListener annotations.
io.micronaut.gcp.pubsub.publisher - package io.micronaut.gcp.pubsub.publisher
io.micronaut.gcp.pubsub.quickstart - package io.micronaut.gcp.pubsub.quickstart
io.micronaut.gcp.pubsub.serdes - package io.micronaut.gcp.pubsub.serdes: Serialization / Deserialization (SerDes) support for PubSub.
io.micronaut.gcp.pubsub.subscriber - package io.micronaut.gcp.pubsub.subscriber
io.micronaut.gcp.pubsub.support - package io.micronaut.gcp.pubsub.support: Support classes for PubSub integration.
io.micronaut.gcp.tracing.zipkin - package io.micronaut.gcp.tracing.zipkin
isClientAck() - Method in class io.micronaut.gcp.pubsub.bind.DefaultPubSubAcknowledgement

J

JavaMessageSerDes - Class in io.micronaut.gcp.pubsub.serdes
JavaMessageSerDes() - Constructor for class io.micronaut.gcp.pubsub.serdes.JavaMessageSerDes
JsonPubSubMessageSerDes - Class in io.micronaut.gcp.pubsub.serdes: A PubSubMessageSerDes implementation that uses Jackson ObjectMapper to convert application/json mime types.
JsonPubSubMessageSerDes(ObjectMapper) - Constructor for class io.micronaut.gcp.pubsub.serdes.JsonPubSubMessageSerDes: Default constructor.

L

LOG - Static variable in class io.micronaut.gcp.function.http.HttpFunction

M

matches(ConditionContext) - Method in class io.micronaut.gcp.condition.RequiresProjectIdCondition
MessageId - Annotation Type in io.micronaut.gcp.pubsub.annotation: An annotation used to indicate that a parameter on a method should be bound to the message id.
MessagePublishTime - Annotation Type in io.micronaut.gcp.pubsub.bind
MessagePublishTimeAnnotationBinder - Class in io.micronaut.gcp.pubsub.bind
MessagePublishTimeAnnotationBinder(ConversionService<?>) - Constructor for class io.micronaut.gcp.pubsub.bind.MessagePublishTimeAnnotationBinder
MultipleProjectClient - Interface in io.micronaut.gcp.pubsub.client

N

nack() - Method in class io.micronaut.gcp.pubsub.bind.DefaultPubSubAcknowledgement
names() - Method in class io.micronaut.gcp.pubsub.bind.PubSubAttributesConvertibleValues
newApplicationContextBuilder() - Method in class io.micronaut.gcp.function.GoogleFunctionInitializer
newApplicationContextBuilder() - Method in class io.micronaut.gcp.function.http.HttpFunction
NO_PROJECT_ID_MESSAGE - Static variable in class io.micronaut.gcp.GoogleCloudConfiguration: A message to report if no project id is configured.

O

ObjectMapperCustomizer - Class in io.micronaut.gcp.function.http.jackson: Customizes the jackson object mapper to ensure essential modules are registered.
ObjectMapperCustomizer() - Constructor for class io.micronaut.gcp.function.http.jackson.ObjectMapperCustomizer
onCreated(BeanCreatedEvent<JacksonConfiguration>) - Method in class io.micronaut.gcp.function.http.jackson.GoogleJacksonConfiguration
onCreated(BeanCreatedEvent<ObjectMapper>) - Method in class io.micronaut.gcp.function.http.jackson.ObjectMapperCustomizer
onMessage(Animal, Long) - Method in class io.micronaut.gcp.pubsub.bind.CustomBindingSubscriber
onMessage(byte[]) - Method in class io.micronaut.gcp.pubsub.quickstart.AnimalListener
onMessage(Animal, Acknowledgement) - Method in class io.micronaut.gcp.pubsub.subscriber.AcknowledgementSubscriber
onMessage(Animal) - Method in class io.micronaut.gcp.pubsub.subscriber.CustomConfigurationSubscriber
onMessage(Animal, String, Integer) - Method in class io.micronaut.gcp.pubsub.subscriber.CustomHeaderSubscriber
onMessage(Animal) - Method in class io.micronaut.gcp.pubsub.subscriber.ErrorHandlingSubscriber
onMessage(Animal) - Method in class io.micronaut.gcp.pubsub.subscriber.SimpleSubscriber
onMessageEU(Animal) - Method in class io.micronaut.gcp.pubsub.subscriber.SimpleSubscriber

P

PREFIX - Static variable in class io.micronaut.gcp.credentials.GoogleCredentialsConfiguration: The prefix to use.
PREFIX - Static variable in class io.micronaut.gcp.GoogleCloudConfiguration: The prefix to use.
PREFIX - Static variable in class io.micronaut.gcp.pubsub.configuration.PubSubConfigurationProperties
process(BeanDefinition<?>, ExecutableMethod<?, ?>) - Method in class io.micronaut.gcp.pubsub.intercept.PubSubConsumerAdvice
PROPERTY_ENABLED - Static variable in class io.micronaut.gcp.tracing.zipkin.StackdriverSenderFactory: The property used to enable tracing.
PublisherConfigurationProperties - Class in io.micronaut.gcp.pubsub.configuration: Configuration properties for PubSub Publishers.
PublisherConfigurationProperties(String) - Constructor for class io.micronaut.gcp.pubsub.configuration.PublisherConfigurationProperties
publisherExecutorProvider() - Method in class io.micronaut.gcp.pubsub.support.PubSubConfigurationFactory
PublisherFactory - Interface in io.micronaut.gcp.pubsub.support: The publisher factory interface that can create publishers.
PublisherFactoryConfig - Class in io.micronaut.gcp.pubsub.support: Holds necessary configuration to create Subscriber instances via SubscriberFactory.
PublisherFactoryConfig(ProjectTopicName, String, String) - Constructor for class io.micronaut.gcp.pubsub.support.PublisherFactoryConfig
PubSubAcknowledgementBinder - Class in io.micronaut.gcp.pubsub.bind: Binds Acknowledgement arguments.
PubSubAcknowledgementBinder() - Constructor for class io.micronaut.gcp.pubsub.bind.PubSubAcknowledgementBinder
PubSubAnnotatedArgumentBinder<A extends java.lang.annotation.Annotation> - Interface in io.micronaut.gcp.pubsub.bind: An interface for PubSub argument binding based on an annotation.
PubSubArgumentBinder<T> - Interface in io.micronaut.gcp.pubsub.bind: An interface for PubSub argument binding.
PubSubAttributesConvertibleValues - Class in io.micronaut.gcp.pubsub.bind: Convert PubSub attributes to the requested type.
PubSubAttributesConvertibleValues(Map<String, String>, ConversionService) - Constructor for class io.micronaut.gcp.pubsub.bind.PubSubAttributesConvertibleValues
PubSubBinderRegistry - Class in io.micronaut.gcp.pubsub.bind
PubSubBinderRegistry(PubSubDefaultArgumentBinder, PubSubArgumentBinder...) - Constructor for class io.micronaut.gcp.pubsub.bind.PubSubBinderRegistry: Default constructor.
PubSubBodyBinder - Class in io.micronaut.gcp.pubsub.bind: Binds arguments annotated with Body and uses the appropriate PubSubMessageSerDes to deserialize the contents of the PubSubMessage data.
PubSubBodyBinder(PubSubMessageSerDesRegistry) - Constructor for class io.micronaut.gcp.pubsub.bind.PubSubBodyBinder
PubSubClient - Annotation Type in io.micronaut.gcp.pubsub.annotation
PubSubClientException - Exception in io.micronaut.gcp.pubsub.exception: Represents an error when publishing messages.
PubSubClientException(String) - Constructor for exception io.micronaut.gcp.pubsub.exception.PubSubClientException: Creates a new exception.
PubSubClientException(String, Throwable) - Constructor for exception io.micronaut.gcp.pubsub.exception.PubSubClientException: Creates a new exception.
PubSubClientIntroductionAdvice - Class in io.micronaut.gcp.pubsub.intercept: Implementation of PubSubClient advice annotation.
PubSubClientIntroductionAdvice(PublisherFactory, PubSubMessageSerDesRegistry, ExecutorService, ConversionService<?>, GoogleCloudConfiguration, PubSubConfigurationProperties) - Constructor for class io.micronaut.gcp.pubsub.intercept.PubSubClientIntroductionAdvice
PubSubConfigurationFactory - Class in io.micronaut.gcp.pubsub.support: Factory class to create default settings for PubSub Publisher and subscriber beans.
PubSubConfigurationFactory(PubSubConfigurationProperties, GoogleCloudConfiguration) - Constructor for class io.micronaut.gcp.pubsub.support.PubSubConfigurationFactory
PubSubConfigurationProperties - Class in io.micronaut.gcp.pubsub.configuration: Configuration properties for PubSub support.
PubSubConfigurationProperties() - Constructor for class io.micronaut.gcp.pubsub.configuration.PubSubConfigurationProperties
PubSubConsumerAdvice - Class in io.micronaut.gcp.pubsub.intercept: Implementation of an ExecutableMethodProcessor that creates MessageReceiver that subscribes to the PubSub subscription and invoke methods annotated by @Subscription.
PubSubConsumerAdvice(BeanContext, ConversionService<?>, PubSubMessageSerDesRegistry, SubscriberFactory, GoogleCloudConfiguration, PubSubConfigurationProperties, PubSubBinderRegistry, PubSubMessageReceiverExceptionHandler) - Constructor for class io.micronaut.gcp.pubsub.intercept.PubSubConsumerAdvice
PubSubConsumerState - Class in io.micronaut.gcp.pubsub.bind: Stores the context of a PubSubMessage that is received.
PubSubConsumerState(PubsubMessage, AckReplyConsumer, ProjectSubscriptionName, String) - Constructor for class io.micronaut.gcp.pubsub.bind.PubSubConsumerState
PubSubDefaultArgumentBinder - Class in io.micronaut.gcp.pubsub.bind: Default body binder of PubSub consumers.
PubSubDefaultArgumentBinder(PubSubBodyBinder) - Constructor for class io.micronaut.gcp.pubsub.bind.PubSubDefaultArgumentBinder
PubSubHeaderBinder - Class in io.micronaut.gcp.pubsub.bind: Binds an argument annotated with Header annotation.
PubSubHeaderBinder(ConversionService) - Constructor for class io.micronaut.gcp.pubsub.bind.PubSubHeaderBinder
PubSubListener - Annotation Type in io.micronaut.gcp.pubsub.annotation: Indicates that a bean will be consuming PubSub Messages.
PubSubListenerException - Exception in io.micronaut.gcp.pubsub.exception: Represents an error when consuming messages.
PubSubListenerException(String) - Constructor for exception io.micronaut.gcp.pubsub.exception.PubSubListenerException
PubSubListenerException(String, Throwable) - Constructor for exception io.micronaut.gcp.pubsub.exception.PubSubListenerException
PubSubMessageIdBinder - Class in io.micronaut.gcp.pubsub.bind: Binds a PubSubMessage Id to the argument.
PubSubMessageIdBinder() - Constructor for class io.micronaut.gcp.pubsub.bind.PubSubMessageIdBinder
PubSubMessageReceiverException - Exception in io.micronaut.gcp.pubsub.exception
PubSubMessageReceiverException(String, Object, PubSubConsumerState) - Constructor for exception io.micronaut.gcp.pubsub.exception.PubSubMessageReceiverException
PubSubMessageReceiverException(String, Throwable, Object, PubSubConsumerState) - Constructor for exception io.micronaut.gcp.pubsub.exception.PubSubMessageReceiverException
PubSubMessageReceiverExceptionHandler - Interface in io.micronaut.gcp.pubsub.exception: Marker interface that PubSubListener beans can implement to handle exceptions.
PubSubMessageSerDes - Interface in io.micronaut.gcp.pubsub.serdes: Responsible for converstion to/from bytes into domain logic.
PubSubMessageSerDesRegistry - Interface in io.micronaut.gcp.pubsub.serdes: A registry of PubSubMessageSerDes instances.
PubSubPublisherState - Class in io.micronaut.gcp.pubsub.support: Stores the context of a PubSubMessage to be pulished.
PubSubPublisherState(String, ProjectTopicName, Map<String, String>, Argument<?>, String) - Constructor for class io.micronaut.gcp.pubsub.support.PubSubPublisherState
PubSubSubscriptionUtils - Class in io.micronaut.gcp.pubsub.support: Various utility methods for dealing with Pub/Sub subscriptions.
PubSubTopicUtils - Class in io.micronaut.gcp.pubsub.support: Various utility methods for dealing with Pub/Sub topics.
PubSubTypeArgumentBinder<T> - Interface in io.micronaut.gcp.pubsub.bind: An interface for PubSub argument binding based on argument type.

R

register(ConversionService<?>) - Method in class io.micronaut.gcp.pubsub.configuration.ThreeTenConverterRegistrar
RequiresGoogleProjectId - Annotation Type in io.micronaut.gcp.condition: A custom condition that indicates the bean requires a configured Google Project ID.
RequiresProjectIdCondition - Class in io.micronaut.gcp.condition: Implementation of RequiresGoogleProjectId.
RequiresProjectIdCondition() - Constructor for class io.micronaut.gcp.condition.RequiresProjectIdCondition

S

send(PubsubMessage) - Method in interface io.micronaut.gcp.pubsub.client.SimpleClient
send(byte[]) - Method in interface io.micronaut.gcp.pubsub.client.SimpleClient
send(Animal) - Method in interface io.micronaut.gcp.pubsub.client.SimpleClient
send(Animal) - Method in interface io.micronaut.gcp.pubsub.publisher.CustomConfigurationClient
send(Animal) - Method in interface io.micronaut.gcp.pubsub.publisher.CustomReturnClient
send(PubsubMessage) - Method in interface io.micronaut.gcp.pubsub.publisher.CustomSerDesClient
send(byte[]) - Method in interface io.micronaut.gcp.pubsub.publisher.CustomSerDesClient
send(Animal) - Method in interface io.micronaut.gcp.pubsub.publisher.CustomSerDesClient
send(byte[]) - Method in interface io.micronaut.gcp.pubsub.quickstart.AnimalClient
sendEU(Animal) - Method in interface io.micronaut.gcp.pubsub.client.MultipleProjectClient
sendReactive(Animal) - Method in interface io.micronaut.gcp.pubsub.publisher.CustomReturnClient
sendUS(Animal) - Method in interface io.micronaut.gcp.pubsub.client.MultipleProjectClient
sendWithCustomType(byte[]) - Method in interface io.micronaut.gcp.pubsub.publisher.CustomSerDesClient
sendWithCustomType(Animal) - Method in interface io.micronaut.gcp.pubsub.publisher.CustomSerDesClient
sendWithDynamicHeaders(Animal, Integer) - Method in interface io.micronaut.gcp.pubsub.publisher.CustomHeadersClient
sendWithId(Animal) - Method in interface io.micronaut.gcp.pubsub.publisher.CustomReturnClient
sendWithStaticHeaders(Animal) - Method in interface io.micronaut.gcp.pubsub.publisher.CustomHeadersClient
serialize(Object) - Method in class io.micronaut.gcp.pubsub.serdes.JavaMessageSerDes
serialize(Object) - Method in class io.micronaut.gcp.pubsub.serdes.JsonPubSubMessageSerDes
serialize(Object) - Method in interface io.micronaut.gcp.pubsub.serdes.PubSubMessageSerDes: Serializes the message.
service(HttpRequest, HttpResponse) - Method in class io.micronaut.gcp.function.http.HttpFunction
setBatchingSettings(BatchingSettings.Builder) - Method in class io.micronaut.gcp.pubsub.configuration.PublisherConfigurationProperties: Controls message publishing batch.
setEncodedKey(String) - Method in class io.micronaut.gcp.credentials.GoogleCredentialsConfiguration: Sets the Base64 encoded service account key content..
setExecutor(String) - Method in class io.micronaut.gcp.pubsub.configuration.PublisherConfigurationProperties
setExecutor(String) - Method in class io.micronaut.gcp.pubsub.configuration.SubscriberConfigurationProperties
setFlowControlSettings(FlowControlSettings.Builder) - Method in class io.micronaut.gcp.pubsub.configuration.PublisherConfigurationProperties: Flow Control settings.
setFlowControlSettings(FlowControlSettings.Builder) - Method in class io.micronaut.gcp.pubsub.configuration.SubscriberConfigurationProperties: Flow Control settings.
setKeepAliveIntervalMinutes(int) - Method in class io.micronaut.gcp.pubsub.configuration.PubSubConfigurationProperties: How often to ping the server to keep the channel alive.
setLocation(String) - Method in class io.micronaut.gcp.credentials.GoogleCredentialsConfiguration: Sets the location to the service account credential key file.
setMaxAckExtensionPeriod(Duration) - Method in class io.micronaut.gcp.pubsub.configuration.SubscriberConfigurationProperties: Set the maximum period a message ack deadline will be extended.
setMaxDurationPerAckExtension(Duration) - Method in class io.micronaut.gcp.pubsub.configuration.SubscriberConfigurationProperties: Set the upper bound for a single mod ack extention period.
setName(String) - Method in class io.micronaut.gcp.pubsub.support.Animal
setParallelPullCount(Integer) - Method in class io.micronaut.gcp.pubsub.configuration.SubscriberConfigurationProperties
setProjectId(String) - Method in class io.micronaut.gcp.GoogleCloudConfiguration: Sets the project id to use.
setPublishingExecutor(String) - Method in class io.micronaut.gcp.pubsub.configuration.PubSubConfigurationProperties
setRetrySettings(RetrySettings.Builder) - Method in class io.micronaut.gcp.pubsub.configuration.PublisherConfigurationProperties: Retry policies.
setScopes(List<URI>) - Method in class io.micronaut.gcp.credentials.GoogleCredentialsConfiguration: The default scopes to associate with the application to access specific APIs.
setSubscribingExecutor(String) - Method in class io.micronaut.gcp.pubsub.configuration.PubSubConfigurationProperties
SimpleClient - Interface in io.micronaut.gcp.pubsub.client
SimpleSubscriber - Class in io.micronaut.gcp.pubsub.subscriber
SimpleSubscriber() - Constructor for class io.micronaut.gcp.pubsub.subscriber.SimpleSubscriber
someBusinessMethod(Animal) - Method in class io.micronaut.gcp.pubsub.quickstart.AnimalService
stackdriverPropagation() - Method in class io.micronaut.gcp.tracing.zipkin.StackdriverSenderFactory: The StackdriverTracePropagation.FACTORY as a bean.
stackdriverReporter(AsyncReporterConfiguration) - Method in class io.micronaut.gcp.tracing.zipkin.StackdriverSenderFactory: A custom AsyncReporter that uses StackdriverEncoder.V2.
stackdriverSender(GoogleCloudConfiguration, GoogleCredentials, ManagedChannel) - Method in class io.micronaut.gcp.tracing.zipkin.StackdriverSenderFactory: The StackdriverSender bean.
StackdriverSenderFactory - Class in io.micronaut.gcp.tracing.zipkin: Configures the StackdriverSender for Micronaut if present on the classpath.
StackdriverSenderFactory() - Constructor for class io.micronaut.gcp.tracing.zipkin.StackdriverSenderFactory
stackdriverTraceSenderChannel() - Method in class io.micronaut.gcp.tracing.zipkin.StackdriverSenderFactory
startThis(ApplicationContext) - Method in class io.micronaut.gcp.function.http.HttpFunction
SubscriberConfigurationProperties - Class in io.micronaut.gcp.pubsub.configuration: Configuration properties for PubSub Subscriber.
SubscriberConfigurationProperties(String) - Constructor for class io.micronaut.gcp.pubsub.configuration.SubscriberConfigurationProperties
SubscriberFactory - Interface in io.micronaut.gcp.pubsub.bind: Factory to create SubscriberInterface using default configurations.
SubscriberFactoryConfig - Class in io.micronaut.gcp.pubsub.bind: Holds necessary configuration to create Subscriber via SubscriberFactory.
SubscriberFactoryConfig(ProjectSubscriptionName, MessageReceiver, String, String) - Constructor for class io.micronaut.gcp.pubsub.bind.SubscriberFactoryConfig
Subscription - Annotation Type in io.micronaut.gcp.pubsub.annotation: Represents a PubSub subscription.
supportedType() - Method in class io.micronaut.gcp.pubsub.serdes.JavaMessageSerDes
supportedType() - Method in class io.micronaut.gcp.pubsub.serdes.JsonPubSubMessageSerDes
supportedType() - Method in interface io.micronaut.gcp.pubsub.serdes.PubSubMessageSerDes

T

ThreeTenConverterRegistrar - Class in io.micronaut.gcp.pubsub.configuration: Type converter used to convert Google's internal Duration type.
ThreeTenConverterRegistrar() - Constructor for class io.micronaut.gcp.pubsub.configuration.ThreeTenConverterRegistrar
Topic - Annotation Type in io.micronaut.gcp.pubsub.annotation: Represents a pubsub topic to be used by classes annotated with PubSubClient.
toProjectSubscriptionName(String, String) - Static method in class io.micronaut.gcp.pubsub.support.PubSubSubscriptionUtils: Create a ProjectSubscriptionName based on a subscription name within a project or the fully-qualified subscription name.
toProjectTopicName(String, String) - Static method in class io.micronaut.gcp.pubsub.support.PubSubTopicUtils: Create a ProjectTopicName based on a topic name within a project or the fully-qualified topic name.
TRACE_SCOPE - Static variable in class io.micronaut.gcp.tracing.zipkin.StackdriverSenderFactory: The trace scope to use.
TRACE_TARGET - Static variable in class io.micronaut.gcp.tracing.zipkin.StackdriverSenderFactory: The trace target to use.
transportChannelProvider() - Method in class io.micronaut.gcp.pubsub.support.PubSubConfigurationFactory

U

UserAgentHeaderProvider - Class in io.micronaut.gcp: Provides the User-Agent header to signal to the Google Cloud Client Libraries that requests originate from a Micronaut Integration.
UserAgentHeaderProvider(String) - Constructor for class io.micronaut.gcp.UserAgentHeaderProvider: Default constructor.

V

values() - Method in class io.micronaut.gcp.pubsub.bind.PubSubAttributesConvertibleValues

A B C D E F G H I J L M N O P R S T U V