components

package

Go to main page

Versions in this module

v0

v0.4.0

Sep 3, 2025

Changes in this version

type AWSKinesisConfig

+ func (a *AWSKinesisConfig) UnmarshalJSON(data []byte) error

+ func (a AWSKinesisConfig) MarshalJSON() ([]byte, error)

type AWSKinesisCredentials

+ func (a *AWSKinesisCredentials) UnmarshalJSON(data []byte) error

+ func (a AWSKinesisCredentials) MarshalJSON() ([]byte, error)

type AWSSQSConfig

+ func (a *AWSSQSConfig) UnmarshalJSON(data []byte) error

+ func (a AWSSQSConfig) MarshalJSON() ([]byte, error)

type AWSSQSCredentials

+ func (a *AWSSQSCredentials) UnmarshalJSON(data []byte) error

+ func (a AWSSQSCredentials) MarshalJSON() ([]byte, error)

+ type Awss3Config struct

+ Bucket string

+ KeyTemplate *string

+ Region string

+ StorageClass *string

+ func (a *Awss3Config) UnmarshalJSON(data []byte) error

+ func (a Awss3Config) MarshalJSON() ([]byte, error)

+ func (o *Awss3Config) GetBucket() string

+ func (o *Awss3Config) GetKeyTemplate() *string

+ func (o *Awss3Config) GetRegion() string

+ func (o *Awss3Config) GetStorageClass() *string

+ type Awss3Credentials struct

+ Key string

+ Secret string

+ Session *string

+ func (a *Awss3Credentials) UnmarshalJSON(data []byte) error

+ func (a Awss3Credentials) MarshalJSON() ([]byte, error)

+ func (o *Awss3Credentials) GetKey() string

+ func (o *Awss3Credentials) GetSecret() string

+ func (o *Awss3Credentials) GetSession() *string

type AzureServiceBusConfig

+ func (a *AzureServiceBusConfig) UnmarshalJSON(data []byte) error

+ func (a AzureServiceBusConfig) MarshalJSON() ([]byte, error)

type AzureServiceBusCredentials

+ func (a *AzureServiceBusCredentials) UnmarshalJSON(data []byte) error

+ func (a AzureServiceBusCredentials) MarshalJSON() ([]byte, error)

type Destination

+ DestinationAwss3 *DestinationAwss3

+ func CreateDestinationAwsS3(awsS3 DestinationAwss3) Destination

+ type DestinationAwss3 struct

+ Config Awss3Config

+ CreatedAt time.Time

+ Credentials Awss3Credentials

+ DisabledAt *time.Time

+ ID string

+ Target *string

+ TargetURL *string

+ Topics Topics

+ Type DestinationAwss3Type

+ func (d *DestinationAwss3) UnmarshalJSON(data []byte) error

+ func (d DestinationAwss3) MarshalJSON() ([]byte, error)

+ func (o *DestinationAwss3) GetConfig() Awss3Config

+ func (o *DestinationAwss3) GetCreatedAt() time.Time

+ func (o *DestinationAwss3) GetCredentials() Awss3Credentials

+ func (o *DestinationAwss3) GetDisabledAt() *time.Time

+ func (o *DestinationAwss3) GetID() string

+ func (o *DestinationAwss3) GetTarget() *string

+ func (o *DestinationAwss3) GetTargetURL() *string

+ func (o *DestinationAwss3) GetTopics() Topics

+ func (o *DestinationAwss3) GetType() DestinationAwss3Type

+ type DestinationAwss3Type string

+ const DestinationAwss3TypeAwsS3

+ func (e *DestinationAwss3Type) UnmarshalJSON(data []byte) error

+ func (e DestinationAwss3Type) ToPointer() *DestinationAwss3Type

type DestinationCreate

+ DestinationCreateAwss3 *DestinationCreateAwss3

+ func CreateDestinationCreateAwsS3(awsS3 DestinationCreateAwss3) DestinationCreate

type DestinationCreateAWSKinesis

+ func (d *DestinationCreateAWSKinesis) UnmarshalJSON(data []byte) error

+ func (d DestinationCreateAWSKinesis) MarshalJSON() ([]byte, error)

type DestinationCreateAWSSQS

+ func (d *DestinationCreateAWSSQS) UnmarshalJSON(data []byte) error

+ func (d DestinationCreateAWSSQS) MarshalJSON() ([]byte, error)

+ type DestinationCreateAwss3 struct

+ Config Awss3Config

+ Credentials Awss3Credentials

+ ID *string

+ Topics Topics

+ Type DestinationCreateAwss3Type

+ func (d *DestinationCreateAwss3) UnmarshalJSON(data []byte) error

+ func (d DestinationCreateAwss3) MarshalJSON() ([]byte, error)

+ func (o *DestinationCreateAwss3) GetConfig() Awss3Config

+ func (o *DestinationCreateAwss3) GetCredentials() Awss3Credentials

+ func (o *DestinationCreateAwss3) GetID() *string

+ func (o *DestinationCreateAwss3) GetTopics() Topics

+ func (o *DestinationCreateAwss3) GetType() DestinationCreateAwss3Type

