run

Documentation

Index

• Constants
• type Consumer
  • func (c *Consumer) Consume(log *zap.Logger, repository *model.Repository) (err error)
  • func (c *Consumer) FindEffxYAML(workDir string) ([]string, error)
  • func (c *Consumer) Run(ctx context.Context, data chan *model.Repository) error
  • func (c *Consumer) SetupFS(workDir, cloneURL string) error

Constants

const LanguageDetectionFeature = "LANGUAGE_DETECTION"

LanguageDetectionFeature is a feature to detect languages, and versions.

Types

type Consumer

type Consumer struct {
	EffxClient *effx.Client
	ScratchDir string
	AuthMethod transport.AuthMethod
}

Consumer is a stateless entity that ingests repositories from integrations.

func (*Consumer) Consume

func (c *Consumer) Consume(log *zap.Logger, repository *model.Repository) (err error)

Consume attempts to index a repository for effx.yaml files

func (*Consumer) FindEffxYAML

func (c *Consumer) FindEffxYAML(workDir string) ([]string, error)

FindEffxYAML searches the provided work directory for effx.yaml files.

func (*Consumer) Run

func (c *Consumer) Run(ctx context.Context, data chan *model.Repository) error

Run consumes repositories from the data channel until the program is shutdown.

func (*Consumer) SetupFS

func (c *Consumer) SetupFS(workDir, cloneURL string) error

SetupFS initializes the workspace with the corresponding git repository.