reader

Documentation

Overview

The reader pkg is responsible for reading data from the store, building buckets from the data, and placing the buckets into a user-supplied channel.

Index

• type Reader
  • func New(cfg *conf.D, st store.Store) *Reader
  • func (r *Reader) Start(out chan *bucket.Bucket)

Types

type Reader

type Reader struct {
	Inbox  chan *bucket.Bucket
	Outbox chan *bucket.Bucket
	Mchan  *metchan.Channel
	// contains filtered or unexported fields
}

func New

func New(cfg *conf.D, st store.Store) *Reader

Sets the scan interval to 1s.

func (*Reader) Start

func (r *Reader) Start(out chan *bucket.Bucket)