Documentation ¶
Index ¶
- Constants
- Variables
- type Broker
- type Caller
- type CastError
- type CircuitBreaker
- type Client
- type ClientCodec
- type ClientContext
- type Cluster
- type CodecOption
- type ConcurrentLimiter
- type Context
- type CookieManagerOption
- type DecodeError
- type Decoder
- type Encoder
- type ExecuteTimeout
- type Formatter
- type Forward
- type InvalidRequestError
- type InvalidResponseError
- type JSONRPCClientCodec
- type JSONRPCServiceCodec
- type LeastActiveLoadBalance
- type Log
- type LongType
- type MapType
- type Message
- type Method
- type NextIOHandler
- type NextInvokeHandler
- type NginxRoundRobinLoadBalance
- type Oneway
- type PanicError
- type Producer
- type Prosumer
- type Provider
- type ProviderContext
- type RandomLoadBalance
- type RateLimiter
- type RealType
- type RoundRobinLoadBalance
- type Service
- type ServiceCodec
- type ServiceContext
- type UnsupportedProtocolError
- type UnsupportedServerTypeError
- type UnsupportedTypeError
- type ValueDecoder
- type ValueEncoder
- type WeightedLeastActiveLoadBalance
- type WeightedRandomLoadBalance
- type WeightedRoundRobinLoadBalance
Constants ¶
View Source
const ( // Serialize Type. TagInteger = io.TagInteger TagLong = io.TagLong TagDouble = io.TagDouble TagNull = io.TagNull TagEmpty = io.TagEmpty TagTrue = io.TagTrue TagFalse = io.TagFalse TagNaN = io.TagNaN TagInfinity = io.TagInfinity TagDate = io.TagDate TagTime = io.TagTime TagUTC = io.TagUTC TagBytes = io.TagBytes TagUTF8Char = io.TagUTF8Char TagString = io.TagString TagGUID = io.TagGUID TagList = io.TagList TagMap = io.TagMap TagClass = io.TagClass TagObject = io.TagObject TagRef = io.TagRef // Serialize Marks. TagPos = io.TagPos TagNeg = io.TagNeg TagSemicolon = io.TagSemicolon TagOpenbrace = io.TagOpenbrace TagClosebrace = io.TagClosebrace TagQuote = io.TagQuote TagPoint = io.TagPoint // Protocol Tags. TagHeader = io.TagHeader TagCall = io.TagCall TagResult = io.TagResult TagError = io.TagError TagEnd = io.TagEnd LongTypeInt = io.LongTypeInt LongTypeUint = io.LongTypeUint LongTypeInt64 = io.LongTypeInt64 LongTypeUint64 = io.LongTypeUint64 LongTypeBigInt = io.LongTypeBigInt RealTypeFloat64 = io.RealTypeFloat64 RealTypeFloat32 = io.RealTypeFloat32 RealTypeBigFloat = io.RealTypeBigFloat MapTypeIIMap = io.MapTypeIIMap MapTypeSIMap = io.MapTypeSIMap StructTypePtr = io.StructTypePtr StructTypeValue = io.StructTypeValue ListTypeISlice = io.ListTypeISlice ListTypeSlice = io.ListTypeSlice NoCookieManager = cookie.NoCookieManager GlobalCookieManager = cookie.GlobalCookieManager ClientCookieManager = cookie.ClientCookieManager )
Variables ¶
View Source
var ( ErrInvalidUTF8 = io.ErrInvalidUTF8 Marshal = io.Marshal Unmarshal = io.Unmarshal Register = io.Register RegisterName = io.RegisterName RegisterValueDecoder = io.RegisterValueDecoder RegisterValueEncoder = io.RegisterValueEncoder RegisterConverter = io.RegisterConverter GetConverter = io.GetConverter Convert = io.Convert GetStructType = io.GetStructType NewDecoder = io.NewDecoder NewDecoderFromReader = io.NewDecoderFromReader NewEncoder = io.NewEncoder GetValueDecoder = io.GetValueDecoder GetValueEncoder = io.GetValueEncoder GetEncoder = io.GetEncoder FreeEncoder = io.FreeEncoder GetDecoder = io.GetDecoder FreeDecoder = io.FreeDecoder ErrClosed = rpc.ErrClosed ErrRequestEntityTooLarge = rpc.ErrRequestEntityTooLarge ErrTimeout = rpc.ErrTimeout IsTemporaryError = rpc.IsTemporaryError IsTimeoutError = rpc.IsTimeoutError RegisterHandler = rpc.RegisterHandler RegisterTransport = rpc.RegisterTransport WithContext = rpc.WithContext GetClientContext = rpc.GetClientContext NewClientContext = rpc.NewClientContext GetServiceContext = rpc.GetServiceContext NewServiceContext = rpc.NewServiceContext FromContext = rpc.FromContext NewContext = rpc.NewContext NewPanicError = rpc.NewPanicError MissingMethod = rpc.MissingMethod NewMethod = rpc.NewMethod NewClientCodec = rpc.NewClientCodec NewServiceCodec = rpc.NewServiceCodec WithDebug = rpc.WithDebug WithSimple = rpc.WithSimple WithLongType = rpc.WithLongType WithRealType = rpc.WithRealType WithMapType = rpc.WithMapType WithStructType = rpc.WithStructType WithListType = rpc.WithListType NewClient = rpc.NewClient NewService = rpc.NewService HTTPTransport = rpc.HTTPTransport FastHTTPTransport = rpc.FastHTTPTransport SocketTransport = rpc.SocketTransport UDPTransport = rpc.UDPTransport WebSocketTransport = rpc.WebSocketTransport HTTPHandler = rpc.HTTPHandler SocketHandler = rpc.SocketHandler UDPHandler = rpc.UDPHandler WebSocketHandler = rpc.WebSocketHandler NewJSONRPCClientCodec = jsonrpc.NewClientCodec NewJSONRPCServiceCodec = jsonrpc.NewServiceCodec WithThreshold = circuitbreaker.WithThreshold WithRecoverTime = circuitbreaker.WithRecoverTime WithMockService = circuitbreaker.WithMockService NewCircuitBreaker = circuitbreaker.New WithRetry = cluster.WithRetry WithIdempotent = cluster.WithIdempotent WithMinInterval = cluster.WithMinInterval WithMaxInterval = cluster.WithMaxInterval FailoverConfig = cluster.FailoverConfig FailtryConfig = cluster.FailtryConfig FailfastConfig = cluster.FailfastConfig NewCluster = cluster.New ForkingPlugin = cluster.Forking BroadcastPlugin = cluster.Broadcast NewForward = forward.New WithMaxPermits = limiter.WithMaxPermits WithTimeout = limiter.WithTimeout NewRateLimiter = limiter.NewRateLimiter NewConcurrentLimiter = limiter.NewConcurrentLimiter NewLeastActiveLoadBalance = loadbalance.NewLeastActiveLoadBalance NewRandomLoadBalance = loadbalance.NewRandomLoadBalance NewRoundRobinLoadBalance = loadbalance.NewRoundRobinLoadBalance NewNginxRoundRobinLoadBalance = loadbalance.NewNginxRoundRobinLoadBalance NewWeightedLeastActiveLoadBalance = loadbalance.NewWeightedLeastActiveLoadBalance NewWeightedRandomLoadBalance = loadbalance.NewWeightedRandomLoadBalance NewWeightedRoundRobinLoadBalance = loadbalance.NewWeightedRoundRobinLoadBalance NewLog = log.New LogPlugin = log.Plugin NewBroker = push.NewBroker GetProducer = push.GetProducer NewProsumer = push.NewProsumer NewCaller = reverse.NewCaller UseService = reverse.UseService GetProviderContext = reverse.GetProviderContext NewProvider = reverse.NewProvider NewExecuteTimeout = timeout.New )
Functions ¶
This section is empty.
Types ¶
type CircuitBreaker ¶
type CircuitBreaker = circuitbreaker.CircuitBreaker
type ClientCodec ¶
type ClientCodec = rpc.ClientCodec
type ClientContext ¶
type ClientContext = rpc.ClientContext
type CodecOption ¶
type CodecOption = rpc.CodecOption
type ConcurrentLimiter ¶
type ConcurrentLimiter = limiter.ConcurrentLimiter
type CookieManagerOption ¶ added in v3.0.6
type CookieManagerOption = cookie.CookieManagerOption
type DecodeError ¶
type DecodeError = io.DecodeError
type ExecuteTimeout ¶
type ExecuteTimeout = timeout.ExecuteTimeout
type InvalidRequestError ¶
type InvalidRequestError = rpc.InvalidRequestError
type InvalidResponseError ¶
type InvalidResponseError = rpc.InvalidResponseError
type JSONRPCClientCodec ¶
type JSONRPCClientCodec = jsonrpc.ClientCodec
type JSONRPCServiceCodec ¶
type JSONRPCServiceCodec = jsonrpc.ServiceCodec
type LeastActiveLoadBalance ¶
type LeastActiveLoadBalance = loadbalance.LeastActiveLoadBalance
type NextIOHandler ¶
type NextIOHandler = rpc.NextIOHandler
type NextInvokeHandler ¶
type NextInvokeHandler = rpc.NextInvokeHandler
type NginxRoundRobinLoadBalance ¶
type NginxRoundRobinLoadBalance = loadbalance.NginxRoundRobinLoadBalance
type PanicError ¶
type PanicError = rpc.PanicError
type ProviderContext ¶
type ProviderContext = reverse.ProviderContext
type RandomLoadBalance ¶
type RandomLoadBalance = loadbalance.RandomLoadBalance
type RateLimiter ¶
type RateLimiter = limiter.RateLimiter
type RoundRobinLoadBalance ¶
type RoundRobinLoadBalance = loadbalance.RoundRobinLoadBalance
type ServiceCodec ¶
type ServiceCodec = rpc.ServiceCodec
type ServiceContext ¶
type ServiceContext = rpc.ServiceContext
type UnsupportedProtocolError ¶
type UnsupportedProtocolError = rpc.UnsupportedProtocolError
type UnsupportedServerTypeError ¶
type UnsupportedServerTypeError = rpc.UnsupportedServerTypeError
type UnsupportedTypeError ¶
type UnsupportedTypeError = io.UnsupportedTypeError
type ValueDecoder ¶
type ValueDecoder = io.ValueDecoder
type ValueEncoder ¶
type ValueEncoder = io.ValueEncoder
type WeightedLeastActiveLoadBalance ¶
type WeightedLeastActiveLoadBalance = loadbalance.WeightedLeastActiveLoadBalance
type WeightedRandomLoadBalance ¶
type WeightedRandomLoadBalance = loadbalance.WeightedRandomLoadBalance
type WeightedRoundRobinLoadBalance ¶
type WeightedRoundRobinLoadBalance = loadbalance.WeightedRoundRobinLoadBalance
Click to show internal directories.
Click to hide internal directories.