Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

micro

package module

Go to main page

Versions in this module

v6

v6.1.2

Mar 6, 2020

v6.1.1

Feb 5, 2020

v6.1.0

Nov 14, 2019

v6.0.3

Nov 13, 2019

v6.0.2

Nov 13, 2019

Changes in this version

+ var RerrClientClosed = tp.NewStatus(100, "client is closed", "")

+ var RerrInternalServerError = tp.NewStatus(tp.CodeInternalServerError, "System is busy, please try again later", "")

+ var RerrInvalidParameter = tp.NewStatus(tp.CodeBadMessage, "Invalid Parameter", "")

+ var RerrNotFound = tp.NewStatus(tp.CodeNotFound, "Not Found", "")

+ var RerrNotOnline = tp.NewStatus(tp.CodeNotFound, "Not Found", "User is not online")

+ var RerrRenderFailed = tp.NewStatus(tp.CodeInternalServerError, "Template Rendering Failed", "")

+ func InnerIpPort(port string) (string, error)

+ func OuterIpPort(port string) (string, error)

+ type CircuitBreakerConfig struct

+ BreakDuration time.Duration

+ Enable bool

+ ErrorPercentage int

+ type CliConfig struct

+ CircuitBreaker CircuitBreakerConfig

+ CountTime bool

+ DefaultBodyCodec string

+ DefaultContextAge time.Duration

+ DefaultDialTimeout time.Duration

+ DefaultSessionAge time.Duration

+ Failover int

+ HeartbeatSecond int

+ LocalIP string

+ Network string

+ PrintDetail bool

+ SlowCometDuration time.Duration

+ TlsCertFile string

+ TlsKeyFile string

+ func (c *CliConfig) Check() error

+ func (c *CliConfig) Reload(bind cfgo.BindFunc) error

+ type Client struct

+ func NewClient(cfg CliConfig, linker Linker, globalLeftPlugin ...tp.Plugin) *Client

+ func (c *Client) AsyncCall(serviceMethod string, arg interface{}, result interface{}, ...) tp.CallCmd

+ func (c *Client) Call(serviceMethod string, arg interface{}, result interface{}, ...) tp.CallCmd

+ func (c *Client) Close()

+ func (c *Client) Peer() tp.Peer

+ func (c *Client) PluginContainer() *tp.PluginContainer

+ func (c *Client) Push(serviceMethod string, arg interface{}, setting ...tp.MessageSetting) *tp.Status

+ func (c *Client) RoutePush(ctrlStruct interface{}, plugin ...tp.Plugin) []string

+ func (c *Client) RoutePushFunc(pushHandleFunc interface{}, plugin ...tp.Plugin) string

+ func (c *Client) SetProtoFunc(protoFunc tp.ProtoFunc)

+ func (c *Client) SubRoute(pathPrefix string, plugin ...tp.Plugin) *tp.SubRouter

+ func (c *Client) UseCallHeartbeat()

+ func (c *Client) UsePushHeartbeat()

+ type Linker interface

+ Close func()

+ Len func(uriPath string) int

+ Select func(uriPath string, exclude map[string]struct{}) (addr string, stat *tp.Status)

+ WatchOffline func() <-chan string

+ func NewStaticLinker(srvAddr string) Linker

+ type Server struct

+ func NewServer(cfg SrvConfig, globalLeftPlugin ...tp.Plugin) *Server

+ func (s *Server) Close() error

+ func (s *Server) CountSession() int

+ func (s *Server) GetSession(sessionId string) (tp.Session, bool)

+ func (s *Server) ListenAndServe(protoFunc ...tp.ProtoFunc) error

+ func (s *Server) Peer() tp.Peer

+ func (s *Server) PluginContainer() *tp.PluginContainer

+ func (s *Server) RangeSession(fn func(sess tp.Session) bool)

+ func (s *Server) RouteCall(ctrlStruct interface{}, plugin ...tp.Plugin) []string

+ func (s *Server) RouteCallFunc(callHandleFunc interface{}, plugin ...tp.Plugin) string

+ func (s *Server) RoutePush(ctrlStruct interface{}, plugin ...tp.Plugin) []string

+ func (s *Server) RoutePushFunc(pushHandleFunc interface{}, plugin ...tp.Plugin) string

+ func (s *Server) Router() *tp.Router

+ func (s *Server) ServeConn(conn net.Conn, protoFunc ...tp.ProtoFunc) (tp.Session, *tp.Status)

+ func (s *Server) SetBindErrorFunc(fn binder.ErrorFunc)

+ func (s *Server) SetUnknownCall(fn func(tp.UnknownCallCtx) (interface{}, *tp.Status), plugin ...tp.Plugin)

+ func (s *Server) SetUnknownPush(fn func(tp.UnknownPushCtx) *tp.Status, plugin ...tp.Plugin)

+ func (s *Server) SubRoute(pathPrefix string, plugin ...tp.Plugin) *tp.SubRouter

+ type SrvConfig struct

+ CountTime bool

+ DefaultBodyCodec string

+ DefaultContextAge time.Duration

+ DefaultSessionAge time.Duration

+ EnableHeartbeat bool

+ ListenAddress string

+ Network string

+ PrintDetail bool

+ SlowCometDuration time.Duration

+ TlsCertFile string

+ TlsKeyFile string

+ func (s *SrvConfig) InnerIpPort() string

+ func (s *SrvConfig) ListenPort() string

+ func (s *SrvConfig) OuterIpPort() string

+ func (s *SrvConfig) PeerConfig() tp.PeerConfig

+ func (s *SrvConfig) Reload(bind cfgo.BindFunc) error

Other modules containing this package

github.com/xiaoenai/tp-micro