nebula

README

nebula

Version

go版本：go 1.13 micro版本：micro 自建镜像1.17.2

Install

go get github.com/Wall-js/nebula
export GOPROXY=https://goproxy.cn,direct golang替换国源

go env -w GOPROXY=https://goproxy.cn,direct
go env -w GOPRIVATE=*.hiqio.com,*.gitlab.com,*.gitee.com //跳过私有库

Demo

服务配置规范

####节点命名

/集群名/命名空间/类型(srv,api,web,evt)/系统/版本(/id)(括号部分可不使用)

/default/nebula/srv/nebula-core/v0.1(/nebula.core.srv)

/cluster/namespace/type/system/version(/appId)

Type

页面web,接口api,服务srv,事件evt

Starting

func main() {
	nebula.SetName("nebula.core.srv")
	hello.RegisterHelloHandler(nebula.Service.Server(), new(handler.Hello))
	micro.RegisterSubscriber("nebula.core.srv.hello", nebula.Service.Server(), new(subscriber.Hello))
	micro.RegisterSubscriber("nebula.core.srv.hello", nebula.Service.Server(), subscriber.Handler)
	nebula.Run()
}

Config

    version := nebula.Conf.Get("version").String("unknown")
    name := nebula.Conf.Get("config","name").String("unknown")

Web

func main() {
	nebula.SetName("go.micro.api.greeter")
	router := gin.New()
	say := new(Say)
	router.GET("/greeter", say.Anything)
	// Register Handler
	nebula.Web.Handle("/", router)
	nebula.RunWeb()
}

Documentation

Index

• Variables
• func AddPrefix(s string)
• func BeforeStart(f ...func())
• func CommonProcess()
• 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 Run()
• func RunProcess(process func(context.Context, context.CancelFunc) error)
• func RunWeb()
• func SetName(s string)
• func SetVersion(version string)
• func Subscribe(b broker.Broker, topic string, handle func(broker.Event) error, ...)

Variables

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

var (
	Conf    = config.NewConfig()
	Service = micro.NewService(
		micro.Flags(
			cli.StringFlag{
				Name:  "dataCenter",
				Usage: "dataCenter dc1",
				Value: "",
			},
			cli.StringFlag{
				Name:  "prefix",
				Usage: "prefix /nebula/",
				Value: "/nebula/",
			},
			cli.StringFlag{
				Name:  "confAddr",
				Usage: "confAddr localhost:8500",
				Value: "localhost:8500",
			},
			cli.StringFlag{
				Name:  "appId",
				Usage: "appId default",
				Value: "default",
			},
			cli.BoolFlag{
				Name:  "t",
				Usage: "-t",
			},
		),
		micro.Action(func(c *cli.Context) {
			dataCenter = c.String("dataCenter")
			DefaultPrefix = c.String("prefix")
			confAddr = c.String("confAddr")
			AppId = c.String("appId")
			test = c.Bool("t")
		}),
	)
	Web           web.Service
	DefaultPrefix string
	PrefixSlice   []string

	AppId string
)

Functions

func AddPrefix

func AddPrefix(s string)

func BeforeStart

func BeforeStart(f ...func())

func CommonProcess

func CommonProcess()

func InitNatsBroker

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

func InitNsqBroker

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

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 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(s string)

func SetVersion

func SetVersion(version string)

func Subscribe

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