task

Documentation

Index

• func RenderTextTemplate(req *RenderRequest, out io.Writer) error
• type FileProvider
• type ParallelScheduler
  • func NewParallelScheduler() *ParallelScheduler
  • func (pe *ParallelScheduler) AddTask(task Task) *ParallelScheduler
  • func (pe *ParallelScheduler) Run() error
• type ReadFromProviderTask
  • func NewReadFromProviderTask(provider FileProvider, out io.Writer) *ReadFromProviderTask
  • func (t *ReadFromProviderTask) Run() error
• type RenderRequest
• type SequentialScheduler
  • func NewSequentialScheduler() *SequentialScheduler
  • func (se *SequentialScheduler) AddTask(task Task) *SequentialScheduler
  • func (se *SequentialScheduler) Run() error
• type ShellCommandTask
  • func (t *ShellCommandTask) Run() error
  • func (t *ShellCommandTask) String() string
• type Task
• type TemplateRenderTask
  • func NewTemplateRenderTask(name string, data interface{}, in io.Reader, out io.Writer) *TemplateRenderTask
  • func (trt *TemplateRenderTask) Run() error
• type WriteFileToDiskTask
  • func NewWriteFileToDiskTask(name string, suffix string, folder string, overwrite bool, in io.Reader) *WriteFileToDiskTask
  • func (wft *WriteFileToDiskTask) Run() error

Functions

func RenderTextTemplate

func RenderTextTemplate(req *RenderRequest, out io.Writer) error

Types

type FileProvider

type FileProvider interface {
	Get() (io.Reader, error)
}

type ParallelScheduler

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

func NewParallelScheduler

func NewParallelScheduler() *ParallelScheduler

func (*ParallelScheduler) AddTask

func (pe *ParallelScheduler) AddTask(task Task) *ParallelScheduler

func (*ParallelScheduler) Run

func (pe *ParallelScheduler) Run() error

type ReadFromProviderTask

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

func NewReadFromProviderTask

func NewReadFromProviderTask(provider FileProvider, out io.Writer) *ReadFromProviderTask

func (*ReadFromProviderTask) Run

func (t *ReadFromProviderTask) Run() error

type RenderRequest

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

type SequentialScheduler

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

func NewSequentialScheduler

func NewSequentialScheduler() *SequentialScheduler

func (*SequentialScheduler) AddTask

func (se *SequentialScheduler) AddTask(task Task) *SequentialScheduler

func (*SequentialScheduler) Run

func (se *SequentialScheduler) Run() error

type ShellCommandTask

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

func (*ShellCommandTask) Run

func (t *ShellCommandTask) Run() error

func (*ShellCommandTask) String

func (t *ShellCommandTask) String() string

type Task

type Task interface {
	Run() error
}

type TemplateRenderTask

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

func NewTemplateRenderTask

func NewTemplateRenderTask(name string, data interface{}, in io.Reader, out io.Writer) *TemplateRenderTask

func (*TemplateRenderTask) Run

func (trt *TemplateRenderTask) Run() error

type WriteFileToDiskTask

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

func NewWriteFileToDiskTask

func NewWriteFileToDiskTask(name string, suffix string, folder string, overwrite bool, in io.Reader) *WriteFileToDiskTask

func (*WriteFileToDiskTask) Run

func (wft *WriteFileToDiskTask) Run() error