querymap

package
v0.0.0-...-35e5317 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 18, 2021 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CleanQueryMap

func CleanQueryMap(querymaps map[string]entity.Query,
	delmaps map[string]int64,
	wftasklist map[string]entity.Wftaskinfo,
	querymapsGuard sync.Mutex,
	delmapsGuard sync.RWMutex,
	producer sarama.SyncProducer,
	TopicInformation string,
	Separator string,
	looptime time.Duration)

func GetQueryMap

func GetQueryMap(cquerymap chan map[string]entity.Query,
	cservermap chan map[int]entity.JsonServer,
	queriesurl string, token string,
	batchsize string,
	looptime time.Duration)

Types

This section is empty.

Jump to

Keyboard shortcuts

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