redirector

Documentation

Index

• type RedirectStrategy
• type Redirector
  • func New(logger *slog.Logger, ...) (*Redirector, error)
  • func (r *Redirector) CancelPendingWrite(svcName string)
  • func (r *Redirector) GetCachedStrategies(svcName string) (string, string)
  • func (r *Redirector) Run(ctx context.Context) error
  • func (r *Redirector) SetForwarder(f writeCanceler)
  • func (r *Redirector) UpdateConfig(redirectStrategies map[string]RedirectStrategy, ...)

Types

type RedirectStrategy

type RedirectStrategy struct {
	Service       string `yaml:"service" json:"service" mapstructure:"service"`
	Datacenter    string `yaml:"datacenter" json:"datacenter" mapstructure:"datacenter"`
	Namespace     string `yaml:"namespace" json:"namespace" mapstructure:"namespace"`
	ServiceSubset string `yaml:"service_subset" json:"service_subset" mapstructure:"service_subset"`
}

type Redirector

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

func New

func New(logger *slog.Logger, consulAddr, consulToken, consulDC, consulNamespace, writeRateLimit string, forwarderEnabled bool, redirectStrategies map[string]RedirectStrategy, dampeningPeriod, minDampeningPeriod string, hasDefaultFailover bool, dryRun bool) (*Redirector, error)

func (*Redirector) CancelPendingWrite

func (r *Redirector) CancelPendingWrite(svcName string)

func (*Redirector) GetCachedStrategies

func (r *Redirector) GetCachedStrategies(svcName string) (string, string)

func (*Redirector) Run

func (r *Redirector) Run(ctx context.Context) error

func (*Redirector) SetForwarder

func (r *Redirector) SetForwarder(f writeCanceler)

func (*Redirector) UpdateConfig

func (r *Redirector) UpdateConfig(redirectStrategies map[string]RedirectStrategy, dampeningPeriod, minDampeningPeriod, consulNamespace, writeRateLimit string, dryRun bool)