rxd

Jul 23, 2025

Changes in this version

type ServiceContext

+ Logger func() log.Logger

Jul 22, 2025

Changes in this version

+ func IsCancelled(err error) bool

type Error

+ const ErrLifecycleDone

Jun 8, 2025

Changes in this version

+ type ServiceStateUpdate struct

+ Name string

+ State State

+ Transition StateTransition

type State

+ const StateUnknown

+ type StateTransition uint8

+ const TransitionEntering

+ const TransitionExited

+ const TransitionUnknown

type StateUpdate

+ Transition StateTransition

Apr 12, 2025

Changes in this version

type ServiceContext

+ IntracomRegistry func() *intracom.Intracom

Oct 14, 2024

Changes in this version

type ServiceAction

+ const NotIn

Aug 26, 2024

Changes in this version

type Daemon

+ func NewDaemonWithLogger(name string, logger log.Logger, options ...DaemonOption) Daemon

type DaemonOption

+ func WithCustomPrestartPipeline(prestart Pipeline) DaemonOption

+ func WithLogWorkerCount(count int) DaemonOption

+ func WithPrestart(conf PrestartConfig, stages ...Stage) DaemonOption

+ type Pipeline interface

+ Add func(stage Stage)

+ Run func(ctx context.Context) <-chan DaemonLog

+ func NewPrestartPipeline(conf PrestartConfig, stages ...Stage) Pipeline

+ type PrestartConfig struct

+ RestartDelay time.Duration

+ RestartOnError bool

+ type RunUntilSuccessManager struct

+ DefaultDelay time.Duration

+ StartupDelay time.Duration

+ func NewRunUntilSuccessManager(defaultDelay, startupDelay time.Duration) RunUntilSuccessManager

+ func (m RunUntilSuccessManager) Manage(sctx ServiceContext, ds DaemonService, updateC chan<- StateUpdate)

type ServiceAction

+ const Changed

+ const Entered

+ const Exited

+ type Stage struct

+ Func StageFunc

+ Name string

+ type StageFunc func(ctx context.Context) error

Jul 22, 2024

Changes in this version

+ var NoFilter = ServiceFilter

+ type CommandHandler struct

+ func (h CommandHandler) ChangeLogLevel(level log.Level, resp *error) error

+ type Daemon interface

+ AddService func(service Service) error

+ AddServices func(services ...Service) error

+ Start func(ctx context.Context) error

+ type DaemonLog struct

+ Fields []log.Field

+ Level log.Level

+ Message string

+ Name string

+ func (l DaemonLog) String() string

+ type DaemonOption func(*daemon)

+ func WithInternalLogger(logger log.Logger) DaemonOption

+ func WithInternalLogging(filepath string, level log.Level) DaemonOption

+ func WithRPC(cfg RPCConfig) DaemonOption

+ func WithReportAlive(timeoutSecs uint64) DaemonOption

+ func WithServiceLogger(logger log.Logger) DaemonOption

+ func WithSignals(signals ...os.Signal) DaemonOption

+ type DaemonService struct

+ Name string

+ Runner ServiceRunner

+ type ErrUninitialized struct

+ Method string

+ StructName string

+ func (e ErrUninitialized) Error() string

type Error

+ const ErrAddingServiceOnceStarted

+ const ErrDaemonStarted

+ const ErrDuplicateServiceName

+ const ErrDuplicateServicePolicy

+ const ErrNilService

+ const ErrNoServiceName

+ const ErrNoServices

+ func (e Error) Error() string

+ type FilterMode int

+ const Exclude

+ const Include

+ const None

+ type ManagerOption func(m *RunContinuousManager)

+ func WithInitDelay(delay time.Duration) ManagerOption

+ func WithTransitionTimeouts(t ManagerStateTimeouts) ManagerOption

+ type ManagerStateTimeouts map[State]time.Duration

+ type NotifyState uint8

+ const NotifyStateAlive

+ const NotifyStateReady

+ const NotifyStateReloading

+ const NotifyStateRestarting

+ const NotifyStateStopped

+ const NotifyStateStopping

+ func (s NotifyState) String() string

+ type RPCConfig struct

+ Addr string

+ Port uint16

+ type RPCServer struct

+ func NewRPCHandler(cfg RPCConfig) (*RPCServer, error)

+ func (s *RPCServer) Start() error

+ func (s *RPCServer) Stop() error

+ type RunContinuousManager struct

+ DefaultDelay time.Duration

+ StartupDelay time.Duration

+ StateTimeouts ManagerStateTimeouts

+ func NewDefaultManager(opts ...ManagerOption) RunContinuousManager

+ func (m RunContinuousManager) Manage(sctx ServiceContext, ds DaemonService, updateState func(string, State))

type Service

+ Manager ServiceManager

+ Name string

+ Runner ServiceRunner

+ type ServiceAction uint8

+ const Changing

+ const Entering

+ const Exiting

+ func (s ServiceAction) String() string

type ServiceContext

+ WithFields func(fields ...log.Field) ServiceContext

+ WithName func(name string) (ServiceContext, context.CancelFunc)

+ WithParent func(ctx context.Context) (ServiceContext, context.CancelFunc)

+ type ServiceFilter struct

+ Mode FilterMode

+ Names map[string]struct{}

+ func NewServiceFilter(mode FilterMode, names ...string) ServiceFilter

+ type ServiceLogger interface

+ Log func(level log.Level, message string, extra ...log.Field)

+ type ServiceManager interface

+ Manage func(ctx ServiceContext, dService DaemonService, ...)

