logstreamer

Documentation

Index

• func FakeGetLogs(ctx context.Context, opts Options) (io.ReadCloser, error)
• func GetLogs(ctx context.Context, opts Options) (io.ReadCloser, error)
• func Stream(ctx context.Context, f GetLogsFunc, out io.Writer, ...) error
• type GetLogsFunc
• type Options

Functions

func FakeGetLogs

func FakeGetLogs(ctx context.Context, opts Options) (io.ReadCloser, error)

func GetLogs

func GetLogs(ctx context.Context, opts Options) (io.ReadCloser, error)

func Stream

func Stream(ctx context.Context, f GetLogsFunc, out io.Writer, podsClient typedv1.PodInterface, podName, containerName string) error

Types

type GetLogsFunc

type GetLogsFunc func(context.Context, Options) (io.ReadCloser, error)

Substitutable for testing

type Options

type Options struct {
	PodsClient    typedv1.PodInterface
	PodName       string
	PodLogOptions *corev1.PodLogOptions
}