ctx

Documentation

Index

• func IsDebugLogEnabled() bool
• func LogDebug(tag string, data ...any)
• func LogError(tag string, data ...any)
• func LogFatal(tag string, data ...any)
• func LogInfo(tag string, data ...any)
• func StartContextualizedApplication(packageServices ...[]Service)
• type AppContext
  • func ApplicationContext() AppContext
• type ConnectableService
• type EnvValue
  • func GetEnv(name string) *EnvValue
  • func (instance *EnvValue) AsBool() bool
  • func (instance *EnvValue) AsBoolDefault(def bool) bool
  • func (instance *EnvValue) AsInt() int
  • func (instance *EnvValue) AsIntArray() []int
  • func (instance *EnvValue) AsIntArrayDefault() []int
  • func (instance *EnvValue) AsIntDefault(def int) int
  • func (instance *EnvValue) AsMap() map[string]*EnvValue
  • func (instance *EnvValue) AsString() string
  • func (instance *EnvValue) AsStringArray() []string
  • func (instance *EnvValue) AsStringArrayDefault(def []string) []string
  • func (instance *EnvValue) AsStringDefault(def string) string
  • func (instance *EnvValue) IsPresent() bool
• type LifecycleAware
• type Service
  • func ConnectServices(services ...string) Service
  • func ServiceArray(srvs ...Service) []Service
• type ServiceConnector
  • func NewServiceConnector[In any, Out any](service ConnectableService[In, Out]) ServiceConnector[In, Out]
  • func (connector *ServiceConnector[In, Out]) AfterStart()
  • func (connector *ServiceConnector[In, Out]) BeforeStop()
  • func (connector *ServiceConnector[In, Out]) Send(msg Out)
• type TimerTask
  • func (instance *TimerTask) StartTimer(interval time.Duration, actionOnTimer func())
  • func (instance *TimerTask) StopTimer()

Functions

func IsDebugLogEnabled

func IsDebugLogEnabled() bool

IsDebugLogEnabled Deprecated: use logger.Configure

func LogDebug

func LogDebug(tag string, data ...any)

LogDebug Deprecated: use logger.Debug

func LogError

func LogError(tag string, data ...any)

LogError Deprecated: use logger.Debug

func LogFatal

func LogFatal(tag string, data ...any)

LogFatal Deprecated: use logger.Debug

func LogInfo

func LogInfo(tag string, data ...any)

LogInfo Deprecated: use logger.Debug

func StartContextualizedApplication

func StartContextualizedApplication(packageServices ...[]Service)

Types

type AppContext

type AppContext interface {
	Register(serviceInstance Service) AppContext
	Start()
	Stop()
	GetService(serviceName string) Service
}

func ApplicationContext

func ApplicationContext() AppContext

type ConnectableService

type ConnectableService[In any, Out any] interface {
	Service
	OnMessage(In)
	Send(Out)
}

type EnvValue

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

func GetEnv

func GetEnv(name string) *EnvValue

func (*EnvValue) AsBool

func (instance *EnvValue) AsBool() bool

func (*EnvValue) AsBoolDefault

func (instance *EnvValue) AsBoolDefault(def bool) bool

func (*EnvValue) AsInt

func (instance *EnvValue) AsInt() int

func (*EnvValue) AsIntArray

func (instance *EnvValue) AsIntArray() []int

func (*EnvValue) AsIntArrayDefault

func (instance *EnvValue) AsIntArrayDefault() []int

func (*EnvValue) AsIntDefault

func (instance *EnvValue) AsIntDefault(def int) int

func (*EnvValue) AsMap

func (instance *EnvValue) AsMap() map[string]*EnvValue

func (*EnvValue) AsString

func (instance *EnvValue) AsString() string

func (*EnvValue) AsStringArray

func (instance *EnvValue) AsStringArray() []string

func (*EnvValue) AsStringArrayDefault

func (instance *EnvValue) AsStringArrayDefault(def []string) []string

func (*EnvValue) AsStringDefault

func (instance *EnvValue) AsStringDefault(def string) string

func (*EnvValue) IsPresent

func (instance *EnvValue) IsPresent() bool

type LifecycleAware

type LifecycleAware interface {
	Service
	AfterStart()
	BeforeStop()
}

type Service

type Service interface {
	Init(serviceProvider func(serviceName string) Service)
	Name() string
	Dispose()
}

func ConnectServices

func ConnectServices(services ...string) Service

func ServiceArray

func ServiceArray(srvs ...Service) []Service

type ServiceConnector

type ServiceConnector[In any, Out any] struct {
	// contains filtered or unexported fields
}

func NewServiceConnector

func NewServiceConnector[In any, Out any](service ConnectableService[In, Out]) ServiceConnector[In, Out]

func (*ServiceConnector[In, Out]) AfterStart

func (connector *ServiceConnector[In, Out]) AfterStart()

func (*ServiceConnector[In, Out]) BeforeStop

func (connector *ServiceConnector[In, Out]) BeforeStop()

func (*ServiceConnector[In, Out]) Send

func (connector *ServiceConnector[In, Out]) Send(msg Out)

type TimerTask

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

func (*TimerTask) StartTimer

func (instance *TimerTask) StartTimer(interval time.Duration, actionOnTimer func())

func (*TimerTask) StopTimer

func (instance *TimerTask) StopTimer()