pubsub

package
v0.26.0 Latest Latest
Warning

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

 Go to latest Published: Jun 19, 2026 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	OnMessageEmittedEventType = "gcp.pubsub.message"
	OnMessageSubscriptionType = "pubsub.onMessage"
)
View Source 
const (
	ResourceTypeTopic        = "gcp.pubsub.topic"
	ResourceTypeSubscription = "gcp.pubsub.subscription"
)

Variables

This section is empty.

Functions

func CreatePullSubscription added in v0.12.0 

func CreatePullSubscription(ctx context.Context, client *common.Client, projectID, subscriptionID, topicID string) error

func CreatePushSubscription 

func CreatePushSubscription(ctx context.Context, client *common.Client, projectID, subscriptionID, topicID, pushEndpoint string, filter ...string) error

func CreateSink 

func CreateSink(ctx context.Context, client *common.Client, projectID, sinkID, topicID, filter string) (string, error)

func CreateTopic 

func CreateTopic(ctx context.Context, client *common.Client, projectID, topicID string) error

func DeleteSink 

func DeleteSink(ctx context.Context, client *common.Client, projectID, sinkID string) error

func DeleteSubscription 

func DeleteSubscription(ctx context.Context, client *common.Client, projectID, subscriptionID string) error

func DeleteTopic 

func DeleteTopic(ctx context.Context, client *common.Client, projectID, topicID string) error

func EnsureTopicPublisher 

func EnsureTopicPublisher(ctx context.Context, client *common.Client, projectID, topicID, writerIdentity string) error

func GetSink 

func GetSink(ctx context.Context, client *common.Client, projectID, sinkID string) (string, error)

func IsAPIEnabled 

func IsAPIEnabled(ctx context.Context, client *common.Client, projectID, service string) (bool, error)

func ListSubscriptionResources added in v0.12.0 

func ListSubscriptionResources(ctx context.Context, client *gcpcommon.Client, topic string) ([]core.IntegrationResource, error)

func ListTopicResources added in v0.12.0 

func ListTopicResources(ctx context.Context, client *gcpcommon.Client) ([]core.IntegrationResource, error)

func PublishMessageToTopic added in v0.12.0 

func PublishMessageToTopic(ctx context.Context, client *common.Client, projectID, topicID, data string, attributes map[string]string) (string, error)

func SubscriptionShortName added in v0.12.0 

func SubscriptionShortName(name string) string

func TopicShortName added in v0.12.0 

func TopicShortName(name string) string

func UpdatePushEndpoint added in v0.11.0 

func UpdatePushEndpoint(ctx context.Context, client *common.Client, projectID, subscriptionID, pushEndpoint string) error

Types

type CreateSubscriptionComponent added in v0.12.0 

type CreateSubscriptionComponent struct{}

func (*CreateSubscriptionComponent) Cancel added in v0.12.0 

func (c *CreateSubscriptionComponent) Cancel(_ core.ExecutionContext) error

func (*CreateSubscriptionComponent) Cleanup added in v0.12.0 

func (c *CreateSubscriptionComponent) Cleanup(_ core.SetupContext) error

func (*CreateSubscriptionComponent) Color added in v0.12.0 

func (c *CreateSubscriptionComponent) Color() string

func (*CreateSubscriptionComponent) Configuration added in v0.12.0 

func (c *CreateSubscriptionComponent) Configuration() []configuration.Field

func (*CreateSubscriptionComponent) Description added in v0.12.0 

func (c *CreateSubscriptionComponent) Description() string

func (*CreateSubscriptionComponent) Documentation added in v0.12.0 

func (c *CreateSubscriptionComponent) Documentation() string

func (*CreateSubscriptionComponent) ExampleOutput added in v0.12.0 

func (c *CreateSubscriptionComponent) ExampleOutput() map[string]any

func (*CreateSubscriptionComponent) Execute added in v0.12.0 

func (c *CreateSubscriptionComponent) Execute(ctx core.ExecutionContext) error

