transport

Documentation

Index

• func MakeHTTPHandler(endpoints endpoint.Endpoints, log log.Logger) http.Handler
• func NewGRPCServer(endpoints endpoint.Endpoints, logger log.Logger) pb.CrimeServiceServer
• func NewRabbitMqServer(endpoints endpoint.Endpoints, logg log.Logger, conf RabbitMQConfig) error
• type RabbitMQConfig

Functions

func MakeHTTPHandler

func MakeHTTPHandler(endpoints endpoint.Endpoints, log log.Logger) http.Handler

func NewGRPCServer

func NewGRPCServer(endpoints endpoint.Endpoints, logger log.Logger) pb.CrimeServiceServer

NewGRPCServer initializes a new gRPC server

func NewRabbitMqServer

func NewRabbitMqServer(endpoints endpoint.Endpoints, logg log.Logger, conf RabbitMQConfig) error

Types

type RabbitMQConfig

type RabbitMQConfig struct {
	Channel *amqp.Channel
}