server

Documentation

Index

• Constants
• type AddrArray
  • func NewAddrArray() AddrArray
  • func (ay AddrArray) Add(addr string)
  • func (ay AddrArray) Array() []string
  • func (ay AddrArray) ToWeight() AddrArray
• type Address
  • func Parse(addr string) (Address, error)
  • func ParseWithSeparate(info string) Address
  • func (s Address) Adjust()
  • func (s Address) HasDomain() bool
  • func (s Address) HasIP() bool
  • func (s Address) HasPort() bool
  • func (s Address) IsHttp() bool
  • func (s Address) IsScheme(scheme string) bool
  • func (s Address) IsWs() bool
  • func (s Address) SetHost(host string)
  • func (s Address) To() string
• type AuthMethod
  • func (a AuthMethod) Int() int8
• type AuthStatus
  • func (a AuthStatus) Int() int8
• type AuthType
  • func (a AuthType) Int() int8
• type ByWeight
  • func (a ByWeight) Len() int
  • func (a ByWeight) Less(i, j int) bool
  • func (a ByWeight) Swap(i, j int)
• type Cluster
• type Database
  • func (d Database) GetDataSourceName() string
• type Domain
  • func (c Domain) DomainTo() string
• type Elastic
• type EndPoints
  • func ReadEndPoints(filename string) (EndPoints, error)
• type HealthCheck
  • func ReadHealthCheck() (HealthCheck, error)
  • func (hc *HealthCheck) IsGRpc() bool
  • func (hc *HealthCheck) IsHttp() bool
  • func (hc *HealthCheck) IsTcp() bool
  • func (hc *HealthCheck) IsTtl() bool
• type Local
• type MqClient
• type MqConfig
• type MqConsumerConfig
• type MqCredentials
• type MqProducerConfig
• type Node
  • func NodeWith(source, build string) Node
  • func (s Node) NameWith(build string) string
  • func (s Node) NameWithRoot(build string) string
  • func (s Node) SetType(t string)
• type Redis
• type Sql
• type ValidatingType
  • func (a ValidatingType) Int() int

Constants

const (
	AT_DEF     = AuthType(0)
	AT_NAME    = AuthType(1)  //用户名
	AT_PHONE   = AuthType(2)  //手机
	AT_EMAIL   = AuthType(3)  //邮箱
	AT_WEIXIN  = AuthType(4)  //微信（第三方）
	AT_WEIBIO  = AuthType(5)  //微博（第三方）
	AT_QQ      = AuthType(6)  //QQ （第三方）
	AT_WXMINI  = AuthType(7)  //微信小程序（第三方）
	AT_WXSER   = AuthType(8)  //微信服务号（第三方）
	AT_TODAY   = AuthType(9)  //今日头条（第三方）
	AT_BAIDU   = AuthType(10) //百度（第三方）
	AT_TOKEN   = AuthType(99) //业务TOKEN验证
	AT_VISITOR = AuthType(100)
	AT_INNER   = AuthType(101)
	AT_END     = AuthType(102)
)

const (
	AS_DEF        = AuthStatus(0) //0=未激活 1=正在.. 2=已激活 3=删除
	AS_ACTIVATING = AuthStatus(1)
	AS_ACTIVATED  = AuthStatus(2)
	AS_DELETED    = AuthStatus(3)
)

const (
	AM_DEF  = AuthMethod(0)
	AM_PASS = AuthMethod(1) //密码
	AM_SMS  = AuthMethod(2) //短信
	AM_END  = AuthMethod(3)
)

const (
	VT_DEF        = ValidatingType(0)
	VT_REG_SMS    = ValidatingType(1) //注册短信
	VT_LOG_SMS    = ValidatingType(2) //登录短信
	VT_REG_INVITE = ValidatingType(3) //注册邀请
	VT_ACT_EMAIL  = ValidatingType(4)
	VT_END        = ValidatingType(255)
)

const (
	//PC MAC IPHONE IPAD APHONE APAD TV
	PT_PC     = "pc"
	PT_MAC    = "mac"
	PT_IPHONE = "iphone"
	PT_IPAD   = "ipad"
	PT_APHONE = "aphone"
	PT_APAD   = "apad"
	PT_TV     = "tv"
)

const (
	GHealthTtl = 10
)

Types

type AddrArray

type AddrArray []Address

func NewAddrArray

func NewAddrArray() AddrArray

func (AddrArray) Add

func (ay AddrArray) Add(addr string)

Add @param s = host:port

func (AddrArray) Array

func (ay AddrArray) Array() []string

func (AddrArray) ToWeight

func (ay AddrArray) ToWeight() AddrArray

type Address

