runtime

Mar 6, 2018

Changes in this version

type Environment

+ ProvisionerID string

+ WorkerType string

type TemporaryFile

+ Truncate func(size int64) error

Oct 9, 2017

Changes in this version

type Environment

+ WorkerGroup string

+ WorkerID string

type TaskInfo

+ Task interface{}

Jun 23, 2017

Changes in this version

type TaskContext

+ func (c *TaskContext) Authorizer() client.Authorizer

+ func (c *TaskContext) HasScopes(scopeSets ...[]string) bool

type TaskContextController

+ func (c *TaskContextController) SetCredentials(clientID, accessToken, certificate string)

type TaskInfo

+ Scopes []string

May 5, 2017

Changes in this version

type MalformedPayloadError

+ func (e MalformedPayloadError) Messages() []string

Apr 22, 2017

Changes in this version

+ func RenderDocument(title string, sections []Section) string

type Environment

+ Worker Stoppable

type ExceptionReason

+ const ReasonCanceled

+ const ReasonIntermittentTask

+ const ReasonInternalError

+ const ReasonMalformedPayload

+ const ReasonNoException

+ const ReasonResourceUnavailable

+ const ReasonSuperseded

+ const ReasonWorkerShutdown

+ func (e ExceptionReason) String() string

+ type LifeCycleTracker struct

+ StoppingGracefully atomics.Once

+ StoppingNow atomics.Once

+ func (s *LifeCycleTracker) StopGracefully()

+ func (s *LifeCycleTracker) StopNow()

+ type Section struct

+ Content string

+ Title string

+ type Stoppable interface

+ StopGracefully func()

+ StopNow func()

+ type StoppableOnce struct

+ Stoppable Stoppable

+ func (s *StoppableOnce) StopGracefully()

+ func (s *StoppableOnce) StopNow()

type TemporaryFolder

+ func NewTemporaryTestFolderOrPanic() TemporaryFolder

Mar 23, 2017

Changes in this version

+ var ErrFatalInternalError = errors.New("Encountered a fatal internal error")

+ var ErrNonFatalInternalError = errors.New("Encountered a non-fatal internal error")

+ type MalformedPayloadError struct

+ func IsMalformedPayloadError(err error) (e MalformedPayloadError, ok bool)

+ func MergeMalformedPayload(errors ...MalformedPayloadError) MalformedPayloadError

+ func NewMalformedPayloadError(a ...interface{}) MalformedPayloadError

+ func (e MalformedPayloadError) Error() string

+ type Monitor interface

+ CapturePanic func(fn func()) (incidentID string)

+ Count func(name string, value float64)

+ Debug func(...interface{})

+ Debugf func(string, ...interface{})

+ Debugln func(...interface{})

+ Error func(...interface{})

+ Errorf func(string, ...interface{})

+ Errorln func(...interface{})

+ Info func(...interface{})

+ Infof func(string, ...interface{})

+ Infoln func(...interface{})

+ Measure func(name string, value ...float64)

+ Panic func(...interface{})

+ Panicf func(string, ...interface{})

+ Panicln func(...interface{})

+ Print func(...interface{})

+ Printf func(string, ...interface{})

+ Println func(...interface{})

+ ReportError func(err error, message ...interface{}) string

+ ReportWarning func(err error, message ...interface{}) string

+ Time func(name string, fn func())

+ Warn func(...interface{})

+ Warnf func(string, ...interface{})

+ Warnln func(...interface{})

+ WithPrefix func(prefix string) Monitor

+ WithTag func(key, value string) Monitor

+ WithTags func(tags map[string]string) Monitor

+ func NewLoggingMonitor(logLevel string, tags map[string]string) Monitor

+ func NewMonitor(project string, auth client.Auth, logLevel string, tags map[string]string) Monitor

type TaskContext

+ func (context *TaskContext) CreateErrorArtifact(artifact ErrorArtifact) error

+ func (context *TaskContext) CreateRedirectArtifact(artifact RedirectArtifact) error

+ func (context *TaskContext) UploadS3Artifact(artifact S3Artifact) error

Jan 23, 2017

Changes in this version

+ func Gunzip(filename string) (string, error)

