cores

Jul 19, 2024

Changes in this version

type ServiceOption

+ func WithService(name string) ServiceOption

+ func WithTag(tag string) ServiceOption

Jul 19, 2024

Changes in this version

type Options

+ ListenerAddr string

Jul 18, 2024

Changes in this version

+ func Run(srv *CoreService) error

+ func Start[T listenEntry](srv *CoreService, addr T) error

+ func StructName(i any) string

+ type CoreService struct

+ func NewPuzzleCore(opts ...ServiceOption) *CoreService

+ func (c *CoreService) GracefulStopPuzzle()

+ type Options struct

+ Cmux cmux.CMux

+ Ctx context.Context

+ ServiceName string

+ Tags []string

+ func (o *Options) RegisterPuzzle(p Puzzle)

+ type Puzzle interface

+ Name func() string

+ StartPuzzle func(*Options) error

+ Stop func() error

+ type ServiceOption func(*Options)

+ func WithCronWorker(cron string, fn WorkerFunc) ServiceOption

+ func WithDaemonWorker(fn WorkerFunc) ServiceOption

+ func WithNameWorker(name string, fn WorkerFunc) ServiceOption

+ func WithWorker(fn WorkerFunc) ServiceOption

+ type Worker interface

+ Fn func(ctx context.Context) error

+ Name func() string

+ type WorkerFunc func(ctx context.Context) error