cache

Documentation

Index

• Constants
• func NewCacheLoader(logger lager.Logger, orgs []string, locationCache *LocationCache, ...) ifrit.Runner
• type LocationCache
  • func NewLocationCache(logger lager.Logger, clock clock.Clock) *LocationCache
  • func (l *LocationCache) Add(repoName, location string)
  • func (l *LocationCache) Lookup(repoName string) (string, bool)
  • func (l *LocationCache) Swap(newLocationCache *LocationCache)
• type RepositoriesService

Constants

const CacheUpdateInterval = 10 * time.Minute

Functions

func NewCacheLoader

func NewCacheLoader(logger lager.Logger, orgs []string, locationCache *LocationCache, repoService RepositoriesService, clock clock.Clock) ifrit.Runner

Types

type LocationCache

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

func NewLocationCache

func NewLocationCache(logger lager.Logger, clock clock.Clock) *LocationCache

func (*LocationCache) Add

func (l *LocationCache) Add(repoName, location string)

func (*LocationCache) Lookup

func (l *LocationCache) Lookup(repoName string) (string, bool)

func (*LocationCache) Swap

func (l *LocationCache) Swap(newLocationCache *LocationCache)

type RepositoriesService

type RepositoriesService interface {
	ListByOrg(ctx context.Context, org string, opt *github.RepositoryListByOrgOptions) ([]*github.Repository, *github.Response, error)
}