Skip to content

Commit df4a731

Browse files
committed
feat: create service for extensions
Signed-off-by: Ankit152 <[email protected]>
1 parent 6a5f9ba commit df4a731

File tree

1 file changed

+6
-1
lines changed

1 file changed

+6
-1
lines changed

apis/v1beta1/config.go

+6-1
Original file line numberDiff line numberDiff line change
@@ -206,7 +206,8 @@ func (c *Config) getPortsForComponentKinds(logger logr.Logger, componentKinds ..
206206
case KindProcessor:
207207
continue
208208
case KindExtension:
209-
continue
209+
retriever = extensions.ParserFor
210+
cfg = *c.Extensions
210211
}
211212
for componentName := range enabledComponents[componentKind] {
212213
// TODO: Clean up the naming here and make it simpler to use a retriever.
@@ -282,6 +283,10 @@ func (c *Config) GetExporterPorts(logger logr.Logger) ([]corev1.ServicePort, err
282283
return c.getPortsForComponentKinds(logger, KindExporter)
283284
}
284285

286+
func (c *Config) GetExtensionPorts(logger logr.Logger) ([]corev1.ServicePort, error) {
287+
return c.getPortsForComponentKinds(logger, KindExtension)
288+
}
289+
285290
func (c *Config) GetAllPorts(logger logr.Logger) ([]corev1.ServicePort, error) {
286291
return c.getPortsForComponentKinds(logger, KindReceiver, KindExporter)
287292
}

0 commit comments

Comments
 (0)