| 105 | return self._nifi |
| 106 | |
| 107 | class FlowFile(object): |
| 108 | def __init__(self, minifi, ff): |
| 109 | super(FlowFile, self).__init__() |
| 110 | self._minifi = minifi |
| 111 | self._ff = ff |
| 112 | |
| 113 | def get_attribute(self, name): |
| 114 | attr = CAttribute(name.encode("UTF-8"), 0, 0) |
| 115 | if self._minifi.get_attribute(self._ff, attr) != 0: |
| 116 | return "" |
| 117 | if attr.value_size > 0: |
| 118 | return ctypes.cast(attr.value, ctypes.c_char_p).value.decode("ascii") |
| 119 | return "" |
| 120 | |
| 121 | def add_attribute(self, name, value): |
| 122 | vallen = len(value) |
| 123 | return self._minifi.add_attribute(self._ff, name.encode("UTF-8"), value.encode("UTF-8"), vallen) == 0 |
| 124 | |
| 125 | def update_attribute(self, name, value): |
| 126 | vallen = len(value) |
| 127 | self._minifi.update_attribute(self._ff, name.encode("UTF-8"), value.encode("UTF-8"), vallen) |
| 128 | |
| 129 | def get_instance(self): |
| 130 | return self._ff |
| 131 | |
| 132 | |
| 133 |
no outgoing calls
no test coverage detected