v1alpha1

Feb 13, 2024

Changes in this version

type AzureQueueStorageEventSource

+ WaitTimeInSeconds *int32

Jan 9, 2024

Changes in this version

type EventSourceSpec

+ Gerrit map[string]GerritEventSource

+ type GerritEventSource struct

+ Auth *apicommon.BasicAuth

+ DeleteHookOnFinish bool

+ Events []string

+ Filter *EventSourceFilter

+ GerritBaseURL string

+ HookName string

+ Metadata map[string]string

+ Projects []string

+ SslVerify bool

+ Webhook *WebhookContext

+ func (*GerritEventSource) Descriptor() ([]byte, []int)

+ func (*GerritEventSource) ProtoMessage()

+ func (g GerritEventSource) NeedToCreateHooks() bool

+ func (in *GerritEventSource) DeepCopy() *GerritEventSource

+ func (in *GerritEventSource) DeepCopyInto(out *GerritEventSource)

+ func (m *GerritEventSource) Marshal() (dAtA []byte, err error)

+ func (m *GerritEventSource) MarshalTo(dAtA []byte) (int, error)

+ func (m *GerritEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *GerritEventSource) Reset()

+ func (m *GerritEventSource) Size() (n int)

+ func (m *GerritEventSource) Unmarshal(dAtA []byte) error

+ func (m *GerritEventSource) XXX_DiscardUnknown()

+ func (m *GerritEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GerritEventSource) XXX_Merge(src proto.Message)

+ func (m *GerritEventSource) XXX_Size() int

+ func (m *GerritEventSource) XXX_Unmarshal(b []byte) error

+ func (this *GerritEventSource) String() string

type SFTPEventSource

+ SSHKeySecret *corev1.SecretKeySelector

Aug 31, 2023

Changes in this version

type AzureQueueStorageEventSource

+ DecodeMessage bool

type BitbucketServerEventSource

+ TLS *apicommon.TLSConfig

type EventSourceSpec

+ SFTP map[string]SFTPEventSource

+ type SFTPEventSource struct

+ Address *corev1.SecretKeySelector

+ EventType string

+ Filter *EventSourceFilter

+ Metadata map[string]string

+ Password *corev1.SecretKeySelector

+ PollIntervalDuration string

+ Username *corev1.SecretKeySelector

+ WatchPathConfig WatchPathConfig

+ func (*SFTPEventSource) Descriptor() ([]byte, []int)

+ func (*SFTPEventSource) ProtoMessage()

+ func (in *SFTPEventSource) DeepCopy() *SFTPEventSource

+ func (in *SFTPEventSource) DeepCopyInto(out *SFTPEventSource)

+ func (m *SFTPEventSource) Marshal() (dAtA []byte, err error)

+ func (m *SFTPEventSource) MarshalTo(dAtA []byte) (int, error)

+ func (m *SFTPEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *SFTPEventSource) Reset()

+ func (m *SFTPEventSource) Size() (n int)

+ func (m *SFTPEventSource) Unmarshal(dAtA []byte) error

+ func (m *SFTPEventSource) XXX_DiscardUnknown()

+ func (m *SFTPEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *SFTPEventSource) XXX_Merge(src proto.Message)

+ func (m *SFTPEventSource) XXX_Size() int

+ func (m *SFTPEventSource) XXX_Unmarshal(b []byte) error

+ func (this *SFTPEventSource) String() string

May 8, 2023

Changes in this version

+ type AzureQueueStorageEventSource struct

+ ConnectionString *corev1.SecretKeySelector

+ DLQ bool

+ Filter *EventSourceFilter

+ JSONBody bool

+ Metadata map[string]string

+ QueueName string

+ StorageAccountName string

+ func (*AzureQueueStorageEventSource) Descriptor() ([]byte, []int)

+ func (*AzureQueueStorageEventSource) ProtoMessage()

+ func (in *AzureQueueStorageEventSource) DeepCopy() *AzureQueueStorageEventSource

+ func (in *AzureQueueStorageEventSource) DeepCopyInto(out *AzureQueueStorageEventSource)

+ func (m *AzureQueueStorageEventSource) Marshal() (dAtA []byte, err error)

+ func (m *AzureQueueStorageEventSource) MarshalTo(dAtA []byte) (int, error)

+ func (m *AzureQueueStorageEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *AzureQueueStorageEventSource) Reset()

+ func (m *AzureQueueStorageEventSource) Size() (n int)

+ func (m *AzureQueueStorageEventSource) Unmarshal(dAtA []byte) error

+ func (m *AzureQueueStorageEventSource) XXX_DiscardUnknown()

+ func (m *AzureQueueStorageEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *AzureQueueStorageEventSource) XXX_Merge(src proto.Message)

+ func (m *AzureQueueStorageEventSource) XXX_Size() int

+ func (m *AzureQueueStorageEventSource) XXX_Unmarshal(b []byte) error

+ func (this *AzureQueueStorageEventSource) String() string

type AzureServiceBusEventSource

+ FullyQualifiedNamespace string

type EventSourceSpec

+ AzureQueueStorage map[string]AzureQueueStorageEventSource

type GitlabEventSource

+ Groups []string

+ func (g GitlabEventSource) GetGroups() []string

type PulsarEventSource

+ AuthAthenzParams map[string]string

+ AuthAthenzSecret *corev1.SecretKeySelector

Dec 12, 2022

Changes in this version

+ type AzureServiceBusEventSource struct

+ ConnectionString *corev1.SecretKeySelector

+ Filter *EventSourceFilter

+ JSONBody bool

+ Metadata map[string]string

+ QueueName string

+ SubscriptionName string

+ TLS *apicommon.TLSConfig

+ TopicName string

+ func (*AzureServiceBusEventSource) Descriptor() ([]byte, []int)

+ func (*AzureServiceBusEventSource) ProtoMessage()

+ func (in *AzureServiceBusEventSource) DeepCopy() *AzureServiceBusEventSource

+ func (in *AzureServiceBusEventSource) DeepCopyInto(out *AzureServiceBusEventSource)

+ func (m *AzureServiceBusEventSource) Marshal() (dAtA []byte, err error)

+ func (m *AzureServiceBusEventSource) MarshalTo(dAtA []byte) (int, error)

+ func (m *AzureServiceBusEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *AzureServiceBusEventSource) Reset()

+ func (m *AzureServiceBusEventSource) Size() (n int)

+ func (m *AzureServiceBusEventSource) Unmarshal(dAtA []byte) error

+ func (m *AzureServiceBusEventSource) XXX_DiscardUnknown()

+ func (m *AzureServiceBusEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *AzureServiceBusEventSource) XXX_Merge(src proto.Message)

+ func (m *AzureServiceBusEventSource) XXX_Size() int

+ func (m *AzureServiceBusEventSource) XXX_Unmarshal(b []byte) error

+ func (this *AzureServiceBusEventSource) String() string

type EventSourceSpec

+ AzureServiceBus map[string]AzureServiceBusEventSource

type MQTTEventSource

+ Auth *apicommon.BasicAuth

Sep 12, 2022

Changes in this version

+ const DefaultMaxWebhookPayloadSize

type BitbucketEventSource

+ DeprecatedOwner string

+ DeprecatedProjectKey string

+ DeprecatedRepositorySlug string

+ Repositories []BitbucketRepository

+ func (b BitbucketEventSource) GetBitbucketRepositories() []BitbucketRepository

+ func (b BitbucketEventSource) ShouldCreateWebhooks() bool

+ type BitbucketRepository struct

+ Owner string

+ RepositorySlug string

+ func (*BitbucketRepository) Descriptor() ([]byte, []int)

+ func (*BitbucketRepository) ProtoMessage()

+ func (in *BitbucketRepository) DeepCopy() *BitbucketRepository

+ func (in *BitbucketRepository) DeepCopyInto(out *BitbucketRepository)

+ func (m *BitbucketRepository) Marshal() (dAtA []byte, err error)

+ func (m *BitbucketRepository) MarshalTo(dAtA []byte) (int, error)

+ func (m *BitbucketRepository) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *BitbucketRepository) Reset()

+ func (m *BitbucketRepository) Size() (n int)

+ func (m *BitbucketRepository) Unmarshal(dAtA []byte) error

+ func (m *BitbucketRepository) XXX_DiscardUnknown()

+ func (m *BitbucketRepository) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *BitbucketRepository) XXX_Merge(src proto.Message)

+ func (m *BitbucketRepository) XXX_Size() int

+ func (m *BitbucketRepository) XXX_Unmarshal(b []byte) error

+ func (r BitbucketRepository) GetRepositoryID() string

+ func (this *BitbucketRepository) String() string

type KafkaEventSource

+ Config string

type SNSEventSource

+ Endpoint string

type SQSEventSource

+ SessionToken *corev1.SecretKeySelector

type WebhookContext

+ MaxPayloadSize *int64

+ func (wc *WebhookContext) GetMaxPayloadSize() int64

+ type WebhookEventSource struct

+ Filter *EventSourceFilter

+ func (*WebhookEventSource) Descriptor() ([]byte, []int)

+ func (*WebhookEventSource) ProtoMessage()

+ func (in *WebhookEventSource) DeepCopy() *WebhookEventSource

+ func (in *WebhookEventSource) DeepCopyInto(out *WebhookEventSource)

+ func (m *WebhookEventSource) Marshal() (dAtA []byte, err error)

+ func (m *WebhookEventSource) MarshalTo(dAtA []byte) (int, error)

+ func (m *WebhookEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *WebhookEventSource) Reset()

+ func (m *WebhookEventSource) Size() (n int)

+ func (m *WebhookEventSource) Unmarshal(dAtA []byte) error

+ func (m *WebhookEventSource) XXX_DiscardUnknown()

+ func (m *WebhookEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *WebhookEventSource) XXX_Merge(src proto.Message)

+ func (m *WebhookEventSource) XXX_Size() int

+ func (m *WebhookEventSource) XXX_Unmarshal(b []byte) error

+ func (this *WebhookEventSource) String() string

Jun 9, 2022

Changes in this version

type BitbucketServerEventSource

+ func (b BitbucketServerEventSource) ShouldCreateWebhooks() bool

type RedisEventSource

+ Username string

type RedisStreamEventSource

+ Username string

May 4, 2022 GO-2022-0492

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Changes in this version

type EventSourceSpec

+ RedisStream map[string]RedisStreamEventSource

type RedisEventSource

+ JSONBody bool

+ type RedisStreamEventSource struct

+ ConsumerGroup string

+ DB int32

+ Filter *EventSourceFilter

+ HostAddress string

+ MaxMsgCountPerRead int32

+ Metadata map[string]string

+ Password *corev1.SecretKeySelector

+ Streams []string

+ TLS *apicommon.TLSConfig

+ func (*RedisStreamEventSource) Descriptor() ([]byte, []int)

+ func (*RedisStreamEventSource) ProtoMessage()

+ func (in *RedisStreamEventSource) DeepCopy() *RedisStreamEventSource

+ func (in *RedisStreamEventSource) DeepCopyInto(out *RedisStreamEventSource)

+ func (m *RedisStreamEventSource) Marshal() (dAtA []byte, err error)

+ func (m *RedisStreamEventSource) MarshalTo(dAtA []byte) (int, error)

+ func (m *RedisStreamEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *RedisStreamEventSource) Reset()

+ func (m *RedisStreamEventSource) Size() (n int)

+ func (m *RedisStreamEventSource) Unmarshal(dAtA []byte) error

+ func (m *RedisStreamEventSource) XXX_DiscardUnknown()

+ func (m *RedisStreamEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RedisStreamEventSource) XXX_Merge(src proto.Message)

+ func (m *RedisStreamEventSource) XXX_Size() int

+ func (m *RedisStreamEventSource) XXX_Unmarshal(b []byte) error

+ func (this *RedisStreamEventSource) String() string

Apr 23, 2022 GO-2022-0492

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Mar 3, 2022 GO-2022-0492

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Mar 2, 2022 GO-2022-0492

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Feb 27, 2022 GO-2022-0492

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Changes in this version

type SQSEventSource

+ Endpoint string

Feb 13, 2022 GO-2022-0492

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Changes in this version

type AMQPEventSource

+ Filter *EventSourceFilter

type AMQPQueueDeclareConfig

+ Arguments string

type AzureEventsHubEventSource

+ Filter *EventSourceFilter

+ type BitbucketAuth struct

+ Basic *BitbucketBasicAuth

+ OAuthToken *corev1.SecretKeySelector

+ func (*BitbucketAuth) Descriptor() ([]byte, []int)

+ func (*BitbucketAuth) ProtoMessage()

+ func (in *BitbucketAuth) DeepCopy() *BitbucketAuth

+ func (in *BitbucketAuth) DeepCopyInto(out *BitbucketAuth)

+ func (m *BitbucketAuth) Marshal() (dAtA []byte, err error)

+ func (m *BitbucketAuth) MarshalTo(dAtA []byte) (int, error)

+ func (m *BitbucketAuth) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *BitbucketAuth) Reset()

+ func (m *BitbucketAuth) Size() (n int)

+ func (m *BitbucketAuth) Unmarshal(dAtA []byte) error

+ func (m *BitbucketAuth) XXX_DiscardUnknown()

+ func (m *BitbucketAuth) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *BitbucketAuth) XXX_Merge(src proto.Message)

+ func (m *BitbucketAuth) XXX_Size() int

+ func (m *BitbucketAuth) XXX_Unmarshal(b []byte) error

+ func (this *BitbucketAuth) String() string

+ type BitbucketBasicAuth struct

+ Password *corev1.SecretKeySelector

+ Username *corev1.SecretKeySelector

+ func (*BitbucketBasicAuth) Descriptor() ([]byte, []int)

+ func (*BitbucketBasicAuth) ProtoMessage()

+ func (in *BitbucketBasicAuth) DeepCopy() *BitbucketBasicAuth

+ func (in *BitbucketBasicAuth) DeepCopyInto(out *BitbucketBasicAuth)

+ func (m *BitbucketBasicAuth) Marshal() (dAtA []byte, err error)

+ func (m *BitbucketBasicAuth) MarshalTo(dAtA []byte) (int, error)

+ func (m *BitbucketBasicAuth) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *BitbucketBasicAuth) Reset()

+ func (m *BitbucketBasicAuth) Size() (n int)

+ func (m *BitbucketBasicAuth) Unmarshal(dAtA []byte) error

+ func (m *BitbucketBasicAuth) XXX_DiscardUnknown()

+ func (m *BitbucketBasicAuth) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *BitbucketBasicAuth) XXX_Merge(src proto.Message)

+ func (m *BitbucketBasicAuth) XXX_Size() int

+ func (m *BitbucketBasicAuth) XXX_Unmarshal(b []byte) error

+ func (this *BitbucketBasicAuth) String() string

+ type BitbucketEventSource struct

+ Auth *BitbucketAuth

+ DeleteHookOnFinish bool

+ Events []string

+ Filter *EventSourceFilter

+ Metadata map[string]string

+ Owner string

+ ProjectKey string

+ RepositorySlug string

+ Webhook *WebhookContext

+ func (*BitbucketEventSource) Descriptor() ([]byte, []int)

+ func (*BitbucketEventSource) ProtoMessage()

+ func (b BitbucketEventSource) HasBitbucketBasicAuth() bool

+ func (b BitbucketEventSource) HasBitbucketOAuthToken() bool

+ func (b BitbucketEventSource) HasConfiguredWebhook() bool

+ func (b BitbucketEventSource) ShouldCreateWebhook() bool

+ func (in *BitbucketEventSource) DeepCopy() *BitbucketEventSource

+ func (in *BitbucketEventSource) DeepCopyInto(out *BitbucketEventSource)

+ func (m *BitbucketEventSource) Marshal() (dAtA []byte, err error)

+ func (m *BitbucketEventSource) MarshalTo(dAtA []byte) (int, error)

+ func (m *BitbucketEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *BitbucketEventSource) Reset()

+ func (m *BitbucketEventSource) Size() (n int)

+ func (m *BitbucketEventSource) Unmarshal(dAtA []byte) error

+ func (m *BitbucketEventSource) XXX_DiscardUnknown()

+ func (m *BitbucketEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *BitbucketEventSource) XXX_Merge(src proto.Message)

+ func (m *BitbucketEventSource) XXX_Size() int

+ func (m *BitbucketEventSource) XXX_Unmarshal(b []byte) error

+ func (this *BitbucketEventSource) String() string

type BitbucketServerEventSource

+ DeprecatedProjectKey string

+ DeprecatedRepositorySlug string

+ Filter *EventSourceFilter

+ Repositories []BitbucketServerRepository

+ func (b BitbucketServerEventSource) GetBitbucketServerRepositories() []BitbucketServerRepository

+ type BitbucketServerRepository struct

+ ProjectKey string

+ RepositorySlug string

+ func (*BitbucketServerRepository) Descriptor() ([]byte, []int)

+ func (*BitbucketServerRepository) ProtoMessage()

+ func (in *BitbucketServerRepository) DeepCopy() *BitbucketServerRepository

+ func (in *BitbucketServerRepository) DeepCopyInto(out *BitbucketServerRepository)

+ func (m *BitbucketServerRepository) Marshal() (dAtA []byte, err error)

+ func (m *BitbucketServerRepository) MarshalTo(dAtA []byte) (int, error)

+ func (m *BitbucketServerRepository) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *BitbucketServerRepository) Reset()

+ func (m *BitbucketServerRepository) Size() (n int)

+ func (m *BitbucketServerRepository) Unmarshal(dAtA []byte) error

+ func (m *BitbucketServerRepository) XXX_DiscardUnknown()

+ func (m *BitbucketServerRepository) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *BitbucketServerRepository) XXX_Merge(src proto.Message)

+ func (m *BitbucketServerRepository) XXX_Size() int

+ func (m *BitbucketServerRepository) XXX_Unmarshal(b []byte) error

+ func (this *BitbucketServerRepository) String() string

type CalendarEventSource

+ Filter *EventSourceFilter

type EmitterEventSource

+ Filter *EventSourceFilter

+ type EventSourceFilter struct

+ Expression string

+ func (*EventSourceFilter) Descriptor() ([]byte, []int)

+ func (*EventSourceFilter) ProtoMessage()

+ func (in *EventSourceFilter) DeepCopy() *EventSourceFilter

+ func (in *EventSourceFilter) DeepCopyInto(out *EventSourceFilter)

+ func (m *EventSourceFilter) Marshal() (dAtA []byte, err error)

+ func (m *EventSourceFilter) MarshalTo(dAtA []byte) (int, error)

+ func (m *EventSourceFilter) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *EventSourceFilter) Reset()

+ func (m *EventSourceFilter) Size() (n int)

+ func (m *EventSourceFilter) Unmarshal(dAtA []byte) error

+ func (m *EventSourceFilter) XXX_DiscardUnknown()

+ func (m *EventSourceFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *EventSourceFilter) XXX_Merge(src proto.Message)

+ func (m *EventSourceFilter) XXX_Size() int

+ func (m *EventSourceFilter) XXX_Unmarshal(b []byte) error

+ func (this *EventSourceFilter) String() string

type EventSourceSpec

+ Bitbucket map[string]BitbucketEventSource

type FileEventSource

+ Filter *EventSourceFilter

type GenericEventSource

+ Filter *EventSourceFilter

type GithubEventSource

+ Filter *EventSourceFilter

type GitlabEventSource

+ Filter *EventSourceFilter

type HDFSEventSource

+ Filter *EventSourceFilter

type KafkaEventSource

+ Filter *EventSourceFilter

type MQTTEventSource

+ Filter *EventSourceFilter

type NATSEventsSource

+ Filter *EventSourceFilter

type NSQEventSource

+ Filter *EventSourceFilter

type PubSubEventSource

+ Filter *EventSourceFilter

type PulsarEventSource

+ Filter *EventSourceFilter

type RedisEventSource

+ Filter *EventSourceFilter

type SNSEventSource

+ Filter *EventSourceFilter

type SQSEventSource

+ DLQ bool

+ Filter *EventSourceFilter

type SlackEventSource

+ Filter *EventSourceFilter

Jan 12, 2022 GO-2022-0492

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Changes in this version

+ type GithubAppCreds struct

+ AppID int64

+ InstallationID int64

+ PrivateKey *corev1.SecretKeySelector

+ func (*GithubAppCreds) Descriptor() ([]byte, []int)

+ func (*GithubAppCreds) ProtoMessage()

+ func (in *GithubAppCreds) DeepCopy() *GithubAppCreds

+ func (in *GithubAppCreds) DeepCopyInto(out *GithubAppCreds)

+ func (m *GithubAppCreds) Marshal() (dAtA []byte, err error)

+ func (m *GithubAppCreds) MarshalTo(dAtA []byte) (int, error)

+ func (m *GithubAppCreds) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *GithubAppCreds) Reset()

+ func (m *GithubAppCreds) Size() (n int)

+ func (m *GithubAppCreds) Unmarshal(dAtA []byte) error

+ func (m *GithubAppCreds) XXX_DiscardUnknown()

+ func (m *GithubAppCreds) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GithubAppCreds) XXX_Merge(src proto.Message)

