speakerlist

Documentation

Index

• type SpeakerList
  • func New(logger log.Logger, ...) (*SpeakerList, error)
  • func (sl *SpeakerList) Rejoin()
  • func (sl *SpeakerList) Start(client *k8s.Client)
  • func (sl *SpeakerList) Stop()
  • func (sl *SpeakerList) UsableSpeakers() map[string]bool

Types

type SpeakerList

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

SpeakerList represents a list of healthy speakers.

func New

func New(logger log.Logger, nodeName, bindAddr, bindPort, secret, namespace, labels string, stopCh chan struct{}) (*SpeakerList, error)

New creates a new SpeakerList and returns a pointer to it.

func (*SpeakerList) Rejoin

func (sl *SpeakerList) Rejoin()

Rejoin initiates a discovery and joins all the speakers to the memberlist cluster.

func (*SpeakerList) Start

func (sl *SpeakerList) Start(client *k8s.Client)

Start initializes the SpeakerList. This functions must be called before using other SpeakerList methods.

func (*SpeakerList) Stop

func (sl *SpeakerList) Stop()

Stop stops the SpeakerList.

func (*SpeakerList) UsableSpeakers

func (sl *SpeakerList) UsableSpeakers() map[string]bool

UsableSpeakers returns a map of usable speaker nodes.