167 lines
3.6 KiB
Go
167 lines
3.6 KiB
Go
package cmd
|
|
|
|
import (
|
|
"context"
|
|
|
|
"github.com/micro/go-micro/broker"
|
|
"github.com/micro/go-micro/client"
|
|
"github.com/micro/go-micro/client/selector"
|
|
"github.com/micro/go-micro/debug/trace"
|
|
"github.com/micro/go-micro/registry"
|
|
"github.com/micro/go-micro/runtime"
|
|
"github.com/micro/go-micro/server"
|
|
"github.com/micro/go-micro/store"
|
|
"github.com/micro/go-micro/transport"
|
|
)
|
|
|
|
type Options struct {
|
|
// For the Command Line itself
|
|
Name string
|
|
Description string
|
|
Version string
|
|
|
|
// We need pointers to things so we can swap them out if needed.
|
|
Broker *broker.Broker
|
|
Registry *registry.Registry
|
|
Selector *selector.Selector
|
|
Transport *transport.Transport
|
|
Client *client.Client
|
|
Server *server.Server
|
|
Runtime *runtime.Runtime
|
|
Store *store.Store
|
|
Tracer *trace.Tracer
|
|
|
|
Brokers map[string]func(...broker.Option) broker.Broker
|
|
Clients map[string]func(...client.Option) client.Client
|
|
Registries map[string]func(...registry.Option) registry.Registry
|
|
Selectors map[string]func(...selector.Option) selector.Selector
|
|
Servers map[string]func(...server.Option) server.Server
|
|
Transports map[string]func(...transport.Option) transport.Transport
|
|
Runtimes map[string]func(...runtime.Option) runtime.Runtime
|
|
Stores map[string]func(...store.Option) store.Store
|
|
Tracers map[string]func(...trace.Option) trace.Tracer
|
|
|
|
// Other options for implementations of the interface
|
|
// can be stored in a context
|
|
Context context.Context
|
|
}
|
|
|
|
// Command line Name
|
|
func Name(n string) Option {
|
|
return func(o *Options) {
|
|
o.Name = n
|
|
}
|
|
}
|
|
|
|
// Command line Description
|
|
func Description(d string) Option {
|
|
return func(o *Options) {
|
|
o.Description = d
|
|
}
|
|
}
|
|
|
|
// Command line Version
|
|
func Version(v string) Option {
|
|
return func(o *Options) {
|
|
o.Version = v
|
|
}
|
|
}
|
|
|
|
func Broker(b *broker.Broker) Option {
|
|
return func(o *Options) {
|
|
o.Broker = b
|
|
}
|
|
}
|
|
|
|
func Selector(s *selector.Selector) Option {
|
|
return func(o *Options) {
|
|
o.Selector = s
|
|
}
|
|
}
|
|
|
|
func Registry(r *registry.Registry) Option {
|
|
return func(o *Options) {
|
|
o.Registry = r
|
|
}
|
|
}
|
|
|
|
func Transport(t *transport.Transport) Option {
|
|
return func(o *Options) {
|
|
o.Transport = t
|
|
}
|
|
}
|
|
|
|
func Client(c *client.Client) Option {
|
|
return func(o *Options) {
|
|
o.Client = c
|
|
}
|
|
}
|
|
|
|
func Server(s *server.Server) Option {
|
|
return func(o *Options) {
|
|
o.Server = s
|
|
}
|
|
}
|
|
|
|
func Tracer(t *trace.Tracer) Option {
|
|
return func(o *Options) {
|
|
o.Tracer = t
|
|
}
|
|
}
|
|
|
|
// New broker func
|
|
func NewBroker(name string, b func(...broker.Option) broker.Broker) Option {
|
|
return func(o *Options) {
|
|
o.Brokers[name] = b
|
|
}
|
|
}
|
|
|
|
// New client func
|
|
func NewClient(name string, b func(...client.Option) client.Client) Option {
|
|
return func(o *Options) {
|
|
o.Clients[name] = b
|
|
}
|
|
}
|
|
|
|
// New registry func
|
|
func NewRegistry(name string, r func(...registry.Option) registry.Registry) Option {
|
|
return func(o *Options) {
|
|
o.Registries[name] = r
|
|
}
|
|
}
|
|
|
|
// New selector func
|
|
func NewSelector(name string, s func(...selector.Option) selector.Selector) Option {
|
|
return func(o *Options) {
|
|
o.Selectors[name] = s
|
|
}
|
|
}
|
|
|
|
// New server func
|
|
func NewServer(name string, s func(...server.Option) server.Server) Option {
|
|
return func(o *Options) {
|
|
o.Servers[name] = s
|
|
}
|
|
}
|
|
|
|
// New transport func
|
|
func NewTransport(name string, t func(...transport.Option) transport.Transport) Option {
|
|
return func(o *Options) {
|
|
o.Transports[name] = t
|
|
}
|
|
}
|
|
|
|
// New runtime func
|
|
func NewRuntime(name string, r func(...runtime.Option) runtime.Runtime) Option {
|
|
return func(o *Options) {
|
|
o.Runtimes[name] = r
|
|
}
|
|
}
|
|
|
|
// New tracer func
|
|
func NewTracer(name string, t func(...trace.Option) trace.Tracer) Option {
|
|
return func(o *Options) {
|
|
o.Tracers[name] = t
|
|
}
|
|
}
|