internal

Documentation

Index

• Variables
• func ConfigCallSection(name string, cfg *viper.Viper) error
• func ConfigGetSections() []string
• func ConfigRegister(name string, parse func(*viper.Viper) error, validate func() ([]error, error)) error
• func ConfigValidateSection(name string) (warnings []error, err error)
• func RandString(n int) string
• func StartLogger()
• type GlobalStateT
• type NatsConfigT
• type WorkerConfigT

Variables

var Log logadapter.Logger

Functions

func ConfigCallSection

func ConfigCallSection(name string, cfg *viper.Viper) error

func ConfigGetSections

func ConfigGetSections() []string

func ConfigRegister

func ConfigRegister(name string, parse func(*viper.Viper) error, validate func() ([]error, error)) error

func ConfigValidateSection

func ConfigValidateSection(name string) (warnings []error, err error)

func RandString

func RandString(n int) string

func StartLogger

func StartLogger()

Types

type GlobalStateT

type GlobalStateT struct {
	WorkerConfig              WorkerConfigT
	NatsConfig                NatsConfigT
	Conn                      *rns.ResticNatsClient
	ClientCommand             chan *nats.Msg
	ClientCommandSubscription *nats.Subscription
	Mx                        sync.Mutex
	T                         tomb.Tomb
}

var GlobalState GlobalStateT

type NatsConfigT

type NatsConfigT struct {
	MaxNatsConnections int
	NatsURL            *url.URL
	NatsNKey           string
	NatsCredfile       string
}

type WorkerConfigT

type WorkerConfigT struct {
	NumWorkers  int
	Connections uint
}