ingressapi

type Config struct {
	Store               Store
	ClusterSecrets      serviceapi.BearerSecrets
	LeaseDuration       time.Duration
	RoutingPollInterval time.Duration
	Now                 func() time.Time
	Report              func(error)
}

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

type DirectConfig struct {
	Store               Store
	LeaseDuration       time.Duration
	RoutingPollInterval time.Duration
	Now                 func() time.Time
	Report              func(error)
}

type Store interface {
	RegisterIngress(context.Context, controlstate.IngressRegistration, time.Time, time.Duration) (controlstate.IngressLease, error)
	RenewIngress(context.Context, controlstate.IngressRenewal, time.Time, time.Duration) (controlstate.IngressLease, error)
	BeginIngressDrain(context.Context, controlstate.IngressLeaseIdentity, time.Time, time.Time) (controlstate.IngressLease, error)
	ReadIngressRoutingTableSnapshot(context.Context, controlstate.IngressLeaseIdentity, time.Time) (controlstate.IngressRoutingTableSnapshot, error)
	ReadIngressRoutingTableEvents(context.Context, controlstate.IngressLeaseIdentity, uint64, int, time.Time) (controlstate.IngressRoutingTablePage, error)
	ReportIngressUsage(context.Context, controlstate.IngressLeaseIdentity, controlstate.IngressUsageBatch, time.Time) error
	ObservePublicURLRecovery(context.Context, controlstate.IngressLeaseIdentity, string, uint64, uint64, time.Time) (controlstate.PublicURLRecoveryObservation, error)
}