Skip to content

Commit

Permalink
more work toward chaos testing
Browse files Browse the repository at this point in the history
  • Loading branch information
Jeremy D. Miller authored and Jeremy D. Miller committed Apr 13, 2023
1 parent 1647a6f commit fd0f9b8
Show file tree
Hide file tree
Showing 3 changed files with 64 additions and 64 deletions.
2 changes: 1 addition & 1 deletion src/Testing/ChaosTesting/ChaosDriver.cs
View file
Original file line number Diff line number Diff line change
Expand Up @@ -39,7 +39,7 @@ public abstract class ChaosScript
{
public abstract Task Drive(ChaosDriver driver);

public TimeSpan TimeOut { get; internal set; } = 15.Seconds();
public TimeSpan TimeOut { get; internal set; } = 60.Seconds();

public override string ToString()
{
Expand Down
58 changes: 29 additions & 29 deletions src/Testing/ChaosTesting/ChaosSpecifications.cs
View file
Original file line number Diff line number Diff line change
Expand Up @@ -28,35 +28,35 @@ public static IEnumerable<TransportConfiguration> TransportConfigurations()
ConfigureSender = opts => opts.UseRabbitMq().AutoProvision().UseConventionalRouting()
};

yield return new TransportConfiguration("Rabbit MQ Inline w/ Five Listeners")
{
ConfigureReceiver = opts => opts.UseRabbitMq().AutoProvision().UseConventionalRouting().ConfigureListeners(x => x.ListenerCount(5)),
ConfigureSender = opts => opts.UseRabbitMq().AutoProvision().UseConventionalRouting()
};

yield return new TransportConfiguration("Rabbit MQ Buffered w/ 1 Listener")
{
ConfigureReceiver = opts => opts.UseRabbitMq().AutoProvision().UseConventionalRouting().ConfigureListeners(x => x.BufferedInMemory()),
ConfigureSender = opts => opts.UseRabbitMq().AutoProvision().UseConventionalRouting().ConfigureSenders(x => x.BufferedInMemory())
};

yield return new TransportConfiguration("Rabbit MQ Buffered w/ 5 Listeners")
{
ConfigureReceiver = opts => opts.UseRabbitMq().AutoProvision().UseConventionalRouting().ConfigureListeners(x => x.BufferedInMemory().ListenerCount(5)),
ConfigureSender = opts => opts.UseRabbitMq().AutoProvision().UseConventionalRouting().ConfigureSenders(x => x.BufferedInMemory())
};

yield return new TransportConfiguration("Rabbit MQ Durable w/ 1 Listener")
{
ConfigureReceiver = opts => opts.UseRabbitMq().AutoProvision().UseConventionalRouting().ConfigureListeners(x => x.UseDurableInbox()),
ConfigureSender = opts => opts.UseRabbitMq().AutoProvision().UseConventionalRouting().ConfigureSenders(x => x.UseDurableOutbox())
};

yield return new TransportConfiguration("Rabbit MQ Durable w/ 5 Listeners")
{
ConfigureReceiver = opts => opts.UseRabbitMq().AutoProvision().UseConventionalRouting().ConfigureListeners(x => x.UseDurableInbox().ListenerCount(5)),
ConfigureSender = opts => opts.UseRabbitMq().AutoProvision().UseConventionalRouting().ConfigureSenders(x => x.UseDurableOutbox())
};
// yield return new TransportConfiguration("Rabbit MQ Inline w/ Five Listeners")
// {
// ConfigureReceiver = opts => opts.UseRabbitMq().AutoProvision().UseConventionalRouting().ConfigureListeners(x => x.ListenerCount(5)),
// ConfigureSender = opts => opts.UseRabbitMq().AutoProvision().UseConventionalRouting()
// };
//
// yield return new TransportConfiguration("Rabbit MQ Buffered w/ 1 Listener")
// {
// ConfigureReceiver = opts => opts.UseRabbitMq().AutoProvision().UseConventionalRouting().ConfigureListeners(x => x.BufferedInMemory()),
// ConfigureSender = opts => opts.UseRabbitMq().AutoProvision().UseConventionalRouting().ConfigureSenders(x => x.BufferedInMemory())
// };
//
// yield return new TransportConfiguration("Rabbit MQ Buffered w/ 5 Listeners")
// {
// ConfigureReceiver = opts => opts.UseRabbitMq().AutoProvision().UseConventionalRouting().ConfigureListeners(x => x.BufferedInMemory().ListenerCount(5)),
// ConfigureSender = opts => opts.UseRabbitMq().AutoProvision().UseConventionalRouting().ConfigureSenders(x => x.BufferedInMemory())
// };
//
// yield return new TransportConfiguration("Rabbit MQ Durable w/ 1 Listener")
// {
// ConfigureReceiver = opts => opts.UseRabbitMq().AutoProvision().UseConventionalRouting().ConfigureListeners(x => x.UseDurableInbox()),
// ConfigureSender = opts => opts.UseRabbitMq().AutoProvision().UseConventionalRouting().ConfigureSenders(x => x.UseDurableOutbox())
// };
//
// yield return new TransportConfiguration("Rabbit MQ Durable w/ 5 Listeners")
// {
// ConfigureReceiver = opts => opts.UseRabbitMq().AutoProvision().UseConventionalRouting().ConfigureListeners(x => x.UseDurableInbox().ListenerCount(5)),
// ConfigureSender = opts => opts.UseRabbitMq().AutoProvision().UseConventionalRouting().ConfigureSenders(x => x.UseDurableOutbox())
// };


}
Expand Down
68 changes: 34 additions & 34 deletions src/Testing/ChaosTesting/Scripts/Simplistic.cs
View file
Original file line number Diff line number Diff line change
Expand Up @@ -9,40 +9,40 @@ public override async Task Drive(ChaosDriver driver)
await driver.StartReceiver("one");
await driver.StartSender("one");

