Documentation
¶
Index ¶
- Constants
- Variables
- func GetRemoteAddr(ctx *share.Context) string
- func GetRequestValue(ctx *share.Context, key string) string
- func GetResponseValue(ctx *share.Context, key string) string
- func SetLogger(l log.Logger)
- func SetRequestValue(ctx *share.Context, key string, value string)
- func SetResponseValue(ctx *share.Context, key string, value string)
- type ClientManager
- func (m *ClientManager) AddService(name, servicePath string) error
- func (m *ClientManager) Close(c *client.XClientPool) error
- func (m *ClientManager) GetClient(name string) (client.XClient, error)
- func (m *ClientManager) GetServices(name string) map[string]string
- func (m *ClientManager) Release() error
- func (m *ClientManager) SetClientFailMode(name string, mode client.FailMode)
- func (m *ClientManager) SetClientOption(name string, option client.Option)
- func (m *ClientManager) SetClientSelectMode(name string, mode client.SelectMode)
- type ClientManagerConfig
- type Server
- func (s *Server) Close() error
- func (s *Server) RegisterFileTransferService(name string, addr string, handler server.FileTransferHandler, ...) error
- func (s *Server) RegisterService(name string, obj interface{}) error
- func (s *Server) RegisterStreamService(name string, addr string, streamHandler server.StreamHandler, ...) error
- func (s *Server) Run() error
- func (s *Server) Shutdown(ctx context.Context) error
- type ServerConfig
- type Service
Constants ¶
View Source
const ( RegistryTypeMDNS = "mdns" RegistryTypeConsul = "consul" RegistryTypeRedis = "redis" RegistryTypeEtcdV3 = "etcdv3" RegistryTypePeer2Peer = "peer2peer" RegistryTypeMultipleServers = "multipleservers" )
Variables ¶
View Source
var ( ErrorUnsupportedRegistryType = errors.New("unsupported registry type") ErrorAddress = errors.New("address error") )
View Source
var (
ErrorSerivceNotExists = errors.New("service not exists")
)
View Source
var (
ErrorServerClosed = errors.New("server closed")
)
Functions ¶
func GetRemoteAddr ¶
Types ¶
type ClientManager ¶
type ClientManager struct {
// contains filtered or unexported fields
}
func NewServiceManager ¶
func NewServiceManager(cfg *ClientManagerConfig) (*ClientManager, error)
func (*ClientManager) AddService ¶
func (m *ClientManager) AddService(name, servicePath string) error
func (*ClientManager) Close ¶
func (m *ClientManager) Close(c *client.XClientPool) error
func (*ClientManager) GetClient ¶
func (m *ClientManager) GetClient(name string) (client.XClient, error)
func (*ClientManager) GetServices ¶
func (m *ClientManager) GetServices(name string) map[string]string
func (*ClientManager) Release ¶
func (m *ClientManager) Release() error
func (*ClientManager) SetClientFailMode ¶
func (m *ClientManager) SetClientFailMode(name string, mode client.FailMode)
func (*ClientManager) SetClientOption ¶
func (m *ClientManager) SetClientOption(name string, option client.Option)
func (*ClientManager) SetClientSelectMode ¶
func (m *ClientManager) SetClientSelectMode(name string, mode client.SelectMode)
type ClientManagerConfig ¶
type Server ¶
type Server struct {
// contains filtered or unexported fields
}
func (*Server) RegisterFileTransferService ¶
func (s *Server) RegisterFileTransferService(name string, addr string, handler server.FileTransferHandler, downloadFileHandler server.DownloadFileHandler, waitNum int) error
func (*Server) RegisterService ¶
func (*Server) RegisterStreamService ¶
func (s *Server) RegisterStreamService(name string, addr string, streamHandler server.StreamHandler, acceptor server.StreamAcceptor, waitNum int) error
type ServerConfig ¶
type ServerConfig struct { Address string // registry RegistryType string RegistryEndpoints string RegistryInterval time.Duration RegistryBasePath string // rate limiting RateLimitingConnectFillInterval time.Duration RateLimitingConnectCapacity int64 RateLimitingRequestFillInterval time.Duration RateLimitingRequestCapacity int64 }
Click to show internal directories.
Click to hide internal directories.