SyncService class base

com.atproto.sync.*

Constructors

SyncService.new(ServiceContext _ctx)

Properties

hashCode int
The hash code for this object.
no setterinherited
runtimeType Type
A representation of the runtime type of the object.
no setterinherited

Methods

getBlob({required String did, required String cid, Map<String, String>? $headers, Map<String, String>? $unknown}) Future<XRPCResponse<Uint8List>>
Get a blob associated with a given account. Returns the full blob as originally uploaded. Does not require auth; implemented by PDS.
getBlocks({required String did, required List<String> cids, Map<String, String>? $headers, Map<String, String>? $unknown}) Future<XRPCResponse<Uint8List>>
Get data blocks from a given repo, by CID. For example, intermediate MST nodes, or records. Does not require auth; implemented by PDS.
getCheckout({required String did, Map<String, String>? $headers, Map<String, String>? $unknown}) Future<XRPCResponse<Uint8List>>
DEPRECATED - please use com.atproto.sync.getRepo instead
getHead({required String did, Map<String, String>? $headers, Map<String, String>? $unknown}) Future<XRPCResponse<SyncGetHeadOutput>>
DEPRECATED - please use com.atproto.sync.getLatestCommit instead
getHostStatus({required String hostname, Map<String, String>? $headers, Map<String, String>? $unknown}) Future<XRPCResponse<SyncGetHostStatusOutput>>
Returns information about a specified upstream host, as consumed by the server. Implemented by relays.
getLatestCommit({required String did, Map<String, String>? $headers, Map<String, String>? $unknown}) Future<XRPCResponse<SyncGetLatestCommitOutput>>
Get the current commit CID & revision of the specified repo. Does not require auth.
getRecord({required String did, required String collection, required String rkey, Map<String, String>? $headers, Map<String, String>? $unknown}) Future<XRPCResponse<Uint8List>>
Get data blocks needed to prove the existence or non-existence of record in the current version of repo. Does not require auth.
getRepo({required String did, String? since, Map<String, String>? $headers, Map<String, String>? $unknown}) Future<XRPCResponse<Uint8List>>
Download a repository export as CAR file. Optionally only a 'diff' since a previous revision. Does not require auth; implemented by PDS.
getRepoStatus({required String did, Map<String, String>? $headers, Map<String, String>? $unknown}) Future<XRPCResponse<SyncGetRepoStatusOutput>>
Get the hosting status for a repository, on this server. Expected to be implemented by PDS and Relay.
listBlobs({required String did, String? since, int? limit, String? cursor, Map<String, String>? $headers, Map<String, String>? $unknown}) Future<XRPCResponse<SyncListBlobsOutput>>
List blob CIDs for an account, since some repo revision. Does not require auth; implemented by PDS.
listHosts({int? limit, String? cursor, Map<String, String>? $headers, Map<String, String>? $unknown}) Future<XRPCResponse<SyncListHostsOutput>>
Enumerates upstream hosts (eg, PDS or relay instances) that this service consumes from. Implemented by relays.
listRepos({int? limit, String? cursor, Map<String, String>? $headers, Map<String, String>? $unknown}) Future<XRPCResponse<SyncListReposOutput>>
Enumerates all the DID, rev, and commit CID for all repos hosted by this service. Does not require auth; implemented by PDS and Relay.
listReposByCollection({required String collection, int? limit, String? cursor, Map<String, String>? $headers, Map<String, String>? $unknown}) Future<XRPCResponse<SyncListReposByCollectionOutput>>
Enumerates all the DIDs which have records with the given collection NSID.
noSuchMethod(Invocation invocation) → dynamic
Invoked when a nonexistent method or property is accessed.
inherited
notifyOfUpdate({required String hostname, Map<String, String>? $headers, Map<String, String>? $unknown}) Future<XRPCResponse<EmptyData>>
Notify a crawling service of a recent update, and that crawling should resume. Intended use is after a gap between repo stream events caused the crawling service to disconnect. Does not require auth; implemented by Relay. DEPRECATED: just use com.atproto.sync.requestCrawl
requestCrawl({required String hostname, Map<String, String>? $headers, Map<String, String>? $unknown}) Future<XRPCResponse<EmptyData>>
Request a service to persistently crawl hosted repos. Expected use is new PDS instances declaring their existence to Relays. Does not require auth.
subscribeRepos({int? cursor}) Future<XRPCResponse<Subscription<Uint8List>>>
Repository event stream, aka Firehose endpoint. Outputs repo commits with diff data, and identity update events, for all repositories on the current server. See the atproto specifications for details around stream sequencing, repo versioning, CAR diff format, and more. Public and does not require auth; implemented by PDS and Relay.
toString() String
A string representation of this object.
inherited

Operators

operator ==(Object other) bool
The equality operator.
inherited