Class MockGatewayMetaState

java.lang.Object
org.opensearch.gateway.GatewayMetaState
org.opensearch.gateway.MockGatewayMetaState
All Implemented Interfaces:
Closeable, AutoCloseable
public class MockGatewayMetaState extends org.opensearch.gateway.GatewayMetaState
GatewayMetaState constructor accepts a lot of arguments. It's not always easy / convenient to construct these dependencies. This class constructor takes far fewer dependencies and constructs usable GatewayMetaState with 2 restrictions: no metadata upgrade will be performed and no cluster state updaters will be run. This is sufficient for most of the tests.

  • Nested Class Summary

    Nested classes/interfaces inherited from class org.opensearch.gateway.GatewayMetaState

    org.opensearch.gateway.GatewayMetaState.RemotePersistedState

  • Field Summary

    Fields inherited from class org.opensearch.gateway.GatewayMetaState

    STALE_STATE_CONFIG_NODE_ID

  • Constructor Summary

    Constructors
    Constructor
    Description
    MockGatewayMetaState(org.opensearch.cluster.node.DiscoveryNode localNode, org.opensearch.common.util.BigArrays bigArrays)
     
    MockGatewayMetaState(org.opensearch.cluster.node.DiscoveryNode localNode, org.opensearch.common.util.BigArrays bigArrays, boolean prepareFullState)
     
    MockGatewayMetaState(org.opensearch.cluster.node.DiscoveryNode localNode, org.opensearch.common.util.BigArrays bigArrays, org.opensearch.gateway.remote.RemoteClusterStateService remoteClusterStateService, org.opensearch.index.recovery.RemoteStoreRestoreService remoteStoreRestoreService)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    close()
     
    void
    start(org.opensearch.common.settings.Settings settings, org.opensearch.env.NodeEnvironment nodeEnvironment, org.opensearch.core.xcontent.NamedXContentRegistry xContentRegistry, org.opensearch.cluster.coordination.PersistedStateRegistry persistedStateRegistry)
     
    void
    start(org.opensearch.common.settings.Settings settings, org.opensearch.env.NodeEnvironment nodeEnvironment, org.opensearch.core.xcontent.NamedXContentRegistry xContentRegistry, org.opensearch.cluster.coordination.PersistedStateRegistry persistedStateRegistry, boolean prepareFullState)
     

    Methods inherited from class org.opensearch.gateway.GatewayMetaState

    allPendingAsyncStatesWritten, getMetadata, getPersistedState, start

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Constructor Details

    • MockGatewayMetaState

      public MockGatewayMetaState(org.opensearch.cluster.node.DiscoveryNode localNode, org.opensearch.common.util.BigArrays bigArrays, boolean prepareFullState)

    • MockGatewayMetaState

      public MockGatewayMetaState(org.opensearch.cluster.node.DiscoveryNode localNode, org.opensearch.common.util.BigArrays bigArrays)

    • MockGatewayMetaState

      public MockGatewayMetaState(org.opensearch.cluster.node.DiscoveryNode localNode, org.opensearch.common.util.BigArrays bigArrays, org.opensearch.gateway.remote.RemoteClusterStateService remoteClusterStateService, org.opensearch.index.recovery.RemoteStoreRestoreService remoteStoreRestoreService)

  • Method Details

    • close

      public void close() throws IOException
      Specified by:
      close in interface AutoCloseable
      Specified by:
      close in interface Closeable
      Overrides:
      close in class org.opensearch.gateway.GatewayMetaState
      Throws:
      IOException

    • start

      public void start(org.opensearch.common.settings.Settings settings, org.opensearch.env.NodeEnvironment nodeEnvironment, org.opensearch.core.xcontent.NamedXContentRegistry xContentRegistry, org.opensearch.cluster.coordination.PersistedStateRegistry persistedStateRegistry)

    • start

      public void start(org.opensearch.common.settings.Settings settings, org.opensearch.env.NodeEnvironment nodeEnvironment, org.opensearch.core.xcontent.NamedXContentRegistry xContentRegistry, org.opensearch.cluster.coordination.PersistedStateRegistry persistedStateRegistry, boolean prepareFullState)