event

Documentation

Index

• func Create(ctx context.Context, conn repository.Querier, event *eventv1.Event, ...) error
• func DeleteById(ctx context.Context, conn repository.Querier, id int) (int, error)
• func LoadAll(ctx context.Context, conn repository.Querier, tenantId *uint32) ([]*eventv1.Event, error)
• func LoadById(ctx context.Context, conn repository.Querier, id int) (*eventv1.Event, error)
• func LoadByKey(ctx context.Context, conn repository.Querier, key string) (*eventv1.Event, error)
• func UpdateEvent(ctx context.Context, conn repository.Querier, id int, ...) error
• func UpdateReplayInfo(ctx context.Context, conn repository.Querier, id int, ...) error

Functions

func Create

func Create(
	ctx context.Context,
	conn repository.Querier,
	event *eventv1.Event,
	tenantId uint32,
) 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 LoadAll

func LoadAll(ctx context.Context, conn repository.Querier, tenantId *uint32) (
	[]*eventv1.Event, error,
)

func LoadById

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

func LoadByKey

func LoadByKey(ctx context.Context, conn repository.Querier, key string) (
	*eventv1.Event, error,
)

func UpdateEvent

func UpdateEvent(
	ctx context.Context,
	conn repository.Querier,
	id int,
	req *eventv1.UpdateEventRequest,
) error

updates selected event attributes

func UpdateReplayInfo

func UpdateReplayInfo(
	ctx context.Context,
	conn repository.Querier,
	id int,
	replayInfo *eventv1.ReplayInfo,
) error

updates the ReplayInfo in the database for an event.