jobs

Nov 9, 2021

Changes in this version

type InstanceRunner

+ AuthHeader string

+ Encrypt bool

+ type TaskRunner struct

+ AuthHeader string

+ Encrypt bool

+ Endpoint string

+ EndpointTemplate string

+ Token string

+ func NewTaskRunner(config map[string]interface{}) (*TaskRunner, error)

+ func (r *TaskRunner) Run(ctx context.Context, account string, parameters interface{}) (string, error)

+ type TaskRunnerRunInput struct

+ Account string

+ Cluster string

+ Name string

Apr 21, 2021

Changes in this version

+ type DatabaseRunner struct

+ Endpoint string

+ EndpointTemplate string

+ Token string

+ func NewDatabaseRunner(config map[string]interface{}) (*DatabaseRunner, error)

+ func (r *DatabaseRunner) Run(ctx context.Context, account string, parameters interface{}) (string, error)

Feb 19, 2021

Changes in this version

type Job

+ func (j *Job) NextRun(t time.Time) (*time.Time, error)

Sep 3, 2020

Changes in this version

+ type ServiceRunner struct

+ AuthHeader string

+ Encrypt bool

+ Endpoint string

+ EndpointTemplate string

+ Token string

+ func NewServiceRunner(config map[string]interface{}) (*ServiceRunner, error)

+ func (r *ServiceRunner) Run(ctx context.Context, account string, parameters interface{}) (string, error)

+ type ServiceRunnerScaleInput struct

+ Account string

+ Cluster string

+ Name string

Apr 1, 2020

Changes in this version

+ type Tag struct

+ Key string

+ Value string

Mar 19, 2020

Changes in this version

+ const ErrExecFailure

+ const ErrMissingDetails

+ const ErrPostExecFailure

+ const ErrPreExecFailure

+ const ErrQueueIsEmpty

+ func ErrCode(msg string, err error) error

+ func NewID() string

+ type DummyRunner struct

+ Template string

+ func NewDummyRunner(config map[string]interface{}) (*DummyRunner, error)

+ func (r *DummyRunner) Run(ctx context.Context, account string, parameters interface{}) (string, error)

+ type InstanceRunner struct

+ Endpoint string

+ EndpointTemplate string

+ Token string

+ func NewInstanceRunner(config map[string]interface{}) (*InstanceRunner, error)

+ func (r *InstanceRunner) Run(ctx context.Context, account string, parameters interface{}) (string, error)

+ type Job struct

+ Account string

+ Description string

+ Details map[string]string

+ Enabled bool

+ Group string

+ ID string

+ ModifiedAt *time.Time

+ ModifiedBy string

+ Name string

+ ScheduleExpression string

+ func (m *Job) MarshalBinary() ([]byte, error)

+ func (m *Job) UnmarshalBinary(data []byte) error

+ func (m *Job) UnmarshalJSON(j []byte) error

+ func (m Job) MarshalJSON() ([]byte, error)

+ type Locker interface

+ Lock func(key, id string) error

+ type QueueError struct

+ Code string

+ Message string

+ OrigErr error

+ func NewQueueError(code, message string, err error) QueueError

+ func (e QueueError) Error() string

+ func (e QueueError) String() string

+ func (e QueueError) Unwrap() error

+ type QueuedJob struct

+ ID string

+ Score float64

+ type Queuer interface

+ Close func() error

+ Enqueue func(queued *QueuedJob) error

+ Fetch func(queued *QueuedJob) error

+ Finalize func(id string) error

+ type RedisLocker struct

+ Expire time.Duration

+ Prefix string

+ func NewRedisLocker(prefix, address, password string, db int, expiration string) (*RedisLocker, error)

+ func (l *RedisLocker) Lock(key, id string) error

+ type RedisQueuer struct

+ BackupName string

+ Name string

+ Window int64

+ func NewRedisQueuer(name, address, password string, db int, window int64) (*RedisQueuer, error)

+ func (q *RedisQueuer) Close() error

+ func (q *RedisQueuer) Enqueue(queued *QueuedJob) error

+ func (q *RedisQueuer) Fetch(queued *QueuedJob) error

+ func (q *RedisQueuer) Finalize(id string) error

+ type Repository interface

+ Create func(ctx context.Context, account string, job *Job) (*Job, error)

+ Delete func(ctx context.Context, account, id string) error

+ Get func(ctx context.Context, account, id string) (*Job, error)

+ List func(ctx context.Context, account string) ([]string, error)

+ Update func(ctx context.Context, account, id string, job *Job) (*Job, error)

+ type Runner interface

+ Run func(ctx context.Context, account string, parameters interface{}) (string, error)

+ type RunnerError struct

+ Code string

+ Message string

+ OrigErr error

+ func NewRunnerError(code, message string, err error) RunnerError

+ func (e RunnerError) Error() string

+ func (e RunnerError) String() string

+ func (e RunnerError) Unwrap() error

+ type S3Repository struct

+ Bucket string

+ Prefix string

+ S3 s3iface.S3API

+ func New(opts ...S3RepositoryOption) (*S3Repository, error)

+ func NewDefaultRepository(config map[string]interface{}) (*S3Repository, error)

+ func (s *S3Repository) Create(ctx context.Context, account string, job *Job) (*Job, error)

+ func (s *S3Repository) Delete(ctx context.Context, account, id string) error

+ func (s *S3Repository) Get(ctx context.Context, account, id string) (*Job, error)

+ func (s *S3Repository) List(ctx context.Context, account string) ([]string, error)

+ func (s *S3Repository) Update(ctx context.Context, account, id string, job *Job) (*Job, error)

+ type S3RepositoryOption func(*S3Repository)

+ func WithBucket(bucket string) S3RepositoryOption

+ func WithEndpoint(endpoint string) S3RepositoryOption

+ func WithPrefix(prefix string) S3RepositoryOption

+ func WithRegion(region string) S3RepositoryOption

+ func WithStaticCredentials(akid, secret, token string) S3RepositoryOption