Versions in this module Expand all Collapse all v0 v0.2.0 Apr 28, 2022 Changes in this version + var DefaultInstanceParams = &ec2.RunInstancesInput + func NewWorkerFactory(logger *zap.Logger, client WorkerEC2Client, input *ec2.RunInstancesInput, ...) compute.WorkerFactory + type Worker struct + func (w *Worker) Close() error + func (w *Worker) Connect(ctx context.Context) (err error) + func (w *Worker) Equals(other compute.Worker) bool + func (w *Worker) IsReady(ctx context.Context, opts ...compute.ReadyOptionsFunc) (bool, error) + func (w *Worker) IsReadyChan(ctx context.Context, opts ...compute.ReadyOptionsFunc) <-chan error + func (w *Worker) Job() proto.JobServiceClient + func (w *Worker) Worker() proto.WorkerServiceClient + type WorkerEC2Client interface + DescribeInstanceStatus func(ctx context.Context, params *ec2.DescribeInstanceStatusInput, ...) (*ec2.DescribeInstanceStatusOutput, error) + DescribeInstances func(ctx context.Context, params *ec2.DescribeInstancesInput, ...) (*ec2.DescribeInstancesOutput, error) + RunInstances func(ctx context.Context, params *ec2.RunInstancesInput, ...) (*ec2.RunInstancesOutput, error) + TerminateInstances func(ctx context.Context, params *ec2.TerminateInstancesInput, ...) (*ec2.TerminateInstancesOutput, error) + type WorkerFactory struct + func (f *WorkerFactory) Create(ctx context.Context) (compute.Worker, error)