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.