12 lines
451 B
Plaintext
12 lines
451 B
Plaintext
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
|
|
|