batcher

type BatchExecutor ¶

type BatchExecutor[T input, U output] func(ctx context.Context, input []*T) []Result[U]

BatchExecutor is a function that executes a slice of inputs against the batched API. inputs will be mutated The returned Result slice is expected to match the len of the input slice and be in the same order, if order matters for the batched API

type Batcher ¶

type Batcher[T input, U output] struct {
	// contains filtered or unexported fields
}

Batcher is used to batch API calls with identical parameters into a single call

func NewBatcher[T input, U output](ctx context.Context, options Options[T, U]) *Batcher[T, U]

func (b *Batcher[T, U]) Add(ctx context.Context, input *T) Result[U]

type CreateFleetBatcher ¶

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

func NewCreateFleetBatcher(ctx context.Context, ec2api ec2iface.EC2API) *CreateFleetBatcher

func (b *CreateFleetBatcher) CreateFleet(ctx context.Context, createFleetInput *ec2.CreateFleetInput) (*ec2.CreateFleetOutput, error)

type DescribeInstancesBatcher ¶

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

func NewDescribeInstancesBatcher(ctx context.Context, ec2api ec2iface.EC2API) *DescribeInstancesBatcher

func (b *DescribeInstancesBatcher) DescribeInstances(ctx context.Context, describeInstancesInput *ec2.DescribeInstancesInput) (*ec2.DescribeInstancesOutput, error)

type EC2API ¶

type EC2API struct {
	*CreateFleetBatcher
	*DescribeInstancesBatcher
	*TerminateInstancesBatcher
}

func EC2(ctx context.Context, ec2api ec2iface.EC2API) *EC2API

type Options ¶

type Options[T input, U output] struct {
	Name              string
	IdleTimeout       time.Duration
	MaxTimeout        time.Duration
	MaxItems          int
	MaxRequestWorkers int
	RequestHasher     RequestHasher[T]
	BatchExecutor     BatchExecutor[T, U]
}

Options allows for configuration of the Batcher

type RequestHasher ¶

type RequestHasher[T input] func(ctx context.Context, input *T) uint64

RequestHasher is a function that hashes input to bucket inputs into distinct batches

type Result ¶

type Result[U output] struct {
	Output *U
	Err    error
}

Result is a container for the output and error of an execution

type TerminateInstancesBatcher ¶

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

func NewTerminateInstancesBatcher(ctx context.Context, ec2api ec2iface.EC2API) *TerminateInstancesBatcher

func (b *TerminateInstancesBatcher) TerminateInstances(ctx context.Context, terminateInstancesInput *ec2.TerminateInstancesInput) (*ec2.TerminateInstancesOutput, error)