realis

package module

Go to main page

Versions in this module

v2

v2.30.0

Jan 26, 2023

Changes in this version

type Client

+ func (r *Client) JobExists(key aurora.JobKey) (bool, error)

v2.29.0

Aug 24, 2022

Changes in this version

+ func MasterNodesFromZK(cluster Cluster) (map[string][]string, error)

+ func MasterNodesFromZKOpts(options ...ZKOpt) (map[string][]string, error)

+ func MesosMasterNodesFromZK(cluster Cluster) (map[string][]string, error)

+ func MesosMasterNodesFromZKOpts(options ...ZKOpt) (map[string][]string, error)

type Cluster

+ MesosZKPath string

v2.28.0

Aug 2, 2022

Changes in this version

+ func ResourcesToMap(resources []*aurora.Resource) map[string]float64

type Client

+ func (c *Client) AvailOfferReport() (OfferReport, error)

+ func (c *Client) FitTasks(taskConfig *aurora.TaskConfig, offers []Offer) (int64, error)

+ func (c *Client) GetSchedulerURL() string

+ func (c *Client) MaintenanceHosts() ([]string, error)

+ func (c *Client) Offers() ([]Offer, error)

+ type MaintenanceList struct

+ Drained []string

+ Draining map[string][]string

+ Scheduled []string

+ type Offer struct

+ AgentID struct{ ... }

+ Attributes []struct{ ... }

+ ExecutorIds []struct{ ... }

+ FrameworkID struct{ ... }

+ Hostname string

+ ID struct{ ... }

+ Resources []struct{ ... }

+ URL struct{ ... }

+ type OfferCount map[float64]int64

+ type OfferGroupReport map[string]OfferCount

+ type OfferReport map[string]OfferGroupReport

v2.27.0

Nov 2, 2021

v2.26.0

Oct 20, 2021

Changes in this version

type AuroraJob

+ func (j *AuroraJob) Production(production bool) *AuroraJob

type AuroraTask

+ func (t *AuroraTask) Production(production bool) *AuroraTask

type JobUpdate

+ func (j *JobUpdate) Production(production bool) *JobUpdate

v2.25.0

Sep 16, 2021

Changes in this version

type AuroraJob

+ func (j *AuroraJob) Priority(priority int32) *AuroraJob

type AuroraTask

+ func (t *AuroraTask) Priority(priority int32) *AuroraTask

type Client

+ func (c *Client) GetJobSummary(role string) (*aurora.JobSummaryResult_, error)

type JobUpdate

+ func (j *JobUpdate) Priority(priority int32) *JobUpdate

v2.22.2

Nov 17, 2020

Changes in this version

+ func MesosFromZKOpts(options ...ZKOpt) (string, error)

+ type MesosAddress struct

+ Hostname string

+ IP string

+ Port uint16

+ type MesosInstance struct

+ Address MesosAddress

+ Version string

v2.22.1

May 7, 2020

Changes in this version

type JobUpdate

+ func (j *JobUpdate) AddInstanceRange(first, last int32) *JobUpdate

+ func (j *JobUpdate) SlaAware(slaAware bool) *JobUpdate

+ func (j *JobUpdate) TaskMaxFailure(maxFail int32) *JobUpdate

v2.22.0

May 6, 2020

Changes in this version

+ func TerminalUpdateStates() []aurora.JobUpdateStatus

type Client

+ func (c *Client) MonitorAutoPausedUpdate(key aurora.JobUpdateKey, interval, timeout time.Duration) (int, error)

type JobUpdate

+ func (j *JobUpdate) BatchUpdateStrategy(autoPause bool, batchSize int32) *JobUpdate

+ func (j *JobUpdate) QueueUpdateStrategy(groupSize int32) *JobUpdate

+ func (j *JobUpdate) VariableBatchStrategy(autoPause bool, batchSizes ...int32) *JobUpdate

v2.21.4

Feb 19, 2020

v2.21.3

Feb 19, 2020

v2.21.2

Feb 19, 2020

Changes in this version

+ const VERSION

+ var ActiveJobUpdateStates = make(map[aurora.JobUpdateStatus]bool)

+ var ActiveStates = make(map[aurora.ScheduleStatus]bool)

+ var AwaitingPulseJobUpdateStates = make(map[aurora.JobUpdateStatus]bool)

+ var LiveStates = make(map[aurora.ScheduleStatus]bool)

+ var SlaveAssignedStates = make(map[aurora.ScheduleStatus]bool)

+ var TerminalStates = make(map[aurora.ScheduleStatus]bool)

