rtpengine

Documentation

Index

• type Endpoint
• type Set
  • func (s *Set) OnAdd(obj interface{})
  • func (s *Set) OnDelete(obj interface{})
  • func (s *Set) OnUpdate(oldObj interface{}, newObj interface{})
  • func (s *Set) Start() error
  • func (s *Set) Watch(ctx context.Context) (err error)

Types

type Endpoint

type Endpoint struct {
	Address string
	Port    uint32
}

Endpoint describes an RTPEngine control Endpoint

type Set

type Set struct {
	ID int

	ServiceName      string
	ServiceNamespace string
	ServicePort      string

	Endpoints []*Endpoint

	Informer cache.SharedIndexInformer

	Logger *zap.Logger
	// contains filtered or unexported fields
}

Set represents an RTPEngine set

func (*Set) OnAdd

func (s *Set) OnAdd(obj interface{})

OnAdd implements cache.ResourceEventHandler

func (*Set) OnDelete

func (s *Set) OnDelete(obj interface{})

OnDelete implements cache.ResourceEventHandler

func (*Set) OnUpdate

func (s *Set) OnUpdate(oldObj interface{}, newObj interface{})

OnUpdate implements cache.ResourceEventHandler

func (*Set) Start

func (s *Set) Start() error

func (*Set) Watch

func (s *Set) Watch(ctx context.Context) (err error)

Watch monitors the Service for changes, updating the Endpoints and returning when changes are detected.