e2e

package module

Go to main page

Versions in this module

v0

v0.14.0

Nov 18, 2022

Changes in this version

type EnvironmentOption

+ func WithVolumes(volumes ...string) EnvironmentOption

v0.13.1

Sep 23, 2022

v0.13.0

Sep 14, 2022

Changes in this version

type DockerEnvironment

+ func New(opts ...EnvironmentOption) (_ *DockerEnvironment, err error)

type EnvironmentOption

+ func WithName(name string) EnvironmentOption

type Runnable

+ func NewFailedRunnable(name string, err error) Runnable

type StartOptions

+ LimitCPUs float64

+ LimitMemoryBytes uint

v0.12.1

May 2, 2022

Changes in this version

type Command

+ func NewCommandRunUntilStop() Command

+ type ExecOption func(o *ExecOptions)

+ func WithExecOptionStderr(stderr io.Writer) ExecOption

+ func WithExecOptionStdout(stdout io.Writer) ExecOption

+ type ExecOptions struct

+ Stderr io.Writer

+ Stdout io.Writer

v0.12.0

Apr 14, 2022

Changes in this version

type Errorer

+ func (e Errorer) RunOnce(context.Context) (string, error)

type HTTPReadinessProbe

+ func NewHTTPSReadinessProbe(portName, path string, expectedStatusRangeStart, expectedStatusRangeEnd int, ...) *HTTPReadinessProbe

+ type InstrumentedRunnableBuilder interface

+ Future func() FutureInstrumentedRunnable

+ Init func(opts StartOptions) InstrumentedRunnable

+ WithMetricPath func(path string) InstrumentedRunnableBuilder

+ WithMetricScheme func(scheme string) InstrumentedRunnableBuilder

+ WithPorts func(ports map[string]int, instrumentedPortName string) InstrumentedRunnableBuilder

type MetricTarget

+ Scheme string

type MetricsOption

+ func WithWaitBackoff(backoffConfig *backoff.Config) MetricsOption

type Runnable

+ func Containerize(e Environment, name string, startFn func(context.Context) error) (Runnable, error)

+ type RunnableCapabilities string

+ const RunnableCapabilitiesSysAdmin

type StartOptions

+ Capabilities []RunnableCapabilities

v0.11.1

Aug 29, 2021

v0.11.0

Aug 25, 2021

Changes in this version

type DockerEnvironment

+ func (e *DockerEnvironment) AddCloser(f func())

+ func (e *DockerEnvironment) HostAddr() string

+ func (e *DockerEnvironment) Name() string

type Environment

+ AddCloser func(func())

+ HostAddr func() string

+ Name func() string

v0.10.0

Aug 4, 2021

Changes in this version

+ func BuildKingpinArgs(flags map[string]string) []string

type CompositeInstrumentedRunnable

+ func (r *CompositeInstrumentedRunnable) MetricTargets() (ret []MetricTarget)

type DockerEnvironment

+ func (e *DockerEnvironment) AddListener(listener EnvironmentListener)

type Environment

+ AddListener func(listener EnvironmentListener)

+ type EnvironmentListener interface

+ OnRunnableChange func(started []Runnable) error

+ type Errorer struct

+ func NewErrorer(name string, err error) Errorer

+ func (Errorer) Dir() string

+ func (Errorer) Endpoint(string) string

+ func (Errorer) InternalDir() string

+ func (Errorer) InternalEndpoint(string) string

+ func (Errorer) IsRunning() bool

+ func (e Errorer) Exec(Command) (string, string, error)

+ func (e Errorer) Future() FutureRunnable

+ func (e Errorer) Init(StartOptions) Runnable

+ func (e Errorer) Kill() error

+ func (e Errorer) Name() string

+ func (e Errorer) Start() error

+ func (e Errorer) Stop() error

+ func (e Errorer) WaitReady() error

+ func (e Errorer) WithConcreteType(Runnable) RunnableBuilder

+ func (e Errorer) WithPorts(map[string]int) RunnableBuilder

+ type Instrumented interface

+ MetricTargets func() []MetricTarget

type InstrumentedRunnable

+ func NewErrInstrumentedRunnable(name string, err error) *InstrumentedRunnable

+ func (r *InstrumentedRunnable) MetricTargets() []MetricTarget

+ type MetricTarget struct

+ InternalEndpoint string

+ MetricPath string

+ type RunnableBuilder interface

+ Future func() FutureRunnable

+ Init func(opts StartOptions) Runnable

+ WithConcreteType func(r Runnable) RunnableBuilder

+ WithPorts func(map[string]int) RunnableBuilder

type StartOptions

+ Privileged bool

+ UserNs string

+ Volumes []string

v0.9.0

Jul 24, 2021

Changes in this version

+ func BuildArgs(flags map[string]string) []string

+ func EmptyFlags() map[string]string

+ func EqualsAmongTwo(sums ...float64) bool

+ func EqualsSingle(expected float64) func(float64) bool

+ func GreaterAmongTwo(sums ...float64) bool

+ func LessAmongTwo(sums ...float64) bool

+ func MergeFlags(inputs ...map[string]string) map[string]string

+ func MergeFlagsWithoutRemovingEmpty(inputs ...map[string]string) map[string]string

+ func StartAndWaitReady(runnables ...Runnable) error

+ func SumValues(values []float64) float64

+ type CmdReadinessProbe struct

+ func NewCmdReadinessProbe(cmd Command) *CmdReadinessProbe

+ func (p *CmdReadinessProbe) Ready(runnable Runnable) error

+ type Command struct

+ Args []string

+ Cmd string

+ EntrypointDisabled bool

