Skip to content

events.v1alpha1.pulsarTrigger

"PulsarTrigger refers to the specification of the Pulsar trigger."

Index

Fields

fn withParameters

withParameters(parameters)

"Parameters is the list of parameters that is applied to resolved Kafka trigger object."

fn withParametersMixin

withParametersMixin(parameters)

"Parameters is the list of parameters that is applied to resolved Kafka trigger object."

Note: This function appends passed data to existing values

fn withPayload

withPayload(payload)

"Payload is the list of key-value extracted from an event payload to construct the request payload."

fn withPayloadMixin

withPayloadMixin(payload)

"Payload is the list of key-value extracted from an event payload to construct the request payload."

Note: This function appends passed data to existing values

fn withTlsAllowInsecureConnection

withTlsAllowInsecureConnection(tlsAllowInsecureConnection)

fn withTlsValidateHostname

withTlsValidateHostname(tlsValidateHostname)

fn withTopic

withTopic(topic)

fn withUrl

withUrl(url)

obj authTokenSecret

"SecretKeySelector selects a key of a Secret."

fn authTokenSecret.withKey

withKey(key)

"The key of the secret to select from. Must be a valid secret key."

fn authTokenSecret.withName

withName(name)

"Name of the referent. More info: https://kubernetes.io/docs/concepts/overview/working-with-objects/names/#names"

fn authTokenSecret.withOptional

withOptional(optional)

"Specify whether the Secret or its key must be defined"

obj connectionBackoff

fn connectionBackoff.withSteps

withSteps(steps)

obj connectionBackoff.duration

fn connectionBackoff.duration.withInt64Val

withInt64Val(int64Val)

fn connectionBackoff.duration.withStrVal

withStrVal(strVal)

fn connectionBackoff.duration.withType

withType(type)

obj connectionBackoff.factor

"Amount represent a numeric amount."

fn connectionBackoff.factor.withValue

withValue(value)

obj connectionBackoff.jitter

"Amount represent a numeric amount."

fn connectionBackoff.jitter.withValue

withValue(value)

obj tls

"TLSConfig refers to TLS configuration for a client."

fn tls.withInsecureSkipVerify

withInsecureSkipVerify(insecureSkipVerify)

obj tls.caCertSecret

"SecretKeySelector selects a key of a Secret."

fn tls.caCertSecret.withKey

withKey(key)

"The key of the secret to select from. Must be a valid secret key."

fn tls.caCertSecret.withName

withName(name)

"Name of the referent. More info: https://kubernetes.io/docs/concepts/overview/working-with-objects/names/#names"

fn tls.caCertSecret.withOptional

withOptional(optional)

"Specify whether the Secret or its key must be defined"

obj tls.clientCertSecret

"SecretKeySelector selects a key of a Secret."

fn tls.clientCertSecret.withKey

withKey(key)

"The key of the secret to select from. Must be a valid secret key."

fn tls.clientCertSecret.withName

withName(name)

"Name of the referent. More info: https://kubernetes.io/docs/concepts/overview/working-with-objects/names/#names"

fn tls.clientCertSecret.withOptional

withOptional(optional)

"Specify whether the Secret or its key must be defined"

obj tls.clientKeySecret

"SecretKeySelector selects a key of a Secret."

fn tls.clientKeySecret.withKey

withKey(key)

"The key of the secret to select from. Must be a valid secret key."

fn tls.clientKeySecret.withName

withName(name)

"Name of the referent. More info: https://kubernetes.io/docs/concepts/overview/working-with-objects/names/#names"

fn tls.clientKeySecret.withOptional

withOptional(optional)

"Specify whether the Secret or its key must be defined"

obj tlsTrustCertsSecret

"SecretKeySelector selects a key of a Secret."

fn tlsTrustCertsSecret.withKey

withKey(key)

"The key of the secret to select from. Must be a valid secret key."

fn tlsTrustCertsSecret.withName

withName(name)

"Name of the referent. More info: https://kubernetes.io/docs/concepts/overview/working-with-objects/names/#names"

fn tlsTrustCertsSecret.withOptional

withOptional(optional)

"Specify whether the Secret or its key must be defined"