Struct LogglyPlugin 

pub struct LogglyPlugin {
    sink: BatchSink,
    log_format: Option<HashMap<String, LogFormatValue>>,
    include_req_body: bool,
    include_resp_body: bool,
}

Batches access-log entries and POSTs them to the Loggly bulk endpoint.

Fields

sink: BatchSink

log_format: Option<HashMap<String, LogFormatValue>>

include_req_body: bool

include_resp_body: bool

Implementations

impl LogglyPlugin

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

Builds the plugin from node config.

Accepted keys:

• customer_token (string, required): Loggly customer token; forms part of the bulk URL. Missing/empty is a config-load error.
• tags (array of strings, default [featherbit]): Loggly tags, comma-joined into the URL and the X-LOGGLY-TAG header.
• host (string, default logs-01.loggly.com): Loggly host; a bare host gets an https:// scheme.
• severity (string, default INFO): accepted for APISIX compatibility but ignored (HTTP bulk mode carries no syslog severity).
• ssl_verify (bool, default true): verify TLS certificates.
• timeout (integer ms, default 5000): whole-call deadline per flush.
• log_format, include_req_body, include_resp_body — see the shared log-entry builder.
• Batch keys — see BatchConfig.

type: loggly
config:
  customer_token: 00000000-0000-0000-0000-000000000000
  tags: [featherbit, prod]
  ssl_verify: true

Trait Implementations

impl Plugin for LogglyPlugin

fn plugin_type(&self) -> &str

Unique identifier for the plugin type (e.g., “proxy-rewrite”, “upstream”). This is also the key its PortSpec is registered under in port_spec.

fn reads_response_body(&self) -> bool

Whether this configured instance reads context.response.body.

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

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

Executes the plugin logic against the request/response context.

fn cache_target(&self) -> Option<CacheTarget>

The cache backend this node writes to, if it is a proxy-cache half.