pubsub

Documentation

Index

• func NewGCPPubSub(logger logger.Logger) pubsub.PubSub
• type GCPPubSub
  • func (g *GCPPubSub) Close() error
  • func (g *GCPPubSub) Features() []pubsub.Feature
  • func (g *GCPPubSub) Init(meta pubsub.Metadata) error
  • func (g *GCPPubSub) Publish(req *pubsub.PublishRequest) error
  • func (g *GCPPubSub) Subscribe(req pubsub.SubscribeRequest, daprHandler func(msg *pubsub.NewMessage) error) error

Functions

func NewGCPPubSub

func NewGCPPubSub(logger logger.Logger) pubsub.PubSub

NewGCPPubSub returns a new GCPPubSub instance

Types

type GCPPubSub

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

GCPPubSub type

func (*GCPPubSub) Close

func (g *GCPPubSub) Close() error

func (*GCPPubSub) Features

func (g *GCPPubSub) Features() []pubsub.Feature

func (*GCPPubSub) Init

func (g *GCPPubSub) Init(meta pubsub.Metadata) error

Init parses metadata and creates a new Pub Sub client

func (*GCPPubSub) Publish

func (g *GCPPubSub) Publish(req *pubsub.PublishRequest) error

Publish the topic to GCP Pubsub

func (*GCPPubSub) Subscribe

func (g *GCPPubSub) Subscribe(req pubsub.SubscribeRequest, daprHandler func(msg *pubsub.NewMessage) error) error

Subscribe to the GCP Pubsub topic