+ type DestinationCreateAwss3Type string

+ const DestinationCreateAwss3TypeAwsS3

+ func (e *DestinationCreateAwss3Type) UnmarshalJSON(data []byte) error

+ func (e DestinationCreateAwss3Type) ToPointer() *DestinationCreateAwss3Type

type DestinationCreateAzureServiceBus

+ func (d *DestinationCreateAzureServiceBus) UnmarshalJSON(data []byte) error

+ func (d DestinationCreateAzureServiceBus) MarshalJSON() ([]byte, error)

type DestinationCreateHookdeck

+ func (d *DestinationCreateHookdeck) UnmarshalJSON(data []byte) error

+ func (d DestinationCreateHookdeck) MarshalJSON() ([]byte, error)

type DestinationCreateRabbitMQ

+ func (d *DestinationCreateRabbitMQ) UnmarshalJSON(data []byte) error

+ func (d DestinationCreateRabbitMQ) MarshalJSON() ([]byte, error)

type DestinationCreateType

+ const DestinationCreateTypeAwsS3

type DestinationCreateWebhook

+ func (d *DestinationCreateWebhook) UnmarshalJSON(data []byte) error

+ func (d DestinationCreateWebhook) MarshalJSON() ([]byte, error)

type DestinationType

+ const DestinationTypeAwsS3

type DestinationUpdate

+ DestinationUpdateAwss3 *DestinationUpdateAwss3

+ func CreateDestinationUpdateDestinationUpdateAwss3(destinationUpdateAwss3 DestinationUpdateAwss3) DestinationUpdate

type DestinationUpdateAWSKinesis

+ func (d *DestinationUpdateAWSKinesis) UnmarshalJSON(data []byte) error

+ func (d DestinationUpdateAWSKinesis) MarshalJSON() ([]byte, error)

type DestinationUpdateAWSSQS

+ func (d *DestinationUpdateAWSSQS) UnmarshalJSON(data []byte) error

+ func (d DestinationUpdateAWSSQS) MarshalJSON() ([]byte, error)

+ type DestinationUpdateAwss3 struct

+ Config *Awss3Config

+ Credentials *Awss3Credentials

+ Topics *Topics

+ func (d *DestinationUpdateAwss3) UnmarshalJSON(data []byte) error

+ func (d DestinationUpdateAwss3) MarshalJSON() ([]byte, error)

+ func (o *DestinationUpdateAwss3) GetConfig() *Awss3Config

+ func (o *DestinationUpdateAwss3) GetCredentials() *Awss3Credentials

+ func (o *DestinationUpdateAwss3) GetTopics() *Topics

type DestinationUpdateHookdeck

+ func (d *DestinationUpdateHookdeck) UnmarshalJSON(data []byte) error

+ func (d DestinationUpdateHookdeck) MarshalJSON() ([]byte, error)

type DestinationUpdateRabbitMQ

+ func (d *DestinationUpdateRabbitMQ) UnmarshalJSON(data []byte) error

+ func (d DestinationUpdateRabbitMQ) MarshalJSON() ([]byte, error)

type DestinationUpdateType

+ const DestinationUpdateTypeDestinationUpdateAwss3

type DestinationUpdateWebhook

+ func (d *DestinationUpdateWebhook) UnmarshalJSON(data []byte) error

+ func (d DestinationUpdateWebhook) MarshalJSON() ([]byte, error)

type HookdeckCredentials

+ func (h *HookdeckCredentials) UnmarshalJSON(data []byte) error

+ func (h HookdeckCredentials) MarshalJSON() ([]byte, error)

type RabbitMQConfig

+ func (r *RabbitMQConfig) UnmarshalJSON(data []byte) error

+ func (r RabbitMQConfig) MarshalJSON() ([]byte, error)

type RabbitMQCredentials

+ func (r *RabbitMQCredentials) UnmarshalJSON(data []byte) error

+ func (r RabbitMQCredentials) MarshalJSON() ([]byte, error)

type WebhookConfig

+ func (w *WebhookConfig) UnmarshalJSON(data []byte) error

+ func (w WebhookConfig) MarshalJSON() ([]byte, error)

v0.3.0

Jul 31, 2025

Changes in this version

+ type AzureServiceBusConfig struct

+ Name string

+ func (o *AzureServiceBusConfig) GetName() string

+ type AzureServiceBusCredentials struct

+ ConnectionString string

+ func (o *AzureServiceBusCredentials) GetConnectionString() string

type Destination

+ DestinationAzureServiceBus *DestinationAzureServiceBus

+ func CreateDestinationAzureServicebus(azureServicebus DestinationAzureServiceBus) Destination

+ type DestinationAzureServiceBus struct

+ Config AzureServiceBusConfig

+ CreatedAt time.Time

+ Credentials AzureServiceBusCredentials

+ DisabledAt *time.Time

+ ID string

+ Target *string

+ TargetURL *string

+ Topics Topics

+ Type DestinationAzureServiceBusType

+ func (d *DestinationAzureServiceBus) UnmarshalJSON(data []byte) error

+ func (d DestinationAzureServiceBus) MarshalJSON() ([]byte, error)

