config

Documentation

Index

• Constants
• Variables
• func NewMemoryNamespaceManager(nn ...*namespace.Namespace) *memoryNamespaceManager
• type Config
  • func New(ctx context.Context, flags *pflag.FlagSet, l *logrusx.Logger) (*Config, error)
  • func (k *Config) CORS() (cors.Options, bool)
  • func (k *Config) DSN() string
  • func (k *Config) NamespaceManager() (namespace.Manager, error)
  • func (k *Config) ReadAPIListenOn() string
  • func (k *Config) Set(key string, v interface{}) error
  • func (k *Config) Source() *configx.Provider
  • func (k *Config) TracingConfig() *tracing.Config
  • func (k *Config) TracingProvider() string
  • func (k *Config) TracingServiceName() string
  • func (k *Config) WriteAPIListenOn() string
• type NamespaceFile
• type NamespaceWatcher
  • func NewNamespaceWatcher(ctx context.Context, l *logrusx.Logger, target string) (*NamespaceWatcher, error)
  • func (n *NamespaceWatcher) GetNamespaceByConfigID(_ context.Context, id int32) (*namespace.Namespace, error)
  • func (n *NamespaceWatcher) GetNamespaceByName(_ context.Context, name string) (*namespace.Namespace, error)
  • func (n *NamespaceWatcher) NamespaceFiles() []*NamespaceFile
  • func (n *NamespaceWatcher) Namespaces(_ context.Context) ([]*namespace.Namespace, error)
  • func (n *NamespaceWatcher) ShouldReload(newValue interface{}) bool
• type Parser
  • func GetParser(fn string) (Parser, error)
• type Provider

Constants

const (
	KeyDSN = "dsn"

	KeyReadAPIHost = "serve.read.host"
	KeyReadAPIPort = "serve.read.port"

	KeyWriteAPIHost = "serve.write.host"
	KeyWriteAPIPort = "serve.write.port"

	KeyNamespaces = "namespaces"

	DSNMemory = "sqlite://file::memory:?_fk=true&cache=shared"
)

Variables

var (
	Version = "master"
	Date    = "undefined"
	Commit  = "undefined"
)

var Schema []byte

Functions

func NewMemoryNamespaceManager

func NewMemoryNamespaceManager(nn ...*namespace.Namespace) *memoryNamespaceManager

Types

type Config

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

func New

func New(ctx context.Context, flags *pflag.FlagSet, l *logrusx.Logger) (*Config, error)

func (*Config) CORS

func (k *Config) CORS() (cors.Options, bool)

func (*Config) DSN

func (k *Config) DSN() string

func (*Config) NamespaceManager

func (k *Config) NamespaceManager() (namespace.Manager, error)

func (*Config) ReadAPIListenOn

func (k *Config) ReadAPIListenOn() string

func (*Config) Set

func (k *Config) Set(key string, v interface{}) error

func (*Config) Source

func (k *Config) Source() *configx.Provider

func (*Config) TracingConfig

func (k *Config) TracingConfig() *tracing.Config

func (*Config) TracingProvider

func (k *Config) TracingProvider() string

func (*Config) TracingServiceName

func (k *Config) TracingServiceName() string

func (*Config) WriteAPIListenOn

func (k *Config) WriteAPIListenOn() string

type NamespaceFile

type NamespaceFile struct {
	Name     string
	Contents []byte
	Parser   Parser
	// contains filtered or unexported fields
}

type NamespaceWatcher

type NamespaceWatcher struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewNamespaceWatcher

func NewNamespaceWatcher(ctx context.Context, l *logrusx.Logger, target string) (*NamespaceWatcher, error)

func (*NamespaceWatcher) GetNamespaceByConfigID

func (n *NamespaceWatcher) GetNamespaceByConfigID(_ context.Context, id int32) (*namespace.Namespace, error)

func (*NamespaceWatcher) GetNamespaceByName

func (n *NamespaceWatcher) GetNamespaceByName(_ context.Context, name string) (*namespace.Namespace, error)

func (*NamespaceWatcher) NamespaceFiles

func (n *NamespaceWatcher) NamespaceFiles() []*NamespaceFile

func (*NamespaceWatcher) Namespaces

func (n *NamespaceWatcher) Namespaces(_ context.Context) ([]*namespace.Namespace, error)

func (*NamespaceWatcher) ShouldReload

func (n *NamespaceWatcher) ShouldReload(newValue interface{}) bool

type Parser

type Parser func([]byte, interface{}) error

func GetParser

func GetParser(fn string) (Parser, error)

type Provider

type Provider interface {
	Config() *Config
}