failure_detector

Documentation

Index

• func NewFailureDetector() go_sheep.SWIM
• type Swim
  • func (Swim) GetCheckers(s *go_sheep.State, targetNode *go_sheep.Node, currentNode *go_sheep.Node, ...) (foundNodes []*go_sheep.Node, err error)
  • func (Swim) GetRandomizedTarget(s *go_sheep.State, currentNodeInfo *go_sheep.Node) (n *go_sheep.Node, err error)
  • func (Swim) MergeState(as, bs *go_sheep.State) (newState *go_sheep.State, err error)

Functions

func NewFailureDetector

func NewFailureDetector() go_sheep.SWIM

Types

type Swim

type Swim struct{}

func (Swim) GetCheckers

func (Swim) GetCheckers(s *go_sheep.State, targetNode *go_sheep.Node, currentNode *go_sheep.Node, n int) (foundNodes []*go_sheep.Node, err error)

func (Swim) GetRandomizedTarget

func (Swim) GetRandomizedTarget(s *go_sheep.State, currentNodeInfo *go_sheep.Node) (n *go_sheep.Node, err error)

func (Swim) MergeState

func (Swim) MergeState(as, bs *go_sheep.State) (newState *go_sheep.State, err error)