transport

Documentation

Index

• type AssignmentReporter
• type Manager
  • func NewManager(config *config.Config, d *db.Database, clock clock.Clock, processOnce bool, ...) (*Manager, error)
  • func (m *Manager) AddPushNotificationToken(token string) error
  • func (m *Manager) DeletePushNotificationToken(token string) error
  • func (m *Manager) Preflight(urls []string) []bool
  • func (m *Manager) RegisterHeyaTransport(authToken, host string, port int) error
  • func (m *Manager) ReportGroup(id ids.ID) error
  • func (m *Manager) Send(from string, tos []string, body []byte) []error
  • func (m *Manager) Shutdown() error
  • func (m *Manager) Start() error
  • func (m *Manager) StatusChanged(f func(string, bool))
  • func (m *Manager) URLsForGroup(id ids.ID) ([]string, error)
  • func (m *Manager) Updates() chan interface{}
  • func (m *Manager) WaitForPending()
• type Message
• type MessageProcessor
• type Transport

Types

type AssignmentReporter

type AssignmentReporter func(ids.ID, string, bool) error

type Manager

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

func NewManager

func NewManager(config *config.Config, d *db.Database, clock clock.Clock, processOnce bool, processor MessageProcessor, assignmentReporter AssignmentReporter) (*Manager, error)

func (*Manager) AddPushNotificationToken

func (m *Manager) AddPushNotificationToken(token string) error

func (*Manager) DeletePushNotificationToken

func (m *Manager) DeletePushNotificationToken(token string) error

func (*Manager) Preflight

func (m *Manager) Preflight(urls []string) []bool

func (*Manager) RegisterHeyaTransport

func (m *Manager) RegisterHeyaTransport(authToken, host string, port int) error

func (*Manager) ReportGroup

func (m *Manager) ReportGroup(id ids.ID) error

func (*Manager) Send

func (m *Manager) Send(from string, tos []string, body []byte) []error

func (*Manager) Shutdown

func (m *Manager) Shutdown() error

func (*Manager) Start

func (m *Manager) Start() error

func (*Manager) StatusChanged

func (m *Manager) StatusChanged(f func(string, bool))

func (*Manager) URLsForGroup

func (m *Manager) URLsForGroup(id ids.ID) ([]string, error)

func (*Manager) Updates

func (m *Manager) Updates() chan interface{}

func (*Manager) WaitForPending

func (m *Manager) WaitForPending()

type Message

type Message interface {
	From() string
	Body() []byte
}

type MessageProcessor

type MessageProcessor func([]Message) error

type Transport

type Transport struct {
	URL      string
	ETTR     int
	Priority int
}