destgcppubsub

package

v0.7.0 Latest Latest Go to latest Published: Oct 13, 2025 License: Apache-2.0 Imports: 11 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/hookdeck/outpost

Links

Open Source Insights

Documentation ¶

Index ¶

type GCPPubSubDestination
- func New(loader metadata.MetadataLoader, ...) (*GCPPubSubDestination, error)
type GCPPubSubDestinationConfig
type GCPPubSubDestinationCredentials
type GCPPubSubPublisher

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type GCPPubSubDestination ¶

type GCPPubSubDestination struct {
	*destregistry.BaseProvider
}

func New ¶

func New(loader metadata.MetadataLoader, basePublisherOpts []destregistry.BasePublisherOption) (*GCPPubSubDestination, error)

func (*GCPPubSubDestination) ComputeTarget ¶

func (d *GCPPubSubDestination) ComputeTarget(destination *models.Destination) destregistry.DestinationTarget

func (*GCPPubSubDestination) CreatePublisher ¶

func (d *GCPPubSubDestination) CreatePublisher(ctx context.Context, destination *models.Destination) (destregistry.Publisher, error)

func (*GCPPubSubDestination) Preprocess ¶

func (d *GCPPubSubDestination) Preprocess(newDestination *models.Destination, originalDestination *models.Destination, opts *destregistry.PreprocessDestinationOpts) error

func (*GCPPubSubDestination) Validate ¶

func (d *GCPPubSubDestination) Validate(ctx context.Context, destination *models.Destination) error

type GCPPubSubDestinationConfig ¶

type GCPPubSubDestinationConfig struct {
	ProjectID string
	Topic     string
	Endpoint  string // For emulator support
}

type GCPPubSubDestinationCredentials ¶

type GCPPubSubDestinationCredentials struct {
	ServiceAccountJSON string
}

type GCPPubSubPublisher ¶

type GCPPubSubPublisher struct {
	*destregistry.BasePublisher
	// contains filtered or unexported fields
}

func (*GCPPubSubPublisher) Close ¶

func (pub *GCPPubSubPublisher) Close() error

func (*GCPPubSubPublisher) Format ¶

func (pub *GCPPubSubPublisher) Format(ctx context.Context, event *models.Event) (*pubsub.Message, error)

func (*GCPPubSubPublisher) Publish ¶

func (pub *GCPPubSubPublisher) Publish(ctx context.Context, event *models.Event) (*destregistry.Delivery, error)

Source Files ¶

View all Source files

destgcppubsub.go

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