Sha256: 5cd0c9fec71eda22ef7846e484b83edad2b938da977886171bfb2de55f162429
Contents?: true
Size: 972 Bytes
Versions: 25
Compression:
Stored size: 972 Bytes
Contents
package flapjack
import (
"encoding/json"
"github.com/garyburd/redigo/redis"
)
// Transport is a representation of a Redis connection.
type Transport struct {
Address string
Database int
Connection redis.Conn
}
// Dial establishes a connection to Redis, wrapped in a Transport.
func Dial(address string, database int) (Transport, error) {
// Connect to Redis
conn, err := redis.Dial("tcp", address)
if err != nil {
return Transport{}, err
}
// Switch database
conn.Do("SELECT", database)
transport := Transport{
Address: address,
Database: database,
Connection: conn,
}
return transport, nil
}
// Send takes an event and sends it over a transport.
func (t Transport) Send(event Event) (interface{}, error) {
err := event.IsValid()
if err == nil {
data, _ := json.Marshal(event)
reply, err := t.Connection.Do("LPUSH", "events", data)
if err != nil {
return nil, err
}
return reply, nil
} else {
return nil, err
}
}
Version data entries
25 entries across 25 versions & 1 rubygems