Versions in this module Expand all Collapse all v1 v1.51.4 Oct 3, 2022 Changes in this version + func SetConfigSelector(state resolver.State, cs ConfigSelector) resolver.State + type ClientInterceptor interface + NewStream func(ctx context.Context, ri RPCInfo, done func(), ...) (ClientStream, error) + type ClientStream interface + CloseSend func() error + Context func() context.Context + Header func() (metadata.MD, error) + RecvMsg func(m interface{}) error + SendMsg func(m interface{}) error + Trailer func() metadata.MD + type ConfigSelector interface + SelectConfig func(RPCInfo) (*RPCConfig, error) + func GetConfigSelector(state resolver.State) ConfigSelector + type RPCConfig struct + Context context.Context + Interceptor ClientInterceptor + MethodConfig serviceconfig.MethodConfig + OnCommitted func() + type RPCInfo struct + Context context.Context + Method string + type SafeConfigSelector struct + func (scs *SafeConfigSelector) SelectConfig(r RPCInfo) (*RPCConfig, error) + func (scs *SafeConfigSelector) UpdateConfigSelector(cs ConfigSelector) + type ServerInterceptor interface + AllowRPC func(ctx context.Context) error
Go to main page