Versions in this module Expand all Collapse all v0 v0.0.3 Apr 21, 2023 v0.0.2 Apr 19, 2023 v0.0.1 Apr 7, 2023 v0.0.0 Apr 5, 2023 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 + 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 + Transport esapi.Transport + WaitForActiveShards string + type BulkIndexerDebugLogger interface + Printf func(string, ...interface{}) + type BulkIndexerItem struct + Action string + Body io.ReadSeeker + DocumentID string + Index string + OnFailure func(context.Context, BulkIndexerItem, BulkIndexerResponseItem, error) + OnSuccess func(context.Context, BulkIndexerItem, BulkIndexerResponseItem) + RetryOnConflict *int + Routing string + Version *int64 + VersionType string + 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)
Go to main page