Documentation
¶
Index ¶
- type Delivery
- type DeliveryAttempt
- type Message
- type Migration
- type Subscription
- func (s *Subscription) Delete(tx hammer.TxRepository, id string) error
- func (s *Subscription) Find(id string) (hammer.Subscription, error)
- func (s *Subscription) FindAll(findOptions hammer.FindOptions) ([]hammer.Subscription, error)
- func (s *Subscription) Store(tx hammer.TxRepository, subscription *hammer.Subscription) error
- type Topic
- type Tx
- type TxFactory
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Delivery ¶
type Delivery struct {
// contains filtered or unexported fields
}
Delivery is a implementation of hammer.DeliveryRepository
func NewDelivery ¶
NewDelivery returns a new Delivery with db connection
func (*Delivery) FindToDispatch ¶
FindToDispatch returns []hammer.Delivery ready to dispatch by limit and offset
type DeliveryAttempt ¶
type DeliveryAttempt struct {
// contains filtered or unexported fields
}
DeliveryAttempt is a implementation of hammer.DeliveryAttemptRepository
func NewDeliveryAttempt ¶
func NewDeliveryAttempt(db *sqlx.DB) DeliveryAttempt
NewDeliveryAttempt returns a new DeliveryAttempt with db connection
func (*DeliveryAttempt) Find ¶
func (d *DeliveryAttempt) Find(id string) (hammer.DeliveryAttempt, error)
Find returns hammer.DeliveryAttempt by id
func (*DeliveryAttempt) FindAll ¶
func (d *DeliveryAttempt) FindAll(findOptions hammer.FindOptions) ([]hammer.DeliveryAttempt, error)
FindAll returns []hammer.DeliveryAttempt by limit and offset
func (*DeliveryAttempt) Store ¶
func (d *DeliveryAttempt) Store(tx hammer.TxRepository, deliveryAttempt *hammer.DeliveryAttempt) error
Store a hammer.DeliveryAttempt on database (create or update)
type Message ¶
type Message struct {
// contains filtered or unexported fields
}
Message is a implementation of hammer.MessageRepository
func NewMessage ¶
NewMessage returns a new Message with db connection
func (*Message) Delete ¶
func (m *Message) Delete(tx hammer.TxRepository, id string) error
Delete a hammer.Message on database
type Migration ¶
type Migration struct {
// contains filtered or unexported fields
}
Migration is a implementation of hammer.MigrationRepository
func NewMigration ¶
NewMigration will create a implementation of hammer.MigrationRepository
type Subscription ¶
type Subscription struct {
// contains filtered or unexported fields
}
Subscription is a implementation of hammer.SubscriptionRepository
func NewSubscription ¶
func NewSubscription(db *sqlx.DB) Subscription
NewSubscription returns a new Subscription with db connection
func (*Subscription) Delete ¶
func (s *Subscription) Delete(tx hammer.TxRepository, id string) error
Delete a hammer.Subscription on database
func (*Subscription) Find ¶
func (s *Subscription) Find(id string) (hammer.Subscription, error)
Find returns hammer.Subscription by id
func (*Subscription) FindAll ¶
func (s *Subscription) FindAll(findOptions hammer.FindOptions) ([]hammer.Subscription, error)
FindAll returns []hammer.Subscription by limit and offset
func (*Subscription) Store ¶
func (s *Subscription) Store(tx hammer.TxRepository, subscription *hammer.Subscription) error
Store a hammer.Subscription on database (create or update)
type Topic ¶
type Topic struct {
// contains filtered or unexported fields
}
Topic is a implementation of hammer.TopicRepository
func (*Topic) Delete ¶
func (t *Topic) Delete(tx hammer.TxRepository, id string) error
Delete a hammer.Topic on database
type Tx ¶
type Tx struct {
// contains filtered or unexported fields
}
Tx is a implementation of hammer.TxRepository
type TxFactory ¶
type TxFactory struct {
// contains filtered or unexported fields
}
TxFactory is a implementation of hammer.TxFactoryRepository
func NewTxFactory ¶
NewTxFactory returns a new TxFactory with db connection
Source Files