ingress

Documentation

Index

• type Buffer
  • func NewBuffer(size int) *Buffer
  • func (d *Buffer) Alert(missed int)
  • func (d *Buffer) Next() *events.Envelope
  • func (d *Buffer) Set(e *events.Envelope)
  • func (d *Buffer) TryNext() (*events.Envelope, bool)
• type Inc
• type Ingestor
  • func NewIngestor(msgs <-chan *events.Envelope, s Set) *Ingestor
  • func (i *Ingestor) Run()
• type Next
• type Processor
  • func NewProcessor(n Next, i Inc, includeRouterLogs bool) *Processor
  • func (p *Processor) Run()
• type Set

Types

type Buffer

type Buffer struct {
	// contains filtered or unexported fields
}

Buffer is a simple wrapper around the go-diode for the events.Envelope type.

func NewBuffer

func NewBuffer(size int) *Buffer

NewBuffer initializes and returns with given size.

func (*Buffer) Alert

func (d *Buffer) Alert(missed int)

Alert is used by the internal diode. When envelopes are dropped we simply log a message noting how many envelopes were dropped.

func (*Buffer) Next

func (d *Buffer) Next() *events.Envelope

Next reads and returns the next envelope. This method will block until an envelope is available.

func (*Buffer) Set

func (d *Buffer) Set(e *events.Envelope)

Set adds an envelope to the buffer.

func (*Buffer) TryNext

func (d *Buffer) TryNext() (*events.Envelope, bool)

TryNext reads and returns the next envelope. This method will not block, if there is no envelope to read it will return nil for the envelope and a boolean of false.

type Inc

type Inc func(string)

Inc is a func that updates a counter for a given ID

type Ingestor

type Ingestor struct {
	// contains filtered or unexported fields
}

Ingestor will read envelopes off of a channel and write them to a given buffer.

func NewIngestor

func NewIngestor(msgs <-chan *events.Envelope, s Set) *Ingestor

NewIngestor returns an initialized Ingestor.

func (*Ingestor) Run

func (i *Ingestor) Run()

Run will start ingesting enveloeps off of the Ingestors message channel and writing them to the setter func. This method will block until the messages channel is closed.

type Next

type Next func() *events.Envelope

Next is a func that reads an envelope off of a buffer.

type Processor

type Processor struct {
	// contains filtered or unexported fields
}

Processor will read data from the Diode and update values in the store

func NewProcessor

func NewProcessor(n Next, i Inc, includeRouterLogs bool) *Processor

NewProcessor initializes a new Processor.

func (*Processor) Run

func (p *Processor) Run()

Run will read events.Envelopes from the processors next func and increment the counter for the Envelopes source instance. This is a blocking method that will run indefinitely.

type Set

type Set func(*events.Envelope)

Set is a func used by the Ingestor to write envelopes to.