mq

Documentation

Index

• func Reg(driver string, driverCreator DriverCreator)
• type Driver
  • func NewDriver(dirver string, config interface{}) (Driver, error)
• type DriverCreator

Functions

func Reg

func Reg(driver string, driverCreator DriverCreator)

Types

type Driver

type Driver interface {
	Send(topic string, name string, data interface{}) error
	On(queue string, fn func(name string, data interface{}) bool) context.CancelFunc
	Recycle()
}

func NewDriver

func NewDriver(dirver string, config interface{}) (Driver, error)

type DriverCreator

type DriverCreator func(driver string, config interface{}) (Driver, error)