pubsub

Documentation

Index

• func NewGCPPubSub(logger logger.Logger) bindings.InputOutputBinding
• type GCPPubSub
  • func (g *GCPPubSub) Close() error
  • func (g *GCPPubSub) GetComponentMetadata() map[string]string
  • func (g *GCPPubSub) Init(ctx context.Context, metadata bindings.Metadata) error
  • func (g *GCPPubSub) Invoke(ctx context.Context, req *bindings.InvokeRequest) (*bindings.InvokeResponse, error)
  • func (g *GCPPubSub) Operations() []bindings.OperationKind
  • func (g *GCPPubSub) Read(ctx context.Context, handler bindings.Handler) error

Functions

func NewGCPPubSub

func NewGCPPubSub(logger logger.Logger) bindings.InputOutputBinding

NewGCPPubSub returns a new GCPPubSub instance.

Types

type GCPPubSub

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

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

func (*GCPPubSub) Close

func (g *GCPPubSub) Close() error

func (*GCPPubSub) GetComponentMetadata

func (g *GCPPubSub) GetComponentMetadata() map[string]string

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 (g *GCPPubSub) Invoke(ctx context.Context, req *bindings.InvokeRequest) (*bindings.InvokeResponse, error)

func (*GCPPubSub) Operations

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

func (*GCPPubSub) Read

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