Index (datareplication 1.0.1 API)

A B C D E F G H I J L M N O P S T U V
All Classes All Packages

A

additionalHeaders(HttpHeader...) - Method in class io.datareplication.consumer.feed.FeedConsumer.Builder: Add the given headers to every HTTP request made by this consumer.
additionalHeaders(HttpHeader...) - Method in class io.datareplication.consumer.snapshot.SnapshotConsumer.Builder: Add the given headers to every HTTP request made by this consumer.
append(Entity<FeedEntityHeader>) - Method in interface io.datareplication.producer.feed.FeedEntityRepository: Add an entity to the repository.
append(String) - Method in class io.datareplication.model.HttpHeader: Append a single value to this header.
append(List<String>) - Method in class io.datareplication.model.HttpHeader: Append multiple value to this header.
assignPages() - Method in interface io.datareplication.producer.feed.FeedProducer
assignPagesLimitPerRun(int) - Method in class io.datareplication.producer.feed.FeedProducer.Builder: Set the maximum number of entities to load and assign in a single FeedProducer.assignPages() call.
authorization(Authorization) - Method in class io.datareplication.consumer.feed.FeedConsumer.Builder: Use the given Authorization for every HTTP request made by this consumer.
authorization(Authorization) - Method in class io.datareplication.consumer.snapshot.SnapshotConsumer.Builder: Use the given Authorization for every HTTP request made by this consumer.
authorization(Supplier<Authorization>) - Method in class io.datareplication.consumer.feed.FeedConsumer.Builder: Use the given function to get the Authorization to use for HTTP requests made by this consumer.
authorization(Supplier<Authorization>) - Method in class io.datareplication.consumer.snapshot.SnapshotConsumer.Builder: Use the given function to get the Authorization to use for HTTP requests made by this consumer.
Authorization - Class in io.datareplication.consumer: The value of an HTTP Authorization header.
AUTHORIZATION - Static variable in class io.datareplication.model.HttpHeader

B

basic(String, String) - Static method in class io.datareplication.consumer.Authorization: Create an Authorization using the Basic scheme with the given username and password.
beginning() - Static method in class io.datareplication.consumer.feed.StartFrom
body() - Method in class io.datareplication.model.Entity: The entity's body.
Body - Interface in io.datareplication.model: The Body interface represents a sequence of bytes (usually for an entity or page body) including a length and an HTTP content type.
bodyChunk(ByteBuffer) - Static method in class io.datareplication.consumer.StreamingPage.Chunk: Create a new StreamingPage.Chunk.BodyChunk.
bodyEnd() - Static method in class io.datareplication.consumer.StreamingPage.Chunk: Return a StreamingPage.Chunk.BodyEnd marker.
boundary() - Method in interface io.datareplication.consumer.StreamingPage
boundary() - Method in class io.datareplication.model.Page: The boundary string for the page's multipart representation.
build() - Method in class io.datareplication.consumer.feed.FeedConsumer.Builder: Build a new FeedConsumer with the parameters set on this builder.
build() - Method in class io.datareplication.consumer.snapshot.SnapshotConsumer.Builder: Build a new SnapshotConsumer with the parameters set on this builder.
build() - Method in class io.datareplication.producer.feed.FeedPageProvider.Builder
build() - Method in class io.datareplication.producer.feed.FeedProducer.Builder
build() - Method in class io.datareplication.producer.snapshot.SnapshotProducer.Builder: Build a new SnapshotProducer with the parameters set on this builder.
builder() - Static method in interface io.datareplication.consumer.feed.FeedConsumer: Create a new FeedConsumer.Builder with default settings.
builder() - Static method in interface io.datareplication.consumer.snapshot.SnapshotConsumer: Create a new SnapshotConsumer.Builder with default settings.
builder(FeedEntityRepository, FeedPageMetadataRepository, FeedPageUrlBuilder) - Static method in interface io.datareplication.producer.feed.FeedPageProvider
builder(FeedEntityRepository, FeedPageMetadataRepository, FeedProducerJournalRepository) - Static method in interface io.datareplication.producer.feed.FeedProducer
builder(SnapshotIndexRepository, SnapshotPageRepository, SnapshotPageUrlBuilder) - Static method in interface io.datareplication.producer.snapshot.SnapshotProducer: Create a new SnapshotProducer.Builder with default settings.

C

