package types import ( "context" "time" userapi "github.com/matrix-org/dendrite/userapi/api" "github.com/matrix-org/gomatrixserverlib" "github.com/sirupsen/logrus" ) type SyncRequest struct { Context context.Context Log *logrus.Entry Device *userapi.Device Response *Response Filter gomatrixserverlib.EventFilter Since StreamingToken Limit int Timeout time.Duration WantFullState bool // Updated by the PDU stream. Rooms map[string]string } type StreamProvider interface { Setup() // Advance will update the latest position of the stream based on // an update and will wake callers waiting on StreamNotifyAfter. Advance(latest 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, req *SyncRequest) 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, req *SyncRequest, from, to StreamPosition) StreamPosition // LatestPosition returns the latest stream position for this stream. LatestPosition(ctx context.Context) StreamPosition } type PartitionedStreamProvider interface { Setup() Advance(latest LogPosition) CompleteSync(ctx context.Context, req *SyncRequest) LogPosition IncrementalSync(ctx context.Context, req *SyncRequest, from, to LogPosition) LogPosition LatestPosition(ctx context.Context) LogPosition }