transformer

Documentation

Index

• Constants
• Variables
• func NewTransformer(clock clock.Clock, cachedDownloader cacheddownloader.CachedDownloader, ...) *transformer
• type CheckProtocol
• type Config
• type HealthcheckType
• type Option
  • func WithContainerProxy(drainWait time.Duration) Option
  • func WithDeclarativeHealthchecks() Option
  • func WithPostSetupHook(user string, hook []string) Option
  • func WithSidecarRootfs(sidecarRootFS string) Option
• type Transformer

Constants

const (
	DefaultDeclarativeHealthcheckRequestTimeout = int(1 * time.Second / time.Millisecond) // this is just 1000, transformed eventually into a str: "1000ms" or equivalently "1s"
	HealthLogSource                             = "HEALTH"
)

Variables

var ErrNoCheck = errors.New("no check configured")

var HealthCheckDstPath string = filepath.Join(string(os.PathSeparator), "etc", "cf-assets", "healthcheck")

Functions

func NewTransformer

func NewTransformer(
	clock clock.Clock,
	cachedDownloader cacheddownloader.CachedDownloader,
	uploader uploader.Uploader,
	compressor compressor.Compressor,
	downloadLimiter chan struct{},
	uploadLimiter chan struct{},
	tempDir string,
	healthyMonitoringInterval time.Duration,
	unhealthyMonitoringInterval time.Duration,
	gracefulShutdownInterval time.Duration,
	healthCheckWorkPool *workpool.WorkPool,
	opts ...Option,
) *transformer

Types

type CheckProtocol

type CheckProtocol int

const (
	HTTPCheck CheckProtocol = iota
	TCPCheck
)

type Config

type Config struct {
	ProxyTLSPorts     []uint16
	BindMounts        []garden.BindMount
	CreationStartTime time.Time
	MetronClient      loggingclient.IngressClient
}

type HealthcheckType

type HealthcheckType int

type Option

type Option func(*transformer)

func WithContainerProxy

func WithContainerProxy(drainWait time.Duration) Option

func WithDeclarativeHealthchecks

func WithDeclarativeHealthchecks() Option

func WithPostSetupHook

func WithPostSetupHook(user string, hook []string) Option

func WithSidecarRootfs

func WithSidecarRootfs(
	sidecarRootFS string,
) Option

type Transformer

type Transformer interface {
	StepsRunner(lager.Logger, executor.Container, garden.Container, log_streamer.LogStreamer, Config) (ifrit.Runner, chan steps.ReadinessState, error)
}