Documentation
¶
Overview ¶
GENERATED BY 'T'ransport 'G'enerator. DO NOT EDIT.
GENERATED BY 'T'ransport 'G'enerator. DO NOT EDIT.
GENERATED BY 'T'ransport 'G'enerator. DO NOT EDIT.
GENERATED BY 'T'ransport 'G'enerator. DO NOT EDIT.
GENERATED BY 'T'ransport 'G'enerator. DO NOT EDIT.
GENERATED BY 'T'ransport 'G'enerator. DO NOT EDIT.
GENERATED BY 'T'ransport 'G'enerator. DO NOT EDIT.
GENERATED BY 'T'ransport 'G'enerator. DO NOT EDIT.
GENERATED BY 'T'ransport 'G'enerator. DO NOT EDIT.
GENERATED BY 'T'ransport 'G'enerator. DO NOT EDIT.
GENERATED BY 'T'ransport 'G'enerator. DO NOT EDIT.
GENERATED BY 'T'ransport 'G'enerator. DO NOT EDIT.
GENERATED BY 'T'ransport 'G'enerator. DO NOT EDIT.
GENERATED BY 'T'ransport 'G'enerator. DO NOT EDIT.
GENERATED BY 'T'ransport 'G'enerator. DO NOT EDIT.
GENERATED BY 'T'ransport 'G'enerator. DO NOT EDIT.
GENERATED BY 'T'ransport 'G'enerator. DO NOT EDIT.
Index ¶
- Constants
- Variables
- func ExitOnError(log zerolog.Logger, err error, msg string)
- func NewServerSettings(svcServerSettings api.ServerSettings) (srv *httpServerSettings)
- type ErrorHandler
- type Handler
- type Header
- type HeaderHandler
- type MethodCallMeta
- type MiddlewareServerSettings
- type MiddlewareServerSettingsCreateRoom
- type MiddlewareServerSettingsGetConnectionsNum
- type MiddlewareServerSettingsGetDeletedRooms
- type MiddlewareServerSettingsGetServerSettings
- type MiddlewareServerSettingsHealthCheck
- type MiddlewareSetServerSettings
- type Option
- func MaxBatchSize(size int) Option
- func MaxBatchWorkers(size int) Option
- func MaxBodySize(max int) Option
- func ReadTimeout(timeout time.Duration) Option
- func ServerSettings(svc *httpServerSettings) Option
- func Service(svc ServiceRoute) Option
- func SetFiberCfg(cfg fiber.Config) Option
- func SetReadBufferSize(size int) Option
- func SetWriteBufferSize(size int) Option
- func Use(args ...interface{}) Option
- func WithHeader(headerName string, handler HeaderHandler) Option
- func WithRequestID(headerName string) Option
- func WriteTimeout(timeout time.Duration) Option
- type Server
- func (srv *Server) Fiber() *fiber.App
- func (srv *Server) ServeHealth(address string, response interface{})
- func (srv *Server) ServeMetrics(log zerolog.Logger, path string, address string)
- func (srv *Server) ServerSettings() *httpServerSettings
- func (srv *Server) Shutdown()
- func (srv *Server) WithLog() *Server
- func (srv *Server) WithTrace(ctx context.Context, appName string, endpoint string, ...) *Server
- type ServerSettingsCreateRoom
- type ServerSettingsGetConnectionsNum
- type ServerSettingsGetDeletedRooms
- type ServerSettingsGetServerSettings
- type ServerSettingsHealthCheck
- type ServiceRoute
Constants ¶
const (
// Version defines the version of the JSON RPC implementation
Version = "2.0"
)
const VersionTg = "v2.3.89"
Variables ¶
var RequestCount *prometheus.CounterVec
var RequestCountAll *prometheus.CounterVec
var RequestLatency *prometheus.HistogramVec
var VersionGauge *prometheus.GaugeVec
Functions ¶
func NewServerSettings ¶
func NewServerSettings(svcServerSettings api.ServerSettings) (srv *httpServerSettings)
Types ¶
type ErrorHandler ¶
type HeaderHandler ¶
type MethodCallMeta ¶ added in v1.0.5
type MiddlewareServerSettings ¶
type MiddlewareServerSettings func(next api.ServerSettings) api.ServerSettings
type MiddlewareServerSettingsCreateRoom ¶
type MiddlewareServerSettingsCreateRoom func(next ServerSettingsCreateRoom) ServerSettingsCreateRoom
type MiddlewareServerSettingsGetConnectionsNum ¶
type MiddlewareServerSettingsGetConnectionsNum func(next ServerSettingsGetConnectionsNum) ServerSettingsGetConnectionsNum
type MiddlewareServerSettingsGetDeletedRooms ¶ added in v1.0.4
type MiddlewareServerSettingsGetDeletedRooms func(next ServerSettingsGetDeletedRooms) ServerSettingsGetDeletedRooms
type MiddlewareServerSettingsGetServerSettings ¶
type MiddlewareServerSettingsGetServerSettings func(next ServerSettingsGetServerSettings) ServerSettingsGetServerSettings
type MiddlewareServerSettingsHealthCheck ¶
type MiddlewareServerSettingsHealthCheck func(next ServerSettingsHealthCheck) ServerSettingsHealthCheck
type MiddlewareSetServerSettings ¶
type MiddlewareSetServerSettings interface {
Wrap(m MiddlewareServerSettings)
WrapGetConnectionsNum(m MiddlewareServerSettingsGetConnectionsNum)
WrapHealthCheck(m MiddlewareServerSettingsHealthCheck)
WrapGetServerSettings(m MiddlewareServerSettingsGetServerSettings)
WrapCreateRoom(m MiddlewareServerSettingsCreateRoom)
WrapGetDeletedRooms(m MiddlewareServerSettingsGetDeletedRooms)
WithTrace()
WithLog()
}
type Option ¶
type Option func(srv *Server)
func MaxBatchSize ¶
func MaxBatchWorkers ¶
func MaxBodySize ¶
func ReadTimeout ¶
func ServerSettings ¶
func ServerSettings(svc *httpServerSettings) Option
func Service ¶
func Service(svc ServiceRoute) Option
func SetFiberCfg ¶
func SetReadBufferSize ¶
func SetWriteBufferSize ¶ added in v1.0.5
func WithHeader ¶
func WithHeader(headerName string, handler HeaderHandler) Option
func WithRequestID ¶
func WriteTimeout ¶
type Server ¶
type Server struct {
// contains filtered or unexported fields
}
func (*Server) ServeHealth ¶
func (*Server) ServeMetrics ¶ added in v1.0.5
func (*Server) ServerSettings ¶
func (srv *Server) ServerSettings() *httpServerSettings
type ServerSettingsGetDeletedRooms ¶ added in v1.0.4
type ServerSettingsGetDeletedRooms func(ctx context.Context, token string, ids []types.GetDeletedRooms) (deletedIds []types.GetDeletedRooms, err error)