Skip to content

events.v1alpha1.redisStreamEventSource

Index

Fields

fn withConsumerGroup

withConsumerGroup(consumerGroup)

fn withDb

withDb(db)

fn withHostAddress

withHostAddress(hostAddress)

fn withMaxMsgCountPerRead

withMaxMsgCountPerRead(maxMsgCountPerRead)

fn withMetadata

withMetadata(metadata)

fn withMetadataMixin

withMetadataMixin(metadata)

Note: This function appends passed data to existing values

fn withStreams

withStreams(streams)

"Streams to look for entries. XREADGROUP is used on all streams using a single consumer group."

fn withStreamsMixin

withStreamsMixin(streams)

"Streams to look for entries. XREADGROUP is used on all streams using a single consumer group."

Note: This function appends passed data to existing values

fn withUsername

withUsername(username)

obj filter

fn filter.withExpression

withExpression(expression)

obj password

"SecretKeySelector selects a key of a Secret."

fn password.withKey

withKey(key)

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

fn password.withName

withName(name)

"Name of the referent. This field is effectively required, but due to backwards compatibility is allowed to be empty. Instances of this type with an empty value here are almost certainly wrong. More info: https://kubernetes.io/docs/concepts/overview/working-with-objects/names/#names"

fn password.withOptional

withOptional(optional)

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

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. This field is effectively required, but due to backwards compatibility is allowed to be empty. Instances of this type with an empty value here are almost certainly wrong. 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. This field is effectively required, but due to backwards compatibility is allowed to be empty. Instances of this type with an empty value here are almost certainly wrong. 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. This field is effectively required, but due to backwards compatibility is allowed to be empty. Instances of this type with an empty value here are almost certainly wrong. 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"