scheduler

Documentation

Index

• func NewMiddleware() (eh.CommandHandlerMiddleware, chan Error)
• type Command
  • func CommandWithExecuteTime(cmd eh.Command, t time.Time) Command
• type Error
  • func (e Error) Error() string

Functions

func NewMiddleware

func NewMiddleware() (eh.CommandHandlerMiddleware, chan Error)

NewMiddleware returns a new async handling middleware that returns any errors on a error channel.

Types

type Command

type Command interface {
	eh.Command

	// ExecuteAt returns the time when the command will execute.
	ExecuteAt() time.Time
}

Command is a scheduled command with an execution time.

func CommandWithExecuteTime

func CommandWithExecuteTime(cmd eh.Command, t time.Time) Command

CommandWithExecuteTime returns a wrapped command with a execution time set.

type Error

type Error struct {
	Err     error
	Ctx     context.Context
	Command eh.Command
}

Error is an async error containing the error and the command.

func (Error) Error

func (e Error) Error() string

Error implements the Error method of the error interface.