Struct ZipkinPlugin 

pub struct ZipkinPlugin {
    phase: Phase,
    endpoint: String,
    service_name: String,
    server_addr: Option<String>,
    sample_ratio: f64,
    ssl_verify: bool,
    timeout: Duration,
    client: Arc<OutboundClient>,
}

One node of the Zipkin tracing pair.

Fields

phase: Phase

endpoint: String

Full collector URL spans POST to, e.g. http://localhost:9411/api/v2/spans.

service_name: String

server_addr: Option<String>

Optional localEndpoint.ipv4 reported on each span.

sample_ratio: f64

Fraction of new traces to sample, in 0.0..=1.0.

ssl_verify: bool

timeout: Duration

client: Arc<OutboundClient>

Implementations

impl ZipkinPlugin

pub fn from_config( config: &HashMap<String, Value>, resources: &Arc<PluginResources>, ) -> Result<Self, String>

Builds the plugin from node config.

Config keys:

Key	Type	Default	Description
phase	string	— (required)	start (before upstream) or end (after upstream).
endpoint	string	— (required)	Full Zipkin v2 collector URL, e.g. http://localhost:9411/api/v2/spans.
service_name	string	"featherbit"	localEndpoint.serviceName reported on each span.
server_addr	string	—	Optional localEndpoint.ipv4 for the reporting host.
sample_ratio	number	1.0	Fraction of new traces to sample, in 0.0..=1.0.
ssl_verify	bool	true	Verify the collector’s TLS certificate.
timeout	int (seconds)	3	Export request timeout (end node).

Fails fast on an unknown phase, a missing/empty endpoint, or a sample_ratio outside 0.0..=1.0. The same config (including endpoint) is placed on both the start and end nodes.

# start node — right after listener, before upstream
- id: zipkin-start
  type: zipkin
  config:
    phase: start
    endpoint: http://localhost:9411/api/v2/spans
    service_name: my-gateway
    sample_ratio: 0.1
# end node — after upstream, right before client
- id: zipkin-end
  type: zipkin
  config:
    phase: end
    endpoint: http://localhost:9411/api/v2/spans

fn sample_new(&self, trace_id: &str) -> bool

Decides whether a brand-new trace should be sampled, per sample_ratio.

fn run_start(&self, ctx: &mut Context)

START: extract or create the span, store it, and inject x-b3-*.

fn run_end(&self, ctx: &Context)

END: load the span and fire-and-forget the Zipkin export when sampled.

Trait Implementations

impl Plugin for ZipkinPlugin

fn plugin_type(&self) -> &str

Unique identifier for the plugin type (e.g., “proxy-rewrite”, “upstream”).

fn execute<'life0, 'life1, 'async_trait>( &'life0 self, ctx: Context, _named_inputs: &'life1 HashMap<String, Value>, ) -> Pin<Box<dyn Future<Output = Result<PluginOutput, PluginExecutionError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Executes the plugin logic against the request/response context.