Documentation ¶
Index ¶
- func KafkaBindingV1Alpha1(bootstrapServer string, ref *tracker.Reference) *kafkabindingv1alpha1.KafkaBinding
- func KafkaBindingV1Beta1(bootstrapServer string, ref *tracker.Reference) *kafkabindingv1beta1.KafkaBinding
- func KafkaPerformanceImageSenderPod(pace string, warmup string, bootstrapUrl string, topicName string, ...) *corev1.Pod
- func KafkaSourceV1Alpha1(bootstrapServer string, topicName string, ref *corev1.ObjectReference, ...) *kafkasourcev1alpha1.KafkaSource
- func KafkaSourceV1Beta1(bootstrapServer string, topicName string, ref *corev1.ObjectReference, ...) *kafkasourcev1beta1.KafkaSource
- func NewGitHubSourceV1Alpha1(name, namespace string, o ...GitHubSourceOptionV1Alpha1) *v1alpha1.GitHubSource
- func NewSecretValueFromSource(name, key string) v1alpha1.SecretValueFromSource
- func WithGithubSourceConditionsV1Alpha1(s *v1alpha1.GitHubSource)
- func WithGithubSourceSecretV1Alpha1(s *v1alpha1.GitHubSource)
- func WithGithubSourceWebHookConfiguredV1Alpha1(s *v1alpha1.GitHubSource)
- type GitHubSourceOptionV1Alpha1
- func WithGitHubAccessTokenSpecV1Alpha1(name, key string) GitHubSourceOptionV1Alpha1
- func WithGitHubSecretTokenSpecV1Alpha1(name, key string) GitHubSourceOptionV1Alpha1
- func WithGitHubSourceSpecV1Alpha1(spec v1alpha1.GitHubSourceSpec) GitHubSourceOptionV1Alpha1
- func WithGithubSourceSinkV1Alpha1(url *apis.URL) GitHubSourceOptionV1Alpha1
- type KafkaSourceV1Alpha1Option
- type KafkaSourceV1Beta1Option
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func KafkaBindingV1Alpha1 ¶ added in v0.16.0
func KafkaBindingV1Alpha1(bootstrapServer string, ref *tracker.Reference) *kafkabindingv1alpha1.KafkaBinding
func KafkaBindingV1Beta1 ¶ added in v0.16.0
func KafkaBindingV1Beta1(bootstrapServer string, ref *tracker.Reference) *kafkabindingv1beta1.KafkaBinding
func KafkaSourceV1Alpha1 ¶ added in v0.16.0
func KafkaSourceV1Alpha1(bootstrapServer string, topicName string, ref *corev1.ObjectReference, options ...KafkaSourceV1Alpha1Option) *kafkasourcev1alpha1.KafkaSource
func KafkaSourceV1Beta1 ¶ added in v0.16.0
func KafkaSourceV1Beta1(bootstrapServer string, topicName string, ref *corev1.ObjectReference, options ...KafkaSourceV1Beta1Option) *kafkasourcev1beta1.KafkaSource
func NewGitHubSourceV1Alpha1 ¶ added in v0.16.0
func NewGitHubSourceV1Alpha1(name, namespace string, o ...GitHubSourceOptionV1Alpha1) *v1alpha1.GitHubSource
NewGitHubSourceV1Alpha1 creates a GitHubSource with GithubSourceOption.
func NewSecretValueFromSource ¶ added in v0.16.0
func NewSecretValueFromSource(name, key string) v1alpha1.SecretValueFromSource
func WithGithubSourceConditionsV1Alpha1 ¶ added in v0.16.0
func WithGithubSourceConditionsV1Alpha1(s *v1alpha1.GitHubSource)
func WithGithubSourceSecretV1Alpha1 ¶ added in v0.16.0
func WithGithubSourceSecretV1Alpha1(s *v1alpha1.GitHubSource)
func WithGithubSourceWebHookConfiguredV1Alpha1 ¶ added in v0.16.0
func WithGithubSourceWebHookConfiguredV1Alpha1(s *v1alpha1.GitHubSource)
Types ¶
type GitHubSourceOptionV1Alpha1 ¶ added in v0.16.0
type GitHubSourceOptionV1Alpha1 func(source *v1alpha1.GitHubSource)
GitHubSourceOptionV1Alpha1 enables further configuration of a GitHubSource.
func WithGitHubAccessTokenSpecV1Alpha1 ¶ added in v0.16.0
func WithGitHubAccessTokenSpecV1Alpha1(name, key string) GitHubSourceOptionV1Alpha1
func WithGitHubSecretTokenSpecV1Alpha1 ¶ added in v0.16.0
func WithGitHubSecretTokenSpecV1Alpha1(name, key string) GitHubSourceOptionV1Alpha1
func WithGitHubSourceSpecV1Alpha1 ¶ added in v0.16.0
func WithGitHubSourceSpecV1Alpha1(spec v1alpha1.GitHubSourceSpec) GitHubSourceOptionV1Alpha1
func WithGithubSourceSinkV1Alpha1 ¶ added in v0.16.0
func WithGithubSourceSinkV1Alpha1(url *apis.URL) GitHubSourceOptionV1Alpha1
type KafkaSourceV1Alpha1Option ¶ added in v0.16.0
type KafkaSourceV1Alpha1Option func(source *kafkasourcev1alpha1.KafkaSource)
func WithConsumerGroupV1Alpha1 ¶ added in v0.16.0
func WithConsumerGroupV1Alpha1(cg string) KafkaSourceV1Alpha1Option
func WithNameV1Alpha1 ¶ added in v0.16.0
func WithNameV1Alpha1(name string) KafkaSourceV1Alpha1Option
type KafkaSourceV1Beta1Option ¶ added in v0.16.0
type KafkaSourceV1Beta1Option func(source *kafkasourcev1beta1.KafkaSource)
func WithConsumerGroupV1Beta1 ¶ added in v0.16.0
func WithConsumerGroupV1Beta1(cg string) KafkaSourceV1Beta1Option
func WithNameV1Beta1 ¶ added in v0.16.0
func WithNameV1Beta1(name string) KafkaSourceV1Beta1Option
Click to show internal directories.
Click to hide internal directories.