actiondb

Documentation

Index

• type ActionDb
  • func New(dbFileName string) (*ActionDb, error)
  • func (d ActionDb) Close() error
  • func (d ActionDb) CloseRecord(pipeId string, actionErr error, output string) error
  • func (d ActionDb) CreateRecord(pipeId string, project string, deliveryId string, conf config.Action) error
  • func (d ActionDb) GetPipelineRecord(pipeId string) (PipeLineRecord, error)
  • func (d ActionDb) ListPipelineRecords(search ListPipelineRecordsQuery) ([]PipeLineRecord, error)
• type ListPipelineRecordsQuery
• type PipeLineRecord
• type PipeStatus
  • func ParsePipelineStatus(status string) (PipeStatus, error)

Types

type ActionDb

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

func New

func New(dbFileName string) (*ActionDb, error)

func (ActionDb) Close

func (d ActionDb) Close() error

func (ActionDb) CloseRecord

func (d ActionDb) CloseRecord(pipeId string, actionErr error, output string) error

func (ActionDb) CreateRecord

func (d ActionDb) CreateRecord(pipeId string, project string, deliveryId string, conf config.Action) error

func (ActionDb) GetPipelineRecord

func (d ActionDb) GetPipelineRecord(pipeId string) (PipeLineRecord, error)

func (ActionDb) ListPipelineRecords

func (d ActionDb) ListPipelineRecords(search ListPipelineRecordsQuery) ([]PipeLineRecord, error)

type ListPipelineRecordsQuery

type ListPipelineRecordsQuery struct {
	Offset     int
	Limit      int
	Status     PipeStatus
	Project    string
	DeliveryId string
}

type PipeLineRecord

type PipeLineRecord struct {
	Id         int64           `db:"id"`
	PipeId     string          `db:"pipe_id"`
	Project    string          `db:"project"`
	DeliveryId string          `db:"delivery_id"`
	Config     json.RawMessage `db:"config"`
	Error      sql.NullString  `db:"error"`
	Output     sql.NullString  `db:"output"`
	CreatedAt  int64           `db:"created_at"`
	EndedAt    sql.NullInt64   `db:"ended_at"`
}

type PipeStatus

type PipeStatus int

const (
	PipeStatusAny     PipeStatus = 0
	PipeStatusOk      PipeStatus = 1
	PipeStatusError   PipeStatus = 2
	PipeStatusPending PipeStatus = 3
)

func ParsePipelineStatus

func ParsePipelineStatus(status string) (PipeStatus, error)