config

package
v0.0.0-...-5cd0c88 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 25, 2018 License: MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func LoadConfigFromViper

func LoadConfigFromViper(c interface{}, v *viper.Viper)

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) Config

func (a AWS) Config() aws.Config

func (AWS) Map

func (a AWS) Map() map[string]interface{}

func (AWS) SessionOptions

func (a AWS) SessionOptions() session.Options

type Dfl

type Dfl struct {
	Expression string `viper:"dfl-expression"`
	Uri        string `viper:"dfl-uri"`
	Vars       string `viper:"dfl-vars"`
}

func (Dfl) Map

func (d Dfl) Map() map[string]interface{}

func (Dfl) Node

func (d Dfl) Node() (dfl.Node, error)

func (*Dfl) Variables

func (d *Dfl) Variables() (map[string]interface{}, error)

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) CanStream

func (i Input) CanStream() bool

func (Input) HasCompression

func (i Input) HasCompression() bool

func (Input) HasFormat

func (i Input) HasFormat() bool

func (*Input) Init

func (i *Input) Init()

func (Input) IsAthenaStoredQuery

func (i Input) IsAthenaStoredQuery() bool

func (Input) IsEncrypted

func (i Input) IsEncrypted() bool

func (Input) IsS3Bucket

func (i Input) IsS3Bucket() bool

func (Input) Map

func (i Input) Map() map[string]interface{}

func (Input) Options

func (i Input) Options() gss.Options

func (Input) Path

func (i Input) Path() string

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) CanStream

func (o Output) CanStream() bool

func (Output) HasCompression

func (o Output) HasCompression() bool

func (Output) HasFormat

func (o Output) HasFormat() bool

func (*Output) Init

func (o *Output) Init()

func (Output) IsAthenaStoredQuery

func (o Output) IsAthenaStoredQuery() bool

func (Output) IsEncrypted

func (o Output) IsEncrypted() bool

func (Output) IsS3Bucket

func (o Output) IsS3Bucket() bool

func (Output) Map

func (o Output) Map() map[string]interface{}

func (Output) Options

func (o Output) Options() gss.Options

func (Output) Path

func (o Output) Path() string

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 (p *Process) AWSSessionOptions() session.Options

func (*Process) HasAWSResource

func (p *Process) HasAWSResource() bool

func (*Process) HasAthenaStoredQuery

func (p *Process) HasAthenaStoredQuery() bool

func (*Process) HasS3Bucket

func (p *Process) HasS3Bucket() bool

func (*Process) InputOptions

func (p *Process) InputOptions() gss.Options

func (*Process) Map

func (p *Process) Map() map[string]interface{}

func (*Process) OutputOptions

func (p *Process) OutputOptions() gss.Options

type Temp

type Temp struct {
	Uri string `viper:"temp-uri"`
}

func (Temp) IsAthenaStoredQuery

func (t Temp) IsAthenaStoredQuery() bool

func (Temp) IsS3Bucket

func (t Temp) IsS3Bucket() bool

func (Temp) Map

func (t Temp) Map() map[string]interface{}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL