server

Documentation

Overview

Package server is default Server implements for different protocol.

Index

• Constants
• func RegistDefaultMessageHandlers(extFactory motan.ExtentionFactory)
• func RegistDefaultServers(extFactory motan.ExtentionFactory)
• func WarperWithFilter(provider motan.Provider, extFactory motan.ExtentionFactory) motan.Provider
• type DefaultExporter
  • func (d *DefaultExporter) Export(server motan.Server, extFactory motan.ExtentionFactory, context *motan.Context) (err error)
  • func (d *DefaultExporter) GetProvider() motan.Provider
  • func (d *DefaultExporter) GetURL() *motan.URL
  • func (d *DefaultExporter) SetProvider(provider motan.Provider)
  • func (d *DefaultExporter) SetURL(url *motan.URL)
  • func (d *DefaultExporter) Unexport() error
• type DefaultMessageHandler
  • 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 FilterProviderWarper
  • func (f *FilterProviderWarper) Call(request motan.Request) (res motan.Response)
  • func (f *FilterProviderWarper) Destroy()
  • func (f *FilterProviderWarper) GetPath() string
  • func (f *FilterProviderWarper) GetURL() *motan.URL
  • func (f *FilterProviderWarper) IsAvailable() bool
  • func (f *FilterProviderWarper) SetService(s interface{})
  • func (f *FilterProviderWarper) SetURL(url *motan.URL)
• type MotanServer
  • 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)

Constants

const (
	Motan2 = "motan2"
	CGI    = "cgi"
)

const (
	Default = "default"
)

Functions

func RegistDefaultMessageHandlers

func RegistDefaultMessageHandlers(extFactory motan.ExtentionFactory)

func RegistDefaultServers

func RegistDefaultServers(extFactory motan.ExtentionFactory)

func WarperWithFilter

func WarperWithFilter(provider motan.Provider, extFactory motan.ExtentionFactory) motan.Provider

Types

type DefaultExporter

type DefaultExporter struct {
	Registrys []motan.Registry
	// contains filtered or unexported fields
}

func (*DefaultExporter) Export

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

func (*DefaultExporter) GetProvider

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

func (*DefaultExporter) GetURL

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

func (*DefaultExporter) SetProvider

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

func (*DefaultExporter) SetURL

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

func (*DefaultExporter) Unexport

func (d *DefaultExporter) Unexport() error

type DefaultMessageHandler

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

func (*DefaultMessageHandler) AddProvider

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

func (*DefaultMessageHandler) Call

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

func (*DefaultMessageHandler) GetProvider

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

func (*DefaultMessageHandler) Initialize

func (d *DefaultMessageHandler) Initialize()

func (*DefaultMessageHandler) RmProvider

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

type FilterProviderWarper

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

func (*FilterProviderWarper) Call

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

func (*FilterProviderWarper) Destroy

func (f *FilterProviderWarper) Destroy()

func (*FilterProviderWarper) GetPath

func (f *FilterProviderWarper) GetPath() string

func (*FilterProviderWarper) GetURL

func (f *FilterProviderWarper) GetURL() *motan.URL

func (*FilterProviderWarper) IsAvailable

func (f *FilterProviderWarper) IsAvailable() bool

func (*FilterProviderWarper) SetService

func (f *FilterProviderWarper) SetService(s interface{})

func (*FilterProviderWarper) SetURL

func (f *FilterProviderWarper) SetURL(url *motan.URL)

type MotanServer

type MotanServer struct {
	URL *motan.URL
	// contains filtered or unexported fields
}

func (*MotanServer) Destroy

func (m *MotanServer) Destroy()

func (*MotanServer) GetMessageHandler

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

func (*MotanServer) GetName

func (m *MotanServer) GetName() string

func (*MotanServer) GetURL

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

func (*MotanServer) Open

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

func (*MotanServer) SetMessageHandler

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

func (*MotanServer) SetURL

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