mesos

package
v0.4.1 Latest Latest
Warning

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

 Go to latest Published: Jul 22, 2022 License: GPL-3.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Scheduler added in v0.4.0 

type Scheduler struct {
	Config    *cfg.Config
	Framework *mesosutil.FrameworkConfig
	Client    *http.Client
	Req       *http.Request
	API       *api.API
}

Scheduler include all the current vars and global config

func Subscribe 

func Subscribe(cfg *cfg.Config, frm *mesosutil.FrameworkConfig) *Scheduler

Subscribe to the mesos backend

func (*Scheduler) EventLoop added in v0.4.0 

func (e *Scheduler) EventLoop()

EventLoop is the main loop for the mesos events.

func (*Scheduler) HandleOffers added in v0.4.0 

func (e *Scheduler) HandleOffers(offers *mesosproto.Event_Offers) error

HandleOffers will handle the offers event of mesos

func (*Scheduler) HandleUpdate added in v0.4.0 

func (e *Scheduler) HandleUpdate(event *mesosproto.Event) error

HandleUpdate will handle the offers event of mesos

func (*Scheduler) Heartbeat added in v0.4.0 

func (e *Scheduler) Heartbeat()

Heartbeat - The Apache Mesos heatbeat function

func (*Scheduler) HeartbeatLoop added in v0.4.1 

func (e *Scheduler) HeartbeatLoop()

HeartbeatLoop - The main loop for the hearbeat

func (*Scheduler) PrepareTaskInfoExecuteContainer added in v0.4.0 

func (e *Scheduler) PrepareTaskInfoExecuteContainer(agent mesosproto.AgentID, cmd mesosutil.Command) ([]mesosproto.TaskInfo, error)

PrepareTaskInfoExecuteContainer will create the TaskInfo Protobuf for Mesos

func (*Scheduler) Reconcile added in v0.4.0 

func (e *Scheduler) Reconcile()

Reconcile will reconcile the task states after the framework was restarted

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.