signal_pgo

Types

Projection

pub type Projection {
  Projection(
    projection_id: String,
    projection_name: String,
    projection_version: Int,
    data: String,
  )
}

Constructors

Projection(
  projection_id: String,
  projection_name: String,
  projection_version: Int,
  data: String,
)

ProjectionMessage

</>

pub type ProjectionMessage {
  Store(Projection)
  Get(
    reply_with: process.Subject(Result(Projection, String)),
    String,
  )
  Delete(String)
  Shutdown
}

Constructors

```
Store(Projection)
```

Get(
  reply_with: process.Subject(Result(Projection, String)),
  String,
)

```
Delete(String)
```
```
Shutdown
```

Functions

start

</>

pub fn start(
  pgo_config: Config,
  event_encoder: fn(a) -> String,
  event_decoder: fn(String, String) -> Result(a, String),
) -> Result(
  #(Subject(StoreMessage(a)), Subject(ProjectionMessage)),
  String,
)