caches

Documentation

Index

• type CurrentChangesCache
  • func GetCurrentChangesCache(ctx context.Context, dbClient db.DB) (CurrentChangesCache, error)
• type CurrentChangesCacheImpl
  • func (c *CurrentChangesCacheImpl) Add(ctx context.Context, ...) (int64, bool, error)
  • func (c *CurrentChangesCacheImpl) Get() map[string]*types.CurrentlyProcessingChange
  • func (c *CurrentChangesCacheImpl) Remove(ctx context.Context, changeEquivalentPatchset string) error

Types

type CurrentChangesCache

type CurrentChangesCache interface {
	// Get returns the current cache.
	Get() map[string]*types.CurrentlyProcessingChange

	// Add creates an entry in the changes cache if it does not already
	// exist. It returns the cqStartTime of this attempt and a boolean
	// indicating whether this is a new CQ attempt.
	Add(ctx context.Context, changeEquivalentPatchset, changeSubject, changeOwner, repo, branch string, dryRun, internal bool, changeID, latestPatchsetID int64) (int64, bool, error)

	// Remove removes the specified change from the cache.
	Remove(ctx context.Context, changeEquivalentPatchset string) error
}

func GetCurrentChangesCache

func GetCurrentChangesCache(ctx context.Context, dbClient db.DB) (CurrentChangesCache, error)

type CurrentChangesCacheImpl

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

func (*CurrentChangesCacheImpl) Add

func (c *CurrentChangesCacheImpl) Add(ctx context.Context, changeEquivalentPatchset, changeSubject, changeOwner, repo, branch string, dryRun, internal bool, changeID, latestPatchsetID int64) (int64, bool, error)

Add implements the CurrentChangesCache interface.

func (*CurrentChangesCacheImpl) Get

func (c *CurrentChangesCacheImpl) Get() map[string]*types.CurrentlyProcessingChange

Get implements the CurrentChangesCache interface.

func (*CurrentChangesCacheImpl) Remove

func (c *CurrentChangesCacheImpl) Remove(ctx context.Context, changeEquivalentPatchset string) error

Remove implements the CurrentChangesCache interface.