dao

Documentation

Index

• func Transact(db *DB, txFunc func(*DBTrans) error) error
• type DB
  • func New(conf *config.PostgresConfig) (*DB, error)
  • func (db *DB) AddDestination(destination *datafeed.AddDestinationRequest) (int64, error)
  • func (db *DB) DeleteDestination(delete *datafeed.DeleteDestinationRequest) error
  • func (db *DB) EnableDestination(ctx context.Context, destination *datafeed.UpdateDestinationEnableRequest) error
  • func (db *DB) GetDestination(get *datafeed.GetDestinationRequest) (*datafeed.GetDestinationResponse, error)
  • func (db *DB) ListDBDestinations() ([]Destination, error)
  • func (db *DB) ListDestinations() (*datafeed.ListDestinationResponse, error)
  • func (db *DB) UpdateDestination(destination *datafeed.UpdateDestinationRequest) error
• type DBTrans
• type Destination

Functions

func Transact

func Transact(db *DB, txFunc func(*DBTrans) error) error

Transact wraps your calls in a transaction. If the call should fail with an error it will perform a rollback. Otherwise the transaction will be committed.

Types

type DB

type DB struct {
	*gorp.DbMap
}

func New

func New(conf *config.PostgresConfig) (*DB, error)

func (*DB) AddDestination

func (db *DB) AddDestination(destination *datafeed.AddDestinationRequest) (int64, error)

func (*DB) DeleteDestination

func (db *DB) DeleteDestination(delete *datafeed.DeleteDestinationRequest) error

func (*DB) EnableDestination

func (db *DB) EnableDestination(ctx context.Context, destination *datafeed.UpdateDestinationEnableRequest) error

func (*DB) GetDestination

func (db *DB) GetDestination(get *datafeed.GetDestinationRequest) (*datafeed.GetDestinationResponse, error)

func (*DB) ListDBDestinations

func (db *DB) ListDBDestinations() ([]Destination, error)

func (*DB) ListDestinations

func (db *DB) ListDestinations() (*datafeed.ListDestinationResponse, error)

func (*DB) UpdateDestination

func (db *DB) UpdateDestination(destination *datafeed.UpdateDestinationRequest) error

type DBTrans

type DBTrans struct {
	*gorp.Transaction
}

type Destination

type Destination struct {
	ID               int64  `db:"id"`
	Name             string `db:"name"`
	URL              string `db:"url"`
	Secret           string `db:"secret"`
	Services         string `db:"services"`
	IntegrationTypes string `db:"integration_types"`
	MetaData         string `db:"meta_data"`
	Enable           bool   `db:"enable"`
}