store

Documentation

Index

• type Store
  • func From(db *sql.DB) *Store
  • func New(driver, config string) *Store
  • func NewTest() *Store
  • func (db *Store) Artifact(id string) (*model.Event, error)
  • func (db *Store) Artifacts(repo, branch string, gitEvent *dx.GitEvent, sourceBranch string, sha []string, ...) ([]*model.Event, error)
  • func (db *Store) CreateEvent(event *model.Event) (*model.Event, error)
  • func (db *Store) CreateUser(user *model.User) error
  • func (db *Store) DeleteUser(login string) error
  • func (db *Store) Event(id string) (*model.Event, error)
  • func (db *Store) GitopsCommit(sha string) (*model.GitopsCommit, error)
  • func (db *Store) KeyValue(key string) (*model.KeyValue, error)
  • func (db *Store) ReposWithCleanupPolicy() ([]string, error)
  • func (db *Store) SaveKeyValue(setting *model.KeyValue) error
  • func (db *Store) SaveOrUpdateGitopsCommit(gitopsCommit *model.GitopsCommit) error
  • func (db *Store) SaveReposWithCleanupPolicy(reposWithCleanupPolicy []string) error
  • func (db *Store) UnprocessedEvents() (events []*model.Event, err error)
  • func (db *Store) UpdateEventStatus(id string, status string, desc string, gitopsStatusString string) error
  • func (db *Store) User(login string) (*model.User, error)
  • func (db *Store) Users() ([]*model.User, error)

Types

type Store

type Store struct {
	*sql.DB
	// contains filtered or unexported fields
}

Store is used to access data from the sql/database driver with a relational database backend.

func From

func From(db *sql.DB) *Store

From returns a Store using an existing database connection.

func New

func New(driver, config string) *Store

New creates a database connection for the given driver and datasource and returns a new Store.

func NewTest

func NewTest() *Store

NewTest creates a new database connection for testing purposes. The database driver and connection string are provided by environment variables, with fallback to in-memory sqlite.

func (*Store) Artifact

func (db *Store) Artifact(id string) (*model.Event, error)

Artifact returns an artifact by id

func (*Store) Artifacts

func (db *Store) Artifacts(
	repo, branch string,
	gitEvent *dx.GitEvent,
	sourceBranch string,
	sha []string,
	limit, offset int,
	since, until *time.Time) ([]*model.Event, error)

Artifacts returns all events in the database within the given constraints

func (*Store) CreateEvent

func (db *Store) CreateEvent(event *model.Event) (*model.Event, error)

CreateEvent stores a new event in the database

func (*Store) CreateUser

func (db *Store) CreateUser(user *model.User) error

CreateUser stores a new user in the database

func (*Store) DeleteUser

func (db *Store) DeleteUser(login string) error

DeleteUser deletes a user in the database

func (*Store) Event

func (db *Store) Event(id string) (*model.Event, error)

Event returns an event by id

func (*Store) GitopsCommit

func (db *Store) GitopsCommit(sha string) (*model.GitopsCommit, error)

func (*Store) KeyValue

func (db *Store) KeyValue(key string) (*model.KeyValue, error)

KeyValue returns the value of a given KeyValue key

func (*Store) ReposWithCleanupPolicy

func (db *Store) ReposWithCleanupPolicy() ([]string, error)

func (*Store) SaveKeyValue

func (db *Store) SaveKeyValue(setting *model.KeyValue) error

SaveKeyValue sets a setting

func (*Store) SaveOrUpdateGitopsCommit

func (db *Store) SaveOrUpdateGitopsCommit(gitopsCommit *model.GitopsCommit) error

func (*Store) SaveReposWithCleanupPolicy

func (db *Store) SaveReposWithCleanupPolicy(reposWithCleanupPolicy []string) error

func (*Store) UnprocessedEvents

func (db *Store) UnprocessedEvents() (events []*model.Event, err error)

UnprocessedEvents selects an event timeline

func (*Store) UpdateEventStatus

func (db *Store) UpdateEventStatus(id string, status string, desc string, gitopsStatusString string) error

UpdateEventStatus updates an event status in the database

func (*Store) User

func (db *Store) User(login string) (*model.User, error)

User gets a user by its login name

func (*Store) Users

func (db *Store) Users() ([]*model.User, error)

Users returns all users in the database