Help us shape the future of Go! Take the 2026 Go Developer Survey

pubsub

package
v1.17.2 Latest Latest
Warning

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

Go to latest
Published: Mar 18, 2026 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewGCPPubSub

func NewGCPPubSub(logger logger.Logger) bindings.InputOutputBinding

NewGCPPubSub returns a new GCPPubSub instance.

Types

type GCPAuthJSON added in v1.16.0

type GCPAuthJSON struct {
	ProjectID           string `json:"project_id"`
	PrivateKeyID        string `json:"private_key_id"`
	PrivateKey          string `json:"private_key"`
	ClientEmail         string `json:"client_email"`
	ClientID            string `json:"client_id"`
	AuthURI             string `json:"auth_uri"`
	TokenURI            string `json:"token_uri"`
	AuthProviderCertURL string `json:"auth_provider_x509_cert_url"`
	ClientCertURL       string `json:"client_x509_cert_url"`
	Type                string `json:"type"`
}

type GCPPubSub

type GCPPubSub struct {
	// contains filtered or unexported fields
}

GCPPubSub is an input/output binding for GCP Pub Sub.

func (*GCPPubSub) Close added in v1.4.4

func (g *GCPPubSub) Close() error

func (*GCPPubSub) GetComponentMetadata added in v1.11.0

func (g *GCPPubSub) GetComponentMetadata() (metadataInfo contribMetadata.MetadataMap)

GetComponentMetadata returns the metadata of the component.

func (*GCPPubSub) Init

func (g *GCPPubSub) Init(ctx context.Context, metadata bindings.Metadata) error

Init parses metadata and creates a new Pub Sub client.

func (*GCPPubSub) Invoke

func (*GCPPubSub) Operations

func (g *GCPPubSub) Operations() []bindings.OperationKind

func (*GCPPubSub) Read

func (g *GCPPubSub) Read(ctx context.Context, handler bindings.Handler) error

Jump to

Keyboard shortcuts

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