schedutil

Documentation

Index

• Constants
• func BuildFrameworkInfo() *mesos.FrameworkInfo
• func BuildHTTPSched(creds credentials) calls.Caller
• func BuildWantsExecutorResources(executorCPU float64, executorMemory float64) (r mesos.Resources)
• func Forever(name string, jobRestartDelay time.Duration, counter xmetrics.Counter, ...)
• func LoadCredentials(username string, password string) (result credentials, err error)
• func PrepareExecutorInfo(execBinary, execImage string, wantsResources mesos.Resources, ...) (*mesos.ExecutorInfo, error)
• type Labels
  • func (labels *Labels) Set(value string) error
  • func (labels Labels) String() string
• type URL
  • func (u *URL) Set(value string) error

Constants

const AuthModeBasic = "basic"

Functions

func BuildFrameworkInfo

func BuildFrameworkInfo() *mesos.FrameworkInfo

func BuildHTTPSched

func BuildHTTPSched(creds credentials) calls.Caller

func BuildWantsExecutorResources

func BuildWantsExecutorResources(executorCPU float64, executorMemory float64) (r mesos.Resources)

func Forever

func Forever(name string, jobRestartDelay time.Duration, counter xmetrics.Counter, f func() error)

func LoadCredentials

func LoadCredentials(username string, password string) (result credentials, err error)

func PrepareExecutorInfo

func PrepareExecutorInfo(
	execBinary, execImage string,
	wantsResources mesos.Resources,
	jobRestartDelay time.Duration,
) (*mesos.ExecutorInfo, error)

Types

type Labels

type Labels []mesos.Label

func (*Labels) Set

func (labels *Labels) Set(value string) error

func (Labels) String

func (labels Labels) String() string

type URL

type URL struct{ url.URL }

func (*URL) Set

func (u *URL) Set(value string) error