events

Documentation

Index

• type Handler
  • func NewEventHandler() *Handler
  • func (h Handler) Log(r *log.Record) error
• type Listener
  • func (e *Listener) Connection() *websocket.Conn
  • func (e *Listener) Deactivate()
  • func (e *Listener) ID() string
  • func (e *Listener) IsDone() bool
  • func (e *Listener) Lock()
  • func (e *Listener) MessageTypes() []string
  • func (e *Listener) Unlock()
  • func (e *Listener) Wait(ctx context.Context)
• type Server
  • func NewServer(debug bool, verbose bool) *Server
  • func (s *Server) AddListener(group string, connection *websocket.Conn, messageTypes []string, ...) (*Listener, error)
  • func (s *Server) Forward(id int64, event api.Event)
  • func (s *Server) Send(group, eventType string, eventMessage interface{}) error
  • func (s *Server) SendLifecycle(group string, event api.EventLifecycle)

Types

type Handler

type Handler struct {
}

Handler describes an event handler.

func NewEventHandler

func NewEventHandler() *Handler

NewEventHandler creates and returns a new event handler.

func (Handler) Log

func (h Handler) Log(r *log.Record) error

Log sends a new logging event.

type Listener

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

Listener describes an event listener.

func (*Listener) Connection

func (e *Listener) Connection() *websocket.Conn

Connection returns the underlying websocket connection.

func (*Listener) Deactivate

func (e *Listener) Deactivate()

Deactivate deactivates the event listener.

func (*Listener) ID

func (e *Listener) ID() string

ID returns the listener ID.

func (*Listener) IsDone

func (e *Listener) IsDone() bool

IsDone returns true if the listener is done.

func (*Listener) Lock

func (e *Listener) Lock()

Lock locks the internal mutex.

func (*Listener) MessageTypes

func (e *Listener) MessageTypes() []string

MessageTypes returns a list of message types the listener will be notified of.

func (*Listener) Unlock

func (e *Listener) Unlock()

Unlock unlocks the internal mutex.

func (*Listener) Wait

func (e *Listener) Wait(ctx context.Context)

Wait waits for a message on its active channel or the context is cancelled, then returns.

type Server

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

Server represents an instance of an event server.

var LoggingServer *Server

LoggingServer controls what server to use for messages coming from the logger.

func NewServer

func NewServer(debug bool, verbose bool) *Server

NewServer returns a new event server.

func (*Server) AddListener

func (s *Server) AddListener(group string, connection *websocket.Conn, messageTypes []string, location string, noForward bool) (*Listener, error)

AddListener creates and returns a new event listener.

func (*Server) Forward

func (s *Server) Forward(id int64, event api.Event)

Forward to the local events dispatcher an event received from another node.

func (*Server) Send

func (s *Server) Send(group, eventType string, eventMessage interface{}) error

Send broadcasts a custom event.

func (*Server) SendLifecycle

func (s *Server) SendLifecycle(group string, event api.EventLifecycle)

SendLifecycle broadcasts a lifecycle event.