A B C D E F G L M N O P S T
All Classes All Packages

A

AccessTokenProvider - Interface in org.zalando.nakadiproducer

afterBaseline(Connection) - Method in interface org.zalando.nakadiproducer.NakadiProducerFlywayCallback

Runs after the baseline task executes.

afterClean(Connection) - Method in interface org.zalando.nakadiproducer.NakadiProducerFlywayCallback

Runs after the clean task executes.

afterEachMigrate(Connection, MigrationInfo) - Method in interface org.zalando.nakadiproducer.NakadiProducerFlywayCallback

Runs after each migration script is executed.

afterEachUndo(Connection, MigrationInfo) - Method in interface org.zalando.nakadiproducer.NakadiProducerFlywayCallback

Runs after each migration script is undone.

afterInfo(Connection) - Method in interface org.zalando.nakadiproducer.NakadiProducerFlywayCallback

Runs after the info task executes.

afterMigrate(Connection) - Method in interface org.zalando.nakadiproducer.NakadiProducerFlywayCallback

Runs after the migrate task executes.

afterRepair(Connection) - Method in interface org.zalando.nakadiproducer.NakadiProducerFlywayCallback

Runs after the repair task executes.

afterUndo(Connection) - Method in interface org.zalando.nakadiproducer.NakadiProducerFlywayCallback

Runs after the undo task executes.

afterValidate(Connection) - Method in interface org.zalando.nakadiproducer.NakadiProducerFlywayCallback

Runs after the validate task executes.

B

beforeBaseline(Connection) - Method in interface org.zalando.nakadiproducer.NakadiProducerFlywayCallback

Runs before the baseline task executes.

beforeClean(Connection) - Method in interface org.zalando.nakadiproducer.NakadiProducerFlywayCallback

Runs before the clean task executes.

beforeEachMigrate(Connection, MigrationInfo) - Method in interface org.zalando.nakadiproducer.NakadiProducerFlywayCallback

Runs before each migration script is executed.

beforeEachUndo(Connection, MigrationInfo) - Method in interface org.zalando.nakadiproducer.NakadiProducerFlywayCallback

Runs before each migration script is undone.

beforeInfo(Connection) - Method in interface org.zalando.nakadiproducer.NakadiProducerFlywayCallback

Runs before the info task executes.

beforeMigrate(Connection) - Method in interface org.zalando.nakadiproducer.NakadiProducerFlywayCallback

Runs before the migrate task executes.

beforeRepair(Connection) - Method in interface org.zalando.nakadiproducer.NakadiProducerFlywayCallback

Runs before the repair task executes.

beforeUndo(Connection) - Method in interface org.zalando.nakadiproducer.NakadiProducerFlywayCallback

Runs before the undo task executes.

beforeValidate(Connection) - Method in interface org.zalando.nakadiproducer.NakadiProducerFlywayCallback

Runs before the validate task executes.

C

createFilteredSnapshotEvents(String, String) - Method in class org.zalando.nakadiproducer.snapshots.impl.SnapshotEventCreationEndpoint

D

delete(EventLog) - Method in class org.zalando.nakadiproducer.eventlog.impl.EventLogRepositoryImpl

deleteAll() - Method in class org.zalando.nakadiproducer.eventlog.impl.EventLogRepositoryImpl

E

EnableNakadiProducer - Annotation Type in org.zalando.nakadiproducer

Deprecated.

This annotation has no effect anymore and will be removed in the next major release

eventLogRepository(NamedParameterJdbcTemplate) - Method in class org.zalando.nakadiproducer.NakadiProducerAutoConfiguration

EventLogRepositoryImpl - Class in org.zalando.nakadiproducer.eventlog.impl

EventLogRepositoryImpl(NamedParameterJdbcTemplate) - Constructor for class org.zalando.nakadiproducer.eventlog.impl.EventLogRepositoryImpl

eventLogWriter(EventLogRepository, ObjectMapper, FlowIdComponent) - Method in class org.zalando.nakadiproducer.NakadiProducerAutoConfiguration

eventTransmissionScheduler(EventTransmitter, boolean) - Method in class org.zalando.nakadiproducer.NakadiProducerAutoConfiguration

EventTransmissionScheduler - Class in org.zalando.nakadiproducer

EventTransmissionScheduler(EventTransmitter, boolean) - Constructor for class org.zalando.nakadiproducer.EventTransmissionScheduler

eventTransmissionService(EventLogRepository, NakadiPublishingClient, ObjectMapper, int, int) - Method in class org.zalando.nakadiproducer.NakadiProducerAutoConfiguration

eventTransmitter(EventTransmissionService) - Method in class org.zalando.nakadiproducer.NakadiProducerAutoConfiguration

F

findByLockedByAndLockedUntilGreaterThan(String, Instant) - Method in class org.zalando.nakadiproducer.eventlog.impl.EventLogRepositoryImpl

findOne(Integer) - Method in class org.zalando.nakadiproducer.eventlog.impl.EventLogRepositoryImpl

flowIdComponent() - Method in class org.zalando.nakadiproducer.NakadiProducerAutoConfiguration

flywayMigrator() - Method in class org.zalando.nakadiproducer.NakadiProducerAutoConfiguration

FlywayMigrator - Class in org.zalando.nakadiproducer

FlywayMigrator() - Constructor for class org.zalando.nakadiproducer.FlywayMigrator

G

getAccessToken() - Method in interface org.zalando.nakadiproducer.AccessTokenProvider

getSupportedEventTypes() - Method in class org.zalando.nakadiproducer.snapshots.impl.SnapshotEventCreationEndpoint

getXFlowIdKey() - Method in class org.zalando.nakadiproducer.flowid.TracerFlowIdComponent

getXFlowIdValue() - Method in class org.zalando.nakadiproducer.flowid.NoopFlowIdComponent

getXFlowIdValue() - Method in class org.zalando.nakadiproducer.flowid.TracerFlowIdComponent

L

lockSomeMessages(String, Instant, Instant) - Method in class org.zalando.nakadiproducer.eventlog.impl.EventLogRepositoryImpl

M

migrateFlyway() - Method in class org.zalando.nakadiproducer.FlywayMigrator

N

NakadiProducerAutoConfiguration - Class in org.zalando.nakadiproducer

NakadiProducerAutoConfiguration() - Constructor for class org.zalando.nakadiproducer.NakadiProducerAutoConfiguration

NakadiProducerFlywayCallback - Interface in org.zalando.nakadiproducer

This is the main callback interface that should be implemented to get access to flyway lifecycle notifications.

NakadiProducerFlywayDataSource - Annotation Type in org.zalando.nakadiproducer

Qualifier annotation for a DataSource to be used by nakadi-producer's Flyway instance.

NoopFlowIdComponent - Class in org.zalando.nakadiproducer.flowid

NoopFlowIdComponent() - Constructor for class org.zalando.nakadiproducer.flowid.NoopFlowIdComponent

O

org.zalando.nakadiproducer - package org.zalando.nakadiproducer

org.zalando.nakadiproducer.eventlog.impl - package org.zalando.nakadiproducer.eventlog.impl

org.zalando.nakadiproducer.flowid - package org.zalando.nakadiproducer.flowid

org.zalando.nakadiproducer.snapshots.impl - package org.zalando.nakadiproducer.snapshots.impl

P

persist(Collection<EventLog>) - Method in class org.zalando.nakadiproducer.eventlog.impl.EventLogRepositoryImpl

persist(EventLog) - Method in class org.zalando.nakadiproducer.eventlog.impl.EventLogRepositoryImpl

S

sendEventsIfSchedulingEnabled() - Method in class org.zalando.nakadiproducer.EventTransmissionScheduler

snapshotCreationService(Optional<List<SnapshotEventGenerator>>, EventLogWriter) - Method in class org.zalando.nakadiproducer.NakadiProducerAutoConfiguration

snapshotEventCreationEndpoint(SnapshotCreationService, FlowIdComponent) - Method in class org.zalando.nakadiproducer.NakadiProducerAutoConfiguration

SnapshotEventCreationEndpoint - Class in org.zalando.nakadiproducer.snapshots.impl

SnapshotEventCreationEndpoint(SnapshotCreationService, FlowIdComponent) - Constructor for class org.zalando.nakadiproducer.snapshots.impl.SnapshotEventCreationEndpoint

SnapshotEventCreationEndpoint.SnapshotReport - Class in org.zalando.nakadiproducer.snapshots.impl

SnapshotReport() - Constructor for class org.zalando.nakadiproducer.snapshots.impl.SnapshotEventCreationEndpoint.SnapshotReport

startTraceIfNoneExists() - Method in class org.zalando.nakadiproducer.flowid.NoopFlowIdComponent

startTraceIfNoneExists() - Method in class org.zalando.nakadiproducer.flowid.TracerFlowIdComponent

T

TracerFlowIdComponent - Class in org.zalando.nakadiproducer.flowid

TracerFlowIdComponent(Tracer) - Constructor for class org.zalando.nakadiproducer.flowid.TracerFlowIdComponent

A B C D E F G L M N O P S T
All Classes All Packages