config

Documentation

Index

• Variables
• func Init() error
• func Parse(ch ...*config.ChangeSet) (*config.ChangeSet, error)
• func Publish(ctx context.Context, ch *proto.WatchResponse) error
• func Values(ch *config.ChangeSet) (config.Values, error)
• func Watch(id string) (*watcher, error)
• func Watcher(ctx context.Context, ch *proto.WatchResponse) error

Variables

var (
	// We need a path splitter since its structured in go-os
	PathSplitter = "/"
	WatchTopic   = "micro.config.watch"
)

Functions

func Init

func Init() error

func Parse

func Parse(ch ...*config.ChangeSet) (*config.ChangeSet, error)

func Publish

func Publish(ctx context.Context, ch *proto.WatchResponse) error

Publish a change

func Values

func Values(ch *config.ChangeSet) (config.Values, error)

func Watch

func Watch(id string) (*watcher, error)

Watch created by a client RPC request

func Watcher

func Watcher(ctx context.Context, ch *proto.WatchResponse) error

Used as a subscriber between config services for events