s-mx/replob

replob's Issues

Создать алгоритм консенсуса masterless

Простые типы:

type NodeId int

type MasterlessConfiguration struct {
  Info NodesInfo // set of nodes
  // timeouts, batching
}

Требуемый интерфейс:

type Carrier interface {
  Less(Carrier) bool
}

type Broadcaster {
  Broadcast(Message)
}

type Committer {
  Commit(Carrier)
}

type BroadcasterCommiter interface {
  Broadcaster
  Committer
}

Реализуемый интерфейс:

type Consensuser interface {
  Propose(Carry)
  OnBroadcast(Message, NodeId)
  OnDisconnect(NodeId)
}

func NewMasterlessConsensus(BroadcasterCommiter, MasterlessConfiguration) Consensuser {
  // реализовать
}

Configuration

Посмотреть пакет flag.

Семафоры в ClientService

избавиться от ClientService

Комит пустого CarriesSet

После OnBroadcast вызывается OnVote, чтобы распространить изменения нод. После этого возможен вызов OnCommit для пустого CarriesSet. Казалось бы, безобидно закомитить пустое множество, но после этого мы вызовем PrepareNextStep, увеличим StepId, и начнем из-за этого терять много сообщений с предыдущего StepId. Это то, что мы хотели?
Resend не поможет, потому что в в сообщениях останется старый StepId. Нужно будет начинать весь процесс голосования сначала при том, что исходные Propose потеряны.
Нужно подумать про решение проблемы.

Интерфейс для структуры Set

Можно зафиксировать операции Set через интерфейс, чтобы алгоритм consensuser мог работать с интерфейсом.

Текущие вопросы

Добавить errors в возвращаемые аргументы.

Алгоритм изменения количества нод

Т.к. у нас алгоритм все время пытается уменьшить число нод, то необходим механимз по добавлению числа нод. Изменение нод:

type NodesChanger {
  OnNodeChange(NodesInfo)
}

Добавить в Broadcaster и Consensuser.

Логирование

Сделать thread safe логирование

Temporary вместо Timeout

Возможно для reconnection нужно звать функцию temporary линк