@Nonnull
@Override
public SnowcastSequencer createSequencer(@Nonnull String sequencerName, @Nonnull SnowcastEpoch epoch,
@Min(128) @Max(8192) int maxLogicalNodeCount,
@Nonnegative @Max(Short.MAX_VALUE) short backupCount) {
TRACER.trace("register sequencer %s with epoch %s, max nodes %s, backups %s", //
sequencerName, epoch, maxLogicalNodeCount, backupCount);
SequencerDefinition definition = new SequencerDefinition(sequencerName, epoch, maxLogicalNodeCount, backupCount);
try {
SequencerDefinition realDefinition = clientCodec.createSequencerDefinition(sequencerName, definition);
return getOrCreateSequencerProvision(realDefinition).getSequencer();
} finally {
TRACER.trace("register sequencer %s end", sequencerName);
}
}
ClientSequencerService.java 文件源码
java
阅读 19
收藏 0
点赞 0
评论 0
项目:snowcast
作者:
评论列表
文章目录