C D F G I M N O R S T Z

C

close() - Method in class de.zalando.paradox.nakadi.consumer.partitioned.zk.ZKLeaderConsumerPartitionCoordinator

close() - Method in class de.zalando.paradox.nakadi.consumer.partitioned.zk.ZKSimpleConsumerPartitionCoordinator

ConsumerPartitionRebalanceStrategy - Interface in de.zalando.paradox.nakadi.consumer.partitioned.zk

ConsumerPartitionRebalanceStrategy.ResultCallback - Interface in de.zalando.paradox.nakadi.consumer.partitioned.zk

D

de.zalando.paradox.nakadi.consumer.partitioned.zk - package de.zalando.paradox.nakadi.consumer.partitioned.zk

F

finished(EventTypePartition) - Method in class de.zalando.paradox.nakadi.consumer.partitioned.zk.ZKLeaderConsumerPartitionCoordinator

G

getCreated() - Method in class de.zalando.paradox.nakadi.consumer.partitioned.zk.ZKMember

getCurator() - Method in class de.zalando.paradox.nakadi.consumer.partitioned.zk.ZKHolder

getLeaderInfoPath(EventTypePartition) - Method in class de.zalando.paradox.nakadi.consumer.partitioned.zk.ZKConsumerPartitionLeader

getLeaderSelectorPath(EventTypePartition) - Method in class de.zalando.paradox.nakadi.consumer.partitioned.zk.ZKConsumerPartitionLeader

getMemberId() - Method in class de.zalando.paradox.nakadi.consumer.partitioned.zk.ZKMember

getOrderedMembersIds(Map<String, ZKMember>) - Method in interface de.zalando.paradox.nakadi.consumer.partitioned.zk.ZKLeaderConsumerPartitionRebalanceStrategy.MembersOrdering

I

init() - Method in class de.zalando.paradox.nakadi.consumer.partitioned.zk.ZKHolder

init() - Method in class de.zalando.paradox.nakadi.consumer.partitioned.zk.ZKLeaderConsumerPartitionCoordinator

init() - Method in class de.zalando.paradox.nakadi.consumer.partitioned.zk.ZKSimpleConsumerPartitionCoordinator

M

MEMBERS_ID_ORDER - Static variable in class de.zalando.paradox.nakadi.consumer.partitioned.zk.ZKMembersOrderings

N

NEWEST_MEMBERS - Static variable in class de.zalando.paradox.nakadi.consumer.partitioned.zk.ZKMembersOrderings

newPathChildrenCache(CuratorFramework, String) - Method in class de.zalando.paradox.nakadi.consumer.partitioned.zk.ZKGroupMember

O

OLDEST_MEMBERS - Static variable in class de.zalando.paradox.nakadi.consumer.partitioned.zk.ZKMembersOrderings

R

rebalance(EventType, ConsumerPartitionRebalanceStrategy.ResultCallback) - Method in interface de.zalando.paradox.nakadi.consumer.partitioned.zk.ConsumerPartitionRebalanceStrategy

rebalance(EventTypePartitions, Collection<NakadiPartition>) - Method in class de.zalando.paradox.nakadi.consumer.partitioned.zk.ZKLeaderConsumerPartitionCoordinator

rebalance(EventType, ConsumerPartitionRebalanceStrategy.ResultCallback) - Method in class de.zalando.paradox.nakadi.consumer.partitioned.zk.ZKLeaderConsumerPartitionRebalanceStrategy

rebalance(EventTypePartitions, Collection<NakadiPartition>) - Method in class de.zalando.paradox.nakadi.consumer.partitioned.zk.ZKSimpleConsumerPartitionCoordinator

rebalancePartitions(EventType, Collection<NakadiPartition>, Collection<NakadiPartition>) - Method in interface de.zalando.paradox.nakadi.consumer.partitioned.zk.ConsumerPartitionRebalanceStrategy.ResultCallback

S

setCurrentMembers(EventType, Map<String, ZKMember>) - Method in interface de.zalando.paradox.nakadi.consumer.partitioned.zk.ConsumerPartitionRebalanceStrategy

setCurrentMembers(EventType, Map<String, ZKMember>) - Method in class de.zalando.paradox.nakadi.consumer.partitioned.zk.ZKLeaderConsumerPartitionRebalanceStrategy

setNakadiPartitions(EventType, Collection<NakadiPartition>) - Method in interface de.zalando.paradox.nakadi.consumer.partitioned.zk.ConsumerPartitionRebalanceStrategy

setNakadiPartitions(EventType, Collection<NakadiPartition>) - Method in class de.zalando.paradox.nakadi.consumer.partitioned.zk.ZKLeaderConsumerPartitionRebalanceStrategy

start() - Method in class de.zalando.paradox.nakadi.consumer.partitioned.zk.ZKGroupMember

T

toString() - Method in class de.zalando.paradox.nakadi.consumer.partitioned.zk.ZKMember

Z

ZKConsumerPartitionLeader - Class in de.zalando.paradox.nakadi.consumer.partitioned.zk

ZKGroupMember - Class in de.zalando.paradox.nakadi.consumer.partitioned.zk

Based on org.apache.curator:curator-recipes:2.9.1 behaviour.

ZKGroupMember(CuratorFramework, String, String) - Constructor for class de.zalando.paradox.nakadi.consumer.partitioned.zk.ZKGroupMember

ZKGroupMember(CuratorFramework, String, String, byte[]) - Constructor for class de.zalando.paradox.nakadi.consumer.partitioned.zk.ZKGroupMember

ZKGroupMember(CuratorFramework, String, String, byte[], PathChildrenCacheListener) - Constructor for class de.zalando.paradox.nakadi.consumer.partitioned.zk.ZKGroupMember

ZKHolder - Class in de.zalando.paradox.nakadi.consumer.partitioned.zk

ZKHolder(String, String, Integer) - Constructor for class de.zalando.paradox.nakadi.consumer.partitioned.zk.ZKHolder

ZKLeaderConsumerPartitionCoordinator - Class in de.zalando.paradox.nakadi.consumer.partitioned.zk

ZKLeaderConsumerPartitionCoordinator(ZKHolder, String, List<EventErrorHandler>) - Constructor for class de.zalando.paradox.nakadi.consumer.partitioned.zk.ZKLeaderConsumerPartitionCoordinator

ZKLeaderConsumerPartitionRebalanceStrategy - Class in de.zalando.paradox.nakadi.consumer.partitioned.zk

ZKLeaderConsumerPartitionRebalanceStrategy(ZKMember) - Constructor for class de.zalando.paradox.nakadi.consumer.partitioned.zk.ZKLeaderConsumerPartitionRebalanceStrategy

ZKLeaderConsumerPartitionRebalanceStrategy(ZKMember, ZKLeaderConsumerPartitionRebalanceStrategy.MembersOrdering) - Constructor for class de.zalando.paradox.nakadi.consumer.partitioned.zk.ZKLeaderConsumerPartitionRebalanceStrategy

ZKLeaderConsumerPartitionRebalanceStrategy.MembersOrdering - Interface in de.zalando.paradox.nakadi.consumer.partitioned.zk

ZKMember - Class in de.zalando.paradox.nakadi.consumer.partitioned.zk

ZKMembersOrderings - Class in de.zalando.paradox.nakadi.consumer.partitioned.zk

ZKSimpleConsumerPartitionCoordinator - Class in de.zalando.paradox.nakadi.consumer.partitioned.zk

ZKSimpleConsumerPartitionCoordinator(ZKHolder, String, List<EventErrorHandler>) - Constructor for class de.zalando.paradox.nakadi.consumer.partitioned.zk.ZKSimpleConsumerPartitionCoordinator

C D F G I M N O R S T Z