core

type CacheManager interface {
	PersistenceManager
}

type DispatchFunc func(Event) error

type DispatchManagerConfig struct {
	WorkerNumber         int
	DefaultQueueCapacity int
	MaxQueueCapacity     int
}

type Event struct {
	ID ID

	// CronExpression allows us to schedule the event based on the cron expression
	CronExpression string

	// ShouldExecuteAt is the timestamp at which the event must be scheduled
	ShouldExecuteAt time.Time

	// Mode is the mode in which the event should be scheduled (CronMode or TimestampMode)
	Mode EventMode

	// Topic is the channel on which the event has to be dispatched
	Topic string

	// Payload is the content of the event
	Payload []byte
}

type EventMode uint

type ID string

type PersistenceManager interface {
	Add(ctx context.Context, e Event) error
	AddBulk(ctx context.Context, evs []Event) error
	Delete(ctx context.Context, id ID) error
	Get(ctx context.Context, id ID) (Event, error)
	GetAll(ctx context.Context) ([]Event, error)
}

type RedisCacheManagerConfig struct {
	Addr string
	Pass string
	DB   int
}

type Scheduler interface {
	Schedule(e Event) (ID, error)
	Unschedule(id ID) error

	Start() error
	Stop()
	SetConfig(conf SchedulerConfig) error
	// contains filtered or unexported methods
}

type SchedulerConfig struct {
	StackManagerConfig
	DispatchManagerConfig
	DefaultInputQueueCapacity int
	MaxInputQueueCapacity     int
	MaxBulkLimit              int
}

type SqlPersistenceManagerConfig struct {
	Url    string
	Driver string
}

type StackManagerConfig struct {
	StacksNumber         int
	DefaultStackCapacity int
	MaxStackCapacity     int
}