part

Documentation

Index

• Variables
• func IsMethod(r *http.Request, method ...string) bool
• func MethodFiliter(w http.ResponseWriter, r *http.Request, method ...string) (pass bool)
• func NewLimitItem(max int) *limitItem
• func NotModified(r *http.Request, w http.ResponseWriter, modTime time.Time) (notMod bool)
• func NotModifiedDur(r *http.Request, w http.ResponseWriter, modDur time.Duration) (notMod bool)
• func WithBr(w http.ResponseWriter, r *http.Request) (wf io.Writer, close func() error)
• func WithDeflate(w http.ResponseWriter, r *http.Request) (wf io.Writer, close func() error)
• func WithEncoding(w http.ResponseWriter, r *http.Request) (wf io.Writer, close func() error)
• func WithFlush(w http.ResponseWriter) http.ResponseWriter
• func WithGzip(w http.ResponseWriter, r *http.Request) (wf io.Writer, close func() error)
• func WithStatusCode(w http.ResponseWriter, code int)
• func WithZstd(w http.ResponseWriter, r *http.Request) (wf io.Writer, close func() error)
• type Cache
  • func (t *Cache) Cache(key string, aliveDur time.Duration, w http.ResponseWriter) http.ResponseWriter
  • func (t *Cache) IsCache(key string) (data *[]byte, isCache bool)
• type Exprier
  • func NewExprier(max int) *Exprier
  • func (t *Exprier) Check(key string) (time.Time, error)
  • func (t *Exprier) Disable()
  • func (t *Exprier) Drop(key string)
  • func (t *Exprier) Len() int
  • func (t *Exprier) LoopCheck(ctx context.Context, key string, whenfail func(key string, e error)) (e error)
  • func (t *Exprier) Reg(dur time.Duration, reNewKey ...string) (string, error)
  • func (t *Exprier) SetMax(max int)
• type Handler
  • func NewHandler(dealF func(path string) (func(w http.ResponseWriter, r *http.Request), bool)) *Handler
  • func (t *Handler) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type Limits
  • func (t *Limits) AddCount(r *http.Request) (isOverflow bool)
  • func (t *Limits) AddLimitItem(item *limitItem)
  • func (t *Limits) ReachMax(r *http.Request) (isOverflow bool)
• type Web
  • func Easy_boot() *Web
  • func New(conf *http.Server) (o *Web)
  • func (t *Web) Handle(path_func map[string]func(http.ResponseWriter, *http.Request))
  • func (t *Web) Shutdown(ctx ...context.Context)
• type WebPath
  • func (t *WebPath) Delete(path string) (deleteMe bool)
  • func (t *WebPath) GetConn(r *http.Request) net.Conn
  • func (t *WebPath) Load(path string) (func(w http.ResponseWriter, r *http.Request), bool)
  • func (t *WebPath) LoadOnePerfix(path string) (f func(w http.ResponseWriter, r *http.Request), ok bool)
  • func (t *WebPath) LoadPerfix(path string) (f func(w http.ResponseWriter, r *http.Request), ok bool)
  • func (t *WebPath) Reset()
  • func (t *WebPath) Store(path string, f func(w http.ResponseWriter, r *http.Request))
  • func (t *WebPath) StoreIfNotExist(path string, f func(w http.ResponseWriter, r *http.Request))
• type WebSync
  • func NewSyncMap(conf *http.Server, m *WebPath, ...) (o *WebSync)
  • func NewSyncMapNoPanic(conf *http.Server, m *WebPath, ...) (o *WebSync, err error)
  • func (t *WebSync) Shutdown(ctx ...context.Context)
• type WithCacheWiter
  • func WithCache(w http.ResponseWriter, maxWait uint32) *WithCacheWiter
  • func (t *WithCacheWiter) Header() http.Header
  • func (t *WithCacheWiter) Write(b []byte) (i int, e error)
  • func (t *WithCacheWiter) WriteHeader(i int)

Variables

var (
	ErrExpried = errors.New("ErrExpried")
	ErrNoFound = errors.New("ErrNoFound")
)

Functions

func IsMethod

func IsMethod(r *http.Request, method ...string) bool

func MethodFiliter

func MethodFiliter(w http.ResponseWriter, r *http.Request, method ...string) (pass bool)

func NewLimitItem

func NewLimitItem(max int) *limitItem

func NotModified

func NotModified(r *http.Request, w http.ResponseWriter, modTime time.Time) (notMod bool)

当请求时间戳与modTime相同时，返回304，true

func NotModifiedDur

func NotModifiedDur(r *http.Request, w http.ResponseWriter, modDur time.Duration) (notMod bool)

当请求时间戳在modDur之内时，返回304，true

func WithBr

func WithBr(w http.ResponseWriter, r *http.Request) (wf io.Writer, close func() error)

func WithDeflate

func WithDeflate(w http.ResponseWriter, r *http.Request) (wf io.Writer, close func() error)

func WithEncoding

func WithEncoding(w http.ResponseWriter, r *http.Request) (wf io.Writer, close func() error)

func WithFlush

func WithFlush(w http.ResponseWriter) http.ResponseWriter

func WithGzip

func WithGzip(w http.ResponseWriter, r *http.Request) (wf io.Writer, close func() error)

