Versions in this module Expand all Collapse all v1 v1.1.0 Feb 11, 2022 Changes in this version type BulkIndexerItem + IfPrimaryTerm *int64 + IfSeqNum *int64 + Refresh *string + RequireAlias *bool + Routing *string + Version *int64 + VersionType *string + WaitForActiveShards interface{} v1.0.0 Aug 31, 2021 Changes in this version + func NewJSONReader(v interface{}) io.Reader + type BulkIndexer interface + Add func(context.Context, BulkIndexerItem) error + Close func(context.Context) error + Stats func() BulkIndexerStats + func NewBulkIndexer(cfg BulkIndexerConfig) (BulkIndexer, error) + type BulkIndexerConfig struct + Client *opensearch.Client + DebugLogger BulkIndexerDebugLogger + Decoder BulkResponseJSONDecoder + ErrorTrace bool + FilterPath []string + FlushBytes int + FlushInterval time.Duration + Header http.Header + Human bool + Index string + NumWorkers int + OnError func(context.Context, error) + OnFlushEnd func(context.Context) + OnFlushStart func(context.Context) context.Context + Pipeline string + Pretty bool + Refresh string + Routing string + Source []string + SourceExcludes []string + SourceIncludes []string + Timeout time.Duration + WaitForActiveShards string + type BulkIndexerDebugLogger interface + Printf func(string, ...interface{}) + type BulkIndexerItem struct + Action string + Body io.Reader + DocumentID string + Index string + OnFailure func(context.Context, BulkIndexerItem, BulkIndexerResponseItem, error) + OnSuccess func(context.Context, BulkIndexerItem, BulkIndexerResponseItem) + RetryOnConflict *int + type BulkIndexerResponse struct + HasErrors bool + Items []map[string]BulkIndexerResponseItem + Took int + type BulkIndexerResponseItem struct + DocumentID string + Error struct{ ... } + Index string + PrimTerm int64 + Result string + SeqNo int64 + Shards struct{ ... } + Status int + Version int64 + type BulkIndexerStats struct + NumAdded uint64 + NumCreated uint64 + NumDeleted uint64 + NumFailed uint64 + NumFlushed uint64 + NumIndexed uint64 + NumRequests uint64 + NumUpdated uint64 + type BulkResponseJSONDecoder interface + UnmarshalFromReader func(io.Reader, *BulkIndexerResponse) error + type JSONEncoder interface + EncodeJSON func(io.Writer) error + type JSONReader struct + func (r *JSONReader) Read(p []byte) (int, error) + func (r *JSONReader) WriteTo(w io.Writer) (int64, error) Other modules containing this package github.com/opensearch-project/opensearch-go/v2 github.com/opensearch-project/opensearch-go/v3 github.com/opensearch-project/opensearch-go/v4
Go to main page