Skip to content
Snippets Groups Projects
Commit b4e718cf authored by sivan's avatar sivan
Browse files

added comments and remove unused file

parent 11371eed
No related branches found
No related tags found
No related merge requests found
......@@ -12,6 +12,7 @@ type Message struct {
type Gateway struct {
}
// CreateGateway creates a gateway
func CreateGateway() *Gateway {
return &Gateway{}
}
......
......@@ -2,6 +2,7 @@ package brokeradapter
import "github.com/streadway/amqp"
// GatewayInterface is an interface describing a GateWay
type GatewayInterface interface {
TransformMessage(msg amqp.Delivery) *Message
}
......@@ -63,7 +63,7 @@ func (d *Driver) CreateConsumer() Consumer {
return consumer
}
// CreateAliceProducer creates an AliceProducer on a certain exchange
// CreateProducer creates an AliceProducer on a certain exchange
func (d *Driver) CreateProducer() Producer {
exchangeID := "ui-direct-exchange"
......
......@@ -5,16 +5,19 @@ import (
"query-service/internal/drivers/brokerdriver"
)
// Driver is mock gateway
type Driver struct {
gateway brokeradapter.GatewayInterface
}
// CreateBroker is a creates a mock driver
func CreateBroker(gateway brokeradapter.GatewayInterface) *Driver {
return &Driver{
gateway: gateway,
}
}
// CreateConsumer creates a mock consumer
func (d *Driver) CreateConsumer() brokerdriver.Consumer {
return &Consumer{
broker: d,
......
......@@ -2,14 +2,17 @@ package mockbrokerdriver
import "query-service/internal/adapters/brokeradapter"
// Consumer is a mock consumer
type Consumer struct {
broker *Driver
}
// ConsumeMessages mocks the consume messages func
func (c *Consumer) ConsumeMessages() {
}
// SetMessageHandler mocks the setting of a message handler
func (c *Consumer) SetMessageHandler(handler func(msg *brokeradapter.Message)) {
}
package entity
import (
"context"
"fmt"
"os"
"query-service/pkg/logger"
"github.com/go-redis/redis/v8"
)
// RedisClient is the Redis client used throughout the service
var RedisClient *redis.Client
// NewRedisClient creates a new redis client
func NewRedisClient() {
}
......@@ -13,9 +13,11 @@ import (
"github.com/arangodb/go-driver/http"
)
// Service is a struct used to store this use case in
type Service struct {
}
// NewService creates a new instantion of this use case
func NewService() *Service {
return &Service{}
}
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment