arangodb-events-rs

KO | EN

gitlite — search

#javascript #hacktoberfest #ai #golang #android #machine-learning #docker #nodejs #macos #java #kubernetes #pytorch #openai #open-source

arangodb-events-rs

(★ 9)

Subscribe to real time events on your ArangoDB database in Rust

arangodb-events-rs 최신버젼 다운로드

최종 버전 다운로드 (.zip)

// repository documentation

Was this content helpful?

★ 0 (0 ratings)

# ArangoDB Events

A library to add triggers to your ArangoDB database, when events occur (insert, update, delete etc.) on your
collections.

[![crates.io](https://img.shields.io/crates/v/arangodb_events_rs?label=latest&logo=rust)](https://crates.io/crates/arangodb_events_rs)
![Downloads](https://img.shields.io/crates/d/arangodb_events_rs.svg)
![Build](https://img.shields.io/github/workflow/status/ForetagInc/arangodb-events-rs/cargo)
[![Documentation](https://docs.rs/arangodb_events_rs/badge.svg?version=latest)](https://docs.rs/arangodb_events_rs/latest)

## Documentation

- [API Documentation](https://docs.rs/arangodb_events_rs/)

## Features
- `async` Enables asynchronous `Handler::call` method

## Installation

Add the crate to your `Cargo.toml`:
```toml
arangodb_events_rs = "0.1.6"
```

## Usage

```rust
use arangodb_events_rs::api::DocumentOperation;
use arangodb_events_rs::{Handler, Trigger, HandlerContextFactory};

pub struct GlobalHandler;

pub struct GlobalHandlerContext {
    pub data: u8,
}

impl Handler for GlobalHandler {
    type Context = GlobalHandlerContext;

fn call(ctx: &GlobalHandlerContext, doc: &DocumentOperation) {
        println!("{}", ctx.data); // 10
    }
}

#[tokio::main]
async fn main() {
    let mut trigger = Trigger::new_auth(
        "http://localhost:8529/",
        "database",
        TriggerAuthentication::new("user", "password"),
    );

trigger.subscribe::<GlobalHandler>(
        HandlerEvent::InsertOrReplace,
        HandlerContextFactory::from(GlobalHandlerContext {
            data: 10,
        })
    ); // This subscribes for all Insert or Replace operations on the database

trigger.subscribe_to::<AccountHandler>(
        HandlerEvent::Remove,
        "accounts",
        HandlerContextFactory::from(AccountHandlerContext {
            data: 50,
        })
    ); // This is gonna listen only for Remove operations over accounts table

trigger
        .init()
        .await
        .expect("Error initializing ArangoDB Trigger");

loop {
        trigger
            .listen()
            .await
            .expect("Error on Trigger listener loop");
    }
}
```

arangodb-events-rs

arangodb-events-rs 최신버젼 다운로드

오늘의 추천 프로젝트

Was this content helpful?

Recent Feedback

arangodb-events-rs

arangodb-events-rs 최신버젼 다운로드

오늘의 추천 프로젝트

Was this content helpful?

Recent Feedback

Download README