trafficweight

Documentation

Index

• func ConfigReconcileLoop(backend TrafficWeightBackend, c cache.Cache, seconds time.Duration, ...)
• type DynamoNoResultsError
  • func (e *DynamoNoResultsError) Error() string
• type FakeBackend
  • func (b *FakeBackend) OnWeightUpdate(config StoreConfig) error
  • func (b *FakeBackend) ReadWeight() (int, error)
• type Item
• type StoreConfig
• type TrafficWeightBackend
  • func NewBackend(backendType, clusterName string, awsRegion string, tableName string, ...) (TrafficWeightBackend, error)
  • func NewDynamodbBackend(logger logr.Logger, clusterName string, awsRegion string, tableName string) TrafficWeightBackend
  • func NewFakeBackend(logger logr.Logger) TrafficWeightBackend

Functions

func ConfigReconcileLoop

func ConfigReconcileLoop(backend TrafficWeightBackend, c cache.Cache, seconds time.Duration, log log.Logger, events chan event.GenericEvent)

Types

type DynamoNoResultsError

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

func (*DynamoNoResultsError) Error

func (e *DynamoNoResultsError) Error() string

type FakeBackend

type FakeBackend struct {
	Log logr.Logger
}

func (*FakeBackend) OnWeightUpdate

func (b *FakeBackend) OnWeightUpdate(config StoreConfig) error

func (*FakeBackend) ReadWeight

func (b *FakeBackend) ReadWeight() (int, error)

type Item

type Item struct {
	ClusterName   string
	DesiredWeight int
	CurrentWeight int
	HealthCheckID string
}

type StoreConfig

type StoreConfig struct {
	DesiredWeight    int
	CurrentWeight    int
	AWSHealthCheckID string
}

var Store StoreConfig

type TrafficWeightBackend

type TrafficWeightBackend interface {
	ReadWeight() (int, error)
	OnWeightUpdate(StoreConfig) error
}

func NewBackend

func NewBackend(backendType, clusterName string, awsRegion string, tableName string, awsHealthCheckID string, logger log.Logger) (TrafficWeightBackend, error)

func NewDynamodbBackend

func NewDynamodbBackend(logger logr.Logger, clusterName string, awsRegion string, tableName string) TrafficWeightBackend

func NewFakeBackend

func NewFakeBackend(logger logr.Logger) TrafficWeightBackend