flagparsers

Documentation

Index

• Constants
• func AddConnectionFlagsToCmd(cmd *cobra.Command)
• func FlagsToConnectionConfig(flags *pflag.FlagSet, args []string) (*cli.ConnectionConfig, error)
• func FlagsToMigrateConfig(flags *pflag.FlagSet, args []string) (*cli.ConnectionConfig, *cli.MigrationConfig, error)
• func FlagsToSchemaTransferConfig(flags *pflag.FlagSet, args []string) (*cli.ConnectionConfig, *cli.MigrationConfig, error)

Constants

const (
	VersionFlag                 = "version"
	InputServerFlag             = "input-server"
	InputUserFlag               = "input-user"
	InputPassFlag               = "input-pass"
	InputUnsafeHTTPSFlag        = "input-unsafe-https"
	RetentionPolicyFlag         = "retention-policy"
	OutputConnFlag              = "output-conn"
	SchemaStrategyFlag          = "schema-strategy"
	CommitStrategyFlag          = "commit-strategy"
	OutputSchemaFlag            = "output-schema"
	FromFlag                    = "from"
	ToFlag                      = "to"
	LimitFlag                   = "limit"
	ChunkSizeFlag               = "chunk-size"
	QuietFlag                   = "quiet"
	DataBufferFlag              = "data-buffer"
	MaxParallelFlag             = "max-parallel"
	RollbackOnExternalErrorFlag = "rollback-on-external-error"
	BatchSizeFlag               = "batch-size"
	TagsAsJSONFlag              = "tags-as-json"
	TagsColumnFlag              = "tags-column"
	FieldsAsJSONFlag            = "fields-as-json"
	FieldsColumnFlag            = "fields-column"
	ChunkTimeIntervalFlag       = "chunk-time-interval"
	// InfluxDB can have different data types for the same field accross
	// different shards. If a field is discovered with an Int64 and a Float64 type
	// and this flag is TRUE it will allow the field to be converted to float,
	// otherwise it will return an error.
	MultishardIntFloatCast = "multishard-int-float-cast"

	DefaultInputServer             = "http://localhost:8086"
	DefaultInputUser               = ""
	DefaultInputPass               = ""
	DefaultInputUnsafeHTTPS        = false
	DefaultRetentionPolicy         = "autogen"
	DefaultOutputConn              = "sslmode=disable"
	DefaultOutputSchema            = ""
	DefaultSchemaStrategy          = schemaconfig.CreateIfMissing
	DefaultCommitStrategy          = ingestionConfig.CommitOnEachBatch
	DefaultDataBufferSize          = 15000
	DefaultChunkSize               = 15000
	DefaultLimit                   = 0
	DefaultMaxParallel             = 2
	DefaultRollbackOnExternalError = true
	DefaultBatchSize               = 8000
	DefaultTagsAsJSON              = false
	DefaultTagsColumn              = "tags"
	DefaultFieldsAsJSON            = false
	DefaultFieldsColumn            = "fields"
	DefaultMultishardIntFloatCast  = false
	DefaultChunkTimeInterval       = ""
)

Flags used in outflux and their default values

Functions

func AddConnectionFlagsToCmd

func AddConnectionFlagsToCmd(cmd *cobra.Command)

AddConnectionFlagsToCmd adds the flags required to connect to an Influx and Timescale database

func FlagsToConnectionConfig

func FlagsToConnectionConfig(flags *pflag.FlagSet, args []string) (*cli.ConnectionConfig, error)

FlagsToConnectionConfig extracts flags related to establishing the connection to input and output database

func FlagsToMigrateConfig

func FlagsToMigrateConfig(flags *pflag.FlagSet, args []string) (*cli.ConnectionConfig, *cli.MigrationConfig, error)

FlagsToMigrateConfig extracts the config for running a migration from the flags of the command

func FlagsToSchemaTransferConfig

func FlagsToSchemaTransferConfig(flags *pflag.FlagSet, args []string) (*cli.ConnectionConfig, *cli.MigrationConfig, error)

FlagsToSchemaTransferConfig extracts the config for running schema transfer from the flags of the command