Negotiators library

Library for writing custom plugable negotiators for Yagna Agents.

Roadmap

• Basic Components API
• [x] Support for loading negotiators from shared libraries
• Support for importing negotiators from statically linked libraries (library as Agent's dependency)
• Scoring Proposals
  • Asynchronous negotiation decisions to enable time and Score based negotiations.
  • CompositeComponent can collect Proposals for some period of time and choose the best from them
    • CompositeComponent should be declarative configured in yaml. No support for custom strategies here
    • Components can set time hints, how mush Negotiator should wait before accepting Proposals. (Dynamic waiting time.)
• Advanced components API
  • Pass additional environment info to components
    • Market, Activity, Payment APIs addresses
    • Components path (Nested negotiators can be created)
  • Events notification
    • Proposal rejection
    • Invoice events (Accepted, Rejected, Paid)
    • Control events - interaction ability with components, change/query params and behavior
    • Provider/Requestor predefined events (Activity creation/destruction, Invoice/DebitNote sent)
    • Shutdown
  • Allowing components to read/write files in specified directory (persistence). (This could be useful for storing reputation records)
  • Allow setting some configuration values from code. Merge config loaded from yaml and overriden values from code. (Some values in Provider are set in command line and don't want to move them to config file.)
• [ ] Rewrite shared libraries API to use C abi. (This will make it possible to integrate shared libraries with other languages.)
• Support for Negotiators in binaries with RPC communication.
  • Local negotiator spawned in new process
  • Connect to exisitng negotiator (remote)
• Integrations
  • Use ya-negotiators as Yagna Provider Agent dependency.
  • Use ya-negotiators in yarapi (https://github.com/golemfactory/yarapi)
  • yapapi integration
    • Create python binding of NegotiatorsChain
    • Create MarketStrategy in yapapi using NegotiatorsChain for scoring Offer
    • Rewrite MarketStrategy handling to better match new model
      • Multi-steps negotiations (currently yapapi responds to Proposal once, when it is in draft state and than it immediately proposes Agreement)
      • yapapi negotiation decision is based on results from NegotiatorsChain (not only scoring)
    • Rewrite mid-agreements payments to rust NegotiatorComponent
    • Bind Events and other notification to pass this information to NegotiatorChain
• Testing Framework for components without need to use Agents
  • Multi Provider/Requestor negotiations
  • Recording negotiators' responses for making assertions
  • Implement timeout for test negotiations
  • Break infinite loops (set max number of negotiation steps)
  • Use matcher to check, if Proposals should be sent to all nodes or only to subset of them
  • Predefined testset for testing components in common scenarios
• Example negotiators
  • Builtin negotiators copied from Yagna Provider
  • Example shared library negotiators filtering Nodes by name
  • Simple local reputation
  • Geo-localization components (both Provider/Requestor). Choosing the nearest node
  • Requestor-Provider ping component
  • Simple remote Nodes orchestrator example (choose which Node will pick up Offer)
• Declarative components building blocks
  • NegotiatorsChain component
    • Allow to nest Negotiators
    • Allow to use seperate file descriptor to build the chain - Providers will be able to use predefined components chains or chains created by someone else. This will work like declarative mechanism of implementing components
  • Statistical and analitical components - generate data to use for scoring Offers
  • Expression building blocks
    • Copy-score component - for example: take value named "golem.stats.benchmark" and copy as "scorer.input.benchmark". This component will make connecting incompatibil components possible
    • Expression evaluator - write custom expression based on values passed from previous negotiators to compute score