Documentation
¶
Index ¶
- func Delete(db gorp.SqlExecutor, ID int64) error
- func Initialize(ctx context.Context, DBFunc func() *gorp.DbMap)
- func Insert(db gorp.SqlExecutor, bc *sdk.Broadcast) error
- func LoadAll(db gorp.SqlExecutor, userID string) ([]sdk.Broadcast, error)
- func LoadByID(db gorp.SqlExecutor, id int64, userID string) (*sdk.Broadcast, error)
- func MarkAsRead(db gorp.SqlExecutor, broadcastID int64, userID string) error
- func Update(db gorp.SqlExecutor, bc *sdk.Broadcast) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Delete ¶
func Delete(db gorp.SqlExecutor, ID int64) error
Delete removes broadcast from database
func Initialize ¶
Initialize starts goroutine for broadcast
func Insert ¶
func Insert(db gorp.SqlExecutor, bc *sdk.Broadcast) error
Insert insert a new worker broadcast in database
func MarkAsRead ¶
func MarkAsRead(db gorp.SqlExecutor, broadcastID int64, userID string) error
MarkAsRead mark the broadcast as read for an user
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.