nail

README

Nail Microservice

Nail sucks down data from NSQ topics and feeds them into a SQL database.

Documentation

Index

• func AddHandler(topic string, spawnFunc spawnFunc)
• type Nail
  • func NewNail(redis *redis.Pool, db *sqlx.DB, addresses []string) *Nail
  • func (s *Nail) Close()
  • func (s *Nail) Run()

Functions

func AddHandler

func AddHandler(topic string, spawnFunc spawnFunc)

AddHandler adds a nail handler

Types

type Nail

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

Nail handles storage of data to SQL

func NewNail

func NewNail(redis *redis.Pool, db *sqlx.DB, addresses []string) *Nail

NewNail creates a new storage engine

func (*Nail) Close

func (s *Nail) Close()

Close stop the nail service

func (*Nail) Run

func (s *Nail) Run()

Run the nail service