log

Documentation

Index

• func App(ctx context.Context, app *apiv1.App, output chan<- Message, options *Options) error
• func Container(ctx context.Context, pod *corev1.Pod, name string, output chan<- Message, ...) (err error)
• func Output(ctx context.Context, c client.Client, name string, opts *client.LogOptions) error
• func Pod(ctx context.Context, pod *corev1.Pod, output chan<- Message, options *Options) error
• func SinceLogCheck(since string, msg v1.LogMessage) (bool, error)
• type Message
• type Options
  • func (o *Options) Complete() (*Options, error)

Functions

func App

func App(ctx context.Context, app *apiv1.App, output chan<- Message, options *Options) error

func Container

func Container(ctx context.Context, pod *corev1.Pod, name string, output chan<- Message, options *Options) (err error)

func Output

func Output(ctx context.Context, c client.Client, name string, opts *client.LogOptions) error

func Pod

func Pod(ctx context.Context, pod *corev1.Pod, output chan<- Message, options *Options) error

func SinceLogCheck

func SinceLogCheck(since string, msg v1.LogMessage) (bool, error)

Types

type Message

type Message struct {
	Line          string
	Pod           *corev1.Pod
	ContainerName string
	Time          time.Time

	Err error
}

type Options

type Options struct {
	RestConfig       *rest.Config
	Client           client.WithWatch
	PodClient        v12.PodsGetter
	Tail             *int64
	Follow           bool
	ContainerReplica string
	Container        string
}

func (*Options) Complete

func (o *Options) Complete() (*Options, error)