redis

README

Package redis provides an interface to query and modify a local server.

---

© 2015-2018 Platina Systems, Inc. All rights reserved. Use of this source code is governed by this BSD-style LICENSE.

Documentation

Overview

Package redis provides an interface to query and modify a local server.

Index

• Constants
• Variables
• func Assign(key, sockname, name string) error
• func Complete(args ...string) (c []string)
• func Connect() (redis.Conn, error)
• func Fprintln(w io.Writer, s string)
• func Get(key string) (s string, err error)
• func Hdel(key, field string, fields ...string) (i int, err error)
• func Hexists(key, field string) (i int, err error)
• func Hget(key, field string) (s string, err error)
• func Hkeys(key string) (keys []string, err error)
• func Hset(key, field string, v interface{}) (i int, err error)
• func Hwait(key, field, value string, dur time.Duration) error
• func IsReady() error
• func Keys(pattern string) (keys []string, err error)
• func Lrange(key string, start, stop int) (keys []string, err error)
• func NewRedisRegAtSock() (*rpc.Client, error)
• func NewRedisdAtSock() (net.Conn, error)
• func Publish(name string, depth ...int) (chan<- string, error)
• func Quotes(s string) string
• func Set(key string, value interface{}) (s string, err error)
• func Split(key string) []string
• func Subscribe(channel string) (psc redis.PubSubConn, err error)
• func Unassign(key string) error

Constants

const License = `` /* 15871-byte string literal not displayed */

const Version = "v1.2.0"

Version format :: v<MAJOR>.<MINOR>.<PATCH>[-rc<CANDIDATE>]

Variables

var DefaultHash string

Functions

func Assign

func Assign(key, sockname, name string) error

Assign an RPC handler for the given key.

func Complete

func Complete(args ...string) (c []string)

Complete redis Key and Subkey. This skips over leading '-' prefaced flags.

func Connect

func Connect() (redis.Conn, error)

Connect to the redis file socket.

func Fprintln

func Fprintln(w io.Writer, s string)

func Get

func Get(key string) (s string, err error)

func Hdel

func Hdel(key, field string, fields ...string) (i int, err error)

func Hexists

func Hexists(key, field string) (i int, err error)

func Hget

func Hget(key, field string) (s string, err error)

func Hkeys

func Hkeys(key string) (keys []string, err error)

func Hset

func Hset(key, field string, v interface{}) (i int, err error)

func Hwait

func Hwait(key, field, value string, dur time.Duration) error

Wait for the given (key, field) to have value or anything if value is "".

func IsReady

func IsReady() error

func Keys

func Keys(pattern string) (keys []string, err error)

func Lrange

func Lrange(key string, start, stop int) (keys []string, err error)

func NewRedisRegAtSock

func NewRedisRegAtSock() (*rpc.Client, error)

func NewRedisdAtSock

func NewRedisdAtSock() (net.Conn, error)

func Publish

func Publish(name string, depth ...int) (chan<- string, error)

Publish messages to the named redis channel. Messages sent through the returned channel are forwarded to the redis server until the channel is closed.

pub, err := redis.Publish(NAME[, DEPTH])
if err {
	panic()
}
defer close(pub)
...
pub.Print("hello world")

The default message channel depth is 16.

func Quotes

func Quotes(s string) string

func Set

func Set(key string, value interface{}) (s string, err error)

func Split

func Split(key string) []string

Split a structured redis key.

"eth0" -> ["eth0"]
"eth0.mtu" -> ["eth0", "mtu"]
"eth0.addr.[10.0.2.15]" -> ["eth0", "addr", "10.0.2.15"]
"eth0.addr.[10.0.2.15].broadcast" ->
	["eth0", "addr", "10.0.2.15", "broadcast"]

func Subscribe

func Subscribe(channel string) (psc redis.PubSubConn, err error)

func Unassign

func Unassign(key string) error

Unassign an RPC handler for the given key.