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, 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.
- 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, boolean) - Constructor for exception io.micronaut.gcp.pubsub.exception.PubSubMessageReceiverException
-
Constructor for PubSubMessageReceiverException.
- 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