func (*CreateSubscriptionComponent) HandleHook added in v0.18.0 

func (c *CreateSubscriptionComponent) HandleHook(ctx core.ActionHookContext) error

func (*CreateSubscriptionComponent) HandleWebhook added in v0.12.0 

func (c *CreateSubscriptionComponent) HandleWebhook(_ core.WebhookRequestContext) (int, *core.WebhookResponseBody, error)

func (*CreateSubscriptionComponent) Hooks added in v0.18.0 

func (c *CreateSubscriptionComponent) Hooks() []core.Hook

func (*CreateSubscriptionComponent) Icon added in v0.12.0 

func (c *CreateSubscriptionComponent) Icon() string

func (*CreateSubscriptionComponent) Label added in v0.12.0 

func (c *CreateSubscriptionComponent) Label() string

func (*CreateSubscriptionComponent) Name added in v0.12.0 

func (c *CreateSubscriptionComponent) Name() string

func (*CreateSubscriptionComponent) OutputChannels added in v0.12.0 

func (c *CreateSubscriptionComponent) OutputChannels(_ any) []core.OutputChannel

func (*CreateSubscriptionComponent) ProcessQueueItem added in v0.12.0 

func (c *CreateSubscriptionComponent) ProcessQueueItem(ctx core.ProcessQueueContext) (*uuid.UUID, error)

func (*CreateSubscriptionComponent) Setup added in v0.12.0 

func (c *CreateSubscriptionComponent) Setup(ctx core.SetupContext) error

type CreateSubscriptionConfiguration added in v0.12.0 

type CreateSubscriptionConfiguration struct {
	Topic        string `json:"topic" mapstructure:"topic"`
	Subscription string `json:"subscription" mapstructure:"subscription"`
	Type         string `json:"type" mapstructure:"type"`
	PushEndpoint string `json:"pushEndpoint" mapstructure:"pushEndpoint"`
}

type CreateTopicComponent added in v0.12.0 

type CreateTopicComponent struct{}

func (*CreateTopicComponent) Cancel added in v0.12.0 

func (c *CreateTopicComponent) Cancel(_ core.ExecutionContext) error

func (*CreateTopicComponent) Cleanup added in v0.12.0 

func (c *CreateTopicComponent) Cleanup(_ core.SetupContext) error

func (*CreateTopicComponent) Color added in v0.12.0 

func (c *CreateTopicComponent) Color() string

func (*CreateTopicComponent) Configuration added in v0.12.0 

func (c *CreateTopicComponent) Configuration() []configuration.Field

func (*CreateTopicComponent) Description added in v0.12.0 

func (c *CreateTopicComponent) Description() string

func (*CreateTopicComponent) Documentation added in v0.12.0 

func (c *CreateTopicComponent) Documentation() string

func (*CreateTopicComponent) ExampleOutput added in v0.12.0 

func (c *CreateTopicComponent) ExampleOutput() map[string]any

func (*CreateTopicComponent) Execute added in v0.12.0 

func (c *CreateTopicComponent) Execute(ctx core.ExecutionContext) error

func (*CreateTopicComponent) HandleHook added in v0.18.0 

func (c *CreateTopicComponent) HandleHook(ctx core.ActionHookContext) error

func (*CreateTopicComponent) HandleWebhook added in v0.12.0 

func (c *CreateTopicComponent) HandleWebhook(_ core.WebhookRequestContext) (int, *core.WebhookResponseBody, error)

func (*CreateTopicComponent) Hooks added in v0.18.0 

func (c *CreateTopicComponent) Hooks() []core.Hook

func (*CreateTopicComponent) Icon added in v0.12.0 

func (c *CreateTopicComponent) Icon() string

func (*CreateTopicComponent) Label added in v0.12.0 

func (c *CreateTopicComponent) Label() string

func (*CreateTopicComponent) Name added in v0.12.0 

func (c *CreateTopicComponent) Name() string

func (*CreateTopicComponent) OutputChannels added in v0.12.0 

