node

Documentation

Index

• type MasterNode
  • func NewMasterNode(config *MasterNodeConfig) (*MasterNode, error)
  • func (m *MasterNode) Run() error
  • func (m *MasterNode) RunAsPrimary() error
  • func (m *MasterNode) RunAsSecondary() error
• type MasterNodeConfig

Types

type MasterNode

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

func NewMasterNode

func NewMasterNode(config *MasterNodeConfig) (*MasterNode, error)

func (*MasterNode) Run

func (m *MasterNode) Run() error

func (*MasterNode) RunAsPrimary

func (m *MasterNode) RunAsPrimary() error

func (*MasterNode) RunAsSecondary

func (m *MasterNode) RunAsSecondary() error

type MasterNodeConfig

type MasterNodeConfig struct {
	NodeID             string
	Port               uint
	ForClientAddr      string
	ZookeeperServers   []string
	ZookeeperTimeout   time.Duration
	ElectionZnode      string
	ElectionPrefix     string
	ElectionAck        string
	KafkaServer        string
	KafkaTopic         string
	DB                 *gorm.DB
	CheckpointInterval time.Duration
	DataNodeGroups     []string
}