Skip to content

[raft/rid] Add rid raftstore ISAs#1540

Open
MariemBaccari wants to merge 11 commits into
interuss:masterfrom
Orbitalize:add_rid_raftstore
Open

[raft/rid] Add rid raftstore ISAs#1540
MariemBaccari wants to merge 11 commits into
interuss:masterfrom
Orbitalize:add_rid_raftstore

Conversation

@MariemBaccari

@MariemBaccari MariemBaccari commented Jun 16, 2026

Copy link
Copy Markdown
Contributor

#1525 (Generic raftstore) -> #1527 (Base memstore) -> #1529 (Aux memstore) -> #1530 (Snapshots) -> #1534 (Rid memstore) -> #1535 (Correct use of now) -> #1539 (Checkpoint) -> #1542 (Scd memstore) -> #1528 (Add aux Raftstore) ->
#1540 (Add rid Raftstore ISAs)

Implements the rid raftstore ISAs. A follow-up PR will implement subscriptions.
All transaction implementations in identification_service_area_appliers.go are copied from the existing implementation under rid/application/isa.go.

Comment thread pkg/models/models.go
return nil
}

parsed, err := VersionFromString(s)

Copy link
Copy Markdown
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

this will strip time field, is that correct?

Copy link
Copy Markdown
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

VersionFromString repopulates the time field

Comment thread pkg/rid/store/raftstore/identification_service_area.go Outdated
Comment thread pkg/rid/store/raftstore/identification_service_area.go Outdated
Comment thread pkg/rid/application/subscription.go Outdated
var sub *ridmodels.Subscription

_, err := a.store.Transact(ctx, "", nil, func(ctx context.Context, repo repos.Repository) error {
raftResult, err := a.store.Transact(ctx, ridraftstore.UpdateSubscriptionTransaction, s, func(ctx context.Context, repo repos.Repository) error {

Copy link
Copy Markdown
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

for the future, but having raft directly as a consquence is not great for isolation :/

Copy link
Copy Markdown
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I agree, I'm open to any recommendation regarding this design.

@barroco barroco added the dss-raft Relating to the application-layer consensus implemenation based on raft label Jun 17, 2026
@MariemBaccari MariemBaccari force-pushed the add_rid_raftstore branch 9 times, most recently from ddd6502 to dd32866 Compare June 18, 2026 12:59
Comment thread pkg/rid/application/subscription.go Outdated
var sub *ridmodels.Subscription

_, err := a.store.Transact(ctx, "", nil, func(ctx context.Context, repo repos.Repository) error {
raftResult, err := a.store.Transact(ctx, ridraftstore.UpdateSubscriptionTransaction, s, func(ctx context.Context, repo repos.Repository) error {

Copy link
Copy Markdown
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I agree, I'm open to any recommendation regarding this design.

Comment thread pkg/rid/store/raftstore/identitfication_service_area_appliers.go
@MariemBaccari MariemBaccari changed the title [raft/rid] Add rid raftstore [raft/rid] Add rid raftstore ISAs Jun 18, 2026
@MariemBaccari MariemBaccari marked this pull request as ready for review June 18, 2026 13:02
@MariemBaccari MariemBaccari force-pushed the add_rid_raftstore branch 2 times, most recently from d243a12 to a295157 Compare June 18, 2026 13:16
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

dss-raft Relating to the application-layer consensus implemenation based on raft

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants