service

Documentation

Index

• Variables
• func AddDocument(index string, data interface{}) error
• func GetAll() (meilisearch.DocumentsResult, error)
• func InitAmqp()
• func InitMelliClient()
• func InitRedisClient()
• func MultiSearch(queries []meilisearch.SearchRequest) (*meilisearch.MultiSearchResponse, error)
• func ProduceMessage(exchange, key, mime string, body interface{})
• func PublishMessage(ch *amqp.Channel, message QueueMessage) error
• func PublishTopic(topic string, payload interface{}) error
• func Search(index string, query string, SearchRequest meilisearch.SearchRequest) (*meilisearch.SearchResponse, error)
• type QueueMessage

Variables

var Ctx = context.Background()

var Melli *meilisearch.Client

var (
	RedisClient *redis.Client
)

Functions

func AddDocument

func AddDocument(index string, data interface{}) error

func GetAll

func GetAll() (meilisearch.DocumentsResult, error)

func InitAmqp

func InitAmqp()

func InitMelliClient

func InitMelliClient()

func InitRedisClient

func InitRedisClient()

func MultiSearch

func MultiSearch(queries []meilisearch.SearchRequest) (*meilisearch.MultiSearchResponse, error)

example

[]meilisearch.SearchRequest{
	{
		IndexUID: "movies",
		Query:    "pooh",
		Limit:    5,
	},
	{
		IndexUID: "movies",
		Query:    "nemo",
		Limit:    5,
	},
	{
		IndexUID: "movie_ratings",
		Query:    "us",
	},
},

func ProduceMessage

func ProduceMessage(exchange, key, mime string, body interface{})

func PublishMessage

func PublishMessage(ch *amqp.Channel, message QueueMessage) error

func PublishTopic

func PublishTopic(topic string, payload interface{}) error

func Search

func Search(index string, query string, SearchRequest meilisearch.SearchRequest) (*meilisearch.SearchResponse, error)

Types

type QueueMessage

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