golang

package
v0.0.0-...-bf94cd9 Latest Latest
Warning

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

 Go to latest Published: Nov 6, 2023 License: GPL-3.0 Imports: 22 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var InitialCap int
View Source 
var ReqHubConns = make([]*net.TCPConn, 0)
View Source 
var ReqSeqCallbacks *syncmap.SyncMap
View Source 
var ToHub []string

Functions

func AgreeHandler 

func AgreeHandler(w http.ResponseWriter, r *http.Request)

func GetListHandler 

func GetListHandler(w http.ResponseWriter, r *http.Request)

func GetMemberHandler 

func GetMemberHandler(w http.ResponseWriter, r *http.Request)

func GetRecommendUserHandler 

func GetRecommendUserHandler(w http.ResponseWriter, r *http.Request)

func GetUserRow 

func GetUserRow(db *sql.DB, sid string) map[string]string

func InitGlobalGroup 

func InitGlobalGroup()

初始化群组

func InitHandler 

func InitHandler()

初始化 http请求

func InitReqHubPool 

func InitReqHubPool(to_hub []string)

func JoinChannel 

func JoinChannel(db *sql.DB, uid int, sid string)

func LoginHandler 

func LoginHandler(w http.ResponseWriter, r *http.Request)

func RegHandler 

func RegHandler(w http.ResponseWriter, r *http.Request)

func RejectHandler 

func RejectHandler(w http.ResponseWriter, r *http.Request)

func ReqAddFriendHandler 

func ReqAddFriendHandler(w http.ResponseWriter, r *http.Request)

func ReqAddGroupHandler 

func ReqAddGroupHandler(w http.ResponseWriter, r *http.Request)

func SystemMsgHandler 

func SystemMsgHandler(w http.ResponseWriter, r *http.Request)

func UploadFileHandler 

func UploadFileHandler(w http.ResponseWriter, r *http.Request)

func UploadImageHandler 

func UploadImageHandler(w http.ResponseWriter, r *http.Request)

Types

type AfterWorkCallback 

type AfterWorkCallback func(resp_buf string) string

type FriendType 

type FriendType struct {
	Groupname string              `json:"groupname"`
	Online    int                 `json:"online"`
	Id        int                 `json:"id"`
	List      []map[string]string `json:"list"`
}

type ListType 

type ListType struct {
	Mine   map[string]string   `json:"mine"`
	Friend []FriendType        `json:"friend"`
	Group  []map[string]string `json:"group"`
}

type MemberType 

type MemberType struct {
	Owner   map[string]string   `json:"owner"`
	Members int                 `json:"members"`
	List    []map[string]string `json:"list"`
}

type PushReqHub 

type PushReqHub struct {
	Sid  bool
	Msg  string
	Info map[string]string
}

type ReturnType 

type ReturnType struct {
	Ret string `json:"ret"`

	Type string `json:"type"`

	Sid string `json:"sid"`

	Msg string `json:"msg"`
}

type Root 

type Root struct {
	Code  int         `json:"code"`
	Msg   string      `json:"msg"`
	Data  interface{} `json:"data"`
	Pages int         `json:"pages"`
}

type Sdk 

type Sdk struct {
	Connected bool

	HubConn *net.TCPConn

	ReqType string

	ReqHeader *protocol.ReqHeader

	Data []byte
}

func (*Sdk) AddCron 

func (sdk *Sdk) AddCron(expression string, exefnc func()) bool

func (*Sdk) AreaAddSid 

func (sdk *Sdk) AreaAddSid(sid string, area_id string) bool

func (*Sdk) AreaKickSid 

func (sdk *Sdk) AreaKickSid(sid string, area_id string) bool

func (*Sdk) BroadcastAll 

func (sdk *Sdk) BroadcastAll(msg []byte) bool

func (*Sdk) Broatcast 

func (sdk *Sdk) Broatcast(sid string, area_id string, data []byte) bool

func (*Sdk) CreateArea 

func (sdk *Sdk) CreateArea(id string, name string) bool

func (*Sdk) Disable 

func (sdk *Sdk) Disable() bool

func (*Sdk) Enable 

func (sdk *Sdk) Enable() bool

func (*Sdk) Get 

func (sdk *Sdk) Get(key string) string

func (*Sdk) GetAllSession 

func (sdk *Sdk) GetAllSession() string

func (*Sdk) GetAreas 

func (sdk *Sdk) GetAreas() map[string]string

func (*Sdk) GetAreasKey 

func (sdk *Sdk) GetAreasKey() []string

func (*Sdk) GetAreasStr 

func (sdk *Sdk) GetAreasStr() string

