dynamo

Documentation

Index

• type Replica
  • func NewReplica(id paxi.ID) *Replica
  • func (r *Replica) HandleReplicate(m Replicate)
  • func (r *Replica) HandleRequest(m paxi.Request)
• type Replicate

Types

type Replica

type Replica struct {
	paxi.Node
	// contains filtered or unexported fields
}

func NewReplica

func NewReplica(id paxi.ID) *Replica

func (*Replica) HandleReplicate

func (r *Replica) HandleReplicate(m Replicate)

func (*Replica) HandleRequest

func (r *Replica) HandleRequest(m paxi.Request)

HandleRequest handles read request if node is one of replica, otherwise forward to random replica write request will only write to first node in replica set, and replicate asynchronously

type Replicate

type Replicate struct {
	Command paxi.Command
}