heya

Documentation

Overview

Defines package responsible for performing the actual sending and receiving of messages to URLs.

Index

• Constants
• type Manager
  • func NewManager(config *config.Config, d *db.Database, processOnce bool, ...) (*Manager, error)
  • func (m *Manager) CreateTransport(authToken, host string, port int) error
  • func (m *Manager) Ping(_ context.Context, host string, port int) error
  • func (m *Manager) ReportGroup(id ids.ID) error
  • func (m *Manager) Send(from, to string, body []byte) error
  • func (m *Manager) SetIOSPushTokens(tokens []string) error
  • func (m *Manager) Shutdown() error
  • func (m *Manager) Start() error
  • func (m *Manager) URLsForGroup(id ids.ID) ([]string, error)
  • func (m *Manager) Updates() chan interface{}
  • func (m *Manager) WaitForPending()
• type MessageImpl
  • func (m *MessageImpl) Body() []byte
  • func (m *MessageImpl) From() string
• type MessageProcessor
• type ParsedURL
  • func ParseURL(u string) (*ParsedURL, error)
  • func (pu *ParsedURL) URL() string
• type StateUpdate

Constants

const (
	StateNew        = 0
	StateUnassigned = 1
	StateAssigned   = 2

	HeyaScheme  = "heya"
	DefaultPort = heya_client.DefaultPort
)

Types

type Manager

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

func NewManager

func NewManager(config *config.Config, d *db.Database, processOnce bool, processor MessageProcessor, assignmentChangeReporter func(ids.ID, string, bool) error) (*Manager, error)

func (*Manager) CreateTransport

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

func (*Manager) Ping

func (m *Manager) Ping(_ context.Context, host string, port int) error

func (*Manager) ReportGroup

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

func (*Manager) Send

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

func (*Manager) SetIOSPushTokens

func (m *Manager) SetIOSPushTokens(tokens []string) error

func (*Manager) Shutdown

func (m *Manager) Shutdown() error

func (*Manager) Start

func (m *Manager) Start() error

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 MessageImpl

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

func (*MessageImpl) Body

func (m *MessageImpl) Body() []byte

func (*MessageImpl) From

func (m *MessageImpl) From() string

type MessageProcessor

type MessageProcessor func([]*MessageImpl) error

type ParsedURL

type ParsedURL struct {
	Host        string
	Port        int
	PublicBytes [32]byte
	SendToken   [32]byte
}

func ParseURL

func ParseURL(u string) (*ParsedURL, error)

func (*ParsedURL) URL

func (pu *ParsedURL) URL() string

type StateUpdate

type StateUpdate struct {
	Host  string
	Port  int
	State string
}