dispatcher

Documentation

Overview

Package dispatcher contains the dispatcher service.

Index

• Variables
• type Clock
• type Dispatcher
  • func New(st *storage.Storage, cfg config.Config, clock Clock) *Dispatcher
  • func (d *Dispatcher) Close()
  • func (d *Dispatcher) MessengerStatus(webhookName string) (messenger.Status, error)
  • func (d *Dispatcher) PostLatestFeedItem(feedName string) error
  • func (d *Dispatcher) Start() error

Variables

var ErrNotFound = errors.New("not found")

Types

type Clock

type Clock interface {
	Now() time.Time
}

type Dispatcher

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

Dispatcher is a service that fetches items from feeds and forwards them to webhooks.

func New

func New(st *storage.Storage, cfg config.Config, clock Clock) *Dispatcher

New creates a new App instance and returns it.

func (*Dispatcher) Close

func (d *Dispatcher) Close()

Close conducts a graceful shutdown of the dispatcher.

func (*Dispatcher) MessengerStatus

func (d *Dispatcher) MessengerStatus(webhookName string) (messenger.Status, error)

MessengerStatus returns the current status of a messenger.

func (*Dispatcher) PostLatestFeedItem

func (d *Dispatcher) PostLatestFeedItem(feedName string) error

func (*Dispatcher) Start

func (d *Dispatcher) Start() error

Start starts the dispatcher User should call Close() subsequently to shut down dispatcher gracefully and prevent any potential data loss.