http

Mar 7, 2025

Changes in this version

type DefaultHTTPHandlerTask

+ func (h *DefaultHTTPHandlerTask) SSEMode(ctx channel.HandlerContext, req *Request, resp *Response, ...) SSEOperation

+ type DefaultSSEOperation struct

+ func (h *DefaultSSEOperation) WriteHeader(ctx channel.HandlerContext, header http.Header, params map[string]any) channel.Future

+ func (h *DefaultSSEOperation) WriteMessage(ctx channel.HandlerContext, message SSEMessage, params map[string]any) channel.Future

+ func (h *DefaultSSEOperation) WriteMessages(ctx channel.HandlerContext, messages []SSEMessage, params map[string]any) channel.Future

+ type SSEMessage struct

+ Comment string

+ Data []string

+ Event string

+ Id string

+ Retry int

+ func (m SSEMessage) Validate() bool

+ type SSEMessages []SSEMessage

+ type SSEOperation interface

+ WriteHeader func(ctx channel.HandlerContext, header http.Header, params map[string]any) channel.Future

+ WriteMessage func(ctx channel.HandlerContext, message SSEMessage, params map[string]any) channel.Future

+ WriteMessages func(ctx channel.HandlerContext, messages []SSEMessage, params map[string]any) channel.Future

Aug 9, 2023

Changes in this version

type ReadRequestLogStruct

+ URI string

Jun 11, 2023

Changes in this version

type SimpleRoute

+ func (r *SimpleRoute) SetGroup(path string, acceptances ...Acceptance) *SimpleRoute

Jun 11, 2023

Changes in this version

type DefaultRoute

+ func (r *DefaultRoute) RouteNode(path string) (node RouteNode, nodeParams map[string]any, isLast bool)

type Route

+ RouteNode func(path string) (node RouteNode, nodeParams map[string]any, isLast bool)

+ type SimpleRoute struct

+ func NewSimpleRoute() *SimpleRoute

+ func (r *SimpleRoute) FindNode(path string) RouteNode

+ func (r *SimpleRoute) RouteNode(path string) (node RouteNode, parameters map[string]any, isLast bool)

+ func (r *SimpleRoute) SetEndpoint(path string, handler HandlerTask, acceptances ...Acceptance) *SimpleRoute

+ func (r *SimpleRoute) SetRoot(handler HandlerTask) *SimpleRoute

+ func (r *SimpleRoute) String() string

Jun 9, 2023

Changes in this version

type DefaultHTTPHandlerTask

+ func (h *DefaultHTTPHandlerTask) Create(ctx channel.HandlerContext, req *Request, resp *Response, ...) ErrorResponse

type HttpTask

+ Create func(ctx channel.HandlerContext, req *Request, resp *Response, ...) ErrorResponse

Jun 7, 2023

Changes in this version

+ const ParamMaxBodyBytes

+ type TaskHelper struct

+ func (h *TaskHelper) GetID(name string, params map[string]any) string

+ func (h *TaskHelper) GetNode(params map[string]any) RouteNode

+ func (h *TaskHelper) GetNodeName(params map[string]any) string

+ func (h *TaskHelper) IsIndex(params map[string]any) bool

+ func (h *TaskHelper) LogExtend(key string, value any, params map[string]any)

Jun 1, 2023

Changes in this version

+ const LogHandlerDefaultMaxBodySize

type LogHandler

+ MaxBodySize int

Jun 1, 2023

Changes in this version

type Acceptance

+ SkipMethodOptions func() bool

type DispatchAcceptance

+ func (a *DispatchAcceptance) SkipMethodOptions() bool

Nov 16, 2021

Changes in this version

type Response

+ func (r *Response) DoneFuture() channel.Future

Sep 1, 2021

Changes in this version

type DefaultHTTPHandlerTask

+ func (h *DefaultHTTPHandlerTask) CORSHelper(req *Request, resp *Response, params map[string]interface{})

type HttpHandlerTask

+ CORSHelper func(req *Request, resp *Response, params map[string]interface{})

Aug 31, 2021

Changes in this version

+ const ConnChCtx

+ const ConnCtx

+ const MaxMultiPartMemory

+ var AcceptanceInterrupt = &DefaultAcceptanceInterrupt

+ var DefaultSessionType = SessionTypeMemory

+ var NotImplemented = erresponse.NotImplemented

+ var ParamAcceptWaitCount channel.ParamKey = "accept_wait_count"

+ var ParamIdleTimeout channel.ParamKey = "idle_timeout"

