embedded

Documentation

Index

• type Component
  • func (c *Component[T]) GetReader(id string) T
  • func (c *Component[T]) GetWriter(id string) T
  • func (c *Component[T]) NewReader(id string, items ...T)
  • func (c *Component[T]) NewWriter(id string, items ...T)
  • func (c *Component[T]) SetReaderBalance(f func(ts ...IInstance[T]) IInstance[T])
  • func (c *Component[T]) SetWriterBalance(f func(ts ...IInstance[T]) IInstance[T])
• type IComponent
  • func NewComponent[T IItem]() IComponent[T]
• type IInstance
  • func NewInstance[T IItem](name string, item T) IInstance[T]
• type IItem
• type Instance
  • func (c *Instance[T]) GetID() string
  • func (c *Instance[T]) GetName() string
  • func (c *Instance[T]) GetValue() T
  • func (c *Instance[T]) GetWeight() float64

Types

type Component

type Component[T IItem] struct {
	Writers       map[string][]IInstance[T]             // 写节点
	WriterBalance func(ts ...IInstance[T]) IInstance[T] // 选取算法
	Readers       map[string][]IInstance[T]             // 读节点
	ReaderBalance func(ts ...IInstance[T]) IInstance[T] //选取算法
}

func (*Component[T]) GetReader

func (c *Component[T]) GetReader(id string) T

func (*Component[T]) GetWriter

func (c *Component[T]) GetWriter(id string) T

func (*Component[T]) NewReader

func (c *Component[T]) NewReader(id string, items ...T)

func (*Component[T]) NewWriter

func (c *Component[T]) NewWriter(id string, items ...T)

func (*Component[T]) SetReaderBalance

func (c *Component[T]) SetReaderBalance(f func(ts ...IInstance[T]) IInstance[T])

func (*Component[T]) SetWriterBalance

func (c *Component[T]) SetWriterBalance(f func(ts ...IInstance[T]) IInstance[T])

type IComponent

type IComponent[T IItem] interface {
	NewWriter(id string, items ...T)
	GetWriter(id string) T
	NewReader(id string, items ...T)
	GetReader(id string) T
	SetWriterBalance(f func(ts ...IInstance[T]) IInstance[T])
	SetReaderBalance(f func(ts ...IInstance[T]) IInstance[T])
}

IComponent

func NewComponent

func NewComponent[T IItem]() IComponent[T]

type IInstance

type IInstance[T IItem] interface {
	GetID() string
	GetName() string
	GetWeight() float64
	GetValue() T
}

IInstance

func NewInstance

func NewInstance[T IItem](name string, item T) IInstance[T]

type IItem

type IItem any // client or sdk

type Instance

type Instance[T IItem] struct {
	Id     string
	Name   string
	Weight float64
	Value  T
}

func (*Instance[T]) GetID

func (c *Instance[T]) GetID() string

func (*Instance[T]) GetName

func (c *Instance[T]) GetName() string

func (*Instance[T]) GetValue

func (c *Instance[T]) GetValue() T

func (*Instance[T]) GetWeight

func (c *Instance[T]) GetWeight() float64