Crate barter_integration

Modules

de

Utilities to assist deserialisation.

error

Custom SocketErrors generated by an ExchangeStream and ExchangeSink.

metric

Contains the flexible Metric type used for representing real-time metrics generically.

model

! # Barter-Integration ! Contains an ExchangeStream capable of acting as a [Stream] for a given remote server, and a ExchangeSink ! capable of acting [Sink] for a given remote server. Foundational data structures that define the building blocks used by the rest of the Barter ecosystem.

protocol

Contains StreamParser implementations for transforming communication protocol specific messages into a generic output data structure.

Structs

Event

Generic event generated by an ExchangeStream. Contains a monotonically increasing sequence number to support determining event order from the socket.

ExchangeSink

Todo:

ExchangeStream

An ExchangeStream is a communication protocol agnostic [Stream]. It polls protocol messages from the inner [Stream], and transforms them into the desired output data structure.

Traits

Transformer

Transformers are capable of transforming any Input into an iterator of Result<Output, SocketError>s.

Validator

Validators are capable of determining if their internal state is satisfactory to fulfill some use case defined by the implementor.