local

Documentation

Index

• Constants
• func NewURL(digest [32]byte) string
• func ParseURL(u string) (digest [32]byte, err error)
• type HTTPHandler
  • func (h HTTPHandler) ServeHTTP(res http.ResponseWriter, req *http.Request)
• type Manager
  • func NewManager(config *config.Config, d *db.Database, processor MessageProcessor, ...) (*Manager, error)
  • func (m *Manager) ReportGroup(id ids.ID) error
  • func (m *Manager) Scan(ctx context.Context) ([]string, error)
  • func (m *Manager) Send(to string, body []byte) error
  • func (m *Manager) Shutdown() error
  • func (m *Manager) Start() error
  • func (m *Manager) TransportURLs() []string
• type MessageImpl
  • func (m *MessageImpl) Body() []byte
  • func (m *MessageImpl) From() string
  • func (m *MessageImpl) To() string
• type MessageProcessor

Constants

const (
	DigestScheme = "id"
)

Functions

func NewURL

func NewURL(digest [32]byte) string

func ParseURL

func ParseURL(u string) (digest [32]byte, err error)

Types

type HTTPHandler

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

func (HTTPHandler) ServeHTTP

func (h HTTPHandler) ServeHTTP(res http.ResponseWriter, req *http.Request)

type Manager

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

func NewManager

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

func (*Manager) ReportGroup

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

func (*Manager) Scan

func (m *Manager) Scan(ctx context.Context) ([]string, error)

func (*Manager) Send

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

func (*Manager) Shutdown

func (m *Manager) Shutdown() error

func (*Manager) Start

func (m *Manager) Start() error

func (*Manager) TransportURLs

func (m *Manager) TransportURLs() []string

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

func (*MessageImpl) To

func (m *MessageImpl) To() string

type MessageProcessor

type MessageProcessor func([]*MessageImpl) error