discovery

Documentation

Index

• type RoutingDiscovery
  • func NewFromFlags(logger logrus.FieldLogger, baseDirector *pb_config.DirectorConfig, ...) (*RoutingDiscovery, error)
  • func NewWithClient(logger logrus.FieldLogger, baseDirector *pb_config.DirectorConfig, ...) *RoutingDiscovery
  • func (d *RoutingDiscovery) DiscoverAndSetFlags(ctx context.Context, directorFlagz *protoflagz.DynProto3Value, ...) error
  • func (d *RoutingDiscovery) DiscoverOnce(ctx context.Context, timeToWait time.Duration) (*pb_config.DirectorConfig, *pb_config.BackendPoolConfig, error)

Types

type RoutingDiscovery

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

RoutingDiscovery allows to get fresh director and backendpool configuration filled with autogenerated routings based on service annotations. See more details about it in server/README.md#Running_with_Dynaming_Routing_Discovery

func NewFromFlags

func NewFromFlags(logger logrus.FieldLogger, baseDirector *pb_config.DirectorConfig, baseBackendpool *pb_config.BackendPoolConfig) (*RoutingDiscovery, error)

NewFromFlags creates new RoutingDiscovery flow flags.

func NewWithClient

func NewWithClient(logger logrus.FieldLogger, baseDirector *pb_config.DirectorConfig, baseBackendpool *pb_config.BackendPoolConfig, serviceClient serviceClient) *RoutingDiscovery

NewWithClient returns a new Kubernetes RoutingDiscovery using given k8s.APIClient configured to be used against kube-apiserver.

func (*RoutingDiscovery) DiscoverAndSetFlags

func (d *RoutingDiscovery) DiscoverAndSetFlags(
	ctx context.Context,
	directorFlagz *protoflagz.DynProto3Value,
	backendpoolFlagz *protoflagz.DynProto3Value,
) error

DiscoverAndSetFlags constantly watches service list endpoint for changes and sets director and backendpool flags to change routing configuration. Having it set by flagz is giving us possibility to see current values in debug/flagz page and perform proper apply in different place (where we are parsing flags).

func (*RoutingDiscovery) DiscoverOnce

func (d *RoutingDiscovery) DiscoverOnce(ctx context.Context, timeToWait time.Duration) (*pb_config.DirectorConfig, *pb_config.BackendPoolConfig, error)

DiscoverOnce returns director & backendpool configs filled with mix of persistent routes & backends given in base configs and dynamically discovered ones.