parser

Documentation

Overview

Package parser deals with parsing various incoming formats

Index

• type Parser
  • func New(log *logrus.Logger, s ParserStorage, exporter storage.MetricsExporter) *Parser
  • func (p *Parser) Put(ctx context.Context, in *PutInput) (err error, pErr error)
• type ParserStorage
• type PutInput

Types

type Parser

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

func New

func New(log *logrus.Logger, s ParserStorage, exporter storage.MetricsExporter) *Parser

func (*Parser) Put

func (p *Parser) Put(ctx context.Context, in *PutInput) (err error, pErr error)

Put takes parser.PutInput, turns it into storage.PutIntput and enqueues it for a write

type ParserStorage

type ParserStorage interface {
	storage.Putter
	storage.Enqueuer
}

type PutInput

type PutInput struct {
	Format            string
	ContentType       string
	Body              io.Reader
	MultipartBoundary string

	// these parameters are the same as the ones in storage.PutInput
	StartTime       time.Time
	EndTime         time.Time
	Key             *segment.Key
	SpyName         string
	SampleRate      uint32
	Units           string
	AggregationType string
}