server

package

Go to main page

Versions in this module

v1

v1.2.0

Sep 9, 2024

Changes in this version

type DefaultExporter

+ func (d *DefaultExporter) GetRuntimeInfo() map[string]interface{}

type DefaultMessageHandler

+ func (d *DefaultMessageHandler) GetName() string

+ func (d *DefaultMessageHandler) GetRuntimeInfo() map[string]interface{}

type FilterProviderWrapper

+ func (f *FilterProviderWrapper) GetRuntimeInfo() map[string]interface{}

type HTTPProxyServer

+ func (s *HTTPProxyServer) GetRuntimeInfo() map[string]interface{}

type MotanServer

+ func (m *MotanServer) GetRuntimeInfo() map[string]interface{}

v1.1.0

Apr 2, 2024

Changes in this version

+ const Motan

+ func GetProcessPoolSize() int

+ func SetProcessPoolSize(size int)

type MotanServer

+ func (m *MotanServer) SetHeartbeat(enabled bool)

v1.0.2

Aug 11, 2021

v1.0.1

Jun 22, 2021

Changes in this version

+ const CGI

+ const Default

+ const DefaultKeepaliveTimeout

+ const DefaultMaxRequestBodySize

+ const DefaultTimeout

+ const HTTPProxyDefaultDomainKey

+ const HTTPProxyEnableKey

+ const HTTPProxyKeepaliveKey

+ const HTTPProxyKeepaliveTimeoutKey

+ const HTTPProxyMaxRequestBodySizeKey

+ const HTTPProxyServerName

+ const HTTPProxyTimeoutKey

+ const Motan2

+ func RegistDefaultMessageHandlers(extFactory motan.ExtensionFactory)

+ func RegistDefaultServers(extFactory motan.ExtensionFactory)

+ func WrapWithFilter(provider motan.Provider, extFactory motan.ExtensionFactory, ...) motan.Provider

+ type DefaultExporter struct

+ Registries []motan.Registry

+ func (d *DefaultExporter) Available()

+ func (d *DefaultExporter) Export(server motan.Server, extFactory motan.ExtensionFactory, context *motan.Context) (err error)

+ func (d *DefaultExporter) GetProvider() motan.Provider

+ func (d *DefaultExporter) GetURL() *motan.URL

+ func (d *DefaultExporter) IsAvailable() bool

+ func (d *DefaultExporter) SetProvider(provider motan.Provider)

+ func (d *DefaultExporter) SetURL(url *motan.URL)

+ func (d *DefaultExporter) Unavailable()

+ func (d *DefaultExporter) Unexport() error

+ type DefaultMessageHandler struct

+ func (d *DefaultMessageHandler) AddProvider(p motan.Provider) error

+ func (d *DefaultMessageHandler) Call(request motan.Request) (res motan.Response)

+ func (d *DefaultMessageHandler) GetProvider(serviceName string) motan.Provider

+ func (d *DefaultMessageHandler) Initialize()

+ func (d *DefaultMessageHandler) RmProvider(p motan.Provider)

+ type FilterProviderWrapper struct

+ func (f *FilterProviderWrapper) Call(request motan.Request) (res motan.Response)

+ func (f *FilterProviderWrapper) Destroy()

+ func (f *FilterProviderWrapper) GetPath() string

+ func (f *FilterProviderWrapper) GetURL() *motan.URL

+ func (f *FilterProviderWrapper) IsAvailable() bool

+ func (f *FilterProviderWrapper) SetService(s interface{})

+ func (f *FilterProviderWrapper) SetURL(url *motan.URL)

+ type HTTPClusterGetter interface

+ GetHTTPCluster func(host string) *cluster.HTTPCluster

+ type HTTPProxyServer struct

+ func NewHTTPProxyServer(url *core.URL) *HTTPProxyServer

+ func (s *HTTPProxyServer) Destroy()

+ func (s *HTTPProxyServer) GetHTTPClient() *fasthttp.Client

+ func (s *HTTPProxyServer) GetName() string

+ func (s *HTTPProxyServer) GetURL() *core.URL

+ func (s *HTTPProxyServer) Open(block bool, proxy bool, clusterGetter HTTPClusterGetter, ...) error

+ func (s *HTTPProxyServer) SetURL(url *core.URL)

+ type MotanServer struct

+ URL *motan.URL

+ func (m *MotanServer) Destroy()

+ func (m *MotanServer) GetMessageHandler() motan.MessageHandler

+ func (m *MotanServer) GetName() string

+ func (m *MotanServer) GetURL() *motan.URL

+ func (m *MotanServer) Open(block bool, proxy bool, handler motan.MessageHandler, ...) error

+ func (m *MotanServer) SetMessageHandler(mh motan.MessageHandler)

+ func (m *MotanServer) SetURL(url *motan.URL)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL