realis

Oct 13, 2022

Changes in this version

type AuroraJob

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

type Job

+ Priority func(priority int32) Job

May 27, 2020

Changes in this version

type ClientOption

+ func CertExtensions(extensions ...string) ClientOption

Jan 14, 2020

Changes in this version

+ func TerminalUpdateStates() []aurora.JobUpdateStatus

type Monitor

+ func (m *Monitor) AutoPausedUpdateMonitor(key aurora.JobUpdateKey, interval, timeout time.Duration) (int, error)

type UpdateJob

+ func (u *UpdateJob) BatchUpdateStrategy(strategy aurora.BatchJobUpdateStrategy) *UpdateJob

+ func (u *UpdateJob) QueueUpdateStrategy(strategy aurora.QueueJobUpdateStrategy) *UpdateJob

+ func (u *UpdateJob) VariableBatchStrategy(strategy aurora.VariableBatchJobUpdateStrategy) *UpdateJob

Jun 12, 2019

Changes in this version

type ClientOption

+ func FailOnPermanentErrors() ClientOption

type Monitor

+ func (m *Monitor) JobUpdateQuery(updateQuery aurora.JobUpdateQuery, interval time.Duration, ...) ([]*aurora.JobUpdateSummary, error)

Mar 15, 2019

Changes in this 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)

type AuroraJob

+ func (j *AuroraJob) SlaPolicy(policy *aurora.SlaPolicy) Job

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

type ClientOption

+ func Trace() ClientOption

type Job

+ GPU func(gpu int64) Job

+ SlaPolicy func(policy *aurora.SlaPolicy) Job

+ Tier func(tier string) Job

type LevelLogger

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

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

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

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

type Monitor

+ func (m *Monitor) JobUpdateStatus(updateKey aurora.JobUpdateKey, desiredStatuses map[aurora.JobUpdateStatus]bool, ...) (aurora.JobUpdateStatus, error)

Jan 8, 2019

Changes in this version

type AuroraJob

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

+ func (j *AuroraJob) GPU(gpus int64) Job

+ func (j *AuroraJob) PartitionPolicy(policy *aurora.PartitionPolicy) Job

type Job

+ AddDedicatedConstraint func(role, name string) Job

+ PartitionPolicy func(policy *aurora.PartitionPolicy) Job

type Realis

+ ForceExplicitTaskReconciliation func(batchSize *int32) error

+ ForceImplicitTaskReconciliation func() error

+ GetPendingReason func(query *aurora.TaskQuery) (pendingReasons []*aurora.PendingReason, e error)

+ SLADrainHosts func(policy *aurora.SlaPolicy, timeout int64, hosts ...string) (*aurora.DrainHostsResult_, error)

+ StartMaintenance func(hosts ...string) (*aurora.Response, *aurora.StartMaintenanceResult_, error)

+ type ResourceType int

+ const CPU

+ const DISK

+ const GPU

+ const RAM

Oct 5, 2018

Changes in this version

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

+ func ToRetryCount(err error) *retryErr

type ClientOption

+ func Debug() ClientOption

+ func ZookeeperOptions(opts ...ZKOpt) ClientOption

+ type LevelLogger struct

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

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

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

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

type Realis

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

+ GetQuota func(role string) (*aurora.Response, error)

+ PauseJobUpdate func(key *aurora.JobUpdateKey, message string) (*aurora.Response, error)

+ PerformBackup func() error

+ PulseJobUpdate func(key *aurora.JobUpdateKey) (*aurora.Response, error)

+ ResumeJobUpdate func(key *aurora.JobUpdateKey, message string) (*aurora.Response, error)

+ SetQuota func(role string, cpu *float64, ram *int64, disk *int64) (*aurora.Response, error)

+ Snapshot func() error

+ 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

Jan 24, 2018

Changes in this version

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

+ func IsTemporary(err error) bool

+ func IsTimeout(err error) bool

type Monitor

+ func (m *Monitor) ScheduleStatus(key *aurora.JobKey, instanceCount int32, ...) (bool, error)

