blob: 7079c67be4b76e55ee4da09b7861189b0835ba71 (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
|
apiVersion: apps/v1
kind: Deployment
metadata:
namespace: {{ namespace }}
name: flumotion-worker-{{ worker.name }}
labels:
app: flumotion
type: worker
worker: {{ worker.name }}
spec:
replicas: 1
selector:
matchLabels:
app: flumotion
type: worker
worker: {{ worker.name }}
strategy:
type: Recreate
revisionHistoryLimit: 5
template:
metadata:
labels:
app: flumotion
type: worker
worker: {{ worker.name }}
spec:
nodeName: {{ worker.name }}
securityContext:
runAsUser: 998
fsGroup: 998
containers:
%% for subname, sub in worker.subs.items()
- name: {{ subname }}
image: spreadspace/flumotion:worker-{{ desc.globals.deployment.parameter.flumotion_image_version }}
imagePullPolicy: Always
env:
- name: WORKER_PASSWORD
valueFrom:
secretKeyRef:
name: flumotion-worker-{{ worker.name }}
key: password
args:
- --verbose
- -H {{ desc.globals.manager.host }}
- -P {{ desc.globals.manager.port }}
- -T {{ desc.globals.manager.transport }}
- -n {{ sub.fullname }}
- -u {{ worker.name }}
- -p $(WORKER_PASSWORD)
- -F {{ 7000 + loop.index0 * 10 }}-{{ 7001 + loop.index0 * 10 }}
volumeMounts:
- name: home
mountPath: /srv
%% set _needs_ = { 'decklink_libs': False, 'privileged': False }
%% if 'input' in sub.flags
%% for input_name in worker.flags.input
%% if desc.inputs[input_name].type == 'decklink'
%% if _needs_.update({'decklink_libs': True, 'privileged': True})
%# jinja variables are weird... https://stackoverflow.com/questions/9486393
%% endif
- name: decklink-device-{{ desc.inputs[input_name].properties.device }}
mountPath: /dev/blackmagic/dv{{ desc.inputs[input_name].properties.device }}
%% endif
%% endfor
%% if _needs_.decklink_libs
- name: decklink-libs
subPath: libDeckLinkAPI.so
mountPath: /usr/lib/libDeckLinkAPI.so
- name: decklink-libs
subPath: libDeckLinkPreviewAPI.so
mountPath: /usr/lib/libDeckLinkPreviewAPI.so
%% endif
%% endif
%% if 'record' in worker.flags
%% for record_name in worker.flags.record
- name: record-{{ record_name }}
mountPath: /srv/recordings/{{ record_name }}
%% endfor
%% endif
%% if _needs_.privileged
securityContext:
privileged: true
%% endif
%% endfor
volumes:
- name: home
emptyDir:
medium: Memory
%% if 'input' in worker.flags
%% set _needs_ = { 'decklink_libs': False }
%% for input_name in worker.flags.input
%% if desc.inputs[input_name].type == 'decklink'
%% if _needs_.update({'decklink_libs': True})
%# jinja variables are weird... https://stackoverflow.com/questions/9486393
%% endif
- name: decklink-device-{{ desc.inputs[input_name].properties.device }}
hostPath:
type: File {# CharDevice doesn't work for some reason... #}
path: /dev/blackmagic/dv{{ desc.inputs[input_name].properties.device }}
%% endif
%% endfor
%% if _needs_.decklink_libs
- name: decklink-libs
hostPath:
type: Directory
path: /usr/lib/
%% endif
%% endif
%% if 'record' in worker.flags
%% for record_name in worker.flags.record
- name: record-{{ record_name }}
hostPath:
type: DirectoryOrCreate
path: {{ desc.records[record_name].directory }}/{{ record_name }}
%% endfor
%% endif
|
