scheduler

Documentation

Index

• type Command
  • func CommandWithExecuteTime(cmd eh.Command, t time.Time) Command
• type CommandHandler
  • func NewCommandHandler(handler eh.CommandHandler) *CommandHandler
  • func (b *CommandHandler) Error() <-chan error
  • func (b *CommandHandler) HandleCommand(ctx context.Context, cmd eh.Command) error

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 CommandHandler

type CommandHandler struct {
	eh.CommandHandler
	// contains filtered or unexported fields
}

CommandHandler handles commands either directly or with a delay on a schedule.

func NewCommandHandler

func NewCommandHandler(handler eh.CommandHandler) *CommandHandler

NewCommandHandler creates a CommandHandler.

func (*CommandHandler) Error

func (b *CommandHandler) Error() <-chan error

Error returns the error channel.

func (*CommandHandler) HandleCommand

func (b *CommandHandler) HandleCommand(ctx context.Context, cmd eh.Command) error

HandleCommand implements the HandleCommand method of the eventhorizon.CommandHandler interface.