network

package

v0.0.0-...-7bf0052 Latest Latest Go to latest Published: Oct 22, 2019 License: Apache-2.0 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

Repository

github.com/beckbikang/owlcache

Documentation ¶

Index ¶

Variables
func BaseCacheDBInit()
func Exe(w http.ResponseWriter, r *http.Request)
func GroupExe(w http.ResponseWriter, r *http.Request)
func IndexPage(w http.ResponseWriter, r *http.Request)
func ResStatusToString(resstatus ResStatus) string
func Server(w http.ResponseWriter, r *http.Request)
type CommandType
type OwlHandler
- func NewOwlHandler() *OwlHandler
- func (owlhandler *OwlHandler) CheckAuth(r *http.Request) bool
- func (owlhandler *OwlHandler) Delete()
- func (owlhandler *OwlHandler) Exists()
- func (owlhandler *OwlHandler) Expire()
- func (owlhandler *OwlHandler) Get()
- func (owlhandler *OwlHandler) GetGroupData()
- func (owlhandler *OwlHandler) HTTPGroupDataHandle(w http.ResponseWriter, r *http.Request)
- func (owlhandler *OwlHandler) HTTPHandle(w http.ResponseWriter, r *http.Request)
- func (owlhandler *OwlHandler) Pass(r *http.Request)
- func (owlhandler *OwlHandler) Set()
- func (owlhandler *OwlHandler) TCPHandle()
- func (owlhandler *OwlHandler) Transmit(resstatus ResStatus)
type OwlRequest
- func (req *OwlRequest) HTTPReceive(w http.ResponseWriter, r *http.Request)
- func (req *OwlRequest) Slicetostring(slice []string) string
- func (req *OwlRequest) String() string
- func (req *OwlRequest) TCPReceive(connstr string)
- func (req *OwlRequest) TrimSpace(str string) string
type OwlResponse
- func (p *OwlResponse) ConvertToString(mode string) string
type OwlServerGroupHandler
- func NewOwlServerGroupHandler() *OwlServerGroupHandler
- func (owlservergrouphandler *OwlServerGroupHandler) Add()
- func (owlservergrouphandler *OwlServerGroupHandler) CheckAuth(r *http.Request) bool
- func (owlservergrouphandler *OwlServerGroupHandler) Delete()
- func (owlservergrouphandler *OwlServerGroupHandler) Get()
- func (owlservergrouphandler *OwlServerGroupHandler) GetAll()
- func (owlservergrouphandler *OwlServerGroupHandler) HTTPServerGroupHandle(w http.ResponseWriter, r *http.Request)
- func (owlservergrouphandler *OwlServerGroupHandler) HTTPServerHandle(w http.ResponseWriter, r *http.Request)
- func (owlservergrouphandler *OwlServerGroupHandler) Transmit(resstatus group.ResStatus)
type ResStatus
type ServerEntity
- func (se *ServerEntity) ServeHTTP(w http.ResponseWriter, r *http.Request)

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	ErrorKeyNotFound       = errors.New("Not found key in cache")
	ErrorKeyNotExist       = errors.New("Key does not exist")
	ErrorOpenHttpsSelected = errors.New("Configuration file Open_Https filled in error")
	ErrorCloseTcp          = errors.New("Configuration file CloseTcp filled in error")
	ErrorGroupWorkMode     = errors.New("Configuration file GroupWorkMode filled in error")
	ErrorCors              = errors.New("Configuration file Cors filled in error")
)

View Source

var BaseAuth *cache.BaseCache

创建一个全局的身份认证缓存

View Source

var BaseCacheDB *cache.BaseCache

创建一个全局的缓存DB

View Source

var HttpClient *httpclient.OwlClient

创建一个全局的HttpClient客户端

View Source

var HttpClientRequestErrorCounter *counter.Counter

创建一个全局的HttpClient错误请求控制计数器

View Source

var MemcacheClientRequestErrorCounter *counter.Counter

创建一个全局的MemcacheClient错误请求控制计数器

View Source

var RedisClientRequestErrorCounter *counter.Counter

创建一个全局的RedisClient错误请求控制计数器

View Source

var ServerGroupList *group.Servergroup

创建一个全局的服务器集群信息存储列表

Functions ¶

func BaseCacheDBInit ¶

func BaseCacheDBInit()

func Exe ¶

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

单机数据执行信息

func GroupExe ¶

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

群组数据执行信息

func IndexPage ¶

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

首页

func ResStatusToString ¶

func ResStatusToString(resstatus ResStatus) string

status to string

func Server ¶

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

设置服务器集群信息，单机

Types ¶

type CommandType ¶

type CommandType string

request command type

const (
	GET    CommandType = "get"
	SET    CommandType = "set"
	DELETE CommandType = "delete"
	PASS   CommandType = "pass"
	EXPIRE CommandType = "expire"
	EXIST  CommandType = "exist"
)

type OwlHandler ¶

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

一个请求只产生一个 OwlHandler

func NewOwlHandler ¶

func NewOwlHandler() *OwlHandler

func (*OwlHandler) CheckAuth ¶

func (owlhandler *OwlHandler) CheckAuth(r *http.Request) bool

