configure

package
v2.0.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 15, 2022 License: MIT Imports: 6 Imported by: 9

Documentation

Index

Constants

View Source 
const (
	ExceedDeepLevel = "substratum: only support two level map/array"
)

Variables

View Source 
var EmptyOptions = func() *Options {
	return &Options{}
}

Functions

func RegisterBackendImplementor added in v2.0.2 

func RegisterBackendImplementor(backend Backend)

RegisterBackendImplementor registers the configuration backend service implementor.

func RegisterCallbackImplementor added in v2.0.2 

func RegisterCallbackImplementor(callback Callback)

RegisterCallbackImplementor registers the value updated callback service implementor.

func RegisterImplementor 

func RegisterImplementor(cfg Configure)

RegisterImplementor registers the configuration service implementor.

Types

type AddrParams 

type AddrParams map[string]string

func (AddrParams) Encode 

func (m AddrParams) Encode(sep string) string

type Address 

type Address struct {
	Schema    Schema     `json:"schema"`
	Username  string     `json:"username"`
	Password  string     `json:"password"`
	Host      string     `json:"host"`
	Port      string     `json:"port"`
	NameSpace string     `json:"namespace"`
	Params    AddrParams `json:"params"`
	RawValue  string     `json:"raw"`
}

func (*Address) Set 

func (c *Address) Set(addr string)

type Array added in v2.0.2 

type Array struct {
	// contains filtered or unexported fields
}

func (*Array) ArrayAt added in v2.0.2 

func (t *Array) ArrayAt(i int) *embedArray

func (*Array) AtomicUpdate added in v2.0.2 

func (t *Array) AtomicUpdate(v string)

func (*Array) Bools added in v2.0.2 

func (t *Array) Bools() []*embedBool

func (*Array) Changed added in v2.0.2 

func (t *Array) Changed(evt UpdateEvent)

func (*Array) Floats added in v2.0.2 

func (t *Array) Floats() []*embedFloat

func (*Array) Ints added in v2.0.2 

func (t *Array) Ints() []*embedInt

func (*Array) Len added in v2.0.2 

func (t *Array) Len() int

func (*Array) String added in v2.0.2 

func (t *Array) String() string

func (*Array) Strings added in v2.0.2 

func (t *Array) Strings() []*embedString

func (*Array) Uints added in v2.0.2 

func (t *Array) Uints() []*embedUint

type Backend added in v2.0.2 

type Backend interface {
	// Type returns the backend provider type.
	Type() string

	// Set value for the specified key.
	Set(key, value string) error

	// Get the value of the specified key or directory.
	Get(key string, dir bool) (*KVPairs, error)

	// Watch for changes of the specified key or directory.
	Watch(key string, version uint64, dir bool) (EventChan, error)

	// Close the provider connection.
	Close()
}

Backend interface.

func BackendImplementor added in v2.0.2 

func BackendImplementor() Backend

BackendImplementor returns the configuration backend service implementor.

type Bool added in v2.0.2 

type Bool struct {
	// contains filtered or unexported fields
}

func (*Bool) AtomicUpdate added in v2.0.2 

func (t *Bool) AtomicUpdate(v string)

func (*Bool) Bool added in v2.0.2 

func (t *Bool) Bool() bool

func (*Bool) Changed added in v2.0.2 

func (t *Bool) Changed(evt UpdateEvent)

func (*Bool) String added in v2.0.2 

func (t *Bool) String() string

type Callback added in v2.0.2 

type Callback interface {
	RegChan() chan<- *CallbackFunc
	EvtChan() chan<- DynamicType
}

func CallbackImplementor added in v2.0.2 

func CallbackImplementor() Callback

CallbackImplementor returns the value updated callback service implementor.

type CallbackFunc added in v2.0.2 

type CallbackFunc struct {
	Value DynamicType
	Event UpdateEvent
}

type Configure 

type Configure interface {
	// Register the configuration pointer.
	Register(component string, v interface{}, opts ...Option) error
}

func Implementor 

func Implementor() Configure

Implementor returns the configuration service implementor.

type Dialect 

type Dialect interface {
	URL() string
}

type DynamicType added in v2.0.2 

type DynamicType interface {
	// AtomicUpdate updates value.
	AtomicUpdate(v string)

	// Changed will be invoked if value updated.
	Changed(evt UpdateEvent)
}

DynamicType interface.

type EventChan added in v2.0.2 

type EventChan chan *WatchEvent

type EventType added in v2.0.2 

type EventType int
const (
	Update  EventType = iota + 1 // Key/value updated
	Delete                       // Key/value deleted
	Refresh                      // Refresh pah
)

type Float added in v2.0.2 

type Float struct {
	// contains filtered or unexported fields
}

func (*Float) AtomicUpdate added in v2.0.2 

func (t *Float) AtomicUpdate(v string)

func (*Float) Changed added in v2.0.2 

func (t *Float) Changed(evt UpdateEvent)

func (*Float) Float32 added in v2.0.2 

func (t *Float) Float32() float32

func (*Float) Float64 added in v2.0.2 

func (t *Float) Float64() float64

func (*Float) String added in v2.0.2 

func (t *Float) String() string

type Int added in v2.0.2 

type Int struct {
	// contains filtered or unexported fields
}

func (*Int) AtomicUpdate added in v2.0.2 

func (t *Int) AtomicUpdate(v string)

func (*Int) Changed added in v2.0.2 

func (t *Int) Changed(evt UpdateEvent)

func (*Int) Int added in v2.0.2 

func (t *Int) Int() int

func (*Int) Int16 added in v2.0.2 

func (t *Int) Int16() int16

func (*Int) Int32 added in v2.0.2 

func (t *Int) Int32() int32

func (*Int) Int64 added in v2.0.2 

func (t *Int) Int64() int64

func (*Int) Int8 added in v2.0.2 

func (t *Int) Int8() int8

func (*Int) String added in v2.0.2 

func (t *Int) String() string

type KVPair added in v2.0.2 

type KVPair struct {
	Key     string
	Value   string
	Version uint64
}

type KVPairs added in v2.0.2 

type KVPairs struct {
	KVs     []*KVPair
	Version uint64
}

type Map added in v2.0.2 

type Map struct {
	// contains filtered or unexported fields
}

func (*Map) ArrayVal added in v2.0.2 

func (t *Map) ArrayVal(key string) *embedArray

func (*Map) AtomicUpdate added in v2.0.2 

func (t *Map) AtomicUpdate(v string)

func (*Map) BoolVal added in v2.0.2 

func (t *Map) BoolVal(key string) *embedBool

func (*Map) Changed added in v2.0.2 

func (t *Map) Changed(evt UpdateEvent)

func (*Map) FloatVal added in v2.0.2 

func (t *Map) FloatVal(key string) *embedFloat

func (*Map) HasKey added in v2.0.2 

func (t *Map) HasKey(key string) bool

func (*Map) IntVal added in v2.0.2 

func (t *Map) IntVal(key string) *embedInt

func (*Map) Keys added in v2.0.2 

func (t *Map) Keys() *embedArray

func (*Map) Len added in v2.0.2 

func (t *Map) Len() int

func (*Map) MapVal added in v2.0.2 

func (t *Map) MapVal(key string) *embedMap

func (*Map) String added in v2.0.2 

func (t *Map) String() string

func (*Map) StringVal added in v2.0.2 

func (t *Map) StringVal(key string) *embedString

func (*Map) UintVal added in v2.0.2 

func (t *Map) UintVal(key string) *embedUint

type Option added in v2.0.2 

type Option func(options *Options)

func WithAutoCreation added in v2.0.2 

func WithAutoCreation(autoCreate bool) Option

type Options added in v2.0.2 

type Options struct {
	AutoCreation bool
}

type Schema 

type Schema string
const (
	SQLite     Schema = "sqlite"
	MySQL      Schema = "mysql"
	PostgreSQL Schema = "postgres"
	SQLServer  Schema = "sqlserver"
	Clickhouse Schema = "clickhouse"

	Redis        Schema = "redis"
	RedisCluster Schema = "rediscluster"

	ElasticSearch6 Schema = "elasticsearch6"
	ElasticSearch7 Schema = "elasticsearch7"

	Kafka    Schema = "kafka"
	Pulsar   Schema = "pulsar"
	RocketMQ Schema = "rocketmq"
)

type StaticType added in v2.0.2 

type StaticType interface {
	// Set value.
	Set(v string)
}

StaticType interface.

type String added in v2.0.2 

type String struct {
	// contains filtered or unexported fields
}

func (*String) AtomicUpdate added in v2.0.2 

func (t *String) AtomicUpdate(v string)

func (*String) Changed added in v2.0.2 

func (t *String) Changed(evt UpdateEvent)

func (*String) String added in v2.0.2 

func (t *String) String() string

type Uint added in v2.0.2 

type Uint struct {
	// contains filtered or unexported fields
}

func (*Uint) AtomicUpdate added in v2.0.2 

func (t *Uint) AtomicUpdate(v string)

func (*Uint) Changed added in v2.0.2 

func (t *Uint) Changed(evt UpdateEvent)

func (*Uint) String added in v2.0.2 

func (t *Uint) String() string

func (*Uint) Uint added in v2.0.2 

func (t *Uint) Uint() uint

func (*Uint) Uint16 added in v2.0.2 

func (t *Uint) Uint16() uint16

func (*Uint) Uint32 added in v2.0.2 

func (t *Uint) Uint32() uint32

func (*Uint) Uint64 added in v2.0.2 

func (t *Uint) Uint64() uint64

func (*Uint) Uint8 added in v2.0.2 

func (t *Uint) Uint8() uint8

type UpdateEvent added in v2.0.2 

type UpdateEvent func()

type WatchEvent added in v2.0.2 

type WatchEvent struct {
	EventType
	KVPair
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.