executor

package
v1.3.1 Latest Latest
Warning

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

Go to latest
Published: Oct 14, 2021 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetJobExecutorKindByName

func GetJobExecutorKindByName(name string) string

GetJobExecutorKindByName return executor Kind, e.g. METRONOME, according to user-defined job specification.

Types

type Empty

type Empty struct {
	ExecutorName executortypes.Name `json:"name,omitempty"`
	ExecutorKind executortypes.Kind `json:"kind,omitempty"`
}

func (*Empty) Cancel

func (e *Empty) Cancel(ctx context.Context, spec interface{}) (interface{}, error)

func (*Empty) Create

func (e *Empty) Create(ctx context.Context, specObj interface{}) (interface{}, error)

func (*Empty) Destroy

func (e *Empty) Destroy(ctx context.Context, spec interface{}) error

func (*Empty) Inspect

func (e *Empty) Inspect(ctx context.Context, spec interface{}) (interface{}, error)

func (*Empty) Kind

func (e *Empty) Kind() executortypes.Kind

func (*Empty) Name

func (e *Empty) Name() executortypes.Name

func (*Empty) Remove

func (e *Empty) Remove(ctx context.Context, spec interface{}) error

func (*Empty) Status

func (e *Empty) Status(ctx context.Context, specObj interface{}) (apistructs.StatusDesc, error)

func (*Empty) Update

func (e *Empty) Update(ctx context.Context, specObj interface{}) (interface{}, error)

type Manager

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

Manager is a executor manager, it holds the all executor instances.

func GetManager

func GetManager() *Manager

func (*Manager) Get

Get returns the executor with name.

func (*Manager) GetByKind

func (m *Manager) GetByKind(kind executortypes.Kind) []executortypes.Executor

GetByKind returns the executor instances with specify kind.

func (*Manager) GetExecutorConfigs

func (m *Manager) GetExecutorConfigs(name executortypes.Name) (*executorconfig.ExecutorWholeConfigs, error)

func (*Manager) ListExecutors

func (m *Manager) ListExecutors() []executortypes.Executor

ListExecutors returns the all executor instances.

func (*Manager) Pool

func (*Manager) PrintPoolUsage

func (m *Manager) PrintPoolUsage()

Directories

Path Synopsis
plugins
k8s
Package k8s implements managing the servicegroup by k8s cluster
Package k8s implements managing the servicegroup by k8s cluster
k8s/configmap
Package configmap manipulates the k8s api of configmap object
Package configmap manipulates the k8s api of configmap object
k8s/deployment
Package deployment manipulates the k8s api of deployment object
Package deployment manipulates the k8s api of deployment object
k8s/event
Package event manipulates the k8s api of event object Package event manipulates the k8s api of event object Package event manipulates the k8s api of event object
Package event manipulates the k8s api of event object Package event manipulates the k8s api of event object Package event manipulates the k8s api of event object
k8s/ingress
Package ingress manipulates the k8s api of ingress object
Package ingress manipulates the k8s api of ingress object
k8s/k8sapi
Package k8sapi contains necessary k8s types and objects
Package k8sapi contains necessary k8s types and objects
k8s/k8serror
Package k8serror encapsulates error of k8s object
Package k8serror encapsulates error of k8s object
k8s/k8sservice
Package k8sservice manipulates the k8s api of service object
Package k8sservice manipulates the k8s api of service object
k8s/namespace
Package namespace manipulates the k8s api of namespace object
Package namespace manipulates the k8s api of namespace object
k8s/persistentvolume
Package persistentvolume manipulates the k8s api of persistentvolume object
Package persistentvolume manipulates the k8s api of persistentvolume object
k8s/persistentvolumeclaim
Package persistentvolumeclaim manipulates the k8s api of persistentvolumeclaim object
Package persistentvolumeclaim manipulates the k8s api of persistentvolumeclaim object
k8s/pod
Package pod manipulates the k8s api of pod object
Package pod manipulates the k8s api of pod object
k8s/role
Package role manipulates the k8s api of role object
Package role manipulates the k8s api of role object
k8s/rolebinding
Package rolebinding manipulates the k8s api of rolebinding object
Package rolebinding manipulates the k8s api of rolebinding object
k8s/secret
Package secret manipulates the k8s api of secret object
Package secret manipulates the k8s api of secret object
k8s/serviceaccount
Package serviceaccount manipulates the k8s api of serviceaccount object
Package serviceaccount manipulates the k8s api of serviceaccount object
k8s/statefulset
Package statefulset manipulates the k8s api of statefulset object
Package statefulset manipulates the k8s api of statefulset object

Jump to

Keyboard shortcuts

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