Documentation
¶
Index ¶
- type Delivery
- type DeliveryAttempt
- type Message
- func (m Message) Create(ctx context.Context, message *hammer.Message) error
- 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)
- type Migration
- type Subscription
- func (s Subscription) Create(ctx context.Context, subscription *hammer.Subscription) error
- 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) Update(ctx context.Context, subscription *hammer.Subscription) error
- type Topic
- func (t Topic) Create(ctx context.Context, topic *hammer.Topic) error
- 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) Update(ctx context.Context, topic *hammer.Topic) error
- type Worker
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.DeliveryService
func NewDelivery ¶
func NewDelivery(deliveryRepo hammer.DeliveryRepository, deliveryAttemptRepo hammer.DeliveryAttemptRepository) *Delivery
NewDelivery returns a new Delivery with DeliveryRepo
type DeliveryAttempt ¶
type DeliveryAttempt struct {
// contains filtered or unexported fields
}
DeliveryAttempt is a implementation of hammer.DeliveryAttemptService
func NewDeliveryAttempt ¶
func NewDeliveryAttempt(deliveryAttemptRepo hammer.DeliveryAttemptRepository) *DeliveryAttempt
NewDeliveryAttempt returns a new DeliveryAttempt with DeliveryAttemptRepo
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 findOptions
type Message ¶
type Message struct {
// contains filtered or unexported fields
}
Message is a implementation of hammer.MessageService
func NewMessage ¶
func NewMessage(topicRepo hammer.TopicRepository, messageRepo hammer.MessageRepository, subscriptionRepo hammer.SubscriptionRepository, deliveryRepo hammer.DeliveryRepository) *Message
NewMessage returns a new Message with MessageRepo
type Migration ¶
type Migration struct {
// contains filtered or unexported fields
}
Migration is a implementation of hammer.MigrationService
func NewMigration ¶
func NewMigration(migrationService hammer.MigrationService) Migration
NewMigration will create a implementation of hammer.MigrationService
type Subscription ¶
type Subscription struct {
// contains filtered or unexported fields
}
Subscription is a implementation of hammer.SubscriptionService
func NewSubscription ¶
func NewSubscription(topicRepo hammer.TopicRepository, subscriptionRepo hammer.SubscriptionRepository) *Subscription
NewSubscription returns a new Subscription with SubscriptionRepo
func (Subscription) Create ¶
func (s Subscription) Create(ctx context.Context, subscription *hammer.Subscription) error
Create a hammer.Subscription on repository
func (Subscription) Delete ¶
func (s Subscription) Delete(ctx context.Context, id string) error
Delete a hammer.Subscription on repository
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 findOptions
func (Subscription) Update ¶
func (s Subscription) Update(ctx context.Context, subscription *hammer.Subscription) error
Update a hammer.Subscription on repository
type Topic ¶
type Topic struct {
// contains filtered or unexported fields
}
Topic is a implementation of hammer.TopicService
func NewTopic ¶
func NewTopic(topicRepo hammer.TopicRepository) *Topic
NewTopic returns a new Topic with topicRepo
Source Files