| /* |
| * Licensed to the Apache Software Foundation (ASF) under one or more |
| * contributor license agreements. See the NOTICE file distributed with |
| * this work for additional information regarding copyright ownership. |
| * The ASF licenses this file to You under the Apache License, Version 2.0 |
| * (the "License"); you may not use this file except in compliance with |
| * the License. You may obtain a copy of the License at |
| * |
| * http://www.apache.org/licenses/LICENSE-2.0 |
| * |
| * Unless required by applicable law or agreed to in writing, software |
| * distributed under the License is distributed on an "AS IS" BASIS, |
| * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| * See the License for the specific language governing permissions and |
| * limitations under the License. |
| */ |
| package org.apache.ignite.raft.jraft.option; |
| |
| import org.apache.ignite.raft.jraft.Closure; |
| import org.apache.ignite.raft.jraft.RaftMessagesFactory; |
| import org.apache.ignite.raft.jraft.StateMachine; |
| import org.apache.ignite.raft.jraft.closure.ClosureQueue; |
| import org.apache.ignite.raft.jraft.core.FSMCallerImpl; |
| import org.apache.ignite.raft.jraft.core.NodeImpl; |
| import org.apache.ignite.raft.jraft.disruptor.StripedDisruptor; |
| import org.apache.ignite.raft.jraft.entity.LogId; |
| import org.apache.ignite.raft.jraft.storage.LogManager; |
| |
| /** |
| * FSM caller options. |
| */ |
| public class FSMCallerOptions { |
| /** Raft group id. */ |
| private String groupId; |
| |
| private LogManager logManager; |
| private StateMachine fsm; |
| private Closure afterShutdown; |
| private LogId bootstrapId; |
| private ClosureQueue closureQueue; |
| private NodeImpl node; |
| private RaftMessagesFactory raftMessagesFactory; |
| private StripedDisruptor<FSMCallerImpl.ApplyTask> fSMCallerExecutorDisruptor; |
| |
| public String getGroupId() { |
| return groupId; |
| } |
| |
| public void setGroupId(String groupId) { |
| this.groupId = groupId; |
| } |
| |
| public StripedDisruptor<FSMCallerImpl.ApplyTask> getfSMCallerExecutorDisruptor() { |
| return fSMCallerExecutorDisruptor; |
| } |
| |
| public void setfSMCallerExecutorDisruptor(StripedDisruptor<FSMCallerImpl.ApplyTask> fSMCallerExecutorDisruptor) { |
| this.fSMCallerExecutorDisruptor = fSMCallerExecutorDisruptor; |
| } |
| |
| public NodeImpl getNode() { |
| return this.node; |
| } |
| |
| public void setNode(NodeImpl node) { |
| this.node = node; |
| } |
| |
| public ClosureQueue getClosureQueue() { |
| return this.closureQueue; |
| } |
| |
| public void setClosureQueue(ClosureQueue closureQueue) { |
| this.closureQueue = closureQueue; |
| } |
| |
| public LogManager getLogManager() { |
| return this.logManager; |
| } |
| |
| public void setLogManager(LogManager logManager) { |
| this.logManager = logManager; |
| } |
| |
| public StateMachine getFsm() { |
| return this.fsm; |
| } |
| |
| public void setFsm(StateMachine fsm) { |
| this.fsm = fsm; |
| } |
| |
| public Closure getAfterShutdown() { |
| return this.afterShutdown; |
| } |
| |
| public void setAfterShutdown(Closure afterShutdown) { |
| this.afterShutdown = afterShutdown; |
| } |
| |
| public LogId getBootstrapId() { |
| return this.bootstrapId; |
| } |
| |
| public void setBootstrapId(LogId bootstrapId) { |
| this.bootstrapId = bootstrapId; |
| } |
| |
| public RaftMessagesFactory getRaftMessagesFactory() { |
| assert raftMessagesFactory != null; |
| |
| return raftMessagesFactory; |
| } |
| |
| public void setRaftMessagesFactory(RaftMessagesFactory raftMessagesFactory) { |
| this.raftMessagesFactory = raftMessagesFactory; |
| } |
| } |