libobserve

Documentation

Index

• Variables
• func InitOTEL(c *conf.OTLP) error
• func Server(observer *BuiltInObserver) middleware.Middleware
• type BuiltInObserver
  • func NewBuiltInObserver() (*BuiltInObserver, error)
  • func (o *BuiltInObserver) GetRequest() *ObserverCounter
  • func (o *BuiltInObserver) NewMQ(key string) *ObserverCounter
  • func (o *BuiltInObserver) Start(ctx context.Context) error
  • func (o *BuiltInObserver) Stop(_ context.Context) error
• type ObserverCounter
  • func NewObserverCounter() *ObserverCounter
  • func (o *ObserverCounter) Failure()
  • func (o *ObserverCounter) Success()

Variables

var ProviderSet = wire.NewSet(NewBuiltInObserver)

Functions

func InitOTEL

func InitOTEL(c *conf.OTLP) error

func Server

func Server(observer *BuiltInObserver) middleware.Middleware

Types

type BuiltInObserver

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

func NewBuiltInObserver

func NewBuiltInObserver() (*BuiltInObserver, error)

func (*BuiltInObserver) GetRequest

func (o *BuiltInObserver) GetRequest() *ObserverCounter

func (*BuiltInObserver) NewMQ

func (o *BuiltInObserver) NewMQ(key string) *ObserverCounter

func (*BuiltInObserver) Start

func (o *BuiltInObserver) Start(ctx context.Context) error

func (*BuiltInObserver) Stop

func (o *BuiltInObserver) Stop(_ context.Context) error

type ObserverCounter

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

func NewObserverCounter

func NewObserverCounter() *ObserverCounter

func (*ObserverCounter) Failure

func (o *ObserverCounter) Failure()

func (*ObserverCounter) Success

func (o *ObserverCounter) Success()