machine

Documentation

Index

• type Machine
  • func New(log finn.Logger, addr string) (*Machine, error)
  • func (m *Machine) Close() error
  • func (m *Machine) Command(a finn.Applier, conn redcon.Conn, cmd redcon.Command) (interface{}, error)
  • func (m *Machine) ConnAccept(conn redcon.Conn) bool
  • func (m *Machine) ConnClosed(conn redcon.Conn, err error)
  • func (m *Machine) Restore(rd io.Reader) error
  • func (m *Machine) Snapshot(wr io.Writer) error

Types

type Machine

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

func New

func New(log finn.Logger, addr string) (*Machine, error)

func (*Machine) Close

func (m *Machine) Close() error

func (*Machine) Command

func (m *Machine) Command(a finn.Applier, conn redcon.Conn, cmd redcon.Command) (interface{}, error)

Command processes a command through the Raft pipeline.

func (*Machine) ConnAccept

func (m *Machine) ConnAccept(conn redcon.Conn) bool

func (*Machine) ConnClosed

func (m *Machine) ConnClosed(conn redcon.Conn, err error)

func (*Machine) Restore

func (m *Machine) Restore(rd io.Reader) error

Restore restores a snapshot

func (*Machine) Snapshot

func (m *Machine) Snapshot(wr io.Writer) error

Snapshot creates a snapshot