database

Documentation

Index

• type CloneCredential
• type CloneCredentialType
• type CommandExecution
• type Database
  • func LaunchDB(conf config.DBConfig) (Database, error)
  • func (db *Database) AssignSecretToPipeline(pipelineId uuid.UUID, secretId uuid.UUID) error
  • func (db *Database) CreateCredential(name string, credentialtype CloneCredentialType, username string, ...) (CloneCredential, error)
  • func (db *Database) CreatePipeline(name string, url string, pollInterval int, credential *uuid.UUID) (Pipeline, error)
  • func (db *Database) CreateRun(pipelineId uuid.UUID) (Run, error)
  • func (db *Database) CreateRunner(name string) (Runner, error)
  • func (db *Database) CreateSecret(name string, secret string) (Secret, error)
  • func (db *Database) CreateWebhook(serverType WebhookSender, pipelineId uuid.UUID) (Webhook, error)
  • func (db *Database) GetCloneCredentialById(id uuid.UUID) (CloneCredential, error)
  • func (db *Database) GetCredentials() ([]CloneCredential, error)
  • func (db *Database) GetPipelineById(id uuid.UUID) (Pipeline, error)
  • func (db *Database) GetPipelineRefs(pipelineId uuid.UUID) (map[string]string, error)
  • func (db *Database) GetPipelines() ([]Pipeline, error)
  • func (db *Database) GetRunnerById(id uuid.UUID) (Runner, error)
  • func (db *Database) GetRunners() ([]Runner, error)
  • func (db *Database) GetRunsForPipeline(pipelineId uuid.UUID) ([]Run, error)
  • func (db *Database) GetSecretById(id uuid.UUID) (Secret, error)
  • func (db *Database) GetSecrets() ([]Secret, error)
  • func (db *Database) GetSecretsForPipeline(pipelineId uuid.UUID) ([]Secret, error)
  • func (db *Database) GetWebhookById(id uuid.UUID) (Webhook, error)
  • func (db *Database) GetWebhooksForPipeline(id uuid.UUID) ([]Webhook, error)
  • func (db *Database) RemovePipelineCredential(pipelineId uuid.UUID) (Pipeline, error)
  • func (db *Database) RemoveSecretFromPipeline(pipelineId uuid.UUID, secretId uuid.UUID) error
  • func (db *Database) SetPipelineCloneCredential(pipelineId uuid.UUID, credentialId *uuid.UUID) (Pipeline, error)
  • func (db *Database) UpdatePipeline(pipelineId uuid.UUID, name *string, url *string, pollInterval *int) (Pipeline, error)
  • func (db *Database) UpdatePipelineRefs(pipelineId uuid.UUID, refsMap map[string]string) error
  • func (db *Database) UpdateRunBuildOutput(runId uuid.UUID, buildResult string) error
  • func (db *Database) UpdateRunResult(r Run) error
• type Pipeline
• type PipelineSecretMapping
• type Run
• type Runner
• type Secret
• type Webhook
• type WebhookSender

Types

type CloneCredential

type CloneCredential struct {
	Id       uuid.UUID
	Name     string
	Type     CloneCredentialType
	Username string
	Secret   string
}

type CloneCredentialType

type CloneCredentialType string

const (
	USER_PASS CloneCredentialType = "USER_PASS"
	SSH_KEY   CloneCredentialType = "SSH_KEY"
)

type CommandExecution

type CommandExecution struct {
	Id         uuid.UUID
	RunId      uuid.UUID
	Command    []string
	ReturnCode int
	Stdout     string
	Stderr     string
	StartTime  time.Time
	EndTime    time.Time
}

type Database

type Database struct {
	Conn *pgxpool.Pool
}

func LaunchDB

func LaunchDB(conf config.DBConfig) (Database, error)

func (*Database) AssignSecretToPipeline

func (db *Database) AssignSecretToPipeline(pipelineId uuid.UUID, secretId uuid.UUID) error

func (*Database) CreateCredential

func (db *Database) CreateCredential(name string, credentialtype CloneCredentialType, username string, secret string) (CloneCredential, error)

func (*Database) CreatePipeline

