leader

Documentation

Index

• func CheckIfLeader() bool
• func GetLeaderID() string
• func SetChangeLeaderCallback(callback func(bool) common.SyncServiceError)
• func SetUnsubcribeCallback(callback func() common.SyncServiceError)
• func StartLeaderDetermination(theStore storage.Storage)
• func StopLeadershipPeriodicUpdate()

Functions

func CheckIfLeader

func CheckIfLeader() bool

CheckIfLeader checks if the current process is the leader

func GetLeaderID

func GetLeaderID() string

func SetChangeLeaderCallback

func SetChangeLeaderCallback(callback func(bool) common.SyncServiceError)

SetChangeLeaderCallback sets the callback to be called when the leadership changes

func SetUnsubcribeCallback

func SetUnsubcribeCallback(callback func() common.SyncServiceError)

SetUnsubcribeCallback sets the callback to be called when there is no connection to the database and the node has to be unsubscribed from all its subscriptions

func StartLeaderDetermination

func StartLeaderDetermination(theStore storage.Storage)

StartLeaderDetermination starts the leader determination process

func StopLeadershipPeriodicUpdate

func StopLeadershipPeriodicUpdate()

StopLeadershipPeriodicUpdate stops the Leadership Periodic Update go routine