viot

Jun 8, 2022

Changes in this version

type Client

+ Parser Parser

Jun 8, 2022

Changes in this version

type Server

+ Parser Parser

Jun 7, 2022

Changes in this version

+ type Parser interface

+ Request func([]byte) (*Request, error)

+ Response func([]byte) (*Response, error)

+ Unrequest func(*Request) ([]byte, error)

+ Unresponse func(*Response) ([]byte, error)

type Request

+ func (T *Request) Config(nonce string) (rc *RequestConfig, err error)

+ func (T *Request) Marshal() ([]byte, error)

type Response

+ func (T *Response) Config(nonce string) (rc *ResponseConfig, err error)

+ func (T *Response) Marshal() ([]byte, error)

type Server

+ TLSConfig *tls.Config

+ func (T *Server) ServeTLS(l net.Listener, certFile, keyFile string) error

+ type SetParser interface

+ SetParse func(p Parser)

Apr 17, 2022

Changes in this version

+ var ErrRespNonce = errors.New("viot: Response nonce not recognized")

Apr 11, 2022

Changes in this version

+ var ConnContextKey = &contextKey

+ var ListenerContextKey = &contextKey

Apr 9, 2022

Changes in this version

+ var SiteContextKey = &contextKey

type ServerHandlerDynamic

+ Module map[string]DynamicTemplateFunc

Feb 13, 2022

Changes in this version

type Route

+ func (T *Route) SetSiteMan(siteMan *SiteMan)

Oct 9, 2021

Changes in this version

+ var DefaultSitePool = NewSitePool()

+ var ErrHostInvalid = errors.New("Host invalid")

+ var ErrRespUnavailable = errors.New("viot: Response unavailable")

+ var ErrRwaControl = errors.New("viot: Processing the original data")

type Client

+ Host string

+ type Flusher interface

+ Flush func()

+ type LogLevel int

+ const LogDebug

+ const LogErr

+ const LogNone

+ type RawControler interface

+ RawControl func(f func(net.Conn, *bufio.Reader) error)

type Request

+ Host string

+ func NewRequest(method, url string, body interface{}) (*Request, error)

+ func NewRequestWithContext(ctx context.Context, method, urlStr string, body interface{}) (*Request, error)

type RequestConfig

+ Host string

type Response

+ func (T *Response) WriteAt(w ResponseWriter)

type ResponseConfig

+ func (T *ResponseConfig) Marshal() ([]byte, error)

type Server

+ ErrorLogLevel LogLevel

type ServerHandlerDynamic

+ Site *Site

+ type Site = vweb.Site

+ type SiteMan = vweb.SiteMan

+ type SitePool struct

+ func NewSitePool() *SitePool

+ func (T *SitePool) NewSite(name string) *Site

type TemplateDot

+ Site *Site

Jan 4, 2021

Changes in this version

type ServerHandlerDynamic

+ ReadFile func(u *url.URL, filePath string) (io.Reader, time.Time, error)

+ ReplaceParse func(name string, p []byte) []byte

+ type ServerHandlerDynamicTemplateExtend struct

+ func (T *ServerHandlerDynamicTemplateExtend) Call(f func([]reflect.Value) []reflect.Value, args ...interface{}) []interface{}

+ func (T *ServerHandlerDynamicTemplateExtend) ExecuteTemplate(out io.Writer, name string, in interface{}) error

+ func (T *ServerHandlerDynamicTemplateExtend) NewFunc(name string) (f func([]reflect.Value) []reflect.Value, err error)

Dec 13, 2020

Changes in this version

+ const DefaultLineBytes

+ var DefaultHomePool = NewHomePool()

+ var ErrAbortHandler = errors.New("Abort processing")

+ var ErrBodyNotAllowed = errors.New("The request method or status code is not allowed")

+ var ErrConnClose = errors.New("Device connection is closed")

+ var ErrDoned = errors.New("Has been completed")

+ var ErrGetBodyed = errors.New("Does not support repeated reading of body")

+ var ErrHijacked = errors.New("Connection has been hijacked")

+ var ErrHomeInvalid = errors.New("viot: Home invalid")

+ var ErrLaunched = errors.New("The connection is waiting for the response of the active request")

+ var ErrMethodInvalid = errors.New("viot: Method Invalid")

+ var ErrProtoInvalid = errors.New("viot: Proto Invalid")

+ var ErrReqUnavailable = errors.New("Request unavailable")

+ var ErrServerClosed = errors.New("Server is down")

+ var ErrURIInvalid = errors.New("viot: URI invalid")

+ var LocalAddrContextKey = &contextKey

+ var ServerContextKey = &contextKey

+ var TemplateFunc = template.FuncMap

+ func Error(w ResponseWriter, err string, code int)

+ func ExtendTemplatePackage(pkgName string, deputy template.FuncMap)

