Lines Matching refs:self
29 def __init__(self, host, timeout=60, **kwargs):
30 super(HTTPUnixConnection, self).__init__('localhost')
31 self.unix_socket = host
32 self.timeout = timeout
34 def connect(self):
36 sock.settimeout(self.timeout)
37 sock.connect(self.unix_socket)
38 self.sock = sock
47 def get_connection(self, url, proxies=None):
57 def __init__(self, content_type='application/json', sock_path=None):
59 sock_path = self.secrets_sock_path
61 self.content_type = content_type
62 self.session = requests.Session()
63 self.session.mount('http+unix://', HTTPUnixAdapter())
64 self.headers = dict({'Content-Type': content_type})
65 self.url = 'http+unix://' + \
68 self.secrets_container
69 self._last_response = None
71 def _join_url(self, resource):
72 path = self.url.rstrip('/') + '/'
77 def _add_headers(self, **kwargs):
81 headers.update(self.headers)
84 def _request(self, cmd, path, **kwargs):
85 self._last_response = None
86 url = self._join_url(path)
87 kwargs['headers'] = self._add_headers(**kwargs)
88 self._last_response = cmd(url, **kwargs)
89 return self._last_response
92 def last_response(self):
93 return self._last_response
95 def get(self, path, **kwargs):
96 return self._request(self.session.get, path, **kwargs)
98 def list(self, **kwargs):
99 return self._request(self.session.get, None, **kwargs)
101 def put(self, name, **kwargs):
102 return self._request(self.session.put, name, **kwargs)
104 def delete(self, name, **kwargs):
105 return self._request(self.session.delete, name, **kwargs)
107 def post(self, name, **kwargs):
108 return self._request(self.session.post, name, **kwargs)
112 def list_secrets(self):
113 res = self.list()
118 def get_secret(self, name):
119 res = self.get(name)
127 def set_secret(self, name, value):
128 res = self.put(name, json={"type": "simple", "value": value})
131 def del_secret(self, name):
132 res = self.delete(name)
135 def create_container(self, name):
136 res = self.post(name)