configuration

Sep 11, 2024

Changes in this version

type Obfuscator

+ func NewObfuscator(key []byte) Obfuscator

type ObfuscatorProvider

+ Obfuscator func() Obfuscator

+ type ProviderKey string

type Secrets

+ func (Secrets) Obfuscator() Obfuscator

Aug 17, 2024

Changes in this version

+ var ErrNotFound = errors.New("not found")

+ func ConfigFromEnvironment() []string

+ func ContextWithConfig(ctx context.Context, configManager *Manager[Configuration]) context.Context

+ func ContextWithSecrets(ctx context.Context, secretsManager *Manager[Secrets]) context.Context

+ func ProviderKeyForAccessor(accessor *url.URL) string

+ type ASM struct

+ func NewASM(ctx context.Context, secretsClient *secretsmanager.Client, advertise *url.URL, ...) *ASM

+ func (ASM) Key() string

+ func (ASM) Role() Secrets

+ func (a *ASM) Delete(ctx context.Context, ref Ref) error

+ func (a *ASM) Store(ctx context.Context, ref Ref, value []byte) (*url.URL, error)

+ func (a *ASM) Sync(ctx context.Context, entries []Entry, values *xsync.MapOf[Ref, SyncedValue]) error

+ func (a *ASM) SyncInterval() time.Duration

+ type AsynchronousProvider interface

+ Sync func(ctx context.Context, entries []Entry, values *xsync.MapOf[Ref, SyncedValue]) error

+ SyncInterval func() time.Duration

+ type Configuration struct

+ func (Configuration) String() string

+ type DBConfigProvider struct

+ func NewDBConfigProvider(dal DBConfigProviderDAL) DBConfigProvider

+ func (DBConfigProvider) Key() string

+ func (DBConfigProvider) Role() Configuration

+ func (d DBConfigProvider) Delete(ctx context.Context, ref Ref) error

+ func (d DBConfigProvider) Load(ctx context.Context, ref Ref, key *url.URL) ([]byte, error)

+ func (d DBConfigProvider) Store(ctx context.Context, ref Ref, value []byte) (*url.URL, error)

+ type DBConfigProviderDAL interface

+ GetModuleConfiguration func(ctx context.Context, module optional.Option[string], name string) ([]byte, error)

+ SetModuleConfiguration func(ctx context.Context, module optional.Option[string], name string, value []byte) error

+ UnsetModuleConfiguration func(ctx context.Context, module optional.Option[string], name string) error

+ type DBConfigResolver struct

+ func NewDBConfigResolver(db DBConfigResolverDAL) DBConfigResolver

+ func (d DBConfigResolver) Get(ctx context.Context, ref Ref) (*url.URL, error)

+ func (d DBConfigResolver) List(ctx context.Context) ([]Entry, error)

+ func (d DBConfigResolver) Role() Configuration

+ func (d DBConfigResolver) Set(ctx context.Context, ref Ref, key *url.URL) error

+ func (d DBConfigResolver) Unset(ctx context.Context, ref Ref) error

+ type DBConfigResolverDAL interface

+ ListModuleConfiguration func(ctx context.Context) ([]sql.ModuleConfiguration, error)

+ type DBSecretResolver struct

+ func NewDBSecretResolver(db DBSecretResolverDAL) DBSecretResolver

+ func (d DBSecretResolver) Get(ctx context.Context, ref Ref) (*url.URL, error)

+ func (d DBSecretResolver) List(ctx context.Context) ([]Entry, error)

+ func (d DBSecretResolver) Role() Secrets

+ func (d DBSecretResolver) Set(ctx context.Context, ref Ref, key *url.URL) error

+ func (d DBSecretResolver) Unset(ctx context.Context, ref Ref) error

+ type DBSecretResolverDAL interface

+ GetModuleSecretURL func(ctx context.Context, module optional.Option[string], name string) (string, error)

+ ListModuleSecrets func(ctx context.Context) ([]dal.ModuleSecret, error)

+ SetModuleSecretURL func(ctx context.Context, module optional.Option[string], name string, url string) error

+ UnsetModuleSecret func(ctx context.Context, module optional.Option[string], name string) error

+ type Entry struct

+ Accessor *url.URL

+ type EnvarProvider struct

+ func (EnvarProvider[R]) Key() string

+ func (EnvarProvider[R]) Role() R

+ func (e EnvarProvider[R]) Delete(ctx context.Context, ref Ref) error

+ func (e EnvarProvider[R]) Load(ctx context.Context, ref Ref, key *url.URL) ([]byte, error)

+ func (e EnvarProvider[R]) Store(ctx context.Context, ref Ref, value []byte) (*url.URL, error)

+ type InlineProvider struct

+ func (InlineProvider[R]) Delete(ctx context.Context, ref Ref) error

+ func (InlineProvider[R]) Key() string

+ func (InlineProvider[R]) Load(ctx context.Context, ref Ref, key *url.URL) ([]byte, error)

+ func (InlineProvider[R]) Role() R

+ func (InlineProvider[R]) Store(ctx context.Context, ref Ref, value []byte) (*url.URL, error)

+ type KeychainProvider struct

+ func (KeychainProvider) Role() Secrets

+ func (k KeychainProvider) Delete(ctx context.Context, ref Ref) error

+ func (k KeychainProvider) Key() string

+ func (k KeychainProvider) Load(ctx context.Context, ref Ref, key *url.URL) ([]byte, error)

+ func (k KeychainProvider) Store(ctx context.Context, ref Ref, value []byte) (*url.URL, error)

+ type Manager struct

+ func ConfigFromContext(ctx context.Context) *Manager[Configuration]

+ func NewConfigurationManager(ctx context.Context, router Router[Configuration]) (*Manager[Configuration], error)

+ func NewDefaultConfigurationManagerFromConfig(ctx context.Context, config string) (*Manager[Configuration], error)

+ func NewDefaultSecretsManagerFromConfig(ctx context.Context, config string, opVault string) (*Manager[Secrets], error)

+ func NewSecretsManager(ctx context.Context, router Router[Secrets], opVault string, config string) (*Manager[Secrets], error)

+ func New[R Role](ctx context.Context, router Router[R], providers []Provider[R]) (*Manager[R], error)

+ func SecretsFromContext(ctx context.Context) *Manager[Secrets]

+ func (m *Manager[R]) Get(ctx context.Context, ref Ref, value any) error

+ func (m *Manager[R]) List(ctx context.Context) ([]Entry, error)

+ func (m *Manager[R]) MapForModule(ctx context.Context, module string) (map[string][]byte, error)

+ func (m *Manager[R]) Set(ctx context.Context, pkey string, ref Ref, value any) error

+ func (m *Manager[R]) SetJSON(ctx context.Context, pkey string, ref Ref, value json.RawMessage) error

+ func (m *Manager[R]) Unset(ctx context.Context, pkey string, ref Ref) error

+ type ManualSyncProvider struct

+ func NewManualSyncProvider[R Role](provider AsynchronousProvider[R]) *ManualSyncProvider[R]

+ func (a *ManualSyncProvider[R]) Delete(ctx context.Context, ref Ref) error

+ func (a *ManualSyncProvider[R]) Key() string

+ func (a *ManualSyncProvider[R]) Role() R

+ func (a *ManualSyncProvider[R]) Store(ctx context.Context, ref Ref, value []byte) (*url.URL, error)

+ func (a *ManualSyncProvider[R]) Sync(ctx context.Context, entries []Entry, values *xsync.MapOf[Ref, SyncedValue]) error

+ func (a *ManualSyncProvider[R]) SyncAndWait() error

+ func (a *ManualSyncProvider[R]) SyncInterval() time.Duration

+ type Obfuscator struct

+ func (o Obfuscator) Obfuscate(input []byte) ([]byte, error)

+ func (o Obfuscator) Reveal(input []byte) ([]byte, error)

+ type ObfuscatorProvider interface

+ type OnePasswordProvider struct

+ ProjectName string

+ Vault string

+ func (OnePasswordProvider) Role() Secrets

+ func (o OnePasswordProvider) Delete(ctx context.Context, ref Ref) error

+ func (o OnePasswordProvider) Key() string

+ func (o OnePasswordProvider) Store(ctx context.Context, ref Ref, value []byte) (*url.URL, error)

+ func (o OnePasswordProvider) Sync(ctx context.Context, entries []Entry, values *xsync.MapOf[Ref, SyncedValue]) error

+ func (o OnePasswordProvider) SyncInterval() time.Duration

+ type ProjectConfigResolver struct

+ Config string

+ func (p ProjectConfigResolver[From]) Unset(ctx context.Context, ref Ref) error

+ func (p ProjectConfigResolver[R]) Get(ctx context.Context, ref Ref) (*url.URL, error)

+ func (p ProjectConfigResolver[R]) List(ctx context.Context) ([]Entry, error)

+ func (p ProjectConfigResolver[R]) Role() R

+ func (p ProjectConfigResolver[R]) Set(ctx context.Context, ref Ref, key *url.URL) error

+ type Provider interface

+ Delete func(ctx context.Context, ref Ref) error

+ Key func() string

+ Role func() R

+ Store func(ctx context.Context, ref Ref, value []byte) (*url.URL, error)

+ type Ref struct

+ Module optional.Option[string]

+ Name string

+ func NewRef(module, name string) Ref

+ func ParseRef(s string) (Ref, error)

+ func (k *Ref) UnmarshalText(text []byte) error

+ func (k Ref) String() string

+ type Role interface

+ type Router interface

+ Get func(ctx context.Context, ref Ref) (key *url.URL, err error)

+ List func(ctx context.Context) ([]Entry, error)

+ Role func() R

+ Set func(ctx context.Context, ref Ref, key *url.URL) error

+ Unset func(ctx context.Context, ref Ref) error

+ type Secrets struct

+ func (Secrets) String() string

+ type SyncedValue struct

+ Value []byte

+ VersionToken optional.Option[VersionToken]

+ type SynchronousProvider interface

+ Load func(ctx context.Context, ref Ref, key *url.URL) ([]byte, error)

+ type VersionToken any