worker

Documentation

Index

• Constants
• Variables
• func AddHost(host string, name string)
• func AddHosts(hosts []string, name string)
• func DeleteScriptToWorkers(key int64) (err error)
• func GetHostName(host string) string
• func GetLicense() bool
• func GetStorageLimit() int64
• func GetTargetedPods() []v1.Pod
• func HostWithPort(host string) string
• func InitHosts()
• func Len() uint
• func PostLicenseToWorkers() error
• func PostSetHostNodeToWorkers()
• func PostStorageLimitToWorkers() error
• func PostTargetedPodsToWorkers() error
• func PutEnvToWorkers(env map[string]interface{}) (err error)
• func PutScriptToWorkers(key int64, payload scripts.Script) (err error)
• func RangeHosts(f func(key, value interface{}) bool)
• func RemoveHost(host string)
• func SetLicense(v bool)
• func SetStorageLimit(limit int64)
• func SetTargetedPods(pods []v1.Pod)
• func UpdateWorkers() (err error)
• func UpdateWorkersAsync()
• type PostLicense
• type PostStorageLimit
• type Self

Constants

const DefaultNodeName = "localhost"

const DefaultWorkerHost = "127.0.0.1"

Variables

var RemovedDefaultHost bool

var WorkerPort = "8897"

Functions

func AddHost

func AddHost(host string, name string)

func AddHosts

func AddHosts(hosts []string, name string)

func DeleteScriptToWorkers

func DeleteScriptToWorkers(key int64) (err error)

func GetHostName

func GetHostName(host string) string

func GetLicense

func GetLicense() bool

func GetStorageLimit

func GetStorageLimit() int64

func GetTargetedPods

func GetTargetedPods() []v1.Pod

func HostWithPort

func HostWithPort(host string) string

func InitHosts

func InitHosts()

func Len

func Len() uint

func PostLicenseToWorkers

func PostLicenseToWorkers() error

func PostSetHostNodeToWorkers

func PostSetHostNodeToWorkers()

func PostStorageLimitToWorkers

func PostStorageLimitToWorkers() error

func PostTargetedPodsToWorkers

func PostTargetedPodsToWorkers() error

func PutEnvToWorkers

func PutEnvToWorkers(env map[string]interface{}) (err error)

func PutScriptToWorkers

func PutScriptToWorkers(key int64, payload scripts.Script) (err error)

func RangeHosts

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

func RemoveHost

func RemoveHost(host string)

func SetLicense

func SetLicense(v bool)

func SetStorageLimit

func SetStorageLimit(limit int64)

func SetTargetedPods

func SetTargetedPods(pods []v1.Pod)

func UpdateWorkers

func UpdateWorkers() (err error)

func UpdateWorkersAsync

func UpdateWorkersAsync()

Types

type PostLicense

type PostLicense struct {
	License bool `json:"license"`
}

type PostStorageLimit

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

type Self

type Self struct {
	Host string `json:"host"`
	Node string `json:"node"`
}