runtimelog

package
v0.19.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 7, 2021 License: Apache-2.0 Imports: 25 Imported by: 0

Documentation

Index

Constants

View Source 
const IstioInitContainerName = container.Name("istio-init")
View Source 
const IstioSidecarContainerName = container.Name("istio-proxy")

Variables

This section is empty.

Functions

func HandlePodLogStreamCreateAction added in v0.19.2 

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

func HandlePodLogStreamDeleteAction added in v0.19.2 

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

func SpanIDForDCService added in v0.10.24 

func SpanIDForDCService(mn model.ManifestName) logstore.SpanID

func SpanIDForPod added in v0.10.24 

func SpanIDForPod(podID k8s.PodID) logstore.SpanID

Types

type ContainerLogStreamStatus added in v0.19.3 

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 {
	// 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 added in v0.17.11 

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

func (*HardCancelReader) Read 

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 

func NewPodLogManager(client ctrlclient.Client) *PodLogManager

func (*PodLogManager) OnChange 

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 added in v0.19.2 

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

func (*PodLogStreamController) Reconcile added in v0.19.3 

func (r *PodLogStreamController) Reconcile(ctx context.Context, req reconcile.Request) (reconcile.Result, error)

Reconcile the given stream against what we're currently tracking.

func (*PodLogStreamController) SetClient added in v0.19.3 

func (c *PodLogStreamController) SetClient(client ctrlclient.Client)

func (*PodLogStreamController) SetupWithManager added in v0.19.3 

func (c *PodLogStreamController) SetupWithManager(mgr ctrl.Manager) error

func (*PodLogStreamController) TearDown added in v0.19.3 

func (c *PodLogStreamController) TearDown(ctx context.Context)

type PodLogStreamCreateAction added in v0.19.2 

type PodLogStreamCreateAction struct {
	PodLogStream *PodLogStream
}

func NewPodLogStreamCreateAction added in v0.19.2 

func NewPodLogStreamCreateAction(s *PodLogStream) PodLogStreamCreateAction

func (PodLogStreamCreateAction) Action added in v0.19.2 

func (PodLogStreamCreateAction) Action()

func (PodLogStreamCreateAction) Summarize added in v0.19.2 

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

type PodLogStreamDeleteAction added in v0.19.2 

type PodLogStreamDeleteAction struct {
	Name string
}

func (PodLogStreamDeleteAction) Action added in v0.19.2 

func (PodLogStreamDeleteAction) Action()

func (PodLogStreamDeleteAction) Summarize added in v0.19.2 

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

type PodLogStreamSpec added in v0.19.2 

type PodLogStreamSpec = v1alpha1.PodLogStreamSpec

type PodLogStreamStatus added in v0.19.3 

type PodLogStreamStatus = v1alpha1.PodLogStreamStatus

type PodLogWatch 

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

type PodSource added in v0.19.3 

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

Helper struct that captures Pod changes and queues up a Reconcile() call for any PodLogStream watching that pod.

func NewPodSource added in v0.19.3 

func NewPodSource(ctx context.Context, kClient k8s.Client) *PodSource

func (*PodSource) Start added in v0.19.3 

func (s *PodSource) Start(ctx context.Context, handler handler.EventHandler, q workqueue.RateLimitingInterface, ps ...predicate.Predicate) error

func (*PodSource) TearDown added in v0.19.3 

func (s *PodSource) TearDown()

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.
JackTT - Gopher 🇻🇳