auditorimpl

Documentation

Overview

Package auditorimpl implements the auditor component interface

Index

• Constants
• type Dependencies
• type JSONRegistry
• type Provides
  • func NewProvides(deps Dependencies) Provides
• type RegistryEntry

Constants

const DefaultRegistryFilename = "registry.json"

DefaultRegistryFilename is the default registry filename

Types

type Dependencies

type Dependencies struct {
	Log    log.Component
	Config config.Component
}

Dependencies defines the dependencies of the auditor

type JSONRegistry

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

JSONRegistry represents the registry that will be written on disk

type Provides

type Provides struct {
	Comp auditor.Component
}

Provides contains the auditor component

func NewProvides

func NewProvides(deps Dependencies) Provides

NewProvides creates a new auditor component

type RegistryEntry

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

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