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 DefaultLoggerImpl
  • func NewDefaultLogger(ctx context.Context, c client.Client) *DefaultLoggerImpl
  • func (d *DefaultLoggerImpl) AppStatus(ready bool, msg string, app *apiv1.App)
  • func (d *DefaultLoggerImpl) Container(timeStamp metav1.Time, containerName, line string)
  • func (d *DefaultLoggerImpl) Errorf(format string, args ...interface{})
  • func (d *DefaultLoggerImpl) Infof(format string, args ...interface{})
• 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 DefaultLoggerImpl

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

func NewDefaultLogger

func NewDefaultLogger(ctx context.Context, c client.Client) *DefaultLoggerImpl

func (*DefaultLoggerImpl) AppStatus

func (d *DefaultLoggerImpl) AppStatus(ready bool, msg string, app *apiv1.App)

func (*DefaultLoggerImpl) Container

func (d *DefaultLoggerImpl) Container(timeStamp metav1.Time, containerName, line string)

func (*DefaultLoggerImpl) Errorf

func (d *DefaultLoggerImpl) Errorf(format string, args ...interface{})

func (*DefaultLoggerImpl) Infof

func (d *DefaultLoggerImpl) Infof(format string, args ...interface{})

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)