client

Documentation

Index

• func BuildRabbitMQURL(c config.RabbitMQConfig) string
• func SendCommand[REQ any, RES any](connection *amqprpc.Client, routingKey string, command REQ) (*RES, error)
• type WeatherClient
  • func NewWeatherClient(rabbitMq config.RabbitMQConfig) *WeatherClient
  • func (wc *WeatherClient) RequestWeatherInformation(command weather.RequestWeatherInformation) (*weather.ResponseWeatherInformation, error)

Functions

func BuildRabbitMQURL

func BuildRabbitMQURL(c config.RabbitMQConfig) string

func SendCommand

func SendCommand[REQ any, RES any](connection *amqprpc.Client, routingKey string, command REQ) (*RES, error)

Types

type WeatherClient

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

func NewWeatherClient

func NewWeatherClient(rabbitMq config.RabbitMQConfig) *WeatherClient

func (*WeatherClient) RequestWeatherInformation

func (wc *WeatherClient) RequestWeatherInformation(command weather.RequestWeatherInformation) (*weather.ResponseWeatherInformation, error)