esbulk

package

v0.2.1 Latest Latest Go to latest Published: Dec 17, 2020 License: Apache-2.0 Imports: 8 Imported by: 0

Details

View Source

const (
	DefaultFileSize = uint32(1 * 1024 * 1024)    // 1 MB
	MaxFileSize     = uint32(2048 * 1024 * 1024) // 20 GB
)

This section is empty.

func New(fileSize uint32) handler.Handler

func Register(cfg *config.Config)

Register 注册事件Handler

type ElasticBulkHandler struct {
	// contains filtered or unexported fields
}

ElasticBulkHandler Bulk JSON 导入文件 Handler

func (h *ElasticBulkHandler) Handle(evt *event.Event) error