google

Documentation

Index

• func New(runnercfg *cfg.RunnerConfig) (provider.Provider, error)
• func Usage() string
• type GoogleProvider
  • func (p *GoogleProvider) ConfigureRun(state *run.State) error
  • func (p *GoogleProvider) SetProtocol(proto *workerproto.Protocol)
  • func (p *GoogleProvider) UseCachedRun(run *run.State) error
  • func (p *GoogleProvider) WorkerFinished(state *run.State) error
  • func (p *GoogleProvider) WorkerStarted(state *run.State) error
• type MetadataService
• type UserData

Functions

func New

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

func Usage

func Usage() string

Types

type GoogleProvider

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

func (*GoogleProvider) ConfigureRun

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

func (*GoogleProvider) SetProtocol

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

func (*GoogleProvider) UseCachedRun

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

func (*GoogleProvider) WorkerFinished

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

func (*GoogleProvider) WorkerStarted

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

type MetadataService

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

type UserData

type UserData struct {
	WorkerPoolID string `json:"workerPoolId"`
	ProviderID   string `json:"providerId"`
	WorkerGroup  string `json:"workerGroup"`
	RootURL      string `json:"rootUrl"`

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

user-data sent to us from the worker-manager service