+ func (o *DestinationAzureServiceBus) GetConfig() AzureServiceBusConfig

+ func (o *DestinationAzureServiceBus) GetCreatedAt() time.Time

+ func (o *DestinationAzureServiceBus) GetCredentials() AzureServiceBusCredentials

+ func (o *DestinationAzureServiceBus) GetDisabledAt() *time.Time

+ func (o *DestinationAzureServiceBus) GetID() string

+ func (o *DestinationAzureServiceBus) GetTarget() *string

+ func (o *DestinationAzureServiceBus) GetTargetURL() *string

+ func (o *DestinationAzureServiceBus) GetTopics() Topics

+ func (o *DestinationAzureServiceBus) GetType() DestinationAzureServiceBusType

+ type DestinationAzureServiceBusType string

+ const DestinationAzureServiceBusTypeAzureServicebus

+ func (e *DestinationAzureServiceBusType) UnmarshalJSON(data []byte) error

+ func (e DestinationAzureServiceBusType) ToPointer() *DestinationAzureServiceBusType

type DestinationCreate

+ DestinationCreateAzureServiceBus *DestinationCreateAzureServiceBus

+ func CreateDestinationCreateAzureServicebus(azureServicebus DestinationCreateAzureServiceBus) DestinationCreate

+ type DestinationCreateAzureServiceBus struct

+ Config AzureServiceBusConfig

+ Credentials AzureServiceBusCredentials

+ ID *string

+ Topics Topics

+ Type DestinationCreateAzureServiceBusType

+ func (o *DestinationCreateAzureServiceBus) GetConfig() AzureServiceBusConfig

+ func (o *DestinationCreateAzureServiceBus) GetCredentials() AzureServiceBusCredentials

+ func (o *DestinationCreateAzureServiceBus) GetID() *string

+ func (o *DestinationCreateAzureServiceBus) GetTopics() Topics

+ func (o *DestinationCreateAzureServiceBus) GetType() DestinationCreateAzureServiceBusType

+ type DestinationCreateAzureServiceBusType string

+ const DestinationCreateAzureServiceBusTypeAzureServicebus

+ func (e *DestinationCreateAzureServiceBusType) UnmarshalJSON(data []byte) error

+ func (e DestinationCreateAzureServiceBusType) ToPointer() *DestinationCreateAzureServiceBusType

type DestinationCreateType

+ const DestinationCreateTypeAzureServicebus

type DestinationType

+ const DestinationTypeAzureServicebus

v0.2.1

May 20, 2025

Changes in this version

+ type PublishResponse struct

+ ID string

+ func (o *PublishResponse) GetID() string

v0.2.0

May 19, 2025

Changes in this version

type PublishRequest

+ ID *string

+ func (o *PublishRequest) GetID() *string

v0.1.7

May 9, 2025

Changes in this version

+ type AWSKinesisConfig struct

+ Endpoint *string

+ PartitionKeyTemplate *string

+ Region string

+ StreamName string

+ func (o *AWSKinesisConfig) GetEndpoint() *string

+ func (o *AWSKinesisConfig) GetPartitionKeyTemplate() *string

+ func (o *AWSKinesisConfig) GetRegion() string

+ func (o *AWSKinesisConfig) GetStreamName() string

+ type AWSKinesisCredentials struct

+ Key string

+ Secret string

+ Session *string

+ func (o *AWSKinesisCredentials) GetKey() string

+ func (o *AWSKinesisCredentials) GetSecret() string

+ func (o *AWSKinesisCredentials) GetSession() *string

+ type AWSSQSConfig struct

+ Endpoint *string

+ QueueURL string

+ func (o *AWSSQSConfig) GetEndpoint() *string

+ func (o *AWSSQSConfig) GetQueueURL() string

+ type AWSSQSCredentials struct

+ Key string

+ Secret string

+ Session *string

+ func (o *AWSSQSCredentials) GetKey() string

+ func (o *AWSSQSCredentials) GetSecret() string

+ func (o *AWSSQSCredentials) GetSession() *string

+ type DeliveryAttempt struct

+ DeliveredAt *time.Time

+ ResponseBody *string

+ ResponseHeaders map[string]string

+ ResponseStatusCode *int64

+ Status *Status

+ func (d *DeliveryAttempt) UnmarshalJSON(data []byte) error

+ func (d DeliveryAttempt) MarshalJSON() ([]byte, error)

+ func (o *DeliveryAttempt) GetDeliveredAt() *time.Time

+ func (o *DeliveryAttempt) GetResponseBody() *string

+ func (o *DeliveryAttempt) GetResponseHeaders() map[string]string

+ func (o *DeliveryAttempt) GetResponseStatusCode() *int64

+ func (o *DeliveryAttempt) GetStatus() *Status

+ type Destination struct

+ DestinationAWSKinesis *DestinationAWSKinesis

+ DestinationAWSSQS *DestinationAWSSQS

+ DestinationHookdeck *DestinationHookdeck

+ DestinationRabbitMQ *DestinationRabbitMQ

+ DestinationWebhook *DestinationWebhook

