event

Documentation

Index

• func Create(ctx context.Context, conn repository.Querier, event *model.DbEvent) (*model.DbEvent, error)
• func CreateExtra(ctx context.Context, conn repository.Querier, event *model.DbEventExtra) error
• func DeleteById(ctx context.Context, conn repository.Querier, id int) (int, error)
• func DeleteExtraById(ctx context.Context, conn repository.Querier, id int) (int, error)
• func LoadAll(ctx context.Context, conn repository.Querier) (ret []*model.DbEvent, err error)
• func LoadById(ctx context.Context, conn repository.Querier, id int) (*model.DbEvent, error)
• func LoadByKey(ctx context.Context, conn repository.Querier, eventKey string) (*model.DbEvent, error)
• func UpdateReplayInfo(ctx context.Context, conn repository.Querier, eventKey string, ...) (int, error)

Functions

func Create

func Create(ctx context.Context, conn repository.Querier, event *model.DbEvent) (
	*model.DbEvent, error,
)

func CreateExtra

func CreateExtra(
	ctx context.Context,
	conn repository.Querier,
	event *model.DbEventExtra,
) error

func DeleteById

func DeleteById(ctx context.Context, conn repository.Querier, id int) (int, error)

deletes an entry from the database, returns number of rows deleted.

func DeleteExtraById

func DeleteExtraById(
	ctx context.Context,
	conn repository.Querier,
	id int,
) (int, error)

deletes the extra event data, returns number of rows deleted.

func LoadAll

func LoadAll(
	ctx context.Context,
	conn repository.Querier) (
	ret []*model.DbEvent, err error,
)

func LoadById

func LoadById(
	ctx context.Context,
	conn repository.Querier,
	id int,
) (*model.DbEvent, error)

func LoadByKey

func LoadByKey(
	ctx context.Context,
	conn repository.Querier,
	eventKey string,
) (*model.DbEvent, error)

func UpdateReplayInfo

func UpdateReplayInfo(
	ctx context.Context,
	conn repository.Querier,
	eventKey string,
	replayInfo model.ReplayInfo) (
	int, error,
)