container

Documentation

Index

• func NewLogEntry(container, line string) logEntry
• func NewLogStreamer(ctx context.Context, dashConfig config.Dash, key store.Key, sinceSeconds int64, ...) (*logStreamer, error)
• type LogEntry
• type LogStreamer

Functions

func NewLogEntry

func NewLogEntry(container, line string) logEntry

func NewLogStreamer

func NewLogStreamer(ctx context.Context, dashConfig config.Dash, key store.Key, sinceSeconds int64, containerNames ...string) (*logStreamer, error)

NewLogStreamer returns an instance of a logStream configured to stream logs for the given namespace/pod/container(s).

Types

type LogEntry

type LogEntry interface {
	Line() string
	Container() string
}

type LogStreamer

type LogStreamer interface {
	// Names returns a list of all of the containers for this log stream.
	Names() []string
	// Stream wraps the client-go GetLogs().Stream call for the configured
	// pods. Stream is responsible for aggregating the logs for all the
	// containers.
	Stream(context.Context, chan<- LogEntry)
	// Close closes all of the streams.
	Close(chan<- LogEntry)
}