pkg

Documentation

Index

• func CloseConnection(conn *sql.DB) error
• func DefaultLogger(ctx context.Context, query string, args ...any)
• func ExecWithLog(ctx context.Context, db *sql.DB, query string, args ...any) (sql.Result, error)
• func MigrateDatabase() error
• func NewConsumer(ctx context.Context, topics []string, groupID string, ...)
• func NewSqlcWithConnection[T any](ctx context.Context, factory SqlcFactory[T], opts ConnectOptions) (T, *sql.DB, error)
• func OpenConnection() (*sql.DB, error)
• func OpenConnectionV2(ctx context.Context, opts ConnectOptions) (*sql.DB, error)
• func QueryRowWithLog(ctx context.Context, db *sql.DB, query string, args ...any) *sql.Row
• func QueryWithLog(ctx context.Context, db *sql.DB, query string, args ...any) (*sql.Rows, error)
• type ConnectOptions
• type Consumer
• type Producer
  • func NewProducer(topic string) *Producer
  • func (producer *Producer) Close() error
  • func (producer *Producer) ProduceMessage(ctx context.Context, key string, value interface{}) error
• type QueryLogger
• type SqlcFactory

Functions

func CloseConnection

func CloseConnection(conn *sql.DB) error

func DefaultLogger

func DefaultLogger(ctx context.Context, query string, args ...any)

func ExecWithLog

func ExecWithLog(ctx context.Context, db *sql.DB, query string, args ...any) (sql.Result, error)

func MigrateDatabase

func MigrateDatabase() error

func NewConsumer

func NewConsumer(ctx context.Context, topics []string, groupID string, handler func(kafka.Message))

func NewSqlcWithConnection

func NewSqlcWithConnection[T any](ctx context.Context, factory SqlcFactory[T], opts ConnectOptions) (T, *sql.DB, error)

func OpenConnection

func OpenConnection() (*sql.DB, error)

func OpenConnectionV2

func OpenConnectionV2(ctx context.Context, opts ConnectOptions) (*sql.DB, error)

func QueryRowWithLog

func QueryRowWithLog(ctx context.Context, db *sql.DB, query string, args ...any) *sql.Row

func QueryWithLog

func QueryWithLog(ctx context.Context, db *sql.DB, query string, args ...any) (*sql.Rows, error)

Types

type ConnectOptions

type ConnectOptions struct {
	DSN             string
	MaxOpenConns    int
	MaxIdleConns    int
	ConnMaxIdle     time.Duration
	ConnMaxLifetime time.Duration
	ForceUTC        bool
	QueryLogger     QueryLogger
}

type Consumer

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

type Producer

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

func NewProducer

func NewProducer(topic string) *Producer

func (*Producer) Close

func (producer *Producer) Close() error

func (*Producer) ProduceMessage

func (producer *Producer) ProduceMessage(ctx context.Context, key string, value interface{}) error

type QueryLogger

type QueryLogger func(ctx context.Context, query string, args ...any)

type SqlcFactory

type SqlcFactory[T any] func(db *sql.DB) T