elasticsearch

type BulkIndexerResponse struct {
	Took      int                                   `json:"took"`
	HasErrors bool                                  `json:"errors"`
	Items     []map[string]*BulkIndexerResponseItem `json:"items,omitempty"`
}

type BulkIndexerResponseItem struct {
	Index      string `json:"_index"`
	DocumentID string `json:"_id"`
	Version    int64  `json:"_version"`
	Result     string `json:"result"`
	Status     int    `json:"status"`
	SeqNo      int64  `json:"_seq_no"`
	PrimTerm   int64  `json:"_primary_term"`

	Shards struct {
		Total      int `json:"total"`
		Successful int `json:"successful"`
		Failed     int `json:"failed"`
	} `json:"_shards"`

	Error struct {
		Type   string `json:"type"`
		Reason string `json:"reason"`
		Cause  struct {
			Type   string `json:"type"`
			Reason string `json:"reason"`
		} `json:"caused_by"`
	} `json:"error,omitempty"`
}

type Client interface {
	Bulk(ctx context.Context, batch api.Batch) error
	Stop()
}

type ClientSet struct {
	// contains filtered or unexported fields
}

type Config struct {
	Hosts                 []string          `yaml:"hosts,omitempty" validate:"required"`
	UserName              string            `yaml:"username,omitempty"`
	Password              string            `yaml:"password,omitempty"`
	Index                 string            `yaml:"index,omitempty"`
	Headers               map[string]string `yaml:"headers,omitempty"`
	Params                map[string]string `yaml:"parameters,omitempty"`
	IfRenderIndexFailed   RenderIndexFail   `yaml:"ifRenderIndexFailed,omitempty"`
	Etype                 string            `yaml:"etype,omitempty"` // elasticsearch type, for v5.* backward compatibility
	DocumentId            string            `yaml:"documentId,omitempty"`
	APIKey                string            `yaml:"apiKey,omitempty"`
	ServiceToken          string            `yaml:"serviceToken,omitempty"`
	CACertPath            string            `yaml:"caCertPath,omitempty"`
	Compress              bool              `yaml:"compress,omitempty"`
	Gzip                  *bool             `yaml:"gzip,omitempty"` // deprecated, use compress above
	OpType                string            `yaml:"opType,omitempty" default:"index"`
	DiscoverNodesOnStart  bool              `yaml:"discoverNodesOnStart,omitempty"`
	DiscoverNodesInterval time.Duration     `yaml:"discoverNodesInterval,omitempty"`
}

type RenderIndexFail struct {
	DropEvent    bool   `yaml:"dropEvent,omitempty" default:"true"`
	IgnoreError  bool   `yaml:"ignoreError,omitempty"`
	DefaultIndex string `yaml:"defaultIndex,omitempty"`
}

type Sink struct {
	// contains filtered or unexported fields
}