internal

package

v0.0.0-...-cf400fd Latest Latest Go to latest Published: Jan 21, 2023 License: MIT Imports: 15 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

func InitLogger(filename string) (*zap.Logger, error)

InitLogger is used to construct the zap logger for logging info

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

App struct holds list dependencies for managing the watcher app

func InitApp(configStr string, logger *zap.Logger) (*App, error)

InitApp is used to construct app

default configStr: ~/.kube/config

func (app *App) Wait()

Wait is used for wait all runner done their tasks

func (app *App) WatchPodChanges(ctx context.Context, namespace string, callbacks ...callback) error

WatchPodChanges is used to watch changes all pods of a given namespace, and execute list callback function

func (app *App) WatchPodChangesAllNameSpaces(ctx context.Context, callbacks ...callback) error

WatchPodChangesAllNameSpaces is async function to watch all pod for all existed namespaces and execute list callback function

For the safe usage it should be controlled by Context, after context was done use function Wait to wait all runner done their tasks

type ParallelStdout struct {
	*os.File
}

ParallelStdout is the wrapped struct of *os.File to handle logic show log to the console

func NewParallelStdout(logFileName string) (*ParallelStdout, error)

NewParallelStdout used to init parallel logger: one for stdout console, two is for file log

func (ps *ParallelStdout) Write(p []byte) (n int, err error)

Write will show log to the console and run the parent `Write` implementation