database

Documentation

Index

• Variables
• func Commit(tx *ent.Tx, err error) error
• func CronGuildEvents(ctx context.Context) error
• func Migrate(ctx context.Context, logger log.Interface)
• func NewAuthService(db *ent.Client, adminIDs []string) *authService
• func NewGuildEventStream(ctx context.Context, inputs predicate.GuildEvent, ...) <-chan *ent.GuildEvent
• func Open(ctx context.Context, logger log.Interface, config models.ConfigDatabase) *ent.Client
• func ParseURL(config models.ConfigDatabase) (string, error)
• func Rollback(tx *ent.Tx, err error) error
• func RunWithTx(ctx context.Context, logger log.Interface, db *ent.Client, fn TxFn) error
• type TxFn

Variables

var Ping func(context.Context) error

Functions

func Commit

func Commit(tx *ent.Tx, err error) error

Commit will commit the transaction, unless the provided error is non-nil, in which case it will rollback the transaction and return a wrapped error.

func CronGuildEvents

func CronGuildEvents(ctx context.Context) error

func Migrate

func Migrate(ctx context.Context, logger log.Interface)

func NewAuthService

func NewAuthService(db *ent.Client, adminIDs []string) *authService

func NewGuildEventStream

func NewGuildEventStream(
	ctx context.Context,
	inputs predicate.GuildEvent,
	interval,
	oldest time.Duration,
) <-chan *ent.GuildEvent

func Open

func Open(ctx context.Context, logger log.Interface, config models.ConfigDatabase) *ent.Client

Open new postgres connection.

func ParseURL

func ParseURL(config models.ConfigDatabase) (string, error)

func Rollback

func Rollback(tx *ent.Tx, err error) error

Rollback will rollback the transaction and return a wrapped error of the original error.

func RunWithTx

func RunWithTx(ctx context.Context, logger log.Interface, db *ent.Client, fn TxFn) error

Types

type TxFn

type TxFn func(ctx context.Context, logger log.Interface, db *ent.Tx) error