+ func Untar(filename string) error

+ func Unzip(filename string) error

Oct 28, 2016

Changes in this version

type TaskContext

+ func (c *TaskContext) Deadline() (deadline time.Time, ok bool)

+ func (c *TaskContext) Done() <-chan struct{}

+ func (c *TaskContext) Err() error

+ func (c *TaskContext) Value(key interface{}) interface{}

Oct 13, 2016

Changes in this version

+ var ErrLogClosed = errors.New("Log already closed")

+ var ErrLogNotClosed = errors.New("Log is still open")

+ func CreateErrorArtifact(artifact ErrorArtifact, context *TaskContext) error

+ func CreateLogger(level string) (*logrus.Logger, error)

+ func CreateRedirectArtifact(artifact RedirectArtifact, context *TaskContext) error

+ func Debug(name string) func(string, ...interface{})

+ func UploadS3Artifact(artifact S3Artifact, context *TaskContext) error

type Environment

+ Log *logrus.Logger

+ Sentry *raven.Client

+ TemporaryStorage TemporaryStorage

+ WebHookServer webhookserver.WebHookServer

+ type ErrorArtifact struct

+ Expires tcclient.Time

+ Message string

+ Name string

+ Reason string

+ type ExceptionReason string

+ const InternalError

+ const MalformedPayload

+ const WorkerShutdown

+ type RedirectArtifact struct

+ Expires tcclient.Time

+ Mimetype string

+ Name string

+ URL string

+ type S3Artifact struct

+ AdditionalHeaders map[string]string

+ Expires tcclient.Time

+ Mimetype string

+ Name string

+ Stream ioext.ReadSeekCloser

+ type ShutdownManager interface

+ WaitForShutdown func() <-chan struct{}

+ func NewShutdownManager(host string) ShutdownManager

type TaskContext

+ func (c *TaskContext) Abort()

+ func (c *TaskContext) AttachWebHook(handler http.Handler) string

+ func (c *TaskContext) Cancel()

+ func (c *TaskContext) ExtractLog() (ioext.ReadSeekCloser, error)

+ func (c *TaskContext) IsAborted() bool

+ func (c *TaskContext) IsCancelled() bool

+ func (c *TaskContext) LogError(a ...interface{})

+ func (c *TaskContext) Queue() client.Queue

type TaskContextController

+ func (c *TaskContextController) SetQueueClient(client client.Queue)

type TaskInfo

+ Created tcclient.Time

+ Deadline tcclient.Time

+ Expires tcclient.Time

+ RunID int

+ TaskID string

+ type TaskStatus string

+ const Aborted

+ const Cancelled

+ const Claimed

+ const Errored

+ const Failed

+ const Reclaimed

+ const Succeeded

+ type TemporaryFile interface

+ Path func() string

+ type TemporaryFolder interface

+ Path func() string

+ Remove func() error

+ type TemporaryStorage interface

+ NewFile func() (TemporaryFile, error)

+ NewFilePath func() string

+ NewFolder func() (TemporaryFolder, error)

+ func NewTemporaryStorage(path string) (TemporaryStorage, error)

Jan 26, 2016

Changes in this version

+ var ErrConflictingSchemas = errors.New("Two schema entries are conflicting!")

+ func NewTaskContext(tempLogFile string) (*TaskContext, *TaskContextController, error)

+ type CompositeSchema interface

+ Parse func(data map[string]json.RawMessage) (interface{}, error)

+ func MergeCompositeSchemas(schemas ...CompositeSchema) (CompositeSchema, error)

+ func NewCompositeSchema(property string, schema string, required bool, makeTarget func() interface{}) (CompositeSchema, error)

+ func NewEmptyCompositeSchema() CompositeSchema

+ type Environment struct

+ GarbageCollector *gc.GarbageCollector

+ type TaskContext struct

+ func (c *TaskContext) Log(a ...interface{})

+ func (c *TaskContext) LogDrain() io.Writer

+ func (c *TaskContext) NewLogReader() (io.ReadCloser, error)

+ type TaskContextController struct

+ func (c *TaskContextController) CloseLog() error

+ func (c *TaskContextController) Dispose() error

+ type TaskInfo struct