file

Documentation

Index

• Variables
• type Aggregator
  • func NewAggregator(redisOpts *util.RedisOpts, opts *Opts) (*Aggregator, error)
  • func (a *Aggregator) Start() error
  • func (a *Aggregator) Stop()
• type Opts

Variables

var (
	// ErrNoSrc is returned when an Aggregator is created without a source directory
	ErrNoSrc = fmt.Errorf("No source directory provided")
)

Types

type Aggregator

type Aggregator struct {
	File *Opts

	Redis *util.RedisOpts
	// contains filtered or unexported fields
}

Aggregator is an aggregator implementation that reads from the filesystem

func NewAggregator

func NewAggregator(redisOpts *util.RedisOpts, opts *Opts) (*Aggregator, error)

NewAggregator returns a Aggregator initialized with the source path provided

func (*Aggregator) Start

func (a *Aggregator) Start() error

Start starts up the aggregation server

func (*Aggregator) Stop

func (a *Aggregator) Stop()

Stop shuts down the aggregation server

type Opts

type Opts struct {
	Source string
}

Opts hold config options for the file publisher