Documentation
¶
Index ¶
- func GetJobExecutorKindByName(name string) string
- type Empty
- func (e *Empty) Cancel(ctx context.Context, spec interface{}) (interface{}, error)
- func (e *Empty) Create(ctx context.Context, specObj interface{}) (interface{}, error)
- func (e *Empty) Destroy(ctx context.Context, spec interface{}) error
- func (e *Empty) Inspect(ctx context.Context, spec interface{}) (interface{}, error)
- func (e *Empty) Kind() executortypes.Kind
- func (e *Empty) Name() executortypes.Name
- func (e *Empty) Remove(ctx context.Context, spec interface{}) error
- func (e *Empty) Status(ctx context.Context, specObj interface{}) (apistructs.StatusDesc, error)
- func (e *Empty) Update(ctx context.Context, specObj interface{}) (interface{}, error)
- type Manager
- func (m *Manager) Get(name executortypes.Name) (executortypes.Executor, error)
- func (m *Manager) GetByKind(kind executortypes.Kind) []executortypes.Executor
- func (m *Manager) GetExecutorConfigs(name executortypes.Name) (*executorconfig.ExecutorWholeConfigs, error)
- func (m *Manager) ListExecutors() []executortypes.Executor
- func (m *Manager) Pool(name executortypes.Name) *goroutinepool.GoroutinePool
- func (m *Manager) PrintPoolUsage()
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetJobExecutorKindByName ¶
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) Kind ¶
func (e *Empty) Kind() executortypes.Kind
func (*Empty) Name ¶
func (e *Empty) Name() executortypes.Name
func (*Empty) Status ¶
func (e *Empty) Status(ctx context.Context, specObj interface{}) (apistructs.StatusDesc, 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 ¶
func (m *Manager) Get(name executortypes.Name) (executortypes.Executor, error)
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 (m *Manager) Pool(name executortypes.Name) *goroutinepool.GoroutinePool
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 |
Click to show internal directories.
Click to hide internal directories.