Documentation
¶
Index ¶
Constants ¶
View Source
const TimeOutSecond = 300
Variables ¶
This section is empty.
Functions ¶
func DeleteExecutor ¶
func DeleteExecutor(msg util.TaskMessage)
Types ¶
type DownstreamController ¶
type DownstreamController struct {
// contains filtered or unexported fields
}
func NewDownstreamController ¶
func NewDownstreamController(messageChan chan model.Message) (*DownstreamController, error)
func (*DownstreamController) Start ¶
func (dc *DownstreamController) Start() error
Start DownstreamController
type Executor ¶
type Executor struct {
// contains filtered or unexported fields
}
func GetExecutor ¶
func GetExecutor(msg util.TaskMessage) *Executor
func (*Executor) HandleMessage ¶
func (e *Executor) HandleMessage(status v1alpha1.TaskStatus) error
type ExecutorMachine ¶
func GetExecutorMachine ¶
func GetExecutorMachine() *ExecutorMachine
func NewExecutorMachine ¶
func NewExecutorMachine(messageChan chan util.TaskMessage, downStreamChan chan model.Message) (*ExecutorMachine, error)
type UpstreamController ¶
type UpstreamController struct {
// contains filtered or unexported fields
}
UpstreamController subscribe messages from edge and sync to k8s api server
func NewUpstreamController ¶
func NewUpstreamController(dc *DownstreamController) (*UpstreamController, error)
NewUpstreamController create UpstreamController from config
func (*UpstreamController) Start ¶
func (uc *UpstreamController) Start() error
Start UpstreamController
Click to show internal directories.
Click to hide internal directories.