+ var ParamMaxHeaderBytes channel.ParamKey = "max_header_bytes"

+ var ParamMaxMultiPartMemory channel.ParamKey = "max_multi_part_memory"

+ var ParamReadHeaderTimeout channel.ParamKey = "read_header_timeout"

+ var ParamReadTimeout channel.ParamKey = "read_timeout"

+ var ParamWriteTimeout channel.ParamKey = "write_timeout"

+ var SessionDomain = ""

+ var SessionExpireTime = 86400

+ var SessionHttpOnly = false

+ var SessionKey = "KKLAB"

+ var SessionSecure = false

+ func DefaultProvider() httpsession.SessionProvider

+ func GetSession(req *Request) httpsession.Session

+ func NewEndPoint(name string, task HandlerTask, acceptances []Acceptance) *_EndPoint

+ func NewGroup(name string, acceptances []Acceptance) *_RouteGroup

+ type Acceptance interface

+ Do func(req *Request, resp *Response, params map[string]interface{}) error

+ type Channel struct

+ func (c *Channel) UnsafeIsAutoRead() bool

+ func (c *Channel) UnsafeRead() (interface{}, error)

+ func (c *Channel) UnsafeWrite(obj interface{}) error

+ type DefaultAcceptanceInterrupt struct

+ func (DefaultAcceptanceInterrupt) Error() string

+ type DefaultHTTPHandlerTask struct

+ func (h *DefaultHTTPHandlerTask) After(req *Request, resp *Response, params map[string]interface{}) ErrorResponse

+ func (h *DefaultHTTPHandlerTask) Before(req *Request, resp *Response, params map[string]interface{}) ErrorResponse

+ func (h *DefaultHTTPHandlerTask) Connect(ctx channel.HandlerContext, req *Request, resp *Response, ...) ErrorResponse

+ func (h *DefaultHTTPHandlerTask) Delete(ctx channel.HandlerContext, req *Request, resp *Response, ...) ErrorResponse

+ func (h *DefaultHTTPHandlerTask) ErrorCaught(req *Request, resp *Response, params map[string]interface{}, err ErrorResponse) error

+ func (h *DefaultHTTPHandlerTask) Get(ctx channel.HandlerContext, req *Request, resp *Response, ...) ErrorResponse

+ func (h *DefaultHTTPHandlerTask) Index(ctx channel.HandlerContext, req *Request, resp *Response, ...) ErrorResponse

+ func (h *DefaultHTTPHandlerTask) Options(ctx channel.HandlerContext, req *Request, resp *Response, ...) ErrorResponse

+ func (h *DefaultHTTPHandlerTask) Patch(ctx channel.HandlerContext, req *Request, resp *Response, ...) ErrorResponse

+ func (h *DefaultHTTPHandlerTask) Post(ctx channel.HandlerContext, req *Request, resp *Response, ...) ErrorResponse

+ func (h *DefaultHTTPHandlerTask) PreCheck(req *Request, resp *Response, params map[string]interface{}) ErrorResponse

+ func (h *DefaultHTTPHandlerTask) Put(ctx channel.HandlerContext, req *Request, resp *Response, ...) ErrorResponse

+ func (h *DefaultHTTPHandlerTask) ThrowErrorResponse(err ErrorResponse)

+ func (h *DefaultHTTPHandlerTask) Trace(ctx channel.HandlerContext, req *Request, resp *Response, ...) ErrorResponse

+ type DefaultHandlerTask struct

+ func NewDefaultHandlerTask() *DefaultHandlerTask

+ func (h *DefaultHandlerTask) GetID(name string, params map[string]interface{}) string

+ func (h *DefaultHandlerTask) GetNodeName(params map[string]interface{}) string

+ func (h *DefaultHandlerTask) IsIndex(params map[string]interface{}) bool

+ func (h *DefaultHandlerTask) LogExtend(key string, value interface{}, params map[string]interface{})

+ type DefaultRoute struct

+ func NewRoute() *DefaultRoute

+ func (r *DefaultRoute) AddEndPoint(point *_EndPoint) *DefaultRoute

+ func (r *DefaultRoute) AddGroup(group *_RouteGroup) *DefaultRoute

+ func (r *DefaultRoute) AddRecursivePoint(point *_EndPoint) *DefaultRoute

+ func (r *DefaultRoute) RouteEndPoint(req *Request) (node RouteNode, nodeParams map[string]interface{}, isLast bool)

+ func (r *DefaultRoute) SetRoot(point *_EndPoint) *DefaultRoute

+ type DispatchAcceptance struct