+ Type DestinationType

+ func CreateDestinationAwsKinesis(awsKinesis DestinationAWSKinesis) Destination

+ func CreateDestinationAwsSqs(awsSqs DestinationAWSSQS) Destination

+ func CreateDestinationHookdeck(hookdeck DestinationHookdeck) Destination

+ func CreateDestinationRabbitmq(rabbitmq DestinationRabbitMQ) Destination

+ func CreateDestinationWebhook(webhook DestinationWebhook) Destination

+ func (u *Destination) UnmarshalJSON(data []byte) error

+ func (u Destination) MarshalJSON() ([]byte, error)

+ type DestinationAWSKinesis struct

+ Config AWSKinesisConfig

+ CreatedAt time.Time

+ Credentials AWSKinesisCredentials

+ DisabledAt *time.Time

+ ID string

+ Target *string

+ TargetURL *string

+ Topics Topics

+ Type DestinationAWSKinesisType

+ func (d *DestinationAWSKinesis) UnmarshalJSON(data []byte) error

+ func (d DestinationAWSKinesis) MarshalJSON() ([]byte, error)

+ func (o *DestinationAWSKinesis) GetConfig() AWSKinesisConfig

+ func (o *DestinationAWSKinesis) GetCreatedAt() time.Time

+ func (o *DestinationAWSKinesis) GetCredentials() AWSKinesisCredentials

+ func (o *DestinationAWSKinesis) GetDisabledAt() *time.Time

+ func (o *DestinationAWSKinesis) GetID() string

+ func (o *DestinationAWSKinesis) GetTarget() *string

+ func (o *DestinationAWSKinesis) GetTargetURL() *string

+ func (o *DestinationAWSKinesis) GetTopics() Topics

+ func (o *DestinationAWSKinesis) GetType() DestinationAWSKinesisType

+ type DestinationAWSKinesisType string

+ const DestinationAWSKinesisTypeAwsKinesis

+ func (e *DestinationAWSKinesisType) UnmarshalJSON(data []byte) error

+ func (e DestinationAWSKinesisType) ToPointer() *DestinationAWSKinesisType

+ type DestinationAWSSQS struct

+ Config AWSSQSConfig

+ CreatedAt time.Time

+ Credentials AWSSQSCredentials

+ DisabledAt *time.Time

+ ID string

+ Target *string

+ TargetURL *string

+ Topics Topics

+ Type DestinationAWSSQSType

+ func (d *DestinationAWSSQS) UnmarshalJSON(data []byte) error

+ func (d DestinationAWSSQS) MarshalJSON() ([]byte, error)

+ func (o *DestinationAWSSQS) GetConfig() AWSSQSConfig

+ func (o *DestinationAWSSQS) GetCreatedAt() time.Time

+ func (o *DestinationAWSSQS) GetCredentials() AWSSQSCredentials

+ func (o *DestinationAWSSQS) GetDisabledAt() *time.Time

+ func (o *DestinationAWSSQS) GetID() string

+ func (o *DestinationAWSSQS) GetTarget() *string

+ func (o *DestinationAWSSQS) GetTargetURL() *string

+ func (o *DestinationAWSSQS) GetTopics() Topics

+ func (o *DestinationAWSSQS) GetType() DestinationAWSSQSType

+ type DestinationAWSSQSType string

+ const DestinationAWSSQSTypeAwsSqs

+ func (e *DestinationAWSSQSType) UnmarshalJSON(data []byte) error

+ func (e DestinationAWSSQSType) ToPointer() *DestinationAWSSQSType

+ type DestinationCreate struct

+ DestinationCreateAWSKinesis *DestinationCreateAWSKinesis

+ DestinationCreateAWSSQS *DestinationCreateAWSSQS

+ DestinationCreateHookdeck *DestinationCreateHookdeck

+ DestinationCreateRabbitMQ *DestinationCreateRabbitMQ

+ DestinationCreateWebhook *DestinationCreateWebhook

+ Type DestinationCreateType

+ func CreateDestinationCreateAwsKinesis(awsKinesis DestinationCreateAWSKinesis) DestinationCreate

+ func CreateDestinationCreateAwsSqs(awsSqs DestinationCreateAWSSQS) DestinationCreate

+ func CreateDestinationCreateHookdeck(hookdeck DestinationCreateHookdeck) DestinationCreate

+ func CreateDestinationCreateRabbitmq(rabbitmq DestinationCreateRabbitMQ) DestinationCreate

+ func CreateDestinationCreateWebhook(webhook DestinationCreateWebhook) DestinationCreate

+ func (u *DestinationCreate) UnmarshalJSON(data []byte) error

+ func (u DestinationCreate) MarshalJSON() ([]byte, error)

+ type DestinationCreateAWSKinesis struct

+ Config AWSKinesisConfig

+ Credentials AWSKinesisCredentials

+ ID *string

+ Topics Topics

+ Type DestinationCreateAWSKinesisType

+ func (o *DestinationCreateAWSKinesis) GetConfig() AWSKinesisConfig

+ func (o *DestinationCreateAWSKinesis) GetCredentials() AWSKinesisCredentials

