events

Documentation

Index

• type Engine
• type Handler
• type Publisher
• type Subscriber

Types

type Engine

type Engine interface {
	Open() error
	Publish(event string, data interface{}) error
	CheckSubAndPublish(fullEvent string, data interface{}) error
	Subscribe(event string, handler Handler) error
	SubscribeQueue(event string, queue string, handler Handler) error
	Unsubscribe(event string, handler Handler) error
	Marshal(data interface{}) ([]byte, error)
	Unmarshal(data []byte, v interface{}) error
	Close() error
}

type Handler

type Handler func(data []byte)

type Publisher

type Publisher interface {
	Publish(event string, data interface{}) error
	CheckSubAndPublish(fullEvent string, data interface{}) error
	Marshal(data interface{}) ([]byte, error)
}

type Subscriber

type Subscriber interface {
	Subscribe(event string, handler Handler) error
	Unsubscribe(event string, handler Handler) error
	Unmarshal(data []byte, v interface{}) error
}