google

Documentation

Index

• type GoogleCloud
  • func NewGoogleCloud(projectID string) (*GoogleCloud, error)
  • func (g *GoogleCloud) Publish(ctx context.Context, topic string, m *ps.Msg) error
  • func (g *GoogleCloud) Shutdown()
  • func (g *GoogleCloud) Subscribe(opts ps.HandlerOptions, h ps.MsgHandler)

Types

type GoogleCloud

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

GoogleCloud provides google cloud pubsub

func NewGoogleCloud

func NewGoogleCloud(projectID string) (*GoogleCloud, error)

NewGoogleCloud creates a new GoogleCloud instace for a project

func (*GoogleCloud) Publish

func (g *GoogleCloud) Publish(ctx context.Context, topic string, m *ps.Msg) error

Publish implements Publish

func (*GoogleCloud) Shutdown

func (g *GoogleCloud) Shutdown()

Shutdown shuts down all subscribers gracefully

func (*GoogleCloud) Subscribe

func (g *GoogleCloud) Subscribe(opts ps.HandlerOptions, h ps.MsgHandler)

Subscribe implements Subscribe