+ func (o *DestinationCreateAWSKinesis) GetID() *string

+ func (o *DestinationCreateAWSKinesis) GetTopics() Topics

+ func (o *DestinationCreateAWSKinesis) GetType() DestinationCreateAWSKinesisType

+ type DestinationCreateAWSKinesisType string

+ const DestinationCreateAWSKinesisTypeAwsKinesis

+ func (e *DestinationCreateAWSKinesisType) UnmarshalJSON(data []byte) error

+ func (e DestinationCreateAWSKinesisType) ToPointer() *DestinationCreateAWSKinesisType

+ type DestinationCreateAWSSQS struct

+ Config AWSSQSConfig

+ Credentials AWSSQSCredentials

+ ID *string

+ Topics Topics

+ Type DestinationCreateAWSSQSType

+ func (o *DestinationCreateAWSSQS) GetConfig() AWSSQSConfig

+ func (o *DestinationCreateAWSSQS) GetCredentials() AWSSQSCredentials

+ func (o *DestinationCreateAWSSQS) GetID() *string

+ func (o *DestinationCreateAWSSQS) GetTopics() Topics

+ func (o *DestinationCreateAWSSQS) GetType() DestinationCreateAWSSQSType

+ type DestinationCreateAWSSQSType string

+ const DestinationCreateAWSSQSTypeAwsSqs

+ func (e *DestinationCreateAWSSQSType) UnmarshalJSON(data []byte) error

+ func (e DestinationCreateAWSSQSType) ToPointer() *DestinationCreateAWSSQSType

+ type DestinationCreateHookdeck struct

+ Config any

+ Credentials HookdeckCredentials

+ ID *string

+ Topics Topics

+ Type DestinationCreateHookdeckType

+ func (o *DestinationCreateHookdeck) GetConfig() any

+ func (o *DestinationCreateHookdeck) GetCredentials() HookdeckCredentials

+ func (o *DestinationCreateHookdeck) GetID() *string

+ func (o *DestinationCreateHookdeck) GetTopics() Topics

+ func (o *DestinationCreateHookdeck) GetType() DestinationCreateHookdeckType

+ type DestinationCreateHookdeckType string

+ const DestinationCreateHookdeckTypeHookdeck

+ func (e *DestinationCreateHookdeckType) UnmarshalJSON(data []byte) error

+ func (e DestinationCreateHookdeckType) ToPointer() *DestinationCreateHookdeckType

+ type DestinationCreateRabbitMQ struct

+ Config RabbitMQConfig

+ Credentials RabbitMQCredentials

+ ID *string

+ Topics Topics

+ Type DestinationCreateRabbitMQType

+ func (o *DestinationCreateRabbitMQ) GetConfig() RabbitMQConfig

+ func (o *DestinationCreateRabbitMQ) GetCredentials() RabbitMQCredentials

+ func (o *DestinationCreateRabbitMQ) GetID() *string

+ func (o *DestinationCreateRabbitMQ) GetTopics() Topics

+ func (o *DestinationCreateRabbitMQ) GetType() DestinationCreateRabbitMQType

+ type DestinationCreateRabbitMQType string

+ const DestinationCreateRabbitMQTypeRabbitmq

+ func (e *DestinationCreateRabbitMQType) UnmarshalJSON(data []byte) error

+ func (e DestinationCreateRabbitMQType) ToPointer() *DestinationCreateRabbitMQType

+ type DestinationCreateType string

+ const DestinationCreateTypeAwsKinesis

+ const DestinationCreateTypeAwsSqs

+ const DestinationCreateTypeHookdeck

+ const DestinationCreateTypeRabbitmq

+ const DestinationCreateTypeWebhook

+ type DestinationCreateWebhook struct

+ Config WebhookConfig

+ Credentials *WebhookCredentials

+ ID *string

+ Topics Topics

+ Type DestinationCreateWebhookType

+ func (o *DestinationCreateWebhook) GetConfig() WebhookConfig

+ func (o *DestinationCreateWebhook) GetCredentials() *WebhookCredentials

+ func (o *DestinationCreateWebhook) GetID() *string

+ func (o *DestinationCreateWebhook) GetTopics() Topics

+ func (o *DestinationCreateWebhook) GetType() DestinationCreateWebhookType

+ type DestinationCreateWebhookType string

+ const DestinationCreateWebhookTypeWebhook

+ func (e *DestinationCreateWebhookType) UnmarshalJSON(data []byte) error

+ func (e DestinationCreateWebhookType) ToPointer() *DestinationCreateWebhookType

+ type DestinationHookdeck struct

+ Config any

+ CreatedAt time.Time

+ Credentials HookdeckCredentials

+ DisabledAt *time.Time

+ ID string

+ Target *string

+ TargetURL *string

+ Topics Topics

+ Type DestinationHookdeckType

+ func (d *DestinationHookdeck) UnmarshalJSON(data []byte) error

+ func (d DestinationHookdeck) MarshalJSON() ([]byte, error)

+ func (o *DestinationHookdeck) GetConfig() any

+ func (o *DestinationHookdeck) GetCreatedAt() time.Time

