realis

package module

Go to main page

Versions in this module

v2

v2.21.0

Feb 5, 2020

Changes in this version

type AuroraJob

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

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

type AuroraTask

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

type Client

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

type ClientOption

+ func FailOnPermanentErrors() ClientOption

+ func Trace() ClientOption

type JobUpdate

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

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 TransportProtocol int

v2.0.1

Jan 8, 2019

Changes in this version

type AuroraJob

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

+ func (j *AuroraJob) BuildThermosPayload() error

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

type AuroraTask

+ func (t *AuroraTask) BuildThermosPayload() error

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

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

type JobUpdate

+ func (j *JobUpdate) BuildThermosPayload() error

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

type ResourceType

+ const GPU

+ 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

v2.0.0

Dec 27, 2018

Changes in this version

+ const RolledBack

+ const Timedout

+ const UpdateFailed

+ 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) 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) 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) RAM(ram int64) *AuroraJob

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

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

+ 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) 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) 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) RAM(ram int64) *AuroraTask

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

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

+ 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) HostMaintenanceMonitor(hosts []string, modes []aurora.MaintenanceMode, ...) (map[string]bool, error)

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

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

+ func (c *Client) JobUpdateMonitor(updateKey aurora.JobUpdateKey, interval, timeout time.Duration) (bool, 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) 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) ScheduleStatusMonitor(key aurora.JobKey, instanceCount int32, ...) (bool, 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 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 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) CPU(cpus float64) *JobUpdate

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

+ func (j *JobUpdate) Disk(disk int64) *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) PulseIntervalTimeout(timeout time.Duration) *JobUpdate

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

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

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

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

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

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

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

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

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

+ 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 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 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 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/paypal/gorealis

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