service

Documentation

Index

• Constants
• Variables
• type CacheService
  • func NewCacheService(client datastore.RedisStore, log kitlog.Logger) CacheService
• type Order
  • func OrderFromOrderSentMessage(msg messages.OrderSentMessage) (*Order, error)
  • func OrderFromProductionStatusChangedMessage(msg messages.ProductionStatusChangedMessage) (*Order, error)
  • func (o *Order) ToProductionStatusChangedMessage() messages.ProductionStatusChangedMessage
• type OrderStatus
• type ProductionService
  • func NewProductionService(cacheSvc CacheService, svc Publisher) ProductionService
• type Publisher
  • func NewPublisher(client datastore.RedisStore) Publisher

Constants

const (
	ORDER_STATUS_UNSET     OrderStatus = ""
	ORDER_STATUS_RECEIVED              = "Recebido"
	ORDER_STATUS_PREPARING             = "Em Preparação"
	ORDER_STATUS_DONE                  = "Pronto"
	ORDER_STATUS_FINISHED              = "Finalizado"
	ORDER_STATUS_CANCELED              = "Cancelado"
)

Variables

var ErrRecordNotFound = errors.New("no matching key found")

Types

type CacheService

type CacheService interface {
	SaveOrderStatusChanged(ctx context.Context, order Order) error
	GetOrder(ctx context.Context, orderID uuid.UUID) (*Order, error)
	SubscribeToIncomingOrders()
}

func NewCacheService

func NewCacheService(client datastore.RedisStore, log kitlog.Logger) CacheService

type Order

type Order struct {
	ID        uuid.UUID   `json:"id"`
	UpdatedAt time.Time   `json:"updated_at"`
	Status    OrderStatus `json:"status"`
}

func OrderFromOrderSentMessage

func OrderFromOrderSentMessage(msg messages.OrderSentMessage) (*Order, error)

func OrderFromProductionStatusChangedMessage

func OrderFromProductionStatusChangedMessage(msg messages.ProductionStatusChangedMessage) (*Order, error)

func (*Order) ToProductionStatusChangedMessage

func (o *Order) ToProductionStatusChangedMessage() messages.ProductionStatusChangedMessage

type OrderStatus

type OrderStatus string

type ProductionService

type ProductionService interface {
	UpdateOrderStatus(ctx context.Context, orderID uuid.UUID, status OrderStatus) (*Order, error)
	SubscribeToIncomingOrders()
}

func NewProductionService

func NewProductionService(cacheSvc CacheService, svc Publisher) ProductionService

type Publisher

type Publisher interface {
	PublishOrderStatusChanged(ctx context.Context, channel string, order messages.ProductionStatusChangedMessage) error
}

func NewPublisher

func NewPublisher(client datastore.RedisStore) Publisher