Project
Loading...
Searching...
No Matches
Public Types | Static Public Member Functions | Static Public Attributes | List of all members
o2::framework::ChannelConfigurationPolicyHelpers Struct Reference

A set of helpers for common ChannelConfigurationPolicy behaviors. More...

#include <ChannelConfigurationPolicyHelpers.h>

Public Types

using PolicyMatcher = std::function< bool(std::string const &producer, std::string const &consumer)>
 
using OutputChannelModifier = std::function< void(OutputChannelSpec &spec)>
 
using InputChannelModifier = std::function< void(InputChannelSpec &spec)>
 

Static Public Member Functions

static PolicyMatcher matchByProducerName (const char *name)
 
static PolicyMatcher matchByConsumerName (const char *name)
 
static InputChannelModifier subscribeInput (FairMQChannelConfigSpec const &spec)
 Makes the passed input channel connect and subscribe.
 
static OutputChannelModifier publishOutput (FairMQChannelConfigSpec const &spec)
 Makes the passed output channel bind and subscribe.
 
static InputChannelModifier pullInput (FairMQChannelConfigSpec const &spec)
 Makes the passed input channel connect and pull.
 
static OutputChannelModifier pushOutput (FairMQChannelConfigSpec const &spec)
 Makes the passed output channel bind and push.
 
static InputChannelModifier reqInput (FairMQChannelConfigSpec const &spec)
 Makes the passed input channel connect and request.
 
static OutputChannelModifier replyOutput (FairMQChannelConfigSpec const &spec)
 Makes the passed output channel bind and reply.
 
static InputChannelModifier pairInput (FairMQChannelConfigSpec const &spec)
 Makes the passed input channel connect and pair.
 
static OutputChannelModifier pairOutput (FairMQChannelConfigSpec const &spec)
 Makes the passed output channel bind and pair.
 

Static Public Attributes

static PolicyMatcher matchAny
 Catch all policy, used by the last rule.
 

Detailed Description

A set of helpers for common ChannelConfigurationPolicy behaviors.

Definition at line 29 of file ChannelConfigurationPolicyHelpers.h.

Member Typedef Documentation

◆ InputChannelModifier

using o2::framework::ChannelConfigurationPolicyHelpers::InputChannelModifier = std::function<void(InputChannelSpec& spec)>

Definition at line 37 of file ChannelConfigurationPolicyHelpers.h.

◆ OutputChannelModifier

using o2::framework::ChannelConfigurationPolicyHelpers::OutputChannelModifier = std::function<void(OutputChannelSpec& spec)>

Definition at line 36 of file ChannelConfigurationPolicyHelpers.h.

◆ PolicyMatcher

using o2::framework::ChannelConfigurationPolicyHelpers::PolicyMatcher = std::function<bool(std::string const& producer, std::string const& consumer)>

Definition at line 35 of file ChannelConfigurationPolicyHelpers.h.

Member Function Documentation

◆ matchByConsumerName()

ChannelConfigurationPolicyHelpers::PolicyMatcher o2::framework::ChannelConfigurationPolicyHelpers::matchByConsumerName ( const char *  name)
static

Definition at line 31 of file ChannelConfigurationPolicyHelpers.cxx.

◆ matchByProducerName()

ChannelConfigurationPolicyHelpers::PolicyMatcher o2::framework::ChannelConfigurationPolicyHelpers::matchByProducerName ( const char *  name)
static

Definition at line 23 of file ChannelConfigurationPolicyHelpers.cxx.

◆ pairInput()

ChannelConfigurationPolicyHelpers::InputChannelModifier o2::framework::ChannelConfigurationPolicyHelpers::pairInput ( FairMQChannelConfigSpec const &  spec)
static

Makes the passed input channel connect and pair.

Definition at line 87 of file ChannelConfigurationPolicyHelpers.cxx.

◆ pairOutput()

ChannelConfigurationPolicyHelpers::OutputChannelModifier o2::framework::ChannelConfigurationPolicyHelpers::pairOutput ( FairMQChannelConfigSpec const &  spec)
static

Makes the passed output channel bind and pair.

Definition at line 99 of file ChannelConfigurationPolicyHelpers.cxx.

◆ publishOutput()

ChannelConfigurationPolicyHelpers::OutputChannelModifier o2::framework::ChannelConfigurationPolicyHelpers::publishOutput ( FairMQChannelConfigSpec const &  spec)
static

Makes the passed output channel bind and subscribe.

Definition at line 51 of file ChannelConfigurationPolicyHelpers.cxx.

◆ pullInput()

ChannelConfigurationPolicyHelpers::InputChannelModifier o2::framework::ChannelConfigurationPolicyHelpers::pullInput ( FairMQChannelConfigSpec const &  spec)
static

Makes the passed input channel connect and pull.

Definition at line 63 of file ChannelConfigurationPolicyHelpers.cxx.

◆ pushOutput()

ChannelConfigurationPolicyHelpers::OutputChannelModifier o2::framework::ChannelConfigurationPolicyHelpers::pushOutput ( FairMQChannelConfigSpec const &  spec)
static

Makes the passed output channel bind and push.

Definition at line 75 of file ChannelConfigurationPolicyHelpers.cxx.

◆ replyOutput()

static OutputChannelModifier o2::framework::ChannelConfigurationPolicyHelpers::replyOutput ( FairMQChannelConfigSpec const &  spec)
static

Makes the passed output channel bind and reply.

◆ reqInput()

static InputChannelModifier o2::framework::ChannelConfigurationPolicyHelpers::reqInput ( FairMQChannelConfigSpec const &  spec)
static

Makes the passed input channel connect and request.

◆ subscribeInput()

ChannelConfigurationPolicyHelpers::InputChannelModifier o2::framework::ChannelConfigurationPolicyHelpers::subscribeInput ( FairMQChannelConfigSpec const &  spec)
static

Makes the passed input channel connect and subscribe.

Definition at line 39 of file ChannelConfigurationPolicyHelpers.cxx.

Member Data Documentation

◆ matchAny

ChannelConfigurationPolicyHelpers::PolicyMatcher o2::framework::ChannelConfigurationPolicyHelpers::matchAny
static
Initial value:
=
[](std::string const&, std::string const&) { return true; }

Catch all policy, used by the last rule.

Definition at line 40 of file ChannelConfigurationPolicyHelpers.h.

The documentation for this struct was generated from the following files: