libapp

Documentation

Index

• Constants
• Variables
• func GetLogger() log.Logger
• func NewContext(ctx context.Context, requiredFeature string) context.Context
• func NewDiscovery() (registry.Discovery, error)
• func NewLeakyBucketMiddleware(rate int) middleware.Middleware
• func NewNodeFilter() selector.NodeFilter
• func NewRegistrar() (registry.Registrar, error)
• func NewStreamMiddlewareJwt(auth *libauth.Auth) func(ctx context.Context) (context.Context, error)
• func NewValidator() (middleware.Middleware, error)
• type Env
• type Flags
• type HealthChecker
  • func NewHealthChecker(serviceName string) (*HealthChecker, error)
  • func (hc *HealthChecker) GetAliveInstances() ([]*api.ServiceEntry, error)
• type InherentSettings
• type Settings
  • func NewAppSettings(id, name, version, protoVersion, date string) (*Settings, error)
  • func (a *Settings) GetEnv(env Env) (string, error)
  • func (a *Settings) GetEnvBool(env Env) (bool, error)
  • func (a *Settings) LoadConfig(conf interface{})

Constants

const DiscoveryAddress = "localhost:8500"

Variables

var ProviderSet = wire.NewSet(NewDiscovery, NewRegistrar, NewNodeFilter)

Functions

func GetLogger

func GetLogger() log.Logger

func NewContext

func NewContext(ctx context.Context, requiredFeature string) context.Context

func NewDiscovery

func NewDiscovery() (registry.Discovery, error)

func NewLeakyBucketMiddleware

func NewLeakyBucketMiddleware(rate int) middleware.Middleware

func NewNodeFilter

func NewNodeFilter() selector.NodeFilter

func NewRegistrar

func NewRegistrar() (registry.Registrar, error)

func NewStreamMiddlewareJwt

func NewStreamMiddlewareJwt(auth *libauth.Auth) func(ctx context.Context) (context.Context, error)

func NewValidator

func NewValidator() (middleware.Middleware, error)

Types

type Env

type Env string

const (
	EnvCreateAdmin Env = "CREATE_ADMIN"
	EnvLogLevel    Env = "LOG_LEVEL"
)

type Flags

type Flags struct {
	ConfPath string
	DataPath string
}

type HealthChecker

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

func NewHealthChecker

func NewHealthChecker(serviceName string) (*HealthChecker, error)

func (*HealthChecker) GetAliveInstances

func (hc *HealthChecker) GetAliveInstances() ([]*api.ServiceEntry, error)

type InherentSettings

type InherentSettings struct {
	EnablePanicRecovery bool
	LogLevel            libzap.Level
	DefaultConfPath     string
}

type Settings

type Settings struct {
	InherentSettings
	Flags
	Version           string
	ProtoVersion      string
	BuildDate         string
	SourceCodeAddress string
	// contains filtered or unexported fields
}

func NewAppSettings

func NewAppSettings(id, name, version, protoVersion, date string) (*Settings, error)

func (*Settings) GetEnv

func (a *Settings) GetEnv(env Env) (string, error)

func (*Settings) GetEnvBool

func (a *Settings) GetEnvBool(env Env) (bool, error)

func (*Settings) LoadConfig

func (a *Settings) LoadConfig(conf interface{})