components

package
v0.4.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 3, 2025 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AWSKinesisConfig

type AWSKinesisConfig struct {
	// The name of the AWS Kinesis stream.
	StreamName string `json:"stream_name"`
	// The AWS region where the Kinesis stream is located.
	Region string `json:"region"`
	// Optional. Custom AWS endpoint URL (e.g., for LocalStack or VPC endpoints).
	Endpoint *string `json:"endpoint,omitempty"`
	// Optional. JMESPath template to extract the partition key from the event payload (e.g., `metadata."event-id"`). Defaults to event ID.
	PartitionKeyTemplate *string `json:"partition_key_template,omitempty"`
}

func (*AWSKinesisConfig) GetEndpoint

func (o *AWSKinesisConfig) GetEndpoint() *string

func (*AWSKinesisConfig) GetPartitionKeyTemplate

func (o *AWSKinesisConfig) GetPartitionKeyTemplate() *string

func (*AWSKinesisConfig) GetRegion

func (o *AWSKinesisConfig) GetRegion() string

func (*AWSKinesisConfig) GetStreamName

func (o *AWSKinesisConfig) GetStreamName() string

func (AWSKinesisConfig) MarshalJSON added in v0.4.0

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

func (*AWSKinesisConfig) UnmarshalJSON added in v0.4.0

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

type AWSKinesisCredentials

type AWSKinesisCredentials struct {
	// AWS Access Key ID.
	Key string `json:"key"`
	// AWS Secret Access Key.
	Secret string `json:"secret"`
	// Optional AWS Session Token (for temporary credentials).
	Session *string `json:"session,omitempty"`
}

func (*AWSKinesisCredentials) GetKey

func (o *AWSKinesisCredentials) GetKey() string

func (*AWSKinesisCredentials) GetSecret

func (o *AWSKinesisCredentials) GetSecret() string

func (*AWSKinesisCredentials) GetSession

func (o *AWSKinesisCredentials) GetSession() *string

func (AWSKinesisCredentials) MarshalJSON added in v0.4.0

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

func (*AWSKinesisCredentials) UnmarshalJSON added in v0.4.0

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

type AWSSQSConfig

type AWSSQSConfig struct {
	// Optional. Custom AWS endpoint URL (e.g., for LocalStack or specific regions).
	Endpoint *string `json:"endpoint,omitempty"`
	// The URL of the SQS queue.
	QueueURL string `json:"queue_url"`
}

func (*AWSSQSConfig) GetEndpoint

func (o *AWSSQSConfig) GetEndpoint() *string

func (*AWSSQSConfig) GetQueueURL

func (o *AWSSQSConfig) GetQueueURL() string

func (AWSSQSConfig) MarshalJSON added in v0.4.0

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

func (*AWSSQSConfig) UnmarshalJSON added in v0.4.0

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

type AWSSQSCredentials

type AWSSQSCredentials struct {
	// AWS Access Key ID.
	Key string `json:"key"`
	// AWS Secret Access Key.
	Secret string `json:"secret"`
	// Optional AWS Session Token (for temporary credentials).
	Session *string `json:"session,omitempty"`
}

func (*AWSSQSCredentials) GetKey

func (o *AWSSQSCredentials) GetKey() string

func (*AWSSQSCredentials) GetSecret

func (o *AWSSQSCredentials) GetSecret() string

func (*AWSSQSCredentials) GetSession

func (o *AWSSQSCredentials) GetSession() *string

func (AWSSQSCredentials) MarshalJSON added in v0.4.0

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

func (*AWSSQSCredentials) UnmarshalJSON added in v0.4.0

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

type Awss3Config added in v0.4.0

type Awss3Config struct {
	// The name of your AWS S3 bucket.
	Bucket string `json:"bucket"`
	// The AWS region where your bucket is located.
	Region string `json:"region"`
	// JMESPath expression for generating S3 object keys. Default is join(”, [time.rfc3339_nano, '_', metadata."event-id", '.json']).
	KeyTemplate *string `json:"key_template,omitempty"`
	// The storage class for the S3 objects (e.g., STANDARD, INTELLIGENT_TIERING, GLACIER, etc.). Defaults to "STANDARD".
	StorageClass *string `json:"storage_class,omitempty"`
}

func (*Awss3Config) GetBucket added in v0.4.0

func (o *Awss3Config) GetBucket() string

func (*Awss3Config) GetKeyTemplate added in v0.4.0

func (o *Awss3Config) GetKeyTemplate() *string

func (*Awss3Config) GetRegion added in v0.4.0

func (o *Awss3Config) GetRegion() string

func (*Awss3Config) GetStorageClass added in v0.4.0

func (o *Awss3Config) GetStorageClass() *string

func (Awss3Config) MarshalJSON added in v0.4.0

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

func (*Awss3Config) UnmarshalJSON added in v0.4.0

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

type Awss3Credentials added in v0.4.0

type Awss3Credentials struct {
	// AWS Access Key ID.
	Key string `json:"key"`
	// AWS Secret Access Key.
	Secret string `json:"secret"`
	// Optional AWS Session Token (for temporary credentials).
	Session *string `json:"session,omitempty"`
}

func (*Awss3Credentials) GetKey added in v0.4.0

func (o *Awss3Credentials) GetKey() string

func (*Awss3Credentials) GetSecret added in v0.4.0

func (o *Awss3Credentials) GetSecret() string

func (*Awss3Credentials) GetSession added in v0.4.0

func (o *Awss3Credentials) GetSession() *string

func (Awss3Credentials) MarshalJSON added in v0.4.0

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

func (*Awss3Credentials) UnmarshalJSON added in v0.4.0

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

type AzureServiceBusConfig added in v0.3.0

type AzureServiceBusConfig struct {
	// The name of the Azure Service Bus queue or topic to publish messages to.
	Name string `json:"name"`
}

func (*AzureServiceBusConfig) GetName added in v0.3.0

func (o *AzureServiceBusConfig) GetName() string

func (AzureServiceBusConfig) MarshalJSON added in v0.4.0

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

func (*AzureServiceBusConfig) UnmarshalJSON added in v0.4.0

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

type AzureServiceBusCredentials added in v0.3.0

type AzureServiceBusCredentials struct {
	// The connection string for the Azure Service Bus namespace.
	ConnectionString string `json:"connection_string"`
}

func (*AzureServiceBusCredentials) GetConnectionString added in v0.3.0

func (o *AzureServiceBusCredentials) GetConnectionString() string

func (AzureServiceBusCredentials) MarshalJSON added in v0.4.0

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

func (*AzureServiceBusCredentials) UnmarshalJSON added in v0.4.0

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

type DeliveryAttempt

type DeliveryAttempt struct {
	DeliveredAt        *time.Time        `json:"delivered_at,omitempty"`
	Status             *Status           `json:"status,omitempty"`
	ResponseStatusCode *int64            `json:"response_status_code,omitempty"`
	ResponseBody       *string           `json:"response_body,omitempty"`
	ResponseHeaders    map[string]string `json:"response_headers,omitempty"`
}

func (*DeliveryAttempt) GetDeliveredAt

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

func (*DeliveryAttempt) GetResponseBody

func (o *DeliveryAttempt) GetResponseBody() *string

func (*DeliveryAttempt) GetResponseHeaders

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

func (*DeliveryAttempt) GetResponseStatusCode

func (o *DeliveryAttempt) GetResponseStatusCode() *int64

func (*DeliveryAttempt) GetStatus

func (o *DeliveryAttempt) GetStatus() *Status

func (DeliveryAttempt) MarshalJSON

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

func (*DeliveryAttempt) UnmarshalJSON

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

type Destination

type Destination struct {
	DestinationWebhook         *DestinationWebhook         `queryParam:"inline" name:"Destination"`
	DestinationAWSSQS          *DestinationAWSSQS          `queryParam:"inline" name:"Destination"`
	DestinationRabbitMQ        *DestinationRabbitMQ        `queryParam:"inline" name:"Destination"`
	DestinationHookdeck        *DestinationHookdeck        `queryParam:"inline" name:"Destination"`
	DestinationAWSKinesis      *DestinationAWSKinesis      `queryParam:"inline" name:"Destination"`
	DestinationAzureServiceBus *DestinationAzureServiceBus `queryParam:"inline" name:"Destination"`
	DestinationAwss3           *DestinationAwss3           `queryParam:"inline" name:"Destination"`

	Type DestinationType
}

