runtimelog

Documentation

Index

• Constants
• func SpanIDForDCService(mn model.ManifestName) logstore.SpanID
• func SpanIDForPod(podID k8s.PodID) 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)
• type HardCancelReader
  • func NewHardCancelReader(ctx context.Context, reader io.Reader) HardCancelReader
  • func (r HardCancelReader) Read(b []byte) (int, error)
• type PodLogActionWriter
  • func (w PodLogActionWriter) Write(level logger.Level, fields logger.Fields, p []byte) error
• type PodLogManager
  • func NewPodLogManager(kClient k8s.Client) *PodLogManager
  • func (m *PodLogManager) OnChange(ctx context.Context, st store.RStore)
• type PodLogWatch

Constants

const IstioInitContainerName = container.Name("istio-init")

const IstioSidecarContainerName = container.Name("istio-proxy")

Functions

func SpanIDForDCService

func SpanIDForDCService(mn model.ManifestName) logstore.SpanID

func SpanIDForPod

func SpanIDForPod(podID k8s.PodID) 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)

type HardCancelReader

type HardCancelReader struct {
	// 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) Read

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

type PodLogActionWriter

type PodLogActionWriter struct {
	Store        store.RStore
	PodID        k8s.PodID
	ManifestName model.ManifestName
}

func (PodLogActionWriter) Write

func (w PodLogActionWriter) Write(level logger.Level, fields logger.Fields, p []byte) error

type PodLogManager

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

Collects logs from deployed containers.

func NewPodLogManager

func NewPodLogManager(kClient k8s.Client) *PodLogManager

func (*PodLogManager) OnChange

func (m *PodLogManager) OnChange(ctx context.Context, st store.RStore)

type PodLogWatch

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