MCPcopy Create free account

hub / github.com/chuangyou/qsf / functions

Functions270 in github.com/chuangyou/qsf

↓ 1 callersMethodTiming
(sampleRate float32, bucket string, d ...time.Duration)
plugin/breaker/panel.go:14
↓ 1 callersMethodUndo
Undo reverts the last Limit() call, returning consumed allowance
plugin/ratelimit/ratelimit.go:66
↓ 1 callersMethodUpdateRate
UpdateRate allows to update the allowed rate
plugin/ratelimit/ratelimit.go:34
↓ 1 callersMethodbreakerFail
(name string)
plugin/breaker/panel.go:131
↓ 1 callersMethodbreakerReady
(name string)
plugin/breaker/panel.go:135
↓ 1 callersMethodbreakerReset
(name string)
plugin/breaker/panel.go:114
↓ 1 callersMethodbreakerTripped
(name string)
plugin/breaker/panel.go:107
↓ 1 callersFunctionclientStreamType
(desc *grpc.StreamDesc)
plugin/prometheus/client_metrics.go:136
↓ 1 callersFunctionextractAddrs
(resp *etcd3.GetResponse)
plugin/loadbalance/registry/etcd/watcher.go:92
↓ 1 callersFunctionfetchPrometheusLines
fetchPrometheusLines does mocked HTTP GET request against real prometheus handler to get the same view that Prometheus would have while scraping this
plugin/prometheus/server_test.go:193
↓ 1 callersMethodhandleSignal
()
server/server.go:160
↓ 1 callersFunctioninitExampleService
(ctx context.Context, mux *runtime.ServeMux, breaker *breaker.Breaker, tracer opentracing.Tracer, grpcMetr
examples/gateway/gateway_example.go:102
↓ 1 callersFunctionnewEtcdWatcher
(key string, cli *etcd3.Client)
plugin/loadbalance/registry/etcd/watcher.go:26
↓ 1 callersFunctionnewOpenTracingClientStream
(cs grpc.ClientStream, method string, desc *grpc.StreamDesc, clientSpan opentracing.Span, otgrpcOpts *options)
plugin/tracing/client.go:131
↓ 1 callersFunctionnewTestStatter
()
plugin/breaker/panel_test.go:81
↓ 1 callersFunctionpreRegisterMethod
preRegisterMethod is invoked on Register of a Server, allowing all gRPC services labels to be pre-populated.
plugin/prometheus/server_metrics.go:172
↓ 1 callersMethodregistry
(registryAddrs []string, serviceName, serviceAddr, serviceNodeId string)
server/server.go:110
↓ 1 callersFunctionremoteCall
()
plugin/breaker/example_test.go:150
↓ 1 callersFunctionrequest_ExampleService_GetExample_0
(ctx context.Context, marshaler runtime.Marshaler, client ExampleServiceClient, req *http.Request, pathParams
examples/pb/example.pb.gw.go:35
↓ 1 callersMethodrunBreakerReset
()
plugin/breaker/client.go:166
↓ 1 callersMethodrunBreakerTripped
()
plugin/breaker/client.go:160
↓ 1 callersFunctionstreamRPCType
(info *grpc.StreamServerInfo)
plugin/prometheus/server_metrics.go:140
↓ 1 callersFunctiontypeFromMethodInfo
(mInfo *grpc.MethodInfo)
plugin/prometheus/util.go:39
MethodAuthFunc
(ctx context.Context)
server/server.go:189
FunctionBenchmarkLimit
--------------------------------------------------------------------
plugin/ratelimit/ratelimit_test.go:120
MethodCloseSend
()
plugin/tracing/client.go:218
MethodCollect
Collect is called by the Prometheus registry when collecting metrics. The implementation sends each collected metric via the provided channel and retu
plugin/prometheus/server_metrics.go:92
MethodCounter
(sampleRate float32, bucket string, n ...int)
plugin/breaker/panel_test.go:97
MethodCounter
(sampleRate float32, bucket string, n ...int)
plugin/breaker/panel.go:142
FunctionCustomHTTPError
(ctx context.Context, _ *runtime.ServeMux, marshaler runtime.Marshaler, w http.ResponseWriter, _ *http.Request
grpc_error/error.go:36
FunctionCustomOtherHTTPError
503=服务不可用,500=服务内部错误,401=未登录,403=禁止访问(可带原因),400=参数错误,429=并发限制,200=OK
grpc_error/error.go:24
MethodDescribe
Describe sends the super-set of all possible descriptors of metrics collected by this Collector to the provided channel and returns once the last desc
plugin/prometheus/client_metrics.go:69
MethodDescribe
Describe sends the super-set of all possible descriptors of metrics collected by this Collector to the provided channel and returns once the last desc
plugin/prometheus/server_metrics.go:79
MethodDescriptor
()
examples/pb/example.pb.go:36
MethodDescriptor
()
examples/pb/example.pb.go:75
FunctionExampleBreaker_events
()
plugin/breaker/example_test.go:81
FunctionExampleHTTPClient
()
plugin/breaker/example_test.go:64
FunctionExampleNewConsecutiveBreaker
()
plugin/breaker/example_test.go:54
FunctionExampleNewThresholdBreaker
()
plugin/breaker/example_test.go:13
FunctionExampleNewThresholdBreaker_manual
()
plugin/breaker/example_test.go:25
FunctionExampleNewThresholdBreaker_timeout
()
plugin/breaker/example_test.go:40
FunctionExamplePanel
()
plugin/breaker/example_test.go:107
FunctionExamplePanel_stats
()
plugin/breaker/example_test.go:130
MethodFail
Fail records a failure in the current bucket.
plugin/breaker/window.go:76
MethodForeachKey
(handler func(key, val string) error)
plugin/tracing/shared.go:32
FunctionForwardResponseFilter
(ctx context.Context, w http.ResponseWriter, resp proto.Message)
examples/gateway/gateway_example.go:127
MethodGauge
(sampleRate float32, bucket string, value ...string)
plugin/breaker/panel_test.go:113
MethodGauge
(sampleRate float32, bucket string, value ...string)
plugin/breaker/panel.go:15
MethodGauge
(sampleRate float32, bucket string, value ...string)
plugin/breaker/panel.go:144
MethodGetExample
(ctx context.Context, request *spb.GetExampleRequest)
examples/server/server_example.go:76
MethodGetExample
(ctx context.Context, in *GetExampleRequest, opts ...grpc.CallOption)
examples/pb/example.pb.go:150
MethodGetExample
(context.Context, *GetExampleRequest)
examples/pb/example.pb.go:161
MethodGetRequestMetadata
(context.Context, ...string)
client/client.go:140
MethodGetRequestMetadata
(ctx context.Context, uri ...string)
client/client.go:150
MethodGetValue
()
examples/pb/example.pb.go:97
FunctionHandleSignal
(httpServer http.Server)
client/client.go:108
MethodHandled
(code codes.Code)
plugin/prometheus/client_reporter.go:41
MethodHead
Head wraps http.Client Head()
plugin/breaker/client.go:117
FunctionIncludingSpans
IncludingSpans binds a IncludeSpanFunc to the options
plugin/tracing/options.go:32
FunctionInternal
500 INTERNAL 服务端内部错误,一般是 BUG
grpc_error/error.go:141
FunctionInvalidArgument
400 INVALID_ARGUMENT 客户端使用了错误的参数
grpc_error/error.go:82
FunctionLogPayloads
LogPayloads returns an Option that tells the OpenTracing instrumentation to try to log application payloads in both directions.
plugin/tracing/options.go:14
FunctionMetaDataJoin
(ctx context.Context, r *http.Request)
examples/gateway/gateway_example.go:124
FunctionNewClient
(config *Config, isGateway bool)
client/client.go:39
FunctionNewHostBasedHTTPClient
NewHostBasedHTTPClient provides a circuit breaker wrapper around http.Client. This client will use one circuit breaker per host parsed from the reques
plugin/breaker/client.go:38
FunctionNewRegistry
(option Option)
plugin/loadbalance/registry/etcd/registry.go:38
FunctionNewResolver
(registryDir, serviceName string, cfg etcd3.Config)
plugin/loadbalance/registry/etcd/resolver.go:18
FunctionNewSevice
(config *Config)
server/server.go:48
FunctionNotFound
404 NotFound 未找到资源
grpc_error/error.go:105
FunctionOpenTracingClientInterceptor
OpenTracingClientInterceptor returns a grpc.UnaryClientInterceptor suitable for use in a grpc.Dial call. For example: conn, err := grpc.Dial( addres
plugin/tracing/client.go:30
FunctionOpenTracingServerInterceptor
OpenTracingServerInterceptor returns a grpc.UnaryServerInterceptor suitable for use in a grpc.NewServer call. For example: s := grpc.NewServer( ...,
plugin/tracing/server.go:27
FunctionOpenTracingStreamClientInterceptor
OpenTracingStreamClientInterceptor returns a grpc.StreamClientInterceptor suitable for use in a grpc.Dial call. The interceptor instruments streaming
plugin/tracing/client.go:92
FunctionOpenTracingStreamServerInterceptor
OpenTracingStreamServerInterceptor returns a grpc.StreamServerInterceptor suitable for use in a grpc.NewServer call. The interceptor instruments strea
plugin/tracing/server.go:89
FunctionPermissionDenied
403 PERMISSION_DENIED 这可能是因为客户端没有权限
grpc_error/error.go:73
MethodPing
(ctx context.Context, ping *pb_testproto.PingRequest)
plugin/prometheus/server_test.go:234
MethodPost
Post wraps http.Client Post()
plugin/breaker/client.go:129
MethodPostForm
PostForm wraps http.Client PostForm()
plugin/breaker/client.go:141
MethodProtoMessage
()
examples/pb/example.pb.go:35
MethodProtoMessage
()
examples/pb/example.pb.go:74
MethodReceivedMessage
()
plugin/prometheus/client_reporter.go:33
MethodRecvMsg
(m interface{})
plugin/prometheus/client_metrics.go:159
MethodRecvMsg
(m interface{})
plugin/prometheus/server_metrics.go:163
MethodRecvMsg
(m interface{})
plugin/tracing/client.go:203
FunctionRegisterExampleServiceHandlerFromEndpoint
RegisterExampleServiceHandlerFromEndpoint is same as RegisterExampleServiceHandler but automatically dials to "endpoint" and closes the connection whe
examples/pb/example.pb.gw.go:50
FunctionRegisterExampleServiceServer
(s *grpc.Server, srv ExampleServiceServer)
examples/pb/example.pb.go:164
MethodRequireTransportSecurity
()
client/client.go:141
MethodRequireTransportSecurity
()
client/client.go:155
MethodReset
Reset resets the count of all buckets.
plugin/breaker/window.go:140
MethodReset
()
examples/pb/example.pb.go:33
MethodReset
()
examples/pb/example.pb.go:72
MethodResolve
Resolve to resolve the service from etcd
plugin/loadbalance/registry/etcd/resolver.go:23
FunctionResourceExhausted
429 RESOURCE_EXHAUSTED 超过资源限额或频率限制
grpc_error/error.go:114
MethodSendMsg
(m interface{})
plugin/prometheus/client_metrics.go:151
MethodSendMsg
(m interface{})
plugin/prometheus/server_metrics.go:155
MethodSendMsg
(m interface{})
plugin/tracing/client.go:195
MethodSentMessage
()
plugin/prometheus/client_reporter.go:37
MethodSetServiceToken
(token string)
client/client.go:147
MethodSetupSuite
()
plugin/prometheus/server_test.go:57
MethodSetupSuite
()
plugin/prometheus/client_test.go:43
MethodSetupTest
()
plugin/prometheus/server_test.go:81
← previousnext →101–200 of 270, ranked by callers