Documentation ¶
Index ¶
- Constants
- func AddAndGetRealIndexName(indexNameIn string, localIndexMap map[string]string, myid uint64) string
- func HandleBulkBody(postBody []byte, ctx *fasthttp.RequestCtx, myid uint64, ...) (int, map[string]interface{}, error)
- func PostBulkErrorResponse(ctx *fasthttp.RequestCtx)
- func ProcessBulkRequest(ctx *fasthttp.RequestCtx, myid uint64, ...)
- func ProcessGetAlias(ctx *fasthttp.RequestCtx, myid uint64)
- func ProcessGetAllAliases(ctx *fasthttp.RequestCtx, myid uint64)
- func ProcessGetIndexAlias(ctx *fasthttp.RequestCtx, myid uint64)
- func ProcessIndexAliasExist(ctx *fasthttp.RequestCtx, myid uint64)
- func ProcessIndexRequest(rawJson []byte, tsNow uint64, indexNameIn string, bytesReceived uint64, ...) error
- func ProcessPostAliasesRequest(ctx *fasthttp.RequestCtx, myid uint64)
- func ProcessPutAliasesRequest(ctx *fasthttp.RequestCtx, myid uint64)
- func ProcessPutIndex(ctx *fasthttp.RequestCtx, myid uint64)
Constants ¶
View Source
const ( INDEX = iota CREATE UPDATE DELETE )
View Source
const CREATE_TOP_STR string = "create"
View Source
const INDEX_TOP_STR string = "index"
View Source
const INDEX_UNDER_STR string = "_index"
View Source
const UPDATE_TOP_STR string = "update"
Variables ¶
This section is empty.
Functions ¶
func AddAndGetRealIndexName ¶
func HandleBulkBody ¶
func PostBulkErrorResponse ¶
func PostBulkErrorResponse(ctx *fasthttp.RequestCtx)
func ProcessBulkRequest ¶
func ProcessBulkRequest(ctx *fasthttp.RequestCtx, myid uint64, kibanaIngHandlerFn kibanaIngHandlerFnDef)
func ProcessGetAlias ¶
func ProcessGetAlias(ctx *fasthttp.RequestCtx, myid uint64)
func ProcessGetAllAliases ¶
func ProcessGetAllAliases(ctx *fasthttp.RequestCtx, myid uint64)
func ProcessGetIndexAlias ¶
func ProcessGetIndexAlias(ctx *fasthttp.RequestCtx, myid uint64)
func ProcessIndexAliasExist ¶
func ProcessIndexAliasExist(ctx *fasthttp.RequestCtx, myid uint64)
func ProcessIndexRequest ¶
func ProcessPostAliasesRequest ¶
func ProcessPostAliasesRequest(ctx *fasthttp.RequestCtx, myid uint64)
func ProcessPutAliasesRequest ¶
func ProcessPutAliasesRequest(ctx *fasthttp.RequestCtx, myid uint64)
func ProcessPutIndex ¶
func ProcessPutIndex(ctx *fasthttp.RequestCtx, myid uint64)
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.