Restructure murano-apps repository
Change-Id: I9cdb1e4afcb9929c7b7a5437faaa25d284daefdb Closes-Bug: #1441644
This commit is contained in:
Dmytro Dovbii
@@ -0,0 +1,468 @@
|
||||
Namespaces:
|
||||
=: io.murano.apps.docker.kubernetes
|
||||
std: io.murano
|
||||
res: io.murano.resources
|
||||
sys: io.murano.system
|
||||
docker: io.murano.apps.docker
|
||||
|
||||
|
||||
Name: KubernetesCluster
|
||||
|
||||
Extends: std:Application
|
||||
|
||||
Properties:
|
||||
name:
|
||||
Contract: $.string().notNull()
|
||||
|
||||
masterNode:
|
||||
Contract: $.class(KubernetesMasterNode).notNull()
|
||||
|
||||
minionNodes:
|
||||
Contract:
|
||||
- $.class(KubernetesMinionNode).notNull()
|
||||
- 1
|
||||
|
||||
nodeCount:
|
||||
Contract: $.int().notNull().check($ > 0)
|
||||
Usage: InOut
|
||||
|
||||
gatewayCount:
|
||||
Contract: $.int().notNull()
|
||||
Usage: InOut
|
||||
|
||||
gatewayNodes:
|
||||
Contract:
|
||||
- $.class(KubernetesGatewayNode).notNull()
|
||||
|
||||
dockerRegistry:
|
||||
Contract: $.string()
|
||||
|
||||
serviceEndpoints:
|
||||
Contract:
|
||||
- port: $.int().notNull().check($ > 0)
|
||||
address: $.string().notNull()
|
||||
scope: $.string().notNull().check($ in list(public, cloud, internal, host))
|
||||
portScope: $.string().notNull().check($ in list(public, cloud, internal, host))
|
||||
containerPort: $.int().notNull().check($ > 0)
|
||||
protocol: $.string().notNull().check($ in list(TCP, UDP))
|
||||
applicationName: $.string().notNull()
|
||||
podId: $.string().notNull()
|
||||
serviceName: $.string()
|
||||
Default: []
|
||||
Usage: Out
|
||||
|
||||
|
||||
Methods:
|
||||
initialize:
|
||||
Body:
|
||||
- $._environment: $.find(std:Environment).require()
|
||||
|
||||
|
||||
deploy:
|
||||
Body:
|
||||
- If: not $.getAttr(deployed, false)
|
||||
Then:
|
||||
- $._environment.reporter.report($this, 'Creating VMs for Kubernetes cluster')
|
||||
- $securityGroupIngress:
|
||||
- ToPort: 4001
|
||||
FromPort: 4001
|
||||
IpProtocol: tcp
|
||||
External: false
|
||||
- ToPort: 7001
|
||||
FromPort: 7001
|
||||
IpProtocol: tcp
|
||||
External: false
|
||||
- ToPort: 10250
|
||||
FromPort: 10250
|
||||
IpProtocol: tcp
|
||||
External: false
|
||||
- ToPort: 8080
|
||||
FromPort: 8080
|
||||
IpProtocol: tcp
|
||||
External: $.masterNode.instance.assignFloatingIp
|
||||
- ToPort: 2380
|
||||
FromPort: 2380
|
||||
IpProtocol: tcp
|
||||
External: false
|
||||
- ToPort: 8285
|
||||
FromPort: 8285
|
||||
IpProtocol: udp
|
||||
External: false
|
||||
- $._environment.securityGroupManager.addGroupIngress($securityGroupIngress)
|
||||
- $.setAttr(deployed, true)
|
||||
|
||||
- $._environment.reporter.report($this, 'Setting up Kubernetes cluster')
|
||||
- Parallel:
|
||||
- Do: $.masterNode.deployInstance()
|
||||
- Do: $.minionNodes.take($.nodeCount).pselect($.deployInstance())
|
||||
- Do: $.gatewayNodes.take($.gatewayCount).pselect($.deployInstance())
|
||||
|
||||
- $.masterNode.setupEtcd()
|
||||
- $.minionNodes.take($.nodeCount).select($.setupEtcd())
|
||||
- $.gatewayNodes.take($.gatewayCount).select($.setupEtcd())
|
||||
|
||||
- $.masterNode.setupNode()
|
||||
- Parallel:
|
||||
- Do: $.minionNodes.take($.nodeCount).pselect($.setupNode())
|
||||
- Do: $.minionNodes.skip($.nodeCount).pselect($.removeFromCluster())
|
||||
- Do: $.gatewayNodes.take($.gatewayCount).pselect($.setupNode())
|
||||
- $._updateEndpoints()
|
||||
- $._environment.reporter.report($this, 'Kubernetes cluster is up and running')
|
||||
|
||||
|
||||
getIp:
|
||||
Body:
|
||||
Return: $.masterNode.getIp()
|
||||
|
||||
createPod:
|
||||
Arguments:
|
||||
- definition:
|
||||
Contract: {}
|
||||
- isNew:
|
||||
Contract: $.bool().notNull()
|
||||
Default: true
|
||||
Body:
|
||||
- $.deploy()
|
||||
- $resources: new(sys:Resources)
|
||||
- $template: $resources.yaml('UpdatePod.template').bind(dict(
|
||||
podDefinition => $definition,
|
||||
isNew => $isNew
|
||||
))
|
||||
- $.masterNode.instance.agent.call($template, $resources)
|
||||
|
||||
|
||||
createReplicationController:
|
||||
Arguments:
|
||||
- definition:
|
||||
Contract: {}
|
||||
- isNew:
|
||||
Contract: $.bool().notNull()
|
||||
Default: true
|
||||
Body:
|
||||
- $.deploy()
|
||||
- $resources: new(sys:Resources)
|
||||
- $template: $resources.yaml('UpdateReplicationController.template').bind(dict(
|
||||
controllerDefinition => $definition,
|
||||
isNew => $isNew
|
||||
))
|
||||
- $.masterNode.instance.agent.call($template, $resources)
|
||||
|
||||
|
||||
destroyReplicationController:
|
||||
Arguments:
|
||||
- id:
|
||||
Contract: $.string().notNull()
|
||||
Body:
|
||||
- $.deploy()
|
||||
- $resources: new(sys:Resources)
|
||||
- $template: $resources.yaml('DestroyReplicationController.template').bind(dict(rcId => $id))
|
||||
- $.kubernetesCluster.masterNode.instance.agent.call($template, $resources)
|
||||
|
||||
|
||||
createServices:
|
||||
Arguments:
|
||||
- applicationName:
|
||||
Contract: $.string().notNull()
|
||||
- applicationPorts:
|
||||
Contract:
|
||||
- $.class(docker:ApplicationPort)
|
||||
- podId:
|
||||
Contract: $.string().notNull()
|
||||
Body:
|
||||
- $resources: new(sys:Resources)
|
||||
|
||||
- $applicationServices: {}
|
||||
- For: endpoint
|
||||
In: $.serviceEndpoints.where($.applicationName = $applicationName).where($.serviceName != null)
|
||||
Do:
|
||||
- $serviceName: $endpoint.serviceName
|
||||
- $applicationServices[$serviceName]: $endpoint
|
||||
|
||||
- $.serviceEndpoints: $.serviceEndpoints.where($.applicationName != $applicationName)
|
||||
|
||||
- $servicesUsed: []
|
||||
- For: applicationPort
|
||||
In: $applicationPorts
|
||||
Do:
|
||||
- If: $applicationPort.scope != host
|
||||
Then:
|
||||
- $serviceName: null
|
||||
- $reuseEndpoint: null
|
||||
- For: service
|
||||
In: $applicationServices.keys()
|
||||
Do:
|
||||
- $endpoint: $applicationServices.get($service)
|
||||
- If: $endpoint.containerPort = $applicationPort.port and $endpoint.protocol = $applicationPort.protocol
|
||||
Then:
|
||||
- $serviceName: $service
|
||||
- $reuseEndpoint: $endpoint
|
||||
- Break:
|
||||
|
||||
- If: $serviceName = null
|
||||
Then:
|
||||
- $serviceName: format('svc-{0}', randomName())
|
||||
- $servicePort: $._findUnusedPort($applicationPort.port, $applicationPort.protocol)
|
||||
- $serviceIp: $._createService($podId, $serviceName, $servicePort, $applicationPort)
|
||||
Else:
|
||||
- $servicesUsed: $servicesUsed + list($serviceName)
|
||||
- $servicePort: $reuseEndpoint.port
|
||||
- $serviceIp: $._updateService($podId, $reuseEndpoint)
|
||||
|
||||
- $newEndpoint:
|
||||
port: $servicePort
|
||||
address: $serviceIp
|
||||
scope: internal
|
||||
portScope: $applicationPort.scope
|
||||
applicationName: $applicationName
|
||||
containerPort: $applicationPort.port
|
||||
protocol: $applicationPort.protocol
|
||||
podId: $podId
|
||||
serviceName: $serviceName
|
||||
- $.serviceEndpoints: $.serviceEndpoints + list($newEndpoint)
|
||||
|
||||
- If: $applicationPort.scope in list(public, cloud)
|
||||
Then:
|
||||
- If: $.gatewayCount > 0
|
||||
Then:
|
||||
- $nodes: $.gatewayNodes.take($.gatewayCount)
|
||||
Else:
|
||||
- $nodes: $.minionNodes.take($.nodeCount)
|
||||
|
||||
- For: t
|
||||
In: $nodes
|
||||
Do:
|
||||
- $newEndpoint.address: $t.getIp()
|
||||
- $newEndpoint.scope: cloud
|
||||
- $.serviceEndpoints: $.serviceEndpoints + list($newEndpoint)
|
||||
|
||||
- If: $t.instance.floatingIpAddress != null and $applicationPort.scope = public
|
||||
Then:
|
||||
- $newEndpoint.address: $t.instance.floatingIpAddress
|
||||
- $newEndpoint.scope: public
|
||||
- $.serviceEndpoints: $.serviceEndpoints + list($newEndpoint)
|
||||
- $newEndpoint:
|
||||
port: $applicationPort.port
|
||||
address: '127.0.0.1'
|
||||
scope: host
|
||||
portScope: $applicationPort.scope
|
||||
containerPort: $applicationPort.port
|
||||
protocol: $applicationPort.protocol
|
||||
applicationName: $applicationName
|
||||
podId: $podId
|
||||
serviceName: null
|
||||
- $.serviceEndpoints: $.serviceEndpoints + list($newEndpoint)
|
||||
|
||||
- For: service
|
||||
In: $applicationServices.keys()
|
||||
Do:
|
||||
- If: not $service in $servicesUsed
|
||||
Then:
|
||||
- $._destroyService($service)
|
||||
- $._environment.stack.push()
|
||||
|
||||
|
||||
_createService:
|
||||
Arguments:
|
||||
- podId:
|
||||
Contract: $.string().notNull()
|
||||
- serviceName:
|
||||
Contract: $.string().notNull()
|
||||
- servicePort:
|
||||
Contract: $.int().notNull()
|
||||
- applicationPort:
|
||||
Contract: $.class(docker:ApplicationPort)
|
||||
Body:
|
||||
- $resources: new(sys:Resources)
|
||||
- $serviceDefinition: $._buildServiceDefinition(
|
||||
$serviceName,
|
||||
$servicePort,
|
||||
$applicationPort.protocol,
|
||||
$applicationPort.port,
|
||||
$podId,
|
||||
$.gatewayCount = 0
|
||||
)
|
||||
- $template: $resources.yaml('UpdateService.template').bind(dict(
|
||||
serviceDefinition => $serviceDefinition,
|
||||
isNew => true
|
||||
))
|
||||
- $securityGroupIngress:
|
||||
- ToPort: $servicePort
|
||||
FromPort: $servicePort
|
||||
IpProtocol: toLower($applicationPort.protocol)
|
||||
External: $applicationPort.scope = public
|
||||
|
||||
- $._environment.securityGroupManager.addGroupIngress($securityGroupIngress)
|
||||
|
||||
- Return: $.masterNode.instance.agent.call($template, $resources)
|
||||
|
||||
|
||||
_updateService:
|
||||
Arguments:
|
||||
- podId:
|
||||
Contract: $.string().notNull()
|
||||
- endpoint:
|
||||
Contract:
|
||||
port: $.int().notNull().check($ > 0)
|
||||
address: $.string().notNull()
|
||||
scope: $.string().notNull().check($ in list(public, cloud, internal, host))
|
||||
containerPort: $.int().notNull().check($ > 0)
|
||||
protocol: $.string().notNull().check($ in list(TCP, UDP))
|
||||
applicationName: $.string().notNull()
|
||||
podId: $.string().notNull()
|
||||
serviceName: $.string()
|
||||
|
||||
Body:
|
||||
- $resources: new(sys:Resources)
|
||||
- $prevNodeCount: $.getAttr(lastNodeCount, 0-1) # 0-1 instead of -1 because YAQL 0.2 doesn't understand unary operators
|
||||
- $prevGatewayCount: $.getAttr(lastGatewayCount, 0-1)
|
||||
- $gatewayModeChanged: $prevGatewayCount != $.gatewayCount and $prevGatewayCount * $.gatewayCount = 0
|
||||
|
||||
- $serviceChanged: $endpoint.podId != $podId or
|
||||
$endpoint.portScope in list(public, cloud) and (
|
||||
$gatewayModeChanged or $.gatewayCount = 0 and $prevNodeCount != $.nodeCount)
|
||||
- If: $serviceChanged
|
||||
Then:
|
||||
- $serviceDefinition: $._buildServiceDefinition(
|
||||
$endpoint.serviceName,
|
||||
$endpoint.port,
|
||||
$endpoint.protocol,
|
||||
$endpoint.containerPort,
|
||||
$podId,
|
||||
$.gatewayCount = 0
|
||||
)
|
||||
- $template: $resources.yaml('UpdateService.template').bind(dict(
|
||||
serviceDefinition => $serviceDefinition,
|
||||
isNew => false
|
||||
))
|
||||
- $serviceIp: $.masterNode.instance.agent.call($template, $resources)
|
||||
Else:
|
||||
- $serviceIp: $endpoint.address
|
||||
- Return: $serviceIp
|
||||
|
||||
_updateEndpoints:
|
||||
Body:
|
||||
- For: endpoint
|
||||
In: $.serviceEndpoints
|
||||
Do:
|
||||
- $._updateService($endpoint.podId, $endpoint)
|
||||
- $.setAttr(lastNodeCount, $.nodeCount)
|
||||
- $.setAttr(lastGatewayCount, $.gatewayCount)
|
||||
|
||||
|
||||
_destroyService:
|
||||
Arguments:
|
||||
serviceName:
|
||||
Contract: $.string().notNull()
|
||||
Body:
|
||||
- $resources: new(sys:Resources)
|
||||
- $template: $resources.yaml('DestroyService.template').bind(dict(
|
||||
serviceId => $service
|
||||
))
|
||||
- $.masterNode.instance.agent.call($template, $resources)
|
||||
|
||||
|
||||
destroyService:
|
||||
Arguments:
|
||||
- applicationName:
|
||||
Contract: $.string().notNull()
|
||||
- podId:
|
||||
Contract: $.string().notNull()
|
||||
Body:
|
||||
- $._destroyService($applicationName, $podId)
|
||||
|
||||
|
||||
_findUnusedPort:
|
||||
Arguments:
|
||||
- initial:
|
||||
Contract: $.int().notNull()
|
||||
- protocol:
|
||||
Contract: $.string().notNull()
|
||||
Body:
|
||||
- If: initial != 22 and $._checkIfPortIsNotUsed($initial, $protocol)
|
||||
Then:
|
||||
Return: $initial
|
||||
|
||||
- $port: 1025
|
||||
- While: not $._checkIfPortIsNotUsed($port, $protocol)
|
||||
Do:
|
||||
$port: $port + 1
|
||||
- Return: $port
|
||||
|
||||
|
||||
_checkIfPortIsNotUsed:
|
||||
Arguments:
|
||||
- port:
|
||||
Contract: $.int().notNull()
|
||||
- protocol:
|
||||
Contract: $.string().notNull()
|
||||
Body:
|
||||
- Return: len(list($.serviceEndpoints.where($.port = $port).where($.protocol = $protocol))) = 0
|
||||
|
||||
|
||||
_buildServiceDefinition:
|
||||
Arguments:
|
||||
- serviceName:
|
||||
Contract: $.string().notNull()
|
||||
- servicePort:
|
||||
Contract: $.int().notNull()
|
||||
- protocol:
|
||||
Contract: $.string().notNull()
|
||||
- containerPort:
|
||||
Contract: $.int().notNull()
|
||||
- podId:
|
||||
Contract: $.string().notNull()
|
||||
- withNodeIps:
|
||||
Contract: $.bool().notNull()
|
||||
Body:
|
||||
- $result:
|
||||
id: $serviceName
|
||||
kind: Service
|
||||
apiVersion: v1beta1
|
||||
port: $servicePort
|
||||
containerPort: $containerPort
|
||||
protocol: $protocol
|
||||
selector:
|
||||
id: $podId
|
||||
- If: $withNodeIps
|
||||
Then:
|
||||
- $result.publicIPs: $.minionNodes.take($.nodeCount).select($.getIp())
|
||||
- Return: $result
|
||||
|
||||
scaleNodesUp:
|
||||
Usage: Action
|
||||
Body:
|
||||
- If: $.nodeCount < len($.minionNodes)
|
||||
Then:
|
||||
- $._environment.reporter.report($this, 'Scaling up Kubernetes cluster')
|
||||
- $.nodeCount: $.nodeCount + 1
|
||||
- $.deploy()
|
||||
|
||||
scaleNodesDown:
|
||||
Usage: Action
|
||||
Body:
|
||||
- If: $.nodeCount > 1
|
||||
Then:
|
||||
- $._environment.reporter.report($this, 'Scaling Kubernetes cluster down')
|
||||
- $.nodeCount: $.nodeCount - 1
|
||||
- $.deploy()
|
||||
|
||||
scaleGatewaysUp:
|
||||
Usage: Action
|
||||
Body:
|
||||
- If: $.gatewayCount < len($.gatewayNodes)
|
||||
Then:
|
||||
- $._environment.reporter.report($this, 'Adding new gateway node')
|
||||
- $.gatewayCount: $.gatewayCount + 1
|
||||
- $.deploy()
|
||||
|
||||
|
||||
exportConfig:
|
||||
Usage: Action
|
||||
Body:
|
||||
- $._environment.reporter.report($this, 'Action exportConfig called')
|
||||
- $resources: new(sys:Resources)
|
||||
- $template: $resources.yaml('ExportConfig.template')
|
||||
- $result: $.masterNode.instance.agent.call($template, $resources)
|
||||
- $._environment.reporter.report($this, 'Got archive from Kubernetes')
|
||||
- Return: new(std:File, base64Content => $result.content,
|
||||
filename => 'application.tar.gz')
|
||||
Reference in New Issue
Block a user