+ func (o *DestinationHookdeck) GetCredentials() HookdeckCredentials

+ func (o *DestinationHookdeck) GetDisabledAt() *time.Time

+ func (o *DestinationHookdeck) GetID() string

+ func (o *DestinationHookdeck) GetTarget() *string

+ func (o *DestinationHookdeck) GetTargetURL() *string

+ func (o *DestinationHookdeck) GetTopics() Topics

+ func (o *DestinationHookdeck) GetType() DestinationHookdeckType

+ type DestinationHookdeckType string

+ const DestinationHookdeckTypeHookdeck

+ func (e *DestinationHookdeckType) UnmarshalJSON(data []byte) error

+ func (e DestinationHookdeckType) ToPointer() *DestinationHookdeckType

+ type DestinationRabbitMQ struct

+ Config RabbitMQConfig

+ CreatedAt time.Time

+ Credentials RabbitMQCredentials

+ DisabledAt *time.Time

+ ID string

+ Target *string

+ TargetURL *string

+ Topics Topics

+ Type DestinationRabbitMQType

+ func (d *DestinationRabbitMQ) UnmarshalJSON(data []byte) error

+ func (d DestinationRabbitMQ) MarshalJSON() ([]byte, error)

+ func (o *DestinationRabbitMQ) GetConfig() RabbitMQConfig

+ func (o *DestinationRabbitMQ) GetCreatedAt() time.Time

+ func (o *DestinationRabbitMQ) GetCredentials() RabbitMQCredentials

+ func (o *DestinationRabbitMQ) GetDisabledAt() *time.Time

+ func (o *DestinationRabbitMQ) GetID() string

+ func (o *DestinationRabbitMQ) GetTarget() *string

+ func (o *DestinationRabbitMQ) GetTargetURL() *string

+ func (o *DestinationRabbitMQ) GetTopics() Topics

+ func (o *DestinationRabbitMQ) GetType() DestinationRabbitMQType

+ type DestinationRabbitMQType string

+ const DestinationRabbitMQTypeRabbitmq

+ func (e *DestinationRabbitMQType) UnmarshalJSON(data []byte) error

+ func (e DestinationRabbitMQType) ToPointer() *DestinationRabbitMQType

+ type DestinationSchemaField struct

+ Default *string

+ Description *string

+ Label *string

+ Maxlength *int64

+ Minlength *int64

+ Pattern *string

+ Required bool

+ Sensitive *bool

+ Type DestinationSchemaFieldType

+ func (o *DestinationSchemaField) GetDefault() *string

+ func (o *DestinationSchemaField) GetDescription() *string

+ func (o *DestinationSchemaField) GetLabel() *string

+ func (o *DestinationSchemaField) GetMaxlength() *int64

+ func (o *DestinationSchemaField) GetMinlength() *int64

+ func (o *DestinationSchemaField) GetPattern() *string

+ func (o *DestinationSchemaField) GetRequired() bool

+ func (o *DestinationSchemaField) GetSensitive() *bool

+ func (o *DestinationSchemaField) GetType() DestinationSchemaFieldType

+ type DestinationSchemaFieldType string

+ const DestinationSchemaFieldTypeCheckbox

+ const DestinationSchemaFieldTypeText

+ func (e *DestinationSchemaFieldType) UnmarshalJSON(data []byte) error

+ func (e DestinationSchemaFieldType) ToPointer() *DestinationSchemaFieldType

+ type DestinationType string

+ const DestinationTypeAwsKinesis

+ const DestinationTypeAwsSqs

+ const DestinationTypeHookdeck

+ const DestinationTypeRabbitmq

+ const DestinationTypeWebhook

+ type DestinationTypeSchema struct

+ ConfigFields []DestinationSchemaField

+ CredentialFields []DestinationSchemaField

+ Description *string

+ Icon *string

+ Instructions *string

+ Label *string

+ RemoteSetupURL *string

+ Type *string

+ func (o *DestinationTypeSchema) GetConfigFields() []DestinationSchemaField

+ func (o *DestinationTypeSchema) GetCredentialFields() []DestinationSchemaField

+ func (o *DestinationTypeSchema) GetDescription() *string

+ func (o *DestinationTypeSchema) GetIcon() *string

+ func (o *DestinationTypeSchema) GetInstructions() *string

+ func (o *DestinationTypeSchema) GetLabel() *string

+ func (o *DestinationTypeSchema) GetRemoteSetupURL() *string

+ func (o *DestinationTypeSchema) GetType() *string

+ type DestinationUpdate struct

+ DestinationUpdateAWSKinesis *DestinationUpdateAWSKinesis

+ DestinationUpdateAWSSQS *DestinationUpdateAWSSQS

+ DestinationUpdateHookdeck *DestinationUpdateHookdeck

+ DestinationUpdateRabbitMQ *DestinationUpdateRabbitMQ

+ DestinationUpdateWebhook *DestinationUpdateWebhook

+ Type DestinationUpdateType

+ func CreateDestinationUpdateDestinationUpdateAWSKinesis(destinationUpdateAWSKinesis DestinationUpdateAWSKinesis) DestinationUpdate

