dbstore

Documentation

Index

• func MigrationSource() *migration.EmbedMigrationSource
• func RunMigration(dsn string) (int, error)
• type DbConstraintStore
  • func NewDbConstraintStore(dsn string) (*DbConstraintStore, error)
  • func (d *DbConstraintStore) Add(constraint *tarianpb.Constraint) error
  • func (d *DbConstraintStore) FindByNamespace(namespace string) ([]*tarianpb.Constraint, error)
  • func (d *DbConstraintStore) GetAll() ([]*tarianpb.Constraint, error)
  • func (d *DbConstraintStore) NamespaceAndNameExist(namespace, name string) (bool, error)
  • func (d *DbConstraintStore) RemoveByNamespaceAndName(namespace, name string) error
• type DbEventStore
  • func NewDbEventStore(dsn string) (*DbEventStore, error)
  • func (d *DbEventStore) Add(event *tarianpb.Event) error
  • func (d *DbEventStore) FindByNamespace(namespace string, limit uint) ([]*tarianpb.Event, error)
  • func (d *DbEventStore) FindWhereAlertNotSent() ([]*tarianpb.Event, error)
  • func (d *DbEventStore) GetAll(limit uint) ([]*tarianpb.Event, error)
  • func (d *DbEventStore) UpdateAlertSent(uid string) error

Functions

func MigrationSource

func MigrationSource() *migration.EmbedMigrationSource

func RunMigration

func RunMigration(dsn string) (int, error)

Types

type DbConstraintStore

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

DbConstraintStore implements store.ConstraintStore

func NewDbConstraintStore

func NewDbConstraintStore(dsn string) (*DbConstraintStore, error)

func (*DbConstraintStore) Add

func (d *DbConstraintStore) Add(constraint *tarianpb.Constraint) error

func (*DbConstraintStore) FindByNamespace

func (d *DbConstraintStore) FindByNamespace(namespace string) ([]*tarianpb.Constraint, error)

func (*DbConstraintStore) GetAll

func (d *DbConstraintStore) GetAll() ([]*tarianpb.Constraint, error)

func (*DbConstraintStore) NamespaceAndNameExist

func (d *DbConstraintStore) NamespaceAndNameExist(namespace, name string) (bool, error)

func (*DbConstraintStore) RemoveByNamespaceAndName

func (d *DbConstraintStore) RemoveByNamespaceAndName(namespace, name string) error

type DbEventStore

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

DbEventStore implements store.EventStore

func NewDbEventStore

func NewDbEventStore(dsn string) (*DbEventStore, error)

func (*DbEventStore) Add

func (d *DbEventStore) Add(event *tarianpb.Event) error

func (*DbEventStore) FindByNamespace

func (d *DbEventStore) FindByNamespace(namespace string, limit uint) ([]*tarianpb.Event, error)

func (*DbEventStore) FindWhereAlertNotSent

func (d *DbEventStore) FindWhereAlertNotSent() ([]*tarianpb.Event, error)

func (*DbEventStore) GetAll

func (d *DbEventStore) GetAll(limit uint) ([]*tarianpb.Event, error)

func (*DbEventStore) UpdateAlertSent

func (d *DbEventStore) UpdateAlertSent(uid string) error