canEqual(Object) - Method in exception io.datareplication.consumer.ConsumerException.CollectedErrors
canEqual(Object) - Method in exception io.datareplication.consumer.feed.FeedException.ContentIdNotFound
canEqual(Object) - Method in exception io.datareplication.consumer.feed.FeedException.FeedNotOldEnough
canEqual(Object) - Method in class io.datareplication.consumer.feed.StartFrom.Beginning
canEqual(Object) - Method in class io.datareplication.consumer.feed.StartFrom.ContentId
canEqual(Object) - Method in class io.datareplication.consumer.feed.StartFrom.Timestamp
canEqual(Object) - Method in exception io.datareplication.consumer.HttpException.ClientError
canEqual(Object) - Method in exception io.datareplication.consumer.HttpException.InvalidUrl
canEqual(Object) - Method in exception io.datareplication.consumer.HttpException.NetworkError
canEqual(Object) - Method in exception io.datareplication.consumer.HttpException.ServerError
canEqual(Object) - Method in exception io.datareplication.consumer.PageFormatException.InvalidContentType
canEqual(Object) - Method in exception io.datareplication.consumer.PageFormatException.InvalidLastModifiedHeader
canEqual(Object) - Method in exception io.datareplication.consumer.PageFormatException.InvalidLastModifiedHeaderInEntity
canEqual(Object) - Method in exception io.datareplication.consumer.PageFormatException.InvalidMultipart
canEqual(Object) - Method in exception io.datareplication.consumer.PageFormatException.MissingContentIdInEntity
canEqual(Object) - Method in exception io.datareplication.consumer.PageFormatException.MissingContentTypeHeader
canEqual(Object) - Method in exception io.datareplication.consumer.PageFormatException.MissingContentTypeInEntity
canEqual(Object) - Method in exception io.datareplication.consumer.PageFormatException.MissingLastModifiedHeader
canEqual(Object) - Method in exception io.datareplication.consumer.PageFormatException.MissingLastModifiedHeaderInEntity
canEqual(Object) - Method in exception io.datareplication.consumer.PageFormatException.MissingNextLinkHeader
canEqual(Object) - Method in exception io.datareplication.consumer.PageFormatException.MissingOperationTypeInEntity
canEqual(Object) - Method in exception io.datareplication.consumer.PageFormatException.MissingSelfLinkHeader
canEqual(Object) - Method in exception io.datareplication.consumer.PageFormatException.NoBoundaryInContentTypeHeader
canEqual(Object) - Method in exception io.datareplication.consumer.PageFormatException.UnparseableContentTypeHeader
canEqual(Object) - Method in exception io.datareplication.consumer.PageFormatException.UnparseableOperationTypeInEntity
canEqual(Object) - Method in class io.datareplication.consumer.StreamingPage.Chunk.BodyChunk
canEqual(Object) - Method in class io.datareplication.consumer.StreamingPage.Chunk.BodyEnd
canEqual(Object) - Method in class io.datareplication.consumer.StreamingPage.Chunk.Header
canEqual(Object) - Method in class io.datareplication.model.feed.Link.Next
canEqual(Object) - Method in class io.datareplication.model.feed.Link.Prev
canEqual(Object) - Method in class io.datareplication.model.feed.Link.Self
canEqual(Object) - Method in exception io.datareplication.model.snapshot.SnapshotIndex.ParsingException
ClientError(Url, int) - Constructor for exception io.datareplication.consumer.HttpException.ClientError
clock(Clock) - Method in class io.datareplication.producer.feed.FeedProducer.Builder: Use the given Clock when generating timestamps for new entities.
clock(Clock) - Method in class io.datareplication.producer.snapshot.SnapshotProducer.Builder: Use the given Clock when generating timestamps for new entities.
CollectedErrors(List<Throwable>) - Constructor for exception io.datareplication.consumer.ConsumerException.CollectedErrors
ConsumerException - Exception in io.datareplication.consumer
ConsumerException(String) - Constructor for exception io.datareplication.consumer.ConsumerException
ConsumerException(String, Throwable) - Constructor for exception io.datareplication.consumer.ConsumerException
ConsumerException.CollectedErrors - Exception in io.datareplication.consumer
CONTENT_ID - Static variable in class io.datareplication.model.HttpHeader
CONTENT_LENGTH - Static variable in class io.datareplication.model.HttpHeader
CONTENT_TYPE - Static variable in class io.datareplication.model.HttpHeader
contentId() - Method in class io.datareplication.consumer.feed.StartFrom.ContentId
contentId() - Method in class io.datareplication.model.feed.FeedEntityHeader: The entity's content ID.
contentId() - Method in class io.datareplication.producer.feed.FeedEntityRepository.PageAssignment: The entity's content ID.
contentId(ContentId, Instant) - Static method in class io.datareplication.consumer.feed.StartFrom
ContentId - Class in io.datareplication.model.feed: The content ID of a feed entity.
ContentIdNotFound(StartFrom.ContentId, Url, Instant) - Constructor for exception io.datareplication.consumer.feed.FeedException.ContentIdNotFound
contentLength() - Method in interface io.datareplication.model.Body: Return the length of the underlying byte sequence in bytes.
contentLength() - Method in class io.datareplication.producer.feed.FeedEntityRepository.PageAssignment: The entity's body length.
contentLength(long) - Static method in class io.datareplication.model.HttpHeader: Create a Content-Length header.
contentType() - Method in class io.datareplication.consumer.StreamingPage.Chunk.Header: The entity's content type.
contentType() - Method in interface io.datareplication.model.Body: Return the content type of the underlying data.
contentType() - Method in class io.datareplication.producer.feed.FeedPageProvider.HeaderAndContentType
contentType(ContentType) - Static method in class io.datareplication.model.HttpHeader: Create a Content-Type header from the given ContentType.
ContentType - Class in io.datareplication.model: A MIME type as used for an HTTP Content-Type header.
createdAt() - Method in class io.datareplication.model.snapshot.SnapshotIndex: The timestamp of the dataset contained in this snapshot.

D

data() - Method in class io.datareplication.consumer.StreamingPage.Chunk.BodyChunk: The chunk's byte data.
delayErrors(boolean) - Method in class io.datareplication.consumer.snapshot.SnapshotConsumer.Builder: When enabled, collect all errors and raise them at the end after all other pages/entities have been consumed.
delete() - Method in interface io.datareplication.producer.feed.FeedProducerJournalRepository: Delete the currently stored journal state from the repository.
delete(List<PageId>) - Method in interface io.datareplication.producer.feed.FeedPageMetadataRepository
DELETE - io.datareplication.model.feed.OperationType: This entity represents the deletion of a resource.
displayName() - Method in class io.datareplication.model.HttpHeader: The header name with its original capitalization for prettier printing.

E

EMPTY - Static variable in class io.datareplication.model.HttpHeaders: An empty HttpHeaders instance.
entities() - Method in class io.datareplication.model.Page: The list of entities for this page.
Entity<Header extends ToHttpHeaders> - Class in io.datareplication.model: The Entity class represents a feed or snapshot entity.
Entity(Header, Body) - Constructor for class io.datareplication.model.Entity: Create a new entity with empty userData.
Entity(Header, Body, Optional<Object>) - Constructor for class io.datareplication.model.Entity: Creates a new Entity instance.
equals(Object) - Method in class io.datareplication.consumer.Authorization
equals(Object) - Method in exception io.datareplication.consumer.ConsumerException.CollectedErrors
equals(Object) - Method in exception io.datareplication.consumer.feed.FeedException.ContentIdNotFound
equals(Object) - Method in exception io.datareplication.consumer.feed.FeedException.FeedNotOldEnough
equals(Object) - Method in class io.datareplication.consumer.feed.StartFrom.Beginning
equals(Object) - Method in class io.datareplication.consumer.feed.StartFrom.ContentId
equals(Object) - Method in class io.datareplication.consumer.feed.StartFrom.Timestamp
equals(Object) - Method in exception io.datareplication.consumer.HttpException.ClientError
equals(Object) - Method in exception io.datareplication.consumer.HttpException.InvalidUrl
equals(Object) - Method in exception io.datareplication.consumer.HttpException.NetworkError
equals(Object) - Method in exception io.datareplication.consumer.HttpException.ServerError
equals(Object) - Method in exception io.datareplication.consumer.PageFormatException.InvalidContentType
equals(Object) - Method in exception io.datareplication.consumer.PageFormatException.InvalidLastModifiedHeader
equals(Object) - Method in exception io.datareplication.consumer.PageFormatException.InvalidLastModifiedHeaderInEntity
equals(Object) - Method in exception io.datareplication.consumer.PageFormatException.InvalidMultipart
equals(Object) - Method in exception io.datareplication.consumer.PageFormatException.MissingContentIdInEntity
equals(Object) - Method in exception io.datareplication.consumer.PageFormatException.MissingContentTypeHeader
equals(Object) - Method in exception io.datareplication.consumer.PageFormatException.MissingContentTypeInEntity
equals(Object) - Method in exception io.datareplication.consumer.PageFormatException.MissingLastModifiedHeader
equals(Object) - Method in exception io.datareplication.consumer.PageFormatException.MissingLastModifiedHeaderInEntity
equals(Object) - Method in exception io.datareplication.consumer.PageFormatException.MissingNextLinkHeader
equals(Object) - Method in exception io.datareplication.consumer.PageFormatException.MissingOperationTypeInEntity
equals(Object) - Method in exception io.datareplication.consumer.PageFormatException.MissingSelfLinkHeader
equals(Object) - Method in exception io.datareplication.consumer.PageFormatException.NoBoundaryInContentTypeHeader
equals(Object) - Method in exception io.datareplication.consumer.PageFormatException.UnparseableContentTypeHeader
equals(Object) - Method in exception io.datareplication.consumer.PageFormatException.UnparseableOperationTypeInEntity
equals(Object) - Method in class io.datareplication.consumer.StreamingPage.Chunk.BodyChunk
equals(Object) - Method in class io.datareplication.consumer.StreamingPage.Chunk.BodyEnd
equals(Object) - Method in class io.datareplication.consumer.StreamingPage.Chunk.Header
equals(Object) - Method in class io.datareplication.model.ContentType
equals(Object) - Method in class io.datareplication.model.Entity
equals(Object) - Method in class io.datareplication.model.feed.ContentId
equals(Object) - Method in class io.datareplication.model.feed.FeedEntityHeader
equals(Object) - Method in class io.datareplication.model.feed.FeedPageHeader
equals(Object) - Method in class io.datareplication.model.feed.Link.Next
equals(Object) - Method in class io.datareplication.model.feed.Link.Prev
equals(Object) - Method in class io.datareplication.model.feed.Link.Self
equals(Object) - Method in class io.datareplication.model.HttpHeader
equals(Object) - Method in class io.datareplication.model.HttpHeaders
equals(Object) - Method in class io.datareplication.model.Page
equals(Object) - Method in class io.datareplication.model.PageId
equals(Object) - Method in class io.datareplication.model.snapshot.SnapshotEntityHeader
equals(Object) - Method in class io.datareplication.model.snapshot.SnapshotId
equals(Object) - Method in class io.datareplication.model.snapshot.SnapshotIndex
equals(Object) - Method in exception io.datareplication.model.snapshot.SnapshotIndex.ParsingException
equals(Object) - Method in class io.datareplication.model.snapshot.SnapshotPageHeader
equals(Object) - Method in class io.datareplication.model.Url
equals(Object) - Method in class io.datareplication.producer.feed.FeedEntityRepository.PageAssignment
equals(Object) - Method in class io.datareplication.producer.feed.FeedPageMetadataRepository.PageMetadata
equals(Object) - Method in class io.datareplication.producer.feed.FeedPageProvider.HeaderAndContentType
equals(Object) - Method in class io.datareplication.producer.feed.FeedProducerJournalRepository.JournalState
exceptions() - Method in exception io.datareplication.consumer.ConsumerException.CollectedErrors
extraHeaders() - Method in class io.datareplication.model.feed.FeedEntityHeader: Additional unstructured headers.
extraHeaders() - Method in class io.datareplication.model.feed.FeedPageHeader: Additional unstructured headers.
extraHeaders() - Method in class io.datareplication.model.snapshot.SnapshotEntityHeader: Additional unstructured headers.
extraHeaders() - Method in class io.datareplication.model.snapshot.SnapshotPageHeader: Additional unstructured headers.

F

FeedConsumer - Interface in io.datareplication.consumer.feed: An interface for consuming a Feed provided by the FeedProducer.
FeedConsumer.Builder - Class in io.datareplication.consumer.feed: A builder for FeedConsumer.
FeedEntityHeader - Class in io.datareplication.model.feed: This class represents the headers of a feed entity.
FeedEntityHeader(Instant, OperationType, ContentId) - Constructor for class io.datareplication.model.feed.FeedEntityHeader
FeedEntityHeader(Instant, OperationType, ContentId, HttpHeaders) - Constructor for class io.datareplication.model.feed.FeedEntityHeader: Creates a new FeedEntityHeader instance.
FeedEntityRepository - Interface in io.datareplication.producer.feed: Repository to store feed entities and what page they are assigned to.
FeedEntityRepository.PageAssignment - Class in io.datareplication.producer.feed: A subset of this repository's fields that are sufficient for operations that don't need the entity body.
FeedException - Exception in io.datareplication.consumer.feed
FeedException.ContentIdNotFound - Exception in io.datareplication.consumer.feed
FeedException.FeedNotOldEnough - Exception in io.datareplication.consumer.feed
FeedNotOldEnough(Url, Instant, Instant) - Constructor for exception io.datareplication.consumer.feed.FeedException.FeedNotOldEnough
FeedPageHeader - Class in io.datareplication.model.feed: This class represents the headers of a snapshot page.
FeedPageHeader(Instant, Link.Self, Optional<Link.Prev>, Optional<Link.Next>) - Constructor for class io.datareplication.model.feed.FeedPageHeader
FeedPageHeader(Instant, Link.Self, Optional<Link.Prev>, Optional<Link.Next>, HttpHeaders) - Constructor for class io.datareplication.model.feed.FeedPageHeader: Creates a new FeedPageHeader instance.
FeedPageMetadataRepository - Interface in io.datareplication.producer.feed
FeedPageMetadataRepository.PageMetadata - Class in io.datareplication.producer.feed
FeedPageProvider - Interface in io.datareplication.producer.feed
FeedPageProvider.Builder - Class in io.datareplication.producer.feed
FeedPageProvider.HeaderAndContentType - Class in io.datareplication.producer.feed
FeedPageUrlBuilder - Interface in io.datareplication.producer.feed
FeedProducer - Interface in io.datareplication.producer.feed
FeedProducer.Builder - Class in io.datareplication.producer.feed
FeedProducerJournalRepository - Interface in io.datareplication.producer.feed: Repository to store rollback information for the feed producer.
FeedProducerJournalRepository.JournalState - Class in io.datareplication.producer.feed: The rollback information stored by the feed producer to allow clean rollbacks.
fromBytes(byte[]) - Static method in interface io.datareplication.model.Body: Return a Body containing the bytes of the given byte array with the default content-type application/octet-stream
fromBytes(byte[], ContentType) - Static method in interface io.datareplication.model.Body: Return a Body containing the bytes of the given byte array.
fromBytesUnsafe(byte[]) - Static method in interface io.datareplication.model.Body: Return a Body containing the bytes of the given byte array with the default content-type application/octet-stream
fromBytesUnsafe(byte[], ContentType) - Static method in interface io.datareplication.model.Body: Return a Body containing the bytes of the given byte array.
fromJson(Body) - Static method in class io.datareplication.model.snapshot.SnapshotIndex: Parses Tries to parse JSON a SnapshotIndex
fromUtf8(String) - Static method in interface io.datareplication.model.Body: Return a Body over the bytes of the given String encoded as UTF-8 with the default content type text/plain; charset=utf-8.
fromUtf8(String, ContentType) - Static method in interface io.datareplication.model.Body: Return a Body over the bytes of the given String encoded as UTF-8.

