Waiting for engine...
Skip to main content

EventStreamsRoute

A message routing rule that filters and routes messages based on metadata properties

type EventStreamsRoute {
  environmentId: ID!
  name: ID!
  inputTopic: String!
  subscriptionName: String!
  defaultOutputTopic: String!
  filters: [EventStreamsRouteFilterGroup!]!
  status: EventStreamsRouteStatus!
  errorMessage: String
  messagesReceivedCount: BigInteger!
  messagesProcessedCount: BigInteger!
  totalRestarts: Int
  lastInvocationTime: DateTime
}

Fields​

EventStreamsRoute.environmentId ● ID! non-null scalar miscellaneous

Environment this route belongs to

EventStreamsRoute.name ● ID! non-null scalar miscellaneous

Name of the route (unique within environment)

EventStreamsRoute.inputTopic ● String! non-null scalar miscellaneous

Input topic to consume messages from

EventStreamsRoute.subscriptionName ● String! non-null scalar miscellaneous

Subscription name for consuming from the input topic

[<CodePill>EventStreamsRoute.defaultOutputTopic</CodePill>](#)<Bullet />[<CodePill>String!</CodePill>](/APIs/GraphQL/APIReference/types/miscellaneous/scalars/string.mdx) <Badge class="badge badge--secondary badge--non_null" text="non-null"/> <Badge class="badge badge--secondary " text="scalar"/> <Badge class="badge badge--secondary " text="miscellaneous"/>

Default output topic for messages that don't match any filters

[<CodePill>EventStreamsRoute.filters</CodePill>](#)<Bullet />[<CodePill>[EventStreamsRouteFilterGroup!]!</CodePill>](/APIs/GraphQL/APIReference/types/event-streams-admin/objects/event-streams-route-filter-group.mdx) <Badge class="badge badge--secondary badge--non_null" text="non-null"/> <Badge class="badge badge--secondary " text="object"/> <Badge class="badge badge--secondary " text="event-streams-admin"/>

List of filter groups with their conditions and output topics

[<CodePill>EventStreamsRoute.status</CodePill>](#)<Bullet />[<CodePill>EventStreamsRouteStatus!</CodePill>](/APIs/GraphQL/APIReference/types/event-streams-admin/enums/event-streams-route-status.mdx) <Badge class="badge badge--secondary badge--non_null" text="non-null"/> <Badge class="badge badge--secondary " text="enum"/> <Badge class="badge badge--secondary " text="event-streams-admin"/>

Current status of the route

[<CodePill>EventStreamsRoute.errorMessage</CodePill>](#)<Bullet />[<CodePill>String</CodePill>](/APIs/GraphQL/APIReference/types/miscellaneous/scalars/string.mdx) <Badge class="badge badge--secondary " text="scalar"/> <Badge class="badge badge--secondary " text="miscellaneous"/>

Error message if status is ERROR

[<CodePill>EventStreamsRoute.messagesReceivedCount</CodePill>](#)<Bullet />[<CodePill>BigInteger!</CodePill>](/APIs/GraphQL/APIReference/types/platform/scalars/big-integer.mdx) <Badge class="badge badge--secondary badge--non_null" text="non-null"/> <Badge class="badge badge--secondary " text="scalar"/> <Badge class="badge badge--secondary " text="platform"/>

Total messages received by this route function

[<CodePill>EventStreamsRoute.messagesProcessedCount</CodePill>](#)<Bullet />[<CodePill>BigInteger!</CodePill>](/APIs/GraphQL/APIReference/types/platform/scalars/big-integer.mdx) <Badge class="badge badge--secondary badge--non_null" text="non-null"/> <Badge class="badge badge--secondary " text="scalar"/> <Badge class="badge badge--secondary " text="platform"/>

Total messages successfully processed by this route function

[<CodePill>EventStreamsRoute.totalRestarts</CodePill>](#)<Bullet />[<CodePill>Int</CodePill>](/APIs/GraphQL/APIReference/types/miscellaneous/scalars/int.mdx) <Badge class="badge badge--secondary " text="scalar"/> <Badge class="badge badge--secondary " text="miscellaneous"/>

Total restarts across all function instances. High values indicate instability (crash loops).

[<CodePill>EventStreamsRoute.lastInvocationTime</CodePill>](#)<Bullet />[<CodePill>DateTime</CodePill>](/APIs/GraphQL/APIReference/types/platform/scalars/date-time.mdx) <Badge class="badge badge--secondary " text="scalar"/> <Badge class="badge badge--secondary " text="platform"/>

Timestamp of last message processed. Null if no messages have been processed yet.

### Returned By

[<CodePill>eventStreamsRoute</CodePill>](/APIs/GraphQL/APIReference/operations/event-streams-admin/queries/event-streams-route.mdx)  <Badge class="badge badge--secondary badge--relation" text="query"/><Bullet />
[<CodePill>eventStreamsRouteCreate</CodePill>](/APIs/GraphQL/APIReference/operations/event-streams-admin/mutations/event-streams-route-create.mdx)  <Badge class="badge badge--secondary badge--relation" text="mutation"/><Bullet />
[<CodePill>eventStreamsRoutes</CodePill>](/APIs/GraphQL/APIReference/operations/event-streams-admin/queries/event-streams-routes.mdx)  <Badge class="badge badge--secondary badge--relation" text="query"/><Bullet />
[<CodePill>eventStreamsRouteStart</CodePill>](/APIs/GraphQL/APIReference/operations/event-streams-admin/mutations/event-streams-route-start.mdx)  <Badge class="badge badge--secondary badge--relation" text="mutation"/><Bullet />
[<CodePill>eventStreamsRouteStop</CodePill>](/APIs/GraphQL/APIReference/operations/event-streams-admin/mutations/event-streams-route-stop.mdx)  <Badge class="badge badge--secondary badge--relation" text="mutation"/><Bullet />
[<CodePill>eventStreamsRouteUpdate</CodePill>](/APIs/GraphQL/APIReference/operations/event-streams-admin/mutations/event-streams-route-update.mdx)  <Badge class="badge badge--secondary badge--relation" text="mutation"/>

On this Page