src/flapjack/transport.go in flapjack-1.0.0rc6 vs src/flapjack/transport.go in flapjack-1.0.0
- old
+ new
@@ -5,30 +5,30 @@
"github.com/garyburd/redigo/redis"
)
// Transport is a representation of a Redis connection.
type Transport struct {
- Address string
- Database int
- Connection redis.Conn
+ 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) {
+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,
+ Address: address,
+ Database: database,
+ Connection: conn,
}
return transport, nil
}
// Send takes an event and sends it over a transport.
@@ -44,6 +44,5 @@
return reply, nil
} else {
return nil, err
}
}
-