consul/contributing/streaming/event-filtering.mmd

12 lines
451 B
Plaintext
Raw Normal View History

graph TD
state.Store -->|events in different topics| EventPublisher.Publish
EventPublisher.Publish -->|group by topic| EventPublisher.topicBuffer
EventPublisher.topicBuffer --> Subscription
Subscription -->|filter by key and namespace| SubscribeEndpoint
SubscribeEndpoint -->|"filter by auth (acl token)"| ProtobufEvents[/ grpc /]
ProtobufEvents -->|filter with bexpr| MaterializedView
MaterializedView --> HTTPEndpoint