---
title: bigpanda.endpoint() function
description: bigpanda.endpoint() sends alerts to BigPanda using data from input rows.
url: https://docs.influxdata.com/flux/v0/stdlib/contrib/rhajek/bigpanda/endpoint/
estimated_tokens: 2118
product: Flux
version: v0
---

# bigpanda.endpoint() function

-   Flux 0.108.0+
-   View InfluxDB support

`bigpanda.endpoint()` is a user-contributed function maintained by the [package author](#package-author-and-maintainer).

`bigpanda.endpoint()` sends alerts to BigPanda using data from input rows.

### Usage

`bigpanda.endpoint` is a factory function that outputs another function. The output function requires a `mapFn` parameter.

#### mapFn

A function that builds the object used to generate the POST request. Requires an `r` parameter.

`mapFn` accepts a table row (`r`) and returns an object that must include the following fields:

-   `status`
-   Additional [alert parameters](https://docs.bigpanda.io/reference#alert-object) to send to the BigPanda alert API.

*For more information, see `bigpanda.sendAlert()` parameters.*

##### Function type signature

```js
(
    appKey: A,
    token: string,
    ?url: string,
) => (mapFn: (r: B) => {C with status: D}) => (<-tables: stream[B]) => stream[{B with _sent: string}]
```

For more information, see [Function type signatures](/flux/v0/function-type-signatures/).

## Parameters

### url

BigPanda [alerts API URL](https://docs.bigpanda.io/reference#alerts-how-it-works). Default is the value of the `bigpanda.defaultURL` option.

### token

(Required) BigPanda [API Authorization token (API key)](https://docs.bigpanda.io/docs/api-key-management).

### appKey

(Required) BigPanda [App Key](https://docs.bigpanda.io/reference#integrating-monitoring-systems).

## Examples

### Send critical alerts to BigPanda

```js
import "influxdata/influxdb/secrets"
import "json"

token = secrets.get(key: "BIGPANDA_API_KEY")
endpoint = bigpanda.endpoint(token: token, appKey: "example-app-key")

crit_events =
    from(bucket: "example-bucket")
        |> range(start: -1m)
        |> filter(fn: (r) => r._measurement == "statuses" and status == "crit")

crit_events
    |> endpoint(
        mapFn: (r) => {
            return {r with status: "critical",
                check: "critical-status-check",
                description: "${r._field} is critical: ${string(v: r._value)}",
                tags: json.encode(v: [{"name": "host", "value": r.host}]),
            }
        },
    )()
```

[notification endpoints](/flux/v0/tags/notification-endpoints/) [transformations](/flux/v0/tags/transformations/)