xt

Documentation

Index

• Variables
• type Cost
• type CostedTerminator
  • func GetRelatedTerminators(list []CostedTerminator) []CostedTerminator
• type Costs
  • func GlobalCosts() Costs
• type CreateCircuitParams
• type DefaultEventVisitor
  • func (visitor DefaultEventVisitor) VisitCircuitRemoved(TerminatorEvent)
  • func (visitor DefaultEventVisitor) VisitDialFailed(TerminatorEvent)
  • func (visitor DefaultEventVisitor) VisitDialSucceeded(TerminatorEvent)
• type EventVisitor
• type Factory
• type PeerData
• type Precedence
  • func GetPrecedenceForName(name string) Precedence
• type Registry
  • func GlobalRegistry() Registry
• type Strategy
• type StrategyChangeEvent
  • func NewStrategyChangeEvent(serviceId string, current, added, changed, removed []Terminator) StrategyChangeEvent
• type Terminator
  • func TList(terminators ...Terminator) []Terminator
• type TerminatorEvent
  • func NewCircuitRemoved(terminator Terminator) TerminatorEvent
  • func NewDialFailedEvent(terminator Terminator) TerminatorEvent
  • func NewDialSucceeded(terminator Terminator) TerminatorEvent

Variables

var Precedences = struct {
	// Required terminators should always be used in preference to non-required terminators
	// Example: The current active node in an active/passive setup. If the strategy determines
	//          that the current active has failed, it will drop the precedence and mark some other
	//          terminator as Required
	Required Precedence

	// Default precedence is where terminators start
	Default Precedence

	// Failed means this terminator should only be used if all other terminators are also in a failed state
	// Example: A strategy might move a terminator to Failed if three dials in a row fail
	Failed Precedence

	// Unknown means this terminator was likely recently removed and should not be used
	unknown Precedence
}{
	Required: &precedence{
		name:    "required",
		minCost: requireMinCost,
		maxCost: defaultMinCost - 1,
	},
	Default: &precedence{
		name:    "default",
		minCost: defaultMinCost,
		maxCost: failedMinCost - 1,
	},
	Failed: &precedence{
		name:    "failed",
		minCost: failedMinCost,
		maxCost: unknownMinCost - 1,
	},
	// contains filtered or unexported fields
}

Precedences define the precedence levels

Types

type Cost

type Cost interface {
	Get() uint16
	Inspect(terminatorId string) *inspect.TerminatorCostDetail
}

type CostedTerminator

type CostedTerminator interface {
	Terminator
	GetRouteCost() uint32
}

func GetRelatedTerminators

func GetRelatedTerminators(list []CostedTerminator) []CostedTerminator

In a list which is sorted by precedence, returns the terminators which have the same precedence as that of the first entry in the list

type Costs

type Costs interface {
	ClearCost(terminatorId string)
	SetDynamicCost(terminatorId string, c Cost)
	GetDynamicCost(terminatorId string) uint16
	GetCost(terminatorId string) Cost
	IterCosts(func(terminatorId string, cost Cost))
}

func GlobalCosts

func GlobalCosts() Costs

type CreateCircuitParams

type CreateCircuitParams interface {
	GetServiceId() string
	GetClientId() *identity.TokenId
	GetLogContext() logcontext.Context
}

type DefaultEventVisitor

type DefaultEventVisitor struct{}

func (DefaultEventVisitor) VisitCircuitRemoved

func (visitor DefaultEventVisitor) VisitCircuitRemoved(TerminatorEvent)

func (DefaultEventVisitor) VisitDialFailed

func (visitor DefaultEventVisitor) VisitDialFailed(TerminatorEvent)

func (DefaultEventVisitor) VisitDialSucceeded

func (visitor DefaultEventVisitor) VisitDialSucceeded(TerminatorEvent)

type EventVisitor

type EventVisitor interface {
	VisitDialFailed(event TerminatorEvent)
	VisitDialSucceeded(event TerminatorEvent)
	VisitCircuitRemoved(event TerminatorEvent)
}

type Factory

type Factory interface {
	GetStrategyName() string
	NewStrategy() Strategy
}

type PeerData

type PeerData map[uint32][]byte

type Precedence

type Precedence interface {
	fmt.Stringer
	GetBaseCost() uint32
	IsFailed() bool
	IsDefault() bool
	IsRequired() bool
	Unbias(cost uint32) uint32
	GetBiasedCost(cost uint32) uint32
}

func GetPrecedenceForName

func GetPrecedenceForName(name string) Precedence

type Registry

type Registry interface {
	RegisterFactory(factory Factory)
	GetStrategy(name string) (Strategy, error)
}

func GlobalRegistry

func GlobalRegistry() Registry

type Strategy

type Strategy interface {
	Select(param CreateCircuitParams, terminators []CostedTerminator) (CostedTerminator, PeerData, error)
	HandleTerminatorChange(event StrategyChangeEvent) error
	NotifyEvent(event TerminatorEvent)
}

type StrategyChangeEvent

type StrategyChangeEvent interface {
	GetServiceId() string
	GetCurrent() []Terminator
	GetAdded() []Terminator
	GetChanged() []Terminator
	GetRemoved() []Terminator
}

func NewStrategyChangeEvent

func NewStrategyChangeEvent(serviceId string, current, added, changed, removed []Terminator) StrategyChangeEvent

type Terminator

type Terminator interface {
	GetId() string
	GetPrecedence() Precedence
	GetCost() uint16
	GetServiceId() string
	GetInstanceId() string
	GetRouterId() string
	GetBinding() string
	GetAddress() string
	GetPeerData() PeerData
	GetCreatedAt() time.Time
	GetHostId() string
	GetSourceCtrl() string
}

func TList

func TList(terminators ...Terminator) []Terminator

type TerminatorEvent

type TerminatorEvent interface {
	GetTerminator() Terminator
	Accept(visitor EventVisitor)
}

func NewCircuitRemoved

func NewCircuitRemoved(terminator Terminator) TerminatorEvent

func NewDialFailedEvent

func NewDialFailedEvent(terminator Terminator) TerminatorEvent

func NewDialSucceeded

func NewDialSucceeded(terminator Terminator) TerminatorEvent