server

Mar 13, 2026

Changes in this version

type Config

+ Mode Mode

+ type Mode int

+ const ModeFull

+ const ModeMonitor

+ const ModeQueue

+ const ModeScheduler

+ const ModeWorkflow

+ func (m Mode) Has(flag Mode) bool

type Option

+ func WithMode(m Mode) Option

Mar 11, 2026

Changes in this version

type HandlerRegistry

+ func (r *HandlerRegistry) HandlerVersions() map[types.TaskType]string

type Option

+ func WithRedisUsername(username string) Option

type Server

+ func (s *Server) Hooks() *types.Hooks

+ func (s *Server) OnJobCompleted(fn types.HookFunc)

+ func (s *Server) OnJobDead(fn types.HookFunc)

+ func (s *Server) OnJobFailed(fn types.HookFunc)

+ func (s *Server) OnJobPaused(fn types.HookFunc)

+ func (s *Server) OnJobResumed(fn types.HookFunc)

Mar 8, 2026

Changes in this version

type Config

+ ElectionTTL time.Duration

+ GroupConfig *types.GroupConfig

+ HeartbeatInterval time.Duration

+ NodeTTL time.Duration

+ RetentionPeriod *time.Duration

+ SchedulerTickInterval time.Duration

+ type HandlerRegistry struct

+ func NewHandlerRegistry() *HandlerRegistry

+ func (r *HandlerRegistry) Get(taskType types.TaskType) (*types.HandlerDefinition, bool)

+ func (r *HandlerRegistry) Len() int

+ func (r *HandlerRegistry) Register(def types.HandlerDefinition) error

+ func (r *HandlerRegistry) TaskTypes() []string

type Option

+ func WithElectionTTL(d time.Duration) Option

+ func WithGroupAggregation(cfg types.GroupConfig) Option

+ func WithHeartbeatInterval(d time.Duration) Option

+ func WithRetentionPeriod(d time.Duration) Option

+ func WithSchedulerTickInterval(d time.Duration) Option

type Server

+ func (s *Server) ClusterTaskTypes() map[string]bool

+ func (s *Server) DynConfig() *dynconfig.Manager

Mar 6, 2026

Changes in this version

type Option

+ func WithPriorityTiers(tiers []store.TierConfig) Option

Feb 24, 2026

Changes in this version

+ type Config struct

+ ClusterRegion string

+ ListenAddr string

+ LockAutoExtend time.Duration

+ LockTTL time.Duration

+ Logger gochainedlog.Logger

+ MaxConcurrency int

+ NodeID string

+ RedisOptions types.RedisOptions

+ ShutdownTimeout time.Duration

+ StoreConfig store.RedisStoreConfig

+ type Option func(*Config)

+ func WithClusterRegion(region string) Option

+ func WithKeyPrefix(prefix string) Option

+ func WithListenAddr(addr string) Option

+ func WithLockAutoExtend(d time.Duration) Option

+ func WithLockTTL(d time.Duration) Option

+ func WithLogger(l gochainedlog.Logger) Option

+ func WithMaxConcurrency(n int) Option

+ func WithNodeID(id string) Option

+ func WithRedisCluster(addrs []string) Option

+ func WithRedisDB(db int) Option

+ func WithRedisPassword(password string) Option

+ func WithRedisPoolSize(n int) Option

+ func WithRedisSentinel(masterName string, sentinelAddrs []string, sentinelPassword string) Option

+ func WithRedisURL(url string) Option

+ func WithShutdownTimeout(d time.Duration) Option

+ type Server struct

+ func New(opts ...Option) (*Server, error)

+ func (s *Server) Dispatcher() monitor.Dispatcher

+ func (s *Server) Middlewares() []types.MiddlewareFunc

+ func (s *Server) RedisClient() rueidis.Client

+ func (s *Server) RegisterHandler(def types.HandlerDefinition) error

+ func (s *Server) Start(ctx context.Context) error

+ func (s *Server) Stop() error

+ func (s *Server) Store() *store.RedisStore

+ func (s *Server) Use(mw ...types.MiddlewareFunc)

+ func (s *Server) Worker() *worker.Worker