es

Documentation

Overview

bulk_insert -index=warehouse -type=product -n=100000 -bulk-size=1000

stan@ubuntuos:~/gowork/src/github.com/stanxii/allindex$ ./bulk_insert -index=warehouse -type=product -n=5000000 -bulk-size=5000

5000000 |   6585 req/s | 12:39

  bulk_insert -index=warehouse -type=product -n=100000 -bulk-size=1000

stan@ubuntuos:~/gowork/src/github.com/stanxii/allindex$ ./bulk_insert -index=warehouse -type=product -n=5000000 -bulk-size=5000

5000000 |   6585 req/s | 12:39

Index

• func BulkDelete(begin time.Time, total uint64, bulkSize *int, client *elastic.Client, ...) error
• func BulkUpdate(begin time.Time, total uint64, bulkSize *int, client *elastic.Client, ...) error

Functions

func BulkDelete

func BulkDelete(begin time.Time, total uint64, bulkSize *int, client *elastic.Client, g *errgroup.Group, ctx context.Context, docsc <-chan ds.DelDoc) error

func (bd *DelBulkClient) bulkDelete(total *uint64, client *elastic.Client, ctx *context.Context, docsc <-chan ds.DelDoc) error {

func BulkUpdate

func BulkUpdate(begin time.Time, total uint64, bulkSize *int, client *elastic.Client, g *errgroup.Group, ctx context.Context, docsc <-chan common.MapStr) error