func WithStatusCode

func WithStatusCode(w http.ResponseWriter, code int)

func WithZstd

func WithZstd(w http.ResponseWriter, r *http.Request) (wf io.Writer, close func() error)

Types

type Cache

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

Deprecated: use NotModifiedDur

func (*Cache) Cache

func (t *Cache) Cache(key string, aliveDur time.Duration, w http.ResponseWriter) http.ResponseWriter

Deprecated: use NotModifiedDur

func (*Cache) IsCache

func (t *Cache) IsCache(key string) (data *[]byte, isCache bool)

Deprecated: use NotModifiedDur

type Exprier

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

func NewExprier

func NewExprier(max int) *Exprier

func (*Exprier) Check

func (t *Exprier) Check(key string) (time.Time, error)

func (*Exprier) Disable

func (t *Exprier) Disable()

func (*Exprier) Drop

func (t *Exprier) Drop(key string)

func (*Exprier) Len

func (t *Exprier) Len() int

func (*Exprier) LoopCheck

func (t *Exprier) LoopCheck(ctx context.Context, key string, whenfail func(key string, e error)) (e error)

func (*Exprier) Reg

func (t *Exprier) Reg(dur time.Duration, reNewKey ...string) (string, error)

func (*Exprier) SetMax

func (t *Exprier) SetMax(max int)

type Handler

type Handler struct {
	DealF func(path string) (func(w http.ResponseWriter, r *http.Request), bool)
}

func NewHandler

func NewHandler(dealF func(path string) (func(w http.ResponseWriter, r *http.Request), bool)) *Handler

func (*Handler) ServeHTTP

func (t *Handler) ServeHTTP(w http.ResponseWriter, r *http.Request)

type Limits

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

func (*Limits) AddCount

func (t *Limits) AddCount(r *http.Request) (isOverflow bool)

func (*Limits) AddLimitItem

func (t *Limits) AddLimitItem(item *limitItem)

func (*Limits) ReachMax

func (t *Limits) ReachMax(r *http.Request) (isOverflow bool)

Deprecated: 反直觉的方法

type Web

type Web struct {
	Server *http.Server
}

func Easy_boot

func Easy_boot() *Web

func New

func New(conf *http.Server) (o *Web)

func (*Web) Handle

func (t *Web) Handle(path_func map[string]func(http.ResponseWriter, *http.Request))

func (*Web) Shutdown

func (t *Web) Shutdown(ctx ...context.Context)

type WebPath

type WebPath struct {
	Path string `json:"path"`

	PerSame *WebPath `json:"-"`
	Per     *WebPath `json:"-"`
	Same    *WebPath `json:"same"`
	Next    *WebPath `json:"next"`
	// contains filtered or unexported fields
}

func (*WebPath) Delete

func (t *WebPath) Delete(path string) (deleteMe bool)

func (*WebPath) GetConn

func (t *WebPath) GetConn(r *http.Request) net.Conn

WebSync

func (*WebPath) Load

func (t *WebPath) Load(path string) (func(w http.ResponseWriter, r *http.Request), bool)

O /../../1 => /../../1

X /../../1 => /../../

X /../../1 => /../

func (*WebPath) LoadOnePerfix

func (t *WebPath) LoadOnePerfix(path string) (f func(w http.ResponseWriter, r *http.Request), ok bool)

O /../../1 => /../../1

O /../../1 => /../../

X /../../1 => /../

func (*WebPath) LoadPerfix

func (t *WebPath) LoadPerfix(path string) (f func(w http.ResponseWriter, r *http.Request), ok bool)

O /../../1 => /../../1

O /../../1 => /../../

O /../../1 => /../

func (*WebPath) Reset

func (t *WebPath) Reset()

WebSync

func (*WebPath) Store

func (t *WebPath) Store(path string, f func(w http.ResponseWriter, r *http.Request))

func (*WebPath) StoreIfNotExist

func (t *WebPath) StoreIfNotExist(path string, f func(w http.ResponseWriter, r *http.Request))

type WebSync

type WebSync struct {
	Server *http.Server
	// contains filtered or unexported fields
}

func NewSyncMap

func NewSyncMap(conf *http.Server, m *WebPath, matchFunc ...func(path string) (func(w http.ResponseWriter, r *http.Request), bool)) (o *WebSync)

func NewSyncMapNoPanic

func NewSyncMapNoPanic(conf *http.Server, m *WebPath, matchFunc ...func(path string) (func(w http.ResponseWriter, r *http.Request), bool)) (o *WebSync, err error)

matchFunc: WebPath.Load WebPath.LoadOnePerfix WebPath.LoadPerfix

func (*WebSync) Shutdown

func (t *WebSync) Shutdown(ctx ...context.Context)

type WithCacheWiter

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

func WithCache

func WithCache(w http.ResponseWriter, maxWait uint32) *WithCacheWiter

func (*WithCacheWiter) Header

func (t *WithCacheWiter) Header() http.Header

func (*WithCacheWiter) Write

func (t *WithCacheWiter) Write(b []byte) (i int, e error)

func (*WithCacheWiter) WriteHeader

func (t *WithCacheWiter) WriteHeader(i int)