runtimelog

package

v0.13.6 Latest Latest Go to latest Published: May 14, 2020 License: Apache-2.0 Imports: 13 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

func SpanIDForDCService(mn model.ManifestName) logstore.SpanID

func SpanIDForPod(podID k8s.PodID) logstore.SpanID

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

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

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

Collects logs from running docker-compose services.

func NewDockerComposeLogManager(dcc dockercompose.DockerComposeClient) *DockerComposeLogManager

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

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(ctx context.Context, reader io.Reader) HardCancelReader

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

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

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

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

Collects logs from deployed containers.

func NewPodLogManager(kClient k8s.Client) *PodLogManager

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

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