Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

feat(runtime): support for owned shared streams #1483

Merged
merged 3 commits into from
May 3, 2024

Commits on May 1, 2024

  1. feat(runtime): support for owned shared streams

    We added support for shared streams in the controller via a reflector.
    There are only two public interfaces available to thread a stream
    through a controller, `for_shared_stream` and `for_shared_stream_with`.
    
    For non-shared streams, the controller can compose with other types of
    streams that will trigger reconciliation, e.g. streams of owned objects,
    or custom streams that take mappers out-of-band. For parity, the
    controller should expose public interfaces to allow the same for shared
    streams.
    
    This change adds four new interfaces:
    
    * `owns_shared_stream`
    * `owns_shared_stream_with`
    * `watches_shared_stream`
    * `watches_shared_stream_with`
    
    The contract is the same as `for_shared_stream`. Accept a stream of
    `Arc<K>` and turn it into a reconciliation trigger.
    
    Signed-off-by: Matei David <matei.david.35@gmail.com>
    mateiidavid committed May 1, 2024
    Configuration menu
    Copy the full SHA
    c9e8855 View commit details
    Browse the repository at this point in the history

Commits on May 2, 2024

  1. Fix doc code

    Signed-off-by: Matei David <matei.david.35@gmail.com>
    mateiidavid committed May 2, 2024
    Configuration menu
    Copy the full SHA
    b025bb7 View commit details
    Browse the repository at this point in the history

Commits on May 3, 2024

  1. Configuration menu
    Copy the full SHA
    52dba2c View commit details
    Browse the repository at this point in the history