func (db *Database) CreatePipeline(name string, url string, pollInterval int, credential *uuid.UUID) (Pipeline, error)

func (*Database) CreateRun

func (db *Database) CreateRun(pipelineId uuid.UUID) (Run, error)

func (*Database) CreateRunner

func (db *Database) CreateRunner(name string) (Runner, error)

func (*Database) CreateSecret

func (db *Database) CreateSecret(name string, secret string) (Secret, error)

func (*Database) CreateWebhook

func (db *Database) CreateWebhook(serverType WebhookSender, pipelineId uuid.UUID) (Webhook, error)

func (*Database) GetCloneCredentialById

func (db *Database) GetCloneCredentialById(id uuid.UUID) (CloneCredential, error)

func (*Database) GetCredentials

func (db *Database) GetCredentials() ([]CloneCredential, error)

func (*Database) GetPipelineById

func (db *Database) GetPipelineById(id uuid.UUID) (Pipeline, error)

func (*Database) GetPipelineRefs

func (db *Database) GetPipelineRefs(pipelineId uuid.UUID) (map[string]string, error)

func (*Database) GetPipelines

func (db *Database) GetPipelines() ([]Pipeline, error)

func (*Database) GetRunnerById

func (db *Database) GetRunnerById(id uuid.UUID) (Runner, error)

func (*Database) GetRunners

func (db *Database) GetRunners() ([]Runner, error)

func (*Database) GetRunsForPipeline

func (db *Database) GetRunsForPipeline(pipelineId uuid.UUID) ([]Run, error)

func (*Database) GetSecretById

func (db *Database) GetSecretById(id uuid.UUID) (Secret, error)

func (*Database) GetSecrets

func (db *Database) GetSecrets() ([]Secret, error)

func (*Database) GetSecretsForPipeline

func (db *Database) GetSecretsForPipeline(pipelineId uuid.UUID) ([]Secret, error)

func (*Database) GetWebhookById

func (db *Database) GetWebhookById(id uuid.UUID) (Webhook, error)

func (*Database) GetWebhooksForPipeline

func (db *Database) GetWebhooksForPipeline(id uuid.UUID) ([]Webhook, error)

func (*Database) RemovePipelineCredential

func (db *Database) RemovePipelineCredential(pipelineId uuid.UUID) (Pipeline, error)

func (*Database) RemoveSecretFromPipeline

func (db *Database) RemoveSecretFromPipeline(pipelineId uuid.UUID, secretId uuid.UUID) error

func (*Database) SetPipelineCloneCredential

func (db *Database) SetPipelineCloneCredential(pipelineId uuid.UUID, credentialId *uuid.UUID) (Pipeline, error)

func (*Database) UpdatePipeline

func (db *Database) UpdatePipeline(pipelineId uuid.UUID, name *string, url *string, pollInterval *int) (Pipeline, error)

func (*Database) UpdatePipelineRefs

func (db *Database) UpdatePipelineRefs(pipelineId uuid.UUID, refsMap map[string]string) error

func (*Database) UpdateRunBuildOutput

func (db *Database) UpdateRunBuildOutput(runId uuid.UUID, buildResult string) error

func (*Database) UpdateRunResult

func (db *Database) UpdateRunResult(r Run) error

type Pipeline

type Pipeline struct {
	Id              uuid.UUID
	Name            string
	Url             string
	PollInterval    int
	CloneCredential *uuid.UUID
}

type PipelineSecretMapping

type PipelineSecretMapping struct {
	Pipeline uuid.UUID
	Secret   uuid.UUID
}

type Run

type Run struct {
	Id          uuid.UUID
	Pipeline    uuid.UUID
	InProgress  bool
	Result      *int64
	BuildOutput []byte
	Stdout      []byte
	Stderr      []byte
}

type Runner

type Runner struct {
	Id    uuid.UUID
	Name  string
	Token string
}

type Secret

type Secret struct {
	Id     uuid.UUID
	Name   string
	Secret string
}

type Webhook

type Webhook struct {
	Id         uuid.UUID
	ServerType WebhookSender
	Secret     string
	Pipeline   uuid.UUID
}

type WebhookSender

type WebhookSender string

const (
	Gitea WebhookSender = "gitea"
)