client

package

v0.0.2 Latest Latest Go to latest Published: Apr 12, 2020 License: MIT Imports: 16 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/ll2l/esweb

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func PrintPrettyMap(query map[string]interface{})
type Client
type Dump
- func (d *Dump) Export(c *Client, writer io.Writer) error
- func (d *Dump) Migrate(c *Client, dstHost, dstUser, dstPass, dstIndex string, numItems int) error
type Pagination
type Record
type Row
type RowsOptions
type Table

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	DefaultCluster  = "http://localhost:9200"
	DefaultUser     = ""
	DefaultPassword = ""
	DefaultAlias    = ""
)

View Source

var DisablePrettyJSON = false

Functions ¶

func PrintPrettyMap ¶

func PrintPrettyMap(query map[string]interface{})

Types ¶

type Client ¶

type Client struct {
	Alias     string
	KibanaUrl string
	History   []Record `json:"history"`
	// contains filtered or unexported fields
}

func New ¶

func New() (*Client, error)

func NewFromBookmarks ¶

func NewFromBookmarks(conf bookmarks.Bookmark) (*Client, error)

func NewFromParams ¶

func NewFromParams(host, alias, user, password string) (*Client, error)

func (*Client) Alive ¶

func (c *Client) Alive() bool

func (*Client) ClusterName ¶

func (c *Client) ClusterName() (string, error)

func (*Client) Export ¶

func (c *Client) Export(indexName string, body string) (*searchResponse, error)

func (*Client) GetDsl ¶

func (c *Client) GetDsl(sql string) (dsl, index string, err error)

func (*Client) IndexInfo ¶

func (c *Client) IndexInfo(indexNames string) (map[string]interface{}, error)

func (*Client) Indices ¶

func (c *Client) Indices() ([]interface{}, error)

func (*Client) Info ¶

func (c *Client) Info() (map[string]interface{}, error)

func (*Client) ManageIndex ¶

func (c *Client) ManageIndex(index string, action string) error

func (*Client) Mapping ¶

func (c *Client) Mapping(indexName string) (map[string]interface{}, error)

func (*Client) Query ¶

func (c *Client) Query(sql string) (*searchResponse, error)

func (*Client) QueryRows ¶

func (c *Client) QueryRows(indexName string, opts RowsOptions) (*searchResponse, error)

func (*Client) Search ¶

func (c *Client) Search(indexName string, body string) (*searchResponse, error)

func (*Client) SearchWithBody ¶

func (c *Client) SearchWithBody(index, body string) (map[string]interface{}, error)

func (*Client) SetServerVersion ¶

func (c *Client) SetServerVersion()

func (*Client) Settings ¶

func (c *Client) Settings(indexName string) (map[string]interface{}, error)

func (*Client) Stats ¶

func (c *Client) Stats(indexName string) (map[string]interface{}, error)

func (*Client) Tasks ¶

func (c *Client) Tasks() (map[string]interface{}, error)

type Dump ¶

type Dump struct {
	Index  string
	Fields []string
}

Dump represents a database dump

func (*Dump) Export ¶

func (d *Dump) Export(c *Client, writer io.Writer) error

func (*Dump) Migrate ¶

func (d *Dump) Migrate(c *Client, dstHost, dstUser, dstPass, dstIndex string, numItems int) error

type Pagination struct {
	Rows    int64 `json:"rows_count"`
	Page    int64 `json:"page"`
	Pages   int64 `json:"pages_count"`
	PerPage int64 `json:"per_page"`
}

type Record ¶

type Record struct {
	Query     string `json:"query"`
	Timestamp string `json:"timestamp"`
}

type Row ¶

type Row []interface{}

type RowsOptions ¶

type RowsOptions struct {
	Where      string // Custom filter
	Offset     int    // Number of rows to skip
	Limit      int    // Number of rows to fetch
	SortColumn string // Column to sort by
	SortOrder  string // Sort direction (ASC, DESC)
}

type Table ¶

type Table struct {
	Columns    []string    `json:"columns"`
	Rows       []Row       `json:"rows"`
	Pagination *Pagination `json:"pagination,omitempty"`
}

func (*Table) CSV ¶

func (res *Table) CSV(withHeader bool) []byte

func (*Table) Format ¶

func (res *Table) Format() []map[string]interface{}

func (*Table) JSON ¶

func (res *Table) JSON() []byte

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL

Documentation ¶

Index ¶

Constants ¶

Variables ¶

Functions ¶

func PrintPrettyMap ¶

Types ¶

type Client ¶

func New ¶

func NewFromBookmarks ¶

func NewFromParams ¶

func (*Client) Alive ¶

func (*Client) ClusterName ¶

func (*Client) Export ¶

func (*Client) GetDsl ¶

func (*Client) IndexInfo ¶

func (*Client) Indices ¶

func (*Client) Info ¶

func (*Client) ManageIndex ¶

func (*Client) Mapping ¶

func (*Client) Query ¶

func (*Client) QueryRows ¶

func (*Client) Search ¶

func (*Client) SearchWithBody ¶

func (*Client) SetServerVersion ¶

func (*Client) Settings ¶

func (*Client) Stats ¶

func (*Client) Tasks ¶

type Dump ¶

func (*Dump) Export ¶

func (*Dump) Migrate ¶

type Pagination ¶

type Record ¶

type Row ¶

type RowsOptions ¶

type Table ¶

func (*Table) CSV ¶

func (*Table) Format ¶

func (*Table) JSON ¶

Source Files ¶