验证权限

func (*OwlHandler) Delete ¶

func (owlhandler *OwlHandler) Delete()

func (*OwlHandler) Exists ¶

func (owlhandler *OwlHandler) Exists()

func (*OwlHandler) Expire ¶

func (owlhandler *OwlHandler) Expire()

func (*OwlHandler) Get ¶

func (owlhandler *OwlHandler) Get()

func (*OwlHandler) GetGroupData ¶

func (owlhandler *OwlHandler) GetGroupData()

发起请求获取集合数据

func (*OwlHandler) HTTPGroupDataHandle ¶

func (owlhandler *OwlHandler) HTTPGroupDataHandle(w http.ResponseWriter, r *http.Request)

http群组执行数据操作

func (*OwlHandler) HTTPHandle ¶

func (owlhandler *OwlHandler) HTTPHandle(w http.ResponseWriter, r *http.Request)

http单机执行数据操作

func (*OwlHandler) Pass ¶

func (owlhandler *OwlHandler) Pass(r *http.Request)

PASS命令验证密码

func (*OwlHandler) Set ¶

func (owlhandler *OwlHandler) Set()

func (*OwlHandler) TCPHandle ¶

func (owlhandler *OwlHandler) TCPHandle()

TCP执行数据操作

func (*OwlHandler) Transmit ¶

func (owlhandler *OwlHandler) Transmit(resstatus ResStatus)

解析response

type OwlRequest ¶

type OwlRequest struct {
	//请求命令
	Cmd CommandType
	//key
	Key string
	//请求内容
	Value interface{}
	//请求内容长度
	Length int
	//过期时间
	Expires time.Duration //int64
	//链接密码
	Pass string
	//token
	Token string
}

func (*OwlRequest) HTTPReceive ¶

func (req *OwlRequest) HTTPReceive(w http.ResponseWriter, r *http.Request)

将http请求内容解析为一个OwlRequest对象

func (*OwlRequest) Slicetostring ¶

func (req *OwlRequest) Slicetostring(slice []string) string

将字符串切片转换成字符串

func (*OwlRequest) String ¶

func (req *OwlRequest) String() string

request to string

func (*OwlRequest) TCPReceive ¶

func (req *OwlRequest) TCPReceive(connstr string)

将socket请求内容解析为一个OwlRequest对象

func (*OwlRequest) TrimSpace ¶

func (req *OwlRequest) TrimSpace(str string) string

过滤接收数据中的\r\n

type OwlResponse ¶

type OwlResponse struct {
	//请求命令
	Cmd CommandType
	//返回状态
	Status ResStatus
	//返回结果
	Results string
	//key
	Key string
	//返回内容
	Data interface{}
	//程序响应IP
	ResponseHost string
	//内容的创建时间
	KeyCreateTime time.Time
}

func (*OwlResponse) ConvertToString ¶

func (p *OwlResponse) ConvertToString(mode string) string

将数据转换成json

type OwlServerGroupHandler ¶

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

一个请求只产生一个 OwlServerGroupHandler

func NewOwlServerGroupHandler ¶

func NewOwlServerGroupHandler() *OwlServerGroupHandler

func (*OwlServerGroupHandler) Add ¶

func (owlservergrouphandler *OwlServerGroupHandler) Add()

添加一个服务器信息

func (*OwlServerGroupHandler) CheckAuth ¶

func (owlservergrouphandler *OwlServerGroupHandler) CheckAuth(r *http.Request) bool

验证权限

func (*OwlServerGroupHandler) Delete ¶

func (owlservergrouphandler *OwlServerGroupHandler) Delete()

删除一个服务器信息

func (*OwlServerGroupHandler) Get ¶

func (owlservergrouphandler *OwlServerGroupHandler) Get()

获取一个服务器信息

func (*OwlServerGroupHandler) GetAll ¶

func (owlservergrouphandler *OwlServerGroupHandler) GetAll()

获取所有服务器列表信息

func (*OwlServerGroupHandler) HTTPServerGroupHandle ¶

func (owlservergrouphandler *OwlServerGroupHandler) HTTPServerGroupHandle(w http.ResponseWriter, r *http.Request)

http服务器组执行数据操作,集群

func (*OwlServerGroupHandler) HTTPServerHandle ¶

func (owlservergrouphandler *OwlServerGroupHandler) HTTPServerHandle(w http.ResponseWriter, r *http.Request)

http服务器组执行数据操作

func (*OwlServerGroupHandler) Transmit ¶

func (owlservergrouphandler *OwlServerGroupHandler) Transmit(resstatus group.ResStatus)

解析response

type ResStatus ¶

type ResStatus int

response status type

const (
	SUCCESS         ResStatus = 200
	ERROR           ResStatus = 500
	NOT_FOUND       ResStatus = 404
	UNKNOWN_COMMAND ResStatus = 501
	NOT_PASS        ResStatus = 401
)

response 状态

type ServerEntity ¶

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

func (*ServerEntity) ServeHTTP ¶

func (se *ServerEntity) ServeHTTP(w http.ResponseWriter, r *http.Request)

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
gossip
httpclient
memcacheclient
redisclient
tcp

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL