Package deltavsoft :: Module rcfproto
[frames] | no frames]

Source Code for Module deltavsoft.rcfproto

   1  # This file was automatically generated by SWIG (http://www.swig.org). 
   2  # Version 2.0.4 
   3  # 
   4  # Do not make changes to this file unless you know what you are doing--modify 
   5  # the SWIG interface file instead. 
   6   
   7   
   8   
   9  import google.protobuf 
  10  import google.protobuf.service 
  11   
  12  from sys import version_info 
  13  if version_info >= (2,6,0): 
14 - def swig_import_helper():
15 from os.path import dirname 16 import imp 17 fp = None 18 try: 19 fp, pathname, description = imp.find_module('_rcfproto', [dirname(__file__)]) 20 except ImportError: 21 import _rcfproto 22 return _rcfproto 23 if fp is not None: 24 try: 25 _mod = imp.load_module('_rcfproto', fp, pathname, description) 26 finally: 27 fp.close() 28 return _mod
29 #_rcfproto = swig_import_helper() 30 import util 31 _rcfproto = util.LoadRCFProtoNativeDll() 32 33 del swig_import_helper 34 else: 35 import _rcfproto 36 del version_info 37 try: 38 _swig_property = property 39 except NameError: 40 pass # Python < 2.2 doesn't have 'property'.
41 -def _swig_setattr_nondynamic(self,class_type,name,value,static=1):
42 if (name == "thisown"): return self.this.own(value) 43 if (name == "this"): 44 if type(value).__name__ == 'SwigPyObject': 45 self.__dict__[name] = value 46 return 47 method = class_type.__swig_setmethods__.get(name,None) 48 if method: return method(self,value) 49 if (not static): 50 self.__dict__[name] = value 51 else: 52 raise AttributeError("You cannot add attributes to %s" % self)
53
54 -def _swig_setattr(self,class_type,name,value):
55 return _swig_setattr_nondynamic(self,class_type,name,value,0)
56
57 -def _swig_getattr(self,class_type,name):
58 if (name == "thisown"): return self.this.own() 59 method = class_type.__swig_getmethods__.get(name,None) 60 if method: return method(self) 61 raise AttributeError(name)
62
63 -def _swig_repr(self):
64 try: strthis = "proxy of " + self.this.__repr__() 65 except: strthis = "" 66 return "<%s.%s; %s >" % (self.__class__.__module__, self.__class__.__name__, strthis,)
67 68 try: 69 _object = object 70 _newclass = 1 71 except AttributeError:
72 - class _object : pass
73 _newclass = 0 74 75 76 try: 77 import weakref 78 weakref_proxy = weakref.proxy 79 except: 80 weakref_proxy = lambda x: x 81 82
83 -class SwigPyIterator(_object):
84 __swig_setmethods__ = {} 85 __setattr__ = lambda self, name, value: _swig_setattr(self, SwigPyIterator, name, value) 86 __swig_getmethods__ = {} 87 __getattr__ = lambda self, name: _swig_getattr(self, SwigPyIterator, name)
88 - def __init__(self, *args, **kwargs): raise AttributeError("No constructor defined - class is abstract")
89 __repr__ = _swig_repr 90 __swig_destroy__ = _rcfproto.delete_SwigPyIterator 91 __del__ = lambda self : None;
92 - def Value(self): return _rcfproto.SwigPyIterator_value(self)
93 - def Incr(self, n = 1): return _rcfproto.SwigPyIterator_incr(self, n)
94 - def Decr(self, n = 1): return _rcfproto.SwigPyIterator_decr(self, n)
95 - def Distance(self, *args): return _rcfproto.SwigPyIterator_distance(self, *args)
96 - def Equal(self, *args): return _rcfproto.SwigPyIterator_equal(self, *args)
97 - def Copy(self): return _rcfproto.SwigPyIterator_copy(self)
98 - def Next(self): return _rcfproto.SwigPyIterator_next(self)
99 - def __next__(self): return _rcfproto.SwigPyIterator___next__(self)
100 - def Previous(self): return _rcfproto.SwigPyIterator_previous(self)
101 - def Advance(self, *args): return _rcfproto.SwigPyIterator_advance(self, *args)
102 - def __eq__(self, *args): return _rcfproto.SwigPyIterator___eq__(self, *args)
103 - def __ne__(self, *args): return _rcfproto.SwigPyIterator___ne__(self, *args)
104 - def __iadd__(self, *args): return _rcfproto.SwigPyIterator___iadd__(self, *args)
105 - def __isub__(self, *args): return _rcfproto.SwigPyIterator___isub__(self, *args)
106 - def __add__(self, *args): return _rcfproto.SwigPyIterator___add__(self, *args)
107 - def __sub__(self, *args): return _rcfproto.SwigPyIterator___sub__(self, *args)
108 - def __iter__(self): return self
109 _SwigPyIterator_swigregister = _rcfproto.SwigPyIterator_swigregister 110 _SwigPyIterator_swigregister(SwigPyIterator) 111 112 SHARED_PTR_DISOWN = _rcfproto.SHARED_PTR_DISOWN
113 -class TransportProtocolList(_object):
114 __swig_setmethods__ = {} 115 __setattr__ = lambda self, name, value: _swig_setattr(self, TransportProtocolList, name, value) 116 __swig_getmethods__ = {} 117 __getattr__ = lambda self, name: _swig_getattr(self, TransportProtocolList, name) 118 __repr__ = _swig_repr
119 - def Iterator(self): return _rcfproto.TransportProtocolList_iterator(self)
120 - def __iter__(self): return self.iterator()
121 - def __nonzero__(self): return _rcfproto.TransportProtocolList___nonzero__(self)
122 - def __bool__(self): return _rcfproto.TransportProtocolList___bool__(self)
123 - def __len__(self): return _rcfproto.TransportProtocolList___len__(self)
124 - def Pop(self): return _rcfproto.TransportProtocolList_pop(self)
125 - def __getslice__(self, *args): return _rcfproto.TransportProtocolList___getslice__(self, *args)
126 - def __setslice__(self, *args): return _rcfproto.TransportProtocolList___setslice__(self, *args)
127 - def __delslice__(self, *args): return _rcfproto.TransportProtocolList___delslice__(self, *args)
128 - def __delitem__(self, *args): return _rcfproto.TransportProtocolList___delitem__(self, *args)
129 - def __getitem__(self, *args): return _rcfproto.TransportProtocolList___getitem__(self, *args)
130 - def __setitem__(self, *args): return _rcfproto.TransportProtocolList___setitem__(self, *args)
131 - def Append(self, *args): return _rcfproto.TransportProtocolList_append(self, *args)
132 - def Empty(self): return _rcfproto.TransportProtocolList_empty(self)
133 - def Size(self): return _rcfproto.TransportProtocolList_size(self)
134 - def Clear(self): return _rcfproto.TransportProtocolList_clear(self)
135 - def Swap(self, *args): return _rcfproto.TransportProtocolList_swap(self, *args)
136 - def Get_allocator(self): return _rcfproto.TransportProtocolList_get_allocator(self)
137 - def Begin(self): return _rcfproto.TransportProtocolList_begin(self)
138 - def End(self): return _rcfproto.TransportProtocolList_end(self)
139 - def Rbegin(self): return _rcfproto.TransportProtocolList_rbegin(self)
140 - def Rend(self): return _rcfproto.TransportProtocolList_rend(self)
141 - def Pop_back(self): return _rcfproto.TransportProtocolList_pop_back(self)
142 - def Erase(self, *args): return _rcfproto.TransportProtocolList_erase(self, *args)
143 - def __init__(self, *args):
144 this = _rcfproto.new_TransportProtocolList(*args) 145 try: self.this.append(this) 146 except: self.this = this
147 - def Push_back(self, *args): return _rcfproto.TransportProtocolList_push_back(self, *args)
148 - def Front(self): return _rcfproto.TransportProtocolList_front(self)
149 - def Back(self): return _rcfproto.TransportProtocolList_back(self)
150 - def Assign(self, *args): return _rcfproto.TransportProtocolList_assign(self, *args)
151 - def Resize(self, *args): return _rcfproto.TransportProtocolList_resize(self, *args)
152 - def Insert(self, *args): return _rcfproto.TransportProtocolList_insert(self, *args)
153 - def Reserve(self, *args): return _rcfproto.TransportProtocolList_reserve(self, *args)
154 - def Capacity(self): return _rcfproto.TransportProtocolList_capacity(self)
155 __swig_destroy__ = _rcfproto.delete_TransportProtocolList 156 __del__ = lambda self : None; 157 _TransportProtocolList_swigregister = _rcfproto.TransportProtocolList_swigregister 158 _TransportProtocolList_swigregister(TransportProtocolList) 159 160 161
162 -def Init():
163 """Reference-counted initialization of RCF framework. May be called multiple times (see deinit()). """ 164 165 return _rcfproto.init()
166 init = _rcfproto.init 167 168
169 -def Deinit():
170 """Reference-counted deinitialization of RCF framework. For actual deinitialization to take place, deinit() must be called as many times as init() has been called. """ 171 172 return _rcfproto.deinit()
173 deinit = _rcfproto.deinit
174 -class LogTarget(_object):
175 """Base class for log targets. Log targets are passed to the enableLogging() function, to configure RCF logging. 176 177 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 178 179 __swig_setmethods__ = {} 180 __setattr__ = lambda self, name, value: _swig_setattr(self, LogTarget, name, value) 181 __swig_getmethods__ = {} 182 __getattr__ = lambda self, name: _swig_getattr(self, LogTarget, name)
183 - def __init__(self, *args, **kwargs): raise AttributeError("No constructor defined")
184 __repr__ = _swig_repr 185 __swig_destroy__ = _rcfproto.delete_LogTarget 186 __del__ = lambda self : None;
187 _LogTarget_swigregister = _rcfproto.LogTarget_swigregister 188 _LogTarget_swigregister(LogTarget) 189
190 -class LogToStdout(LogTarget):
191 """Configures log output to be directed to standard output. 192 193 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 194 195 __swig_setmethods__ = {} 196 for _s in [LogTarget]: __swig_setmethods__.update(getattr(_s,'__swig_setmethods__',{})) 197 __setattr__ = lambda self, name, value: _swig_setattr(self, LogToStdout, name, value) 198 __swig_getmethods__ = {} 199 for _s in [LogTarget]: __swig_getmethods__.update(getattr(_s,'__swig_getmethods__',{})) 200 __getattr__ = lambda self, name: _swig_getattr(self, LogToStdout, name) 201 __repr__ = _swig_repr
202 - def __init__(self):
203 this = _rcfproto.new_LogToStdout() 204 try: self.this.append(this) 205 except: self.this = this
206 __swig_destroy__ = _rcfproto.delete_LogToStdout 207 __del__ = lambda self : None; 208 _LogToStdout_swigregister = _rcfproto.LogToStdout_swigregister 209 _LogToStdout_swigregister(LogToStdout) 210
211 -class LogToDebugWindow(LogTarget):
212 """Configures log output to be directed to Windows debug output. 213 214 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 215 216 __swig_setmethods__ = {} 217 for _s in [LogTarget]: __swig_setmethods__.update(getattr(_s,'__swig_setmethods__',{})) 218 __setattr__ = lambda self, name, value: _swig_setattr(self, LogToDebugWindow, name, value) 219 __swig_getmethods__ = {} 220 for _s in [LogTarget]: __swig_getmethods__.update(getattr(_s,'__swig_getmethods__',{})) 221 __getattr__ = lambda self, name: _swig_getattr(self, LogToDebugWindow, name) 222 __repr__ = _swig_repr
223 - def __init__(self):
224 this = _rcfproto.new_LogToDebugWindow() 225 try: self.this.append(this) 226 except: self.this = this
227 __swig_destroy__ = _rcfproto.delete_LogToDebugWindow 228 __del__ = lambda self : None; 229 _LogToDebugWindow_swigregister = _rcfproto.LogToDebugWindow_swigregister 230 _LogToDebugWindow_swigregister(LogToDebugWindow) 231
232 -class LogToEventLog(LogTarget):
233 """Configures log output to be directed to the Windows event log. 234 235 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 236 237 __swig_setmethods__ = {} 238 for _s in [LogTarget]: __swig_setmethods__.update(getattr(_s,'__swig_setmethods__',{})) 239 __setattr__ = lambda self, name, value: _swig_setattr(self, LogToEventLog, name, value) 240 __swig_getmethods__ = {} 241 for _s in [LogTarget]: __swig_getmethods__.update(getattr(_s,'__swig_getmethods__',{})) 242 __getattr__ = lambda self, name: _swig_getattr(self, LogToEventLog, name) 243 __repr__ = _swig_repr
244 - def __init__(self, *args):
245 this = _rcfproto.new_LogToEventLog(*args) 246 try: self.this.append(this) 247 except: self.this = this
248 __swig_destroy__ = _rcfproto.delete_LogToEventLog 249 __del__ = lambda self : None; 250 _LogToEventLog_swigregister = _rcfproto.LogToEventLog_swigregister 251 _LogToEventLog_swigregister(LogToEventLog) 252
253 -class LogToFile(LogTarget):
254 """Configures log output to be directed to a log file. 255 256 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 257 258 __swig_setmethods__ = {} 259 for _s in [LogTarget]: __swig_setmethods__.update(getattr(_s,'__swig_setmethods__',{})) 260 __setattr__ = lambda self, name, value: _swig_setattr(self, LogToFile, name, value) 261 __swig_getmethods__ = {} 262 for _s in [LogTarget]: __swig_getmethods__.update(getattr(_s,'__swig_getmethods__',{})) 263 __getattr__ = lambda self, name: _swig_getattr(self, LogToFile, name) 264 __repr__ = _swig_repr
265 - def __init__(self, *args):
266 this = _rcfproto.new_LogToFile(*args) 267 try: self.this.append(this) 268 except: self.this = this
269 __swig_destroy__ = _rcfproto.delete_LogToFile 270 __del__ = lambda self : None; 271 _LogToFile_swigregister = _rcfproto.LogToFile_swigregister 272 _LogToFile_swigregister(LogToFile) 273 274 275
276 -def EnableLogging(*args):
277 """Configures logging for the RCF runtime. logTarget is where the log output will appear. loglevel is the detail level of the log, ranging from 0 (no logging), 1 (errors-only logging) to 4 (maximum detail logging). logFormat is an optional parameter describing the format of the log output. """ 278 279 return _rcfproto.enableLogging(*args)
280 enableLogging = _rcfproto.enableLogging 281 282
283 -def DisableLogging():
284 """Disables logging for the RCF runtime. """ 285 286 return _rcfproto.disableLogging()
287 disableLogging = _rcfproto.disableLogging 288 Tp_Unspecified = _rcfproto.Tp_Unspecified 289 Tp_Clear = _rcfproto.Tp_Clear 290 Tp_Ntlm = _rcfproto.Tp_Ntlm 291 Tp_Kerberos = _rcfproto.Tp_Kerberos 292 Tp_Negotiate = _rcfproto.Tp_Negotiate 293 Tp_Ssl = _rcfproto.Tp_Ssl 294 Tt_Unknown = _rcfproto.Tt_Unknown 295 Tt_Tcp = _rcfproto.Tt_Tcp 296 Tt_Udp = _rcfproto.Tt_Udp 297 Tt_Win32NamedPipe = _rcfproto.Tt_Win32NamedPipe 298 Tt_UnixNamedPipe = _rcfproto.Tt_UnixNamedPipe 299 Tt_Http = _rcfproto.Tt_Http 300 Tt_Https = _rcfproto.Tt_Https 301 Si_Schannel = _rcfproto.Si_Schannel 302 Si_OpenSsl = _rcfproto.Si_OpenSsl 303 Cl_CurrentUser = _rcfproto.Cl_CurrentUser 304 Cl_LocalMachine = _rcfproto.Cl_LocalMachine 305 Cs_AddressBook = _rcfproto.Cs_AddressBook 306 Cs_AuthRoot = _rcfproto.Cs_AuthRoot 307 Cs_CertificateAuthority = _rcfproto.Cs_CertificateAuthority 308 Cs_Disallowed = _rcfproto.Cs_Disallowed 309 Cs_My = _rcfproto.Cs_My 310 Cs_Root = _rcfproto.Cs_Root 311 Cs_TrustedPeople = _rcfproto.Cs_TrustedPeople 312 Cs_TrustedPublisher = _rcfproto.Cs_TrustedPublisher 313 Cit_Unspecified = _rcfproto.Cit_Unspecified 314 Cit_Win32 = _rcfproto.Cit_Win32 315 Cit_X509 = _rcfproto.Cit_X509
316 -class Certificate(_object):
317 """Base class of all certificate classes. 318 319 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 320 321 __swig_setmethods__ = {} 322 __setattr__ = lambda self, name, value: _swig_setattr(self, Certificate, name, value) 323 __swig_getmethods__ = {} 324 __getattr__ = lambda self, name: _swig_getattr(self, Certificate, name)
325 - def __init__(self, *args, **kwargs): raise AttributeError("No constructor defined")
326 __repr__ = _swig_repr
327 - def _getType(self): return _rcfproto.Certificate__getType(self)
328 - def _downcastToWin32Certificate(self, *args): return _rcfproto.Certificate__downcastToWin32Certificate(self, *args)
329 - def _downcastToX509Certificate(self, *args): return _rcfproto.Certificate__downcastToX509Certificate(self, *args)
330 __swig_destroy__ = _rcfproto.delete_Certificate 331 __del__ = lambda self : None;
332 _Certificate_swigregister = _rcfproto.Certificate_swigregister 333 _Certificate_swigregister(Certificate) 334
335 -class PemCertificate(Certificate):
336 """Use this class to load a certificate in .pem format. Only applicable to OpenSSL. 337 338 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 339 340 __swig_setmethods__ = {} 341 for _s in [Certificate]: __swig_setmethods__.update(getattr(_s,'__swig_setmethods__',{})) 342 __setattr__ = lambda self, name, value: _swig_setattr(self, PemCertificate, name, value) 343 __swig_getmethods__ = {} 344 for _s in [Certificate]: __swig_getmethods__.update(getattr(_s,'__swig_getmethods__',{})) 345 __getattr__ = lambda self, name: _swig_getattr(self, PemCertificate, name) 346 __repr__ = _swig_repr 347
348 - def __init__(self, *args):
349 """Loads a .pem certificate, using the given file path and password. """ 350 351 this = _rcfproto.new_PemCertificate(*args) 352 try: self.this.append(this) 353 except: self.this = this
354 __swig_destroy__ = _rcfproto.delete_PemCertificate 355 __del__ = lambda self : None;
356 _PemCertificate_swigregister = _rcfproto.PemCertificate_swigregister 357 _PemCertificate_swigregister(PemCertificate) 358
359 -class X509Certificate(Certificate):
360 """Represents an in-memory certificate, usually from a remote peer. Only applicable to OpenSSL. 361 362 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 363 364 __swig_setmethods__ = {} 365 for _s in [Certificate]: __swig_setmethods__.update(getattr(_s,'__swig_setmethods__',{})) 366 __setattr__ = lambda self, name, value: _swig_setattr(self, X509Certificate, name, value) 367 __swig_getmethods__ = {} 368 for _s in [Certificate]: __swig_getmethods__.update(getattr(_s,'__swig_getmethods__',{})) 369 __getattr__ = lambda self, name: _swig_getattr(self, X509Certificate, name)
370 - def __init__(self, *args, **kwargs): raise AttributeError("No constructor defined")
371 __repr__ = _swig_repr
372 - def _getType(self): return _rcfproto.X509Certificate__getType(self)
373
374 - def GetCertificateName(self):
375 """Gets the name of the certificate. """ 376 return _rcfproto.X509Certificate_getCertificateName(self)
377
378 - def GetIssuerName(self):
379 """Gets the name of the issuer of the certificate. """ 380 return _rcfproto.X509Certificate_getIssuerName(self)
381 __swig_destroy__ = _rcfproto.delete_X509Certificate 382 __del__ = lambda self : None;
383 _X509Certificate_swigregister = _rcfproto.X509Certificate_swigregister 384 _X509Certificate_swigregister(X509Certificate) 385
386 -class Win32Certificate(Certificate):
387 """Represents an in-memory certificate, usually from a remote peer. Only applicable to Schannel. 388 389 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 390 391 __swig_setmethods__ = {} 392 for _s in [Certificate]: __swig_setmethods__.update(getattr(_s,'__swig_setmethods__',{})) 393 __setattr__ = lambda self, name, value: _swig_setattr(self, Win32Certificate, name, value) 394 __swig_getmethods__ = {} 395 for _s in [Certificate]: __swig_getmethods__.update(getattr(_s,'__swig_getmethods__',{})) 396 __getattr__ = lambda self, name: _swig_getattr(self, Win32Certificate, name)
397 - def __init__(self, *args, **kwargs): raise AttributeError("No constructor defined")
398 __repr__ = _swig_repr
399 - def _getType(self): return _rcfproto.Win32Certificate__getType(self)
400
401 - def GetCertificateName(self):
402 """Gets the name of the certificate. """ 403 return _rcfproto.Win32Certificate_getCertificateName(self)
404
405 - def GetIssuerName(self):
406 """Gets the name of the issuer of the certificate. """ 407 return _rcfproto.Win32Certificate_getIssuerName(self)
408
409 - def ExportToPfx(self, *args):
410 """Exports the certificate in PFX format, to the given file path. """ 411 return _rcfproto.Win32Certificate_exportToPfx(self, *args)
412
413 - def FindRootCertificate(self, *args):
414 """Attempts to locate a root certificate for this certificate, in the given certificate store. Returns the root certificate if found, and otherwise null. """ 415 return _rcfproto.Win32Certificate_findRootCertificate(self, *args)
416 __swig_destroy__ = _rcfproto.delete_Win32Certificate 417 __del__ = lambda self : None;
418 _Win32Certificate_swigregister = _rcfproto.Win32Certificate_swigregister 419 _Win32Certificate_swigregister(Win32Certificate) 420
421 -class PfxCertificate(Win32Certificate):
422 """Use this class to load a certificate from .pfx format. Only applicable to Schannel. 423 424 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 425 426 __swig_setmethods__ = {} 427 for _s in [Win32Certificate]: __swig_setmethods__.update(getattr(_s,'__swig_setmethods__',{})) 428 __setattr__ = lambda self, name, value: _swig_setattr(self, PfxCertificate, name, value) 429 __swig_getmethods__ = {} 430 for _s in [Win32Certificate]: __swig_getmethods__.update(getattr(_s,'__swig_getmethods__',{})) 431 __getattr__ = lambda self, name: _swig_getattr(self, PfxCertificate, name) 432 __repr__ = _swig_repr 433
434 - def __init__(self, *args):
435 """Loads a certificate from a .pfx file, using the given file path, password and certificate name. """ 436 437 this = _rcfproto.new_PfxCertificate(*args) 438 try: self.this.append(this) 439 except: self.this = this
440
441 - def AddToStore(self, *args):
442 """Adds the certificate to the given Windows certificate store. """ 443 return _rcfproto.PfxCertificate_addToStore(self, *args)
444 __swig_destroy__ = _rcfproto.delete_PfxCertificate 445 __del__ = lambda self : None;
446 _PfxCertificate_swigregister = _rcfproto.PfxCertificate_swigregister 447 _PfxCertificate_swigregister(PfxCertificate) 448
449 -class StoreCertificate(Win32Certificate):
450 """Represents a certificate in a Windows certificate store. 451 452 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 453 454 __swig_setmethods__ = {} 455 for _s in [Win32Certificate]: __swig_setmethods__.update(getattr(_s,'__swig_setmethods__',{})) 456 __setattr__ = lambda self, name, value: _swig_setattr(self, StoreCertificate, name, value) 457 __swig_getmethods__ = {} 458 for _s in [Win32Certificate]: __swig_getmethods__.update(getattr(_s,'__swig_getmethods__',{})) 459 __getattr__ = lambda self, name: _swig_getattr(self, StoreCertificate, name) 460 __repr__ = _swig_repr 461
462 - def __init__(self, *args):
463 """Loads a certificate from a certificate store. """ 464 465 this = _rcfproto.new_StoreCertificate(*args) 466 try: self.this.append(this) 467 except: self.this = this
468
469 - def RemoveFromStore(self):
470 """Removes the certificate from the store it was loaded from. """ 471 return _rcfproto.StoreCertificate_removeFromStore(self)
472 __swig_destroy__ = _rcfproto.delete_StoreCertificate 473 __del__ = lambda self : None;
474 _StoreCertificate_swigregister = _rcfproto.StoreCertificate_swigregister 475 _StoreCertificate_swigregister(StoreCertificate) 476
477 -class StoreCertificateIterator(_object):
478 """Iterates over the certificates in a Windows certificate store. 479 480 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 481 482 __swig_setmethods__ = {} 483 __setattr__ = lambda self, name, value: _swig_setattr(self, StoreCertificateIterator, name, value) 484 __swig_getmethods__ = {} 485 __getattr__ = lambda self, name: _swig_getattr(self, StoreCertificateIterator, name) 486 __repr__ = _swig_repr 487
488 - def __init__(self, *args):
489 """Constructs a store iterator for the the given certificate location and store. """ 490 491 this = _rcfproto.new_StoreCertificateIterator(*args) 492 try: self.this.append(this) 493 except: self.this = this
494
495 - def MoveNext(self):
496 """Moves to the next certificate in the store. Returns false if there are no more certificates, and true otherwise. """ 497 return _rcfproto.StoreCertificateIterator_moveNext(self)
498
499 - def Reset(self):
500 """Resets the iterator back to the beginning of the store. """ 501 return _rcfproto.StoreCertificateIterator_reset(self)
502
503 - def Current(self):
504 """Returns the current certificate. """ 505 return _rcfproto.StoreCertificateIterator_current(self)
506 __swig_destroy__ = _rcfproto.delete_StoreCertificateIterator 507 __del__ = lambda self : None;
508 _StoreCertificateIterator_swigregister = _rcfproto.StoreCertificateIterator_swigregister 509 _StoreCertificateIterator_swigregister(StoreCertificateIterator) 510 511 512
513 -def SetDefaultSslImplementation(*args):
514 """Sets the default SSL implementation to use (OpenSSL or Schannel). The default is OpenSSL. """ 515 516 return _rcfproto.setDefaultSslImplementation(*args)
517 setDefaultSslImplementation = _rcfproto.setDefaultSslImplementation 518 519
520 -def GetDefaultSslImplementation():
521 """Gets the default SSL implementation. """ 522 523 return _rcfproto.getDefaultSslImplementation()
524 getDefaultSslImplementation = _rcfproto.getDefaultSslImplementation
525 -class IpAddress(_object):
526 """Represents an IP address (IPv4 or IPv6). 527 528 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 529 530 __swig_setmethods__ = {} 531 __setattr__ = lambda self, name, value: _swig_setattr(self, IpAddress, name, value) 532 __swig_getmethods__ = {} 533 __getattr__ = lambda self, name: _swig_getattr(self, IpAddress, name) 534 __repr__ = _swig_repr 535
536 - def __init__(self, *args):
537 """Construct an IP address from a host name """ 538 539 this = _rcfproto.new_IpAddress(*args) 540 try: self.this.append(this) 541 except: self.this = this
542 __swig_destroy__ = _rcfproto.delete_IpAddress 543 __del__ = lambda self : None;
544 _IpAddress_swigregister = _rcfproto.IpAddress_swigregister 545 _IpAddress_swigregister(IpAddress) 546
547 -class ThreadPool(_object):
548 """Represents a server-side thread pool. 549 550 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 551 552 __swig_setmethods__ = {} 553 __setattr__ = lambda self, name, value: _swig_setattr(self, ThreadPool, name, value) 554 __swig_getmethods__ = {} 555 __getattr__ = lambda self, name: _swig_getattr(self, ThreadPool, name) 556 __repr__ = _swig_repr
557 - def __init__(self, *args):
558 this = _rcfproto.new_ThreadPool(*args) 559 try: self.this.append(this) 560 except: self.this = this
561
562 - def SetThreadMinCount(self, *args):
563 """Sets the minimum number of threads in the thread pool. """ 564 return _rcfproto.ThreadPool_setThreadMinCount(self, *args)
565
566 - def GetThreadMinCount(self):
567 """Returns the minimum number of threads in the thread pool. """ 568 return _rcfproto.ThreadPool_getThreadMinCount(self)
569
570 - def SetThreadMaxCount(self, *args):
571 """Sets the maximum number of threads in the thread pool. """ 572 return _rcfproto.ThreadPool_setThreadMaxCount(self, *args)
573
574 - def GetThreadMaxCount(self):
575 """Returns the maximum number of threads in the thread pool. """ 576 return _rcfproto.ThreadPool_getThreadMaxCount(self)
577
578 - def SetThreadIdleTimeoutMs(self, *args):
579 """Sets the thread idle timeout value, in milliseconds. After a thread has been idle for this time, it will be shut down, unless the thread count is already at the minimum value for the thread pool. """ 580 return _rcfproto.ThreadPool_setThreadIdleTimeoutMs(self, *args)
581
582 - def GetThreadIdleTimeoutMs(self):
583 """Returns the thread idle timeout value, in milliseconds. """ 584 return _rcfproto.ThreadPool_getThreadIdleTimeoutMs(self)
585
586 - def SetReserveLastThread(self, *args):
587 """If this setting is true, clients will receive an error message right away, if all threads in the thread pool are busy. Otherwise, the client will wait for a thread in the thread pool to become free. """ 588 return _rcfproto.ThreadPool_setReserveLastThread(self, *args)
589 - def GetReserveLastThread(self): return _rcfproto.ThreadPool_getReserveLastThread(self)
590
591 - def SetThreadName(self, *args):
592 """Sets the thread name of the thread pool threads, as visible in a debugger. """ 593 return _rcfproto.ThreadPool_setThreadName(self, *args)
594
595 - def GetThreadName(self):
596 """Returns the thread name of the thread pool threads. """ 597 return _rcfproto.ThreadPool_getThreadName(self)
598 __swig_destroy__ = _rcfproto.delete_ThreadPool 599 __del__ = lambda self : None; 600 _ThreadPool_swigregister = _rcfproto.ThreadPool_swigregister 601 _ThreadPool_swigregister(ThreadPool) 602
603 -class Endpoint(_object):
604 """Base class for all network endpoint types. 605 606 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 607 608 __swig_setmethods__ = {} 609 __setattr__ = lambda self, name, value: _swig_setattr(self, Endpoint, name, value) 610 __swig_getmethods__ = {} 611 __getattr__ = lambda self, name: _swig_getattr(self, Endpoint, name)
612 - def __init__(self, *args, **kwargs): raise AttributeError("No constructor defined")
613 __repr__ = _swig_repr 614 __swig_destroy__ = _rcfproto.delete_Endpoint 615 __del__ = lambda self : None;
616 _Endpoint_swigregister = _rcfproto.Endpoint_swigregister 617 _Endpoint_swigregister(Endpoint) 618
619 -class TcpEndpoint(Endpoint):
620 """Represents a TCP endpoint. 621 622 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 623 624 __swig_setmethods__ = {} 625 for _s in [Endpoint]: __swig_setmethods__.update(getattr(_s,'__swig_setmethods__',{})) 626 __setattr__ = lambda self, name, value: _swig_setattr(self, TcpEndpoint, name, value) 627 __swig_getmethods__ = {} 628 for _s in [Endpoint]: __swig_getmethods__.update(getattr(_s,'__swig_getmethods__',{})) 629 __getattr__ = lambda self, name: _swig_getattr(self, TcpEndpoint, name) 630 __repr__ = _swig_repr 631
632 - def __init__(self, *args):
633 """Constructs a TcpEndpoint from a port number. The IP address defaults to 127.0.0.1 . """ 634 635 this = _rcfproto.new_TcpEndpoint(*args) 636 try: self.this.append(this) 637 except: self.this = this
638
639 - def GetIp(self):
640 """Gets the IP address of the TcpEndpoint. """ 641 return _rcfproto.TcpEndpoint_getIp(self)
642
643 - def GetPort(self):
644 """Gets the port number of the TcpEndpoint. """ 645 return _rcfproto.TcpEndpoint_getPort(self)
646
647 - def AsString(self):
648 """Returns a string representation of the TcpEndpoint. """ 649 return _rcfproto.TcpEndpoint_asString(self)
650 __swig_destroy__ = _rcfproto.delete_TcpEndpoint 651 __del__ = lambda self : None;
652 _TcpEndpoint_swigregister = _rcfproto.TcpEndpoint_swigregister 653 _TcpEndpoint_swigregister(TcpEndpoint) 654
655 -class Win32NamedPipeEndpoint(Endpoint):
656 """Represents a Win32 named pipe endpoint. Only available on Windows platforms. 657 658 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 659 660 __swig_setmethods__ = {} 661 for _s in [Endpoint]: __swig_setmethods__.update(getattr(_s,'__swig_setmethods__',{})) 662 __setattr__ = lambda self, name, value: _swig_setattr(self, Win32NamedPipeEndpoint, name, value) 663 __swig_getmethods__ = {} 664 for _s in [Endpoint]: __swig_getmethods__.update(getattr(_s,'__swig_getmethods__',{})) 665 __getattr__ = lambda self, name: _swig_getattr(self, Win32NamedPipeEndpoint, name) 666 __repr__ = _swig_repr 667
668 - def __init__(self, *args):
669 """Constructs a Win32 named pipe endpoint with the given pipe name. """ 670 671 this = _rcfproto.new_Win32NamedPipeEndpoint(*args) 672 try: self.this.append(this) 673 except: self.this = this
674 __swig_destroy__ = _rcfproto.delete_Win32NamedPipeEndpoint 675 __del__ = lambda self : None;
676 _Win32NamedPipeEndpoint_swigregister = _rcfproto.Win32NamedPipeEndpoint_swigregister 677 _Win32NamedPipeEndpoint_swigregister(Win32NamedPipeEndpoint) 678
679 -class UnixLocalEndpoint(Endpoint):
680 """Represents a UNIX local socket endpoint. Only available on UNIX platforms. 681 682 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 683 684 __swig_setmethods__ = {} 685 for _s in [Endpoint]: __swig_setmethods__.update(getattr(_s,'__swig_setmethods__',{})) 686 __setattr__ = lambda self, name, value: _swig_setattr(self, UnixLocalEndpoint, name, value) 687 __swig_getmethods__ = {} 688 for _s in [Endpoint]: __swig_getmethods__.update(getattr(_s,'__swig_getmethods__',{})) 689 __getattr__ = lambda self, name: _swig_getattr(self, UnixLocalEndpoint, name) 690 __repr__ = _swig_repr 691
692 - def __init__(self, *args):
693 """Constructs a UNIX local socket endpoint with the given name. """ 694 695 this = _rcfproto.new_UnixLocalEndpoint(*args) 696 try: self.this.append(this) 697 except: self.this = this
698 __swig_destroy__ = _rcfproto.delete_UnixLocalEndpoint 699 __del__ = lambda self : None;
700 _UnixLocalEndpoint_swigregister = _rcfproto.UnixLocalEndpoint_swigregister 701 _UnixLocalEndpoint_swigregister(UnixLocalEndpoint) 702
703 -class HttpEndpoint(TcpEndpoint):
704 """Represents a HTTP endpoint. 705 706 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 707 708 __swig_setmethods__ = {} 709 for _s in [TcpEndpoint]: __swig_setmethods__.update(getattr(_s,'__swig_setmethods__',{})) 710 __setattr__ = lambda self, name, value: _swig_setattr(self, HttpEndpoint, name, value) 711 __swig_getmethods__ = {} 712 for _s in [TcpEndpoint]: __swig_getmethods__.update(getattr(_s,'__swig_getmethods__',{})) 713 __getattr__ = lambda self, name: _swig_getattr(self, HttpEndpoint, name) 714 __repr__ = _swig_repr 715
716 - def __init__(self, *args):
717 """Constructs an HTTP endpoint on the given port number. """ 718 719 this = _rcfproto.new_HttpEndpoint(*args) 720 try: self.this.append(this) 721 except: self.this = this
722 __swig_destroy__ = _rcfproto.delete_HttpEndpoint 723 __del__ = lambda self : None;
724 _HttpEndpoint_swigregister = _rcfproto.HttpEndpoint_swigregister 725 _HttpEndpoint_swigregister(HttpEndpoint) 726
727 -class HttpsEndpoint(TcpEndpoint):
728 """Represents a HTTPS endpoint. 729 730 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 731 732 __swig_setmethods__ = {} 733 for _s in [TcpEndpoint]: __swig_setmethods__.update(getattr(_s,'__swig_setmethods__',{})) 734 __setattr__ = lambda self, name, value: _swig_setattr(self, HttpsEndpoint, name, value) 735 __swig_getmethods__ = {} 736 for _s in [TcpEndpoint]: __swig_getmethods__.update(getattr(_s,'__swig_getmethods__',{})) 737 __getattr__ = lambda self, name: _swig_getattr(self, HttpsEndpoint, name) 738 __repr__ = _swig_repr 739
740 - def __init__(self, *args):
741 """Constructs an HTTPS endpoint on the given port number. """ 742 743 this = _rcfproto.new_HttpsEndpoint(*args) 744 try: self.this.append(this) 745 except: self.this = this
746 __swig_destroy__ = _rcfproto.delete_HttpsEndpoint 747 __del__ = lambda self : None;
748 _HttpsEndpoint_swigregister = _rcfproto.HttpsEndpoint_swigregister 749 _HttpsEndpoint_swigregister(HttpsEndpoint) 750
751 -class ServerTransport(_object):
752 """Base class for all server transports. 753 754 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 755 756 __swig_setmethods__ = {} 757 __setattr__ = lambda self, name, value: _swig_setattr(self, ServerTransport, name, value) 758 __swig_getmethods__ = {} 759 __getattr__ = lambda self, name: _swig_getattr(self, ServerTransport, name)
760 - def __init__(self, *args, **kwargs): raise AttributeError("No constructor defined - class is abstract")
761 __repr__ = _swig_repr 762
763 - def GetTransportType(self):
764 """Returns the transport type of this server transport. """ 765 return _rcfproto.ServerTransport_getTransportType(self)
766
767 - def SetMaxIncomingMessageLength(self, *args):
768 """Sets maximum incoming message length. Incoming messages that are larger than this size will be dropped. """ 769 return _rcfproto.ServerTransport_setMaxIncomingMessageLength(self, *args)
770
772 """Returns maximum incoming message length. """ 773 return _rcfproto.ServerTransport_getMaxIncomingMessageLength(self)
774
775 - def SetConnectionLimit(self, *args):
776 """Sets the maximum number of simultaneous connections to the server transport. """ 777 return _rcfproto.ServerTransport_setConnectionLimit(self, *args)
778
779 - def GetConnectionLimit(self):
780 """Returns the maximum number of simultaneous connections to the server transport. """ 781 return _rcfproto.ServerTransport_getConnectionLimit(self)
782
783 - def SetInitialNumberOfConnections(self, *args):
784 """Sets the initial number of listening connections that are created when the server transport starts. """ 785 return _rcfproto.ServerTransport_setInitialNumberOfConnections(self, *args)
786
788 """Returns the initial number of listening connections that are created when the server transport starts. """ 789 return _rcfproto.ServerTransport_getInitialNumberOfConnections(self)
790
791 - def SetThreadPool(self, *args):
792 """Sets the thread pool that the server transport will use. """ 793 return _rcfproto.ServerTransport_setThreadPool(self, *args)
794
795 - def SetSupportedProtocols(self, *args):
796 """Sets the list of supported protocols the server transport supports. Clients that connect without using one of the supported protocols are dropped. If the list of supported protocols is empty, all protocols are allowed. """ 797 return _rcfproto.ServerTransport_setSupportedProtocols(self, *args)
798 - def GetSupportedProtocols(self): return _rcfproto.ServerTransport_getSupportedProtocols(self)
799 __swig_destroy__ = _rcfproto.delete_ServerTransport 800 __del__ = lambda self : None;
801 _ServerTransport_swigregister = _rcfproto.ServerTransport_swigregister 802 _ServerTransport_swigregister(ServerTransport) 803
804 -class ClientTransport(_object):
805 """Base class for all client transports. 806 807 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 808 809 __swig_setmethods__ = {} 810 __setattr__ = lambda self, name, value: _swig_setattr(self, ClientTransport, name, value) 811 __swig_getmethods__ = {} 812 __getattr__ = lambda self, name: _swig_getattr(self, ClientTransport, name)
813 - def __init__(self, *args, **kwargs): raise AttributeError("No constructor defined - class is abstract")
814 __repr__ = _swig_repr 815
816 - def GetTransportType(self):
817 """Returns the transport type of this client transport. """ 818 return _rcfproto.ClientTransport_getTransportType(self)
819
820 - def SetMaxIncomingMessageLength(self, *args):
821 """Sets maximum incoming message length. Incoming messages that are larger than this size will be dropped. """ 822 return _rcfproto.ClientTransport_setMaxIncomingMessageLength(self, *args)
823
825 """Returns maximum incoming message length. """ 826 return _rcfproto.ClientTransport_getMaxIncomingMessageLength(self)
827
828 - def GetLastRequestSize(self):
829 """Returns the byte size of the last request sent on the client transport. """ 830 return _rcfproto.ClientTransport_getLastRequestSize(self)
831
832 - def GetLastResponseSize(self):
833 """Returns the byte size of the last response received on the client transport. """ 834 return _rcfproto.ClientTransport_getLastResponseSize(self)
835
836 - def GetRunningTotalBytesSent(self):
837 """Returns the running total of bytes sent on the client transport. """ 838 return _rcfproto.ClientTransport_getRunningTotalBytesSent(self)
839
841 """Returns the running total of bytes received on the client transport. """ 842 return _rcfproto.ClientTransport_getRunningTotalBytesReceived(self)
843
844 - def ResetRunningTotals(self):
845 """Resets the bytes-sent and bytes-received running totals to zero. """ 846 return _rcfproto.ClientTransport_resetRunningTotals(self)
847 __swig_destroy__ = _rcfproto.delete_ClientTransport 848 __del__ = lambda self : None;
849 _ClientTransport_swigregister = _rcfproto.ClientTransport_swigregister 850 _ClientTransport_swigregister(ClientTransport) 851
852 -class _SwigCallbackArgs(_object):
853 __swig_setmethods__ = {} 854 __setattr__ = lambda self, name, value: _swig_setattr(self, _SwigCallbackArgs, name, value) 855 __swig_getmethods__ = {} 856 __getattr__ = lambda self, name: _swig_getattr(self, _SwigCallbackArgs, name) 857 __repr__ = _swig_repr 858 __swig_setmethods__["mErrorString"] = _rcfproto._SwigCallbackArgs_mErrorString_set 859 __swig_getmethods__["mErrorString"] = _rcfproto._SwigCallbackArgs_mErrorString_get 860 if _newclass:mErrorString = _swig_property(_rcfproto._SwigCallbackArgs_mErrorString_get, _rcfproto._SwigCallbackArgs_mErrorString_set) 861 __swig_setmethods__["mCertificatePtr"] = _rcfproto._SwigCallbackArgs_mCertificatePtr_set 862 __swig_getmethods__["mCertificatePtr"] = _rcfproto._SwigCallbackArgs_mCertificatePtr_get 863 if _newclass:mCertificatePtr = _swig_property(_rcfproto._SwigCallbackArgs_mCertificatePtr_get, _rcfproto._SwigCallbackArgs_mCertificatePtr_set)
864 - def __init__(self):
865 this = _rcfproto.new__SwigCallbackArgs() 866 try: self.this.append(this) 867 except: self.this = this
868 __swig_destroy__ = _rcfproto.delete__SwigCallbackArgs 869 __del__ = lambda self : None; 870 __SwigCallbackArgs_swigregister = _rcfproto._SwigCallbackArgs_swigregister 871 __SwigCallbackArgs_swigregister(_SwigCallbackArgs) 872
873 -class _SwigCallback(_object):
874 __swig_setmethods__ = {} 875 __setattr__ = lambda self, name, value: _swig_setattr(self, _SwigCallback, name, value) 876 __swig_getmethods__ = {} 877 __getattr__ = lambda self, name: _swig_getattr(self, _SwigCallback, name) 878 __repr__ = _swig_repr
879 - def __init__(self):
880 if self.__class__ == _SwigCallback: 881 _self = None 882 else: 883 _self = self 884 this = _rcfproto.new__SwigCallback(_self, ) 885 try: self.this.append(this) 886 except: self.this = this
887 __swig_destroy__ = _rcfproto.delete__SwigCallback 888 __del__ = lambda self : None;
889 - def Run(self): return _rcfproto._SwigCallback_Run(self)
890 - def ProtoRpcBegin(self, *args): return _rcfproto._SwigCallback_ProtoRpcBegin(self, *args)
891 - def ValidateCertificate(self, *args): return _rcfproto._SwigCallback_ValidateCertificate(self, *args)
892 - def __disown__(self):
893 self.this.disown() 894 _rcfproto.disown__SwigCallback(self) 895 return weakref_proxy(self)
896 __SwigCallback_swigregister = _rcfproto._SwigCallback_swigregister 897 __SwigCallback_swigregister(_SwigCallback) 898
899 -class RcfProtoChannel(google.protobuf.service.RpcChannel):
900 """Represents a single RPC connection to a server. 901 902 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 903 904 __swig_setmethods__ = {} 905 __setattr__ = lambda self, name, value: _swig_setattr(self, RcfProtoChannel, name, value) 906 __swig_getmethods__ = {} 907 __getattr__ = lambda self, name: _swig_getattr(self, RcfProtoChannel, name) 908 __repr__ = _swig_repr 909
910 - def __init__(self, *args):
911 """Constructs a RPC channel from an endpoint. """ 912 913 this = _rcfproto.new_RcfProtoChannel(*args) 914 try: self.this.append(this) 915 except: self.this = this
916 - def _CallMethodSwig_WithCopy(self, *args): return _rcfproto.RcfProtoChannel__CallMethodSwig_WithCopy(self, *args)
917 - def _GetResponseBuffer_WithCopy(self): return _rcfproto.RcfProtoChannel__GetResponseBuffer_WithCopy(self)
918
919 - def Failed(self):
920 """After a call has finished, returns true if the call failed. The possible reasons for failure depend on the RPC implementation. Failed() must not be called before a call has finished. If Failed() returns true, the contents of the response message are undefined. """ 921 return _rcfproto.RcfProtoChannel_Failed(self)
922
923 - def ErrorText(self):
924 """If Failed() is true, returns a human-readable description of the error. """ 925 return _rcfproto.RcfProtoChannel_ErrorText(self)
926
927 - def StartCancel(self):
928 """Advises the RPC system that the caller desires that the RPC call be canceled. The RPC system may cancel it immediately, may wait awhile and then cancel it, or may not even cancel the call at all. If the call is canceled, the "done" callback will still be called and the RpcController will indicate that the call failed at that time. """ 929 return _rcfproto.RcfProtoChannel_StartCancel(self)
930 - def Completed(self): return _rcfproto.RcfProtoChannel_Completed(self)
931
932 - def Connect(self):
933 """Connects to the server. """ 934 return _rcfproto.RcfProtoChannel_connect(self)
935
936 - def Disconnect(self):
937 """Disconencts from the server. """ 938 return _rcfproto.RcfProtoChannel_disconnect(self)
939
940 - def SetRemoteCallTimeoutMs(self, *args):
941 """Sets the remote call timeout value, in milliseconds. """ 942 return _rcfproto.RcfProtoChannel_setRemoteCallTimeoutMs(self, *args)
943
944 - def GetRemoteCallTimeoutMs(self):
945 """Gets the remote call timeout value, in milliseconds. """ 946 return _rcfproto.RcfProtoChannel_getRemoteCallTimeoutMs(self)
947
948 - def SetConnectTimeoutMs(self, *args):
949 """Sets the connect timeout value, in milliseconds. """ 950 return _rcfproto.RcfProtoChannel_setConnectTimeoutMs(self, *args)
951
952 - def GetConnectTimeoutMs(self):
953 """Gets the connect timeout value, in milliseconds. """ 954 return _rcfproto.RcfProtoChannel_getConnectTimeoutMs(self)
955
956 - def SetTransportProtocol(self, *args):
957 """Sets the transport protocol being used by the channel. """ 958 return _rcfproto.RcfProtoChannel_setTransportProtocol(self, *args)
959
960 - def GetTransportProtocol(self):
961 """Gets the transport protocol being used by the channel. """ 962 return _rcfproto.RcfProtoChannel_getTransportProtocol(self)
963
964 - def SetAsynchronousRpcMode(self, *args):
965 """Sets the asynchronous RPC mode. By default the asynchronous RPC mode is false. """ 966 return _rcfproto.RcfProtoChannel_setAsynchronousRpcMode(self, *args)
967
968 - def GetAsynchronousRpcMode(self):
969 """Gets the asynchronous RPC mode. """ 970 return _rcfproto.RcfProtoChannel_getAsynchronousRpcMode(self)
971
972 - def SetPingBackIntervalMs(self, *args):
973 """Sets the ping back interval of the connection, in milliseconds. Ping backs are sent from the server back to the client, while a remote call is in progress. """ 974 return _rcfproto.RcfProtoChannel_setPingBackIntervalMs(self, *args)
975
976 - def GetPingBackIntervalMs(self):
977 """Returns the ping back interval of the connection. """ 978 return _rcfproto.RcfProtoChannel_getPingBackIntervalMs(self)
979
980 - def SetHttpProxy(self, *args):
981 """Sets the network address of the HTTP proxy server, through which to route remote calls. Only valid when using a HTTP or HTTPS endpoint. """ 982 return _rcfproto.RcfProtoChannel_setHttpProxy(self, *args)
983
984 - def GetHttpProxy(self):
985 """Returns the network address of the HTTP proxy server. """ 986 return _rcfproto.RcfProtoChannel_getHttpProxy(self)
987
988 - def SetHttpProxyPort(self, *args):
989 """Sets the port number of the HTTP proxy server, through which to route remote calls. Only valid when using a HTTP or HTTPS endpoint. """ 990 return _rcfproto.RcfProtoChannel_setHttpProxyPort(self, *args)
991
992 - def GetHttpProxyPort(self):
993 """Returns the port number of the HTTP proxy server. """ 994 return _rcfproto.RcfProtoChannel_getHttpProxyPort(self)
995
996 - def GetTransportType(self):
997 """Returns the transport type of the connection. """ 998 return _rcfproto.RcfProtoChannel_getTransportType(self)
999
1000 - def SetUsername(self, *args):
1001 """Sets the Windows username to use when connecting. Only valid for NTLM and Kerberos transport protocols. """ 1002 return _rcfproto.RcfProtoChannel_setUsername(self, *args)
1003
1004 - def GetUsername(self):
1005 """Returns the Windows username to use when connecting. """ 1006 return _rcfproto.RcfProtoChannel_getUsername(self)
1007
1008 - def SetPassword(self, *args):
1009 """Sets the Windows password to use when connecting. Only valid for NTLM and Kerberos transport protocols. """ 1010 return _rcfproto.RcfProtoChannel_setPassword(self, *args)
1011
1012 - def GetPassword(self):
1013 """Returns the Windows password to use when connecting. """ 1014 return _rcfproto.RcfProtoChannel_getPassword(self)
1015
1016 - def SetKerberosSpn(self, *args):
1017 """Sets the Kerberos SPN to use when connecting. Only valid for Kerberos transport protocols. """ 1018 return _rcfproto.RcfProtoChannel_setKerberosSpn(self, *args)
1019
1020 - def GetKerberosSpn(self):
1021 """Returns the Kerberos SPN to use when connecting. """ 1022 return _rcfproto.RcfProtoChannel_getKerberosSpn(self)
1023
1024 - def SetEnableCompression(self, *args):
1025 """Sets the transport level compression setting for this connection. """ 1026 return _rcfproto.RcfProtoChannel_setEnableCompression(self, *args)
1027
1028 - def GetEnableCompression(self):
1029 """Returns the transport level compression setting for this connection. """ 1030 return _rcfproto.RcfProtoChannel_getEnableCompression(self)
1031
1032 - def SetCertificate(self, *args):
1033 """Sets the SSL certificate for the channel. """ 1034 return _rcfproto.RcfProtoChannel_setCertificate(self, *args)
1035
1036 - def GetCertificate(self):
1037 """Gets the SSL certificate for the channel. """ 1038 return _rcfproto.RcfProtoChannel_getCertificate(self)
1039
1040 - def SetCaCertificate(self, *args):
1041 """Sets the certificate authority for the channel. """ 1042 return _rcfproto.RcfProtoChannel_setCaCertificate(self, *args)
1043
1044 - def GetCaCertificate(self):
1045 """Gets the certificate authority for the channel. """ 1046 return _rcfproto.RcfProtoChannel_getCaCertificate(self)
1047
1048 - def SetOpenSslCipherSuite(self, *args):
1049 """Sets the OpenSSL cipher suite. Only applicable when using OpenSSL as the SSL implementation. """ 1050 return _rcfproto.RcfProtoChannel_setOpenSslCipherSuite(self, *args)
1051
1052 - def GetOpenSslCipherSuite(self):
1053 """Gets the OpenSSL cipher suite. """ 1054 return _rcfproto.RcfProtoChannel_getOpenSslCipherSuite(self)
1055
1057 """Sets the Schannel certificate validation setting. Only applicable when using Schannel as the SSL implementation. If this setting is non-empty, it will be used by Schannel to automatically validate peer certificates. """ 1058 return _rcfproto.RcfProtoChannel_setEnableSchannelCertificateValidation(self, *args)
1059
1061 """Gets the Schannel certificate validation setting. """ 1062 return _rcfproto.RcfProtoChannel_getEnableSchannelCertificateValidation(self)
1063 - def _setCertificateValidationCallback(self, *args): return _rcfproto.RcfProtoChannel__setCertificateValidationCallback(self, *args)
1064
1065 - def SetSslImplementation(self, *args):
1066 """Sets the SSL implementation to be used by the channel. """ 1067 return _rcfproto.RcfProtoChannel_setSslImplementation(self, *args)
1068
1069 - def GetSslImplementation(self):
1070 """Gets the SSL implementation. """ 1071 return _rcfproto.RcfProtoChannel_getSslImplementation(self)
1072 __swig_destroy__ = _rcfproto.delete_RcfProtoChannel 1073 __del__ = lambda self : None; 1074 1075 # BEGIN INSERTED CODE 1076 1077
1078 - def CallMethod(self, methodDesc, controller, request, responsePrototype, done):
1079 """Gets the certificate validation callback. """ 1080 1081 rcfprotoimpl.RcfProtoChannelImpl.CallMethod(self, methodDesc, controller, request, responsePrototype, done)
1082
1083 - def GetResponse(self):
1084 return rcfprotoimpl.RcfProtoChannelImpl.GetResponse(self);
1085
1086 - def SetCertificateValidationCallback(self, certValidationCallback):
1087 rcfprotoimpl.RcfProtoChannelImpl.SetCertificateValidationCallback(self, certValidationCallback);
1088 1089 # END INSERTED CODE 1090 1091 1092 _RcfProtoChannel_swigregister = _rcfproto.RcfProtoChannel_swigregister 1093 _RcfProtoChannel_swigregister(RcfProtoChannel) 1094
1095 -class RcfProtoSession(_object):
1096 """Represents the server-side session associated with a RPC connection. 1097 1098 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 1099 1100 __swig_setmethods__ = {} 1101 __setattr__ = lambda self, name, value: _swig_setattr(self, RcfProtoSession, name, value) 1102 __swig_getmethods__ = {} 1103 __getattr__ = lambda self, name: _swig_getattr(self, RcfProtoSession, name)
1104 - def __init__(self, *args, **kwargs): raise AttributeError("No constructor defined")
1105 __repr__ = _swig_repr 1106
1107 - def SetFailed(self, *args):
1108 """Causes Failed() to return true on the client side. "reason" will be incorporated into the message returned by ErrorText(). If you find you need to return machine-readable information about failures, you should incorporate it into your response protocol buffer and should NOT call SetFailed(). """ 1109 return _rcfproto.RcfProtoSession_SetFailed(self, *args)
1110
1111 - def IsCanceled(self):
1112 """If true, indicates that the client canceled the RPC, so the server may as well give up on replying to it. The server should still call the final "done" callback. """ 1113 return _rcfproto.RcfProtoSession_IsCanceled(self)
1114 - def _Commit(self, *args): return _rcfproto.RcfProtoSession__Commit(self, *args)
1115 - def _GetRequestBuffer_WithCopy(self): return _rcfproto.RcfProtoSession__GetRequestBuffer_WithCopy(self)
1116 - def _SetResponseBuffer_WithCopy(self, *args): return _rcfproto.RcfProtoSession__SetResponseBuffer_WithCopy(self, *args)
1117
1118 - def GetClientUsername(self):
1119 """Returns the Windows username of the client, if a NTLM or Kerberos transport protocol is being used. """ 1120 return _rcfproto.RcfProtoSession_getClientUsername(self)
1121
1122 - def GetTransportProtocol(self):
1123 """Returns the transport protocol in use on this server session. """ 1124 return _rcfproto.RcfProtoSession_getTransportProtocol(self)
1125
1126 - def GetTransportType(self):
1127 """Returns the transport type of this server session. """ 1128 return _rcfproto.RcfProtoSession_getTransportType(self)
1129
1130 - def GetEnableCompression(self):
1131 """Returns true if compression is enabled for this server session, and false otherwise. Compression is enabled by the client. """ 1132 return _rcfproto.RcfProtoSession_getEnableCompression(self)
1133
1134 - def GetConnectionDuration(self):
1135 """Returns the duration of the client connection, in milliseconds. """ 1136 return _rcfproto.RcfProtoSession_getConnectionDuration(self)
1137
1138 - def GetRemoteCallCount(self):
1139 """Returns the number of remote calls executed on the server session so far. """ 1140 return _rcfproto.RcfProtoSession_getRemoteCallCount(self)
1141
1142 - def GetTotalBytesReceived(self):
1143 """Returns the total number of bytes received by the server session so far. """ 1144 return _rcfproto.RcfProtoSession_getTotalBytesReceived(self)
1145
1146 - def GetTotalBytesSent(self):
1147 """Returns the total number of bytes sent from the server session so far. """ 1148 return _rcfproto.RcfProtoSession_getTotalBytesSent(self)
1149 __swig_destroy__ = _rcfproto.delete_RcfProtoSession 1150 __del__ = lambda self : None;
1151 _RcfProtoSession_swigregister = _rcfproto.RcfProtoSession_swigregister 1152 _RcfProtoSession_swigregister(RcfProtoSession) 1153
1154 -class RcfProtoServer(_object):
1155 """Serves up Protocol Buffer-based services to clients, over one or more server transports. 1156 1157 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 1158 1159 __swig_setmethods__ = {} 1160 __setattr__ = lambda self, name, value: _swig_setattr(self, RcfProtoServer, name, value) 1161 __swig_getmethods__ = {} 1162 __getattr__ = lambda self, name: _swig_getattr(self, RcfProtoServer, name) 1163 __repr__ = _swig_repr
1164 - def __init__(self, *args):
1165 this = _rcfproto.new_RcfProtoServer(*args) 1166 try: self.this.append(this) 1167 except: self.this = this
1168 __swig_destroy__ = _rcfproto.delete_RcfProtoServer 1169 __del__ = lambda self : None; 1170
1171 - def Start(self):
1172 """Starts the RCFProto server. """ 1173 1174 self.callbackTable = rcfprotoimpl.SwigCallback_ServerRpc(self) 1175 return _rcfproto.RcfProtoServer_start(self)
1176 1177
1178 - def Stop(self):
1179 """Stops the RCFProto server. """ 1180 return _rcfproto.RcfProtoServer_stop(self)
1181 - def _setCallbackTable(self, *args): return _rcfproto.RcfProtoServer__setCallbackTable(self, *args)
1182
1183 - def SetThreadPool(self, *args):
1184 """Sets the thread pool the server will use. Thread pools can also be assigned to individual transports. """ 1185 return _rcfproto.RcfProtoServer_setThreadPool(self, *args)
1186
1187 - def GetThreadPool(self):
1188 """Returns the thread pool the server is using. """ 1189 return _rcfproto.RcfProtoServer_getThreadPool(self)
1190
1191 - def AddEndpoint(self, *args):
1192 """Adds a transport endpoint to the server. """ 1193 return _rcfproto.RcfProtoServer_addEndpoint(self, *args)
1194
1195 - def SetSupportedTransportProtocols(self, *args):
1196 """Sets the list of supported protocols the server supports. Clients that connect without using one of the supported protocols are dropped. If the list of supported protocols is empty, all protocols are allowed. Note that supported protocols can also be specified on a server transport, in which case the server transport setting overrides the server setting. """ 1197 return _rcfproto.RcfProtoServer_setSupportedTransportProtocols(self, *args)
1198
1199 - def GetSupportedTransportProtocols(self):
1200 """Returns the list of supported protocols for the server. """ 1201 return _rcfproto.RcfProtoServer_getSupportedTransportProtocols(self)
1202
1203 - def SetSessionTimeoutMs(self, *args):
1204 """Sets the session timeout value, in milliseconds. Client connections that are idle for this amount of time will be dropped by the server. """ 1205 return _rcfproto.RcfProtoServer_setSessionTimeoutMs(self, *args)
1206
1207 - def GetSessionTimeoutMs(self):
1208 """Returns the session timeout value, in milliseconds. """ 1209 return _rcfproto.RcfProtoServer_getSessionTimeoutMs(self)
1210
1211 - def SetSessionHarvestingIntervalMs(self, *args):
1212 """Sets the session harvesting interval, in milliseconds. This setting determines how often the server will scan for idle client connections. """ 1213 return _rcfproto.RcfProtoServer_setSessionHarvestingIntervalMs(self, *args)
1214
1215 - def GetSessionHarvestingIntervalMs(self):
1216 """Returns the session harvesting interval, in milliseconds. """ 1217 return _rcfproto.RcfProtoServer_getSessionHarvestingIntervalMs(self)
1218
1219 - def SetCertificate(self, *args):
1220 """Sets the SSL certificate of the server. """ 1221 return _rcfproto.RcfProtoServer_setCertificate(self, *args)
1222
1223 - def GetCertificate(self):
1224 """Gets the SSL certificate of the server. """ 1225 return _rcfproto.RcfProtoServer_getCertificate(self)
1226
1227 - def SetOpenSslCipherSuite(self, *args):
1228 """Sets the OpenSSL cipher suite. Only applicable when OpenSSL is used as the SSL implementation. """ 1229 return _rcfproto.RcfProtoServer_setOpenSslCipherSuite(self, *args)
1230
1231 - def GetOpenSslCipherSuite(self):
1232 """Gets the OpenSSL cipher suite. """ 1233 return _rcfproto.RcfProtoServer_getOpenSslCipherSuite(self)
1234
1235 - def SetCaCertificate(self, *args):
1236 """Sets the SSL certificate authority of the server. """ 1237 return _rcfproto.RcfProtoServer_setCaCertificate(self, *args)
1238
1239 - def GetCaCertificate(self):
1240 """Gets the SSL certificate authority of the server. """ 1241 return _rcfproto.RcfProtoServer_getCaCertificate(self)
1242
1243 - def SetEnableSchannelCertificateValidation(self, *args):
1244 """Sets the Schannel certificate validation setting. Only applicable when using Schannel as the SSL implementation. If this setting is non-empty, it will be used by Schannel to automatically validate peer certificates. """ 1245 return _rcfproto.RcfProtoServer_setEnableSchannelCertificateValidation(self, *args)
1246
1247 - def GetEnableSchannelCertificateValidation(self):
1248 """Gets the Schannel certificate validation setting. """ 1249 return _rcfproto.RcfProtoServer_getEnableSchannelCertificateValidation(self)
1250 - def SetSslImplementation(self, *args): return _rcfproto.RcfProtoServer_setSslImplementation(self, *args)
1251
1252 - def GetSslImplementation(self):
1253 """Gets the SSL implementation of the server. """ 1254 return _rcfproto.RcfProtoServer_getSslImplementation(self)
1255 # BEGIN INSERTED CODE
1256 - def BindService(self, svc):
1257 rcfprotoimpl.RcfProtoServerImpl.BindService(self, svc)
1258 1259 1260 # END INSERTED CODE 1261 1262 _RcfProtoServer_swigregister = _rcfproto.RcfProtoServer_swigregister 1263 _RcfProtoServer_swigregister(RcfProtoServer) 1264 1265 # This file is compatible with both classic and new-style classes. 1266 1267
1268 -class RcfProtoController(google.protobuf.service.RpcController) :
1269 """RPC controller interface, for both server-side and client-side code. 1270 1271 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 1272 1273
1274 - def __init__(self, channel = None, session = None):
1275 if channel: 1276 self.channel = channel 1277 self.session = None 1278 elif session: 1279 self.channel = None 1280 self.session = session
1281 1282
1283 - def Reset(self):
1284 """Resets the RcfProtoController to its initial state so that it may be reused in a new call. Must not be called while an RPC is in progress. """ 1285 1286 self.channel = None 1287 self.session = None
1288 1289
1290 - def Failed(self):
1291 """Client-side: After a call has finished, returns true if the call failed. Failed() must not be called before a call has finished. If Failed() returns true, the contents of the response message are undefined. """ 1292 1293 return self.channel.Failed()
1294 1295 1296
1297 - def ErrorText(self):
1298 """Client-side: If Failed() is true, returns a human-readable description of the error. """ 1299 1300 return self.channel.ErrorText()
1301 1302
1303 - def StartCancel(self):
1304 """Client-side: Cancels an RPC that is in progress. Once canceled, the "done" callback will still be called and the RcfProtoController will indicate that the call failed at that time. """ 1305 1306 self.channel.StartCancel()
1307 1308
1309 - def Completed(self):
1310 """Client-side: Returns false while a call is in progress, and true after the call has been completed and the completion handler run (if a completion handler was provided). """ 1311 1312 return self.channel.Completed()
1313 1314 # Server-side methods below 1315 1316
1317 - def SetFailed(self, reason):
1318 """Server-side: Causes Failed() to return true on the client-side. "reason" will be incorporated into the message returned by ErrorText(). If you find you need to return machine-readable information about failures, you should incorporate it into your response protocol buffer and should NOT call SetFailed(). """ 1319 1320 self.session.SetFailed(reason)
1321 1322
1323 - def IsCanceled(self):
1324 """Server-side: If true, indicates that the client canceled the RPC, so the server may as well give up on replying to it. The server should still call the final "done" callback. """ 1325 1326 self.session.IsCanceled()
1327 1328
1329 - def NotifyOnCancel(self, callback):
1330 """Asks that the given callback be called when the RPC is canceled. The callback will always be called exactly once. If the RPC completes without being canceled, the callback will be called after completion. If the RPC has already been canceled when NotifyOnCancel() is called, the callback will be called immediately. NotifyOnCancel() must be called no more than once per request. """ 1331 1332 self.session.NotifyOnCancel(callback)
1333
1334 - def GetSession(self):
1335 return self.session
1336
1337 - def GetChannel(self):
1338 return self.channel
1339 1340 1341 import rcfprotoimpl 1342 from rcfprotoimpl import * 1343