monitor

package
v0.0.0-...-996fa4a Latest Latest
Warning

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

Go to latest
Published: Feb 2, 2024 License: AGPL-3.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type HTTP

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

HTTP represents a storage which publishes stats over HTTP.

func NewHTTP

func NewHTTP(snapshotter stats.Snapshotter) *HTTP

NewHTTP creates a new HTTP stats sink.

func (*HTTP) Close

func (s *HTTP) Close() error

Close gracefully terminates the storage and ensures that every related resource is properly disposed.

func (*HTTP) Configure

func (s *HTTP) Configure(config map[string]interface{}) (err error)

Configure configures the storage. The config parameter provided is loosely typed, since various storage mechanisms will require different configurations.

func (*HTTP) Name

func (s *HTTP) Name() string

Name returns the name of the provider.

type Noop

type Noop struct{}

Noop represents a storage which does nothing.

func NewNoop

func NewNoop() *Noop

NewNoop creates a new no-op storage.

func (*Noop) Close

func (s *Noop) Close() error

Close gracefully terminates the storage and ensures that every related resource is properly disposed.

func (*Noop) Configure

func (s *Noop) Configure(config map[string]interface{}) error

Configure configures the storage. The config parameter provided is loosely typed, since various storage mechanisms will require different configurations.

func (*Noop) Name

func (s *Noop) Name() string

Name returns the name of the provider.

type Prometheus

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

Prometheus represents a storage which publishes stats to a statsd sink.

func NewPrometheus

func NewPrometheus(snapshotter stats.Snapshotter, mux *http.ServeMux) *Prometheus

NewPrometheus creates a new prometheus endpoint.

func (*Prometheus) Close

func (p *Prometheus) Close() error

Close gracefully terminates the storage and ensures that every related resource is properly disposed.

func (*Prometheus) Configure

func (p *Prometheus) Configure(config map[string]interface{}) (err error)

Configure configures the storage. The config parameter provided is loosely typed, since various storage mechanisms will require different configurations.

func (*Prometheus) Name

func (p *Prometheus) Name() string

Name returns the name of the provider.

type Self

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

Self represents a storage which self-publishes stats.

func NewSelf

func NewSelf(snapshotter stats.Snapshotter, selfPublish func(string, []byte)) *Self

NewSelf creates a new self-publishing stats sink.

func (*Self) Close

func (s *Self) Close() error

Close gracefully terminates the storage and ensures that every related resource is properly disposed.

func (*Self) Configure

func (s *Self) Configure(config map[string]interface{}) error

Configure configures the storage. The config parameter provided is loosely typed, since various storage mechanisms will require different configurations.

func (*Self) Name

func (s *Self) Name() string

Name returns the name of the provider.

type Statsd

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

Statsd represents a storage which publishes stats to a statsd sink.

func NewStatsd

func NewStatsd(snapshotter stats.Snapshotter, nodeID string) *Statsd

NewStatsd creates a new statsd sink.

func (*Statsd) Close

func (s *Statsd) Close() error

Close gracefully terminates the storage and ensures that every related resource is properly disposed.

func (*Statsd) Configure

func (s *Statsd) Configure(config map[string]interface{}) (err error)

Configure configures the storage. The config parameter provided is loosely typed, since various storage mechanisms will require different configurations.

func (*Statsd) Name

func (s *Statsd) Name() string

Name returns the name of the provider.

type Storage

type Storage interface {
	config.Provider
	io.Closer
}

Storage represents a message storage contract that message storage provides must fulfill.

Jump to

Keyboard shortcuts

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