persister

package

v0.0.0-...-7fa8e96 Latest Latest Go to latest Published: Feb 7, 2020 License: Apache-2.0 Imports: 14 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

This section is empty.

type Config struct {
	MetricsClientConfig metrics_client.Config
	StorageClientConfig storage.Config
	// contains filtered or unexported fields
}

Config contains the configuration require to create a Persister

func (cfg *Config) RegisterFlags(f *flag.FlagSet)

RegisterFlags adds the flags required to config this to the given FlagSet

type Persister struct {
	*sync.Mutex
	// contains filtered or unexported fields
}

Persister ingests payloads that are serialized into metrics and repeatedly sent to a metrics endpoint in the schema.MetricData format

func New(cfg *Config) (*Persister, error)

New constructs a new persister

func (p *Persister) IndexHandler(w http.ResponseWriter, r *http.Request)

IndexHandler serves up the metrics currently being persisted

func (p *Persister) Persist(rowKey string, metrics []*schema.MetricData) error

Persist add metrics to memory map for persisting

func (p *Persister) PersistHandler(w http.ResponseWriter, r *http.Request)

PersistHandler handles requests with payloads meant to be persisted

func (p *Persister) Push(quit chan struct{})

Push schedules sending metrics to the gateway

func (p *Persister) RemoveRowsHandler(w http.ResponseWriter, r *http.Request)

RemoveRowsHandler handles requests to remove payloads from the persister

func (p *Persister) Send() error

Send packages and sends metrics to the gateway

type RemoveRowsRequest struct {
	RowKeys []string `json:"rowkeys"`
}

RemoveRowsRequest contains the information required to remove metrics from the persister

Path	Synopsis
persist
storage