pipeline

Documentation

Index

• type Buffer
  • func (c *Buffer) Len() int64
  • func (c *Buffer) MergeReader() io.Reader
  • func (c *Buffer) ReadAll() *bytes.Buffer
• type GetterFunc
• type Pipeline
  • func NewPipeline(c PipelineConfig) Pipeline
  • func (p *Pipeline) Execute() (PipelineCtx, error)
• type PipelineConfig
• type PipelineCtx
• type SinkFunc
• type Sinker
  • func NewSinker(c SinkerConfig) Sinker
  • func (s *Sinker) Run(ctx PipelineCtx) (PipelineCtx, error)
• type SinkerConfig
• type Source
  • func NewSource(config SourceConfig) Source
  • func (s *Source) Run(ctx PipelineCtx) (PipelineCtx, error)
• type SourceConfig
• type Step

Types

type Buffer

type Buffer struct {
	Body []byte

	Reader io.Reader
	// contains filtered or unexported fields
}

func (*Buffer) Len

func (c *Buffer) Len() int64

func (*Buffer) MergeReader

func (c *Buffer) MergeReader() io.Reader

func (*Buffer) ReadAll

func (c *Buffer) ReadAll() *bytes.Buffer

type GetterFunc

type GetterFunc = func(actx PipelineCtx) (PipelineCtx, error)

type Pipeline

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

func NewPipeline

func NewPipeline(c PipelineConfig) Pipeline

func (*Pipeline) Execute

func (p *Pipeline) Execute() (PipelineCtx, error)

type PipelineConfig

type PipelineConfig struct {
	Source *Source
	Sinker *Sinker
	Steps  []Step
}

type PipelineCtx

type PipelineCtx struct {
	Path             media.Path
	Buffer           *Buffer
	ContentType      media.ContentType
	EmbeddedMetadata media.Metadata
	Tags             []media.Tag
}

type SinkFunc

type SinkFunc = func(PipelineCtx) error

type Sinker

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

func NewSinker

func NewSinker(c SinkerConfig) Sinker

func (*Sinker) Run

func (s *Sinker) Run(ctx PipelineCtx) (PipelineCtx, error)

type SinkerConfig

type SinkerConfig struct {
	Sinker SinkFunc
}

type Source

type Source struct {
	SourceConfig
}

func NewSource

func NewSource(config SourceConfig) Source

func (*Source) Run

func (s *Source) Run(ctx PipelineCtx) (PipelineCtx, error)

type SourceConfig

type SourceConfig struct {
	Getter GetterFunc
}

type Step

type Step interface {
	Run(ctx PipelineCtx) (PipelineCtx, error)
}