+ func ExponentialBackoff(backoff Backoff, logger Logger, condition ConditionFunc) error

+ func GetCerts(certPath string) (*x509.CertPool, error)

+ func IsTemporary(err error) bool

+ func IsTimeout(err error) bool

+ func Jitter(duration time.Duration, maxFactor float64) time.Duration

+ func LeaderFromZK(cluster Cluster) (string, error)

+ func LeaderFromZKOpts(options ...ZKOpt) (string, error)

+ func LoadClusters(config string) (map[string]Cluster, error)

+ func ToRetryCount(err error) *retryErr

+ type AuroraJob struct

+ func NewJob() *AuroraJob

+ func (j *AuroraJob) AddDedicatedConstraint(role, name string) *AuroraJob

+ func (j *AuroraJob) AddLabel(key string, value string) *AuroraJob

+ func (j *AuroraJob) AddLimitConstraint(name string, limit int32) *AuroraJob

+ func (j *AuroraJob) AddNamedPorts(names ...string) *AuroraJob

+ func (j *AuroraJob) AddPorts(num int) *AuroraJob

+ func (j *AuroraJob) AddURIs(extract bool, cache bool, values ...string) *AuroraJob

+ func (j *AuroraJob) AddValueConstraint(name string, negated bool, values ...string) *AuroraJob

+ func (j *AuroraJob) AuroraTask() *AuroraTask

+ func (j *AuroraJob) BuildThermosPayload() error

+ func (j *AuroraJob) CPU(cpus float64) *AuroraJob

+ func (j *AuroraJob) Container(container Container) *AuroraJob

+ func (j *AuroraJob) CronCollisionPolicy(policy aurora.CronCollisionPolicy) *AuroraJob

+ func (j *AuroraJob) CronSchedule(cron string) *AuroraJob

+ func (j *AuroraJob) Disk(disk int64) *AuroraJob

+ func (j *AuroraJob) Environment(env string) *AuroraJob

+ func (j *AuroraJob) ExecutorData(data string) *AuroraJob

+ func (j *AuroraJob) ExecutorName(name string) *AuroraJob

+ func (j *AuroraJob) GPU(gpu int64) *AuroraJob

+ func (j *AuroraJob) GetInstanceCount() int32

+ func (j *AuroraJob) InstanceCount(instCount int32) *AuroraJob

+ func (j *AuroraJob) IsService(isService bool) *AuroraJob

+ func (j *AuroraJob) JobConfig() *aurora.JobConfiguration

+ func (j *AuroraJob) JobKey() aurora.JobKey

+ func (j *AuroraJob) MaxFailure(maxFail int32) *AuroraJob

+ func (j *AuroraJob) Name(name string) *AuroraJob

+ func (j *AuroraJob) PartitionPolicy(reschedule bool, delay int64) *AuroraJob

+ func (j *AuroraJob) RAM(ram int64) *AuroraJob

+ func (j *AuroraJob) Role(role string) *AuroraJob

+ func (j *AuroraJob) TaskConfig() *aurora.TaskConfig

+ func (j *AuroraJob) ThermosExecutor(thermos ThermosExecutor) *AuroraJob

+ func (j *AuroraJob) Tier(tier string) *AuroraJob

+ type AuroraTask struct

+ func NewTask() *AuroraTask

+ func TaskFromThrift(config *aurora.TaskConfig) *AuroraTask

+ func (t *AuroraTask) AddDedicatedConstraint(role, name string) *AuroraTask

+ func (t *AuroraTask) AddLabel(key string, value string) *AuroraTask

+ func (t *AuroraTask) AddLimitConstraint(name string, limit int32) *AuroraTask

+ func (t *AuroraTask) AddNamedPorts(names ...string) *AuroraTask

+ func (t *AuroraTask) AddPorts(num int) *AuroraTask

+ func (t *AuroraTask) AddURIs(extract bool, cache bool, values ...string) *AuroraTask

+ func (t *AuroraTask) AddValueConstraint(name string, negated bool, values ...string) *AuroraTask

+ func (t *AuroraTask) BuildThermosPayload() error

+ func (t *AuroraTask) CPU(cpus float64) *AuroraTask

+ func (t *AuroraTask) Clone() *AuroraTask

+ func (t *AuroraTask) Container(container Container) *AuroraTask

+ func (t *AuroraTask) Disk(disk int64) *AuroraTask

+ func (t *AuroraTask) Environment(env string) *AuroraTask

+ func (t *AuroraTask) ExecutorData(data string) *AuroraTask

