pubsub

Documentation

Index

• func AddDriver(driver Interface)
• func DriverName() string
• func Drivers() map[string]Interface
• func Publish(topic string, message []byte, params ...interface{}) error
• func Register() error
• func SetDefaultDriver(driver Interface)
• func Subscribe(topic string, onMessage func(topic string, message []byte, driver Interface), ...)
• type Interface
  • func Driver(driver string) (Interface, bool)
  • func Use(driver string) Interface
• type Message

Functions

func AddDriver

func AddDriver(driver Interface)

func DriverName

func DriverName() string

func Drivers

func Drivers() map[string]Interface

func Publish

func Publish(topic string, message []byte, params ...interface{}) error

func Register

func Register() error

func SetDefaultDriver

func SetDefaultDriver(driver Interface)

func Subscribe

func Subscribe(topic string, onMessage func(topic string, message []byte, driver Interface), params ...interface{})

Types

type Interface

type Interface interface {
	Name() string
	Register() error
	Subscribe(topic string, onMessage func(topic string, message []byte, driver Interface), params ...interface{})
	Publish(topic string, message []byte, params ...interface{}) error

	// SetMarshaller set interface{} to []byte marshalling function
	SetMarshaller(func(input interface{}) ([]byte, error))

	// SetUnMarshaller set []byte to interface{} unmarshalling function
	SetUnMarshaller(func(bytes []byte, out interface{}) error)
}

func Driver

func Driver(driver string) (Interface, bool)

func Use

func Use(driver string) Interface

type Message

type Message struct {
	Time    time.Time
	Message []byte
}