neo

Documentation

Index

• func IndexBlockFile(f *os.File) (b *blockv1.BlockIndex, err error)
• 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)

Functions

func IndexBlockFile

func IndexBlockFile(f *os.File) (b *blockv1.BlockIndex, err error)

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)