Versions in this module Expand all Collapse all v0 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)
Go to main page