func CreateDestinationAwsKinesis

func CreateDestinationAwsKinesis(awsKinesis DestinationAWSKinesis) Destination

func CreateDestinationAwsS3 added in v0.4.0

func CreateDestinationAwsS3(awsS3 DestinationAwss3) Destination

func CreateDestinationAwsSqs

func CreateDestinationAwsSqs(awsSqs DestinationAWSSQS) Destination

func CreateDestinationAzureServicebus added in v0.3.0

func CreateDestinationAzureServicebus(azureServicebus DestinationAzureServiceBus) Destination

func CreateDestinationHookdeck

func CreateDestinationHookdeck(hookdeck DestinationHookdeck) Destination

func CreateDestinationRabbitmq

func CreateDestinationRabbitmq(rabbitmq DestinationRabbitMQ) Destination

func CreateDestinationWebhook

func CreateDestinationWebhook(webhook DestinationWebhook) Destination

func (Destination) MarshalJSON

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

func (*Destination) UnmarshalJSON

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

type DestinationAWSKinesis

type DestinationAWSKinesis struct {
	// Control plane generated ID or user provided ID for the destination.
	ID string `json:"id"`
	// Type of the destination.
	Type DestinationAWSKinesisType `json:"type"`
	// "*" or an array of enabled topics.
	Topics Topics `json:"topics"`
	// ISO Date when the destination was disabled, or null if enabled.
	DisabledAt *time.Time `json:"disabled_at"`
	// ISO Date when the destination was created.
	CreatedAt   time.Time             `json:"created_at"`
	Config      AWSKinesisConfig      `json:"config"`
	Credentials AWSKinesisCredentials `json:"credentials"`
	// A human-readable representation of the destination target (Kinesis stream name). Read-only.
	Target *string `json:"target,omitempty"`
	// A URL link to the destination target (AWS Console link to the stream). Read-only.
	TargetURL *string `json:"target_url,omitempty"`
}

func (*DestinationAWSKinesis) GetConfig

func (o *DestinationAWSKinesis) GetConfig() AWSKinesisConfig

func (*DestinationAWSKinesis) GetCreatedAt

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

func (*DestinationAWSKinesis) GetCredentials

func (o *DestinationAWSKinesis) GetCredentials() AWSKinesisCredentials

func (*DestinationAWSKinesis) GetDisabledAt

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

func (*DestinationAWSKinesis) GetID

func (o *DestinationAWSKinesis) GetID() string

func (*DestinationAWSKinesis) GetTarget

func (o *DestinationAWSKinesis) GetTarget() *string

func (*DestinationAWSKinesis) GetTargetURL

func (o *DestinationAWSKinesis) GetTargetURL() *string

func (*DestinationAWSKinesis) GetTopics

func (o *DestinationAWSKinesis) GetTopics() Topics

func (*DestinationAWSKinesis) GetType

func (DestinationAWSKinesis) MarshalJSON

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

func (*DestinationAWSKinesis) UnmarshalJSON

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

type DestinationAWSKinesisType

type DestinationAWSKinesisType string

DestinationAWSKinesisType - Type of the destination.

const (
	DestinationAWSKinesisTypeAwsKinesis DestinationAWSKinesisType = "aws_kinesis"
)

func (DestinationAWSKinesisType) ToPointer

func (*DestinationAWSKinesisType) UnmarshalJSON

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

type DestinationAWSSQS

type DestinationAWSSQS struct {
	// Control plane generated ID or user provided ID for the destination.
	ID string `json:"id"`
	// Type of the destination.
	Type DestinationAWSSQSType `json:"type"`
	// "*" or an array of enabled topics.
	Topics Topics `json:"topics"`
	// ISO Date when the destination was disabled, or null if enabled.
	DisabledAt *time.Time `json:"disabled_at"`
	// ISO Date when the destination was created.
	CreatedAt   time.Time         `json:"created_at"`
	Config      AWSSQSConfig      `json:"config"`
	Credentials AWSSQSCredentials `json:"credentials"`
	// A human-readable representation of the destination target (SQS queue name). Read-only.
	Target *string `json:"target,omitempty"`
	// A URL link to the destination target (AWS Console link to the queue). Read-only.
	TargetURL *string `json:"target_url,omitempty"`
}

func (*DestinationAWSSQS) GetConfig

func (o *DestinationAWSSQS) GetConfig() AWSSQSConfig

func (*DestinationAWSSQS) GetCreatedAt

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

func (*DestinationAWSSQS) GetCredentials

func (o *DestinationAWSSQS) GetCredentials() AWSSQSCredentials

func (*DestinationAWSSQS) GetDisabledAt

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

func (*DestinationAWSSQS) GetID

func (o *DestinationAWSSQS) GetID() string

func (*DestinationAWSSQS) GetTarget

func (o *DestinationAWSSQS) GetTarget() *string

func (*DestinationAWSSQS) GetTargetURL

func (o *DestinationAWSSQS) GetTargetURL() *string

func (*DestinationAWSSQS) GetTopics

func (o *DestinationAWSSQS) GetTopics() Topics

func (*DestinationAWSSQS) GetType

func (DestinationAWSSQS) MarshalJSON

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

func (*DestinationAWSSQS) UnmarshalJSON

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

type DestinationAWSSQSType

type DestinationAWSSQSType string

DestinationAWSSQSType - Type of the destination.

const (
	DestinationAWSSQSTypeAwsSqs DestinationAWSSQSType = "aws_sqs"
)

func (DestinationAWSSQSType) ToPointer

func (*DestinationAWSSQSType) UnmarshalJSON

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

type DestinationAwss3 added in v0.4.0

type DestinationAwss3 struct {
	// Control plane generated ID or user provided ID for the destination.
	ID string `json:"id"`
	// Type of the destination.
	Type DestinationAwss3Type `json:"type"`
	// "*" or an array of enabled topics.
	Topics Topics `json:"topics"`
	// ISO Date when the destination was disabled, or null if enabled.
	DisabledAt *time.Time `json:"disabled_at"`
	// ISO Date when the destination was created.
	CreatedAt   time.Time        `json:"created_at"`
	Config      Awss3Config      `json:"config"`
	Credentials Awss3Credentials `json:"credentials"`
	// A human-readable representation of the destination target (bucket and region). Read-only.
	Target *string `json:"target,omitempty"`
	// A URL link to the destination target (AWS Console link to the bucket). Read-only.
	TargetURL *string `json:"target_url,omitempty"`
}

func (*DestinationAwss3) GetConfig added in v0.4.0

func (o *DestinationAwss3) GetConfig() Awss3Config

func (*DestinationAwss3) GetCreatedAt added in v0.4.0

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

func (*DestinationAwss3) GetCredentials added in v0.4.0

func (o *DestinationAwss3) GetCredentials() Awss3Credentials

func (*DestinationAwss3) GetDisabledAt added in v0.4.0

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

func (*DestinationAwss3) GetID added in v0.4.0

func (o *DestinationAwss3) GetID() string

func (*DestinationAwss3) GetTarget added in v0.4.0

func (o *DestinationAwss3) GetTarget() *string

func (*DestinationAwss3) GetTargetURL added in v0.4.0

func (o *DestinationAwss3) GetTargetURL() *string

func (*DestinationAwss3) GetTopics added in v0.4.0

func (o *DestinationAwss3) GetTopics() Topics

func (*DestinationAwss3) GetType added in v0.4.0

func (DestinationAwss3) MarshalJSON added in v0.4.0

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

func (*DestinationAwss3) UnmarshalJSON added in v0.4.0

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

type DestinationAwss3Type added in v0.4.0

type DestinationAwss3Type string

DestinationAwss3Type - Type of the destination.

const (
	DestinationAwss3TypeAwsS3 DestinationAwss3Type = "aws_s3"
)

func (DestinationAwss3Type) ToPointer added in v0.4.0

func (*DestinationAwss3Type) UnmarshalJSON added in v0.4.0

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

type DestinationAzureServiceBus added in v0.3.0

type DestinationAzureServiceBus struct {
	// Control plane generated ID or user provided ID for the destination.
	ID string `json:"id"`
	// Type of the destination.
	Type DestinationAzureServiceBusType `json:"type"`
	// "*" or an array of enabled topics.
	Topics Topics `json:"topics"`
	// ISO Date when the destination was disabled, or null if enabled.
	DisabledAt *time.Time `json:"disabled_at"`
	// ISO Date when the destination was created.
	CreatedAt   time.Time                  `json:"created_at"`
	Config      AzureServiceBusConfig      `json:"config"`
	Credentials AzureServiceBusCredentials `json:"credentials"`
	// A human-readable representation of the destination target (Azure Service Bus queue/topic name). Read-only.
	Target *string `json:"target,omitempty"`
	// A URL link to the destination target (Azure Portal link to the Service Bus). Read-only.
	TargetURL *string `json:"target_url,omitempty"`
}

func (*DestinationAzureServiceBus) GetConfig added in v0.3.0

func (*DestinationAzureServiceBus) GetCreatedAt added in v0.3.0

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

func (*DestinationAzureServiceBus) GetCredentials added in v0.3.0

func (*DestinationAzureServiceBus) GetDisabledAt added in v0.3.0

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

func (*DestinationAzureServiceBus) GetID added in v0.3.0

func (*DestinationAzureServiceBus) GetTarget added in v0.3.0

func (o *DestinationAzureServiceBus) GetTarget() *string

func (*DestinationAzureServiceBus) GetTargetURL added in v0.3.0

func (o *DestinationAzureServiceBus) GetTargetURL() *string

func (*DestinationAzureServiceBus) GetTopics added in v0.3.0

func (o *DestinationAzureServiceBus) GetTopics() Topics

func (*DestinationAzureServiceBus) GetType added in v0.3.0

func (DestinationAzureServiceBus) MarshalJSON added in v0.3.0

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

func (*DestinationAzureServiceBus) UnmarshalJSON added in v0.3.0

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

type DestinationAzureServiceBusType added in v0.3.0

type DestinationAzureServiceBusType string

DestinationAzureServiceBusType - Type of the destination.

const (
	DestinationAzureServiceBusTypeAzureServicebus DestinationAzureServiceBusType = "azure_servicebus"
)

func (DestinationAzureServiceBusType) ToPointer added in v0.3.0

func (*DestinationAzureServiceBusType) UnmarshalJSON added in v0.3.0

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

type DestinationCreate

type DestinationCreate struct {
	DestinationCreateWebhook         *DestinationCreateWebhook         `queryParam:"inline" name:"DestinationCreate"`
	DestinationCreateAWSSQS          *DestinationCreateAWSSQS          `queryParam:"inline" name:"DestinationCreate"`
	DestinationCreateRabbitMQ        *DestinationCreateRabbitMQ        `queryParam:"inline" name:"DestinationCreate"`
	DestinationCreateHookdeck        *DestinationCreateHookdeck        `queryParam:"inline" name:"DestinationCreate"`
	DestinationCreateAWSKinesis      *DestinationCreateAWSKinesis      `queryParam:"inline" name:"DestinationCreate"`
	DestinationCreateAzureServiceBus *DestinationCreateAzureServiceBus `queryParam:"inline" name:"DestinationCreate"`
	DestinationCreateAwss3           *DestinationCreateAwss3           `queryParam:"inline" name:"DestinationCreate"`

	Type DestinationCreateType
}

func CreateDestinationCreateAwsKinesis

func CreateDestinationCreateAwsKinesis(awsKinesis DestinationCreateAWSKinesis) DestinationCreate

func CreateDestinationCreateAwsS3 added in v0.4.0

func CreateDestinationCreateAwsS3(awsS3 DestinationCreateAwss3) DestinationCreate

func CreateDestinationCreateAwsSqs

func CreateDestinationCreateAwsSqs(awsSqs DestinationCreateAWSSQS) DestinationCreate

func CreateDestinationCreateAzureServicebus added in v0.3.0

func CreateDestinationCreateAzureServicebus(azureServicebus DestinationCreateAzureServiceBus) DestinationCreate

func CreateDestinationCreateHookdeck

func CreateDestinationCreateHookdeck(hookdeck DestinationCreateHookdeck) DestinationCreate

func CreateDestinationCreateRabbitmq

func CreateDestinationCreateRabbitmq(rabbitmq DestinationCreateRabbitMQ) DestinationCreate

func CreateDestinationCreateWebhook

func CreateDestinationCreateWebhook(webhook DestinationCreateWebhook) DestinationCreate

func (DestinationCreate) MarshalJSON

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

func (*DestinationCreate) UnmarshalJSON

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

type DestinationCreateAWSKinesis

type DestinationCreateAWSKinesis struct {
	// Optional user-provided ID. A UUID will be generated if empty.
	ID *string `json:"id,omitempty"`
	// Type of the destination. Must be 'aws_kinesis'.
	Type DestinationCreateAWSKinesisType `json:"type"`
	// "*" or an array of enabled topics.
	Topics      Topics                `json:"topics"`
	Config      AWSKinesisConfig      `json:"config"`
	Credentials AWSKinesisCredentials `json:"credentials"`
}

func (*DestinationCreateAWSKinesis) GetConfig

func (*DestinationCreateAWSKinesis) GetCredentials

func (*DestinationCreateAWSKinesis) GetID

func (o *DestinationCreateAWSKinesis) GetID() *string

func (*DestinationCreateAWSKinesis) GetTopics

func (o *DestinationCreateAWSKinesis) GetTopics() Topics

func (*DestinationCreateAWSKinesis) GetType

func (DestinationCreateAWSKinesis) MarshalJSON added in v0.4.0

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

func (*DestinationCreateAWSKinesis) UnmarshalJSON added in v0.4.0

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

type DestinationCreateAWSKinesisType

type DestinationCreateAWSKinesisType string

DestinationCreateAWSKinesisType - Type of the destination. Must be 'aws_kinesis'.

const (
	DestinationCreateAWSKinesisTypeAwsKinesis DestinationCreateAWSKinesisType = "aws_kinesis"
)

func (DestinationCreateAWSKinesisType) ToPointer

func (*DestinationCreateAWSKinesisType) UnmarshalJSON

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

type DestinationCreateAWSSQS

type DestinationCreateAWSSQS struct {
	// Optional user-provided ID. A UUID will be generated if empty.
	ID *string `json:"id,omitempty"`
	// Type of the destination. Must be 'aws_sqs'.
	Type DestinationCreateAWSSQSType `json:"type"`
	// "*" or an array of enabled topics.
	Topics      Topics            `json:"topics"`
	Config      AWSSQSConfig      `json:"config"`
	Credentials AWSSQSCredentials `json:"credentials"`
}

func (*DestinationCreateAWSSQS) GetConfig

func (o *DestinationCreateAWSSQS) GetConfig() AWSSQSConfig

func (*DestinationCreateAWSSQS) GetCredentials

func (o *DestinationCreateAWSSQS) GetCredentials() AWSSQSCredentials

func (*DestinationCreateAWSSQS) GetID

func (o *DestinationCreateAWSSQS) GetID() *string

func (*DestinationCreateAWSSQS) GetTopics

func (o *DestinationCreateAWSSQS) GetTopics() Topics

func (*DestinationCreateAWSSQS) GetType

func (DestinationCreateAWSSQS) MarshalJSON added in v0.4.0

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

func (*DestinationCreateAWSSQS) UnmarshalJSON added in v0.4.0

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

type DestinationCreateAWSSQSType

type DestinationCreateAWSSQSType string

DestinationCreateAWSSQSType - Type of the destination. Must be 'aws_sqs'.

