nebula

Mar 16, 2020

Changes in this version

+ var NatsBroker = nats.NewBroker()

+ var NsqBroker = nsq.NewBroker()

+ var RabbitBroker = rabbitmq.NewBroker()

+ func InitNatsBroker(b broker.Broker, options ...broker.Option)

+ func InitNsqBroker(b broker.Broker, options ...broker.Option)

+ func InitRabbitBroker(b broker.Broker, options ...broker.Option)

+ func NewNatsBroker(opts ...broker.Option) broker.Broker

+ func NewNsqBroker(opts ...broker.Option) broker.Broker

+ func NewRabbitBroker(opts ...broker.Option) broker.Broker

+ func Publish(b broker.Broker, topic string, data []byte, opts ...broker.PublishOption) string

+ func Subscribe(b broker.Broker, topic string, handle func(broker.Event) error, ...)

Jan 10, 2020

Changes in this version

+ var Conf = config.NewConfig()

+ var Service = micro.NewService()

+ var Version = "v1.17.5"

+ var Web = web.NewService()

+ func InitProcess()

+ func NewService() micro.Service

+ func Run()

+ func RunProcess(process func(context.Context, context.CancelFunc) error)

+ func RunWeb()

+ func SetName(name string)

+ type Option func(*Options)

+ type Options struct

+ Conf config.Config

+ Service micro.Service

+ Version string

+ Web web.Service