pkg

Documentation

Index

• func PullRequestToCr(pullRequest *github.PullRequest, output *RepositorySyncOutput) v1alpha1.PullRequest
• type RepositorySyncInput
• type RepositorySyncOutput
• type RepositorySyncer
  • func NewRepositorySyncer(logger logr.Logger, workflowFileNames []string, cache *RepositorySyncerCache) RepositorySyncer
  • func (rs *RepositorySyncer) Run(ctx context.Context, req RepositorySyncInput) (*RepositorySyncOutput, error)
• type RepositorySyncerCache
  • func NewRepositorySyncerCache() *RepositorySyncerCache
  • func (rsc *RepositorySyncerCache) GetAllRuns() []*github.WorkflowRun
  • func (rsc *RepositorySyncerCache) SaveInCache(workflowRuns []*github.WorkflowRun) bool

Functions

func PullRequestToCr

func PullRequestToCr(
	pullRequest *github.PullRequest,
	output *RepositorySyncOutput,
) v1alpha1.PullRequest

Types

type RepositorySyncInput

type RepositorySyncInput struct {
	Repository githubv1alpha1.Repository
	Token      string
}

type RepositorySyncOutput

type RepositorySyncOutput struct {
	Input        *RepositorySyncInput
	PullRequests []*github.PullRequest
	WorkflowRuns []*github.WorkflowRun
}

type RepositorySyncer

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

func NewRepositorySyncer

func NewRepositorySyncer(
	logger logr.Logger,
	workflowFileNames []string,
	cache *RepositorySyncerCache,
) RepositorySyncer

func (*RepositorySyncer) Run

func (rs *RepositorySyncer) Run(ctx context.Context, req RepositorySyncInput) (*RepositorySyncOutput, error)

type RepositorySyncerCache

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

func NewRepositorySyncerCache

func NewRepositorySyncerCache() *RepositorySyncerCache

func (*RepositorySyncerCache) GetAllRuns

func (rsc *RepositorySyncerCache) GetAllRuns() []*github.WorkflowRun

func (*RepositorySyncerCache) SaveInCache

func (rsc *RepositorySyncerCache) SaveInCache(workflowRuns []*github.WorkflowRun) bool