webservice

Documentation

Index

• Constants
• func AddCrawlerNode(c *fiber.Ctx) error
• func AddNode(c *fiber.Ctx) error
• func ChangePassword(c *fiber.Ctx) error
• func CheckUsable(c *fiber.Ctx) error
• func InitHttpService() (bool, error)
• func InitStorage() error
• func InitWs(app *fiber.App) error
• func NodeList(ctx *fiber.Ctx) error
• func Pac(c *fiber.Ctx) error
• func Registration(c *fiber.Ctx) error
• func SubClash(c *fiber.Ctx) error
• func SubV2ray(c *fiber.Ctx) error
• func SyncNode(c *fiber.Ctx) error
• func Version(c *fiber.Ctx) error
• type AddCrawlerNodeReq
• type AddNodeReq
• type Init
  • func (p *Init) Init() (needRun bool, err error)
  • func (p *Init) Name() string
  • func (p *Init) WaitFinish()
• type Sub
• type WsClient
  • func NewWsClient(c *websocket.Conn) *WsClient
  • func (p *WsClient) Init(clientId string) error
  • func (p *WsClient) RecvMsgForever()
  • func (p *WsClient) SendMsg(msg interface{}) error
• type WsClientDispatch
  • func NewWsClientDispatch() *WsClientDispatch
  • func (p *WsClientDispatch) Add(c *websocket.Conn) error
  • func (p *WsClientDispatch) OnClose(clientId string)

Constants

const (
	SessionKeyUid     = "Uid"
	SessionKeyUserKey = "UserKey"
	SessionKeyUserIp  = "UserIp"
)

Functions

func AddCrawlerNode

func AddCrawlerNode(c *fiber.Ctx) error

func AddNode

func AddNode(c *fiber.Ctx) error

func ChangePassword

func ChangePassword(c *fiber.Ctx) error

func CheckUsable

func CheckUsable(c *fiber.Ctx) error

func InitHttpService

func InitHttpService() (bool, error)

func InitStorage

func InitStorage() error

func InitWs

func InitWs(app *fiber.App) error

func NodeList

func NodeList(ctx *fiber.Ctx) error

func Pac

func Pac(c *fiber.Ctx) error

func Registration

func Registration(c *fiber.Ctx) error

func SubClash

func SubClash(c *fiber.Ctx) error

func SubV2ray

func SubV2ray(c *fiber.Ctx) error

func SyncNode

func SyncNode(c *fiber.Ctx) error

func Version

func Version(c *fiber.Ctx) error

Types

type AddCrawlerNodeReq

type AddCrawlerNodeReq struct {
	NodeUrl     string                  `json:"node_url" validate:"required"`
	CrawlerType domain.CrawlType        `json:"crawler_type"`
	Rule        domain.CrawlerConf_Rule `json:"rule"`
	UseTpe      domain.UseType          `json:"use_tpe"`
}

type AddNodeReq

type AddNodeReq struct {
	NodeUrl string `json:"node_url" validate:"required"`
}

type Init

type Init struct {
}

func (*Init) Init

func (p *Init) Init() (needRun bool, err error)

func (*Init) Name

func (p *Init) Name() string

func (*Init) WaitFinish

func (p *Init) WaitFinish()

type Sub

type Sub struct {
	Limit          *int     `json:"limit" query:"limit" yaml:"limit"  default:"50"`
	DnsServiceList []string `json:"dns_service_list" query:"dns_service_list" yaml:"dns_service_list"`
	EnableIpv6     *bool    `json:"enable_ipv6" query:"enable_ipv6" yaml:"enable_ipv6"`
	CheckProxy     *bool    `json:"check_proxy" query:"check_proxy" yaml:"check_proxy"`
}

type WsClient

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

func NewWsClient

func NewWsClient(c *websocket.Conn) *WsClient

func (*WsClient) Init

func (p *WsClient) Init(clientId string) error

func (*WsClient) RecvMsgForever

func (p *WsClient) RecvMsgForever()

func (*WsClient) SendMsg

func (p *WsClient) SendMsg(msg interface{}) error

type WsClientDispatch

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

func NewWsClientDispatch

func NewWsClientDispatch() *WsClientDispatch

func (*WsClientDispatch) Add

func (p *WsClientDispatch) Add(c *websocket.Conn) error

func (*WsClientDispatch) OnClose

func (p *WsClientDispatch) OnClose(clientId string)