Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

mesos

package

Go to main page

Versions in this module

v0

v0.4.2

May 7, 2024

v0.4.1

Mar 19, 2024

Changes in this version

+ type Mesos struct

+ Config *cfg.Config

+ Framework *cfg.FrameworkConfig

+ func New(cfg *cfg.Config, frm *cfg.FrameworkConfig) *Mesos

+ func (e *Mesos) Call(message *mesosproto.Call) error

+ func (e *Mesos) DeclineOffer(offerIds []mesosproto.OfferID) *mesosproto.Call

+ func (e *Mesos) DecodeTask(key string) cfg.Command

+ func (e *Mesos) GetAgentInfo(agentID string) cfg.MesosSlaves

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

+ func (e *Mesos) GetOffer(offers *mesosproto.Event_Offers, cmd cfg.Command) (mesosproto.Offer, []mesosproto.OfferID)

+ func (e *Mesos) GetTaskInfo(taskID string) cfg.MesosTasks

+ func (e *Mesos) IsRessourceMatched(ressource []mesosproto.Resource, cmd cfg.Command) bool

+ func (e *Mesos) Kill(taskID string, agentID string) error

+ func (e *Mesos) Revive()

+ func (e *Mesos) SuppressFramework()

v0.4.0

Nov 24, 2022

Changes in this version

+ type Scheduler struct

+ API *api.API

+ Client *http.Client

+ Config *cfg.Config

+ Framework *mesosutil.FrameworkConfig

+ Req *http.Request

+ func (e *Scheduler) CheckState()

+ func (e *Scheduler) CreateK3SServerString()

+ func (e *Scheduler) EventLoop()

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

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

+ func (e *Scheduler) Heartbeat()

+ func (e *Scheduler) HeartbeatLoop()

+ func (e *Scheduler) Reconcile()

+ func (e *Scheduler) ReconcileLoop()

+ func (e *Scheduler) StartDatastore(taskID string)

+ func (e *Scheduler) StartK3SAgent(taskID string)

+ func (e *Scheduler) StartK3SServer(taskID string)

v0.3.0

Apr 22, 2022

Changes in this version

+ func Heartbeat()

v0.2.0

Oct 16, 2021

Changes in this version

+ func Call(message *mesosproto.Call) error

+ func CreateK3SServerString()

+ func HandleOffers(offers *mesosproto.Event_Offers) error

+ func HandleUpdate(event *mesosproto.Event) error

+ func IsK3SServerRunning() bool

+ func K3SHeartbeat()

+ func Kill(taskID string) error

+ func Reconcile()

+ func Revive()

+ func SearchMissingEtcd(restart bool) bool

+ func SearchMissingK3SAgent(restart bool) bool

+ func SearchMissingK3SServer(restart bool) bool

+ func SetConfig(cfg *cfg.Config)

+ func StartEtcd(id int)

+ func StartK3SAgent(id int)

+ func StartK3SServer(id int)

+ func StatusEtcd(id int) *cfg.State

+ func StatusK3SAgent(id int) *cfg.State

+ func StatusK3SServer(id int) *cfg.State

+ func Subscribe() error