server

Documentation

Index

• type ConfigInfo
• type Option
  • func WithAddress(address string) Option
  • func WithKind(kind constant.ServiceKind) Option
  • func WithMetaData(key, value string) Option
  • func WithScheme(scheme string) Option
• type Route
• type Server
• type Service
• type ServiceInfo
  • func ApplyOptions(options ...Option) ServiceInfo
  • func (si ServiceInfo) Equal(o any) bool
  • func (si ServiceInfo) Label() string
  • func (s *ServiceInfo) RegistryName() string
  • func (s *ServiceInfo) ServicePrefix() string
• type WeightGroup

Types

type ConfigInfo

type ConfigInfo struct {
	Routes []Route
}

ConfigInfo ServiceConfigurator represents service configurator

type Option

type Option func(c *ServiceInfo)

Option ...

func WithAddress

func WithAddress(address string) Option

WithAddress ...

func WithKind

func WithKind(kind constant.ServiceKind) Option

WithKind ...

func WithMetaData

func WithMetaData(key, value string) Option

WithMetaData ...

func WithScheme

func WithScheme(scheme string) Option

WithScheme ...

type Route

type Route struct {
	// 权重组，按照
	WeightGroups []WeightGroup
	// 方法名
	Method string
}

Route ...

type Server

type Server interface {
	Serve() error
	Stop() error
	GracefulStop(ctx context.Context) error
	Info() *ServiceInfo
	Health() bool
}

Server ...

type Service

type Service struct {
	Namespace string            `json:"namespace" toml:"namespace"`
	Name      string            `json:"name" toml:"name"`
	Labels    map[string]string `json:"labels" toml:"labels"`
	Methods   []string          `json:"methods" toml:"methods"`
}

Service ...

type ServiceInfo

type ServiceInfo struct {
	Name       string               `json:"name"`
	AppID      string               `json:"appId"`
	Scheme     string               `json:"scheme"`
	Address    string               `json:"address"`
	Weight     float64              `json:"weight"`
	Enable     bool                 `json:"enable"`
	Healthy    bool                 `json:"healthy"`
	Metadata   map[string]string    `json:"metadata"`
	Region     string               `json:"region"`
	Zone       string               `json:"zone"`
	Kind       constant.ServiceKind `json:"kind"`
	Deployment string               `json:"deployment"` // Deployment 部署组: 不同组的流量隔离  比如某些服务给内部调用和第三方调用，可以配置不同的deployment,进行流量隔离
	Group      string               `json:"group"`      // Group 流量组: 流量在Group之间进行负载均衡
	Services   map[string]*Service  `json:"services" toml:"services"`
	Version    string               `json:"version"`
	Mode       string               `json:"mode"`
	Hostname   string               `json:"hostname"`
}

ServiceInfo represents service info

func ApplyOptions

func ApplyOptions(options ...Option) ServiceInfo

ApplyOptions ...

func (ServiceInfo) Equal

func (si ServiceInfo) Equal(o any) bool

Equal allows the values to be compared by Attributes.Equal, this change is in order to fit the change in grpc-go: attributes: add Equal method; resolver: add AddressMap and State.BalancerAttributes (#4855)

func (ServiceInfo) Label

func (si ServiceInfo) Label() string

Label ...

func (*ServiceInfo) RegistryName

func (s *ServiceInfo) RegistryName() string

func (*ServiceInfo) ServicePrefix

func (s *ServiceInfo) ServicePrefix() string

type WeightGroup

type WeightGroup struct {
	Group  string
	Weight int
}

WeightGroup ...