remote

Documentation

Index

• func GetEventQueueSize() int
• func GetSessionTableSize() int
• func HandleRequestBuffer(reqbuf *bytes.Buffer, ctx *ConnContext) ([]event.Event, error)
• func ReleaseEventQueue(q *ConnEventQueue)
• type ConnContext
  • func NewConnContext() *ConnContext
• type ConnEventQueue
  • func GetEventQueue(cid ConnId, createIfMissing bool) *ConnEventQueue
  • func (q *ConnEventQueue) PeekMulti(n int, timeout time.Duration) ([]event.Event, error)
• type ConnId
• type EncryptConfig
• type ProxySession
• type ServerConfig
  • func (conf *ServerConfig) VerifyUser(user string) bool
• type SessionId

Functions

func GetEventQueueSize

func GetEventQueueSize() int

func GetSessionTableSize

func GetSessionTableSize() int

func HandleRequestBuffer

func HandleRequestBuffer(reqbuf *bytes.Buffer, ctx *ConnContext) ([]event.Event, error)

func ReleaseEventQueue

func ReleaseEventQueue(q *ConnEventQueue)

Types

type ConnContext

type ConnContext struct {
	ConnId
	IV uint64
}

func NewConnContext

func NewConnContext() *ConnContext

type ConnEventQueue

type ConnEventQueue struct {
	event.EventQueue
	// contains filtered or unexported fields
}

func GetEventQueue

func GetEventQueue(cid ConnId, createIfMissing bool) *ConnEventQueue

func (*ConnEventQueue) PeekMulti

func (q *ConnEventQueue) PeekMulti(n int, timeout time.Duration) ([]event.Event, error)

type ConnId

type ConnId struct {
	User      string
	ConnIndex int
	RunId     int64
}

type EncryptConfig

type EncryptConfig struct {
	Method string
	Key    string
}

type ProxySession

type ProxySession struct {
	Id         SessionId
	CreateTime time.Time
	// contains filtered or unexported fields
}

type ServerConfig

type ServerConfig struct {
	Listen      string
	AdminListen string
	Auth        []string
	Encrypt     EncryptConfig
	Log         []string
}

var ServerConf ServerConfig

func (*ServerConfig) VerifyUser

func (conf *ServerConfig) VerifyUser(user string) bool

type SessionId

type SessionId struct {
	ConnId
	Id uint32
}