const (
	DestinationCreateAWSSQSTypeAwsSqs DestinationCreateAWSSQSType = "aws_sqs"
)

func (DestinationCreateAWSSQSType) ToPointer

func (*DestinationCreateAWSSQSType) UnmarshalJSON

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

type DestinationCreateAwss3 added in v0.4.0

type DestinationCreateAwss3 struct {
	// Optional user-provided ID. A UUID will be generated if empty.
	ID *string `json:"id,omitempty"`
	// Type of the destination. Must be 'aws_s3'.
	Type DestinationCreateAwss3Type `json:"type"`
	// "*" or an array of enabled topics.
	Topics      Topics           `json:"topics"`
	Config      Awss3Config      `json:"config"`
	Credentials Awss3Credentials `json:"credentials"`
}

func (*DestinationCreateAwss3) GetConfig added in v0.4.0

func (o *DestinationCreateAwss3) GetConfig() Awss3Config

func (*DestinationCreateAwss3) GetCredentials added in v0.4.0

func (o *DestinationCreateAwss3) GetCredentials() Awss3Credentials

func (*DestinationCreateAwss3) GetID added in v0.4.0

func (o *DestinationCreateAwss3) GetID() *string

func (*DestinationCreateAwss3) GetTopics added in v0.4.0

func (o *DestinationCreateAwss3) GetTopics() Topics

func (*DestinationCreateAwss3) GetType added in v0.4.0

func (DestinationCreateAwss3) MarshalJSON added in v0.4.0

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

func (*DestinationCreateAwss3) UnmarshalJSON added in v0.4.0

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

type DestinationCreateAwss3Type added in v0.4.0

type DestinationCreateAwss3Type string

DestinationCreateAwss3Type - Type of the destination. Must be 'aws_s3'.

const (
	DestinationCreateAwss3TypeAwsS3 DestinationCreateAwss3Type = "aws_s3"
)

func (DestinationCreateAwss3Type) ToPointer added in v0.4.0

func (*DestinationCreateAwss3Type) UnmarshalJSON added in v0.4.0

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

type DestinationCreateAzureServiceBus added in v0.3.0

type DestinationCreateAzureServiceBus struct {
	// Optional user-provided ID. A UUID will be generated if empty.
	ID *string `json:"id,omitempty"`
	// Type of the destination. Must be 'azure_servicebus'.
	Type DestinationCreateAzureServiceBusType `json:"type"`
	// "*" or an array of enabled topics.
	Topics      Topics                     `json:"topics"`
	Config      AzureServiceBusConfig      `json:"config"`
	Credentials AzureServiceBusCredentials `json:"credentials"`
}

func (*DestinationCreateAzureServiceBus) GetConfig added in v0.3.0

func (*DestinationCreateAzureServiceBus) GetCredentials added in v0.3.0

func (*DestinationCreateAzureServiceBus) GetID added in v0.3.0

func (*DestinationCreateAzureServiceBus) GetTopics added in v0.3.0

func (*DestinationCreateAzureServiceBus) GetType added in v0.3.0

func (DestinationCreateAzureServiceBus) MarshalJSON added in v0.4.0

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

func (*DestinationCreateAzureServiceBus) UnmarshalJSON added in v0.4.0

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

type DestinationCreateAzureServiceBusType added in v0.3.0

type DestinationCreateAzureServiceBusType string

DestinationCreateAzureServiceBusType - Type of the destination. Must be 'azure_servicebus'.

const (
	DestinationCreateAzureServiceBusTypeAzureServicebus DestinationCreateAzureServiceBusType = "azure_servicebus"
)

func (DestinationCreateAzureServiceBusType) ToPointer added in v0.3.0

func (*DestinationCreateAzureServiceBusType) UnmarshalJSON added in v0.3.0

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

type DestinationCreateHookdeck

type DestinationCreateHookdeck struct {
	// Optional user-provided ID. A UUID will be generated if empty.
	ID *string `json:"id,omitempty"`
	// Type of the destination. Must be 'hookdeck'.
	Type DestinationCreateHookdeckType `json:"type"`
	// "*" or an array of enabled topics.
	Topics      Topics              `json:"topics"`
	Config      any                 `json:"config,omitempty"`
	Credentials HookdeckCredentials `json:"credentials"`
}

func (*DestinationCreateHookdeck) GetConfig

func (o *DestinationCreateHookdeck) GetConfig() any

func (*DestinationCreateHookdeck) GetCredentials

func (o *DestinationCreateHookdeck) GetCredentials() HookdeckCredentials

func (*DestinationCreateHookdeck) GetID

func (o *DestinationCreateHookdeck) GetID() *string

func (*DestinationCreateHookdeck) GetTopics

func (o *DestinationCreateHookdeck) GetTopics() Topics

func (*DestinationCreateHookdeck) GetType

func (DestinationCreateHookdeck) MarshalJSON added in v0.4.0

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

func (*DestinationCreateHookdeck) UnmarshalJSON added in v0.4.0

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

type DestinationCreateHookdeckType

type DestinationCreateHookdeckType string

DestinationCreateHookdeckType - Type of the destination. Must be 'hookdeck'.

const (
	DestinationCreateHookdeckTypeHookdeck DestinationCreateHookdeckType = "hookdeck"
)

func (DestinationCreateHookdeckType) ToPointer

func (*DestinationCreateHookdeckType) UnmarshalJSON

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

type DestinationCreateRabbitMQ

type DestinationCreateRabbitMQ struct {
	// Optional user-provided ID. A UUID will be generated if empty.
	ID *string `json:"id,omitempty"`
	// Type of the destination. Must be 'rabbitmq'.
	Type DestinationCreateRabbitMQType `json:"type"`
	// "*" or an array of enabled topics.
	Topics      Topics              `json:"topics"`
	Config      RabbitMQConfig      `json:"config"`
	Credentials RabbitMQCredentials `json:"credentials"`
}

func (*DestinationCreateRabbitMQ) GetConfig

func (*DestinationCreateRabbitMQ) GetCredentials

func (o *DestinationCreateRabbitMQ) GetCredentials() RabbitMQCredentials

func (*DestinationCreateRabbitMQ) GetID

func (o *DestinationCreateRabbitMQ) GetID() *string

func (*DestinationCreateRabbitMQ) GetTopics

func (o *DestinationCreateRabbitMQ) GetTopics() Topics

func (*DestinationCreateRabbitMQ) GetType

func (DestinationCreateRabbitMQ) MarshalJSON added in v0.4.0

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

func (*DestinationCreateRabbitMQ) UnmarshalJSON added in v0.4.0

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

type DestinationCreateRabbitMQType

type DestinationCreateRabbitMQType string

DestinationCreateRabbitMQType - Type of the destination. Must be 'rabbitmq'.

const (
	DestinationCreateRabbitMQTypeRabbitmq DestinationCreateRabbitMQType = "rabbitmq"
)

func (DestinationCreateRabbitMQType) ToPointer

func (*DestinationCreateRabbitMQType) UnmarshalJSON

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

type DestinationCreateType

type DestinationCreateType string
const (
	DestinationCreateTypeWebhook         DestinationCreateType = "webhook"
	DestinationCreateTypeAwsSqs          DestinationCreateType = "aws_sqs"
	DestinationCreateTypeRabbitmq        DestinationCreateType = "rabbitmq"
	DestinationCreateTypeHookdeck        DestinationCreateType = "hookdeck"
	DestinationCreateTypeAwsKinesis      DestinationCreateType = "aws_kinesis"
	DestinationCreateTypeAzureServicebus DestinationCreateType = "azure_servicebus"
	DestinationCreateTypeAwsS3           DestinationCreateType = "aws_s3"
)

type DestinationCreateWebhook

type DestinationCreateWebhook struct {
	// Optional user-provided ID. A UUID will be generated if empty.
	ID *string `json:"id,omitempty"`
	// Type of the destination. Must be 'webhook'.
	Type DestinationCreateWebhookType `json:"type"`
	// "*" or an array of enabled topics.
	Topics      Topics              `json:"topics"`
	Config      WebhookConfig       `json:"config"`
	Credentials *WebhookCredentials `json:"credentials,omitempty"`
}

func (*DestinationCreateWebhook) GetConfig

func (o *DestinationCreateWebhook) GetConfig() WebhookConfig

func (*DestinationCreateWebhook) GetCredentials

func (o *DestinationCreateWebhook) GetCredentials() *WebhookCredentials

func (*DestinationCreateWebhook) GetID

func (o *DestinationCreateWebhook) GetID() *string

func (*DestinationCreateWebhook) GetTopics

func (o *DestinationCreateWebhook) GetTopics() Topics

func (*DestinationCreateWebhook) GetType

func (DestinationCreateWebhook) MarshalJSON added in v0.4.0

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

func (*DestinationCreateWebhook) UnmarshalJSON added in v0.4.0

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

type DestinationCreateWebhookType

type DestinationCreateWebhookType string

DestinationCreateWebhookType - Type of the destination. Must be 'webhook'.

const (
	DestinationCreateWebhookTypeWebhook DestinationCreateWebhookType = "webhook"
)

func (DestinationCreateWebhookType) ToPointer

func (*DestinationCreateWebhookType) UnmarshalJSON

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

type DestinationHookdeck

type DestinationHookdeck struct {
	// Control plane generated ID or user provided ID for the destination.
	ID string `json:"id"`
	// Type of the destination.
	Type DestinationHookdeckType `json:"type"`
	// "*" or an array of enabled topics.
	Topics Topics `json:"topics"`
	// ISO Date when the destination was disabled, or null if enabled.
	DisabledAt *time.Time `json:"disabled_at"`
	// ISO Date when the destination was created.
	CreatedAt   time.Time           `json:"created_at"`
	Config      any                 `json:"config,omitempty"`
	Credentials HookdeckCredentials `json:"credentials"`
	// A human-readable representation of the destination target (Hookdeck). Read-only.
	Target *string `json:"target,omitempty"`
	// A URL link to the destination target (e.g., Hookdeck dashboard). Read-only.
	TargetURL *string `json:"target_url,omitempty"`
}

func (*DestinationHookdeck) GetConfig

func (o *DestinationHookdeck) GetConfig() any

func (*DestinationHookdeck) GetCreatedAt

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

func (*DestinationHookdeck) GetCredentials

func (o *DestinationHookdeck) GetCredentials() HookdeckCredentials

func (*DestinationHookdeck) GetDisabledAt

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

func (*DestinationHookdeck) GetID

func (o *DestinationHookdeck) GetID() string

func (*DestinationHookdeck) GetTarget

func (o *DestinationHookdeck) GetTarget() *string

func (*DestinationHookdeck) GetTargetURL

func (o *DestinationHookdeck) GetTargetURL() *string

func (*DestinationHookdeck) GetTopics

func (o *DestinationHookdeck) GetTopics() Topics

func (*DestinationHookdeck) GetType

func (DestinationHookdeck) MarshalJSON

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

func (*DestinationHookdeck) UnmarshalJSON

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

type DestinationHookdeckType

type DestinationHookdeckType string

DestinationHookdeckType - Type of the destination.

const (
	DestinationHookdeckTypeHookdeck DestinationHookdeckType = "hookdeck"
)

func (DestinationHookdeckType) ToPointer

func (*DestinationHookdeckType) UnmarshalJSON

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

type DestinationRabbitMQ

type DestinationRabbitMQ struct {
	// Control plane generated ID or user provided ID for the destination.
	ID string `json:"id"`
	// Type of the destination.
	Type DestinationRabbitMQType `json:"type"`
	// "*" or an array of enabled topics.
	Topics Topics `json:"topics"`
	// ISO Date when the destination was disabled, or null if enabled.
	DisabledAt *time.Time `json:"disabled_at"`
	// ISO Date when the destination was created.
	CreatedAt   time.Time           `json:"created_at"`
	Config      RabbitMQConfig      `json:"config"`
	Credentials RabbitMQCredentials `json:"credentials"`
	// A human-readable representation of the destination target (RabbitMQ exchange). Read-only.
	Target *string `json:"target,omitempty"`
	// A URL link to the destination target (not applicable for RabbitMQ exchange). Read-only.
	TargetURL *string `json:"target_url,omitempty"`
}

func (*DestinationRabbitMQ) GetConfig

func (o *DestinationRabbitMQ) GetConfig() RabbitMQConfig

func (*DestinationRabbitMQ) GetCreatedAt

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

func (*DestinationRabbitMQ) GetCredentials

func (o *DestinationRabbitMQ) GetCredentials() RabbitMQCredentials

func (*DestinationRabbitMQ) GetDisabledAt

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

func (*DestinationRabbitMQ) GetID

func (o *DestinationRabbitMQ) GetID() string

func (*DestinationRabbitMQ) GetTarget

func (o *DestinationRabbitMQ) GetTarget() *string

func (*DestinationRabbitMQ) GetTargetURL

func (o *DestinationRabbitMQ) GetTargetURL() *string

func (*DestinationRabbitMQ) GetTopics

func (o *DestinationRabbitMQ) GetTopics() Topics

func (*DestinationRabbitMQ) GetType

func (DestinationRabbitMQ) MarshalJSON

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

func (*DestinationRabbitMQ) UnmarshalJSON

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

type DestinationRabbitMQType

type DestinationRabbitMQType string

DestinationRabbitMQType - Type of the destination.

const (
	DestinationRabbitMQTypeRabbitmq DestinationRabbitMQType = "rabbitmq"
)

func (DestinationRabbitMQType) ToPointer

func (*DestinationRabbitMQType) UnmarshalJSON

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

type DestinationSchemaField

type DestinationSchemaField struct {
	Type        DestinationSchemaFieldType `json:"type"`
	Label       *string                    `json:"label,omitempty"`
	Description *string                    `json:"description,omitempty"`
	Required    bool                       `json:"required"`
	// Indicates if the field contains sensitive information.
	Sensitive *bool `json:"sensitive,omitempty"`
	// Default value for the field.
	Default *string `json:"default,omitempty"`
	// Minimum length for a text input.
	Minlength *int64 `json:"minlength,omitempty"`
	// Maximum length for a text input.
	Maxlength *int64 `json:"maxlength,omitempty"`
	// Regex pattern for validation (compatible with HTML5 pattern attribute).
	Pattern *string `json:"pattern,omitempty"`
}

func (*DestinationSchemaField) GetDefault

func (o *DestinationSchemaField) GetDefault() *string

func (*DestinationSchemaField) GetDescription

func (o *DestinationSchemaField) GetDescription() *string

func (*DestinationSchemaField) GetLabel

func (o *DestinationSchemaField) GetLabel() *string

func (*DestinationSchemaField) GetMaxlength

func (o *DestinationSchemaField) GetMaxlength() *int64

func (*DestinationSchemaField) GetMinlength

func (o *DestinationSchemaField) GetMinlength() *int64

func (*DestinationSchemaField) GetPattern

func (o *DestinationSchemaField) GetPattern() *string

func (*DestinationSchemaField) GetRequired

func (o *DestinationSchemaField) GetRequired() bool

func (*DestinationSchemaField) GetSensitive

func (o *DestinationSchemaField) GetSensitive() *bool

func (*DestinationSchemaField) GetType

type DestinationSchemaFieldType

type DestinationSchemaFieldType string
const (
	DestinationSchemaFieldTypeText     DestinationSchemaFieldType = "text"
	DestinationSchemaFieldTypeCheckbox DestinationSchemaFieldType = "checkbox"
)

func (DestinationSchemaFieldType) ToPointer

func (*DestinationSchemaFieldType) UnmarshalJSON

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

type DestinationType

type DestinationType string
const (
	DestinationTypeWebhook         DestinationType = "webhook"
	DestinationTypeAwsSqs          DestinationType = "aws_sqs"
	DestinationTypeRabbitmq        DestinationType = "rabbitmq"
	DestinationTypeHookdeck        DestinationType = "hookdeck"
	DestinationTypeAwsKinesis      DestinationType = "aws_kinesis"
	DestinationTypeAzureServicebus DestinationType = "azure_servicebus"
	DestinationTypeAwsS3           DestinationType = "aws_s3"
)

type DestinationTypeSchema

type DestinationTypeSchema struct {
	Type        *string `json:"type,omitempty"`
	Label       *string `json:"label,omitempty"`
	Description *string `json:"description,omitempty"`
	// SVG icon string.
	Icon *string `json:"icon,omitempty"`
	// Markdown instructions.
	Instructions *string `json:"instructions,omitempty"`
	// Some destinations may have Oauth flow or other managed-setup flow that can be triggered with a link. If a `remote_setup_url` is set then the user should be prompted to follow the link to configure the destination.
	// See the [building your own UI guide](https://outpost.hookdeck.com/guides/building-your-own-ui.mdx) for recommended UI patterns and wireframes for implementation in your own app.
	RemoteSetupURL *string `json:"remote_setup_url,omitempty"`
	// Config fields are non-secret values that can be stored and displayed to the user in plain text.
	ConfigFields []DestinationSchemaField `json:"config_fields,omitempty"`
	// Credential fields are secret values that will be AES encrypted and obfuscated to the user. Some credentials may not be obfuscated; the destination type dictates the obfuscation logic.
	CredentialFields []DestinationSchemaField `json:"credential_fields,omitempty"`
}

func (*DestinationTypeSchema) GetConfigFields

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

func (*DestinationTypeSchema) GetCredentialFields

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

func (*DestinationTypeSchema) GetDescription

func (o *DestinationTypeSchema) GetDescription() *string

func (*DestinationTypeSchema) GetIcon

func (o *DestinationTypeSchema) GetIcon() *string

func (*DestinationTypeSchema) GetInstructions

func (o *DestinationTypeSchema) GetInstructions() *string

func (*DestinationTypeSchema) GetLabel

func (o *DestinationTypeSchema) GetLabel() *string

func (*DestinationTypeSchema) GetRemoteSetupURL

func (o *DestinationTypeSchema) GetRemoteSetupURL() *string

func (*DestinationTypeSchema) GetType

func (o *DestinationTypeSchema) GetType() *string

type DestinationUpdate

type DestinationUpdate struct {
	DestinationUpdateWebhook    *DestinationUpdateWebhook    `queryParam:"inline" name:"DestinationUpdate"`
	DestinationUpdateAWSSQS     *DestinationUpdateAWSSQS     `queryParam:"inline" name:"DestinationUpdate"`
	DestinationUpdateRabbitMQ   *DestinationUpdateRabbitMQ   `queryParam:"inline" name:"DestinationUpdate"`
	DestinationUpdateHookdeck   *DestinationUpdateHookdeck   `queryParam:"inline" name:"DestinationUpdate"`
	DestinationUpdateAWSKinesis *DestinationUpdateAWSKinesis `queryParam:"inline" name:"DestinationUpdate"`
	DestinationUpdateAwss3      *DestinationUpdateAwss3      `queryParam:"inline" name:"DestinationUpdate"`

	Type DestinationUpdateType
}

func CreateDestinationUpdateDestinationUpdateAWSKinesis

func CreateDestinationUpdateDestinationUpdateAWSKinesis(destinationUpdateAWSKinesis DestinationUpdateAWSKinesis) DestinationUpdate

func CreateDestinationUpdateDestinationUpdateAWSSQS

func CreateDestinationUpdateDestinationUpdateAWSSQS(destinationUpdateAWSSQS DestinationUpdateAWSSQS) DestinationUpdate

func CreateDestinationUpdateDestinationUpdateAwss3 added in v0.4.0

func CreateDestinationUpdateDestinationUpdateAwss3(destinationUpdateAwss3 DestinationUpdateAwss3) DestinationUpdate

func CreateDestinationUpdateDestinationUpdateHookdeck

func CreateDestinationUpdateDestinationUpdateHookdeck(destinationUpdateHookdeck DestinationUpdateHookdeck) DestinationUpdate

func CreateDestinationUpdateDestinationUpdateRabbitMQ

func CreateDestinationUpdateDestinationUpdateRabbitMQ(destinationUpdateRabbitMQ DestinationUpdateRabbitMQ) DestinationUpdate

func CreateDestinationUpdateDestinationUpdateWebhook

func CreateDestinationUpdateDestinationUpdateWebhook(destinationUpdateWebhook DestinationUpdateWebhook) DestinationUpdate

func (DestinationUpdate) MarshalJSON

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

func (*DestinationUpdate) UnmarshalJSON

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

type DestinationUpdateAWSKinesis

type DestinationUpdateAWSKinesis struct {
	// "*" or an array of enabled topics.
	Topics      *Topics                `json:"topics,omitempty"`
	Config      *AWSKinesisConfig      `json:"config,omitempty"`
	Credentials *AWSKinesisCredentials `json:"credentials,omitempty"`
}

func (*DestinationUpdateAWSKinesis) GetConfig

func (*DestinationUpdateAWSKinesis) GetCredentials

func (*DestinationUpdateAWSKinesis) GetTopics

func (o *DestinationUpdateAWSKinesis) GetTopics() *Topics

func (DestinationUpdateAWSKinesis) MarshalJSON added in v0.4.0

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

func (*DestinationUpdateAWSKinesis) UnmarshalJSON added in v0.4.0

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

type DestinationUpdateAWSSQS

type DestinationUpdateAWSSQS struct {
	// "*" or an array of enabled topics.
	Topics      *Topics            `json:"topics,omitempty"`
	Config      *AWSSQSConfig      `json:"config,omitempty"`
	Credentials *AWSSQSCredentials `json:"credentials,omitempty"`
}

func (*DestinationUpdateAWSSQS) GetConfig

func (o *DestinationUpdateAWSSQS) GetConfig() *AWSSQSConfig

func (*DestinationUpdateAWSSQS) GetCredentials

func (o *DestinationUpdateAWSSQS) GetCredentials() *AWSSQSCredentials

func (*DestinationUpdateAWSSQS) GetTopics

func (o *DestinationUpdateAWSSQS) GetTopics() *Topics

func (DestinationUpdateAWSSQS) MarshalJSON added in v0.4.0

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

func (*DestinationUpdateAWSSQS) UnmarshalJSON added in v0.4.0

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

type DestinationUpdateAwss3 added in v0.4.0

type DestinationUpdateAwss3 struct {
	// "*" or an array of enabled topics.
	Topics      *Topics           `json:"topics,omitempty"`
	Config      *Awss3Config      `json:"config,omitempty"`
	Credentials *Awss3Credentials `json:"credentials,omitempty"`
}

func (*DestinationUpdateAwss3) GetConfig added in v0.4.0

func (o *DestinationUpdateAwss3) GetConfig() *Awss3Config

func (*DestinationUpdateAwss3) GetCredentials added in v0.4.0

func (o *DestinationUpdateAwss3) GetCredentials() *Awss3Credentials

func (*DestinationUpdateAwss3) GetTopics added in v0.4.0

func (o *DestinationUpdateAwss3) GetTopics() *Topics

func (DestinationUpdateAwss3) MarshalJSON added in v0.4.0

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

func (*DestinationUpdateAwss3) UnmarshalJSON added in v0.4.0

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

type DestinationUpdateHookdeck

type DestinationUpdateHookdeck struct {
	// "*" or an array of enabled topics.
	Topics      *Topics              `json:"topics,omitempty"`
	Config      any                  `json:"config,omitempty"`
	Credentials *HookdeckCredentials `json:"credentials,omitempty"`
}

func (*DestinationUpdateHookdeck) GetConfig

func (o *DestinationUpdateHookdeck) GetConfig() any

func (*DestinationUpdateHookdeck) GetCredentials

func (o *DestinationUpdateHookdeck) GetCredentials() *HookdeckCredentials

func (*DestinationUpdateHookdeck) GetTopics

