leader

Documentation

Index

• type Module
  • func New(nodeID string, module *pubsub.Module) *Module
  • func (s *Module) AddCallBack(id string, cb func())
  • func (s *Module) GetLeaderNodeID(ctx context.Context) (string, error)
  • func (s *Module) IsLeader(ctx context.Context, nodeID string) (bool, error)
  • func (s *Module) RemoveCallBack(id string)

Types

type Module

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

Module handles all the leader tasks

func New

func New(nodeID string, module *pubsub.Module) *Module

New initializes leader module

func (*Module) AddCallBack

func (s *Module) AddCallBack(id string, cb func())

AddCallBack adds a call back function

func (*Module) GetLeaderNodeID

func (s *Module) GetLeaderNodeID(ctx context.Context) (string, error)

GetLeaderNodeID gets leader node id

func (*Module) IsLeader

func (s *Module) IsLeader(ctx context.Context, nodeID string) (bool, error)

IsLeader checks if the provided node id is the leader gateway or not

func (*Module) RemoveCallBack

func (s *Module) RemoveCallBack(id string)

RemoveCallBack removes a call back function