cores

README

cores

Documentation

Index

• func Run(srv *CoreService) error
• func Start[T listenEntry](srv *CoreService, addr T) error
• func StructName(i any) string
• type CoreService
  • func NewPuzzleCore(opts ...ServiceOption) *CoreService
  • func (c *CoreService) GracefulStopPuzzle()
• type Options
  • func (o *Options) RegisterPuzzle(p Puzzle)
• type Puzzle
• type ServiceOption
  • 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
• type WorkerFunc

Functions

func Run

func Run(srv *CoreService) error

func Start

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

func StructName

func StructName(i any) string

Types

type CoreService

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

func NewPuzzleCore

func NewPuzzleCore(opts ...ServiceOption) *CoreService

func (*CoreService) GracefulStopPuzzle

func (c *CoreService) GracefulStopPuzzle()

type Options

type Options struct {
	Ctx         context.Context
	ServiceName string
	Tags        []string
	Cmux        cmux.CMux
	// contains filtered or unexported fields
}

func (*Options) RegisterPuzzle

func (o *Options) RegisterPuzzle(p Puzzle)

RegisterPuzzle will put Puzzle into cores service It replaces the previously registered Puzzle with the same name

type Puzzle

type Puzzle interface {
	Name() string
	StartPuzzle(context.Context, *Options) error
	Stop() error
}

type ServiceOption

type ServiceOption func(*Options)

func WithCronWorker

func WithCronWorker(cron string, fn WorkerFunc) ServiceOption

func WithDaemonWorker

func WithDaemonWorker(fn WorkerFunc) ServiceOption

func WithNameWorker

func WithNameWorker(name string, fn WorkerFunc) ServiceOption

func WithWorker

func WithWorker(fn WorkerFunc) ServiceOption

type Worker

type Worker interface {
	Name() string
	Fn(ctx context.Context) error
}

type WorkerFunc

type WorkerFunc func(ctx context.Context) error