executor

Documentation

Index

• type Executor
  • func NewExecutor(client s3client.Client, logger logger.Logger, concurrency int) *Executor
  • func (e *Executor) Execute(ctx context.Context, items []planner.Item) []Result
• type Result

Types

type Executor

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

func NewExecutor

func NewExecutor(client s3client.Client, logger logger.Logger, concurrency int) *Executor

func (*Executor) Execute

func (e *Executor) Execute(ctx context.Context, items []planner.Item) []Result

type Result

type Result struct {
	Item  planner.Item
	Error error
}