GetHost will return the hostname

GetMethodStatus get method RPC status.

Group get group

MockEvent sends a single event to subscribers.

NewBaseProtocol creates a new BaseProtocol

NewCounterVec create a CounterVec default implementation.

Next returns next service event once received

NotZero asserts that the value is non-zero.

Realize realizes a general struct, described in `obj`, to an object for Golang.

SetLoadbalance sets the loadbalance extension with @name For example: random/round_robin/consistent_hash/least_active/...

Shutdown sets all serving status to NOT_SERVING, and configures the server to ignore all future status changes. This changes serving status for all s

asError uses errors.As to unwrap any error and look for a triple *Error.

AddAttachment adds the specified map to existing attachments in this instance.

CleanAllStatus is used to clean all status

EXPECT returns an object that allows the caller to indicate expected use.

False asserts that "got" is false.

NewBaseExporter creates a new BaseExporter

NewExporter is an absolute function with @customFunc to create a spec exporter

String returns a concise string describing the Event.

WithInterface sets interface param for URL

WithReply creates option with @reply function.

Destroy will destroy the service discovery. If the discovery cannot be destroyed, it will return an error.

Get the application-level services which are mapped to this service

GetTotal gets total.

Method gets @s.methods.

ReplaceParams will replace the URL.params usually it should only be invoked when you want to modify an URL, such as MergeURL

String retuen descriptor

WithAttachments creates option with @attachments.

WithPath set load config path

suiteMethod returns a suitable Rpc methodType

GetFailed gets failed.

Message returns the underlying error message. It may be empty if the original error was created with a status code and a nil error.

RegisterGracefulShutdownCallback registers a protocol-level graceful shutdown callback.

Reset discards the Compressor's internal state, if any, and prepares it to write compressed data to a new sink.

ServeHTTP implements [http.Handler].

Sum calculates the sum of the numbers sent on the stream.

UnExport is to un export an exported service

setHeaderCanonical is a shortcut for Header.Set() which bypasses the CanonicalMIMEHeaderKey operation when we know the key is already in canonical for

ColonSeparatedKey The format is "{interface}:[version]:[group]"

GetPort will return the port.

GetURLStatus get URL RPC status.

IsMatch indicates whether this matcher matches the patterns with request context.

List candidate invoker list for the current Directory. NOTICE: The invoker list returned to the caller may be backed by the same data hold by the curr

PublishConfig will publish the config with the (key, group, value) pair for zk: path is /$(group)/config/$(key) -> value for nacos: group, key -> valu

SetResult sets invoker result.

CountUp returns a stream of the numbers up to the given request.

GetInstances will return all service instances with serviceName

GetLoadbalance finds the loadbalance extension with @name

GetParamInt gets int64 value by @key

GetService gets a service definition by protocol and name

GetSuccessiveRequestFailureCount gets successive request failure count.

MethodName gets RPC invocation method name.

RegisterService register service instance use metadata info

Remove the mapping between application-level service and interface-level service

ActualMethodName gets actual invocation method name. It returns the method name been called if it's a generic call

CloseAndReceive closes the send side of the stream and waits for the response.

GetCacheInvokerMapKey get directory cacheInvokerMap key

GetURL gets base invoker URL

Invokers gets all invokers

IsDestroyed gets destroyed flag

add a metric num to a summary