persister

Documentation

Overview

package persister is a copy of github.com/lomik/go-carbon/persister with non essential stuff removed, and using a fork of go-whisper, which allows us to build on windows

this is a parser for graphite's storage-schemas.conf it supports old and new retention format see https://graphite.readthedocs.io/en/0.9.9/config-carbon.html#storage-schemas-conf based on https://github.com/grobian/carbonwriter but with some improvements

Index

• func ParseRetentionDefs(retentionDefs string) (whisper.Retentions, error)
• type Schema
• type WhisperSchemas
  • func ReadWhisperSchemas(filename string) (WhisperSchemas, error)
  • func (s WhisperSchemas) Len() int
  • func (s WhisperSchemas) Less(i, j int) bool
  • func (s WhisperSchemas) Match(metric string) (Schema, bool)
  • func (s WhisperSchemas) Swap(i, j int)

Functions

func ParseRetentionDefs

func ParseRetentionDefs(retentionDefs string) (whisper.Retentions, error)

ParseRetentionDefs parses retention definitions into a Retentions structure

Types

type Schema

type Schema struct {
	Name         string
	Pattern      *regexp.Regexp
	RetentionStr string
	Retentions   whisper.Retentions
	Priority     int64
}

Schema represents one schema setting

type WhisperSchemas

type WhisperSchemas []Schema

WhisperSchemas contains schema settings

func ReadWhisperSchemas

func ReadWhisperSchemas(filename string) (WhisperSchemas, error)

ReadWhisperSchemas reads and parses a storage-schemas.conf file and returns a sorted schemas structure see https://graphite.readthedocs.io/en/0.9.9/config-carbon.html#storage-schemas-conf

func (WhisperSchemas) Len

func (s WhisperSchemas) Len() int

func (WhisperSchemas) Less

func (s WhisperSchemas) Less(i, j int) bool

func (WhisperSchemas) Match

func (s WhisperSchemas) Match(metric string) (Schema, bool)

Match finds the schema for metric or returns false if none found

func (WhisperSchemas) Swap

func (s WhisperSchemas) Swap(i, j int)