worker

package
v0.6.7 Latest Latest
Warning

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

Go to latest
Published: Feb 14, 2023 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

View Source
const DefaultNodeName = "localhost"
View Source
const DefaultWorkerHost = "127.0.0.1"
View Source
const DefaultWorkerPort = 8897

Variables

View Source
var RemovedDefaultHost bool

Functions

func AddHost

func AddHost(host string, name string)

func AddHosts

func AddHosts(hosts []string, name string)

func CheckWorkersSpawn added in v0.6.6

func CheckWorkersSpawn() error

func GetHostName added in v0.4.0

func GetHostName(host string) string

func GetStorageLimit added in v0.6.4

func GetStorageLimit() int64

func GetTargetedPods added in v0.6.2

func GetTargetedPods() []v1.Pod

func HostWithPort

func HostWithPort(host string) string

func InitHosts

func InitHosts()

func Len added in v0.6.5

func Len() uint

func PostStorageLimitToWorkers added in v0.5.0

func PostStorageLimitToWorkers() error

func PostTargetedPodsToWorkers added in v0.6.0

func PostTargetedPodsToWorkers() error

func RangeHosts

func RangeHosts(f func(key, value interface{}) bool)

func RemoveHost

func RemoveHost(host string)

func SetStorageLimit added in v0.6.4

func SetStorageLimit(limit int64)

func SetTargetedPods added in v0.6.0

func SetTargetedPods(pods []v1.Pod)

func UpdateWorkers added in v0.6.4

func UpdateWorkers() (err error)

Types

type PostStorageLimit added in v0.5.0

type PostStorageLimit struct {
	Limit int64 `json:"limit"`
}

Jump to

Keyboard shortcuts

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