runtimelog

Documentation

Index

• func SpanIDForDCService(mn model.ManifestName) logstore.SpanID
• type DockerComposeLogActionWriter
  • 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, _ 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)

Functions

func SpanIDForDCService

func SpanIDForDCService(mn model.ManifestName) logstore.SpanID

Types

type DockerComposeLogActionWriter

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

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, _ 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)