corrosion/query_event

This module allows for decoding query events returned by /v1/queries and /v1/subscriptions

Types

ChangeType

pub type ChangeType {
  Insert
  Update
  Delete
}

Constructors

```
Insert
```
```
Update
```
```
Delete
```

QueryEvent

pub type QueryEvent {
  Columns(column_names: List(String))
  Row(rowid: Int, values: List(dynamic.Dynamic))
  EOQ(time: Float, change_id: option.Option(Int))
  Change(
    change_type: ChangeType,
    row_id: Int,
    values: List(dynamic.Dynamic),
    change_id: Int,
  )
  QueryError(message: String)
}

Constructors

```
Columns(column_names: List(String))
```

Row(rowid: Int, values: List(dynamic.Dynamic))

EOQ(time: Float, change_id: option.Option(Int))

Change(
  change_type: ChangeType,
  row_id: Int,
  values: List(dynamic.Dynamic),
  change_id: Int,
)

```
QueryError(message: String)
```

Values

decoder

pub fn decoder() -> decode.Decoder(QueryEvent)

✨