db

Documentation

Index

• func NewDB(db *sql.DB, logger log.Logger) store.DB
• type DB
  • func (db *DB) InsertSynchronizedCA(ctx context.Context, cloudConnectorID string, caName string, ...) error
  • func (db *DB) SelectAllSynchronizedCAs(ctx context.Context) ([]cloudproviders.DatabaseSynchronizedCA, error)
  • func (db *DB) SelectSynchronizedCAsByCaName(ctx context.Context, caName string) ([]cloudproviders.DatabaseSynchronizedCA, error)
  • func (db *DB) SelectSynchronizedCAsByConnectorID(ctx context.Context, connectorID string) ([]cloudproviders.DatabaseSynchronizedCA, error)
  • func (db *DB) SelectSynchronizedCAsByConnectorIDAndConnectorID(ctx context.Context, caName string, connectorID string) (cloudproviders.DatabaseSynchronizedCA, error)
  • func (db *DB) UpdateSynchronizedCA(ctx context.Context, cloudConnectorID string, caName string, ...) error

Functions

func NewDB

func NewDB(db *sql.DB, logger log.Logger) store.DB

Types

type DB

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

func (*DB) InsertSynchronizedCA

func (db *DB) InsertSynchronizedCA(ctx context.Context, cloudConnectorID string, caName string, enabledTs time.Time) error

func (*DB) SelectAllSynchronizedCAs

func (db *DB) SelectAllSynchronizedCAs(ctx context.Context) ([]cloudproviders.DatabaseSynchronizedCA, error)

func (*DB) SelectSynchronizedCAsByCaName

func (db *DB) SelectSynchronizedCAsByCaName(ctx context.Context, caName string) ([]cloudproviders.DatabaseSynchronizedCA, error)

func (*DB) SelectSynchronizedCAsByConnectorID

func (db *DB) SelectSynchronizedCAsByConnectorID(ctx context.Context, connectorID string) ([]cloudproviders.DatabaseSynchronizedCA, error)

func (*DB) SelectSynchronizedCAsByConnectorIDAndConnectorID

func (db *DB) SelectSynchronizedCAsByConnectorIDAndConnectorID(ctx context.Context, caName string, connectorID string) (cloudproviders.DatabaseSynchronizedCA, error)

func (*DB) UpdateSynchronizedCA

func (db *DB) UpdateSynchronizedCA(ctx context.Context, cloudConnectorID string, caName string, serial_number string) error