Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Docker ¶
type Docker struct {
// contains filtered or unexported fields
}
Docker is a Reader that can read Docker events.
func NewDocker ¶
func NewDocker(params DockerParams) *Docker
NewDocker creates a new instance of Docker.
type DockerContainer ¶
type DockerContainer struct {
// contains filtered or unexported fields
}
DockerContainer is a Reader that can read logs from a single docker container.
func NewDockerContainer ¶
func NewDockerContainer(params DockerContainerParams) *DockerContainer
NewDockerContainer creates a new instance of DockerContainer.
func (*DockerContainer) ReadLogs ¶
func (d *DockerContainer) ReadLogs(ctx context.Context, params types.ReadLogsParams) error
ReadLogs implements Reader.
func (*DockerContainer) ReaderID ¶
func (d *DockerContainer) ReaderID() types.ReaderID
ReaderID implements Reader.
type DockerContainerParams ¶
type DockerContainerParams struct { types.ReaderParams // ReaderParams contains common reader params. Client *client.Client // Client is the docker client to use. ContainerID string // ContainerID to read logs from. }
DockerContainer contains parameters for NewDockerContainer.
type DockerParams ¶
type DockerParams struct { types.ReaderParams // ReaderParams contains common reader params. Client *client.Client // Client is the docker client to use. Persister types.Persister // Persister to load/save container state. NewProcessor processor.Factory // NewProcessor creates a Processor for all messages. }
DockerParams contains parameters for NewDocker.
type Journald ¶
type Journald struct {
// contains filtered or unexported fields
}
Journald is a Reader that can read events from systemd's journal.
func NewJournald ¶
func NewJournald(params JournaldParams) *Journald
NewJournald creates a new instance of Journald.
type JournaldParams ¶
type JournaldParams struct { types.ReaderParams // ReaderParams contains common reader params. NewJournal func() (*sdjournal.Journal, error) // NewJournal creates a Journal to read from. }
JournaldParams contains parameters for NewJournald.
Click to show internal directories.
Click to hide internal directories.