cache

Documentation

Index

• type JobIDCache
  • func NewJobIDCache() JobIDCache

Types

type JobIDCache

type JobIDCache interface {
	// GetJobIDs retrieves the ids from cache based on input Aurora JobKey
	// role parameter.
	GetJobIDs(role string) []*peloton.JobID

	// PopulateFromJobCache populates the JobIDCache based on the QueryJobCache
	// result for a particular Aurora JobKey role.
	PopulateFromJobCache(
		role string,
		jobCache []*jobmgrsvc.QueryJobCacheResponse_JobCache,
	)

	// Invalidate invalidates the cache entries based on a particular Aurora
	// JobKey role.
	Invalidate(role string)
}

JobIDCache is a cache to map between Aurora JobKey and Peloton ID, cache is keyed using JobKey role.

func NewJobIDCache

func NewJobIDCache() JobIDCache