data

Documentation

Overview

Handles routing application messages to the correct database handler. At present, only one handler exists, that is, for "eav".

Index

• Constants
• type Manager
  • func NewManager(c *config.Config, d *db.Database, clock clock.Clock) (*Manager, error)
  • func (m *Manager) AddBackfill(id ids.ID, name string, body []byte, fromSelf bool) error
  • func (m *Manager) AddMessage(id ids.ID, name string, body []byte, fromSelf bool) error
  • func (m *Manager) Shutdown() error
  • func (m *Manager) Start() error
  • func (m *Manager) Updates() chan interface{}

Constants

const EAVDatabase = "eav"

Types

type Manager

type Manager struct {
	EAV *eav.EAV
	// contains filtered or unexported fields
}

func NewManager

func NewManager(c *config.Config, d *db.Database, clock clock.Clock) (*Manager, error)

func (*Manager) AddBackfill

func (m *Manager) AddBackfill(id ids.ID, name string, body []byte, fromSelf bool) error

func (*Manager) AddMessage

func (m *Manager) AddMessage(id ids.ID, name string, body []byte, fromSelf bool) error

func (*Manager) Shutdown

func (m *Manager) Shutdown() error

func (*Manager) Start

func (m *Manager) Start() error

func (*Manager) Updates

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