Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetPrimaryPodAndContainer ¶
func GetPrimaryPodAndContainer(logContext *core.LogContext) (*core.PodLogContext, *core.ContainerContext, error)
GetPrimaryPodAndContainer finds the primary pod and container from a LogContext.
Types ¶
type K8sLogStreamer ¶
type K8sLogStreamer struct {
// contains filtered or unexported fields
}
K8sLogStreamer streams logs directly from Kubernetes pods.
func NewK8sLogStreamer ¶
func NewK8sLogStreamer(k8sConfig *rest.Config) (*K8sLogStreamer, error)
NewK8sLogStreamer creates a K8sLogStreamer from a Kubernetes REST config. It clears the timeout so that long-lived log streams are not interrupted.
func (*K8sLogStreamer) TailLogs ¶
func (s *K8sLogStreamer) TailLogs(ctx context.Context, logContext *core.LogContext, stream *connect.ServerStream[dataproxy.TailLogsResponse]) error
TailLogs streams log lines for the given LogContext from a Kubernetes pod.
type LogStreamer ¶
type LogStreamer interface {
TailLogs(ctx context.Context, logContext *core.LogContext, stream *connect.ServerStream[dataproxy.TailLogsResponse]) error
}
LogStreamer abstracts log fetching from different backends.
Source Files
Click to show internal directories.
Click to hide internal directories.