interfaces

Documentation

Overview

Defines an event scheduler interface

Index

• type AddScheduleInput
• type EventScheduler
• type WorkflowExecutor

Types

type AddScheduleInput

type AddScheduleInput struct {
	// Defines the unique identifier associated with the schedule
	Identifier admin.NamedEntityIdentifier
	// Defines the schedule expression.
	ScheduleExpression admin.Schedule
	// Message payload encoded as an CloudWatch event rule InputTemplate.
	Payload *string
}

type EventScheduler

type EventScheduler interface {
	// Schedules an event.
	AddSchedule(ctx context.Context, input AddScheduleInput) error

	// Removes an existing schedule.
	RemoveSchedule(ctx context.Context, identifier admin.NamedEntityIdentifier) error
}

type WorkflowExecutor

type WorkflowExecutor interface {
	Run()
	Stop() error
}

Handles responding to scheduled workflow execution events and creating executions.