mirror of
https://github.com/matrix-org/dendrite
synced 2024-10-31 13:09:08 +01:00
6348486a13
This should transactional snapshot isolation for `/sync` etc requests. For now we don't use repeatable read due to some odd test failures with invites.
28 lines
1.1 KiB
Go
28 lines
1.1 KiB
Go
package streams
|
|
|
|
import (
|
|
"context"
|
|
|
|
"github.com/matrix-org/dendrite/syncapi/storage"
|
|
"github.com/matrix-org/dendrite/syncapi/types"
|
|
)
|
|
|
|
type StreamProvider interface {
|
|
Setup(ctx context.Context, snapshot storage.DatabaseTransaction)
|
|
|
|
// Advance will update the latest position of the stream based on
|
|
// an update and will wake callers waiting on StreamNotifyAfter.
|
|
Advance(latest types.StreamPosition)
|
|
|
|
// CompleteSync will update the response to include all updates as needed
|
|
// for a complete sync. It will always return immediately.
|
|
CompleteSync(ctx context.Context, snapshot storage.DatabaseTransaction, req *types.SyncRequest) types.StreamPosition
|
|
|
|
// IncrementalSync will update the response to include all updates between
|
|
// the from and to sync positions. It will always return immediately,
|
|
// making no changes if the range contains no updates.
|
|
IncrementalSync(ctx context.Context, snapshot storage.DatabaseTransaction, req *types.SyncRequest, from, to types.StreamPosition) types.StreamPosition
|
|
|
|
// LatestPosition returns the latest stream position for this stream.
|
|
LatestPosition(ctx context.Context) types.StreamPosition
|
|
}
|