+ func (t *AuroraTask) ExecutorName(name string) *AuroraTask

+ func (t *AuroraTask) GPU(gpu int64) *AuroraTask

+ func (t *AuroraTask) IsService(isService bool) *AuroraTask

+ func (t *AuroraTask) JobKey() aurora.JobKey

+ func (t *AuroraTask) MaxFailure(maxFail int32) *AuroraTask

+ func (t *AuroraTask) Name(name string) *AuroraTask

+ func (t *AuroraTask) PartitionPolicy(policy aurora.PartitionPolicy) *AuroraTask

+ func (t *AuroraTask) RAM(ram int64) *AuroraTask

+ func (t *AuroraTask) Role(role string) *AuroraTask

+ func (t *AuroraTask) TaskConfig() *aurora.TaskConfig

+ func (t *AuroraTask) ThermosExecutor(thermos ThermosExecutor) *AuroraTask

+ func (t *AuroraTask) Tier(tier string) *AuroraTask

+ type Backoff struct

+ Duration time.Duration

+ Factor float64

+ Jitter float64

+ Steps int

+ type Client struct

+ func NewClient(options ...ClientOption) (*Client, error)

+ func (c *Client) AbortJobUpdate(updateKey aurora.JobUpdateKey, message string) error

+ func (c *Client) AddInstances(instKey aurora.InstanceKey, count int32) error

+ func (c *Client) Close()

+ func (c *Client) CreateJob(auroraJob *AuroraJob) error

+ func (c *Client) CreateService(update *JobUpdate) (*aurora.StartJobUpdateResult_, error)

+ func (c *Client) DescheduleCronJob(key aurora.JobKey) error

+ func (c *Client) DrainHosts(hosts ...string) ([]*aurora.HostStatus, error)

+ func (c *Client) EndMaintenance(hosts ...string) ([]*aurora.HostStatus, error)

+ func (c *Client) FetchTaskConfig(instKey aurora.InstanceKey) (*aurora.TaskConfig, error)

+ func (c *Client) ForceExplicitTaskReconciliation(batchSize *int32) error

+ func (c *Client) ForceImplicitTaskReconciliation() error

+ func (c *Client) GetInstanceIds(key aurora.JobKey, states []aurora.ScheduleStatus) ([]int32, error)

+ func (c *Client) GetJobUpdateSummaries(jobUpdateQuery *aurora.JobUpdateQuery) (*aurora.GetJobUpdateSummariesResult_, error)

+ func (c *Client) GetJobs(role string) (*aurora.GetJobsResult_, error)

+ func (c *Client) GetPendingReason(query *aurora.TaskQuery) ([]*aurora.PendingReason, error)

+ func (c *Client) GetQuota(role string) (*aurora.GetQuotaResult_, error)

+ func (c *Client) GetTaskStatus(query *aurora.TaskQuery) ([]*aurora.ScheduledTask, error)

+ func (c *Client) GetTasksWithoutConfigs(query *aurora.TaskQuery) ([]*aurora.ScheduledTask, error)

+ func (c *Client) JobUpdateDetails(updateQuery aurora.JobUpdateQuery) ([]*aurora.JobUpdateDetails, error)

+ func (c *Client) KillInstances(key aurora.JobKey, instances ...int32) (bool, error)

+ func (c *Client) KillJob(key aurora.JobKey) error

+ func (c *Client) MaintenanceStatus(hosts ...string) (*aurora.MaintenanceStatusResult_, error)

+ func (c *Client) MonitorHostMaintenance(hosts []string, modes []aurora.MaintenanceMode, ...) (map[string]bool, error)

+ func (c *Client) MonitorInstances(key aurora.JobKey, instances int32, interval, timeout time.Duration) (bool, error)

+ func (c *Client) MonitorJobUpdate(updateKey aurora.JobUpdateKey, interval, timeout time.Duration) (bool, error)

+ func (c *Client) MonitorJobUpdateQuery(updateQuery aurora.JobUpdateQuery, interval time.Duration, ...) ([]*aurora.JobUpdateSummary, error)

+ func (c *Client) MonitorJobUpdateStatus(updateKey aurora.JobUpdateKey, desiredStatuses []aurora.JobUpdateStatus, ...) (aurora.JobUpdateStatus, error)

+ func (c *Client) MonitorScheduleStatus(key aurora.JobKey, instanceCount int32, ...) (bool, error)

+ func (c *Client) PauseJobUpdate(updateKey *aurora.JobUpdateKey, message string) error

+ func (c *Client) PerformBackup() error

