add mucp for config/source

config/source/mucp/mucp.go

@@ -0,0 +1,72 @@
+package mucp
+
+import (
+	"context"
+
+	"github.com/micro/go-micro/config/cmd"
+	"github.com/micro/go-micro/config/source"
+	proto "github.com/micro/go-micro/config/source/mucp/proto"
+	"github.com/micro/go-micro/util/log"
+)
+
+var (
+	DefaultServiceName = "go.micro.config"
+)
+
+type mucpSource struct {
+	serviceName string
+	key         string
+	opts        source.Options
+	client      proto.SourceService
+}
+
+func (m *mucpSource) Read() (set *source.ChangeSet, err error) {
+	req, err := m.client.Read(context.Background(), &proto.ReadRequest{Path: m.key})
+	if err != nil {
+		return nil, err
+	}
+
+	return toChangeSet(req.Change.ChangeSet), nil
+}
+
+func (m *mucpSource) Watch() (w source.Watcher, err error) {
+	stream, err := m.client.Watch(context.Background(), &proto.WatchRequest{Key: m.key})
+	if err != nil {
+		log.Error("watch err: ", err)
+		return
+	}
+	return newWatcher(stream)
+}
+
+// Write is unsupported
+func (m *mucpSource) Write(cs *source.ChangeSet) error {
+	return nil
+}
+
+func (m *mucpSource) String() string {
+	return "mucp"
+}
+
+func NewSource(opts ...source.Option) source.Source {
+	var options source.Options
+	for _, o := range opts {
+		o(&options)
+	}
+
+	addr := DefaultServiceName
+
+	if options.Context != nil {
+		a, ok := options.Context.Value(serviceNameKey{}).(string)
+		if ok {
+			addr = a
+		}
+	}
+
+	s := &mucpSource{
+		serviceName: addr,
+		opts:        options,
+		client:      proto.NewSourceService(addr, *cmd.DefaultOptions().Client),
+	}
+
+	return s
+}

config/source/mucp/options.go

@@ -0,0 +1,18 @@
+package mucp
+
+import (
+	"context"
+
+	"github.com/micro/go-micro/config/source"
+)
+
+type serviceNameKey struct{}
+
+func ServiceName(a string) source.Option {
+	return func(o *source.Options) {
+		if o.Context == nil {
+			o.Context = context.Background()
+		}
+		o.Context = context.WithValue(o.Context, serviceNameKey{}, a)
+	}
+}