The highest tagged major version is v3.

dbtoes

package

v2.1.43 Latest Latest Go to latest Published: Aug 14, 2025 License: MIT Imports: 4 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/bpcoder16/Chestnut

Links

Open Source Insights

Documentation ¶

Index ¶

func Default(ctx context.Context, esManager *esclientv7.Manager, index string, ...) error
func TimePeriod(ctx context.Context, esManager *esclientv7.Manager, index string, ...) error
func TimePeriodRetry(ctx context.Context, esManager *esclientv7.Manager, index string, ...) error
type ESCommonItem

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func Default ¶ added in v2.1.26

func Default(ctx context.Context, esManager *esclientv7.Manager, index string, lastId uint64, esDataListFunc func(lastId uint64, limit int) (uint64, []any, error)) error

func TimePeriod ¶

func TimePeriod(ctx context.Context, esManager *esclientv7.Manager, index string, lastTime time.Time, lastId uint64, esDataListFunc func(lastTime time.Time, lastId uint64, limit int) (time.Time, uint64, []any, error)) error

func TimePeriodRetry ¶ added in v2.1.27

func TimePeriodRetry(ctx context.Context, esManager *esclientv7.Manager, index string, lastTime time.Time, lastId uint64, esDataListFunc func(lastTime time.Time, lastId uint64, limit int) (time.Time, uint64, []any, error), retryTimes uint8) error

Types ¶

type ESCommonItem ¶

type ESCommonItem interface {
	GetDocId() string
}

Source Files ¶

View all Source files

db_to_es.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL