infra

Documentation

Index

• type ConsumerMQ
  • func NewConsumerMQ(rabbitCli *RabbitMQ) *ConsumerMQ
  • func (r *ConsumerMQ) Get(ctx context.Context, req *models.GetMessagesRequest) ([]models.GetMessagesResponse, error)
• type GRPC
  • func NewGRPC() *GRPC
  • func (g *GRPC) Close()
  • func (g *GRPC) GetConn(address string) (*grpc.ClientConn, error)
• type HTTPCli
  • func NewHTTPCli() *HTTPCli
• type MessageRabbit
• type RabbitMQ
  • func NewRabbitMQ(user, password, host, vhost string, port int) *RabbitMQ
  • func (r *RabbitMQ) Close()
  • func (r *RabbitMQ) GetRabbitmqAMQP() (*amqp.Connection, *amqp.Channel)

Types

type ConsumerMQ

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

func NewConsumerMQ

func NewConsumerMQ(rabbitCli *RabbitMQ) *ConsumerMQ

func (*ConsumerMQ) Get

func (r *ConsumerMQ) Get(ctx context.Context, req *models.GetMessagesRequest) ([]models.GetMessagesResponse, error)

type GRPC

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

func NewGRPC

func NewGRPC() *GRPC

func (*GRPC) Close

func (g *GRPC) Close()

func (*GRPC) GetConn

func (g *GRPC) GetConn(address string) (*grpc.ClientConn, error)

type HTTPCli

type HTTPCli struct {
	*http.Client
}

func NewHTTPCli

func NewHTTPCli() *HTTPCli

type MessageRabbit

type MessageRabbit struct {
	Body []byte
	Type string
}

type RabbitMQ

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

func NewRabbitMQ

func NewRabbitMQ(user, password, host, vhost string, port int) *RabbitMQ

func (*RabbitMQ) Close

func (r *RabbitMQ) Close()

func (*RabbitMQ) GetRabbitmqAMQP

func (r *RabbitMQ) GetRabbitmqAMQP() (*amqp.Connection, *amqp.Channel)