func (o *DestinationUpdateHookdeck) GetTopics() *Topics

func (DestinationUpdateHookdeck) MarshalJSON added in v0.4.0

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

func (*DestinationUpdateHookdeck) UnmarshalJSON added in v0.4.0

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

type DestinationUpdateRabbitMQ

type DestinationUpdateRabbitMQ struct {
	// "*" or an array of enabled topics.
	Topics      *Topics              `json:"topics,omitempty"`
	Config      *RabbitMQConfig      `json:"config,omitempty"`
	Credentials *RabbitMQCredentials `json:"credentials,omitempty"`
}

func (*DestinationUpdateRabbitMQ) GetConfig

func (o *DestinationUpdateRabbitMQ) GetConfig() *RabbitMQConfig

func (*DestinationUpdateRabbitMQ) GetCredentials

func (o *DestinationUpdateRabbitMQ) GetCredentials() *RabbitMQCredentials

func (*DestinationUpdateRabbitMQ) GetTopics

func (o *DestinationUpdateRabbitMQ) GetTopics() *Topics

func (DestinationUpdateRabbitMQ) MarshalJSON added in v0.4.0

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

func (*DestinationUpdateRabbitMQ) UnmarshalJSON added in v0.4.0

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

type DestinationUpdateType

type DestinationUpdateType string
const (
	DestinationUpdateTypeDestinationUpdateWebhook    DestinationUpdateType = "DestinationUpdateWebhook"
	DestinationUpdateTypeDestinationUpdateAWSSQS     DestinationUpdateType = "DestinationUpdateAWSSQS"
	DestinationUpdateTypeDestinationUpdateRabbitMQ   DestinationUpdateType = "DestinationUpdateRabbitMQ"
	DestinationUpdateTypeDestinationUpdateHookdeck   DestinationUpdateType = "DestinationUpdateHookdeck"
	DestinationUpdateTypeDestinationUpdateAWSKinesis DestinationUpdateType = "DestinationUpdateAWSKinesis"
	DestinationUpdateTypeDestinationUpdateAwss3      DestinationUpdateType = "DestinationUpdateAWSS3"
)

type DestinationUpdateWebhook

type DestinationUpdateWebhook struct {
	// "*" or an array of enabled topics.
	Topics      *Topics                   `json:"topics,omitempty"`
	Config      *WebhookConfig            `json:"config,omitempty"`
	Credentials *WebhookCredentialsUpdate `json:"credentials,omitempty"`
}

func (*DestinationUpdateWebhook) GetConfig

func (o *DestinationUpdateWebhook) GetConfig() *WebhookConfig

func (*DestinationUpdateWebhook) GetCredentials

func (*DestinationUpdateWebhook) GetTopics

func (o *DestinationUpdateWebhook) GetTopics() *Topics

func (DestinationUpdateWebhook) MarshalJSON added in v0.4.0

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

func (*DestinationUpdateWebhook) UnmarshalJSON added in v0.4.0

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

type DestinationWebhook

type DestinationWebhook struct {
	// Control plane generated ID or user provided ID for the destination.
	ID string `json:"id"`
	// Type of the destination.
	Type DestinationWebhookType `json:"type"`
	// "*" or an array of enabled topics.
	Topics Topics `json:"topics"`
	// ISO Date when the destination was disabled, or null if enabled.
	DisabledAt *time.Time `json:"disabled_at"`
	// ISO Date when the destination was created.
	CreatedAt   time.Time          `json:"created_at"`
	Config      WebhookConfig      `json:"config"`
	Credentials WebhookCredentials `json:"credentials"`
	// A human-readable representation of the destination target (e.g., URL host). Read-only.
	Target *string `json:"target,omitempty"`
	// A URL link to the destination target (the webhook URL). Read-only.
	TargetURL *string `json:"target_url,omitempty"`
}

func (*DestinationWebhook) GetConfig

func (o *DestinationWebhook) GetConfig() WebhookConfig

func (*DestinationWebhook) GetCreatedAt

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

func (*DestinationWebhook) GetCredentials

func (o *DestinationWebhook) GetCredentials() WebhookCredentials

func (*DestinationWebhook) GetDisabledAt

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

func (*DestinationWebhook) GetID

func (o *DestinationWebhook) GetID() string

func (*DestinationWebhook) GetTarget

func (o *DestinationWebhook) GetTarget() *string

func (*DestinationWebhook) GetTargetURL

func (o *DestinationWebhook) GetTargetURL() *string

func (*DestinationWebhook) GetTopics

func (o *DestinationWebhook) GetTopics() Topics

func (*DestinationWebhook) GetType

func (DestinationWebhook) MarshalJSON

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

func (*DestinationWebhook) UnmarshalJSON

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

type DestinationWebhookType

type DestinationWebhookType string

DestinationWebhookType - Type of the destination.

const (
	DestinationWebhookTypeWebhook DestinationWebhookType = "webhook"
)

func (DestinationWebhookType) ToPointer

func (*DestinationWebhookType) UnmarshalJSON

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

type Event

type Event struct {
	ID            *string `json:"id,omitempty"`
	DestinationID *string `json:"destination_id,omitempty"`
	Topic         *string `json:"topic,omitempty"`
	// Time the event was received/processed.
	Time *time.Time `json:"time,omitempty"`
	// Time the event was successfully delivered.
	SuccessfulAt *time.Time `json:"successful_at,omitempty"`
	// Key-value string pairs of metadata associated with the event.
	Metadata map[string]string `json:"metadata,omitempty"`
	// Freeform JSON data of the event.
	Data map[string]any `json:"data,omitempty"`
}

func (*Event) GetData

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

func (*Event) GetDestinationID

func (o *Event) GetDestinationID() *string

func (*Event) GetID

func (o *Event) GetID() *string

func (*Event) GetMetadata

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

func (*Event) GetSuccessfulAt

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

func (*Event) GetTime

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

func (*Event) GetTopic

func (o *Event) GetTopic() *string

func (Event) MarshalJSON

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

func (*Event) UnmarshalJSON

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

type HTTPMetadata

type HTTPMetadata struct {
	// Raw HTTP response; suitable for custom response parsing
	Response *http.Response `json:"-"`
	// Raw HTTP request; suitable for debugging
	Request *http.Request `json:"-"`
}

func (*HTTPMetadata) GetRequest

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

func (*HTTPMetadata) GetResponse

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

type HookdeckCredentials

type HookdeckCredentials struct {
	// Hookdeck authentication token.
	Token string `json:"token"`
}

func (*HookdeckCredentials) GetToken

func (o *HookdeckCredentials) GetToken() string

func (HookdeckCredentials) MarshalJSON added in v0.4.0

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

func (*HookdeckCredentials) UnmarshalJSON added in v0.4.0

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

type PortalRedirect

type PortalRedirect struct {
	// Redirect URL containing a JWT to authenticate the user with the portal.
	RedirectURL *string `json:"redirect_url,omitempty"`
}

func (*PortalRedirect) GetRedirectURL

func (o *PortalRedirect) GetRedirectURL() *string

type PublishRequest

type PublishRequest struct {
	// Optional. A unique identifier for the event. If not provided, a UUID will be generated.
	ID *string `json:"id,omitempty"`
	// The ID of the tenant to publish for.
	TenantID *string `json:"tenant_id,omitempty"`
	// Optional. Route event to a specific destination.
	DestinationID *string `json:"destination_id,omitempty"`
	// Topic name for the event. Required if Outpost has been configured with topics.
	Topic *string `json:"topic,omitempty"`
	// Should event delivery be retried on failure.
	EligibleForRetry *bool `json:"eligible_for_retry,omitempty"`
	// Any key-value string pairs for metadata.
	Metadata map[string]string `json:"metadata,omitempty"`
	// Any JSON payload for the event data.
	Data map[string]any `json:"data"`
}

func (*PublishRequest) GetData

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

func (*PublishRequest) GetDestinationID

func (o *PublishRequest) GetDestinationID() *string

func (*PublishRequest) GetEligibleForRetry

