elasticxbulk

Documentation

Index

• type Action
• type Operation
• type Option
  • func ErrorTrace(e bool) Option
  • func FilterPath(f ...string) Option
  • func Human(h bool) Option
  • func Pipeline(p string) Option
  • func Pretty(p bool) Option
  • func Refresh(r refresh.Refresh) Option
  • func RequireAlias(r bool) Option
  • func Routing(r string) Option
  • func Source(s string) Option
  • func SourceExcludes(s ...string) Option
  • func SourceIncludes(s ...string) Option
  • func Timeout(t string) Option
  • func WaitForActiveShards(w string) Option

Types

type Action

type Action string

const (
	ActionIndex  Action = "index"
	ActionCreate Action = "create"
	ActionUpdate Action = "update"
	ActionDelete Action = "delete"
)

type Operation

type Operation struct {
	IndexName  string
	Action     Action
	DocumentID string
	Doc        interface{}
}

type Option

type Option func(*bulk.Bulk)

func ErrorTrace

func ErrorTrace(e bool) Option

ErrorTrace When set to `true` Elasticsearch will include the full stack trace of errors when they occur. API name: error_trace

func FilterPath

func FilterPath(f ...string) Option

FilterPath Comma-separated list of filters used to reduce the response. API name: filter_path

func Human

func Human(h bool) Option

Human If true, the response will be prettified. API name: human

func Pipeline

func Pipeline(p string) Option

Pipeline ID of the pipeline to use to preprocess incoming documents. If the index has a default ingest pipeline specified, then setting the value to `_none` disables the default ingest pipeline for this request. If a final pipeline is configured it will always run, regardless of the value of this parameter. API name: pipeline

func Pretty

func Pretty(p bool) Option

Pretty If true, the response will be prettified. API name: pretty

func Refresh

func Refresh(r refresh.Refresh) Option

Refresh If `true`, Elasticsearch refreshes the affected shards to make this operation visible to search, if `wait_for` then wait for a refresh to make this operation visible to search, if `false` do nothing with refreshes. Valid values: `true`, `false`, `wait_for`. API name: refresh

func RequireAlias

func RequireAlias(r bool) Option

RequireAlias If true, requires destination to be an alias. API name: require_alias

func Routing

func Routing(r string) Option

Routing Custom value used to route operations to a specific shard. API name: routing

func Source

func Source(s string) Option

Source_ `true` or `false` to return the `_source` field or not, or a list of fields to return. API name: _source

func SourceExcludes

func SourceExcludes(s ...string) Option

SourceExcludes_ A comma-separated list of source fields to exclude from the response. API name: _source_excludes

func SourceIncludes

func SourceIncludes(s ...string) Option

SourceIncludes_ A comma-separated list of source fields to include in the response. API name: _source_includes

func Timeout

func Timeout(t string) Option

Timeout Explicit operation timeout. API name: timeout

func WaitForActiveShards

func WaitForActiveShards(w string) Option

WaitForActiveShards The number of shard copies that must be active before proceeding with the operation. Set to all or any positive integer up to the total number of shards in the index (`number_of_replicas+1`). API name: wait_for_active_shards