runtimelog

type DockerComposeLogActionWriter ¶

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

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(dcc dockercompose.DockerComposeClient) *DockerComposeLogManager

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

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

func (r *HardCancelReader) LastReadTime() time.Time

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

type ObjectMeta ¶ added in v0.19.2

type ObjectMeta = metav1.ObjectMeta

type PodLogManager ¶

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

Translates EngineState into PodLogWatch API objects

func NewPodLogManager(client ctrlclient.Client) *PodLogManager

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

type PodLogStream ¶ added in v0.19.2

type PodLogStream = v1alpha1.PodLogStream

type PodLogStreamController ¶ added in v0.19.2

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

Reconciles the PodLogStream API object.

Collects logs from deployed containers.

func NewPodLogStreamController(client ctrlclient.Client, st store.RStore, kClient k8s.Client) *PodLogStreamController

func (c *PodLogStreamController) OnChange(ctx context.Context, st store.RStore, summary store.ChangeSummary)

type PodLogStreamCreateAction ¶ added in v0.19.2

type PodLogStreamCreateAction struct {
	PodLogStream *PodLogStream
}

func NewPodLogStreamCreateAction(s *PodLogStream) PodLogStreamCreateAction

func (PodLogStreamCreateAction) Action()

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

type PodLogStreamDeleteAction ¶ added in v0.19.2

type PodLogStreamDeleteAction struct {
	Name string
}

func (PodLogStreamDeleteAction) Action()

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

type PodLogStreamSpec ¶ added in v0.19.2

type PodLogStreamSpec = v1alpha1.PodLogStreamSpec

type PodLogWatch ¶

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