runtimelog

Documentation

Index

• type DockerComposeLogActionWriter
  • func (w *DockerComposeLogActionWriter) LastLogTime() time.Time
  • func (w *DockerComposeLogActionWriter) Write(p []byte) (n int, err error)
• type DockerComposeLogManager
  • func NewDockerComposeLogManager(dcc dockercompose.DockerComposeClient) *DockerComposeLogManager
  • func (m *DockerComposeLogManager) OnChange(ctx context.Context, st store.RStore, summary store.ChangeSummary) error
• type HardCancelReader
  • func NewHardCancelReader(ctx context.Context, reader io.Reader) *HardCancelReader
  • func (r *HardCancelReader) LastReadTime() time.Time
  • func (r *HardCancelReader) Read(b []byte) (int, error)

Types

type DockerComposeLogActionWriter

type DockerComposeLogActionWriter struct {
	// contains filtered or unexported fields
}

func (*DockerComposeLogActionWriter) LastLogTime

func (w *DockerComposeLogActionWriter) LastLogTime() time.Time

LastLogTime returns the timestamp of the last log message seen or zero time if none.

The last log message seen timestamp might be before the `since` argument, so was discarded.

This method is not goroutine-safe: it is intended to be used after the writer is done.

func (*DockerComposeLogActionWriter) Write

func (w *DockerComposeLogActionWriter) Write(p []byte) (n int, err error)

type DockerComposeLogManager

type DockerComposeLogManager struct {
	// contains filtered or unexported fields
}

Collects logs from running docker-compose services.

func NewDockerComposeLogManager

func NewDockerComposeLogManager(dcc dockercompose.DockerComposeClient) *DockerComposeLogManager

func (*DockerComposeLogManager) OnChange

func (m *DockerComposeLogManager) OnChange(ctx context.Context, st store.RStore, summary store.ChangeSummary) error

type HardCancelReader

type HardCancelReader struct {
	Now func() time.Time
	// contains filtered or unexported fields
}

A reader that will stop returning data after its context has been canceled.

If any data is read from the underlying stream after the cancel happens, throw the data out.

func NewHardCancelReader

func NewHardCancelReader(ctx context.Context, reader io.Reader) *HardCancelReader

func (*HardCancelReader) LastReadTime

func (r *HardCancelReader) LastReadTime() time.Time

func (*HardCancelReader) Read

func (r *HardCancelReader) Read(b []byte) (int, error)