+ func (a *DispatchAcceptance) Do(req *Request, resp *Response, params map[string]interface{}) error

+ func (a *DispatchAcceptance) GetID(name string, params map[string]interface{}) string

+ func (a *DispatchAcceptance) GetNodeName(params map[string]interface{}) string

+ func (a *DispatchAcceptance) IsIndex(params map[string]interface{}) string

+ func (a *DispatchAcceptance) LogExtend(key string, value interface{}, params map[string]interface{})

+ type DispatchHandler struct

+ DefaultStatusCode int

+ DefaultStatusResponse map[int]func(req *Request, resp *Response, params map[string]interface{})

+ func NewDispatchHandler(route Route) *DispatchHandler

+ func (h *DispatchHandler) ErrorCaught(ctx channel.HandlerContext, err error)

+ func (h *DispatchHandler) Read(ctx channel.HandlerContext, obj interface{})

+ type ErrorResponse interface

+ type ErrorResponseImpl struct

+ Caught *kkpanic.CaughtImpl

+ func (e *ErrorResponseImpl) String() string

+ type GZipHandler struct

+ CompressThreshold int

+ func (h *GZipHandler) Added(ctx channel.HandlerContext)

+ func (h *GZipHandler) Write(ctx channel.HandlerContext, obj interface{}, future channel.Future)

+ type HandlerTask interface

+ GetID func(name string, params map[string]interface{}) string

+ GetNodeName func(params map[string]interface{}) string

+ type HttpHandlerTask interface

+ After func(req *Request, resp *Response, params map[string]interface{}) ErrorResponse

+ Before func(req *Request, resp *Response, params map[string]interface{}) ErrorResponse

+ ErrorCaught func(req *Request, resp *Response, params map[string]interface{}, err ErrorResponse) error

+ PreCheck func(req *Request, resp *Response, params map[string]interface{}) ErrorResponse

+ type HttpTask interface

+ Connect func(ctx channel.HandlerContext, req *Request, resp *Response, ...) ErrorResponse

+ Delete func(ctx channel.HandlerContext, req *Request, resp *Response, ...) ErrorResponse

+ Get func(ctx channel.HandlerContext, req *Request, resp *Response, ...) ErrorResponse

+ Index func(ctx channel.HandlerContext, req *Request, resp *Response, ...) ErrorResponse

+ Options func(ctx channel.HandlerContext, req *Request, resp *Response, ...) ErrorResponse

+ Patch func(ctx channel.HandlerContext, req *Request, resp *Response, ...) ErrorResponse

+ Post func(ctx channel.HandlerContext, req *Request, resp *Response, ...) ErrorResponse

+ Put func(ctx channel.HandlerContext, req *Request, resp *Response, ...) ErrorResponse

+ Trace func(ctx channel.HandlerContext, req *Request, resp *Response, ...) ErrorResponse

+ type LanguageValue struct

+ Factor float32

+ Value language.Tag

+ type LogHandler struct

+ FilterFunc func(req *Request, resp *Response, params map[string]interface{}) bool

+ func NewLogHandler(printBody bool) *LogHandler

+ func (h *LogHandler) Read(ctx channel.HandlerContext, obj interface{})

+ func (h *LogHandler) Write(ctx channel.HandlerContext, obj interface{}, future channel.Future)

+ type LogStruct struct

+ AcceptTime int64

+ ChannelID string

+ CompressTime int64

+ Extend interface{}

+ HAcceptanceTime int64

+ HErrorTime int64

+ HLocateTime int64

+ HandlerTime int64

+ Method string

+ ProcessTime int64

+ RemoteAddr string

+ RemoteAddrs string

+ Request *RequestLogStruct

+ Response *ResponseLogStruct

+ StatusCode int

+ TrackID string

+ URI string

+ type ObjectLogStruct struct

+ ChannelID string

+ Handler string

+ Message interface{}

+ RemoteAddr string

+ State string

+ TrackID string

+ URI string

+ type Pack struct

+ Params map[string]interface{}

+ Request *Request

+ Response *Response

+ RouteNode RouteNode

+ Writer ResponseWriter

+ type QualityValue struct

+ Factor float32

+ Value string

+ type ReadRequestLogStruct struct

+ ChannelID string

+ RemoteAddr string

+ RemoteAddrs string

+ Request *RequestLogStruct

+ TrackID string

+ type Request struct

+ func WrapRequest(ch channel.Channel, req *http.Request) *Request

+ func (r *Request) Accept() []QualityValue

+ func (r *Request) AcceptCharset() []QualityValue

