pkg

type Config struct {
	ListenAddress string        `yaml:"listen_address"`
	CA            *TLSInfo      `yaml:"ca"`
	LogLevel      string        `yaml:"log_level"`
	Statsd        *StatsdConfig `yaml:"statsd"`

	Registries []Registry `yaml:"registries"`
}

type DefaultMitmHijacker struct{}

type DockerRegistryHijacker struct {
	// contains filtered or unexported fields
}

type MitmHijacker interface {
	// RequestHandler is called for all incoming requests
	// * the first item of the return tuple, the boolean, says whether the hijacker wishes to hijack that request; in
	//   that case,
	// * if that first item is true, the hijacker can optionally provide a *http.Response to copy to the client
	// * if the first item of the return tuple is false, or error is not nil, then the proxy forwards the request upstream
	RequestHandler(http.ResponseWriter, *http.Request) (bool, *http.Response, error)

	// hijackers can choose to transform statsd metrics' names
	// metricName is guaranteed to be one of the constants defined above.
	// If it returns an empty string, then the metric point is not emitted.
	TransformMetricName(MitmProxyStatsdMetricName, *http.Request) string
}

type MitmProxy struct {
	// contains filtered or unexported fields
}

type MitmProxyStatsdMetricName string

type RedirectRegistry struct {
	krakenconfig.Config `yaml:",inline"`

	// if specified, this should indicate how to rewrite repositories
	// à la SSH config, %r will be replaced by the original repository name,
	// and %t by the original tag name
	RewriteRepositories string `yaml:"rewrite_repositories"`
}

type Registry struct {
	krakenconfig.Config `yaml:",inline"`

	// if specified, that will be used instead of the registry's address to determine
	// if a given request is addressed to this registry
	MatchingRegex string `yaml:"matching_regex"`

	// which registries to try & redirect to, in order
	Redirects []RedirectRegistry `yaml:"redirects"`
}

type StatsdConfig struct {
	Address       string        `yaml:"address"`
	Prefix        string        `yaml:"prefix"`
	FlushInterval time.Duration `yaml:"flush_interval"`
	FlushBytes    int           `yaml:"flush_bytes"`
}

type TLSInfo struct {
	CertPath string `yaml:"cert_path"`
	KeyPath  string `yaml:"key_path"`
}