kafka

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 kafka source
	ErrNoSrc = fmt.Errorf("No source kafka details provided")
)

Types

type Aggregator

type Aggregator struct {
	Kafka *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 kafka details 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 {
	Broker string
	Topic  string
}

Opts hold configuration for the kafka publisheru