Versions in this module Expand all Collapse all v1 v1.9.3 Nov 27, 2024 Changes in this version + const AnnotationLeaderElection + const AnnotationResourceSpecHash + const ControllerHealthPort + const ControllerMetricsPort + const DefaultEventBusName + const DefaultMaxWebhookPayloadSize + const EnvImagePullPolicy + const EnvVarEventBusConfig + const EnvVarEventBusSubject + const EnvVarEventSource + const EnvVarEventSourceObject + const EnvVarKubeConfig + const EnvVarLeaderElection + const EnvVarPodName + const EnvVarSensorObject + const EventBusAuthFileMountPath + const EventBusMetricsPort + const EventSourceMetricsPort + const JetStreamClientAuthSecretKey + const JetStreamClusterCACertKey + const JetStreamClusterCertKey + const JetStreamClusterPrivateKeyKey + const JetStreamConfigMapKey + const JetStreamMaxPayload + const JetStreamServerCACertKey + const JetStreamServerCertKey + const JetStreamServerPrivateKeyKey + const JetStreamServerSecretAuthKey + const JetStreamServerSecretEncryptionKey + const JetStreamStreamName + const LabelEventSourceName + const LabelOwnerName + const LabelSensorName + const MediaTypeJSON + const MediaTypeYAML + const STANMaxAge + const STANMaxBytes + const STANMaxMsgs + const STANMaxPayload + const STANMaxSubs + const STANRaftCommitTimeout + const STANRaftElectionTimeout + const STANRaftHeartbeatTimeout + const STANRaftLeaseTimeout + const SensorMetricsPort + const SensorNamespace + var AddToScheme = SchemeBuilder.AddToScheme + var ConfigMapKeySelectorType = reflect.TypeOf(&corev1.ConfigMapKeySelector{}) + var ErrIntOverflowGenerated = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthGenerated = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrNilEventSource = fmt.Errorf("event source can't be nil") + var ErrUnexpectedEndOfGroupGenerated = fmt.Errorf("proto: unexpected end of group") + var EventBusGroupVersionKind = SchemeGroupVersion.WithKind("EventBus") + var EventBusGroupVersionResource = SchemeGroupVersion.WithResource("eventbus") + var EventSourceGroupVersionKind = SchemeGroupVersion.WithKind("EventSource") + var EventSourceGroupVersionResource = SchemeGroupVersion.WithResource("eventsources") + var RecreateStrategyEventSources = []EventSourceType + var SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes) + var SchemeGroupVersion = schema.GroupVersion + var SecretKeySelectorType = reflect.TypeOf(&corev1.SecretKeySelector{}) + var SensorGroupVersionKind = SchemeGroupVersion.WithKind("Sensor") + var SensorGroupVersionResource = SchemeGroupVersion.WithResource("sensors") + func GetOpenAPIDefinitions(ref common.ReferenceCallback) map[string]common.OpenAPIDefinition + func GroupKind(kind string) schema.GroupKind + func Resource(resource string) schema.GroupResource + func ValidateBasicAuth(auth *BasicAuth) error + func ValidateEventSource(eventSource *EventSource) error + func ValidateSASLConfig(saslConfig *SASLConfig) error + func ValidateTLSConfig(tlsConfig *TLSConfig) error + type AMQPConsumeConfig struct + AutoAck bool + ConsumerTag string + Exclusive bool + NoLocal bool + NoWait bool + func (*AMQPConsumeConfig) Descriptor() ([]byte, []int) + func (*AMQPConsumeConfig) ProtoMessage() + func (in *AMQPConsumeConfig) DeepCopy() *AMQPConsumeConfig + func (in *AMQPConsumeConfig) DeepCopyInto(out *AMQPConsumeConfig) + func (m *AMQPConsumeConfig) Marshal() (dAtA []byte, err error) + func (m *AMQPConsumeConfig) MarshalTo(dAtA []byte) (int, error) + func (m *AMQPConsumeConfig) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *AMQPConsumeConfig) Reset() + func (m *AMQPConsumeConfig) Size() (n int) + func (m *AMQPConsumeConfig) Unmarshal(dAtA []byte) error + func (m *AMQPConsumeConfig) XXX_DiscardUnknown() + func (m *AMQPConsumeConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *AMQPConsumeConfig) XXX_Merge(src proto.Message) + func (m *AMQPConsumeConfig) XXX_Size() int + func (m *AMQPConsumeConfig) XXX_Unmarshal(b []byte) error + func (this *AMQPConsumeConfig) String() string + type AMQPEventSource struct + Auth *BasicAuth + ConnectionBackoff *Backoff + Consume *AMQPConsumeConfig + ExchangeDeclare *AMQPExchangeDeclareConfig + ExchangeName string + ExchangeType string + Filter *EventSourceFilter + JSONBody bool + Metadata map[string]string + QueueBind *AMQPQueueBindConfig + QueueDeclare *AMQPQueueDeclareConfig + RoutingKey string + TLS *TLSConfig + URL string + URLSecret *corev1.SecretKeySelector + func (*AMQPEventSource) Descriptor() ([]byte, []int) + func (*AMQPEventSource) ProtoMessage() + func (in *AMQPEventSource) DeepCopy() *AMQPEventSource + func (in *AMQPEventSource) DeepCopyInto(out *AMQPEventSource) + func (m *AMQPEventSource) Marshal() (dAtA []byte, err error) + func (m *AMQPEventSource) MarshalTo(dAtA []byte) (int, error) + func (m *AMQPEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *AMQPEventSource) Reset() + func (m *AMQPEventSource) Size() (n int) + func (m *AMQPEventSource) Unmarshal(dAtA []byte) error + func (m *AMQPEventSource) XXX_DiscardUnknown() + func (m *AMQPEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *AMQPEventSource) XXX_Merge(src proto.Message) + func (m *AMQPEventSource) XXX_Size() int + func (m *AMQPEventSource) XXX_Unmarshal(b []byte) error + func (this *AMQPEventSource) String() string + type AMQPExchangeDeclareConfig struct + AutoDelete bool + Durable bool + Internal bool + NoWait bool + func (*AMQPExchangeDeclareConfig) Descriptor() ([]byte, []int) + func (*AMQPExchangeDeclareConfig) ProtoMessage() + func (in *AMQPExchangeDeclareConfig) DeepCopy() *AMQPExchangeDeclareConfig + func (in *AMQPExchangeDeclareConfig) DeepCopyInto(out *AMQPExchangeDeclareConfig) + func (m *AMQPExchangeDeclareConfig) Marshal() (dAtA []byte, err error) + func (m *AMQPExchangeDeclareConfig) MarshalTo(dAtA []byte) (int, error) + func (m *AMQPExchangeDeclareConfig) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *AMQPExchangeDeclareConfig) Reset() + func (m *AMQPExchangeDeclareConfig) Size() (n int) + func (m *AMQPExchangeDeclareConfig) Unmarshal(dAtA []byte) error + func (m *AMQPExchangeDeclareConfig) XXX_DiscardUnknown() + func (m *AMQPExchangeDeclareConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *AMQPExchangeDeclareConfig) XXX_Merge(src proto.Message) + func (m *AMQPExchangeDeclareConfig) XXX_Size() int + func (m *AMQPExchangeDeclareConfig) XXX_Unmarshal(b []byte) error + func (this *AMQPExchangeDeclareConfig) String() string + type AMQPQueueBindConfig struct + NoWait bool + func (*AMQPQueueBindConfig) Descriptor() ([]byte, []int) + func (*AMQPQueueBindConfig) ProtoMessage() + func (in *AMQPQueueBindConfig) DeepCopy() *AMQPQueueBindConfig + func (in *AMQPQueueBindConfig) DeepCopyInto(out *AMQPQueueBindConfig) + func (m *AMQPQueueBindConfig) Marshal() (dAtA []byte, err error) + func (m *AMQPQueueBindConfig) MarshalTo(dAtA []byte) (int, error) + func (m *AMQPQueueBindConfig) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *AMQPQueueBindConfig) Reset() + func (m *AMQPQueueBindConfig) Size() (n int) + func (m *AMQPQueueBindConfig) Unmarshal(dAtA []byte) error + func (m *AMQPQueueBindConfig) XXX_DiscardUnknown() + func (m *AMQPQueueBindConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *AMQPQueueBindConfig) XXX_Merge(src proto.Message) + func (m *AMQPQueueBindConfig) XXX_Size() int + func (m *AMQPQueueBindConfig) XXX_Unmarshal(b []byte) error + func (this *AMQPQueueBindConfig) String() string + type AMQPQueueDeclareConfig struct + Arguments string + AutoDelete bool + Durable bool + Exclusive bool + Name string + NoWait bool + func (*AMQPQueueDeclareConfig) Descriptor() ([]byte, []int) + func (*AMQPQueueDeclareConfig) ProtoMessage() + func (in *AMQPQueueDeclareConfig) DeepCopy() *AMQPQueueDeclareConfig + func (in *AMQPQueueDeclareConfig) DeepCopyInto(out *AMQPQueueDeclareConfig) + func (m *AMQPQueueDeclareConfig) Marshal() (dAtA []byte, err error) + func (m *AMQPQueueDeclareConfig) MarshalTo(dAtA []byte) (int, error) + func (m *AMQPQueueDeclareConfig) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *AMQPQueueDeclareConfig) Reset() + func (m *AMQPQueueDeclareConfig) Size() (n int) + func (m *AMQPQueueDeclareConfig) Unmarshal(dAtA []byte) error + func (m *AMQPQueueDeclareConfig) XXX_DiscardUnknown() + func (m *AMQPQueueDeclareConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *AMQPQueueDeclareConfig) XXX_Merge(src proto.Message) + func (m *AMQPQueueDeclareConfig) XXX_Size() int + func (m *AMQPQueueDeclareConfig) XXX_Unmarshal(b []byte) error + func (this *AMQPQueueDeclareConfig) String() string + type AWSLambdaTrigger struct + AccessKey *corev1.SecretKeySelector + FunctionName string + InvocationType *string + Parameters []TriggerParameter + Payload []TriggerParameter + Region string + RoleARN string + SecretKey *corev1.SecretKeySelector + func (*AWSLambdaTrigger) Descriptor() ([]byte, []int) + func (*AWSLambdaTrigger) ProtoMessage() + func (in *AWSLambdaTrigger) DeepCopy() *AWSLambdaTrigger + func (in *AWSLambdaTrigger) DeepCopyInto(out *AWSLambdaTrigger) + func (m *AWSLambdaTrigger) Marshal() (dAtA []byte, err error) + func (m *AWSLambdaTrigger) MarshalTo(dAtA []byte) (int, error) + func (m *AWSLambdaTrigger) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *AWSLambdaTrigger) Reset() + func (m *AWSLambdaTrigger) Size() (n int) + func (m *AWSLambdaTrigger) Unmarshal(dAtA []byte) error + func (m *AWSLambdaTrigger) XXX_DiscardUnknown() + func (m *AWSLambdaTrigger) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *AWSLambdaTrigger) XXX_Merge(src proto.Message) + func (m *AWSLambdaTrigger) XXX_Size() int + func (m *AWSLambdaTrigger) XXX_Unmarshal(b []byte) error + func (this *AWSLambdaTrigger) String() string + type Amount struct + Value []byte + func NewAmount(s string) Amount + func (*Amount) Descriptor() ([]byte, []int) + func (*Amount) ProtoMessage() + func (a *Amount) UnmarshalJSON(value []byte) error + func (in *Amount) DeepCopy() *Amount + func (in *Amount) DeepCopyInto(out *Amount) + func (m *Amount) Marshal() (dAtA []byte, err error) + func (m *Amount) MarshalTo(dAtA []byte) (int, error) + func (m *Amount) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Amount) Reset() + func (m *Amount) Size() (n int) + func (m *Amount) Unmarshal(dAtA []byte) error + func (m *Amount) XXX_DiscardUnknown() + func (m *Amount) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Amount) XXX_Merge(src proto.Message) + func (m *Amount) XXX_Size() int + func (m *Amount) XXX_Unmarshal(b []byte) error + func (n *Amount) Float64() (float64, error) + func (n Amount) MarshalJSON() ([]byte, error) + func (n Amount) OpenAPISchemaFormat() string + func (n Amount) OpenAPISchemaType() []string + func (this *Amount) String() string + type ArgoWorkflowOperation string + const Resubmit + const Resume + const Retry + const Stop + const Submit + const SubmitFrom + const Suspend + const Terminate + type ArgoWorkflowTrigger struct + Args []string + Operation ArgoWorkflowOperation + Parameters []TriggerParameter + Source *ArtifactLocation + func (*ArgoWorkflowTrigger) Descriptor() ([]byte, []int) + func (*ArgoWorkflowTrigger) ProtoMessage() + func (in *ArgoWorkflowTrigger) DeepCopy() *ArgoWorkflowTrigger + func (in *ArgoWorkflowTrigger) DeepCopyInto(out *ArgoWorkflowTrigger) + func (m *ArgoWorkflowTrigger) Marshal() (dAtA []byte, err error) + func (m *ArgoWorkflowTrigger) MarshalTo(dAtA []byte) (int, error) + func (m *ArgoWorkflowTrigger) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ArgoWorkflowTrigger) Reset() + func (m *ArgoWorkflowTrigger) Size() (n int) + func (m *ArgoWorkflowTrigger) Unmarshal(dAtA []byte) error + func (m *ArgoWorkflowTrigger) XXX_DiscardUnknown() + func (m *ArgoWorkflowTrigger) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ArgoWorkflowTrigger) XXX_Merge(src proto.Message) + func (m *ArgoWorkflowTrigger) XXX_Size() int + func (m *ArgoWorkflowTrigger) XXX_Unmarshal(b []byte) error + func (this *ArgoWorkflowTrigger) String() string + type ArtifactLocation struct + Configmap *corev1.ConfigMapKeySelector + File *FileArtifact + Git *GitArtifact + Inline *string + Resource *K8SResource + S3 *S3Artifact + URL *URLArtifact + func (*ArtifactLocation) Descriptor() ([]byte, []int) + func (*ArtifactLocation) ProtoMessage() + func (a *ArtifactLocation) HasLocation() bool + func (in *ArtifactLocation) DeepCopy() *ArtifactLocation + func (in *ArtifactLocation) DeepCopyInto(out *ArtifactLocation) + func (m *ArtifactLocation) Marshal() (dAtA []byte, err error) + func (m *ArtifactLocation) MarshalTo(dAtA []byte) (int, error) + func (m *ArtifactLocation) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ArtifactLocation) Reset() + func (m *ArtifactLocation) Size() (n int) + func (m *ArtifactLocation) Unmarshal(dAtA []byte) error + func (m *ArtifactLocation) XXX_DiscardUnknown() + func (m *ArtifactLocation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ArtifactLocation) XXX_Merge(src proto.Message) + func (m *ArtifactLocation) XXX_Size() int + func (m *ArtifactLocation) XXX_Unmarshal(b []byte) error + func (this *ArtifactLocation) String() string + type AuthStrategy string + var AuthStrategyBasic AuthStrategy = "basic" + var AuthStrategyNone AuthStrategy = "none" + var AuthStrategyToken AuthStrategy = "token" + type AzureEventHubsTrigger struct + FQDN string + HubName string + Parameters []TriggerParameter + Payload []TriggerParameter + SharedAccessKey *corev1.SecretKeySelector + SharedAccessKeyName *corev1.SecretKeySelector + func (*AzureEventHubsTrigger) Descriptor() ([]byte, []int) + func (*AzureEventHubsTrigger) ProtoMessage() + func (in *AzureEventHubsTrigger) DeepCopy() *AzureEventHubsTrigger + func (in *AzureEventHubsTrigger) DeepCopyInto(out *AzureEventHubsTrigger) + func (m *AzureEventHubsTrigger) Marshal() (dAtA []byte, err error) + func (m *AzureEventHubsTrigger) MarshalTo(dAtA []byte) (int, error) + func (m *AzureEventHubsTrigger) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *AzureEventHubsTrigger) Reset() + func (m *AzureEventHubsTrigger) Size() (n int) + func (m *AzureEventHubsTrigger) Unmarshal(dAtA []byte) error + func (m *AzureEventHubsTrigger) XXX_DiscardUnknown() + func (m *AzureEventHubsTrigger) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *AzureEventHubsTrigger) XXX_Merge(src proto.Message) + func (m *AzureEventHubsTrigger) XXX_Size() int + func (m *AzureEventHubsTrigger) XXX_Unmarshal(b []byte) error + func (this *AzureEventHubsTrigger) String() string + type AzureEventsHubEventSource struct + FQDN string + Filter *EventSourceFilter + HubName string + Metadata map[string]string + SharedAccessKey *corev1.SecretKeySelector + SharedAccessKeyName *corev1.SecretKeySelector + func (*AzureEventsHubEventSource) Descriptor() ([]byte, []int) + func (*AzureEventsHubEventSource) ProtoMessage() + func (in *AzureEventsHubEventSource) DeepCopy() *AzureEventsHubEventSource + func (in *AzureEventsHubEventSource) DeepCopyInto(out *AzureEventsHubEventSource) + func (m *AzureEventsHubEventSource) Marshal() (dAtA []byte, err error) + func (m *AzureEventsHubEventSource) MarshalTo(dAtA []byte) (int, error) + func (m *AzureEventsHubEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *AzureEventsHubEventSource) Reset() + func (m *AzureEventsHubEventSource) Size() (n int) + func (m *AzureEventsHubEventSource) Unmarshal(dAtA []byte) error + func (m *AzureEventsHubEventSource) XXX_DiscardUnknown() + func (m *AzureEventsHubEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *AzureEventsHubEventSource) XXX_Merge(src proto.Message) + func (m *AzureEventsHubEventSource) XXX_Size() int + func (m *AzureEventsHubEventSource) XXX_Unmarshal(b []byte) error + func (this *AzureEventsHubEventSource) String() string + type AzureQueueStorageEventSource struct + ConnectionString *corev1.SecretKeySelector + DLQ bool + DecodeMessage bool + Filter *EventSourceFilter + JSONBody bool + Metadata map[string]string + QueueName string + StorageAccountName string + WaitTimeInSeconds *int32 + func (*AzureQueueStorageEventSource) Descriptor() ([]byte, []int) + func (*AzureQueueStorageEventSource) ProtoMessage() + func (in *AzureQueueStorageEventSource) DeepCopy() *AzureQueueStorageEventSource + func (in *AzureQueueStorageEventSource) DeepCopyInto(out *AzureQueueStorageEventSource) + func (m *AzureQueueStorageEventSource) Marshal() (dAtA []byte, err error) + func (m *AzureQueueStorageEventSource) MarshalTo(dAtA []byte) (int, error) + func (m *AzureQueueStorageEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *AzureQueueStorageEventSource) Reset() + func (m *AzureQueueStorageEventSource) Size() (n int) + func (m *AzureQueueStorageEventSource) Unmarshal(dAtA []byte) error + func (m *AzureQueueStorageEventSource) XXX_DiscardUnknown() + func (m *AzureQueueStorageEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *AzureQueueStorageEventSource) XXX_Merge(src proto.Message) + func (m *AzureQueueStorageEventSource) XXX_Size() int + func (m *AzureQueueStorageEventSource) XXX_Unmarshal(b []byte) error + func (this *AzureQueueStorageEventSource) String() string + type AzureServiceBusEventSource struct + ConnectionString *corev1.SecretKeySelector + Filter *EventSourceFilter + FullyQualifiedNamespace string + JSONBody bool + Metadata map[string]string + QueueName string + SubscriptionName string + TLS *TLSConfig + TopicName string + func (*AzureServiceBusEventSource) Descriptor() ([]byte, []int) + func (*AzureServiceBusEventSource) ProtoMessage() + func (in *AzureServiceBusEventSource) DeepCopy() *AzureServiceBusEventSource + func (in *AzureServiceBusEventSource) DeepCopyInto(out *AzureServiceBusEventSource) + func (m *AzureServiceBusEventSource) Marshal() (dAtA []byte, err error) + func (m *AzureServiceBusEventSource) MarshalTo(dAtA []byte) (int, error) + func (m *AzureServiceBusEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *AzureServiceBusEventSource) Reset() + func (m *AzureServiceBusEventSource) Size() (n int) + func (m *AzureServiceBusEventSource) Unmarshal(dAtA []byte) error + func (m *AzureServiceBusEventSource) XXX_DiscardUnknown() + func (m *AzureServiceBusEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *AzureServiceBusEventSource) XXX_Merge(src proto.Message) + func (m *AzureServiceBusEventSource) XXX_Size() int + func (m *AzureServiceBusEventSource) XXX_Unmarshal(b []byte) error + func (this *AzureServiceBusEventSource) String() string + type AzureServiceBusTrigger struct + ConnectionString *corev1.SecretKeySelector + Parameters []TriggerParameter + Payload []TriggerParameter + QueueName string + SubscriptionName string + TLS *TLSConfig + TopicName string + func (*AzureServiceBusTrigger) Descriptor() ([]byte, []int) + func (*AzureServiceBusTrigger) ProtoMessage() + func (in *AzureServiceBusTrigger) DeepCopy() *AzureServiceBusTrigger + func (in *AzureServiceBusTrigger) DeepCopyInto(out *AzureServiceBusTrigger) + func (m *AzureServiceBusTrigger) Marshal() (dAtA []byte, err error) + func (m *AzureServiceBusTrigger) MarshalTo(dAtA []byte) (int, error) + func (m *AzureServiceBusTrigger) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *AzureServiceBusTrigger) Reset() + func (m *AzureServiceBusTrigger) Size() (n int) + func (m *AzureServiceBusTrigger) Unmarshal(dAtA []byte) error + func (m *AzureServiceBusTrigger) XXX_DiscardUnknown() + func (m *AzureServiceBusTrigger) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *AzureServiceBusTrigger) XXX_Merge(src proto.Message) + func (m *AzureServiceBusTrigger) XXX_Size() int + func (m *AzureServiceBusTrigger) XXX_Unmarshal(b []byte) error + func (this *AzureServiceBusTrigger) String() string + type Backoff struct + Duration *Int64OrString + Factor *Amount + Jitter *Amount + Steps int32 + func (*Backoff) Descriptor() ([]byte, []int) + func (*Backoff) ProtoMessage() + func (b Backoff) GetSteps() int + func (in *Backoff) DeepCopy() *Backoff + func (in *Backoff) DeepCopyInto(out *Backoff) + func (m *Backoff) Marshal() (dAtA []byte, err error) + func (m *Backoff) MarshalTo(dAtA []byte) (int, error) + func (m *Backoff) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Backoff) Reset() + func (m *Backoff) Size() (n int) + func (m *Backoff) Unmarshal(dAtA []byte) error + func (m *Backoff) XXX_DiscardUnknown() + func (m *Backoff) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Backoff) XXX_Merge(src proto.Message) + func (m *Backoff) XXX_Size() int + func (m *Backoff) XXX_Unmarshal(b []byte) error + func (this *Backoff) String() string + type BasicAuth struct + Password *corev1.SecretKeySelector + Username *corev1.SecretKeySelector + func (*BasicAuth) Descriptor() ([]byte, []int) + func (*BasicAuth) ProtoMessage() + func (in *BasicAuth) DeepCopy() *BasicAuth + func (in *BasicAuth) DeepCopyInto(out *BasicAuth) + func (m *BasicAuth) Marshal() (dAtA []byte, err error) + func (m *BasicAuth) MarshalTo(dAtA []byte) (int, error) + func (m *BasicAuth) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BasicAuth) Reset() + func (m *BasicAuth) Size() (n int) + func (m *BasicAuth) Unmarshal(dAtA []byte) error + func (m *BasicAuth) XXX_DiscardUnknown() + func (m *BasicAuth) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *BasicAuth) XXX_Merge(src proto.Message) + func (m *BasicAuth) XXX_Size() int + func (m *BasicAuth) XXX_Unmarshal(b []byte) error + func (this *BasicAuth) String() string + type BitbucketAuth struct + Basic *BitbucketBasicAuth + OAuthToken *corev1.SecretKeySelector + func (*BitbucketAuth) Descriptor() ([]byte, []int) + func (*BitbucketAuth) ProtoMessage() + func (in *BitbucketAuth) DeepCopy() *BitbucketAuth + func (in *BitbucketAuth) DeepCopyInto(out *BitbucketAuth) + func (m *BitbucketAuth) Marshal() (dAtA []byte, err error) + func (m *BitbucketAuth) MarshalTo(dAtA []byte) (int, error) + func (m *BitbucketAuth) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BitbucketAuth) Reset() + func (m *BitbucketAuth) Size() (n int) + func (m *BitbucketAuth) Unmarshal(dAtA []byte) error + func (m *BitbucketAuth) XXX_DiscardUnknown() + func (m *BitbucketAuth) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *BitbucketAuth) XXX_Merge(src proto.Message) + func (m *BitbucketAuth) XXX_Size() int + func (m *BitbucketAuth) XXX_Unmarshal(b []byte) error + func (this *BitbucketAuth) String() string + type BitbucketBasicAuth struct + Password *corev1.SecretKeySelector + Username *corev1.SecretKeySelector + func (*BitbucketBasicAuth) Descriptor() ([]byte, []int) + func (*BitbucketBasicAuth) ProtoMessage() + func (in *BitbucketBasicAuth) DeepCopy() *BitbucketBasicAuth + func (in *BitbucketBasicAuth) DeepCopyInto(out *BitbucketBasicAuth) + func (m *BitbucketBasicAuth) Marshal() (dAtA []byte, err error) + func (m *BitbucketBasicAuth) MarshalTo(dAtA []byte) (int, error) + func (m *BitbucketBasicAuth) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BitbucketBasicAuth) Reset() + func (m *BitbucketBasicAuth) Size() (n int) + func (m *BitbucketBasicAuth) Unmarshal(dAtA []byte) error + func (m *BitbucketBasicAuth) XXX_DiscardUnknown() + func (m *BitbucketBasicAuth) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *BitbucketBasicAuth) XXX_Merge(src proto.Message) + func (m *BitbucketBasicAuth) XXX_Size() int + func (m *BitbucketBasicAuth) XXX_Unmarshal(b []byte) error + func (this *BitbucketBasicAuth) String() string + type BitbucketEventSource struct + Auth *BitbucketAuth + DeleteHookOnFinish bool + DeprecatedOwner string + DeprecatedProjectKey string + DeprecatedRepositorySlug string + Events []string + Filter *EventSourceFilter + Metadata map[string]string + Repositories []BitbucketRepository + Webhook *WebhookContext + func (*BitbucketEventSource) Descriptor() ([]byte, []int) + func (*BitbucketEventSource) ProtoMessage() + func (b BitbucketEventSource) GetBitbucketRepositories() []BitbucketRepository + func (b BitbucketEventSource) HasBitbucketBasicAuth() bool + func (b BitbucketEventSource) HasBitbucketOAuthToken() bool + func (b BitbucketEventSource) HasConfiguredWebhook() bool + func (b BitbucketEventSource) ShouldCreateWebhooks() bool + func (in *BitbucketEventSource) DeepCopy() *BitbucketEventSource + func (in *BitbucketEventSource) DeepCopyInto(out *BitbucketEventSource) + func (m *BitbucketEventSource) Marshal() (dAtA []byte, err error) + func (m *BitbucketEventSource) MarshalTo(dAtA []byte) (int, error) + func (m *BitbucketEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BitbucketEventSource) Reset() + func (m *BitbucketEventSource) Size() (n int) + func (m *BitbucketEventSource) Unmarshal(dAtA []byte) error + func (m *BitbucketEventSource) XXX_DiscardUnknown() + func (m *BitbucketEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *BitbucketEventSource) XXX_Merge(src proto.Message) + func (m *BitbucketEventSource) XXX_Size() int + func (m *BitbucketEventSource) XXX_Unmarshal(b []byte) error + func (this *BitbucketEventSource) String() string + type BitbucketRepository struct + Owner string + RepositorySlug string + func (*BitbucketRepository) Descriptor() ([]byte, []int) + func (*BitbucketRepository) ProtoMessage() + func (in *BitbucketRepository) DeepCopy() *BitbucketRepository + func (in *BitbucketRepository) DeepCopyInto(out *BitbucketRepository) + func (m *BitbucketRepository) Marshal() (dAtA []byte, err error) + func (m *BitbucketRepository) MarshalTo(dAtA []byte) (int, error) + func (m *BitbucketRepository) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BitbucketRepository) Reset() + func (m *BitbucketRepository) Size() (n int) + func (m *BitbucketRepository) Unmarshal(dAtA []byte) error + func (m *BitbucketRepository) XXX_DiscardUnknown() + func (m *BitbucketRepository) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *BitbucketRepository) XXX_Merge(src proto.Message) + func (m *BitbucketRepository) XXX_Size() int + func (m *BitbucketRepository) XXX_Unmarshal(b []byte) error + func (r BitbucketRepository) GetRepositoryID() string + func (this *BitbucketRepository) String() string + type BitbucketServerEventSource struct + AccessToken *corev1.SecretKeySelector + BitbucketServerBaseURL string + CheckInterval string + DeleteHookOnFinish bool + DeprecatedProjectKey string + DeprecatedRepositorySlug string + Events []string + Filter *EventSourceFilter + Metadata map[string]string + OneEventPerChange bool + Projects []string + Repositories []BitbucketServerRepository + SkipBranchRefsChangedOnOpenPR bool + TLS *TLSConfig + Webhook *WebhookContext + WebhookSecret *corev1.SecretKeySelector + func (*BitbucketServerEventSource) Descriptor() ([]byte, []int) + func (*BitbucketServerEventSource) ProtoMessage() + func (b BitbucketServerEventSource) GetBitbucketServerRepositories() []BitbucketServerRepository + func (b BitbucketServerEventSource) ShouldCreateWebhooks() bool + func (in *BitbucketServerEventSource) DeepCopy() *BitbucketServerEventSource + func (in *BitbucketServerEventSource) DeepCopyInto(out *BitbucketServerEventSource) + func (m *BitbucketServerEventSource) Marshal() (dAtA []byte, err error) + func (m *BitbucketServerEventSource) MarshalTo(dAtA []byte) (int, error) + func (m *BitbucketServerEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BitbucketServerEventSource) Reset() + func (m *BitbucketServerEventSource) Size() (n int) + func (m *BitbucketServerEventSource) Unmarshal(dAtA []byte) error + func (m *BitbucketServerEventSource) XXX_DiscardUnknown() + func (m *BitbucketServerEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *BitbucketServerEventSource) XXX_Merge(src proto.Message) + func (m *BitbucketServerEventSource) XXX_Size() int + func (m *BitbucketServerEventSource) XXX_Unmarshal(b []byte) error + func (this *BitbucketServerEventSource) String() string + type BitbucketServerRepository struct + ProjectKey string + RepositorySlug string + func (*BitbucketServerRepository) Descriptor() ([]byte, []int) + func (*BitbucketServerRepository) ProtoMessage() + func (in *BitbucketServerRepository) DeepCopy() *BitbucketServerRepository + func (in *BitbucketServerRepository) DeepCopyInto(out *BitbucketServerRepository) + func (m *BitbucketServerRepository) Marshal() (dAtA []byte, err error) + func (m *BitbucketServerRepository) MarshalTo(dAtA []byte) (int, error) + func (m *BitbucketServerRepository) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BitbucketServerRepository) Reset() + func (m *BitbucketServerRepository) Size() (n int) + func (m *BitbucketServerRepository) Unmarshal(dAtA []byte) error + func (m *BitbucketServerRepository) XXX_DiscardUnknown() + func (m *BitbucketServerRepository) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *BitbucketServerRepository) XXX_Merge(src proto.Message) + func (m *BitbucketServerRepository) XXX_Size() int + func (m *BitbucketServerRepository) XXX_Unmarshal(b []byte) error + func (this *BitbucketServerRepository) String() string + type BusConfig struct + JetStream *JetStreamConfig + Kafka *KafkaBus + NATS *NATSConfig + func (*BusConfig) Descriptor() ([]byte, []int) + func (*BusConfig) ProtoMessage() + func (in *BusConfig) DeepCopy() *BusConfig + func (in *BusConfig) DeepCopyInto(out *BusConfig) + func (m *BusConfig) Marshal() (dAtA []byte, err error) + func (m *BusConfig) MarshalTo(dAtA []byte) (int, error) + func (m *BusConfig) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BusConfig) Reset() + func (m *BusConfig) Size() (n int) + func (m *BusConfig) Unmarshal(dAtA []byte) error + func (m *BusConfig) XXX_DiscardUnknown() + func (m *BusConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *BusConfig) XXX_Merge(src proto.Message) + func (m *BusConfig) XXX_Size() int + func (m *BusConfig) XXX_Unmarshal(b []byte) error + func (this *BusConfig) String() string + type CalendarEventSource struct + ExclusionDates []string + Filter *EventSourceFilter + Interval string + Metadata map[string]string + Persistence *EventPersistence + Schedule string + Timezone string + func (*CalendarEventSource) Descriptor() ([]byte, []int) + func (*CalendarEventSource) ProtoMessage() + func (in *CalendarEventSource) DeepCopy() *CalendarEventSource + func (in *CalendarEventSource) DeepCopyInto(out *CalendarEventSource) + func (m *CalendarEventSource) Marshal() (dAtA []byte, err error) + func (m *CalendarEventSource) MarshalTo(dAtA []byte) (int, error) + func (m *CalendarEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CalendarEventSource) Reset() + func (m *CalendarEventSource) Size() (n int) + func (m *CalendarEventSource) Unmarshal(dAtA []byte) error + func (m *CalendarEventSource) XXX_DiscardUnknown() + func (m *CalendarEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CalendarEventSource) XXX_Merge(src proto.Message) + func (m *CalendarEventSource) XXX_Size() int + func (m *CalendarEventSource) XXX_Unmarshal(b []byte) error + func (this *CalendarEventSource) String() string + type CatchupConfiguration struct + Enabled bool + MaxDuration string + func (*CatchupConfiguration) Descriptor() ([]byte, []int) + func (*CatchupConfiguration) ProtoMessage() + func (in *CatchupConfiguration) DeepCopy() *CatchupConfiguration + func (in *CatchupConfiguration) DeepCopyInto(out *CatchupConfiguration) + func (m *CatchupConfiguration) Marshal() (dAtA []byte, err error) + func (m *CatchupConfiguration) MarshalTo(dAtA []byte) (int, error) + func (m *CatchupConfiguration) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CatchupConfiguration) Reset() + func (m *CatchupConfiguration) Size() (n int) + func (m *CatchupConfiguration) Unmarshal(dAtA []byte) error + func (m *CatchupConfiguration) XXX_DiscardUnknown() + func (m *CatchupConfiguration) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CatchupConfiguration) XXX_Merge(src proto.Message) + func (m *CatchupConfiguration) XXX_Size() int + func (m *CatchupConfiguration) XXX_Unmarshal(b []byte) error + func (this *CatchupConfiguration) String() string + type Comparator string + const EmptyComparator + const EqualTo + const GreaterThan + const GreaterThanOrEqualTo + const LessThan + const LessThanOrEqualTo + const NotEqualTo + type Condition struct + LastTransitionTime metav1.Time + Message string + Reason string + Status corev1.ConditionStatus + Type ConditionType + func (*Condition) Descriptor() ([]byte, []int) + func (*Condition) ProtoMessage() + func (c *Condition) GetMessage() string + func (c *Condition) GetReason() string + func (c *Condition) IsFalse() bool + func (c *Condition) IsTrue() bool + func (c *Condition) IsUnknown() bool + func (in *Condition) DeepCopy() *Condition + func (in *Condition) DeepCopyInto(out *Condition) + func (m *Condition) Marshal() (dAtA []byte, err error) + func (m *Condition) MarshalTo(dAtA []byte) (int, error) + func (m *Condition) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Condition) Reset() + func (m *Condition) Size() (n int) + func (m *Condition) Unmarshal(dAtA []byte) error + func (m *Condition) XXX_DiscardUnknown() + func (m *Condition) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Condition) XXX_Merge(src proto.Message) + func (m *Condition) XXX_Size() int + func (m *Condition) XXX_Unmarshal(b []byte) error + func (this *Condition) String() string + type ConditionType string + const ConditionReady + const EventBusConditionConfigured + const EventBusConditionDeployed + const EventSourceConditionDeployed + const EventSourceConditionSourcesProvided + const SensorConditionDepencencyProvided + const SensorConditionDeployed + const SensorConditionTriggersProvided + type ConditionsResetByTime struct + Cron string + Timezone string + func (*ConditionsResetByTime) Descriptor() ([]byte, []int) + func (*ConditionsResetByTime) ProtoMessage() + func (in *ConditionsResetByTime) DeepCopy() *ConditionsResetByTime + func (in *ConditionsResetByTime) DeepCopyInto(out *ConditionsResetByTime) + func (m *ConditionsResetByTime) Marshal() (dAtA []byte, err error) + func (m *ConditionsResetByTime) MarshalTo(dAtA []byte) (int, error) + func (m *ConditionsResetByTime) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ConditionsResetByTime) Reset() + func (m *ConditionsResetByTime) Size() (n int) + func (m *ConditionsResetByTime) Unmarshal(dAtA []byte) error + func (m *ConditionsResetByTime) XXX_DiscardUnknown() + func (m *ConditionsResetByTime) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ConditionsResetByTime) XXX_Merge(src proto.Message) + func (m *ConditionsResetByTime) XXX_Size() int + func (m *ConditionsResetByTime) XXX_Unmarshal(b []byte) error + func (this *ConditionsResetByTime) String() string + type ConditionsResetCriteria struct + ByTime *ConditionsResetByTime + func (*ConditionsResetCriteria) Descriptor() ([]byte, []int) + func (*ConditionsResetCriteria) ProtoMessage() + func (in *ConditionsResetCriteria) DeepCopy() *ConditionsResetCriteria + func (in *ConditionsResetCriteria) DeepCopyInto(out *ConditionsResetCriteria) + func (m *ConditionsResetCriteria) Marshal() (dAtA []byte, err error) + func (m *ConditionsResetCriteria) MarshalTo(dAtA []byte) (int, error) + func (m *ConditionsResetCriteria) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ConditionsResetCriteria) Reset() + func (m *ConditionsResetCriteria) Size() (n int) + func (m *ConditionsResetCriteria) Unmarshal(dAtA []byte) error + func (m *ConditionsResetCriteria) XXX_DiscardUnknown() + func (m *ConditionsResetCriteria) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ConditionsResetCriteria) XXX_Merge(src proto.Message) + func (m *ConditionsResetCriteria) XXX_Size() int + func (m *ConditionsResetCriteria) XXX_Unmarshal(b []byte) error + func (this *ConditionsResetCriteria) String() string + type ConfigMapPersistence struct + CreateIfNotExist bool + Name string + func (*ConfigMapPersistence) Descriptor() ([]byte, []int) + func (*ConfigMapPersistence) ProtoMessage() + func (in *ConfigMapPersistence) DeepCopy() *ConfigMapPersistence + func (in *ConfigMapPersistence) DeepCopyInto(out *ConfigMapPersistence) + func (m *ConfigMapPersistence) Marshal() (dAtA []byte, err error) + func (m *ConfigMapPersistence) MarshalTo(dAtA []byte) (int, error) + func (m *ConfigMapPersistence) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ConfigMapPersistence) Reset() + func (m *ConfigMapPersistence) Size() (n int) + func (m *ConfigMapPersistence) Unmarshal(dAtA []byte) error + func (m *ConfigMapPersistence) XXX_DiscardUnknown() + func (m *ConfigMapPersistence) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ConfigMapPersistence) XXX_Merge(src proto.Message) + func (m *ConfigMapPersistence) XXX_Size() int + func (m *ConfigMapPersistence) XXX_Unmarshal(b []byte) error + func (this *ConfigMapPersistence) String() string + type ContainerTemplate struct + ImagePullPolicy corev1.PullPolicy + Resources corev1.ResourceRequirements + SecurityContext *corev1.SecurityContext + func (*ContainerTemplate) Descriptor() ([]byte, []int) + func (*ContainerTemplate) ProtoMessage() + func (in *ContainerTemplate) DeepCopy() *ContainerTemplate + func (in *ContainerTemplate) DeepCopyInto(out *ContainerTemplate) + func (m *ContainerTemplate) Marshal() (dAtA []byte, err error) + func (m *ContainerTemplate) MarshalTo(dAtA []byte) (int, error) + func (m *ContainerTemplate) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ContainerTemplate) Reset() + func (m *ContainerTemplate) Size() (n int) + func (m *ContainerTemplate) Unmarshal(dAtA []byte) error + func (m *ContainerTemplate) XXX_DiscardUnknown() + func (m *ContainerTemplate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ContainerTemplate) XXX_Merge(src proto.Message) + func (m *ContainerTemplate) XXX_Size() int + func (m *ContainerTemplate) XXX_Unmarshal(b []byte) error + func (this *ContainerTemplate) String() string + type CustomTrigger struct + CertSecret *corev1.SecretKeySelector + Parameters []TriggerParameter + Payload []TriggerParameter + Secure bool + ServerNameOverride string + ServerURL string + Spec map[string]string + func (*CustomTrigger) Descriptor() ([]byte, []int) + func (*CustomTrigger) ProtoMessage() + func (in *CustomTrigger) DeepCopy() *CustomTrigger + func (in *CustomTrigger) DeepCopyInto(out *CustomTrigger) + func (m *CustomTrigger) Marshal() (dAtA []byte, err error) + func (m *CustomTrigger) MarshalTo(dAtA []byte) (int, error) + func (m *CustomTrigger) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CustomTrigger) Reset() + func (m *CustomTrigger) Size() (n int) + func (m *CustomTrigger) Unmarshal(dAtA []byte) error + func (m *CustomTrigger) XXX_DiscardUnknown() + func (m *CustomTrigger) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CustomTrigger) XXX_Merge(src proto.Message) + func (m *CustomTrigger) XXX_Size() int + func (m *CustomTrigger) XXX_Unmarshal(b []byte) error + func (this *CustomTrigger) String() string + type DataFilter struct + Comparator Comparator + Path string + Template string + Type JSONType + Value []string + func (*DataFilter) Descriptor() ([]byte, []int) + func (*DataFilter) ProtoMessage() + func (in *DataFilter) DeepCopy() *DataFilter + func (in *DataFilter) DeepCopyInto(out *DataFilter) + func (m *DataFilter) Marshal() (dAtA []byte, err error) + func (m *DataFilter) MarshalTo(dAtA []byte) (int, error) + func (m *DataFilter) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DataFilter) Reset() + func (m *DataFilter) Size() (n int) + func (m *DataFilter) Unmarshal(dAtA []byte) error + func (m *DataFilter) XXX_DiscardUnknown() + func (m *DataFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DataFilter) XXX_Merge(src proto.Message) + func (m *DataFilter) XXX_Size() int + func (m *DataFilter) XXX_Unmarshal(b []byte) error + func (this *DataFilter) String() string + type EmailTrigger struct + Body string + From string + Host string + Parameters []TriggerParameter + Port int32 + SMTPPassword *corev1.SecretKeySelector + Subject string + To []string + Username string + func (*EmailTrigger) Descriptor() ([]byte, []int) + func (*EmailTrigger) ProtoMessage() + func (in *EmailTrigger) DeepCopy() *EmailTrigger + func (in *EmailTrigger) DeepCopyInto(out *EmailTrigger) + func (m *EmailTrigger) Marshal() (dAtA []byte, err error) + func (m *EmailTrigger) MarshalTo(dAtA []byte) (int, error) + func (m *EmailTrigger) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *EmailTrigger) Reset() + func (m *EmailTrigger) Size() (n int) + func (m *EmailTrigger) Unmarshal(dAtA []byte) error + func (m *EmailTrigger) XXX_DiscardUnknown() + func (m *EmailTrigger) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *EmailTrigger) XXX_Merge(src proto.Message) + func (m *EmailTrigger) XXX_Size() int + func (m *EmailTrigger) XXX_Unmarshal(b []byte) error + func (this *EmailTrigger) String() string + type EmitterEventSource struct + Broker string + ChannelKey string + ChannelName string + ConnectionBackoff *Backoff + Filter *EventSourceFilter + JSONBody bool + Metadata map[string]string + Password *corev1.SecretKeySelector + TLS *TLSConfig + Username *corev1.SecretKeySelector + func (*EmitterEventSource) Descriptor() ([]byte, []int) + func (*EmitterEventSource) ProtoMessage() + func (in *EmitterEventSource) DeepCopy() *EmitterEventSource + func (in *EmitterEventSource) DeepCopyInto(out *EmitterEventSource) + func (m *EmitterEventSource) Marshal() (dAtA []byte, err error) + func (m *EmitterEventSource) MarshalTo(dAtA []byte) (int, error) + func (m *EmitterEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *EmitterEventSource) Reset() + func (m *EmitterEventSource) Size() (n int) + func (m *EmitterEventSource) Unmarshal(dAtA []byte) error + func (m *EmitterEventSource) XXX_DiscardUnknown() + func (m *EmitterEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *EmitterEventSource) XXX_Merge(src proto.Message) + func (m *EmitterEventSource) XXX_Size() int + func (m *EmitterEventSource) XXX_Unmarshal(b []byte) error + func (this *EmitterEventSource) String() string + type Event struct + Context *EventContext + Data []byte + func (*Event) Descriptor() ([]byte, []int) + func (*Event) ProtoMessage() + func (e Event) DataString() string + func (e Event) String() string + func (in *Event) DeepCopy() *Event + func (in *Event) DeepCopyInto(out *Event) + func (m *Event) Marshal() (dAtA []byte, err error) + func (m *Event) MarshalTo(dAtA []byte) (int, error) + func (m *Event) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Event) Reset() + func (m *Event) Size() (n int) + func (m *Event) Unmarshal(dAtA []byte) error + func (m *Event) XXX_DiscardUnknown() + func (m *Event) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Event) XXX_Merge(src proto.Message) + func (m *Event) XXX_Size() int + func (m *Event) XXX_Unmarshal(b []byte) error + type EventBus struct + Spec EventBusSpec + Status EventBusStatus + func (*EventBus) Descriptor() ([]byte, []int) + func (*EventBus) ProtoMessage() + func (in *EventBus) DeepCopy() *EventBus + func (in *EventBus) DeepCopyInto(out *EventBus) + func (in *EventBus) DeepCopyObject() runtime.Object + func (m *EventBus) Marshal() (dAtA []byte, err error) + func (m *EventBus) MarshalTo(dAtA []byte) (int, error) + func (m *EventBus) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *EventBus) Reset() + func (m *EventBus) Size() (n int) + func (m *EventBus) Unmarshal(dAtA []byte) error + func (m *EventBus) XXX_DiscardUnknown() + func (m *EventBus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *EventBus) XXX_Merge(src proto.Message) + func (m *EventBus) XXX_Size() int + func (m *EventBus) XXX_Unmarshal(b []byte) error + func (this *EventBus) String() string + type EventBusList struct + Items []EventBus + func (*EventBusList) Descriptor() ([]byte, []int) + func (*EventBusList) ProtoMessage() + func (in *EventBusList) DeepCopy() *EventBusList + func (in *EventBusList) DeepCopyInto(out *EventBusList) + func (in *EventBusList) DeepCopyObject() runtime.Object + func (m *EventBusList) Marshal() (dAtA []byte, err error) + func (m *EventBusList) MarshalTo(dAtA []byte) (int, error) + func (m *EventBusList) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *EventBusList) Reset() + func (m *EventBusList) Size() (n int) + func (m *EventBusList) Unmarshal(dAtA []byte) error + func (m *EventBusList) XXX_DiscardUnknown() + func (m *EventBusList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *EventBusList) XXX_Merge(src proto.Message) + func (m *EventBusList) XXX_Size() int + func (m *EventBusList) XXX_Unmarshal(b []byte) error + func (this *EventBusList) String() string + type EventBusSpec struct + JetStream *JetStreamBus + JetStreamExotic *JetStreamConfig + Kafka *KafkaBus + NATS *NATSBus + func (*EventBusSpec) Descriptor() ([]byte, []int) + func (*EventBusSpec) ProtoMessage() + func (in *EventBusSpec) DeepCopy() *EventBusSpec + func (in *EventBusSpec) DeepCopyInto(out *EventBusSpec) + func (m *EventBusSpec) Marshal() (dAtA []byte, err error) + func (m *EventBusSpec) MarshalTo(dAtA []byte) (int, error) + func (m *EventBusSpec) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *EventBusSpec) Reset() + func (m *EventBusSpec) Size() (n int) + func (m *EventBusSpec) Unmarshal(dAtA []byte) error + func (m *EventBusSpec) XXX_DiscardUnknown() + func (m *EventBusSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *EventBusSpec) XXX_Merge(src proto.Message) + func (m *EventBusSpec) XXX_Size() int + func (m *EventBusSpec) XXX_Unmarshal(b []byte) error + func (this *EventBusSpec) String() string + type EventBusStatus struct + Config BusConfig + func (*EventBusStatus) Descriptor() ([]byte, []int) + func (*EventBusStatus) ProtoMessage() + func (in *EventBusStatus) DeepCopy() *EventBusStatus + func (in *EventBusStatus) DeepCopyInto(out *EventBusStatus) + func (m *EventBusStatus) Marshal() (dAtA []byte, err error) + func (m *EventBusStatus) MarshalTo(dAtA []byte) (int, error) + func (m *EventBusStatus) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *EventBusStatus) Reset() + func (m *EventBusStatus) Size() (n int) + func (m *EventBusStatus) Unmarshal(dAtA []byte) error + func (m *EventBusStatus) XXX_DiscardUnknown() + func (m *EventBusStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *EventBusStatus) XXX_Merge(src proto.Message) + func (m *EventBusStatus) XXX_Size() int + func (m *EventBusStatus) XXX_Unmarshal(b []byte) error + func (s *EventBusStatus) InitConditions() + func (s *EventBusStatus) MarkConfigured() + func (s *EventBusStatus) MarkDeployFailed(reason, message string) + func (s *EventBusStatus) MarkDeployed(reason, message string) + func (s *EventBusStatus) MarkDeploying(reason, message string) + func (s *EventBusStatus) MarkNotConfigured(reason, message string) + func (this *EventBusStatus) String() string + type EventBusType string + var EventBusJetStream EventBusType = "jetstream" + var EventBusKafka EventBusType = "kafka" + var EventBusNATS EventBusType = "nats" + type EventContext struct + DataContentType string + ID string + Source string + SpecVersion string + Subject string + Time metav1.Time + Type string + func (*EventContext) Descriptor() ([]byte, []int) + func (*EventContext) ProtoMessage() + func (e EventContext) String() string + func (in *EventContext) DeepCopy() *EventContext + func (in *EventContext) DeepCopyInto(out *EventContext) + func (m *EventContext) Marshal() (dAtA []byte, err error) + func (m *EventContext) MarshalTo(dAtA []byte) (int, error) + func (m *EventContext) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *EventContext) Reset() + func (m *EventContext) Size() (n int) + func (m *EventContext) Unmarshal(dAtA []byte) error + func (m *EventContext) XXX_DiscardUnknown() + func (m *EventContext) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *EventContext) XXX_Merge(src proto.Message) + func (m *EventContext) XXX_Size() int + func (m *EventContext) XXX_Unmarshal(b []byte) error + type EventDependency struct + EventName string + EventSourceName string + Filters *EventDependencyFilter + FiltersLogicalOperator LogicalOperator + Name string + Transform *EventDependencyTransformer + func (*EventDependency) Descriptor() ([]byte, []int) + func (*EventDependency) ProtoMessage() + func (in *EventDependency) DeepCopy() *EventDependency + func (in *EventDependency) DeepCopyInto(out *EventDependency) + func (m *EventDependency) Marshal() (dAtA []byte, err error) + func (m *EventDependency) MarshalTo(dAtA []byte) (int, error) + func (m *EventDependency) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *EventDependency) Reset() + func (m *EventDependency) Size() (n int) + func (m *EventDependency) Unmarshal(dAtA []byte) error + func (m *EventDependency) XXX_DiscardUnknown() + func (m *EventDependency) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *EventDependency) XXX_Merge(src proto.Message) + func (m *EventDependency) XXX_Size() int + func (m *EventDependency) XXX_Unmarshal(b []byte) error + func (this *EventDependency) String() string + type EventDependencyFilter struct + Context *EventContext + Data []DataFilter + DataLogicalOperator LogicalOperator + ExprLogicalOperator LogicalOperator + Exprs []ExprFilter + Script string + Time *TimeFilter + func (*EventDependencyFilter) Descriptor() ([]byte, []int) + func (*EventDependencyFilter) ProtoMessage() + func (in *EventDependencyFilter) DeepCopy() *EventDependencyFilter + func (in *EventDependencyFilter) DeepCopyInto(out *EventDependencyFilter) + func (m *EventDependencyFilter) Marshal() (dAtA []byte, err error) + func (m *EventDependencyFilter) MarshalTo(dAtA []byte) (int, error) + func (m *EventDependencyFilter) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *EventDependencyFilter) Reset() + func (m *EventDependencyFilter) Size() (n int) + func (m *EventDependencyFilter) Unmarshal(dAtA []byte) error + func (m *EventDependencyFilter) XXX_DiscardUnknown() + func (m *EventDependencyFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *EventDependencyFilter) XXX_Merge(src proto.Message) + func (m *EventDependencyFilter) XXX_Size() int + func (m *EventDependencyFilter) XXX_Unmarshal(b []byte) error + func (this *EventDependencyFilter) String() string + type EventDependencyTransformer struct + JQ string + Script string + func (*EventDependencyTransformer) Descriptor() ([]byte, []int) + func (*EventDependencyTransformer) ProtoMessage() + func (in *EventDependencyTransformer) DeepCopy() *EventDependencyTransformer + func (in *EventDependencyTransformer) DeepCopyInto(out *EventDependencyTransformer) + func (m *EventDependencyTransformer) Marshal() (dAtA []byte, err error) + func (m *EventDependencyTransformer) MarshalTo(dAtA []byte) (int, error) + func (m *EventDependencyTransformer) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *EventDependencyTransformer) Reset() + func (m *EventDependencyTransformer) Size() (n int) + func (m *EventDependencyTransformer) Unmarshal(dAtA []byte) error + func (m *EventDependencyTransformer) XXX_DiscardUnknown() + func (m *EventDependencyTransformer) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *EventDependencyTransformer) XXX_Merge(src proto.Message) + func (m *EventDependencyTransformer) XXX_Size() int + func (m *EventDependencyTransformer) XXX_Unmarshal(b []byte) error + func (this *EventDependencyTransformer) String() string + type EventPersistence struct + Catchup *CatchupConfiguration + ConfigMap *ConfigMapPersistence + func (*EventPersistence) Descriptor() ([]byte, []int) + func (*EventPersistence) ProtoMessage() + func (ep *EventPersistence) IsCatchUpEnabled() bool + func (in *EventPersistence) DeepCopy() *EventPersistence + func (in *EventPersistence) DeepCopyInto(out *EventPersistence) + func (m *EventPersistence) Marshal() (dAtA []byte, err error) + func (m *EventPersistence) MarshalTo(dAtA []byte) (int, error) + func (m *EventPersistence) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *EventPersistence) Reset() + func (m *EventPersistence) Size() (n int) + func (m *EventPersistence) Unmarshal(dAtA []byte) error + func (m *EventPersistence) XXX_DiscardUnknown() + func (m *EventPersistence) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *EventPersistence) XXX_Merge(src proto.Message) + func (m *EventPersistence) XXX_Size() int + func (m *EventPersistence) XXX_Unmarshal(b []byte) error + func (this *EventPersistence) String() string + type EventSource struct + Spec EventSourceSpec + Status EventSourceStatus + func (*EventSource) Descriptor() ([]byte, []int) + func (*EventSource) ProtoMessage() + func (in *EventSource) DeepCopy() *EventSource + func (in *EventSource) DeepCopyInto(out *EventSource) + func (in *EventSource) DeepCopyObject() runtime.Object + func (m *EventSource) Marshal() (dAtA []byte, err error) + func (m *EventSource) MarshalTo(dAtA []byte) (int, error) + func (m *EventSource) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *EventSource) Reset() + func (m *EventSource) Size() (n int) + func (m *EventSource) Unmarshal(dAtA []byte) error + func (m *EventSource) XXX_DiscardUnknown() + func (m *EventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *EventSource) XXX_Merge(src proto.Message) + func (m *EventSource) XXX_Size() int + func (m *EventSource) XXX_Unmarshal(b []byte) error + func (this *EventSource) String() string + type EventSourceFilter struct + Expression string + func (*EventSourceFilter) Descriptor() ([]byte, []int) + func (*EventSourceFilter) ProtoMessage() + func (in *EventSourceFilter) DeepCopy() *EventSourceFilter + func (in *EventSourceFilter) DeepCopyInto(out *EventSourceFilter) + func (m *EventSourceFilter) Marshal() (dAtA []byte, err error) + func (m *EventSourceFilter) MarshalTo(dAtA []byte) (int, error) + func (m *EventSourceFilter) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *EventSourceFilter) Reset() + func (m *EventSourceFilter) Size() (n int) + func (m *EventSourceFilter) Unmarshal(dAtA []byte) error + func (m *EventSourceFilter) XXX_DiscardUnknown() + func (m *EventSourceFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *EventSourceFilter) XXX_Merge(src proto.Message) + func (m *EventSourceFilter) XXX_Size() int + func (m *EventSourceFilter) XXX_Unmarshal(b []byte) error + func (this *EventSourceFilter) String() string + type EventSourceList struct + Items []EventSource + func (*EventSourceList) Descriptor() ([]byte, []int) + func (*EventSourceList) ProtoMessage() + func (in *EventSourceList) DeepCopy() *EventSourceList + func (in *EventSourceList) DeepCopyInto(out *EventSourceList) + func (in *EventSourceList) DeepCopyObject() runtime.Object + func (m *EventSourceList) Marshal() (dAtA []byte, err error) + func (m *EventSourceList) MarshalTo(dAtA []byte) (int, error) + func (m *EventSourceList) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *EventSourceList) Reset() + func (m *EventSourceList) Size() (n int) + func (m *EventSourceList) Unmarshal(dAtA []byte) error + func (m *EventSourceList) XXX_DiscardUnknown() + func (m *EventSourceList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *EventSourceList) XXX_Merge(src proto.Message) + func (m *EventSourceList) XXX_Size() int + func (m *EventSourceList) XXX_Unmarshal(b []byte) error + func (this *EventSourceList) String() string + type EventSourceSpec struct + AMQP map[string]AMQPEventSource + AzureEventsHub map[string]AzureEventsHubEventSource + AzureQueueStorage map[string]AzureQueueStorageEventSource + AzureServiceBus map[string]AzureServiceBusEventSource + Bitbucket map[string]BitbucketEventSource + BitbucketServer map[string]BitbucketServerEventSource + Calendar map[string]CalendarEventSource + Emitter map[string]EmitterEventSource + EventBusName string + File map[string]FileEventSource + Generic map[string]GenericEventSource + Gerrit map[string]GerritEventSource + Github map[string]GithubEventSource + Gitlab map[string]GitlabEventSource + HDFS map[string]HDFSEventSource + Kafka map[string]KafkaEventSource + MQTT map[string]MQTTEventSource + Minio map[string]S3Artifact + NATS map[string]NATSEventsSource + NSQ map[string]NSQEventSource + PubSub map[string]PubSubEventSource + Pulsar map[string]PulsarEventSource + Redis map[string]RedisEventSource + RedisStream map[string]RedisStreamEventSource + Replicas *int32 + Resource map[string]ResourceEventSource + SFTP map[string]SFTPEventSource + SNS map[string]SNSEventSource + SQS map[string]SQSEventSource + Service *Service + Slack map[string]SlackEventSource + StorageGrid map[string]StorageGridEventSource + Stripe map[string]StripeEventSource + Template *Template + Webhook map[string]WebhookEventSource + func (*EventSourceSpec) Descriptor() ([]byte, []int) + func (*EventSourceSpec) ProtoMessage() + func (e EventSourceSpec) GetReplicas() int32 + func (in *EventSourceSpec) DeepCopy() *EventSourceSpec + func (in *EventSourceSpec) DeepCopyInto(out *EventSourceSpec) + func (m *EventSourceSpec) Marshal() (dAtA []byte, err error) + func (m *EventSourceSpec) MarshalTo(dAtA []byte) (int, error) + func (m *EventSourceSpec) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *EventSourceSpec) Reset() + func (m *EventSourceSpec) Size() (n int) + func (m *EventSourceSpec) Unmarshal(dAtA []byte) error + func (m *EventSourceSpec) XXX_DiscardUnknown() + func (m *EventSourceSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *EventSourceSpec) XXX_Merge(src proto.Message) + func (m *EventSourceSpec) XXX_Size() int + func (m *EventSourceSpec) XXX_Unmarshal(b []byte) error + func (this *EventSourceSpec) String() string + type EventSourceStatus struct + func (*EventSourceStatus) Descriptor() ([]byte, []int) + func (*EventSourceStatus) ProtoMessage() + func (es *EventSourceStatus) InitConditions() + func (es *EventSourceStatus) MarkDeployFailed(reason, message string) + func (es *EventSourceStatus) MarkDeployed() + func (es *EventSourceStatus) MarkSourcesNotProvided(reason, message string) + func (es *EventSourceStatus) MarkSourcesProvided() + func (in *EventSourceStatus) DeepCopy() *EventSourceStatus + func (in *EventSourceStatus) DeepCopyInto(out *EventSourceStatus) + func (m *EventSourceStatus) Marshal() (dAtA []byte, err error) + func (m *EventSourceStatus) MarshalTo(dAtA []byte) (int, error) + func (m *EventSourceStatus) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *EventSourceStatus) Reset() + func (m *EventSourceStatus) Size() (n int) + func (m *EventSourceStatus) Unmarshal(dAtA []byte) error + func (m *EventSourceStatus) XXX_DiscardUnknown() + func (m *EventSourceStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *EventSourceStatus) XXX_Merge(src proto.Message) + func (m *EventSourceStatus) XXX_Size() int + func (m *EventSourceStatus) XXX_Unmarshal(b []byte) error + func (this *EventSourceStatus) String() string + type EventSourceType string + var AMQPEvent EventSourceType = "amqp" + var AzureEventsHub EventSourceType = "azureEventsHub" + var AzureQueueStorage EventSourceType = "azureQueueStorage" + var AzureServiceBus EventSourceType = "azureServiceBus" + var BitbucketEvent EventSourceType = "bitbucket" + var BitbucketServerEvent EventSourceType = "bitbucketserver" + var CalendarEvent EventSourceType = "calendar" + var EmitterEvent EventSourceType = "emitter" + var FileEvent EventSourceType = "file" + var GenericEvent EventSourceType = "generic" + var GerritEvent EventSourceType = "gerrit" + var GithubEvent EventSourceType = "github" + var GitlabEvent EventSourceType = "gitlab" + var HDFSEvent EventSourceType = "hdfs" + var KafkaEvent EventSourceType = "kafka" + var MQTTEvent EventSourceType = "mqtt" + var MinioEvent EventSourceType = "minio" + var NATSEvent EventSourceType = "nats" + var NSQEvent EventSourceType = "nsq" + var PubSubEvent EventSourceType = "pubsub" + var PulsarEvent EventSourceType = "pulsar" + var RedisEvent EventSourceType = "redis" + var RedisStreamEvent EventSourceType = "redisStream" + var ResourceEvent EventSourceType = "resource" + var SFTPEvent EventSourceType = "sftp" + var SNSEvent EventSourceType = "sns" + var SQSEvent EventSourceType = "sqs" + var SlackEvent EventSourceType = "slack" + var StorageGridEvent EventSourceType = "storagegrid" + var StripeEvent EventSourceType = "stripe" + var WebhookEvent EventSourceType = "webhook" + type ExprFilter struct + Expr string + Fields []PayloadField + func (*ExprFilter) Descriptor() ([]byte, []int) + func (*ExprFilter) ProtoMessage() + func (in *ExprFilter) DeepCopy() *ExprFilter + func (in *ExprFilter) DeepCopyInto(out *ExprFilter) + func (m *ExprFilter) Marshal() (dAtA []byte, err error) + func (m *ExprFilter) MarshalTo(dAtA []byte) (int, error) + func (m *ExprFilter) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ExprFilter) Reset() + func (m *ExprFilter) Size() (n int) + func (m *ExprFilter) Unmarshal(dAtA []byte) error + func (m *ExprFilter) XXX_DiscardUnknown() + func (m *ExprFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ExprFilter) XXX_Merge(src proto.Message) + func (m *ExprFilter) XXX_Size() int + func (m *ExprFilter) XXX_Unmarshal(b []byte) error + func (this *ExprFilter) String() string + type FileArtifact struct + Path string + func (*FileArtifact) Descriptor() ([]byte, []int) + func (*FileArtifact) ProtoMessage() + func (in *FileArtifact) DeepCopy() *FileArtifact + func (in *FileArtifact) DeepCopyInto(out *FileArtifact) + func (m *FileArtifact) Marshal() (dAtA []byte, err error) + func (m *FileArtifact) MarshalTo(dAtA []byte) (int, error) + func (m *FileArtifact) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *FileArtifact) Reset() + func (m *FileArtifact) Size() (n int) + func (m *FileArtifact) Unmarshal(dAtA []byte) error + func (m *FileArtifact) XXX_DiscardUnknown() + func (m *FileArtifact) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *FileArtifact) XXX_Merge(src proto.Message) + func (m *FileArtifact) XXX_Size() int + func (m *FileArtifact) XXX_Unmarshal(b []byte) error + func (this *FileArtifact) String() string + type FileEventSource struct + EventType string + Filter *EventSourceFilter + Metadata map[string]string + Polling bool + WatchPathConfig WatchPathConfig + func (*FileEventSource) Descriptor() ([]byte, []int) + func (*FileEventSource) ProtoMessage() + func (in *FileEventSource) DeepCopy() *FileEventSource + func (in *FileEventSource) DeepCopyInto(out *FileEventSource) + func (m *FileEventSource) Marshal() (dAtA []byte, err error) + func (m *FileEventSource) MarshalTo(dAtA []byte) (int, error) + func (m *FileEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *FileEventSource) Reset() + func (m *FileEventSource) Size() (n int) + func (m *FileEventSource) Unmarshal(dAtA []byte) error + func (m *FileEventSource) XXX_DiscardUnknown() + func (m *FileEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *FileEventSource) XXX_Merge(src proto.Message) + func (m *FileEventSource) XXX_Size() int + func (m *FileEventSource) XXX_Unmarshal(b []byte) error + func (this *FileEventSource) String() string + type GenericEventSource struct + AuthSecret *corev1.SecretKeySelector + Config string + Filter *EventSourceFilter + Insecure bool + JSONBody bool + Metadata map[string]string + URL string + func (*GenericEventSource) Descriptor() ([]byte, []int) + func (*GenericEventSource) ProtoMessage() + func (in *GenericEventSource) DeepCopy() *GenericEventSource + func (in *GenericEventSource) DeepCopyInto(out *GenericEventSource) + func (m *GenericEventSource) Marshal() (dAtA []byte, err error) + func (m *GenericEventSource) MarshalTo(dAtA []byte) (int, error) + func (m *GenericEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GenericEventSource) Reset() + func (m *GenericEventSource) Size() (n int) + func (m *GenericEventSource) Unmarshal(dAtA []byte) error + func (m *GenericEventSource) XXX_DiscardUnknown() + func (m *GenericEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GenericEventSource) XXX_Merge(src proto.Message) + func (m *GenericEventSource) XXX_Size() int + func (m *GenericEventSource) XXX_Unmarshal(b []byte) error + func (this *GenericEventSource) String() string + type GerritEventSource struct + Auth *BasicAuth + DeleteHookOnFinish bool + Events []string + Filter *EventSourceFilter + GerritBaseURL string + HookName string + Metadata map[string]string + Projects []string + SslVerify bool + Webhook *WebhookContext + func (*GerritEventSource) Descriptor() ([]byte, []int) + func (*GerritEventSource) ProtoMessage() + func (g GerritEventSource) NeedToCreateHooks() bool + func (in *GerritEventSource) DeepCopy() *GerritEventSource + func (in *GerritEventSource) DeepCopyInto(out *GerritEventSource) + func (m *GerritEventSource) Marshal() (dAtA []byte, err error) + func (m *GerritEventSource) MarshalTo(dAtA []byte) (int, error) + func (m *GerritEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GerritEventSource) Reset() + func (m *GerritEventSource) Size() (n int) + func (m *GerritEventSource) Unmarshal(dAtA []byte) error + func (m *GerritEventSource) XXX_DiscardUnknown() + func (m *GerritEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GerritEventSource) XXX_Merge(src proto.Message) + func (m *GerritEventSource) XXX_Size() int + func (m *GerritEventSource) XXX_Unmarshal(b []byte) error + func (this *GerritEventSource) String() string + type GitArtifact struct + Branch string + CloneDirectory string + Creds *GitCreds + FilePath string + InsecureIgnoreHostKey bool + Ref string + Remote *GitRemoteConfig + SSHKeySecret *corev1.SecretKeySelector + Tag string + URL string + func (*GitArtifact) Descriptor() ([]byte, []int) + func (*GitArtifact) ProtoMessage() + func (in *GitArtifact) DeepCopy() *GitArtifact + func (in *GitArtifact) DeepCopyInto(out *GitArtifact) + func (m *GitArtifact) Marshal() (dAtA []byte, err error) + func (m *GitArtifact) MarshalTo(dAtA []byte) (int, error) + func (m *GitArtifact) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GitArtifact) Reset() + func (m *GitArtifact) Size() (n int) + func (m *GitArtifact) Unmarshal(dAtA []byte) error + func (m *GitArtifact) XXX_DiscardUnknown() + func (m *GitArtifact) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GitArtifact) XXX_Merge(src proto.Message) + func (m *GitArtifact) XXX_Size() int + func (m *GitArtifact) XXX_Unmarshal(b []byte) error + func (this *GitArtifact) String() string + type GitCreds struct + Password *corev1.SecretKeySelector + Username *corev1.SecretKeySelector + func (*GitCreds) Descriptor() ([]byte, []int) + func (*GitCreds) ProtoMessage() + func (in *GitCreds) DeepCopy() *GitCreds + func (in *GitCreds) DeepCopyInto(out *GitCreds) + func (m *GitCreds) Marshal() (dAtA []byte, err error) + func (m *GitCreds) MarshalTo(dAtA []byte) (int, error) + func (m *GitCreds) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GitCreds) Reset() + func (m *GitCreds) Size() (n int) + func (m *GitCreds) Unmarshal(dAtA []byte) error + func (m *GitCreds) XXX_DiscardUnknown() + func (m *GitCreds) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GitCreds) XXX_Merge(src proto.Message) + func (m *GitCreds) XXX_Size() int + func (m *GitCreds) XXX_Unmarshal(b []byte) error + func (this *GitCreds) String() string + type GitRemoteConfig struct + Name string + URLS []string + func (*GitRemoteConfig) Descriptor() ([]byte, []int) + func (*GitRemoteConfig) ProtoMessage() + func (in *GitRemoteConfig) DeepCopy() *GitRemoteConfig + func (in *GitRemoteConfig) DeepCopyInto(out *GitRemoteConfig) + func (m *GitRemoteConfig) Marshal() (dAtA []byte, err error) + func (m *GitRemoteConfig) MarshalTo(dAtA []byte) (int, error) + func (m *GitRemoteConfig) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GitRemoteConfig) Reset() + func (m *GitRemoteConfig) Size() (n int) + func (m *GitRemoteConfig) Unmarshal(dAtA []byte) error + func (m *GitRemoteConfig) XXX_DiscardUnknown() + func (m *GitRemoteConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GitRemoteConfig) XXX_Merge(src proto.Message) + func (m *GitRemoteConfig) XXX_Size() int + func (m *GitRemoteConfig) XXX_Unmarshal(b []byte) error + func (this *GitRemoteConfig) String() string + type GithubAppCreds struct + AppID int64 + InstallationID int64 + PrivateKey *corev1.SecretKeySelector + func (*GithubAppCreds) Descriptor() ([]byte, []int) + func (*GithubAppCreds) ProtoMessage() + func (in *GithubAppCreds) DeepCopy() *GithubAppCreds + func (in *GithubAppCreds) DeepCopyInto(out *GithubAppCreds) + func (m *GithubAppCreds) Marshal() (dAtA []byte, err error) + func (m *GithubAppCreds) MarshalTo(dAtA []byte) (int, error) + func (m *GithubAppCreds) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GithubAppCreds) Reset() + func (m *GithubAppCreds) Size() (n int) + func (m *GithubAppCreds) Unmarshal(dAtA []byte) error + func (m *GithubAppCreds) XXX_DiscardUnknown() + func (m *GithubAppCreds) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GithubAppCreds) XXX_Merge(src proto.Message) + func (m *GithubAppCreds) XXX_Size() int + func (m *GithubAppCreds) XXX_Unmarshal(b []byte) error + func (this *GithubAppCreds) String() string + type GithubEventSource struct + APIToken *corev1.SecretKeySelector + Active bool + ContentType string + DeleteHookOnFinish bool + DeprecatedOwner string + DeprecatedRepository string + Events []string + Filter *EventSourceFilter + GithubApp *GithubAppCreds + GithubBaseURL string + GithubUploadURL string + ID int64 + Insecure bool + Metadata map[string]string + Organizations []string + Repositories []OwnedRepositories + Webhook *WebhookContext + WebhookSecret *corev1.SecretKeySelector + func (*GithubEventSource) Descriptor() ([]byte, []int) + func (*GithubEventSource) ProtoMessage() + func (g GithubEventSource) GetOwnedRepositories() []OwnedRepositories + func (g GithubEventSource) HasConfiguredWebhook() bool + func (g GithubEventSource) HasGithubAPIToken() bool + func (g GithubEventSource) HasGithubAppCreds() bool + func (g GithubEventSource) NeedToCreateHooks() bool + func (in *GithubEventSource) DeepCopy() *GithubEventSource + func (in *GithubEventSource) DeepCopyInto(out *GithubEventSource) + func (m *GithubEventSource) Marshal() (dAtA []byte, err error) + func (m *GithubEventSource) MarshalTo(dAtA []byte) (int, error) + func (m *GithubEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GithubEventSource) Reset() + func (m *GithubEventSource) Size() (n int) + func (m *GithubEventSource) Unmarshal(dAtA []byte) error + func (m *GithubEventSource) XXX_DiscardUnknown() + func (m *GithubEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GithubEventSource) XXX_Merge(src proto.Message) + func (m *GithubEventSource) XXX_Size() int + func (m *GithubEventSource) XXX_Unmarshal(b []byte) error + func (this *GithubEventSource) String() string + type GitlabEventSource struct + AccessToken *corev1.SecretKeySelector + DeleteHookOnFinish bool + DeprecatedProjectID string + EnableSSLVerification bool + Events []string + Filter *EventSourceFilter + GitlabBaseURL string + Groups []string + Metadata map[string]string + Projects []string + SecretToken *corev1.SecretKeySelector + Webhook *WebhookContext + func (*GitlabEventSource) Descriptor() ([]byte, []int) + func (*GitlabEventSource) ProtoMessage() + func (g GitlabEventSource) GetGroups() []string + func (g GitlabEventSource) GetProjects() []string + func (g GitlabEventSource) NeedToCreateHooks() bool + func (in *GitlabEventSource) DeepCopy() *GitlabEventSource + func (in *GitlabEventSource) DeepCopyInto(out *GitlabEventSource) + func (m *GitlabEventSource) Marshal() (dAtA []byte, err error) + func (m *GitlabEventSource) MarshalTo(dAtA []byte) (int, error) + func (m *GitlabEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GitlabEventSource) Reset() + func (m *GitlabEventSource) Size() (n int) + func (m *GitlabEventSource) Unmarshal(dAtA []byte) error + func (m *GitlabEventSource) XXX_DiscardUnknown() + func (m *GitlabEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GitlabEventSource) XXX_Merge(src proto.Message) + func (m *GitlabEventSource) XXX_Size() int + func (m *GitlabEventSource) XXX_Unmarshal(b []byte) error + func (this *GitlabEventSource) String() string + type HDFSEventSource struct + Addresses []string + CheckInterval string + Filter *EventSourceFilter + HDFSUser string + KrbCCacheSecret *corev1.SecretKeySelector + KrbConfigConfigMap *corev1.ConfigMapKeySelector + KrbKeytabSecret *corev1.SecretKeySelector + KrbRealm string + KrbServicePrincipalName string + KrbUsername string + Metadata map[string]string + Type string + func (*HDFSEventSource) Descriptor() ([]byte, []int) + func (*HDFSEventSource) ProtoMessage() + func (in *HDFSEventSource) DeepCopy() *HDFSEventSource + func (in *HDFSEventSource) DeepCopyInto(out *HDFSEventSource) + func (m *HDFSEventSource) Marshal() (dAtA []byte, err error) + func (m *HDFSEventSource) MarshalTo(dAtA []byte) (int, error) + func (m *HDFSEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *HDFSEventSource) Reset() + func (m *HDFSEventSource) Size() (n int) + func (m *HDFSEventSource) Unmarshal(dAtA []byte) error + func (m *HDFSEventSource) XXX_DiscardUnknown() + func (m *HDFSEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *HDFSEventSource) XXX_Merge(src proto.Message) + func (m *HDFSEventSource) XXX_Size() int + func (m *HDFSEventSource) XXX_Unmarshal(b []byte) error + func (this *HDFSEventSource) String() string + type HTTPTrigger struct + BasicAuth *BasicAuth + Headers map[string]string + Method string + Parameters []TriggerParameter + Payload []TriggerParameter + SecureHeaders []*SecureHeader + TLS *TLSConfig + Timeout int64 + URL string + func (*HTTPTrigger) Descriptor() ([]byte, []int) + func (*HTTPTrigger) ProtoMessage() + func (in *HTTPTrigger) DeepCopy() *HTTPTrigger + func (in *HTTPTrigger) DeepCopyInto(out *HTTPTrigger) + func (m *HTTPTrigger) Marshal() (dAtA []byte, err error) + func (m *HTTPTrigger) MarshalTo(dAtA []byte) (int, error) + func (m *HTTPTrigger) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *HTTPTrigger) Reset() + func (m *HTTPTrigger) Size() (n int) + func (m *HTTPTrigger) Unmarshal(dAtA []byte) error + func (m *HTTPTrigger) XXX_DiscardUnknown() + func (m *HTTPTrigger) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *HTTPTrigger) XXX_Merge(src proto.Message) + func (m *HTTPTrigger) XXX_Size() int + func (m *HTTPTrigger) XXX_Unmarshal(b []byte) error + func (this *HTTPTrigger) String() string + type Int64OrString struct + Int64Val int64 + StrVal string + Type Type + func FromInt64(val int64) Int64OrString + func FromString(val string) Int64OrString + func Parse(val string) Int64OrString + func (*Int64OrString) Descriptor() ([]byte, []int) + func (*Int64OrString) ProtoMessage() + func (Int64OrString) OpenAPISchemaFormat() string + func (Int64OrString) OpenAPISchemaType() []string + func (in *Int64OrString) DeepCopy() *Int64OrString + func (in *Int64OrString) DeepCopyInto(out *Int64OrString) + func (int64str *Int64OrString) Int64Value() int64 + func (int64str *Int64OrString) UnmarshalJSON(value []byte) error + func (int64str Int64OrString) MarshalJSON() ([]byte, error) + func (m *Int64OrString) Marshal() (dAtA []byte, err error) + func (m *Int64OrString) MarshalTo(dAtA []byte) (int, error) + func (m *Int64OrString) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Int64OrString) Reset() + func (m *Int64OrString) Size() (n int) + func (m *Int64OrString) Unmarshal(dAtA []byte) error + func (m *Int64OrString) XXX_DiscardUnknown() + func (m *Int64OrString) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Int64OrString) XXX_Merge(src proto.Message) + func (m *Int64OrString) XXX_Size() int + func (m *Int64OrString) XXX_Unmarshal(b []byte) error + func (this *Int64OrString) String() string + type JSONType string + const JSONTypeBool + const JSONTypeNumber + const JSONTypeString + type JetStreamBus struct + Affinity *corev1.Affinity + ContainerTemplate *ContainerTemplate + ImagePullSecrets []corev1.LocalObjectReference + MaxPayload *string + Metadata *Metadata + MetricsContainerTemplate *ContainerTemplate + NodeSelector map[string]string + Persistence *PersistenceStrategy + Priority *int32 + PriorityClassName string + ReloaderContainerTemplate *ContainerTemplate + Replicas *int32 + SecurityContext *corev1.PodSecurityContext + ServiceAccountName string + Settings *string + StartArgs []string + StreamConfig *string + Tolerations []corev1.Toleration + Version string + func (*JetStreamBus) Descriptor() ([]byte, []int) + func (*JetStreamBus) ProtoMessage() + func (in *JetStreamBus) DeepCopy() *JetStreamBus + func (in *JetStreamBus) DeepCopyInto(out *JetStreamBus) + func (j JetStreamBus) GetReplicas() int + func (m *JetStreamBus) Marshal() (dAtA []byte, err error) + func (m *JetStreamBus) MarshalTo(dAtA []byte) (int, error) + func (m *JetStreamBus) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *JetStreamBus) Reset() + func (m *JetStreamBus) Size() (n int) + func (m *JetStreamBus) Unmarshal(dAtA []byte) error + func (m *JetStreamBus) XXX_DiscardUnknown() + func (m *JetStreamBus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *JetStreamBus) XXX_Merge(src proto.Message) + func (m *JetStreamBus) XXX_Size() int + func (m *JetStreamBus) XXX_Unmarshal(b []byte) error + func (this *JetStreamBus) String() string + type JetStreamConfig struct + AccessSecret *corev1.SecretKeySelector + StreamConfig string + URL string + func (*JetStreamConfig) Descriptor() ([]byte, []int) + func (*JetStreamConfig) ProtoMessage() + func (in *JetStreamConfig) DeepCopy() *JetStreamConfig + func (in *JetStreamConfig) DeepCopyInto(out *JetStreamConfig) + func (m *JetStreamConfig) Marshal() (dAtA []byte, err error) + func (m *JetStreamConfig) MarshalTo(dAtA []byte) (int, error) + func (m *JetStreamConfig) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *JetStreamConfig) Reset() + func (m *JetStreamConfig) Size() (n int) + func (m *JetStreamConfig) Unmarshal(dAtA []byte) error + func (m *JetStreamConfig) XXX_DiscardUnknown() + func (m *JetStreamConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *JetStreamConfig) XXX_Merge(src proto.Message) + func (m *JetStreamConfig) XXX_Size() int + func (m *JetStreamConfig) XXX_Unmarshal(b []byte) error + func (this *JetStreamConfig) String() string + type K8SResource struct + Value []byte + func NewK8SResource(s interface{}) K8SResource + func (*K8SResource) Descriptor() ([]byte, []int) + func (*K8SResource) ProtoMessage() + func (a *K8SResource) UnmarshalJSON(value []byte) error + func (in *K8SResource) DeepCopy() *K8SResource + func (in *K8SResource) DeepCopyInto(out *K8SResource) + func (m *K8SResource) Marshal() (dAtA []byte, err error) + func (m *K8SResource) MarshalTo(dAtA []byte) (int, error) + func (m *K8SResource) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *K8SResource) Reset() + func (m *K8SResource) Size() (n int) + func (m *K8SResource) Unmarshal(dAtA []byte) error + func (m *K8SResource) XXX_DiscardUnknown() + func (m *K8SResource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *K8SResource) XXX_Merge(src proto.Message) + func (m *K8SResource) XXX_Size() int + func (m *K8SResource) XXX_Unmarshal(b []byte) error + func (n K8SResource) MarshalJSON() ([]byte, error) + func (n K8SResource) OpenAPISchemaFormat() string + func (n K8SResource) OpenAPISchemaType() []string + func (this *K8SResource) String() string + type K8SResourcePolicy struct + Backoff *Backoff + ErrorOnBackoffTimeout bool + Labels map[string]string + func (*K8SResourcePolicy) Descriptor() ([]byte, []int) + func (*K8SResourcePolicy) ProtoMessage() + func (in *K8SResourcePolicy) DeepCopy() *K8SResourcePolicy + func (in *K8SResourcePolicy) DeepCopyInto(out *K8SResourcePolicy) + func (m *K8SResourcePolicy) Marshal() (dAtA []byte, err error) + func (m *K8SResourcePolicy) MarshalTo(dAtA []byte) (int, error) + func (m *K8SResourcePolicy) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *K8SResourcePolicy) Reset() + func (m *K8SResourcePolicy) Size() (n int) + func (m *K8SResourcePolicy) Unmarshal(dAtA []byte) error + func (m *K8SResourcePolicy) XXX_DiscardUnknown() + func (m *K8SResourcePolicy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *K8SResourcePolicy) XXX_Merge(src proto.Message) + func (m *K8SResourcePolicy) XXX_Size() int + func (m *K8SResourcePolicy) XXX_Unmarshal(b []byte) error + func (this *K8SResourcePolicy) String() string + type KafkaBus struct + ConsumerGroup *KafkaConsumerGroup + SASL *SASLConfig + TLS *TLSConfig + Topic string + URL string + Version string + func (*KafkaBus) Descriptor() ([]byte, []int) + func (*KafkaBus) ProtoMessage() + func (in *KafkaBus) DeepCopy() *KafkaBus + func (in *KafkaBus) DeepCopyInto(out *KafkaBus) + func (m *KafkaBus) Marshal() (dAtA []byte, err error) + func (m *KafkaBus) MarshalTo(dAtA []byte) (int, error) + func (m *KafkaBus) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *KafkaBus) Reset() + func (m *KafkaBus) Size() (n int) + func (m *KafkaBus) Unmarshal(dAtA []byte) error + func (m *KafkaBus) XXX_DiscardUnknown() + func (m *KafkaBus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *KafkaBus) XXX_Merge(src proto.Message) + func (m *KafkaBus) XXX_Size() int + func (m *KafkaBus) XXX_Unmarshal(b []byte) error + func (this *KafkaBus) String() string + type KafkaConsumerGroup struct + GroupName string + Oldest bool + RebalanceStrategy string + func (*KafkaConsumerGroup) Descriptor() ([]byte, []int) + func (*KafkaConsumerGroup) ProtoMessage() + func (in *KafkaConsumerGroup) DeepCopy() *KafkaConsumerGroup + func (in *KafkaConsumerGroup) DeepCopyInto(out *KafkaConsumerGroup) + func (m *KafkaConsumerGroup) Marshal() (dAtA []byte, err error) + func (m *KafkaConsumerGroup) MarshalTo(dAtA []byte) (int, error) + func (m *KafkaConsumerGroup) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *KafkaConsumerGroup) Reset() + func (m *KafkaConsumerGroup) Size() (n int) + func (m *KafkaConsumerGroup) Unmarshal(dAtA []byte) error + func (m *KafkaConsumerGroup) XXX_DiscardUnknown() + func (m *KafkaConsumerGroup) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *KafkaConsumerGroup) XXX_Merge(src proto.Message) + func (m *KafkaConsumerGroup) XXX_Size() int + func (m *KafkaConsumerGroup) XXX_Unmarshal(b []byte) error + func (this *KafkaConsumerGroup) String() string + type KafkaEventSource struct + Config string + ConnectionBackoff *Backoff + ConsumerGroup *KafkaConsumerGroup + Filter *EventSourceFilter + JSONBody bool + LimitEventsPerSecond int64 + Metadata map[string]string + Partition string + SASL *SASLConfig + TLS *TLSConfig + Topic string + URL string + Version string + func (*KafkaEventSource) Descriptor() ([]byte, []int) + func (*KafkaEventSource) ProtoMessage() + func (in *KafkaEventSource) DeepCopy() *KafkaEventSource + func (in *KafkaEventSource) DeepCopyInto(out *KafkaEventSource) + func (m *KafkaEventSource) Marshal() (dAtA []byte, err error) + func (m *KafkaEventSource) MarshalTo(dAtA []byte) (int, error) + func (m *KafkaEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *KafkaEventSource) Reset() + func (m *KafkaEventSource) Size() (n int) + func (m *KafkaEventSource) Unmarshal(dAtA []byte) error + func (m *KafkaEventSource) XXX_DiscardUnknown() + func (m *KafkaEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *KafkaEventSource) XXX_Merge(src proto.Message) + func (m *KafkaEventSource) XXX_Size() int + func (m *KafkaEventSource) XXX_Unmarshal(b []byte) error + func (this *KafkaEventSource) String() string + type KafkaTrigger struct + Compress bool + FlushFrequency int32 + Headers map[string]string + Parameters []TriggerParameter + Partition int32 + PartitioningKey *string + Payload []TriggerParameter + RequiredAcks int32 + SASL *SASLConfig + SchemaRegistry *SchemaRegistryConfig + SecureHeaders []*SecureHeader + TLS *TLSConfig + Topic string + URL string + Version string + func (*KafkaTrigger) Descriptor() ([]byte, []int) + func (*KafkaTrigger) ProtoMessage() + func (in *KafkaTrigger) DeepCopy() *KafkaTrigger + func (in *KafkaTrigger) DeepCopyInto(out *KafkaTrigger) + func (m *KafkaTrigger) Marshal() (dAtA []byte, err error) + func (m *KafkaTrigger) MarshalTo(dAtA []byte) (int, error) + func (m *KafkaTrigger) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *KafkaTrigger) Reset() + func (m *KafkaTrigger) Size() (n int) + func (m *KafkaTrigger) Unmarshal(dAtA []byte) error + func (m *KafkaTrigger) XXX_DiscardUnknown() + func (m *KafkaTrigger) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *KafkaTrigger) XXX_Merge(src proto.Message) + func (m *KafkaTrigger) XXX_Size() int + func (m *KafkaTrigger) XXX_Unmarshal(b []byte) error + func (this *KafkaTrigger) String() string + type KubernetesResourceOperation string + const Create + const Delete + const Patch + const Update + type LogTrigger struct + IntervalSeconds uint64 + func (*LogTrigger) Descriptor() ([]byte, []int) + func (*LogTrigger) ProtoMessage() + func (in *LogTrigger) DeepCopy() *LogTrigger + func (in *LogTrigger) DeepCopyInto(out *LogTrigger) + func (in *LogTrigger) GetInterval() time.Duration + func (m *LogTrigger) Marshal() (dAtA []byte, err error) + func (m *LogTrigger) MarshalTo(dAtA []byte) (int, error) + func (m *LogTrigger) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *LogTrigger) Reset() + func (m *LogTrigger) Size() (n int) + func (m *LogTrigger) Unmarshal(dAtA []byte) error + func (m *LogTrigger) XXX_DiscardUnknown() + func (m *LogTrigger) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *LogTrigger) XXX_Merge(src proto.Message) + func (m *LogTrigger) XXX_Size() int + func (m *LogTrigger) XXX_Unmarshal(b []byte) error + func (this *LogTrigger) String() string + type LogicalOperator string + const AndLogicalOperator + const EmptyLogicalOperator + const OrLogicalOperator + type MQTTEventSource struct + Auth *BasicAuth + ClientID string + ConnectionBackoff *Backoff + Filter *EventSourceFilter + JSONBody bool + Metadata map[string]string + TLS *TLSConfig + Topic string + URL string + func (*MQTTEventSource) Descriptor() ([]byte, []int) + func (*MQTTEventSource) ProtoMessage() + func (in *MQTTEventSource) DeepCopy() *MQTTEventSource + func (in *MQTTEventSource) DeepCopyInto(out *MQTTEventSource) + func (m *MQTTEventSource) Marshal() (dAtA []byte, err error) + func (m *MQTTEventSource) MarshalTo(dAtA []byte) (int, error) + func (m *MQTTEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *MQTTEventSource) Reset() + func (m *MQTTEventSource) Size() (n int) + func (m *MQTTEventSource) Unmarshal(dAtA []byte) error + func (m *MQTTEventSource) XXX_DiscardUnknown() + func (m *MQTTEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MQTTEventSource) XXX_Merge(src proto.Message) + func (m *MQTTEventSource) XXX_Size() int + func (m *MQTTEventSource) XXX_Unmarshal(b []byte) error + func (this *MQTTEventSource) String() string + type Metadata struct + Annotations map[string]string + Labels map[string]string + func (*Metadata) Descriptor() ([]byte, []int) + func (*Metadata) ProtoMessage() + func (in *Metadata) DeepCopy() *Metadata + func (in *Metadata) DeepCopyInto(out *Metadata) + func (m *Metadata) Marshal() (dAtA []byte, err error) + func (m *Metadata) MarshalTo(dAtA []byte) (int, error) + func (m *Metadata) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Metadata) Reset() + func (m *Metadata) Size() (n int) + func (m *Metadata) Unmarshal(dAtA []byte) error + func (m *Metadata) XXX_DiscardUnknown() + func (m *Metadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Metadata) XXX_Merge(src proto.Message) + func (m *Metadata) XXX_Size() int + func (m *Metadata) XXX_Unmarshal(b []byte) error + func (this *Metadata) String() string + type NATSAuth struct + Basic *BasicAuth + Credential *corev1.SecretKeySelector + NKey *corev1.SecretKeySelector + Token *corev1.SecretKeySelector + func (*NATSAuth) Descriptor() ([]byte, []int) + func (*NATSAuth) ProtoMessage() + func (in *NATSAuth) DeepCopy() *NATSAuth + func (in *NATSAuth) DeepCopyInto(out *NATSAuth) + func (m *NATSAuth) Marshal() (dAtA []byte, err error) + func (m *NATSAuth) MarshalTo(dAtA []byte) (int, error) + func (m *NATSAuth) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *NATSAuth) Reset() + func (m *NATSAuth) Size() (n int) + func (m *NATSAuth) Unmarshal(dAtA []byte) error + func (m *NATSAuth) XXX_DiscardUnknown() + func (m *NATSAuth) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *NATSAuth) XXX_Merge(src proto.Message) + func (m *NATSAuth) XXX_Size() int + func (m *NATSAuth) XXX_Unmarshal(b []byte) error + func (this *NATSAuth) String() string + type NATSBus struct + Exotic *NATSConfig + Native *NativeStrategy + func (*NATSBus) Descriptor() ([]byte, []int) + func (*NATSBus) ProtoMessage() + func (in *NATSBus) DeepCopy() *NATSBus + func (in *NATSBus) DeepCopyInto(out *NATSBus) + func (m *NATSBus) Marshal() (dAtA []byte, err error) + func (m *NATSBus) MarshalTo(dAtA []byte) (int, error) + func (m *NATSBus) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *NATSBus) Reset() + func (m *NATSBus) Size() (n int) + func (m *NATSBus) Unmarshal(dAtA []byte) error + func (m *NATSBus) XXX_DiscardUnknown() + func (m *NATSBus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *NATSBus) XXX_Merge(src proto.Message) + func (m *NATSBus) XXX_Size() int + func (m *NATSBus) XXX_Unmarshal(b []byte) error + func (this *NATSBus) String() string + type NATSConfig struct + AccessSecret *corev1.SecretKeySelector + Auth *AuthStrategy + ClusterID *string + URL string + func (*NATSConfig) Descriptor() ([]byte, []int) + func (*NATSConfig) ProtoMessage() + func (in *NATSConfig) DeepCopy() *NATSConfig + func (in *NATSConfig) DeepCopyInto(out *NATSConfig) + func (m *NATSConfig) Marshal() (dAtA []byte, err error) + func (m *NATSConfig) MarshalTo(dAtA []byte) (int, error) + func (m *NATSConfig) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *NATSConfig) Reset() + func (m *NATSConfig) Size() (n int) + func (m *NATSConfig) Unmarshal(dAtA []byte) error + func (m *NATSConfig) XXX_DiscardUnknown() + func (m *NATSConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *NATSConfig) XXX_Merge(src proto.Message) + func (m *NATSConfig) XXX_Size() int + func (m *NATSConfig) XXX_Unmarshal(b []byte) error + func (this *NATSConfig) String() string + type NATSEventsSource struct + Auth *NATSAuth + ConnectionBackoff *Backoff + Filter *EventSourceFilter + JSONBody bool + Metadata map[string]string + Queue *string + Subject string + TLS *TLSConfig + URL string + func (*NATSEventsSource) Descriptor() ([]byte, []int) + func (*NATSEventsSource) ProtoMessage() + func (in *NATSEventsSource) DeepCopy() *NATSEventsSource + func (in *NATSEventsSource) DeepCopyInto(out *NATSEventsSource) + func (m *NATSEventsSource) Marshal() (dAtA []byte, err error) + func (m *NATSEventsSource) MarshalTo(dAtA []byte) (int, error) + func (m *NATSEventsSource) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *NATSEventsSource) Reset() + func (m *NATSEventsSource) Size() (n int) + func (m *NATSEventsSource) Unmarshal(dAtA []byte) error + func (m *NATSEventsSource) XXX_DiscardUnknown() + func (m *NATSEventsSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *NATSEventsSource) XXX_Merge(src proto.Message) + func (m *NATSEventsSource) XXX_Size() int + func (m *NATSEventsSource) XXX_Unmarshal(b []byte) error + func (this *NATSEventsSource) String() string + type NATSTrigger struct + Parameters []TriggerParameter + Payload []TriggerParameter + Subject string + TLS *TLSConfig + URL string + func (*NATSTrigger) Descriptor() ([]byte, []int) + func (*NATSTrigger) ProtoMessage() + func (in *NATSTrigger) DeepCopy() *NATSTrigger + func (in *NATSTrigger) DeepCopyInto(out *NATSTrigger) + func (m *NATSTrigger) Marshal() (dAtA []byte, err error) + func (m *NATSTrigger) MarshalTo(dAtA []byte) (int, error) + func (m *NATSTrigger) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *NATSTrigger) Reset() + func (m *NATSTrigger) Size() (n int) + func (m *NATSTrigger) Unmarshal(dAtA []byte) error + func (m *NATSTrigger) XXX_DiscardUnknown() + func (m *NATSTrigger) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *NATSTrigger) XXX_Merge(src proto.Message) + func (m *NATSTrigger) XXX_Size() int + func (m *NATSTrigger) XXX_Unmarshal(b []byte) error + func (this *NATSTrigger) String() string + type NSQEventSource struct + Channel string + ConnectionBackoff *Backoff + Filter *EventSourceFilter + HostAddress string + JSONBody bool + Metadata map[string]string + TLS *TLSConfig + Topic string + func (*NSQEventSource) Descriptor() ([]byte, []int) + func (*NSQEventSource) ProtoMessage() + func (in *NSQEventSource) DeepCopy() *NSQEventSource + func (in *NSQEventSource) DeepCopyInto(out *NSQEventSource) + func (m *NSQEventSource) Marshal() (dAtA []byte, err error) + func (m *NSQEventSource) MarshalTo(dAtA []byte) (int, error) + func (m *NSQEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *NSQEventSource) Reset() + func (m *NSQEventSource) Size() (n int) + func (m *NSQEventSource) Unmarshal(dAtA []byte) error + func (m *NSQEventSource) XXX_DiscardUnknown() + func (m *NSQEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *NSQEventSource) XXX_Merge(src proto.Message) + func (m *NSQEventSource) XXX_Size() int + func (m *NSQEventSource) XXX_Unmarshal(b []byte) error + func (this *NSQEventSource) String() string + type NativeStrategy struct + Affinity *corev1.Affinity + Auth *AuthStrategy + ContainerTemplate *ContainerTemplate + ImagePullSecrets []corev1.LocalObjectReference + MaxAge *string + MaxBytes *string + MaxMsgs *uint64 + MaxPayload *string + MaxSubs *uint64 + Metadata *Metadata + MetricsContainerTemplate *ContainerTemplate + NodeSelector map[string]string + Persistence *PersistenceStrategy + Priority *int32 + PriorityClassName string + RaftCommitTimeout *string + RaftElectionTimeout *string + RaftHeartbeatTimeout *string + RaftLeaseTimeout *string + Replicas int32 + SecurityContext *corev1.PodSecurityContext + ServiceAccountName string + Tolerations []corev1.Toleration + func (*NativeStrategy) Descriptor() ([]byte, []int) + func (*NativeStrategy) ProtoMessage() + func (in *NativeStrategy) DeepCopy() *NativeStrategy + func (in *NativeStrategy) DeepCopyInto(out *NativeStrategy) + func (in *NativeStrategy) GetReplicas() int + func (m *NativeStrategy) Marshal() (dAtA []byte, err error) + func (m *NativeStrategy) MarshalTo(dAtA []byte) (int, error) + func (m *NativeStrategy) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *NativeStrategy) Reset() + func (m *NativeStrategy) Size() (n int) + func (m *NativeStrategy) Unmarshal(dAtA []byte) error + func (m *NativeStrategy) XXX_DiscardUnknown() + func (m *NativeStrategy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *NativeStrategy) XXX_Merge(src proto.Message) + func (m *NativeStrategy) XXX_Size() int + func (m *NativeStrategy) XXX_Unmarshal(b []byte) error + func (this *NativeStrategy) String() string + type OpenWhiskTrigger struct + ActionName string + AuthToken *corev1.SecretKeySelector + Host string + Namespace string + Parameters []TriggerParameter + Payload []TriggerParameter + Version string + func (*OpenWhiskTrigger) Descriptor() ([]byte, []int) + func (*OpenWhiskTrigger) ProtoMessage() + func (in *OpenWhiskTrigger) DeepCopy() *OpenWhiskTrigger + func (in *OpenWhiskTrigger) DeepCopyInto(out *OpenWhiskTrigger) + func (m *OpenWhiskTrigger) Marshal() (dAtA []byte, err error) + func (m *OpenWhiskTrigger) MarshalTo(dAtA []byte) (int, error) + func (m *OpenWhiskTrigger) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *OpenWhiskTrigger) Reset() + func (m *OpenWhiskTrigger) Size() (n int) + func (m *OpenWhiskTrigger) Unmarshal(dAtA []byte) error + func (m *OpenWhiskTrigger) XXX_DiscardUnknown() + func (m *OpenWhiskTrigger) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *OpenWhiskTrigger) XXX_Merge(src proto.Message) + func (m *OpenWhiskTrigger) XXX_Size() int + func (m *OpenWhiskTrigger) XXX_Unmarshal(b []byte) error + func (this *OpenWhiskTrigger) String() string + type OwnedRepositories struct + Names []string + Owner string + func (*OwnedRepositories) Descriptor() ([]byte, []int) + func (*OwnedRepositories) ProtoMessage() + func (in *OwnedRepositories) DeepCopy() *OwnedRepositories + func (in *OwnedRepositories) DeepCopyInto(out *OwnedRepositories) + func (m *OwnedRepositories) Marshal() (dAtA []byte, err error) + func (m *OwnedRepositories) MarshalTo(dAtA []byte) (int, error) + func (m *OwnedRepositories) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *OwnedRepositories) Reset() + func (m *OwnedRepositories) Size() (n int) + func (m *OwnedRepositories) Unmarshal(dAtA []byte) error + func (m *OwnedRepositories) XXX_DiscardUnknown() + func (m *OwnedRepositories) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *OwnedRepositories) XXX_Merge(src proto.Message) + func (m *OwnedRepositories) XXX_Size() int + func (m *OwnedRepositories) XXX_Unmarshal(b []byte) error + func (this *OwnedRepositories) String() string + type PayloadField struct + Name string + Path string + func (*PayloadField) Descriptor() ([]byte, []int) + func (*PayloadField) ProtoMessage() + func (in *PayloadField) DeepCopy() *PayloadField + func (in *PayloadField) DeepCopyInto(out *PayloadField) + func (m *PayloadField) Marshal() (dAtA []byte, err error) + func (m *PayloadField) MarshalTo(dAtA []byte) (int, error) + func (m *PayloadField) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *PayloadField) Reset() + func (m *PayloadField) Size() (n int) + func (m *PayloadField) Unmarshal(dAtA []byte) error + func (m *PayloadField) XXX_DiscardUnknown() + func (m *PayloadField) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PayloadField) XXX_Merge(src proto.Message) + func (m *PayloadField) XXX_Size() int + func (m *PayloadField) XXX_Unmarshal(b []byte) error + func (this *PayloadField) String() string + type PersistenceStrategy struct + AccessMode *corev1.PersistentVolumeAccessMode + StorageClassName *string + VolumeSize *apiresource.Quantity + func (*PersistenceStrategy) Descriptor() ([]byte, []int) + func (*PersistenceStrategy) ProtoMessage() + func (in *PersistenceStrategy) DeepCopy() *PersistenceStrategy + func (in *PersistenceStrategy) DeepCopyInto(out *PersistenceStrategy) + func (m *PersistenceStrategy) Marshal() (dAtA []byte, err error) + func (m *PersistenceStrategy) MarshalTo(dAtA []byte) (int, error) + func (m *PersistenceStrategy) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *PersistenceStrategy) Reset() + func (m *PersistenceStrategy) Size() (n int) + func (m *PersistenceStrategy) Unmarshal(dAtA []byte) error + func (m *PersistenceStrategy) XXX_DiscardUnknown() + func (m *PersistenceStrategy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PersistenceStrategy) XXX_Merge(src proto.Message) + func (m *PersistenceStrategy) XXX_Size() int + func (m *PersistenceStrategy) XXX_Unmarshal(b []byte) error + func (this *PersistenceStrategy) String() string + type PubSubEventSource struct + CredentialSecret *corev1.SecretKeySelector + DeleteSubscriptionOnFinish bool + Filter *EventSourceFilter + JSONBody bool + Metadata map[string]string + ProjectID string + SubscriptionID string + Topic string + TopicProjectID string + func (*PubSubEventSource) Descriptor() ([]byte, []int) + func (*PubSubEventSource) ProtoMessage() + func (in *PubSubEventSource) DeepCopy() *PubSubEventSource + func (in *PubSubEventSource) DeepCopyInto(out *PubSubEventSource) + func (m *PubSubEventSource) Marshal() (dAtA []byte, err error) + func (m *PubSubEventSource) MarshalTo(dAtA []byte) (int, error) + func (m *PubSubEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *PubSubEventSource) Reset() + func (m *PubSubEventSource) Size() (n int) + func (m *PubSubEventSource) Unmarshal(dAtA []byte) error + func (m *PubSubEventSource) XXX_DiscardUnknown() + func (m *PubSubEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PubSubEventSource) XXX_Merge(src proto.Message) + func (m *PubSubEventSource) XXX_Size() int + func (m *PubSubEventSource) XXX_Unmarshal(b []byte) error + func (this *PubSubEventSource) String() string + type PulsarEventSource struct + AuthAthenzParams map[string]string + AuthAthenzSecret *corev1.SecretKeySelector + AuthTokenSecret *corev1.SecretKeySelector + ConnectionBackoff *Backoff + Filter *EventSourceFilter + JSONBody bool + Metadata map[string]string + TLS *TLSConfig + TLSAllowInsecureConnection bool + TLSTrustCertsSecret *corev1.SecretKeySelector + TLSValidateHostname bool + Topics []string + Type string + URL string + func (*PulsarEventSource) Descriptor() ([]byte, []int) + func (*PulsarEventSource) ProtoMessage() + func (in *PulsarEventSource) DeepCopy() *PulsarEventSource + func (in *PulsarEventSource) DeepCopyInto(out *PulsarEventSource) + func (m *PulsarEventSource) Marshal() (dAtA []byte, err error) + func (m *PulsarEventSource) MarshalTo(dAtA []byte) (int, error) + func (m *PulsarEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *PulsarEventSource) Reset() + func (m *PulsarEventSource) Size() (n int) + func (m *PulsarEventSource) Unmarshal(dAtA []byte) error + func (m *PulsarEventSource) XXX_DiscardUnknown() + func (m *PulsarEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PulsarEventSource) XXX_Merge(src proto.Message) + func (m *PulsarEventSource) XXX_Size() int + func (m *PulsarEventSource) XXX_Unmarshal(b []byte) error + func (this *PulsarEventSource) String() string + type PulsarTrigger struct + AuthAthenzParams map[string]string + AuthAthenzSecret *corev1.SecretKeySelector + AuthTokenSecret *corev1.SecretKeySelector + ConnectionBackoff *Backoff + Parameters []TriggerParameter + Payload []TriggerParameter + TLS *TLSConfig + TLSAllowInsecureConnection bool + TLSTrustCertsSecret *corev1.SecretKeySelector + TLSValidateHostname bool + Topic string + URL string + func (*PulsarTrigger) Descriptor() ([]byte, []int) + func (*PulsarTrigger) ProtoMessage() + func (in *PulsarTrigger) DeepCopy() *PulsarTrigger + func (in *PulsarTrigger) DeepCopyInto(out *PulsarTrigger) + func (m *PulsarTrigger) Marshal() (dAtA []byte, err error) + func (m *PulsarTrigger) MarshalTo(dAtA []byte) (int, error) + func (m *PulsarTrigger) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *PulsarTrigger) Reset() + func (m *PulsarTrigger) Size() (n int) + func (m *PulsarTrigger) Unmarshal(dAtA []byte) error + func (m *PulsarTrigger) XXX_DiscardUnknown() + func (m *PulsarTrigger) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PulsarTrigger) XXX_Merge(src proto.Message) + func (m *PulsarTrigger) XXX_Size() int + func (m *PulsarTrigger) XXX_Unmarshal(b []byte) error + func (this *PulsarTrigger) String() string + type RateLimit struct + RequestsPerUnit int32 + Unit RateLimiteUnit + func (*RateLimit) Descriptor() ([]byte, []int) + func (*RateLimit) ProtoMessage() + func (in *RateLimit) DeepCopy() *RateLimit + func (in *RateLimit) DeepCopyInto(out *RateLimit) + func (m *RateLimit) Marshal() (dAtA []byte, err error) + func (m *RateLimit) MarshalTo(dAtA []byte) (int, error) + func (m *RateLimit) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *RateLimit) Reset() + func (m *RateLimit) Size() (n int) + func (m *RateLimit) Unmarshal(dAtA []byte) error + func (m *RateLimit) XXX_DiscardUnknown() + func (m *RateLimit) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RateLimit) XXX_Merge(src proto.Message) + func (m *RateLimit) XXX_Size() int + func (m *RateLimit) XXX_Unmarshal(b []byte) error + func (this *RateLimit) String() string + type RateLimiteUnit string + const Hour + const Minute + const Second + type RedisEventSource struct + Channels []string + DB int32 + Filter *EventSourceFilter + HostAddress string + JSONBody bool + Metadata map[string]string + Namespace string + Password *corev1.SecretKeySelector + TLS *TLSConfig + Username string + func (*RedisEventSource) Descriptor() ([]byte, []int) + func (*RedisEventSource) ProtoMessage() + func (in *RedisEventSource) DeepCopy() *RedisEventSource + func (in *RedisEventSource) DeepCopyInto(out *RedisEventSource) + func (m *RedisEventSource) Marshal() (dAtA []byte, err error) + func (m *RedisEventSource) MarshalTo(dAtA []byte) (int, error) + func (m *RedisEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *RedisEventSource) Reset() + func (m *RedisEventSource) Size() (n int) + func (m *RedisEventSource) Unmarshal(dAtA []byte) error + func (m *RedisEventSource) XXX_DiscardUnknown() + func (m *RedisEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RedisEventSource) XXX_Merge(src proto.Message) + func (m *RedisEventSource) XXX_Size() int + func (m *RedisEventSource) XXX_Unmarshal(b []byte) error + func (this *RedisEventSource) String() string + type RedisStreamEventSource struct + ConsumerGroup string + DB int32 + Filter *EventSourceFilter + HostAddress string + MaxMsgCountPerRead int32 + Metadata map[string]string + Password *corev1.SecretKeySelector + Streams []string + TLS *TLSConfig + Username string + func (*RedisStreamEventSource) Descriptor() ([]byte, []int) + func (*RedisStreamEventSource) ProtoMessage() + func (in *RedisStreamEventSource) DeepCopy() *RedisStreamEventSource + func (in *RedisStreamEventSource) DeepCopyInto(out *RedisStreamEventSource) + func (m *RedisStreamEventSource) Marshal() (dAtA []byte, err error) + func (m *RedisStreamEventSource) MarshalTo(dAtA []byte) (int, error) + func (m *RedisStreamEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *RedisStreamEventSource) Reset() + func (m *RedisStreamEventSource) Size() (n int) + func (m *RedisStreamEventSource) Unmarshal(dAtA []byte) error + func (m *RedisStreamEventSource) XXX_DiscardUnknown() + func (m *RedisStreamEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RedisStreamEventSource) XXX_Merge(src proto.Message) + func (m *RedisStreamEventSource) XXX_Size() int + func (m *RedisStreamEventSource) XXX_Unmarshal(b []byte) error + func (this *RedisStreamEventSource) String() string + type ResourceEventSource struct + EventTypes []ResourceEventType + Filter *ResourceFilter + Metadata map[string]string + Namespace string + func (*ResourceEventSource) Descriptor() ([]byte, []int) + func (*ResourceEventSource) ProtoMessage() + func (in *ResourceEventSource) DeepCopy() *ResourceEventSource + func (in *ResourceEventSource) DeepCopyInto(out *ResourceEventSource) + func (m *ResourceEventSource) Marshal() (dAtA []byte, err error) + func (m *ResourceEventSource) MarshalTo(dAtA []byte) (int, error) + func (m *ResourceEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ResourceEventSource) Reset() + func (m *ResourceEventSource) Size() (n int) + func (m *ResourceEventSource) Unmarshal(dAtA []byte) error + func (m *ResourceEventSource) XXX_DiscardUnknown() + func (m *ResourceEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ResourceEventSource) XXX_Merge(src proto.Message) + func (m *ResourceEventSource) XXX_Size() int + func (m *ResourceEventSource) XXX_Unmarshal(b []byte) error + func (this *ResourceEventSource) String() string + type ResourceEventType string + const ADD + const DELETE + const UPDATE + type ResourceFilter struct + AfterStart bool + CreatedBy metav1.Time + Fields []Selector + Labels []Selector + Prefix string + func (*ResourceFilter) Descriptor() ([]byte, []int) + func (*ResourceFilter) ProtoMessage() + func (in *ResourceFilter) DeepCopy() *ResourceFilter + func (in *ResourceFilter) DeepCopyInto(out *ResourceFilter) + func (m *ResourceFilter) Marshal() (dAtA []byte, err error) + func (m *ResourceFilter) MarshalTo(dAtA []byte) (int, error) + func (m *ResourceFilter) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ResourceFilter) Reset() + func (m *ResourceFilter) Size() (n int) + func (m *ResourceFilter) Unmarshal(dAtA []byte) error + func (m *ResourceFilter) XXX_DiscardUnknown() + func (m *ResourceFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ResourceFilter) XXX_Merge(src proto.Message) + func (m *ResourceFilter) XXX_Size() int + func (m *ResourceFilter) XXX_Unmarshal(b []byte) error + func (this *ResourceFilter) String() string + type S3Artifact struct + AccessKey *corev1.SecretKeySelector + Bucket *S3Bucket + CACertificate *corev1.SecretKeySelector + Endpoint string + Events []string + Filter *S3Filter + Insecure bool + Metadata map[string]string + Region string + SecretKey *corev1.SecretKeySelector + func (*S3Artifact) Descriptor() ([]byte, []int) + func (*S3Artifact) ProtoMessage() + func (in *S3Artifact) DeepCopy() *S3Artifact + func (in *S3Artifact) DeepCopyInto(out *S3Artifact) + func (m *S3Artifact) Marshal() (dAtA []byte, err error) + func (m *S3Artifact) MarshalTo(dAtA []byte) (int, error) + func (m *S3Artifact) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *S3Artifact) Reset() + func (m *S3Artifact) Size() (n int) + func (m *S3Artifact) Unmarshal(dAtA []byte) error + func (m *S3Artifact) XXX_DiscardUnknown() + func (m *S3Artifact) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *S3Artifact) XXX_Merge(src proto.Message) + func (m *S3Artifact) XXX_Size() int + func (m *S3Artifact) XXX_Unmarshal(b []byte) error + func (this *S3Artifact) String() string + type S3Bucket struct + Key string + Name string + func (*S3Bucket) Descriptor() ([]byte, []int) + func (*S3Bucket) ProtoMessage() + func (in *S3Bucket) DeepCopy() *S3Bucket + func (in *S3Bucket) DeepCopyInto(out *S3Bucket) + func (m *S3Bucket) Marshal() (dAtA []byte, err error) + func (m *S3Bucket) MarshalTo(dAtA []byte) (int, error) + func (m *S3Bucket) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *S3Bucket) Reset() + func (m *S3Bucket) Size() (n int) + func (m *S3Bucket) Unmarshal(dAtA []byte) error + func (m *S3Bucket) XXX_DiscardUnknown() + func (m *S3Bucket) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *S3Bucket) XXX_Merge(src proto.Message) + func (m *S3Bucket) XXX_Size() int + func (m *S3Bucket) XXX_Unmarshal(b []byte) error + func (this *S3Bucket) String() string + type S3Filter struct + Prefix string + Suffix string + func (*S3Filter) Descriptor() ([]byte, []int) + func (*S3Filter) ProtoMessage() + func (in *S3Filter) DeepCopy() *S3Filter + func (in *S3Filter) DeepCopyInto(out *S3Filter) + func (m *S3Filter) Marshal() (dAtA []byte, err error) + func (m *S3Filter) MarshalTo(dAtA []byte) (int, error) + func (m *S3Filter) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *S3Filter) Reset() + func (m *S3Filter) Size() (n int) + func (m *S3Filter) Unmarshal(dAtA []byte) error + func (m *S3Filter) XXX_DiscardUnknown() + func (m *S3Filter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *S3Filter) XXX_Merge(src proto.Message) + func (m *S3Filter) XXX_Size() int + func (m *S3Filter) XXX_Unmarshal(b []byte) error + func (this *S3Filter) String() string + type SASLConfig struct + Mechanism string + PasswordSecret *corev1.SecretKeySelector + UserSecret *corev1.SecretKeySelector + func (*SASLConfig) Descriptor() ([]byte, []int) + func (*SASLConfig) ProtoMessage() + func (in *SASLConfig) DeepCopy() *SASLConfig + func (in *SASLConfig) DeepCopyInto(out *SASLConfig) + func (m *SASLConfig) Marshal() (dAtA []byte, err error) + func (m *SASLConfig) MarshalTo(dAtA []byte) (int, error) + func (m *SASLConfig) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *SASLConfig) Reset() + func (m *SASLConfig) Size() (n int) + func (m *SASLConfig) Unmarshal(dAtA []byte) error + func (m *SASLConfig) XXX_DiscardUnknown() + func (m *SASLConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SASLConfig) XXX_Merge(src proto.Message) + func (m *SASLConfig) XXX_Size() int + func (m *SASLConfig) XXX_Unmarshal(b []byte) error + func (s SASLConfig) GetMechanism() string + func (this *SASLConfig) String() string + type SFTPEventSource struct + Address *corev1.SecretKeySelector + EventType string + Filter *EventSourceFilter + Metadata map[string]string + Password *corev1.SecretKeySelector + PollIntervalDuration string + SSHKeySecret *corev1.SecretKeySelector + Username *corev1.SecretKeySelector + WatchPathConfig WatchPathConfig + func (*SFTPEventSource) Descriptor() ([]byte, []int) + func (*SFTPEventSource) ProtoMessage() + func (in *SFTPEventSource) DeepCopy() *SFTPEventSource + func (in *SFTPEventSource) DeepCopyInto(out *SFTPEventSource) + func (m *SFTPEventSource) Marshal() (dAtA []byte, err error) + func (m *SFTPEventSource) MarshalTo(dAtA []byte) (int, error) + func (m *SFTPEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *SFTPEventSource) Reset() + func (m *SFTPEventSource) Size() (n int) + func (m *SFTPEventSource) Unmarshal(dAtA []byte) error + func (m *SFTPEventSource) XXX_DiscardUnknown() + func (m *SFTPEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SFTPEventSource) XXX_Merge(src proto.Message) + func (m *SFTPEventSource) XXX_Size() int + func (m *SFTPEventSource) XXX_Unmarshal(b []byte) error + func (this *SFTPEventSource) String() string + type SNSEventSource struct + AccessKey *corev1.SecretKeySelector + Endpoint string + Filter *EventSourceFilter + Metadata map[string]string + Region string + RoleARN string + SecretKey *corev1.SecretKeySelector + TopicArn string + ValidateSignature bool + Webhook *WebhookContext + func (*SNSEventSource) Descriptor() ([]byte, []int) + func (*SNSEventSource) ProtoMessage() + func (in *SNSEventSource) DeepCopy() *SNSEventSource + func (in *SNSEventSource) DeepCopyInto(out *SNSEventSource) + func (m *SNSEventSource) Marshal() (dAtA []byte, err error) + func (m *SNSEventSource) MarshalTo(dAtA []byte) (int, error) + func (m *SNSEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *SNSEventSource) Reset() + func (m *SNSEventSource) Size() (n int) + func (m *SNSEventSource) Unmarshal(dAtA []byte) error + func (m *SNSEventSource) XXX_DiscardUnknown() + func (m *SNSEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SNSEventSource) XXX_Merge(src proto.Message) + func (m *SNSEventSource) XXX_Size() int + func (m *SNSEventSource) XXX_Unmarshal(b []byte) error + func (this *SNSEventSource) String() string + type SQSEventSource struct + AccessKey *corev1.SecretKeySelector + DLQ bool + Endpoint string + Filter *EventSourceFilter + JSONBody bool + Metadata map[string]string + Queue string + QueueAccountID string + Region string + RoleARN string + SecretKey *corev1.SecretKeySelector + SessionToken *corev1.SecretKeySelector + WaitTimeSeconds int64 + func (*SQSEventSource) Descriptor() ([]byte, []int) + func (*SQSEventSource) ProtoMessage() + func (in *SQSEventSource) DeepCopy() *SQSEventSource + func (in *SQSEventSource) DeepCopyInto(out *SQSEventSource) + func (m *SQSEventSource) Marshal() (dAtA []byte, err error) + func (m *SQSEventSource) MarshalTo(dAtA []byte) (int, error) + func (m *SQSEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *SQSEventSource) Reset() + func (m *SQSEventSource) Size() (n int) + func (m *SQSEventSource) Unmarshal(dAtA []byte) error + func (m *SQSEventSource) XXX_DiscardUnknown() + func (m *SQSEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SQSEventSource) XXX_Merge(src proto.Message) + func (m *SQSEventSource) XXX_Size() int + func (m *SQSEventSource) XXX_Unmarshal(b []byte) error + func (this *SQSEventSource) String() string + type SchemaRegistryConfig struct + Auth BasicAuth + SchemaID int32 + URL string + func (*SchemaRegistryConfig) Descriptor() ([]byte, []int) + func (*SchemaRegistryConfig) ProtoMessage() + func (in *SchemaRegistryConfig) DeepCopy() *SchemaRegistryConfig + func (in *SchemaRegistryConfig) DeepCopyInto(out *SchemaRegistryConfig) + func (m *SchemaRegistryConfig) Marshal() (dAtA []byte, err error) + func (m *SchemaRegistryConfig) MarshalTo(dAtA []byte) (int, error) + func (m *SchemaRegistryConfig) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *SchemaRegistryConfig) Reset() + func (m *SchemaRegistryConfig) Size() (n int) + func (m *SchemaRegistryConfig) Unmarshal(dAtA []byte) error + func (m *SchemaRegistryConfig) XXX_DiscardUnknown() + func (m *SchemaRegistryConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SchemaRegistryConfig) XXX_Merge(src proto.Message) + func (m *SchemaRegistryConfig) XXX_Size() int + func (m *SchemaRegistryConfig) XXX_Unmarshal(b []byte) error + func (this *SchemaRegistryConfig) String() string + type SecureHeader struct + Name string + ValueFrom *ValueFromSource + func (*SecureHeader) Descriptor() ([]byte, []int) + func (*SecureHeader) ProtoMessage() + func (in *SecureHeader) DeepCopy() *SecureHeader + func (in *SecureHeader) DeepCopyInto(out *SecureHeader) + func (m *SecureHeader) Marshal() (dAtA []byte, err error) + func (m *SecureHeader) MarshalTo(dAtA []byte) (int, error) + func (m *SecureHeader) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *SecureHeader) Reset() + func (m *SecureHeader) Size() (n int) + func (m *SecureHeader) Unmarshal(dAtA []byte) error + func (m *SecureHeader) XXX_DiscardUnknown() + func (m *SecureHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SecureHeader) XXX_Merge(src proto.Message) + func (m *SecureHeader) XXX_Size() int + func (m *SecureHeader) XXX_Unmarshal(b []byte) error + func (this *SecureHeader) String() string + type Selector struct + Key string + Operation string + Value string + func (*Selector) Descriptor() ([]byte, []int) + func (*Selector) ProtoMessage() + func (in *Selector) DeepCopy() *Selector + func (in *Selector) DeepCopyInto(out *Selector) + func (m *Selector) Marshal() (dAtA []byte, err error) + func (m *Selector) MarshalTo(dAtA []byte) (int, error) + func (m *Selector) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Selector) Reset() + func (m *Selector) Size() (n int) + func (m *Selector) Unmarshal(dAtA []byte) error + func (m *Selector) XXX_DiscardUnknown() + func (m *Selector) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Selector) XXX_Merge(src proto.Message) + func (m *Selector) XXX_Size() int + func (m *Selector) XXX_Unmarshal(b []byte) error + func (this *Selector) String() string + type Sensor struct + Spec SensorSpec + Status SensorStatus + func (*Sensor) Descriptor() ([]byte, []int) + func (*Sensor) ProtoMessage() + func (in *Sensor) DeepCopy() *Sensor + func (in *Sensor) DeepCopyInto(out *Sensor) + func (in *Sensor) DeepCopyObject() runtime.Object + func (m *Sensor) Marshal() (dAtA []byte, err error) + func (m *Sensor) MarshalTo(dAtA []byte) (int, error) + func (m *Sensor) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Sensor) Reset() + func (m *Sensor) Size() (n int) + func (m *Sensor) Unmarshal(dAtA []byte) error + func (m *Sensor) XXX_DiscardUnknown() + func (m *Sensor) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Sensor) XXX_Merge(src proto.Message) + func (m *Sensor) XXX_Size() int + func (m *Sensor) XXX_Unmarshal(b []byte) error + func (this *Sensor) String() string + type SensorList struct + Items []Sensor + func (*SensorList) Descriptor() ([]byte, []int) + func (*SensorList) ProtoMessage() + func (in *SensorList) DeepCopy() *SensorList + func (in *SensorList) DeepCopyInto(out *SensorList) + func (in *SensorList) DeepCopyObject() runtime.Object + func (m *SensorList) Marshal() (dAtA []byte, err error) + func (m *SensorList) MarshalTo(dAtA []byte) (int, error) + func (m *SensorList) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *SensorList) Reset() + func (m *SensorList) Size() (n int) + func (m *SensorList) Unmarshal(dAtA []byte) error + func (m *SensorList) XXX_DiscardUnknown() + func (m *SensorList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SensorList) XXX_Merge(src proto.Message) + func (m *SensorList) XXX_Size() int + func (m *SensorList) XXX_Unmarshal(b []byte) error + func (this *SensorList) String() string + type SensorSpec struct + Dependencies []EventDependency + ErrorOnFailedRound bool + EventBusName string + LoggingFields map[string]string + Replicas *int32 + RevisionHistoryLimit *int32 + Template *Template + Triggers []Trigger + func (*SensorSpec) Descriptor() ([]byte, []int) + func (*SensorSpec) ProtoMessage() + func (in *SensorSpec) DeepCopy() *SensorSpec + func (in *SensorSpec) DeepCopyInto(out *SensorSpec) + func (m *SensorSpec) Marshal() (dAtA []byte, err error) + func (m *SensorSpec) MarshalTo(dAtA []byte) (int, error) + func (m *SensorSpec) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *SensorSpec) Reset() + func (m *SensorSpec) Size() (n int) + func (m *SensorSpec) Unmarshal(dAtA []byte) error + func (m *SensorSpec) XXX_DiscardUnknown() + func (m *SensorSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SensorSpec) XXX_Merge(src proto.Message) + func (m *SensorSpec) XXX_Size() int + func (m *SensorSpec) XXX_Unmarshal(b []byte) error + func (s SensorSpec) GetReplicas() int32 + func (this *SensorSpec) String() string + type SensorStatus struct + func (*SensorStatus) Descriptor() ([]byte, []int) + func (*SensorStatus) ProtoMessage() + func (in *SensorStatus) DeepCopy() *SensorStatus + func (in *SensorStatus) DeepCopyInto(out *SensorStatus) + func (m *SensorStatus) Marshal() (dAtA []byte, err error) + func (m *SensorStatus) MarshalTo(dAtA []byte) (int, error) + func (m *SensorStatus) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *SensorStatus) Reset() + func (m *SensorStatus) Size() (n int) + func (m *SensorStatus) Unmarshal(dAtA []byte) error + func (m *SensorStatus) XXX_DiscardUnknown() + func (m *SensorStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SensorStatus) XXX_Merge(src proto.Message) + func (m *SensorStatus) XXX_Size() int + func (m *SensorStatus) XXX_Unmarshal(b []byte) error + func (s *SensorStatus) InitConditions() + func (s *SensorStatus) MarkDependenciesNotProvided(reason, message string) + func (s *SensorStatus) MarkDependenciesProvided() + func (s *SensorStatus) MarkDeployFailed(reason, message string) + func (s *SensorStatus) MarkDeployed() + func (s *SensorStatus) MarkTriggersNotProvided(reason, message string) + func (s *SensorStatus) MarkTriggersProvided() + func (this *SensorStatus) String() string + type Service struct + ClusterIP string + Metadata *Metadata + Ports []corev1.ServicePort + func (*Service) Descriptor() ([]byte, []int) + func (*Service) ProtoMessage() + func (in *Service) DeepCopy() *Service + func (in *Service) DeepCopyInto(out *Service) + func (m *Service) Marshal() (dAtA []byte, err error) + func (m *Service) MarshalTo(dAtA []byte) (int, error) + func (m *Service) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Service) Reset() + func (m *Service) Size() (n int) + func (m *Service) Unmarshal(dAtA []byte) error + func (m *Service) XXX_DiscardUnknown() + func (m *Service) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Service) XXX_Merge(src proto.Message) + func (m *Service) XXX_Size() int + func (m *Service) XXX_Unmarshal(b []byte) error + func (this *Service) String() string + type SlackEventSource struct + Filter *EventSourceFilter + Metadata map[string]string + SigningSecret *corev1.SecretKeySelector + Token *corev1.SecretKeySelector + Webhook *WebhookContext + func (*SlackEventSource) Descriptor() ([]byte, []int) + func (*SlackEventSource) ProtoMessage() + func (in *SlackEventSource) DeepCopy() *SlackEventSource + func (in *SlackEventSource) DeepCopyInto(out *SlackEventSource) + func (m *SlackEventSource) Marshal() (dAtA []byte, err error) + func (m *SlackEventSource) MarshalTo(dAtA []byte) (int, error) + func (m *SlackEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *SlackEventSource) Reset() + func (m *SlackEventSource) Size() (n int) + func (m *SlackEventSource) Unmarshal(dAtA []byte) error + func (m *SlackEventSource) XXX_DiscardUnknown() + func (m *SlackEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SlackEventSource) XXX_Merge(src proto.Message) + func (m *SlackEventSource) XXX_Size() int + func (m *SlackEventSource) XXX_Unmarshal(b []byte) error + func (this *SlackEventSource) String() string + type SlackSender struct + Icon string + Username string + func (*SlackSender) Descriptor() ([]byte, []int) + func (*SlackSender) ProtoMessage() + func (in *SlackSender) DeepCopy() *SlackSender + func (in *SlackSender) DeepCopyInto(out *SlackSender) + func (m *SlackSender) Marshal() (dAtA []byte, err error) + func (m *SlackSender) MarshalTo(dAtA []byte) (int, error) + func (m *SlackSender) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *SlackSender) Reset() + func (m *SlackSender) Size() (n int) + func (m *SlackSender) Unmarshal(dAtA []byte) error + func (m *SlackSender) XXX_DiscardUnknown() + func (m *SlackSender) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SlackSender) XXX_Merge(src proto.Message) + func (m *SlackSender) XXX_Size() int + func (m *SlackSender) XXX_Unmarshal(b []byte) error + func (this *SlackSender) String() string + type SlackThread struct + BroadcastMessageToChannel bool + MessageAggregationKey string + func (*SlackThread) Descriptor() ([]byte, []int) + func (*SlackThread) ProtoMessage() + func (in *SlackThread) DeepCopy() *SlackThread + func (in *SlackThread) DeepCopyInto(out *SlackThread) + func (m *SlackThread) Marshal() (dAtA []byte, err error) + func (m *SlackThread) MarshalTo(dAtA []byte) (int, error) + func (m *SlackThread) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *SlackThread) Reset() + func (m *SlackThread) Size() (n int) + func (m *SlackThread) Unmarshal(dAtA []byte) error + func (m *SlackThread) XXX_DiscardUnknown() + func (m *SlackThread) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SlackThread) XXX_Merge(src proto.Message) + func (m *SlackThread) XXX_Size() int + func (m *SlackThread) XXX_Unmarshal(b []byte) error + func (this *SlackThread) String() string + type SlackTrigger struct + Attachments string + Blocks string + Channel string + Message string + Parameters []TriggerParameter + Sender SlackSender + SlackToken *corev1.SecretKeySelector + Thread SlackThread + func (*SlackTrigger) Descriptor() ([]byte, []int) + func (*SlackTrigger) ProtoMessage() + func (in *SlackTrigger) DeepCopy() *SlackTrigger + func (in *SlackTrigger) DeepCopyInto(out *SlackTrigger) + func (m *SlackTrigger) Marshal() (dAtA []byte, err error) + func (m *SlackTrigger) MarshalTo(dAtA []byte) (int, error) + func (m *SlackTrigger) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *SlackTrigger) Reset() + func (m *SlackTrigger) Size() (n int) + func (m *SlackTrigger) Unmarshal(dAtA []byte) error + func (m *SlackTrigger) XXX_DiscardUnknown() + func (m *SlackTrigger) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SlackTrigger) XXX_Merge(src proto.Message) + func (m *SlackTrigger) XXX_Size() int + func (m *SlackTrigger) XXX_Unmarshal(b []byte) error + func (this *SlackTrigger) String() string + type StandardK8STrigger struct + LiveObject bool + Operation KubernetesResourceOperation + Parameters []TriggerParameter + PatchStrategy k8stypes.PatchType + Source *ArtifactLocation + func (*StandardK8STrigger) Descriptor() ([]byte, []int) + func (*StandardK8STrigger) ProtoMessage() + func (in *StandardK8STrigger) DeepCopy() *StandardK8STrigger + func (in *StandardK8STrigger) DeepCopyInto(out *StandardK8STrigger) + func (m *StandardK8STrigger) Marshal() (dAtA []byte, err error) + func (m *StandardK8STrigger) MarshalTo(dAtA []byte) (int, error) + func (m *StandardK8STrigger) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *StandardK8STrigger) Reset() + func (m *StandardK8STrigger) Size() (n int) + func (m *StandardK8STrigger) Unmarshal(dAtA []byte) error + func (m *StandardK8STrigger) XXX_DiscardUnknown() + func (m *StandardK8STrigger) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *StandardK8STrigger) XXX_Merge(src proto.Message) + func (m *StandardK8STrigger) XXX_Size() int + func (m *StandardK8STrigger) XXX_Unmarshal(b []byte) error + func (this *StandardK8STrigger) String() string + type Status struct + Conditions []Condition + func (*Status) Descriptor() ([]byte, []int) + func (*Status) ProtoMessage() + func (in *Status) DeepCopy() *Status + func (in *Status) DeepCopyInto(out *Status) + func (m *Status) Marshal() (dAtA []byte, err error) + func (m *Status) MarshalTo(dAtA []byte) (int, error) + func (m *Status) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Status) Reset() + func (m *Status) Size() (n int) + func (m *Status) Unmarshal(dAtA []byte) error + func (m *Status) XXX_DiscardUnknown() + func (m *Status) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Status) XXX_Merge(src proto.Message) + func (m *Status) XXX_Size() int + func (m *Status) XXX_Unmarshal(b []byte) error + func (s *Status) GetCondition(t ConditionType) *Condition + func (s *Status) InitializeConditions(conditionTypes ...ConditionType) + func (s *Status) IsReady() bool + func (s *Status) MarkFalse(t ConditionType, reason, message string) + func (s *Status) MarkTrue(t ConditionType) + func (s *Status) MarkTrueWithReason(t ConditionType, reason, message string) + func (s *Status) MarkUnknown(t ConditionType, reason, message string) + func (s *Status) SetCondition(condition Condition) + func (this *Status) String() string + type StatusPolicy struct + Allow []int32 + func (*StatusPolicy) Descriptor() ([]byte, []int) + func (*StatusPolicy) ProtoMessage() + func (in *StatusPolicy) DeepCopy() *StatusPolicy + func (in *StatusPolicy) DeepCopyInto(out *StatusPolicy) + func (in *StatusPolicy) GetAllow() []int + func (m *StatusPolicy) Marshal() (dAtA []byte, err error) + func (m *StatusPolicy) MarshalTo(dAtA []byte) (int, error) + func (m *StatusPolicy) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *StatusPolicy) Reset() + func (m *StatusPolicy) Size() (n int) + func (m *StatusPolicy) Unmarshal(dAtA []byte) error + func (m *StatusPolicy) XXX_DiscardUnknown() + func (m *StatusPolicy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *StatusPolicy) XXX_Merge(src proto.Message) + func (m *StatusPolicy) XXX_Size() int + func (m *StatusPolicy) XXX_Unmarshal(b []byte) error + func (this *StatusPolicy) String() string + type StorageGridEventSource struct + APIURL string + AuthToken *corev1.SecretKeySelector + Bucket string + Events []string + Filter *StorageGridFilter + Metadata map[string]string + Region string + TopicArn string + Webhook *WebhookContext + func (*StorageGridEventSource) Descriptor() ([]byte, []int) + func (*StorageGridEventSource) ProtoMessage() + func (in *StorageGridEventSource) DeepCopy() *StorageGridEventSource + func (in *StorageGridEventSource) DeepCopyInto(out *StorageGridEventSource) + func (m *StorageGridEventSource) Marshal() (dAtA []byte, err error) + func (m *StorageGridEventSource) MarshalTo(dAtA []byte) (int, error) + func (m *StorageGridEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *StorageGridEventSource) Reset() + func (m *StorageGridEventSource) Size() (n int) + func (m *StorageGridEventSource) Unmarshal(dAtA []byte) error + func (m *StorageGridEventSource) XXX_DiscardUnknown() + func (m *StorageGridEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *StorageGridEventSource) XXX_Merge(src proto.Message) + func (m *StorageGridEventSource) XXX_Size() int + func (m *StorageGridEventSource) XXX_Unmarshal(b []byte) error + func (this *StorageGridEventSource) String() string + type StorageGridFilter struct + Prefix string + Suffix string + func (*StorageGridFilter) Descriptor() ([]byte, []int) + func (*StorageGridFilter) ProtoMessage() + func (in *StorageGridFilter) DeepCopy() *StorageGridFilter + func (in *StorageGridFilter) DeepCopyInto(out *StorageGridFilter) + func (m *StorageGridFilter) Marshal() (dAtA []byte, err error) + func (m *StorageGridFilter) MarshalTo(dAtA []byte) (int, error) + func (m *StorageGridFilter) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *StorageGridFilter) Reset() + func (m *StorageGridFilter) Size() (n int) + func (m *StorageGridFilter) Unmarshal(dAtA []byte) error + func (m *StorageGridFilter) XXX_DiscardUnknown() + func (m *StorageGridFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *StorageGridFilter) XXX_Merge(src proto.Message) + func (m *StorageGridFilter) XXX_Size() int + func (m *StorageGridFilter) XXX_Unmarshal(b []byte) error + func (this *StorageGridFilter) String() string + type StripeEventSource struct + APIKey *corev1.SecretKeySelector + CreateWebhook bool + EventFilter []string + Metadata map[string]string + Webhook *WebhookContext + func (*StripeEventSource) Descriptor() ([]byte, []int) + func (*StripeEventSource) ProtoMessage() + func (in *StripeEventSource) DeepCopy() *StripeEventSource + func (in *StripeEventSource) DeepCopyInto(out *StripeEventSource) + func (m *StripeEventSource) Marshal() (dAtA []byte, err error) + func (m *StripeEventSource) MarshalTo(dAtA []byte) (int, error) + func (m *StripeEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *StripeEventSource) Reset() + func (m *StripeEventSource) Size() (n int) + func (m *StripeEventSource) Unmarshal(dAtA []byte) error + func (m *StripeEventSource) XXX_DiscardUnknown() + func (m *StripeEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *StripeEventSource) XXX_Merge(src proto.Message) + func (m *StripeEventSource) XXX_Size() int + func (m *StripeEventSource) XXX_Unmarshal(b []byte) error + func (this *StripeEventSource) String() string + type TLSConfig struct + CACertSecret *corev1.SecretKeySelector + ClientCertSecret *corev1.SecretKeySelector + ClientKeySecret *corev1.SecretKeySelector + InsecureSkipVerify bool + func (*TLSConfig) Descriptor() ([]byte, []int) + func (*TLSConfig) ProtoMessage() + func (in *TLSConfig) DeepCopy() *TLSConfig + func (in *TLSConfig) DeepCopyInto(out *TLSConfig) + func (m *TLSConfig) Marshal() (dAtA []byte, err error) + func (m *TLSConfig) MarshalTo(dAtA []byte) (int, error) + func (m *TLSConfig) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TLSConfig) Reset() + func (m *TLSConfig) Size() (n int) + func (m *TLSConfig) Unmarshal(dAtA []byte) error + func (m *TLSConfig) XXX_DiscardUnknown() + func (m *TLSConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TLSConfig) XXX_Merge(src proto.Message) + func (m *TLSConfig) XXX_Size() int + func (m *TLSConfig) XXX_Unmarshal(b []byte) error + func (this *TLSConfig) String() string + type Template struct + Affinity *corev1.Affinity + Container *corev1.Container + ImagePullSecrets []corev1.LocalObjectReference + Metadata *Metadata + NodeSelector map[string]string + Priority *int32 + PriorityClassName string + SecurityContext *corev1.PodSecurityContext + ServiceAccountName string + Tolerations []corev1.Toleration + Volumes []corev1.Volume + func (*Template) Descriptor() ([]byte, []int) + func (*Template) ProtoMessage() + func (in *Template) DeepCopy() *Template + func (in *Template) DeepCopyInto(out *Template) + func (m *Template) Marshal() (dAtA []byte, err error) + func (m *Template) MarshalTo(dAtA []byte) (int, error) + func (m *Template) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Template) Reset() + func (m *Template) Size() (n int) + func (m *Template) Unmarshal(dAtA []byte) error + func (m *Template) XXX_DiscardUnknown() + func (m *Template) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Template) XXX_Merge(src proto.Message) + func (m *Template) XXX_Size() int + func (m *Template) XXX_Unmarshal(b []byte) error + func (this *Template) String() string + type TimeFilter struct + Start string + Stop string + func (*TimeFilter) Descriptor() ([]byte, []int) + func (*TimeFilter) ProtoMessage() + func (in *TimeFilter) DeepCopy() *TimeFilter + func (in *TimeFilter) DeepCopyInto(out *TimeFilter) + func (m *TimeFilter) Marshal() (dAtA []byte, err error) + func (m *TimeFilter) MarshalTo(dAtA []byte) (int, error) + func (m *TimeFilter) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TimeFilter) Reset() + func (m *TimeFilter) Size() (n int) + func (m *TimeFilter) Unmarshal(dAtA []byte) error + func (m *TimeFilter) XXX_DiscardUnknown() + func (m *TimeFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TimeFilter) XXX_Merge(src proto.Message) + func (m *TimeFilter) XXX_Size() int + func (m *TimeFilter) XXX_Unmarshal(b []byte) error + func (this *TimeFilter) String() string + type Trigger struct + AtLeastOnce bool + DlqTrigger *Trigger + Parameters []TriggerParameter + Policy *TriggerPolicy + RateLimit *RateLimit + RetryStrategy *Backoff + Template *TriggerTemplate + func (*Trigger) Descriptor() ([]byte, []int) + func (*Trigger) ProtoMessage() + func (in *Trigger) DeepCopy() *Trigger + func (in *Trigger) DeepCopyInto(out *Trigger) + func (m *Trigger) Marshal() (dAtA []byte, err error) + func (m *Trigger) MarshalTo(dAtA []byte) (int, error) + func (m *Trigger) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Trigger) Reset() + func (m *Trigger) Size() (n int) + func (m *Trigger) Unmarshal(dAtA []byte) error + func (m *Trigger) XXX_DiscardUnknown() + func (m *Trigger) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Trigger) XXX_Merge(src proto.Message) + func (m *Trigger) XXX_Size() int + func (m *Trigger) XXX_Unmarshal(b []byte) error + func (this *Trigger) String() string + type TriggerParameter struct + Dest string + Operation TriggerParameterOperation + Src *TriggerParameterSource + func (*TriggerParameter) Descriptor() ([]byte, []int) + func (*TriggerParameter) ProtoMessage() + func (in *TriggerParameter) DeepCopy() *TriggerParameter + func (in *TriggerParameter) DeepCopyInto(out *TriggerParameter) + func (m *TriggerParameter) Marshal() (dAtA []byte, err error) + func (m *TriggerParameter) MarshalTo(dAtA []byte) (int, error) + func (m *TriggerParameter) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TriggerParameter) Reset() + func (m *TriggerParameter) Size() (n int) + func (m *TriggerParameter) Unmarshal(dAtA []byte) error + func (m *TriggerParameter) XXX_DiscardUnknown() + func (m *TriggerParameter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TriggerParameter) XXX_Merge(src proto.Message) + func (m *TriggerParameter) XXX_Size() int + func (m *TriggerParameter) XXX_Unmarshal(b []byte) error + func (this *TriggerParameter) String() string + type TriggerParameterOperation string + const TriggerParameterOpAppend + const TriggerParameterOpNone + const TriggerParameterOpOverwrite + const TriggerParameterOpPrepend + type TriggerParameterSource struct + ContextKey string + ContextTemplate string + DataKey string + DataTemplate string + DependencyName string + UseRawData bool + Value *string + func (*TriggerParameterSource) Descriptor() ([]byte, []int) + func (*TriggerParameterSource) ProtoMessage() + func (in *TriggerParameterSource) DeepCopy() *TriggerParameterSource + func (in *TriggerParameterSource) DeepCopyInto(out *TriggerParameterSource) + func (m *TriggerParameterSource) Marshal() (dAtA []byte, err error) + func (m *TriggerParameterSource) MarshalTo(dAtA []byte) (int, error) + func (m *TriggerParameterSource) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TriggerParameterSource) Reset() + func (m *TriggerParameterSource) Size() (n int) + func (m *TriggerParameterSource) Unmarshal(dAtA []byte) error + func (m *TriggerParameterSource) XXX_DiscardUnknown() + func (m *TriggerParameterSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TriggerParameterSource) XXX_Merge(src proto.Message) + func (m *TriggerParameterSource) XXX_Size() int + func (m *TriggerParameterSource) XXX_Unmarshal(b []byte) error + func (this *TriggerParameterSource) String() string + type TriggerPolicy struct + K8s *K8SResourcePolicy + Status *StatusPolicy + func (*TriggerPolicy) Descriptor() ([]byte, []int) + func (*TriggerPolicy) ProtoMessage() + func (in *TriggerPolicy) DeepCopy() *TriggerPolicy + func (in *TriggerPolicy) DeepCopyInto(out *TriggerPolicy) + func (m *TriggerPolicy) Marshal() (dAtA []byte, err error) + func (m *TriggerPolicy) MarshalTo(dAtA []byte) (int, error) + func (m *TriggerPolicy) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TriggerPolicy) Reset() + func (m *TriggerPolicy) Size() (n int) + func (m *TriggerPolicy) Unmarshal(dAtA []byte) error + func (m *TriggerPolicy) XXX_DiscardUnknown() + func (m *TriggerPolicy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TriggerPolicy) XXX_Merge(src proto.Message) + func (m *TriggerPolicy) XXX_Size() int + func (m *TriggerPolicy) XXX_Unmarshal(b []byte) error + func (this *TriggerPolicy) String() string + type TriggerTemplate struct + AWSLambda *AWSLambdaTrigger + ArgoWorkflow *ArgoWorkflowTrigger + AzureEventHubs *AzureEventHubsTrigger + AzureServiceBus *AzureServiceBusTrigger + Conditions string + ConditionsReset []ConditionsResetCriteria + CustomTrigger *CustomTrigger + Email *EmailTrigger + HTTP *HTTPTrigger + K8s *StandardK8STrigger + Kafka *KafkaTrigger + Log *LogTrigger + NATS *NATSTrigger + Name string + OpenWhisk *OpenWhiskTrigger + Pulsar *PulsarTrigger + Slack *SlackTrigger + func (*TriggerTemplate) Descriptor() ([]byte, []int) + func (*TriggerTemplate) ProtoMessage() + func (in *TriggerTemplate) DeepCopy() *TriggerTemplate + func (in *TriggerTemplate) DeepCopyInto(out *TriggerTemplate) + func (m *TriggerTemplate) Marshal() (dAtA []byte, err error) + func (m *TriggerTemplate) MarshalTo(dAtA []byte) (int, error) + func (m *TriggerTemplate) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TriggerTemplate) Reset() + func (m *TriggerTemplate) Size() (n int) + func (m *TriggerTemplate) Unmarshal(dAtA []byte) error + func (m *TriggerTemplate) XXX_DiscardUnknown() + func (m *TriggerTemplate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TriggerTemplate) XXX_Merge(src proto.Message) + func (m *TriggerTemplate) XXX_Size() int + func (m *TriggerTemplate) XXX_Unmarshal(b []byte) error + func (this *TriggerTemplate) String() string + type TriggerType string + var TriggerTypeArgoWorkflow TriggerType = "ArgoWorkflow" + var TriggerTypeAzureEventHubs TriggerType = "AzureEventHubs" + var TriggerTypeAzureServiceBus TriggerType = "AzureServiceBus" + var TriggerTypeCustom TriggerType = "Custom" + var TriggerTypeEmail TriggerType = "Email" + var TriggerTypeHTTP TriggerType = "HTTP" + var TriggerTypeK8s TriggerType = "Kubernetes" + var TriggerTypeKafka TriggerType = "Kafka" + var TriggerTypeLambda TriggerType = "Lambda" + var TriggerTypeLog TriggerType = "Log" + var TriggerTypeNATS TriggerType = "NATS" + var TriggerTypeOpenWhisk TriggerType = "OpenWhisk" + var TriggerTypePulsar TriggerType = "Pulsar" + var TriggerTypeSlack TriggerType = "Slack" + type Type int64 + const Int64 + const String + type URLArtifact struct + Path string + VerifyCert bool + func (*URLArtifact) Descriptor() ([]byte, []int) + func (*URLArtifact) ProtoMessage() + func (in *URLArtifact) DeepCopy() *URLArtifact + func (in *URLArtifact) DeepCopyInto(out *URLArtifact) + func (m *URLArtifact) Marshal() (dAtA []byte, err error) + func (m *URLArtifact) MarshalTo(dAtA []byte) (int, error) + func (m *URLArtifact) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *URLArtifact) Reset() + func (m *URLArtifact) Size() (n int) + func (m *URLArtifact) Unmarshal(dAtA []byte) error + func (m *URLArtifact) XXX_DiscardUnknown() + func (m *URLArtifact) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *URLArtifact) XXX_Merge(src proto.Message) + func (m *URLArtifact) XXX_Size() int + func (m *URLArtifact) XXX_Unmarshal(b []byte) error + func (this *URLArtifact) String() string + type ValueFromSource struct + ConfigMapKeyRef *corev1.ConfigMapKeySelector + SecretKeyRef *corev1.SecretKeySelector + func (*ValueFromSource) Descriptor() ([]byte, []int) + func (*ValueFromSource) ProtoMessage() + func (in *ValueFromSource) DeepCopy() *ValueFromSource + func (in *ValueFromSource) DeepCopyInto(out *ValueFromSource) + func (m *ValueFromSource) Marshal() (dAtA []byte, err error) + func (m *ValueFromSource) MarshalTo(dAtA []byte) (int, error) + func (m *ValueFromSource) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ValueFromSource) Reset() + func (m *ValueFromSource) Size() (n int) + func (m *ValueFromSource) Unmarshal(dAtA []byte) error + func (m *ValueFromSource) XXX_DiscardUnknown() + func (m *ValueFromSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ValueFromSource) XXX_Merge(src proto.Message) + func (m *ValueFromSource) XXX_Size() int + func (m *ValueFromSource) XXX_Unmarshal(b []byte) error + func (this *ValueFromSource) String() string + type WatchPathConfig struct + Directory string + Path string + PathRegexp string + func (*WatchPathConfig) Descriptor() ([]byte, []int) + func (*WatchPathConfig) ProtoMessage() + func (c *WatchPathConfig) Validate() error + func (in *WatchPathConfig) DeepCopy() *WatchPathConfig + func (in *WatchPathConfig) DeepCopyInto(out *WatchPathConfig) + func (m *WatchPathConfig) Marshal() (dAtA []byte, err error) + func (m *WatchPathConfig) MarshalTo(dAtA []byte) (int, error) + func (m *WatchPathConfig) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *WatchPathConfig) Reset() + func (m *WatchPathConfig) Size() (n int) + func (m *WatchPathConfig) Unmarshal(dAtA []byte) error + func (m *WatchPathConfig) XXX_DiscardUnknown() + func (m *WatchPathConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *WatchPathConfig) XXX_Merge(src proto.Message) + func (m *WatchPathConfig) XXX_Size() int + func (m *WatchPathConfig) XXX_Unmarshal(b []byte) error + func (this *WatchPathConfig) String() string + type WebhookContext struct + AuthSecret *corev1.SecretKeySelector + Endpoint string + MaxPayloadSize *int64 + Metadata map[string]string + Method string + Port string + ServerCertSecret *corev1.SecretKeySelector + ServerKeySecret *corev1.SecretKeySelector + URL string + func (*WebhookContext) Descriptor() ([]byte, []int) + func (*WebhookContext) ProtoMessage() + func (in *WebhookContext) DeepCopy() *WebhookContext + func (in *WebhookContext) DeepCopyInto(out *WebhookContext) + func (m *WebhookContext) Marshal() (dAtA []byte, err error) + func (m *WebhookContext) MarshalTo(dAtA []byte) (int, error) + func (m *WebhookContext) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *WebhookContext) Reset() + func (m *WebhookContext) Size() (n int) + func (m *WebhookContext) Unmarshal(dAtA []byte) error + func (m *WebhookContext) XXX_DiscardUnknown() + func (m *WebhookContext) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *WebhookContext) XXX_Merge(src proto.Message) + func (m *WebhookContext) XXX_Size() int + func (m *WebhookContext) XXX_Unmarshal(b []byte) error + func (this *WebhookContext) String() string + func (wc *WebhookContext) GetMaxPayloadSize() int64 + type WebhookEventSource struct + Filter *EventSourceFilter + func (*WebhookEventSource) Descriptor() ([]byte, []int) + func (*WebhookEventSource) ProtoMessage() + func (in *WebhookEventSource) DeepCopy() *WebhookEventSource + func (in *WebhookEventSource) DeepCopyInto(out *WebhookEventSource) + func (m *WebhookEventSource) Marshal() (dAtA []byte, err error) + func (m *WebhookEventSource) MarshalTo(dAtA []byte) (int, error) + func (m *WebhookEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *WebhookEventSource) Reset() + func (m *WebhookEventSource) Size() (n int) + func (m *WebhookEventSource) Unmarshal(dAtA []byte) error + func (m *WebhookEventSource) XXX_DiscardUnknown() + func (m *WebhookEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *WebhookEventSource) XXX_Merge(src proto.Message) + func (m *WebhookEventSource) XXX_Size() int + func (m *WebhookEventSource) XXX_Unmarshal(b []byte) error + func (this *WebhookEventSource) String() string
Go to main page