neo

Documentation

Index

• type ActiveBlock
  • func NewBlock(ctx context.Context, dir string, capacity int) *ActiveBlock
  • func (a *ActiveBlock) Close() error
  • func (a *ActiveBlock) Commit(domain string)
  • func (a *ActiveBlock) ReadBlock(id ulid.ULID, f func(parquet.ReaderAtSeeker))
  • func (a *ActiveBlock) WriteEntry(e *entry.Entry)
• type Sys

Types

type ActiveBlock

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

func NewBlock

func NewBlock(ctx context.Context, dir string, capacity int) *ActiveBlock

func (*ActiveBlock) Close

func (a *ActiveBlock) Close() error

func (*ActiveBlock) Commit

func (a *ActiveBlock) Commit(domain string)

func (*ActiveBlock) ReadBlock

func (a *ActiveBlock) ReadBlock(id ulid.ULID, f func(parquet.ReaderAtSeeker))

func (*ActiveBlock) WriteEntry

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

type Sys

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