nebula

Documentation

Index

• Variables
• func InitNatsBroker(b broker.Broker, options ...broker.Option)
• func InitNsqBroker(b broker.Broker, options ...broker.Option)
• func InitProcess()
• 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 NewService() micro.Service
• func Publish(b broker.Broker, topic string, data []byte, opts ...broker.PublishOption) string
• func Run()
• func RunProcess(process func(context.Context, context.CancelFunc) error)
• func RunWeb()
• func SetName(name string)
• func Subscribe(b broker.Broker, topic string, handle func(broker.Event) error, ...)
• type Option
• type Options

Variables

var (
	RabbitBroker = rabbitmq.NewBroker()
	NatsBroker   = nats.NewBroker()
	NsqBroker    = nsq.NewBroker()
)

var (
	Version = "v1.17.5"
	Conf    = config.NewConfig()
	Service = micro.NewService()
	Web     = web.NewService()
)

Functions

func InitNatsBroker

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

func InitNsqBroker

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

func InitProcess

func InitProcess()

func InitRabbitBroker

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

func NewNatsBroker

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

func NewNsqBroker

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

func NewRabbitBroker

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

func NewService

func NewService() micro.Service

func Publish

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

func Run

func Run()

func RunProcess

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

func RunWeb

func RunWeb()

func SetName

func SetName(name string)

func Subscribe

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

Types

type Option

type Option func(*Options)

type Options

type Options struct {
	Version string
	Conf    config.Config
	Service micro.Service
	Web     web.Service
	// contains filtered or unexported fields
}