Index
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form
A
- accept(CloudEventContext, T) - Method in class io.micronaut.gcp.function.cloudevents.GoogleCloudEventsFunction
-
Called to service an incoming event.
- accept(CloudEvent) - Method in class io.micronaut.gcp.function.cloudevents.GoogleCloudEventsFunction
- ACCESS_CONFIGS - Enum constant in enum class io.micronaut.discovery.cloud.gcp.GoogleComputeMetadataKeys
- ack() - Method in class io.micronaut.gcp.pubsub.bind.DefaultPubSubAcknowledgement
- addHeader(String, String) - Method in class io.micronaut.gcp.credentials.DefaultOAuth2HttpTransportFactory.MutableBlockingLowLevelHttpRequest
- addSubscriber(ProjectSubscriptionName, MessageReceiver) - Method in interface io.micronaut.gcp.pubsub.push.PushSubscriberHandler
-
Configure a
MessageReceiver
for the given subscription. - argumentType() - Method in class io.micronaut.gcp.pubsub.bind.PubSubAcknowledgementBinder
- attributes() - Method in record class io.micronaut.gcp.pubsub.push.PushRequest.PushMessage
-
Returns the value of the
attributes
record component. - ATTRIBUTES - Enum constant in enum class io.micronaut.discovery.cloud.gcp.GoogleComputeMetadataKeys
B
- 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
- bodyAsByteArray(JsonMapper, Supplier<MediaType>, Supplier<Charset>, Supplier<Object>) - Static method in class io.micronaut.gcp.function.http.BodyUtils
- BodyUtils - Class in io.micronaut.gcp.function.http
-
Utility class to provide conversion for HTTP request body.
- 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
- close() - Method in class io.micronaut.gcp.pubsub.intercept.PubSubClientIntroductionAdvice
- close() - Method in class io.micronaut.gcp.pubsub.support.PubSubPublisherState
- composeFullTraceName(String, String) - Static method in interface io.micronaut.gcp.logging.StackdriverTraceConstants
-
Composes the full trace name as expected by the Google Developers Console log viewer, to enable trace correlation with log entries.
- configuration() - Element in annotation interface io.micronaut.gcp.pubsub.annotation.Subscription
-
Defines the name of a particular configuration used for a Subscriber.
- configuration() - Element in annotation interface io.micronaut.gcp.pubsub.annotation.Topic
-
Defines the name of a particular configuration used for a Publisher.
- contentType() - Element in annotation interface io.micronaut.gcp.pubsub.annotation.PushSubscription
-
Defines the Content-Type to be used for message deserialization.
- contentType() - Element in annotation interface io.micronaut.gcp.pubsub.annotation.Subscription
-
Defines the Content-Type to be used for message deserialization.
- contentType() - Element in annotation interface io.micronaut.gcp.pubsub.annotation.Topic
-
Defines the Content-Type to be used for message serialization.
- CPU_PLATFORM - Enum constant in enum class io.micronaut.discovery.cloud.gcp.GoogleComputeMetadataKeys
- create() - Method in class io.micronaut.gcp.credentials.DefaultOAuth2HttpTransportFactory
- createPublisher(PublisherFactoryConfig) - Method in class io.micronaut.gcp.pubsub.support.DefaultPublisherFactory
-
Creates 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. - credentialsProvider(GoogleCredentials) - Method in class io.micronaut.gcp.secretmanager.SecretManagerFactory
-
Returns a default
CredentialsProvider
, allows users to override it and provide their own implementation.
D
- data() - Method in record class io.micronaut.gcp.pubsub.push.PushRequest.PushMessage
-
Returns the value of the
data
record component. - DEFAULT_CONNECTTIMEOUT - Static variable in class io.micronaut.discovery.cloud.gcp.GoogleComputeMetadataConfiguration
-
The default connect timeout in seconds.
- DEFAULT_ENABLED - Static variable in class io.micronaut.discovery.cloud.gcp.GoogleComputeMetadataConfiguration
-
The default enable value.
- DEFAULT_ENABLED - Static variable in class io.micronaut.gcp.credentials.GoogleCredentialsConfiguration
-
Google credentials configuration is enabled by default.
- DEFAULT_METADATAURL - Static variable in class io.micronaut.discovery.cloud.gcp.GoogleComputeMetadataConfiguration
-
The default metadata url value.
- DEFAULT_NACK_ON_SHUTDOWN - Static variable in class io.micronaut.gcp.pubsub.configuration.PubSubConfigurationProperties
- DEFAULT_PROJECTMETADATAURL - Static variable in class io.micronaut.discovery.cloud.gcp.GoogleComputeMetadataConfiguration
-
The default project metadata url value.
- DEFAULT_READTIMEOUT - Static variable in class io.micronaut.discovery.cloud.gcp.GoogleComputeMetadataConfiguration
-
The default read timeout in seconds.
- DEFAULT_SCOPES - Static variable in class io.micronaut.gcp.credentials.GoogleCredentialsConfiguration
-
The default scopes.
- DEFAULT_USE_HTTP_CLIENT - Static variable in class io.micronaut.gcp.credentials.GoogleCredentialsConfiguration
-
Use transport based on
HttpClient
by default. - defaultGoogleCredentials() - Method in class io.micronaut.gcp.credentials.GoogleCredentialsFactory
-
Method used to return the default
GoogleCredentials
and provide it as a bean. - DefaultOAuth2HttpTransportFactory - Class in io.micronaut.gcp.credentials
-
An implementation of
HttpTransportFactory
based uponHttpClient
that can be supplied when creatingGoogleCredentials
, allowing full control over configuration of the client. - DefaultOAuth2HttpTransportFactory(BeanContext, HttpClientConfiguration) - Constructor for class io.micronaut.gcp.credentials.DefaultOAuth2HttpTransportFactory
-
Constructor for
DefaultOAuth2HttpTransportFactory
. - DefaultOAuth2HttpTransportFactory.MutableBlockingLowLevelHttpRequest - Class in io.micronaut.gcp.credentials
-
Implementation of
LowLevelHttpRequest
that uses the blocking API ofHttpClient
. - 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 implementPubSubMessageReceiverExceptionHandler
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
- DEFAULTS - Enum constant in enum class io.micronaut.discovery.cloud.gcp.GoogleComputeMetadataKeys
- DefaultSecretManagerClient - Class in io.micronaut.gcp.secretmanager.client
-
Default implementation of
SecretManagerClient
. - DefaultSecretManagerClient(SecretManagerServiceClient, GoogleCloudConfiguration, ExecutorService) - Constructor for class io.micronaut.gcp.secretmanager.client.DefaultSecretManagerClient
- 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
- DESCRIPTION - Enum constant in enum class io.micronaut.discovery.cloud.gcp.GoogleComputeMetadataKeys
- 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.
- DISKS - Enum constant in enum class io.micronaut.discovery.cloud.gcp.GoogleComputeMetadataKeys
- DNS_SERVERS - Enum constant in enum class io.micronaut.discovery.cloud.gcp.GoogleComputeMetadataKeys
- doFilter(MutableHttpRequest<?>, ClientFilterChain) - Method in class io.micronaut.gcp.http.client.GoogleAuthFilter
E
- endpoint() - Element in annotation interface io.micronaut.gcp.pubsub.annotation.Topic
-
Sets the endpoint that PubSub will use to store messages.
- equals(Object) - Method in record class io.micronaut.gcp.pubsub.push.PushRequest
-
Indicates whether some other object is "equal to" this one.
- equals(Object) - Method in record class io.micronaut.gcp.pubsub.push.PushRequest.PushMessage
-
Indicates whether some other object is "equal to" this one.
- execute() - Method in class io.micronaut.gcp.credentials.DefaultOAuth2HttpTransportFactory.MutableBlockingLowLevelHttpRequest
F
- find(MediaType) - Method in interface io.micronaut.gcp.pubsub.serdes.PubSubMessageSerDesRegistry
-
Retrieves the appropriate PubSubMessageSerDes for the provided contentType.
- find(String) - Method in class io.micronaut.gcp.pubsub.serdes.DefaultPubSubMessageSerDesRegistry
- find(String) - Method in interface io.micronaut.gcp.pubsub.serdes.PubSubMessageSerDesRegistry
-
Retrieves the appropriate PubSubMessageSerDes for the provided contentType.
- findArgumentBinder(Argument<T>) - Method in class io.micronaut.gcp.pubsub.bind.PubSubBinderRegistry
- findCookie(CharSequence) - Method in class io.micronaut.gcp.function.http.GoogleCookies
- formatTraceId(String) - Method in class io.micronaut.gcp.logging.StackdriverJsonLayout
-
Formats traceId to be exact 32 digits.
- FORWARDED_IPS - Enum constant in enum class io.micronaut.discovery.cloud.gcp.GoogleComputeMetadataKeys
- from(PubSubMessageReceiverException) - Static method in exception io.micronaut.gcp.pubsub.push.PubSubPushMessageReceiverException
-
Creates a
PubSubPushMessageReceiverException
from a generalPubSubMessageReceiverException
to indicate the error occurred while processing a push message.
G
- GATEWAY - Enum constant in enum class io.micronaut.discovery.cloud.gcp.GoogleComputeMetadataKeys
- get(CharSequence, ArgumentConversionContext<T>) - Method in class io.micronaut.gcp.function.http.GoogleCookies
- get(CharSequence, ArgumentConversionContext<T>) - Method in class io.micronaut.gcp.pubsub.bind.PubSubAttributesConvertibleValues
- get(CharSequence, Class<T>) - Method in class io.micronaut.gcp.function.http.GoogleCookies
- getAckReplyConsumer() - Method in class io.micronaut.gcp.pubsub.bind.PubSubConsumerState
- getAll() - Method in class io.micronaut.gcp.function.http.GoogleCookies
- 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
- getApplicationConfiguration() - Method in class io.micronaut.gcp.function.http.test.InvokerHttpServer
- getApplicationContext() - Method in class io.micronaut.gcp.function.http.test.InvokerHttpServer
- getAudience() - Method in class io.micronaut.gcp.http.client.GoogleAuthServiceConfig
- 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
- getBodyAsBytes() - Method in interface io.micronaut.gcp.function.http.GoogleHttpResponse
- getBodyAsText() - Method in interface io.micronaut.gcp.function.http.GoogleHttpResponse
- getComputePlatform() - Method in class io.micronaut.discovery.cloud.gcp.GoogleComputeInstanceMetadata
- getConfigurationName() - Method in class io.micronaut.gcp.pubsub.support.PubSubPublisherState.TopicState
- getConnectTimeout() - Method in class io.micronaut.discovery.cloud.gcp.GoogleComputeMetadataConfiguration
- getContents() - Method in class io.micronaut.gcp.secretmanager.client.VersionedSecret
- getContentType() - Method in class io.micronaut.gcp.pubsub.bind.PubSubConsumerState
- getContentType() - Method in class io.micronaut.gcp.pubsub.support.PubSubPublisherState.TopicState
- getCustomConfigs() - Method in class io.micronaut.gcp.secretmanager.configuration.SecretManagerConfigurationProperties
- getCustomJson() - Method in class io.micronaut.gcp.logging.StackdriverJsonLayout
- getDefaultExecutor() - Method in class io.micronaut.gcp.pubsub.bind.SubscriberFactoryConfig
- getDefaultExecutor() - Method in class io.micronaut.gcp.pubsub.support.PublisherFactoryConfig
- getDescription() - Method in class io.micronaut.gcp.secretmanager.SecretManagerConfigurationClient
- getEncodedKey() - Method in class io.micronaut.gcp.credentials.GoogleCredentialsConfiguration
-
The Base64 encoded service account key content.
- getEndpoint() - Method in class io.micronaut.gcp.pubsub.support.PubSubPublisherState.TopicState
- 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.
- getFunctionClass() - Method in class io.micronaut.gcp.function.http.test.InvokerHttpServer
-
The function class.
- 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.
- getHost() - Method in class io.micronaut.gcp.function.http.test.InvokerHttpServer
- getHttpHeaders() - Method in interface io.micronaut.gcp.function.http.GoogleHttpResponse
- getJsonFormatter() - Method in class io.micronaut.gcp.logging.StackdriverJsonLayout
- getKeepAliveIntervalMinutes() - Method in class io.micronaut.gcp.pubsub.configuration.PubSubConfigurationProperties
-
How often to ping the server to keep the channel alive.
- getKeys() - Method in class io.micronaut.gcp.secretmanager.configuration.SecretManagerConfigurationProperties
- 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
- getMetadataUrl() - Method in class io.micronaut.discovery.cloud.gcp.GoogleComputeMetadataConfiguration
- getName() - Method in enum class io.micronaut.discovery.cloud.gcp.GoogleComputeMetadataKeys
- 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.secretmanager.client.VersionedSecret
- getOrdered() - Method in class io.micronaut.gcp.pubsub.support.PubSubPublisherState.TopicState
- getOrderingArgument() - Method in class io.micronaut.gcp.pubsub.support.PubSubPublisherState
- getParallelPullCount() - Method in class io.micronaut.gcp.pubsub.configuration.SubscriberConfigurationProperties
- getPath() - Method in interface io.micronaut.gcp.pubsub.push.PushControllerConfiguration
- getPort() - Method in class io.micronaut.gcp.function.http.test.InvokerHttpServer
- getProjectId() - Method in class io.micronaut.gcp.GoogleCloudConfiguration
-
Returns the Google project ID for the project.
- getProjectId() - Method in class io.micronaut.gcp.logging.StackdriverJsonLayout
- getProjectId() - Method in class io.micronaut.gcp.secretmanager.client.VersionedSecret
- getProjectMetadataUrl() - Method in class io.micronaut.discovery.cloud.gcp.GoogleComputeMetadataConfiguration
- getProjectTopicName() - Method in class io.micronaut.gcp.pubsub.support.PubSubPublisherState.TopicState
- getPropertySources(Environment) - Method in class io.micronaut.gcp.secretmanager.SecretManagerConfigurationClient
- getPropertyValue() - Method in class io.micronaut.gcp.logging.GoogleCloudPropertyDefiner
- getPublisher() - Method in class io.micronaut.gcp.pubsub.support.PubSubPublisherState
- getPublishingExecutor() - Method in class io.micronaut.gcp.pubsub.configuration.PubSubConfigurationProperties
-
The name of the
ScheduledExecutorService
to be used by allPublisher
instances. - getPubsubMessage() - Method in class io.micronaut.gcp.pubsub.bind.PubSubConsumerState
- getReadTimeout() - Method in class io.micronaut.discovery.cloud.gcp.GoogleComputeMetadataConfiguration
- getReceiver() - Method in class io.micronaut.gcp.pubsub.bind.SubscriberFactoryConfig
- getRegion() - Method in class io.micronaut.discovery.cloud.gcp.GoogleComputeInstanceMetadata
- getRetrySettings() - Method in class io.micronaut.gcp.pubsub.configuration.PublisherConfigurationProperties
-
Retry policies.
- getScheme() - Method in class io.micronaut.gcp.function.http.test.InvokerHttpServer
- getScopes() - Method in class io.micronaut.gcp.credentials.GoogleCredentialsConfiguration
-
The scopes to use.
- getSecret(String) - Method in class io.micronaut.gcp.secretmanager.client.DefaultSecretManagerClient
- getSecret(String) - Method in interface io.micronaut.gcp.secretmanager.client.SecretManagerClient
-
Fetches a secret from the Secret Manager storage using the `gcp.projectId` project, and "latest" as the version.
- getSecret(String, String) - Method in class io.micronaut.gcp.secretmanager.client.DefaultSecretManagerClient
- getSecret(String, String) - Method in interface io.micronaut.gcp.secretmanager.client.SecretManagerClient
-
Fetches a secret from the Secret Manager storage using the `gcp.projectId` project.
- getSecret(String, String, String) - Method in class io.micronaut.gcp.secretmanager.client.DefaultSecretManagerClient
- getSecret(String, String, String) - Method in interface io.micronaut.gcp.secretmanager.client.SecretManagerClient
-
Fetches a secret from the Secret Manager storage.
- getServiceId() - Method in class io.micronaut.gcp.http.client.GoogleAuthServiceConfig
- 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
-
The name of the
ScheduledExecutorService
to be used by allSubscriber
instances. - getSubscriptionName() - Method in class io.micronaut.gcp.pubsub.bind.PubSubConsumerState
- getSubscriptionName() - Method in class io.micronaut.gcp.pubsub.bind.SubscriberFactoryConfig
- getTopicEndpoint() - Method in class io.micronaut.gcp.pubsub.configuration.PubSubConfigurationProperties
-
Which endpoint the
Publisher
should publish messages to. - getTopicState() - Method in class io.micronaut.gcp.pubsub.support.PublisherFactoryConfig
- getTopicState() - Method in class io.micronaut.gcp.pubsub.support.PubSubPublisherState
- getType() - Method in class io.micronaut.gcp.function.cloudevents.GoogleCloudEventsFunction
- getURI() - Method in class io.micronaut.gcp.function.http.test.InvokerHttpServer
- getURL() - Method in class io.micronaut.gcp.function.http.test.InvokerHttpServer
- 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.
- getVersion() - Method in class io.micronaut.gcp.secretmanager.client.VersionedSecret
- 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(BeanContext) - Constructor for class io.micronaut.gcp.http.client.GoogleAuthFilter
- GoogleAuthServiceConfig - Class in io.micronaut.gcp.http.client
-
Creates a GoogleAuthServiceConfig for each Service configured under gcp.http.client.auth.services.*.audience.
- GoogleAuthServiceConfig(String) - Constructor for class io.micronaut.gcp.http.client.GoogleAuthServiceConfig
- GoogleCloudConfiguration - Class in io.micronaut.gcp
-
General Google cloud configuration.
- GoogleCloudConfiguration() - Constructor for class io.micronaut.gcp.GoogleCloudConfiguration
- GoogleCloudEventsFunction<T> - Class in io.micronaut.gcp.function.cloudevents
-
A super class that extends
GoogleFunctionInitializer
and can be used to map cloud events payloads. - GoogleCloudEventsFunction() - Constructor for class io.micronaut.gcp.function.cloudevents.GoogleCloudEventsFunction
- GoogleCloudPropertyDefiner - Class in io.micronaut.gcp.logging
-
Logback extension that sets a property called google_cloud_logging to allow users to switch between appender configurations.
- GoogleCloudPropertyDefiner() - Constructor for class io.micronaut.gcp.logging.GoogleCloudPropertyDefiner
- GoogleComputeInstanceMetadata - Class in io.micronaut.discovery.cloud.gcp
-
Represents
ComputeInstanceMetadata
for Google Cloud Platform. - GoogleComputeInstanceMetadata() - Constructor for class io.micronaut.discovery.cloud.gcp.GoogleComputeInstanceMetadata
- GoogleComputeInstanceMetadataResolver - Class in io.micronaut.discovery.cloud.gcp
-
Resolves
ComputeInstanceMetadata
for Google Cloud Platform. - GoogleComputeInstanceMetadataResolver() - Constructor for class io.micronaut.discovery.cloud.gcp.GoogleComputeInstanceMetadataResolver
-
Construct with default settings.
- GoogleComputeInstanceMetadataResolver(JsonMapper, GoogleComputeMetadataConfiguration) - Constructor for class io.micronaut.discovery.cloud.gcp.GoogleComputeInstanceMetadataResolver
- GoogleComputeMetadataConfiguration - Class in io.micronaut.discovery.cloud.gcp
-
Configuration for computing metadata for
ComputePlatform.GOOGLE_COMPUTE
. - GoogleComputeMetadataConfiguration() - Constructor for class io.micronaut.discovery.cloud.gcp.GoogleComputeMetadataConfiguration
- GoogleComputeMetadataKeys - Enum Class in io.micronaut.discovery.cloud.gcp
-
Models common Google compute instance metadata keys.
- GoogleCookies - Class in io.micronaut.gcp.function.http
-
Implementation of
Cookies
for serverless. - GoogleCookies(String, HttpHeaders, ConversionService) - Constructor for class io.micronaut.gcp.function.http.GoogleCookies
- 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
-
Deprecated.
- GoogleCredentialsFactory(GoogleCredentialsConfiguration, HttpTransportFactory) - Constructor for class io.micronaut.gcp.credentials.GoogleCredentialsFactory
- 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
- groups() - Element in annotation interface io.micronaut.gcp.pubsub.validation.ValidPushMessage
H
- handle(PubSubMessageReceiverException) - Method in class io.micronaut.gcp.pubsub.exception.DefaultPubSubMessageReceiverExceptionHandler
- handlePushRequest(PushRequest) - Method in class io.micronaut.gcp.pubsub.push.PushController
-
Handle incoming PubSub Push messages by deserializing them from their specified JSON format and forwarding the deserialized message to the configured
PushSubscriberHandler
. - handleRequest(PushRequest) - Method in interface io.micronaut.gcp.pubsub.push.PushSubscriberHandler
-
Handle the incoming
PushRequest
received via HTTP request processing. - hashCode() - Method in record class io.micronaut.gcp.pubsub.push.PushRequest
-
Returns a hash code value for this object.
- hashCode() - Method in record class io.micronaut.gcp.pubsub.push.PushRequest.PushMessage
-
Returns a hash code value for this object.
- hasProjectId() - Method in class io.micronaut.gcp.GoogleCloudConfiguration
-
Whether a project id is configured.
- HEADER_METADATA_FLAVOR - Static variable in class io.micronaut.discovery.cloud.gcp.GoogleComputeInstanceMetadataResolver
-
Constant for Metadata flavor.
- HOSTNAME - Enum constant in enum class io.micronaut.discovery.cloud.gcp.GoogleComputeMetadataKeys
- 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.
- HttpFunction(ApplicationContext) - Constructor for class io.micronaut.gcp.function.http.HttpFunction
I
- ID - Enum constant in enum class io.micronaut.discovery.cloud.gcp.GoogleComputeMetadataKeys
- IMAGE - Enum constant in enum class io.micronaut.discovery.cloud.gcp.GoogleComputeMetadataKeys
- 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.
- InvokerHttpServer - Class in io.micronaut.gcp.function.http.test
-
An embedded server implementation that uses the function invoker.
- InvokerHttpServer(ApplicationContext, HttpServerConfiguration) - Constructor for class io.micronaut.gcp.function.http.test.InvokerHttpServer
- io.micronaut.discovery.cloud.gcp - package io.micronaut.discovery.cloud.gcp
-
Google Compute cloud configuration.
- 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.cloudevents - package io.micronaut.gcp.function.cloudevents
-
Support classes for GCP functions based on Cloud Events.
- 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.function.http.test - package io.micronaut.gcp.function.http.test
- io.micronaut.gcp.http.client - package io.micronaut.gcp.http.client
- io.micronaut.gcp.logging - package io.micronaut.gcp.logging
-
Logging classes for integration with StackDriver.
- 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.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
andPubSubListener
annotations. - io.micronaut.gcp.pubsub.push - package io.micronaut.gcp.pubsub.push
- io.micronaut.gcp.pubsub.serdes - package io.micronaut.gcp.pubsub.serdes
-
Serialization / Deserialization (SerDes) support for PubSub.
- io.micronaut.gcp.pubsub.support - package io.micronaut.gcp.pubsub.support
-
Support classes for PubSub integration.
- io.micronaut.gcp.pubsub.validation - package io.micronaut.gcp.pubsub.validation
- io.micronaut.gcp.secretmanager - package io.micronaut.gcp.secretmanager
- io.micronaut.gcp.secretmanager.client - package io.micronaut.gcp.secretmanager.client
- io.micronaut.gcp.secretmanager.configuration - package io.micronaut.gcp.secretmanager.configuration
- io.micronaut.gcp.tracing.zipkin - package io.micronaut.gcp.tracing.zipkin
- IP - Enum constant in enum class io.micronaut.discovery.cloud.gcp.GoogleComputeMetadataKeys
- IP_ALIASES - Enum constant in enum class io.micronaut.discovery.cloud.gcp.GoogleComputeMetadataKeys
- isAutoAcknowledge() - Method in exception io.micronaut.gcp.pubsub.exception.PubSubMessageReceiverException
- isClientAck() - Method in class io.micronaut.gcp.pubsub.bind.DefaultPubSubAcknowledgement
- isDefaultConfigEnabled() - Method in class io.micronaut.gcp.secretmanager.configuration.SecretManagerConfigurationProperties
-
Whether to load the default config files (`application`, `application_${env}`, `[APPLICATION_NAME], `[APPLICATION_NAME]_${env}`).
- isEnabled() - Method in class io.micronaut.discovery.cloud.gcp.GoogleComputeMetadataConfiguration
- isEnabled() - Method in class io.micronaut.gcp.credentials.GoogleCredentialsConfiguration
-
Allows disabling Google credentials configuration.
- isIncludeExceptionInMessage() - Method in class io.micronaut.gcp.logging.StackdriverJsonLayout
- isIncludeSpanId() - Method in class io.micronaut.gcp.logging.StackdriverJsonLayout
- isIncludeTraceId() - Method in class io.micronaut.gcp.logging.StackdriverJsonLayout
- isNackOnShutdown() - Method in class io.micronaut.gcp.pubsub.configuration.PubSubConfigurationProperties
-
Whether subscribers should stop processing pending in-memory messages and eagerly nack() during application shutdown.
- isRunning() - Method in class io.micronaut.gcp.function.http.test.InvokerHttpServer
- isUseHttpClient() - Method in class io.micronaut.gcp.credentials.GoogleCredentialsConfiguration
-
If the HttpClient based transport should be used for retrieving authentication tokens.
- isValid(PushRequest.PushMessage, ConstraintValidatorContext) - Method in class io.micronaut.gcp.pubsub.validation.PushMessageValidator
-
Validates pub sub push messages, ensuring they meet the specified constraint that a message must contain either a non-empty
data
field, or at least one non-emptyattribute
.
J
- JsonPubSubMessageSerDes - Class in io.micronaut.gcp.pubsub.serdes
-
A
PubSubMessageSerDes
implementation that uses aJsonMapper
to convert application/json mime types. - JsonPubSubMessageSerDes(JsonMapper) - Constructor for class io.micronaut.gcp.pubsub.serdes.JsonPubSubMessageSerDes
-
Default constructor.
L
- LATEST - Static variable in interface io.micronaut.gcp.secretmanager.client.SecretManagerClient
- LICENSES - Enum constant in enum class io.micronaut.discovery.cloud.gcp.GoogleComputeMetadataKeys
- localChannelProvider(Environment) - Method in class io.micronaut.gcp.pubsub.support.PubSubConfigurationFactory
- LOG - Static variable in class io.micronaut.gcp.function.http.HttpFunction
M
- MAC - Enum constant in enum class io.micronaut.discovery.cloud.gcp.GoogleComputeMetadataKeys
- MACHINE_TYPE - Enum constant in enum class io.micronaut.discovery.cloud.gcp.GoogleComputeMetadataKeys
- MAINTENANCE_EVENT - Enum constant in enum class io.micronaut.discovery.cloud.gcp.GoogleComputeMetadataKeys
- map(CloudEvent, Class<T>) - Method in class io.micronaut.gcp.function.cloudevents.GoogleCloudEventsFunction
-
Maps a cloud event to the target type.
- matches(ConditionContext) - Method in class io.micronaut.gcp.condition.RequiresProjectIdCondition
- MDC_FIELD_SPAN_EXPORT - Static variable in interface io.micronaut.gcp.logging.StackdriverTraceConstants
-
The name of the MDC parameter, Spring Sleuth is storing the span export information at.
- MDC_FIELD_SPAN_ID - Static variable in interface io.micronaut.gcp.logging.StackdriverTraceConstants
-
The name of the MDC parameter, Spring Sleuth is storing the span id at.
- MDC_FIELD_TRACE_ID - Static variable in interface io.micronaut.gcp.logging.StackdriverTraceConstants
-
The name of the MDC parameter, Spring Sleuth is storing the trace id at.
- message() - Method in record class io.micronaut.gcp.pubsub.push.PushRequest
-
Returns the value of the
message
record component. - message() - Element in annotation interface io.micronaut.gcp.pubsub.validation.ValidPushMessage
- MESSAGE - Static variable in annotation interface io.micronaut.gcp.pubsub.validation.ValidPushMessage
-
ValidPushMessage message.
- messageId() - Method in record class io.micronaut.gcp.pubsub.push.PushRequest.PushMessage
-
Returns the value of the
messageId
record component. - MessageId - Annotation Interface in io.micronaut.gcp.pubsub.annotation
-
An annotation used to indicate that a parameter on a method should be bound to the message id.
- Modules - Interface in io.micronaut.gcp
-
Provides names of implemented modules to be used as
Named
qualifiers as a well forUserAgentHeaderProvider
.
N
- nack() - Method in class io.micronaut.gcp.pubsub.bind.DefaultPubSubAcknowledgement
- NAME - Enum constant in enum class io.micronaut.discovery.cloud.gcp.GoogleComputeMetadataKeys
- names() - Method in class io.micronaut.gcp.pubsub.bind.PubSubAttributesConvertibleValues
- NETMASK - Enum constant in enum class io.micronaut.discovery.cloud.gcp.GoogleComputeMetadataKeys
- NETWORK - Enum constant in enum class io.micronaut.discovery.cloud.gcp.GoogleComputeMetadataKeys
- NETWORK_INTERFACES - Enum constant in enum class io.micronaut.discovery.cloud.gcp.GoogleComputeMetadataKeys
- 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.
- noCredentialsProvider() - Method in class io.micronaut.gcp.pubsub.support.PubSubConfigurationFactory
-
Returns a
NoCredentialsProvider
. - NUMERIC_PROJECT_ID - Enum constant in enum class io.micronaut.discovery.cloud.gcp.GoogleComputeMetadataKeys
O
- OAuth2MessageBodyWriter - Class in io.micronaut.gcp.credentials
-
A
MessageBodyWriter
implementation for writing theLowLevelHttpRequest
that is used for OAuth2 token refresh. - OAuth2MessageBodyWriter() - Constructor for class io.micronaut.gcp.credentials.OAuth2MessageBodyWriter
- 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<ObjectMapper>) - Method in class io.micronaut.gcp.function.http.jackson.ObjectMapperCustomizer
- onCreated(BeanCreatedEvent<JacksonConfiguration>) - Method in class io.micronaut.gcp.function.http.jackson.GoogleJacksonConfiguration
- OrderingKey - Annotation Interface in io.micronaut.gcp.pubsub.annotation
-
Defines the value of they to be used for message ordering.
P
- payload() - Element in annotation interface io.micronaut.gcp.pubsub.validation.ValidPushMessage
- PREFIX - Static variable in class io.micronaut.discovery.cloud.gcp.GoogleComputeMetadataConfiguration
-
Prefix for Google Compute configuration.
- 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.http.client.GoogleAuthServiceConfig
- PREFIX - Static variable in class io.micronaut.gcp.pubsub.configuration.PubSubConfigurationProperties
- PREFIX - Static variable in class io.micronaut.gcp.secretmanager.configuration.SecretManagerConfigurationProperties
- project() - Element in annotation interface io.micronaut.gcp.pubsub.annotation.PubSubClient
- PROJECT_ID - Enum constant in enum class io.micronaut.discovery.cloud.gcp.GoogleComputeMetadataKeys
- 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
Publisher
instances viaPublisherFactory
. - PublisherFactoryConfig(PubSubPublisherState.TopicState, String) - Constructor for class io.micronaut.gcp.pubsub.support.PublisherFactoryConfig
- publishTime() - Method in record class io.micronaut.gcp.pubsub.push.PushRequest.PushMessage
-
Returns the value of the
publishTime
record component. - PUBSUB - Static variable in interface io.micronaut.gcp.Modules
-
Module name for gcp-pubsub.
- PubSubAcknowledgementBinder - Class in io.micronaut.gcp.pubsub.bind
-
Binds
Acknowledgement
arguments. - PubSubAcknowledgementBinder() - Constructor for class io.micronaut.gcp.pubsub.bind.PubSubAcknowledgementBinder
- PubSubAnnotatedArgumentBinder<A extends 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
MessageBody
and uses the appropriatePubSubMessageSerDes
to deserialize the contents of the PubSubMessage data. - PubSubBodyBinder(ConversionService, PubSubMessageSerDesRegistry) - Constructor for class io.micronaut.gcp.pubsub.bind.PubSubBodyBinder
-
Constructs a PubSub body binder instance.
- PubSubBodyBinder(PubSubMessageSerDesRegistry) - Constructor for class io.micronaut.gcp.pubsub.bind.PubSubBodyBinder
-
Deprecated, for removal: This API element is subject to removal in a future version.An instance of
ConversionService
is needed for binding the full range of supported types (including reactive) to PubSub subscriber methods.PubSubBodyBinder(ConversionService, PubSubMessageSerDesRegistry)
should be used instead. - PubSubClient - Annotation Interface 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
- 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
MessageHeader
annotation. - PubSubHeaderBinder(ConversionService) - Constructor for class io.micronaut.gcp.pubsub.bind.PubSubHeaderBinder
- PubSubListener - Annotation Interface 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
-
Deprecated.This exception is expected to only ever be created internally by the framework, and this form is no longer used.
PubSubMessageReceiverException(String, Object, PubSubConsumerState, boolean)
is now used instead. Any outside appropriate usage of this class (such as in exception handler tests) should be updated accordingly. - PubSubMessageReceiverException(String, Object, PubSubConsumerState, boolean) - Constructor for exception io.micronaut.gcp.pubsub.exception.PubSubMessageReceiverException
-
Constructor for PubSubMessageReceiverException.
- PubSubMessageReceiverException(String, Throwable, Object, PubSubConsumerState) - Constructor for exception io.micronaut.gcp.pubsub.exception.PubSubMessageReceiverException
-
Deprecated.This exception is expected to only ever be created internally by the framework, and this form is no longer used.
PubSubMessageReceiverException(String, Throwable, Object, PubSubConsumerState, boolean)
is now used instead. Any outside appropriate usage of this class (such as in exception handler tests) should be updated accordingly. - PubSubMessageReceiverException(String, Throwable, Object, PubSubConsumerState, boolean) - Constructor for exception io.micronaut.gcp.pubsub.exception.PubSubMessageReceiverException
-
Constructor for 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(PubSubPublisherState.TopicState, Map<String, String>, Argument<?>, PublisherInterface, Optional<Argument>) - Constructor for class io.micronaut.gcp.pubsub.support.PubSubPublisherState
- PubSubPublisherState.TopicState - Class in io.micronaut.gcp.pubsub.support
-
Internal class to represent Topic State.
- PubSubPushMessageReceiverException - Exception in io.micronaut.gcp.pubsub.push
-
An exception thrown if there is an error during PubSub push message processing.
- 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.
- PushController - Class in io.micronaut.gcp.pubsub.push
-
A
Controller
implementation for handling PubSub Push JSON messages. - PushController(PushSubscriberHandler) - Constructor for class io.micronaut.gcp.pubsub.push.PushController
-
Constructor for the push controller.
- PushControllerConfiguration - Interface in io.micronaut.gcp.pubsub.push
-
Configuration for the PubSub Push Controller.
- PushMessage(Map<String, String>, String, String, String) - Constructor for record class io.micronaut.gcp.pubsub.push.PushRequest.PushMessage
-
Creates an instance of a
PushMessage
record class. - PushMessageValidator - Class in io.micronaut.gcp.pubsub.validation
-
A validator for incoming PubSub push messages.
- PushMessageValidator() - Constructor for class io.micronaut.gcp.pubsub.validation.PushMessageValidator
- PushRequest - Record Class in io.micronaut.gcp.pubsub.push
-
A record for deserializing incoming PubSub Push request messages.
- PushRequest(String, PushRequest.PushMessage) - Constructor for record class io.micronaut.gcp.pubsub.push.PushRequest
-
Creates an instance of a
PushRequest
record class. - PushRequest.PushMessage - Record Class in io.micronaut.gcp.pubsub.push
-
The body of the deserialized push message.
- PushSubscriberHandler - Interface in io.micronaut.gcp.pubsub.push
-
Handles incoming
PushRequest
messages. - PushSubscription - Annotation Interface in io.micronaut.gcp.pubsub.annotation
-
Represents a PubSub Push subscription.
- put(CharSequence, Cookie) - Method in class io.micronaut.gcp.function.http.GoogleCookies
-
Put a new cookie.
R
- register(MutableConversionService) - Method in class io.micronaut.gcp.pubsub.configuration.ThreeTenConverterRegistrar
- RequiresGoogleProjectId - Annotation Interface 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
- resolve(Environment) - Method in class io.micronaut.discovery.cloud.gcp.GoogleComputeInstanceMetadataResolver
S
- SCOPES - Enum constant in enum class io.micronaut.discovery.cloud.gcp.GoogleComputeMetadataKeys
- SECRET_MANAGER - Static variable in interface io.micronaut.gcp.Modules
-
Module name for secret-manager.
- SecretManagerClient - Interface in io.micronaut.gcp.secretmanager.client
-
This interface is intended to abstract interactions with
SecretManagerServiceClient
, and instead of returning Google'sApiFuture
transform it on reactive extensions. - SecretManagerConfigurationClient - Class in io.micronaut.gcp.secretmanager
- SecretManagerConfigurationClient(SecretManagerClient, SecretManagerConfigurationProperties) - Constructor for class io.micronaut.gcp.secretmanager.SecretManagerConfigurationClient
- SecretManagerConfigurationProperties - Class in io.micronaut.gcp.secretmanager.configuration
-
Configuration for SecretManager clients and config client integration.
- SecretManagerConfigurationProperties() - Constructor for class io.micronaut.gcp.secretmanager.configuration.SecretManagerConfigurationProperties
- SecretManagerFactory - Class in io.micronaut.gcp.secretmanager
-
Factory to create SecretManager clients.
- SecretManagerFactory() - Constructor for class io.micronaut.gcp.secretmanager.SecretManagerFactory
- secretManagerServiceClient(CredentialsProvider, TransportChannelProvider) - Method in class io.micronaut.gcp.secretmanager.SecretManagerFactory
-
Creates a
SecretManagerServiceClient
instance. - 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
- SERVICE_ACCOUNTS - Enum constant in enum class io.micronaut.discovery.cloud.gcp.GoogleComputeMetadataKeys
- SERVICE_CONTEXT_ATTRIBUTE - Static variable in interface io.micronaut.gcp.logging.StackdriverTraceConstants
-
The JSON field name for the service context.
- setAudience(String) - Method in class io.micronaut.gcp.http.client.GoogleAuthServiceConfig
- setBatchingSettings(BatchingSettings.Builder) - Method in class io.micronaut.gcp.pubsub.configuration.PublisherConfigurationProperties
-
Controls message publishing batch.
- setConnectTimeout(Duration) - Method in class io.micronaut.discovery.cloud.gcp.GoogleComputeMetadataConfiguration
-
Default value (2).
- setCustomConfigs(Set<String>) - Method in class io.micronaut.gcp.secretmanager.configuration.SecretManagerConfigurationProperties
- setCustomJson(Map<String, Object>) - Method in class io.micronaut.gcp.logging.StackdriverJsonLayout
- setDefaultConfigEnabled(boolean) - Method in class io.micronaut.gcp.secretmanager.configuration.SecretManagerConfigurationProperties
- setEnabled(boolean) - Method in class io.micronaut.discovery.cloud.gcp.GoogleComputeMetadataConfiguration
-
Default value (true).
- setEnabled(boolean) - Method in class io.micronaut.gcp.credentials.GoogleCredentialsConfiguration
-
Allows disabling Google credentials configuration.
- 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.
- setIncludeExceptionInMessage(boolean) - Method in class io.micronaut.gcp.logging.StackdriverJsonLayout
- setIncludeSpanId(boolean) - Method in class io.micronaut.gcp.logging.StackdriverJsonLayout
- setIncludeTraceId(boolean) - Method in class io.micronaut.gcp.logging.StackdriverJsonLayout
- setKeepAliveIntervalMinutes(int) - Method in class io.micronaut.gcp.pubsub.configuration.PubSubConfigurationProperties
-
How often to ping the server to keep the channel alive.
- setKeys(Set<String>) - Method in class io.micronaut.gcp.secretmanager.configuration.SecretManagerConfigurationProperties
- 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.
- setMetadataUrl(String) - Method in class io.micronaut.discovery.cloud.gcp.GoogleComputeMetadataConfiguration
-
Default value ("http://metadata.google.internal/computeMetadata/v1/project/").
- setNackOnShutdown(boolean) - Method in class io.micronaut.gcp.pubsub.configuration.PubSubConfigurationProperties
- 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.
- setProjectId(String) - Method in class io.micronaut.gcp.logging.StackdriverJsonLayout
- setProjectMetadataUrl(String) - Method in class io.micronaut.discovery.cloud.gcp.GoogleComputeMetadataConfiguration
-
Default value ("http://metadata.google.internal/project/v1/project/").
- setPublishingExecutor(String) - Method in class io.micronaut.gcp.pubsub.configuration.PubSubConfigurationProperties
- setReadTimeout(Duration) - Method in class io.micronaut.discovery.cloud.gcp.GoogleComputeMetadataConfiguration
-
Default value (5 seconds).
- 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
- setTopicEndpoint(String) - Method in class io.micronaut.gcp.pubsub.configuration.PubSubConfigurationProperties
- setUseHttpClient(boolean) - Method in class io.micronaut.gcp.credentials.GoogleCredentialsConfiguration
-
Allows disabling use of the
HttpClient
based transport for retrieving authentication tokens. - SEVERITY_ATTRIBUTE - Static variable in interface io.micronaut.gcp.logging.StackdriverTraceConstants
-
The JSON field name for the log level (severity).
- SPAN_ID_ATTRIBUTE - Static variable in interface io.micronaut.gcp.logging.StackdriverTraceConstants
-
The JSON field name for the span-id.
- StackdriverJsonLayout - Class in io.micronaut.gcp.logging
-
Logback JsonLayout class to include tracing and other MDC fields.
- StackdriverJsonLayout() - Constructor for class io.micronaut.gcp.logging.StackdriverJsonLayout
- stackdriverPropagation() - Method in class io.micronaut.gcp.tracing.zipkin.StackdriverSenderFactory
-
The
Propagation.Factory
as a bean. - stackdriverReporter(AsyncReporterConfiguration) - Method in class io.micronaut.gcp.tracing.zipkin.StackdriverSenderFactory
-
A custom
AsyncReporter
that usesStackdriverEncoder.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
- StackdriverTraceConstants - Interface in io.micronaut.gcp.logging
-
Constants for Stackdriver Trace.
- stackdriverTraceSenderChannel() - Method in class io.micronaut.gcp.tracing.zipkin.StackdriverSenderFactory
- start() - Method in class io.micronaut.gcp.function.http.test.InvokerHttpServer
- start() - Method in class io.micronaut.gcp.logging.StackdriverJsonLayout
- startThis(ApplicationContext) - Method in class io.micronaut.gcp.function.http.HttpFunction
- stop() - Method in class io.micronaut.gcp.function.http.test.InvokerHttpServer
- 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
viaSubscriberFactory
. - SubscriberFactoryConfig(ProjectSubscriptionName, MessageReceiver, String, String) - Constructor for class io.micronaut.gcp.pubsub.bind.SubscriberFactoryConfig
- subscription() - Method in record class io.micronaut.gcp.pubsub.push.PushRequest
-
Returns the value of the
subscription
record component. - Subscription - Annotation Interface in io.micronaut.gcp.pubsub.annotation
-
Represents a PubSub subscription.
- supportedType() - Method in class io.micronaut.gcp.pubsub.serdes.JsonPubSubMessageSerDes
- supportedType() - Method in interface io.micronaut.gcp.pubsub.serdes.PubSubMessageSerDes
T
- TAGS - Enum constant in enum class io.micronaut.discovery.cloud.gcp.GoogleComputeMetadataKeys
- 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
- TIMESTAMP_NANOS_ATTRIBUTE - Static variable in interface io.micronaut.gcp.logging.StackdriverTraceConstants
-
The JSON field name for the nanos of the timestamp.
- TIMESTAMP_SECONDS_ATTRIBUTE - Static variable in interface io.micronaut.gcp.logging.StackdriverTraceConstants
-
The JSON field name for the seconds of the timestamp.
- toJsonMap(ILoggingEvent) - Method in class io.micronaut.gcp.logging.StackdriverJsonLayout
-
Convert a logging event into a Map.
- Topic - Annotation Interface in io.micronaut.gcp.pubsub.annotation
-
Represents a pubsub topic to be used by classes annotated with
PubSubClient
. - TopicState(String, ProjectTopicName, String, String, Boolean) - Constructor for class io.micronaut.gcp.pubsub.support.PubSubPublisherState.TopicState
- 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. - toString() - Method in record class io.micronaut.gcp.pubsub.push.PushRequest.PushMessage
-
Returns a string representation of this record class.
- toString() - Method in record class io.micronaut.gcp.pubsub.push.PushRequest
-
Returns a string representation of this record class.
- TRACE_ID_ATTRIBUTE - Static variable in interface io.micronaut.gcp.logging.StackdriverTraceConstants
-
The JSON field name for the trace-id.
- 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.
- TRACING - Static variable in interface io.micronaut.gcp.Modules
-
Module name for the gcp-tracing.
- transportChannelProvider() - Method in class io.micronaut.gcp.pubsub.support.PubSubConfigurationFactory
- transportChannelProvider() - Method in class io.micronaut.gcp.secretmanager.SecretManagerFactory
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
- ValidPushMessage - Annotation Interface in io.micronaut.gcp.pubsub.validation
-
A class-level validation constraint for PubSub push messages.
- value() - Element in annotation interface io.micronaut.gcp.pubsub.annotation.PushSubscription
-
The name of the subscription, it could be a simple name such as "animals" or a FQN such as
projects/<project_name>/subscriptions/<subscription_name>
. - value() - Element in annotation interface io.micronaut.gcp.pubsub.annotation.Subscription
-
The name of the subscription, it could be a simple name such as "animals" or a FQN such as
projects/<project_name>/subscriptions/<subscription_name>
. - value() - Element in annotation interface io.micronaut.gcp.pubsub.annotation.Topic
-
Set the name of the topic used to publish messages.
- valueOf(String) - Static method in enum class io.micronaut.discovery.cloud.gcp.GoogleComputeMetadataKeys
-
Returns the enum constant of this class with the specified name.
- values() - Static method in enum class io.micronaut.discovery.cloud.gcp.GoogleComputeMetadataKeys
-
Returns an array containing the constants of this enum class, in the order they are declared.
- values() - Method in class io.micronaut.gcp.function.http.GoogleCookies
- values() - Method in class io.micronaut.gcp.pubsub.bind.PubSubAttributesConvertibleValues
- VersionedSecret - Class in io.micronaut.gcp.secretmanager.client
-
A wrapper class around
AccessSecretVersionResponse
with secret information. - VersionedSecret(String, String, String, byte[]) - Constructor for class io.micronaut.gcp.secretmanager.client.VersionedSecret
- VIRTUAL_CLOCK - Enum constant in enum class io.micronaut.discovery.cloud.gcp.GoogleComputeMetadataKeys
W
- writeTo(Argument<DefaultOAuth2HttpTransportFactory.MutableBlockingLowLevelHttpRequest>, MediaType, DefaultOAuth2HttpTransportFactory.MutableBlockingLowLevelHttpRequest, MutableHeaders, OutputStream) - Method in class io.micronaut.gcp.credentials.OAuth2MessageBodyWriter
Z
- ZONE - Enum constant in enum class io.micronaut.discovery.cloud.gcp.GoogleComputeMetadataKeys
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form
GoogleCredentialsFactory(GoogleCredentialsConfiguration, HttpTransportFactory)
instead.