Package io.github.ghkdqhrbals.redisstreamcoordinator

Ignored tests

• RedisCoordinatorStateStoreIntegrationTest. redis store rejects stale snapshot writes()
• RedisCoordinatorStateStoreIntegrationTest. redis store writes one metadata hash key()
• RedisCoordinatorStateStoreIntegrationTest. redis stream provisioning creates consumer groups for created and scaled shard versions()
• RedisStreamProvisioningIntegrationTest. coordinator provisions Redis consumer groups on create and scale()
• RedisStreamProvisioningIntegrationTest. monitoring exposes shard offsets lag and paged stream messages()
• RedisStreamProvisioningIntegrationTest. stream provisioner is idempotent for existing Redis consumer groups()
• RedisStreamProvisioningIntegrationTest. stream provisioner retry succeeds after partial Redis failure leaves existing groups()

Classes