manager

Documentation

Index

• Constants
• func DeleteExecutor(msg util.TaskMessage)
• type DownstreamController
  • func NewDownstreamController(messageChan chan model.Message) (*DownstreamController, error)
  • func (dc *DownstreamController) Start() error
• type Executor
  • func GetExecutor(msg util.TaskMessage) *Executor
  • func (e *Executor) HandleMessage(status v1alpha1.TaskStatus) error
• type ExecutorMachine
  • func GetExecutorMachine() *ExecutorMachine
  • func NewExecutorMachine(messageChan chan util.TaskMessage, downStreamChan chan model.Message) (*ExecutorMachine, error)
  • func (em *ExecutorMachine) Start() error
• type UpstreamController
  • func NewUpstreamController(dc *DownstreamController) (*UpstreamController, error)
  • func (uc *UpstreamController) Start() error

Constants

const TimeOutSecond = 300

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

type ExecutorMachine struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func GetExecutorMachine

func GetExecutorMachine() *ExecutorMachine

func NewExecutorMachine

func NewExecutorMachine(messageChan chan util.TaskMessage, downStreamChan chan model.Message) (*ExecutorMachine, error)

func (*ExecutorMachine) Start

func (em *ExecutorMachine) Start() error

Start ExecutorMachine

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