events

README

This implementation of the event interface (see /frame/interfaces) uses the Trigga pub/sub messaging server (see github.com/opesun/trigga).

This implementation doesn't panic with a nil connection, but returns errors on operations.

Documentation

Index

• type Event
  • func (e *Event) Publish(msg []byte) error
  • func (e *Event) Read() ([]byte, error)
  • func (e *Event) Subscribe() error
  • func (e *Event) Unsubscribe() error
• type Events
  • func New(conn *gt.Connection) *Events
  • func (e *Events) Select(name string) iface.Event

Types

type Event

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

func (*Event) Publish

func (e *Event) Publish(msg []byte) error

func (*Event) Read

func (e *Event) Read() ([]byte, error)

func (*Event) Subscribe

func (e *Event) Subscribe() error

func (*Event) Unsubscribe

func (e *Event) Unsubscribe() error

type Events

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

func New

func New(conn *gt.Connection) *Events

func (*Events) Select

func (e *Events) Select(name string) iface.Event