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 NewSystemOutProxyWriter(writer io.Writer) io.Writer
• 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 ProxyWriter
  • func (proxy ProxyWriter) Write(chunk []byte) (n int, err error)
• 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

func LogDebug

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

func LogError

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

func LogFatal

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

func LogInfo

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

func NewSystemOutProxyWriter

func NewSystemOutProxyWriter(writer io.Writer) io.Writer

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 ProxyWriter

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

func (ProxyWriter) Write

func (proxy ProxyWriter) Write(chunk []byte) (n int, err error)

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