Versions in this module Expand all Collapse all v0 v0.6.1 Jul 31, 2023 v0.0.4 Jul 31, 2023 Changes in this version + const BitConnectTimeout + const BitIOBufferSize + const BitRPCTimeout + const BitReadWriteTimeout + const ConnResetTag + const HTTPHeader + const HTTPHost + const HTTPURL + const RemoteClosedTag + const RetryLastCostTag + const RetryPrevInstTag + const RetryTag + const ShmIPCTag + func CalcEventCostUs(start, end Event) uint64 + func ClientPanicToErr(ctx context.Context, panicInfo interface{}, ri RPCInfo, logErr bool) error + func FreezeRPCInfo(ctx context.Context) context.Context + func NewCtxWithRPCInfo(ctx context.Context, ri RPCInfo) context.Context + func NewInvocation(service, method string, pkgOpt ...string) *invocation + func PutRPCInfo(ri RPCInfo) + func Record(ctx context.Context, ri RPCInfo, event stats.Event, err error) + type EndpointBasicInfo struct + Method string + ServiceName string + Tags map[string]string + type EndpointInfo interface + Address func() net.Addr + DefaultTag func(key, def string) string + Method func() string + ServiceName func() string + Tag func(key string) (value string, exist bool) + func EmptyEndpointInfo() EndpointInfo + func FromBasicInfo(bi *EndpointBasicInfo) EndpointInfo + func NewEndpointInfo(serviceName, method string, address net.Addr, tags map[string]string) EndpointInfo + type Event interface + Event func() stats.Event + Info func() string + IsNil func() bool + Status func() stats.Status + Time func() time.Time + type InteractionMode int32 + const Oneway + const PingPong + const Streaming + type Invocation interface + BizStatusErr func() kerrors.BizStatusErrorIface + MethodName func() string + PackageName func() string + SeqID func() int32 + ServiceName func() string + func NewServerInvocation() Invocation + type InvocationSetter interface + Reset func() + SetBizStatusErr func(err kerrors.BizStatusErrorIface) + SetMethodName func(name string) + SetPackageName func(name string) + SetSeqID func(seqID int32) + SetServiceName func(name string) + type MutableEndpointInfo interface + ImmutableView func() EndpointInfo + Reset func() + ResetFromBasicInfo func(bi *EndpointBasicInfo) + SetAddress func(addr net.Addr) error + SetMethod func(method string) error + SetServiceName func(service string) error + SetTag func(key, value string) error + func AsMutableEndpointInfo(ei EndpointInfo) MutableEndpointInfo + func NewMutableEndpointInfo(serviceName, method string, address net.Addr, tags map[string]string) MutableEndpointInfo + type MutableRPCConfig interface + Clone func() MutableRPCConfig + CopyFrom func(from RPCConfig) + ImmutableView func() RPCConfig + IsConnectTimeoutLocked func() bool + IsRPCTimeoutLocked func() bool + IsReadWriteTimeoutLocked func() bool + LockConfig func(bits int) + SetConnectTimeout func(to time.Duration) error + SetIOBufferSize func(sz int) error + SetInteractionMode func(mode InteractionMode) error + SetRPCTimeout func(to time.Duration) error + SetReadWriteTimeout func(to time.Duration) error + SetTransportProtocol func(tp transport.Protocol) error + func AsMutableRPCConfig(r RPCConfig) MutableRPCConfig + type MutableRPCStats interface + ImmutableView func() RPCStats + Reset func() + SetError func(err error) + SetLevel func(level stats.Level) + SetPanicked func(x interface{}) + SetRecvSize func(size uint64) + SetSendSize func(size uint64) + func AsMutableRPCStats(r RPCStats) MutableRPCStats + type RPCConfig interface + IOBufferSize func() int + InteractionMode func() InteractionMode + TransportProtocol func() transport.Protocol + func NewRPCConfig() RPCConfig + type RPCInfo interface + Config func() RPCConfig + From func() EndpointInfo + Invocation func() Invocation + Stats func() RPCStats + To func() EndpointInfo + func GetRPCInfo(ctx context.Context) RPCInfo + func NewRPCInfo(from, to EndpointInfo, ink Invocation, config RPCConfig, stats RPCStats) RPCInfo + type RPCStats interface + Error func() error + GetEvent func(event stats.Event) Event + Level func() stats.Level + Panicked func() (bool, interface{}) + Record func(ctx context.Context, event stats.Event, status stats.Status, info string) + RecvSize func() uint64 + SendSize func() uint64 + func NewRPCStats() RPCStats + type Taggable interface + SetTag func(key, value string) error + func AsTaggable(i interface{}) Taggable + type TimeoutProvider interface + Timeouts func(ri RPCInfo) Timeouts + type Timeouts interface + ConnectTimeout func() time.Duration + RPCTimeout func() time.Duration + ReadWriteTimeout func() time.Duration + type TraceController struct + func (c *TraceController) Append(col stats.Tracer) + func (c *TraceController) DoFinish(ctx context.Context, ri RPCInfo, err error) + func (c *TraceController) DoStart(ctx context.Context, ri RPCInfo) context.Context + func (c *TraceController) HasTracer() bool
Go to main page