pipeline

package
v0.1.0-beta.3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 19, 2025 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type EnrichedComponent

type EnrichedComponent struct {
	providers.RegistryComponent
	PackageData *providers.PackageMetadata
}

EnrichedComponent represents a component enriched with package manager data

type Pipeline

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

Pipeline represents the knowledge base update pipeline

func NewPipeline

func NewPipeline(providerFactory providers.ProviderFactory, logger logger.Logger, githubToken string, storageClient *storage.Storage) *Pipeline

NewPipelineWithLoggerAndToken creates a new pipeline with a custom logger and GitHub token

func (*Pipeline) GetCacheStats

func (p *Pipeline) GetCacheStats() map[string]interface{}

GetCacheStats returns statistics about the repository releases cache

func (*Pipeline) GroupComponentsByRepository

func (p *Pipeline) GroupComponentsByRepository(components []providers.RegistryComponent) map[string][]providers.RegistryComponent

GroupComponentsByRepository groups components by their repository URL

func (*Pipeline) UpdateKnowledgeBase

func (p *Pipeline) UpdateKnowledgeBase(language types.ComponentLanguage) error

UpdateKnowledgeBase updates the knowledge base with fresh data for the specified language

type RepositoryReleasesCache

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

RepositoryReleasesCache caches GitHub releases for repositories to avoid duplicate API calls

func NewRepositoryReleasesCache

func NewRepositoryReleasesCache() *RepositoryReleasesCache

NewRepositoryReleasesCache creates a new repository releases cache

func (*RepositoryReleasesCache) Get

func (c *RepositoryReleasesCache) Get(repositoryURL string) ([]providers.GitHubRelease, bool)

Get retrieves cached releases for a repository

func (*RepositoryReleasesCache) Set

func (c *RepositoryReleasesCache) Set(repositoryURL string, releases []providers.GitHubRelease)

Set stores releases for a repository in the cache

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL