runtimelog

Documentation

Index

• type DockerComposeLogAction
  • func (DockerComposeLogAction) Action()
• 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 PodLogAction
  • func (PodLogAction) Action()
• type PodLogActionWriter
  • func (w PodLogActionWriter) Write(p []byte) (n int, err error)
• type PodLogManager
  • func NewPodLogManager(kClient k8s.Client) *PodLogManager
  • func (m *PodLogManager) OnChange(ctx context.Context, st store.RStore)
• type PodLogWatch

Types

type DockerComposeLogAction

type DockerComposeLogAction struct {
	store.LogEvent
}

func (DockerComposeLogAction) Action

func (DockerComposeLogAction) Action()

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 PodLogAction

type PodLogAction struct {
	store.LogEvent
	PodID k8s.PodID
}

func (PodLogAction) Action

func (PodLogAction) Action()

type PodLogActionWriter

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

func (PodLogActionWriter) Write

func (w PodLogActionWriter) Write(p []byte) (n int, err 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
}