server

package

v1.0.0 Latest Latest Go to latest Published: Sep 19, 2022 License: Apache-2.0 Imports: 9 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.

This section is empty.

This section is empty.

type NotifyResult struct {
	Result string `json:"result"`
	Msg    string `json:"msg"`
}

type Option func(s *Server)

func WithBasePath(basePath string) Option

func WithEngine(engine *gin.Engine) Option

func WithGlobalErrorHandler(ef func(reqId string, taskPath string, paniced interface{}) error) Option

全局错误处理。如果ef返回的error不为nil，则会将error信息通知到client

func WithLogger(logger *logrus.Logger) Option

func WithMaxWaitSecondsWhenNotifyErrorBlock(n int) Option

通知出错时，需要重新通知。如果队列阻塞时，最长等待时间。

func WithNotifyErrorFrequencySeconds(n int) Option

通知出错时，需要重新通知。每n秒，重新通知一次。

func WithNotifyGoroutineNum(n int) Option

通知client的goroutine数量

func WithPort(port string) Option

func WithRetryNotifyTimes(n int) Option

通知出错时，最多尝试次数

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

func NewServer(options ...Option) *Server

func (s *Server) Close()

func (s *Server) RegisterTaskHandler(taskPath string, handler TaskHandler)

func (s *Server) Start()

type TaskHandler interface {
	Handle(reqId string, params map[string]string) (string, error)
}

type TaskHandlerFunc func(reqId string, params map[string]string) (string, error)

func (f TaskHandlerFunc) Handle(reqId string, params map[string]string) (string, error)