await driver.SendMessages("one", 1000);
await driver.SendMessages("one", 293);
}
}

public class ReceiverStartsLater : ChaosScript
{
public override async Task Drive(ChaosDriver driver)
{
await driver.StartSender("one");
await driver.SendMessages("one", 1000);
await Task.Delay(1.Seconds());
await driver.StartReceiver("one");
}
}

public class ReceiverGoesUpAndDown : ChaosScript
{
public ReceiverGoesUpAndDown()
{
TimeOut = 1.Minutes();
}

public override async Task Drive(ChaosDriver driver)
{
await driver.StartSender("one");
await driver.SendMessages("one", 1000);

await driver.StartSender("two");
driver.SendMessagesContinuously("two", 100, 10.Seconds());
await Task.Delay(1.Seconds());
await driver.StartReceiver("one");
await Task.Delay(3.Seconds());
await driver.StopSender("one");

await driver.StartReceiver("two");
}
}
// public class ReceiverStartsLater : ChaosScript
// {
// public override async Task Drive(ChaosDriver driver)
// {
// await driver.StartSender("one");
// await driver.SendMessages("one", 1000);
// await Task.Delay(1.Seconds());
// await driver.StartReceiver("one");
// }
// }
//
// public class ReceiverGoesUpAndDown : ChaosScript
// {
// public ReceiverGoesUpAndDown()
// {
// TimeOut = 1.Minutes();
// }
//
// public override async Task Drive(ChaosDriver driver)
// {
// await driver.StartSender("one");
// await driver.SendMessages("one", 1000);
//
// await driver.StartSender("two");
// driver.SendMessagesContinuously("two", 100, 10.Seconds());
// await Task.Delay(1.Seconds());
// await driver.StartReceiver("one");
// await Task.Delay(3.Seconds());
// await driver.StopSender("one");
//
// await driver.StartReceiver("two");
// }
// }

0 comments on commit fd0f9b8

Please sign in to comment.