+ func (r *Request) AcceptEncoding() []QualityValue

+ func (r *Request) AcceptLanguage() []LanguageValue

+ func (r *Request) AddCookie(c *http.Cookie)

+ func (r *Request) Body() buf.ByteBuf

+ func (r *Request) Channel() channel.Channel

+ func (r *Request) ContentLength() int64

+ func (r *Request) Cookie(name string) (*http.Cookie, error)

+ func (r *Request) Cookies() []*http.Cookie

+ func (r *Request) CreatedAt() *time.Time

+ func (r *Request) FormFile(key string) (multipart.File, *multipart.FileHeader, error)

+ func (r *Request) FormValue(key string) string

+ func (r *Request) Header() http.Header

+ func (r *Request) Host() string

+ func (r *Request) Method() string

+ func (r *Request) Origin() string

+ func (r *Request) PreferLang() *language.Tag

+ func (r *Request) Proto() string

+ func (r *Request) Referer() string

+ func (r *Request) RemoteAddr() (ip net.IP, port string)

+ func (r *Request) RemoteAddrs() []string

+ func (r *Request) RemoteIP() (ip net.IP)

+ func (r *Request) RenewSession()

+ func (r *Request) Request() *http.Request

+ func (r *Request) RequestURI() string

+ func (r *Request) Session() httpsession.Session

+ func (r *Request) TE() []QualityValue

+ func (r *Request) TrackID() string

+ func (r *Request) Url() *url.URL

+ func (r *Request) UserAgent() string

+ type RequestLogStruct struct

+ Body string

+ BodyLength int

+ HOST string

+ Headers map[string]interface{}

+ Method string

+ URI string

+ type Response struct

+ func EmptyResponse() *Response

+ func NewResponse(request *Request) *Response

+ func WrapResponse(ch channel.NetChannel, response *http.Response) *Response

+ func (r *Response) AddHeader(name string, value string) *Response

+ func (r *Response) Body() []byte

+ func (r *Response) Cookie(name string) *http.Cookie

+ func (r *Response) Cookies() map[string][]http.Cookie

+ func (r *Response) DelHeader(name string) *Response

+ func (r *Response) GetHeader(name string) string

+ func (r *Response) Header() http.Header

+ func (r *Response) JsonResponse(obj interface{})

+ func (r *Response) Redirect(redirectUrl string)

+ func (r *Response) Request() *Request

+ func (r *Response) ResponseError(er ErrorResponse)

+ func (r *Response) SetBody(buf buf.ByteBuf)

+ func (r *Response) SetContentType(ct string)

+ func (r *Response) SetCookie(cookie *http.Cookie) *Response

+ func (r *Response) SetHeader(name string, value string) *Response

+ func (r *Response) SetStatusCode(statusCode int) *Response

+ func (r *Response) StatusCode() int

+ func (r *Response) TextResponse(buf buf.ByteBuf)

+ type ResponseLogStruct struct

+ Body string

+ Headers map[string]interface{}

+ OutBodyLength int

+ PreCompressLength int

+ StatusCode int

+ URI string

+ type ResponseWriter interface

+ type ReturnCatch struct

+ type Route interface

+ RouteEndPoint func(req *Request) (node RouteNode, nodeParams map[string]interface{}, isLast bool)

+ type RouteNode interface

+ Acceptances func() []Acceptance

+ AggregatedAcceptances func() []Acceptance

+ HandlerTask func() HandlerTask

+ Name func() string

+ Parent func() RouteNode

+ Resources func() map[string]RouteNode

+ RouteType func() RouteType

+ type RouteType int

+ const RouteTypeEndPoint

+ const RouteTypeGroup

+ const RouteTypeRecursiveEndPoint

+ const RouteTypeRootEndPoint

+ type ServerChannel struct

+ func (c *ServerChannel) IsActive() bool

+ func (c *ServerChannel) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ func (c *ServerChannel) UnsafeAccept() (channel.Channel, channel.Future)

+ func (c *ServerChannel) UnsafeBind(localAddr net.Addr) error

+ func (c *ServerChannel) UnsafeClose() error

+ type SessionType string

+ const SessionTypeMemory

+ const SessionTypeRedis

+ type StaticFilesHandlerTask struct

+ DoCache bool

+ DoMinify bool

+ FolderPath string

+ func NewStaticFilesHandlerTask(folderPath string) *StaticFilesHandlerTask

+ func (h *StaticFilesHandlerTask) Get(ctx channel.HandlerContext, req *Request, resp *Response, ...) ErrorResponse