util

package

v0.8.0 Latest Latest Go to latest Published: May 2, 2024 License: Apache-2.0 Imports: 12 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/kedacore/http-add-on

Links

Open Source Insights

Documentation ¶

Index ¶

func ApplyContext(f func(ctx context.Context) error, ctx context.Context) func() error
func ContextWithHTTPSO(ctx context.Context, httpso *httpv1alpha1.HTTPScaledObject) context.Context
func ContextWithLogger(ctx context.Context, logger logr.Logger) context.Context
func ContextWithStream(ctx context.Context, url *url.URL) context.Context
func DeapplyError(f func(), err error) func() error
func HTTPSOFromContext(ctx context.Context) *httpv1alpha1.HTTPScaledObject
func IgnoringError(f func() error)
func IsIgnoredErr(err error) bool
func IsNil(i interface{}) bool
func LoggerFromContext(ctx context.Context) logr.Logger
func RequestWithHTTPSO(r *http.Request, httpso *httpv1alpha1.HTTPScaledObject) *http.Request
func RequestWithLogger(r *http.Request, logger logr.Logger) *http.Request
func RequestWithLoggerWithName(r *http.Request, name string) *http.Request
func RequestWithStream(r *http.Request, stream *url.URL) *http.Request
func ResolveOsEnvBool(envName string, defaultValue bool) (bool, error)
func ResolveOsEnvDuration(envName string) (*time.Duration, error)
func ResolveOsEnvInt(envName string, defaultValue int) (int, error)
func StreamFromContext(ctx context.Context) *url.URL
func WithTimeout(d time.Duration, f func() error) error
type AtomicValue
- func NewAtomicValue[V any](v V) *AtomicValue[V]
- func (av *AtomicValue[V]) Get() V
- func (av *AtomicValue[V]) Set(v V)
type HealthChecker
type HealthCheckerFunc
- func (f HealthCheckerFunc) HealthCheck(ctx context.Context) error
type Signaler
- func NewSignaler() Signaler
type Stopwatch
- func (sw *Stopwatch) ElapsedTime() time.Duration
- func (sw *Stopwatch) Start()
- func (sw *Stopwatch) StartTime() time.Time
- func (sw *Stopwatch) Stop()
- func (sw *Stopwatch) StopTime() time.Time

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func ApplyContext ¶

func ApplyContext(f func(ctx context.Context) error, ctx context.Context) func() error

func ContextWithHTTPSO ¶

func ContextWithHTTPSO(ctx context.Context, httpso *httpv1alpha1.HTTPScaledObject) context.Context

func ContextWithLogger ¶

func ContextWithLogger(ctx context.Context, logger logr.Logger) context.Context

func ContextWithStream ¶

func ContextWithStream(ctx context.Context, url *url.URL) context.Context

func DeapplyError ¶

func DeapplyError(f func(), err error) func() error

func HTTPSOFromContext ¶

func HTTPSOFromContext(ctx context.Context) *httpv1alpha1.HTTPScaledObject

func IgnoringError ¶

func IgnoringError(f func() error)

func IsIgnoredErr ¶ added in v0.6.0

func IsIgnoredErr(err error) bool

func IsNil ¶

func IsNil(i interface{}) bool

func LoggerFromContext ¶

func LoggerFromContext(ctx context.Context) logr.Logger

func RequestWithHTTPSO ¶

func RequestWithHTTPSO(r *http.Request, httpso *httpv1alpha1.HTTPScaledObject) *http.Request

func RequestWithLogger ¶

func RequestWithLogger(r *http.Request, logger logr.Logger) *http.Request

func RequestWithLoggerWithName ¶

func RequestWithLoggerWithName(r *http.Request, name string) *http.Request

func RequestWithStream ¶

func RequestWithStream(r *http.Request, stream *url.URL) *http.Request

func ResolveOsEnvBool ¶ added in v0.6.0

func ResolveOsEnvBool(envName string, defaultValue bool) (bool, error)

func ResolveOsEnvDuration ¶ added in v0.6.0

func ResolveOsEnvDuration(envName string) (*time.Duration, error)

func ResolveOsEnvInt ¶ added in v0.6.0

func ResolveOsEnvInt(envName string, defaultValue int) (int, error)

func StreamFromContext ¶

func StreamFromContext(ctx context.Context) *url.URL

func WithTimeout ¶

func WithTimeout(d time.Duration, f func() error) error

Types ¶

type AtomicValue ¶

type AtomicValue[V any] struct {
	// contains filtered or unexported fields
}

func NewAtomicValue ¶

func NewAtomicValue[V any](v V) *AtomicValue[V]

func (*AtomicValue[V]) Get ¶

func (av *AtomicValue[V]) Get() V

func (*AtomicValue[V]) Set ¶

func (av *AtomicValue[V]) Set(v V)

type HealthChecker ¶

type HealthChecker interface {
	HealthCheck(ctx context.Context) error
}

type HealthCheckerFunc ¶

type HealthCheckerFunc func(ctx context.Context) error

func (HealthCheckerFunc) HealthCheck ¶

func (f HealthCheckerFunc) HealthCheck(ctx context.Context) error

type Signaler ¶

type Signaler interface {
	Signal()
	Wait(ctx context.Context) error
}

func NewSignaler ¶

func NewSignaler() Signaler

type Stopwatch ¶

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

func (*Stopwatch) ElapsedTime ¶

func (sw *Stopwatch) ElapsedTime() time.Duration

func (*Stopwatch) Start ¶

func (sw *Stopwatch) Start()

func (*Stopwatch) StartTime ¶

func (sw *Stopwatch) StartTime() time.Time

func (*Stopwatch) Stop ¶

func (sw *Stopwatch) Stop()

func (*Stopwatch) StopTime ¶

func (sw *Stopwatch) StopTime() time.Time

Source Files ¶

View all Source files

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