logstream

Documentation

Index

• Constants
• type Callback
• type Canceler
• type Source
  • func FromNamespace(ctx context.Context, c kubernetes.Interface, namespace string) Source
  • func FromNamespaces(ctx context.Context, c kubernetes.Interface, namespaces []string) Source

Constants

const (

	// ChaosDuck is the well known name for the chaosduck.
	ChaosDuck = "chaosduck"
	// QueueProxy is the well known name for the queueproxy.
	QueueProxy = "queueproxy"
)

Types

type Callback

type Callback func(string, ...interface{})

Callback is invoked after pod logs are transformed

type Canceler

type Canceler func()

Canceler is the type of a function returned when a logstream is started to be deferred so that the logstream can be stopped when the test is complete.

type Source

type Source interface {
	// Start a log stream for the given resource name and invoke
	// the callback with the processed log
	StartStream(name string, l Callback) (Canceler, error)
}

Source allows you to create streams for a given resource name

func FromNamespace

func FromNamespace(ctx context.Context, c kubernetes.Interface, namespace string) Source

func FromNamespaces

func FromNamespaces(ctx context.Context, c kubernetes.Interface, namespaces []string) Source