arpc

type ARpcApp interface {
	scene.Application
	RegisterService(handler arpc.Handler) error
}

type Client interface {
	scene.Named
	Logger() logger.ILogger
	Client() *arpc.Client
	Call(method string, req interface{}, rsp interface{}, timeout time.Duration, args ...interface{}) error
	AddConnectedHandler(func(c *arpc.Client))
}

type ClientFactory struct {
	scene.ModuleFactory
	Network string
	Addr    string
	Options []ClientOption
}

type ClientOption func(server Client) error

type ClientProvider scene.IModuleDependencyProvider[Client]

type DiscoverResponse struct {
	Methods map[string][]ServiceInstance `json:"methods"`
}

type NexusClientFactory struct {
	scene.ModuleFactory
	Network string
	Addr    string
	Options []ClientOption
	UseApps []scene.AppInit[ARpcApp]
}

type NexusGateway struct {
	// contains filtered or unexported fields
}

type ProxyRequest struct {
	Method   string          `json:"method"`
	Payload  json.RawMessage `json:"payload"`
	TimeoutM int64           `json:"timeout_ms,omitempty"`
}

type ProxyResponse struct {
	Payload json.RawMessage `json:"payload,omitempty"`
	Error   string          `json:"error,omitempty"`
}

type RegisterMethodRequest struct {
	Method     string            `json:"method"`
	InstanceID string            `json:"instance_id"`
	Metadata   map[string]string `json:"metadata,omitempty"`
}

type RegisterServiceResponse struct {
	InstanceID string `json:"instance_id"`
}

type ServerOption func(server *arpc.Server) error

type ServiceInstance struct {
	InstanceID string            `json:"instance_id"`
	Metadata   map[string]string `json:"metadata,omitempty"`
}