README
¶
nksh
Neo4j-Kafka-Stream-Handler
Documentation
¶
Index ¶
- func CloseNeo4j()
- func ConnectNeo4j(host string) error
- func DNSLookupIP(host string, retrys int) ([]net.IP, error)
- func LookupClusterHosts(host string, port int, params ...string) ([]string, error)
- func Neo4jDriver() neo4j.Driver
- func SetLogger(logger logrus.FieldLogger)
- func Startup(kafkaHost, zookeeperHost string, funcs ...shared.DispatcherFunc) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CloseNeo4j ¶
func CloseNeo4j()
func ConnectNeo4j ¶
func LookupClusterHosts ¶
func Neo4jDriver ¶
func SetLogger ¶
func SetLogger(logger logrus.FieldLogger)
Types ¶
This section is empty.
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.