Documentation
¶
Index ¶
- type MessageModel
- func (messageModel *MessageModel) Insert(config db.MysqlConfig, subID string, msg *pubsub.Message) error
- func (messageModel *MessageModel) IsDuplicate(config db.MysqlConfig, subID string, msg *pubsub.Message) (bool, error)
- func (messageModel *MessageModel) Select(config db.MysqlConfig, selectQuery string) ([]MessageRow, error)
- func (messageModel *MessageModel) UpdateDeliveryAttempt(config db.MysqlConfig, subID string, msg *pubsub.Message) error
- type MessageRow
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MessageModel ¶
type MessageModel struct {
}
func (*MessageModel) Insert ¶
func (messageModel *MessageModel) Insert(config db.MysqlConfig, subID string, msg *pubsub.Message) error
func (*MessageModel) IsDuplicate ¶
func (messageModel *MessageModel) IsDuplicate(config db.MysqlConfig, subID string, msg *pubsub.Message) (bool, error)
func (*MessageModel) Select ¶
func (messageModel *MessageModel) Select(config db.MysqlConfig, selectQuery string) ([]MessageRow, error)
func (*MessageModel) UpdateDeliveryAttempt ¶
func (messageModel *MessageModel) UpdateDeliveryAttempt(config db.MysqlConfig, subID string, msg *pubsub.Message) error
type MessageRow ¶
type MessageRow struct {
MessageId sql.NullString
Subscription sql.NullString
Data sql.NullString
DecodedData sql.NullString
Attribute sql.NullString
PublishTime sql.NullTime
DeliveryAttempt sql.NullInt32
OrderingKey sql.NullString
}
Source Files
Click to show internal directories.
Click to hide internal directories.