infra

package
v0.8.0 Latest Latest
Warning

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

 Go to latest Published: Oct 4, 2023 License: GPL-3.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	KeyPrefix   = "K_"
	CountPrefix = "C_"
	MinPrefix   = "M_"
)
View Source 
const Version string = "1"

Version of the YAML strcuture.

Variables

View Source 
var (
	// ErrConfigFileNotExists is returned when a config file doesn't exist.
	ErrConfigFileNotExists = errors.New("error config file does not exist")

	// ErrConfigInvalidVersion is returned when a config file has an invalid version.
	ErrConfigInvalidVersion = errors.New("invalid version in config file")

	// ErrConfigInvalidConstraintType is returned when a config file has an invalid constraint type.
	ErrConfigInvalidConstraintType = errors.New("invalid constraint type in config file")

	// ErrConfigInvalidConstraintTarget is returned when a config file has an invalid constraint target.
	ErrConfigInvalidConstraintTarget = errors.New("invalid constraint target in config file")
)
View Source 
var (
	TotalKey   = []byte("TOTAL")   //nolint:gochecknoglobals
	NilKey     = []byte("NIL")     //nolint:gochecknoglobals
	IgnoredKey = []byte("IGNORED") //nolint:gochecknoglobals
	MaskedKey  = []byte("MASKED")  //nolint:gochecknoglobals
)

Functions

func CreateConfig added in v0.2.0 

func CreateConfig(yamlconfig *YAMLStructure) (mimo.Config, error)

func CreatePreprocesses added in v0.4.0 

func CreatePreprocesses(yamlconfig *YAMLStructure, config *mimo.Config) error

func LoadConfig added in v0.2.0 

func LoadConfig(filename string) (mimo.Config, error)

func PebbleCounterBackendFactory added in v0.5.0 

func PebbleCounterBackendFactory(path string) (mimo.CounterBackend, error)

func PebbleMultimapFactory added in v0.3.0 

func PebbleMultimapFactory(path string) (mimo.Multimap, error)

Types

type DataRowReaderJSONLine 

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

func NewDataRowReaderJSONLineFromFile 

func NewDataRowReaderJSONLineFromFile(filename string) (*DataRowReaderJSONLine, error)

func (*DataRowReaderJSONLine) Close added in v0.8.0 

func (drr *DataRowReaderJSONLine) Close() error

func (*DataRowReaderJSONLine) ReadDataRow 

func (drr *DataRowReaderJSONLine) ReadDataRow() (mimo.DataRow, error)

type DataRowReaderWriterJSONLine added in v0.8.0 

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

func NewDataRowReaderJSONLine 

func NewDataRowReaderJSONLine(input io.Reader, output io.Writer) *DataRowReaderWriterJSONLine

func (*DataRowReaderWriterJSONLine) Close added in v0.8.0 

func (drr *DataRowReaderWriterJSONLine) Close() error

func (*DataRowReaderWriterJSONLine) ReadDataRow added in v0.8.0 

func (drr *DataRowReaderWriterJSONLine) ReadDataRow() (mimo.DataRow, error)

type PebbleCounterBackend added in v0.5.0 

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

func (PebbleCounterBackend) Close added in v0.5.0 

func (b PebbleCounterBackend) Close() error

func (PebbleCounterBackend) GetIgnoredCount added in v0.5.0 

func (b PebbleCounterBackend) GetIgnoredCount() int64

func (PebbleCounterBackend) GetMaskedCount added in v0.5.0 

func (b PebbleCounterBackend) GetMaskedCount() int64

func (PebbleCounterBackend) GetNilCount added in v0.5.0 

func (b PebbleCounterBackend) GetNilCount() int64

func (PebbleCounterBackend) GetTotalCount added in v0.5.0 

func (b PebbleCounterBackend) GetTotalCount() int64

func (PebbleCounterBackend) IncreaseIgnoredCount added in v0.5.0 

func (b PebbleCounterBackend) IncreaseIgnoredCount()

func (PebbleCounterBackend) IncreaseMaskedCount added in v0.5.0 

func (b PebbleCounterBackend) IncreaseMaskedCount()

func (PebbleCounterBackend) IncreaseNilCount added in v0.5.0 

func (b PebbleCounterBackend) IncreaseNilCount()

func (PebbleCounterBackend) IncreaseTotalCount added in v0.5.0 

func (b PebbleCounterBackend) IncreaseTotalCount()

type PebbleMultimapBackend added in v0.3.0 

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

func (PebbleMultimapBackend) Close added in v0.3.0 

func (b PebbleMultimapBackend) Close() error

func (PebbleMultimapBackend) GetKey added in v0.3.0 

func (b PebbleMultimapBackend) GetKey(key string) (map[string]int, error)

func (PebbleMultimapBackend) GetSamplesMono added in v0.5.0 

func (b PebbleMultimapBackend) GetSamplesMono(maxlen int) []mimo.Sample

func (PebbleMultimapBackend) GetSamplesMulti added in v0.5.0 

func (b PebbleMultimapBackend) GetSamplesMulti(maxlen int) []mimo.Sample

func (PebbleMultimapBackend) GetSize added in v0.3.0 

func (b PebbleMultimapBackend) GetSize(key string) int

func (PebbleMultimapBackend) NewSizeIterator added in v0.3.0 

func (b PebbleMultimapBackend) NewSizeIterator() mimo.SizeIterator

func (PebbleMultimapBackend) SetKey added in v0.3.0 

func (b PebbleMultimapBackend) SetKey(key string, value map[string]int) error

type PebbleSizeIterator added in v0.3.0 

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

func (PebbleSizeIterator) Close added in v0.3.0 

func (i PebbleSizeIterator) Close() error

func (PebbleSizeIterator) First added in v0.3.0 

func (i PebbleSizeIterator) First() bool

func (PebbleSizeIterator) Next added in v0.3.0 

func (i PebbleSizeIterator) Next() bool

func (PebbleSizeIterator) Valid added in v0.3.0 

func (i PebbleSizeIterator) Valid() bool

func (PebbleSizeIterator) Value added in v0.3.0 

func (i PebbleSizeIterator) Value() int

type ReportExporter 

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

func NewReportExporter 

func NewReportExporter() ReportExporter

func (ReportExporter) Export 

func (e ReportExporter) Export(report *mimo.Report, filename string) error

type SubscriberLogger 

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

func NewSubscriberLogger added in v0.6.0 

func NewSubscriberLogger(watch ...string) SubscriberLogger

func (SubscriberLogger) FirstNonMaskedValue 

func (sl SubscriberLogger) FirstNonMaskedValue(fieldname string, _ any)

func (SubscriberLogger) IncoherentValue added in v0.6.0 

func (sl SubscriberLogger) IncoherentValue(fieldname string, value any, pseudonym any)

func (SubscriberLogger) InconsistentPseudonym added in v0.6.0 

func (sl SubscriberLogger) InconsistentPseudonym(fieldname string, value any, pseudonym any)

func (SubscriberLogger) NewField 

func (sl SubscriberLogger) NewField(fieldname string)

func (SubscriberLogger) NonMaskedValue added in v0.6.0 

func (sl SubscriberLogger) NonMaskedValue(fieldname string, value any)

type YAMLColumn added in v0.2.0 

type YAMLColumn struct {
	Name              string                    `yaml:"name"`
	Exclude           []any                     `yaml:"exclude,omitempty"`
	ExcludeTemplate   string                    `yaml:"excludeTemplate,omitempty"`
	CoherentWith      []string                  `yaml:"coherentWith,omitempty"`
	CoherentSource    string                    `yaml:"coherentSource,omitempty"`
	Constraints       map[string]YAMLConstraint `yaml:"constraints,omitempty"`
	Alias             string                    `yaml:"alias,omitempty"`
	IgnoreDisparities bool                      `yaml:"ignoreDisparities,omitempty"`
}

YAMLColumn defines how to store a column config in YAML format.

type YAMLConstraint added in v0.2.0 

type YAMLConstraint map[string]float64

type YAMLPreprocess added in v0.4.0 

type YAMLPreprocess struct {
	Path  string `yaml:"path"`
	Value string `yaml:"value"`
}

type YAMLStructure added in v0.2.0 

type YAMLStructure struct {
	Version      string           `yaml:"version"`
	Columns      []YAMLColumn     `yaml:"metrics,omitempty"`
	Preprocesses []YAMLPreprocess `yaml:"preprocess,omitempty"`
}

YAMLStructure of the file.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.