command

Commands accepted by the pure Stage protocol.

Types

Command

A validated request to mutate Stage protocol state.

pub type Command(event) {
  Subscribe(
    id: subscription_id.SubscriptionId,
    participant_id: participant_id.ParticipantId,
    partition: Int,
  )
  Ask(
    subscription_id: subscription_id.SubscriptionId,
    amount: Int,
  )
  Push(events: List(event))
  Cancel(subscription_id: subscription_id.SubscriptionId)
  ParticipantDown(participant_id: participant_id.ParticipantId)
  Shutdown
}

Constructors

Subscribe(
  id: subscription_id.SubscriptionId,
  participant_id: participant_id.ParticipantId,
  partition: Int,
)

Ask(subscription_id: subscription_id.SubscriptionId, amount: Int)

```
Push(events: List(event))
```

Cancel(subscription_id: subscription_id.SubscriptionId)

ParticipantDown(participant_id: participant_id.ParticipantId)

```
Shutdown
```