func (c *CreateTopicComponent) OutputChannels(_ any) []core.OutputChannel

func (*CreateTopicComponent) ProcessQueueItem added in v0.12.0 

func (c *CreateTopicComponent) ProcessQueueItem(ctx core.ProcessQueueContext) (*uuid.UUID, error)

func (*CreateTopicComponent) Setup added in v0.12.0 

func (c *CreateTopicComponent) Setup(ctx core.SetupContext) error

type CreateTopicConfiguration added in v0.12.0 

type CreateTopicConfiguration struct {
	Topic string `json:"topic" mapstructure:"topic"`
}

type DeleteSubscriptionComponent added in v0.12.0 

type DeleteSubscriptionComponent struct{}

func (*DeleteSubscriptionComponent) Cancel added in v0.12.0 

func (c *DeleteSubscriptionComponent) Cancel(_ core.ExecutionContext) error

func (*DeleteSubscriptionComponent) Cleanup added in v0.12.0 

func (c *DeleteSubscriptionComponent) Cleanup(_ core.SetupContext) error

func (*DeleteSubscriptionComponent) Color added in v0.12.0 

func (c *DeleteSubscriptionComponent) Color() string

func (*DeleteSubscriptionComponent) Configuration added in v0.12.0 

func (c *DeleteSubscriptionComponent) Configuration() []configuration.Field

func (*DeleteSubscriptionComponent) Description added in v0.12.0 

func (c *DeleteSubscriptionComponent) Description() string

func (*DeleteSubscriptionComponent) Documentation added in v0.12.0 

func (c *DeleteSubscriptionComponent) Documentation() string

func (*DeleteSubscriptionComponent) ExampleOutput added in v0.12.0 

func (c *DeleteSubscriptionComponent) ExampleOutput() map[string]any

func (*DeleteSubscriptionComponent) Execute added in v0.12.0 

func (c *DeleteSubscriptionComponent) Execute(ctx core.ExecutionContext) error

func (*DeleteSubscriptionComponent) HandleHook added in v0.18.0 

func (c *DeleteSubscriptionComponent) HandleHook(ctx core.ActionHookContext) error

func (*DeleteSubscriptionComponent) HandleWebhook added in v0.12.0 

func (c *DeleteSubscriptionComponent) HandleWebhook(_ core.WebhookRequestContext) (int, *core.WebhookResponseBody, error)

func (*DeleteSubscriptionComponent) Hooks added in v0.18.0 

func (c *DeleteSubscriptionComponent) Hooks() []core.Hook

func (*DeleteSubscriptionComponent) Icon added in v0.12.0 

func (c *DeleteSubscriptionComponent) Icon() string

func (*DeleteSubscriptionComponent) Label added in v0.12.0 

func (c *DeleteSubscriptionComponent) Label() string

func (*DeleteSubscriptionComponent) Name added in v0.12.0 

func (c *DeleteSubscriptionComponent) Name() string

func (*DeleteSubscriptionComponent) OutputChannels added in v0.12.0 

func (c *DeleteSubscriptionComponent) OutputChannels(_ any) []core.OutputChannel

func (*DeleteSubscriptionComponent) ProcessQueueItem added in v0.12.0 

func (c *DeleteSubscriptionComponent) ProcessQueueItem(ctx core.ProcessQueueContext) (*uuid.UUID, error)

func (*DeleteSubscriptionComponent) Setup added in v0.12.0 

func (c *DeleteSubscriptionComponent) Setup(ctx core.SetupContext) error

type DeleteSubscriptionConfiguration added in v0.12.0 

type DeleteSubscriptionConfiguration struct {
	Subscription string `json:"subscription" mapstructure:"subscription"`
}

type DeleteTopicComponent added in v0.12.0 

type DeleteTopicComponent struct{}

func (*DeleteTopicComponent) Cancel added in v0.12.0 

func (c *DeleteTopicComponent) Cancel(_ core.ExecutionContext) error

