server

package
Version: v0.3.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 11, 2011 License: MIT Imports: 13 Imported by: 0

Documentation

Index

Constants

View Source
const (
	Valid = 1 << iota
	Done
)

Response flags

Variables

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

Functions

This section is empty.

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

Source Files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL