Documentation ¶
Overview ¶
Package v1alpha1 is the v1alpha1 version of the API. +groupName=argoproj.io +k8s:deepcopy-gen=package,register +k8s:openapi-gen=true
Package v1alpha1 contains API Schema definitions for the sources v1alpha1 API group +k8s:openapi-gen=true +k8s:deepcopy-gen=package,register +k8s:defaulter-gen=TypeMeta +groupName=argoproj.io
Index ¶
- Constants
- Variables
- func GetOpenAPIDefinitions(ref common.ReferenceCallback) map[string]common.OpenAPIDefinition
- func Kind(kind string) schema.GroupKind
- func Resource(resource string) schema.GroupResource
- func ValidateEventSource(eventSource *EventSource) error
- type AMQPConsumeConfig
- func (in *AMQPConsumeConfig) DeepCopy() *AMQPConsumeConfig
- func (in *AMQPConsumeConfig) DeepCopyInto(out *AMQPConsumeConfig)
- func (*AMQPConsumeConfig) Descriptor() ([]byte, []int)
- 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 (*AMQPConsumeConfig) ProtoMessage()
- func (m *AMQPConsumeConfig) Reset()
- func (m *AMQPConsumeConfig) Size() (n int)
- func (this *AMQPConsumeConfig) String() string
- 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
- type AMQPEventSource
- func (in *AMQPEventSource) DeepCopy() *AMQPEventSource
- func (in *AMQPEventSource) DeepCopyInto(out *AMQPEventSource)
- func (*AMQPEventSource) Descriptor() ([]byte, []int)
- 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 (*AMQPEventSource) ProtoMessage()
- func (m *AMQPEventSource) Reset()
- func (m *AMQPEventSource) Size() (n int)
- func (this *AMQPEventSource) String() string
- 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
- type AMQPExchangeDeclareConfig
- func (in *AMQPExchangeDeclareConfig) DeepCopy() *AMQPExchangeDeclareConfig
- func (in *AMQPExchangeDeclareConfig) DeepCopyInto(out *AMQPExchangeDeclareConfig)
- func (*AMQPExchangeDeclareConfig) Descriptor() ([]byte, []int)
- 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 (*AMQPExchangeDeclareConfig) ProtoMessage()
- func (m *AMQPExchangeDeclareConfig) Reset()
- func (m *AMQPExchangeDeclareConfig) Size() (n int)
- func (this *AMQPExchangeDeclareConfig) String() string
- 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
- type AMQPQueueBindConfig
- func (in *AMQPQueueBindConfig) DeepCopy() *AMQPQueueBindConfig
- func (in *AMQPQueueBindConfig) DeepCopyInto(out *AMQPQueueBindConfig)
- func (*AMQPQueueBindConfig) Descriptor() ([]byte, []int)
- 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 (*AMQPQueueBindConfig) ProtoMessage()
- func (m *AMQPQueueBindConfig) Reset()
- func (m *AMQPQueueBindConfig) Size() (n int)
- func (this *AMQPQueueBindConfig) String() string
- 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
- type AMQPQueueDeclareConfig
- func (in *AMQPQueueDeclareConfig) DeepCopy() *AMQPQueueDeclareConfig
- func (in *AMQPQueueDeclareConfig) DeepCopyInto(out *AMQPQueueDeclareConfig)
- func (*AMQPQueueDeclareConfig) Descriptor() ([]byte, []int)
- 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 (*AMQPQueueDeclareConfig) ProtoMessage()
- func (m *AMQPQueueDeclareConfig) Reset()
- func (m *AMQPQueueDeclareConfig) Size() (n int)
- func (this *AMQPQueueDeclareConfig) String() string
- 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
- type AzureEventsHubEventSource
- func (in *AzureEventsHubEventSource) DeepCopy() *AzureEventsHubEventSource
- func (in *AzureEventsHubEventSource) DeepCopyInto(out *AzureEventsHubEventSource)
- func (*AzureEventsHubEventSource) Descriptor() ([]byte, []int)
- 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 (*AzureEventsHubEventSource) ProtoMessage()
- func (m *AzureEventsHubEventSource) Reset()
- func (m *AzureEventsHubEventSource) Size() (n int)
- func (this *AzureEventsHubEventSource) String() string
- 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
- type AzureQueueStorageEventSource
- func (in *AzureQueueStorageEventSource) DeepCopy() *AzureQueueStorageEventSource
- func (in *AzureQueueStorageEventSource) DeepCopyInto(out *AzureQueueStorageEventSource)
- func (*AzureQueueStorageEventSource) Descriptor() ([]byte, []int)
- 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 (*AzureQueueStorageEventSource) ProtoMessage()
- func (m *AzureQueueStorageEventSource) Reset()
- func (m *AzureQueueStorageEventSource) Size() (n int)
- func (this *AzureQueueStorageEventSource) String() string
- 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
- type AzureServiceBusEventSource
- func (in *AzureServiceBusEventSource) DeepCopy() *AzureServiceBusEventSource
- func (in *AzureServiceBusEventSource) DeepCopyInto(out *AzureServiceBusEventSource)
- func (*AzureServiceBusEventSource) Descriptor() ([]byte, []int)
- 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 (*AzureServiceBusEventSource) ProtoMessage()
- func (m *AzureServiceBusEventSource) Reset()
- func (m *AzureServiceBusEventSource) Size() (n int)
- func (this *AzureServiceBusEventSource) String() string
- 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
- type BitbucketAuth
- func (in *BitbucketAuth) DeepCopy() *BitbucketAuth
- func (in *BitbucketAuth) DeepCopyInto(out *BitbucketAuth)
- func (*BitbucketAuth) Descriptor() ([]byte, []int)
- 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 (*BitbucketAuth) ProtoMessage()
- func (m *BitbucketAuth) Reset()
- func (m *BitbucketAuth) Size() (n int)
- func (this *BitbucketAuth) String() string
- 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
- type BitbucketBasicAuth
- func (in *BitbucketBasicAuth) DeepCopy() *BitbucketBasicAuth
- func (in *BitbucketBasicAuth) DeepCopyInto(out *BitbucketBasicAuth)
- func (*BitbucketBasicAuth) Descriptor() ([]byte, []int)
- 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 (*BitbucketBasicAuth) ProtoMessage()
- func (m *BitbucketBasicAuth) Reset()
- func (m *BitbucketBasicAuth) Size() (n int)
- func (this *BitbucketBasicAuth) String() string
- 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
- type BitbucketEventSource
- func (in *BitbucketEventSource) DeepCopy() *BitbucketEventSource
- func (in *BitbucketEventSource) DeepCopyInto(out *BitbucketEventSource)
- func (*BitbucketEventSource) Descriptor() ([]byte, []int)
- func (b BitbucketEventSource) GetBitbucketRepositories() []BitbucketRepository
- func (b BitbucketEventSource) HasBitbucketBasicAuth() bool
- func (b BitbucketEventSource) HasBitbucketOAuthToken() bool
- func (b BitbucketEventSource) HasConfiguredWebhook() bool
- 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 (*BitbucketEventSource) ProtoMessage()
- func (m *BitbucketEventSource) Reset()
- func (b BitbucketEventSource) ShouldCreateWebhooks() bool
- func (m *BitbucketEventSource) Size() (n int)
- func (this *BitbucketEventSource) String() string
- 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
- type BitbucketRepository
- func (in *BitbucketRepository) DeepCopy() *BitbucketRepository
- func (in *BitbucketRepository) DeepCopyInto(out *BitbucketRepository)
- func (*BitbucketRepository) Descriptor() ([]byte, []int)
- func (r BitbucketRepository) GetRepositoryID() string
- 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 (*BitbucketRepository) ProtoMessage()
- func (m *BitbucketRepository) Reset()
- func (m *BitbucketRepository) Size() (n int)
- func (this *BitbucketRepository) String() string
- 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
- type BitbucketServerEventSource
- func (in *BitbucketServerEventSource) DeepCopy() *BitbucketServerEventSource
- func (in *BitbucketServerEventSource) DeepCopyInto(out *BitbucketServerEventSource)
- func (*BitbucketServerEventSource) Descriptor() ([]byte, []int)
- func (b BitbucketServerEventSource) GetBitbucketServerRepositories() []BitbucketServerRepository
- 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 (*BitbucketServerEventSource) ProtoMessage()
- func (m *BitbucketServerEventSource) Reset()
- func (b BitbucketServerEventSource) ShouldCreateWebhooks() bool
- func (m *BitbucketServerEventSource) Size() (n int)
- func (this *BitbucketServerEventSource) String() string
- 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
- type BitbucketServerRepository
- func (in *BitbucketServerRepository) DeepCopy() *BitbucketServerRepository
- func (in *BitbucketServerRepository) DeepCopyInto(out *BitbucketServerRepository)
- func (*BitbucketServerRepository) Descriptor() ([]byte, []int)
- 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 (*BitbucketServerRepository) ProtoMessage()
- func (m *BitbucketServerRepository) Reset()
- func (m *BitbucketServerRepository) Size() (n int)
- func (this *BitbucketServerRepository) String() string
- 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
- type CalendarEventSource
- func (in *CalendarEventSource) DeepCopy() *CalendarEventSource
- func (in *CalendarEventSource) DeepCopyInto(out *CalendarEventSource)
- func (*CalendarEventSource) Descriptor() ([]byte, []int)
- 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 (*CalendarEventSource) ProtoMessage()
- func (m *CalendarEventSource) Reset()
- func (m *CalendarEventSource) Size() (n int)
- func (this *CalendarEventSource) String() string
- 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
- type CatchupConfiguration
- func (in *CatchupConfiguration) DeepCopy() *CatchupConfiguration
- func (in *CatchupConfiguration) DeepCopyInto(out *CatchupConfiguration)
- func (*CatchupConfiguration) Descriptor() ([]byte, []int)
- 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 (*CatchupConfiguration) ProtoMessage()
- func (m *CatchupConfiguration) Reset()
- func (m *CatchupConfiguration) Size() (n int)
- func (this *CatchupConfiguration) String() string
- 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
- type ConfigMapPersistence
- func (in *ConfigMapPersistence) DeepCopy() *ConfigMapPersistence
- func (in *ConfigMapPersistence) DeepCopyInto(out *ConfigMapPersistence)
- func (*ConfigMapPersistence) Descriptor() ([]byte, []int)
- 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 (*ConfigMapPersistence) ProtoMessage()
- func (m *ConfigMapPersistence) Reset()
- func (m *ConfigMapPersistence) Size() (n int)
- func (this *ConfigMapPersistence) String() string
- 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
- type EmitterEventSource
- func (in *EmitterEventSource) DeepCopy() *EmitterEventSource
- func (in *EmitterEventSource) DeepCopyInto(out *EmitterEventSource)
- func (*EmitterEventSource) Descriptor() ([]byte, []int)
- 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 (*EmitterEventSource) ProtoMessage()
- func (m *EmitterEventSource) Reset()
- func (m *EmitterEventSource) Size() (n int)
- func (this *EmitterEventSource) String() string
- 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
- type EventPersistence
- func (in *EventPersistence) DeepCopy() *EventPersistence
- func (in *EventPersistence) DeepCopyInto(out *EventPersistence)
- func (*EventPersistence) Descriptor() ([]byte, []int)
- func (ep *EventPersistence) IsCatchUpEnabled() bool
- 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 (*EventPersistence) ProtoMessage()
- func (m *EventPersistence) Reset()
- func (m *EventPersistence) Size() (n int)
- func (this *EventPersistence) String() string
- 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
- type EventSource
- func (in *EventSource) DeepCopy() *EventSource
- func (in *EventSource) DeepCopyInto(out *EventSource)
- func (in *EventSource) DeepCopyObject() runtime.Object
- func (*EventSource) Descriptor() ([]byte, []int)
- 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 (*EventSource) ProtoMessage()
- func (m *EventSource) Reset()
- func (m *EventSource) Size() (n int)
- func (this *EventSource) String() string
- 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
- type EventSourceFilter
- func (in *EventSourceFilter) DeepCopy() *EventSourceFilter
- func (in *EventSourceFilter) DeepCopyInto(out *EventSourceFilter)
- func (*EventSourceFilter) Descriptor() ([]byte, []int)
- 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 (*EventSourceFilter) ProtoMessage()
- func (m *EventSourceFilter) Reset()
- func (m *EventSourceFilter) Size() (n int)
- func (this *EventSourceFilter) String() string
- 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
- type EventSourceList
- func (in *EventSourceList) DeepCopy() *EventSourceList
- func (in *EventSourceList) DeepCopyInto(out *EventSourceList)
- func (in *EventSourceList) DeepCopyObject() runtime.Object
- func (*EventSourceList) Descriptor() ([]byte, []int)
- 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 (*EventSourceList) ProtoMessage()
- func (m *EventSourceList) Reset()
- func (m *EventSourceList) Size() (n int)
- func (this *EventSourceList) String() string
- 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
- type EventSourceSpec
- func (in *EventSourceSpec) DeepCopy() *EventSourceSpec
- func (in *EventSourceSpec) DeepCopyInto(out *EventSourceSpec)
- func (*EventSourceSpec) Descriptor() ([]byte, []int)
- func (e EventSourceSpec) GetReplicas() int32
- 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 (*EventSourceSpec) ProtoMessage()
- func (m *EventSourceSpec) Reset()
- func (m *EventSourceSpec) Size() (n int)
- func (this *EventSourceSpec) String() string
- 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
- type EventSourceStatus
- func (in *EventSourceStatus) DeepCopy() *EventSourceStatus
- func (in *EventSourceStatus) DeepCopyInto(out *EventSourceStatus)
- func (*EventSourceStatus) Descriptor() ([]byte, []int)
- 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 (m *EventSourceStatus) Marshal() (dAtA []byte, err error)
- func (m *EventSourceStatus) MarshalTo(dAtA []byte) (int, error)
- func (m *EventSourceStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*EventSourceStatus) ProtoMessage()
- func (m *EventSourceStatus) Reset()
- func (m *EventSourceStatus) Size() (n int)
- func (this *EventSourceStatus) String() string
- 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
- type FileEventSource
- func (in *FileEventSource) DeepCopy() *FileEventSource
- func (in *FileEventSource) DeepCopyInto(out *FileEventSource)
- func (*FileEventSource) Descriptor() ([]byte, []int)
- 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 (*FileEventSource) ProtoMessage()
- func (m *FileEventSource) Reset()
- func (m *FileEventSource) Size() (n int)
- func (this *FileEventSource) String() string
- 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
- type GenericEventSource
- func (in *GenericEventSource) DeepCopy() *GenericEventSource
- func (in *GenericEventSource) DeepCopyInto(out *GenericEventSource)
- func (*GenericEventSource) Descriptor() ([]byte, []int)
- 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 (*GenericEventSource) ProtoMessage()
- func (m *GenericEventSource) Reset()
- func (m *GenericEventSource) Size() (n int)
- func (this *GenericEventSource) String() string
- 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
- type GerritEventSource
- func (in *GerritEventSource) DeepCopy() *GerritEventSource
- func (in *GerritEventSource) DeepCopyInto(out *GerritEventSource)
- func (*GerritEventSource) Descriptor() ([]byte, []int)
- 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 (g GerritEventSource) NeedToCreateHooks() bool
- func (*GerritEventSource) ProtoMessage()
- func (m *GerritEventSource) Reset()
- func (m *GerritEventSource) Size() (n int)
- func (this *GerritEventSource) String() string
- 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
- type GithubAppCreds
- func (in *GithubAppCreds) DeepCopy() *GithubAppCreds
- func (in *GithubAppCreds) DeepCopyInto(out *GithubAppCreds)
- func (*GithubAppCreds) Descriptor() ([]byte, []int)
- 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 (*GithubAppCreds) ProtoMessage()
- func (m *GithubAppCreds) Reset()
- func (m *GithubAppCreds) Size() (n int)
- func (this *GithubAppCreds) String() string
- 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
- type GithubEventSource
- func (in *GithubEventSource) DeepCopy() *GithubEventSource
- func (in *GithubEventSource) DeepCopyInto(out *GithubEventSource)
- func (*GithubEventSource) Descriptor() ([]byte, []int)
- func (g GithubEventSource) GetOwnedRepositories() []OwnedRepositories
- func (g GithubEventSource) HasConfiguredWebhook() bool
- func (g GithubEventSource) HasGithubAPIToken() bool
- func (g GithubEventSource) HasGithubAppCreds() bool
- 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 (g GithubEventSource) NeedToCreateHooks() bool
- func (*GithubEventSource) ProtoMessage()
- func (m *GithubEventSource) Reset()
- func (m *GithubEventSource) Size() (n int)
- func (this *GithubEventSource) String() string
- 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
- type GitlabEventSource
- func (in *GitlabEventSource) DeepCopy() *GitlabEventSource
- func (in *GitlabEventSource) DeepCopyInto(out *GitlabEventSource)
- func (*GitlabEventSource) Descriptor() ([]byte, []int)
- func (g GitlabEventSource) GetGroups() []string
- func (g GitlabEventSource) GetProjects() []string
- 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 (g GitlabEventSource) NeedToCreateHooks() bool
- func (*GitlabEventSource) ProtoMessage()
- func (m *GitlabEventSource) Reset()
- func (m *GitlabEventSource) Size() (n int)
- func (this *GitlabEventSource) String() string
- 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
- type HDFSEventSource
- func (in *HDFSEventSource) DeepCopy() *HDFSEventSource
- func (in *HDFSEventSource) DeepCopyInto(out *HDFSEventSource)
- func (*HDFSEventSource) Descriptor() ([]byte, []int)
- 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 (*HDFSEventSource) ProtoMessage()
- func (m *HDFSEventSource) Reset()
- func (m *HDFSEventSource) Size() (n int)
- func (this *HDFSEventSource) String() string
- 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
- type KafkaConsumerGroup
- func (in *KafkaConsumerGroup) DeepCopy() *KafkaConsumerGroup
- func (in *KafkaConsumerGroup) DeepCopyInto(out *KafkaConsumerGroup)
- func (*KafkaConsumerGroup) Descriptor() ([]byte, []int)
- 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 (*KafkaConsumerGroup) ProtoMessage()
- func (m *KafkaConsumerGroup) Reset()
- func (m *KafkaConsumerGroup) Size() (n int)
- func (this *KafkaConsumerGroup) String() string
- 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
- type KafkaEventSource
- func (in *KafkaEventSource) DeepCopy() *KafkaEventSource
- func (in *KafkaEventSource) DeepCopyInto(out *KafkaEventSource)
- func (*KafkaEventSource) Descriptor() ([]byte, []int)
- 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 (*KafkaEventSource) ProtoMessage()
- func (m *KafkaEventSource) Reset()
- func (m *KafkaEventSource) Size() (n int)
- func (this *KafkaEventSource) String() string
- 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
- type MQTTEventSource
- func (in *MQTTEventSource) DeepCopy() *MQTTEventSource
- func (in *MQTTEventSource) DeepCopyInto(out *MQTTEventSource)
- func (*MQTTEventSource) Descriptor() ([]byte, []int)
- 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 (*MQTTEventSource) ProtoMessage()
- func (m *MQTTEventSource) Reset()
- func (m *MQTTEventSource) Size() (n int)
- func (this *MQTTEventSource) String() string
- 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
- type NATSAuth
- func (in *NATSAuth) DeepCopy() *NATSAuth
- func (in *NATSAuth) DeepCopyInto(out *NATSAuth)
- func (*NATSAuth) Descriptor() ([]byte, []int)
- 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 (*NATSAuth) ProtoMessage()
- func (m *NATSAuth) Reset()
- func (m *NATSAuth) Size() (n int)
- func (this *NATSAuth) String() string
- 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
- type NATSEventsSource
- func (in *NATSEventsSource) DeepCopy() *NATSEventsSource
- func (in *NATSEventsSource) DeepCopyInto(out *NATSEventsSource)
- func (*NATSEventsSource) Descriptor() ([]byte, []int)
- 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 (*NATSEventsSource) ProtoMessage()
- func (m *NATSEventsSource) Reset()
- func (m *NATSEventsSource) Size() (n int)
- func (this *NATSEventsSource) String() string
- 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
- type NSQEventSource
- func (in *NSQEventSource) DeepCopy() *NSQEventSource
- func (in *NSQEventSource) DeepCopyInto(out *NSQEventSource)
- func (*NSQEventSource) Descriptor() ([]byte, []int)
- 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 (*NSQEventSource) ProtoMessage()
- func (m *NSQEventSource) Reset()
- func (m *NSQEventSource) Size() (n int)
- func (this *NSQEventSource) String() string
- 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
- type OwnedRepositories
- func (in *OwnedRepositories) DeepCopy() *OwnedRepositories
- func (in *OwnedRepositories) DeepCopyInto(out *OwnedRepositories)
- func (*OwnedRepositories) Descriptor() ([]byte, []int)
- 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 (*OwnedRepositories) ProtoMessage()
- func (m *OwnedRepositories) Reset()
- func (m *OwnedRepositories) Size() (n int)
- func (this *OwnedRepositories) String() string
- 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
- type PubSubEventSource
- func (in *PubSubEventSource) DeepCopy() *PubSubEventSource
- func (in *PubSubEventSource) DeepCopyInto(out *PubSubEventSource)
- func (*PubSubEventSource) Descriptor() ([]byte, []int)
- 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 (*PubSubEventSource) ProtoMessage()
- func (m *PubSubEventSource) Reset()
- func (m *PubSubEventSource) Size() (n int)
- func (this *PubSubEventSource) String() string
- 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
- type PulsarEventSource
- func (in *PulsarEventSource) DeepCopy() *PulsarEventSource
- func (in *PulsarEventSource) DeepCopyInto(out *PulsarEventSource)
- func (*PulsarEventSource) Descriptor() ([]byte, []int)
- 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 (*PulsarEventSource) ProtoMessage()
- func (m *PulsarEventSource) Reset()
- func (m *PulsarEventSource) Size() (n int)
- func (this *PulsarEventSource) String() string
- 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
- type RedisEventSource
- func (in *RedisEventSource) DeepCopy() *RedisEventSource
- func (in *RedisEventSource) DeepCopyInto(out *RedisEventSource)
- func (*RedisEventSource) Descriptor() ([]byte, []int)
- 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 (*RedisEventSource) ProtoMessage()
- func (m *RedisEventSource) Reset()
- func (m *RedisEventSource) Size() (n int)
- func (this *RedisEventSource) String() string
- 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
- type RedisStreamEventSource
- func (in *RedisStreamEventSource) DeepCopy() *RedisStreamEventSource
- func (in *RedisStreamEventSource) DeepCopyInto(out *RedisStreamEventSource)
- func (*RedisStreamEventSource) Descriptor() ([]byte, []int)
- 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 (*RedisStreamEventSource) ProtoMessage()
- func (m *RedisStreamEventSource) Reset()
- func (m *RedisStreamEventSource) Size() (n int)
- func (this *RedisStreamEventSource) String() string
- 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
- type ResourceEventSource
- func (in *ResourceEventSource) DeepCopy() *ResourceEventSource
- func (in *ResourceEventSource) DeepCopyInto(out *ResourceEventSource)
- func (*ResourceEventSource) Descriptor() ([]byte, []int)
- 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 (*ResourceEventSource) ProtoMessage()
- func (m *ResourceEventSource) Reset()
- func (m *ResourceEventSource) Size() (n int)
- func (this *ResourceEventSource) String() string
- 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
- type ResourceEventType
- type ResourceFilter
- func (in *ResourceFilter) DeepCopy() *ResourceFilter
- func (in *ResourceFilter) DeepCopyInto(out *ResourceFilter)
- func (*ResourceFilter) Descriptor() ([]byte, []int)
- 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 (*ResourceFilter) ProtoMessage()
- func (m *ResourceFilter) Reset()
- func (m *ResourceFilter) Size() (n int)
- func (this *ResourceFilter) String() string
- 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
- type SFTPEventSource
- func (in *SFTPEventSource) DeepCopy() *SFTPEventSource
- func (in *SFTPEventSource) DeepCopyInto(out *SFTPEventSource)
- func (*SFTPEventSource) Descriptor() ([]byte, []int)
- 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 (*SFTPEventSource) ProtoMessage()
- func (m *SFTPEventSource) Reset()
- func (m *SFTPEventSource) Size() (n int)
- func (this *SFTPEventSource) String() string
- 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
- type SNSEventSource
- func (in *SNSEventSource) DeepCopy() *SNSEventSource
- func (in *SNSEventSource) DeepCopyInto(out *SNSEventSource)
- func (*SNSEventSource) Descriptor() ([]byte, []int)
- 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 (*SNSEventSource) ProtoMessage()
- func (m *SNSEventSource) Reset()
- func (m *SNSEventSource) Size() (n int)
- func (this *SNSEventSource) String() string
- 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
- type SQSEventSource
- func (in *SQSEventSource) DeepCopy() *SQSEventSource
- func (in *SQSEventSource) DeepCopyInto(out *SQSEventSource)
- func (*SQSEventSource) Descriptor() ([]byte, []int)
- 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 (*SQSEventSource) ProtoMessage()
- func (m *SQSEventSource) Reset()
- func (m *SQSEventSource) Size() (n int)
- func (this *SQSEventSource) String() string
- 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
- type Selector
- func (in *Selector) DeepCopy() *Selector
- func (in *Selector) DeepCopyInto(out *Selector)
- func (*Selector) Descriptor() ([]byte, []int)
- 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 (*Selector) ProtoMessage()
- func (m *Selector) Reset()
- func (m *Selector) Size() (n int)
- func (this *Selector) String() string
- 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
- type Service
- func (in *Service) DeepCopy() *Service
- func (in *Service) DeepCopyInto(out *Service)
- func (*Service) Descriptor() ([]byte, []int)
- 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 (*Service) ProtoMessage()
- func (m *Service) Reset()
- func (m *Service) Size() (n int)
- func (this *Service) String() string
- 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
- type SlackEventSource
- func (in *SlackEventSource) DeepCopy() *SlackEventSource
- func (in *SlackEventSource) DeepCopyInto(out *SlackEventSource)
- func (*SlackEventSource) Descriptor() ([]byte, []int)
- 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 (*SlackEventSource) ProtoMessage()
- func (m *SlackEventSource) Reset()
- func (m *SlackEventSource) Size() (n int)
- func (this *SlackEventSource) String() string
- 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
- type StorageGridEventSource
- func (in *StorageGridEventSource) DeepCopy() *StorageGridEventSource
- func (in *StorageGridEventSource) DeepCopyInto(out *StorageGridEventSource)
- func (*StorageGridEventSource) Descriptor() ([]byte, []int)
- 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 (*StorageGridEventSource) ProtoMessage()
- func (m *StorageGridEventSource) Reset()
- func (m *StorageGridEventSource) Size() (n int)
- func (this *StorageGridEventSource) String() string
- 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
- type StorageGridFilter
- func (in *StorageGridFilter) DeepCopy() *StorageGridFilter
- func (in *StorageGridFilter) DeepCopyInto(out *StorageGridFilter)
- func (*StorageGridFilter) Descriptor() ([]byte, []int)
- 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 (*StorageGridFilter) ProtoMessage()
- func (m *StorageGridFilter) Reset()
- func (m *StorageGridFilter) Size() (n int)
- func (this *StorageGridFilter) String() string
- 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
- type StripeEventSource
- func (in *StripeEventSource) DeepCopy() *StripeEventSource
- func (in *StripeEventSource) DeepCopyInto(out *StripeEventSource)
- func (*StripeEventSource) Descriptor() ([]byte, []int)
- 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 (*StripeEventSource) ProtoMessage()
- func (m *StripeEventSource) Reset()
- func (m *StripeEventSource) Size() (n int)
- func (this *StripeEventSource) String() string
- 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
- type Template
- func (in *Template) DeepCopy() *Template
- func (in *Template) DeepCopyInto(out *Template)
- func (*Template) Descriptor() ([]byte, []int)
- 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 (*Template) ProtoMessage()
- func (m *Template) Reset()
- func (m *Template) Size() (n int)
- func (this *Template) String() string
- 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
- type WatchPathConfig
- func (in *WatchPathConfig) DeepCopy() *WatchPathConfig
- func (in *WatchPathConfig) DeepCopyInto(out *WatchPathConfig)
- func (*WatchPathConfig) Descriptor() ([]byte, []int)
- 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 (*WatchPathConfig) ProtoMessage()
- func (m *WatchPathConfig) Reset()
- func (m *WatchPathConfig) Size() (n int)
- func (this *WatchPathConfig) String() string
- func (m *WatchPathConfig) Unmarshal(dAtA []byte) error
- func (c *WatchPathConfig) Validate() 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
- type WebhookContext
- func (in *WebhookContext) DeepCopy() *WebhookContext
- func (in *WebhookContext) DeepCopyInto(out *WebhookContext)
- func (*WebhookContext) Descriptor() ([]byte, []int)
- func (wc *WebhookContext) GetMaxPayloadSize() int64
- 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 (*WebhookContext) ProtoMessage()
- func (m *WebhookContext) Reset()
- func (m *WebhookContext) Size() (n int)
- func (this *WebhookContext) String() string
- 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
- type WebhookEventSource
- func (in *WebhookEventSource) DeepCopy() *WebhookEventSource
- func (in *WebhookEventSource) DeepCopyInto(out *WebhookEventSource)
- func (*WebhookEventSource) Descriptor() ([]byte, []int)
- 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 (*WebhookEventSource) ProtoMessage()
- func (m *WebhookEventSource) Reset()
- func (m *WebhookEventSource) Size() (n int)
- func (this *WebhookEventSource) String() string
- 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
Constants ¶
const ( // EventSourceConditionSourcesProvided has the status True when the EventSource // has its event source provided. EventSourceConditionSourcesProvided apicommon.ConditionType = "SourcesProvided" // EventSourceConditionDeployed has the status True when the EventSource // has its Deployment created. EventSourceConditionDeployed apicommon.ConditionType = "Deployed" )
const DefaultMaxWebhookPayloadSize int64 = 1048576 // 1MB
Variables ¶
var ( ErrInvalidLengthGenerated = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowGenerated = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupGenerated = fmt.Errorf("proto: unexpected end of group") )
var ( // SchemeGroupVersion is a group version used to register these objects SchemeGroupVersion = schema.GroupVersion{Group: eventsource.Group, Version: "v1alpha1"} // SchemaGroupVersionKind is a group version kind used to attach owner references to eventsource-controller SchemaGroupVersionKind = SchemeGroupVersion.WithKind(eventsource.Kind) // SchemeBuilder is used to add go types to the GroupVersionKind scheme SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes) // AddToScheme is required by pkg/client/... AddToScheme = SchemeBuilder.AddToScheme )
Functions ¶
func GetOpenAPIDefinitions ¶
func GetOpenAPIDefinitions(ref common.ReferenceCallback) map[string]common.OpenAPIDefinition
func Resource ¶
func Resource(resource string) schema.GroupResource
Resource takes unqualified resource and returns Group qualified GroupResource
func ValidateEventSource ¶
func ValidateEventSource(eventSource *EventSource) error
ValidateEventSource validates a generic event source
Types ¶
type AMQPConsumeConfig ¶ added in v1.3.0
type AMQPConsumeConfig struct { // ConsumerTag is the identity of the consumer included in every delivery // +optional ConsumerTag string `json:"consumerTag,omitempty" protobuf:"bytes,1,opt,name=consumerTag"` // AutoAck when true, the server will acknowledge deliveries to this consumer prior to writing // the delivery to the network // +optional AutoAck bool `json:"autoAck,omitempty" protobuf:"varint,2,opt,name=autoAck"` // Exclusive when true, the server will ensure that this is the sole consumer from this queue // +optional Exclusive bool `json:"exclusive,omitempty" protobuf:"varint,3,opt,name=exclusive"` // NoLocal flag is not supported by RabbitMQ // +optional NoLocal bool `json:"noLocal,omitempty" protobuf:"varint,4,opt,name=noLocal"` // NowWait when true, do not wait for the server to confirm the request and immediately begin deliveries // +optional NoWait bool `json:"noWait,omitempty" protobuf:"varint,5,opt,name=noWait"` }
AMQPConsumeConfig holds the configuration to immediately starts delivering queued messages +k8s:openapi-gen=true
func (*AMQPConsumeConfig) DeepCopy ¶ added in v1.3.0
func (in *AMQPConsumeConfig) DeepCopy() *AMQPConsumeConfig
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AMQPConsumeConfig.
func (*AMQPConsumeConfig) DeepCopyInto ¶ added in v1.3.0
func (in *AMQPConsumeConfig) DeepCopyInto(out *AMQPConsumeConfig)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*AMQPConsumeConfig) Descriptor ¶ added in v1.3.0
func (*AMQPConsumeConfig) Descriptor() ([]byte, []int)
func (*AMQPConsumeConfig) Marshal ¶ added in v1.3.0
func (m *AMQPConsumeConfig) Marshal() (dAtA []byte, err error)
func (*AMQPConsumeConfig) MarshalTo ¶ added in v1.3.0
func (m *AMQPConsumeConfig) MarshalTo(dAtA []byte) (int, error)
func (*AMQPConsumeConfig) MarshalToSizedBuffer ¶ added in v1.3.0
func (m *AMQPConsumeConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*AMQPConsumeConfig) ProtoMessage ¶ added in v1.3.0
func (*AMQPConsumeConfig) ProtoMessage()
func (*AMQPConsumeConfig) Reset ¶ added in v1.3.0
func (m *AMQPConsumeConfig) Reset()
func (*AMQPConsumeConfig) Size ¶ added in v1.3.0
func (m *AMQPConsumeConfig) Size() (n int)
func (*AMQPConsumeConfig) String ¶ added in v1.3.0
func (this *AMQPConsumeConfig) String() string
func (*AMQPConsumeConfig) Unmarshal ¶ added in v1.3.0
func (m *AMQPConsumeConfig) Unmarshal(dAtA []byte) error
func (*AMQPConsumeConfig) XXX_DiscardUnknown ¶ added in v1.3.0
func (m *AMQPConsumeConfig) XXX_DiscardUnknown()
func (*AMQPConsumeConfig) XXX_Marshal ¶ added in v1.3.0
func (m *AMQPConsumeConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AMQPConsumeConfig) XXX_Merge ¶ added in v1.3.0
func (m *AMQPConsumeConfig) XXX_Merge(src proto.Message)
func (*AMQPConsumeConfig) XXX_Size ¶ added in v1.3.0
func (m *AMQPConsumeConfig) XXX_Size() int
func (*AMQPConsumeConfig) XXX_Unmarshal ¶ added in v1.3.0
func (m *AMQPConsumeConfig) XXX_Unmarshal(b []byte) error
type AMQPEventSource ¶
type AMQPEventSource struct { // URL for rabbitmq service URL string `json:"url,omitempty" protobuf:"bytes,1,opt,name=url"` // ExchangeName is the exchange name // For more information, visit https://www.rabbitmq.com/tutorials/amqp-concepts.html ExchangeName string `json:"exchangeName" protobuf:"bytes,2,opt,name=exchangeName"` // ExchangeType is rabbitmq exchange type ExchangeType string `json:"exchangeType" protobuf:"bytes,3,opt,name=exchangeType"` // Routing key for bindings RoutingKey string `json:"routingKey" protobuf:"bytes,4,opt,name=routingKey"` // Backoff holds parameters applied to connection. // +optional ConnectionBackoff *apicommon.Backoff `json:"connectionBackoff,omitempty" protobuf:"bytes,5,opt,name=connectionBackoff"` // JSONBody specifies that all event body payload coming from this // source will be JSON // +optional JSONBody bool `json:"jsonBody,omitempty" protobuf:"varint,6,opt,name=jsonBody"` // TLS configuration for the amqp client. // +optional TLS *apicommon.TLSConfig `json:"tls,omitempty" protobuf:"bytes,7,opt,name=tls"` // Metadata holds the user defined metadata which will passed along the event payload. // +optional Metadata map[string]string `json:"metadata,omitempty" protobuf:"bytes,8,rep,name=metadata"` // ExchangeDeclare holds the configuration for the exchange on the server // For more information, visit https://pkg.go.dev/github.com/rabbitmq/amqp091-go#Channel.ExchangeDeclare // +optional ExchangeDeclare *AMQPExchangeDeclareConfig `json:"exchangeDeclare,omitempty" protobuf:"bytes,9,opt,name=exchangeDeclare"` // QueueDeclare holds the configuration of a queue to hold messages and deliver to consumers. // Declaring creates a queue if it doesn't already exist, or ensures that an existing queue matches // the same parameters // For more information, visit https://pkg.go.dev/github.com/rabbitmq/amqp091-go#Channel.QueueDeclare // +optional QueueDeclare *AMQPQueueDeclareConfig `json:"queueDeclare,omitempty" protobuf:"bytes,10,opt,name=queueDeclare"` // QueueBind holds the configuration that binds an exchange to a queue so that publishings to the // exchange will be routed to the queue when the publishing routing key matches the binding routing key // For more information, visit https://pkg.go.dev/github.com/rabbitmq/amqp091-go#Channel.QueueBind // +optional QueueBind *AMQPQueueBindConfig `json:"queueBind,omitempty" protobuf:"bytes,11,opt,name=queueBind"` // Consume holds the configuration to immediately starts delivering queued messages // For more information, visit https://pkg.go.dev/github.com/rabbitmq/amqp091-go#Channel.Consume // +optional Consume *AMQPConsumeConfig `json:"consume,omitempty" protobuf:"bytes,12,opt,name=consume"` // Auth hosts secret selectors for username and password // +optional Auth *apicommon.BasicAuth `json:"auth,omitempty" protobuf:"bytes,13,opt,name=auth"` // URLSecret is secret reference for rabbitmq service URL URLSecret *corev1.SecretKeySelector `json:"urlSecret,omitempty" protobuf:"bytes,14,opt,name=urlSecret"` // Filter // +optional Filter *EventSourceFilter `json:"filter,omitempty" protobuf:"bytes,15,opt,name=filter"` }
AMQPEventSource refers to an event-source for AMQP stream events
func (*AMQPEventSource) DeepCopy ¶
func (in *AMQPEventSource) DeepCopy() *AMQPEventSource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AMQPEventSource.
func (*AMQPEventSource) DeepCopyInto ¶
func (in *AMQPEventSource) DeepCopyInto(out *AMQPEventSource)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*AMQPEventSource) Descriptor ¶ added in v0.17.0
func (*AMQPEventSource) Descriptor() ([]byte, []int)
func (*AMQPEventSource) Marshal ¶ added in v0.17.0
func (m *AMQPEventSource) Marshal() (dAtA []byte, err error)
func (*AMQPEventSource) MarshalTo ¶ added in v0.17.0
func (m *AMQPEventSource) MarshalTo(dAtA []byte) (int, error)
func (*AMQPEventSource) MarshalToSizedBuffer ¶ added in v0.17.0
func (m *AMQPEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*AMQPEventSource) ProtoMessage ¶ added in v0.17.0
func (*AMQPEventSource) ProtoMessage()
func (*AMQPEventSource) Reset ¶ added in v0.17.0
func (m *AMQPEventSource) Reset()
func (*AMQPEventSource) Size ¶ added in v0.17.0
func (m *AMQPEventSource) Size() (n int)
func (*AMQPEventSource) String ¶ added in v0.17.0
func (this *AMQPEventSource) String() string
func (*AMQPEventSource) Unmarshal ¶ added in v0.17.0
func (m *AMQPEventSource) Unmarshal(dAtA []byte) error
func (*AMQPEventSource) XXX_DiscardUnknown ¶ added in v0.17.0
func (m *AMQPEventSource) XXX_DiscardUnknown()
func (*AMQPEventSource) XXX_Marshal ¶ added in v0.17.0
func (m *AMQPEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AMQPEventSource) XXX_Merge ¶ added in v0.17.0
func (m *AMQPEventSource) XXX_Merge(src proto.Message)
func (*AMQPEventSource) XXX_Size ¶ added in v0.17.0
func (m *AMQPEventSource) XXX_Size() int
func (*AMQPEventSource) XXX_Unmarshal ¶ added in v0.17.0
func (m *AMQPEventSource) XXX_Unmarshal(b []byte) error
type AMQPExchangeDeclareConfig ¶ added in v1.3.0
type AMQPExchangeDeclareConfig struct { // Durable keeps the exchange also after the server restarts // +optional Durable bool `json:"durable,omitempty" protobuf:"varint,1,opt,name=durable"` // AutoDelete removes the exchange when no bindings are active // +optional AutoDelete bool `json:"autoDelete,omitempty" protobuf:"varint,2,opt,name=autoDelete"` // Internal when true does not accept publishings // +optional Internal bool `json:"internal,omitempty" protobuf:"varint,3,opt,name=internal"` // NowWait when true does not wait for a confirmation from the server // +optional NoWait bool `json:"noWait,omitempty" protobuf:"varint,4,opt,name=noWait"` }
AMQPExchangeDeclareConfig holds the configuration for the exchange on the server +k8s:openapi-gen=true
func (*AMQPExchangeDeclareConfig) DeepCopy ¶ added in v1.3.0
func (in *AMQPExchangeDeclareConfig) DeepCopy() *AMQPExchangeDeclareConfig
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AMQPExchangeDeclareConfig.
func (*AMQPExchangeDeclareConfig) DeepCopyInto ¶ added in v1.3.0
func (in *AMQPExchangeDeclareConfig) DeepCopyInto(out *AMQPExchangeDeclareConfig)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*AMQPExchangeDeclareConfig) Descriptor ¶ added in v1.3.0
func (*AMQPExchangeDeclareConfig) Descriptor() ([]byte, []int)
func (*AMQPExchangeDeclareConfig) Marshal ¶ added in v1.3.0
func (m *AMQPExchangeDeclareConfig) Marshal() (dAtA []byte, err error)
func (*AMQPExchangeDeclareConfig) MarshalTo ¶ added in v1.3.0
func (m *AMQPExchangeDeclareConfig) MarshalTo(dAtA []byte) (int, error)
func (*AMQPExchangeDeclareConfig) MarshalToSizedBuffer ¶ added in v1.3.0
func (m *AMQPExchangeDeclareConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*AMQPExchangeDeclareConfig) ProtoMessage ¶ added in v1.3.0
func (*AMQPExchangeDeclareConfig) ProtoMessage()
func (*AMQPExchangeDeclareConfig) Reset ¶ added in v1.3.0
func (m *AMQPExchangeDeclareConfig) Reset()
func (*AMQPExchangeDeclareConfig) Size ¶ added in v1.3.0
func (m *AMQPExchangeDeclareConfig) Size() (n int)
func (*AMQPExchangeDeclareConfig) String ¶ added in v1.3.0
func (this *AMQPExchangeDeclareConfig) String() string
func (*AMQPExchangeDeclareConfig) Unmarshal ¶ added in v1.3.0
func (m *AMQPExchangeDeclareConfig) Unmarshal(dAtA []byte) error
func (*AMQPExchangeDeclareConfig) XXX_DiscardUnknown ¶ added in v1.3.0
func (m *AMQPExchangeDeclareConfig) XXX_DiscardUnknown()
func (*AMQPExchangeDeclareConfig) XXX_Marshal ¶ added in v1.3.0
func (m *AMQPExchangeDeclareConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AMQPExchangeDeclareConfig) XXX_Merge ¶ added in v1.3.0
func (m *AMQPExchangeDeclareConfig) XXX_Merge(src proto.Message)
func (*AMQPExchangeDeclareConfig) XXX_Size ¶ added in v1.3.0
func (m *AMQPExchangeDeclareConfig) XXX_Size() int
func (*AMQPExchangeDeclareConfig) XXX_Unmarshal ¶ added in v1.3.0
func (m *AMQPExchangeDeclareConfig) XXX_Unmarshal(b []byte) error
type AMQPQueueBindConfig ¶ added in v1.3.0
type AMQPQueueBindConfig struct { // NowWait false and the queue could not be bound, the channel will be closed with an error // +optional NoWait bool `json:"noWait,omitempty" protobuf:"varint,1,opt,name=noWait"` }
AMQPQueueBindConfig holds the configuration that binds an exchange to a queue so that publishings to the exchange will be routed to the queue when the publishing routing key matches the binding routing key +k8s:openapi-gen=true
func (*AMQPQueueBindConfig) DeepCopy ¶ added in v1.3.0
func (in *AMQPQueueBindConfig) DeepCopy() *AMQPQueueBindConfig
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AMQPQueueBindConfig.
func (*AMQPQueueBindConfig) DeepCopyInto ¶ added in v1.3.0
func (in *AMQPQueueBindConfig) DeepCopyInto(out *AMQPQueueBindConfig)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*AMQPQueueBindConfig) Descriptor ¶ added in v1.3.0
func (*AMQPQueueBindConfig) Descriptor() ([]byte, []int)
func (*AMQPQueueBindConfig) Marshal ¶ added in v1.3.0
func (m *AMQPQueueBindConfig) Marshal() (dAtA []byte, err error)
func (*AMQPQueueBindConfig) MarshalTo ¶ added in v1.3.0
func (m *AMQPQueueBindConfig) MarshalTo(dAtA []byte) (int, error)
func (*AMQPQueueBindConfig) MarshalToSizedBuffer ¶ added in v1.3.0
func (m *AMQPQueueBindConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*AMQPQueueBindConfig) ProtoMessage ¶ added in v1.3.0
func (*AMQPQueueBindConfig) ProtoMessage()
func (*AMQPQueueBindConfig) Reset ¶ added in v1.3.0
func (m *AMQPQueueBindConfig) Reset()
func (*AMQPQueueBindConfig) Size ¶ added in v1.3.0
func (m *AMQPQueueBindConfig) Size() (n int)
func (*AMQPQueueBindConfig) String ¶ added in v1.3.0
func (this *AMQPQueueBindConfig) String() string
func (*AMQPQueueBindConfig) Unmarshal ¶ added in v1.3.0
func (m *AMQPQueueBindConfig) Unmarshal(dAtA []byte) error
func (*AMQPQueueBindConfig) XXX_DiscardUnknown ¶ added in v1.3.0
func (m *AMQPQueueBindConfig) XXX_DiscardUnknown()
func (*AMQPQueueBindConfig) XXX_Marshal ¶ added in v1.3.0
func (m *AMQPQueueBindConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AMQPQueueBindConfig) XXX_Merge ¶ added in v1.3.0
func (m *AMQPQueueBindConfig) XXX_Merge(src proto.Message)
func (*AMQPQueueBindConfig) XXX_Size ¶ added in v1.3.0
func (m *AMQPQueueBindConfig) XXX_Size() int
func (*AMQPQueueBindConfig) XXX_Unmarshal ¶ added in v1.3.0
func (m *AMQPQueueBindConfig) XXX_Unmarshal(b []byte) error
type AMQPQueueDeclareConfig ¶ added in v1.3.0
type AMQPQueueDeclareConfig struct { // Name of the queue. If empty the server auto-generates a unique name for this queue // +optional Name string `json:"name,omitempty" protobuf:"bytes,1,opt,name=name"` // Durable keeps the queue also after the server restarts // +optional Durable bool `json:"durable,omitempty" protobuf:"varint,2,opt,name=durable"` // AutoDelete removes the queue when no consumers are active // +optional AutoDelete bool `json:"autoDelete,omitempty" protobuf:"varint,3,opt,name=autoDelete"` // Exclusive sets the queues to be accessible only by the connection that declares them and will be // deleted wgen the connection closes // +optional Exclusive bool `json:"exclusive,omitempty" protobuf:"varint,4,opt,name=exclusive"` // NowWait when true, the queue assumes to be declared on the server // +optional NoWait bool `json:"noWait,omitempty" protobuf:"varint,5,opt,name=noWait"` // Arguments of a queue (also known as "x-arguments") used for optional features and plugins // +optional Arguments string `json:"arguments,omitempty" protobuf:"bytes,6,opt,name=arguments"` }
AMQPQueueDeclareConfig holds the configuration of a queue to hold messages and deliver to consumers. Declaring creates a queue if it doesn't already exist, or ensures that an existing queue matches the same parameters +k8s:openapi-gen=true
func (*AMQPQueueDeclareConfig) DeepCopy ¶ added in v1.3.0
func (in *AMQPQueueDeclareConfig) DeepCopy() *AMQPQueueDeclareConfig
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AMQPQueueDeclareConfig.
func (*AMQPQueueDeclareConfig) DeepCopyInto ¶ added in v1.3.0
func (in *AMQPQueueDeclareConfig) DeepCopyInto(out *AMQPQueueDeclareConfig)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*AMQPQueueDeclareConfig) Descriptor ¶ added in v1.3.0
func (*AMQPQueueDeclareConfig) Descriptor() ([]byte, []int)
func (*AMQPQueueDeclareConfig) Marshal ¶ added in v1.3.0
func (m *AMQPQueueDeclareConfig) Marshal() (dAtA []byte, err error)
func (*AMQPQueueDeclareConfig) MarshalTo ¶ added in v1.3.0
func (m *AMQPQueueDeclareConfig) MarshalTo(dAtA []byte) (int, error)
func (*AMQPQueueDeclareConfig) MarshalToSizedBuffer ¶ added in v1.3.0
func (m *AMQPQueueDeclareConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*AMQPQueueDeclareConfig) ProtoMessage ¶ added in v1.3.0
func (*AMQPQueueDeclareConfig) ProtoMessage()
func (*AMQPQueueDeclareConfig) Reset ¶ added in v1.3.0
func (m *AMQPQueueDeclareConfig) Reset()
func (*AMQPQueueDeclareConfig) Size ¶ added in v1.3.0
func (m *AMQPQueueDeclareConfig) Size() (n int)
func (*AMQPQueueDeclareConfig) String ¶ added in v1.3.0
func (this *AMQPQueueDeclareConfig) String() string
func (*AMQPQueueDeclareConfig) Unmarshal ¶ added in v1.3.0
func (m *AMQPQueueDeclareConfig) Unmarshal(dAtA []byte) error
func (*AMQPQueueDeclareConfig) XXX_DiscardUnknown ¶ added in v1.3.0
func (m *AMQPQueueDeclareConfig) XXX_DiscardUnknown()
func (*AMQPQueueDeclareConfig) XXX_Marshal ¶ added in v1.3.0
func (m *AMQPQueueDeclareConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AMQPQueueDeclareConfig) XXX_Merge ¶ added in v1.3.0
func (m *AMQPQueueDeclareConfig) XXX_Merge(src proto.Message)
func (*AMQPQueueDeclareConfig) XXX_Size ¶ added in v1.3.0
func (m *AMQPQueueDeclareConfig) XXX_Size() int
func (*AMQPQueueDeclareConfig) XXX_Unmarshal ¶ added in v1.3.0
func (m *AMQPQueueDeclareConfig) XXX_Unmarshal(b []byte) error
type AzureEventsHubEventSource ¶
type AzureEventsHubEventSource struct { // FQDN of the EventHubs namespace you created // More info at https://docs.microsoft.com/en-us/azure/event-hubs/event-hubs-get-connection-string FQDN string `json:"fqdn" protobuf:"bytes,1,opt,name=fqdn"` SharedAccessKeyName *corev1.SecretKeySelector `json:"sharedAccessKeyName,omitempty" protobuf:"bytes,2,opt,name=sharedAccessKeyName"` SharedAccessKey *corev1.SecretKeySelector `json:"sharedAccessKey,omitempty" protobuf:"bytes,3,opt,name=sharedAccessKey"` // Event Hub path/name HubName string `json:"hubName" protobuf:"bytes,4,opt,name=hubName"` // Metadata holds the user defined metadata which will passed along the event payload. // +optional Metadata map[string]string `json:"metadata,omitempty" protobuf:"bytes,5,rep,name=metadata"` // Filter // +optional Filter *EventSourceFilter `json:"filter,omitempty" protobuf:"bytes,6,opt,name=filter"` }
AzureEventsHubEventSource describes the event source for azure events hub More info at https://docs.microsoft.com/en-us/azure/event-hubs/
func (*AzureEventsHubEventSource) DeepCopy ¶
func (in *AzureEventsHubEventSource) DeepCopy() *AzureEventsHubEventSource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AzureEventsHubEventSource.
func (*AzureEventsHubEventSource) DeepCopyInto ¶
func (in *AzureEventsHubEventSource) DeepCopyInto(out *AzureEventsHubEventSource)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*AzureEventsHubEventSource) Descriptor ¶ added in v0.17.0
func (*AzureEventsHubEventSource) Descriptor() ([]byte, []int)
func (*AzureEventsHubEventSource) Marshal ¶ added in v0.17.0
func (m *AzureEventsHubEventSource) Marshal() (dAtA []byte, err error)
func (*AzureEventsHubEventSource) MarshalTo ¶ added in v0.17.0
func (m *AzureEventsHubEventSource) MarshalTo(dAtA []byte) (int, error)
func (*AzureEventsHubEventSource) MarshalToSizedBuffer ¶ added in v0.17.0
func (m *AzureEventsHubEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*AzureEventsHubEventSource) ProtoMessage ¶ added in v0.17.0
func (*AzureEventsHubEventSource) ProtoMessage()
func (*AzureEventsHubEventSource) Reset ¶ added in v0.17.0
func (m *AzureEventsHubEventSource) Reset()
func (*AzureEventsHubEventSource) Size ¶ added in v0.17.0
func (m *AzureEventsHubEventSource) Size() (n int)
func (*AzureEventsHubEventSource) String ¶ added in v0.17.0
func (this *AzureEventsHubEventSource) String() string
func (*AzureEventsHubEventSource) Unmarshal ¶ added in v0.17.0
func (m *AzureEventsHubEventSource) Unmarshal(dAtA []byte) error
func (*AzureEventsHubEventSource) XXX_DiscardUnknown ¶ added in v0.17.0
func (m *AzureEventsHubEventSource) XXX_DiscardUnknown()
func (*AzureEventsHubEventSource) XXX_Marshal ¶ added in v0.17.0
func (m *AzureEventsHubEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AzureEventsHubEventSource) XXX_Merge ¶ added in v0.17.0
func (m *AzureEventsHubEventSource) XXX_Merge(src proto.Message)
func (*AzureEventsHubEventSource) XXX_Size ¶ added in v0.17.0
func (m *AzureEventsHubEventSource) XXX_Size() int
func (*AzureEventsHubEventSource) XXX_Unmarshal ¶ added in v0.17.0
func (m *AzureEventsHubEventSource) XXX_Unmarshal(b []byte) error
type AzureQueueStorageEventSource ¶ added in v1.8.0
type AzureQueueStorageEventSource struct { // StorageAccountName is the name of the storage account where the queue is. This field is necessary to // access via Azure AD (managed identity) and it is ignored if ConnectionString is set. // +optional StorageAccountName string `json:"storageAccountName,omitempty" protobuf:"bytes,1,opt,name=storageAccountName"` // ConnectionString is the connection string to access Azure Queue Storage. If this fields is not provided // it will try to access via Azure AD with StorageAccountName. // +optional ConnectionString *corev1.SecretKeySelector `json:"connectionString,omitempty" protobuf:"bytes,2,opt,name=connectionString"` // QueueName is the name of the queue QueueName string `json:"queueName" protobuf:"bytes,3,opt,name=queueName"` // JSONBody specifies that all event body payload coming from this // source will be JSON // +optional JSONBody bool `json:"jsonBody,omitempty" protobuf:"varint,4,opt,name=jsonBody"` // DLQ specifies if a dead-letter queue is configured for messages that can't be processed successfully. // If set to true, messages with invalid payload won't be acknowledged to allow to forward them farther to the dead-letter queue. // The default value is false. // +optional DLQ bool `json:"dlq,omitempty" protobuf:"varint,5,opt,name=dlq"` // Metadata holds the user defined metadata which will passed along the event payload. // +optional Metadata map[string]string `json:"metadata,omitempty" protobuf:"bytes,6,rep,name=metadata"` // Filter // +optional Filter *EventSourceFilter `json:"filter,omitempty" protobuf:"bytes,7,opt,name=filter"` // DecodeMessage specifies if all the messages should be base64 decoded. // If set to true the decoding is done before the evaluation of JSONBody // +optional DecodeMessage bool `json:"decodeMessage,omitempty" protobuf:"bytes,8,opt,name=decodeMessage"` }
AzureQueueStorageEventSource describes the event source for azure queue storage more info at https://learn.microsoft.com/en-us/azure/storage/queues/
func (*AzureQueueStorageEventSource) DeepCopy ¶ added in v1.8.0
func (in *AzureQueueStorageEventSource) DeepCopy() *AzureQueueStorageEventSource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AzureQueueStorageEventSource.
func (*AzureQueueStorageEventSource) DeepCopyInto ¶ added in v1.8.0
func (in *AzureQueueStorageEventSource) DeepCopyInto(out *AzureQueueStorageEventSource)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*AzureQueueStorageEventSource) Descriptor ¶ added in v1.8.0
func (*AzureQueueStorageEventSource) Descriptor() ([]byte, []int)
func (*AzureQueueStorageEventSource) Marshal ¶ added in v1.8.0
func (m *AzureQueueStorageEventSource) Marshal() (dAtA []byte, err error)
func (*AzureQueueStorageEventSource) MarshalTo ¶ added in v1.8.0
func (m *AzureQueueStorageEventSource) MarshalTo(dAtA []byte) (int, error)
func (*AzureQueueStorageEventSource) MarshalToSizedBuffer ¶ added in v1.8.0
func (m *AzureQueueStorageEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*AzureQueueStorageEventSource) ProtoMessage ¶ added in v1.8.0
func (*AzureQueueStorageEventSource) ProtoMessage()
func (*AzureQueueStorageEventSource) Reset ¶ added in v1.8.0
func (m *AzureQueueStorageEventSource) Reset()
func (*AzureQueueStorageEventSource) Size ¶ added in v1.8.0
func (m *AzureQueueStorageEventSource) Size() (n int)
func (*AzureQueueStorageEventSource) String ¶ added in v1.8.0
func (this *AzureQueueStorageEventSource) String() string
func (*AzureQueueStorageEventSource) Unmarshal ¶ added in v1.8.0
func (m *AzureQueueStorageEventSource) Unmarshal(dAtA []byte) error
func (*AzureQueueStorageEventSource) XXX_DiscardUnknown ¶ added in v1.8.0
func (m *AzureQueueStorageEventSource) XXX_DiscardUnknown()
func (*AzureQueueStorageEventSource) XXX_Marshal ¶ added in v1.8.0
func (m *AzureQueueStorageEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AzureQueueStorageEventSource) XXX_Merge ¶ added in v1.8.0
func (m *AzureQueueStorageEventSource) XXX_Merge(src proto.Message)
func (*AzureQueueStorageEventSource) XXX_Size ¶ added in v1.8.0
func (m *AzureQueueStorageEventSource) XXX_Size() int
func (*AzureQueueStorageEventSource) XXX_Unmarshal ¶ added in v1.8.0
func (m *AzureQueueStorageEventSource) XXX_Unmarshal(b []byte) error
type AzureServiceBusEventSource ¶ added in v1.7.4
type AzureServiceBusEventSource struct { // ConnectionString is the connection string for the Azure Service Bus. If this fields is not provided // it will try to access via Azure AD with DefaultAzureCredential and FullyQualifiedNamespace. // +optional ConnectionString *corev1.SecretKeySelector `json:"connectionString,omitempty" protobuf:"bytes,1,opt,name=connectionString"` // QueueName is the name of the Azure Service Bus Queue QueueName string `json:"queueName" protobuf:"bytes,2,opt,name=queueName"` // TopicName is the name of the Azure Service Bus Topic TopicName string `json:"topicName" protobuf:"bytes,3,opt,name=topicName"` // SubscriptionName is the name of the Azure Service Bus Topic Subscription SubscriptionName string `json:"subscriptionName" protobuf:"bytes,4,opt,name=subscriptionName"` // TLS configuration for the service bus client // +optional TLS *apicommon.TLSConfig `json:"tls,omitempty" protobuf:"bytes,5,opt,name=tls"` // JSONBody specifies that all event body payload coming from this // source will be JSON // +optional JSONBody bool `json:"jsonBody,omitempty" protobuf:"varint,6,opt,name=jsonBody"` // Metadata holds the user defined metadata which will passed along the event payload. // +optional Metadata map[string]string `json:"metadata,omitempty" protobuf:"bytes,7,rep,name=metadata"` // Filter // +optional Filter *EventSourceFilter `json:"filter,omitempty" protobuf:"bytes,8,opt,name=filter"` // FullyQualifiedNamespace is the Service Bus namespace name (ex: myservicebus.servicebus.windows.net). This field is necessary to // access via Azure AD (managed identity) and it is ignored if ConnectionString is set. // +optional FullyQualifiedNamespace string `json:"fullyQualifiedNamespace,omitempty" protobuf:"bytes,9,opt,name=fullyQualifiedNamespace"` }
AzureServiceBusEventSource describes the event source for azure service bus More info at https://docs.microsoft.com/en-us/azure/service-bus-messaging/
func (*AzureServiceBusEventSource) DeepCopy ¶ added in v1.7.4
func (in *AzureServiceBusEventSource) DeepCopy() *AzureServiceBusEventSource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AzureServiceBusEventSource.
func (*AzureServiceBusEventSource) DeepCopyInto ¶ added in v1.7.4
func (in *AzureServiceBusEventSource) DeepCopyInto(out *AzureServiceBusEventSource)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*AzureServiceBusEventSource) Descriptor ¶ added in v1.7.4
func (*AzureServiceBusEventSource) Descriptor() ([]byte, []int)
func (*AzureServiceBusEventSource) Marshal ¶ added in v1.7.4
func (m *AzureServiceBusEventSource) Marshal() (dAtA []byte, err error)
func (*AzureServiceBusEventSource) MarshalTo ¶ added in v1.7.4
func (m *AzureServiceBusEventSource) MarshalTo(dAtA []byte) (int, error)
func (*AzureServiceBusEventSource) MarshalToSizedBuffer ¶ added in v1.7.4
func (m *AzureServiceBusEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*AzureServiceBusEventSource) ProtoMessage ¶ added in v1.7.4
func (*AzureServiceBusEventSource) ProtoMessage()
func (*AzureServiceBusEventSource) Reset ¶ added in v1.7.4
func (m *AzureServiceBusEventSource) Reset()
func (*AzureServiceBusEventSource) Size ¶ added in v1.7.4
func (m *AzureServiceBusEventSource) Size() (n int)
func (*AzureServiceBusEventSource) String ¶ added in v1.7.4
func (this *AzureServiceBusEventSource) String() string
func (*AzureServiceBusEventSource) Unmarshal ¶ added in v1.7.4
func (m *AzureServiceBusEventSource) Unmarshal(dAtA []byte) error
func (*AzureServiceBusEventSource) XXX_DiscardUnknown ¶ added in v1.7.4
func (m *AzureServiceBusEventSource) XXX_DiscardUnknown()
func (*AzureServiceBusEventSource) XXX_Marshal ¶ added in v1.7.4
func (m *AzureServiceBusEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AzureServiceBusEventSource) XXX_Merge ¶ added in v1.7.4
func (m *AzureServiceBusEventSource) XXX_Merge(src proto.Message)
func (*AzureServiceBusEventSource) XXX_Size ¶ added in v1.7.4
func (m *AzureServiceBusEventSource) XXX_Size() int
func (*AzureServiceBusEventSource) XXX_Unmarshal ¶ added in v1.7.4
func (m *AzureServiceBusEventSource) XXX_Unmarshal(b []byte) error
type BitbucketAuth ¶ added in v1.6.0
type BitbucketAuth struct { // Basic is BasicAuth auth strategy. // +optional Basic *BitbucketBasicAuth `json:"basic,omitempty" protobuf:"bytes,1,opt,name=basic"` // OAuthToken refers to the K8s secret that holds the OAuth Bearer token. // +optional OAuthToken *corev1.SecretKeySelector `json:"oauthToken,omitempty" protobuf:"bytes,2,opt,name=oauthToken"` }
BitbucketAuth holds the different auth strategies for connecting to Bitbucket
func (*BitbucketAuth) DeepCopy ¶ added in v1.6.0
func (in *BitbucketAuth) DeepCopy() *BitbucketAuth
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BitbucketAuth.
func (*BitbucketAuth) DeepCopyInto ¶ added in v1.6.0
func (in *BitbucketAuth) DeepCopyInto(out *BitbucketAuth)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*BitbucketAuth) Descriptor ¶ added in v1.6.0
func (*BitbucketAuth) Descriptor() ([]byte, []int)
func (*BitbucketAuth) Marshal ¶ added in v1.6.0
func (m *BitbucketAuth) Marshal() (dAtA []byte, err error)
func (*BitbucketAuth) MarshalTo ¶ added in v1.6.0
func (m *BitbucketAuth) MarshalTo(dAtA []byte) (int, error)
func (*BitbucketAuth) MarshalToSizedBuffer ¶ added in v1.6.0
func (m *BitbucketAuth) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*BitbucketAuth) ProtoMessage ¶ added in v1.6.0
func (*BitbucketAuth) ProtoMessage()
func (*BitbucketAuth) Reset ¶ added in v1.6.0
func (m *BitbucketAuth) Reset()
func (*BitbucketAuth) Size ¶ added in v1.6.0
func (m *BitbucketAuth) Size() (n int)
func (*BitbucketAuth) String ¶ added in v1.6.0
func (this *BitbucketAuth) String() string
func (*BitbucketAuth) Unmarshal ¶ added in v1.6.0
func (m *BitbucketAuth) Unmarshal(dAtA []byte) error
func (*BitbucketAuth) XXX_DiscardUnknown ¶ added in v1.6.0
func (m *BitbucketAuth) XXX_DiscardUnknown()
func (*BitbucketAuth) XXX_Marshal ¶ added in v1.6.0
func (m *BitbucketAuth) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*BitbucketAuth) XXX_Merge ¶ added in v1.6.0
func (m *BitbucketAuth) XXX_Merge(src proto.Message)
func (*BitbucketAuth) XXX_Size ¶ added in v1.6.0
func (m *BitbucketAuth) XXX_Size() int
func (*BitbucketAuth) XXX_Unmarshal ¶ added in v1.6.0
func (m *BitbucketAuth) XXX_Unmarshal(b []byte) error
type BitbucketBasicAuth ¶ added in v1.6.0
type BitbucketBasicAuth struct { // Username refers to the K8s secret that holds the username. Username *corev1.SecretKeySelector `json:"username" protobuf:"bytes,1,name=username"` // Password refers to the K8s secret that holds the password. Password *corev1.SecretKeySelector `json:"password" protobuf:"bytes,2,name=password"` }
BasicAuth holds the information required to authenticate user via basic auth mechanism
func (*BitbucketBasicAuth) DeepCopy ¶ added in v1.6.0
func (in *BitbucketBasicAuth) DeepCopy() *BitbucketBasicAuth
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BitbucketBasicAuth.
func (*BitbucketBasicAuth) DeepCopyInto ¶ added in v1.6.0
func (in *BitbucketBasicAuth) DeepCopyInto(out *BitbucketBasicAuth)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*BitbucketBasicAuth) Descriptor ¶ added in v1.6.0
func (*BitbucketBasicAuth) Descriptor() ([]byte, []int)
func (*BitbucketBasicAuth) Marshal ¶ added in v1.6.0
func (m *BitbucketBasicAuth) Marshal() (dAtA []byte, err error)
func (*BitbucketBasicAuth) MarshalTo ¶ added in v1.6.0
func (m *BitbucketBasicAuth) MarshalTo(dAtA []byte) (int, error)
func (*BitbucketBasicAuth) MarshalToSizedBuffer ¶ added in v1.6.0
func (m *BitbucketBasicAuth) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*BitbucketBasicAuth) ProtoMessage ¶ added in v1.6.0
func (*BitbucketBasicAuth) ProtoMessage()
func (*BitbucketBasicAuth) Reset ¶ added in v1.6.0
func (m *BitbucketBasicAuth) Reset()
func (*BitbucketBasicAuth) Size ¶ added in v1.6.0
func (m *BitbucketBasicAuth) Size() (n int)
func (*BitbucketBasicAuth) String ¶ added in v1.6.0
func (this *BitbucketBasicAuth) String() string
func (*BitbucketBasicAuth) Unmarshal ¶ added in v1.6.0
func (m *BitbucketBasicAuth) Unmarshal(dAtA []byte) error
func (*BitbucketBasicAuth) XXX_DiscardUnknown ¶ added in v1.6.0
func (m *BitbucketBasicAuth) XXX_DiscardUnknown()
func (*BitbucketBasicAuth) XXX_Marshal ¶ added in v1.6.0
func (m *BitbucketBasicAuth) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*BitbucketBasicAuth) XXX_Merge ¶ added in v1.6.0
func (m *BitbucketBasicAuth) XXX_Merge(src proto.Message)
func (*BitbucketBasicAuth) XXX_Size ¶ added in v1.6.0
func (m *BitbucketBasicAuth) XXX_Size() int
func (*BitbucketBasicAuth) XXX_Unmarshal ¶ added in v1.6.0
func (m *BitbucketBasicAuth) XXX_Unmarshal(b []byte) error
type BitbucketEventSource ¶ added in v1.6.0
type BitbucketEventSource struct { // DeleteHookOnFinish determines whether to delete the defined Bitbucket hook once the event source is stopped. // +optional DeleteHookOnFinish bool `json:"deleteHookOnFinish,omitempty" protobuf:"varint,1,opt,name=deleteHookOnFinish"` // Metadata holds the user defined metadata which will be passed along the event payload. // +optional Metadata map[string]string `json:"metadata,omitempty" protobuf:"bytes,2,rep,name=metadata"` // Webhook refers to the configuration required to run an http server Webhook *WebhookContext `json:"webhook" protobuf:"bytes,3,name=webhook"` // Auth information required to connect to Bitbucket. Auth *BitbucketAuth `json:"auth" protobuf:"bytes,4,name=auth"` // Events this webhook is subscribed to. Events []string `json:"events" protobuf:"bytes,5,name=events"` // DeprecatedOwner is the owner of the repository. // Deprecated: use Repositories instead. Will be unsupported in v1.9 // +optional DeprecatedOwner string `json:"owner,omitempty" protobuf:"bytes,6,name=owner"` // DeprecatedProjectKey is the key of the project to which the repository relates // Deprecated: use Repositories instead. Will be unsupported in v1.9 // +optional DeprecatedProjectKey string `json:"projectKey,omitempty" protobuf:"bytes,7,opt,name=projectKey"` // DeprecatedRepositorySlug is a URL-friendly version of a repository name, automatically generated by Bitbucket for use in the URL // Deprecated: use Repositories instead. Will be unsupported in v1.9 // +optional DeprecatedRepositorySlug string `json:"repositorySlug,omitempty" protobuf:"bytes,8,name=repositorySlug"` // Repositories holds a list of repositories for which integration needs to set up // +optional Repositories []BitbucketRepository `json:"repositories,omitempty" protobuf:"bytes,9,rep,name=repositories"` // Filter // +optional Filter *EventSourceFilter `json:"filter,omitempty" protobuf:"bytes,10,opt,name=filter"` }
BitbucketEventSource describes the event source for Bitbucket
func (*BitbucketEventSource) DeepCopy ¶ added in v1.6.0
func (in *BitbucketEventSource) DeepCopy() *BitbucketEventSource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BitbucketEventSource.
func (*BitbucketEventSource) DeepCopyInto ¶ added in v1.6.0
func (in *BitbucketEventSource) DeepCopyInto(out *BitbucketEventSource)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*BitbucketEventSource) Descriptor ¶ added in v1.6.0
func (*BitbucketEventSource) Descriptor() ([]byte, []int)
func (BitbucketEventSource) GetBitbucketRepositories ¶ added in v1.7.2
func (b BitbucketEventSource) GetBitbucketRepositories() []BitbucketRepository
func (BitbucketEventSource) HasBitbucketBasicAuth ¶ added in v1.6.0
func (b BitbucketEventSource) HasBitbucketBasicAuth() bool
func (BitbucketEventSource) HasBitbucketOAuthToken ¶ added in v1.6.0
func (b BitbucketEventSource) HasBitbucketOAuthToken() bool
func (BitbucketEventSource) HasConfiguredWebhook ¶ added in v1.6.0
func (b BitbucketEventSource) HasConfiguredWebhook() bool
func (*BitbucketEventSource) Marshal ¶ added in v1.6.0
func (m *BitbucketEventSource) Marshal() (dAtA []byte, err error)
func (*BitbucketEventSource) MarshalTo ¶ added in v1.6.0
func (m *BitbucketEventSource) MarshalTo(dAtA []byte) (int, error)
func (*BitbucketEventSource) MarshalToSizedBuffer ¶ added in v1.6.0
func (m *BitbucketEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*BitbucketEventSource) ProtoMessage ¶ added in v1.6.0
func (*BitbucketEventSource) ProtoMessage()
func (*BitbucketEventSource) Reset ¶ added in v1.6.0
func (m *BitbucketEventSource) Reset()
func (BitbucketEventSource) ShouldCreateWebhooks ¶ added in v1.7.2
func (b BitbucketEventSource) ShouldCreateWebhooks() bool
func (*BitbucketEventSource) Size ¶ added in v1.6.0
func (m *BitbucketEventSource) Size() (n int)
func (*BitbucketEventSource) String ¶ added in v1.6.0
func (this *BitbucketEventSource) String() string
func (*BitbucketEventSource) Unmarshal ¶ added in v1.6.0
func (m *BitbucketEventSource) Unmarshal(dAtA []byte) error
func (*BitbucketEventSource) XXX_DiscardUnknown ¶ added in v1.6.0
func (m *BitbucketEventSource) XXX_DiscardUnknown()
func (*BitbucketEventSource) XXX_Marshal ¶ added in v1.6.0
func (m *BitbucketEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*BitbucketEventSource) XXX_Merge ¶ added in v1.6.0
func (m *BitbucketEventSource) XXX_Merge(src proto.Message)
func (*BitbucketEventSource) XXX_Size ¶ added in v1.6.0
func (m *BitbucketEventSource) XXX_Size() int
func (*BitbucketEventSource) XXX_Unmarshal ¶ added in v1.6.0
func (m *BitbucketEventSource) XXX_Unmarshal(b []byte) error
type BitbucketRepository ¶ added in v1.7.2
type BitbucketRepository struct { // Owner is the owner of the repository Owner string `json:"owner" protobuf:"bytes,1,name=owner"` // RepositorySlug is a URL-friendly version of a repository name, automatically generated by Bitbucket for use in the URL RepositorySlug string `json:"repositorySlug" protobuf:"bytes,2,rep,name=repositorySlug"` }
func (*BitbucketRepository) DeepCopy ¶ added in v1.7.2
func (in *BitbucketRepository) DeepCopy() *BitbucketRepository
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BitbucketRepository.
func (*BitbucketRepository) DeepCopyInto ¶ added in v1.7.2
func (in *BitbucketRepository) DeepCopyInto(out *BitbucketRepository)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*BitbucketRepository) Descriptor ¶ added in v1.7.2
func (*BitbucketRepository) Descriptor() ([]byte, []int)
func (BitbucketRepository) GetRepositoryID ¶ added in v1.7.2
func (r BitbucketRepository) GetRepositoryID() string
GetRepositoryID helper returns a string key identifier for the repo
func (*BitbucketRepository) Marshal ¶ added in v1.7.2
func (m *BitbucketRepository) Marshal() (dAtA []byte, err error)
func (*BitbucketRepository) MarshalTo ¶ added in v1.7.2
func (m *BitbucketRepository) MarshalTo(dAtA []byte) (int, error)
func (*BitbucketRepository) MarshalToSizedBuffer ¶ added in v1.7.2
func (m *BitbucketRepository) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*BitbucketRepository) ProtoMessage ¶ added in v1.7.2
func (*BitbucketRepository) ProtoMessage()
func (*BitbucketRepository) Reset ¶ added in v1.7.2
func (m *BitbucketRepository) Reset()
func (*BitbucketRepository) Size ¶ added in v1.7.2
func (m *BitbucketRepository) Size() (n int)
func (*BitbucketRepository) String ¶ added in v1.7.2
func (this *BitbucketRepository) String() string
func (*BitbucketRepository) Unmarshal ¶ added in v1.7.2
func (m *BitbucketRepository) Unmarshal(dAtA []byte) error
func (*BitbucketRepository) XXX_DiscardUnknown ¶ added in v1.7.2
func (m *BitbucketRepository) XXX_DiscardUnknown()
func (*BitbucketRepository) XXX_Marshal ¶ added in v1.7.2
func (m *BitbucketRepository) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*BitbucketRepository) XXX_Merge ¶ added in v1.7.2
func (m *BitbucketRepository) XXX_Merge(src proto.Message)
func (*BitbucketRepository) XXX_Size ¶ added in v1.7.2
func (m *BitbucketRepository) XXX_Size() int
func (*BitbucketRepository) XXX_Unmarshal ¶ added in v1.7.2
func (m *BitbucketRepository) XXX_Unmarshal(b []byte) error
type BitbucketServerEventSource ¶ added in v1.5.0
type BitbucketServerEventSource struct { // Webhook holds configuration to run a http server Webhook *WebhookContext `json:"webhook,omitempty" protobuf:"bytes,1,opt,name=webhook"` // DeprecatedProjectKey is the key of project for which integration needs to set up // Deprecated: use Repositories instead. Will be unsupported in v1.8 // +optional DeprecatedProjectKey string `json:"projectKey,omitempty" protobuf:"bytes,2,opt,name=projectKey"` // DeprecatedRepositorySlug is the slug of the repository for which integration needs to set up // Deprecated: use Repositories instead. Will be unsupported in v1.8 // +optional DeprecatedRepositorySlug string `json:"repositorySlug,omitempty" protobuf:"bytes,3,opt,name=repositorySlug"` // Repositories holds a list of repositories for which integration needs to set up // +optional Repositories []BitbucketServerRepository `json:"repositories,omitempty" protobuf:"bytes,4,rep,name=repositories"` // Events are bitbucket event to listen to. // Refer https://confluence.atlassian.com/bitbucketserver/event-payload-938025882.html Events []string `json:"events" protobuf:"bytes,5,opt,name=events"` // AccessToken is reference to K8s secret which holds the bitbucket api access information AccessToken *corev1.SecretKeySelector `json:"accessToken,omitempty" protobuf:"bytes,6,opt,name=accessToken"` // WebhookSecret is reference to K8s secret which holds the bitbucket webhook secret (for HMAC validation) WebhookSecret *corev1.SecretKeySelector `json:"webhookSecret,omitempty" protobuf:"bytes,7,opt,name=webhookSecret"` // BitbucketServerBaseURL is the base URL for API requests to a custom endpoint BitbucketServerBaseURL string `json:"bitbucketserverBaseURL" protobuf:"bytes,8,opt,name=bitbucketserverBaseURL"` // DeleteHookOnFinish determines whether to delete the Bitbucket Server hook for the project once the event source is stopped. // +optional DeleteHookOnFinish bool `json:"deleteHookOnFinish,omitempty" protobuf:"varint,9,opt,name=deleteHookOnFinish"` // Metadata holds the user defined metadata which will passed along the event payload. // +optional Metadata map[string]string `json:"metadata,omitempty" protobuf:"bytes,10,rep,name=metadata"` // Filter // +optional Filter *EventSourceFilter `json:"filter,omitempty" protobuf:"bytes,11,opt,name=filter"` // TLS configuration for the bitbucketserver client. // +optional TLS *apicommon.TLSConfig `json:"tls,omitempty" protobuf:"bytes,12,opt,name=tls"` }
BitbucketServerEventSource refers to event-source related to Bitbucket Server events
func (*BitbucketServerEventSource) DeepCopy ¶ added in v1.5.0
func (in *BitbucketServerEventSource) DeepCopy() *BitbucketServerEventSource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BitbucketServerEventSource.
func (*BitbucketServerEventSource) DeepCopyInto ¶ added in v1.5.0
func (in *BitbucketServerEventSource) DeepCopyInto(out *BitbucketServerEventSource)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*BitbucketServerEventSource) Descriptor ¶ added in v1.5.0
func (*BitbucketServerEventSource) Descriptor() ([]byte, []int)
func (BitbucketServerEventSource) GetBitbucketServerRepositories ¶ added in v1.6.0
func (b BitbucketServerEventSource) GetBitbucketServerRepositories() []BitbucketServerRepository
func (*BitbucketServerEventSource) Marshal ¶ added in v1.5.0
func (m *BitbucketServerEventSource) Marshal() (dAtA []byte, err error)
func (*BitbucketServerEventSource) MarshalTo ¶ added in v1.5.0
func (m *BitbucketServerEventSource) MarshalTo(dAtA []byte) (int, error)
func (*BitbucketServerEventSource) MarshalToSizedBuffer ¶ added in v1.5.0
func (m *BitbucketServerEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*BitbucketServerEventSource) ProtoMessage ¶ added in v1.5.0
func (*BitbucketServerEventSource) ProtoMessage()
func (*BitbucketServerEventSource) Reset ¶ added in v1.5.0
func (m *BitbucketServerEventSource) Reset()
func (BitbucketServerEventSource) ShouldCreateWebhooks ¶ added in v1.7.1
func (b BitbucketServerEventSource) ShouldCreateWebhooks() bool
func (*BitbucketServerEventSource) Size ¶ added in v1.5.0
func (m *BitbucketServerEventSource) Size() (n int)
func (*BitbucketServerEventSource) String ¶ added in v1.5.0
func (this *BitbucketServerEventSource) String() string
func (*BitbucketServerEventSource) Unmarshal ¶ added in v1.5.0
func (m *BitbucketServerEventSource) Unmarshal(dAtA []byte) error
func (*BitbucketServerEventSource) XXX_DiscardUnknown ¶ added in v1.5.0
func (m *BitbucketServerEventSource) XXX_DiscardUnknown()
func (*BitbucketServerEventSource) XXX_Marshal ¶ added in v1.5.0
func (m *BitbucketServerEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*BitbucketServerEventSource) XXX_Merge ¶ added in v1.5.0
func (m *BitbucketServerEventSource) XXX_Merge(src proto.Message)
func (*BitbucketServerEventSource) XXX_Size ¶ added in v1.5.0
func (m *BitbucketServerEventSource) XXX_Size() int
func (*BitbucketServerEventSource) XXX_Unmarshal ¶ added in v1.5.0
func (m *BitbucketServerEventSource) XXX_Unmarshal(b []byte) error
type BitbucketServerRepository ¶ added in v1.6.0
type BitbucketServerRepository struct { // ProjectKey is the key of project for which integration needs to set up ProjectKey string `json:"projectKey" protobuf:"bytes,1,opt,name=projectKey"` // RepositorySlug is the slug of the repository for which integration needs to set up RepositorySlug string `json:"repositorySlug" protobuf:"bytes,2,rep,name=repositorySlug"` }
func (*BitbucketServerRepository) DeepCopy ¶ added in v1.6.0
func (in *BitbucketServerRepository) DeepCopy() *BitbucketServerRepository
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BitbucketServerRepository.
func (*BitbucketServerRepository) DeepCopyInto ¶ added in v1.6.0
func (in *BitbucketServerRepository) DeepCopyInto(out *BitbucketServerRepository)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*BitbucketServerRepository) Descriptor ¶ added in v1.6.0
func (*BitbucketServerRepository) Descriptor() ([]byte, []int)
func (*BitbucketServerRepository) Marshal ¶ added in v1.6.0
func (m *BitbucketServerRepository) Marshal() (dAtA []byte, err error)
func (*BitbucketServerRepository) MarshalTo ¶ added in v1.6.0
func (m *BitbucketServerRepository) MarshalTo(dAtA []byte) (int, error)
func (*BitbucketServerRepository) MarshalToSizedBuffer ¶ added in v1.6.0
func (m *BitbucketServerRepository) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*BitbucketServerRepository) ProtoMessage ¶ added in v1.6.0
func (*BitbucketServerRepository) ProtoMessage()
func (*BitbucketServerRepository) Reset ¶ added in v1.6.0
func (m *BitbucketServerRepository) Reset()
func (*BitbucketServerRepository) Size ¶ added in v1.6.0
func (m *BitbucketServerRepository) Size() (n int)
func (*BitbucketServerRepository) String ¶ added in v1.6.0
func (this *BitbucketServerRepository) String() string
func (*BitbucketServerRepository) Unmarshal ¶ added in v1.6.0
func (m *BitbucketServerRepository) Unmarshal(dAtA []byte) error
func (*BitbucketServerRepository) XXX_DiscardUnknown ¶ added in v1.6.0
func (m *BitbucketServerRepository) XXX_DiscardUnknown()
func (*BitbucketServerRepository) XXX_Marshal ¶ added in v1.6.0
func (m *BitbucketServerRepository) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*BitbucketServerRepository) XXX_Merge ¶ added in v1.6.0
func (m *BitbucketServerRepository) XXX_Merge(src proto.Message)
func (*BitbucketServerRepository) XXX_Size ¶ added in v1.6.0
func (m *BitbucketServerRepository) XXX_Size() int
func (*BitbucketServerRepository) XXX_Unmarshal ¶ added in v1.6.0
func (m *BitbucketServerRepository) XXX_Unmarshal(b []byte) error
type CalendarEventSource ¶
type CalendarEventSource struct { // Schedule is a cron-like expression. For reference, see: https://en.wikipedia.org/wiki/Cron // +optional Schedule string `json:"schedule" protobuf:"bytes,1,opt,name=schedule"` // Interval is a string that describes an interval duration, e.g. 1s, 30m, 2h... // +optional Interval string `json:"interval" protobuf:"bytes,2,opt,name=interval"` // ExclusionDates defines the list of DATE-TIME exceptions for recurring events. ExclusionDates []string `json:"exclusionDates,omitempty" protobuf:"bytes,3,rep,name=exclusionDates"` // Timezone in which to run the schedule // +optional Timezone string `json:"timezone,omitempty" protobuf:"bytes,4,opt,name=timezone"` // Metadata holds the user defined metadata which will passed along the event payload. // +optional Metadata map[string]string `json:"metadata,omitempty" protobuf:"bytes,5,rep,name=metadata"` // Persistence hold the configuration for event persistence Persistence *EventPersistence `json:"persistence,omitempty" protobuf:"bytes,6,opt,name=persistence"` // Filter // +optional Filter *EventSourceFilter `json:"filter,omitempty" protobuf:"bytes,8,opt,name=filter"` }
CalendarEventSource describes a time based dependency. One of the fields (schedule, interval, or recurrence) must be passed. Schedule takes precedence over interval; interval takes precedence over recurrence
func (*CalendarEventSource) DeepCopy ¶
func (in *CalendarEventSource) DeepCopy() *CalendarEventSource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CalendarEventSource.
func (*CalendarEventSource) DeepCopyInto ¶
func (in *CalendarEventSource) DeepCopyInto(out *CalendarEventSource)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*CalendarEventSource) Descriptor ¶ added in v0.17.0
func (*CalendarEventSource) Descriptor() ([]byte, []int)
func (*CalendarEventSource) Marshal ¶ added in v0.17.0
func (m *CalendarEventSource) Marshal() (dAtA []byte, err error)
func (*CalendarEventSource) MarshalTo ¶ added in v0.17.0
func (m *CalendarEventSource) MarshalTo(dAtA []byte) (int, error)
func (*CalendarEventSource) MarshalToSizedBuffer ¶ added in v0.17.0
func (m *CalendarEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CalendarEventSource) ProtoMessage ¶ added in v0.17.0
func (*CalendarEventSource) ProtoMessage()
func (*CalendarEventSource) Reset ¶ added in v0.17.0
func (m *CalendarEventSource) Reset()
func (*CalendarEventSource) Size ¶ added in v0.17.0
func (m *CalendarEventSource) Size() (n int)
func (*CalendarEventSource) String ¶ added in v0.17.0
func (this *CalendarEventSource) String() string
func (*CalendarEventSource) Unmarshal ¶ added in v0.17.0
func (m *CalendarEventSource) Unmarshal(dAtA []byte) error
func (*CalendarEventSource) XXX_DiscardUnknown ¶ added in v0.17.0
func (m *CalendarEventSource) XXX_DiscardUnknown()
func (*CalendarEventSource) XXX_Marshal ¶ added in v0.17.0
func (m *CalendarEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CalendarEventSource) XXX_Merge ¶ added in v0.17.0
func (m *CalendarEventSource) XXX_Merge(src proto.Message)
func (*CalendarEventSource) XXX_Size ¶ added in v0.17.0
func (m *CalendarEventSource) XXX_Size() int
func (*CalendarEventSource) XXX_Unmarshal ¶ added in v0.17.0
func (m *CalendarEventSource) XXX_Unmarshal(b []byte) error
type CatchupConfiguration ¶ added in v1.1.0
type CatchupConfiguration struct { // Enabled enables to triggered the missed schedule when eventsource restarts Enabled bool `json:"enabled,omitempty" protobuf:"varint,1,opt,name=enabled"` // MaxDuration holds max catchup duration MaxDuration string `json:"maxDuration,omitempty" protobuf:"bytes,2,opt,name=maxDuration"` }
func (*CatchupConfiguration) DeepCopy ¶ added in v1.1.0
func (in *CatchupConfiguration) DeepCopy() *CatchupConfiguration
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CatchupConfiguration.
func (*CatchupConfiguration) DeepCopyInto ¶ added in v1.1.0
func (in *CatchupConfiguration) DeepCopyInto(out *CatchupConfiguration)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*CatchupConfiguration) Descriptor ¶ added in v1.1.0
func (*CatchupConfiguration) Descriptor() ([]byte, []int)
func (*CatchupConfiguration) Marshal ¶ added in v1.1.0
func (m *CatchupConfiguration) Marshal() (dAtA []byte, err error)
func (*CatchupConfiguration) MarshalTo ¶ added in v1.1.0
func (m *CatchupConfiguration) MarshalTo(dAtA []byte) (int, error)
func (*CatchupConfiguration) MarshalToSizedBuffer ¶ added in v1.1.0
func (m *CatchupConfiguration) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CatchupConfiguration) ProtoMessage ¶ added in v1.1.0
func (*CatchupConfiguration) ProtoMessage()
func (*CatchupConfiguration) Reset ¶ added in v1.1.0
func (m *CatchupConfiguration) Reset()
func (*CatchupConfiguration) Size ¶ added in v1.1.0
func (m *CatchupConfiguration) Size() (n int)
func (*CatchupConfiguration) String ¶ added in v1.1.0
func (this *CatchupConfiguration) String() string
func (*CatchupConfiguration) Unmarshal ¶ added in v1.1.0
func (m *CatchupConfiguration) Unmarshal(dAtA []byte) error
func (*CatchupConfiguration) XXX_DiscardUnknown ¶ added in v1.1.0
func (m *CatchupConfiguration) XXX_DiscardUnknown()
func (*CatchupConfiguration) XXX_Marshal ¶ added in v1.1.0
func (m *CatchupConfiguration) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CatchupConfiguration) XXX_Merge ¶ added in v1.1.0
func (m *CatchupConfiguration) XXX_Merge(src proto.Message)
func (*CatchupConfiguration) XXX_Size ¶ added in v1.1.0
func (m *CatchupConfiguration) XXX_Size() int
func (*CatchupConfiguration) XXX_Unmarshal ¶ added in v1.1.0
func (m *CatchupConfiguration) XXX_Unmarshal(b []byte) error
type ConfigMapPersistence ¶ added in v1.1.0
type ConfigMapPersistence struct { // Name of the configmap Name string `json:"name,omitempty" protobuf:"bytes,1,opt,name=name"` // CreateIfNotExist will create configmap if it doesn't exists CreateIfNotExist bool `json:"createIfNotExist,omitempty" protobuf:"varint,2,opt,name=createIfNotExist"` }
func (*ConfigMapPersistence) DeepCopy ¶ added in v1.1.0
func (in *ConfigMapPersistence) DeepCopy() *ConfigMapPersistence
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConfigMapPersistence.
func (*ConfigMapPersistence) DeepCopyInto ¶ added in v1.1.0
func (in *ConfigMapPersistence) DeepCopyInto(out *ConfigMapPersistence)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ConfigMapPersistence) Descriptor ¶ added in v1.1.0
func (*ConfigMapPersistence) Descriptor() ([]byte, []int)
func (*ConfigMapPersistence) Marshal ¶ added in v1.1.0
func (m *ConfigMapPersistence) Marshal() (dAtA []byte, err error)
func (*ConfigMapPersistence) MarshalTo ¶ added in v1.1.0
func (m *ConfigMapPersistence) MarshalTo(dAtA []byte) (int, error)
func (*ConfigMapPersistence) MarshalToSizedBuffer ¶ added in v1.1.0
func (m *ConfigMapPersistence) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ConfigMapPersistence) ProtoMessage ¶ added in v1.1.0
func (*ConfigMapPersistence) ProtoMessage()
func (*ConfigMapPersistence) Reset ¶ added in v1.1.0
func (m *ConfigMapPersistence) Reset()
func (*ConfigMapPersistence) Size ¶ added in v1.1.0
func (m *ConfigMapPersistence) Size() (n int)
func (*ConfigMapPersistence) String ¶ added in v1.1.0
func (this *ConfigMapPersistence) String() string
func (*ConfigMapPersistence) Unmarshal ¶ added in v1.1.0
func (m *ConfigMapPersistence) Unmarshal(dAtA []byte) error
func (*ConfigMapPersistence) XXX_DiscardUnknown ¶ added in v1.1.0
func (m *ConfigMapPersistence) XXX_DiscardUnknown()
func (*ConfigMapPersistence) XXX_Marshal ¶ added in v1.1.0
func (m *ConfigMapPersistence) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ConfigMapPersistence) XXX_Merge ¶ added in v1.1.0
func (m *ConfigMapPersistence) XXX_Merge(src proto.Message)
func (*ConfigMapPersistence) XXX_Size ¶ added in v1.1.0
func (m *ConfigMapPersistence) XXX_Size() int
func (*ConfigMapPersistence) XXX_Unmarshal ¶ added in v1.1.0
func (m *ConfigMapPersistence) XXX_Unmarshal(b []byte) error
type EmitterEventSource ¶
type EmitterEventSource struct { // Broker URI to connect to. Broker string `json:"broker" protobuf:"bytes,1,opt,name=broker"` // ChannelKey refers to the channel key ChannelKey string `json:"channelKey" protobuf:"bytes,2,opt,name=channelKey"` // ChannelName refers to the channel name ChannelName string `json:"channelName" protobuf:"bytes,3,opt,name=channelName"` // Username to use to connect to broker // +optional Username *corev1.SecretKeySelector `json:"username,omitempty" protobuf:"bytes,4,opt,name=username"` // Password to use to connect to broker // +optional Password *corev1.SecretKeySelector `json:"password,omitempty" protobuf:"bytes,5,opt,name=password"` // Backoff holds parameters applied to connection. // +optional ConnectionBackoff *apicommon.Backoff `json:"connectionBackoff,omitempty" protobuf:"bytes,6,opt,name=connectionBackoff"` // JSONBody specifies that all event body payload coming from this // source will be JSON // +optional JSONBody bool `json:"jsonBody,omitempty" protobuf:"varint,7,opt,name=jsonBody"` // TLS configuration for the emitter client. // +optional TLS *apicommon.TLSConfig `json:"tls,omitempty" protobuf:"bytes,8,opt,name=tls"` // Metadata holds the user defined metadata which will passed along the event payload. // +optional Metadata map[string]string `json:"metadata,omitempty" protobuf:"bytes,9,rep,name=metadata"` // Filter // +optional Filter *EventSourceFilter `json:"filter,omitempty" protobuf:"bytes,10,opt,name=filter"` }
EmitterEventSource describes the event source for emitter More info at https://emitter.io/develop/getting-started/
func (*EmitterEventSource) DeepCopy ¶
func (in *EmitterEventSource) DeepCopy() *EmitterEventSource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EmitterEventSource.
func (*EmitterEventSource) DeepCopyInto ¶
func (in *EmitterEventSource) DeepCopyInto(out *EmitterEventSource)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*EmitterEventSource) Descriptor ¶ added in v0.17.0
func (*EmitterEventSource) Descriptor() ([]byte, []int)
func (*EmitterEventSource) Marshal ¶ added in v0.17.0
func (m *EmitterEventSource) Marshal() (dAtA []byte, err error)
func (*EmitterEventSource) MarshalTo ¶ added in v0.17.0
func (m *EmitterEventSource) MarshalTo(dAtA []byte) (int, error)
func (*EmitterEventSource) MarshalToSizedBuffer ¶ added in v0.17.0
func (m *EmitterEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EmitterEventSource) ProtoMessage ¶ added in v0.17.0
func (*EmitterEventSource) ProtoMessage()
func (*EmitterEventSource) Reset ¶ added in v0.17.0
func (m *EmitterEventSource) Reset()
func (*EmitterEventSource) Size ¶ added in v0.17.0
func (m *EmitterEventSource) Size() (n int)
func (*EmitterEventSource) String ¶ added in v0.17.0
func (this *EmitterEventSource) String() string
func (*EmitterEventSource) Unmarshal ¶ added in v0.17.0
func (m *EmitterEventSource) Unmarshal(dAtA []byte) error
func (*EmitterEventSource) XXX_DiscardUnknown ¶ added in v0.17.0
func (m *EmitterEventSource) XXX_DiscardUnknown()
func (*EmitterEventSource) XXX_Marshal ¶ added in v0.17.0
func (m *EmitterEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EmitterEventSource) XXX_Merge ¶ added in v0.17.0
func (m *EmitterEventSource) XXX_Merge(src proto.Message)
func (*EmitterEventSource) XXX_Size ¶ added in v0.17.0
func (m *EmitterEventSource) XXX_Size() int
func (*EmitterEventSource) XXX_Unmarshal ¶ added in v0.17.0
func (m *EmitterEventSource) XXX_Unmarshal(b []byte) error
type EventPersistence ¶ added in v1.1.0
type EventPersistence struct { // Catchup enables to triggered the missed schedule when eventsource restarts Catchup *CatchupConfiguration `json:"catchup,omitempty" protobuf:"bytes,1,opt,name=catchup"` // ConfigMap holds configmap details for persistence ConfigMap *ConfigMapPersistence `json:"configMap,omitempty" protobuf:"bytes,2,opt,name=configMap"` }
func (*EventPersistence) DeepCopy ¶ added in v1.1.0
func (in *EventPersistence) DeepCopy() *EventPersistence
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EventPersistence.
func (*EventPersistence) DeepCopyInto ¶ added in v1.1.0
func (in *EventPersistence) DeepCopyInto(out *EventPersistence)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*EventPersistence) Descriptor ¶ added in v1.1.0
func (*EventPersistence) Descriptor() ([]byte, []int)
func (*EventPersistence) IsCatchUpEnabled ¶ added in v1.1.0
func (ep *EventPersistence) IsCatchUpEnabled() bool
func (*EventPersistence) Marshal ¶ added in v1.1.0
func (m *EventPersistence) Marshal() (dAtA []byte, err error)
func (*EventPersistence) MarshalTo ¶ added in v1.1.0
func (m *EventPersistence) MarshalTo(dAtA []byte) (int, error)
func (*EventPersistence) MarshalToSizedBuffer ¶ added in v1.1.0
func (m *EventPersistence) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventPersistence) ProtoMessage ¶ added in v1.1.0
func (*EventPersistence) ProtoMessage()
func (*EventPersistence) Reset ¶ added in v1.1.0
func (m *EventPersistence) Reset()
func (*EventPersistence) Size ¶ added in v1.1.0
func (m *EventPersistence) Size() (n int)
func (*EventPersistence) String ¶ added in v1.1.0
func (this *EventPersistence) String() string
func (*EventPersistence) Unmarshal ¶ added in v1.1.0
func (m *EventPersistence) Unmarshal(dAtA []byte) error
func (*EventPersistence) XXX_DiscardUnknown ¶ added in v1.1.0
func (m *EventPersistence) XXX_DiscardUnknown()
func (*EventPersistence) XXX_Marshal ¶ added in v1.1.0
func (m *EventPersistence) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EventPersistence) XXX_Merge ¶ added in v1.1.0
func (m *EventPersistence) XXX_Merge(src proto.Message)
func (*EventPersistence) XXX_Size ¶ added in v1.1.0
func (m *EventPersistence) XXX_Size() int
func (*EventPersistence) XXX_Unmarshal ¶ added in v1.1.0
func (m *EventPersistence) XXX_Unmarshal(b []byte) error
type EventSource ¶
type EventSource struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata" protobuf:"bytes,1,opt,name=metadata"` Spec EventSourceSpec `json:"spec" protobuf:"bytes,2,opt,name=spec"` // +optional Status EventSourceStatus `json:"status,omitempty" protobuf:"bytes,3,opt,name=status"` }
EventSource is the definition of a eventsource resource +genclient +kubebuilder:resource:shortName=es +kubebuilder:subresource:status +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object +k8s:openapi-gen=true
func (*EventSource) DeepCopy ¶
func (in *EventSource) DeepCopy() *EventSource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EventSource.
func (*EventSource) DeepCopyInto ¶
func (in *EventSource) DeepCopyInto(out *EventSource)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*EventSource) DeepCopyObject ¶
func (in *EventSource) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*EventSource) Descriptor ¶ added in v0.17.0
func (*EventSource) Descriptor() ([]byte, []int)
func (*EventSource) Marshal ¶ added in v0.17.0
func (m *EventSource) Marshal() (dAtA []byte, err error)
func (*EventSource) MarshalTo ¶ added in v0.17.0
func (m *EventSource) MarshalTo(dAtA []byte) (int, error)
func (*EventSource) MarshalToSizedBuffer ¶ added in v0.17.0
func (m *EventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventSource) ProtoMessage ¶ added in v0.17.0
func (*EventSource) ProtoMessage()
func (*EventSource) Reset ¶ added in v0.17.0
func (m *EventSource) Reset()
func (*EventSource) Size ¶ added in v0.17.0
func (m *EventSource) Size() (n int)
func (*EventSource) String ¶ added in v0.17.0
func (this *EventSource) String() string
func (*EventSource) Unmarshal ¶ added in v0.17.0
func (m *EventSource) Unmarshal(dAtA []byte) error
func (*EventSource) XXX_DiscardUnknown ¶ added in v0.17.0
func (m *EventSource) XXX_DiscardUnknown()
func (*EventSource) XXX_Marshal ¶ added in v0.17.0
func (m *EventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EventSource) XXX_Merge ¶ added in v0.17.0
func (m *EventSource) XXX_Merge(src proto.Message)
func (*EventSource) XXX_Size ¶ added in v0.17.0
func (m *EventSource) XXX_Size() int
func (*EventSource) XXX_Unmarshal ¶ added in v0.17.0
func (m *EventSource) XXX_Unmarshal(b []byte) error
type EventSourceFilter ¶ added in v1.6.0
type EventSourceFilter struct {
Expression string `json:"expression,omitempty" protobuf:"bytes,1,opt,name=expression"`
}
func (*EventSourceFilter) DeepCopy ¶ added in v1.6.0
func (in *EventSourceFilter) DeepCopy() *EventSourceFilter
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EventSourceFilter.
func (*EventSourceFilter) DeepCopyInto ¶ added in v1.6.0
func (in *EventSourceFilter) DeepCopyInto(out *EventSourceFilter)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*EventSourceFilter) Descriptor ¶ added in v1.6.0
func (*EventSourceFilter) Descriptor() ([]byte, []int)
func (*EventSourceFilter) Marshal ¶ added in v1.6.0
func (m *EventSourceFilter) Marshal() (dAtA []byte, err error)
func (*EventSourceFilter) MarshalTo ¶ added in v1.6.0
func (m *EventSourceFilter) MarshalTo(dAtA []byte) (int, error)
func (*EventSourceFilter) MarshalToSizedBuffer ¶ added in v1.6.0
func (m *EventSourceFilter) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventSourceFilter) ProtoMessage ¶ added in v1.6.0
func (*EventSourceFilter) ProtoMessage()
func (*EventSourceFilter) Reset ¶ added in v1.6.0
func (m *EventSourceFilter) Reset()
func (*EventSourceFilter) Size ¶ added in v1.6.0
func (m *EventSourceFilter) Size() (n int)
func (*EventSourceFilter) String ¶ added in v1.6.0
func (this *EventSourceFilter) String() string
func (*EventSourceFilter) Unmarshal ¶ added in v1.6.0
func (m *EventSourceFilter) Unmarshal(dAtA []byte) error
func (*EventSourceFilter) XXX_DiscardUnknown ¶ added in v1.6.0
func (m *EventSourceFilter) XXX_DiscardUnknown()
func (*EventSourceFilter) XXX_Marshal ¶ added in v1.6.0
func (m *EventSourceFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EventSourceFilter) XXX_Merge ¶ added in v1.6.0
func (m *EventSourceFilter) XXX_Merge(src proto.Message)
func (*EventSourceFilter) XXX_Size ¶ added in v1.6.0
func (m *EventSourceFilter) XXX_Size() int
func (*EventSourceFilter) XXX_Unmarshal ¶ added in v1.6.0
func (m *EventSourceFilter) XXX_Unmarshal(b []byte) error
type EventSourceList ¶
type EventSourceList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata" protobuf:"bytes,1,opt,name=metadata"` Items []EventSource `json:"items" protobuf:"bytes,2,rep,name=items"` }
EventSourceList is the list of eventsource resources +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
func (*EventSourceList) DeepCopy ¶
func (in *EventSourceList) DeepCopy() *EventSourceList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EventSourceList.
func (*EventSourceList) DeepCopyInto ¶
func (in *EventSourceList) DeepCopyInto(out *EventSourceList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*EventSourceList) DeepCopyObject ¶
func (in *EventSourceList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*EventSourceList) Descriptor ¶ added in v0.17.0
func (*EventSourceList) Descriptor() ([]byte, []int)
func (*EventSourceList) Marshal ¶ added in v0.17.0
func (m *EventSourceList) Marshal() (dAtA []byte, err error)
func (*EventSourceList) MarshalTo ¶ added in v0.17.0
func (m *EventSourceList) MarshalTo(dAtA []byte) (int, error)
func (*EventSourceList) MarshalToSizedBuffer ¶ added in v0.17.0
func (m *EventSourceList) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventSourceList) ProtoMessage ¶ added in v0.17.0
func (*EventSourceList) ProtoMessage()
func (*EventSourceList) Reset ¶ added in v0.17.0
func (m *EventSourceList) Reset()
func (*EventSourceList) Size ¶ added in v0.17.0
func (m *EventSourceList) Size() (n int)
func (*EventSourceList) String ¶ added in v0.17.0
func (this *EventSourceList) String() string
func (*EventSourceList) Unmarshal ¶ added in v0.17.0
func (m *EventSourceList) Unmarshal(dAtA []byte) error
func (*EventSourceList) XXX_DiscardUnknown ¶ added in v0.17.0
func (m *EventSourceList) XXX_DiscardUnknown()
func (*EventSourceList) XXX_Marshal ¶ added in v0.17.0
func (m *EventSourceList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EventSourceList) XXX_Merge ¶ added in v0.17.0
func (m *EventSourceList) XXX_Merge(src proto.Message)
func (*EventSourceList) XXX_Size ¶ added in v0.17.0
func (m *EventSourceList) XXX_Size() int
func (*EventSourceList) XXX_Unmarshal ¶ added in v0.17.0
func (m *EventSourceList) XXX_Unmarshal(b []byte) error
type EventSourceSpec ¶
type EventSourceSpec struct { // EventBusName references to a EventBus name. By default the value is "default" EventBusName string `json:"eventBusName,omitempty" protobuf:"bytes,1,opt,name=eventBusName"` // Template is the pod specification for the event source // +optional Template *Template `json:"template,omitempty" protobuf:"bytes,2,opt,name=template"` // Service is the specifications of the service to expose the event source // +optional Service *Service `json:"service,omitempty" protobuf:"bytes,3,opt,name=service"` // Minio event sources Minio map[string]apicommon.S3Artifact `json:"minio,omitempty" protobuf:"bytes,4,rep,name=minio"` // Calendar event sources Calendar map[string]CalendarEventSource `json:"calendar,omitempty" protobuf:"bytes,5,rep,name=calendar"` // File event sources File map[string]FileEventSource `json:"file,omitempty" protobuf:"bytes,6,rep,name=file"` // Resource event sources Resource map[string]ResourceEventSource `json:"resource,omitempty" protobuf:"bytes,7,rep,name=resource"` // Webhook event sources Webhook map[string]WebhookEventSource `json:"webhook,omitempty" protobuf:"bytes,8,rep,name=webhook"` // AMQP event sources AMQP map[string]AMQPEventSource `json:"amqp,omitempty" protobuf:"bytes,9,rep,name=amqp"` // Kafka event sources Kafka map[string]KafkaEventSource `json:"kafka,omitempty" protobuf:"bytes,10,rep,name=kafka"` // MQTT event sources MQTT map[string]MQTTEventSource `json:"mqtt,omitempty" protobuf:"bytes,11,rep,name=mqtt"` // NATS event sources NATS map[string]NATSEventsSource `json:"nats,omitempty" protobuf:"bytes,12,rep,name=nats"` // SNS event sources SNS map[string]SNSEventSource `json:"sns,omitempty" protobuf:"bytes,13,rep,name=sns"` // SQS event sources SQS map[string]SQSEventSource `json:"sqs,omitempty" protobuf:"bytes,14,rep,name=sqs"` // PubSub event sources PubSub map[string]PubSubEventSource `json:"pubSub,omitempty" protobuf:"bytes,15,rep,name=pubSub"` // Github event sources Github map[string]GithubEventSource `json:"github,omitempty" protobuf:"bytes,16,rep,name=github"` // Gitlab event sources Gitlab map[string]GitlabEventSource `json:"gitlab,omitempty" protobuf:"bytes,17,rep,name=gitlab"` // HDFS event sources HDFS map[string]HDFSEventSource `json:"hdfs,omitempty" protobuf:"bytes,18,rep,name=hdfs"` // Slack event sources Slack map[string]SlackEventSource `json:"slack,omitempty" protobuf:"bytes,19,rep,name=slack"` // StorageGrid event sources StorageGrid map[string]StorageGridEventSource `json:"storageGrid,omitempty" protobuf:"bytes,20,rep,name=storageGrid"` // AzureEventsHub event sources AzureEventsHub map[string]AzureEventsHubEventSource `json:"azureEventsHub,omitempty" protobuf:"bytes,21,rep,name=azureEventsHub"` // Stripe event sources Stripe map[string]StripeEventSource `json:"stripe,omitempty" protobuf:"bytes,22,rep,name=stripe"` // Emitter event source Emitter map[string]EmitterEventSource `json:"emitter,omitempty" protobuf:"bytes,23,rep,name=emitter"` // Redis event source Redis map[string]RedisEventSource `json:"redis,omitempty" protobuf:"bytes,24,rep,name=redis"` // NSQ event source NSQ map[string]NSQEventSource `json:"nsq,omitempty" protobuf:"bytes,25,rep,name=nsq"` // Pulsar event source Pulsar map[string]PulsarEventSource `json:"pulsar,omitempty" protobuf:"bytes,26,opt,name=pulsar"` // Generic event source Generic map[string]GenericEventSource `json:"generic,omitempty" protobuf:"bytes,27,rep,name=generic"` // Replicas is the event source deployment replicas Replicas *int32 `json:"replicas,omitempty" protobuf:"varint,28,opt,name=replicas"` // Bitbucket Server event sources BitbucketServer map[string]BitbucketServerEventSource `json:"bitbucketserver,omitempty" protobuf:"bytes,29,rep,name=bitbucketserver"` // Bitbucket event sources Bitbucket map[string]BitbucketEventSource `json:"bitbucket,omitempty" protobuf:"bytes,30,rep,name=bitbucket"` // Redis stream source RedisStream map[string]RedisStreamEventSource `json:"redisStream,omitempty" protobuf:"bytes,31,rep,name=redisStream"` // Azure Service Bus event source AzureServiceBus map[string]AzureServiceBusEventSource `json:"azureServiceBus,omitempty" protobuf:"bytes,32,rep,name=azureServiceBus"` // AzureQueueStorage event source AzureQueueStorage map[string]AzureQueueStorageEventSource `json:"azureQueueStorage,omitempty" protobuf:"bytes,33,rep,name=azureQueueStorage"` // SFTP event sources SFTP map[string]SFTPEventSource `json:"sftp,omitempty" protobuf:"bytes,34,rep,name=sftp"` // Gerrit event source Gerrit map[string]GerritEventSource `json:"gerrit,omitempty" protobuf:"bytes,35,rep,name=gerrit"` }
EventSourceSpec refers to specification of event-source resource
func (*EventSourceSpec) DeepCopy ¶
func (in *EventSourceSpec) DeepCopy() *EventSourceSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EventSourceSpec.
func (*EventSourceSpec) DeepCopyInto ¶
func (in *EventSourceSpec) DeepCopyInto(out *EventSourceSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*EventSourceSpec) Descriptor ¶ added in v0.17.0
func (*EventSourceSpec) Descriptor() ([]byte, []int)
func (EventSourceSpec) GetReplicas ¶ added in v1.3.0
func (e EventSourceSpec) GetReplicas() int32
func (*EventSourceSpec) Marshal ¶ added in v0.17.0
func (m *EventSourceSpec) Marshal() (dAtA []byte, err error)
func (*EventSourceSpec) MarshalTo ¶ added in v0.17.0
func (m *EventSourceSpec) MarshalTo(dAtA []byte) (int, error)
func (*EventSourceSpec) MarshalToSizedBuffer ¶ added in v0.17.0
func (m *EventSourceSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventSourceSpec) ProtoMessage ¶ added in v0.17.0
func (*EventSourceSpec) ProtoMessage()
func (*EventSourceSpec) Reset ¶ added in v0.17.0
func (m *EventSourceSpec) Reset()
func (*EventSourceSpec) Size ¶ added in v0.17.0
func (m *EventSourceSpec) Size() (n int)
func (*EventSourceSpec) String ¶ added in v0.17.0
func (this *EventSourceSpec) String() string
func (*EventSourceSpec) Unmarshal ¶ added in v0.17.0
func (m *EventSourceSpec) Unmarshal(dAtA []byte) error
func (*EventSourceSpec) XXX_DiscardUnknown ¶ added in v0.17.0
func (m *EventSourceSpec) XXX_DiscardUnknown()
func (*EventSourceSpec) XXX_Marshal ¶ added in v0.17.0
func (m *EventSourceSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EventSourceSpec) XXX_Merge ¶ added in v0.17.0
func (m *EventSourceSpec) XXX_Merge(src proto.Message)
func (*EventSourceSpec) XXX_Size ¶ added in v0.17.0
func (m *EventSourceSpec) XXX_Size() int
func (*EventSourceSpec) XXX_Unmarshal ¶ added in v0.17.0
func (m *EventSourceSpec) XXX_Unmarshal(b []byte) error
type EventSourceStatus ¶
type EventSourceStatus struct {
apicommon.Status `json:",inline" protobuf:"bytes,1,opt,name=status"`
}
EventSourceStatus holds the status of the event-source resource
func (*EventSourceStatus) DeepCopy ¶
func (in *EventSourceStatus) DeepCopy() *EventSourceStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EventSourceStatus.
func (*EventSourceStatus) DeepCopyInto ¶
func (in *EventSourceStatus) DeepCopyInto(out *EventSourceStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*EventSourceStatus) Descriptor ¶ added in v0.17.0
func (*EventSourceStatus) Descriptor() ([]byte, []int)
func (*EventSourceStatus) InitConditions ¶ added in v0.17.0
func (es *EventSourceStatus) InitConditions()
InitConditions sets conditions to Unknown state.
func (*EventSourceStatus) MarkDeployFailed ¶ added in v0.17.0
func (es *EventSourceStatus) MarkDeployFailed(reason, message string)
MarkDeployFailed set the eventsource deploy failed
func (*EventSourceStatus) MarkDeployed ¶ added in v0.17.0
func (es *EventSourceStatus) MarkDeployed()
MarkDeployed set the eventsource has been deployed.
func (*EventSourceStatus) MarkSourcesNotProvided ¶ added in v0.17.0
func (es *EventSourceStatus) MarkSourcesNotProvided(reason, message string)
MarkSourcesNotProvided the eventsource has invalid sources spec provided.
func (*EventSourceStatus) MarkSourcesProvided ¶ added in v0.17.0
func (es *EventSourceStatus) MarkSourcesProvided()
MarkSourcesProvided set the eventsource has valid sources spec provided.
func (*EventSourceStatus) Marshal ¶ added in v0.17.0
func (m *EventSourceStatus) Marshal() (dAtA []byte, err error)
func (*EventSourceStatus) MarshalTo ¶ added in v0.17.0
func (m *EventSourceStatus) MarshalTo(dAtA []byte) (int, error)
func (*EventSourceStatus) MarshalToSizedBuffer ¶ added in v0.17.0
func (m *EventSourceStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventSourceStatus) ProtoMessage ¶ added in v0.17.0
func (*EventSourceStatus) ProtoMessage()
func (*EventSourceStatus) Reset ¶ added in v0.17.0
func (m *EventSourceStatus) Reset()
func (*EventSourceStatus) Size ¶ added in v0.17.0
func (m *EventSourceStatus) Size() (n int)
func (*EventSourceStatus) String ¶ added in v0.17.0
func (this *EventSourceStatus) String() string
func (*EventSourceStatus) Unmarshal ¶ added in v0.17.0
func (m *EventSourceStatus) Unmarshal(dAtA []byte) error
func (*EventSourceStatus) XXX_DiscardUnknown ¶ added in v0.17.0
func (m *EventSourceStatus) XXX_DiscardUnknown()
func (*EventSourceStatus) XXX_Marshal ¶ added in v0.17.0
func (m *EventSourceStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EventSourceStatus) XXX_Merge ¶ added in v0.17.0
func (m *EventSourceStatus) XXX_Merge(src proto.Message)
func (*EventSourceStatus) XXX_Size ¶ added in v0.17.0
func (m *EventSourceStatus) XXX_Size() int
func (*EventSourceStatus) XXX_Unmarshal ¶ added in v0.17.0
func (m *EventSourceStatus) XXX_Unmarshal(b []byte) error
type FileEventSource ¶
type FileEventSource struct { // Type of file operations to watch // Refer https://github.com/fsnotify/fsnotify/blob/master/fsnotify.go for more information EventType string `json:"eventType" protobuf:"bytes,1,opt,name=eventType"` // WatchPathConfig contains configuration about the file path to watch WatchPathConfig WatchPathConfig `json:"watchPathConfig" protobuf:"bytes,2,opt,name=watchPathConfig"` // Use polling instead of inotify Polling bool `json:"polling,omitempty" protobuf:"varint,3,opt,name=polling"` // Metadata holds the user defined metadata which will passed along the event payload. // +optional Metadata map[string]string `json:"metadata,omitempty" protobuf:"bytes,4,rep,name=metadata"` // Filter // +optional Filter *EventSourceFilter `json:"filter,omitempty" protobuf:"bytes,5,opt,name=filter"` }
FileEventSource describes an event-source for file related events.
func (*FileEventSource) DeepCopy ¶
func (in *FileEventSource) DeepCopy() *FileEventSource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new FileEventSource.
func (*FileEventSource) DeepCopyInto ¶
func (in *FileEventSource) DeepCopyInto(out *FileEventSource)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*FileEventSource) Descriptor ¶ added in v0.17.0
func (*FileEventSource) Descriptor() ([]byte, []int)
func (*FileEventSource) Marshal ¶ added in v0.17.0
func (m *FileEventSource) Marshal() (dAtA []byte, err error)
func (*FileEventSource) MarshalTo ¶ added in v0.17.0
func (m *FileEventSource) MarshalTo(dAtA []byte) (int, error)
func (*FileEventSource) MarshalToSizedBuffer ¶ added in v0.17.0
func (m *FileEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*FileEventSource) ProtoMessage ¶ added in v0.17.0
func (*FileEventSource) ProtoMessage()
func (*FileEventSource) Reset ¶ added in v0.17.0
func (m *FileEventSource) Reset()
func (*FileEventSource) Size ¶ added in v0.17.0
func (m *FileEventSource) Size() (n int)
func (*FileEventSource) String ¶ added in v0.17.0
func (this *FileEventSource) String() string
func (*FileEventSource) Unmarshal ¶ added in v0.17.0
func (m *FileEventSource) Unmarshal(dAtA []byte) error
func (*FileEventSource) XXX_DiscardUnknown ¶ added in v0.17.0
func (m *FileEventSource) XXX_DiscardUnknown()
func (*FileEventSource) XXX_Marshal ¶ added in v0.17.0
func (m *FileEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*FileEventSource) XXX_Merge ¶ added in v0.17.0
func (m *FileEventSource) XXX_Merge(src proto.Message)
func (*FileEventSource) XXX_Size ¶ added in v0.17.0
func (m *FileEventSource) XXX_Size() int
func (*FileEventSource) XXX_Unmarshal ¶ added in v0.17.0
func (m *FileEventSource) XXX_Unmarshal(b []byte) error
type GenericEventSource ¶
type GenericEventSource struct { // URL of the gRPC server that implements the event source. URL string `json:"url" protobuf:"bytes,1,name=url"` // Config is the event source configuration Config string `json:"config" protobuf:"bytes,2,name=config"` // Insecure determines the type of connection. Insecure bool `json:"insecure,omitempty" protobuf:"varint,3,opt,name=insecure"` // JSONBody specifies that all event body payload coming from this // source will be JSON // +optional JSONBody bool `json:"jsonBody,omitempty" protobuf:"varint,4,opt,name=jsonBody"` // Metadata holds the user defined metadata which will passed along the event payload. // +optional Metadata map[string]string `json:"metadata,omitempty" protobuf:"bytes,5,rep,name=metadata"` // AuthSecret holds a secret selector that contains a bearer token for authentication // +optional AuthSecret *corev1.SecretKeySelector `json:"authSecret,omitempty" protobuf:"bytes,6,opt,name=authSecret"` // Filter // +optional Filter *EventSourceFilter `json:"filter,omitempty" protobuf:"bytes,7,opt,name=filter"` }
GenericEventSource refers to a generic event source. It can be used to implement a custom event source.
func (*GenericEventSource) DeepCopy ¶
func (in *GenericEventSource) DeepCopy() *GenericEventSource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GenericEventSource.
func (*GenericEventSource) DeepCopyInto ¶
func (in *GenericEventSource) DeepCopyInto(out *GenericEventSource)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*GenericEventSource) Descriptor ¶ added in v0.17.0
func (*GenericEventSource) Descriptor() ([]byte, []int)
func (*GenericEventSource) Marshal ¶ added in v0.17.0
func (m *GenericEventSource) Marshal() (dAtA []byte, err error)
func (*GenericEventSource) MarshalTo ¶ added in v0.17.0
func (m *GenericEventSource) MarshalTo(dAtA []byte) (int, error)
func (*GenericEventSource) MarshalToSizedBuffer ¶ added in v0.17.0
func (m *GenericEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GenericEventSource) ProtoMessage ¶ added in v0.17.0
func (*GenericEventSource) ProtoMessage()
func (*GenericEventSource) Reset ¶ added in v0.17.0
func (m *GenericEventSource) Reset()
func (*GenericEventSource) Size ¶ added in v0.17.0
func (m *GenericEventSource) Size() (n int)
func (*GenericEventSource) String ¶ added in v0.17.0
func (this *GenericEventSource) String() string
func (*GenericEventSource) Unmarshal ¶ added in v0.17.0
func (m *GenericEventSource) Unmarshal(dAtA []byte) error
func (*GenericEventSource) XXX_DiscardUnknown ¶ added in v0.17.0
func (m *GenericEventSource) XXX_DiscardUnknown()
func (*GenericEventSource) XXX_Marshal ¶ added in v0.17.0
func (m *GenericEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GenericEventSource) XXX_Merge ¶ added in v0.17.0
func (m *GenericEventSource) XXX_Merge(src proto.Message)
func (*GenericEventSource) XXX_Size ¶ added in v0.17.0
func (m *GenericEventSource) XXX_Size() int
func (*GenericEventSource) XXX_Unmarshal ¶ added in v0.17.0
func (m *GenericEventSource) XXX_Unmarshal(b []byte) error
type GerritEventSource ¶ added in v1.9.0
type GerritEventSource struct { // Webhook holds configuration to run a http server Webhook *WebhookContext `json:"webhook,omitempty" protobuf:"bytes,1,opt,name=webhook"` // HookName is the name of the webhook HookName string `json:"hookName" protobuf:"bytes,2,opt,name=hookName"` // Events are gerrit event to listen to. // Refer https://gerrit-review.googlesource.com/Documentation/cmd-stream-events.html#events Events []string `json:"events" protobuf:"bytes,3,opt,name=events"` // Auth hosts secret selectors for username and password // +optional Auth *apicommon.BasicAuth `json:"auth,omitempty" protobuf:"bytes,4,opt,name=auth"` // GerritBaseURL is the base URL for API requests to a custom endpoint GerritBaseURL string `json:"gerritBaseURL" protobuf:"bytes,5,opt,name=gerritBaseURL"` // DeleteHookOnFinish determines whether to delete the Gerrit hook for the project once the event source is stopped. // +optional DeleteHookOnFinish bool `json:"deleteHookOnFinish,omitempty" protobuf:"varint,6,opt,name=deleteHookOnFinish"` // Metadata holds the user defined metadata which will passed along the event payload. // +optional Metadata map[string]string `json:"metadata,omitempty" protobuf:"bytes,7,rep,name=metadata"` // List of project namespace paths like "whynowy/test". Projects []string `json:"projects,omitempty" protobuf:"bytes,8,rep,name=projects"` // SslVerify to enable ssl verification // +optional SslVerify bool `json:"sslVerify,omitempty" protobuf:"varint,9,opt,name=sslVerify"` // Filter // +optional Filter *EventSourceFilter `json:"filter,omitempty" protobuf:"bytes,10,opt,name=filter"` }
GerritEventSource refers to event-source related to gerrit events
func (*GerritEventSource) DeepCopy ¶ added in v1.9.0
func (in *GerritEventSource) DeepCopy() *GerritEventSource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GerritEventSource.
func (*GerritEventSource) DeepCopyInto ¶ added in v1.9.0
func (in *GerritEventSource) DeepCopyInto(out *GerritEventSource)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*GerritEventSource) Descriptor ¶ added in v1.9.0
func (*GerritEventSource) Descriptor() ([]byte, []int)
func (*GerritEventSource) Marshal ¶ added in v1.9.0
func (m *GerritEventSource) Marshal() (dAtA []byte, err error)
func (*GerritEventSource) MarshalTo ¶ added in v1.9.0
func (m *GerritEventSource) MarshalTo(dAtA []byte) (int, error)
func (*GerritEventSource) MarshalToSizedBuffer ¶ added in v1.9.0
func (m *GerritEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (GerritEventSource) NeedToCreateHooks ¶ added in v1.9.0
func (g GerritEventSource) NeedToCreateHooks() bool
func (*GerritEventSource) ProtoMessage ¶ added in v1.9.0
func (*GerritEventSource) ProtoMessage()
func (*GerritEventSource) Reset ¶ added in v1.9.0
func (m *GerritEventSource) Reset()
func (*GerritEventSource) Size ¶ added in v1.9.0
func (m *GerritEventSource) Size() (n int)
func (*GerritEventSource) String ¶ added in v1.9.0
func (this *GerritEventSource) String() string
func (*GerritEventSource) Unmarshal ¶ added in v1.9.0
func (m *GerritEventSource) Unmarshal(dAtA []byte) error
func (*GerritEventSource) XXX_DiscardUnknown ¶ added in v1.9.0
func (m *GerritEventSource) XXX_DiscardUnknown()
func (*GerritEventSource) XXX_Marshal ¶ added in v1.9.0
func (m *GerritEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GerritEventSource) XXX_Merge ¶ added in v1.9.0
func (m *GerritEventSource) XXX_Merge(src proto.Message)
func (*GerritEventSource) XXX_Size ¶ added in v1.9.0
func (m *GerritEventSource) XXX_Size() int
func (*GerritEventSource) XXX_Unmarshal ¶ added in v1.9.0
func (m *GerritEventSource) XXX_Unmarshal(b []byte) error
type GithubAppCreds ¶ added in v1.5.6
type GithubAppCreds struct { // PrivateKey refers to a K8s secret containing the GitHub app private key PrivateKey *corev1.SecretKeySelector `json:"privateKey" protobuf:"bytes,1,opt,name=privateKey"` // AppID refers to the GitHub App ID for the application you created AppID int64 `json:"appID" protobuf:"bytes,2,opt,name=appID"` // InstallationID refers to the Installation ID of the GitHub app you created and installed InstallationID int64 `json:"installationID" protobuf:"bytes,3,opt,name=installationID"` }
func (*GithubAppCreds) DeepCopy ¶ added in v1.5.6
func (in *GithubAppCreds) DeepCopy() *GithubAppCreds
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GithubAppCreds.
func (*GithubAppCreds) DeepCopyInto ¶ added in v1.5.6
func (in *GithubAppCreds) DeepCopyInto(out *GithubAppCreds)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*GithubAppCreds) Descriptor ¶ added in v1.5.6
func (*GithubAppCreds) Descriptor() ([]byte, []int)
func (*GithubAppCreds) Marshal ¶ added in v1.5.6
func (m *GithubAppCreds) Marshal() (dAtA []byte, err error)
func (*GithubAppCreds) MarshalTo ¶ added in v1.5.6
func (m *GithubAppCreds) MarshalTo(dAtA []byte) (int, error)
func (*GithubAppCreds) MarshalToSizedBuffer ¶ added in v1.5.6
func (m *GithubAppCreds) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GithubAppCreds) ProtoMessage ¶ added in v1.5.6
func (*GithubAppCreds) ProtoMessage()
func (*GithubAppCreds) Reset ¶ added in v1.5.6
func (m *GithubAppCreds) Reset()
func (*GithubAppCreds) Size ¶ added in v1.5.6
func (m *GithubAppCreds) Size() (n int)
func (*GithubAppCreds) String ¶ added in v1.5.6
func (this *GithubAppCreds) String() string
func (*GithubAppCreds) Unmarshal ¶ added in v1.5.6
func (m *GithubAppCreds) Unmarshal(dAtA []byte) error
func (*GithubAppCreds) XXX_DiscardUnknown ¶ added in v1.5.6
func (m *GithubAppCreds) XXX_DiscardUnknown()
func (*GithubAppCreds) XXX_Marshal ¶ added in v1.5.6
func (m *GithubAppCreds) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GithubAppCreds) XXX_Merge ¶ added in v1.5.6
func (m *GithubAppCreds) XXX_Merge(src proto.Message)
func (*GithubAppCreds) XXX_Size ¶ added in v1.5.6
func (m *GithubAppCreds) XXX_Size() int
func (*GithubAppCreds) XXX_Unmarshal ¶ added in v1.5.6
func (m *GithubAppCreds) XXX_Unmarshal(b []byte) error
type GithubEventSource ¶
type GithubEventSource struct { // Id is the webhook's id // Deprecated: This is not used at all, will be removed in v1.6 // +optional ID int64 `json:"id" protobuf:"varint,1,opt,name=id"` // Webhook refers to the configuration required to run a http server Webhook *WebhookContext `json:"webhook,omitempty" protobuf:"bytes,2,opt,name=webhook"` // DeprecatedOwner refers to GitHub owner name i.e. argoproj // Deprecated: use Repositories instead. Will be unsupported in v 1.6 // +optional DeprecatedOwner string `json:"owner" protobuf:"bytes,3,opt,name=owner"` // DeprecatedRepository refers to GitHub repo name i.e. argo-events // Deprecated: use Repositories instead. Will be unsupported in v 1.6 // +optional DeprecatedRepository string `json:"repository" protobuf:"bytes,4,opt,name=repository"` // Events refer to Github events to which the event source will subscribe Events []string `json:"events" protobuf:"bytes,5,rep,name=events"` // APIToken refers to a K8s secret containing github api token // +optional APIToken *corev1.SecretKeySelector `json:"apiToken,omitempty" protobuf:"bytes,6,opt,name=apiToken"` // WebhookSecret refers to K8s secret containing GitHub webhook secret // https://developer.github.com/webhooks/securing/ // +optional WebhookSecret *corev1.SecretKeySelector `json:"webhookSecret,omitempty" protobuf:"bytes,7,opt,name=webhookSecret"` // Insecure tls verification Insecure bool `json:"insecure,omitempty" protobuf:"varint,8,opt,name=insecure"` // Active refers to status of the webhook for event deliveries. // https://developer.github.com/webhooks/creating/#active // +optional Active bool `json:"active,omitempty" protobuf:"varint,9,opt,name=active"` // ContentType of the event delivery ContentType string `json:"contentType,omitempty" protobuf:"bytes,10,opt,name=contentType"` // GitHub base URL (for GitHub Enterprise) // +optional GithubBaseURL string `json:"githubBaseURL,omitempty" protobuf:"bytes,11,opt,name=githubBaseURL"` // GitHub upload URL (for GitHub Enterprise) // +optional GithubUploadURL string `json:"githubUploadURL,omitempty" protobuf:"bytes,12,opt,name=githubUploadURL"` // DeleteHookOnFinish determines whether to delete the GitHub hook for the repository once the event source is stopped. // +optional DeleteHookOnFinish bool `json:"deleteHookOnFinish,omitempty" protobuf:"varint,13,opt,name=deleteHookOnFinish"` // Metadata holds the user defined metadata which will passed along the event payload. // +optional Metadata map[string]string `json:"metadata,omitempty" protobuf:"bytes,14,rep,name=metadata"` // Repositories holds the information of repositories, which uses repo owner as the key, // and list of repo names as the value. Not required if Organizations is set. Repositories []OwnedRepositories `json:"repositories,omitempty" protobuf:"bytes,15,rep,name=repositories"` // Organizations holds the names of organizations (used for organization level webhooks). Not required if Repositories is set. Organizations []string `json:"organizations,omitempty" protobuf:"bytes,16,rep,name=organizations"` // GitHubApp holds the GitHub app credentials // +optional GithubApp *GithubAppCreds `json:"githubApp,omitempty" protobuf:"bytes,17,opt,name=githubApp"` // Filter // +optional Filter *EventSourceFilter `json:"filter,omitempty" protobuf:"bytes,18,opt,name=filter"` }
GithubEventSource refers to event-source for github related events
func (*GithubEventSource) DeepCopy ¶
func (in *GithubEventSource) DeepCopy() *GithubEventSource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GithubEventSource.
func (*GithubEventSource) DeepCopyInto ¶
func (in *GithubEventSource) DeepCopyInto(out *GithubEventSource)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*GithubEventSource) Descriptor ¶ added in v0.17.0
func (*GithubEventSource) Descriptor() ([]byte, []int)
func (GithubEventSource) GetOwnedRepositories ¶ added in v1.3.1
func (g GithubEventSource) GetOwnedRepositories() []OwnedRepositories
func (GithubEventSource) HasConfiguredWebhook ¶ added in v1.5.6
func (g GithubEventSource) HasConfiguredWebhook() bool
func (GithubEventSource) HasGithubAPIToken ¶ added in v1.5.6
func (g GithubEventSource) HasGithubAPIToken() bool
func (GithubEventSource) HasGithubAppCreds ¶ added in v1.5.6
func (g GithubEventSource) HasGithubAppCreds() bool
func (*GithubEventSource) Marshal ¶ added in v0.17.0
func (m *GithubEventSource) Marshal() (dAtA []byte, err error)
func (*GithubEventSource) MarshalTo ¶ added in v0.17.0
func (m *GithubEventSource) MarshalTo(dAtA []byte) (int, error)
func (*GithubEventSource) MarshalToSizedBuffer ¶ added in v0.17.0
func (m *GithubEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (GithubEventSource) NeedToCreateHooks ¶ added in v1.3.1
func (g GithubEventSource) NeedToCreateHooks() bool
func (*GithubEventSource) ProtoMessage ¶ added in v0.17.0
func (*GithubEventSource) ProtoMessage()
func (*GithubEventSource) Reset ¶ added in v0.17.0
func (m *GithubEventSource) Reset()
func (*GithubEventSource) Size ¶ added in v0.17.0
func (m *GithubEventSource) Size() (n int)
func (*GithubEventSource) String ¶ added in v0.17.0
func (this *GithubEventSource) String() string
func (*GithubEventSource) Unmarshal ¶ added in v0.17.0
func (m *GithubEventSource) Unmarshal(dAtA []byte) error
func (*GithubEventSource) XXX_DiscardUnknown ¶ added in v0.17.0
func (m *GithubEventSource) XXX_DiscardUnknown()
func (*GithubEventSource) XXX_Marshal ¶ added in v0.17.0
func (m *GithubEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GithubEventSource) XXX_Merge ¶ added in v0.17.0
func (m *GithubEventSource) XXX_Merge(src proto.Message)
func (*GithubEventSource) XXX_Size ¶ added in v0.17.0
func (m *GithubEventSource) XXX_Size() int
func (*GithubEventSource) XXX_Unmarshal ¶ added in v0.17.0
func (m *GithubEventSource) XXX_Unmarshal(b []byte) error
type GitlabEventSource ¶
type GitlabEventSource struct { // Webhook holds configuration to run a http server Webhook *WebhookContext `json:"webhook,omitempty" protobuf:"bytes,1,opt,name=webhook"` // DeprecatedProjectID is the id of project for which integration needs to setup // Deprecated: use Projects instead. Will be unsupported in v 1.7 // +optional DeprecatedProjectID string `json:"projectID,omitempty" protobuf:"bytes,2,opt,name=projectID"` // Events are gitlab event to listen to. // Refer https://github.com/xanzy/go-gitlab/blob/bf34eca5d13a9f4c3f501d8a97b8ac226d55e4d9/projects.go#L794. Events []string `json:"events" protobuf:"bytes,3,opt,name=events"` // AccessToken references to k8 secret which holds the gitlab api access information AccessToken *corev1.SecretKeySelector `json:"accessToken,omitempty" protobuf:"bytes,4,opt,name=accessToken"` // EnableSSLVerification to enable ssl verification // +optional EnableSSLVerification bool `json:"enableSSLVerification,omitempty" protobuf:"varint,5,opt,name=enableSSLVerification"` // GitlabBaseURL is the base URL for API requests to a custom endpoint GitlabBaseURL string `json:"gitlabBaseURL" protobuf:"bytes,6,opt,name=gitlabBaseURL"` // DeleteHookOnFinish determines whether to delete the GitLab hook for the project once the event source is stopped. // +optional DeleteHookOnFinish bool `json:"deleteHookOnFinish,omitempty" protobuf:"varint,8,opt,name=deleteHookOnFinish"` // Metadata holds the user defined metadata which will passed along the event payload. // +optional Metadata map[string]string `json:"metadata,omitempty" protobuf:"bytes,9,rep,name=metadata"` // List of project IDs or project namespace paths like "whynowy/test". Projects and groups cannot be empty at the same time. // +optional Projects []string `json:"projects,omitempty" protobuf:"bytes,10,rep,name=projects"` // SecretToken references to k8 secret which holds the Secret Token used by webhook config SecretToken *corev1.SecretKeySelector `json:"secretToken,omitempty" protobuf:"bytes,11,opt,name=secretToken"` // Filter // +optional Filter *EventSourceFilter `json:"filter,omitempty" protobuf:"bytes,12,opt,name=filter"` // List of group IDs or group name like "test". // Group level hook available in Premium and Ultimate Gitlab. // +optional Groups []string `json:"groups,omitempty" protobuf:"bytes,13,rep,name=groups"` }
GitlabEventSource refers to event-source related to Gitlab events
func (*GitlabEventSource) DeepCopy ¶
func (in *GitlabEventSource) DeepCopy() *GitlabEventSource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GitlabEventSource.
func (*GitlabEventSource) DeepCopyInto ¶
func (in *GitlabEventSource) DeepCopyInto(out *GitlabEventSource)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*GitlabEventSource) Descriptor ¶ added in v0.17.0
func (*GitlabEventSource) Descriptor() ([]byte, []int)
func (GitlabEventSource) GetGroups ¶ added in v1.8.0
func (g GitlabEventSource) GetGroups() []string
func (GitlabEventSource) GetProjects ¶ added in v1.5.0
func (g GitlabEventSource) GetProjects() []string
func (*GitlabEventSource) Marshal ¶ added in v0.17.0
func (m *GitlabEventSource) Marshal() (dAtA []byte, err error)
func (*GitlabEventSource) MarshalTo ¶ added in v0.17.0
func (m *GitlabEventSource) MarshalTo(dAtA []byte) (int, error)
func (*GitlabEventSource) MarshalToSizedBuffer ¶ added in v0.17.0
func (m *GitlabEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (GitlabEventSource) NeedToCreateHooks ¶ added in v1.5.0
func (g GitlabEventSource) NeedToCreateHooks() bool
func (*GitlabEventSource) ProtoMessage ¶ added in v0.17.0
func (*GitlabEventSource) ProtoMessage()
func (*GitlabEventSource) Reset ¶ added in v0.17.0
func (m *GitlabEventSource) Reset()
func (*GitlabEventSource) Size ¶ added in v0.17.0
func (m *GitlabEventSource) Size() (n int)
func (*GitlabEventSource) String ¶ added in v0.17.0
func (this *GitlabEventSource) String() string
func (*GitlabEventSource) Unmarshal ¶ added in v0.17.0
func (m *GitlabEventSource) Unmarshal(dAtA []byte) error
func (*GitlabEventSource) XXX_DiscardUnknown ¶ added in v0.17.0
func (m *GitlabEventSource) XXX_DiscardUnknown()
func (*GitlabEventSource) XXX_Marshal ¶ added in v0.17.0
func (m *GitlabEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GitlabEventSource) XXX_Merge ¶ added in v0.17.0
func (m *GitlabEventSource) XXX_Merge(src proto.Message)
func (*GitlabEventSource) XXX_Size ¶ added in v0.17.0
func (m *GitlabEventSource) XXX_Size() int
func (*GitlabEventSource) XXX_Unmarshal ¶ added in v0.17.0
func (m *GitlabEventSource) XXX_Unmarshal(b []byte) error
type HDFSEventSource ¶
type HDFSEventSource struct { WatchPathConfig `json:",inline" protobuf:"bytes,1,opt,name=watchPathConfig"` // Type of file operations to watch Type string `json:"type" protobuf:"bytes,2,opt,name=type"` // CheckInterval is a string that describes an interval duration to check the directory state, e.g. 1s, 30m, 2h... (defaults to 1m) CheckInterval string `json:"checkInterval,omitempty" protobuf:"bytes,3,opt,name=checkInterval"` Addresses []string `json:"addresses" protobuf:"bytes,4,rep,name=addresses"` // HDFSUser is the user to access HDFS file system. // It is ignored if either ccache or keytab is used. HDFSUser string `json:"hdfsUser,omitempty" protobuf:"bytes,5,opt,name=hdfsUser"` // KrbCCacheSecret is the secret selector for Kerberos ccache // Either ccache or keytab can be set to use Kerberos. KrbCCacheSecret *corev1.SecretKeySelector `json:"krbCCacheSecret,omitempty" protobuf:"bytes,6,opt,name=krbCCacheSecret"` // KrbKeytabSecret is the secret selector for Kerberos keytab // Either ccache or keytab can be set to use Kerberos. KrbKeytabSecret *corev1.SecretKeySelector `json:"krbKeytabSecret,omitempty" protobuf:"bytes,7,opt,name=krbKeytabSecret"` // KrbUsername is the Kerberos username used with Kerberos keytab // It must be set if keytab is used. KrbUsername string `json:"krbUsername,omitempty" protobuf:"bytes,8,opt,name=krbUsername"` // KrbRealm is the Kerberos realm used with Kerberos keytab // It must be set if keytab is used. KrbRealm string `json:"krbRealm,omitempty" protobuf:"bytes,9,opt,name=krbRealm"` // KrbConfig is the configmap selector for Kerberos config as string // It must be set if either ccache or keytab is used. KrbConfigConfigMap *corev1.ConfigMapKeySelector `json:"krbConfigConfigMap,omitempty" protobuf:"bytes,10,opt,name=krbConfigConfigMap"` // KrbServicePrincipalName is the principal name of Kerberos service // It must be set if either ccache or keytab is used. KrbServicePrincipalName string `json:"krbServicePrincipalName,omitempty" protobuf:"bytes,11,opt,name=krbServicePrincipalName"` // Metadata holds the user defined metadata which will passed along the event payload. // +optional Metadata map[string]string `json:"metadata,omitempty" protobuf:"bytes,12,rep,name=metadata"` // Filter // +optional Filter *EventSourceFilter `json:"filter,omitempty" protobuf:"bytes,13,opt,name=filter"` }
HDFSEventSource refers to event-source for HDFS related events
func (*HDFSEventSource) DeepCopy ¶
func (in *HDFSEventSource) DeepCopy() *HDFSEventSource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new HDFSEventSource.
func (*HDFSEventSource) DeepCopyInto ¶
func (in *HDFSEventSource) DeepCopyInto(out *HDFSEventSource)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*HDFSEventSource) Descriptor ¶ added in v0.17.0
func (*HDFSEventSource) Descriptor() ([]byte, []int)
func (*HDFSEventSource) Marshal ¶ added in v0.17.0
func (m *HDFSEventSource) Marshal() (dAtA []byte, err error)
func (*HDFSEventSource) MarshalTo ¶ added in v0.17.0
func (m *HDFSEventSource) MarshalTo(dAtA []byte) (int, error)
func (*HDFSEventSource) MarshalToSizedBuffer ¶ added in v0.17.0
func (m *HDFSEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*HDFSEventSource) ProtoMessage ¶ added in v0.17.0
func (*HDFSEventSource) ProtoMessage()
func (*HDFSEventSource) Reset ¶ added in v0.17.0
func (m *HDFSEventSource) Reset()
func (*HDFSEventSource) Size ¶ added in v0.17.0
func (m *HDFSEventSource) Size() (n int)
func (*HDFSEventSource) String ¶ added in v0.17.0
func (this *HDFSEventSource) String() string
func (*HDFSEventSource) Unmarshal ¶ added in v0.17.0
func (m *HDFSEventSource) Unmarshal(dAtA []byte) error
func (*HDFSEventSource) XXX_DiscardUnknown ¶ added in v0.17.0
func (m *HDFSEventSource) XXX_DiscardUnknown()
func (*HDFSEventSource) XXX_Marshal ¶ added in v0.17.0
func (m *HDFSEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*HDFSEventSource) XXX_Merge ¶ added in v0.17.0
func (m *HDFSEventSource) XXX_Merge(src proto.Message)
func (*HDFSEventSource) XXX_Size ¶ added in v0.17.0
func (m *HDFSEventSource) XXX_Size() int
func (*HDFSEventSource) XXX_Unmarshal ¶ added in v0.17.0
func (m *HDFSEventSource) XXX_Unmarshal(b []byte) error
type KafkaConsumerGroup ¶ added in v1.0.0
type KafkaConsumerGroup struct { // The name for the consumer group to use GroupName string `json:"groupName" protobuf:"bytes,1,opt,name=groupName"` // When starting up a new group do we want to start from the oldest event (true) or the newest event (false), defaults to false // +optional Oldest bool `json:"oldest,omitempty" protobuf:"varint,2,opt,name=oldest"` // Rebalance strategy can be one of: sticky, roundrobin, range. Range is the default. // +optional RebalanceStrategy string `json:"rebalanceStrategy" protobuf:"bytes,3,opt,name=rebalanceStrategy"` }
func (*KafkaConsumerGroup) DeepCopy ¶ added in v1.0.0
func (in *KafkaConsumerGroup) DeepCopy() *KafkaConsumerGroup
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaConsumerGroup.
func (*KafkaConsumerGroup) DeepCopyInto ¶ added in v1.0.0
func (in *KafkaConsumerGroup) DeepCopyInto(out *KafkaConsumerGroup)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*KafkaConsumerGroup) Descriptor ¶ added in v1.0.0
func (*KafkaConsumerGroup) Descriptor() ([]byte, []int)
func (*KafkaConsumerGroup) Marshal ¶ added in v1.0.0
func (m *KafkaConsumerGroup) Marshal() (dAtA []byte, err error)
func (*KafkaConsumerGroup) MarshalTo ¶ added in v1.0.0
func (m *KafkaConsumerGroup) MarshalTo(dAtA []byte) (int, error)
func (*KafkaConsumerGroup) MarshalToSizedBuffer ¶ added in v1.0.0
func (m *KafkaConsumerGroup) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*KafkaConsumerGroup) ProtoMessage ¶ added in v1.0.0
func (*KafkaConsumerGroup) ProtoMessage()
func (*KafkaConsumerGroup) Reset ¶ added in v1.0.0
func (m *KafkaConsumerGroup) Reset()
func (*KafkaConsumerGroup) Size ¶ added in v1.0.0
func (m *KafkaConsumerGroup) Size() (n int)
func (*KafkaConsumerGroup) String ¶ added in v1.0.0
func (this *KafkaConsumerGroup) String() string
func (*KafkaConsumerGroup) Unmarshal ¶ added in v1.0.0
func (m *KafkaConsumerGroup) Unmarshal(dAtA []byte) error
func (*KafkaConsumerGroup) XXX_DiscardUnknown ¶ added in v1.0.0
func (m *KafkaConsumerGroup) XXX_DiscardUnknown()
func (*KafkaConsumerGroup) XXX_Marshal ¶ added in v1.0.0
func (m *KafkaConsumerGroup) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*KafkaConsumerGroup) XXX_Merge ¶ added in v1.0.0
func (m *KafkaConsumerGroup) XXX_Merge(src proto.Message)
func (*KafkaConsumerGroup) XXX_Size ¶ added in v1.0.0
func (m *KafkaConsumerGroup) XXX_Size() int
func (*KafkaConsumerGroup) XXX_Unmarshal ¶ added in v1.0.0
func (m *KafkaConsumerGroup) XXX_Unmarshal(b []byte) error
type KafkaEventSource ¶
type KafkaEventSource struct { // URL to kafka cluster, multiple URLs separated by comma URL string `json:"url" protobuf:"bytes,1,opt,name=url"` // Partition name // +optional Partition string `json:"partition" protobuf:"bytes,2,opt,name=partition"` // Topic name Topic string `json:"topic" protobuf:"bytes,3,opt,name=topic"` // Backoff holds parameters applied to connection. ConnectionBackoff *apicommon.Backoff `json:"connectionBackoff,omitempty" protobuf:"bytes,4,opt,name=connectionBackoff"` // TLS configuration for the kafka client. // +optional TLS *apicommon.TLSConfig `json:"tls,omitempty" protobuf:"bytes,5,opt,name=tls"` // JSONBody specifies that all event body payload coming from this // source will be JSON // +optional JSONBody bool `json:"jsonBody,omitempty" protobuf:"varint,6,opt,name=jsonBody"` // Metadata holds the user defined metadata which will passed along the event payload. // +optional Metadata map[string]string `json:"metadata,omitempty" protobuf:"bytes,7,rep,name=metadata"` // Consumer group for kafka client // +optional ConsumerGroup *KafkaConsumerGroup `json:"consumerGroup,omitempty" protobuf:"bytes,8,opt,name=consumerGroup"` // Sets a limit on how many events get read from kafka per second. // +optional LimitEventsPerSecond int64 `json:"limitEventsPerSecond,omitempty" protobuf:"varint,9,opt,name=limitEventsPerSecond"` // Specify what kafka version is being connected to enables certain features in sarama, defaults to 1.0.0 // +optional Version string `json:"version" protobuf:"bytes,10,opt,name=version"` // SASL configuration for the kafka client // +optional SASL *apicommon.SASLConfig `json:"sasl,omitempty" protobuf:"bytes,11,opt,name=sasl"` // Filter // +optional Filter *EventSourceFilter `json:"filter,omitempty" protobuf:"bytes,12,opt,name=filter"` // Yaml format Sarama config for Kafka connection. // It follows the struct of sarama.Config. See https://github.com/IBM/sarama/blob/main/config.go // e.g. // // consumer: // fetch: // min: 1 // net: // MaxOpenRequests: 5 // // +optional Config string `json:"config,omitempty" protobuf:"bytes,13,opt,name=config"` }
KafkaEventSource refers to event-source for Kafka related events
func (*KafkaEventSource) DeepCopy ¶
func (in *KafkaEventSource) DeepCopy() *KafkaEventSource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaEventSource.
func (*KafkaEventSource) DeepCopyInto ¶
func (in *KafkaEventSource) DeepCopyInto(out *KafkaEventSource)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*KafkaEventSource) Descriptor ¶ added in v0.17.0
func (*KafkaEventSource) Descriptor() ([]byte, []int)
func (*KafkaEventSource) Marshal ¶ added in v0.17.0
func (m *KafkaEventSource) Marshal() (dAtA []byte, err error)
func (*KafkaEventSource) MarshalTo ¶ added in v0.17.0
func (m *KafkaEventSource) MarshalTo(dAtA []byte) (int, error)
func (*KafkaEventSource) MarshalToSizedBuffer ¶ added in v0.17.0
func (m *KafkaEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*KafkaEventSource) ProtoMessage ¶ added in v0.17.0
func (*KafkaEventSource) ProtoMessage()
func (*KafkaEventSource) Reset ¶ added in v0.17.0
func (m *KafkaEventSource) Reset()
func (*KafkaEventSource) Size ¶ added in v0.17.0
func (m *KafkaEventSource) Size() (n int)
func (*KafkaEventSource) String ¶ added in v0.17.0
func (this *KafkaEventSource) String() string
func (*KafkaEventSource) Unmarshal ¶ added in v0.17.0
func (m *KafkaEventSource) Unmarshal(dAtA []byte) error
func (*KafkaEventSource) XXX_DiscardUnknown ¶ added in v0.17.0
func (m *KafkaEventSource) XXX_DiscardUnknown()
func (*KafkaEventSource) XXX_Marshal ¶ added in v0.17.0
func (m *KafkaEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*KafkaEventSource) XXX_Merge ¶ added in v0.17.0
func (m *KafkaEventSource) XXX_Merge(src proto.Message)
func (*KafkaEventSource) XXX_Size ¶ added in v0.17.0
func (m *KafkaEventSource) XXX_Size() int
func (*KafkaEventSource) XXX_Unmarshal ¶ added in v0.17.0
func (m *KafkaEventSource) XXX_Unmarshal(b []byte) error
type MQTTEventSource ¶
type MQTTEventSource struct { // URL to connect to broker URL string `json:"url" protobuf:"bytes,1,opt,name=url"` // Topic name Topic string `json:"topic" protobuf:"bytes,2,opt,name=topic"` // ClientID is the id of the client ClientID string `json:"clientId" protobuf:"bytes,3,opt,name=clientId"` // ConnectionBackoff holds backoff applied to connection. ConnectionBackoff *apicommon.Backoff `json:"connectionBackoff,omitempty" protobuf:"bytes,4,opt,name=connectionBackoff"` // JSONBody specifies that all event body payload coming from this // source will be JSON // +optional JSONBody bool `json:"jsonBody,omitempty" protobuf:"varint,5,opt,name=jsonBody"` // TLS configuration for the mqtt client. // +optional TLS *apicommon.TLSConfig `json:"tls,omitempty" protobuf:"bytes,6,opt,name=tls"` // Metadata holds the user defined metadata which will passed along the event payload. // +optional Metadata map[string]string `json:"metadata,omitempty" protobuf:"bytes,7,rep,name=metadata"` // Filter // +optional Filter *EventSourceFilter `json:"filter,omitempty" protobuf:"bytes,8,opt,name=filter"` // Auth hosts secret selectors for username and password // +optional Auth *apicommon.BasicAuth `json:"auth,omitempty" protobuf:"bytes,9,opt,name=auth"` }
MQTTEventSource refers to event-source for MQTT related events
func (*MQTTEventSource) DeepCopy ¶
func (in *MQTTEventSource) DeepCopy() *MQTTEventSource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MQTTEventSource.
func (*MQTTEventSource) DeepCopyInto ¶
func (in *MQTTEventSource) DeepCopyInto(out *MQTTEventSource)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*MQTTEventSource) Descriptor ¶ added in v0.17.0
func (*MQTTEventSource) Descriptor() ([]byte, []int)
func (*MQTTEventSource) Marshal ¶ added in v0.17.0
func (m *MQTTEventSource) Marshal() (dAtA []byte, err error)
func (*MQTTEventSource) MarshalTo ¶ added in v0.17.0
func (m *MQTTEventSource) MarshalTo(dAtA []byte) (int, error)
func (*MQTTEventSource) MarshalToSizedBuffer ¶ added in v0.17.0
func (m *MQTTEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MQTTEventSource) ProtoMessage ¶ added in v0.17.0
func (*MQTTEventSource) ProtoMessage()
func (*MQTTEventSource) Reset ¶ added in v0.17.0
func (m *MQTTEventSource) Reset()
func (*MQTTEventSource) Size ¶ added in v0.17.0
func (m *MQTTEventSource) Size() (n int)
func (*MQTTEventSource) String ¶ added in v0.17.0
func (this *MQTTEventSource) String() string
func (*MQTTEventSource) Unmarshal ¶ added in v0.17.0
func (m *MQTTEventSource) Unmarshal(dAtA []byte) error
func (*MQTTEventSource) XXX_DiscardUnknown ¶ added in v0.17.0
func (m *MQTTEventSource) XXX_DiscardUnknown()
func (*MQTTEventSource) XXX_Marshal ¶ added in v0.17.0
func (m *MQTTEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MQTTEventSource) XXX_Merge ¶ added in v0.17.0
func (m *MQTTEventSource) XXX_Merge(src proto.Message)
func (*MQTTEventSource) XXX_Size ¶ added in v0.17.0
func (m *MQTTEventSource) XXX_Size() int
func (*MQTTEventSource) XXX_Unmarshal ¶ added in v0.17.0
func (m *MQTTEventSource) XXX_Unmarshal(b []byte) error
type NATSAuth ¶ added in v1.3.0
type NATSAuth struct { // Baisc auth with username and password // +optional Basic *apicommon.BasicAuth `json:"basic,omitempty" protobuf:"bytes,1,opt,name=basic"` // Token used to connect // +optional Token *corev1.SecretKeySelector `json:"token,omitempty" protobuf:"bytes,2,opt,name=token"` // NKey used to connect // +optional NKey *corev1.SecretKeySelector `json:"nkey,omitempty" protobuf:"bytes,3,opt,name=nkey"` // credential used to connect // +optional Credential *corev1.SecretKeySelector `json:"credential,omitempty" protobuf:"bytes,4,opt,name=credential"` }
NATSAuth refers to the auth info for NATS EventSource
func (*NATSAuth) DeepCopy ¶ added in v1.3.0
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NATSAuth.
func (*NATSAuth) DeepCopyInto ¶ added in v1.3.0
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*NATSAuth) Descriptor ¶ added in v1.3.0
func (*NATSAuth) MarshalToSizedBuffer ¶ added in v1.3.0
func (*NATSAuth) ProtoMessage ¶ added in v1.3.0
func (*NATSAuth) ProtoMessage()
func (*NATSAuth) XXX_DiscardUnknown ¶ added in v1.3.0
func (m *NATSAuth) XXX_DiscardUnknown()
func (*NATSAuth) XXX_Marshal ¶ added in v1.3.0
func (*NATSAuth) XXX_Unmarshal ¶ added in v1.3.0
type NATSEventsSource ¶
type NATSEventsSource struct { // URL to connect to NATS cluster URL string `json:"url" protobuf:"bytes,1,opt,name=url"` // Subject holds the name of the subject onto which messages are published Subject string `json:"subject" protobuf:"bytes,2,opt,name=subject"` // ConnectionBackoff holds backoff applied to connection. ConnectionBackoff *apicommon.Backoff `json:"connectionBackoff,omitempty" protobuf:"bytes,3,opt,name=connectionBackoff"` // JSONBody specifies that all event body payload coming from this // source will be JSON // +optional JSONBody bool `json:"jsonBody,omitempty" protobuf:"varint,4,opt,name=jsonBody"` // TLS configuration for the nats client. // +optional TLS *apicommon.TLSConfig `json:"tls,omitempty" protobuf:"bytes,5,opt,name=tls"` // Metadata holds the user defined metadata which will passed along the event payload. // +optional Metadata map[string]string `json:"metadata,omitempty" protobuf:"bytes,6,rep,name=metadata"` // Auth information // +optional Auth *NATSAuth `json:"auth,omitempty" protobuf:"bytes,7,opt,name=auth"` // Filter // +optional Filter *EventSourceFilter `json:"filter,omitempty" protobuf:"bytes,8,opt,name=filter"` }
NATSEventsSource refers to event-source for NATS related events
func (*NATSEventsSource) DeepCopy ¶
func (in *NATSEventsSource) DeepCopy() *NATSEventsSource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NATSEventsSource.
func (*NATSEventsSource) DeepCopyInto ¶
func (in *NATSEventsSource) DeepCopyInto(out *NATSEventsSource)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*NATSEventsSource) Descriptor ¶ added in v0.17.0
func (*NATSEventsSource) Descriptor() ([]byte, []int)
func (*NATSEventsSource) Marshal ¶ added in v0.17.0
func (m *NATSEventsSource) Marshal() (dAtA []byte, err error)
func (*NATSEventsSource) MarshalTo ¶ added in v0.17.0
func (m *NATSEventsSource) MarshalTo(dAtA []byte) (int, error)
func (*NATSEventsSource) MarshalToSizedBuffer ¶ added in v0.17.0
func (m *NATSEventsSource) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*NATSEventsSource) ProtoMessage ¶ added in v0.17.0
func (*NATSEventsSource) ProtoMessage()
func (*NATSEventsSource) Reset ¶ added in v0.17.0
func (m *NATSEventsSource) Reset()
func (*NATSEventsSource) Size ¶ added in v0.17.0
func (m *NATSEventsSource) Size() (n int)
func (*NATSEventsSource) String ¶ added in v0.17.0
func (this *NATSEventsSource) String() string
func (*NATSEventsSource) Unmarshal ¶ added in v0.17.0
func (m *NATSEventsSource) Unmarshal(dAtA []byte) error
func (*NATSEventsSource) XXX_DiscardUnknown ¶ added in v0.17.0
func (m *NATSEventsSource) XXX_DiscardUnknown()
func (*NATSEventsSource) XXX_Marshal ¶ added in v0.17.0
func (m *NATSEventsSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*NATSEventsSource) XXX_Merge ¶ added in v0.17.0
func (m *NATSEventsSource) XXX_Merge(src proto.Message)
func (*NATSEventsSource) XXX_Size ¶ added in v0.17.0
func (m *NATSEventsSource) XXX_Size() int
func (*NATSEventsSource) XXX_Unmarshal ¶ added in v0.17.0
func (m *NATSEventsSource) XXX_Unmarshal(b []byte) error
type NSQEventSource ¶
type NSQEventSource struct { // HostAddress is the address of the host for NSQ lookup HostAddress string `json:"hostAddress" protobuf:"bytes,1,opt,name=hostAddress"` // Topic to subscribe to. Topic string `json:"topic" protobuf:"bytes,2,opt,name=topic"` // Channel used for subscription Channel string `json:"channel" protobuf:"bytes,3,opt,name=channel"` // Backoff holds parameters applied to connection. // +optional ConnectionBackoff *apicommon.Backoff `json:"connectionBackoff,omitempty" protobuf:"bytes,4,opt,name=connectionBackoff"` // JSONBody specifies that all event body payload coming from this // source will be JSON // +optional JSONBody bool `json:"jsonBody,omitempty" protobuf:"varint,5,opt,name=jsonBody"` // TLS configuration for the nsq client. // +optional TLS *apicommon.TLSConfig `json:"tls,omitempty" protobuf:"bytes,6,opt,name=tls"` // Metadata holds the user defined metadata which will passed along the event payload. // +optional Metadata map[string]string `json:"metadata,omitempty" protobuf:"bytes,7,rep,name=metadata"` // Filter // +optional Filter *EventSourceFilter `json:"filter,omitempty" protobuf:"bytes,8,opt,name=filter"` }
NSQEventSource describes the event source for NSQ PubSub More info at https://godoc.org/github.com/nsqio/go-nsq
func (*NSQEventSource) DeepCopy ¶
func (in *NSQEventSource) DeepCopy() *NSQEventSource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NSQEventSource.
func (*NSQEventSource) DeepCopyInto ¶
func (in *NSQEventSource) DeepCopyInto(out *NSQEventSource)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*NSQEventSource) Descriptor ¶ added in v0.17.0
func (*NSQEventSource) Descriptor() ([]byte, []int)
func (*NSQEventSource) Marshal ¶ added in v0.17.0
func (m *NSQEventSource) Marshal() (dAtA []byte, err error)
func (*NSQEventSource) MarshalTo ¶ added in v0.17.0
func (m *NSQEventSource) MarshalTo(dAtA []byte) (int, error)
func (*NSQEventSource) MarshalToSizedBuffer ¶ added in v0.17.0
func (m *NSQEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*NSQEventSource) ProtoMessage ¶ added in v0.17.0
func (*NSQEventSource) ProtoMessage()
func (*NSQEventSource) Reset ¶ added in v0.17.0
func (m *NSQEventSource) Reset()
func (*NSQEventSource) Size ¶ added in v0.17.0
func (m *NSQEventSource) Size() (n int)
func (*NSQEventSource) String ¶ added in v0.17.0
func (this *NSQEventSource) String() string
func (*NSQEventSource) Unmarshal ¶ added in v0.17.0
func (m *NSQEventSource) Unmarshal(dAtA []byte) error
func (*NSQEventSource) XXX_DiscardUnknown ¶ added in v0.17.0
func (m *NSQEventSource) XXX_DiscardUnknown()
func (*NSQEventSource) XXX_Marshal ¶ added in v0.17.0
func (m *NSQEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*NSQEventSource) XXX_Merge ¶ added in v0.17.0
func (m *NSQEventSource) XXX_Merge(src proto.Message)
func (*NSQEventSource) XXX_Size ¶ added in v0.17.0
func (m *NSQEventSource) XXX_Size() int
func (*NSQEventSource) XXX_Unmarshal ¶ added in v0.17.0
func (m *NSQEventSource) XXX_Unmarshal(b []byte) error
type OwnedRepositories ¶ added in v1.3.1
type OwnedRepositories struct { // Organization or user name Owner string `json:"owner,omitempty" protobuf:"bytes,1,opt,name=owner"` // Repository names Names []string `json:"names,omitempty" protobuf:"bytes,2,rep,name=names"` }
func (*OwnedRepositories) DeepCopy ¶ added in v1.3.1
func (in *OwnedRepositories) DeepCopy() *OwnedRepositories
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OwnedRepositories.
func (*OwnedRepositories) DeepCopyInto ¶ added in v1.3.1
func (in *OwnedRepositories) DeepCopyInto(out *OwnedRepositories)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*OwnedRepositories) Descriptor ¶ added in v1.3.1
func (*OwnedRepositories) Descriptor() ([]byte, []int)
func (*OwnedRepositories) Marshal ¶ added in v1.3.1
func (m *OwnedRepositories) Marshal() (dAtA []byte, err error)
func (*OwnedRepositories) MarshalTo ¶ added in v1.3.1
func (m *OwnedRepositories) MarshalTo(dAtA []byte) (int, error)
func (*OwnedRepositories) MarshalToSizedBuffer ¶ added in v1.3.1
func (m *OwnedRepositories) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*OwnedRepositories) ProtoMessage ¶ added in v1.3.1
func (*OwnedRepositories) ProtoMessage()
func (*OwnedRepositories) Reset ¶ added in v1.3.1
func (m *OwnedRepositories) Reset()
func (*OwnedRepositories) Size ¶ added in v1.3.1
func (m *OwnedRepositories) Size() (n int)
func (*OwnedRepositories) String ¶ added in v1.3.1
func (this *OwnedRepositories) String() string
func (*OwnedRepositories) Unmarshal ¶ added in v1.3.1
func (m *OwnedRepositories) Unmarshal(dAtA []byte) error
func (*OwnedRepositories) XXX_DiscardUnknown ¶ added in v1.3.1
func (m *OwnedRepositories) XXX_DiscardUnknown()
func (*OwnedRepositories) XXX_Marshal ¶ added in v1.3.1
func (m *OwnedRepositories) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*OwnedRepositories) XXX_Merge ¶ added in v1.3.1
func (m *OwnedRepositories) XXX_Merge(src proto.Message)
func (*OwnedRepositories) XXX_Size ¶ added in v1.3.1
func (m *OwnedRepositories) XXX_Size() int
func (*OwnedRepositories) XXX_Unmarshal ¶ added in v1.3.1
func (m *OwnedRepositories) XXX_Unmarshal(b []byte) error
type PubSubEventSource ¶
type PubSubEventSource struct { // ProjectID is GCP project ID for the subscription. // Required if you run Argo Events outside of GKE/GCE. // (otherwise, the default value is its project) // +optional ProjectID string `json:"projectID" protobuf:"bytes,1,opt,name=projectID"` // TopicProjectID is GCP project ID for the topic. // By default, it is same as ProjectID. // +optional TopicProjectID string `json:"topicProjectID" protobuf:"bytes,2,opt,name=topicProjectID"` // Topic to which the subscription should belongs. // Required if you want the eventsource to create a new subscription. // If you specify this field along with an existing subscription, // it will be verified whether it actually belongs to the specified topic. // +optional Topic string `json:"topic" protobuf:"bytes,3,opt,name=topic"` // SubscriptionID is ID of subscription. // Required if you use existing subscription. // The default value will be auto generated hash based on this eventsource setting, so the subscription // might be recreated every time you update the setting, which has a possibility of event loss. // +optional SubscriptionID string `json:"subscriptionID" protobuf:"bytes,4,opt,name=subscriptionID"` // CredentialSecret references to the secret that contains JSON credentials to access GCP. // If it is missing, it implicitly uses Workload Identity to access. // https://cloud.google.com/kubernetes-engine/docs/how-to/workload-identity // +optional CredentialSecret *corev1.SecretKeySelector `json:"credentialSecret,omitempty" protobuf:"bytes,5,opt,name=credentialSecret"` // DeleteSubscriptionOnFinish determines whether to delete the GCP PubSub subscription once the event source is stopped. // +optional DeleteSubscriptionOnFinish bool `json:"deleteSubscriptionOnFinish,omitempty" protobuf:"varint,6,opt,name=deleteSubscriptionOnFinish"` // JSONBody specifies that all event body payload coming from this // source will be JSON // +optional JSONBody bool `json:"jsonBody,omitempty" protobuf:"varint,7,opt,name=jsonBody"` // Metadata holds the user defined metadata which will passed along the event payload. // +optional Metadata map[string]string `json:"metadata,omitempty" protobuf:"bytes,8,rep,name=metadata"` // Filter // +optional Filter *EventSourceFilter `json:"filter,omitempty" protobuf:"bytes,9,opt,name=filter"` }
PubSubEventSource refers to event-source for GCP PubSub related events.
func (*PubSubEventSource) DeepCopy ¶
func (in *PubSubEventSource) DeepCopy() *PubSubEventSource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PubSubEventSource.
func (*PubSubEventSource) DeepCopyInto ¶
func (in *PubSubEventSource) DeepCopyInto(out *PubSubEventSource)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*PubSubEventSource) Descriptor ¶ added in v0.17.0
func (*PubSubEventSource) Descriptor() ([]byte, []int)
func (*PubSubEventSource) Marshal ¶ added in v0.17.0
func (m *PubSubEventSource) Marshal() (dAtA []byte, err error)
func (*PubSubEventSource) MarshalTo ¶ added in v0.17.0
func (m *PubSubEventSource) MarshalTo(dAtA []byte) (int, error)
func (*PubSubEventSource) MarshalToSizedBuffer ¶ added in v0.17.0
func (m *PubSubEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PubSubEventSource) ProtoMessage ¶ added in v0.17.0
func (*PubSubEventSource) ProtoMessage()
func (*PubSubEventSource) Reset ¶ added in v0.17.0
func (m *PubSubEventSource) Reset()
func (*PubSubEventSource) Size ¶ added in v0.17.0
func (m *PubSubEventSource) Size() (n int)
func (*PubSubEventSource) String ¶ added in v0.17.0
func (this *PubSubEventSource) String() string
func (*PubSubEventSource) Unmarshal ¶ added in v0.17.0
func (m *PubSubEventSource) Unmarshal(dAtA []byte) error
func (*PubSubEventSource) XXX_DiscardUnknown ¶ added in v0.17.0
func (m *PubSubEventSource) XXX_DiscardUnknown()
func (*PubSubEventSource) XXX_Marshal ¶ added in v0.17.0
func (m *PubSubEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PubSubEventSource) XXX_Merge ¶ added in v0.17.0
func (m *PubSubEventSource) XXX_Merge(src proto.Message)
func (*PubSubEventSource) XXX_Size ¶ added in v0.17.0
func (m *PubSubEventSource) XXX_Size() int
func (*PubSubEventSource) XXX_Unmarshal ¶ added in v0.17.0
func (m *PubSubEventSource) XXX_Unmarshal(b []byte) error
type PulsarEventSource ¶ added in v1.0.0
type PulsarEventSource struct { // Name of the topics to subscribe to. // +required Topics []string `json:"topics" protobuf:"bytes,1,rep,name=topics"` // Type of the subscription. // Only "exclusive" and "shared" is supported. // Defaults to exclusive. // +optional Type string `json:"type,omitempty" protobuf:"bytes,2,opt,name=type"` // Configure the service URL for the Pulsar service. // +required URL string `json:"url" protobuf:"bytes,3,name=url"` // Trusted TLS certificate secret. // +optional TLSTrustCertsSecret *corev1.SecretKeySelector `json:"tlsTrustCertsSecret,omitempty" protobuf:"bytes,4,opt,name=tlsTrustCertsSecret"` // Whether the Pulsar client accept untrusted TLS certificate from broker. // +optional TLSAllowInsecureConnection bool `json:"tlsAllowInsecureConnection,omitempty" protobuf:"bytes,5,opt,name=tlsAllowInsecureConnection"` // Whether the Pulsar client verify the validity of the host name from broker. // +optional TLSValidateHostname bool `json:"tlsValidateHostname,omitempty" protobuf:"bytes,6,opt,name=tlsValidateHostname"` // TLS configuration for the pulsar client. // +optional TLS *apicommon.TLSConfig `json:"tls,omitempty" protobuf:"bytes,7,opt,name=tls"` // Backoff holds parameters applied to connection. // +optional ConnectionBackoff *apicommon.Backoff `json:"connectionBackoff,omitempty" protobuf:"bytes,8,opt,name=connectionBackoff"` // JSONBody specifies that all event body payload coming from this // source will be JSON // +optional JSONBody bool `json:"jsonBody,omitempty" protobuf:"bytes,9,opt,name=jsonBody"` // Metadata holds the user defined metadata which will passed along the event payload. // +optional Metadata map[string]string `json:"metadata,omitempty" protobuf:"bytes,10,rep,name=metadata"` // Authentication token for the pulsar client. // Either token or athenz can be set to use auth. // +optional AuthTokenSecret *corev1.SecretKeySelector `json:"authTokenSecret,omitempty" protobuf:"bytes,11,opt,name=authTokenSecret"` // Filter // +optional Filter *EventSourceFilter `json:"filter,omitempty" protobuf:"bytes,12,opt,name=filter"` // Authentication athenz parameters for the pulsar client. // Refer https://github.com/apache/pulsar-client-go/blob/master/pulsar/auth/athenz.go // Either token or athenz can be set to use auth. // +optional AuthAthenzParams map[string]string `json:"authAthenzParams,omitempty" protobuf:"bytes,13,rep,name=authAthenzParams"` // Authentication athenz privateKey secret for the pulsar client. // AuthAthenzSecret must be set if AuthAthenzParams is used. // +optional AuthAthenzSecret *corev1.SecretKeySelector `json:"authAthenzSecret,omitempty" protobuf:"bytes,14,opt,name=authAthenzSecret"` }
PulsarEventSource describes the event source for Apache Pulsar
func (*PulsarEventSource) DeepCopy ¶ added in v1.0.0
func (in *PulsarEventSource) DeepCopy() *PulsarEventSource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PulsarEventSource.
func (*PulsarEventSource) DeepCopyInto ¶ added in v1.0.0
func (in *PulsarEventSource) DeepCopyInto(out *PulsarEventSource)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*PulsarEventSource) Descriptor ¶ added in v1.0.0
func (*PulsarEventSource) Descriptor() ([]byte, []int)
func (*PulsarEventSource) Marshal ¶ added in v1.0.0
func (m *PulsarEventSource) Marshal() (dAtA []byte, err error)
func (*PulsarEventSource) MarshalTo ¶ added in v1.0.0
func (m *PulsarEventSource) MarshalTo(dAtA []byte) (int, error)
func (*PulsarEventSource) MarshalToSizedBuffer ¶ added in v1.0.0
func (m *PulsarEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PulsarEventSource) ProtoMessage ¶ added in v1.0.0
func (*PulsarEventSource) ProtoMessage()
func (*PulsarEventSource) Reset ¶ added in v1.0.0
func (m *PulsarEventSource) Reset()
func (*PulsarEventSource) Size ¶ added in v1.0.0
func (m *PulsarEventSource) Size() (n int)
func (*PulsarEventSource) String ¶ added in v1.0.0
func (this *PulsarEventSource) String() string
func (*PulsarEventSource) Unmarshal ¶ added in v1.0.0
func (m *PulsarEventSource) Unmarshal(dAtA []byte) error
func (*PulsarEventSource) XXX_DiscardUnknown ¶ added in v1.0.0
func (m *PulsarEventSource) XXX_DiscardUnknown()
func (*PulsarEventSource) XXX_Marshal ¶ added in v1.0.0
func (m *PulsarEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PulsarEventSource) XXX_Merge ¶ added in v1.0.0
func (m *PulsarEventSource) XXX_Merge(src proto.Message)
func (*PulsarEventSource) XXX_Size ¶ added in v1.0.0
func (m *PulsarEventSource) XXX_Size() int
func (*PulsarEventSource) XXX_Unmarshal ¶ added in v1.0.0
func (m *PulsarEventSource) XXX_Unmarshal(b []byte) error
type RedisEventSource ¶
type RedisEventSource struct { // HostAddress refers to the address of the Redis host/server HostAddress string `json:"hostAddress" protobuf:"bytes,1,opt,name=hostAddress"` // Password required for authentication if any. // +optional Password *corev1.SecretKeySelector `json:"password,omitempty" protobuf:"bytes,2,opt,name=password"` // Namespace to use to retrieve the password from. It should only be specified if password is declared // +optional Namespace string `json:"namespace,omitempty" protobuf:"bytes,3,opt,name=namespace"` // DB to use. If not specified, default DB 0 will be used. // +optional DB int32 `json:"db,omitempty" protobuf:"varint,4,opt,name=db"` Channels []string `json:"channels" protobuf:"bytes,5,rep,name=channels"` // TLS configuration for the redis client. // +optional TLS *apicommon.TLSConfig `json:"tls,omitempty" protobuf:"bytes,6,opt,name=tls"` // Metadata holds the user defined metadata which will passed along the event payload. // +optional Metadata map[string]string `json:"metadata,omitempty" protobuf:"bytes,7,rep,name=metadata"` // Filter // +optional Filter *EventSourceFilter `json:"filter,omitempty" protobuf:"bytes,8,opt,name=filter"` // JSONBody specifies that all event body payload coming from this // source will be JSON // +optional JSONBody bool `json:"jsonBody,omitempty" protobuf:"varint,9,opt,name=jsonBody"` // Username required for ACL style authentication if any. // +optional Username string `json:"username,omitempty" protobuf:"bytes,10,opt,name=username"` }
RedisEventSource describes an event source for the Redis PubSub. More info at https://godoc.org/github.com/go-redis/redis#example-PubSub
func (*RedisEventSource) DeepCopy ¶
func (in *RedisEventSource) DeepCopy() *RedisEventSource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RedisEventSource.
func (*RedisEventSource) DeepCopyInto ¶
func (in *RedisEventSource) DeepCopyInto(out *RedisEventSource)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*RedisEventSource) Descriptor ¶ added in v0.17.0
func (*RedisEventSource) Descriptor() ([]byte, []int)
func (*RedisEventSource) Marshal ¶ added in v0.17.0
func (m *RedisEventSource) Marshal() (dAtA []byte, err error)
func (*RedisEventSource) MarshalTo ¶ added in v0.17.0
func (m *RedisEventSource) MarshalTo(dAtA []byte) (int, error)
func (*RedisEventSource) MarshalToSizedBuffer ¶ added in v0.17.0
func (m *RedisEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*RedisEventSource) ProtoMessage ¶ added in v0.17.0
func (*RedisEventSource) ProtoMessage()
func (*RedisEventSource) Reset ¶ added in v0.17.0
func (m *RedisEventSource) Reset()
func (*RedisEventSource) Size ¶ added in v0.17.0
func (m *RedisEventSource) Size() (n int)
func (*RedisEventSource) String ¶ added in v0.17.0
func (this *RedisEventSource) String() string
func (*RedisEventSource) Unmarshal ¶ added in v0.17.0
func (m *RedisEventSource) Unmarshal(dAtA []byte) error
func (*RedisEventSource) XXX_DiscardUnknown ¶ added in v0.17.0
func (m *RedisEventSource) XXX_DiscardUnknown()
func (*RedisEventSource) XXX_Marshal ¶ added in v0.17.0
func (m *RedisEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RedisEventSource) XXX_Merge ¶ added in v0.17.0
func (m *RedisEventSource) XXX_Merge(src proto.Message)
func (*RedisEventSource) XXX_Size ¶ added in v0.17.0
func (m *RedisEventSource) XXX_Size() int
func (*RedisEventSource) XXX_Unmarshal ¶ added in v0.17.0
func (m *RedisEventSource) XXX_Unmarshal(b []byte) error
type RedisStreamEventSource ¶ added in v1.7.0
type RedisStreamEventSource struct { // HostAddress refers to the address of the Redis host/server (master instance) HostAddress string `json:"hostAddress" protobuf:"bytes,1,opt,name=hostAddress"` // Password required for authentication if any. // +optional Password *corev1.SecretKeySelector `json:"password,omitempty" protobuf:"bytes,2,opt,name=password"` // DB to use. If not specified, default DB 0 will be used. // +optional DB int32 `json:"db,omitempty" protobuf:"varint,3,opt,name=db"` // Streams to look for entries. XREADGROUP is used on all streams using a single consumer group. Streams []string `json:"streams" protobuf:"bytes,4,rep,name=streams"` // MaxMsgCountPerRead holds the maximum number of messages per stream that will be read in each XREADGROUP of all streams // Example: if there are 2 streams and MaxMsgCountPerRead=10, then each XREADGROUP may read upto a total of 20 messages. // Same as COUNT option in XREADGROUP(https://redis.io/topics/streams-intro). Defaults to 10 // +optional MaxMsgCountPerRead int32 `json:"maxMsgCountPerRead,omitempty" protobuf:"varint,5,opt,name=maxMsgCountPerRead"` // ConsumerGroup refers to the Redis stream consumer group that will be // created on all redis streams. Messages are read through this group. Defaults to 'argo-events-cg' // +optional ConsumerGroup string `json:"consumerGroup,omitempty" protobuf:"bytes,6,opt,name=consumerGroup"` // TLS configuration for the redis client. // +optional TLS *apicommon.TLSConfig `json:"tls,omitempty" protobuf:"bytes,7,opt,name=tls"` // Metadata holds the user defined metadata which will passed along the event payload. // +optional Metadata map[string]string `json:"metadata,omitempty" protobuf:"bytes,8,rep,name=metadata"` // Filter // +optional Filter *EventSourceFilter `json:"filter,omitempty" protobuf:"bytes,9,opt,name=filter"` // Username required for ACL style authentication if any. // +optional Username string `json:"username,omitempty" protobuf:"bytes,10,opt,name=username"` }
RedisStreamEventSource describes an event source for Redis streams (https://redis.io/topics/streams-intro)
func (*RedisStreamEventSource) DeepCopy ¶ added in v1.7.0
func (in *RedisStreamEventSource) DeepCopy() *RedisStreamEventSource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new RedisStreamEventSource.
func (*RedisStreamEventSource) DeepCopyInto ¶ added in v1.7.0
func (in *RedisStreamEventSource) DeepCopyInto(out *RedisStreamEventSource)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*RedisStreamEventSource) Descriptor ¶ added in v1.7.0
func (*RedisStreamEventSource) Descriptor() ([]byte, []int)
func (*RedisStreamEventSource) Marshal ¶ added in v1.7.0
func (m *RedisStreamEventSource) Marshal() (dAtA []byte, err error)
func (*RedisStreamEventSource) MarshalTo ¶ added in v1.7.0
func (m *RedisStreamEventSource) MarshalTo(dAtA []byte) (int, error)
func (*RedisStreamEventSource) MarshalToSizedBuffer ¶ added in v1.7.0
func (m *RedisStreamEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*RedisStreamEventSource) ProtoMessage ¶ added in v1.7.0
func (*RedisStreamEventSource) ProtoMessage()
func (*RedisStreamEventSource) Reset ¶ added in v1.7.0
func (m *RedisStreamEventSource) Reset()
func (*RedisStreamEventSource) Size ¶ added in v1.7.0
func (m *RedisStreamEventSource) Size() (n int)
func (*RedisStreamEventSource) String ¶ added in v1.7.0
func (this *RedisStreamEventSource) String() string
func (*RedisStreamEventSource) Unmarshal ¶ added in v1.7.0
func (m *RedisStreamEventSource) Unmarshal(dAtA []byte) error
func (*RedisStreamEventSource) XXX_DiscardUnknown ¶ added in v1.7.0
func (m *RedisStreamEventSource) XXX_DiscardUnknown()
func (*RedisStreamEventSource) XXX_Marshal ¶ added in v1.7.0
func (m *RedisStreamEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RedisStreamEventSource) XXX_Merge ¶ added in v1.7.0
func (m *RedisStreamEventSource) XXX_Merge(src proto.Message)
func (*RedisStreamEventSource) XXX_Size ¶ added in v1.7.0
func (m *RedisStreamEventSource) XXX_Size() int
func (*RedisStreamEventSource) XXX_Unmarshal ¶ added in v1.7.0
func (m *RedisStreamEventSource) XXX_Unmarshal(b []byte) error
type ResourceEventSource ¶
type ResourceEventSource struct { // Namespace where resource is deployed Namespace string `json:"namespace" protobuf:"bytes,1,opt,name=namespace"` // Filter is applied on the metadata of the resource // If you apply filter, then the internal event informer will only monitor objects that pass the filter. // +optional Filter *ResourceFilter `json:"filter,omitempty" protobuf:"bytes,2,opt,name=filter"` // Group of the resource metav1.GroupVersionResource `json:",inline" protobuf:"bytes,3,opt,name=groupVersionResource"` // EventTypes is the list of event type to watch. // Possible values are - ADD, UPDATE and DELETE. EventTypes []ResourceEventType `json:"eventTypes" protobuf:"bytes,4,rep,name=eventTypes,casttype=ResourceEventType"` // Metadata holds the user defined metadata which will passed along the event payload. // +optional Metadata map[string]string `json:"metadata,omitempty" protobuf:"bytes,5,rep,name=metadata"` }
ResourceEventSource refers to a event-source for K8s resource related events.
func (*ResourceEventSource) DeepCopy ¶
func (in *ResourceEventSource) DeepCopy() *ResourceEventSource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ResourceEventSource.
func (*ResourceEventSource) DeepCopyInto ¶
func (in *ResourceEventSource) DeepCopyInto(out *ResourceEventSource)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ResourceEventSource) Descriptor ¶ added in v0.17.0
func (*ResourceEventSource) Descriptor() ([]byte, []int)
func (*ResourceEventSource) Marshal ¶ added in v0.17.0
func (m *ResourceEventSource) Marshal() (dAtA []byte, err error)
func (*ResourceEventSource) MarshalTo ¶ added in v0.17.0
func (m *ResourceEventSource) MarshalTo(dAtA []byte) (int, error)
func (*ResourceEventSource) MarshalToSizedBuffer ¶ added in v0.17.0
func (m *ResourceEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ResourceEventSource) ProtoMessage ¶ added in v0.17.0
func (*ResourceEventSource) ProtoMessage()
func (*ResourceEventSource) Reset ¶ added in v0.17.0
func (m *ResourceEventSource) Reset()
func (*ResourceEventSource) Size ¶ added in v0.17.0
func (m *ResourceEventSource) Size() (n int)
func (*ResourceEventSource) String ¶ added in v0.17.0
func (this *ResourceEventSource) String() string
func (*ResourceEventSource) Unmarshal ¶ added in v0.17.0
func (m *ResourceEventSource) Unmarshal(dAtA []byte) error
func (*ResourceEventSource) XXX_DiscardUnknown ¶ added in v0.17.0
func (m *ResourceEventSource) XXX_DiscardUnknown()
func (*ResourceEventSource) XXX_Marshal ¶ added in v0.17.0
func (m *ResourceEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ResourceEventSource) XXX_Merge ¶ added in v0.17.0
func (m *ResourceEventSource) XXX_Merge(src proto.Message)
func (*ResourceEventSource) XXX_Size ¶ added in v0.17.0
func (m *ResourceEventSource) XXX_Size() int
func (*ResourceEventSource) XXX_Unmarshal ¶ added in v0.17.0
func (m *ResourceEventSource) XXX_Unmarshal(b []byte) error
type ResourceEventType ¶
type ResourceEventType string
ResourceEventType is the type of event for the K8s resource mutation
const ( ADD ResourceEventType = "ADD" UPDATE ResourceEventType = "UPDATE" DELETE ResourceEventType = "DELETE" )
possible values of ResourceEventType
type ResourceFilter ¶
type ResourceFilter struct { // Prefix filter is applied on the resource name. // +optional Prefix string `json:"prefix,omitempty" protobuf:"bytes,1,opt,name=prefix"` // Labels provide listing options to K8s API to watch resource/s. // Refer https://kubernetes.io/docs/concepts/overview/working-with-objects/label-selectors/ for more info. // Unlike K8s field selector, multiple values are passed as comma separated values instead of list of values. // Eg: value: value1,value2. // Same as K8s label selector, operator "=", "==", "!=", "exists", "!", "notin", "in", "gt" and "lt" // are supported // +optional Labels []Selector `json:"labels,omitempty" protobuf:"bytes,2,rep,name=labels"` // Fields provide field filters similar to K8s field selector // (see https://kubernetes.io/docs/concepts/overview/working-with-objects/field-selectors/). // Unlike K8s field selector, it supports arbitrary fileds like "spec.serviceAccountName", // and the value could be a string or a regex. // Same as K8s field selector, operator "=", "==" and "!=" are supported. // +optional Fields []Selector `json:"fields,omitempty" protobuf:"bytes,3,rep,name=fields"` // If resource is created before the specified time then the event is treated as valid. // +optional CreatedBy metav1.Time `json:"createdBy,omitempty" protobuf:"bytes,4,opt,name=createdBy"` // If the resource is created after the start time then the event is treated as valid. // +optional AfterStart bool `json:"afterStart,omitempty" protobuf:"varint,5,opt,name=afterStart"` }
ResourceFilter contains K8s ObjectMeta information to further filter resource event objects
func (*ResourceFilter) DeepCopy ¶
func (in *ResourceFilter) DeepCopy() *ResourceFilter
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ResourceFilter.
func (*ResourceFilter) DeepCopyInto ¶
func (in *ResourceFilter) DeepCopyInto(out *ResourceFilter)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ResourceFilter) Descriptor ¶ added in v0.17.0
func (*ResourceFilter) Descriptor() ([]byte, []int)
func (*ResourceFilter) Marshal ¶ added in v0.17.0
func (m *ResourceFilter) Marshal() (dAtA []byte, err error)
func (*ResourceFilter) MarshalTo ¶ added in v0.17.0
func (m *ResourceFilter) MarshalTo(dAtA []byte) (int, error)
func (*ResourceFilter) MarshalToSizedBuffer ¶ added in v0.17.0
func (m *ResourceFilter) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ResourceFilter) ProtoMessage ¶ added in v0.17.0
func (*ResourceFilter) ProtoMessage()
func (*ResourceFilter) Reset ¶ added in v0.17.0
func (m *ResourceFilter) Reset()
func (*ResourceFilter) Size ¶ added in v0.17.0
func (m *ResourceFilter) Size() (n int)
func (*ResourceFilter) String ¶ added in v0.17.0
func (this *ResourceFilter) String() string
func (*ResourceFilter) Unmarshal ¶ added in v0.17.0
func (m *ResourceFilter) Unmarshal(dAtA []byte) error
func (*ResourceFilter) XXX_DiscardUnknown ¶ added in v0.17.0
func (m *ResourceFilter) XXX_DiscardUnknown()
func (*ResourceFilter) XXX_Marshal ¶ added in v0.17.0
func (m *ResourceFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ResourceFilter) XXX_Merge ¶ added in v0.17.0
func (m *ResourceFilter) XXX_Merge(src proto.Message)
func (*ResourceFilter) XXX_Size ¶ added in v0.17.0
func (m *ResourceFilter) XXX_Size() int
func (*ResourceFilter) XXX_Unmarshal ¶ added in v0.17.0
func (m *ResourceFilter) XXX_Unmarshal(b []byte) error
type SFTPEventSource ¶ added in v1.8.1
type SFTPEventSource struct { // Type of file operations to watch // Refer https://github.com/fsnotify/fsnotify/blob/master/fsnotify.go for more information EventType string `json:"eventType" protobuf:"bytes,1,opt,name=eventType"` // WatchPathConfig contains configuration about the file path to watch WatchPathConfig WatchPathConfig `json:"watchPathConfig" protobuf:"bytes,2,opt,name=watchPathConfig"` // Username required for authentication if any. Username *corev1.SecretKeySelector `json:"username,omitempty" protobuf:"bytes,3,opt,name=username"` // Password required for authentication if any. Password *corev1.SecretKeySelector `json:"password,omitempty" protobuf:"bytes,4,opt,name=password"` // SSHKeySecret refers to the secret that contains SSH key SSHKeySecret *corev1.SecretKeySelector `json:"sshKeySecret,omitempty" protobuf:"bytes,5,opt,name=sshKeySecret"` // Address sftp address. Address *corev1.SecretKeySelector `json:"address,omitempty" protobuf:"bytes,6,opt,name=address"` // Metadata holds the user defined metadata which will passed along the event payload. // +optional Metadata map[string]string `json:"metadata,omitempty" protobuf:"bytes,7,rep,name=metadata"` // Filter // +optional Filter *EventSourceFilter `json:"filter,omitempty" protobuf:"bytes,8,opt,name=filter"` // PollIntervalDuration the interval at which to poll the SFTP server // defaults to 10 seconds // +optional PollIntervalDuration string `json:"pollIntervalDuration" protobuf:"varint,9,opt,name=pollIntervalDuration"` }
SFTPEventSource describes an event-source for sftp related events.
func (*SFTPEventSource) DeepCopy ¶ added in v1.8.1
func (in *SFTPEventSource) DeepCopy() *SFTPEventSource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SFTPEventSource.
func (*SFTPEventSource) DeepCopyInto ¶ added in v1.8.1
func (in *SFTPEventSource) DeepCopyInto(out *SFTPEventSource)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*SFTPEventSource) Descriptor ¶ added in v1.8.1
func (*SFTPEventSource) Descriptor() ([]byte, []int)
func (*SFTPEventSource) Marshal ¶ added in v1.8.1
func (m *SFTPEventSource) Marshal() (dAtA []byte, err error)
func (*SFTPEventSource) MarshalTo ¶ added in v1.8.1
func (m *SFTPEventSource) MarshalTo(dAtA []byte) (int, error)
func (*SFTPEventSource) MarshalToSizedBuffer ¶ added in v1.8.1
func (m *SFTPEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SFTPEventSource) ProtoMessage ¶ added in v1.8.1
func (*SFTPEventSource) ProtoMessage()
func (*SFTPEventSource) Reset ¶ added in v1.8.1
func (m *SFTPEventSource) Reset()
func (*SFTPEventSource) Size ¶ added in v1.8.1
func (m *SFTPEventSource) Size() (n int)
func (*SFTPEventSource) String ¶ added in v1.8.1
func (this *SFTPEventSource) String() string
func (*SFTPEventSource) Unmarshal ¶ added in v1.8.1
func (m *SFTPEventSource) Unmarshal(dAtA []byte) error
func (*SFTPEventSource) XXX_DiscardUnknown ¶ added in v1.8.1
func (m *SFTPEventSource) XXX_DiscardUnknown()
func (*SFTPEventSource) XXX_Marshal ¶ added in v1.8.1
func (m *SFTPEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SFTPEventSource) XXX_Merge ¶ added in v1.8.1
func (m *SFTPEventSource) XXX_Merge(src proto.Message)
func (*SFTPEventSource) XXX_Size ¶ added in v1.8.1
func (m *SFTPEventSource) XXX_Size() int
func (*SFTPEventSource) XXX_Unmarshal ¶ added in v1.8.1
func (m *SFTPEventSource) XXX_Unmarshal(b []byte) error
type SNSEventSource ¶
type SNSEventSource struct { // Webhook configuration for http server Webhook *WebhookContext `json:"webhook,omitempty" protobuf:"bytes,1,opt,name=webhook"` // TopicArn TopicArn string `json:"topicArn" protobuf:"bytes,2,opt,name=topicArn"` // AccessKey refers K8s secret containing aws access key AccessKey *corev1.SecretKeySelector `json:"accessKey,omitempty" protobuf:"bytes,3,opt,name=accessKey"` // SecretKey refers K8s secret containing aws secret key SecretKey *corev1.SecretKeySelector `json:"secretKey,omitempty" protobuf:"bytes,4,opt,name=secretKey"` // Region is AWS region Region string `json:"region" protobuf:"bytes,5,opt,name=region"` // RoleARN is the Amazon Resource Name (ARN) of the role to assume. // +optional RoleARN string `json:"roleARN,omitempty" protobuf:"bytes,6,opt,name=roleARN"` // Metadata holds the user defined metadata which will passed along the event payload. // +optional Metadata map[string]string `json:"metadata,omitempty" protobuf:"bytes,7,rep,name=metadata"` // ValidateSignature is boolean that can be set to true for SNS signature verification // +optional ValidateSignature bool `json:"validateSignature,omitempty" protobuf:"varint,8,opt,name=validateSignature"` // Filter // +optional Filter *EventSourceFilter `json:"filter,omitempty" protobuf:"bytes,9,opt,name=filter"` // Endpoint configures connection to a specific SNS endpoint instead of Amazons servers // +optional Endpoint string `json:"endpoint" protobuf:"bytes,10,opt,name=endpoint"` }
SNSEventSource refers to event-source for AWS SNS related events
func (*SNSEventSource) DeepCopy ¶
func (in *SNSEventSource) DeepCopy() *SNSEventSource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SNSEventSource.
func (*SNSEventSource) DeepCopyInto ¶
func (in *SNSEventSource) DeepCopyInto(out *SNSEventSource)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*SNSEventSource) Descriptor ¶ added in v0.17.0
func (*SNSEventSource) Descriptor() ([]byte, []int)
func (*SNSEventSource) Marshal ¶ added in v0.17.0
func (m *SNSEventSource) Marshal() (dAtA []byte, err error)
func (*SNSEventSource) MarshalTo ¶ added in v0.17.0
func (m *SNSEventSource) MarshalTo(dAtA []byte) (int, error)
func (*SNSEventSource) MarshalToSizedBuffer ¶ added in v0.17.0
func (m *SNSEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SNSEventSource) ProtoMessage ¶ added in v0.17.0
func (*SNSEventSource) ProtoMessage()
func (*SNSEventSource) Reset ¶ added in v0.17.0
func (m *SNSEventSource) Reset()
func (*SNSEventSource) Size ¶ added in v0.17.0
func (m *SNSEventSource) Size() (n int)
func (*SNSEventSource) String ¶ added in v0.17.0
func (this *SNSEventSource) String() string
func (*SNSEventSource) Unmarshal ¶ added in v0.17.0
func (m *SNSEventSource) Unmarshal(dAtA []byte) error
func (*SNSEventSource) XXX_DiscardUnknown ¶ added in v0.17.0
func (m *SNSEventSource) XXX_DiscardUnknown()
func (*SNSEventSource) XXX_Marshal ¶ added in v0.17.0
func (m *SNSEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SNSEventSource) XXX_Merge ¶ added in v0.17.0
func (m *SNSEventSource) XXX_Merge(src proto.Message)
func (*SNSEventSource) XXX_Size ¶ added in v0.17.0
func (m *SNSEventSource) XXX_Size() int
func (*SNSEventSource) XXX_Unmarshal ¶ added in v0.17.0
func (m *SNSEventSource) XXX_Unmarshal(b []byte) error
type SQSEventSource ¶
type SQSEventSource struct { // AccessKey refers K8s secret containing aws access key AccessKey *corev1.SecretKeySelector `json:"accessKey,omitempty" protobuf:"bytes,1,opt,name=accessKey"` // SecretKey refers K8s secret containing aws secret key SecretKey *corev1.SecretKeySelector `json:"secretKey,omitempty" protobuf:"bytes,2,opt,name=secretKey"` // Region is AWS region Region string `json:"region" protobuf:"bytes,3,opt,name=region"` // Queue is AWS SQS queue to listen to for messages Queue string `json:"queue" protobuf:"bytes,4,opt,name=queue"` // WaitTimeSeconds is The duration (in seconds) for which the call waits for a message to arrive // in the queue before returning. WaitTimeSeconds int64 `json:"waitTimeSeconds" protobuf:"varint,5,opt,name=waitTimeSeconds"` // RoleARN is the Amazon Resource Name (ARN) of the role to assume. // +optional RoleARN string `json:"roleARN,omitempty" protobuf:"bytes,6,opt,name=roleARN"` // JSONBody specifies that all event body payload coming from this // source will be JSON // +optional JSONBody bool `json:"jsonBody,omitempty" protobuf:"varint,7,opt,name=jsonBody"` // QueueAccountID is the ID of the account that created the queue to monitor // +optional QueueAccountID string `json:"queueAccountId,omitempty" protobuf:"bytes,8,opt,name=queueAccountId"` // Metadata holds the user defined metadata which will passed along the event payload. // +optional Metadata map[string]string `json:"metadata,omitempty" protobuf:"bytes,9,rep,name=metadata"` // DLQ specifies if a dead-letter queue is configured for messages that can't be processed successfully. // If set to true, messages with invalid payload won't be acknowledged to allow to forward them farther to the dead-letter queue. // The default value is false. // +optional DLQ bool `json:"dlq,omitempty" protobuf:"varint,10,opt,name=dlq"` // Filter // +optional Filter *EventSourceFilter `json:"filter,omitempty" protobuf:"bytes,11,opt,name=filter"` // Endpoint configures connection to a specific SQS endpoint instead of Amazons servers // +optional Endpoint string `json:"endpoint" protobuf:"bytes,12,opt,name=endpoint"` // SessionToken refers to K8s secret containing AWS temporary credentials(STS) session token // +optional SessionToken *corev1.SecretKeySelector `json:"sessionToken,omitempty" protobuf:"bytes,13,opt,name=sessionToken"` }
SQSEventSource refers to event-source for AWS SQS related events
func (*SQSEventSource) DeepCopy ¶
func (in *SQSEventSource) DeepCopy() *SQSEventSource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SQSEventSource.
func (*SQSEventSource) DeepCopyInto ¶
func (in *SQSEventSource) DeepCopyInto(out *SQSEventSource)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*SQSEventSource) Descriptor ¶ added in v0.17.0
func (*SQSEventSource) Descriptor() ([]byte, []int)
func (*SQSEventSource) Marshal ¶ added in v0.17.0
func (m *SQSEventSource) Marshal() (dAtA []byte, err error)
func (*SQSEventSource) MarshalTo ¶ added in v0.17.0
func (m *SQSEventSource) MarshalTo(dAtA []byte) (int, error)
func (*SQSEventSource) MarshalToSizedBuffer ¶ added in v0.17.0
func (m *SQSEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SQSEventSource) ProtoMessage ¶ added in v0.17.0
func (*SQSEventSource) ProtoMessage()
func (*SQSEventSource) Reset ¶ added in v0.17.0
func (m *SQSEventSource) Reset()
func (*SQSEventSource) Size ¶ added in v0.17.0
func (m *SQSEventSource) Size() (n int)
func (*SQSEventSource) String ¶ added in v0.17.0
func (this *SQSEventSource) String() string
func (*SQSEventSource) Unmarshal ¶ added in v0.17.0
func (m *SQSEventSource) Unmarshal(dAtA []byte) error
func (*SQSEventSource) XXX_DiscardUnknown ¶ added in v0.17.0
func (m *SQSEventSource) XXX_DiscardUnknown()
func (*SQSEventSource) XXX_Marshal ¶ added in v0.17.0
func (m *SQSEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SQSEventSource) XXX_Merge ¶ added in v0.17.0
func (m *SQSEventSource) XXX_Merge(src proto.Message)
func (*SQSEventSource) XXX_Size ¶ added in v0.17.0
func (m *SQSEventSource) XXX_Size() int
func (*SQSEventSource) XXX_Unmarshal ¶ added in v0.17.0
func (m *SQSEventSource) XXX_Unmarshal(b []byte) error
type Selector ¶
type Selector struct { // Key name Key string `json:"key" protobuf:"bytes,1,opt,name=key"` // Supported operations like ==, != etc. // Defaults to ==. // Refer https://kubernetes.io/docs/concepts/overview/working-with-objects/labels/#label-selectors for more info. // +optional Operation string `json:"operation,omitempty" protobuf:"bytes,2,opt,name=operation"` // Value Value string `json:"value" protobuf:"bytes,3,opt,name=value"` }
Selector represents conditional operation to select K8s objects.
func (*Selector) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Selector.
func (*Selector) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Selector) Descriptor ¶ added in v0.17.0
func (*Selector) MarshalToSizedBuffer ¶ added in v0.17.0
func (*Selector) ProtoMessage ¶ added in v0.17.0
func (*Selector) ProtoMessage()
func (*Selector) XXX_DiscardUnknown ¶ added in v0.17.0
func (m *Selector) XXX_DiscardUnknown()
func (*Selector) XXX_Marshal ¶ added in v0.17.0
func (*Selector) XXX_Unmarshal ¶ added in v0.17.0
type Service ¶ added in v0.17.0
type Service struct { // The list of ports that are exposed by this ClusterIP service. // +patchMergeKey=port // +patchStrategy=merge // +listType=map // +listMapKey=port // +listMapKey=protocol Ports []corev1.ServicePort `json:"ports,omitempty" patchStrategy:"merge" patchMergeKey:"port" protobuf:"bytes,1,rep,name=ports"` // clusterIP is the IP address of the service and is usually assigned // randomly by the master. If an address is specified manually and is not in // use by others, it will be allocated to the service; otherwise, creation // of the service will fail. This field can not be changed through updates. // Valid values are "None", empty string (""), or a valid IP address. "None" // can be specified for headless services when proxying is not required. // More info: https://kubernetes.io/docs/concepts/services-networking/service/#virtual-ips-and-service-proxies // +optional ClusterIP string `json:"clusterIP,omitempty" protobuf:"bytes,2,opt,name=clusterIP"` }
Service holds the service information eventsource exposes
func (*Service) DeepCopy ¶ added in v0.17.0
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Service.
func (*Service) DeepCopyInto ¶ added in v0.17.0
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Service) Descriptor ¶ added in v0.17.0
func (*Service) MarshalToSizedBuffer ¶ added in v0.17.0
func (*Service) ProtoMessage ¶ added in v0.17.0
func (*Service) ProtoMessage()
func (*Service) XXX_DiscardUnknown ¶ added in v0.17.0
func (m *Service) XXX_DiscardUnknown()
func (*Service) XXX_Marshal ¶ added in v0.17.0
func (*Service) XXX_Unmarshal ¶ added in v0.17.0
type SlackEventSource ¶
type SlackEventSource struct { // Slack App signing secret SigningSecret *corev1.SecretKeySelector `json:"signingSecret,omitempty" protobuf:"bytes,1,opt,name=signingSecret"` // Token for URL verification handshake Token *corev1.SecretKeySelector `json:"token,omitempty" protobuf:"bytes,2,opt,name=token"` // Webhook holds configuration for a REST endpoint Webhook *WebhookContext `json:"webhook,omitempty" protobuf:"bytes,3,opt,name=webhook"` // Metadata holds the user defined metadata which will passed along the event payload. // +optional Metadata map[string]string `json:"metadata,omitempty" protobuf:"bytes,4,rep,name=metadata"` // Filter // +optional Filter *EventSourceFilter `json:"filter,omitempty" protobuf:"bytes,5,opt,name=filter"` }
SlackEventSource refers to event-source for Slack related events
func (*SlackEventSource) DeepCopy ¶
func (in *SlackEventSource) DeepCopy() *SlackEventSource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SlackEventSource.
func (*SlackEventSource) DeepCopyInto ¶
func (in *SlackEventSource) DeepCopyInto(out *SlackEventSource)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*SlackEventSource) Descriptor ¶ added in v0.17.0
func (*SlackEventSource) Descriptor() ([]byte, []int)
func (*SlackEventSource) Marshal ¶ added in v0.17.0
func (m *SlackEventSource) Marshal() (dAtA []byte, err error)
func (*SlackEventSource) MarshalTo ¶ added in v0.17.0
func (m *SlackEventSource) MarshalTo(dAtA []byte) (int, error)
func (*SlackEventSource) MarshalToSizedBuffer ¶ added in v0.17.0
func (m *SlackEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SlackEventSource) ProtoMessage ¶ added in v0.17.0
func (*SlackEventSource) ProtoMessage()
func (*SlackEventSource) Reset ¶ added in v0.17.0
func (m *SlackEventSource) Reset()
func (*SlackEventSource) Size ¶ added in v0.17.0
func (m *SlackEventSource) Size() (n int)
func (*SlackEventSource) String ¶ added in v0.17.0
func (this *SlackEventSource) String() string
func (*SlackEventSource) Unmarshal ¶ added in v0.17.0
func (m *SlackEventSource) Unmarshal(dAtA []byte) error
func (*SlackEventSource) XXX_DiscardUnknown ¶ added in v0.17.0
func (m *SlackEventSource) XXX_DiscardUnknown()
func (*SlackEventSource) XXX_Marshal ¶ added in v0.17.0
func (m *SlackEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SlackEventSource) XXX_Merge ¶ added in v0.17.0
func (m *SlackEventSource) XXX_Merge(src proto.Message)
func (*SlackEventSource) XXX_Size ¶ added in v0.17.0
func (m *SlackEventSource) XXX_Size() int
func (*SlackEventSource) XXX_Unmarshal ¶ added in v0.17.0
func (m *SlackEventSource) XXX_Unmarshal(b []byte) error
type StorageGridEventSource ¶
type StorageGridEventSource struct { // Webhook holds configuration for a REST endpoint Webhook *WebhookContext `json:"webhook,omitempty" protobuf:"bytes,1,opt,name=webhook"` Events []string `json:"events,omitempty" protobuf:"bytes,2,rep,name=events"` // Filter on object key which caused the notification. Filter *StorageGridFilter `json:"filter,omitempty" protobuf:"bytes,3,opt,name=filter"` // TopicArn TopicArn string `json:"topicArn" protobuf:"bytes,4,name=topicArn"` // Name of the bucket to register notifications for. Bucket string `json:"bucket" protobuf:"bytes,5,name=bucket"` // S3 region. // Defaults to us-east-1 // +optional Region string `json:"region,omitempty" protobuf:"bytes,6,opt,name=region"` // Auth token for storagegrid api AuthToken *corev1.SecretKeySelector `json:"authToken" protobuf:"bytes,7,name=authToken"` // APIURL is the url of the storagegrid api. APIURL string `json:"apiURL" protobuf:"bytes,8,name=apiURL"` // Metadata holds the user defined metadata which will passed along the event payload. // +optional Metadata map[string]string `json:"metadata,omitempty" protobuf:"bytes,9,rep,name=metadata"` }
StorageGridEventSource refers to event-source for StorageGrid related events
func (*StorageGridEventSource) DeepCopy ¶
func (in *StorageGridEventSource) DeepCopy() *StorageGridEventSource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StorageGridEventSource.
func (*StorageGridEventSource) DeepCopyInto ¶
func (in *StorageGridEventSource) DeepCopyInto(out *StorageGridEventSource)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*StorageGridEventSource) Descriptor ¶ added in v0.17.0
func (*StorageGridEventSource) Descriptor() ([]byte, []int)
func (*StorageGridEventSource) Marshal ¶ added in v0.17.0
func (m *StorageGridEventSource) Marshal() (dAtA []byte, err error)
func (*StorageGridEventSource) MarshalTo ¶ added in v0.17.0
func (m *StorageGridEventSource) MarshalTo(dAtA []byte) (int, error)
func (*StorageGridEventSource) MarshalToSizedBuffer ¶ added in v0.17.0
func (m *StorageGridEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*StorageGridEventSource) ProtoMessage ¶ added in v0.17.0
func (*StorageGridEventSource) ProtoMessage()
func (*StorageGridEventSource) Reset ¶ added in v0.17.0
func (m *StorageGridEventSource) Reset()
func (*StorageGridEventSource) Size ¶ added in v0.17.0
func (m *StorageGridEventSource) Size() (n int)
func (*StorageGridEventSource) String ¶ added in v0.17.0
func (this *StorageGridEventSource) String() string
func (*StorageGridEventSource) Unmarshal ¶ added in v0.17.0
func (m *StorageGridEventSource) Unmarshal(dAtA []byte) error
func (*StorageGridEventSource) XXX_DiscardUnknown ¶ added in v0.17.0
func (m *StorageGridEventSource) XXX_DiscardUnknown()
func (*StorageGridEventSource) XXX_Marshal ¶ added in v0.17.0
func (m *StorageGridEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StorageGridEventSource) XXX_Merge ¶ added in v0.17.0
func (m *StorageGridEventSource) XXX_Merge(src proto.Message)
func (*StorageGridEventSource) XXX_Size ¶ added in v0.17.0
func (m *StorageGridEventSource) XXX_Size() int
func (*StorageGridEventSource) XXX_Unmarshal ¶ added in v0.17.0
func (m *StorageGridEventSource) XXX_Unmarshal(b []byte) error
type StorageGridFilter ¶
type StorageGridFilter struct { Prefix string `json:"prefix" protobuf:"bytes,1,opt,name=prefix"` Suffix string `json:"suffix" protobuf:"bytes,2,opt,name=suffix"` }
StorageGridFilter represents filters to apply to bucket notifications for specifying constraints on objects +k8s:openapi-gen=true
func (*StorageGridFilter) DeepCopy ¶
func (in *StorageGridFilter) DeepCopy() *StorageGridFilter
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StorageGridFilter.
func (*StorageGridFilter) DeepCopyInto ¶
func (in *StorageGridFilter) DeepCopyInto(out *StorageGridFilter)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*StorageGridFilter) Descriptor ¶ added in v0.17.0
func (*StorageGridFilter) Descriptor() ([]byte, []int)
func (*StorageGridFilter) Marshal ¶ added in v0.17.0
func (m *StorageGridFilter) Marshal() (dAtA []byte, err error)
func (*StorageGridFilter) MarshalTo ¶ added in v0.17.0
func (m *StorageGridFilter) MarshalTo(dAtA []byte) (int, error)
func (*StorageGridFilter) MarshalToSizedBuffer ¶ added in v0.17.0
func (m *StorageGridFilter) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*StorageGridFilter) ProtoMessage ¶ added in v0.17.0
func (*StorageGridFilter) ProtoMessage()
func (*StorageGridFilter) Reset ¶ added in v0.17.0
func (m *StorageGridFilter) Reset()
func (*StorageGridFilter) Size ¶ added in v0.17.0
func (m *StorageGridFilter) Size() (n int)
func (*StorageGridFilter) String ¶ added in v0.17.0
func (this *StorageGridFilter) String() string
func (*StorageGridFilter) Unmarshal ¶ added in v0.17.0
func (m *StorageGridFilter) Unmarshal(dAtA []byte) error
func (*StorageGridFilter) XXX_DiscardUnknown ¶ added in v0.17.0
func (m *StorageGridFilter) XXX_DiscardUnknown()
func (*StorageGridFilter) XXX_Marshal ¶ added in v0.17.0
func (m *StorageGridFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StorageGridFilter) XXX_Merge ¶ added in v0.17.0
func (m *StorageGridFilter) XXX_Merge(src proto.Message)
func (*StorageGridFilter) XXX_Size ¶ added in v0.17.0
func (m *StorageGridFilter) XXX_Size() int
func (*StorageGridFilter) XXX_Unmarshal ¶ added in v0.17.0
func (m *StorageGridFilter) XXX_Unmarshal(b []byte) error
type StripeEventSource ¶
type StripeEventSource struct { // Webhook holds configuration for a REST endpoint Webhook *WebhookContext `json:"webhook,omitempty" protobuf:"bytes,1,opt,name=webhook"` // CreateWebhook if specified creates a new webhook programmatically. // +optional CreateWebhook bool `json:"createWebhook,omitempty" protobuf:"varint,2,opt,name=createWebhook"` // APIKey refers to K8s secret that holds Stripe API key. Used only if CreateWebhook is enabled. // +optional APIKey *corev1.SecretKeySelector `json:"apiKey,omitempty" protobuf:"bytes,3,opt,name=apiKey"` // EventFilter describes the type of events to listen to. If not specified, all types of events will be processed. // More info at https://stripe.com/docs/api/events/list // +optional EventFilter []string `json:"eventFilter,omitempty" protobuf:"bytes,4,rep,name=eventFilter"` // Metadata holds the user defined metadata which will passed along the event payload. // +optional Metadata map[string]string `json:"metadata,omitempty" protobuf:"bytes,5,rep,name=metadata"` }
StripeEventSource describes the event source for stripe webhook notifications More info at https://stripe.com/docs/webhooks
func (*StripeEventSource) DeepCopy ¶
func (in *StripeEventSource) DeepCopy() *StripeEventSource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StripeEventSource.
func (*StripeEventSource) DeepCopyInto ¶
func (in *StripeEventSource) DeepCopyInto(out *StripeEventSource)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*StripeEventSource) Descriptor ¶ added in v0.17.0
func (*StripeEventSource) Descriptor() ([]byte, []int)
func (*StripeEventSource) Marshal ¶ added in v0.17.0
func (m *StripeEventSource) Marshal() (dAtA []byte, err error)
func (*StripeEventSource) MarshalTo ¶ added in v0.17.0
func (m *StripeEventSource) MarshalTo(dAtA []byte) (int, error)
func (*StripeEventSource) MarshalToSizedBuffer ¶ added in v0.17.0
func (m *StripeEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*StripeEventSource) ProtoMessage ¶ added in v0.17.0
func (*StripeEventSource) ProtoMessage()
func (*StripeEventSource) Reset ¶ added in v0.17.0
func (m *StripeEventSource) Reset()
func (*StripeEventSource) Size ¶ added in v0.17.0
func (m *StripeEventSource) Size() (n int)
func (*StripeEventSource) String ¶ added in v0.17.0
func (this *StripeEventSource) String() string
func (*StripeEventSource) Unmarshal ¶ added in v0.17.0
func (m *StripeEventSource) Unmarshal(dAtA []byte) error
func (*StripeEventSource) XXX_DiscardUnknown ¶ added in v0.17.0
func (m *StripeEventSource) XXX_DiscardUnknown()
func (*StripeEventSource) XXX_Marshal ¶ added in v0.17.0
func (m *StripeEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StripeEventSource) XXX_Merge ¶ added in v0.17.0
func (m *StripeEventSource) XXX_Merge(src proto.Message)
func (*StripeEventSource) XXX_Size ¶ added in v0.17.0
func (m *StripeEventSource) XXX_Size() int
func (*StripeEventSource) XXX_Unmarshal ¶ added in v0.17.0
func (m *StripeEventSource) XXX_Unmarshal(b []byte) error
type Template ¶ added in v0.17.0
type Template struct { // Metadata sets the pods's metadata, i.e. annotations and labels Metadata *apicommon.Metadata `json:"metadata,omitempty" protobuf:"bytes,1,opt,name=metadata"` // ServiceAccountName is the name of the ServiceAccount to use to run event source pod. // More info: https://kubernetes.io/docs/tasks/configure-pod-container/configure-service-account/ // +optional ServiceAccountName string `json:"serviceAccountName,omitempty" protobuf:"bytes,2,opt,name=serviceAccountName"` // Container is the main container image to run in the event source pod // +optional Container *corev1.Container `json:"container,omitempty" protobuf:"bytes,3,opt,name=container"` // Volumes is a list of volumes that can be mounted by containers in an eventsource. // +patchStrategy=merge // +patchMergeKey=name // +optional Volumes []corev1.Volume `json:"volumes,omitempty" patchStrategy:"merge" patchMergeKey:"name" protobuf:"bytes,4,rep,name=volumes"` // SecurityContext holds pod-level security attributes and common container settings. // Optional: Defaults to empty. See type description for default values of each field. // +optional SecurityContext *corev1.PodSecurityContext `json:"securityContext,omitempty" protobuf:"bytes,5,opt,name=securityContext"` // If specified, the pod's scheduling constraints // +optional Affinity *corev1.Affinity `json:"affinity,omitempty" protobuf:"bytes,6,opt,name=affinity"` // If specified, the pod's tolerations. // +optional Tolerations []corev1.Toleration `json:"tolerations,omitempty" protobuf:"bytes,7,rep,name=tolerations"` // NodeSelector is a selector which must be true for the pod to fit on a node. // Selector which must match a node's labels for the pod to be scheduled on that node. // More info: https://kubernetes.io/docs/concepts/configuration/assign-pod-node/ // +optional NodeSelector map[string]string `json:"nodeSelector,omitempty" protobuf:"bytes,8,rep,name=nodeSelector"` // ImagePullSecrets is an optional list of references to secrets in the same namespace to use for pulling any of the images used by this PodSpec. // If specified, these secrets will be passed to individual puller implementations for them to use. For example, // in the case of docker, only DockerConfig type secrets are honored. // More info: https://kubernetes.io/docs/concepts/containers/images#specifying-imagepullsecrets-on-a-pod // +optional // +patchMergeKey=name // +patchStrategy=merge ImagePullSecrets []corev1.LocalObjectReference `json:"imagePullSecrets,omitempty" patchStrategy:"merge" patchMergeKey:"name" protobuf:"bytes,9,rep,name=imagePullSecrets"` // If specified, indicates the EventSource pod's priority. "system-node-critical" // and "system-cluster-critical" are two special keywords which indicate the // highest priorities with the former being the highest priority. Any other // name must be defined by creating a PriorityClass object with that name. // If not specified, the pod priority will be default or zero if there is no // default. // More info: https://kubernetes.io/docs/concepts/configuration/pod-priority-preemption/ // +optional PriorityClassName string `json:"priorityClassName,omitempty" protobuf:"bytes,10,opt,name=priorityClassName"` // The priority value. Various system components use this field to find the // priority of the EventSource pod. When Priority Admission Controller is enabled, // it prevents users from setting this field. The admission controller populates // this field from PriorityClassName. // The higher the value, the higher the priority. // More info: https://kubernetes.io/docs/concepts/configuration/pod-priority-preemption/ // +optional Priority *int32 `json:"priority,omitempty" protobuf:"bytes,11,opt,name=priority"` }
Template holds the information of an EventSource deployment template
func (*Template) DeepCopy ¶ added in v0.17.0
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Template.
func (*Template) DeepCopyInto ¶ added in v0.17.0
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Template) Descriptor ¶ added in v0.17.0
func (*Template) MarshalToSizedBuffer ¶ added in v0.17.0
func (*Template) ProtoMessage ¶ added in v0.17.0
func (*Template) ProtoMessage()
func (*Template) XXX_DiscardUnknown ¶ added in v0.17.0
func (m *Template) XXX_DiscardUnknown()
func (*Template) XXX_Marshal ¶ added in v0.17.0
func (*Template) XXX_Unmarshal ¶ added in v0.17.0
type WatchPathConfig ¶ added in v0.17.0
type WatchPathConfig struct { // Directory to watch for events Directory string `json:"directory" protobuf:"bytes,1,opt,name=directory"` // Path is relative path of object to watch with respect to the directory Path string `json:"path,omitempty" protobuf:"bytes,2,opt,name=path"` // PathRegexp is regexp of relative path of object to watch with respect to the directory PathRegexp string `json:"pathRegexp,omitempty" protobuf:"bytes,3,opt,name=pathRegexp"` }
func (*WatchPathConfig) DeepCopy ¶ added in v0.17.0
func (in *WatchPathConfig) DeepCopy() *WatchPathConfig
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WatchPathConfig.
func (*WatchPathConfig) DeepCopyInto ¶ added in v0.17.0
func (in *WatchPathConfig) DeepCopyInto(out *WatchPathConfig)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*WatchPathConfig) Descriptor ¶ added in v0.17.0
func (*WatchPathConfig) Descriptor() ([]byte, []int)
func (*WatchPathConfig) Marshal ¶ added in v0.17.0
func (m *WatchPathConfig) Marshal() (dAtA []byte, err error)
func (*WatchPathConfig) MarshalTo ¶ added in v0.17.0
func (m *WatchPathConfig) MarshalTo(dAtA []byte) (int, error)
func (*WatchPathConfig) MarshalToSizedBuffer ¶ added in v0.17.0
func (m *WatchPathConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*WatchPathConfig) ProtoMessage ¶ added in v0.17.0
func (*WatchPathConfig) ProtoMessage()
func (*WatchPathConfig) Reset ¶ added in v0.17.0
func (m *WatchPathConfig) Reset()
func (*WatchPathConfig) Size ¶ added in v0.17.0
func (m *WatchPathConfig) Size() (n int)
func (*WatchPathConfig) String ¶ added in v0.17.0
func (this *WatchPathConfig) String() string
func (*WatchPathConfig) Unmarshal ¶ added in v0.17.0
func (m *WatchPathConfig) Unmarshal(dAtA []byte) error
func (*WatchPathConfig) Validate ¶ added in v0.17.0
func (c *WatchPathConfig) Validate() error
Validate validates WatchPathConfig
func (*WatchPathConfig) XXX_DiscardUnknown ¶ added in v0.17.0
func (m *WatchPathConfig) XXX_DiscardUnknown()
func (*WatchPathConfig) XXX_Marshal ¶ added in v0.17.0
func (m *WatchPathConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*WatchPathConfig) XXX_Merge ¶ added in v0.17.0
func (m *WatchPathConfig) XXX_Merge(src proto.Message)
func (*WatchPathConfig) XXX_Size ¶ added in v0.17.0
func (m *WatchPathConfig) XXX_Size() int
func (*WatchPathConfig) XXX_Unmarshal ¶ added in v0.17.0
func (m *WatchPathConfig) XXX_Unmarshal(b []byte) error
type WebhookContext ¶ added in v0.17.0
type WebhookContext struct { // REST API endpoint Endpoint string `json:"endpoint" protobuf:"bytes,1,opt,name=endpoint"` // Method is HTTP request method that indicates the desired action to be performed for a given resource. // See RFC7231 Hypertext Transfer Protocol (HTTP/1.1): Semantics and Content Method string `json:"method" protobuf:"bytes,2,opt,name=method"` // Port on which HTTP server is listening for incoming events. Port string `json:"port" protobuf:"bytes,3,opt,name=port"` // URL is the url of the server. URL string `json:"url" protobuf:"bytes,4,opt,name=url"` // ServerCertPath refers the file that contains the cert. ServerCertSecret *corev1.SecretKeySelector `json:"serverCertSecret,omitempty" protobuf:"bytes,5,opt,name=serverCertSecret"` // ServerKeyPath refers the file that contains private key ServerKeySecret *corev1.SecretKeySelector `json:"serverKeySecret,omitempty" protobuf:"bytes,6,opt,name=serverKeySecret"` // Metadata holds the user defined metadata which will passed along the event payload. // +optional Metadata map[string]string `json:"metadata,omitempty" protobuf:"bytes,7,rep,name=metadata"` // AuthSecret holds a secret selector that contains a bearer token for authentication // +optional AuthSecret *corev1.SecretKeySelector `json:"authSecret,omitempty" protobuf:"bytes,8,opt,name=authSecret"` // MaxPayloadSize is the maximum webhook payload size that the server will accept. // Requests exceeding that limit will be rejected with "request too large" response. // Default value: 1048576 (1MB). // +optional MaxPayloadSize *int64 `json:"maxPayloadSize,omitempty" protobuf:"bytes,9,opt,name=maxPayloadSize"` }
WebhookContext holds a general purpose REST API context
func (*WebhookContext) DeepCopy ¶ added in v0.17.0
func (in *WebhookContext) DeepCopy() *WebhookContext
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WebhookContext.
func (*WebhookContext) DeepCopyInto ¶ added in v0.17.0
func (in *WebhookContext) DeepCopyInto(out *WebhookContext)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*WebhookContext) Descriptor ¶ added in v0.17.0
func (*WebhookContext) Descriptor() ([]byte, []int)
func (*WebhookContext) GetMaxPayloadSize ¶ added in v1.7.2
func (wc *WebhookContext) GetMaxPayloadSize() int64
func (*WebhookContext) Marshal ¶ added in v0.17.0
func (m *WebhookContext) Marshal() (dAtA []byte, err error)
func (*WebhookContext) MarshalTo ¶ added in v0.17.0
func (m *WebhookContext) MarshalTo(dAtA []byte) (int, error)
func (*WebhookContext) MarshalToSizedBuffer ¶ added in v0.17.0
func (m *WebhookContext) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*WebhookContext) ProtoMessage ¶ added in v0.17.0
func (*WebhookContext) ProtoMessage()
func (*WebhookContext) Reset ¶ added in v0.17.0
func (m *WebhookContext) Reset()
func (*WebhookContext) Size ¶ added in v0.17.0
func (m *WebhookContext) Size() (n int)
func (*WebhookContext) String ¶ added in v0.17.0
func (this *WebhookContext) String() string
func (*WebhookContext) Unmarshal ¶ added in v0.17.0
func (m *WebhookContext) Unmarshal(dAtA []byte) error
func (*WebhookContext) XXX_DiscardUnknown ¶ added in v0.17.0
func (m *WebhookContext) XXX_DiscardUnknown()
func (*WebhookContext) XXX_Marshal ¶ added in v0.17.0
func (m *WebhookContext) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*WebhookContext) XXX_Merge ¶ added in v0.17.0
func (m *WebhookContext) XXX_Merge(src proto.Message)
func (*WebhookContext) XXX_Size ¶ added in v0.17.0
func (m *WebhookContext) XXX_Size() int
func (*WebhookContext) XXX_Unmarshal ¶ added in v0.17.0
func (m *WebhookContext) XXX_Unmarshal(b []byte) error
type WebhookEventSource ¶ added in v1.7.2
type WebhookEventSource struct { WebhookContext `json:",inline" protobuf:"bytes,1,opt,name=webhookContext"` // Filter // +optional Filter *EventSourceFilter `json:"filter,omitempty" protobuf:"bytes,2,opt,name=filter"` }
CalendarEventSource describes an HTTP based EventSource
func (*WebhookEventSource) DeepCopy ¶ added in v1.7.2
func (in *WebhookEventSource) DeepCopy() *WebhookEventSource
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new WebhookEventSource.
func (*WebhookEventSource) DeepCopyInto ¶ added in v1.7.2
func (in *WebhookEventSource) DeepCopyInto(out *WebhookEventSource)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*WebhookEventSource) Descriptor ¶ added in v1.7.2
func (*WebhookEventSource) Descriptor() ([]byte, []int)
func (*WebhookEventSource) Marshal ¶ added in v1.7.2
func (m *WebhookEventSource) Marshal() (dAtA []byte, err error)
func (*WebhookEventSource) MarshalTo ¶ added in v1.7.2
func (m *WebhookEventSource) MarshalTo(dAtA []byte) (int, error)
func (*WebhookEventSource) MarshalToSizedBuffer ¶ added in v1.7.2
func (m *WebhookEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*WebhookEventSource) ProtoMessage ¶ added in v1.7.2
func (*WebhookEventSource) ProtoMessage()
func (*WebhookEventSource) Reset ¶ added in v1.7.2
func (m *WebhookEventSource) Reset()
func (*WebhookEventSource) Size ¶ added in v1.7.2
func (m *WebhookEventSource) Size() (n int)
func (*WebhookEventSource) String ¶ added in v1.7.2
func (this *WebhookEventSource) String() string
func (*WebhookEventSource) Unmarshal ¶ added in v1.7.2
func (m *WebhookEventSource) Unmarshal(dAtA []byte) error
func (*WebhookEventSource) XXX_DiscardUnknown ¶ added in v1.7.2
func (m *WebhookEventSource) XXX_DiscardUnknown()
func (*WebhookEventSource) XXX_Marshal ¶ added in v1.7.2
func (m *WebhookEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*WebhookEventSource) XXX_Merge ¶ added in v1.7.2
func (m *WebhookEventSource) XXX_Merge(src proto.Message)
func (*WebhookEventSource) XXX_Size ¶ added in v1.7.2
func (m *WebhookEventSource) XXX_Size() int
func (*WebhookEventSource) XXX_Unmarshal ¶ added in v1.7.2
func (m *WebhookEventSource) XXX_Unmarshal(b []byte) error