+ func CreateDestinationUpdateDestinationUpdateAWSSQS(destinationUpdateAWSSQS DestinationUpdateAWSSQS) DestinationUpdate

+ func CreateDestinationUpdateDestinationUpdateHookdeck(destinationUpdateHookdeck DestinationUpdateHookdeck) DestinationUpdate

+ func CreateDestinationUpdateDestinationUpdateRabbitMQ(destinationUpdateRabbitMQ DestinationUpdateRabbitMQ) DestinationUpdate

+ func CreateDestinationUpdateDestinationUpdateWebhook(destinationUpdateWebhook DestinationUpdateWebhook) DestinationUpdate

+ func (u *DestinationUpdate) UnmarshalJSON(data []byte) error

+ func (u DestinationUpdate) MarshalJSON() ([]byte, error)

+ type DestinationUpdateAWSKinesis struct

+ Config *AWSKinesisConfig

+ Credentials *AWSKinesisCredentials

+ Topics *Topics

+ func (o *DestinationUpdateAWSKinesis) GetConfig() *AWSKinesisConfig

+ func (o *DestinationUpdateAWSKinesis) GetCredentials() *AWSKinesisCredentials

+ func (o *DestinationUpdateAWSKinesis) GetTopics() *Topics

+ type DestinationUpdateAWSSQS struct

+ Config *AWSSQSConfig

+ Credentials *AWSSQSCredentials

+ Topics *Topics

+ func (o *DestinationUpdateAWSSQS) GetConfig() *AWSSQSConfig

+ func (o *DestinationUpdateAWSSQS) GetCredentials() *AWSSQSCredentials

+ func (o *DestinationUpdateAWSSQS) GetTopics() *Topics

+ type DestinationUpdateHookdeck struct

+ Config any

+ Credentials *HookdeckCredentials

+ Topics *Topics

+ func (o *DestinationUpdateHookdeck) GetConfig() any

+ func (o *DestinationUpdateHookdeck) GetCredentials() *HookdeckCredentials

+ func (o *DestinationUpdateHookdeck) GetTopics() *Topics

+ type DestinationUpdateRabbitMQ struct

+ Config *RabbitMQConfig

+ Credentials *RabbitMQCredentials

+ Topics *Topics

+ func (o *DestinationUpdateRabbitMQ) GetConfig() *RabbitMQConfig

+ func (o *DestinationUpdateRabbitMQ) GetCredentials() *RabbitMQCredentials

+ func (o *DestinationUpdateRabbitMQ) GetTopics() *Topics

+ type DestinationUpdateType string

+ const DestinationUpdateTypeDestinationUpdateAWSKinesis

+ const DestinationUpdateTypeDestinationUpdateAWSSQS

+ const DestinationUpdateTypeDestinationUpdateHookdeck

+ const DestinationUpdateTypeDestinationUpdateRabbitMQ

+ const DestinationUpdateTypeDestinationUpdateWebhook

+ type DestinationUpdateWebhook struct

+ Config *WebhookConfig

+ Credentials *WebhookCredentialsUpdate

+ Topics *Topics

+ func (o *DestinationUpdateWebhook) GetConfig() *WebhookConfig

+ func (o *DestinationUpdateWebhook) GetCredentials() *WebhookCredentialsUpdate

+ func (o *DestinationUpdateWebhook) GetTopics() *Topics

+ type DestinationWebhook struct

+ Config WebhookConfig

+ CreatedAt time.Time

+ Credentials WebhookCredentials

+ DisabledAt *time.Time

+ ID string

+ Target *string

+ TargetURL *string

+ Topics Topics

+ Type DestinationWebhookType

+ func (d *DestinationWebhook) UnmarshalJSON(data []byte) error

+ func (d DestinationWebhook) MarshalJSON() ([]byte, error)

+ func (o *DestinationWebhook) GetConfig() WebhookConfig

+ func (o *DestinationWebhook) GetCreatedAt() time.Time

+ func (o *DestinationWebhook) GetCredentials() WebhookCredentials

+ func (o *DestinationWebhook) GetDisabledAt() *time.Time

+ func (o *DestinationWebhook) GetID() string

+ func (o *DestinationWebhook) GetTarget() *string

+ func (o *DestinationWebhook) GetTargetURL() *string

+ func (o *DestinationWebhook) GetTopics() Topics

+ func (o *DestinationWebhook) GetType() DestinationWebhookType

+ type DestinationWebhookType string

+ const DestinationWebhookTypeWebhook

+ func (e *DestinationWebhookType) UnmarshalJSON(data []byte) error

+ func (e DestinationWebhookType) ToPointer() *DestinationWebhookType

+ type Event struct

+ Data map[string]any

+ DestinationID *string

+ ID *string

+ Metadata map[string]string

+ SuccessfulAt *time.Time

+ Time *time.Time

+ Topic *string

+ func (e *Event) UnmarshalJSON(data []byte) error

+ func (e Event) MarshalJSON() ([]byte, error)

+ func (o *Event) GetData() map[string]any

+ func (o *Event) GetDestinationID() *string

