messaging

Documentation

Index

• type Config
• type Messenger
  • func New(config Config) (*Messenger, error)
  • func (m *Messenger) DeleteSub() error
  • func (m *Messenger) RunListener(ctx context.Context, msgChan chan<- Msg) error
• type MessengerInterface
• type Msg
• type MsgContents
• type NoopMessenger
  • func (m *NoopMessenger) DeleteSub() error
  • func (m *NoopMessenger) RunListener(ctx context.Context, msgChan chan<- Msg) error

Types

type Config

type Config struct {
	CredsPath      string
	TopicID        string
	SubscriptionID string
	ProjectID      string
}

A Config stores the configuration for messaging Client instances

type Messenger

type Messenger struct {
	PubsubClient   *pubsub.Client
	SubscriptionID string
	TopicID        string
	Subscription   *pubsub.Subscription
}

A Messenger provies the API for interacting with a pubsub messaging queue (google Pub/Sub)

func New

func New(config Config) (*Messenger, error)

New returns a new Messenger with provided configuration initialized and attached

func (*Messenger) DeleteSub

func (m *Messenger) DeleteSub() error

DeleteSub removes the subscription

func (*Messenger) RunListener

func (m *Messenger) RunListener(ctx context.Context, msgChan chan<- Msg) error

type MessengerInterface

type MessengerInterface interface {
	RunListener(context.Context, chan<- Msg) error
	DeleteSub() error
}

type Msg

type Msg struct {
	Data MsgContents `json:"data"`
}

type MsgContents

type MsgContents struct {
	Message string `json:"message"`
}

type NoopMessenger

type NoopMessenger struct{}

func (*NoopMessenger) DeleteSub

func (m *NoopMessenger) DeleteSub() error

func (*NoopMessenger) RunListener

func (m *NoopMessenger) RunListener(ctx context.Context, msgChan chan<- Msg) error