core

package
v0.1.28 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 21, 2024 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	VERSION = "0.1.10"
)

Variables

View Source 
var ConnOnCreating = errors.New("conn  on creating ")
View Source 
var MessageIdIsBlank = errors.New("message Id is blank")
View Source 
var NetError = errors.New("net ERROR")
View Source 
var NoFoundUser = errors.New("NOT FOUND USER")
View Source 
var ProtocolError = errors.New("km protocolError")
View Source 
var ReadTimeout = errors.New("read timeout")
View Source 
var UnKnownClassId = errors.New("UNKNOWN CLASS ID")
View Source 
var UnKnownConn = errors.New("UNKNOWN Conn")
View Source 
var UnKnownMessageType = errors.New("UNKNOWN MESSAGE TYPE")
View Source 
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) DeleteUser 

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

func (*Context) FlashLiveTime added in v0.1.16 

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

func (*Context) GetCfgBool added in v0.1.18 

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

func (*Context) GetCfgBoolDefault added in v0.1.18 

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 added in v0.0.7 

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

func (*Context) GetHandle 

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

func (*Context) GetHistory added in v0.0.6 

func (context *Context) GetHistory(userName string) (*user.HistoryMessage, bool)

func (*Context) GetHttpPush 

func (context *Context) GetHttpPush() *HttpPush

func (*Context) GetLog added in v0.0.7 

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

func (*Context) GetSystemInfo 

func (context *Context) GetSystemInfo() systemInfo

func (*Context) GetUser 

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

func (*Context) GetUserAllOrder added in v0.1.1 

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

func (*Context) GetUserNum 

func (context *Context) GetUserNum() int

func (*Context) Go added in v0.1.14 

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

Go 协程异常保活，避免协程内错误导致整个系统

func (*Context) GoForIndex added in v0.1.27 

func (context *Context) GoForIndex(index int, handle func(ind int))

GoForIndex 协程异常保活，避免协程内错误导致整个系统

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) RecordMessage added in v0.1.16 

func (context *Context) RecordMessage(msg message.IMessage)

func (*Context) RecoverGo added in v0.1.14 

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

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

func (*Context) RegisterHandle 

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

func (*Context) SendGroupTextMessage 

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

func (*Context) SendMessage 

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

func (*Context) SendMessageForBack added in v0.0.5 

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

func (*Context) SendMultiMessageNoReplay added in v0.1.27 

func (context *Context) SendMultiMessageNoReplay(fromUser string, usernames []string, text string)

func (*Context) SendNoForwardMessage 

func (context *Context) SendNoForwardMessage(msg message.IMessage) (error, 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 DockMessage 

type DockMessage struct {
	InputMessage message.IMessage
	// contains filtered or unexported fields
}

type HttpPush 

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

func (*HttpPush) Start 

func (httpPush *HttpPush) Start() error

type IForward 

type IForward interface {
	HandleAddUser(iUser user.IUser)
	HandleDeleteUser(username string)
	WriteMessage(iMessage message.IMessage, exMachineId []string, writeFunc user.WriteCallBackFunc)
	GetOrderUser(username string) ([]user.IOrderUser, bool)
	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) HandleAddUser 

func (md *MsgDock) HandleAddUser(iUser user.IUser)

func (*MsgDock) HandleDeleteUser 

func (md *MsgDock) HandleDeleteUser(username string)

func (*MsgDock) Query 

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

func (*MsgDock) WriteMessage 

func (md *MsgDock) WriteMessage(msg message.IMessage, writeFunc user.WriteCallBackFunc)

func (*MsgDock) WriteNoForwardMessage 

func (md *MsgDock) WriteNoForwardMessage(msg message.IMessage, writeFunc user.WriteCallBackFunc)

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) GetIndex added in v0.1.27 

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 added in v0.1.27 

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
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.