func (*Sdk) GetBase 

func (sdk *Sdk) GetBase() string

获取服务器的根路径

func (*Sdk) GetEnableStatus 

func (sdk *Sdk) GetEnableStatus() bool

获取服务启用状态

func (*Sdk) GetSession 

func (sdk *Sdk) GetSession(sid string) string

func (*Sdk) GetSessionType 

func (sdk *Sdk) GetSessionType(sid string) *area.Session

该方法仅在单机模式下调用

func (*Sdk) GetSidsByArea 

func (sdk *Sdk) GetSidsByArea(channel_id string) string

func (*Sdk) GetUserJoinedAreas 

func (sdk *Sdk) GetUserJoinedAreas(sid string) string

func (*Sdk) Init 

func (sdk *Sdk) Init(_type string, req_header *protocol.ReqHeader, data []byte) *Sdk

func (*Sdk) InitCmd 

func (sdk *Sdk) InitCmd(cmd string, sid string, reqid int, data []byte) *Sdk

func (*Sdk) Kick 

func (sdk *Sdk) Kick(sid string) bool

func (*Sdk) Push 

func (sdk *Sdk) Push(from_sid string, to_sid string, to_data []byte) bool

func (*Sdk) PushBySids 

func (sdk *Sdk) PushBySids(from_sid string, to_sids []string, data []byte) bool

func (*Sdk) PushHub 

func (sdk *Sdk) PushHub(req_cmd string, data []byte) bool

func (*Sdk) RemoveArea 

func (sdk *Sdk) RemoveArea(id string) bool

func (*Sdk) RemoveCron 

func (sdk *Sdk) RemoveCron(expression string) bool

func (*Sdk) ReqHub 

func (sdk *Sdk) ReqHub(req_cmd string, data []byte) (string, bool)

向Hub请求数据并监听返回,该请求将会阻塞除非等待返回超时

func (*Sdk) ReqHubAsync 

func (sdk *Sdk) ReqHubAsync(req_cmd string, data []byte, handler AfterWorkCallback) (string, bool)

向Hub请求数据并监听返回,该请求将会阻塞除非等待返回超时

func (*Sdk) Set 

func (sdk *Sdk) Set(key string, value string, expire int) bool

func (*Sdk) UpdateSession 

func (sdk *Sdk) UpdateSession(sid string, data string) bool

type SysMsgType 

type SysMsgType struct {
	Id         int64             `json:"id"`
	Content    string            `json:"content"`
	Username   string            `json:"username"`
	Uid        int64             `json:"uid"`
	From       int64             `json:"from"`
	From_group int64             `json:"from_group"`
	Type       int64             `json:"type"`
	Href       string            `json:"href"`
	Read       int64             `json:"read"`
	Remark     string            `json:"remark"`
	Time       string            `json:"time"`
	Status     int64             `json:"status"`
	User       map[string]string `json:"user"`
}

type TaskType 

type TaskType struct {
	Conn *net.TCPConn

	WsConn *websocket.Conn

	ReqType string

	ReqHeader *protocol.ReqHeader

	Data []byte
}

func (TaskType) Auth 

func (this TaskType) Auth() ReturnType

func (TaskType) Authorize 

func (this TaskType) Authorize() ReturnType

func (TaskType) Broadcast 

func (this TaskType) Broadcast() string

func (TaskType) GetAreas 

func (this TaskType) GetAreas() string

func (TaskType) GetBase 

func (this TaskType) GetBase(conn *net.TCPConn, cmd string, req_sid string, req_id int, req_data string) string

func (TaskType) GetUserSession 

func (this TaskType) GetUserSession() string

func (*TaskType) Init 

func (this *TaskType) Init(conn *net.TCPConn, req_obj *protocol.ReqRoot) *TaskType

func (TaskType) JoinArea 

func (this TaskType) JoinArea() string

func (TaskType) KickSelf 

func (this TaskType) KickSelf() interface{}

func (TaskType) LeaveChannel 

func (this TaskType) LeaveChannel() interface{}

func (TaskType) Message 

func (this TaskType) Message() string

func (TaskType) Push 

func (this TaskType) Push() string

func (TaskType) PushGroupMessage 

func (this TaskType) PushGroupMessage() string

func (TaskType) PushMessage 

func (this TaskType) PushMessage() string

func (TaskType) SubscripeGroup 

func (this TaskType) SubscripeGroup() ReturnType

func (TaskType) Update 

func (this TaskType) Update() string

func (*TaskType) WsInit 

func (this *TaskType) WsInit(wsconn *websocket.Conn, req_obj *protocol.ReqRoot) *TaskType

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.