i have observable each item transformed in way may result in exception, can retried. don't want failures break stream, each item represents independent transaction. best solution can come this: final atomiclong errcount = new atomiclong(); observable.from(immutablelist.of(1l, 2l, 3l)).flatmap(new func1<long, observable<long>>() { @override public observable<long> call(long along) { return observable.from(immutablelist.of(along)).map(new func1<long, long>() { @override public long call(long along) { if (along == 2 && errcount.getandincrement() < 1) { throw new runtimeexception("retryable error"); } return along * 100; } }).retry(2); } }).foreach(new action1<long>() { @override public void call(long along) { sys...
i trying use following elasticsearch module puppet (with hiera). i trying configure node.name example, can seen in instance.pp file. elasticsearch::instance not class however, defined , seems used in other classes (specifically elasticsearch, in init.pp ). i have tried instantiating class, config through like: elasticsearch::elasticsearch::instance::node.name: 'myname' in .yaml, no avail. i try explain problems mentioned. class vs define . main difference classes singletons in puppet. if want create instance of elasticsearch::instance add puppet manifest: elasticsearch::instance { 'some_name': } exactly same in examples . the purpose of using hiera puppet provide proper values puppet manifests depend on deployment environment. cannot create resource defining in hiera. if define resource in hiera, use create_resource function create instance. please read following article . in example, equivalent of making instance in puppet man...
Comments
Post a Comment