+ func NewCommand(cmd string, args ...string) Command

+ func NewCommandWithoutEntrypoint(cmd string, args ...string) Command

+ type CompositeInstrumentedRunnable struct

+ func NewCompositeInstrumentedRunnable(runnables ...*InstrumentedRunnable) *CompositeInstrumentedRunnable

+ func (s *CompositeInstrumentedRunnable) Instances() []*InstrumentedRunnable

+ func (s *CompositeInstrumentedRunnable) SumMetrics(metricNames []string, opts ...MetricsOption) ([]float64, error)

+ func (s *CompositeInstrumentedRunnable) WaitSumMetrics(expected MetricValueExpectation, metricNames ...string) error

+ func (s *CompositeInstrumentedRunnable) WaitSumMetricsWithOptions(expected MetricValueExpectation, metricNames []string, opts ...MetricsOption) error

+ type DockerEnvironment struct

+ func NewDockerEnvironment(name string, opts ...EnvironmentOption) (*DockerEnvironment, error)

+ func (e *DockerEnvironment) Close()

+ func (e *DockerEnvironment) FutureRunnable(name string, ports map[string]int) FutureRunnable

+ func (e *DockerEnvironment) Runnable(name string, ports map[string]int, opts StartOptions) Runnable

+ func (e *DockerEnvironment) SharedDir() string

+ type Environment interface

+ Close func()

+ FutureRunnable func(name string, Ports map[string]int) FutureRunnable

+ Runnable func(name string, Ports map[string]int, opts StartOptions) Runnable

+ SharedDir func() string

+ type EnvironmentOption func(*environmentOptions)

+ func WithLogger(logger Logger) EnvironmentOption

+ func WithVerbose() EnvironmentOption

+ type ErrRunnable struct

+ func NewErrRunnable(name string, err error) ErrRunnable

+ func (ErrRunnable) Dir() string

+ func (ErrRunnable) Endpoint(string) string

+ func (ErrRunnable) InternalDir() string

+ func (ErrRunnable) InternalEndpoint(string) string

+ func (ErrRunnable) IsRunning() bool

+ func (r ErrRunnable) Exec(Command) (string, string, error)

+ func (r ErrRunnable) Init(StartOptions) Runnable

+ func (r ErrRunnable) Kill() error

+ func (r ErrRunnable) Name() string

+ func (r ErrRunnable) Start() error

+ func (r ErrRunnable) Stop() error

+ func (r ErrRunnable) WaitReady() error

+ type FutureInstrumentedRunnable struct

+ func NewFutureInstrumentedRunnable(env Environment, name string, ports map[string]int, metricPortName string) *FutureInstrumentedRunnable

+ func (r *FutureInstrumentedRunnable) Init(opts StartOptions) *InstrumentedRunnable

+ type FutureRunnable interface

+ Init func(opts StartOptions) Runnable

+ type HTTPReadinessProbe struct

+ func NewHTTPReadinessProbe(portName string, path string, ...) *HTTPReadinessProbe

+ func (p *HTTPReadinessProbe) Ready(runnable Runnable) (err error)

+ type InstrumentedRunnable struct

+ func NewInstrumentedRunnable(env Environment, name string, ports map[string]int, metricPortName string, ...) *InstrumentedRunnable

+ func (r *InstrumentedRunnable) Metrics() (_ string, err error)

+ func (r *InstrumentedRunnable) SumMetrics(metricNames []string, opts ...MetricsOption) ([]float64, error)

+ func (r *InstrumentedRunnable) WaitRemovedMetric(metricName string, opts ...MetricsOption) error

+ func (r *InstrumentedRunnable) WaitSumMetrics(expected MetricValueExpectation, metricNames ...string) error

+ func (r *InstrumentedRunnable) WaitSumMetricsWithOptions(expected MetricValueExpectation, metricNames []string, opts ...MetricsOption) error

+ type LinePrefixLogger struct

+ func (w *LinePrefixLogger) Write(p []byte) (n int, err error)

+ type Linkable interface

+ Dir func() string

+ InternalDir func() string

+ InternalEndpoint func(portName string) string

+ Name func() string

+ type Logger interface

+ Log func(keyvals ...interface{}) error

+ type MetricValueExpectation func(sums ...float64) bool

+ func Equals(value float64) MetricValueExpectation

+ func Greater(value float64) MetricValueExpectation

+ func GreaterOrEqual(value float64) MetricValueExpectation

+ func Less(value float64) MetricValueExpectation

+ type MetricsOption func(*metricsOptions)

+ func SkipMissingMetrics() MetricsOption

+ func WaitMissingMetrics() MetricsOption

+ func WithLabelMatchers(matchers ...*matchers.Matcher) MetricsOption

+ func WithMetricCount() MetricsOption

+ type ReadinessProbe interface

+ Ready func(runnable Runnable) (err error)

+ type Runnable interface

+ Endpoint func(portName string) string

+ Exec func(command Command) (string, string, error)

+ IsRunning func() bool

+ Kill func() error

+ Start func() error

+ Stop func() error

+ WaitReady func() error

+ type SimpleLogger struct

+ func NewLogger(w io.Writer) *SimpleLogger

+ func (l *SimpleLogger) Log(keyvals ...interface{}) error

+ type StartOptions struct

+ Command Command

+ EnvVars map[string]string

+ Image string

+ Readiness ReadinessProbe

+ User string

+ WaitReadyBackoff *backoff.Config

+ type TCPReadinessProbe struct

+ func NewTCPReadinessProbe(portName string) *TCPReadinessProbe

+ func (p *TCPReadinessProbe) Ready(runnable Runnable) (err error)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL