auditor

Documentation

Index

• type Auditor
  • func New(inputChan chan message.Message, runPath string) *Auditor
  • func (a *Auditor) GetLastCommittedOffset(identifier string) int64
  • func (a *Auditor) GetLastCommittedTimestamp(identifier string) string
  • func (a *Auditor) Start()
  • func (a *Auditor) Stop()
• type JSONRegistry
• type RegistryEntry

Types

type Auditor

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

An Auditor handles messages successfully submitted to the intake

func New

func New(inputChan chan message.Message, runPath string) *Auditor

New returns an initialized Auditor

func (*Auditor) GetLastCommittedOffset

func (a *Auditor) GetLastCommittedOffset(identifier string) int64

GetLastCommittedOffset returns the last committed offset for a given identifier, returns 0 if it does not exist.

func (*Auditor) GetLastCommittedTimestamp

func (a *Auditor) GetLastCommittedTimestamp(identifier string) string

GetLastCommittedTimestamp returns the last committed offset for a given identifier

func (*Auditor) Start

func (a *Auditor) Start()

Start starts the Auditor

func (*Auditor) Stop

func (a *Auditor) Stop()

Stop stops the Auditor

type JSONRegistry

type JSONRegistry struct {
	Version  int
	Registry map[string]RegistryEntry
}

JSONRegistry represents the registry that will be written on disk

type RegistryEntry

type RegistryEntry struct {
	Timestamp   string
	Offset      int64
	LastUpdated time.Time
}

A RegistryEntry represents an entry in the registry where we keep track of current offsets