poller

type Consumer interface {
	Consume(*Objects) error
}

type FromFlags interface {
	Validate() error
	Make(service.All, Consumer, Registrar, stats.Stats) Poller
}

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

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

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

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

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

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

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

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

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

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

type Objects struct {
	Zone        api.Zone          `json:"zone"`
	Proxy       api.Proxy         `json:"proxy"`
	Clusters    []api.Cluster     `json:"clusters"`
	Domains     api.Domains       `json:"domains"`
	Listeners   api.Listeners     `json:"listeners"`
	Routes      []api.Route       `json:"routes"`
	SharedRules []api.SharedRules `json:"shared_rules"`
	Checksum    api.Checksum      `json:"checksum"`
	// contains filtered or unexported fields
}

type ObjectsUpdateFn func(*Objects)

type Poller interface {
	// Poll will perform a single iteration that will produce objects that are
	// pushed to a Consumer. It may update internal state during the iteration.
	Poll() error

	// PollLoop polls for changes to the configuration objects of a Proxy in an
	// infinite loop, logging errors. Closing the Poller signals the loop to exit.
	PollLoop()

	// Close causes PollLoop to exit.
	Close() error
}

type Registrar interface {
	// Register a proxy. ifFirst is called synchronously if the proxy was not
	// registered by anyone else before the call. ifFirst is called within the
	// critical section; as such calling Register or Deregister from within
	// ifFirst is forbidden.
	Register(pRef service.ProxyRef, ifFirst func(service.All, api.Proxy)) error

	// Deregister a proxy. ifLast is called synchronously if the proxy is no longer
	// registered by anyone after the call. ifLast is called within the
	// critical section; as such calling Register or Deregister from within
	// ifLast is forbidden.
	Deregister(pRef service.ProxyRef, ifLast func()) error

	// Refs returns the list of currently registered proxies
	Refs() []service.ProxyRef
}

type Remote interface {
	Objects(proxyKey api.ProxyKey) (*Objects, error)

	// ObjectsWithOverrides returns the *Objects for a given ProxyKey. If a
	// function exists in the map corresponding to the key of an object (cast as a
	// string) that exists in the *Objects being constructed, that function will
	// be invoked on the *Objects before proceeding to the next step of the object
	// graph walk. If a proxy is being created then newProxy will be used as the
	// starting point for the validation.
	ObjectsWithOverrides(
		proxyKey api.ProxyKey,
		overrides map[string]ObjectsUpdateFn,
		newProxy *api.Proxy,
	) (*Objects, error)
}

type TaggedRule struct {
	api.Rule
	// SharedRuleName is empty if the Rule came from a Route
	SharedRuleName string
}