telemetry

Documentation

Index

• type Client
  • func NewClient() *Client
  • func (cl *Client) Shutdown(timeout time.Duration)
  • func (c *Client) Start(ctx context.Context) error
• type HealthProvider
• type HealthServer
  • func NewHealthServer() *HealthServer
  • func (srv *HealthServer) Register(provider HealthProvider)
  • func (srv *HealthServer) ServeHTTP(resp http.ResponseWriter, req *http.Request)
  • func (srv *HealthServer) Shutdown(timeout time.Duration)
  • func (srv *HealthServer) Start() error
• type OTELErrorHandler
  • func (h OTELErrorHandler) Handle(err error)
• type Span
  • func NewSpan(ctx context.Context, timeout time.Duration, req *kubefox.Event) (context.Context, Span)

Types

type Client

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

func NewClient

func NewClient() *Client

func (*Client) Shutdown

func (cl *Client) Shutdown(timeout time.Duration)

func (*Client) Start

func (c *Client) Start(ctx context.Context) error

type HealthProvider

type HealthProvider interface {
	Name() string
	IsHealthy(ctx context.Context) bool
}

type HealthServer

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

func NewHealthServer

func NewHealthServer() *HealthServer

func (*HealthServer) Register

func (srv *HealthServer) Register(provider HealthProvider)

func (*HealthServer) ServeHTTP

func (srv *HealthServer) ServeHTTP(resp http.ResponseWriter, req *http.Request)

func (*HealthServer) Shutdown

func (srv *HealthServer) Shutdown(timeout time.Duration)

func (*HealthServer) Start

func (srv *HealthServer) Start() error

type OTELErrorHandler

type OTELErrorHandler struct {
	Log *logkf.Logger
}

func (OTELErrorHandler) Handle

func (h OTELErrorHandler) Handle(err error)

type Span

type Span interface {
	End(*kubefox.Event)
}

func NewSpan

func NewSpan(ctx context.Context, timeout time.Duration, req *kubefox.Event) (context.Context, Span)