app

Documentation

Overview

msh is a minimal mesos v1 scheduler; it executes a shell command on a mesos agent.

Index

• Constants
• func IsErrSuccess(err error) bool
• type App
  • func New(c Config) *App
  • func (app *App) Run(ctx context.Context) error
• type Config
  • func DefaultConfig() Config
  • func (c *Config) RegisterFlags(fs *flag.FlagSet)
• type ExitError
  • func (e ExitError) Error() string

Constants

const (
	RFC3339a = "20060102T150405Z0700"
)

Functions

func IsErrSuccess

func IsErrSuccess(err error) bool

Types

type App

type App struct {
	Config
	// contains filtered or unexported fields
}

func New

func New(c Config) *App

func (*App) Run

func (app *App) Run(ctx context.Context) error

type Config

type Config struct {
	FrameworkName       string
	TaskName            string
	MesosMaster         string // MesosMaster is formatted as host:port
	User                string
	Role                string
	CPUs                float64
	Memory              float64
	TTY                 bool
	Pod                 bool
	Interactive         bool
	Command             []string // Command must not be empty.
	Log                 func(string, ...interface{})
	Silent              bool
	AdditionalResources mesos.Resources
}

func DefaultConfig

func DefaultConfig() Config

func (*Config) RegisterFlags

func (c *Config) RegisterFlags(fs *flag.FlagSet)

type ExitError

type ExitError int

func (ExitError) Error

func (e ExitError) Error() string