neo

Documentation

Index

• type Ingest
  • func NewIngest(ctx context.Context, o objstore.Bucket, capacity int) *Ingest
  • func (a *Ingest) Close() error
  • func (a *Ingest) Run(ctx context.Context)
  • func (a *Ingest) WriteEntry(e *entry.Entry)
• type Sys

Types

type Ingest

type Ingest struct {
	context.Context
	// contains filtered or unexported fields
}

func NewIngest

func NewIngest(ctx context.Context, o objstore.Bucket, capacity int) *Ingest

func (*Ingest) Close

func (a *Ingest) Close() error

func (*Ingest) Run

func (a *Ingest) Run(ctx context.Context)

Implements worker.Job. Persists active blocks

func (*Ingest) WriteEntry

func (a *Ingest) WriteEntry(e *entry.Entry)

type Sys

type Sys struct {
	Timestamp time.Time
	Labels    map[string]string
	Name      string
	Value     float64
}