sql

Documentation

Index

• type Config
  • func (c *Config) DatabaseURL() string
• type DeliveriesRepository
  • func NewDeliveriesRepository(sess db.Session) *DeliveriesRepository
  • func (dr *DeliveriesRepository) FindAllNotDelivered(ctx context.Context) ([]domain.Delivery, error)
  • func (dr *DeliveriesRepository) FindByIdentifier(ctx context.Context, identifier string) (domain.Delivery, error)
  • func (dr *DeliveriesRepository) Insert(ctx context.Context, delivery domain.Delivery) error
• type Delivery
• type Event

Types

type Config

type Config struct {
	URL          string
	SSLMode      string
	BinaryParams string
}

Config defines the SQL connection configuration

func (*Config) DatabaseURL

func (c *Config) DatabaseURL() string

DatabaseURL returns the url prepared with its param values.

type DeliveriesRepository

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

func NewDeliveriesRepository

func NewDeliveriesRepository(sess db.Session) *DeliveriesRepository

func (*DeliveriesRepository) FindAllNotDelivered

func (dr *DeliveriesRepository) FindAllNotDelivered(ctx context.Context) ([]domain.Delivery, error)

func (*DeliveriesRepository) FindByIdentifier

func (dr *DeliveriesRepository) FindByIdentifier(ctx context.Context, identifier string) (domain.Delivery, error)

func (*DeliveriesRepository) Insert

func (dr *DeliveriesRepository) Insert(ctx context.Context, delivery domain.Delivery) error

type Delivery

type Delivery struct {
	Identifier string  `db:"identifier"`
	Events     []Event `db:"events"`
	Delivered  bool    `db:"delivered"`
}

type Event

type Event struct {
	Timestamp   string `json:"timestamp"`
	Information string `json:"information"`
}