+ func Nonce() (nonce string, err error)

+ func ParseIOTVersion(vers string) (major, minor int, ok bool)

+ type Client struct

+ Addr string

+ Dialer vconnpool.Dialer

+ Home string

+ ReadDeadline time.Duration

+ WriteDeadline time.Duration

+ func (T *Client) Do(req *Request) (resp *Response, err error)

+ func (T *Client) DoCtx(ctx context.Context, req *Request) (resp *Response, err error)

+ func (T *Client) Get(url string, header Header) (resp *Response, err error)

+ func (T *Client) GetCtx(ctx context.Context, urlstr string, header Header) (resp *Response, err error)

+ func (T *Client) Post(url string, header Header, body interface{}) (resp *Response, err error)

+ func (T *Client) PostCtx(ctx context.Context, urlstr string, header Header, body interface{}) (resp *Response, err error)

+ type CloseNotifier interface

+ CloseNotify func() <-chan bool

+ type ConnState int

+ const StateActive

+ const StateClosed

+ const StateHijacked

+ const StateIdle

+ const StateNew

+ func (c ConnState) String() string

+ type DotContexter interface

+ Context func() context.Context

+ WithContext func(ctx context.Context)

+ type DynamicTemplateFunc func() DynamicTemplater

+ type DynamicTemplater interface

+ Execute func(out *bytes.Buffer, dot interface{}) error

+ Parse func(r *bufio.Reader) (err error)

+ SetPath func(rootPath, pagePath string)

+ type Globaler interface

+ Del func(key interface{})

+ Get func(key interface{}) interface{}

+ Has func(key interface{}) bool

+ Reset func()

+ Set func(key, val interface{})

+ type Handler interface

+ ServeIOT func(ResponseWriter, *Request)

+ type HandlerFunc func(ResponseWriter, *Request)

+ func (T HandlerFunc) ServeIOT(w ResponseWriter, r *Request)

+ type Header map[string]string

+ func (h Header) Clone() Header

+ func (h Header) Del(key string)

+ func (h Header) Get(key string) string

+ func (h Header) Set(key, value string)

+ type Hijacker interface

+ Hijack func() (net.Conn, *bufio.ReadWriter, error)

+ type Home struct

+ Extend interface{}

+ Global Globaler

+ RootDir func(path string) string

+ Sessions *Sessions

+ func (T *Home) PoolName() string

+ type HomeMan struct

+ func (T *HomeMan) Add(host string, home *Home)

+ func (T *HomeMan) Get(host string) (*Home, bool)

+ func (T *HomeMan) Range(f func(host string, home *Home) bool)

+ type HomePool struct

+ func NewHomePool() *HomePool

+ func (T *HomePool) Close() error

+ func (T *HomePool) DelHome(name string)

+ func (T *HomePool) NewHome(name string) *Home

+ func (T *HomePool) RangeHome(f func(name string, home *Home) bool)

+ func (T *HomePool) SetRecoverSession(d time.Duration)

+ func (T *HomePool) Start() error

+ type Launcher interface

+ Launch func() RoundTripper

+ type Request struct

+ Close bool

+ Header Header

+ Home string

+ Method string

+ Proto string

+ ProtoMajor int

+ ProtoMinor int

+ RemoteAddr string

+ RequestURI string

+ TLS *tls.ConnectionState

+ URL *url.URL

+ func ReadRequest(b io.Reader) (req *Request, err error)

+ func (T *Request) Context() context.Context

+ func (T *Request) GetBasicAuth() (username, password string, ok bool)

+ func (T *Request) GetBody(i interface{}) error

+ func (T *Request) GetNonce() string

+ func (T *Request) GetTokenAuth() (token string, ok bool)

+ func (T *Request) ProtoAtLeast(major, minor int) bool

+ func (T *Request) RequestConfig(nonce string) (riot *RequestConfig, err error)

+ func (T *Request) SetBasicAuth(username, password string)

+ func (T *Request) SetBody(i interface{}) error

+ func (T *Request) SetTokenAuth(token string)

+ func (T *Request) WithContext(ctx context.Context) *Request

+ type RequestConfig struct

+ Header Header

+ Home string

+ Method string

+ Nonce string

+ Path string

+ Proto string

+ func (T *RequestConfig) GetBody() interface{}

+ func (T *RequestConfig) Marshal() ([]byte, error)

+ func (T *RequestConfig) SetBody(i interface{})

+ func (T *RequestConfig) Unmarshal(data []byte) error

+ type Response struct

+ Body interface{}

+ Close bool

+ Header Header

+ RemoteAddr string

+ Request *Request

+ Status int

+ func ReadResponse(r *bufio.Reader, req *Request) (res *Response, err error)

+ func (T *Response) ResponseConfig(nonce string) (riot *ResponseConfig, err error)

+ func (T *Response) SetNonce(n string)

