redisprovider

Documentation

Index

• func JobUUID2RedisKey(jobUUID job.JobUUID) string
• func NewRedisJobBackendProvider(logger *zap.Logger, conf *config.Config) (jobbackendprovider.IJobBackendProvider, error)
• type RedisJobBackendProvider
  • func (p *RedisJobBackendProvider) Healthcheck() bool
  • func (p *RedisJobBackendProvider) Init(notifChan chan jobbackendprovider.Event) error
  • func (p *RedisJobBackendProvider) JobExists(jobUUID job.JobUUID) (bool, error)
  • func (p *RedisJobBackendProvider) LoadJobs() (job.JobMap, error)
  • func (p *RedisJobBackendProvider) NotifyChange(event jobbackendprovider.Event)
  • func (p *RedisJobBackendProvider) OnAllResourcesUnlocked() error
  • func (p *RedisJobBackendProvider) OnJobCanceled(j *job.Job) error
  • func (p *RedisJobBackendProvider) OnJobCreated(j *job.Job) error
  • func (p *RedisJobBackendProvider) OnJobDeleted(jobUUID job.JobUUID) error
  • func (p *RedisJobBackendProvider) OnJobEnqueued(j *job.Job) error
  • func (p *RedisJobBackendProvider) OnJobStarted(j *job.Job) error
  • func (p *RedisJobBackendProvider) OnJobSucceeded(j *job.Job) error
  • func (p *RedisJobBackendProvider) OnJobTimeout(j *job.Job) error
  • func (p *RedisJobBackendProvider) OnJobsDeleted() error
  • func (p *RedisJobBackendProvider) OnResourceUnlocked(j *job.Job, resource string) error
  • func (p *RedisJobBackendProvider) Run() error
  • func (p *RedisJobBackendProvider) SaveJob(j *job.Job) error
  • func (p *RedisJobBackendProvider) SetJobTTL(j *job.Job) error
  • func (p *RedisJobBackendProvider) Stop() error

Functions

func JobUUID2RedisKey

func JobUUID2RedisKey(jobUUID job.JobUUID) string

func NewRedisJobBackendProvider

func NewRedisJobBackendProvider(logger *zap.Logger, conf *config.Config) (jobbackendprovider.IJobBackendProvider, error)

Types

type RedisJobBackendProvider

type RedisJobBackendProvider struct {
	// contains filtered or unexported fields
}

func (*RedisJobBackendProvider) Healthcheck

func (p *RedisJobBackendProvider) Healthcheck() bool

func (*RedisJobBackendProvider) Init

func (p *RedisJobBackendProvider) Init(notifChan chan jobbackendprovider.Event) error

func (*RedisJobBackendProvider) JobExists

func (p *RedisJobBackendProvider) JobExists(jobUUID job.JobUUID) (bool, error)

func (*RedisJobBackendProvider) LoadJobs

func (p *RedisJobBackendProvider) LoadJobs() (job.JobMap, error)

func (*RedisJobBackendProvider) NotifyChange

func (p *RedisJobBackendProvider) NotifyChange(event jobbackendprovider.Event)

func (*RedisJobBackendProvider) OnAllResourcesUnlocked

func (p *RedisJobBackendProvider) OnAllResourcesUnlocked() error

func (*RedisJobBackendProvider) OnJobCanceled

func (p *RedisJobBackendProvider) OnJobCanceled(j *job.Job) error

func (*RedisJobBackendProvider) OnJobCreated

func (p *RedisJobBackendProvider) OnJobCreated(j *job.Job) error

func (*RedisJobBackendProvider) OnJobDeleted

func (p *RedisJobBackendProvider) OnJobDeleted(jobUUID job.JobUUID) error

func (*RedisJobBackendProvider) OnJobEnqueued

func (p *RedisJobBackendProvider) OnJobEnqueued(j *job.Job) error

func (*RedisJobBackendProvider) OnJobStarted

func (p *RedisJobBackendProvider) OnJobStarted(j *job.Job) error

func (*RedisJobBackendProvider) OnJobSucceeded

func (p *RedisJobBackendProvider) OnJobSucceeded(j *job.Job) error

func (*RedisJobBackendProvider) OnJobTimeout

func (p *RedisJobBackendProvider) OnJobTimeout(j *job.Job) error

func (*RedisJobBackendProvider) OnJobsDeleted

func (p *RedisJobBackendProvider) OnJobsDeleted() error

func (*RedisJobBackendProvider) OnResourceUnlocked

func (p *RedisJobBackendProvider) OnResourceUnlocked(j *job.Job, resource string) error

func (*RedisJobBackendProvider) Run

func (p *RedisJobBackendProvider) Run() error

func (*RedisJobBackendProvider) SaveJob

func (p *RedisJobBackendProvider) SaveJob(j *job.Job) error

func (*RedisJobBackendProvider) SetJobTTL

func (p *RedisJobBackendProvider) SetJobTTL(j *job.Job) error

func (*RedisJobBackendProvider) Stop

func (p *RedisJobBackendProvider) Stop() error