Documentation ¶
Index ¶
- Variables
- type BaseFilter
- type FC
- func (f *FC) AddFilter(filter Filter, names ...string) error
- func (f *FC) AddInputFilter(filter InputFilter, names ...string) error
- func (f *FC) AddOutputFilter(filter OutputFilter, names ...string) error
- func (f *FC) GetInputFilter(name string) (filter InputFilter, err error)
- func (f *FC) NewPipeline() *Pipeline
- type Filter
- type FilterHCL
- type FilterJSON
- type FilterNULL
- type FilterTPL
- type FilterVarFiles
- type FilterYAML
- type InputFilter
- type OutputFilter
- type Pipeline
- type S3Downloader
- type TplImport
- Bugs
Constants ¶
This section is empty.
Variables ¶
View Source
var DefaultFC = NewFC()
Functions ¶
This section is empty.
Types ¶
type BaseFilter ¶
type BaseFilter interface { Description() string // contains filtered or unexported methods }
type FC ¶
type FC struct { InputFilters map[string]InputFilter Filters map[string]Filter OutputFilters map[string]OutputFilter }
func (*FC) AddInputFilter ¶
func (f *FC) AddInputFilter(filter InputFilter, names ...string) error
func (*FC) AddOutputFilter ¶
func (f *FC) AddOutputFilter(filter OutputFilter, names ...string) error
func (*FC) GetInputFilter ¶
func (f *FC) GetInputFilter(name string) (filter InputFilter, err error)
func (*FC) NewPipeline ¶
type Filter ¶
type Filter interface { BaseFilter Filter(input interface{}, args ...string) (interface{}, error) }
type FilterHCL ¶
type FilterHCL struct {
// contains filtered or unexported fields
}
func (FilterHCL) Description ¶
type FilterJSON ¶
type FilterJSON struct {
// contains filtered or unexported fields
}
func (FilterJSON) Description ¶
func (FilterJSON) Description() string
type FilterNULL ¶ added in v1.0.9
type FilterNULL struct {
// contains filtered or unexported fields
}
func (FilterNULL) Description ¶ added in v1.0.9
func (FilterNULL) Description() string
type FilterTPL ¶
type FilterTPL struct {
// contains filtered or unexported fields
}
func NewFilterTPL ¶ added in v1.0.4
func NewFilterTPL() (r *FilterTPL)
func (FilterTPL) Description ¶
type FilterVarFiles ¶
type FilterVarFiles struct {
// contains filtered or unexported fields
}
func (FilterVarFiles) Description ¶
func (FilterVarFiles) Description() string
func (FilterVarFiles) Filter ¶
func (f FilterVarFiles) Filter(input interface{}, args ...string) (interface{}, error)
type FilterYAML ¶
type FilterYAML struct {
// contains filtered or unexported fields
}
func (FilterYAML) Description ¶
func (FilterYAML) Description() string
type InputFilter ¶
type InputFilter interface { BaseFilter Input(input io.Reader, output interface{}, args ...string) error }
type OutputFilter ¶
type OutputFilter interface { BaseFilter Output(output io.Writer, input interface{}, args ...string) error }
type Pipeline ¶
type Pipeline struct {
// contains filtered or unexported fields
}
func (*Pipeline) SetInputFilter ¶
type S3Downloader ¶ added in v1.0.8
type S3Downloader struct {
// contains filtered or unexported fields
}
S3Downloader ...
func NewS3Downloader ¶ added in v1.0.8
func NewS3Downloader() (*S3Downloader, error)
NewS3Downloader creates new S3Downloader
func (*S3Downloader) DownloadFileVersion ¶ added in v1.0.8
func (s *S3Downloader) DownloadFileVersion(bucket, key, version string) (*s3.GetObjectOutput, error)
DownloadFileVersion downloads single file with specific version
func (*S3Downloader) DownloadFilesByPattern ¶ added in v1.0.8
func (s *S3Downloader) DownloadFilesByPattern(bucket, pattern string) (map[string]*s3.GetObjectOutput, error)
DownloadFilesByPattern downloads files matching to pattern from bucket. It uses 16 goroutines for parallel downloads.
Notes ¶
Bugs ¶
Source Files ¶
Click to show internal directories.
Click to hide internal directories.