func (*DeleteTopicComponent) Cleanup added in v0.12.0 

func (c *DeleteTopicComponent) Cleanup(_ core.SetupContext) error

func (*DeleteTopicComponent) Color added in v0.12.0 

func (c *DeleteTopicComponent) Color() string

func (*DeleteTopicComponent) Configuration added in v0.12.0 

func (c *DeleteTopicComponent) Configuration() []configuration.Field

func (*DeleteTopicComponent) Description added in v0.12.0 

func (c *DeleteTopicComponent) Description() string

func (*DeleteTopicComponent) Documentation added in v0.12.0 

func (c *DeleteTopicComponent) Documentation() string

func (*DeleteTopicComponent) ExampleOutput added in v0.12.0 

func (c *DeleteTopicComponent) ExampleOutput() map[string]any

func (*DeleteTopicComponent) Execute added in v0.12.0 

func (c *DeleteTopicComponent) Execute(ctx core.ExecutionContext) error

func (*DeleteTopicComponent) HandleHook added in v0.18.0 

func (c *DeleteTopicComponent) HandleHook(ctx core.ActionHookContext) error

func (*DeleteTopicComponent) HandleWebhook added in v0.12.0 

func (c *DeleteTopicComponent) HandleWebhook(_ core.WebhookRequestContext) (int, *core.WebhookResponseBody, error)

func (*DeleteTopicComponent) Hooks added in v0.18.0 

func (c *DeleteTopicComponent) Hooks() []core.Hook

func (*DeleteTopicComponent) Icon added in v0.12.0 

func (c *DeleteTopicComponent) Icon() string

func (*DeleteTopicComponent) Label added in v0.12.0 

func (c *DeleteTopicComponent) Label() string

func (*DeleteTopicComponent) Name added in v0.12.0 

func (c *DeleteTopicComponent) Name() string

func (*DeleteTopicComponent) OutputChannels added in v0.12.0 

func (c *DeleteTopicComponent) OutputChannels(_ any) []core.OutputChannel

func (*DeleteTopicComponent) ProcessQueueItem added in v0.12.0 

func (c *DeleteTopicComponent) ProcessQueueItem(ctx core.ProcessQueueContext) (*uuid.UUID, error)

func (*DeleteTopicComponent) Setup added in v0.12.0 

func (c *DeleteTopicComponent) Setup(ctx core.SetupContext) error

type DeleteTopicConfiguration added in v0.12.0 

type DeleteTopicConfiguration struct {
	Topic string `json:"topic" mapstructure:"topic"`
}

type OnMessage added in v0.12.0 

type OnMessage struct{}

func (*OnMessage) Cleanup added in v0.12.0 

func (t *OnMessage) Cleanup(ctx core.TriggerContext) error

func (*OnMessage) Color added in v0.12.0 

func (t *OnMessage) Color() string

func (*OnMessage) Configuration added in v0.12.0 

func (t *OnMessage) Configuration() []configuration.Field

func (*OnMessage) Description added in v0.12.0 

func (t *OnMessage) Description() string

func (*OnMessage) Documentation added in v0.12.0 

func (t *OnMessage) Documentation() string

func (*OnMessage) ExampleData added in v0.12.0 

func (t *OnMessage) ExampleData() map[string]any

func (*OnMessage) HandleHook added in v0.18.0 

func (t *OnMessage) HandleHook(ctx core.TriggerHookContext) (map[string]any, error)

func (*OnMessage) HandleWebhook added in v0.12.0 

func (t *OnMessage) HandleWebhook(ctx core.WebhookRequestContext) (int, *core.WebhookResponseBody, error)

func (*OnMessage) Hooks added in v0.18.0 

func (t *OnMessage) Hooks() []core.Hook

func (*OnMessage) Icon added in v0.12.0 

func (t *OnMessage) Icon() string

func (*OnMessage) Label added in v0.12.0 

func (t *OnMessage) Label() string

func (*OnMessage) Name added in v0.12.0 