type Address struct {
	Scheme  string `json:"scheme" yaml:"scheme" xml:"scheme"`
	Host    string `json:"host" yaml:"host" xml:"host"`
	Port    int    `json:"port" yaml:"port" xml:"port"`
	Path    string `json:"path,omitempty" yaml:"path,omitempty" xml:"path,omitempty"`
	Name    string `json:"name,omitempty" yaml:"name,omitempty" xml:"name,omitempty"`
	Weight  int    `json:"weight,omitempty" yaml:"weight,omitempty" xml:"weight,omitempty"`
	Timeout int    `json:"timeout,omitempty" yaml:"timeout,omitempty" xml:"timeout,omitempty"`
}

func Parse

func Parse(addr string) (Address, error)

func ParseWithSeparate

func ParseWithSeparate(info string) Address

ParseWithSeparate info = name|scheme://host:post|timeout|weight

func (Address) Adjust

func (s Address) Adjust()

Adjust 如果IP是自己，调整为 127.0.0.1

func (Address) HasDomain

func (s Address) HasDomain() bool

HasDomain 简单的域名 .com,.cn

func (Address) HasIP

func (s Address) HasIP() bool

func (Address) HasPort

func (s Address) HasPort() bool

func (Address) IsHttp

func (s Address) IsHttp() bool

func (Address) IsScheme

func (s Address) IsScheme(scheme string) bool

func (Address) IsWs

func (s Address) IsWs() bool

func (Address) SetHost

func (s Address) SetHost(host string)

func (Address) To

func (s Address) To() string

To scheme://host:port

type AuthMethod

type AuthMethod int8

认证方法

func (AuthMethod) Int

func (a AuthMethod) Int() int8

type AuthStatus

type AuthStatus int8

认证状态

func (AuthStatus) Int

func (a AuthStatus) Int() int8

type AuthType

type AuthType int8

认证 1=用户名, 2=手机 3=邮箱 4=微信 5=微博 6=QQ 7=小程序

func (AuthType) Int

func (a AuthType) Int() int8

type ByWeight

type ByWeight []Address

func (ByWeight) Len

func (a ByWeight) Len() int

func (ByWeight) Less

func (a ByWeight) Less(i, j int) bool

func (ByWeight) Swap

func (a ByWeight) Swap(i, j int)

type Cluster

type Cluster struct {
	Nodes        []Address     `json:"nodes" yaml:"nodes" xml:"nodes"`
	Password     string        `json:"password" yaml:"password" xml:"password"`
	PoolSize     int           `json:"pool_size" yaml:"pool_size" xml:"pool_size"`
	ReadOnly     bool          `json:"read_only" yaml:"read_only" xml:"read_only"`
	DialTimeout  time.Duration `json:"dial_timeout" yaml:"dial_timeout" xml:"dial_timeout"`
	ReadTimeout  time.Duration `json:"read_timeout" yaml:"read_timeout" xml:"read_timeout"`
	WriteTimeout time.Duration `json:"write_timeout" yaml:"write_timeout" xml:"write_timeout"`
}

Cluster 集群配置

type Database

type Database struct {
	Host       string `json:"host" yaml:"host" xml:"host"`
	Port       int    `json:"port" yaml:"port" xml:"port"`
	User       string `json:"user" yaml:"user" xml:"user"`
	Pwd        string `json:"pwd" yaml:"pwd" xml:"pwd"`
	DriverType string `json:"type" yaml:"type" xml:"type"` //mysql, sqlite
	Name       string `json:"name" yaml:"name" xml:"name"` //数据库名
}

func (Database) GetDataSourceName

func (d Database) GetDataSourceName() string

type Domain

type Domain struct {
	Domain string `json:"-"`
	Raw    string `json:"domain" yaml:"domain" xml:"domain"`
}

func (Domain) DomainTo

func (c Domain) DomainTo() string

type Elastic

type Elastic struct {
	Name              string `json:"name" yaml:"name" xml:"name"` //数据名（不是数据库名）
	Url               string `json:"url" yaml:"url" xml:"url"`
	User              string `json:"user" yaml:"user" xml:"user"`
	Pwd               string `json:"pwd" yaml:"pwd" xml:"pwd"`
	Sniff             bool   `json:"sniff" yaml:"sniff" xml:"sniff"`
	XPackSecurityUser string `json:"XPackSecurityUser" yaml:"XPackSecurityUser" xml:"XPackSecurityUser"`
}

type EndPoints

type EndPoints struct {
	Servers AddrArray `json:"servers"`
	Type    string    `json:"type"` //IP直连，不需要向consul,etcd,dubbo注册
}

func ReadEndPoints

func ReadEndPoints(filename string) (EndPoints, error)

