aws

Documentation

Index

• Constants
• Variables
• func New(runnercfg *cfg.RunnerConfig) (provider.Provider, error)
• func Usage() string
• type AWSProvider
  • func (p *AWSProvider) ConfigureRun(state *run.State) error
  • func (p *AWSProvider) GetWorkerIdentityProof() (map[string]interface{}, error)
  • func (p *AWSProvider) SetProtocol(proto *workerproto.Protocol)
  • func (p *AWSProvider) UseCachedRun(run *run.State) error
  • func (p *AWSProvider) WorkerFinished(state *run.State) error
  • func (p *AWSProvider) WorkerStarted(state *run.State) error
• type InstanceIdentityDocument
• type MetadataService
• type UserData

Constants

const TERMINATION_PATH = "/meta-data/spot/termination-time"

Variables

var EC2MetadataBaseURL = "http://169.254.169.254/latest"

Functions

func New

func New(runnercfg *cfg.RunnerConfig) (provider.Provider, error)

func Usage

func Usage() string

Types

type AWSProvider

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

func (*AWSProvider) ConfigureRun

func (p *AWSProvider) ConfigureRun(state *run.State) error

func (*AWSProvider) GetWorkerIdentityProof

func (p *AWSProvider) GetWorkerIdentityProof() (map[string]interface{}, error)

func (*AWSProvider) SetProtocol

func (p *AWSProvider) SetProtocol(proto *workerproto.Protocol)

func (*AWSProvider) UseCachedRun

func (p *AWSProvider) UseCachedRun(run *run.State) error

func (*AWSProvider) WorkerFinished

func (p *AWSProvider) WorkerFinished(state *run.State) error

func (*AWSProvider) WorkerStarted

func (p *AWSProvider) WorkerStarted(state *run.State) error

type InstanceIdentityDocument

type InstanceIdentityDocument struct {
	InstanceId       string `json:"instanceId"`
	ImageId          string `json:"imageId"`
	InstanceType     string `json:"instanceType"`
	Region           string `json:"region"`
	AvailabilityZone string `json:"availabilityZone"`
	PrivateIp        string `json:"privateIp"`
}

type MetadataService

type MetadataService interface {
	// contains filtered or unexported methods
}

type UserData

type UserData struct {
	WorkerPoolId string `json:"workerPoolId"`
	ProviderId   string `json:"providerId"`
	RootURL      string `json:"rootUrl"`
	WorkerGroup  string `json:"workerGroup"`

	// NOTE: this is ignored, in preference to the configuration
	// returned from registerWorker
	ProviderWorkerConfig *json.RawMessage `json:"workerConfig"`
}