rpc_client

type Directory interface {
	ListProviderUrls(serviceName string) []*config.URL
	LookupProvider(serviceName string, url *config.URL) (*transport.Provider, error)
	InvalidProvider(serviceNmae string, url *config.URL) error
	DeleteProvider(serviceNmae string, url *config.URL) error
	// contains filtered or unexported methods
}

type FailFastClusterInvoker struct {
	Directory
	Next    framework.Invoker
	LB      slb.LoadBalance
	Retries int32
}

type GenericService struct {
	Invoke func(ctx context.Context, methodName string, args map[string]interface{}) (interface{}, error) `rpc:"$invoke"`
}

type MethodSpecial struct {
	MethodName    string
	Async         bool
	OneWay        bool
	Timeout       int
	LoadBalance   string
	HashArgsIndex string
}

type ProviderInvoker struct {
}

type ReferConfig struct {
	//是否泛化
	Generic    bool
	Retries    int32
	SerialType serializations.SERIALIZATION

	Fallback      map[string]interface{}
	JavaClassName string
	Version       string
	Group         string
	Timeout       time.Duration
	LoadBalance   string

	HashNodes     int
	HashArgsIndex string

	UniqueMetaName    string
	UniqueServiceName string

	//ipv4:port
	TargetAddress []string

	MethodSpecials []*MethodSpecial
	IsInit         bool
	// contains filtered or unexported fields
}

type RpcConsumer interface {
	ConsumerClassName() string
}

type RpcConsumerFunc func() string