pubsub

Documentation

Index

• type Message
• type Pubsub
  • func New(project, emulatorHost string) (*Pubsub, error)
  • func (p *Pubsub) Close() error
  • func (p *Pubsub) Host() string
  • func (p *Pubsub) Messages(ctx context.Context, subscription string) chan Message
  • func (p *Pubsub) Project() string
  • func (p *Pubsub) Publish(subscription string, content string) error
  • func (p *Pubsub) Subscriptions() ([]Subscription, error)
  • func (p *Pubsub) UpdateProject(project string) error
• type Subscription

Types

type Message

type Message struct {
	ID        string
	Data      []byte
	Timestamp time.Time
	Ack       func()
}

type Pubsub

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

func New

func New(project, emulatorHost string) (*Pubsub, error)

func (*Pubsub) Close

func (p *Pubsub) Close() error

func (*Pubsub) Host

func (p *Pubsub) Host() string

func (*Pubsub) Messages

func (p *Pubsub) Messages(ctx context.Context, subscription string) chan Message

func (*Pubsub) Project

func (p *Pubsub) Project() string

func (*Pubsub) Publish

func (p *Pubsub) Publish(subscription string, content string) error

func (*Pubsub) Subscriptions

func (p *Pubsub) Subscriptions() ([]Subscription, error)

func (*Pubsub) UpdateProject

func (p *Pubsub) UpdateProject(project string) error

type Subscription

type Subscription struct {
	Name            string
	Topic           string
	DeadLetterTopic string
}