ReadEndPoints filename 相对文件名

type HealthCheck

type HealthCheck struct {
	Ttl      bool          `json:"ttl"`
	GRpc     bool          `json:"grpc"`
	Http     bool          `json:"http"`
	Tcp      bool          `json:"tcp"`
	Interval time.Duration `json:"interval"` //(second)
	Value    string        `json:"value"`
}

func ReadHealthCheck

func ReadHealthCheck() (HealthCheck, error)

func (*HealthCheck) IsGRpc

func (hc *HealthCheck) IsGRpc() bool

func (*HealthCheck) IsHttp

func (hc *HealthCheck) IsHttp() bool

func (*HealthCheck) IsTcp

func (hc *HealthCheck) IsTcp() bool

func (*HealthCheck) IsTtl

func (hc *HealthCheck) IsTtl() bool

type Local

type Local struct {
	Name    string
	Version string
	AppId   string
}

type MqClient

type MqClient struct {
	GroupID      string `json:"groupId" yaml:"groupId" xml:"groupId"`
	Server       string `json:"server" yaml:"server" xml:"server"`
	Domain       string `json:"domain" yaml:"domain" xml:"domain"`
	GroupName    string `json:"groupName" yaml:"groupName" xml:"groupName"`
	InstanceName string `json:"instance" yaml:"instance" xml:"instance"`
}

type MqConfig

type MqConfig struct {
	Client       MqClient         `json:"client" yaml:"client" xml:"client"`
	Credentials  MqCredentials    `json:"credentials" yaml:"credentials" xml:"credentials"`
	LogLevel     int              `json:"logLevel" yaml:"logLevel" xml:"logLevel"`
	ProducerConf MqProducerConfig `json:"producer" yaml:"producer" xml:"producer"`
	ConsumerConf MqConsumerConfig `json:"consumer" yaml:"consumer" xml:"consumer"`
}

type MqConsumerConfig

type MqConsumerConfig struct {
	ThreadCount int `json:"threadCount" yaml:"threadCount" xml:"threadCount"`
	Model       int `json:"model" yaml:"model" xml:"model"`
	Size        int `json:"size" yaml:"size" xml:"size"`
}

type MqCredentials

type MqCredentials struct {
	AccessKey   string `json:"accessKey" yaml:"accessKey" xml:"accessKey"`
	SecretKey   string `json:"secretKey" yaml:"secretKey" xml:"secretKey"`
	SecretToken string `json:"secretToken" yaml:"secretToken" xml:"secretToken"`
}

type MqProducerConfig

type MqProducerConfig struct {
	Timeout  int `json:"timeout" yaml:"timeout" xml:"timeout"`
	Compress int `json:"compress" yaml:"compress" xml:"compress"`
	Size     int `json:"size" yaml:"size" xml:"size"`
	Retry    int `json:"retry" yaml:"retry" xml:"retry"`
}

type Node

type Node struct {
	Root    string
	Service string
	//"grpc"， "thrift"
	RpcMethod string
}

func NodeWith

func NodeWith(source, build string) Node

func (Node) NameWith

func (s Node) NameWith(build string) string

func (Node) NameWithRoot

func (s Node) NameWithRoot(build string) string

func (Node) SetType

func (s Node) SetType(t string)

type Redis

type Redis struct {
	Name string `json:"name" yaml:"name" xml:"name"` //redis名
	Host string `json:"host" yaml:"host" xml:"host"`
	Port int    `json:"port" yaml:"port" xml:"port"`
	User string `json:"user" yaml:"user" xml:"user"`
	Pwd  string `json:"pwd" yaml:"pwd" xml:"pwd"`
	DB   int    `json:"db" yaml:"db" xml:"db"`
}

type Sql

type Sql struct {
	Name         string        `json:"name" yaml:"name" xml:"name"` //数据名（不是数据库名）
	Master       Database      `json:"master" yaml:"master" xml:"master"`
	Sources      []Database    `json:"sources" yaml:"sources" xml:"sources"`
	Replicas     []Database    `json:"replicas" yaml:"replicas" xml:"replicas"`
	MaxOpenConns int           `json:"max_open_conns" yaml:"max_open_conns" xml:"max_open_conns"`
	MaxIdleConns int           `json:"max_idle_conns" yaml:"max_idle_conns" xml:"max_idle_conns"`
	MaxIdleTime  time.Duration `json:"max_idle_time" yaml:"max_idle_time" xml:"max_idle_time"`
	Logger       int           `json:"logger" yaml:"logger" xml:"logger"`
}

type ValidatingType

type ValidatingType int

验证类型

func (ValidatingType) Int

func (a ValidatingType) Int() int