auditor

Documentation

Index

• type Auditor
  • func New(inputChan chan message.Message) *Auditor
  • func (a *Auditor) GetLastCommitedOffset(identifier string) (int64, int)
  • func (a *Auditor) GetLastCommitedTimestamp(identifier string) string
  • func (a *Auditor) Start()
• type JsonRegistry
• type JsonRegistryV0
• type RegistryEntry
• type RegistryEntryV0

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) *Auditor

New returns an initialized Auditor

func (*Auditor) GetLastCommitedOffset

func (a *Auditor) GetLastCommitedOffset(identifier string) (int64, int)

GetLastCommitedOffset returns the last commited offset for a given identifier

func (*Auditor) GetLastCommitedTimestamp

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

GetLastCommitedTimestamp returns the last commited offset for a given identifier

func (*Auditor) Start

func (a *Auditor) Start()

Start starts the Auditor

type JsonRegistry

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

JsonRegistry represents the registry that will be written on disk

type JsonRegistryV0

type JsonRegistryV0 struct {
	Version  int
	Registry map[string]RegistryEntryV0
}

type RegistryEntry

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

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

type RegistryEntryV0

type RegistryEntryV0 struct {
	Path      string
	Timestamp time.Time
	Offset    int64
}