server

Documentation

Index

• Constants
• Variables
• type Manager
• type OpError
• type R
• type Server
  • func (sv *Server) AdvanceUntil(done chan int)
  • func (s *Server) Serve(l net.Listener, cal chan bool)
• type T

Constants

const (
	Valid = 1 << iota
	Done
)

Response flags

Variables

var (
	ErrPoisoned = os.NewError("poisoned")
)

Types

type Manager

type Manager interface {
	paxos.Proposer
	ProposeOnce(v string, c chan bool) store.Event
	Alpha() int
}

type OpError

type OpError struct {
	Detail string
}

type R

type R proto.Response

type Server

type Server struct {
	Addr string
	St   *store.Store
	Mg   Manager
	Self string
}

func (*Server) AdvanceUntil

func (sv *Server) AdvanceUntil(done chan int)

Repeatedly propose nop values until a successful read from `done`.

func (*Server) Serve

func (s *Server) Serve(l net.Listener, cal chan bool)

type T

type T proto.Request