notifier

Documentation

Index

• Constants
• type EventMessage
• type Notification
• type Server
  • func New(prov provider) (*Server, error)
  • func (r *Server) Error(err error)
  • func (r *Server) Errors() (chan error, error)
  • func (r *Server) Start() error

Constants

const QueueName = "notification"

Types

type EventMessage

type EventMessage struct {
	Event     string      `json:"event"`
	Timestamp int64       `json:"timestamp"`
	EventData interface{} `json:"message"`
}

type Notification

type Notification struct {
	Topic     string      `json:"topic"`
	Event     string      `json:"event"`
	EventData interface{} `json:"message"`
}

type Server

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

func New

func New(prov provider) (*Server, error)

func (*Server) Error

func (r *Server) Error(err error)

func (*Server) Errors

func (r *Server) Errors() (chan error, error)

func (*Server) Start

func (r *Server) Start() error