utils

Documentation

Index

• func HTTPResponse(req *restful.Request, rsp *restful.Response, code uint32)
• func InitProtoCache(option map[string]interface{}, cacheTypes []string, ...)
• func ParseJsonBody(req *restful.Request, value interface{}) error
• func ParseQueryParams(req *restful.Request) map[string]string
• type Cache
  • func NewCache(options map[string]interface{}, cacheType []string) (Cache, error)
• type CacheObject
  • func (c *CacheObject) GetBuf() []byte
  • func (c *CacheObject) Marshal(m proto.Message) error
• type Handler
  • func (h *Handler) Parse(message proto.Message) (context.Context, error)
  • func (h *Handler) ParseArray(createMessage func() proto.Message) (context.Context, error)
  • func (h *Handler) ParseArrayByText(createMessage func() proto.Message, text string) (context.Context, error)
  • func (h *Handler) ParseFile() ([]*apiconfig.ConfigFile, error)
  • func (h *Handler) ParseHeaderContext() context.Context
  • func (h *Handler) WriteHeader(polarisCode uint32, httpStatus int)
  • func (h *Handler) WriteHeaderAndProto(obj api.ResponseMessage)
  • func (h *Handler) WriteHeaderAndProtoV2(obj api.ResponseMessageV2)
• type MessageToCache

Functions

func HTTPResponse

func HTTPResponse(req *restful.Request, rsp *restful.Response, code uint32)

HTTPResponse http答复简单封装

func InitProtoCache

func InitProtoCache(option map[string]interface{}, cacheTypes []string, discoverCacheConvert MessageToCache)

func ParseJsonBody

func ParseJsonBody(req *restful.Request, value interface{}) error

ParseJsonBody parse http body as json object

func ParseQueryParams

func ParseQueryParams(req *restful.Request) map[string]string

ParseQueryParams 解析并获取HTTP的query params

Types

type Cache

type Cache interface {
	// Get
	Get(cacheType string, key string) *CacheObject
	// Put
	Put(v *CacheObject) (*CacheObject, bool)
}

Cache

func NewCache

func NewCache(options map[string]interface{}, cacheType []string) (Cache, error)

NewCache Component a PB cache pool

type CacheObject

type CacheObject struct {
	OriginVal proto.Message

	CacheType string

	Key string
	// contains filtered or unexported fields
}

func (*CacheObject) GetBuf

func (c *CacheObject) GetBuf() []byte

func (*CacheObject) Marshal

func (c *CacheObject) Marshal(m proto.Message) error

type Handler

type Handler struct {
	Request  *restful.Request
	Response *restful.Response
}

Handler HTTP请求/回复处理器

func (*Handler) Parse

func (h *Handler) Parse(message proto.Message) (context.Context, error)

Parse 解析请求

func (*Handler) ParseArray

func (h *Handler) ParseArray(createMessage func() proto.Message) (context.Context, error)

ParseArray 解析PB数组对象

func (*Handler) ParseArrayByText

func (h *Handler) ParseArrayByText(createMessage func() proto.Message, text string) (context.Context, error)

ParseArrayByText 通过字符串解析PB数组对象

func (*Handler) ParseFile

func (h *Handler) ParseFile() ([]*apiconfig.ConfigFile, error)

ParseFile 解析上传的配置文件

func (*Handler) ParseHeaderContext

func (h *Handler) ParseHeaderContext() context.Context

ParseHeaderContext 将http请求header中携带的用户信息提取出来

func (*Handler) WriteHeader

func (h *Handler) WriteHeader(polarisCode uint32, httpStatus int)

WriteHeader 仅返回Code

func (*Handler) WriteHeaderAndProto

func (h *Handler) WriteHeaderAndProto(obj api.ResponseMessage)

WriteHeaderAndProto 返回Code和Proto

func (*Handler) WriteHeaderAndProtoV2

func (h *Handler) WriteHeaderAndProtoV2(obj api.ResponseMessageV2)

WriteHeaderAndProtoV2 返回Code和Proto

type MessageToCache

type MessageToCache func(m interface{}) *CacheObject

MessageToCache