+ func (o *Event) GetID() *string

+ func (o *Event) GetMetadata() map[string]string

+ func (o *Event) GetSuccessfulAt() *time.Time

+ func (o *Event) GetTime() *time.Time

+ func (o *Event) GetTopic() *string

+ type HTTPMetadata struct

+ Request *http.Request

+ Response *http.Response

+ func (o *HTTPMetadata) GetRequest() *http.Request

+ func (o *HTTPMetadata) GetResponse() *http.Response

+ type HookdeckCredentials struct

+ Token string

+ func (o *HookdeckCredentials) GetToken() string

+ type PortalRedirect struct

+ RedirectURL *string

+ func (o *PortalRedirect) GetRedirectURL() *string

+ type PublishRequest struct

+ Data map[string]any

+ DestinationID *string

+ EligibleForRetry bool

+ Metadata map[string]string

+ TenantID string

+ Topic string

+ func (o *PublishRequest) GetData() map[string]any

+ func (o *PublishRequest) GetDestinationID() *string

+ func (o *PublishRequest) GetEligibleForRetry() bool

+ func (o *PublishRequest) GetMetadata() map[string]string

+ func (o *PublishRequest) GetTenantID() string

+ func (o *PublishRequest) GetTopic() string

+ type RabbitMQConfig struct

+ Exchange string

+ ServerURL string

+ TLS *TLS

+ func (o *RabbitMQConfig) GetExchange() string

+ func (o *RabbitMQConfig) GetServerURL() string

+ func (o *RabbitMQConfig) GetTLS() *TLS

+ type RabbitMQCredentials struct

+ Password string

+ Username string

+ func (o *RabbitMQCredentials) GetPassword() string

+ func (o *RabbitMQCredentials) GetUsername() string

+ type Security struct

+ AdminAPIKey *string

+ TenantJwt *string

+ func (o *Security) GetAdminAPIKey() *string

+ func (o *Security) GetTenantJwt() *string

+ type Status string

+ const StatusFailed

+ const StatusSuccess

+ func (e *Status) UnmarshalJSON(data []byte) error

+ func (e Status) ToPointer() *Status

+ type SuccessResponse struct

+ Success *bool

+ func (o *SuccessResponse) GetSuccess() *bool

+ type TLS string

+ const TLSFalse

+ const TLSTrue

+ func (e *TLS) UnmarshalJSON(data []byte) error

+ func (e TLS) ToPointer() *TLS

+ type Tenant struct

+ CreatedAt *time.Time

+ DestinationsCount *int64

+ ID *string

+ Topics []string

+ func (o *Tenant) GetCreatedAt() *time.Time

+ func (o *Tenant) GetDestinationsCount() *int64

+ func (o *Tenant) GetID() *string

+ func (o *Tenant) GetTopics() []string

+ func (t *Tenant) UnmarshalJSON(data []byte) error

+ func (t Tenant) MarshalJSON() ([]byte, error)

+ type TenantToken struct

+ Token *string

+ func (o *TenantToken) GetToken() *string

+ type Topics struct

+ ArrayOfStr []string

+ TopicsEnum *TopicsEnum

+ Type TopicsType

+ func CreateTopicsArrayOfStr(arrayOfStr []string) Topics

+ func CreateTopicsTopicsEnum(topicsEnum TopicsEnum) Topics

+ func (u *Topics) UnmarshalJSON(data []byte) error

+ func (u Topics) MarshalJSON() ([]byte, error)

+ type TopicsEnum string

+ const TopicsEnumWildcard

+ func (e *TopicsEnum) UnmarshalJSON(data []byte) error

+ func (e TopicsEnum) ToPointer() *TopicsEnum

+ type TopicsType string

+ const TopicsTypeArrayOfStr

+ const TopicsTypeTopicsEnum

+ type WebhookConfig struct

+ URL string

+ func (o *WebhookConfig) GetURL() string

+ type WebhookCredentials struct

+ PreviousSecret *string

+ PreviousSecretInvalidAt *time.Time

+ Secret *string

+ func (o *WebhookCredentials) GetPreviousSecret() *string

+ func (o *WebhookCredentials) GetPreviousSecretInvalidAt() *time.Time

+ func (o *WebhookCredentials) GetSecret() *string

+ func (w *WebhookCredentials) UnmarshalJSON(data []byte) error

+ func (w WebhookCredentials) MarshalJSON() ([]byte, error)

+ type WebhookCredentialsUpdate struct

+ PreviousSecret *string

+ PreviousSecretInvalidAt *time.Time

+ RotateSecret *bool

+ Secret *string

+ func (o *WebhookCredentialsUpdate) GetPreviousSecret() *string

+ func (o *WebhookCredentialsUpdate) GetPreviousSecretInvalidAt() *time.Time

+ func (o *WebhookCredentialsUpdate) GetRotateSecret() *bool

+ func (o *WebhookCredentialsUpdate) GetSecret() *string

+ func (w *WebhookCredentialsUpdate) UnmarshalJSON(data []byte) error

+ func (w WebhookCredentialsUpdate) MarshalJSON() ([]byte, error)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL