validation

Documentation

Index

• func Periodic(ctx context.Context, period time.Duration, f Validation) error
• type ConsensusData
• type ConsensusValidation
  • func NewConsensusValidation(size, tolerate int) *ConsensusValidation
  • func (c *ConsensusValidation) Complete(iter *ConsensusValidationIteration) error
  • func (c *ConsensusValidation) Next() *ConsensusValidationIteration
• type ConsensusValidationIteration
  • func (iter *ConsensusValidationIteration) OnData(id int, data *ConsensusData)
• type SyncValidation
  • func (s *SyncValidation) OnData(id int, synced bool) error
• type Validation
  • func Consensus(c *cluster.Cluster, tolerate, distance int) Validation
  • func Sync(c *cluster.Cluster, tolerate int) Validation

Functions

func Periodic

func Periodic(ctx context.Context, period time.Duration, f Validation) error

Periodic runs validation once in a period, starting immediately.

Types

type ConsensusData

type ConsensusData struct {
	Consensus, State []byte
}

type ConsensusValidation

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

func NewConsensusValidation

func NewConsensusValidation(size, tolerate int) *ConsensusValidation

func (*ConsensusValidation) Complete

func (c *ConsensusValidation) Complete(iter *ConsensusValidationIteration) error

func (*ConsensusValidation) Next

func (c *ConsensusValidation) Next() *ConsensusValidationIteration

type ConsensusValidationIteration

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

func (*ConsensusValidationIteration) OnData

func (iter *ConsensusValidationIteration) OnData(id int, data *ConsensusData)

type SyncValidation

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

func (*SyncValidation) OnData

func (s *SyncValidation) OnData(id int, synced bool) error

type Validation

type Validation func(context.Context) error

func Consensus

func Consensus(c *cluster.Cluster, tolerate, distance int) Validation

func Sync

func Sync(c *cluster.Cluster, tolerate int) Validation