config

Documentation

Index

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

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 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) GetNamespace

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

func (*NamespaceWatcher) Namespaces

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

type Provider

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

func New

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

func (*Provider) CORS

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

func (*Provider) DSN

func (k *Provider) DSN() string

func (*Provider) NamespaceManager

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

func (*Provider) ReadAPIListenOn

func (k *Provider) ReadAPIListenOn() string

func (*Provider) Set

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

func (*Provider) TracingConfig

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

func (*Provider) TracingProvider

func (k *Provider) TracingProvider() string

func (*Provider) TracingServiceName

func (k *Provider) TracingServiceName() string

func (*Provider) WriteAPIListenOn

func (k *Provider) WriteAPIListenOn() string