internal

Documentation

Index

• type DbConnection
  • func NewDbConnection(cacheAddress string, cachePort string) *DbConnection
• type Service
  • func NewService(cacheAddress string, cachePort string, stockAddress string, stockPort string, ...) *Service
  • func (service *Service) GetArticles(ctx context.Context, req *proto.RequestArticles) (*proto.ResponseArticles, error)
  • func (service *Service) ListenStockUpdates()

Types

type DbConnection

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

DbConnection handles all database operation

func NewDbConnection

func NewDbConnection(cacheAddress string, cachePort string) *DbConnection

NewDbConnection creates a connection to redis and makes an object (DbConnection) to interact with redis

type Service

type Service struct {
	proto.UnimplementedCatalogueServer
	rabbitmq.AmqpService
	// contains filtered or unexported fields
}

func NewService

func NewService(cacheAddress string, cachePort string, stockAddress string, stockPort string, rabbitAddress string, rabbitPort string) *Service

func (*Service) GetArticles

func (service *Service) GetArticles(ctx context.Context, req *proto.RequestArticles) (*proto.ResponseArticles, error)

GetArticles implementation of in the proto file defined interface of catalogue service

func (*Service) ListenStockUpdates

func (service *Service) ListenStockUpdates()

ListenStockUpdates reads out stockUpdate messages from bound amqp queue