configcenter

Documentation

Index

• func LoadConfigFromLocalFile(confPath string, handler *CCHandler) error
• func New(ctx context.Context, procName string, confPath string, disc crd.ConfRegDiscvIf, ...) error
• func NewConfigCenter(ctx context.Context, zkAddr string, procName string, confPath string, ...) error
• type CC
• type CCHandler
• type ProcHandlerFunc
• type ProcessConfig
  • func ParseConfigWithData(data []byte) (*ProcessConfig, error)
  • func ParseConfigWithFile(filePath string) (*ProcessConfig, error)

Functions

func LoadConfigFromLocalFile

func LoadConfigFromLocalFile(confPath string, handler *CCHandler) error

func New

func New(ctx context.Context, procName string, confPath string, disc crd.ConfRegDiscvIf, handler *CCHandler) error

func NewConfigCenter

func NewConfigCenter(ctx context.Context, zkAddr string, procName string, confPath string, handler *CCHandler) error

Types

type CC

type CC struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type CCHandler

type CCHandler struct {
	OnProcessUpdate  ProcHandlerFunc
	OnLanguageUpdate func(previous, current map[string]language.LanguageMap)
	OnErrorUpdate    func(previous, current map[string]errors.ErrorCode)
}

type ProcHandlerFunc

type ProcHandlerFunc func(previous, current ProcessConfig)

type ProcessConfig

type ProcessConfig struct {
	ConfigMap map[string]string
}

func ParseConfigWithData

func ParseConfigWithData(data []byte) (*ProcessConfig, error)

func ParseConfigWithFile

func ParseConfigWithFile(filePath string) (*ProcessConfig, error)