idlewatcher

Documentation

Index

• type ForceCacheControl
  • func (f *ForceCacheControl) Unwrap() http.ResponseWriter
  • func (f *ForceCacheControl) WriteHeader(code int)
• type StopCallback
• type Waker
  • func NewHTTPWaker(parent task.Parent, route route.Route, rp *reverseproxy.ReverseProxy) (Waker, gperr.Error)
  • func NewStreamWaker(parent task.Parent, route route.Route, stream net.Stream) (Waker, gperr.Error)
• type Watcher
  • func (w *Watcher) Accept() (conn types.StreamConn, err error)
  • func (w *Watcher) Addr() net.Addr
  • func (w *Watcher) Close() error
  • func (w *Watcher) Config() *idlewatcher.Config
  • func (w *Watcher) ContainerID() string
  • func (w *Watcher) ContainerName() string
  • func (w *Watcher) Finish(reason any)
  • func (w *Watcher) Handle(conn types.StreamConn) error
  • func (w *Watcher) Latency() time.Duration
  • func (w *Watcher) MarshalJSON() ([]byte, error)
  • func (w *Watcher) Name() string
  • func (w *Watcher) ServeHTTP(rw http.ResponseWriter, r *http.Request)
  • func (w *Watcher) Setup() error
  • func (w *Watcher) Start(parent task.Parent) gperr.Error
  • func (w *Watcher) Status() health.Status
  • func (w *Watcher) String() string
  • func (w *Watcher) Task() *task.Task
  • func (w *Watcher) Uptime() time.Duration
  • func (w *Watcher) Wake() error
  • func (w *Watcher) WakeDebug() *zerolog.Event
  • func (w *Watcher) WakeError(err error)
  • func (w *Watcher) WakeTrace() *zerolog.Event

Types

type ForceCacheControl

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

func (*ForceCacheControl) Unwrap

func (f *ForceCacheControl) Unwrap() http.ResponseWriter

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

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

func (*Watcher) ContainerID

func (w *Watcher) ContainerID() string

func (*Watcher) ContainerName

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