Documentation
¶
Index ¶
- type Delivery
- func (d Delivery) Dispatch(ctx context.Context) (*hammer.DeliveryAttempt, error)
- func (d Delivery) Find(ctx context.Context, id string) (*hammer.Delivery, error)
- func (d Delivery) FindAll(ctx context.Context, findOptions hammer.FindOptions) ([]*hammer.Delivery, error)
- func (d Delivery) Store(ctx context.Context, delivery *hammer.Delivery) error
- type DeliveryAttempt
- func (d DeliveryAttempt) Find(ctx context.Context, id string) (*hammer.DeliveryAttempt, error)
- func (d DeliveryAttempt) FindAll(ctx context.Context, findOptions hammer.FindOptions) ([]*hammer.DeliveryAttempt, error)
- func (d DeliveryAttempt) Store(ctx context.Context, deliveryAttempt *hammer.DeliveryAttempt) error
- type Message
- func (m Message) Delete(ctx context.Context, id string) error
- func (m Message) Find(ctx context.Context, id string) (*hammer.Message, error)
- func (m Message) FindAll(ctx context.Context, findOptions hammer.FindOptions) ([]*hammer.Message, error)
- func (m Message) Store(ctx context.Context, message *hammer.Message) error
- type Migration
- type Subscription
- func (s *Subscription) Delete(ctx context.Context, id string) error
- func (s *Subscription) Find(ctx context.Context, id string) (*hammer.Subscription, error)
- func (s *Subscription) FindAll(ctx context.Context, findOptions hammer.FindOptions) ([]*hammer.Subscription, error)
- func (s *Subscription) Store(ctx context.Context, subscription *hammer.Subscription) error
- type Topic
- func (t *Topic) Delete(ctx context.Context, id string) error
- func (t *Topic) Find(ctx context.Context, id string) (*hammer.Topic, error)
- func (t *Topic) FindAll(ctx context.Context, findOptions hammer.FindOptions) ([]*hammer.Topic, error)
- func (t *Topic) Store(ctx context.Context, topic *hammer.Topic) error
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
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(ctx context.Context, id string) (*hammer.DeliveryAttempt, error)
Find returns hammer.DeliveryAttempt by id
func (DeliveryAttempt) FindAll ¶
func (d DeliveryAttempt) FindAll(ctx context.Context, findOptions hammer.FindOptions) ([]*hammer.DeliveryAttempt, error)
FindAll returns []hammer.DeliveryAttempt by limit and offset
func (DeliveryAttempt) Store ¶
func (d DeliveryAttempt) Store(ctx context.Context, 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
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(ctx context.Context, id string) error
Delete a hammer.Subscription on database
func (*Subscription) Find ¶
func (s *Subscription) Find(ctx context.Context, id string) (*hammer.Subscription, error)
Find returns hammer.Subscription by id
func (*Subscription) FindAll ¶
func (s *Subscription) FindAll(ctx context.Context, findOptions hammer.FindOptions) ([]*hammer.Subscription, error)
FindAll returns []hammer.Subscription by limit and offset
func (*Subscription) Store ¶
func (s *Subscription) Store(ctx context.Context, 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