+ func (m *GithubAppCreds) XXX_Size() int

+ func (m *GithubAppCreds) XXX_Unmarshal(b []byte) error

+ func (this *GithubAppCreds) String() string

type GithubEventSource

+ GithubApp *GithubAppCreds

+ Organizations []string

+ func (g GithubEventSource) HasConfiguredWebhook() bool

+ func (g GithubEventSource) HasGithubAPIToken() bool

+ func (g GithubEventSource) HasGithubAppCreds() bool

Dec 19, 2021 GO-2022-0492

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Dec 10, 2021 GO-2022-0492

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Nov 22, 2021 GO-2022-0492

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Nov 9, 2021 GO-2022-0492

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Nov 8, 2021 GO-2022-0492

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Oct 12, 2021 GO-2022-0492

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Changes in this version

type AMQPEventSource

+ URLSecret *corev1.SecretKeySelector

+ type BitbucketServerEventSource struct

+ AccessToken *corev1.SecretKeySelector

+ BitbucketServerBaseURL string

+ DeleteHookOnFinish bool

+ Events []string

+ Metadata map[string]string

+ ProjectKey string

+ RepositorySlug string

+ Webhook *WebhookContext

+ WebhookSecret *corev1.SecretKeySelector

+ func (*BitbucketServerEventSource) Descriptor() ([]byte, []int)

+ func (*BitbucketServerEventSource) ProtoMessage()

+ func (in *BitbucketServerEventSource) DeepCopy() *BitbucketServerEventSource

+ func (in *BitbucketServerEventSource) DeepCopyInto(out *BitbucketServerEventSource)

+ func (m *BitbucketServerEventSource) Marshal() (dAtA []byte, err error)

+ func (m *BitbucketServerEventSource) MarshalTo(dAtA []byte) (int, error)

+ func (m *BitbucketServerEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *BitbucketServerEventSource) Reset()

+ func (m *BitbucketServerEventSource) Size() (n int)

+ func (m *BitbucketServerEventSource) Unmarshal(dAtA []byte) error

+ func (m *BitbucketServerEventSource) XXX_DiscardUnknown()

+ func (m *BitbucketServerEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *BitbucketServerEventSource) XXX_Merge(src proto.Message)

+ func (m *BitbucketServerEventSource) XXX_Size() int

+ func (m *BitbucketServerEventSource) XXX_Unmarshal(b []byte) error

+ func (this *BitbucketServerEventSource) String() string

type EventSourceSpec

+ BitbucketServer map[string]BitbucketServerEventSource

type GitlabEventSource

+ DeprecatedProjectID string

+ Projects []string

+ SecretToken *corev1.SecretKeySelector

+ func (g GitlabEventSource) GetProjects() []string

+ func (g GitlabEventSource) NeedToCreateHooks() bool

type PulsarEventSource

+ AuthTokenSecret *corev1.SecretKeySelector

Sep 30, 2021 GO-2022-0492

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Sep 21, 2021 GO-2022-0492

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Sep 1, 2021 GO-2022-0492

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Jul 12, 2021 GO-2022-0492

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Changes in this version

type AMQPEventSource

+ Auth *apicommon.BasicAuth

type KafkaEventSource

+ SASL *apicommon.SASLConfig

May 4, 2021 GO-2022-0492

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Changes in this version

type GithubEventSource

+ DeprecatedOwner string

+ DeprecatedRepository string

+ Repositories []OwnedRepositories

+ func (g GithubEventSource) GetOwnedRepositories() []OwnedRepositories

+ func (g GithubEventSource) NeedToCreateHooks() bool

+ type OwnedRepositories struct

+ Names []string

+ Owner string

+ func (*OwnedRepositories) Descriptor() ([]byte, []int)

+ func (*OwnedRepositories) ProtoMessage()

+ func (in *OwnedRepositories) DeepCopy() *OwnedRepositories

+ func (in *OwnedRepositories) DeepCopyInto(out *OwnedRepositories)

+ func (m *OwnedRepositories) Marshal() (dAtA []byte, err error)

+ func (m *OwnedRepositories) MarshalTo(dAtA []byte) (int, error)

+ func (m *OwnedRepositories) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *OwnedRepositories) Reset()

+ func (m *OwnedRepositories) Size() (n int)

+ func (m *OwnedRepositories) Unmarshal(dAtA []byte) error

+ func (m *OwnedRepositories) XXX_DiscardUnknown()

+ func (m *OwnedRepositories) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *OwnedRepositories) XXX_Merge(src proto.Message)

+ func (m *OwnedRepositories) XXX_Size() int

+ func (m *OwnedRepositories) XXX_Unmarshal(b []byte) error

+ func (this *OwnedRepositories) String() string

Apr 12, 2021 GO-2022-0492

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Changes in this version

+ type AMQPConsumeConfig struct

+ AutoAck bool

+ ConsumerTag string

+ Exclusive bool

+ NoLocal bool

+ NoWait bool

+ func (*AMQPConsumeConfig) Descriptor() ([]byte, []int)

+ func (*AMQPConsumeConfig) ProtoMessage()

+ func (in *AMQPConsumeConfig) DeepCopy() *AMQPConsumeConfig

+ func (in *AMQPConsumeConfig) DeepCopyInto(out *AMQPConsumeConfig)

+ func (m *AMQPConsumeConfig) Marshal() (dAtA []byte, err error)

+ func (m *AMQPConsumeConfig) MarshalTo(dAtA []byte) (int, error)

+ func (m *AMQPConsumeConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *AMQPConsumeConfig) Reset()

+ func (m *AMQPConsumeConfig) Size() (n int)

+ func (m *AMQPConsumeConfig) Unmarshal(dAtA []byte) error

+ func (m *AMQPConsumeConfig) XXX_DiscardUnknown()

+ func (m *AMQPConsumeConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *AMQPConsumeConfig) XXX_Merge(src proto.Message)

+ func (m *AMQPConsumeConfig) XXX_Size() int

+ func (m *AMQPConsumeConfig) XXX_Unmarshal(b []byte) error

+ func (this *AMQPConsumeConfig) String() string

type AMQPEventSource

+ Consume *AMQPConsumeConfig

+ ExchangeDeclare *AMQPExchangeDeclareConfig

+ QueueBind *AMQPQueueBindConfig

+ QueueDeclare *AMQPQueueDeclareConfig

+ type AMQPExchangeDeclareConfig struct

+ AutoDelete bool

+ Durable bool

+ Internal bool

+ NoWait bool

+ func (*AMQPExchangeDeclareConfig) Descriptor() ([]byte, []int)

+ func (*AMQPExchangeDeclareConfig) ProtoMessage()

+ func (in *AMQPExchangeDeclareConfig) DeepCopy() *AMQPExchangeDeclareConfig

+ func (in *AMQPExchangeDeclareConfig) DeepCopyInto(out *AMQPExchangeDeclareConfig)

+ func (m *AMQPExchangeDeclareConfig) Marshal() (dAtA []byte, err error)

+ func (m *AMQPExchangeDeclareConfig) MarshalTo(dAtA []byte) (int, error)

+ func (m *AMQPExchangeDeclareConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *AMQPExchangeDeclareConfig) Reset()

+ func (m *AMQPExchangeDeclareConfig) Size() (n int)

+ func (m *AMQPExchangeDeclareConfig) Unmarshal(dAtA []byte) error

+ func (m *AMQPExchangeDeclareConfig) XXX_DiscardUnknown()

+ func (m *AMQPExchangeDeclareConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *AMQPExchangeDeclareConfig) XXX_Merge(src proto.Message)

+ func (m *AMQPExchangeDeclareConfig) XXX_Size() int

+ func (m *AMQPExchangeDeclareConfig) XXX_Unmarshal(b []byte) error

+ func (this *AMQPExchangeDeclareConfig) String() string

+ type AMQPQueueBindConfig struct

+ NoWait bool

+ func (*AMQPQueueBindConfig) Descriptor() ([]byte, []int)

+ func (*AMQPQueueBindConfig) ProtoMessage()

+ func (in *AMQPQueueBindConfig) DeepCopy() *AMQPQueueBindConfig

+ func (in *AMQPQueueBindConfig) DeepCopyInto(out *AMQPQueueBindConfig)

+ func (m *AMQPQueueBindConfig) Marshal() (dAtA []byte, err error)

+ func (m *AMQPQueueBindConfig) MarshalTo(dAtA []byte) (int, error)

+ func (m *AMQPQueueBindConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *AMQPQueueBindConfig) Reset()

+ func (m *AMQPQueueBindConfig) Size() (n int)

+ func (m *AMQPQueueBindConfig) Unmarshal(dAtA []byte) error

+ func (m *AMQPQueueBindConfig) XXX_DiscardUnknown()

+ func (m *AMQPQueueBindConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *AMQPQueueBindConfig) XXX_Merge(src proto.Message)

+ func (m *AMQPQueueBindConfig) XXX_Size() int

+ func (m *AMQPQueueBindConfig) XXX_Unmarshal(b []byte) error

+ func (this *AMQPQueueBindConfig) String() string

+ type AMQPQueueDeclareConfig struct

+ AutoDelete bool

+ Durable bool

+ Exclusive bool

+ Name string

+ NoWait bool

+ func (*AMQPQueueDeclareConfig) Descriptor() ([]byte, []int)

+ func (*AMQPQueueDeclareConfig) ProtoMessage()

+ func (in *AMQPQueueDeclareConfig) DeepCopy() *AMQPQueueDeclareConfig

+ func (in *AMQPQueueDeclareConfig) DeepCopyInto(out *AMQPQueueDeclareConfig)

+ func (m *AMQPQueueDeclareConfig) Marshal() (dAtA []byte, err error)

+ func (m *AMQPQueueDeclareConfig) MarshalTo(dAtA []byte) (int, error)

+ func (m *AMQPQueueDeclareConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *AMQPQueueDeclareConfig) Reset()

+ func (m *AMQPQueueDeclareConfig) Size() (n int)

+ func (m *AMQPQueueDeclareConfig) Unmarshal(dAtA []byte) error

+ func (m *AMQPQueueDeclareConfig) XXX_DiscardUnknown()

+ func (m *AMQPQueueDeclareConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *AMQPQueueDeclareConfig) XXX_Merge(src proto.Message)

+ func (m *AMQPQueueDeclareConfig) XXX_Size() int

+ func (m *AMQPQueueDeclareConfig) XXX_Unmarshal(b []byte) error

+ func (this *AMQPQueueDeclareConfig) String() string

type EventSourceSpec

+ DeprecatedReplica *int32

+ Replicas *int32

+ func (e EventSourceSpec) GetReplicas() int32

+ type NATSAuth struct

+ Basic *apicommon.BasicAuth

+ Credential *corev1.SecretKeySelector

+ NKey *corev1.SecretKeySelector

+ Token *corev1.SecretKeySelector

+ func (*NATSAuth) Descriptor() ([]byte, []int)

+ func (*NATSAuth) ProtoMessage()

+ func (in *NATSAuth) DeepCopy() *NATSAuth

+ func (in *NATSAuth) DeepCopyInto(out *NATSAuth)

+ func (m *NATSAuth) Marshal() (dAtA []byte, err error)

+ func (m *NATSAuth) MarshalTo(dAtA []byte) (int, error)

+ func (m *NATSAuth) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *NATSAuth) Reset()

+ func (m *NATSAuth) Size() (n int)

+ func (m *NATSAuth) Unmarshal(dAtA []byte) error

+ func (m *NATSAuth) XXX_DiscardUnknown()

+ func (m *NATSAuth) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *NATSAuth) XXX_Merge(src proto.Message)

+ func (m *NATSAuth) XXX_Size() int

+ func (m *NATSAuth) XXX_Unmarshal(b []byte) error

+ func (this *NATSAuth) String() string

type NATSEventsSource

+ Auth *NATSAuth

type Template

+ Priority *int32

+ PriorityClassName string

Apr 8, 2021 GO-2022-0492

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Apr 5, 2021 GO-2022-0492

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Mar 31, 2021 GO-2022-0492

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Mar 23, 2021 GO-2022-0492

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Feb 18, 2021 GO-2022-0492

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Jan 27, 2021 GO-2022-0492

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Jan 26, 2021 GO-2022-0492

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Jan 8, 2021 GO-2022-0492

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Changes in this version

type GenericEventSource

+ AuthSecret *corev1.SecretKeySelector

type SNSEventSource

+ ValidateSignature bool

type Template

+ ImagePullSecrets []corev1.LocalObjectReference

Nov 16, 2020 GO-2022-0492

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Changes in this version

type CalendarEventSource

+ Persistence *EventPersistence

+ type CatchupConfiguration struct

+ Enabled bool

+ MaxDuration string

+ func (*CatchupConfiguration) Descriptor() ([]byte, []int)

+ func (*CatchupConfiguration) ProtoMessage()

+ func (in *CatchupConfiguration) DeepCopy() *CatchupConfiguration

+ func (in *CatchupConfiguration) DeepCopyInto(out *CatchupConfiguration)

+ func (m *CatchupConfiguration) Marshal() (dAtA []byte, err error)

+ func (m *CatchupConfiguration) MarshalTo(dAtA []byte) (int, error)

+ func (m *CatchupConfiguration) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *CatchupConfiguration) Reset()

+ func (m *CatchupConfiguration) Size() (n int)

+ func (m *CatchupConfiguration) Unmarshal(dAtA []byte) error

+ func (m *CatchupConfiguration) XXX_DiscardUnknown()

+ func (m *CatchupConfiguration) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *CatchupConfiguration) XXX_Merge(src proto.Message)

+ func (m *CatchupConfiguration) XXX_Size() int

+ func (m *CatchupConfiguration) XXX_Unmarshal(b []byte) error

+ func (this *CatchupConfiguration) String() string

+ type ConfigMapPersistence struct

+ CreateIfNotExist bool

+ Name string

+ func (*ConfigMapPersistence) Descriptor() ([]byte, []int)

+ func (*ConfigMapPersistence) ProtoMessage()

+ func (in *ConfigMapPersistence) DeepCopy() *ConfigMapPersistence

+ func (in *ConfigMapPersistence) DeepCopyInto(out *ConfigMapPersistence)

+ func (m *ConfigMapPersistence) Marshal() (dAtA []byte, err error)

+ func (m *ConfigMapPersistence) MarshalTo(dAtA []byte) (int, error)

+ func (m *ConfigMapPersistence) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ConfigMapPersistence) Reset()

+ func (m *ConfigMapPersistence) Size() (n int)

+ func (m *ConfigMapPersistence) Unmarshal(dAtA []byte) error

+ func (m *ConfigMapPersistence) XXX_DiscardUnknown()

+ func (m *ConfigMapPersistence) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ConfigMapPersistence) XXX_Merge(src proto.Message)

+ func (m *ConfigMapPersistence) XXX_Size() int

+ func (m *ConfigMapPersistence) XXX_Unmarshal(b []byte) error

+ func (this *ConfigMapPersistence) String() string

+ type EventPersistence struct

+ Catchup *CatchupConfiguration

+ ConfigMap *ConfigMapPersistence

+ func (*EventPersistence) Descriptor() ([]byte, []int)

+ func (*EventPersistence) ProtoMessage()

+ func (ep *EventPersistence) IsCatchUpEnabled() bool

+ func (in *EventPersistence) DeepCopy() *EventPersistence

+ func (in *EventPersistence) DeepCopyInto(out *EventPersistence)

+ func (m *EventPersistence) Marshal() (dAtA []byte, err error)

+ func (m *EventPersistence) MarshalTo(dAtA []byte) (int, error)

+ func (m *EventPersistence) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *EventPersistence) Reset()

+ func (m *EventPersistence) Size() (n int)

+ func (m *EventPersistence) Unmarshal(dAtA []byte) error

+ func (m *EventPersistence) XXX_DiscardUnknown()

+ func (m *EventPersistence) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *EventPersistence) XXX_Merge(src proto.Message)

+ func (m *EventPersistence) XXX_Size() int

+ func (m *EventPersistence) XXX_Unmarshal(b []byte) error

+ func (this *EventPersistence) String() string

type GenericEventSource

+ Config string

+ Insecure bool

+ JSONBody bool

+ Metadata map[string]string

+ URL string

Nov 5, 2020 GO-2022-0492

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Sep 4, 2020 GO-2022-0492

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Changes in this version

type AMQPEventSource

+ Metadata map[string]string

type AzureEventsHubEventSource

+ Metadata map[string]string

type CalendarEventSource

+ Metadata map[string]string

type EmitterEventSource

+ Metadata map[string]string

type EventSourceSpec

+ Pulsar map[string]PulsarEventSource

type FileEventSource

+ Metadata map[string]string

type GithubEventSource

+ Metadata map[string]string

type GitlabEventSource

+ Metadata map[string]string

type HDFSEventSource

+ Metadata map[string]string

+ type KafkaConsumerGroup struct

+ GroupName string

+ Oldest bool

+ RebalanceStrategy string

+ func (*KafkaConsumerGroup) Descriptor() ([]byte, []int)

+ func (*KafkaConsumerGroup) ProtoMessage()

+ func (in *KafkaConsumerGroup) DeepCopy() *KafkaConsumerGroup

+ func (in *KafkaConsumerGroup) DeepCopyInto(out *KafkaConsumerGroup)

+ func (m *KafkaConsumerGroup) Marshal() (dAtA []byte, err error)

+ func (m *KafkaConsumerGroup) MarshalTo(dAtA []byte) (int, error)

+ func (m *KafkaConsumerGroup) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *KafkaConsumerGroup) Reset()

+ func (m *KafkaConsumerGroup) Size() (n int)

+ func (m *KafkaConsumerGroup) Unmarshal(dAtA []byte) error

+ func (m *KafkaConsumerGroup) XXX_DiscardUnknown()

+ func (m *KafkaConsumerGroup) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *KafkaConsumerGroup) XXX_Merge(src proto.Message)

+ func (m *KafkaConsumerGroup) XXX_Size() int

+ func (m *KafkaConsumerGroup) XXX_Unmarshal(b []byte) error

+ func (this *KafkaConsumerGroup) String() string

type KafkaEventSource

+ ConsumerGroup *KafkaConsumerGroup

+ LimitEventsPerSecond int64

+ Metadata map[string]string

+ Version string

type MQTTEventSource

+ Metadata map[string]string

type NATSEventsSource

+ Metadata map[string]string

type NSQEventSource

+ Metadata map[string]string

type PubSubEventSource

+ CredentialSecret *corev1.SecretKeySelector

+ DeprecatedCredentialsFile string

+ Metadata map[string]string

+ SubscriptionID string

+ type PulsarEventSource struct

+ ConnectionBackoff *apicommon.Backoff

+ JSONBody bool

+ Metadata map[string]string

+ TLS *apicommon.TLSConfig

+ TLSAllowInsecureConnection bool

+ TLSTrustCertsSecret *corev1.SecretKeySelector

+ TLSValidateHostname bool

+ Topics []string

+ Type string

+ URL string

+ func (*PulsarEventSource) Descriptor() ([]byte, []int)

+ func (*PulsarEventSource) ProtoMessage()

+ func (in *PulsarEventSource) DeepCopy() *PulsarEventSource

+ func (in *PulsarEventSource) DeepCopyInto(out *PulsarEventSource)

+ func (m *PulsarEventSource) Marshal() (dAtA []byte, err error)

+ func (m *PulsarEventSource) MarshalTo(dAtA []byte) (int, error)

+ func (m *PulsarEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PulsarEventSource) Reset()

+ func (m *PulsarEventSource) Size() (n int)

+ func (m *PulsarEventSource) Unmarshal(dAtA []byte) error

+ func (m *PulsarEventSource) XXX_DiscardUnknown()

+ func (m *PulsarEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *PulsarEventSource) XXX_Merge(src proto.Message)

+ func (m *PulsarEventSource) XXX_Size() int

+ func (m *PulsarEventSource) XXX_Unmarshal(b []byte) error

+ func (this *PulsarEventSource) String() string

type RedisEventSource

+ Metadata map[string]string

type ResourceEventSource

+ Metadata map[string]string

type SNSEventSource

+ Metadata map[string]string

type SQSEventSource

+ Metadata map[string]string

type SlackEventSource

+ Metadata map[string]string

type StorageGridEventSource

+ Metadata map[string]string

type StripeEventSource

+ Metadata map[string]string

type WebhookContext

+ AuthSecret *corev1.SecretKeySelector

+ DeprecatedServerCertPath string

+ DeprecatedServerKeyPath string

+ Metadata map[string]string

+ ServerCertSecret *corev1.SecretKeySelector

+ ServerKeySecret *corev1.SecretKeySelector

Aug 26, 2020 GO-2022-0492

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Aug 16, 2020 GO-2022-0492

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Aug 7, 2020 GO-2022-0492

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Jul 24, 2020 GO-2022-0492

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Changes in this version

+ const EventSourceConditionDeployed

+ const EventSourceConditionSourcesProvided

+ var ErrIntOverflowGenerated = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthGenerated = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrUnexpectedEndOfGroupGenerated = fmt.Errorf("proto: unexpected end of group")

type AMQPEventSource

+ func (*AMQPEventSource) Descriptor() ([]byte, []int)

+ func (*AMQPEventSource) ProtoMessage()

+ func (m *AMQPEventSource) Marshal() (dAtA []byte, err error)

+ func (m *AMQPEventSource) MarshalTo(dAtA []byte) (int, error)

+ func (m *AMQPEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *AMQPEventSource) Reset()

+ func (m *AMQPEventSource) Size() (n int)

+ func (m *AMQPEventSource) Unmarshal(dAtA []byte) error

+ func (m *AMQPEventSource) XXX_DiscardUnknown()

+ func (m *AMQPEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *AMQPEventSource) XXX_Merge(src proto.Message)

+ func (m *AMQPEventSource) XXX_Size() int

+ func (m *AMQPEventSource) XXX_Unmarshal(b []byte) error

+ func (this *AMQPEventSource) String() string

type AzureEventsHubEventSource

+ func (*AzureEventsHubEventSource) Descriptor() ([]byte, []int)

+ func (*AzureEventsHubEventSource) ProtoMessage()

+ func (m *AzureEventsHubEventSource) Marshal() (dAtA []byte, err error)

+ func (m *AzureEventsHubEventSource) MarshalTo(dAtA []byte) (int, error)

+ func (m *AzureEventsHubEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *AzureEventsHubEventSource) Reset()

+ func (m *AzureEventsHubEventSource) Size() (n int)

+ func (m *AzureEventsHubEventSource) Unmarshal(dAtA []byte) error

+ func (m *AzureEventsHubEventSource) XXX_DiscardUnknown()

+ func (m *AzureEventsHubEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *AzureEventsHubEventSource) XXX_Merge(src proto.Message)

+ func (m *AzureEventsHubEventSource) XXX_Size() int

+ func (m *AzureEventsHubEventSource) XXX_Unmarshal(b []byte) error

+ func (this *AzureEventsHubEventSource) String() string

type CalendarEventSource

+ func (*CalendarEventSource) Descriptor() ([]byte, []int)

+ func (*CalendarEventSource) ProtoMessage()

+ func (m *CalendarEventSource) Marshal() (dAtA []byte, err error)

+ func (m *CalendarEventSource) MarshalTo(dAtA []byte) (int, error)

+ func (m *CalendarEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *CalendarEventSource) Reset()

+ func (m *CalendarEventSource) Size() (n int)

+ func (m *CalendarEventSource) Unmarshal(dAtA []byte) error

+ func (m *CalendarEventSource) XXX_DiscardUnknown()

+ func (m *CalendarEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *CalendarEventSource) XXX_Merge(src proto.Message)

+ func (m *CalendarEventSource) XXX_Size() int

+ func (m *CalendarEventSource) XXX_Unmarshal(b []byte) error

+ func (this *CalendarEventSource) String() string

type EmitterEventSource

+ func (*EmitterEventSource) Descriptor() ([]byte, []int)

+ func (*EmitterEventSource) ProtoMessage()

+ func (m *EmitterEventSource) Marshal() (dAtA []byte, err error)

+ func (m *EmitterEventSource) MarshalTo(dAtA []byte) (int, error)

+ func (m *EmitterEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *EmitterEventSource) Reset()

+ func (m *EmitterEventSource) Size() (n int)

+ func (m *EmitterEventSource) Unmarshal(dAtA []byte) error

+ func (m *EmitterEventSource) XXX_DiscardUnknown()

+ func (m *EmitterEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *EmitterEventSource) XXX_Merge(src proto.Message)

+ func (m *EmitterEventSource) XXX_Size() int

+ func (m *EmitterEventSource) XXX_Unmarshal(b []byte) error

+ func (this *EmitterEventSource) String() string

type EventSource

+ func (*EventSource) Descriptor() ([]byte, []int)

+ func (*EventSource) ProtoMessage()

+ func (m *EventSource) Marshal() (dAtA []byte, err error)

+ func (m *EventSource) MarshalTo(dAtA []byte) (int, error)

+ func (m *EventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *EventSource) Reset()

+ func (m *EventSource) Size() (n int)

+ func (m *EventSource) Unmarshal(dAtA []byte) error

+ func (m *EventSource) XXX_DiscardUnknown()

+ func (m *EventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *EventSource) XXX_Merge(src proto.Message)

+ func (m *EventSource) XXX_Size() int

+ func (m *EventSource) XXX_Unmarshal(b []byte) error

+ func (this *EventSource) String() string

type EventSourceList

+ func (*EventSourceList) Descriptor() ([]byte, []int)

+ func (*EventSourceList) ProtoMessage()

+ func (m *EventSourceList) Marshal() (dAtA []byte, err error)

+ func (m *EventSourceList) MarshalTo(dAtA []byte) (int, error)

+ func (m *EventSourceList) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *EventSourceList) Reset()

+ func (m *EventSourceList) Size() (n int)

+ func (m *EventSourceList) Unmarshal(dAtA []byte) error

+ func (m *EventSourceList) XXX_DiscardUnknown()

+ func (m *EventSourceList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *EventSourceList) XXX_Merge(src proto.Message)

+ func (m *EventSourceList) XXX_Size() int

+ func (m *EventSourceList) XXX_Unmarshal(b []byte) error

+ func (this *EventSourceList) String() string

type EventSourceSpec

+ EventBusName string

+ Replica *int32

+ Service *Service

+ Template Template

+ func (*EventSourceSpec) Descriptor() ([]byte, []int)

+ func (*EventSourceSpec) ProtoMessage()

+ func (m *EventSourceSpec) Marshal() (dAtA []byte, err error)

+ func (m *EventSourceSpec) MarshalTo(dAtA []byte) (int, error)

+ func (m *EventSourceSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *EventSourceSpec) Reset()

+ func (m *EventSourceSpec) Size() (n int)

+ func (m *EventSourceSpec) Unmarshal(dAtA []byte) error

+ func (m *EventSourceSpec) XXX_DiscardUnknown()

+ func (m *EventSourceSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *EventSourceSpec) XXX_Merge(src proto.Message)

+ func (m *EventSourceSpec) XXX_Size() int

+ func (m *EventSourceSpec) XXX_Unmarshal(b []byte) error

+ func (this *EventSourceSpec) String() string

type EventSourceStatus

+ func (*EventSourceStatus) Descriptor() ([]byte, []int)

+ func (*EventSourceStatus) ProtoMessage()

+ func (es *EventSourceStatus) InitConditions()

+ func (es *EventSourceStatus) MarkDeployFailed(reason, message string)

+ func (es *EventSourceStatus) MarkDeployed()

+ func (es *EventSourceStatus) MarkSourcesNotProvided(reason, message string)

+ func (es *EventSourceStatus) MarkSourcesProvided()

+ func (m *EventSourceStatus) Marshal() (dAtA []byte, err error)

+ func (m *EventSourceStatus) MarshalTo(dAtA []byte) (int, error)

+ func (m *EventSourceStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *EventSourceStatus) Reset()

+ func (m *EventSourceStatus) Size() (n int)

+ func (m *EventSourceStatus) Unmarshal(dAtA []byte) error

+ func (m *EventSourceStatus) XXX_DiscardUnknown()

+ func (m *EventSourceStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *EventSourceStatus) XXX_Merge(src proto.Message)

+ func (m *EventSourceStatus) XXX_Size() int

+ func (m *EventSourceStatus) XXX_Unmarshal(b []byte) error

+ func (this *EventSourceStatus) String() string

type FileEventSource

+ func (*FileEventSource) Descriptor() ([]byte, []int)

+ func (*FileEventSource) ProtoMessage()

+ func (m *FileEventSource) Marshal() (dAtA []byte, err error)

+ func (m *FileEventSource) MarshalTo(dAtA []byte) (int, error)

+ func (m *FileEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *FileEventSource) Reset()

+ func (m *FileEventSource) Size() (n int)

+ func (m *FileEventSource) Unmarshal(dAtA []byte) error

+ func (m *FileEventSource) XXX_DiscardUnknown()

+ func (m *FileEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *FileEventSource) XXX_Merge(src proto.Message)

+ func (m *FileEventSource) XXX_Size() int

+ func (m *FileEventSource) XXX_Unmarshal(b []byte) error

+ func (this *FileEventSource) String() string

type GenericEventSource

+ func (*GenericEventSource) Descriptor() ([]byte, []int)

+ func (*GenericEventSource) ProtoMessage()

+ func (m *GenericEventSource) Marshal() (dAtA []byte, err error)

+ func (m *GenericEventSource) MarshalTo(dAtA []byte) (int, error)

+ func (m *GenericEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *GenericEventSource) Reset()

+ func (m *GenericEventSource) Size() (n int)

+ func (m *GenericEventSource) Unmarshal(dAtA []byte) error

+ func (m *GenericEventSource) XXX_DiscardUnknown()

+ func (m *GenericEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GenericEventSource) XXX_Merge(src proto.Message)

+ func (m *GenericEventSource) XXX_Size() int

+ func (m *GenericEventSource) XXX_Unmarshal(b []byte) error

+ func (this *GenericEventSource) String() string

type GithubEventSource

+ ID int64

+ func (*GithubEventSource) Descriptor() ([]byte, []int)

+ func (*GithubEventSource) ProtoMessage()

+ func (m *GithubEventSource) Marshal() (dAtA []byte, err error)

+ func (m *GithubEventSource) MarshalTo(dAtA []byte) (int, error)

+ func (m *GithubEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *GithubEventSource) Reset()

+ func (m *GithubEventSource) Size() (n int)

+ func (m *GithubEventSource) Unmarshal(dAtA []byte) error

+ func (m *GithubEventSource) XXX_DiscardUnknown()

+ func (m *GithubEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GithubEventSource) XXX_Merge(src proto.Message)

+ func (m *GithubEventSource) XXX_Size() int

+ func (m *GithubEventSource) XXX_Unmarshal(b []byte) error

+ func (this *GithubEventSource) String() string

type GitlabEventSource

+ func (*GitlabEventSource) Descriptor() ([]byte, []int)

+ func (*GitlabEventSource) ProtoMessage()

+ func (m *GitlabEventSource) Marshal() (dAtA []byte, err error)

+ func (m *GitlabEventSource) MarshalTo(dAtA []byte) (int, error)

+ func (m *GitlabEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *GitlabEventSource) Reset()

+ func (m *GitlabEventSource) Size() (n int)

+ func (m *GitlabEventSource) Unmarshal(dAtA []byte) error

+ func (m *GitlabEventSource) XXX_DiscardUnknown()

+ func (m *GitlabEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GitlabEventSource) XXX_Merge(src proto.Message)

+ func (m *GitlabEventSource) XXX_Size() int

+ func (m *GitlabEventSource) XXX_Unmarshal(b []byte) error

+ func (this *GitlabEventSource) String() string

type HDFSEventSource

+ func (*HDFSEventSource) Descriptor() ([]byte, []int)

+ func (*HDFSEventSource) ProtoMessage()

+ func (m *HDFSEventSource) Marshal() (dAtA []byte, err error)

+ func (m *HDFSEventSource) MarshalTo(dAtA []byte) (int, error)

+ func (m *HDFSEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *HDFSEventSource) Reset()

+ func (m *HDFSEventSource) Size() (n int)

+ func (m *HDFSEventSource) Unmarshal(dAtA []byte) error

+ func (m *HDFSEventSource) XXX_DiscardUnknown()

+ func (m *HDFSEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *HDFSEventSource) XXX_Merge(src proto.Message)

+ func (m *HDFSEventSource) XXX_Size() int

+ func (m *HDFSEventSource) XXX_Unmarshal(b []byte) error

+ func (this *HDFSEventSource) String() string

type KafkaEventSource

+ JSONBody bool

+ func (*KafkaEventSource) Descriptor() ([]byte, []int)

+ func (*KafkaEventSource) ProtoMessage()

+ func (m *KafkaEventSource) Marshal() (dAtA []byte, err error)

+ func (m *KafkaEventSource) MarshalTo(dAtA []byte) (int, error)

+ func (m *KafkaEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *KafkaEventSource) Reset()

+ func (m *KafkaEventSource) Size() (n int)

+ func (m *KafkaEventSource) Unmarshal(dAtA []byte) error

+ func (m *KafkaEventSource) XXX_DiscardUnknown()

+ func (m *KafkaEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *KafkaEventSource) XXX_Merge(src proto.Message)

+ func (m *KafkaEventSource) XXX_Size() int

+ func (m *KafkaEventSource) XXX_Unmarshal(b []byte) error

+ func (this *KafkaEventSource) String() string

type MQTTEventSource

+ ClientID string

+ func (*MQTTEventSource) Descriptor() ([]byte, []int)

+ func (*MQTTEventSource) ProtoMessage()

+ func (m *MQTTEventSource) Marshal() (dAtA []byte, err error)

+ func (m *MQTTEventSource) MarshalTo(dAtA []byte) (int, error)

+ func (m *MQTTEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *MQTTEventSource) Reset()

+ func (m *MQTTEventSource) Size() (n int)

+ func (m *MQTTEventSource) Unmarshal(dAtA []byte) error

+ func (m *MQTTEventSource) XXX_DiscardUnknown()

+ func (m *MQTTEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *MQTTEventSource) XXX_Merge(src proto.Message)

+ func (m *MQTTEventSource) XXX_Size() int

+ func (m *MQTTEventSource) XXX_Unmarshal(b []byte) error

+ func (this *MQTTEventSource) String() string

+ type Metadata struct

+ Annotations map[string]string

+ Labels map[string]string

+ func (*Metadata) Descriptor() ([]byte, []int)

+ func (*Metadata) ProtoMessage()

+ func (in *Metadata) DeepCopy() *Metadata

+ func (in *Metadata) DeepCopyInto(out *Metadata)

+ func (m *Metadata) Marshal() (dAtA []byte, err error)

+ func (m *Metadata) MarshalTo(dAtA []byte) (int, error)

+ func (m *Metadata) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Metadata) Reset()

+ func (m *Metadata) Size() (n int)

+ func (m *Metadata) Unmarshal(dAtA []byte) error

+ func (m *Metadata) XXX_DiscardUnknown()

+ func (m *Metadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Metadata) XXX_Merge(src proto.Message)

+ func (m *Metadata) XXX_Size() int

+ func (m *Metadata) XXX_Unmarshal(b []byte) error

+ func (this *Metadata) String() string

type NATSEventsSource

+ func (*NATSEventsSource) Descriptor() ([]byte, []int)

+ func (*NATSEventsSource) ProtoMessage()

+ func (m *NATSEventsSource) Marshal() (dAtA []byte, err error)

+ func (m *NATSEventsSource) MarshalTo(dAtA []byte) (int, error)

+ func (m *NATSEventsSource) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *NATSEventsSource) Reset()

+ func (m *NATSEventsSource) Size() (n int)

+ func (m *NATSEventsSource) Unmarshal(dAtA []byte) error

+ func (m *NATSEventsSource) XXX_DiscardUnknown()

+ func (m *NATSEventsSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *NATSEventsSource) XXX_Merge(src proto.Message)

+ func (m *NATSEventsSource) XXX_Size() int

+ func (m *NATSEventsSource) XXX_Unmarshal(b []byte) error

+ func (this *NATSEventsSource) String() string

type NSQEventSource

+ func (*NSQEventSource) Descriptor() ([]byte, []int)

+ func (*NSQEventSource) ProtoMessage()

+ func (m *NSQEventSource) Marshal() (dAtA []byte, err error)

+ func (m *NSQEventSource) MarshalTo(dAtA []byte) (int, error)

+ func (m *NSQEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *NSQEventSource) Reset()

+ func (m *NSQEventSource) Size() (n int)

+ func (m *NSQEventSource) Unmarshal(dAtA []byte) error

+ func (m *NSQEventSource) XXX_DiscardUnknown()

+ func (m *NSQEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *NSQEventSource) XXX_Merge(src proto.Message)

+ func (m *NSQEventSource) XXX_Size() int

+ func (m *NSQEventSource) XXX_Unmarshal(b []byte) error

+ func (this *NSQEventSource) String() string

type PubSubEventSource

+ EnableWorkloadIdentity bool

+ func (*PubSubEventSource) Descriptor() ([]byte, []int)

+ func (*PubSubEventSource) ProtoMessage()

+ func (m *PubSubEventSource) Marshal() (dAtA []byte, err error)

+ func (m *PubSubEventSource) MarshalTo(dAtA []byte) (int, error)

+ func (m *PubSubEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PubSubEventSource) Reset()

+ func (m *PubSubEventSource) Size() (n int)

+ func (m *PubSubEventSource) Unmarshal(dAtA []byte) error

+ func (m *PubSubEventSource) XXX_DiscardUnknown()

+ func (m *PubSubEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *PubSubEventSource) XXX_Merge(src proto.Message)

+ func (m *PubSubEventSource) XXX_Size() int

+ func (m *PubSubEventSource) XXX_Unmarshal(b []byte) error

+ func (this *PubSubEventSource) String() string

type RedisEventSource

+ func (*RedisEventSource) Descriptor() ([]byte, []int)

+ func (*RedisEventSource) ProtoMessage()

+ func (m *RedisEventSource) Marshal() (dAtA []byte, err error)

+ func (m *RedisEventSource) MarshalTo(dAtA []byte) (int, error)

+ func (m *RedisEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *RedisEventSource) Reset()

+ func (m *RedisEventSource) Size() (n int)

+ func (m *RedisEventSource) Unmarshal(dAtA []byte) error

+ func (m *RedisEventSource) XXX_DiscardUnknown()

+ func (m *RedisEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RedisEventSource) XXX_Merge(src proto.Message)

+ func (m *RedisEventSource) XXX_Size() int

+ func (m *RedisEventSource) XXX_Unmarshal(b []byte) error

+ func (this *RedisEventSource) String() string

type ResourceEventSource

+ func (*ResourceEventSource) Descriptor() ([]byte, []int)

+ func (*ResourceEventSource) ProtoMessage()

+ func (m *ResourceEventSource) Marshal() (dAtA []byte, err error)

+ func (m *ResourceEventSource) MarshalTo(dAtA []byte) (int, error)

+ func (m *ResourceEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ResourceEventSource) Reset()

+ func (m *ResourceEventSource) Size() (n int)

+ func (m *ResourceEventSource) Unmarshal(dAtA []byte) error

+ func (m *ResourceEventSource) XXX_DiscardUnknown()

+ func (m *ResourceEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ResourceEventSource) XXX_Merge(src proto.Message)

+ func (m *ResourceEventSource) XXX_Size() int

+ func (m *ResourceEventSource) XXX_Unmarshal(b []byte) error

+ func (this *ResourceEventSource) String() string

type ResourceFilter

+ func (*ResourceFilter) Descriptor() ([]byte, []int)

+ func (*ResourceFilter) ProtoMessage()

+ func (m *ResourceFilter) Marshal() (dAtA []byte, err error)

+ func (m *ResourceFilter) MarshalTo(dAtA []byte) (int, error)

+ func (m *ResourceFilter) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ResourceFilter) Reset()

+ func (m *ResourceFilter) Size() (n int)

+ func (m *ResourceFilter) Unmarshal(dAtA []byte) error

+ func (m *ResourceFilter) XXX_DiscardUnknown()

+ func (m *ResourceFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ResourceFilter) XXX_Merge(src proto.Message)

+ func (m *ResourceFilter) XXX_Size() int

+ func (m *ResourceFilter) XXX_Unmarshal(b []byte) error

+ func (this *ResourceFilter) String() string

type SNSEventSource

+ func (*SNSEventSource) Descriptor() ([]byte, []int)

+ func (*SNSEventSource) ProtoMessage()

+ func (m *SNSEventSource) Marshal() (dAtA []byte, err error)

+ func (m *SNSEventSource) MarshalTo(dAtA []byte) (int, error)

+ func (m *SNSEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *SNSEventSource) Reset()

+ func (m *SNSEventSource) Size() (n int)

+ func (m *SNSEventSource) Unmarshal(dAtA []byte) error

+ func (m *SNSEventSource) XXX_DiscardUnknown()

+ func (m *SNSEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *SNSEventSource) XXX_Merge(src proto.Message)

+ func (m *SNSEventSource) XXX_Size() int

+ func (m *SNSEventSource) XXX_Unmarshal(b []byte) error

+ func (this *SNSEventSource) String() string

type SQSEventSource

+ QueueAccountID string

+ func (*SQSEventSource) Descriptor() ([]byte, []int)

+ func (*SQSEventSource) ProtoMessage()

+ func (m *SQSEventSource) Marshal() (dAtA []byte, err error)

+ func (m *SQSEventSource) MarshalTo(dAtA []byte) (int, error)

+ func (m *SQSEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *SQSEventSource) Reset()

+ func (m *SQSEventSource) Size() (n int)

+ func (m *SQSEventSource) Unmarshal(dAtA []byte) error

+ func (m *SQSEventSource) XXX_DiscardUnknown()

+ func (m *SQSEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *SQSEventSource) XXX_Merge(src proto.Message)

