core

Documentation

Index

• Constants
• Variables
• func GetUsername(re *Parameter) string
• type Context
  • func (context *Context) AddUser(iUser user.IUser)
  • func (context *Context) AllGroupInfo() map[string]int
  • func (context *Context) DeleteUser(iUser user.IUser) bool
  • func (context *Context) GetCfgBool(section, key string) bool
  • func (context *Context) GetCfgBoolDefault(section, key string, defaultValue bool) bool
  • func (context *Context) GetCfgInt(section, key string) int
  • func (context *Context) GetCfgString(section, key string) string
  • func (context *Context) GetCfgStringDefault(section, key, defaultValue string) string
  • func (context *Context) GetHandle(handleName string) (RegisterHandle, bool)
  • func (context *Context) GetHttpPush() *HttpPush
  • func (context *Context) GetLog() *zap.Logger
  • func (context *Context) GetStartTime() string
  • func (context *Context) GetSystemInfo() systemInfo
  • func (context *Context) GetUser(userName string) ([]user.IUser, bool)
  • func (context *Context) GetUserCreateTime(userName string) *time.Time
  • func (context *Context) GetUserNum() int
  • func (context *Context) GetUserOrder(username string) []user.IOrderUser
  • func (context *Context) Go(handle func())
  • func (context *Context) Query(parameter *Parameter) any
  • func (context *Context) RangeUser(f func(username string, user *user.StoreUser) bool)
  • func (context *Context) RecoverGo(handle func())
  • func (context *Context) RegisterHandle(handleName string, handle RegisterHandle)
  • func (context *Context) SendAsyncMessage(msg message.IMessage, write user.WriteCallBackFunc)
  • func (context *Context) SendGroupTextMessage(form string, groupId, msg string) int32
  • func (context *Context) SendLocalMessage(msg message.IMessage) (err error, fa bool)
  • func (context *Context) SendMessage(msg message.IMessage) (err error, fa bool)
  • func (context *Context) SendTextMessage(from string, to string, msg string) (error, bool)
  • func (context *Context) SetForward(forward IForward)
  • func (context *Context) SetSystemInfo(key string, value any)
• type HttpPush
  • func (httpPush *HttpPush) Start()
• type IForward
• type IHttpServer
  • func NewHttpServer(name string) IHttpServer
• type MsgDock
  • func NewMsgDock(userStore *user.Store, context *Context) *MsgDock
  • func (md *MsgDock) Query(parameter *Parameter, localValue any) []any
  • func (md *MsgDock) SendLocalMessage(msg message.IMessage) (bool, error)
  • func (md *MsgDock) SendMessage(msg message.IMessage) (bool, error)
• type Parameter
  • func NewParameter(re *http.Request) *Parameter
  • func (m *Parameter) CopyParameter() *Parameter
  • func (m *Parameter) GetIndex() int
  • func (m *Parameter) GetInt(key string) int
  • func (m *Parameter) GetString(key string) string
  • func (m *Parameter) GetVString(keys ...string) string
  • func (m *Parameter) SetIndex(index int)
  • func (m *Parameter) SetString(key string, value string)
• type Register
  • func NewRegister(config *config.Config) *Register
  • func (register *Register) AddServer(server Server)
  • func (register *Register) Create() *HttpPush
• type RegisterHandle
• type Server

Constants

const (
	VERSION = "0.2.1"
)

Variables

var ConnOnCreating = errors.New("conn  on creating ")

var MessageIdIsBlank = errors.New("message Id is blank")

var NetError = errors.New("net ERROR")

var NoFoundUser = errors.New("NOT FOUND USER")

var ProtocolError = errors.New("km protocolError")

var ReadTimeout = errors.New("read timeout")

var UnKnownClassId = errors.New("UNKNOWN CLASS ID")

var UnKnownConn = errors.New("UNKNOWN Conn")

var UnKnownMessageType = errors.New("UNKNOWN MESSAGE TYPE")

var UnKnownVersion = errors.New("UNKNOWN Version")

Functions

func GetUsername

func GetUsername(re *Parameter) string

Types

type Context

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

func (*Context) AddUser

func (context *Context) AddUser(iUser user.IUser)

func (*Context) AllGroupInfo

func (context *Context) AllGroupInfo() map[string]int

func (*Context) DeleteUser

func (context *Context) DeleteUser(iUser user.IUser) bool

func (*Context) GetCfgBool

func (context *Context) GetCfgBool(section, key string) bool

func (*Context) GetCfgBoolDefault

func (context *Context) GetCfgBoolDefault(section, key string, defaultValue bool) bool

func (*Context) GetCfgInt

func (context *Context) GetCfgInt(section, key string) int

func (*Context) GetCfgString

func (context *Context) GetCfgString(section, key string) string

func (*Context) GetCfgStringDefault

func (context *Context) GetCfgStringDefault(section, key, defaultValue string) string

func (*Context) GetHandle

func (context *Context) GetHandle(handleName string) (RegisterHandle, bool)

func (*Context) GetHttpPush

func (context *Context) GetHttpPush() *HttpPush

func (*Context) GetLog

func (context *Context) GetLog() *zap.Logger

func (*Context) GetStartTime

func (context *Context) GetStartTime() string

func (*Context) GetSystemInfo

func (context *Context) GetSystemInfo() systemInfo

func (*Context) GetUser

func (context *Context) GetUser(userName string) ([]user.IUser, bool)

func (*Context) GetUserCreateTime

func (context *Context) GetUserCreateTime(userName string) *time.Time

func (*Context) GetUserNum

func (context *Context) GetUserNum() int

func (*Context) GetUserOrder

func (context *Context) GetUserOrder(username string) []user.IOrderUser

func (*Context) Go

func (context *Context) Go(handle func())

func (*Context) Query

func (context *Context) Query(parameter *Parameter) any

func (*Context) RangeUser

func (context *Context) RangeUser(f func(username string, user *user.StoreUser) bool)

func (*Context) RecoverGo

func (context *Context) RecoverGo(handle func())

RecoverGo 协程异常恢复，异常后，会重启当前协程

func (*Context) RegisterHandle

func (context *Context) RegisterHandle(handleName string, handle RegisterHandle)

func (*Context) SendAsyncMessage

func (context *Context) SendAsyncMessage(msg message.IMessage, write user.WriteCallBackFunc)

func (*Context) SendGroupTextMessage

func (context *Context) SendGroupTextMessage(form string, groupId, msg string) int32

func (*Context) SendLocalMessage

func (context *Context) SendLocalMessage(msg message.IMessage) (err error, fa bool)

func (*Context) SendMessage

func (context *Context) SendMessage(msg message.IMessage) (err error, fa bool)

func (*Context) SendTextMessage

func (context *Context) SendTextMessage(from string, to string, msg string) (error, bool)

func (*Context) SetForward

func (context *Context) SetForward(forward IForward)

func (*Context) SetSystemInfo

func (context *Context) SetSystemInfo(key string, value any)

type HttpPush

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

func (*HttpPush) Start

func (httpPush *HttpPush) Start()

type IForward

type IForward interface {
	WriteSyncMessage(iMessage message.IMessage) (bool, error)
	Query(parameter *Parameter, localValue any) []any
}

IForward 集群使用/*

type IHttpServer

type IHttpServer interface {
	AddHttpRoute(pattern string, handler func(http.ResponseWriter, *http.Request))

	GetServerHost() string
	// contains filtered or unexported methods
}

func NewHttpServer

func NewHttpServer(name string) IHttpServer

type MsgDock

type MsgDock struct {
	IForward IForward
	// contains filtered or unexported fields
}

func NewMsgDock

func NewMsgDock(userStore *user.Store, context *Context) *MsgDock

func (*MsgDock) Query

func (md *MsgDock) Query(parameter *Parameter, localValue any) []any

func (*MsgDock) SendLocalMessage

func (md *MsgDock) SendLocalMessage(msg message.IMessage) (bool, error)

func (*MsgDock) SendMessage

func (md *MsgDock) SendMessage(msg message.IMessage) (bool, error)

type Parameter

type Parameter struct {
	Path     string
	Form     url.Values
	PostForm url.Values
	SetFrom  url.Values
}

func NewParameter

func NewParameter(re *http.Request) *Parameter

func (*Parameter) CopyParameter

func (m *Parameter) CopyParameter() *Parameter

func (*Parameter) GetIndex

func (m *Parameter) GetIndex() int

func (*Parameter) GetInt

func (m *Parameter) GetInt(key string) int

func (*Parameter) GetString

func (m *Parameter) GetString(key string) string

func (*Parameter) GetVString

func (m *Parameter) GetVString(keys ...string) string

func (*Parameter) SetIndex

func (m *Parameter) SetIndex(index int)

func (*Parameter) SetString

func (m *Parameter) SetString(key string, value string)

type Register

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

func NewRegister

func NewRegister(config *config.Config) *Register

func (*Register) AddServer

func (register *Register) AddServer(server Server)

func (*Register) Create

func (register *Register) Create() *HttpPush

type RegisterHandle

type RegisterHandle func(parameter *Parameter) any

type Server

type Server interface {
	Start() error
	Init(context *Context)
	Name() string
}