k8s

package
v1.0.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 30, 2023 License: MIT Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func New

func New(kubeconfig string, namespace string, objectName string, identity string) (lockrun.LockingSystem, error)

func Parse

func Parse(args []string) (lockrun.LockingSystem, []string, error)

Types

type K8sLockingSystem

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

func (*K8sLockingSystem) Close

func (ls *K8sLockingSystem) Close()

func (*K8sLockingSystem) Run

func (ls *K8sLockingSystem) Run(
	ctx context.Context,
	onLockAcquired func(),
	onLockLost func(),
) error

func (*K8sLockingSystem) Stop

func (ls *K8sLockingSystem) Stop()

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL