config

Documentation

Overview

Package config models the configuration file for Amplify

Index

• Constants
• func AddGlobalFlags(cmd *cobra.Command)
• func InitViper(cmd *cobra.Command) (*viper.Viper, error)
• type AppConfig
  • func ParseAppConfig(cmd *cobra.Command) *AppConfig
• type Config
  • func GetConfig(path string) (*Config, error)
• type DB
• type IPFSSearch
• type Job
• type Node
  • func (n *Node) ApplyDefaults()
  • func (n Node) IsRoot() bool
• type NodeInput
• type NodeOutput
• type Trigger

Constants

const (
	LogLevelFlag               = "log-level"
	ConfigPathFlag             = "config"
	PortFlag                   = "port"
	IPFSSearchEnabledFlag      = "trigger.ipfs-search.enabled"
	IPFSSearchQueryURLFlag     = "trigger.ipfs-search.query-url"
	IPFSSearchPeriodFlag       = "trigger.ipfs-search.period"
	DBURIFlag                  = "db.uri"
	NumConcurrentNodesFlag     = "num-concurrent-nodes"
	NumConcurrentWorkflowsFlag = "num-concurrent-workflows"
	MaxWaitingWorkflowsFlag    = "max-waiting-workflows"
	DisableCORSFlag            = "disable-cors"
)

Define all global flag names

const (
	DefaultTimeout = 10 * time.Minute
	DefaultCPU     = "1"
	DefaultMemory  = "1Gi"
)

Functions

func AddGlobalFlags

func AddGlobalFlags(cmd *cobra.Command)

func InitViper

func InitViper(cmd *cobra.Command) (*viper.Viper, error)

Types

type AppConfig

type AppConfig struct {
	LogLevel            zerolog.Level `yaml:"log-level"`
	ConfigPath          string        `yaml:"config-path"`
	Port                int           `yaml:"port"`
	Trigger             Trigger       `yaml:"trigger"`
	DB                  DB            `yaml:"db"`
	NodeConcurrency     int           `yaml:"concurrency"`
	WorkflowConcurrency int           `yaml:"workflow-concurrency"`
	MaxWaitingWorkflows int           `yaml:"max-waiting-workflows"`
	DisableCORS         bool          `yaml:"disable-cors"`
}

func ParseAppConfig

func ParseAppConfig(cmd *cobra.Command) *AppConfig

type Config

type Config struct {
	Jobs  []Job  `yaml:"jobs"`
	Graph []Node `yaml:"graph"`
}

func GetConfig

func GetConfig(path string) (*Config, error)

type DB

type DB struct {
	URI string `yaml:"uri"`
}

type IPFSSearch

type IPFSSearch struct {
	Enabled  bool          `yaml:"enabled"`
	QueryURL string        `yaml:"query-url"`
	Period   time.Duration `yaml:"period"`
}

type Job

type Job struct {
	ID            string        `yaml:"id"`
	Type          string        `yaml:"type"`
	InternalJobID string        `yaml:"internal_job_id"`
	Image         string        `yaml:"image"`
	Entrypoint    []string      `yaml:"entrypoint"`
	Timeout       time.Duration `yaml:"timeout"`
	Memory        string        `yaml:"memory"`
	CPU           string        `yaml:"cpu"`
}

type Node

type Node struct {
	ID      string       `yaml:"id"`
	JobID   string       `yaml:"job_id"`
	Inputs  []NodeInput  `yaml:"inputs"`
	Outputs []NodeOutput `yaml:"outputs"`
}

func (*Node) ApplyDefaults

func (n *Node) ApplyDefaults()

func (Node) IsRoot

func (n Node) IsRoot() bool

type NodeInput

type NodeInput struct {
	Root      bool   `yaml:"root"`
	NodeID    string `yaml:"node_id"`
	OutputID  string `yaml:"output_id"`
	Path      string `yaml:"path"`
	Predicate string `yaml:"predicate"`
}

type NodeOutput

type NodeOutput struct {
	ID   string `yaml:"id"`
	Path string `yaml:"path"`
}

type Trigger

type Trigger struct {
	IPFSSearch IPFSSearch `yaml:"ipfs-search"`
}