service

Documentation

Index

• type Consumer
• type ConsumerService
  • func NewConsumerService(repo data.CoffeeRepository, nc Subscriber, logger log.Logger) *ConsumerService
  • func (c ConsumerService) GetCoffees(msg Message)
  • func (c ConsumerService) RegisterConsumer(topic string, consumer Consumer)
• type Message
• type Outbox
  • func NewOutbox(db *data.OutboxRepository, p events.Publisher) Outbox
  • func (o *Outbox) Send(ctx context.Context, topic string, message []byte) (string, error)
  • func (o *Outbox) StartBackgroundPolling(interval time.Duration) (cancel func())
• type ProductService
  • func NewCoffeeService(repo data.CoffeeRepository, outbox *Outbox, logger log.Logger) *ProductService
  • func (p *ProductService) Add(w http.ResponseWriter, r *http.Request)
  • func (p *ProductService) Get(w http.ResponseWriter, r *http.Request)
  • func (p *ProductService) List(w http.ResponseWriter, r *http.Request)
  • func (p *ProductService) RegisterRoutes(r *mux.Router)
• type Subscriber

Types

type Consumer

type Consumer func(msg Message)

type ConsumerService

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

func NewConsumerService

func NewConsumerService(repo data.CoffeeRepository, nc Subscriber, logger log.Logger) *ConsumerService

func (ConsumerService) GetCoffees

func (c ConsumerService) GetCoffees(msg Message)

func (ConsumerService) RegisterConsumer

func (c ConsumerService) RegisterConsumer(topic string, consumer Consumer)

type Message

type Message interface {
	Respond(data []byte) error
}

type Outbox

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

func NewOutbox

func NewOutbox(db *data.OutboxRepository, p events.Publisher) Outbox

func (*Outbox) Send

func (o *Outbox) Send(ctx context.Context, topic string, message []byte) (string, error)

func (*Outbox) StartBackgroundPolling

func (o *Outbox) StartBackgroundPolling(interval time.Duration) (cancel func())

type ProductService

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

ProductService defines the operations the service supports

func NewCoffeeService

func NewCoffeeService(repo data.CoffeeRepository, outbox *Outbox, logger log.Logger) *ProductService

NewCoffeeService creates a new instance of the coffee service

func (*ProductService) Add

func (p *ProductService) Add(w http.ResponseWriter, r *http.Request)

Add adds a new coffee from the json body

func (*ProductService) Get

func (p *ProductService) Get(w http.ResponseWriter, r *http.Request)

Get retrieves a coffee by id

func (*ProductService) List

func (p *ProductService) List(w http.ResponseWriter, r *http.Request)

List retrieves a list of coffees

func (*ProductService) RegisterRoutes

func (p *ProductService) RegisterRoutes(r *mux.Router)

type Subscriber

type Subscriber interface {
	SubscribeSync(subj string) (*nats.Subscription, error)
}