runtimelog

Documentation

Index

• Constants
• func HandlePodLogStreamCreateAction(state *store.EngineState, action PodLogStreamCreateAction)
• func HandlePodLogStreamDeleteAction(state *store.EngineState, action PodLogStreamDeleteAction)
• func SpanIDForDCService(mn model.ManifestName) logstore.SpanID
• type ContainerLogStreamStatus
• 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)
• 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)
• type ObjectMeta
• type PodLogManager
  • func NewPodLogManager(client ctrlclient.Client) *PodLogManager
  • func (m *PodLogManager) OnChange(ctx context.Context, st store.RStore, summary store.ChangeSummary)
• type PodLogStream
• type PodLogStreamCreateAction
  • func NewPodLogStreamCreateAction(s *PodLogStream) PodLogStreamCreateAction
  • func (PodLogStreamCreateAction) Action()
  • func (a PodLogStreamCreateAction) Summarize(s *store.ChangeSummary)
• type PodLogStreamDeleteAction
  • func (PodLogStreamDeleteAction) Action()
  • func (a PodLogStreamDeleteAction) Summarize(s *store.ChangeSummary)
• type PodLogStreamSpec
• type PodLogStreamStatus

Constants

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

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

Functions

func HandlePodLogStreamCreateAction

func HandlePodLogStreamCreateAction(state *store.EngineState, action PodLogStreamCreateAction)

func HandlePodLogStreamDeleteAction

func HandlePodLogStreamDeleteAction(state *store.EngineState, action PodLogStreamDeleteAction)

func SpanIDForDCService

func SpanIDForDCService(mn model.ManifestName) logstore.SpanID

Types

type ContainerLogStreamStatus

type ContainerLogStreamStatus = v1alpha1.ContainerLogStreamStatus

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)

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)

type ObjectMeta

type ObjectMeta = metav1.ObjectMeta

type PodLogManager

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

Translates EngineState into PodLogWatch API objects

func NewPodLogManager

func NewPodLogManager(client ctrlclient.Client) *PodLogManager

func (*PodLogManager) OnChange

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

type PodLogStream

type PodLogStream = v1alpha1.PodLogStream

type PodLogStreamCreateAction

type PodLogStreamCreateAction struct {
	PodLogStream *PodLogStream
}

func NewPodLogStreamCreateAction

func NewPodLogStreamCreateAction(s *PodLogStream) PodLogStreamCreateAction

func (PodLogStreamCreateAction) Action

func (PodLogStreamCreateAction) Action()

func (PodLogStreamCreateAction) Summarize

func (a PodLogStreamCreateAction) Summarize(s *store.ChangeSummary)

type PodLogStreamDeleteAction

type PodLogStreamDeleteAction struct {
	Name string
}

func (PodLogStreamDeleteAction) Action

func (PodLogStreamDeleteAction) Action()

func (PodLogStreamDeleteAction) Summarize

func (a PodLogStreamDeleteAction) Summarize(s *store.ChangeSummary)

type PodLogStreamSpec

type PodLogStreamSpec = v1alpha1.PodLogStreamSpec

type PodLogStreamStatus

type PodLogStreamStatus = v1alpha1.PodLogStreamStatus