+ type TemporaryErr struct

+ func NewPermamentError(err error) TemporaryErr

+ func NewTemporaryError(err error) *TemporaryErr

+ func (t *TemporaryErr) Temporary() bool

+ type TimeoutErr struct

+ func NewTimeoutError(err error) *TimeoutErr

+ func (t *TimeoutErr) Timeout() bool

Dec 23, 2017

Changes in this version

+ const ConnRefusedErr

+ const NoLeaderFoundErr

+ const RolledBack

+ const Timeout

+ const UpdateFailed

+ const VERSION

+ var RetryConnErr = errors.New("error occured during with aurora retrying")

+ func CheckAndRetryConn(r Realis, auroraCall AuroraThriftCall) (*aurora.Response, error)

+ func ExponentialBackoff(backoff Backoff, condition ConditionFunc) error

+ func Getcerts(certpath string) (*x509.CertPool, error)

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

+ type AuroraThriftCall func() (resp *aurora.Response, err error)

+ type Backoff struct

+ Duration time.Duration

+ Factor float64

+ Jitter float64

+ Steps int

+ type ClientOption func(*RealisConfig)

+ func BackOff(b *Backoff) ClientOption

+ func BasicAuth(username, password string) ClientOption

+ func Certspath(certspath string) ClientOption

+ func ClientCerts(clientKey, clientCert string) ClientOption

+ func InsecureSkipVerify(InsecureSkipVerify bool) ClientOption

+ func Retries(backoff *Backoff) ClientOption

+ func SchedulerUrl(url string) ClientOption

+ func SetLogger(l Logger) ClientOption

+ func ThriftBinary() ClientOption

+ func ThriftJSON() ClientOption

+ func TimeoutMS(timeout int) ClientOption

+ func ZKCluster(cluster *Cluster) ClientOption

+ func ZKUrl(url string) ClientOption

type Cluster

+ func GetDefaultClusterFromZKUrl(zkurl string) *Cluster

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

+ type Logger interface

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

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

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

type MesosContainer

+ func NewMesosContainer() MesosContainer

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

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

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

type Monitor

+ func (m *Monitor) HostMaintenance(hosts []string, modes []aurora.MaintenanceMode, sleepTime, steps int) (map[string]bool, error)

type NoopLogger

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

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

type Realis

+ func NewRealisClient(options ...ClientOption) (Realis, error)

+ CreateService func(auroraJob Job, settings UpdateSettings) (*aurora.Response, *aurora.StartJobUpdateResult_, error)

+ DrainHosts func(hosts ...string) (*aurora.Response, *aurora.DrainHostsResult_, error)

+ EndMaintenance func(hosts ...string) (*aurora.Response, *aurora.EndMaintenanceResult_, error)

+ GetJobUpdateSummaries func(jobUpdateQuery *aurora.JobUpdateQuery) (*aurora.Response, error)

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

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

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

+ RealisConfig func() *RealisConfig

+ ReestablishConn func() error

+ RemoveInstances func(key *aurora.JobKey, count int32) (*aurora.Response, error)

type RealisConfig

+ InsecureSkipVerify bool

type UpdateJob

+ func NewDefaultUpdateJob(config *aurora.TaskConfig) *UpdateJob

+ type UpdateSettings struct

+ func NewUpdateSettings() *UpdateSettings

+ func (u *UpdateSettings) BatchSize(size int32) *UpdateSettings

+ func (u *UpdateSettings) MaxFailedInstances(inst int32) *UpdateSettings

+ func (u *UpdateSettings) MaxPerInstanceFailures(inst int32) *UpdateSettings

+ func (u *UpdateSettings) RollbackOnFail(rollback bool) *UpdateSettings

+ func (u *UpdateSettings) WaitForBatchCompletion(batchWait bool) *UpdateSettings

+ func (u *UpdateSettings) WatchTime(ms int32) *UpdateSettings

+ func (u UpdateSettings) Settings() aurora.JobUpdateSettings

Nov 3, 2016

Changes in this version

+ type NoopLogger struct

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

Nov 2, 2016

