mirror of
https://github.com/hanzoai/bootnode.git
synced 2026-09-30 20:46:32 +00:00
Create pod command
This commit is contained in:
@@ -70,10 +70,10 @@ class Bootnode(object):
|
||||
self.gcloud.create_disk(name)
|
||||
|
||||
config = Ethereum(name, network)
|
||||
pool = self.kube.get_pool(network)
|
||||
if not pool:
|
||||
self.kube.create_pool(network)
|
||||
self.gcloud.create_pod(disk, name, config)
|
||||
# pool = self.kube.get_pool(network)
|
||||
# if not pool:
|
||||
# self.kube.create_pool(network)
|
||||
self.kube.create_pod(config)
|
||||
|
||||
def list_pods(self, network=None):
|
||||
table(self.kube.list_pods(network=network), 'name', 'phase', 'block_number', 'ip')
|
||||
|
||||
@@ -10,6 +10,12 @@ class Node(object):
|
||||
self.node = node
|
||||
|
||||
|
||||
class Pool(object):
|
||||
def __init__(self, pool, api=None):
|
||||
self.api = api
|
||||
self.pool = pool
|
||||
|
||||
|
||||
class Pod(object):
|
||||
def __init__(self, pod, api=None):
|
||||
self.api = api
|
||||
@@ -74,6 +80,9 @@ class Kubernetes(object):
|
||||
namespace, command=command, stdin=stdin, stderr=stderr,
|
||||
stdout=stdout, tty=tty)
|
||||
|
||||
def create_pod(self, config):
|
||||
return self.api.create_namespaced_pod(POD_NAMESPACE, body=config)
|
||||
|
||||
def list_pods(self, network=None):
|
||||
pods = [Pod(p, self) for p in
|
||||
self.api.list_namespaced_pod(POD_NAMESPACE).items]
|
||||
|
||||
Reference in New Issue
Block a user