Documentation
¶
Index ¶
Constants ¶
View Source
const ( //ProductKafkaTopic ... ProductKafkaTopic = "yuuxxq8y-product" //TaskKafkaTopic ... TaskKafkaTopic = "yuuxxq8y-task" )
Variables ¶
View Source
var GraphSet = wire.NewSet( ServerDeps, HTTPProvider, NewMetricServer, NewServerManager, NewKafkaConsumer, )
GraphSet ...
View Source
var ServerDeps = wire.NewSet( config.GraphSet, handler.GraphSet, services.GraphSet, repo_bind.GraphSet, infra.GraphSet, )
ServerDeps ...
Functions ¶
This section is empty.
Types ¶
type HTTPServer ¶
type HTTPServer struct {
// contains filtered or unexported fields
}
func HTTPProvider ¶
func HTTPProvider( ctx context.Context, prodPBHandler services_pb.ProductServiceServer, taskPBHandler services_pb.TaskServiceServer, ) (*HTTPServer, error)
HTTPProvider ...
type KafkaConsumer ¶
type KafkaConsumer struct {
// contains filtered or unexported fields
}
KafkaConsumer ...
func NewKafkaConsumer ¶
func NewKafkaConsumer( productService services.ProductServiceInterface, taskService services.TaskServiceInterface, repo repo.ProductRepoInterface, ) (*KafkaConsumer, error)
NewKafkaConsumer ...
type Manager ¶
type Manager struct {
// contains filtered or unexported fields
}
Manager ...
func NewServerManager ¶
func NewServerManager( httpServer *HTTPServer, metricServer *MetricServer, kafkaConsumer *KafkaConsumer, ) *Manager
NewServerManager ...
type MetricServer ¶
type MetricServer struct {
// contains filtered or unexported fields
}
MetricServer ...
func NewMetricServer ¶
func NewMetricServer( metricPort config.MetricPort, ) (*MetricServer, error)
NewMetricServer ...
Source Files
Click to show internal directories.
Click to hide internal directories.