services

Documentation

Index

• type ProviderCache
  • func (cache *ProviderCache) ArchivePath() string
  • func (cache *ProviderCache) AuthenticatePackage(ctx context.Context) (*provider.PackageAuthenticationResult, error)
• type ProviderCaches
  • func (caches ProviderCaches) Find(target *models.Provider) *ProviderCache
  • func (caches ProviderCaches) FindByRequestID(requestID string) ProviderCaches
• type ProviderService
  • func NewProviderService(baseCacheDir, baseArchiveDir, baseUserCacheDir string) *ProviderService
  • func (service *ProviderService) CacheProvider(ctx context.Context, requestID string, provider *models.Provider) *ProviderCache
  • func (service *ProviderService) GetProviderCache(provider *models.Provider) *ProviderCache
  • func (service *ProviderService) RunCacheWorker(ctx context.Context) error
  • func (service *ProviderService) WaitForCacheReady(requestID string) ProviderCaches

Types

type ProviderCache

type ProviderCache struct {
	*models.Provider
	// contains filtered or unexported fields
}

func (*ProviderCache) ArchivePath

func (cache *ProviderCache) ArchivePath() string

func (*ProviderCache) AuthenticatePackage

func (cache *ProviderCache) AuthenticatePackage(ctx context.Context) (*provider.PackageAuthenticationResult, error)

type ProviderCaches

type ProviderCaches []*ProviderCache

func (ProviderCaches) Find

func (caches ProviderCaches) Find(target *models.Provider) *ProviderCache

func (ProviderCaches) FindByRequestID

func (caches ProviderCaches) FindByRequestID(requestID string) ProviderCaches

type ProviderService

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

func NewProviderService

func NewProviderService(baseCacheDir, baseArchiveDir, baseUserCacheDir string) *ProviderService

func (*ProviderService) CacheProvider

func (service *ProviderService) CacheProvider(ctx context.Context, requestID string, provider *models.Provider) *ProviderCache

CacheProvider starts caching the given provider using non-blocking approach.

func (*ProviderService) GetProviderCache

func (service *ProviderService) GetProviderCache(provider *models.Provider) *ProviderCache

GetProviderCache returns the requested provider archive cache, if it exists.

func (*ProviderService) RunCacheWorker

func (service *ProviderService) RunCacheWorker(ctx context.Context) error

RunCacheWorker is responsible to handle a new caching requestID and removing temporary files upon completion.

func (*ProviderService) WaitForCacheReady

func (service *ProviderService) WaitForCacheReady(requestID string) ProviderCaches

WaitForCacheReady returns cached providers that were requested by `terraform init` from the cache server, with an URL containing the given `requestID` value. The function returns the value only when all cache requests have been processed.