bulk

Aug 28, 2023

Changes in this version

+ const UnknownStatusCode

+ type BulkDeleteRequest struct

+ func NewBulkDeleteRequest() *BulkDeleteRequest

+ func (r *BulkDeleteRequest) ID(id string) *BulkDeleteRequest

+ func (r *BulkDeleteRequest) Index(index string) *BulkDeleteRequest

+ func (r *BulkDeleteRequest) Source() ([]string, error)

+ func (r *BulkDeleteRequest) String() string

+ func (r *BulkDeleteRequest) Type(typ string) *BulkDeleteRequest

+ func (r *BulkDeleteRequest) Version(version int64) *BulkDeleteRequest

+ func (r *BulkDeleteRequest) VersionType(versionType string) *BulkDeleteRequest

+ type BulkIndexRequest struct

+ func NewBulkIndexRequest() *BulkIndexRequest

+ func (r *BulkIndexRequest) Doc(doc interface{}) *BulkIndexRequest

+ func (r *BulkIndexRequest) ID(id string) *BulkIndexRequest

+ func (r *BulkIndexRequest) Index(index string) *BulkIndexRequest

+ func (r *BulkIndexRequest) OpType(opType string) *BulkIndexRequest

+ func (r *BulkIndexRequest) Source() ([]string, error)

+ func (r *BulkIndexRequest) String() string

+ func (r *BulkIndexRequest) Type(typ string) *BulkIndexRequest

+ func (r *BulkIndexRequest) Version(version int64) *BulkIndexRequest

+ func (r *BulkIndexRequest) VersionType(versionType string) *BulkIndexRequest

+ type BulkProcessorParameters struct

+ AfterFunc GenericBulkAfterFunc

+ Backoff GenericBackoff

+ BeforeFunc GenericBulkBeforeFunc

+ BulkActions int

+ BulkSize int

+ FlushInterval time.Duration

+ Name string

+ NumOfWorkers int

+ type BulkUpdateRequest struct

+ func NewBulkUpdateRequest() *BulkUpdateRequest

+ func (r *BulkUpdateRequest) Doc(doc interface{}) *BulkUpdateRequest

+ func (r *BulkUpdateRequest) ID(id string) *BulkUpdateRequest

+ func (r *BulkUpdateRequest) Index(index string) *BulkUpdateRequest

+ func (r *BulkUpdateRequest) Source() ([]string, error)

+ func (r *BulkUpdateRequest) String() string

+ func (r *BulkUpdateRequest) Version(version int64) *BulkUpdateRequest

+ func (r *BulkUpdateRequest) VersionType(versionType string) *BulkUpdateRequest

+ type GenericBackoff interface

+ Next func(retry int) (time.Duration, bool)

+ func NewExponentialBackoff(initialTimeout, maxTimeout time.Duration) GenericBackoff

+ type GenericBulkAfterFunc func(executionId int64, requests []GenericBulkableRequest, ...)

+ type GenericBulkBeforeFunc func(executionId int64, requests []GenericBulkableRequest)

+ type GenericBulkProcessor interface

+ Add func(request *GenericBulkableAddRequest)

+ Close func() error

+ Flush func() error

+ Start func(ctx context.Context) error

+ Stop func() error

+ type GenericBulkResponse struct

+ Errors bool

+ Items []map[string]*GenericBulkResponseItem

+ Took int

+ type GenericBulkResponseItem struct

+ Error interface{}

+ ID string

+ Index string

+ Result string

+ Status int

+ Type string

+ Version int64

+ type GenericBulkableAddRequest struct

+ Doc interface{}

+ ID string

+ Index string

+ RequestType GenericBulkableRequestType

+ Type string

+ Version int64

+ VersionType string

+ type GenericBulkableRequest interface

+ Source func() ([]string, error)

+ String func() string

+ type GenericBulkableRequestType int

+ const BulkableCreateRequest

+ const BulkableDeleteRequest

+ const BulkableIndexRequest

+ type GenericError struct

+ Details error

+ Status int