config

Documentation

Index

• Constants
• Variables
• func CacheableURIPrefixes() map[string][]*url.URL
• func DeprecateFlags(cmd *cobra.Command, deprecations ...DeprecatedFlag) error
• func GetCacheSRV() string
• func GetConsumer() (consumer.Consumer, error)
• func HideFlags(cmd *cobra.Command, flags ...string) error
• func PersistentStartupProcessFlags() error
• func ResolveOverridesToMap(resolveOverrides []string) (map[string]string, error)
• func ViperInit()
• type ConsistentHashingStrategy
• type DeprecatedFlag

Constants

const (
	ConsumerFile         = "file"
	ConsumerTarExtractor = "tar-extractor"
	ConsumerNull         = "null"
)

const (
	// these options are a massive hack. They're only availabe via
	// envvar, not command line
	OptCacheNodesSRVNameByHostCIDR = "cache-nodes-srv-name-by-host-cidr"
	OptCacheNodesSRVName           = "cache-nodes-srv-name"
	OptCacheURIPrefixes            = "cache-uri-prefixes"
	OptCacheUsePathProxy           = "cache-use-path-proxy"
	OptHostIP                      = "host-ip"

	// Normal options with CLI arguments
	OptConcurrency        = "concurrency"
	OptConnTimeout        = "connect-timeout"
	OptChunkSize          = "chunk-size"
	OptExtract            = "extract"
	OptForce              = "force"
	OptForceHTTP2         = "force-http2"
	OptLoggingLevel       = "log-level"
	OptMaxChunks          = "max-chunks"
	OptMaxConnPerHost     = "max-conn-per-host"
	OptMaxConcurrentFiles = "max-concurrent-files"
	OptMinimumChunkSize   = "minimum-chunk-size"
	OptOutputConsumer     = "output"
	OptPIDFile            = "pid-file"
	OptResolve            = "resolve"
	OptRetries            = "retries"
	OptVerbose            = "verbose"
)

Variables

var (
	DefaultCacheURIPrefixes = []string{"https://weights.replicate.delivery"}
)

Functions

func CacheableURIPrefixes

func CacheableURIPrefixes() map[string][]*url.URL

CacheableURIPrefixes returns a map of cache URI prefixes to send through consistent hash, if set. ENV is `PGET_CACHE_URI_PREFIXES`, and the format is `https://example.com/prefix1 https://example.com/prefix2 https://example.com/ [...]`

func DeprecateFlags

func DeprecateFlags(cmd *cobra.Command, deprecations ...DeprecatedFlag) error

func GetCacheSRV

func GetCacheSRV() string

GetCacheSRV returns the SRV name of the cache to use, if set.

func GetConsumer

func GetConsumer() (consumer.Consumer, error)

GetConsumer returns the consumer specified by the user on the command line or an error if the consumer is invalid. Note that this function explicitly calls viper.GetString(OptExtract) internally.

func HideFlags

func HideFlags(cmd *cobra.Command, flags ...string) error

func PersistentStartupProcessFlags

func PersistentStartupProcessFlags() error

func ResolveOverridesToMap

func ResolveOverridesToMap(resolveOverrides []string) (map[string]string, error)

func ViperInit

func ViperInit()

Types

type ConsistentHashingStrategy

type ConsistentHashingStrategy struct{}

var ConsistentHashingStrategyKey ConsistentHashingStrategy

type DeprecatedFlag

type DeprecatedFlag struct {
	Flag string
	Msg  string
}