statusrep

Documentation

Index

• type EndpointStatusReporter
  • func NewEndpointStatusReporter(hostname string, endpointUpdates <-chan interface{}, inSync <-chan bool, ...) *EndpointStatusReporter
  • func (esr *EndpointStatusReporter) Start()
  • func (esr *EndpointStatusReporter) Stop()

Types

type EndpointStatusReporter

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

func NewEndpointStatusReporter

func NewEndpointStatusReporter(hostname string,
	endpointUpdates <-chan interface{},
	inSync <-chan bool,
	datastore datastore,
	reportingDelay time.Duration,
	resyncInterval time.Duration) *EndpointStatusReporter

func (*EndpointStatusReporter) Start

func (esr *EndpointStatusReporter) Start()

func (*EndpointStatusReporter) Stop

func (esr *EndpointStatusReporter) Stop()