redisd

README

Package redisd provides a server.

---

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

Documentation

Overview

Package redisd provides a redis server daemon that is started by /sbin/init or /usr/sbin/goesd *before* all other daemons.

Index

• Constants
• type Assignments
  • func (as Assignments) Delete(key string) Assignments
  • func (as Assignments) Find(key string) interface{}
  • func (as Assignments) Insert(prefix string, v interface{}) Assignments
  • func (as Assignments) Len() int
  • func (as Assignments) Less(i, j int) (t bool)
  • func (as Assignments) Swap(i, j int)
• type Command
  • func (*Command) Apropos() lang.Alt
  • func (*Command) Kind() cmd.Kind
  • func (c *Command) Main(args ...string) error
  • func (*Command) Man() lang.Alt
  • func (*Command) String() string
  • func (*Command) Usage() string
• type Redisd
  • func (redisd *Redisd) Hexists(key, field string) (int, error)
  • func (redisd *Redisd) Hget(key, field string) ([]byte, error)
  • func (redisd *Redisd) Hgetall(key string) ([][]byte, error)
  • func (redisd *Redisd) Hkeys(key string) ([][]byte, error)
  • func (redisd *Redisd) Hset(key, field string, value []byte) (int, error)
  • func (redisd *Redisd) Info(secs ...string) ([]byte, error)
  • func (redisd *Redisd) Keys(pattern string) ([][]byte, error)
  • func (redisd *Redisd) Monitor() (*grs.MonitorReply, error)
  • func (redisd *Redisd) Ping() (*grs.StatusReply, error)
  • func (redisd *Redisd) Subscribe(channels ...[]byte) (*grs.MultiChannelWriter, error)
• type Server

Constants

const SizeofInt = (32 << (^uint(0) >> 63)) >> 3

Types

type Assignments

type Assignments []*assignment

func (Assignments) Delete

func (as Assignments) Delete(key string) Assignments

func (Assignments) Find

func (as Assignments) Find(key string) interface{}

func (Assignments) Insert

func (as Assignments) Insert(prefix string, v interface{}) Assignments

func (Assignments) Len

func (as Assignments) Len() int

func (Assignments) Less

func (as Assignments) Less(i, j int) (t bool)

for reverse order, longest match sort

func (Assignments) Swap

func (as Assignments) Swap(i, j int)

type Command

type Command struct {
	// Machines may restrict redisd listening to this list of net devices.
	// If unset, the local admin may restrict this through
	// /etc/default/goes ARGS.  Otherwise, the default is all active net
	// devices.
	Devs []string

	// Machines may use this Hook to Print redis "[key: ]field: value"
	// strings before any other daemons are run.
	Hook func(*publisher.Publisher)

	// A non-empty Machine is published to redis as "machine: Machine"
	Machine string

	// default: 6379
	Port int

	// Machines may override this list of published hashes.
	// default: redis.DefaultHash
	PublishedKeys []string
	// contains filtered or unexported fields
}

func (*Command) Apropos

func (*Command) Apropos() lang.Alt

func (*Command) Kind

func (*Command) Kind() cmd.Kind

func (*Command) Main

func (c *Command) Main(args ...string) error

func (*Command) Man

func (*Command) Man() lang.Alt

func (*Command) String

func (*Command) String() string

func (*Command) Usage

func (*Command) Usage() string

type Redisd

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

func (*Redisd) Hexists

func (redisd *Redisd) Hexists(key, field string) (int, error)

func (*Redisd) Hget

func (redisd *Redisd) Hget(key, field string) ([]byte, error)

func (*Redisd) Hgetall

func (redisd *Redisd) Hgetall(key string) ([][]byte, error)

func (*Redisd) Hkeys

func (redisd *Redisd) Hkeys(key string) ([][]byte, error)

func (*Redisd) Hset

func (redisd *Redisd) Hset(key, field string, value []byte) (int, error)

func (*Redisd) Info

func (redisd *Redisd) Info(secs ...string) ([]byte, error)

func (*Redisd) Keys

func (redisd *Redisd) Keys(pattern string) ([][]byte, error)

func (*Redisd) Monitor

func (redisd *Redisd) Monitor() (*grs.MonitorReply, error)

func (*Redisd) Ping

func (redisd *Redisd) Ping() (*grs.StatusReply, error)

func (*Redisd) Subscribe

func (redisd *Redisd) Subscribe(channels ...[]byte) (*grs.MultiChannelWriter,
	error)

type Server

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