remove

Documentation

Overview

Package remove Some tasks to operate ES

Index

• func BindRemoveCPLogs()
• type MonitorTaskConfig
  • func (c *MonitorTaskConfig) Lock()
  • func (c *MonitorTaskConfig) SetLock(l *sync.Mutex)
  • func (c *MonitorTaskConfig) Unlock()
• type Query
• type Range
• type Resp

Functions

func BindRemoveCPLogs

func BindRemoveCPLogs()

BindRemoveCPLogs Tasks to remove documents in ES

Types

type MonitorTaskConfig

type MonitorTaskConfig struct {
	Index  string
	Expire int
	Term   *map[string]interface{}
	// contains filtered or unexported fields
}

MonitorTaskConfig config for each ES index

func (*MonitorTaskConfig) Lock

func (c *MonitorTaskConfig) Lock()

func (*MonitorTaskConfig) SetLock

func (c *MonitorTaskConfig) SetLock(l *sync.Mutex)

func (*MonitorTaskConfig) Unlock

func (c *MonitorTaskConfig) Unlock()

type Query

type Query struct {
	Range *Range `json:"query"`
	Size  int    `json:"size"`
	// Sort  []map[string]string     `json:"sort"`
	Term *map[string]interface{} `json:"term,omitempty"`
}

Query json query to request elasticsearch

type Range

type Range struct {
	Range map[string]interface{} `json:"range"`
}

Range range query in Query

type Resp

type Resp struct {
	Deleted int `json:"deleted"`
	Total   int `json:"total"`
}

Resp json response from elasticsearch