ConfigServer

Documentation

Index

• Variables
• func GetConf(path ...string) string
• func InitClient(filename string, ServerID string)
• func ReadFile(fpath string, cur interface{})
• func Server(c *Configurator)
• func WriteFile(fpath string, cur interface{})
• type Api_toml
  • func (*Api_toml) Read(fpath string, v interface{})
  • func (*Api_toml) Write(fpath string, v interface{})
• type Api_yaml
  • func (*Api_yaml) Read(fpath string, v interface{})
  • func (*Api_yaml) Write(fpath string, v interface{})
• type Basic
• 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 *MPB.ReadRequest, rsp *MPB.ReadResponse) (err error)
  • func (s Service) Watch(ctx context.Context, req *MPB.WatchRequest, server MPB.Config_WatchStream) (err error)

Variables

var (
	SConf     *Configurator
	OldConf   MPB.Config
	CurRouter *MPB.Server
	CurGame   *MPB.Server
	CurGate   *MPB.Server
)

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

Functions

func GetConf

func GetConf(path ...string) string

func InitClient

func InitClient(filename string, ServerID string)

func ReadFile

func ReadFile(fpath string, cur interface{})

func Server

func Server(c *Configurator)

func WriteFile

func WriteFile(fpath string, cur interface{})

Types

type Api_toml

type Api_toml struct{}

func (*Api_toml) Read

func (*Api_toml) Read(fpath string, v interface{})

func (*Api_toml) Write

func (*Api_toml) Write(fpath string, v interface{})

type Api_yaml

type Api_yaml struct{}

func (*Api_yaml) Read

func (*Api_yaml) Read(fpath string, v interface{})

func (*Api_yaml) Write

func (*Api_yaml) Write(fpath string, v interface{})

type Basic

type Basic struct {
	sync.RWMutex
	Isdirty bool
}

type Configurator

type Configurator struct {
	sync.RWMutex

	Conf       config.Config
	Update     func(*Configurator)
	Opt        *Options
	ServerName string
	MyConf     MPB.Config
	// 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 *MPB.ReadRequest, rsp *MPB.ReadResponse) (err error)

func (Service) Watch

func (s Service) Watch(ctx context.Context, req *MPB.WatchRequest, server MPB.Config_WatchStream) (err error)