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 175
176 -def IsProBuild():
177 """ """ 178 179 return _rcfproto.isProBuild()
180 isProBuild = _rcfproto.isProBuild
181 -class LogTarget(_object):
182 """Base class for log targets. Log targets are passed to the enableLogging() function, to configure RCF logging. 183 184 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 185 186 __swig_setmethods__ = {} 187 __setattr__ = lambda self, name, value: _swig_setattr(self, LogTarget, name, value) 188 __swig_getmethods__ = {} 189 __getattr__ = lambda self, name: _swig_getattr(self, LogTarget, name)
190 - def __init__(self, *args, **kwargs): raise AttributeError("No constructor defined")
191 __repr__ = _swig_repr 192 __swig_destroy__ = _rcfproto.delete_LogTarget 193 __del__ = lambda self : None;
194 _LogTarget_swigregister = _rcfproto.LogTarget_swigregister 195 _LogTarget_swigregister(LogTarget) 196
197 -class LogToStdout(LogTarget):
198 """Configures log output to be directed to standard output. 199 200 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 201 202 __swig_setmethods__ = {} 203 for _s in [LogTarget]: __swig_setmethods__.update(getattr(_s,'__swig_setmethods__',{})) 204 __setattr__ = lambda self, name, value: _swig_setattr(self, LogToStdout, name, value) 205 __swig_getmethods__ = {} 206 for _s in [LogTarget]: __swig_getmethods__.update(getattr(_s,'__swig_getmethods__',{})) 207 __getattr__ = lambda self, name: _swig_getattr(self, LogToStdout, name) 208 __repr__ = _swig_repr
209 - def __init__(self):
210 this = _rcfproto.new_LogToStdout() 211 try: self.this.append(this) 212 except: self.this = this
213 __swig_destroy__ = _rcfproto.delete_LogToStdout 214 __del__ = lambda self : None; 215 _LogToStdout_swigregister = _rcfproto.LogToStdout_swigregister 216 _LogToStdout_swigregister(LogToStdout) 217
218 -class LogToDebugWindow(LogTarget):
219 """Configures log output to be directed to Windows debug output. 220 221 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 222 223 __swig_setmethods__ = {} 224 for _s in [LogTarget]: __swig_setmethods__.update(getattr(_s,'__swig_setmethods__',{})) 225 __setattr__ = lambda self, name, value: _swig_setattr(self, LogToDebugWindow, name, value) 226 __swig_getmethods__ = {} 227 for _s in [LogTarget]: __swig_getmethods__.update(getattr(_s,'__swig_getmethods__',{})) 228 __getattr__ = lambda self, name: _swig_getattr(self, LogToDebugWindow, name) 229 __repr__ = _swig_repr
230 - def __init__(self):
231 this = _rcfproto.new_LogToDebugWindow() 232 try: self.this.append(this) 233 except: self.this = this
234 __swig_destroy__ = _rcfproto.delete_LogToDebugWindow 235 __del__ = lambda self : None; 236 _LogToDebugWindow_swigregister = _rcfproto.LogToDebugWindow_swigregister 237 _LogToDebugWindow_swigregister(LogToDebugWindow) 238
239 -class LogToEventLog(LogTarget):
240 """Configures log output to be directed to the Windows event log. 241 242 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 243 244 __swig_setmethods__ = {} 245 for _s in [LogTarget]: __swig_setmethods__.update(getattr(_s,'__swig_setmethods__',{})) 246 __setattr__ = lambda self, name, value: _swig_setattr(self, LogToEventLog, name, value) 247 __swig_getmethods__ = {} 248 for _s in [LogTarget]: __swig_getmethods__.update(getattr(_s,'__swig_getmethods__',{})) 249 __getattr__ = lambda self, name: _swig_getattr(self, LogToEventLog, name) 250 __repr__ = _swig_repr
251 - def __init__(self, *args):
252 this = _rcfproto.new_LogToEventLog(*args) 253 try: self.this.append(this) 254 except: self.this = this
255 __swig_destroy__ = _rcfproto.delete_LogToEventLog 256 __del__ = lambda self : None; 257 _LogToEventLog_swigregister = _rcfproto.LogToEventLog_swigregister 258 _LogToEventLog_swigregister(LogToEventLog) 259
260 -class LogToFile(LogTarget):
261 """Configures log output to be directed to a log file. 262 263 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 264 265 __swig_setmethods__ = {} 266 for _s in [LogTarget]: __swig_setmethods__.update(getattr(_s,'__swig_setmethods__',{})) 267 __setattr__ = lambda self, name, value: _swig_setattr(self, LogToFile, name, value) 268 __swig_getmethods__ = {} 269 for _s in [LogTarget]: __swig_getmethods__.update(getattr(_s,'__swig_getmethods__',{})) 270 __getattr__ = lambda self, name: _swig_getattr(self, LogToFile, name) 271 __repr__ = _swig_repr
272 - def __init__(self, *args):
273 this = _rcfproto.new_LogToFile(*args) 274 try: self.this.append(this) 275 except: self.this = this
276 __swig_destroy__ = _rcfproto.delete_LogToFile 277 __del__ = lambda self : None; 278 _LogToFile_swigregister = _rcfproto.LogToFile_swigregister 279 _LogToFile_swigregister(LogToFile) 280 281 282
283 -def EnableLogging(*args):
284 """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. """ 285 286 return _rcfproto.enableLogging(*args)
287 enableLogging = _rcfproto.enableLogging 288 289
290 -def DisableLogging():
291 """Disables logging for the RCF runtime. """ 292 293 return _rcfproto.disableLogging()
294 disableLogging = _rcfproto.disableLogging 295 Tp_Unspecified = _rcfproto.Tp_Unspecified 296 Tp_Clear = _rcfproto.Tp_Clear 297 Tp_Ntlm = _rcfproto.Tp_Ntlm 298 Tp_Kerberos = _rcfproto.Tp_Kerberos 299 Tp_Negotiate = _rcfproto.Tp_Negotiate 300 Tp_Ssl = _rcfproto.Tp_Ssl 301 Tt_Unknown = _rcfproto.Tt_Unknown 302 Tt_Tcp = _rcfproto.Tt_Tcp 303 Tt_Udp = _rcfproto.Tt_Udp 304 Tt_Win32NamedPipe = _rcfproto.Tt_Win32NamedPipe 305 Tt_UnixNamedPipe = _rcfproto.Tt_UnixNamedPipe 306 Tt_Http = _rcfproto.Tt_Http 307 Tt_Https = _rcfproto.Tt_Https 308 Si_Schannel = _rcfproto.Si_Schannel 309 Si_OpenSsl = _rcfproto.Si_OpenSsl 310 Cl_CurrentUser = _rcfproto.Cl_CurrentUser 311 Cl_LocalMachine = _rcfproto.Cl_LocalMachine 312 Cs_AddressBook = _rcfproto.Cs_AddressBook 313 Cs_AuthRoot = _rcfproto.Cs_AuthRoot 314 Cs_CertificateAuthority = _rcfproto.Cs_CertificateAuthority 315 Cs_Disallowed = _rcfproto.Cs_Disallowed 316 Cs_My = _rcfproto.Cs_My 317 Cs_Root = _rcfproto.Cs_Root 318 Cs_TrustedPeople = _rcfproto.Cs_TrustedPeople 319 Cs_TrustedPublisher = _rcfproto.Cs_TrustedPublisher 320 Cit_Unspecified = _rcfproto.Cit_Unspecified 321 Cit_Win32 = _rcfproto.Cit_Win32 322 Cit_X509 = _rcfproto.Cit_X509
323 -class Certificate(_object):
324 """Base class of all certificate classes. 325 326 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 327 328 __swig_setmethods__ = {} 329 __setattr__ = lambda self, name, value: _swig_setattr(self, Certificate, name, value) 330 __swig_getmethods__ = {} 331 __getattr__ = lambda self, name: _swig_getattr(self, Certificate, name)
332 - def __init__(self, *args, **kwargs): raise AttributeError("No constructor defined")
333 __repr__ = _swig_repr
334 - def _getType(self): return _rcfproto.Certificate__getType(self)
335 - def _downcastToWin32Certificate(self, *args): return _rcfproto.Certificate__downcastToWin32Certificate(self, *args)
336 - def _downcastToX509Certificate(self, *args): return _rcfproto.Certificate__downcastToX509Certificate(self, *args)
337 __swig_destroy__ = _rcfproto.delete_Certificate 338 __del__ = lambda self : None;
339 _Certificate_swigregister = _rcfproto.Certificate_swigregister 340 _Certificate_swigregister(Certificate) 341
342 -class PemCertificate(Certificate):
343 """Use this class to load a certificate in .pem format. Only applicable to OpenSSL. 344 345 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 346 347 __swig_setmethods__ = {} 348 for _s in [Certificate]: __swig_setmethods__.update(getattr(_s,'__swig_setmethods__',{})) 349 __setattr__ = lambda self, name, value: _swig_setattr(self, PemCertificate, name, value) 350 __swig_getmethods__ = {} 351 for _s in [Certificate]: __swig_getmethods__.update(getattr(_s,'__swig_getmethods__',{})) 352 __getattr__ = lambda self, name: _swig_getattr(self, PemCertificate, name) 353 __repr__ = _swig_repr 354
355 - def __init__(self, *args):
356 """Loads a .pem certificate, using the given file path and password. """ 357 358 this = _rcfproto.new_PemCertificate(*args) 359 try: self.this.append(this) 360 except: self.this = this
361 __swig_destroy__ = _rcfproto.delete_PemCertificate 362 __del__ = lambda self : None;
363 _PemCertificate_swigregister = _rcfproto.PemCertificate_swigregister 364 _PemCertificate_swigregister(PemCertificate) 365
366 -class X509Certificate(Certificate):
367 """Represents an in-memory certificate, usually from a remote peer. Only applicable to OpenSSL. 368 369 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 370 371 __swig_setmethods__ = {} 372 for _s in [Certificate]: __swig_setmethods__.update(getattr(_s,'__swig_setmethods__',{})) 373 __setattr__ = lambda self, name, value: _swig_setattr(self, X509Certificate, name, value) 374 __swig_getmethods__ = {} 375 for _s in [Certificate]: __swig_getmethods__.update(getattr(_s,'__swig_getmethods__',{})) 376 __getattr__ = lambda self, name: _swig_getattr(self, X509Certificate, name)
377 - def __init__(self, *args, **kwargs): raise AttributeError("No constructor defined")
378 __repr__ = _swig_repr
379 - def _getType(self): return _rcfproto.X509Certificate__getType(self)
380
381 - def GetCertificateName(self):
382 """Gets the name of the certificate. """ 383 return _rcfproto.X509Certificate_getCertificateName(self)
384
385 - def GetIssuerName(self):
386 """Gets the name of the issuer of the certificate. """ 387 return _rcfproto.X509Certificate_getIssuerName(self)
388 __swig_destroy__ = _rcfproto.delete_X509Certificate 389 __del__ = lambda self : None;
390 _X509Certificate_swigregister = _rcfproto.X509Certificate_swigregister 391 _X509Certificate_swigregister(X509Certificate) 392
393 -class Win32Certificate(Certificate):
394 """Represents an in-memory certificate, usually from a remote peer. Only applicable to Schannel. 395 396 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 397 398 __swig_setmethods__ = {} 399 for _s in [Certificate]: __swig_setmethods__.update(getattr(_s,'__swig_setmethods__',{})) 400 __setattr__ = lambda self, name, value: _swig_setattr(self, Win32Certificate, name, value) 401 __swig_getmethods__ = {} 402 for _s in [Certificate]: __swig_getmethods__.update(getattr(_s,'__swig_getmethods__',{})) 403 __getattr__ = lambda self, name: _swig_getattr(self, Win32Certificate, name)
404 - def __init__(self, *args, **kwargs): raise AttributeError("No constructor defined")
405 __repr__ = _swig_repr
406 - def _getType(self): return _rcfproto.Win32Certificate__getType(self)
407
408 - def GetCertificateName(self):
409 """Gets the name of the certificate. """ 410 return _rcfproto.Win32Certificate_getCertificateName(self)
411
412 - def GetIssuerName(self):
413 """Gets the name of the issuer of the certificate. """ 414 return _rcfproto.Win32Certificate_getIssuerName(self)
415
416 - def ExportToPfx(self, *args):
417 """Exports the certificate in PFX format, to the given file path. """ 418 return _rcfproto.Win32Certificate_exportToPfx(self, *args)
419
420 - def FindRootCertificate(self, *args):
421 """Attempts to locate a root certificate for this certificate, in the given certificate store. Returns the root certificate if found, and otherwise null. """ 422 return _rcfproto.Win32Certificate_findRootCertificate(self, *args)
423 __swig_destroy__ = _rcfproto.delete_Win32Certificate 424 __del__ = lambda self : None;
425 _Win32Certificate_swigregister = _rcfproto.Win32Certificate_swigregister 426 _Win32Certificate_swigregister(Win32Certificate) 427
428 -class PfxCertificate(Win32Certificate):
429 """Use this class to load a certificate from .pfx format. Only applicable to Schannel. 430 431 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 432 433 __swig_setmethods__ = {} 434 for _s in [Win32Certificate]: __swig_setmethods__.update(getattr(_s,'__swig_setmethods__',{})) 435 __setattr__ = lambda self, name, value: _swig_setattr(self, PfxCertificate, name, value) 436 __swig_getmethods__ = {} 437 for _s in [Win32Certificate]: __swig_getmethods__.update(getattr(_s,'__swig_getmethods__',{})) 438 __getattr__ = lambda self, name: _swig_getattr(self, PfxCertificate, name) 439 __repr__ = _swig_repr 440
441 - def __init__(self, *args):
442 """Loads a certificate from a .pfx file, using the given file path, password and certificate name. """ 443 444 this = _rcfproto.new_PfxCertificate(*args) 445 try: self.this.append(this) 446 except: self.this = this
447
448 - def AddToStore(self, *args):
449 """Adds the certificate to the given Windows certificate store. """ 450 return _rcfproto.PfxCertificate_addToStore(self, *args)
451 __swig_destroy__ = _rcfproto.delete_PfxCertificate 452 __del__ = lambda self : None;
453 _PfxCertificate_swigregister = _rcfproto.PfxCertificate_swigregister 454 _PfxCertificate_swigregister(PfxCertificate) 455
456 -class StoreCertificate(Win32Certificate):
457 """Represents a certificate in a Windows certificate store. 458 459 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 460 461 __swig_setmethods__ = {} 462 for _s in [Win32Certificate]: __swig_setmethods__.update(getattr(_s,'__swig_setmethods__',{})) 463 __setattr__ = lambda self, name, value: _swig_setattr(self, StoreCertificate, name, value) 464 __swig_getmethods__ = {} 465 for _s in [Win32Certificate]: __swig_getmethods__.update(getattr(_s,'__swig_getmethods__',{})) 466 __getattr__ = lambda self, name: _swig_getattr(self, StoreCertificate, name) 467 __repr__ = _swig_repr 468
469 - def __init__(self, *args):
470 """Loads a certificate from a certificate store. """ 471 472 this = _rcfproto.new_StoreCertificate(*args) 473 try: self.this.append(this) 474 except: self.this = this
475
476 - def RemoveFromStore(self):
477 """Removes the certificate from the store it was loaded from. """ 478 return _rcfproto.StoreCertificate_removeFromStore(self)
479 __swig_destroy__ = _rcfproto.delete_StoreCertificate 480 __del__ = lambda self : None;
481 _StoreCertificate_swigregister = _rcfproto.StoreCertificate_swigregister 482 _StoreCertificate_swigregister(StoreCertificate) 483
484 -class StoreCertificateIterator(_object):
485 """Iterates over the certificates in a Windows certificate store. 486 487 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 488 489 __swig_setmethods__ = {} 490 __setattr__ = lambda self, name, value: _swig_setattr(self, StoreCertificateIterator, name, value) 491 __swig_getmethods__ = {} 492 __getattr__ = lambda self, name: _swig_getattr(self, StoreCertificateIterator, name) 493 __repr__ = _swig_repr 494
495 - def __init__(self, *args):
496 """Constructs a store iterator for the the given certificate location and store. """ 497 498 this = _rcfproto.new_StoreCertificateIterator(*args) 499 try: self.this.append(this) 500 except: self.this = this
501
502 - def MoveNext(self):
503 """Moves to the next certificate in the store. Returns false if there are no more certificates, and true otherwise. """ 504 return _rcfproto.StoreCertificateIterator_moveNext(self)
505
506 - def Reset(self):
507 """Resets the iterator back to the beginning of the store. """ 508 return _rcfproto.StoreCertificateIterator_reset(self)
509
510 - def Current(self):
511 """Returns the current certificate. """ 512 return _rcfproto.StoreCertificateIterator_current(self)
513 __swig_destroy__ = _rcfproto.delete_StoreCertificateIterator 514 __del__ = lambda self : None;
515 _StoreCertificateIterator_swigregister = _rcfproto.StoreCertificateIterator_swigregister 516 _StoreCertificateIterator_swigregister(StoreCertificateIterator) 517 518 519
520 -def SetDefaultSslImplementation(*args):
521 """Sets the default SSL implementation to use (OpenSSL or Schannel). The default is OpenSSL. """ 522 523 return _rcfproto.setDefaultSslImplementation(*args)
524 setDefaultSslImplementation = _rcfproto.setDefaultSslImplementation 525 526
527 -def GetDefaultSslImplementation():
528 """Gets the default SSL implementation. """ 529 530 return _rcfproto.getDefaultSslImplementation()
531 getDefaultSslImplementation = _rcfproto.getDefaultSslImplementation
532 -class IpAddress(_object):
533 """Represents an IP address (IPv4 or IPv6). 534 535 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 536 537 __swig_setmethods__ = {} 538 __setattr__ = lambda self, name, value: _swig_setattr(self, IpAddress, name, value) 539 __swig_getmethods__ = {} 540 __getattr__ = lambda self, name: _swig_getattr(self, IpAddress, name) 541 __repr__ = _swig_repr 542
543 - def __init__(self, *args):
544 """Construct an IP address from a host name """ 545 546 this = _rcfproto.new_IpAddress(*args) 547 try: self.this.append(this) 548 except: self.this = this
549 __swig_destroy__ = _rcfproto.delete_IpAddress 550 __del__ = lambda self : None;
551 _IpAddress_swigregister = _rcfproto.IpAddress_swigregister 552 _IpAddress_swigregister(IpAddress) 553
554 -class ThreadPool(_object):
555 """Represents a server-side thread pool. 556 557 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 558 559 __swig_setmethods__ = {} 560 __setattr__ = lambda self, name, value: _swig_setattr(self, ThreadPool, name, value) 561 __swig_getmethods__ = {} 562 __getattr__ = lambda self, name: _swig_getattr(self, ThreadPool, name) 563 __repr__ = _swig_repr
564 - def __init__(self, *args):
565 this = _rcfproto.new_ThreadPool(*args) 566 try: self.this.append(this) 567 except: self.this = this
568
569 - def SetThreadMinCount(self, *args):
570 """Sets the minimum number of threads in the thread pool. """ 571 return _rcfproto.ThreadPool_setThreadMinCount(self, *args)
572
573 - def GetThreadMinCount(self):
574 """Returns the minimum number of threads in the thread pool. """ 575 return _rcfproto.ThreadPool_getThreadMinCount(self)
576
577 - def SetThreadMaxCount(self, *args):
578 """Sets the maximum number of threads in the thread pool. """ 579 return _rcfproto.ThreadPool_setThreadMaxCount(self, *args)
580
581 - def GetThreadMaxCount(self):
582 """Returns the maximum number of threads in the thread pool. """ 583 return _rcfproto.ThreadPool_getThreadMaxCount(self)
584
585 - def SetThreadIdleTimeoutMs(self, *args):
586 """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. """ 587 return _rcfproto.ThreadPool_setThreadIdleTimeoutMs(self, *args)
588
589 - def GetThreadIdleTimeoutMs(self):
590 """Returns the thread idle timeout value, in milliseconds. """ 591 return _rcfproto.ThreadPool_getThreadIdleTimeoutMs(self)
592
593 - def SetReserveLastThread(self, *args):
594 """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. """ 595 return _rcfproto.ThreadPool_setReserveLastThread(self, *args)
596 - def GetReserveLastThread(self): return _rcfproto.ThreadPool_getReserveLastThread(self)
597
598 - def SetThreadName(self, *args):
599 """Sets the thread name of the thread pool threads, as visible in a debugger. """ 600 return _rcfproto.ThreadPool_setThreadName(self, *args)
601
602 - def GetThreadName(self):
603 """Returns the thread name of the thread pool threads. """ 604 return _rcfproto.ThreadPool_getThreadName(self)
605 __swig_destroy__ = _rcfproto.delete_ThreadPool 606 __del__ = lambda self : None; 607 _ThreadPool_swigregister = _rcfproto.ThreadPool_swigregister 608 _ThreadPool_swigregister(ThreadPool) 609
610 -class Endpoint(_object):
611 """Base class for all network endpoint types. 612 613 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 614 615 __swig_setmethods__ = {} 616 __setattr__ = lambda self, name, value: _swig_setattr(self, Endpoint, name, value) 617 __swig_getmethods__ = {} 618 __getattr__ = lambda self, name: _swig_getattr(self, Endpoint, name)
619 - def __init__(self, *args, **kwargs): raise AttributeError("No constructor defined")
620 __repr__ = _swig_repr 621 __swig_destroy__ = _rcfproto.delete_Endpoint 622 __del__ = lambda self : None;
623 _Endpoint_swigregister = _rcfproto.Endpoint_swigregister 624 _Endpoint_swigregister(Endpoint) 625
626 -class TcpEndpoint(Endpoint):
627 """Represents a TCP endpoint. 628 629 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 630 631 __swig_setmethods__ = {} 632 for _s in [Endpoint]: __swig_setmethods__.update(getattr(_s,'__swig_setmethods__',{})) 633 __setattr__ = lambda self, name, value: _swig_setattr(self, TcpEndpoint, name, value) 634 __swig_getmethods__ = {} 635 for _s in [Endpoint]: __swig_getmethods__.update(getattr(_s,'__swig_getmethods__',{})) 636 __getattr__ = lambda self, name: _swig_getattr(self, TcpEndpoint, name) 637 __repr__ = _swig_repr 638
639 - def __init__(self, *args):
640 """Constructs a TcpEndpoint from a port number. The IP address defaults to 127.0.0.1 . """ 641 642 this = _rcfproto.new_TcpEndpoint(*args) 643 try: self.this.append(this) 644 except: self.this = this
645
646 - def GetIp(self):
647 """Gets the IP address of the TcpEndpoint. """ 648 return _rcfproto.TcpEndpoint_getIp(self)
649
650 - def GetPort(self):
651 """Gets the port number of the TcpEndpoint. """ 652 return _rcfproto.TcpEndpoint_getPort(self)
653
654 - def AsString(self):
655 """Returns a string representation of the TcpEndpoint. """ 656 return _rcfproto.TcpEndpoint_asString(self)
657 __swig_destroy__ = _rcfproto.delete_TcpEndpoint 658 __del__ = lambda self : None;
659 _TcpEndpoint_swigregister = _rcfproto.TcpEndpoint_swigregister 660 _TcpEndpoint_swigregister(TcpEndpoint) 661
662 -class Win32NamedPipeEndpoint(Endpoint):
663 """Represents a Win32 named pipe endpoint. Only available on Windows platforms. 664 665 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 666 667 __swig_setmethods__ = {} 668 for _s in [Endpoint]: __swig_setmethods__.update(getattr(_s,'__swig_setmethods__',{})) 669 __setattr__ = lambda self, name, value: _swig_setattr(self, Win32NamedPipeEndpoint, name, value) 670 __swig_getmethods__ = {} 671 for _s in [Endpoint]: __swig_getmethods__.update(getattr(_s,'__swig_getmethods__',{})) 672 __getattr__ = lambda self, name: _swig_getattr(self, Win32NamedPipeEndpoint, name) 673 __repr__ = _swig_repr 674
675 - def __init__(self, *args):
676 """Constructs a Win32 named pipe endpoint with the given pipe name. """ 677 678 this = _rcfproto.new_Win32NamedPipeEndpoint(*args) 679 try: self.this.append(this) 680 except: self.this = this
681 __swig_destroy__ = _rcfproto.delete_Win32NamedPipeEndpoint 682 __del__ = lambda self : None;
683 _Win32NamedPipeEndpoint_swigregister = _rcfproto.Win32NamedPipeEndpoint_swigregister 684 _Win32NamedPipeEndpoint_swigregister(Win32NamedPipeEndpoint) 685
686 -class UnixLocalEndpoint(Endpoint):
687 """Represents a UNIX local socket endpoint. Only available on UNIX platforms. 688 689 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 690 691 __swig_setmethods__ = {} 692 for _s in [Endpoint]: __swig_setmethods__.update(getattr(_s,'__swig_setmethods__',{})) 693 __setattr__ = lambda self, name, value: _swig_setattr(self, UnixLocalEndpoint, name, value) 694 __swig_getmethods__ = {} 695 for _s in [Endpoint]: __swig_getmethods__.update(getattr(_s,'__swig_getmethods__',{})) 696 __getattr__ = lambda self, name: _swig_getattr(self, UnixLocalEndpoint, name) 697 __repr__ = _swig_repr 698
699 - def __init__(self, *args):
700 """Constructs a UNIX local socket endpoint with the given name. """ 701 702 this = _rcfproto.new_UnixLocalEndpoint(*args) 703 try: self.this.append(this) 704 except: self.this = this
705 __swig_destroy__ = _rcfproto.delete_UnixLocalEndpoint 706 __del__ = lambda self : None;
707 _UnixLocalEndpoint_swigregister = _rcfproto.UnixLocalEndpoint_swigregister 708 _UnixLocalEndpoint_swigregister(UnixLocalEndpoint) 709
710 -class HttpEndpoint(TcpEndpoint):
711 """Represents a HTTP endpoint. 712 713 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 714 715 __swig_setmethods__ = {} 716 for _s in [TcpEndpoint]: __swig_setmethods__.update(getattr(_s,'__swig_setmethods__',{})) 717 __setattr__ = lambda self, name, value: _swig_setattr(self, HttpEndpoint, name, value) 718 __swig_getmethods__ = {} 719 for _s in [TcpEndpoint]: __swig_getmethods__.update(getattr(_s,'__swig_getmethods__',{})) 720 __getattr__ = lambda self, name: _swig_getattr(self, HttpEndpoint, name) 721 __repr__ = _swig_repr 722
723 - def __init__(self, *args):
724 """Constructs an HTTP endpoint on the given port number. """ 725 726 this = _rcfproto.new_HttpEndpoint(*args) 727 try: self.this.append(this) 728 except: self.this = this
729 __swig_destroy__ = _rcfproto.delete_HttpEndpoint 730 __del__ = lambda self : None;
731 _HttpEndpoint_swigregister = _rcfproto.HttpEndpoint_swigregister 732 _HttpEndpoint_swigregister(HttpEndpoint) 733
734 -class HttpsEndpoint(TcpEndpoint):
735 """Represents a HTTPS endpoint. 736 737 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 738 739 __swig_setmethods__ = {} 740 for _s in [TcpEndpoint]: __swig_setmethods__.update(getattr(_s,'__swig_setmethods__',{})) 741 __setattr__ = lambda self, name, value: _swig_setattr(self, HttpsEndpoint, name, value) 742 __swig_getmethods__ = {} 743 for _s in [TcpEndpoint]: __swig_getmethods__.update(getattr(_s,'__swig_getmethods__',{})) 744 __getattr__ = lambda self, name: _swig_getattr(self, HttpsEndpoint, name) 745 __repr__ = _swig_repr 746
747 - def __init__(self, *args):
748 """Constructs an HTTPS endpoint on the given port number. """ 749 750 this = _rcfproto.new_HttpsEndpoint(*args) 751 try: self.this.append(this) 752 except: self.this = this
753 __swig_destroy__ = _rcfproto.delete_HttpsEndpoint 754 __del__ = lambda self : None;
755 _HttpsEndpoint_swigregister = _rcfproto.HttpsEndpoint_swigregister 756 _HttpsEndpoint_swigregister(HttpsEndpoint) 757
758 -class ServerTransport(_object):
759 """Base class for all server transports. 760 761 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 762 763 __swig_setmethods__ = {} 764 __setattr__ = lambda self, name, value: _swig_setattr(self, ServerTransport, name, value) 765 __swig_getmethods__ = {} 766 __getattr__ = lambda self, name: _swig_getattr(self, ServerTransport, name)
767 - def __init__(self, *args, **kwargs): raise AttributeError("No constructor defined - class is abstract")
768 __repr__ = _swig_repr 769
770 - def GetTransportType(self):
771 """Returns the transport type of this server transport. """ 772 return _rcfproto.ServerTransport_getTransportType(self)
773
774 - def SetMaxIncomingMessageLength(self, *args):
775 """Sets maximum incoming message length. Incoming messages that are larger than this size will be dropped. """ 776 return _rcfproto.ServerTransport_setMaxIncomingMessageLength(self, *args)
777
779 """Returns maximum incoming message length. """ 780 return _rcfproto.ServerTransport_getMaxIncomingMessageLength(self)
781
782 - def SetConnectionLimit(self, *args):
783 """Sets the maximum number of simultaneous connections to the server transport. """ 784 return _rcfproto.ServerTransport_setConnectionLimit(self, *args)
785
786 - def GetConnectionLimit(self):
787 """Returns the maximum number of simultaneous connections to the server transport. """ 788 return _rcfproto.ServerTransport_getConnectionLimit(self)
789
790 - def SetInitialNumberOfConnections(self, *args):
791 """Sets the initial number of listening connections that are created when the server transport starts. """ 792 return _rcfproto.ServerTransport_setInitialNumberOfConnections(self, *args)
793
795 """Returns the initial number of listening connections that are created when the server transport starts. """ 796 return _rcfproto.ServerTransport_getInitialNumberOfConnections(self)
797
798 - def SetThreadPool(self, *args):
799 """Sets the thread pool that the server transport will use. """ 800 return _rcfproto.ServerTransport_setThreadPool(self, *args)
801
802 - def SetSupportedProtocols(self, *args):
803 """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. """ 804 return _rcfproto.ServerTransport_setSupportedProtocols(self, *args)
805 - def GetSupportedProtocols(self): return _rcfproto.ServerTransport_getSupportedProtocols(self)
806 __swig_destroy__ = _rcfproto.delete_ServerTransport 807 __del__ = lambda self : None;
808 _ServerTransport_swigregister = _rcfproto.ServerTransport_swigregister 809 _ServerTransport_swigregister(ServerTransport) 810
811 -class ClientTransport(_object):
812 """Base class for all client transports. 813 814 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 815 816 __swig_setmethods__ = {} 817 __setattr__ = lambda self, name, value: _swig_setattr(self, ClientTransport, name, value) 818 __swig_getmethods__ = {} 819 __getattr__ = lambda self, name: _swig_getattr(self, ClientTransport, name)
820 - def __init__(self, *args, **kwargs): raise AttributeError("No constructor defined - class is abstract")
821 __repr__ = _swig_repr 822
823 - def GetTransportType(self):
824 """Returns the transport type of this client transport. """ 825 return _rcfproto.ClientTransport_getTransportType(self)
826
827 - def SetMaxIncomingMessageLength(self, *args):
828 """Sets maximum incoming message length. Incoming messages that are larger than this size will be dropped. """ 829 return _rcfproto.ClientTransport_setMaxIncomingMessageLength(self, *args)
830
832 """Returns maximum incoming message length. """ 833 return _rcfproto.ClientTransport_getMaxIncomingMessageLength(self)
834
835 - def GetLastRequestSize(self):
836 """Returns the byte size of the last request sent on the client transport. """ 837 return _rcfproto.ClientTransport_getLastRequestSize(self)
838
839 - def GetLastResponseSize(self):
840 """Returns the byte size of the last response received on the client transport. """ 841 return _rcfproto.ClientTransport_getLastResponseSize(self)
842
843 - def GetRunningTotalBytesSent(self):
844 """Returns the running total of bytes sent on the client transport. """ 845 return _rcfproto.ClientTransport_getRunningTotalBytesSent(self)
846
848 """Returns the running total of bytes received on the client transport. """ 849 return _rcfproto.ClientTransport_getRunningTotalBytesReceived(self)
850
851 - def ResetRunningTotals(self):
852 """Resets the bytes-sent and bytes-received running totals to zero. """ 853 return _rcfproto.ClientTransport_resetRunningTotals(self)
854 __swig_destroy__ = _rcfproto.delete_ClientTransport 855 __del__ = lambda self : None;
856 _ClientTransport_swigregister = _rcfproto.ClientTransport_swigregister 857 _ClientTransport_swigregister(ClientTransport) 858
859 -class _SwigCallbackArgs(_object):
860 __swig_setmethods__ = {} 861 __setattr__ = lambda self, name, value: _swig_setattr(self, _SwigCallbackArgs, name, value) 862 __swig_getmethods__ = {} 863 __getattr__ = lambda self, name: _swig_getattr(self, _SwigCallbackArgs, name) 864 __repr__ = _swig_repr 865 __swig_setmethods__["mErrorString"] = _rcfproto._SwigCallbackArgs_mErrorString_set 866 __swig_getmethods__["mErrorString"] = _rcfproto._SwigCallbackArgs_mErrorString_get 867 if _newclass:mErrorString = _swig_property(_rcfproto._SwigCallbackArgs_mErrorString_get, _rcfproto._SwigCallbackArgs_mErrorString_set) 868 __swig_setmethods__["mCertificatePtr"] = _rcfproto._SwigCallbackArgs_mCertificatePtr_set 869 __swig_getmethods__["mCertificatePtr"] = _rcfproto._SwigCallbackArgs_mCertificatePtr_get 870 if _newclass:mCertificatePtr = _swig_property(_rcfproto._SwigCallbackArgs_mCertificatePtr_get, _rcfproto._SwigCallbackArgs_mCertificatePtr_set)
871 - def __init__(self):
872 this = _rcfproto.new__SwigCallbackArgs() 873 try: self.this.append(this) 874 except: self.this = this
875 __swig_destroy__ = _rcfproto.delete__SwigCallbackArgs 876 __del__ = lambda self : None; 877 __SwigCallbackArgs_swigregister = _rcfproto._SwigCallbackArgs_swigregister 878 __SwigCallbackArgs_swigregister(_SwigCallbackArgs) 879
880 -class _SwigCallback(_object):
881 __swig_setmethods__ = {} 882 __setattr__ = lambda self, name, value: _swig_setattr(self, _SwigCallback, name, value) 883 __swig_getmethods__ = {} 884 __getattr__ = lambda self, name: _swig_getattr(self, _SwigCallback, name) 885 __repr__ = _swig_repr
886 - def __init__(self):
887 if self.__class__ == _SwigCallback: 888 _self = None 889 else: 890 _self = self 891 this = _rcfproto.new__SwigCallback(_self, ) 892 try: self.this.append(this) 893 except: self.this = this
894 __swig_destroy__ = _rcfproto.delete__SwigCallback 895 __del__ = lambda self : None;
896 - def Run(self): return _rcfproto._SwigCallback_Run(self)
897 - def ProtoRpcBegin(self, *args): return _rcfproto._SwigCallback_ProtoRpcBegin(self, *args)
898 - def ValidateCertificate(self, *args): return _rcfproto._SwigCallback_ValidateCertificate(self, *args)
899 - def __disown__(self):
900 self.this.disown() 901 _rcfproto.disown__SwigCallback(self) 902 return weakref_proxy(self)
903 __SwigCallback_swigregister = _rcfproto._SwigCallback_swigregister 904 __SwigCallback_swigregister(_SwigCallback) 905
906 -class RcfProtoChannel(google.protobuf.service.RpcChannel):
907 """Represents a single RPC connection to a server. 908 909 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 910 911 __swig_setmethods__ = {} 912 __setattr__ = lambda self, name, value: _swig_setattr(self, RcfProtoChannel, name, value) 913 __swig_getmethods__ = {} 914 __getattr__ = lambda self, name: _swig_getattr(self, RcfProtoChannel, name) 915 __repr__ = _swig_repr 916
917 - def __init__(self, *args):
918 """Constructs a RPC channel from an endpoint. """ 919 920 this = _rcfproto.new_RcfProtoChannel(*args) 921 try: self.this.append(this) 922 except: self.this = this
923 - def _CallMethodSwig_WithCopy(self, *args): return _rcfproto.RcfProtoChannel__CallMethodSwig_WithCopy(self, *args)
924 - def _GetResponseBuffer_WithCopy(self): return _rcfproto.RcfProtoChannel__GetResponseBuffer_WithCopy(self)
925
926 - def Failed(self):
927 """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. """ 928 return _rcfproto.RcfProtoChannel_Failed(self)
929
930 - def ErrorText(self):
931 """If Failed() is true, returns a human-readable description of the error. """ 932 return _rcfproto.RcfProtoChannel_ErrorText(self)
933
934 - def StartCancel(self):
935 """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. """ 936 return _rcfproto.RcfProtoChannel_StartCancel(self)
937 - def Completed(self): return _rcfproto.RcfProtoChannel_Completed(self)
938
939 - def Connect(self):
940 """Connects to the server. """ 941 return _rcfproto.RcfProtoChannel_connect(self)
942
943 - def Disconnect(self):
944 """Disconencts from the server. """ 945 return _rcfproto.RcfProtoChannel_disconnect(self)
946
947 - def SetMaxMessageLength(self, *args):
948 """Sets the maximum incoming message size. """ 949 return _rcfproto.RcfProtoChannel_setMaxMessageLength(self, *args)
950
951 - def GetMaxMessageLength(self):
952 """Gets the maximum incoming message size. """ 953 return _rcfproto.RcfProtoChannel_getMaxMessageLength(self)
954
955 - def SetRemoteCallTimeoutMs(self, *args):
956 """Sets the remote call timeout value, in milliseconds. """ 957 return _rcfproto.RcfProtoChannel_setRemoteCallTimeoutMs(self, *args)
958
959 - def GetRemoteCallTimeoutMs(self):
960 """Gets the remote call timeout value, in milliseconds. """ 961 return _rcfproto.RcfProtoChannel_getRemoteCallTimeoutMs(self)
962
963 - def SetConnectTimeoutMs(self, *args):
964 """Sets the connect timeout value, in milliseconds. """ 965 return _rcfproto.RcfProtoChannel_setConnectTimeoutMs(self, *args)
966
967 - def GetConnectTimeoutMs(self):
968 """Gets the connect timeout value, in milliseconds. """ 969 return _rcfproto.RcfProtoChannel_getConnectTimeoutMs(self)
970
971 - def SetTransportProtocol(self, *args):
972 """Sets the transport protocol being used by the channel. """ 973 return _rcfproto.RcfProtoChannel_setTransportProtocol(self, *args)
974
975 - def GetTransportProtocol(self):
976 """Gets the transport protocol being used by the channel. """ 977 return _rcfproto.RcfProtoChannel_getTransportProtocol(self)
978
979 - def SetAsynchronousRpcMode(self, *args):
980 """Sets the asynchronous RPC mode. By default the asynchronous RPC mode is false. """ 981 return _rcfproto.RcfProtoChannel_setAsynchronousRpcMode(self, *args)
982
983 - def GetAsynchronousRpcMode(self):
984 """Gets the asynchronous RPC mode. """ 985 return _rcfproto.RcfProtoChannel_getAsynchronousRpcMode(self)
986
987 - def SetPingBackIntervalMs(self, *args):
988 """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. """ 989 return _rcfproto.RcfProtoChannel_setPingBackIntervalMs(self, *args)
990
991 - def GetPingBackIntervalMs(self):
992 """Returns the ping back interval of the connection. """ 993 return _rcfproto.RcfProtoChannel_getPingBackIntervalMs(self)
994
995 - def SetHttpProxy(self, *args):
996 """Sets the network address of the HTTP proxy server, through which to route remote calls. Only valid when using a HTTP or HTTPS endpoint. """ 997 return _rcfproto.RcfProtoChannel_setHttpProxy(self, *args)
998
999 - def GetHttpProxy(self):
1000 """Returns the network address of the HTTP proxy server. """ 1001 return _rcfproto.RcfProtoChannel_getHttpProxy(self)
1002
1003 - def SetHttpProxyPort(self, *args):
1004 """Sets the port number of the HTTP proxy server, through which to route remote calls. Only valid when using a HTTP or HTTPS endpoint. """ 1005 return _rcfproto.RcfProtoChannel_setHttpProxyPort(self, *args)
1006
1007 - def GetHttpProxyPort(self):
1008 """Returns the port number of the HTTP proxy server. """ 1009 return _rcfproto.RcfProtoChannel_getHttpProxyPort(self)
1010
1011 - def GetTransportType(self):
1012 """Returns the transport type of the connection. """ 1013 return _rcfproto.RcfProtoChannel_getTransportType(self)
1014
1015 - def SetUsername(self, *args):
1016 """Sets the Windows username to use when connecting. Only valid for NTLM and Kerberos transport protocols. """ 1017 return _rcfproto.RcfProtoChannel_setUsername(self, *args)
1018
1019 - def GetUsername(self):
1020 """Returns the Windows username to use when connecting. """ 1021 return _rcfproto.RcfProtoChannel_getUsername(self)
1022
1023 - def SetPassword(self, *args):
1024 """Sets the Windows password to use when connecting. Only valid for NTLM and Kerberos transport protocols. """ 1025 return _rcfproto.RcfProtoChannel_setPassword(self, *args)
1026
1027 - def GetPassword(self):
1028 """Returns the Windows password to use when connecting. """ 1029 return _rcfproto.RcfProtoChannel_getPassword(self)
1030
1031 - def SetKerberosSpn(self, *args):
1032 """Sets the Kerberos SPN to use when connecting. Only valid for Kerberos transport protocols. """ 1033 return _rcfproto.RcfProtoChannel_setKerberosSpn(self, *args)
1034
1035 - def GetKerberosSpn(self):
1036 """Returns the Kerberos SPN to use when connecting. """ 1037 return _rcfproto.RcfProtoChannel_getKerberosSpn(self)
1038
1039 - def SetEnableCompression(self, *args):
1040 """Sets the transport level compression setting for this connection. """ 1041 return _rcfproto.RcfProtoChannel_setEnableCompression(self, *args)
1042
1043 - def GetEnableCompression(self):
1044 """Returns the transport level compression setting for this connection. """ 1045 return _rcfproto.RcfProtoChannel_getEnableCompression(self)
1046
1047 - def SetCertificate(self, *args):
1048 """Sets the SSL certificate for the channel. """ 1049 return _rcfproto.RcfProtoChannel_setCertificate(self, *args)
1050
1051 - def GetCertificate(self):
1052 """Gets the SSL certificate for the channel. """ 1053 return _rcfproto.RcfProtoChannel_getCertificate(self)
1054
1055 - def SetCaCertificate(self, *args):
1056 """Sets the certificate authority for the channel. """ 1057 return _rcfproto.RcfProtoChannel_setCaCertificate(self, *args)
1058
1059 - def GetCaCertificate(self):
1060 """Gets the certificate authority for the channel. """ 1061 return _rcfproto.RcfProtoChannel_getCaCertificate(self)
1062
1063 - def SetOpenSslCipherSuite(self, *args):
1064 """Sets the OpenSSL cipher suite. Only applicable when using OpenSSL as the SSL implementation. """ 1065 return _rcfproto.RcfProtoChannel_setOpenSslCipherSuite(self, *args)
1066
1067 - def GetOpenSslCipherSuite(self):
1068 """Gets the OpenSSL cipher suite. """ 1069 return _rcfproto.RcfProtoChannel_getOpenSslCipherSuite(self)
1070
1072 """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. """ 1073 return _rcfproto.RcfProtoChannel_setEnableSchannelCertificateValidation(self, *args)
1074
1076 """Gets the Schannel certificate validation setting. """ 1077 return _rcfproto.RcfProtoChannel_getEnableSchannelCertificateValidation(self)
1078 - def _setCertificateValidationCallback(self, *args): return _rcfproto.RcfProtoChannel__setCertificateValidationCallback(self, *args)
1079
1080 - def SetSslImplementation(self, *args):
1081 """Sets the SSL implementation to be used by the channel. """ 1082 return _rcfproto.RcfProtoChannel_setSslImplementation(self, *args)
1083
1084 - def GetSslImplementation(self):
1085 """Gets the SSL implementation. """ 1086 return _rcfproto.RcfProtoChannel_getSslImplementation(self)
1087 __swig_destroy__ = _rcfproto.delete_RcfProtoChannel 1088 __del__ = lambda self : None; 1089 1090 # BEGIN INSERTED CODE 1091 1092
1093 - def CallMethod(self, methodDesc, controller, request, responsePrototype, done):
1094 """Gets the certificate validation callback. """ 1095 1096 rcfprotoimpl.RcfProtoChannelImpl.CallMethod(self, methodDesc, controller, request, responsePrototype, done)
1097
1098 - def GetResponse(self):
1099 return rcfprotoimpl.RcfProtoChannelImpl.GetResponse(self);
1100
1101 - def SetCertificateValidationCallback(self, certValidationCallback):
1102 rcfprotoimpl.RcfProtoChannelImpl.SetCertificateValidationCallback(self, certValidationCallback);
1103 1104 # END INSERTED CODE 1105 1106 1107 _RcfProtoChannel_swigregister = _rcfproto.RcfProtoChannel_swigregister 1108 _RcfProtoChannel_swigregister(RcfProtoChannel) 1109
1110 -class RcfProtoSession(_object):
1111 """Represents the server-side session associated with a RPC connection. 1112 1113 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 1114 1115 __swig_setmethods__ = {} 1116 __setattr__ = lambda self, name, value: _swig_setattr(self, RcfProtoSession, name, value) 1117 __swig_getmethods__ = {} 1118 __getattr__ = lambda self, name: _swig_getattr(self, RcfProtoSession, name)
1119 - def __init__(self, *args, **kwargs): raise AttributeError("No constructor defined")
1120 __repr__ = _swig_repr 1121
1122 - def SetFailed(self, *args):
1123 """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(). """ 1124 return _rcfproto.RcfProtoSession_SetFailed(self, *args)
1125
1126 - def IsCanceled(self):
1127 """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. """ 1128 return _rcfproto.RcfProtoSession_IsCanceled(self)
1129 - def _Commit(self, *args): return _rcfproto.RcfProtoSession__Commit(self, *args)
1130 - def _GetRequestBuffer_WithCopy(self): return _rcfproto.RcfProtoSession__GetRequestBuffer_WithCopy(self)
1131 - def _SetResponseBuffer_WithCopy(self, *args): return _rcfproto.RcfProtoSession__SetResponseBuffer_WithCopy(self, *args)
1132
1133 - def GetClientUsername(self):
1134 """Returns the Windows username of the client, if a NTLM or Kerberos transport protocol is being used. """ 1135 return _rcfproto.RcfProtoSession_getClientUsername(self)
1136
1137 - def GetTransportProtocol(self):
1138 """Returns the transport protocol in use on this server session. """ 1139 return _rcfproto.RcfProtoSession_getTransportProtocol(self)
1140
1141 - def GetTransportType(self):
1142 """Returns the transport type of this server session. """ 1143 return _rcfproto.RcfProtoSession_getTransportType(self)
1144
1145 - def GetEnableCompression(self):
1146 """Returns true if compression is enabled for this server session, and false otherwise. Compression is enabled by the client. """ 1147 return _rcfproto.RcfProtoSession_getEnableCompression(self)
1148
1149 - def GetConnectionDuration(self):
1150 """Returns the duration of the client connection, in milliseconds. """ 1151 return _rcfproto.RcfProtoSession_getConnectionDuration(self)
1152
1153 - def GetRemoteCallCount(self):
1154 """Returns the number of remote calls executed on the server session so far. """ 1155 return _rcfproto.RcfProtoSession_getRemoteCallCount(self)
1156
1157 - def GetTotalBytesReceived(self):
1158 """Returns the total number of bytes received by the server session so far. """ 1159 return _rcfproto.RcfProtoSession_getTotalBytesReceived(self)
1160
1161 - def GetTotalBytesSent(self):
1162 """Returns the total number of bytes sent from the server session so far. """ 1163 return _rcfproto.RcfProtoSession_getTotalBytesSent(self)
1164 __swig_destroy__ = _rcfproto.delete_RcfProtoSession 1165 __del__ = lambda self : None;
1166 _RcfProtoSession_swigregister = _rcfproto.RcfProtoSession_swigregister 1167 _RcfProtoSession_swigregister(RcfProtoSession) 1168
1169 -class RcfProtoServer(_object):
1170 """Serves up Protocol Buffer-based services to clients, over one or more server transports. 1171 1172 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 1173 1174 __swig_setmethods__ = {} 1175 __setattr__ = lambda self, name, value: _swig_setattr(self, RcfProtoServer, name, value) 1176 __swig_getmethods__ = {} 1177 __getattr__ = lambda self, name: _swig_getattr(self, RcfProtoServer, name) 1178 __repr__ = _swig_repr
1179 - def __init__(self, *args):
1180 this = _rcfproto.new_RcfProtoServer(*args) 1181 try: self.this.append(this) 1182 except: self.this = this
1183 __swig_destroy__ = _rcfproto.delete_RcfProtoServer 1184 __del__ = lambda self : None; 1185
1186 - def Start(self):
1187 """Starts the RCFProto server. """ 1188 1189 self.callbackTable = rcfprotoimpl.SwigCallback_ServerRpc(self) 1190 return _rcfproto.RcfProtoServer_start(self)
1191 1192
1193 - def Stop(self):
1194 """Stops the RCFProto server. """ 1195 return _rcfproto.RcfProtoServer_stop(self)
1196 - def _setCallbackTable(self, *args): return _rcfproto.RcfProtoServer__setCallbackTable(self, *args)
1197
1198 - def SetThreadPool(self, *args):
1199 """Sets the thread pool the server will use. Thread pools can also be assigned to individual transports. """ 1200 return _rcfproto.RcfProtoServer_setThreadPool(self, *args)
1201
1202 - def GetThreadPool(self):
1203 """Returns the thread pool the server is using. """ 1204 return _rcfproto.RcfProtoServer_getThreadPool(self)
1205
1206 - def AddEndpoint(self, *args):
1207 """Adds a transport endpoint to the server. """ 1208 return _rcfproto.RcfProtoServer_addEndpoint(self, *args)
1209
1210 - def SetSupportedTransportProtocols(self, *args):
1211 """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. """ 1212 return _rcfproto.RcfProtoServer_setSupportedTransportProtocols(self, *args)
1213
1214 - def GetSupportedTransportProtocols(self):
1215 """Returns the list of supported protocols for the server. """ 1216 return _rcfproto.RcfProtoServer_getSupportedTransportProtocols(self)
1217
1218 - def SetSessionTimeoutMs(self, *args):
1219 """Sets the session timeout value, in milliseconds. Client connections that are idle for this amount of time will be dropped by the server. """ 1220 return _rcfproto.RcfProtoServer_setSessionTimeoutMs(self, *args)
1221
1222 - def GetSessionTimeoutMs(self):
1223 """Returns the session timeout value, in milliseconds. """ 1224 return _rcfproto.RcfProtoServer_getSessionTimeoutMs(self)
1225
1226 - def SetSessionHarvestingIntervalMs(self, *args):
1227 """Sets the session harvesting interval, in milliseconds. This setting determines how often the server will scan for idle client connections. """ 1228 return _rcfproto.RcfProtoServer_setSessionHarvestingIntervalMs(self, *args)
1229
1230 - def GetSessionHarvestingIntervalMs(self):
1231 """Returns the session harvesting interval, in milliseconds. """ 1232 return _rcfproto.RcfProtoServer_getSessionHarvestingIntervalMs(self)
1233
1234 - def SetCertificate(self, *args):
1235 """Sets the SSL certificate of the server. """ 1236 return _rcfproto.RcfProtoServer_setCertificate(self, *args)
1237
1238 - def GetCertificate(self):
1239 """Gets the SSL certificate of the server. """ 1240 return _rcfproto.RcfProtoServer_getCertificate(self)
1241
1242 - def SetOpenSslCipherSuite(self, *args):
1243 """Sets the OpenSSL cipher suite. Only applicable when OpenSSL is used as the SSL implementation. """ 1244 return _rcfproto.RcfProtoServer_setOpenSslCipherSuite(self, *args)
1245
1246 - def GetOpenSslCipherSuite(self):
1247 """Gets the OpenSSL cipher suite. """ 1248 return _rcfproto.RcfProtoServer_getOpenSslCipherSuite(self)
1249
1250 - def SetCaCertificate(self, *args):
1251 """Sets the SSL certificate authority of the server. """ 1252 return _rcfproto.RcfProtoServer_setCaCertificate(self, *args)
1253
1254 - def GetCaCertificate(self):
1255 """Gets the SSL certificate authority of the server. """ 1256 return _rcfproto.RcfProtoServer_getCaCertificate(self)
1257
1258 - def SetEnableSchannelCertificateValidation(self, *args):
1259 """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. """ 1260 return _rcfproto.RcfProtoServer_setEnableSchannelCertificateValidation(self, *args)
1261
1262 - def GetEnableSchannelCertificateValidation(self):
1263 """Gets the Schannel certificate validation setting. """ 1264 return _rcfproto.RcfProtoServer_getEnableSchannelCertificateValidation(self)
1265 - def SetSslImplementation(self, *args): return _rcfproto.RcfProtoServer_setSslImplementation(self, *args)
1266
1267 - def GetSslImplementation(self):
1268 """Gets the SSL implementation of the server. """ 1269 return _rcfproto.RcfProtoServer_getSslImplementation(self)
1270 # BEGIN INSERTED CODE
1271 - def BindService(self, svc):
1272 rcfprotoimpl.RcfProtoServerImpl.BindService(self, svc)
1273 1274 1275 # END INSERTED CODE 1276 1277 _RcfProtoServer_swigregister = _rcfproto.RcfProtoServer_swigregister 1278 _RcfProtoServer_swigregister(RcfProtoServer) 1279 1280 # This file is compatible with both classic and new-style classes. 1281 1282
1283 -class RcfProtoController(google.protobuf.service.RpcController) :
1284 """RPC controller interface, for both server-side and client-side code. 1285 1286 @undocumented: __swig_setmethods__, __setattr__, __swig_getmethods__, __getattr__, __repr__, __swig_destroy__, __del__""" 1287 1288
1289 - def __init__(self, channel = None, session = None):
1290 if channel: 1291 self.channel = channel 1292 self.session = None 1293 elif session: 1294 self.channel = None 1295 self.session = session
1296 1297
1298 - def Reset(self):
1299 """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. """ 1300 1301 self.channel = None 1302 self.session = None
1303 1304
1305 - def Failed(self):
1306 """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. """ 1307 1308 return self.channel.Failed()
1309 1310 1311
1312 - def ErrorText(self):
1313 """Client-side: If Failed() is true, returns a human-readable description of the error. """ 1314 1315 return self.channel.ErrorText()
1316 1317
1318 - def StartCancel(self):
1319 """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. """ 1320 1321 self.channel.StartCancel()
1322 1323
1324 - def Completed(self):
1325 """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). """ 1326 1327 return self.channel.Completed()
1328 1329 # Server-side methods below 1330 1331
1332 - def SetFailed(self, reason):
1333 """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(). """ 1334 1335 self.session.SetFailed(reason)
1336 1337
1338 - def IsCanceled(self):
1339 """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. """ 1340 1341 self.session.IsCanceled()
1342 1343
1344 - def NotifyOnCancel(self, callback):
1345 """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. """ 1346 1347 self.session.NotifyOnCancel(callback)
1348
1349 - def GetSession(self):
1350 return self.session
1351
1352 - def GetChannel(self):
1353 return self.channel
1354 1355 1356 import rcfprotoimpl 1357 from rcfprotoimpl import * 1358