mirror of
https://github.com/matrix-org/dendrite.git
synced 2026-01-17 02:53:11 -06:00
478579eea1
Pulls in upstream latest changes from [dendrite-fork ](https://github.com/HereNotThere/dendrite)to subtree at servers/dendrite here. Co-authored-by: Tak Wai Wong <64229756+tak-hntlabs@users.noreply.github.com> Co-authored-by: Tak Wai Wong <tak@hntlabs.com> Co-authored-by: John Terzis <john@hntlabs.com>
29 lines
1.1 KiB
Go
29 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
|
|
}
|