type ServiceOption

+ func WithManager(manager ServiceManager) ServiceOption

+ type ServiceRunner interface

+ Idle func(ServiceContext) error

+ Init func(ServiceContext) error

+ Run func(ServiceContext) error

+ Stop func(ServiceContext) error

+ type ServiceStates map[string]State

+ type ServiceWatcher interface

+ WatchAllServices func(action ServiceAction, target State, services ...string) (<-chan ServiceStates, context.CancelFunc)

+ WatchAllStates func(ServiceFilter) (<-chan ServiceStates, context.CancelFunc)

+ WatchAnyServices func(action ServiceAction, target State, services ...string) (<-chan ServiceStates, context.CancelFunc)

type State

+ const StateExit

+ const StateIdle

+ const StateInit

+ const StateRun

+ const StateStop

+ type StatesResponse struct

+ Err error

+ States ServiceStates

+ type SystemNotifier interface

+ Notify func(state NotifyState) error

+ Start func(ctx context.Context, logger log.Logger) error

+ func NewSystemdNotifier(socketName string, durationSecs uint64) (SystemNotifier, error)

Jan 3, 2024

Changes in this version

type RunPolicy

+ func (r RunPolicy) String() string

type ServiceContext

+ ShutdownCtx context.Context

type ServiceOption

+ func UsingContext(parent context.Context) ServiceOption

+ func UsingLogHandler(h slog.Handler) ServiceOption

type State

+ func (s State) String() string

Dec 31, 2023

Changes in this version

+ func AllServicesEnterState(sc *ServiceContext, target State, serviceNames ...string) (<-chan States, context.CancelFunc)

+ func AnyServicesEnterState(sc *ServiceContext, target State, serviceNames ...string) (<-chan States, context.CancelFunc)

+ type DaemonConfig struct

+ IntracomLogHandler slog.Handler

+ LogHandler slog.Handler

+ Name string

+ Signals []os.Signal

Jul 1, 2023

Changes in this version

+ func AllServicesEnteredState(sc *ServiceContext, target State, serviceNames ...string) (<-chan States, context.CancelFunc)

+ func AllServicesStates(sc *ServiceContext) (<-chan States, context.CancelFunc)

+ func AnyServicesExitState(sc *ServiceContext, target State, serviceNames ...string) (<-chan States, context.CancelFunc)

+ type StateUpdate struct

+ Name string

+ State State

+ type States map[string]State

Jun 22, 2023

Changes in this version

+ const InternalServiceStates

Jun 17, 2023

Changes in this version

+ const NoFlags

+ func NewDaemon(services ...*ServiceContext) *daemon

+ func NewServiceOpts(options ...ServiceOption) *serviceOpts

+ type Level string

+ var Debug Level = "debug"

+ var Error Level = "error"

+ var Info Level = "info"

+ type LogMessage struct

+ Level Level

+ Message string

+ func NewLog(message string, level Level) LogMessage

+ type LogSeverity int

+ const LevelAll

+ const LevelDebug

+ const LevelError

+ const LevelInfo

+ const LevelOff

+ const LevelWarn

+ type Logger struct

+ func NewLogger(logSeverity LogSeverity, flags int) *Logger

+ func (l *Logger) Debug(v ...any)

+ func (l *Logger) Debugf(format string, v ...any)

+ func (l *Logger) Error(v ...any)

+ func (l *Logger) Errorf(format string, v ...any)

+ func (l *Logger) Info(v ...any)

+ func (l *Logger) Infof(format string, v ...any)

+ func (l *Logger) Warn(v ...any)

+ func (l *Logger) Warnf(format string, v ...any)

+ type Logging interface

+ Debug func(v ...any)

+ Debugf func(format string, v ...any)

+ Error func(v ...any)

+ Errorf func(format string, v ...any)

+ Info func(v ...any)

+ Infof func(format string, v ...any)

+ Warn func(v ...any)

+ Warnf func(format string, v ...any)

+ type RunPolicy string

+ const RetryUntilSuccessPolicy

+ const RunOncePolicy

+ const RunUntilStoppedPolicy

+ type Service interface

+ Idle func(*ServiceContext) ServiceResponse

+ Init func(*ServiceContext) ServiceResponse

+ Run func(*ServiceContext) ServiceResponse

+ Stop func(*ServiceContext) ServiceResponse

+ type ServiceContext struct

+ Ctx context.Context

+ Log Logging

+ Name string

+ func NewService(name string, service Service, opts *serviceOpts) *ServiceContext

+ func (sc *ServiceContext) AddDependentService(s *ServiceContext, states ...State) error

+ func (sc *ServiceContext) ChangeState() chan State

+ func (sc *ServiceContext) IntracomPublish(topic string, message []byte)

+ func (sc *ServiceContext) IntracomSubscribe(topic string, id string) <-chan []byte

+ func (sc *ServiceContext) IntracomUnsubscribe(topic string, id string)

+ func (sc *ServiceContext) ShutdownSignal() <-chan struct{}

+ type ServiceOption func(*serviceOpts)

+ func UsingDefaultLogger(severity LogSeverity, flags int) ServiceOption

+ func UsingLogger(logger Logging) ServiceOption

+ func UsingRunPolicy(policy RunPolicy) ServiceOption

+ type ServiceResponse struct

+ Error error

+ NextState State

+ func NewResponse(err error, nextState State) ServiceResponse

+ type State string

+ const ExitState

+ const IdleState

+ const InitState

+ const RunState

+ const StopState