mesos

package
v0.4.2 Latest Latest
Warning

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

 Go to latest Published: Nov 22, 2022 License: GPL-3.0 Imports: 17 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
	Vault     *vault.Vault
	Redis     *redis.Redis
}

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) GetNetworkInfo added in v0.4.2 

func (e *Scheduler) GetNetworkInfo(taskID string) []mesosproto.NetworkInfo

GetNetworkInfo get network info of task

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 nolint: gocyclo

func (*Scheduler) Reconcile added in v0.4.0 

func (e *Scheduler) Reconcile()

Reconcile will reconcile the task states after the framework was restarted

func (*Scheduler) ReconcileLoop added in v0.4.2 

func (e *Scheduler) ReconcileLoop()

ReconcileLoop - The reconcile loop to check periodicly the task state

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.