worker

Documentation

Index

• Constants
• Variables
• func AddHost(host string, name string)
• func AddHosts(hosts []string, name string)
• func GetHostName(host string) string
• func GetTarggetedPods() []v1.Pod
• func HostWithPort(host string) string
• func InitHosts()
• func PostStorageLimitToWorkers(payload PostStorageLimit) error
• func PostTargettedPodsToWorkers() error
• func RangeHosts(f func(key, value interface{}) bool)
• func RemoveHost(host string)
• func SetTargettedPods(pods []v1.Pod)
• type PostStorageLimit

Constants

const DefaultNodeName = "localhost"

const DefaultWorkerHost = "127.0.0.1"

const DefaultWorkerPort = 8897

Variables

var RemovedDefaultHost bool

Functions

func AddHost

func AddHost(host string, name string)

func AddHosts

func AddHosts(hosts []string, name string)

func GetHostName

func GetHostName(host string) string

func GetTarggetedPods

func GetTarggetedPods() []v1.Pod

func HostWithPort

func HostWithPort(host string) string

func InitHosts

func InitHosts()

func PostStorageLimitToWorkers

func PostStorageLimitToWorkers(payload PostStorageLimit) error

func PostTargettedPodsToWorkers

func PostTargettedPodsToWorkers() error

func RangeHosts

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

func RemoveHost

func RemoveHost(host string)

func SetTargettedPods

func SetTargettedPods(pods []v1.Pod)

Types

type PostStorageLimit

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