config

Apr 13, 2026

Changes in this version

type LoaderParams

+ Mode string

type LoggerConfig

+ GetLoggerConsole func() bool

+ GetLoggerRemote func() bool

Apr 11, 2026

Changes in this version

+ var ErrInvalidRaw = errors.New("invalid config raw")

+ type BootstrapConfig interface

+ GetAppId func() string

+ GetAppName func() string

+ GetAppSecret func() string

+ GetAppVersion func() string

+ GetGatewayAuthToken func() string

+ GetGatewayEndpoint func() string

+ GetManagementPort func() uint

+ GetServerPort func() uint

+ GetServiceAuthToken func() string

+ GetServiceEndpoint func() string

+ GetServiceInstanceId func() string

+ GetServiceNamespace func() string

+ GetSystemName func() string

+ GetSystemType func() uint32

+ GetSystemVersion func() string

+ type LoggerConfig interface

+ IsEnableConsole func() bool

+ IsEnableRemote func() bool

+ type Raw struct

+ Content []byte

+ CreatedAt time.Time

+ Encrypted bool

+ Meta map[string]string

+ UpdatedAt time.Time

+ UpdatedBy string

+ Version string

+ type TelemetryConfig interface

+ GetOtelEndpoint func() string

+ GetOtelInsecure func() bool

+ GetOtelLogs func() bool

+ GetOtelMetrics func() bool

+ GetOtelTraces func() bool

type WatchEvent

+ Raw *Raw

Mar 27, 2026

Changes in this version

+ var ErrLocalLoaderIsNil = errors.New("config local loader is nil")

+ var ErrPayloadDecoderIsNil = errors.New("config payload decoder is nil")

+ var ErrRemoteLoaderIsNil = errors.New("config remote loader is nil")

+ var ErrUnsupportedLoadMode = errors.New("unsupported config load mode")

+ func LoadConfig[T any](params LoaderParams, localLoad LocalLoaderFunc, remoteLoad RemoteLoaderFunc, ...) (T, error)

+ func LoadStoreConfig[T any](ctx context.Context, store Store, params StoreParams, ...) (T, error)

+ type LoaderParams struct

+ AppId string

+ AppSecret []byte

+ FileName string

+ Group string

+ Key string

+ LoadMode string

+ type LocalLoaderFunc func(fileName string, target any) error

+ type PayloadDecodeFunc func(content string, secret []byte, target any) error

+ type RemoteLoaderFunc func(appId, group, key string) (string, error)

+ type StoreParams struct

+ AppId string

+ AppSecret []byte

+ Env string

+ Group string

+ Key Key

+ Name string

Mar 25, 2026

Changes in this version

+ func DecodeBootstrapConfig[T any](request StoreBootstrapRequest, localLoader LocalConfigLoader, ...) (T, error)

+ func DecodeStoreJSON[T any](ctx context.Context, store Store, request StoreReadRequest, ...) (T, error)

+ type LocalConfigLoader func(fileName string, target any) error

+ type PayloadDecoder func(content string, secret []byte, target any) error

+ type RemoteConfigGetter func(appId, group, key string) (string, error)

+ type StoreBootstrapRequest struct

+ AppId string

+ AppSecret []byte

+ FileName string

+ Group string

+ Key string

+ LoadMode string

+ type StoreReadRequest struct

+ AppId string

+ AppSecret []byte

+ Env string

+ Group string

+ Key Key

+ Name string

Mar 23, 2026

Changes in this version

type Key

+ AppId string

+ TenantId string

type Query

+ AppId string

+ TenantId string

+ UserId string

Mar 22, 2026

Changes in this version

+ var ErrCodecIsNil = errors.New("config codec is nil")

+ var ErrEncryptorIsNil = errors.New("config encryptor is nil")

+ var ErrInvalidItem = errors.New("invalid config item")

+ var ErrInvalidKey = errors.New("invalid config key")

+ var ErrResourceNotFound = errors.New("config resource not found")

+ var ErrStoreIsNil = errors.New("config store is nil")

+ var ErrVersionConflict = errors.New("config version conflict")

+ var ErrWatcherIsNil = errors.New("config watcher is nil")

+ type Codec interface

+ Marshal func(v any) ([]byte, error)

+ Unmarshal func(data []byte, dst any) error

+ type Encryptor interface

+ Decrypt func(data []byte, key []byte) ([]byte, error)

+ Encrypt func(data []byte, key []byte) ([]byte, error)

+ type EventType int

+ const EventDelete

+ const EventPut

+ type Item struct

+ Content []byte

+ Encrypted bool

+ Meta map[string]string

+ UpdatedAt time.Time

+ UpdatedBy string

+ Version string

+ type Key struct

+ AppID string

+ Env string

+ Group string

+ Name string

+ Tenant string

+ type Meta struct

+ CurrentVersion string

+ LatestVersion string

+ type Option func(*Options)

+ func WithCodec(codec Codec) Option

+ func WithEncryptor(encryptor Encryptor) Option

+ func WithNamespace(namespace string) Option

+ func WithRetry(retry uint32) Option

+ func WithTimeout(timeout time.Duration) Option

+ func WithWatchBuffer(size int) Option

+ type Options struct

+ Codec Codec

+ Encryptor Encryptor

+ Namespace string

+ Retry uint32

+ Timeout time.Duration

+ WatchBuffer int

+ func NewOptions(opts ...Option) *Options

+ type Query struct

+ AppID string

+ Key Key

+ Tags map[string]string

+ TenantID string

+ UserID string

+ type Store interface

+ Delete func(ctx context.Context, key Key) error

+ Get func(ctx context.Context, key Key) (*Item, error)

+ GetByQuery func(ctx context.Context, query Query) (*Item, error)

+ GetMeta func(ctx context.Context, key Key) (*Meta, error)

+ GetVersion func(ctx context.Context, key Key, version string) (*Item, error)

+ ListVersions func(ctx context.Context, key Key, limit int) ([]string, error)

+ Put func(ctx context.Context, key Key, item *Item) error

+ PutMeta func(ctx context.Context, key Key, meta *Meta) error

+ PutVersion func(ctx context.Context, key Key, item *Item) (string, error)

+ type WatchEvent struct

+ Item *Item

+ Key Key

+ Type EventType

+ type Watcher interface

+ Unwatch func(key Key)

+ Watch func(ctx context.Context, key Key) (<-chan WatchEvent, error)