servicer

Documentation

Index

• Constants
• func DelServicer(s Servicer)
• func Empty() *node
• func ExtractAddress(address string) (string, int)
• func GenerateAddress(host string, port int) string
• func NewNode(host string, port int, opts ...Option) *node
• func SetServicer(s Servicer) (err error)
• func UpdateServicer(s Servicer)
• type Node
• type Option
  • func WithFloatWeight(w float64) Option
  • func WithWeight(w int) Option
• type Servicer
  • func GetServicer(serviceName string) (Servicer, bool)
• type Statistics

Constants

const (
	TypeRegistry uint8 = 1
	TypeIPPort   uint8 = 2
	TypeDomain   uint8 = 3
)

Functions

func DelServicer

func DelServicer(s Servicer)

func Empty

func Empty() *node

func ExtractAddress

func ExtractAddress(address string) (string, int)

func GenerateAddress

func GenerateAddress(host string, port int) string

func NewNode

func NewNode(host string, port int, opts ...Option) *node

func SetServicer

func SetServicer(s Servicer) (err error)

func UpdateServicer

func UpdateServicer(s Servicer)

Types

type Node

type Node interface {
	Address() string
	Host() string
	Port() int
	Weight() int
	FloatWeight() float64
	Statistics() Statistics
	IncrSuccess()
	IncrFail()
}

type Option

type Option func(*node)

func WithFloatWeight

func WithFloatWeight(w float64) Option

func WithWeight

func WithWeight(w int) Option

type Servicer

type Servicer interface {
	Name() string
	RegistryName() string
	Pick(ctx context.Context) (Node, error)
	All(ctx context.Context) ([]Node, error)
	Done(ctx context.Context, node Node, err error) error
	GetCaCrt() []byte
	GetClientPem() []byte
	GetClientKey() []byte
}

func GetServicer

func GetServicer(serviceName string) (Servicer, bool)

type Statistics

type Statistics struct {
	Success uint64
	Fail    uint64
}