ringpop

Documentation

Index

• func ValidateRingpopConfig(rpConfig *config.Membership) error
• type RingpopFactory
  • func NewRingpopFactory(rpConfig *config.Membership, channel *tchannel.Channel, serviceName string, ...) (*RingpopFactory, error)
  • func (factory *RingpopFactory) GetMembershipMonitor() (membership.Monitor, error)

Functions

func ValidateRingpopConfig

func ValidateRingpopConfig(rpConfig *config.Membership) error

ValidateRingpopConfig validates that ringpop config is parseable and valid

Types

type RingpopFactory

type RingpopFactory struct {
	sync.Mutex
	// contains filtered or unexported fields
}

RingpopFactory implements the RingpopFactory interface

func NewRingpopFactory

func NewRingpopFactory(
	rpConfig *config.Membership,
	channel *tchannel.Channel,
	serviceName string,
	servicePortMap map[string]int,
	logger log.Logger,
	metadataManager persistence.ClusterMetadataManager,
) (*RingpopFactory, error)

NewRingpopFactory builds a ringpop factory conforming to the underlying configuration

func (*RingpopFactory) GetMembershipMonitor

func (factory *RingpopFactory) GetMembershipMonitor() (membership.Monitor, error)

GetMembershipMonitor return a membership monitor