krpc

Documentation

Index

• Constants
• func AddLocal(local *Local)
• func Close()
• func Dial(serviceName ServiceName, group string) (grpc.ClientConnInterface, error)
• func DialDefault(serviceName ServiceName) (grpc.ClientConnInterface, error)
• func SetLoadBalance(name string)
• func SetLocals(locals []*Local)
• func SetMode(m Mode)
• type LoadBalance
  • func NewLoadBalance(name string) LoadBalance
• type Local
  • func (l *Local) Addr() string
  • func (l *Local) InnerAddr() string
  • func (l *Local) Instance() *grpc.Instance
  • func (l *Local) ServiceName() string
• type Locals
  • func (l Locals) Add(lo *Local)
  • func (l Locals) Get(name string) (*Local, bool)
• type Mode
• type ServiceName
  • func (s ServiceName) Default() string
  • func (s ServiceName) Group(group string) string

Constants

const (
	Scheme_Etcd = "etcd"
)

Functions

func AddLocal

func AddLocal(local *Local)

func Close

func Close()

func Dial

func Dial(serviceName ServiceName, group string) (grpc.ClientConnInterface, error)

func DialDefault

func DialDefault(serviceName ServiceName) (grpc.ClientConnInterface, error)

func SetLoadBalance

func SetLoadBalance(name string)

func SetLocals

func SetLocals(locals []*Local)

func SetMode

func SetMode(m Mode)

Types

type LoadBalance

type LoadBalance struct {
	Config []map[string]any `json:"loadBalancingConfig"`
}

func NewLoadBalance

func NewLoadBalance(name string) LoadBalance

type Local

type Local struct {
	Host    string      `yaml:"host" json:"host"`
	Port    int         `yaml:"port" json:"port"`
	Name    ServiceName `yaml:"name" json:"name"`
	Group   string      `yaml:"group" json:"group"`
	Weight  int64       `yaml:"weight" json:"weight"`
	Version string      `yaml:"version" json:"version"`
}

func (*Local) Addr

func (l *Local) Addr() string

func (*Local) InnerAddr

func (l *Local) InnerAddr() string

func (*Local) Instance

func (l *Local) Instance() *grpc.Instance

func (*Local) ServiceName

func (l *Local) ServiceName() string

type Locals

type Locals map[string]*Local

func (Locals) Add

func (l Locals) Add(lo *Local)

func (Locals) Get

func (l Locals) Get(name string) (*Local, bool)

type Mode

type Mode string

const (
	Mode_Local  Mode = "local"  // local service
	Mode_Remote Mode = "remote" // remote service
)

type ServiceName

type ServiceName string

func (ServiceName) Default

func (s ServiceName) Default() string

func (ServiceName) Group

func (s ServiceName) Group(group string) string