reader

Documentation

Index

• type Docker
  • func NewDocker(params DockerParams) *Docker
  • func (d *Docker) ReadLogs(ctx context.Context, params types.ReadLogsParams) error
  • func (d *Docker) ReaderID() types.ReaderID
• type DockerContainer
  • func NewDockerContainer(params DockerContainerParams) *DockerContainer
  • func (d *DockerContainer) ReadLogs(ctx context.Context, params types.ReadLogsParams) error
  • func (d *DockerContainer) ReaderID() types.ReaderID
• type DockerContainerParams
• type DockerParams
• type Journald
  • func NewJournald(params JournaldParams) *Journald
  • func (d *Journald) ReadLogs(ctx context.Context, params types.ReadLogsParams) error
  • func (d *Journald) ReaderID() types.ReaderID
• type JournaldParams
• type ScanDockerContainerLogsParams

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.

func (*Docker) ReadLogs

func (d *Docker) ReadLogs(ctx context.Context, params types.ReadLogsParams) error

ReadLogs implements Reader.

func (*Docker) ReaderID

func (d *Docker) ReaderID() types.ReaderID

ReaderID implements Reader.

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.

func (*Journald) ReadLogs

func (d *Journald) ReadLogs(ctx context.Context, params types.ReadLogsParams) error

ReadLogs implements Reader.

func (*Journald) ReaderID

func (d *Journald) ReaderID() types.ReaderID

ReaderID implements Reader.

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.

type ScanDockerContainerLogsParams

type ScanDockerContainerLogsParams struct {
	WatcherID      types.ReaderID
	ContainerID    string
	Source         types.Source
	ReadLogsParams types.ReadLogsParams
	Reader         io.Reader
	Container      dtypes.ContainerJSON
}