Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Auditor ¶
type Auditor struct {
// contains filtered or unexported fields
}
An Auditor handles messages successfully submitted to the intake
func (*Auditor) Channel ¶
Channel returns the channel to use to communicate with the auditor or nil if the auditor is currently stopped.
func (*Auditor) GetOffset ¶
GetOffset returns the last committed offset for a given identifier, returns an empty string if it does not exist.
func (*Auditor) GetTailingMode ¶
GetTailingMode returns the last committed offset for a given identifier, returns an empty string if it does not exist.
type JSONRegistry ¶
type JSONRegistry struct { Version int Registry map[string]RegistryEntry }
JSONRegistry represents the registry that will be written on disk
Click to show internal directories.
Click to hide internal directories.