infrastructure

Documentation

Index

• func InitTracer(zipkinURL string, zipkinBridge bool) (stdopentracing.Tracer, zipkinreporter.Reporter)
• type CustomerRepository
  • func (c *CustomerRepository) CreateCustomer(name string, creditLimit float64) (string, error)
  • func (c *CustomerRepository) GetCustomerByName(name string) (*domain.Customer, error)
  • func (c *CustomerRepository) Ping() error
• type CustomerRepositoryInterface
  • func NewCustomerRepository() CustomerRepositoryInterface
• type MockEventBus
  • func (ev MockEventBus) Publish(queueName string, evt domain.Event) error

Functions

func InitTracer

func InitTracer(zipkinURL string, zipkinBridge bool) (stdopentracing.Tracer, zipkinreporter.Reporter)

Types

type CustomerRepository

type CustomerRepository struct {
	Customers map[string]*domain.Customer
}

func (*CustomerRepository) CreateCustomer

func (c *CustomerRepository) CreateCustomer(name string, creditLimit float64) (string, error)

func (*CustomerRepository) GetCustomerByName

func (c *CustomerRepository) GetCustomerByName(name string) (*domain.Customer, error)

func (*CustomerRepository) Ping

func (c *CustomerRepository) Ping() error

type CustomerRepositoryInterface

type CustomerRepositoryInterface interface {
	CreateCustomer(string, float64) (string, error)
	GetCustomerByName(string) (*domain.Customer, error)
	Ping() error
}

func NewCustomerRepository

func NewCustomerRepository() CustomerRepositoryInterface

type MockEventBus

type MockEventBus struct {
}

MockEventBus is a mock implementation of an event bus.

func (MockEventBus) Publish

func (ev MockEventBus) Publish(queueName string, evt domain.Event) error

Publish sends a new message to the event bus.