repository

Documentation

Index

• type CLIRepository
  • func NewCLIRepository(db *gorm.DB) *CLIRepository
  • func (repo *CLIRepository) Create(ctx context.Context, events model.Events) error
  • func (repo *CLIRepository) Delete(ctx context.Context, events model.Events) error
  • func (repo *CLIRepository) GetMarked(ctx context.Context) (model.Events, error)
  • func (repo *CLIRepository) MarkSent(ctx context.Context) error
  • func (repo *CLIRepository) WithTx(txProvider service.TxProvider) service.Repository
• type TxProvider
  • func NewTxProvider(db *gorm.DB) *TxProvider
  • func (p *TxProvider) Transaction(f func(txProvider service.TxProvider) error) error

Types

type CLIRepository

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

func NewCLIRepository

func NewCLIRepository(db *gorm.DB) *CLIRepository

func (*CLIRepository) Create

func (repo *CLIRepository) Create(ctx context.Context, events model.Events) error

func (*CLIRepository) Delete

func (repo *CLIRepository) Delete(ctx context.Context, events model.Events) error

func (*CLIRepository) GetMarked

func (repo *CLIRepository) GetMarked(ctx context.Context) (model.Events, error)

func (*CLIRepository) MarkSent

func (repo *CLIRepository) MarkSent(ctx context.Context) error

func (*CLIRepository) WithTx

func (repo *CLIRepository) WithTx(txProvider service.TxProvider) service.Repository

type TxProvider

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

func NewTxProvider

func NewTxProvider(db *gorm.DB) *TxProvider

func (*TxProvider) Transaction

func (p *TxProvider) Transaction(f func(txProvider service.TxProvider) error) error