idlewatcher

package
v0.10.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 22, 2025 License: MIT Imports: 31 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ForceCacheControl

type ForceCacheControl struct {
	http.ResponseWriter
	// contains filtered or unexported fields
}

func (*ForceCacheControl) Unwrap

func (*ForceCacheControl) WriteHeader

func (f *ForceCacheControl) WriteHeader(code int)

type StopCallback

type StopCallback func() error

type Waker

type Waker = types.Waker

func NewHTTPWaker

func NewHTTPWaker(parent task.Parent, route route.Route, rp *reverseproxy.ReverseProxy) (Waker, gperr.Error)

lifetime should follow route provider.

func NewStreamWaker

func NewStreamWaker(parent task.Parent, route route.Route, stream net.Stream) (Waker, gperr.Error)

type Watcher

type Watcher struct {
	zerolog.Logger
	// contains filtered or unexported fields
}

func (*Watcher) Accept

func (w *Watcher) Accept() (conn types.StreamConn, err error)

Accept implements types.Stream.

func (*Watcher) Addr

func (w *Watcher) Addr() net.Addr

Setup implements types.Stream.

func (*Watcher) Close

func (w *Watcher) Close() error

Close implements types.Stream.

func (*Watcher) Config added in v0.10.0

func (w *Watcher) Config() *idlewatcher.Config

func (*Watcher) ContainerID added in v0.10.0

func (w *Watcher) ContainerID() string

func (*Watcher) ContainerName added in v0.10.0

func (w *Watcher) ContainerName() string

func (*Watcher) Finish

func (w *Watcher) Finish(reason any)

Finish implements health.HealthMonitor.

func (*Watcher) Handle

func (w *Watcher) Handle(conn types.StreamConn) error

Handle implements types.Stream.

func (*Watcher) Latency

func (w *Watcher) Latency() time.Duration

Latency implements health.HealthMonitor.

func (*Watcher) MarshalJSON

func (w *Watcher) MarshalJSON() ([]byte, error)

MarshalJSON implements health.HealthMonitor.

func (*Watcher) Name

func (w *Watcher) Name() string

Name implements health.HealthMonitor.

func (*Watcher) ServeHTTP

func (w *Watcher) ServeHTTP(rw http.ResponseWriter, r *http.Request)

ServeHTTP implements http.Handler.

func (*Watcher) Setup

func (w *Watcher) Setup() error

Setup implements types.Stream.

func (*Watcher) Start

func (w *Watcher) Start(parent task.Parent) gperr.Error

Start implements health.HealthMonitor.

func (*Watcher) Status

func (w *Watcher) Status() health.Status

Status implements health.HealthMonitor.

func (*Watcher) String

func (w *Watcher) String() string

String implements health.HealthMonitor.

func (*Watcher) Task

func (w *Watcher) Task() *task.Task

Task implements health.HealthMonitor.

func (*Watcher) Uptime

func (w *Watcher) Uptime() time.Duration

Uptime implements health.HealthMonitor.

func (*Watcher) Wake

func (w *Watcher) Wake() error

func (*Watcher) WakeDebug

func (w *Watcher) WakeDebug() *zerolog.Event

WakeDebug logs a debug message related to waking the container.

func (*Watcher) WakeError

func (w *Watcher) WakeError(err error)

func (*Watcher) WakeTrace

func (w *Watcher) WakeTrace() *zerolog.Event

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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