repository

Documentation

Index

• type Delivery
  • func NewDelivery(db *sqlx.DB) *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 NewDeliveryAttempt(db *sqlx.DB) *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 NewMessage(db *sqlx.DB) *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
  • func NewMigration(db *sqlx.DB, migrationDir string) *Migration
  • func (m *Migration) Run(ctx context.Context) error
• type Subscription
  • func NewSubscription(db *sqlx.DB) *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 NewTopic(db *sqlx.DB) *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

Types

type Delivery

type Delivery struct {
	// contains filtered or unexported fields
}

Delivery is a implementation of hammer.DeliveryRepository

func NewDelivery

func NewDelivery(db *sqlx.DB) *Delivery

NewDelivery returns a new Delivery with db connection

func (Delivery) Dispatch

func (d Delivery) Dispatch(ctx context.Context) (*hammer.DeliveryAttempt, error)

Dispatch fetchs a delivery and send to url destination.

func (Delivery) Find

func (d Delivery) Find(ctx context.Context, id string) (*hammer.Delivery, error)

Find returns hammer.Delivery by id

func (Delivery) FindAll

func (d Delivery) FindAll(ctx context.Context, findOptions hammer.FindOptions) ([]*hammer.Delivery, error)

FindAll returns []hammer.Delivery by limit and offset

func (Delivery) Store

func (d Delivery) Store(ctx context.Context, delivery *hammer.Delivery) error

Store a hammer.Delivery on database (create or update)

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

func NewMessage(db *sqlx.DB) *Message

NewMessage returns a new Message with db connection

func (Message) Delete

func (m Message) Delete(ctx context.Context, id string) error

Delete a hammer.Message on database

func (Message) Find

func (m Message) Find(ctx context.Context, id string) (*hammer.Message, error)

Find returns hammer.Message by id

func (Message) FindAll

func (m Message) FindAll(ctx context.Context, findOptions hammer.FindOptions) ([]*hammer.Message, error)

FindAll returns []hammer.Message by limit and offset

func (Message) Store

func (m Message) Store(ctx context.Context, message *hammer.Message) error

Store a hammer.Message on database (create or update)

type Migration

type Migration struct {
	// contains filtered or unexported fields
}

Migration is a implementation of hammer.MigrationRepository

func NewMigration

func NewMigration(db *sqlx.DB, migrationDir string) *Migration

NewMigration will create a implementation of hammer.MigrationRepository

func (*Migration) Run

func (m *Migration) Run(ctx context.Context) error

Run migrations

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

func NewTopic

func NewTopic(db *sqlx.DB) *Topic

NewTopic returns a new Topic with db connection

func (*Topic) Delete

func (t *Topic) Delete(ctx context.Context, id string) error

Delete a hammer.Topic on database

func (*Topic) Find

func (t *Topic) Find(ctx context.Context, id string) (*hammer.Topic, error)

Find returns hammer.Topic by id

func (*Topic) FindAll

func (t *Topic) FindAll(ctx context.Context, findOptions hammer.FindOptions) ([]*hammer.Topic, error)

FindAll returns []hammer.Topic by limit and offset

func (*Topic) Store

func (t *Topic) Store(ctx context.Context, topic *hammer.Topic) error

Store a hammer.Topic on database (create or update)