Documentation ¶
Index ¶
- func LoadConfigFromViper(c interface{}, v *viper.Viper)
- type AWS
- type Dfl
- type Input
- func (i Input) CanStream() bool
- func (i Input) HasCompression() bool
- func (i Input) HasFormat() bool
- func (i *Input) Init()
- func (i Input) IsAthenaStoredQuery() bool
- func (i Input) IsEncrypted() bool
- func (i Input) IsS3Bucket() bool
- func (i Input) Map() map[string]interface{}
- func (i Input) Options() gss.Options
- func (i Input) Path() string
- type Output
- func (o Output) CanStream() bool
- func (o Output) HasCompression() bool
- func (o Output) HasFormat() bool
- func (o *Output) Init()
- func (o Output) IsAthenaStoredQuery() bool
- func (o Output) IsEncrypted() bool
- func (o Output) IsS3Bucket() bool
- func (o Output) Map() map[string]interface{}
- func (o Output) Options() gss.Options
- func (o Output) Path() string
- type Process
- func (p *Process) AWSSessionOptions() session.Options
- func (p *Process) HasAWSResource() bool
- func (p *Process) HasAthenaStoredQuery() bool
- func (p *Process) HasS3Bucket() bool
- func (p *Process) InputOptions() gss.Options
- func (p *Process) Map() map[string]interface{}
- func (p *Process) OutputOptions() gss.Options
- type Temp
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func LoadConfigFromViper ¶
Types ¶
type AWS ¶
type AWS struct { DefaultRegion string `viper:"aws-default-region"` AccessKeyId string `viper:"aws-access-key-id"` SecretAccessKey string `viper:"aws-secret-access-key"` SessionToken string `viper:"aws-session-token"` }
func (AWS) SessionOptions ¶
type Dfl ¶
type Input ¶
type Input struct { Uri string `viper:"input-uri"` Format string `viper:"input-format"` Header []string `viper:"input-header"` Comment string `viper:"input-comment"` LazyQuotes bool `viper:"input-lazy-quotes"` Compression string `viper:"input-compression"` ReaderBufferSize int `viper:"input-reader-buffer-size"` Passphrase string `viper:"input-passphrase"` Salt string `viper:"input-salt"` SkipLines int `viper:"input-skip-lines"` Limit int `viper:"input-limit"` }
func (Input) HasCompression ¶
func (Input) IsAthenaStoredQuery ¶
func (Input) IsEncrypted ¶
func (Input) IsS3Bucket ¶
type Output ¶
type Output struct { Uri string `viper:"output-uri"` Format string `viper:"output-format"` Header []string `viper:"output-header"` Comment string `viper:"output-comment"` LazyQuotes bool `viper:"output-lazy-quotes"` Append bool `viper:"output-append"` BufferMemory bool `viper:"output-buffer-memory"` Compression string `viper:"output-compression"` Passphrase string `viper:"output-passphrase"` Salt string `viper:"output-salt"` Limit int `viper:"output-limit"` Mkdirs bool `viper:"output-mkdirs"` }
func (Output) HasCompression ¶
func (Output) IsAthenaStoredQuery ¶
func (Output) IsEncrypted ¶
func (Output) IsS3Bucket ¶
type Process ¶
type Process struct { AWS *AWS Input *Input Output *Output Temp *Temp Dfl *Dfl ErrorDestination string `viper:"error-destination"` ErrorCompression string `viper:"error-compression"` LogDestination string `viper:"log-destination"` LogCompression string `viper:"log-compression"` }
func (*Process) AWSSessionOptions ¶
func (*Process) HasAWSResource ¶
func (*Process) HasAthenaStoredQuery ¶
func (*Process) HasS3Bucket ¶
func (*Process) InputOptions ¶
func (*Process) OutputOptions ¶
Click to show internal directories.
Click to hide internal directories.