Struct Target 

pub struct Target {
    pub cluster: ClusterId,
    pub index: IndexName,
    pub endpoint: Option<String>,
}

The physical destination of a single routed request.

Both fields are ids/names (never tenant values), so a Target is safe to render in telemetry and /debug/explain (docs/05 §7).

Examples

use osproxy_core::{ClusterId, IndexName, Target};

let target = Target::new(ClusterId::from("eu-1"), IndexName::from("logs-shared"));
assert_eq!(target.cluster.as_str(), "eu-1");
assert_eq!(target.to_string(), "eu-1/logs-shared");

Fields

cluster: ClusterId

The physical OpenSearch cluster the request is sent to.

index: IndexName

The concrete (physical) index the request operates on.

endpoint: Option<String>

The cluster’s base URL, supplied by the tenancy as part of the placement result (the sink builds a pool for it on first use). None only in unit tests that dispatch to an in-memory sink, which ignores it.

Excluded from identity (equality/hashing/Display): the endpoint is a function of the cluster, not part of which target this is, so two ops for the same cluster+index stay one demux key regardless of it.

Implementations

impl Target

pub fn new(cluster: ClusterId, index: IndexName) -> Self

Constructs a target from a cluster and an index (no endpoint).

pub fn with_endpoint(self, endpoint: Option<String>) -> Self

Sets the cluster’s base URL (builder style), as resolved from the placement result.

Trait Implementations

impl Clone for Target

fn clone(&self) -> Target

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Target

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Display for Target

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Eq for Target

impl Hash for Target

fn hash<H: Hasher>(&self, state: &mut H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl PartialEq for Target

fn eq(&self, other: &Self) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.