Changes in this version

type AuroraJob

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

+ 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 Job

+ Container func(container Container) Job

+ type MesosContainer struct

Oct 1, 2016

Changes in this version

+ func AddBasicAuth(config *RealisConfig, username string, password string)

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

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

+ type AuroraJob struct

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

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

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

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

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

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

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

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

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

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

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

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

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

+ func (j AuroraJob) GetInstanceCount() int32

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

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

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

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

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

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

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

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

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

+ type Cluster struct

+ AgentRoot string

+ AgentRunDir string

+ AuthMechanism string

+ Name string

+ ProxyURL string

+ SchedURI string

+ SchedZKPath string

+ ZK string

+ ZKPort int

+ type Endpoint struct

+ Host string

+ Port int

+ type Job interface

+ AddLabel func(key string, value string) Job

+ AddLimitConstraint func(name string, limit int32) Job

+ AddNamedPorts func(names ...string) Job

+ AddPorts func(num int) Job

+ AddURIs func(extract bool, cache bool, values ...string) Job

+ AddValueConstraint func(name string, negated bool, values ...string) Job

+ CPU func(cpus float64) Job

+ CronCollisionPolicy func(policy aurora.CronCollisionPolicy) Job

+ CronSchedule func(cron string) Job

+ Disk func(disk int64) Job

+ Environment func(env string) Job

+ ExecutorData func(data string) Job

+ ExecutorName func(name string) Job

+ GetInstanceCount func() int32

+ InstanceCount func(instCount int32) Job

+ IsService func(isService bool) Job

+ JobConfig func() *aurora.JobConfiguration

+ JobKey func() *aurora.JobKey

+ MaxFailure func(maxFail int32) Job

+ Name func(name string) Job

+ RAM func(ram int64) Job

+ Role func(role string) Job

+ TaskConfig func() *aurora.TaskConfig

+ func NewJob() Job

+ type Monitor struct

+ Client Realis

+ func (m *Monitor) Instances(key *aurora.JobKey, instances int32, interval int, timeout int) bool

+ func (m *Monitor) JobUpdate(updateKey aurora.JobUpdateKey, interval int, timeout int) bool

+ type Realis interface

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

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

+ Close func()

+ CreateJob func(auroraJob Job) (*aurora.Response, error)

+ DescheduleCronJob func(key *aurora.JobKey) (*aurora.Response, error)

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

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

+ JobUpdateDetails func(updateQuery aurora.JobUpdateQuery) (*aurora.Response, error)

+ KillInstances func(key *aurora.JobKey, instances ...int32) (*aurora.Response, error)

+ KillJob func(key *aurora.JobKey) (*aurora.Response, error)

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

+ RestartJob func(key *aurora.JobKey) (*aurora.Response, error)

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

+ ScheduleCronJob func(auroraJob Job) (*aurora.Response, error)

+ StartCronJob func(key *aurora.JobKey) (*aurora.Response, error)

+ StartJobUpdate func(updateJob *UpdateJob, message string) (*aurora.Response, error)

+ func NewClient(config RealisConfig) Realis

+ type RealisConfig struct

+ func NewDefaultConfig(url string) (RealisConfig, error)

+ type ServiceInstance struct

+ AdditionalEndpoints map[string]Endpoint

+ Service Endpoint

+ Status string

+ type UpdateJob struct

+ func NewUpdateJob(config *aurora.TaskConfig) *UpdateJob

+ func (u *UpdateJob) BatchSize(size int32) *UpdateJob

+ func (u *UpdateJob) InstanceCount(inst int32) *UpdateJob

+ func (u *UpdateJob) MaxFailedInstances(inst int32) *UpdateJob

+ func (u *UpdateJob) MaxPerInstanceFailures(inst int32) *UpdateJob

+ func (u *UpdateJob) RollbackOnFail(rollback bool) *UpdateJob

+ func (u *UpdateJob) WaitForBatchCompletion(batchWait bool) *UpdateJob

+ func (u *UpdateJob) WatchTime(milliseconds int32) *UpdateJob