strike48-connector 0.3.6

Rust SDK for the Strike48 Connector Framework
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58

//! Behavior-specific connectors for Strike48.
//!
//! This module provides typed connector traits for each connector behavior.
//! Some behaviors have an adapter or runner shortcut that handles the
//! `BaseConnector` boilerplate; others currently still require implementing
//! [`crate::BaseConnector`] directly and driving it with
//! [`crate::ConnectorRunner`].
//!
//! | Behavior | Trait | Recommended entry point |
//! |---|---|---|
//! | `Tool` | [`tool::ToolConnector`] | wrap in [`tool_adapter::ToolAdapter`] and call [`crate::simple::run_tool`] |
//! | `RequestResponse` | [`crate::SimpleConnector`] | call its `run` method |
//! | `App` | [`app::AppConnector`] | use [`serve::App::builder`], or [`crate::simple::serve_app`] / [`crate::simple::serve_static`] |
//! | `Source` | [`source::SourceConnector`] | implement [`crate::BaseConnector`] directly (no adapter yet) |
//! | `Sink` | [`sink::SinkConnector`] | implement [`crate::BaseConnector`] directly (no adapter yet) |
//! | `PubSub` | [`pubsub::PubSubConnector`] | implement [`crate::BaseConnector`] directly (no adapter yet) |

pub mod app;
pub mod pubsub;
pub mod request_response;
pub mod serve;
pub mod sink;
pub mod source;
pub mod tool;
pub mod tool_adapter;
pub mod utilities;

// App behavior
pub use app::*;
pub use serve::{App, AppBuilder};

// Source behavior
pub use source::{FetchRequest, FetchResponse, SourceConfig, SourceConnector};

// Sink behavior
pub use sink::{IdempotentSink, ItemError, SinkConfig, SinkConnector, WriteResult};

// Tool behavior
pub use tool::{ParamType, ParameterSchema, ToolConnector, ToolParam, ToolResult, ToolSchema};
pub use tool_adapter::ToolAdapter;

// PubSub behavior
pub use pubsub::{
    InMemoryPubSub, Message, PubSubConfig, PubSubConnector, PublishOptions, SubscribeOptions,
    Subscription, SubscriptionError, TopicPattern,
};

// RequestResponse behavior
pub use request_response::{
    BatchRequest, BatchResponse, ConcurrentRequestHandler, RequestContext, RequestError,
    RequestMetrics, RequestResponseConfig, RequestResponseConnector, Response,
};

// Utilities
pub use utilities::{
    Cache, CacheStats, OperationMetrics, RetryConfig, Timer, ValidationError, retry_async, timed,
    validate_against_schema, validate_json,
};