xmidt-event-streams

module

v0.29.19 Latest Latest Go to latest Published: Apr 29, 2026 License: Apache-2.0

Details

Accepts a wrp.Message and pipes it to one or more a configured stream(s) based on event type.

This library currently has a built in module for uber fx and prometheus metrics.

import "github.com/xmidt-org/xmidt-event-streams/filter"
...
msg := &wrp.Message{}
filterManager.Queue(msg)

opts := fx.Options(
  ...
  
  filter.FilterModule,
  ...
)

see streams_only.yaml

Path	Synopsis
cmd
eventstream command
filter SPDX-FileCopyrightText: 2017 Comcast Cable Communications Management, LLC SPDX-License-Identifier: Apache-2.0	SPDX-FileCopyrightText: 2017 Comcast Cable Communications Management, LLC SPDX-License-Identifier: Apache-2.0
internal
auth
batch
event SPDX-FileCopyrightText: 2017 Comcast Cable Communications Management, LLC SPDX-License-Identifier: Apache-2.0	SPDX-FileCopyrightText: 2017 Comcast Cable Communications Management, LLC SPDX-License-Identifier: Apache-2.0
install
kinesis
log
metrics
mock
mytime
queue
sender