Table of Contents - cross_spec-0.1.0 Documentation
Classes and Modules
- CrossSpec
- CrossSpec::Client
- CrossSpec::Config
- CrossSpec::FailureBeacon
- CrossSpec::KafkaClient
- CrossSpec::Message
- CrossSpec::ServiceMessage
- CrossSpec::Spec
- CrossSpec::SpecWaiting
- CrossSpec::TaskMessage
Methods
- ::beacon — CrossSpec
- ::config — CrossSpec
- ::configure — CrossSpec
- ::failure_beacon! — CrossSpec
- ::from_json — CrossSpec::ServiceMessage
- ::from_json — CrossSpec::TaskMessage
- ::handle — CrossSpec
- ::listen! — CrossSpec
- ::new — CrossSpec::Client
- ::new — CrossSpec::KafkaClient
- ::new — CrossSpec::Message
- ::new — CrossSpec::ServiceMessage
- ::new — CrossSpec::SpecWaiting
- ::new — CrossSpec::TaskMessage
- ::trace — CrossSpec::Spec
- #async — CrossSpec::Spec
- #await — CrossSpec::Spec
- #broadcast — CrossSpec::Client
- #broadcast — CrossSpec::KafkaClient
- #client — CrossSpec::Config
- #data — CrossSpec::SpecWaiting
- #done? — CrossSpec::SpecWaiting
- #each_message — CrossSpec::KafkaClient
- #group_id — CrossSpec::KafkaClient
- #handlers — CrossSpec::Config
- #increment_matches — CrossSpec::SpecWaiting
- #kafka — CrossSpec::Config
- #kafka_connection_string — CrossSpec::Config
- #kafka_connection_string= — CrossSpec::Config
- #listen! — CrossSpec::Client
- #origin_biomarker — CrossSpec::Message
- #process — CrossSpec::SpecWaiting
- #store_data — CrossSpec::SpecWaiting
- #sync — CrossSpec::Spec