uhaha

Aug 27, 2022

Changes in this version

type Config

+ LocalConnector func(lconn LocalConnector)

+ StateChange func(state State)

+ type LocalConn interface

+ Close func()

+ Do func(args ...string) redcon.RESP

+ type LocalConnector interface

+ Open func() (LocalConn, error)

+ type State byte

+ const Candidate

+ const Follower

+ const Leader

+ const Shutdown

+ func (state State) String() string

Aug 13, 2022

Changes in this version

type Rand

+ UUID func() string

May 27, 2022

Changes in this version

type Config

+ ResponseFilter ResponseFilter

type Receiver

+ Args func() []string

+ type ResponseFilter func(serviceName string, context interface{}, args []string, v interface{}) interface

type Service

+ Name func() string

+ ResponseFilter func() ResponseFilter

May 6, 2021

Changes in this version

type Config

+ InitRunQuit bool

Nov 16, 2020

Changes in this version

+ func RedisDial(addr, auth string, tlscfg *tls.Config) (redis.Conn, error)

type Config

+ ServerReady func(addr, auth string, tlscfg *tls.Config)

+ TryErrors bool

Oct 5, 2020

Changes in this version

type Config

+ func (conf *Config) AddIntermediateCommand(name string, fn func(m Machine, args []string) (interface{}, error))

Oct 3, 2020

Changes in this version

type Config

+ Advertise string

Sep 28, 2020

Changes in this version

type Config

+ PreseveAddr bool

Sep 24, 2020

Changes in this version

type Config

+ LogReady func(log Logger)

Sep 23, 2020

Changes in this version

type Config

+ GitSHA string

Sep 21, 2020

Changes in this version

type Config

+ func (conf *Config) AddCatchallCommand(fn func(m Machine, args []string) (interface{}, error))

Sep 19, 2020

Changes in this version

type Config

+ ConnClosed func(context interface{}, addr string)

+ ConnOpened func(addr string) (context interface{}, accept bool)

type Machine

+ Context func() interface{}

type SendOptions

+ Context interface{}

type Service

+ Closed func(context interface{}, addr string)

+ Opened func(addr string) (context interface{}, accept bool)

Sep 16, 2020

Changes in this version

+ var ErrNotLeader = raft.ErrNotLeader

Sep 15, 2020

Changes in this version

type Rand

+ Uint32 func() uint32

Sep 11, 2020

Changes in this version

+ func ReadRawMachineInfo(m Machine, info *RawMachineInfo)

+ func WriteRawMachineInfo(m Machine, info *RawMachineInfo)

+ type RawMachineInfo struct

+ Seed int64

+ TS int64

Sep 1, 2020

Changes in this version

+ type FilterArgs []string

Aug 31, 2020

Changes in this version

+ var ErrCorrupt = errors.New("corrupt")

+ var ErrInvalid = errors.New("invalid")

+ var ErrSyntax = errors.New("syntax error")

+ var ErrUnauthorized = errors.New("unauthorized")

+ var ErrUnknownCommand = errors.New("unknown command")

+ var ErrWrongNumArgs = errors.New("wrong number of arguments")

+ func Main(conf Config)

+ type Backend int

+ const Bolt

+ const LevelDB

+ type Config struct

+ Addr string

+ Auth string

+ Backend Backend

+ BackupPath string

+ DataDir string

+ DataDirReady func(dir string)

+ Flag struct{ ... }

+ InitialData interface{}

+ JoinAddr string

+ LocalTime bool

+ LogLevel string

+ LogOutput io.Writer

+ MaxPool int

+ Name string

+ NoSync bool

+ NodeID string

+ OpenReads bool

+ Restore func(rd io.Reader) (data interface{}, err error)

+ Snapshot func(data interface{}) (Snapshot, error)

+ TLSCACertPath string

+ TLSCertPath string

+ TLSKeyPath string

+ Tick func(m Machine)

+ TickDelay time.Duration

+ UseJSONSnapshots bool

+ Version string

+ func (conf *Config) AddPassiveCommand(name string, fn func(m Machine, args []string) (interface{}, error))

+ func (conf *Config) AddReadCommand(name string, fn func(m Machine, args []string) (interface{}, error))

+ func (conf *Config) AddService(sniff func(rd io.Reader) bool, acceptor func(s Service, ln net.Listener))

+ func (conf *Config) AddWriteCommand(name string, fn func(m Machine, args []string) (interface{}, error))

+ type Hijack func(s Service, conn HijackedConn)

+ type HijackedConn interface

+ Close func() error

+ Flush func() error

+ ReadCommand func() (args []string, err error)

+ ReadCommands func(func(args []string) bool) error

+ RemoteAddr func() string

+ WriteAny func(v interface{})

+ WriteRaw func(data []byte)

+ type Logger interface

+ Debug func(args ...interface{})

+ Debugf func(format string, args ...interface{})

+ Debugln func(args ...interface{})

+ Error func(args ...interface{})

+ Errorf func(format string, args ...interface{})

+ Errorln func(args ...interface{})

+ Fatal func(args ...interface{})

+ Fatalf func(format string, args ...interface{})

+ Fatalln func(args ...interface{})

+ Notice func(args ...interface{})

+ Noticef func(format string, args ...interface{})

+ Noticeln func(args ...interface{})

+ Panic func(args ...interface{})

+ Panicf func(format string, args ...interface{})

+ Panicln func(args ...interface{})

+ Print func(args ...interface{})

+ Printf func(format string, args ...interface{})

+ Println func(args ...interface{})

+ Verb func(args ...interface{})

+ Verbf func(format string, args ...interface{})

+ Verbln func(args ...interface{})

+ Warning func(args ...interface{})

+ Warningf func(format string, args ...interface{})

+ Warningln func(args ...interface{})

+ type Machine interface

+ Data func() interface{}

+ Log func() Logger

+ Now func() time.Time

+ Rand func() Rand

+ type Message struct

+ Addr string

+ Args []string

+ Elapsed time.Duration

+ Err error

+ Resp interface{}

+ type Monitor interface

+ NewObserver func() Observer

+ Send func(msg Message)

+ type Observer interface

+ C func() <-chan Message

+ Stop func()

+ type Rand interface

+ Float64 func() float64

+ Int func() int

+ Read func([]byte) (n int, err error)

+ Uint64 func() uint64

+ type Receiver interface

+ Recv func() (interface{}, time.Duration, error)

+ func Response(v interface{}, elapsed time.Duration, err error) Receiver

+ type SendOptions struct

+ AllowOpenReads bool

+ DenyOpenReads bool

+ From interface{}

+ type Service interface

+ Auth func(auth string) error

+ Log func() Logger

+ Monitor func() Monitor

+ Send func(args []string, opts *SendOptions) Receiver

+ type Snapshot interface

+ Done func(path string)

+ Persist func(io.Writer) error