sessdata

Documentation

Index

• Constants
• Variables
• func AcquireIp(username, macAddr string) net.IP
• func CloseCSess(token string)
• func CloseSess(token string)
• func CopyStruct(a interface{}, b interface{}, fields ...string) (err error)
• func DelSess(token string)
• func DelSessByStoken(stoken string)
• func Dtls2MasterSecret(did string) string
• func GenToken() string
• func LimitClient(user string, close bool) bool
• func ReleaseIp(ip net.IP, macAddr string)
• func Start()
• type ConnSession
  • func (cs *ConnSession) Close()
  • func (cs *ConnSession) GetDtlsSession() *DtlsSession
  • func (cs *ConnSession) NewDtlsConn() *DtlsSession
  • func (cs *ConnSession) RateLimit(byt int, isUp bool) error
  • func (cs *ConnSession) SetIfName(name string)
  • func (cs *ConnSession) SetMtu(mtu string)
• type DtlsSession
  • func (ds *DtlsSession) Close()
• type LType
• type LimitRater
  • func NewLimitRater(lim, burst int) *LimitRater
  • func (l *LimitRater) Wait(bt int) error
• type Online
  • func OnlineSess() []Online
• type Onlines
  • func (o Onlines) Len() int
  • func (o Onlines) Less(i, j int) bool
  • func (o Onlines) Swap(i, j int)
• type Payload
• type Session
  • func Dtls2Sess(did string) *Session
  • func NewSession(token string) *Session
  • func SToken2Sess(stoken string) *Session
  • func Token2Sess(token string) *Session
  • func (s *Session) NewConn() *ConnSession

Constants

const BandwidthPeriodSec = 2 // 流量速率统计周期(秒)

const MaxMtu = 1460

Variables

var (
	IpPool = &ipPoolConfig{}
)

Functions

func AcquireIp

func AcquireIp(username, macAddr string) net.IP

AcquireIp 获取动态ip

func CloseCSess

func CloseCSess(token string)

func CloseSess

func CloseSess(token string)

func CopyStruct

func CopyStruct(a interface{}, b interface{}, fields ...string) (err error)

用b的所有字段覆盖a的 如果fields不为空, 表示用b的特定字段覆盖a的 a应该为结构体指针

func DelSess

func DelSess(token string)

func DelSessByStoken

func DelSessByStoken(stoken string)

func Dtls2MasterSecret

func Dtls2MasterSecret(did string) string

func GenToken

func GenToken() string

func LimitClient

func LimitClient(user string, close bool) bool

func ReleaseIp

func ReleaseIp(ip net.IP, macAddr string)

回收ip

func Start

func Start()

Types

type ConnSession

type ConnSession struct {
	Sess                *Session
	MasterSecret        string // dtls协议的 master_secret
	IpAddr              net.IP // 分配的ip地址
	LocalIp             net.IP
	MacHw               net.HardwareAddr // 客户端mac地址,从Session取出
	RemoteAddr          string
	Mtu                 int
	IfName              string
	Client              string // 客户端  mobile pc
	CstpDpd             int
	Group               *dbdata.Group
	Limit               *LimitRater
	BandwidthUp         uint32 // 使用上行带宽 Byte
	BandwidthDown       uint32 // 使用下行带宽 Byte
	BandwidthUpPeriod   uint32 // 前一周期的总量
	BandwidthDownPeriod uint32
	BandwidthUpAll      uint64 // 使用上行带宽总量
	BandwidthDownAll    uint64 // 使用下行带宽总量

	CloseChan      chan struct{}
	PayloadIn      chan *Payload
	PayloadOutCstp chan *Payload    // Cstp的数据
	PayloadOutDtls chan *Payload    // Dtls的数据
	IpAuditMap     map[string]int64 // 审计的ip数据
	// contains filtered or unexported fields
}

连接sess

func (*ConnSession) Close

func (cs *ConnSession) Close()

func (*ConnSession) GetDtlsSession

func (cs *ConnSession) GetDtlsSession() *DtlsSession

func (*ConnSession) NewDtlsConn

func (cs *ConnSession) NewDtlsConn() *DtlsSession

创建dtls链接

func (*ConnSession) RateLimit

func (cs *ConnSession) RateLimit(byt int, isUp bool) error

func (*ConnSession) SetIfName

func (cs *ConnSession) SetIfName(name string)

func (*ConnSession) SetMtu

func (cs *ConnSession) SetMtu(mtu string)

type DtlsSession

type DtlsSession struct {
	CloseChan chan struct{}

	IpAddr net.IP
	// contains filtered or unexported fields
}

func (*DtlsSession) Close

func (ds *DtlsSession) Close()

关闭dtls链接

type LType

type LType int8

const (
	LTypeEthernet LType = 1
	LTypeIPData   LType = 2
)

type LimitRater

type LimitRater struct {
	// contains filtered or unexported fields
}

func NewLimitRater

func NewLimitRater(lim, burst int) *LimitRater

lim: 令牌产生速率 burst: 允许的最大爆发速率

func (*LimitRater) Wait

func (l *LimitRater) Wait(bt int) error

bt 不能超过burst大小

type Online

type Online struct {
	Token            string    `json:"token"`
	Username         string    `json:"username"`
	Group            string    `json:"group"`
	MacAddr          string    `json:"mac_addr"`
	Ip               net.IP    `json:"ip"`
	RemoteAddr       string    `json:"remote_addr"`
	TunName          string    `json:"tun_name"`
	Mtu              int       `json:"mtu"`
	Client           string    `json:"client"`
	BandwidthUp      string    `json:"bandwidth_up"`
	BandwidthDown    string    `json:"bandwidth_down"`
	BandwidthUpAll   string    `json:"bandwidth_up_all"`
	BandwidthDownAll string    `json:"bandwidth_down_all"`
	LastLogin        time.Time `json:"last_login"`
}

func OnlineSess

func OnlineSess() []Online

type Onlines

type Onlines []Online

func (Onlines) Len

func (o Onlines) Len() int

func (Onlines) Less

func (o Onlines) Less(i, j int) bool

func (Onlines) Swap

func (o Onlines) Swap(i, j int)

type Payload

type Payload struct {
	LType LType // LinkType
	PType byte  // payload types
	Data  []byte
}

type Session

type Session struct {
	Sid            string // auth返回的 session-id
	Token          string // session信息的唯一token
	DtlsSid        string // dtls协议的 session_id
	MacAddr        string // 客户端mac地址
	UniqueIdGlobal string // 客户端唯一标示
	Username       string // 用户名
	Group          string
	AuthStep       string
	AuthPass       string

	LastLogin time.Time
	IsActive  bool

	// 开启link需要设置的参数
	CSess *ConnSession
	// contains filtered or unexported fields
}

func Dtls2Sess

func Dtls2Sess(did string) *Session

func NewSession

func NewSession(token string) *Session

func SToken2Sess

func SToken2Sess(stoken string) *Session

func Token2Sess

func Token2Sess(token string) *Session

func (*Session) NewConn

func (s *Session) NewConn() *ConnSession