utils

Documentation

Index

• type EndpointPusher
  • func NewEndpointPusher() *EndpointPusher
  • func (p *EndpointPusher) Push(ctx context.Context, endpoints []string)
  • func (p *EndpointPusher) Register(ch chan []string)

Types

type EndpointPusher

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

EndpointPusher pushes endpoints to registered channels if the ep is L3 reachable

func NewEndpointPusher

func NewEndpointPusher() *EndpointPusher

NewEndpointPusher .

func (*EndpointPusher) Push

func (p *EndpointPusher) Push(ctx context.Context, endpoints []string)

Push pushes endpoint candicates

func (*EndpointPusher) Register

func (p *EndpointPusher) Register(ch chan []string)

Register registers a channel that will receive the endpoints later