G

generation() - Method in class io.datareplication.producer.feed.FeedPageMetadataRepository.PageMetadata
get() - Method in interface io.datareplication.producer.feed.FeedProducerJournalRepository: Get the currently stored journal state from the repository.
get(PageId) - Method in interface io.datareplication.producer.feed.FeedEntityRepository: Load all entities whose FeedEntityRepository.PageAssignment.pageId() field is set to the given page.
get(PageId) - Method in interface io.datareplication.producer.feed.FeedPageMetadataRepository
get(String) - Method in class io.datareplication.model.HttpHeaders
getPageAssignments(PageId) - Method in interface io.datareplication.producer.feed.FeedEntityRepository: Load all entities whose FeedEntityRepository.PageAssignment.pageId() field is set to the given page.
getUnassigned(int) - Method in interface io.datareplication.producer.feed.FeedEntityRepository: Load all entities whose FeedEntityRepository.PageAssignment.pageId() field is empty.
getWithoutNextLink() - Method in interface io.datareplication.producer.feed.FeedPageMetadataRepository

H

hashCode() - Method in class io.datareplication.consumer.Authorization
hashCode() - Method in exception io.datareplication.consumer.ConsumerException.CollectedErrors
hashCode() - Method in exception io.datareplication.consumer.feed.FeedException.ContentIdNotFound
hashCode() - Method in exception io.datareplication.consumer.feed.FeedException.FeedNotOldEnough
hashCode() - Method in class io.datareplication.consumer.feed.StartFrom.Beginning
hashCode() - Method in class io.datareplication.consumer.feed.StartFrom.ContentId
hashCode() - Method in class io.datareplication.consumer.feed.StartFrom.Timestamp
hashCode() - Method in exception io.datareplication.consumer.HttpException.ClientError
hashCode() - Method in exception io.datareplication.consumer.HttpException.InvalidUrl
hashCode() - Method in exception io.datareplication.consumer.HttpException.NetworkError
hashCode() - Method in exception io.datareplication.consumer.HttpException.ServerError
hashCode() - Method in exception io.datareplication.consumer.PageFormatException.InvalidContentType
hashCode() - Method in exception io.datareplication.consumer.PageFormatException.InvalidLastModifiedHeader
hashCode() - Method in exception io.datareplication.consumer.PageFormatException.InvalidLastModifiedHeaderInEntity
hashCode() - Method in exception io.datareplication.consumer.PageFormatException.InvalidMultipart
hashCode() - Method in exception io.datareplication.consumer.PageFormatException.MissingContentIdInEntity
hashCode() - Method in exception io.datareplication.consumer.PageFormatException.MissingContentTypeHeader
hashCode() - Method in exception io.datareplication.consumer.PageFormatException.MissingContentTypeInEntity
hashCode() - Method in exception io.datareplication.consumer.PageFormatException.MissingLastModifiedHeader
hashCode() - Method in exception io.datareplication.consumer.PageFormatException.MissingLastModifiedHeaderInEntity
hashCode() - Method in exception io.datareplication.consumer.PageFormatException.MissingNextLinkHeader
hashCode() - Method in exception io.datareplication.consumer.PageFormatException.MissingOperationTypeInEntity
hashCode() - Method in exception io.datareplication.consumer.PageFormatException.MissingSelfLinkHeader
hashCode() - Method in exception io.datareplication.consumer.PageFormatException.NoBoundaryInContentTypeHeader
hashCode() - Method in exception io.datareplication.consumer.PageFormatException.UnparseableContentTypeHeader
hashCode() - Method in exception io.datareplication.consumer.PageFormatException.UnparseableOperationTypeInEntity
hashCode() - Method in class io.datareplication.consumer.StreamingPage.Chunk.BodyChunk
hashCode() - Method in class io.datareplication.consumer.StreamingPage.Chunk.BodyEnd
hashCode() - Method in class io.datareplication.consumer.StreamingPage.Chunk.Header
hashCode() - Method in class io.datareplication.model.ContentType
hashCode() - Method in class io.datareplication.model.Entity
hashCode() - Method in class io.datareplication.model.feed.ContentId
hashCode() - Method in class io.datareplication.model.feed.FeedEntityHeader
hashCode() - Method in class io.datareplication.model.feed.FeedPageHeader
hashCode() - Method in class io.datareplication.model.feed.Link.Next
hashCode() - Method in class io.datareplication.model.feed.Link.Prev
hashCode() - Method in class io.datareplication.model.feed.Link.Self
hashCode() - Method in class io.datareplication.model.HttpHeader
hashCode() - Method in class io.datareplication.model.HttpHeaders
hashCode() - Method in class io.datareplication.model.Page
hashCode() - Method in class io.datareplication.model.PageId
hashCode() - Method in class io.datareplication.model.snapshot.SnapshotEntityHeader
hashCode() - Method in class io.datareplication.model.snapshot.SnapshotId
hashCode() - Method in class io.datareplication.model.snapshot.SnapshotIndex
hashCode() - Method in exception io.datareplication.model.snapshot.SnapshotIndex.ParsingException
hashCode() - Method in class io.datareplication.model.snapshot.SnapshotPageHeader
hashCode() - Method in class io.datareplication.model.Url
hashCode() - Method in class io.datareplication.producer.feed.FeedEntityRepository.PageAssignment
hashCode() - Method in class io.datareplication.producer.feed.FeedPageMetadataRepository.PageMetadata
hashCode() - Method in class io.datareplication.producer.feed.FeedPageProvider.HeaderAndContentType
hashCode() - Method in class io.datareplication.producer.feed.FeedProducerJournalRepository.JournalState
header() - Method in class io.datareplication.consumer.StreamingPage.Chunk.Header: The entity's headers.
header() - Method in interface io.datareplication.consumer.StreamingPage
header() - Method in class io.datareplication.model.Entity: The entity's headers.
header() - Method in class io.datareplication.model.Page: The page's headers.
header() - Method in class io.datareplication.producer.feed.FeedPageProvider.HeaderAndContentType
header(EntityHeader, ContentType) - Static method in class io.datareplication.consumer.StreamingPage.Chunk: Create a new StreamingPage.Chunk.Header.
HeaderAndContentType(FeedPageHeader, ContentType) - Constructor for class io.datareplication.producer.feed.FeedPageProvider.HeaderAndContentType
HttpException - Exception in io.datareplication.consumer
HttpException.ClientError - Exception in io.datareplication.consumer
HttpException.InvalidUrl - Exception in io.datareplication.consumer
HttpException.NetworkError - Exception in io.datareplication.consumer
HttpException.ServerError - Exception in io.datareplication.consumer
HttpHeader - Class in io.datareplication.model: An HTTP header consisting of a name and one or more values.
HttpHeaders - Class in io.datareplication.model: A collection of multiple HttpHeader objects.