+ func (T *Response) Write(w io.Writer) error

+ func (T *Response) WriteTo(w ResponseWriter)

+ type ResponseConfig struct

+ Body interface{}

+ Header Header

+ Nonce string

+ Status int

+ type ResponseWriter interface

+ Header func() Header

+ SetBody func(interface{}) error

+ Status func(int)

+ type RoundTripper interface

+ RoundTrip func(*Request) (*Response, error)

+ RoundTripContext func(ctx context.Context, req *Request) (resp *Response, err error)

+ type Route struct

+ HandlerError func(w ResponseWriter, r *Request)

+ func (T *Route) HandleFunc(url string, handler func(w ResponseWriter, r *Request))

+ func (T *Route) ServeIOT(w ResponseWriter, r *Request)

+ type Server struct

+ Addr string

+ BaseContext func(net.Listener) context.Context

+ ConnContext func(context.Context, net.Conn) (context.Context, net.Conn, error)

+ ConnState func(net.Conn, ConnState)

+ ErrorLog *log.Logger

+ Handler Handler

+ HandlerRequest func(b io.Reader) (req *Request, err error)

+ HandlerResponse func(b io.Reader) (res *Response, err error)

+ IdleTimeout time.Duration

+ MaxLineBytes int

+ ReadTimeout time.Duration

+ TLSNextProto map[string]func(*Server, *tls.Conn, Handler)

+ WriteTimeout time.Duration

+ func (T *Server) Close() error

+ func (T *Server) ListenAndServe() error

+ func (T *Server) RegisterOnShutdown(f func())

+ func (T *Server) Serve(l net.Listener) error

+ func (T *Server) SetKeepAlivesEnabled(v bool)

+ func (T *Server) Shutdown(ctx context.Context) error

+ type ServerHandlerDynamic struct

+ Context context.Context

+ HandlerError func(w ResponseWriter, r *Request, err error)

+ Home *Home

+ PagePath string

+ Plus map[string]DynamicTemplateFunc

+ RootPath string

+ func (T *ServerHandlerDynamic) Execute(bufw *bytes.Buffer, dock interface{}) (err error)

+ func (T *ServerHandlerDynamic) Parse(bufr *bytes.Buffer) (err error)

+ func (T *ServerHandlerDynamic) ParseFile(path string) error

+ func (T *ServerHandlerDynamic) ParseText(content, name string) error

+ func (T *ServerHandlerDynamic) ServeIOT(rw ResponseWriter, req *Request)

+ type Session struct

+ func (T *Session) Defer(call interface{}, args ...interface{}) error

+ func (T *Session) Free()

+ func (T *Session) Token() string

+ type Sessioner interface

+ Defer func(call interface{}, args ...interface{}) error

+ Del func(key interface{})

+ Free func()

+ Get func(key interface{}) interface{}

+ GetHas func(key interface{}) (val interface{}, ok bool)

+ Has func(key interface{}) bool

+ Reset func()

+ Set func(key, val interface{})

+ SetExpired func(key interface{}, d time.Duration)

+ SetExpiredCall func(key interface{}, d time.Duration, f func(interface{}))

+ Token func() string

+ type Sessions struct

+ Expired time.Duration

+ func (T *Sessions) DelSession(token string)

+ func (T *Sessions) GetSession(token string) (Sessioner, bool)

+ func (T *Sessions) Len() int

+ func (T *Sessions) ProcessDeadAll() []interface{}

+ func (T *Sessions) SetSession(token string, s Sessioner) Sessioner

+ type TemplateDot struct

+ Home *Home

+ R *Request

+ W ResponseWriter

+ Writed bool

+ func (T *TemplateDot) Context() context.Context

+ func (T *TemplateDot) Defer(call interface{}, args ...interface{}) error

+ func (T *TemplateDot) Free()

+ func (T *TemplateDot) Global() Globaler

+ func (T *TemplateDot) Header() Header

+ func (T *TemplateDot) Hijack() (net.Conn, *bufio.ReadWriter, error)

+ func (T *TemplateDot) Launch() RoundTripper

+ func (T *TemplateDot) Request() *Request

+ func (T *TemplateDot) ResponseWriter() ResponseWriter

+ func (T *TemplateDot) RootDir(upath string) string

+ func (T *TemplateDot) Session(token string) Sessioner

+ func (T *TemplateDot) Swap() *vmap.Map

+ func (T *TemplateDot) WithContext(ctx context.Context)

+ type TemplateDoter interface

+ Defer func(call interface{}, args ...interface{}) error

+ Global func() Globaler

+ Header func() Header

+ Hijack func() (net.Conn, *bufio.ReadWriter, error)

+ Launch func() RoundTripper

+ Request func() *Request

+ ResponseWriter func() ResponseWriter

+ RootDir func(path string) string

+ Session func(token string) Sessioner

+ Swap func() *vmap.Map