ConfigServer

Documentation

Index

• Variables
• func Server(c *Configurator)
• type Configurator
  • func New(name string, source source.Source, update func(*Configurator)) *Configurator
• type Option
  • func WithSource(src source.Source) Option
• type Options
• type Service
  • func (s Service) Read(ctx context.Context, req *mproto.ReadRequest) (rsp *mproto.ReadResponse, err error)
  • func (s Service) Watch(req *mproto.WatchRequest, server mproto.Source_WatchServer) (err error)

Variables

var (
	Conf = make(map[string]*Configurator)
)

Functions

func Server

func Server(c *Configurator)

Types

type Configurator

type Configurator struct {
	sync.RWMutex

	Conf   config.Config
	Update func(*Configurator)
	Opt    *Options
	Path   string
	// contains filtered or unexported fields
}

configurator 配置器

func New

func New(name string, source source.Source, update func(*Configurator)) *Configurator

type Option

type Option func(o *Options)

func WithSource

func WithSource(src source.Source) Option

type Options

type Options struct {
	Apps    map[string]interface{}
	Sources []source.Source
}

type Service

type Service struct{}

func (Service) Read

func (s Service) Read(ctx context.Context, req *mproto.ReadRequest) (rsp *mproto.ReadResponse, err error)

func (Service) Watch

func (s Service) Watch(req *mproto.WatchRequest, server mproto.Source_WatchServer) (err error)