Versions in this module Expand all Collapse all v0 v0.29.0 Feb 5, 2021 v0.28.0 Feb 4, 2021 Changes in this version + type ComposableDataStream struct + Name string + func NewClosedComposableDataStreamFromBuffer(buffer *bytes.Buffer) *ComposableDataStream + func NewComposableDataStream(name string, errorHandler func(error)) *ComposableDataStream + func (stream *ComposableDataStream) Bytes() []byte + func (stream *ComposableDataStream) Close() + func (stream *ComposableDataStream) Closed() bool + func (stream *ComposableDataStream) Completed() bool + func (stream *ComposableDataStream) Copy() io.Reader + func (stream *ComposableDataStream) CopyOrResult() io.Reader + func (stream *ComposableDataStream) Intercept() io.ReadWriteCloser + func (stream *ComposableDataStream) Len() int + func (stream *ComposableDataStream) MergeWith(newReader io.Reader) + func (stream *ComposableDataStream) Replace(reader io.Reader) + func (stream *ComposableDataStream) StartCopyingInto(writer io.Writer) + func (stream *ComposableDataStream) String() string + func (stream *ComposableDataStream) Wait() + func (stream *ComposableDataStream) WriteCloser() io.WriteCloser + type ComposableDataStreamIntercept struct + func NewComposableDataStreamIntercept(reader io.Reader, writer io.WriteCloser, errorHandler func(error)) *ComposableDataStreamIntercept + func (intercept *ComposableDataStreamIntercept) Close() error + func (intercept *ComposableDataStreamIntercept) Read(p []byte) (int, error) + func (intercept *ComposableDataStreamIntercept) Write(p []byte) (int, error) + type DefaultSettings struct + Command string + Dir string + type HookDefinitions = map[string][]string + type PipelineDefinition struct + BuiltIn bool + DefinitionArguments map[string]interface{} + FileName string + Public bool + func NewPipelineDefinition(arguments map[string]interface{}, pipelineFile PipelineFile, isPublic bool, ...) *PipelineDefinition + type PipelineDefinitionsLookup = map[string][]PipelineDefinition + func MergePipelineDefinitions(definition1 PipelineDefinitionsLookup, definition2 PipelineDefinitionsLookup) PipelineDefinitionsLookup + type PipelineFile struct + Default DefaultSettings + FileName string + Hooks HookDefinitions + Import []string + Private map[string]map[string]interface{} + Public map[string]map[string]interface{} + type PipelineFileImportSkeleton struct + Import []string + type PipelineRun struct + Definition *PipelineDefinition + ExitCode *int + Identifier *string + InvocationArguments map[string]interface{} + Log *PipelineRunLogger + LogClosingWaitGroup *sync.WaitGroup + Parent *PipelineRun + StartWaitGroup *sync.WaitGroup + Stderr *ComposableDataStream + Stdin *ComposableDataStream + Stdout *ComposableDataStream + Synchronous bool + func NewPipelineRun(identifier *string, invocationArguments map[string]interface{}, ...) (*PipelineRun, error) + func (run *PipelineRun) AddCancelHook(cancelHook func() error) + func (run *PipelineRun) ArgumentAtPath(path ...string) (interface{}, error) + func (run *PipelineRun) ArgumentAtPathIncludingParents(path ...string) (interface{}, error) + func (run *PipelineRun) ArgumentsCopy() map[string]interface{} + func (run *PipelineRun) Cancel() error + func (run *PipelineRun) Cancelled() bool + func (run *PipelineRun) Close() + func (run *PipelineRun) Completed() bool + func (run *PipelineRun) SetArgumentAtPath(value interface{}, path ...string) error + func (run *PipelineRun) SetArguments(value map[string]interface{}) + func (run *PipelineRun) String() string + func (run *PipelineRun) Wait() + type PipelineRunLogger struct + ErrorCallback func(error) + Indentation int + func NewClosedPipelineRunLoggerWithErrors(errors *multierror.Error) *PipelineRunLogger + func NewClosedPipelineRunLoggerWithResult(buffer *bytes.Buffer) *PipelineRunLogger + func NewPipelineRunLogger(run *PipelineRun, indentation int) *PipelineRunLogger + func (logger *PipelineRunLogger) AddReaderEntry(reader io.Reader) + func (logger *PipelineRunLogger) AddWriteCloserEntry() io.WriteCloser + func (logger *PipelineRunLogger) AllErrorMessages() []string + func (logger *PipelineRunLogger) Bytes() []byte + func (logger *PipelineRunLogger) Close() + func (logger *PipelineRunLogger) Closed() bool + func (logger *PipelineRunLogger) Completed() bool + func (logger *PipelineRunLogger) Debug(entry *logrus.Entry) + func (logger *PipelineRunLogger) DebugCount() int + func (logger *PipelineRunLogger) DebugWithFields(fields ...log_fields.LogEntryField) + func (logger *PipelineRunLogger) Error(err error, fields ...log_fields.LogEntryField) + func (logger *PipelineRunLogger) ErrorCount() int + func (logger *PipelineRunLogger) Info(entry *logrus.Entry) + func (logger *PipelineRunLogger) InfoCount() int + func (logger *PipelineRunLogger) InfoWithFields(fields ...log_fields.LogEntryField) + func (logger *PipelineRunLogger) LastError() error + func (logger *PipelineRunLogger) Level() logrus.Level + func (logger *PipelineRunLogger) PossibleError(err error) + func (logger *PipelineRunLogger) PossibleErrorWithExplanation(err error, explanation string) + func (logger *PipelineRunLogger) Reader() io.Reader + func (logger *PipelineRunLogger) SetLevel(level logrus.Level) + func (logger *PipelineRunLogger) StderrOutput(message string, fields ...log_fields.LogEntryField) + func (logger *PipelineRunLogger) String() string + func (logger *PipelineRunLogger) Summary() string + func (logger *PipelineRunLogger) Trace(entry *logrus.Entry) + func (logger *PipelineRunLogger) TraceCount() int + func (logger *PipelineRunLogger) TraceWithFields(fields ...log_fields.LogEntryField) + func (logger *PipelineRunLogger) Wait() + func (logger *PipelineRunLogger) Warn(entry *logrus.Entry) + func (logger *PipelineRunLogger) WarnCount() int + func (logger *PipelineRunLogger) WarnWithFields(fields ...log_fields.LogEntryField)
Go to main page