config

Documentation

Index

• Constants
• Variables
• func DevstackEnvFile() string
• func DevstackGetShouldPrintInfo() bool
• func DevstackSetShouldPrintInfo()
• func ForEnvironment() types.BacalhauConfig
• func GetClientID(path string) (string, error)
• func GetClientPrivateKey(path string) (*rsa.PrivateKey, error)
• func GetLibp2pPrivKey(path string) (libp2p_crypto.PrivKey, error)
• func KeyAsEnvVar(key string) string
• func New(opts ...Option) *config
• func PreferredAddress() string
• func ShouldKeepStack() bool
• func WritePersistedConfigs(configFilePath string, cfg types.BacalhauConfig) error
• type DockerCredentials
  • func GetDockerCredentials() DockerCredentials
  • func (d *DockerCredentials) IsValid() bool
• type Environment
  • func GetConfigEnvironment() Environment
  • func (e Environment) IsKnown() bool
  • func (e Environment) String() string
• type Option
  • func WithDefaultConfig(cfg types.BacalhauConfig) Option
  • func WithViper(v *viper.Viper) Option
• type ReadWriter
• type Reader
• type Writer

Constants

const (
	FileName = "config.yaml"

	// user key files
	Libp2pPrivateKeyFileName = "libp2p_private_key"
	UserPrivateKeyFileName   = "user_id.pem"

	// compute paths
	ComputeStoragesPath = "executor_storages"
	ComputeStorePath    = "compute_store"
	PluginsPath         = "plugins"

	// orchestrator paths
	OrchestratorStorePath = "orchestrator_store"
	AutoCertCachePath     = "autocert-cache"
	NetworkTransportStore = "nats-store"

	// update check paths
	UpdateCheckStatePath = "update.json"

	// auth paths
	TokensPath = "tokens.json"
)

const (
	DockerUsernameEnvVar = "DOCKER_USERNAME"
	DockerPasswordEnvVar = "DOCKER_PASSWORD"
)

Variables

var (
	ComputeExecutionsStorePath = filepath.Join(ComputeStorePath, "executions.db")
	OrchestratorJobStorePath   = filepath.Join(OrchestratorStorePath, "jobs.db")

	DecoderHook = viper.DecodeHook(mapstructure.TextUnmarshallerHookFunc())
)

Functions

func DevstackEnvFile

func DevstackEnvFile() string

func DevstackGetShouldPrintInfo

func DevstackGetShouldPrintInfo() bool

func DevstackSetShouldPrintInfo

func DevstackSetShouldPrintInfo()

func ForEnvironment

func ForEnvironment() types.BacalhauConfig

func GetClientID

func GetClientID(path string) (string, error)

func GetClientPrivateKey

func GetClientPrivateKey(path string) (*rsa.PrivateKey, error)

func GetLibp2pPrivKey

func GetLibp2pPrivKey(path string) (libp2p_crypto.PrivKey, error)

func KeyAsEnvVar

func KeyAsEnvVar(key string) string

KeyAsEnvVar returns the environment variable corresponding to a config key

func New

func New(opts ...Option) *config

func PreferredAddress

func PreferredAddress() string

PreferredAddress will allow for the specifying of the preferred address to listen on for cases where it is not clear, or where the address does not appear when using 0.0.0.0

func ShouldKeepStack

func ShouldKeepStack() bool

func WritePersistedConfigs

func WritePersistedConfigs(configFilePath string, cfg types.BacalhauConfig) error

WritePersistedConfigs will write certain values from the resolved config to the persisted config. These include fields for configurations that must not change between version updates, such as the execution store and job store paths, in case we change their default values in future updates.

Types

type DockerCredentials

type DockerCredentials struct {
	Username string
	Password string
}

func GetDockerCredentials

func GetDockerCredentials() DockerCredentials

func (*DockerCredentials) IsValid

func (d *DockerCredentials) IsValid() bool

type Environment

type Environment string

const (
	// Known environments that are configured in ops/terraform:
	EnvironmentStaging Environment = "staging"
	EnvironmentProd    Environment = "production"
	EnvironmentDev     Environment = "development"
	EnvironmentTest    Environment = "test"
	EnvironmentLocal   Environment = "local"
)

func GetConfigEnvironment

func GetConfigEnvironment() Environment

func (Environment) IsKnown

func (e Environment) IsKnown() bool

func (Environment) String

func (e Environment) String() string

type Option

type Option = func(s *config)

func WithDefaultConfig

func WithDefaultConfig(cfg types.BacalhauConfig) Option

func WithViper

func WithViper(v *viper.Viper) Option

type ReadWriter

type ReadWriter interface {
	Reader
	Writer
}

type Reader

type Reader interface {
	Current() (types.BacalhauConfig, error)
}

type Writer

type Writer interface {
	Load(path string) error
	Set(key string, value interface{})
	SetIfAbsent(key string, value interface{})
}