api

Documentation

Index

• func BulkHandler(endpoint string, r *http.Request, server server.PGElasticServer) (response interface{}, err error)
• func DeleteDocumentHandler(index, typeName, endpoint string, r *http.Request, s server.PGElasticServer) (response interface{}, err error)
• func FindDocumentHandler(indexPattern, typePattern, endpoint string, r *http.Request, ...) (response interface{}, err error)
• func FindIndexDocumentHandler(endpoint string, r *http.Request, s server.PGElasticServer) (response interface{}, err error)
• func GetDocumentHandler(index, typeName, endpoint string, r *http.Request, s server.PGElasticServer) (response interface{}, err error)
• func HeadIndexHandler(endpoint string, r *http.Request, server server.PGElasticServer) (interface{}, error)
• func HealthHandler(endpoint string, r *http.Request, server server.PGElasticServer) (interface{}, error)
• func ProcessBulkQuery(rawQuery []string, server server.PGElasticServer) (interface{}, error)
• func PutDocumentHandler(index, typeName, endpoint string, r *http.Request, s server.PGElasticServer) (interface{}, error)
• func PutIndexHandler(endpoint string, r *http.Request, server server.PGElasticServer) (interface{}, error)
• func PutTypeMapping(endpoint string, r *http.Request, server server.PGElasticServer) (interface{}, error)

Functions

func BulkHandler

func BulkHandler(endpoint string, r *http.Request, server server.PGElasticServer) (response interface{}, err error)

BulkHandler handles ElasticSearch bulk requests

func DeleteDocumentHandler

func DeleteDocumentHandler(index, typeName, endpoint string, r *http.Request, s server.PGElasticServer) (response interface{}, err error)

DeleteDocumentHandler handles request to delete document from storage

func FindDocumentHandler

func FindDocumentHandler(indexPattern, typePattern, endpoint string, r *http.Request, s server.PGElasticServer) (response interface{}, err error)

FindDocumentHandler handles request to find document on storage

func FindIndexDocumentHandler

func FindIndexDocumentHandler(endpoint string, r *http.Request, s server.PGElasticServer) (response interface{}, err error)

FindIndexDocumentHandler handles request to find document of any type on storage

func GetDocumentHandler

func GetDocumentHandler(index, typeName, endpoint string, r *http.Request, s server.PGElasticServer) (response interface{}, err error)

GetDocumentHandler handles request to get document from storage

func HeadIndexHandler

func HeadIndexHandler(endpoint string, r *http.Request, server server.PGElasticServer) (interface{}, error)

HeadIndexHandler process a response to check is an index exists in database

func HealthHandler

func HealthHandler(endpoint string, r *http.Request, server server.PGElasticServer) (interface{}, error)

HealthHandler process a health-check response

func ProcessBulkQuery

func ProcessBulkQuery(rawQuery []string, server server.PGElasticServer) (interface{}, error)

ProcessBulkQuery processes a bulk query

func PutDocumentHandler

func PutDocumentHandler(index, typeName, endpoint string, r *http.Request, s server.PGElasticServer) (interface{}, error)

PutDocumentHandler handles request to put document into storage

func PutIndexHandler

func PutIndexHandler(endpoint string, r *http.Request, server server.PGElasticServer) (interface{}, error)

PutIndexHandler process a response to put a new index into database

func PutTypeMapping

func PutTypeMapping(endpoint string, r *http.Request, server server.PGElasticServer) (interface{}, error)

PutTypeMapping process a response to put a type mapping into database