realis

package module

Go to main page

Versions in this module

v1

v1.3.1-medallia

Jan 3, 2019

v1.2.0

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

v1.1.0

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

v1.0.5

Nov 11, 2016

v1.0.4

Nov 3, 2016

Changes in this version

+ type NoopLogger struct

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

v1.0.3

Nov 2, 2016

v1.0.2

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

v1.0.1

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

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