IceStormInternal.ice

Go to the documentation of this file.

// **********************************************************************
//
// Copyright (c) 2003-2017 ZeroC, Inc. All rights reserved.
//
// This copy of Ice is licensed to you under the terms described in the
// ICE_LICENSE file included in this distribution.
//
// **********************************************************************
 
#pragma once
 
[[ "ice-prefix", "cpp:header-ext:h" ]]
 
#include <Ice/BuiltinSequences.ice>
#include <Ice/Current.ice>
#include <Ice/Identity.ice>
#include <IceStorm/Election.ice>
#include <IceStorm/IceStorm.ice>
 
    [["cpp:include:deque"]]
 
    module IceStorm
{
 
    /**
 *
 * The event data.
 *
 **/
    ["cpp:class"] struct EventData
    {
        /** The operation name. */
        string op;
        /** The operation mode. */
        Ice::OperationMode mode;
        /** The encoded data for the operation's input parameters. */
        Ice::ByteSeq data;
        /** The Ice::Current::Context data from the originating request. */
        Ice::Context context;
    }
 
    local exception SendQueueSizeMaxReached{}
 
        /** A sequence of EventData. */
        ["cpp:type:std::deque< ::IceStorm::EventDataPtr>"] sequence<EventData>
            EventDataSeq;
 
    /**
 *
 * The TopicLink interface. This is used to forward events between
 * federated Topic instances.
 *
 * @see TopicInternal
 *
 **/
    interface TopicLink
    {
        /**
     *
     * Forward a sequence of events.
     *
     * @param events The events to forward.
     *
     **/
        void forward(EventDataSeq events);
    }
 
    /** Thrown if the reap call would block. */
    exception ReapWouldBlock
    {
    }
 
    /**
 *
 * Internal operations for a topic.
 *
 * @see Topic
 *
 **/
    interface TopicInternal extends Topic
    {
        /**
     *
     * Retrieve a proxy to the TopicLink interface.
     *
     * @return The TopicLink for the Topic.
     *
     **/
        idempotent TopicLink* getLinkProxy();
 
        /**
     *
     * Reap the given identities.
     *
     * @param id The sequence of identities.
     *
     * @throws ReapWouldBlock Raised if the reap call would block.
     *
     **/
        void reap(Ice::IdentitySeq id) throws ReapWouldBlock;
    }
 
    /**
 *
 * Internal operations for a topic manager.
 *
 * @see TopicManager
 *
 **/
    interface TopicManagerInternal extends TopicManager
    {
        /**
     *
     * Return the replica node proxy for this topic manager.
     *
     * @return The replica proxy, or null if this instance is not
     * replicated.
     *
     **/
        ["cpp:const"] idempotent IceStormElection::Node* getReplicaNode();
    }
 
} // End module IceStorm