es

Documentation

Index

• func DefaultNewClient(c *ClientConfig, cc *Config) (es *elasticsearch.Client, err error)
• func OperationApiLog(c *Client, op, idx, body string) func()
• type Client
  • func (c *Client) CliFlags(name string) []cli.Flag
  • func (c *Client) Load(name string, cfg *Config) (err error)
  • func (c *Client) Ref() *Component
• type ClientConfig
• type Component
  • func (c *Component) CliFlags() []cli.Flag
  • func (c *Component) Close(_ logger.Interface, _ gsf.Config) (err error)
  • func (c *Component) Init(log logger.Interface, cfg gsf.Config) error
  • func (c *Component) Run(_ logger.Interface, _ gsf.Config) error
• type Config
• type Operation
  • func NewOperation(c *Client) *Operation
  • func (c *Operation) Search(idx string, body string, receive interface{}, ctx context.Context) (cnt uint64, err error)
• type RespBasic
• type RespError
• type RespSearch
• type RespSearchItem

Functions

func DefaultNewClient

func DefaultNewClient(c *ClientConfig, cc *Config) (es *elasticsearch.Client, err error)

func OperationApiLog

func OperationApiLog(c *Client, op, idx, body string) func()

Types

type Client

type Client struct {
	Client *elasticsearch.Client
	Cfg    ClientConfig

	Log          logger.Interface
	CreateClient func(c *ClientConfig, cc *Config) (es *elasticsearch.Client, err error)
	// contains filtered or unexported fields
}

func (*Client) CliFlags

func (c *Client) CliFlags(name string) []cli.Flag

func (*Client) Load

func (c *Client) Load(name string, cfg *Config) (err error)

func (*Client) Ref

func (c *Client) Ref() *Component

type ClientConfig

type ClientConfig struct {
	Host        []string `json:"host"       yaml:"host"`
	Pwd         string   `json:"password"   yaml:"password"`
	User        string   `json:"user"       yaml:"user"`
	MaxIdleConn int      `json:"idle_limit" yaml:"idle_limit"`
}

type Component

type Component struct {
	DSNPrint bool
	Cfg      Config
	Clts     map[string]*Client
}

func (*Component) CliFlags

func (c *Component) CliFlags() []cli.Flag

func (*Component) Close

func (c *Component) Close(_ logger.Interface, _ gsf.Config) (err error)

func (*Component) Init

func (c *Component) Init(log logger.Interface, cfg gsf.Config) error

func (*Component) Run

func (c *Component) Run(_ logger.Interface, _ gsf.Config) error

type Config

type Config struct {
	MaxConnTime   int `json:"max_con_time"    yaml:"max_con_time"`
	MaxIdleTime   int `json:"max_idle_time"   yaml:"max_idle_time"`
	KeepAliveTime int `json:"keep_alive_time" yaml:"keep_alive_time"`
	SlowThreshold int `json:"slow_threshold"  yaml:"slow_threshold"`
}

type Operation

type Operation struct {
	ApiLog func(c *Client, op, idx, body string) func()
	// contains filtered or unexported fields
}

func NewOperation

func NewOperation(c *Client) *Operation

func (*Operation) Search

func (c *Operation) Search(idx string, body string, receive interface{}, ctx context.Context) (cnt uint64, err error)

type RespBasic

type RespBasic struct {
	Took     uint64 `json:"took"`
	TimedOut bool   `json:"timed_out"`
}

type RespError

type RespError struct {
	Status uint64 `json:"status"`
	Error  struct {
		Type   string `json:"type"`
		Reason string `json:"reason"`
	} `json:"error"`
}

type RespSearch

type RespSearch struct {
	RespBasic
	Hits struct {
		Total struct {
			Value    uint64 `json:"value"`
			Relation string `json:"relation"`
		} `json:"total"`
		Hits interface{} `json:"hits"`
	} `json:"hits"`
}

type RespSearchItem

type RespSearchItem[T any] struct {
	Id     string `json:"_id"`
	Source T      `json:"_source"`
}