Did I find the right examples for you? yes no      Crawl my project      Python Jobs

All Samples(34)  |  Call(30)  |  Derive(0)  |  Import(4)

src/p/y/pyon-HEAD/pyon/net/endpoint.py   pyon(Download)
from pyon.core.exception import ExceptionFactory, IonException, BadRequest
from pyon.net.channel import ChannelClosedError, PublisherChannel, ListenChannel, SubscriberChannel, ServerChannel, BidirClientChannel
from pyon.core.interceptor.interceptor import Invocation, process_interceptors
from pyon.util.containers import get_ion_ts, get_ion_ts_millis
from pyon.util.log import log
        This method exists so we can override it in derived classes (ex with a process).
        """
        inv = Invocation(**kwargs)
        return inv
 

src/p/y/pyon-HEAD/pyon/net/test/test_endpoint.py   pyon(Download)
from pyon.core.bootstrap import get_sys_name, CFG
from pyon.container.cc import Container
from pyon.core.interceptor.interceptor import Invocation
from pyon.net.channel import BaseChannel, SendChannel, BidirClientChannel, SubscriberChannel, ChannelClosedError, ServerChannel, RecvChannel, ListenChannel
from pyon.net.endpoint import EndpointUnit, BaseEndpoint, RPCServer, Subscriber, Publisher, RequestResponseClient, RequestEndpointUnit, RPCRequestEndpointUnit, RPCClient, RPCResponseEndpointUnit, EndpointError, SendingBaseEndpoint, ListeningBaseEndpoint

src/p/y/pyon-HEAD/pyon/core/test/test_objperf.py   pyon(Download)
        time_serialize(test_obj1, "dict of ion nested", has_ion=True)
 
        from pyon.core.interceptor.interceptor import Invocation
        from pyon.core.interceptor.encode import EncodeInterceptor
        encode = EncodeInterceptor()
        invocation = Invocation()

src/p/y/pyon-HEAD/pyon/core/interceptor/test/interceptor_test.py   pyon(Download)
from pyon.core.interceptor.encode import EncodeInterceptor
from pyon.core.interceptor.validate import ValidateInterceptor
from pyon.core.interceptor.interceptor import Invocation
from pyon.public import IonObject, DotDict, BadRequest
 
    def test_numpy_encode(self):
 
        a = np.array([90,8010,3,14112,3.14159265358979323846264],dtype='float32')
 
        invoke = Invocation()
    def test_packed_numpy(self):
        a = np.array([(90,8010,3,14112,3.14159265358979323846264)],dtype='float32')
        invoke = Invocation()
        invoke.message = {'double stuffed':[a,a,a]}
        encode = EncodeInterceptor()
    def test_set(self):
        a = {1,2}
        invoke = Invocation()
        invoke.message = a
        encode = EncodeInterceptor()
    def test_scalars(self):
        a = np.uint64(312)
        invoke = Invocation()
        invoke.message = a
        encode = EncodeInterceptor()