ReubenBond on 3.4.1
Try to limit forwarding when a … (compare)
ReubenBond on master
Try to limit forwarding when a … (compare)
Client = new ClientBuilder()
.UseCosmosDBGatewayListProvider(options =>
{
options.AccountEndpoint = "---";
options.AccountKey = "---";
})
.Configure<ClusterOptions>(options =>
{
options.ClusterId = "Test1";
options.ServiceId = "HelloWorld";
})
.Configure<GatewayOptions>(d => d.GatewayListRefreshPeriod = TimeSpan.FromSeconds(5))
.ConfigureLogging(logging => logging.AddConsole())
.AddSimpleMessageStreamProvider(Constants.GuildInfoStreamProvider)
.Build();
var guildProvider = actorComponent.Client.GetStreamProvider(Constants.GuildInfoStreamProvider);
var guildChanged = guildProvider.GetStream<PlayerGuildChangedMsg>(Guid.Empty, info.id);
var guildChangedSubEvent = await guildChanged.SubscribeAsync((msg, token) => GuildChangedCallback(session, msg,db));
ISiloHostBuilder builder = new SiloHostBuilder()
.AddCosmosDBGrainStorage("Profile",options =>
{
options.Client = DatabaseClient.Core;
options.CanCreateResources = true;
})
.AddCosmosDBGrainStorage("PubSubStore",options =>
{
options.Client = DatabaseClient.Core;
})
.UseCosmosDBMembership(options =>
{
options.Client = DatabaseClient.Core;
options.CanCreateResources = true;
})
.Configure<ClusterOptions>(options =>
{
options.ClusterId = "Test1";
options.ServiceId = "HelloWorld";
})
.Configure<EndpointOptions>(options =>
{
options.AdvertisedIPAddress = IPAddress.Loopback;
options.SiloPort = siloPort;
options.GatewayPort = gatewayPort;
})
.ConfigureServices(collection =>
{
collection.AddSingleton(DatabaseClient);
})
.AddSimpleMessageStreamProvider(Constants.GuildInfoStreamProvider)
.ConfigureApplicationParts(parts => parts.AddApplicationPart(typeof(StateCode).Assembly).WithReferences())
.ConfigureLogging(logging => logging.AddConsole());
public class PlayerGuildChangedMsg
{
public long GuildId;
}
if(SkipStorage) { return; }
.
true
in k8s and you shouldn't have any negative implications because of that (you are already on a container IP, for example, and not a host interface)
2 requestContextData)
at Orleans.Runtime.Catalog.InitActivation(ActivationData activation, Dictionary
2 requestContextData)