manager

type BitbucketWebhookReceiver struct {
	// Channel to send new runs to
	TriggeredPipelines chan PipelineConfig
	// Logger is the logger to send logging messages to.
	Logger logging.LeveledLoggerInterface
	// BitbucketClient is a client to interact with Bitbucket.
	BitbucketClient bitbucketInterface
	// WebhookSecret is the shared Bitbucket secret to validate webhook requests.
	WebhookSecret string

	BitbucketWebhookReceiverBase
}

type BitbucketWebhookReceiverBase struct {
	// Namespace is the Kubernetes namespace in which the server runs.
	Namespace string
	// Project is the Bitbucket project to which this server corresponds.
	Project string
	// RepoBase is the common URL base of all repositories on Bitbucket.
	RepoBase string
}

type PipelineConfig struct {
	PipelineInfo
	PVC          string
	PipelineSpec config.Pipeline
	Params       []tekton.Param
}

type PipelineInfo struct {
	Project         string `json:"project"`
	Component       string `json:"component"`
	Repository      string `json:"repository"`
	GitRef          string `json:"gitRef"`
	GitFullRef      string `json:"gitFullRef"`
	GitSHA          string `json:"gitSha"`
	RepoBase        string `json:"repoBase"`
	GitURI          string `json:"gitURI"`
	Namespace       string `json:"namespace"`
	TriggerEvent    string `json:"trigger-event"`
	ChangeRefType   string `json:"change-ref-type"`
	Comment         string `json:"comment"`
	PullRequestKey  int    `json:"prKey"`
	PullRequestBase string `json:"prBase"`
}

type Pruner struct {
	// TriggeredRepos receives repo names for each triggered repository.
	TriggeredRepos chan string
	// TektonClient is a client to interact with Tekton.
	TektonClient tektonClient.ClientInterface
	Logger       logging.LeveledLoggerInterface
	// MinKeepHours specifies the minimum hours to keep a pipeline run.
	// This setting has precendence over MaxKeepRuns.
	MinKeepHours int
	// MaxKeepRuns is the maximum number of pipeline runs to keep.
	MaxKeepRuns int
	// contains filtered or unexported fields
}

type Scheduler struct {
	// Channel to read newly received runs from
	TriggeredPipelines chan PipelineConfig
	// Channel to send triggered repos on (signalling to start pruning)
	TriggeredRepos chan string
	// Channel to send pending runs on (singalling to start watching)
	PendingRunRepos  chan string
	TektonClient     tektonClient.ClientInterface
	KubernetesClient kubernetesClient.ClientInterface
	Logger           logging.LeveledLoggerInterface

	StorageConfig StorageConfig
}

type StorageConfig struct {
	Provisioner string
	ClassName   string
	Size        string
}

type Watcher struct {
	// PendingRunRepos receives repositories for which there is a new
	// pending pipeline run.
	PendingRunRepos chan string
	// Queues holds repositories for which there are pending runs.
	Queues       map[string]bool
	Logger       logging.LeveledLoggerInterface
	TektonClient tektonClient.ClientPipelineRunInterface
}