service

package

v0.0.0-...-a604d9f Latest Latest Go to latest Published: May 24, 2021 License: BSD-3-Clause Imports: 20 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

View Source

var (

	// 服务器 IP
	InternalIPv4 string
	ExternalIPv4 string
)

func BulkPostJSON(api []string, jsonList []string)

暂无大量数据分批发送需求

func DataAggregate(ctx context.Context)

把内存队列数据推送到 Redis

func DataRouter(ctx context.Context)

func Heartbeat()

心跳日志

func PostAPI(ctx context.Context, key string, apiConf conf.TPostAPIConf)

func PostAggregate(key string)

接口分类汇聚

func PostES(key string, data []string)

func PushDataToQueue(apiname string, body []byte, ip string)

接收请求, 将数据写入内存队列

func RedisInfo() common.TStringAnyMaps

Redis Info

func RunningStatus() common.TStringAnyMaps

运行状态

func TodoScheduler(ctx context.Context)

func UDPServer(addr string, withSendTo bool) error

标准的 UDP 服务

func UDPServerG(addr string, withSendTo bool) error

type TUDPServerG struct {
	*gnet.EventServer
	// contains filtered or unexported fields
}

func (s *TUDPServerG) React(frame []byte, c gnet.Conn) (out []byte, action gnet.Action)