config

Documentation

Index

• type ArrayFlag
  • func (i *ArrayFlag) Set(value string) error
  • func (i *ArrayFlag) String() string
• type Config
  • func TryParseArgs() *Config
  • func TryParseNirvanaConfig() (*Config, error)
• type DBConfig
  • func (dc *DBConfig) HasTLS() bool
• type JobContext

Types

type ArrayFlag

type ArrayFlag []string

func (*ArrayFlag) Set

func (i *ArrayFlag) Set(value string) error

func (*ArrayFlag) String

func (i *ArrayFlag) String() string

type Config

type Config struct {
	DBConfig
	YtPath       string `json:"yt_path"`
	YtCluster    string `json:"yt_cluster"`
	YtSpec       string `json:"yt_spec"`
	YtToken      string `json:"yt_token"`
	MDBToken     string `json:"dbaas_token"`
	MDBClusterID string `json:"dbaas_cluster_id"`
}

func TryParseArgs

func TryParseArgs() *Config

func TryParseNirvanaConfig

func TryParseNirvanaConfig() (*Config, error)

type DBConfig

type DBConfig struct {
	DBHost     string   `json:"db_host" yaml:"db_host"`
	DBPort     int      `json:"db_port" yaml:"db_port"`
	DBUser     string   `json:"db_user" yaml:"db_user"`
	DBPassword string   `json:"db_password" yaml:"db_password"`
	DBSchema   string   `json:"db_schema" yaml:"db_schema"`
	DBTables   []string `json:"db_tables" yaml:"db_tables"`
	DBFilter   []string `json:"db_filters" yaml:"db_filters"`
	DBName     string   `json:"db_name" yaml:"db_name"`
	Master     bool     `json:"master" yaml:"master"`
	TLSFile    string   `json:"tls_file" yaml:"tls_file"`
}

legacy thing - used only for back-compatiblity command-line tools pg*

func (*DBConfig) HasTLS

func (dc *DBConfig) HasTLS() bool

type JobContext

type JobContext struct {
	Meta struct {
		WorkflowUID         string `json:"workflowUid"`
		WorkflowInstanceUID string `json:"workflowInstanceUid"`
		WorkflowURL         string `json:"workflowURL"`
		OperationUID        string `json:"operationUid"`
		BlockUID            string `json:"blockUid"`
		BlockCode           string `json:"blockCode"`
		BlockURL            string `json:"blockURL"`
		ProcessUID          string `json:"processUid"`
		ProcessURL          string `json:"processURL"`
		Priority            struct {
			Min       int     `json:"min"`
			Max       int     `json:"max"`
			Value     int     `json:"value"`
			NormValue float64 `json:"normValue"`
		} `json:"priority"`
		Description  string `json:"description"`
		Owner        string `json:"owner"`
		QuotaProject string `json:"quotaProject"`
	} `json:"meta"`
	Parameters  Config      `json:"parameters"`
	Inputs      interface{} `json:"inputs"`
	Outputs     interface{} `json:"outputs"`
	InputItems  interface{} `json:"inputItems"`
	OutputItems interface{} `json:"outputItems"`
}