listener

package

v1.7.0 Latest Latest Go to latest Published: Jul 27, 2024 License: MIT Imports: 14 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func GroupFromConfig(cfg *config.GroupConfig) (*Group, error)

func (g *Group) ID() uint64

func (g *Group) Ingest(a *protocol.Announcement) error

func (g *Group) List() []iface.GroupItem

func (g *Group) OnJoin(cb iface.GroupEventCallback) func()

func (g *Group) OnLeave(cb iface.GroupEventCallback) func()

func (g *Group) ReadinessBarrier() <-chan struct{}

func (g *Group) Ready() bool

func (g *Group) Start() error

func (g *Group) Stop() error

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

func NewListener(cfg *config.ListenerConfig) (*Listener, error)

func (l *Listener) GroupReadinessBarrier(id uint64) <-chan struct{}

func (l *Listener) GroupReady(id uint64) bool

func (l *Listener) Groups() []uint64

func (l *Listener) ListGroup(id uint64) []iface.GroupItem

func (l *Listener) OnJoin(group uint64, cb iface.GroupEventCallback) func()

func (l *Listener) OnLeave(group uint64, cb iface.GroupEventCallback) func()

func (l *Listener) Run(ctx context.Context) error

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

func NewUDPSource(address string, label string, callback func(string, *protocol.Announcement)) *UDPSource

func (s *UDPSource) Start() error

func (s *UDPSource) Stop() error