Module: Takagi

Defined in:
lib/takagi.rb,
lib/takagi/base.rb,
lib/takagi/coap.rb,
lib/takagi/hooks.rb,
lib/takagi/client.rb,
lib/takagi/config.rb,
lib/takagi/errors.rb,
lib/takagi/logger.rb,
lib/takagi/plugin.rb,
lib/takagi/router.rb,
lib/takagi/server.rb,
lib/takagi/helpers.rb,
lib/takagi/reactor.rb,
lib/takagi/version.rb,
lib/takagi/branding.rb,
lib/takagi/profiles.rb,
lib/takagi/event_bus.rb,
lib/takagi/cbor/error.rb,
lib/takagi/controller.rb,
lib/takagi/server/tcp.rb,
lib/takagi/server/udp.rb,
lib/takagi/tcp_client.rb,
lib/takagi/application.rb,
lib/takagi/client_base.rb,
lib/takagi/initializer.rb,
lib/takagi/network/tcp.rb,
lib/takagi/network/udp.rb,
lib/takagi/cbor/decoder.rb,
lib/takagi/cbor/encoder.rb,
lib/takagi/cbor/version.rb,
lib/takagi/message/base.rb,
lib/takagi/network/base.rb,
lib/takagi/server/multi.rb,
lib/takagi/registry/base.rb,
lib/takagi/serialization.rb,
lib/takagi/coap/signaling.rb,
lib/takagi/client/response.rb,
lib/takagi/event_bus/scope.rb,
lib/takagi/message/inbound.rb,
lib/takagi/message/request.rb,
lib/takagi/observer/client.rb,
lib/takagi/observer/sender.rb,
lib/takagi/server/registry.rb,
lib/takagi/server_registry.rb,
lib/takagi/composite_router.rb,
lib/takagi/event_bus/future.rb,
lib/takagi/message/outbound.rb,
lib/takagi/middleware_stack.rb,
lib/takagi/network/registry.rb,
lib/takagi/observe_registry.rb,
lib/takagi/observer/watcher.rb,
lib/takagi/reactor_registry.rb,
lib/takagi/response_builder.rb,
lib/takagi/coap/code_helpers.rb,
lib/takagi/observer/registry.rb,
lib/takagi/server/udp_worker.rb,
lib/takagi/core/attribute_set.rb,
lib/takagi/middleware/caching.rb,
lib/takagi/middleware/logging.rb,
lib/takagi/middleware/metrics.rb,
lib/takagi/network/tcp_sender.rb,
lib/takagi/network/udp_sender.rb,
lib/takagi/observable/emitter.rb,
lib/takagi/observable/reactor.rb,
lib/takagi/serialization/base.rb,
lib/takagi/event_bus/lru_cache.rb,
lib/takagi/network/framing/tcp.rb,
lib/takagi/network/framing/udp.rb,
lib/takagi/observable/registry.rb,
lib/takagi/coap/registries/base.rb,
lib/takagi/middleware/debugging.rb,
lib/takagi/router/route_matcher.rb,
lib/takagi/base/server_lifecycle.rb,
lib/takagi/event_bus/coap_bridge.rb,
lib/takagi/base/plugin_management.rb,
lib/takagi/coap/registries/method.rb,
lib/takagi/coap/registries/option.rb,
lib/takagi/controller/thread_pool.rb,
lib/takagi/serialization/registry.rb,
lib/takagi/base/reactor_management.rb,
lib/takagi/coap/registries/response.rb,
lib/takagi/event_bus/address_prefix.rb,
lib/takagi/event_bus/async_executor.rb,
lib/takagi/event_bus/message_buffer.rb,
lib/takagi/middleware/rate_limiting.rb,
lib/takagi/coap/registries/signaling.rb,
lib/takagi/middleware/authentication.rb,
lib/takagi/router/metadata_extractor.rb,
lib/takagi/base/middleware_management.rb,
lib/takagi/discovery/core_link_format.rb,
lib/takagi/event_bus/observer_cleanup.rb,
lib/takagi/message/deduplication_cache.rb,
lib/takagi/coap/registries/message_type.rb,
lib/takagi/controller/resource_allocator.rb,
lib/takagi/serialization/cbor_serializer.rb,
lib/takagi/serialization/json_serializer.rb,
lib/takagi/serialization/text_serializer.rb,
lib/takagi/coap/registries/content_format.rb,
lib/takagi/message/retransmission_manager.rb,
lib/takagi/serialization/octet_stream_serializer.rb

Overview

Coap and Ruby in Sinatra like package

Defined Under Namespace

Modules: Branding, CBOR, CoAP, Core, Discovery, Errors, Helpers, Hooks, Message, Middleware, Network, Observable, Observer, Profiles, ReactorRegistry, Registry, Serialization, Server Classes: Application, Base, Client, ClientBase, CompositeRouter, Config, Controller, Error, EventBus, Initializer, Logger, MiddlewareStack, Plugin, ResponseBuilder, Router, TcpClient, UdpClient

Constant Summary collapse

Reactor =
Deprecated.

Use Observable::Reactor instead. This alias will be removed in v2.0.0

Backward compatibility alias for Observable::Reactor

The new Observable::Reactor provides:

  • Thread pool support for parallel execution

  • Event-driven notifications via EventBus

  • Hybrid polling + push modes

  • Better resource management

Examples:

Migration

# Old
reactor = Takagi::Reactor.new

# New
reactor = Takagi::Observable::Reactor.new(threads: 4)
Observable::Reactor
VERSION =
'1.1.0'
NAME =
'Radius'
ServerRegistry =
Deprecated.

Use Takagi::Server::Registry instead. This alias will be removed in v2.0.0

Backward compatibility alias for Server::Registry

Server::Registry
ObserveRegistry =
Deprecated.

Use Takagi::Observer::Registry instead. This alias will be removed in v2.0.0

Backward compatibility alias for Observer::Registry

Observer::Registry

Class Method Summary collapse

Class Method Details

.configObject



9
10
11
# File 'lib/takagi.rb', line 9

def self.config
  @config ||= Takagi::Config.new
end

.loggerObject



13
14
15
# File 'lib/takagi.rb', line 13

def self.logger
  @logger ||= Takagi::Logger.new(level: ::Logger::INFO)
end