+ func (m *SQSEventSource) XXX_Size() int

+ func (m *SQSEventSource) XXX_Unmarshal(b []byte) error

+ func (this *SQSEventSource) String() string

type Selector

+ func (*Selector) Descriptor() ([]byte, []int)

+ func (*Selector) ProtoMessage()

+ func (m *Selector) Marshal() (dAtA []byte, err error)

+ func (m *Selector) MarshalTo(dAtA []byte) (int, error)

+ func (m *Selector) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Selector) Reset()

+ func (m *Selector) Size() (n int)

+ func (m *Selector) Unmarshal(dAtA []byte) error

+ func (m *Selector) XXX_DiscardUnknown()

+ func (m *Selector) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Selector) XXX_Merge(src proto.Message)

+ func (m *Selector) XXX_Size() int

+ func (m *Selector) XXX_Unmarshal(b []byte) error

+ func (this *Selector) String() string

+ type Service struct

+ ClusterIP string

+ Ports []corev1.ServicePort

+ func (*Service) Descriptor() ([]byte, []int)

+ func (*Service) ProtoMessage()

+ func (in *Service) DeepCopy() *Service

+ func (in *Service) DeepCopyInto(out *Service)

+ func (m *Service) Marshal() (dAtA []byte, err error)

+ func (m *Service) MarshalTo(dAtA []byte) (int, error)

+ func (m *Service) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Service) Reset()

+ func (m *Service) Size() (n int)

+ func (m *Service) Unmarshal(dAtA []byte) error

+ func (m *Service) XXX_DiscardUnknown()

+ func (m *Service) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Service) XXX_Merge(src proto.Message)

+ func (m *Service) XXX_Size() int

+ func (m *Service) XXX_Unmarshal(b []byte) error

+ func (this *Service) String() string

type SlackEventSource

+ func (*SlackEventSource) Descriptor() ([]byte, []int)

+ func (*SlackEventSource) ProtoMessage()

+ func (m *SlackEventSource) Marshal() (dAtA []byte, err error)

+ func (m *SlackEventSource) MarshalTo(dAtA []byte) (int, error)

+ func (m *SlackEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *SlackEventSource) Reset()

+ func (m *SlackEventSource) Size() (n int)

+ func (m *SlackEventSource) Unmarshal(dAtA []byte) error

+ func (m *SlackEventSource) XXX_DiscardUnknown()

+ func (m *SlackEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *SlackEventSource) XXX_Merge(src proto.Message)

+ func (m *SlackEventSource) XXX_Size() int

+ func (m *SlackEventSource) XXX_Unmarshal(b []byte) error

+ func (this *SlackEventSource) String() string

type StorageGridEventSource

+ APIURL string

+ func (*StorageGridEventSource) Descriptor() ([]byte, []int)

+ func (*StorageGridEventSource) ProtoMessage()

+ func (m *StorageGridEventSource) Marshal() (dAtA []byte, err error)

+ func (m *StorageGridEventSource) MarshalTo(dAtA []byte) (int, error)

+ func (m *StorageGridEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *StorageGridEventSource) Reset()

+ func (m *StorageGridEventSource) Size() (n int)

+ func (m *StorageGridEventSource) Unmarshal(dAtA []byte) error

+ func (m *StorageGridEventSource) XXX_DiscardUnknown()

+ func (m *StorageGridEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *StorageGridEventSource) XXX_Merge(src proto.Message)

+ func (m *StorageGridEventSource) XXX_Size() int

+ func (m *StorageGridEventSource) XXX_Unmarshal(b []byte) error

+ func (this *StorageGridEventSource) String() string

type StorageGridFilter

+ func (*StorageGridFilter) Descriptor() ([]byte, []int)

+ func (*StorageGridFilter) ProtoMessage()

+ func (m *StorageGridFilter) Marshal() (dAtA []byte, err error)

+ func (m *StorageGridFilter) MarshalTo(dAtA []byte) (int, error)

+ func (m *StorageGridFilter) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *StorageGridFilter) Reset()

+ func (m *StorageGridFilter) Size() (n int)

+ func (m *StorageGridFilter) Unmarshal(dAtA []byte) error

+ func (m *StorageGridFilter) XXX_DiscardUnknown()

+ func (m *StorageGridFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *StorageGridFilter) XXX_Merge(src proto.Message)

+ func (m *StorageGridFilter) XXX_Size() int

+ func (m *StorageGridFilter) XXX_Unmarshal(b []byte) error

+ func (this *StorageGridFilter) String() string

type StripeEventSource

+ func (*StripeEventSource) Descriptor() ([]byte, []int)

+ func (*StripeEventSource) ProtoMessage()

+ func (m *StripeEventSource) Marshal() (dAtA []byte, err error)

+ func (m *StripeEventSource) MarshalTo(dAtA []byte) (int, error)

+ func (m *StripeEventSource) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *StripeEventSource) Reset()

+ func (m *StripeEventSource) Size() (n int)

+ func (m *StripeEventSource) Unmarshal(dAtA []byte) error

+ func (m *StripeEventSource) XXX_DiscardUnknown()

+ func (m *StripeEventSource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *StripeEventSource) XXX_Merge(src proto.Message)

+ func (m *StripeEventSource) XXX_Size() int

+ func (m *StripeEventSource) XXX_Unmarshal(b []byte) error

+ func (this *StripeEventSource) String() string

type TLSConfig

+ func (*TLSConfig) Descriptor() ([]byte, []int)

+ func (*TLSConfig) ProtoMessage()

+ func (m *TLSConfig) Marshal() (dAtA []byte, err error)

+ func (m *TLSConfig) MarshalTo(dAtA []byte) (int, error)

+ func (m *TLSConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *TLSConfig) Reset()

+ func (m *TLSConfig) Size() (n int)

+ func (m *TLSConfig) Unmarshal(dAtA []byte) error

+ func (m *TLSConfig) XXX_DiscardUnknown()

+ func (m *TLSConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TLSConfig) XXX_Merge(src proto.Message)

+ func (m *TLSConfig) XXX_Size() int

+ func (m *TLSConfig) XXX_Unmarshal(b []byte) error

+ func (this *TLSConfig) String() string

+ type Template struct

+ Affinity *corev1.Affinity

+ Container *corev1.Container

+ Metadata Metadata

+ NodeSelector map[string]string

+ SecurityContext *corev1.PodSecurityContext

+ ServiceAccountName string

+ Tolerations []corev1.Toleration

+ Volumes []corev1.Volume

+ func (*Template) Descriptor() ([]byte, []int)

+ func (*Template) ProtoMessage()

+ func (in *Template) DeepCopy() *Template

+ func (in *Template) DeepCopyInto(out *Template)

+ func (m *Template) Marshal() (dAtA []byte, err error)

+ func (m *Template) MarshalTo(dAtA []byte) (int, error)

+ func (m *Template) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Template) Reset()

+ func (m *Template) Size() (n int)

+ func (m *Template) Unmarshal(dAtA []byte) error

+ func (m *Template) XXX_DiscardUnknown()

+ func (m *Template) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Template) XXX_Merge(src proto.Message)

+ func (m *Template) XXX_Size() int

+ func (m *Template) XXX_Unmarshal(b []byte) error

+ func (this *Template) String() string

+ type WatchPathConfig struct

+ Directory string

+ Path string

+ PathRegexp string

+ func (*WatchPathConfig) Descriptor() ([]byte, []int)

+ func (*WatchPathConfig) ProtoMessage()

+ func (c *WatchPathConfig) Validate() error

+ func (in *WatchPathConfig) DeepCopy() *WatchPathConfig

+ func (in *WatchPathConfig) DeepCopyInto(out *WatchPathConfig)

+ func (m *WatchPathConfig) Marshal() (dAtA []byte, err error)

+ func (m *WatchPathConfig) MarshalTo(dAtA []byte) (int, error)

+ func (m *WatchPathConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *WatchPathConfig) Reset()

+ func (m *WatchPathConfig) Size() (n int)

+ func (m *WatchPathConfig) Unmarshal(dAtA []byte) error

+ func (m *WatchPathConfig) XXX_DiscardUnknown()

+ func (m *WatchPathConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *WatchPathConfig) XXX_Merge(src proto.Message)

+ func (m *WatchPathConfig) XXX_Size() int

+ func (m *WatchPathConfig) XXX_Unmarshal(b []byte) error

+ func (this *WatchPathConfig) String() string

+ type WebhookContext struct

+ Endpoint string

+ Method string

+ Port string

+ ServerCertPath string

+ ServerKeyPath string

+ URL string

+ func (*WebhookContext) Descriptor() ([]byte, []int)

+ func (*WebhookContext) ProtoMessage()

+ func (in *WebhookContext) DeepCopy() *WebhookContext

+ func (in *WebhookContext) DeepCopyInto(out *WebhookContext)

+ func (m *WebhookContext) Marshal() (dAtA []byte, err error)

+ func (m *WebhookContext) MarshalTo(dAtA []byte) (int, error)

+ func (m *WebhookContext) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *WebhookContext) Reset()

+ func (m *WebhookContext) Size() (n int)

+ func (m *WebhookContext) Unmarshal(dAtA []byte) error

+ func (m *WebhookContext) XXX_DiscardUnknown()

+ func (m *WebhookContext) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *WebhookContext) XXX_Merge(src proto.Message)

+ func (m *WebhookContext) XXX_Size() int

+ func (m *WebhookContext) XXX_Unmarshal(b []byte) error

+ func (this *WebhookContext) String() string

Jun 14, 2020 GO-2022-0492

  GO-2022-0492: Path traversal in github.com/argoproj/argo-events

Changes in this version

+ var AddToScheme = SchemeBuilder.AddToScheme

+ var SchemaGroupVersionKind = schema.GroupVersionKind

+ var SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes)

+ var SchemeGroupVersion = schema.GroupVersion

+ 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

+ func ValidateTLSConfig(tlsConfig *TLSConfig) error

+ type AMQPEventSource struct

+ ConnectionBackoff *common.Backoff

+ ExchangeName string

+ ExchangeType string

+ JSONBody bool

+ RoutingKey string

+ TLS *TLSConfig

+ URL string

+ func (in *AMQPEventSource) DeepCopy() *AMQPEventSource

+ func (in *AMQPEventSource) DeepCopyInto(out *AMQPEventSource)

+ type AzureEventsHubEventSource struct

+ FQDN string

+ HubName string

+ Namespace string

+ SharedAccessKey *corev1.SecretKeySelector

+ SharedAccessKeyName *corev1.SecretKeySelector

+ func (in *AzureEventsHubEventSource) DeepCopy() *AzureEventsHubEventSource

+ func (in *AzureEventsHubEventSource) DeepCopyInto(out *AzureEventsHubEventSource)

+ type CalendarEventSource struct

+ ExclusionDates []string

+ Interval string

+ Schedule string

+ Timezone string

+ UserPayload *json.RawMessage

+ func (in *CalendarEventSource) DeepCopy() *CalendarEventSource

+ func (in *CalendarEventSource) DeepCopyInto(out *CalendarEventSource)

+ type EmitterEventSource struct

+ Broker string

+ ChannelKey string

+ ChannelName string

+ ConnectionBackoff *common.Backoff

+ JSONBody bool

+ Namespace string

+ Password *corev1.SecretKeySelector

+ TLS *TLSConfig

+ Username *corev1.SecretKeySelector

+ func (in *EmitterEventSource) DeepCopy() *EmitterEventSource

+ func (in *EmitterEventSource) DeepCopyInto(out *EmitterEventSource)

+ type EventSource struct

+ Spec *EventSourceSpec

+ Status EventSourceStatus

+ func (in *EventSource) DeepCopy() *EventSource

+ func (in *EventSource) DeepCopyInto(out *EventSource)

+ func (in *EventSource) DeepCopyObject() runtime.Object

+ type EventSourceList struct

+ Items []EventSource

+ func (in *EventSourceList) DeepCopy() *EventSourceList

+ func (in *EventSourceList) DeepCopyInto(out *EventSourceList)

+ func (in *EventSourceList) DeepCopyObject() runtime.Object

+ type EventSourceSpec struct

+ AMQP map[string]AMQPEventSource

+ AzureEventsHub map[string]AzureEventsHubEventSource

+ Calendar map[string]CalendarEventSource

+ Emitter map[string]EmitterEventSource

+ File map[string]FileEventSource

+ Generic map[string]GenericEventSource

+ Github map[string]GithubEventSource

+ Gitlab map[string]GitlabEventSource

+ HDFS map[string]HDFSEventSource

+ Kafka map[string]KafkaEventSource

+ MQTT map[string]MQTTEventSource

+ Minio map[string]apicommon.S3Artifact

+ NATS map[string]NATSEventsSource

+ NSQ map[string]NSQEventSource

+ PubSub map[string]PubSubEventSource

+ Redis map[string]RedisEventSource

+ Resource map[string]ResourceEventSource

+ SNS map[string]SNSEventSource

+ SQS map[string]SQSEventSource

+ Slack map[string]SlackEventSource

+ StorageGrid map[string]StorageGridEventSource

+ Stripe map[string]StripeEventSource

+ Type apicommon.EventSourceType

+ Webhook map[string]webhook.Context

+ func (in *EventSourceSpec) DeepCopy() *EventSourceSpec

+ func (in *EventSourceSpec) DeepCopyInto(out *EventSourceSpec)

+ type EventSourceStatus struct

+ CreatedAt metav1.Time

+ func (in *EventSourceStatus) DeepCopy() *EventSourceStatus

+ func (in *EventSourceStatus) DeepCopyInto(out *EventSourceStatus)

+ type FileEventSource struct

+ EventType string

+ Polling bool

+ WatchPathConfig fsevent.WatchPathConfig

+ func (in *FileEventSource) DeepCopy() *FileEventSource

+ func (in *FileEventSource) DeepCopyInto(out *FileEventSource)

+ type GenericEventSource struct

+ Value string

+ func (in *GenericEventSource) DeepCopy() *GenericEventSource

+ func (in *GenericEventSource) DeepCopyInto(out *GenericEventSource)

+ type GithubEventSource struct

+ APIToken *corev1.SecretKeySelector

+ Active bool

+ ContentType string

+ DeleteHookOnFinish bool

+ Events []string

+ GithubBaseURL string

+ GithubUploadURL string

+ Id int64

+ Insecure bool

+ Namespace string

+ Owner string

+ Repository string

+ Webhook *webhook.Context

+ WebhookSecret *corev1.SecretKeySelector

+ func (in *GithubEventSource) DeepCopy() *GithubEventSource

+ func (in *GithubEventSource) DeepCopyInto(out *GithubEventSource)

+ type GitlabEventSource struct

+ AccessToken *corev1.SecretKeySelector

+ DeleteHookOnFinish bool

+ EnableSSLVerification bool

+ Events []string

+ GitlabBaseURL string

+ ProjectID string

+ Webhook *webhook.Context

+ func (in *GitlabEventSource) DeepCopy() *GitlabEventSource

+ func (in *GitlabEventSource) DeepCopyInto(out *GitlabEventSource)

+ type HDFSEventSource struct

+ Addresses []string

+ CheckInterval string

+ HDFSUser string

+ KrbCCacheSecret *corev1.SecretKeySelector

+ KrbConfigConfigMap *corev1.ConfigMapKeySelector

+ KrbKeytabSecret *corev1.SecretKeySelector

+ KrbRealm string

+ KrbServicePrincipalName string

+ KrbUsername string

+ Namespace string

+ Type string

+ func (in *HDFSEventSource) DeepCopy() *HDFSEventSource

+ func (in *HDFSEventSource) DeepCopyInto(out *HDFSEventSource)

+ type KafkaEventSource struct

+ ConnectionBackoff *common.Backoff

+ Partition string

+ TLS *TLSConfig

+ Topic string

+ URL string

+ func (in *KafkaEventSource) DeepCopy() *KafkaEventSource

+ func (in *KafkaEventSource) DeepCopyInto(out *KafkaEventSource)

+ type MQTTEventSource struct

+ ClientId string

+ ConnectionBackoff *common.Backoff

+ JSONBody bool

+ TLS *TLSConfig

+ Topic string

+ URL string

+ func (in *MQTTEventSource) DeepCopy() *MQTTEventSource

+ func (in *MQTTEventSource) DeepCopyInto(out *MQTTEventSource)

+ type NATSEventsSource struct

+ ConnectionBackoff *common.Backoff

+ JSONBody bool

+ Subject string

+ TLS *TLSConfig

+ URL string

+ func (in *NATSEventsSource) DeepCopy() *NATSEventsSource

+ func (in *NATSEventsSource) DeepCopyInto(out *NATSEventsSource)

+ type NSQEventSource struct

+ Channel string

+ ConnectionBackoff *common.Backoff

+ HostAddress string

+ JSONBody bool

+ TLS *TLSConfig

+ Topic string

+ func (in *NSQEventSource) DeepCopy() *NSQEventSource

+ func (in *NSQEventSource) DeepCopyInto(out *NSQEventSource)

+ type PubSubEventSource struct

+ CredentialsFile string

+ DeleteSubscriptionOnFinish bool

+ EnableWorkflowIdentity bool

+ JSONBody bool

+ ProjectID string

+ Topic string

+ TopicProjectID string

+ func (in *PubSubEventSource) DeepCopy() *PubSubEventSource

+ func (in *PubSubEventSource) DeepCopyInto(out *PubSubEventSource)

+ type RedisEventSource struct

+ Channels []string

+ DB int

+ HostAddress string

+ Namespace string

+ Password *corev1.SecretKeySelector

+ TLS *TLSConfig

+ func (in *RedisEventSource) DeepCopy() *RedisEventSource

+ func (in *RedisEventSource) DeepCopyInto(out *RedisEventSource)

+ type ResourceEventSource struct

+ EventTypes []ResourceEventType

+ Filter *ResourceFilter

+ Namespace string

+ func (in *ResourceEventSource) DeepCopy() *ResourceEventSource

+ func (in *ResourceEventSource) DeepCopyInto(out *ResourceEventSource)

+ type ResourceEventType string

+ const ADD

+ const DELETE

+ const UPDATE

+ type ResourceFilter struct

+ AfterStart bool

+ CreatedBy metav1.Time

+ Fields []Selector

+ Labels []Selector

+ Prefix string

+ func (in *ResourceFilter) DeepCopy() *ResourceFilter

+ func (in *ResourceFilter) DeepCopyInto(out *ResourceFilter)

+ type SNSEventSource struct

+ AccessKey *corev1.SecretKeySelector

+ Namespace string

+ Region string

+ RoleARN string

+ SecretKey *corev1.SecretKeySelector

+ TopicArn string

+ Webhook *webhook.Context

+ func (in *SNSEventSource) DeepCopy() *SNSEventSource

+ func (in *SNSEventSource) DeepCopyInto(out *SNSEventSource)

+ type SQSEventSource struct

+ AccessKey *corev1.SecretKeySelector

+ JSONBody bool

+ Namespace string

+ Queue string

+ QueueAccountId string

+ Region string

+ RoleARN string

+ SecretKey *corev1.SecretKeySelector

+ WaitTimeSeconds int64

+ func (in *SQSEventSource) DeepCopy() *SQSEventSource

+ func (in *SQSEventSource) DeepCopyInto(out *SQSEventSource)

+ type Selector struct

+ Key string

+ Operation string

+ Value string

+ func (in *Selector) DeepCopy() *Selector

+ func (in *Selector) DeepCopyInto(out *Selector)

+ type SlackEventSource struct

+ Namespace string

+ SigningSecret *corev1.SecretKeySelector

+ Token *corev1.SecretKeySelector

+ Webhook *webhook.Context

+ func (in *SlackEventSource) DeepCopy() *SlackEventSource

+ func (in *SlackEventSource) DeepCopyInto(out *SlackEventSource)

+ type StorageGridEventSource struct

+ ApiURL string

+ AuthToken *corev1.SecretKeySelector

+ Bucket string

+ Events []string

+ Filter *StorageGridFilter

+ Region string

+ TopicArn string

+ Webhook *webhook.Context

+ func (in *StorageGridEventSource) DeepCopy() *StorageGridEventSource

+ func (in *StorageGridEventSource) DeepCopyInto(out *StorageGridEventSource)

+ type StorageGridFilter struct

+ Prefix string

+ Suffix string

+ func (in *StorageGridFilter) DeepCopy() *StorageGridFilter

+ func (in *StorageGridFilter) DeepCopyInto(out *StorageGridFilter)

+ type StripeEventSource struct

+ APIKey *corev1.SecretKeySelector

+ CreateWebhook bool

+ EventFilter []string

+ Namespace string

+ Webhook *webhook.Context

+ func (in *StripeEventSource) DeepCopy() *StripeEventSource

+ func (in *StripeEventSource) DeepCopyInto(out *StripeEventSource)

+ type TLSConfig struct

+ CACertPath string

+ ClientCertPath string

+ ClientKeyPath string

+ func (in *TLSConfig) DeepCopy() *TLSConfig

+ func (in *TLSConfig) DeepCopyInto(out *TLSConfig)