rds

Documentation

Index

• func ParseRows(rows *sql.Rows, schema interface{}) ([]interface{}, error)
• type Store
  • func NewAwsRDS(cfg *config.RDS) Store

Functions

func ParseRows

func ParseRows(rows *sql.Rows, schema interface{}) ([]interface{}, error)

ParseRows will parse the row

Types

type Store

type Store interface {
	lifecycle.StartStopper

	// Get DB instance
	GetDB() *sql.DB

	// Transact wrap the transaction
	Transact(txFunc func(*sql.Tx) error) error
}

Store is the interface of KV store.

func NewAwsRDS

func NewAwsRDS(cfg *config.RDS) Store

NewAwsRDS instantiates an aws RDS based RDS