Documentation ¶
Index ¶
- Variables
- func NewWorkerFactory(logger *zap.Logger, client WorkerEC2Client, input *ec2.RunInstancesInput, ...) compute.WorkerFactory
- type Worker
- 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
- type WorkerFactory
Constants ¶
This section is empty.
Variables ¶
View Source
var DefaultInstanceParams = &ec2.RunInstancesInput{ MinCount: aws.Int32(1), MaxCount: aws.Int32(1), IamInstanceProfile: nil, ImageId: aws.String("ami-0892d3c7ee96c0bf7"), InstanceMarketOptions: &types.InstanceMarketOptionsRequest{ MarketType: types.MarketTypeSpot, SpotOptions: nil, }, InstanceType: "g4dn.xlarge", KeyName: aws.String("us-west-ec2-keys"), SecurityGroupIds: []string{"sg-09b52430796d9b9c5"}, UserData: aws.String(base64.StdEncoding.EncodeToString(userData)), }
Functions ¶
func NewWorkerFactory ¶
func NewWorkerFactory(logger *zap.Logger, client WorkerEC2Client, input *ec2.RunInstancesInput, port uint16) compute.WorkerFactory
Types ¶
type Worker ¶
type Worker struct {
// contains filtered or unexported fields
}
func (*Worker) IsReadyChan ¶
func (*Worker) Job ¶
func (w *Worker) Job() proto.JobServiceClient
func (*Worker) Worker ¶
func (w *Worker) Worker() proto.WorkerServiceClient
type WorkerEC2Client ¶
type WorkerEC2Client interface { RunInstances(ctx context.Context, params *ec2.RunInstancesInput, optFns ...func(*ec2.Options)) (*ec2.RunInstancesOutput, error) DescribeInstances(ctx context.Context, params *ec2.DescribeInstancesInput, optFns ...func(*ec2.Options)) (*ec2.DescribeInstancesOutput, error) DescribeInstanceStatus(ctx context.Context, params *ec2.DescribeInstanceStatusInput, optFns ...func(*ec2.Options)) (*ec2.DescribeInstanceStatusOutput, error) TerminateInstances(ctx context.Context, params *ec2.TerminateInstancesInput, optFns ...func(*ec2.Options)) (*ec2.TerminateInstancesOutput, error) }
type WorkerFactory ¶
type WorkerFactory struct {
// contains filtered or unexported fields
}
Click to show internal directories.
Click to hide internal directories.