func (o *PublishRequest) GetEligibleForRetry() *bool

func (*PublishRequest) GetID added in v0.2.0

func (o *PublishRequest) GetID() *string

func (*PublishRequest) GetMetadata

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

func (*PublishRequest) GetTenantID

func (o *PublishRequest) GetTenantID() *string

func (*PublishRequest) GetTopic

func (o *PublishRequest) GetTopic() *string

type PublishResponse added in v0.2.1

type PublishResponse struct {
	// The ID of the event that was accepted for publishing. This will be the ID provided in the request's `id` field if present, otherwise it's a server-generated UUID.
	ID string `json:"id"`
}

func (*PublishResponse) GetID added in v0.2.1

func (o *PublishResponse) GetID() string

type RabbitMQConfig

type RabbitMQConfig struct {
	// RabbitMQ server address (host:port).
	ServerURL string `json:"server_url"`
	// The exchange to publish messages to.
	Exchange string `json:"exchange"`
	// Whether to use TLS connection (amqps). Defaults to "false".
	TLS *TLS `json:"tls,omitempty"`
}

func (*RabbitMQConfig) GetExchange

func (o *RabbitMQConfig) GetExchange() string

func (*RabbitMQConfig) GetServerURL

func (o *RabbitMQConfig) GetServerURL() string

func (*RabbitMQConfig) GetTLS

func (o *RabbitMQConfig) GetTLS() *TLS

func (RabbitMQConfig) MarshalJSON added in v0.4.0

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

func (*RabbitMQConfig) UnmarshalJSON added in v0.4.0

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

type RabbitMQCredentials

type RabbitMQCredentials struct {
	// RabbitMQ username.
	Username string `json:"username"`
	// RabbitMQ password.
	Password string `json:"password"`
}

func (*RabbitMQCredentials) GetPassword

func (o *RabbitMQCredentials) GetPassword() string

func (*RabbitMQCredentials) GetUsername

func (o *RabbitMQCredentials) GetUsername() string

func (RabbitMQCredentials) MarshalJSON added in v0.4.0

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

func (*RabbitMQCredentials) UnmarshalJSON added in v0.4.0

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

type Security

type Security struct {
	AdminAPIKey *string `security:"scheme,type=http,subtype=bearer,name=Authorization"`
	TenantJwt   *string `security:"scheme,type=http,subtype=bearer,name=Authorization"`
}

func (*Security) GetAdminAPIKey

func (o *Security) GetAdminAPIKey() *string

func (*Security) GetTenantJwt

func (o *Security) GetTenantJwt() *string

type Status

type Status string
const (
	StatusSuccess Status = "success"
	StatusFailed  Status = "failed"
)

func (Status) ToPointer

func (e Status) ToPointer() *Status

func (*Status) UnmarshalJSON

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

type SuccessResponse

type SuccessResponse struct {
	Success *bool `json:"success,omitempty"`
}

func (*SuccessResponse) GetSuccess

func (o *SuccessResponse) GetSuccess() *bool

type TLS

type TLS string

TLS - Whether to use TLS connection (amqps). Defaults to "false".

const (
	TLSTrue  TLS = "true"
	TLSFalse TLS = "false"
)

func (TLS) ToPointer

func (e TLS) ToPointer() *TLS

func (*TLS) UnmarshalJSON

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

type Tenant

type Tenant struct {
	// User-defined system ID for the tenant.
	ID *string `json:"id,omitempty"`
	// Number of destinations associated with the tenant.
	DestinationsCount *int64 `json:"destinations_count,omitempty"`
	// List of subscribed topics across all destinations for this tenant.
	Topics []string `json:"topics,omitempty"`
	// ISO Date when the tenant was created.
	CreatedAt *time.Time `json:"created_at,omitempty"`
}

func (*Tenant) GetCreatedAt

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

func (*Tenant) GetDestinationsCount

func (o *Tenant) GetDestinationsCount() *int64

func (*Tenant) GetID

func (o *Tenant) GetID() *string

func (*Tenant) GetTopics

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

func (Tenant) MarshalJSON

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

func (*Tenant) UnmarshalJSON

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

type TenantToken

type TenantToken struct {
	// JWT token scoped to the tenant for safe browser API calls.
	Token *string `json:"token,omitempty"`
}

func (*TenantToken) GetToken

func (o *TenantToken) GetToken() *string

type Topics

type Topics struct {
	TopicsEnum *TopicsEnum `queryParam:"inline" name:"Topics"`
	ArrayOfStr []string    `queryParam:"inline" name:"Topics"`

	Type TopicsType
}

Topics - "*" or an array of enabled topics.

func CreateTopicsArrayOfStr

func CreateTopicsArrayOfStr(arrayOfStr []string) Topics

func CreateTopicsTopicsEnum

func CreateTopicsTopicsEnum(topicsEnum TopicsEnum) Topics

func (Topics) MarshalJSON

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

func (*Topics) UnmarshalJSON

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

type TopicsEnum

type TopicsEnum string
const (
	TopicsEnumWildcard TopicsEnum = "*"
)

func (TopicsEnum) ToPointer

func (e TopicsEnum) ToPointer() *TopicsEnum

func (*TopicsEnum) UnmarshalJSON

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

type TopicsType

type TopicsType string
const (
	TopicsTypeTopicsEnum TopicsType = "Topics_enum"
	TopicsTypeArrayOfStr TopicsType = "arrayOfStr"
)

type WebhookConfig

type WebhookConfig struct {
	// The URL to send the webhook events to.
	URL string `json:"url"`
}

func (*WebhookConfig) GetURL

func (o *WebhookConfig) GetURL() string

func (WebhookConfig) MarshalJSON added in v0.4.0

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

func (*WebhookConfig) UnmarshalJSON added in v0.4.0

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

type WebhookCredentials

type WebhookCredentials struct {
	// The secret used for signing webhook requests. Auto-generated if omitted on creation by admin. Read-only for tenants unless rotating.
	Secret *string `json:"secret,omitempty"`
	// The previous secret used during rotation. Valid for 24 hours by default. Read-only.
	PreviousSecret *string `json:"previous_secret,omitempty"`
	// ISO timestamp when the previous secret becomes invalid. Read-only.
	PreviousSecretInvalidAt *time.Time `json:"previous_secret_invalid_at,omitempty"`
}

func (*WebhookCredentials) GetPreviousSecret

func (o *WebhookCredentials) GetPreviousSecret() *string

func (*WebhookCredentials) GetPreviousSecretInvalidAt

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

func (*WebhookCredentials) GetSecret

func (o *WebhookCredentials) GetSecret() *string

func (WebhookCredentials) MarshalJSON

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

func (*WebhookCredentials) UnmarshalJSON

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

type WebhookCredentialsUpdate

type WebhookCredentialsUpdate struct {
	// New secret (only allowed for admin).
	Secret *string `json:"secret,omitempty"`
	// Previous secret for rotation (only allowed for admin).
	PreviousSecret *string `json:"previous_secret,omitempty"`
	// Invalidation time for previous secret (only allowed for admin).
	PreviousSecretInvalidAt *time.Time `json:"previous_secret_invalid_at,omitempty"`
	// Set to true to rotate the secret. The current secret becomes the previous_secret, and a new secret is generated. `previous_secret_invalid_at` defaults to 24h if not provided.
	RotateSecret *bool `json:"rotate_secret,omitempty"`
}

func (*WebhookCredentialsUpdate) GetPreviousSecret

func (o *WebhookCredentialsUpdate) GetPreviousSecret() *string

func (*WebhookCredentialsUpdate) GetPreviousSecretInvalidAt

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

func (*WebhookCredentialsUpdate) GetRotateSecret

func (o *WebhookCredentialsUpdate) GetRotateSecret() *bool

func (*WebhookCredentialsUpdate) GetSecret

func (o *WebhookCredentialsUpdate) GetSecret() *string

func (WebhookCredentialsUpdate) MarshalJSON

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

func (*WebhookCredentialsUpdate) UnmarshalJSON

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

Jump to

Keyboard shortcuts

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