func (t *OnMessage) Name() string

func (*OnMessage) OnIntegrationMessage added in v0.12.0 

func (t *OnMessage) OnIntegrationMessage(ctx core.IntegrationMessageContext) error

func (*OnMessage) Setup added in v0.12.0 

func (t *OnMessage) Setup(ctx core.TriggerContext) error

type OnMessageConfiguration added in v0.12.0 

type OnMessageConfiguration struct {
	Topic        string `json:"topic" mapstructure:"topic"`
	Subscription string `json:"subscription" mapstructure:"subscription"`
}

type OnMessageMetadata added in v0.12.0 

type OnMessageMetadata struct {
	InternalSubscriptionID string `json:"internalSubscription"`
	Topic                  string `json:"topic"`
	GCPSubName             string `json:"gcpSubName"`
}

type PublishMessage added in v0.12.0 

type PublishMessage struct{}

func (*PublishMessage) Cancel added in v0.12.0 

func (c *PublishMessage) Cancel(_ core.ExecutionContext) error

func (*PublishMessage) Cleanup added in v0.12.0 

func (c *PublishMessage) Cleanup(_ core.SetupContext) error

func (*PublishMessage) Color added in v0.12.0 

func (c *PublishMessage) Color() string

func (*PublishMessage) Configuration added in v0.12.0 

func (c *PublishMessage) Configuration() []configuration.Field

func (*PublishMessage) Description added in v0.12.0 

func (c *PublishMessage) Description() string

func (*PublishMessage) Documentation added in v0.12.0 

func (c *PublishMessage) Documentation() string

func (*PublishMessage) ExampleOutput added in v0.12.0 

func (c *PublishMessage) ExampleOutput() map[string]any

func (*PublishMessage) Execute added in v0.12.0 

func (c *PublishMessage) Execute(ctx core.ExecutionContext) error

func (*PublishMessage) HandleHook added in v0.18.0 

func (c *PublishMessage) HandleHook(ctx core.ActionHookContext) error

func (*PublishMessage) HandleWebhook added in v0.12.0 

func (c *PublishMessage) HandleWebhook(_ core.WebhookRequestContext) (int, *core.WebhookResponseBody, error)

func (*PublishMessage) Hooks added in v0.18.0 

func (c *PublishMessage) Hooks() []core.Hook

func (*PublishMessage) Icon added in v0.12.0 

func (c *PublishMessage) Icon() string

func (*PublishMessage) Label added in v0.12.0 

func (c *PublishMessage) Label() string

func (*PublishMessage) Name added in v0.12.0 

func (c *PublishMessage) Name() string

func (*PublishMessage) OutputChannels added in v0.12.0 

func (c *PublishMessage) OutputChannels(_ any) []core.OutputChannel

func (*PublishMessage) ProcessQueueItem added in v0.12.0 

func (c *PublishMessage) ProcessQueueItem(ctx core.ProcessQueueContext) (*uuid.UUID, error)

func (*PublishMessage) Setup added in v0.12.0 

func (c *PublishMessage) Setup(ctx core.SetupContext) error

type PublishMessageConfiguration added in v0.12.0 

type PublishMessageConfiguration struct {
	Topic  string  `json:"topic" mapstructure:"topic"`
	Format string  `json:"format" mapstructure:"format"`
	JSON   *any    `json:"json" mapstructure:"json"`
	Text   *string `json:"text" mapstructure:"text"`
}

type SubscriptionResource added in v0.12.0 

type SubscriptionResource struct {
	Name  string `json:"name"`
	Topic string `json:"topic"`
}

func ListSubscriptions added in v0.12.0 

func ListSubscriptions(ctx context.Context, client *common.Client, projectID string) ([]SubscriptionResource, error)

type TopicResource added in v0.12.0 

type TopicResource struct {
	Name string `json:"name"`
}

func ListTopics added in v0.12.0 

func ListTopics(ctx context.Context, client *common.Client, projectID string) ([]TopicResource, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.