I

id() - Method in class io.datareplication.model.snapshot.SnapshotIndex: The ID of the snapshot.
InvalidContentType(String) - Constructor for exception io.datareplication.consumer.PageFormatException.InvalidContentType
InvalidLastModifiedHeader(String, Throwable) - Constructor for exception io.datareplication.consumer.PageFormatException.InvalidLastModifiedHeader
InvalidLastModifiedHeaderInEntity(int, String, Throwable) - Constructor for exception io.datareplication.consumer.PageFormatException.InvalidLastModifiedHeaderInEntity
InvalidMultipart(Throwable) - Constructor for exception io.datareplication.consumer.PageFormatException.InvalidMultipart
InvalidUrl(Url, Throwable) - Constructor for exception io.datareplication.consumer.HttpException.InvalidUrl
io.datareplication.consumer - package io.datareplication.consumer
io.datareplication.consumer.feed - package io.datareplication.consumer.feed
io.datareplication.consumer.snapshot - package io.datareplication.consumer.snapshot: The snapshot consumer downloads and parses a snapshot into a stream of entities.
io.datareplication.model - package io.datareplication.model
io.datareplication.model.feed - package io.datareplication.model.feed
io.datareplication.model.snapshot - package io.datareplication.model.snapshot
io.datareplication.producer.feed - package io.datareplication.producer.feed: The feed producer builds a linear feed from incoming entities across multiple distributed producer instances.
io.datareplication.producer.snapshot - package io.datareplication.producer.snapshot: The snapshot producer creates snapshot pages and the matching snapshot index from a stream of entities and saves them in user-provided repositories.
isEmpty() - Method in class io.datareplication.model.HttpHeaders
iterator() - Method in class io.datareplication.model.HttpHeaders: Iterate over the headers in this object.

J

JournalState(List<PageId>, PageId, Optional<PageId>) - Constructor for class io.datareplication.producer.feed.FeedProducerJournalRepository.JournalState: Creates a new JournalState instance.

L

LAST_MODIFIED - Static variable in class io.datareplication.model.HttpHeader
lastModified() - Method in class io.datareplication.model.feed.FeedEntityHeader: The entity's last modified Instant.
lastModified() - Method in class io.datareplication.model.feed.FeedPageHeader: The page's timestamp.
lastModified() - Method in class io.datareplication.producer.feed.FeedEntityRepository.PageAssignment: The entity's last-modified timestamp.
lastModified() - Method in class io.datareplication.producer.feed.FeedPageMetadataRepository.PageMetadata
lastModified(Instant) - Static method in class io.datareplication.model.HttpHeader: Create a Last-Modified header from the given Instant.
latestPageId() - Method in interface io.datareplication.producer.feed.FeedPageProvider
Link - Class in io.datareplication.model.feed: Represents the link from a feed page.
LINK - Static variable in class io.datareplication.model.HttpHeader
Link.Next - Class in io.datareplication.model.feed
Link.Prev - Class in io.datareplication.model.feed
Link.Self - Class in io.datareplication.model.feed
loadSnapshotIndex(Url) - Method in interface io.datareplication.consumer.snapshot.SnapshotConsumer: Download and parse the snapshot index at the given URL.

M

maxBytesPerPage(long) - Method in class io.datareplication.producer.feed.FeedProducer.Builder: Set the maximum bytes per page.
maxBytesPerPage(long) - Method in class io.datareplication.producer.snapshot.SnapshotProducer.Builder: Set the maximum bytes per page.
maxEntitiesPerPage(long) - Method in class io.datareplication.producer.feed.FeedProducer.Builder: Set the maximum entities per page.
maxEntitiesPerPage(long) - Method in class io.datareplication.producer.snapshot.SnapshotProducer.Builder: Set the maximum entities per page.
MissingContentIdInEntity(int) - Constructor for exception io.datareplication.consumer.PageFormatException.MissingContentIdInEntity
MissingContentTypeHeader(HttpHeaders) - Constructor for exception io.datareplication.consumer.PageFormatException.MissingContentTypeHeader
MissingContentTypeInEntity(int) - Constructor for exception io.datareplication.consumer.PageFormatException.MissingContentTypeInEntity
MissingLastModifiedHeader(HttpHeaders) - Constructor for exception io.datareplication.consumer.PageFormatException.MissingLastModifiedHeader
MissingLastModifiedHeaderInEntity(int) - Constructor for exception io.datareplication.consumer.PageFormatException.MissingLastModifiedHeaderInEntity
MissingNextLinkHeader(HttpHeaders) - Constructor for exception io.datareplication.consumer.PageFormatException.MissingNextLinkHeader
MissingOperationTypeInEntity(int) - Constructor for exception io.datareplication.consumer.PageFormatException.MissingOperationTypeInEntity
MissingSelfLinkHeader(HttpHeaders) - Constructor for exception io.datareplication.consumer.PageFormatException.MissingSelfLinkHeader

N

name() - Method in class io.datareplication.model.HttpHeader: The normalized header name for case-insensitive comparisons.
nameEquals(String) - Method in class io.datareplication.model.HttpHeader: Return true if the given header name refers to the same header as this one.
networkConcurrency(int) - Method in class io.datareplication.consumer.snapshot.SnapshotConsumer.Builder: Set the maximum number of pages to download concurrently.
NetworkError(Url, Throwable) - Constructor for exception io.datareplication.consumer.HttpException.NetworkError
newInputStream() - Method in interface io.datareplication.model.Body: Create a new InputStream pointing to the start of the underlying byte sequence.
newLatestPage() - Method in class io.datareplication.producer.feed.FeedProducerJournalRepository.JournalState: ID of the latest feed page when the active transaction completes.
newPages() - Method in class io.datareplication.producer.feed.FeedProducerJournalRepository.JournalState: List of IDs of pages that were created by the currently active transaction.
next() - Method in class io.datareplication.model.feed.FeedPageHeader: The URL of the immediately next (i.e.
next() - Method in class io.datareplication.producer.feed.FeedPageMetadataRepository.PageMetadata
next(Url) - Static method in class io.datareplication.model.feed.Link
NoBoundaryInContentTypeHeader(String) - Constructor for exception io.datareplication.consumer.PageFormatException.NoBoundaryInContentTypeHeader
numberOfBytes() - Method in class io.datareplication.producer.feed.FeedPageMetadataRepository.PageMetadata
numberOfEntities() - Method in class io.datareplication.producer.feed.FeedPageMetadataRepository.PageMetadata

O

of(HttpHeader...) - Static method in class io.datareplication.model.HttpHeaders: Create a new HttpHeaders from the given headers.
of(Iterable<HttpHeader>) - Static method in class io.datareplication.model.HttpHeaders: Create a new HttpHeaders from the given headers.
of(String) - Static method in class io.datareplication.model.ContentType
of(String) - Static method in class io.datareplication.model.feed.ContentId
of(String) - Static method in class io.datareplication.model.PageId
of(String) - Static method in class io.datareplication.model.snapshot.SnapshotId
of(String) - Static method in class io.datareplication.model.Url
of(String, String) - Static method in class io.datareplication.consumer.Authorization: Creates a new Authorization instance.
of(String, String) - Static method in class io.datareplication.model.HttpHeader: Create a header with the given name and single value.
of(String, List<String>) - Static method in class io.datareplication.model.HttpHeader: Create a header with the given name and values.
of(Iterator<HttpHeader>) - Static method in class io.datareplication.model.HttpHeaders: Create a new HttpHeaders from the given headers.
OPERATION_TYPE - Static variable in class io.datareplication.model.HttpHeader
operationType() - Method in class io.datareplication.model.feed.FeedEntityHeader: The kind of operation this entity represents.
OperationType - Enum in io.datareplication.model.feed: A feed entity's operation type.
originalLastModified() - Method in class io.datareplication.producer.feed.FeedEntityRepository.PageAssignment: The old last-modified timestamp in case the entity is pushed backwards.

P

page(PageId) - Method in interface io.datareplication.producer.feed.FeedPageProvider
Page<PageHeader extends ToHttpHeaders,EntityHeader extends ToHttpHeaders> - Class in io.datareplication.model: The Page class represents a complete feed or snapshot page, both on the producer and consumer side.
Page(PageHeader, String, List<Entity<EntityHeader>>) - Constructor for class io.datareplication.model.Page
PageAssignment(ContentId, Instant, Optional<Instant>, long, Optional<PageId>) - Constructor for class io.datareplication.producer.feed.FeedEntityRepository.PageAssignment: Creates a new PageAssignment instance.
PageFormatException - Exception in io.datareplication.consumer
PageFormatException.InvalidContentType - Exception in io.datareplication.consumer
PageFormatException.InvalidLastModifiedHeader - Exception in io.datareplication.consumer
PageFormatException.InvalidLastModifiedHeaderInEntity - Exception in io.datareplication.consumer
PageFormatException.InvalidMultipart - Exception in io.datareplication.consumer
PageFormatException.MissingContentIdInEntity - Exception in io.datareplication.consumer
PageFormatException.MissingContentTypeHeader - Exception in io.datareplication.consumer
PageFormatException.MissingContentTypeInEntity - Exception in io.datareplication.consumer
PageFormatException.MissingLastModifiedHeader - Exception in io.datareplication.consumer
PageFormatException.MissingLastModifiedHeaderInEntity - Exception in io.datareplication.consumer
PageFormatException.MissingNextLinkHeader - Exception in io.datareplication.consumer
PageFormatException.MissingOperationTypeInEntity - Exception in io.datareplication.consumer
PageFormatException.MissingSelfLinkHeader - Exception in io.datareplication.consumer
PageFormatException.NoBoundaryInContentTypeHeader - Exception in io.datareplication.consumer
PageFormatException.UnparseableContentTypeHeader - Exception in io.datareplication.consumer
PageFormatException.UnparseableOperationTypeInEntity - Exception in io.datareplication.consumer
pageHeader(PageId) - Method in interface io.datareplication.producer.feed.FeedPageProvider
pageId() - Method in class io.datareplication.producer.feed.FeedEntityRepository.PageAssignment: The ID of the page that the entity is assigned to.
pageId() - Method in class io.datareplication.producer.feed.FeedPageMetadataRepository.PageMetadata
PageId - Class in io.datareplication.model: The ID of a feed or snapshot page.
PageMetadata(PageId, Instant, Optional<PageId>, Optional<PageId>, long, int, int) - Constructor for class io.datareplication.producer.feed.FeedPageMetadataRepository.PageMetadata
pages() - Method in class io.datareplication.model.snapshot.SnapshotIndex: The URLs of the pages that make up this snapshot.
pageUrl(PageId) - Method in interface io.datareplication.producer.feed.FeedPageUrlBuilder
pageUrl(SnapshotId, PageId) - Method in interface io.datareplication.producer.snapshot.SnapshotPageUrlBuilder: Return a URL for snapshot page identified by snapshot and page IDs.
parameters() - Method in class io.datareplication.consumer.Authorization: The parameters for the authorization.
ParsingException(Throwable) - Constructor for exception io.datareplication.model.snapshot.SnapshotIndex.ParsingException
PATCH - io.datareplication.model.feed.OperationType: This entity represents a partial update of some resource.
prev() - Method in class io.datareplication.model.feed.FeedPageHeader: The URL of the immediately previous (i.e.
prev() - Method in class io.datareplication.producer.feed.FeedPageMetadataRepository.PageMetadata
prev(Url) - Static method in class io.datareplication.model.feed.Link
previousLatestPage() - Method in class io.datareplication.producer.feed.FeedProducerJournalRepository.JournalState: ID of the latest feed page at the start of the transaction, if different from FeedProducerJournalRepository.JournalState.newLatestPage().
produce(Flow.Publisher<Entity<SnapshotEntityHeader>>) - Method in interface io.datareplication.producer.snapshot.SnapshotProducer: Produces a snapshot of given stream of entities.
publish(Entity<FeedEntityHeader>) - Method in interface io.datareplication.producer.feed.FeedProducer
publish(OperationType, Body) - Method in interface io.datareplication.producer.feed.FeedProducer
publish(OperationType, Body, Object) - Method in interface io.datareplication.producer.feed.FeedProducer
PUT - io.datareplication.model.feed.OperationType: This entity represents a complete replacement of some resource.

S

save(SnapshotId, PageId, Page<SnapshotPageHeader, SnapshotEntityHeader>) - Method in interface io.datareplication.producer.snapshot.SnapshotPageRepository: Save the given snapshot page in the repository.
save(SnapshotIndex) - Method in interface io.datareplication.producer.snapshot.SnapshotIndexRepository: Save the given SnapshotIndex in the repository.
save(FeedProducerJournalRepository.JournalState) - Method in interface io.datareplication.producer.feed.FeedProducerJournalRepository: Save the given journal state to the repository.
save(List<FeedPageMetadataRepository.PageMetadata>) - Method in interface io.datareplication.producer.feed.FeedPageMetadataRepository
savePageAssignments(List<FeedEntityRepository.PageAssignment>) - Method in interface io.datareplication.producer.feed.FeedEntityRepository: Update the given entities.
scheme() - Method in class io.datareplication.consumer.Authorization: Specifies the authentication scheme, which determines the format of the Authorization.parameters() field.
self() - Method in class io.datareplication.model.feed.FeedPageHeader: The stable URL of this page itself.
self(Url) - Static method in class io.datareplication.model.feed.Link
ServerError(Url, int) - Constructor for exception io.datareplication.consumer.HttpException.ServerError
SnapshotConsumer - Interface in io.datareplication.consumer.snapshot: A SnapshotConsumer allows downloading and consuming the entities of a snapshot, given the URL of a snapshot index.
SnapshotConsumer.Builder - Class in io.datareplication.consumer.snapshot: A builder for SnapshotConsumer.
SnapshotEntityHeader - Class in io.datareplication.model.snapshot: This class represents the headers of a snapshot entity.
SnapshotEntityHeader() - Constructor for class io.datareplication.model.snapshot.SnapshotEntityHeader
SnapshotEntityHeader(HttpHeaders) - Constructor for class io.datareplication.model.snapshot.SnapshotEntityHeader: Creates a new SnapshotEntityHeader instance.
SnapshotId - Class in io.datareplication.model.snapshot: The ID of a snapshot.
SnapshotIndex - Class in io.datareplication.model.snapshot: The index of a snapshot.
SnapshotIndex(SnapshotId, Instant, List<Url>) - Constructor for class io.datareplication.model.snapshot.SnapshotIndex
SnapshotIndex.ParsingException - Exception in io.datareplication.model.snapshot: ParsingException occurs when a SnapshotIndex can't be parsed
SnapshotIndexRepository - Interface in io.datareplication.producer.snapshot: Repository to store a SnapshotIndex created by the snapshot consumer.
SnapshotPageHeader - Class in io.datareplication.model.snapshot: This class represents the headers of a snapshot page.
SnapshotPageHeader() - Constructor for class io.datareplication.model.snapshot.SnapshotPageHeader
SnapshotPageHeader(HttpHeaders) - Constructor for class io.datareplication.model.snapshot.SnapshotPageHeader: Creates a new SnapshotPageHeader instance.
SnapshotPageRepository - Interface in io.datareplication.producer.snapshot: Repository to store snapshot pages produced by SnapshotProducer.
SnapshotPageUrlBuilder - Interface in io.datareplication.producer.snapshot: An interface to build an HTTP url for a specific snapshot page.
SnapshotProducer - Interface in io.datareplication.producer.snapshot: A SnapshotProducer produces a snapshot index, which consists of a list of pages which contain all entities.
SnapshotProducer.Builder - Class in io.datareplication.producer.snapshot: A builder for SnapshotProducer.
StartFrom - Class in io.datareplication.consumer.feed
StartFrom.Beginning - Class in io.datareplication.consumer.feed
StartFrom.ContentId - Class in io.datareplication.consumer.feed
StartFrom.Timestamp - Class in io.datareplication.consumer.feed
stream() - Method in class io.datareplication.model.HttpHeaders: Return a Stream over the headers in this object.
streamEntities(SnapshotIndex) - Method in interface io.datareplication.consumer.snapshot.SnapshotConsumer: Return a stream of entities in the given SnapshotIndex.
streamEntities(Url, StartFrom) - Method in interface io.datareplication.consumer.feed.FeedConsumer: Stream the entities of the feed starting from the given Url.
StreamingPage<PageHeader extends ToHttpHeaders,EntityHeader extends ToHttpHeaders> - Interface in io.datareplication.consumer: The StreamingPage interface represents a streaming feed or snapshot page.
StreamingPage.Chunk<EntityHeader> - Class in io.datareplication.consumer: An element in a StreamingPage.
StreamingPage.Chunk.BodyChunk<EntityHeader> - Class in io.datareplication.consumer: A block of data of the current entity's body.
StreamingPage.Chunk.BodyEnd<EntityHeader> - Class in io.datareplication.consumer: Represents the end of an entity.
StreamingPage.Chunk.Header<EntityHeader> - Class in io.datareplication.consumer: Represents the start of an entity.
streamPages(SnapshotIndex) - Method in interface io.datareplication.consumer.snapshot.SnapshotConsumer: Return a stream of pages in the given SnapshotIndex.
streamPages(Url, StartFrom) - Method in interface io.datareplication.consumer.feed.FeedConsumer: Stream the feed pages starting from the given Url.

T

timestamp() - Method in class io.datareplication.consumer.feed.StartFrom.ContentId
timestamp() - Method in class io.datareplication.consumer.feed.StartFrom.Timestamp
timestamp(Instant) - Static method in class io.datareplication.consumer.feed.StartFrom
toBytes() - Method in interface io.datareplication.model.Body: Return this byte sequence as a byte array.
toCompleteEntities() - Method in interface io.datareplication.consumer.StreamingPage: Wrap this page in a stream of complete Entity objects.
toCompletePage() - Method in interface io.datareplication.consumer.StreamingPage: Fully download this page and return a Page of its entities.
toHeader() - Method in class io.datareplication.consumer.Authorization: Return this Authorization as an HttpHeader.
toHttpHeaders() - Method in interface io.datareplication.model.Body: Return the Content-Length and Content-Type headers for this Body.
toHttpHeaders() - Method in class io.datareplication.model.Entity: Return all headers for this entity.
toHttpHeaders() - Method in class io.datareplication.model.feed.FeedEntityHeader
toHttpHeaders() - Method in class io.datareplication.model.feed.FeedPageHeader
toHttpHeaders() - Method in class io.datareplication.model.HttpHeaders
toHttpHeaders() - Method in class io.datareplication.model.snapshot.SnapshotEntityHeader
toHttpHeaders() - Method in class io.datareplication.model.snapshot.SnapshotPageHeader
toHttpHeaders() - Method in interface io.datareplication.model.ToHttpHeaders: Return HTTP headers for this object.
toHttpHeaders() - Method in class io.datareplication.producer.feed.FeedPageProvider.HeaderAndContentType
ToHttpHeaders - Interface in io.datareplication.model: The ToHttpHeaders interface allows extracting HTTP for an object.
toJson() - Method in class io.datareplication.model.snapshot.SnapshotIndex: Converts this Snapshot instance to a Body
toMultipartBody() - Method in class io.datareplication.model.Page: Return the body of this page as a multipart document.
toString() - Method in class io.datareplication.consumer.Authorization
toString() - Method in class io.datareplication.consumer.feed.StartFrom.Beginning
toString() - Method in class io.datareplication.consumer.feed.StartFrom.ContentId
toString() - Method in class io.datareplication.consumer.feed.StartFrom.Timestamp
toString() - Method in class io.datareplication.consumer.StreamingPage.Chunk.BodyChunk
toString() - Method in class io.datareplication.consumer.StreamingPage.Chunk.BodyEnd
toString() - Method in class io.datareplication.consumer.StreamingPage.Chunk.Header
toString() - Method in class io.datareplication.model.ContentType
toString() - Method in class io.datareplication.model.Entity
toString() - Method in class io.datareplication.model.feed.ContentId
toString() - Method in class io.datareplication.model.feed.FeedEntityHeader
toString() - Method in class io.datareplication.model.feed.FeedPageHeader
toString() - Method in class io.datareplication.model.feed.Link.Next
toString() - Method in class io.datareplication.model.feed.Link.Prev
toString() - Method in class io.datareplication.model.feed.Link.Self
toString() - Method in enum io.datareplication.model.feed.OperationType
toString() - Method in class io.datareplication.model.HttpHeader
toString() - Method in class io.datareplication.model.HttpHeaders
toString() - Method in class io.datareplication.model.Page
toString() - Method in class io.datareplication.model.PageId
toString() - Method in class io.datareplication.model.snapshot.SnapshotEntityHeader
toString() - Method in class io.datareplication.model.snapshot.SnapshotId
toString() - Method in class io.datareplication.model.snapshot.SnapshotIndex
toString() - Method in class io.datareplication.model.snapshot.SnapshotPageHeader
toString() - Method in class io.datareplication.model.Url
toString() - Method in class io.datareplication.producer.feed.FeedEntityRepository.PageAssignment
toString() - Method in class io.datareplication.producer.feed.FeedPageMetadataRepository.PageMetadata
toString() - Method in class io.datareplication.producer.feed.FeedPageProvider.HeaderAndContentType
toString() - Method in class io.datareplication.producer.feed.FeedProducerJournalRepository.JournalState
toUtf8() - Method in interface io.datareplication.model.Body: Decode this byte sequence as UTF-8.

U

UnparseableContentTypeHeader(String) - Constructor for exception io.datareplication.consumer.PageFormatException.UnparseableContentTypeHeader
UnparseableContentTypeHeader(String, Throwable) - Constructor for exception io.datareplication.consumer.PageFormatException.UnparseableContentTypeHeader
UnparseableOperationTypeInEntity(Integer, String, Throwable) - Constructor for exception io.datareplication.consumer.PageFormatException.UnparseableOperationTypeInEntity
update(HttpHeader...) - Method in class io.datareplication.model.HttpHeaders: Return a new HttpHeaders with the given headers updated.
update(Iterable<HttpHeader>) - Method in class io.datareplication.model.HttpHeaders: Return a new HttpHeaders with the given headers updated.
update(Iterator<HttpHeader>) - Method in class io.datareplication.model.HttpHeaders: Return a new HttpHeaders with the given headers updated.
Url - Class in io.datareplication.model: A URL.
userData() - Method in class io.datareplication.model.Entity: An optional piece of user-specified metadata.

V

value() - Method in class io.datareplication.model.ContentType
value() - Method in class io.datareplication.model.feed.ContentId
value() - Method in class io.datareplication.model.feed.Link.Next
value() - Method in class io.datareplication.model.feed.Link.Prev
value() - Method in class io.datareplication.model.feed.Link.Self
value() - Method in class io.datareplication.model.PageId
value() - Method in class io.datareplication.model.snapshot.SnapshotId
value() - Method in class io.datareplication.model.Url
valueOf(String) - Static method in enum io.datareplication.model.feed.OperationType: Returns the enum constant of this type with the specified name.
values() - Static method in enum io.datareplication.model.feed.OperationType: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Method in class io.datareplication.model.HttpHeader

A B C D E F G H I J L M N O P S T U V
All Classes All Packages