ingest

Documentation

Index

• type Ingester
  • func New(c *config.Applications, client storage.Client) *Ingester
  • func (i *Ingester) Connect() error
  • func (i *Ingester) EventsFailed() int64
  • func (i *Ingester) EventsProcessed() int64
  • func (i *Ingester) EventsSuccessful() int64
  • func (i *Ingester) GetEventStats() (int64, int64, int64)
  • func (i *Ingester) IngestMessage(msg []byte)
  • func (i *Ingester) QueueLen() int
  • func (i *Ingester) ResetStats()
  • func (i *Ingester) Run()

Types

type Ingester

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

func New

func New(c *config.Applications, client storage.Client) *Ingester

func (*Ingester) Connect

func (i *Ingester) Connect() error

Connect initiates the connection to the NATS server. It's separate from Run() so connection errors can be handled easily while still running the ingester in a goroutine.

func (*Ingester) EventsFailed

func (i *Ingester) EventsFailed() int64

Returns the total number of failed events by the ingester client

func (*Ingester) EventsProcessed

func (i *Ingester) EventsProcessed() int64

Returns the total number of events processed by the ingester client

func (*Ingester) EventsSuccessful

func (i *Ingester) EventsSuccessful() int64

Returns the total number of successful events by the ingester client

func (*Ingester) GetEventStats

func (i *Ingester) GetEventStats() (int64, int64, int64)

GetEventStats returns the statistics of the ingested events

func (*Ingester) IngestMessage

func (i *Ingester) IngestMessage(msg []byte)

Sends a message through the ingestion "pipeline" (aka our events channel)

func (*Ingester) QueueLen

func (i *Ingester) QueueLen() int

Returns the total number of event messages in the ingester client queue

func (*Ingester) ResetStats

func (i *Ingester) ResetStats()

ResetStats will set all event stats back to its initial state, zero.

func (*Ingester) Run

func (i *Ingester) Run()