+ func (c *Client) PulseJobUpdate(updateKey aurora.JobUpdateKey) (aurora.JobUpdatePulseStatus, error)

+ func (c *Client) RealisConfig() *clientConfig

+ func (c *Client) ReestablishConn() error

+ func (c *Client) RemoveInstances(key aurora.JobKey, count int) error

+ func (c *Client) RestartInstances(key aurora.JobKey, instances ...int32) error

+ func (c *Client) RestartJob(key aurora.JobKey) error

+ func (c *Client) ResumeJobUpdate(updateKey aurora.JobUpdateKey, message string) error

+ func (c *Client) RollbackJobUpdate(key aurora.JobUpdateKey, message string) error

+ func (c *Client) SLADrainHosts(policy *aurora.SlaPolicy, timeout int64, hosts ...string) ([]*aurora.HostStatus, error)

+ func (c *Client) ScheduleCronJob(auroraJob *AuroraJob) error

+ func (c *Client) SetQuota(role string, cpu *float64, ramMb *int64, diskMb *int64) error

+ func (c *Client) Snapshot() error

+ func (c *Client) StartCronJob(key aurora.JobKey) error

+ func (c *Client) StartJobUpdate(updateJob *JobUpdate, message string) (*aurora.StartJobUpdateResult_, error)

+ func (c *Client) StartMaintenance(hosts ...string) ([]*aurora.HostStatus, error)

+ type ClientOption func(*clientConfig)

+ func BackOff(b Backoff) ClientOption

+ func BasicAuth(username, password string) ClientOption

+ func CertsPath(certspath string) ClientOption

+ func ClientCerts(clientKey, clientCert string) ClientOption

+ func Debug() ClientOption

+ func FailOnPermanentErrors() ClientOption

+ func InsecureSkipVerify(InsecureSkipVerify bool) ClientOption

+ func SchedulerUrl(url string) ClientOption

+ func SetLogger(l Logger) ClientOption

+ func ThriftBinary() ClientOption

+ func ThriftJSON() ClientOption

+ func Timeout(timeout time.Duration) ClientOption

+ func Trace() ClientOption

+ func ZKCluster(cluster *Cluster) ClientOption

+ func ZKUrl(url string) ClientOption

+ func ZookeeperOptions(opts ...ZKOpt) ClientOption

+ type Cluster struct

+ AgentRoot string

+ AgentRunDir string

+ AuthMechanism string

+ Name string

+ ProxyURL string

+ SchedURI string

+ SchedZKPath string

+ ZK string

+ ZKPort int

+ func GetDefaultClusterFromZKUrl(zkURL string) *Cluster

+ type ConditionFunc func() (done bool, err error)

+ type Container interface

+ Build func() *aurora.Container

+ type DockerContainer struct

+ func NewDockerContainer() *DockerContainer

+ func (c *DockerContainer) AddParameter(name, value string) *DockerContainer

+ func (c *DockerContainer) Build() *aurora.Container

+ func (c *DockerContainer) Image(image string) *DockerContainer

+ type Endpoint struct

+ Host string

+ Port int

+ type JobUpdate struct

+ func JobUpdateFromAuroraTask(task *AuroraTask) *JobUpdate

+ func JobUpdateFromConfig(task *aurora.TaskConfig) *JobUpdate

+ func NewJobUpdate() *JobUpdate

+ func (j *JobUpdate) AddDedicatedConstraint(role, name string) *JobUpdate

+ func (j *JobUpdate) AddLabel(key string, value string) *JobUpdate

+ func (j *JobUpdate) AddLimitConstraint(name string, limit int32) *JobUpdate

+ func (j *JobUpdate) AddNamedPorts(names ...string) *JobUpdate

+ func (j *JobUpdate) AddPorts(num int) *JobUpdate

+ func (j *JobUpdate) AddURIs(extract bool, cache bool, values ...string) *JobUpdate

+ func (j *JobUpdate) AddValueConstraint(name string, negated bool, values ...string) *JobUpdate

+ func (j *JobUpdate) BatchSize(size int32) *JobUpdate

+ func (j *JobUpdate) BuildThermosPayload() error

+ func (j *JobUpdate) CPU(cpus float64) *JobUpdate

+ func (j *JobUpdate) Container(container Container) *JobUpdate

+ func (j *JobUpdate) Disk(disk int64) *JobUpdate

+ func (j *JobUpdate) Environment(env string) *JobUpdate

+ func (j *JobUpdate) ExecutorData(data string) *JobUpdate

+ func (j *JobUpdate) ExecutorName(name string) *JobUpdate

+ func (j *JobUpdate) InstanceCount(inst int32) *JobUpdate

+ func (j *JobUpdate) IsService(isService bool) *JobUpdate

+ func (j *JobUpdate) JobKey() aurora.JobKey

+ func (j *JobUpdate) MaxFailedInstances(inst int32) *JobUpdate

+ func (j *JobUpdate) MaxFailure(maxFail int32) *JobUpdate

+ func (j *JobUpdate) MaxPerInstanceFailures(inst int32) *JobUpdate

+ func (j *JobUpdate) Name(name string) *JobUpdate

+ func (j *JobUpdate) PartitionPolicy(reschedule bool, delay int64) *JobUpdate

+ func (j *JobUpdate) PulseIntervalTimeout(timeout time.Duration) *JobUpdate

+ func (j *JobUpdate) RAM(ram int64) *JobUpdate

+ func (j *JobUpdate) Role(role string) *JobUpdate

+ func (j *JobUpdate) RollbackOnFail(rollback bool) *JobUpdate

+ func (j *JobUpdate) TaskConfig() *aurora.TaskConfig

+ func (j *JobUpdate) ThermosExecutor(thermos ThermosExecutor) *JobUpdate

+ func (j *JobUpdate) Tier(tier string) *JobUpdate

+ func (j *JobUpdate) WaitForBatchCompletion(batchWait bool) *JobUpdate

+ func (j *JobUpdate) WatchTime(timeout time.Duration) *JobUpdate

+ type LevelLogger struct

+ func (l *LevelLogger) EnableDebug(enable bool)

+ func (l *LevelLogger) EnableTrace(enable bool)

+ func (l LevelLogger) DebugPrint(a ...interface{})

+ func (l LevelLogger) DebugPrintf(format string, a ...interface{})

+ func (l LevelLogger) DebugPrintln(a ...interface{})

+ func (l LevelLogger) TracePrint(a ...interface{})

+ func (l LevelLogger) TracePrintf(format string, a ...interface{})

+ func (l LevelLogger) TracePrintln(a ...interface{})

+ type Logger interface

+ Print func(v ...interface{})

+ Printf func(format string, v ...interface{})

+ Println func(v ...interface{})

+ type MesosContainer struct

+ func NewMesosContainer() *MesosContainer

+ func (c *MesosContainer) AddVolume(hostPath, containerPath string, mode aurora.Mode) *MesosContainer

+ func (c *MesosContainer) AppcImage(name, imageId string) *MesosContainer

+ func (c *MesosContainer) Build() *aurora.Container

+ func (c *MesosContainer) DockerImage(name, tag string) *MesosContainer

+ type NoopLogger struct

+ func (NoopLogger) Print(a ...interface{})

+ func (NoopLogger) Printf(format string, a ...interface{})

+ func (NoopLogger) Println(a ...interface{})

+ type ResourceType int

+ const CPU

+ const DISK

+ const GPU

+ const RAM

+ type ServiceInstance struct

+ AdditionalEndpoints map[string]Endpoint

+ Service Endpoint

+ Status string

+ type TemporaryErr struct

+ func NewTemporaryError(err error) *TemporaryErr

+ func (t *TemporaryErr) Temporary() bool

+ type ThermosConstraint struct

+ Order []string

+ type ThermosExecutor struct

+ Task ThermosTask

+ func (t *ThermosExecutor) AddProcess(process ThermosProcess) *ThermosExecutor

+ func (t *ThermosExecutor) Clone() *ThermosExecutor

+ func (t *ThermosExecutor) ProcessOrder(order ...string) *ThermosExecutor

+ type ThermosProcess struct

+ Cmdline string

+ Daemon bool

+ Ephemeral bool

+ Final bool

+ MaxFailures int

+ MinDuration int

+ Name string

+ func NewThermosProcess(name, command string) ThermosProcess

+ type ThermosTask struct

+ Constraints []*ThermosConstraint

+ Processes map[string]*ThermosProcess

+ Resources thermosResources

+ func (t *ThermosTask) MarshalJSON() ([]byte, error)

+ func (t *ThermosTask) UnmarshalJSON(data []byte) error

+ type TransportProtocol int

+ type ZKOpt func(z *zkConfig)

+ func ZKBackoff(b Backoff) ZKOpt

+ func ZKEndpoints(endpoints ...string) ZKOpt

+ func ZKLogger(l Logger) ZKOpt

+ func ZKPath(path string) ZKOpt

+ func ZKTimeout(d time.Duration) ZKOpt

Other modules containing this package

github.com/aurora-scheduler/gorealis

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL