executor

Documentation

Index

• type ArangoDB
• type Cassandra
• type ClickHouse
• type CouchDB
• type DHCP4
• type DNS
• type ETCD
• type Elasticsearch
• type FTP
• type GRPC
• type GraphQL
• type HTTP
• type ICMP
• type InfluxDB
• type Kafka
• type LDAP
• type MQTT
• type Memcache
• type MongoDB
• type NATS
• type NTP
• type Neo4j
• type Params
• type Plan
  • func NewPlan(p Params, s Stage) (Plan, error)
• type Pulsar
• type RabbitMQ
• type Redis
• type SNMP
• type SQL
• type SSH
• type ScyllaDB
• type Stage
• type Syslog
• type TCP
• type TFTP
• type Telnet
• type UDP
• type Websocket

Types

type ArangoDB

type ArangoDB interface {
	Execute(context.Context, *arangodb.Config) error
}

ArangoDB is used for executing ArangoDB.

type Cassandra

type Cassandra interface {
	Execute(context.Context, *cassandra.Config) error
}

Cassandra is used for executing Cassandra.

type ClickHouse

type ClickHouse interface {
	Execute(context.Context, *clickhouse.Config) error
}

ClickHouse is used for executing ClickHouse.

type CouchDB

type CouchDB interface {
	Execute(context.Context, *couchdb.Config) error
}

CouchDB is used for executing CouchDB.

type DHCP4

type DHCP4 interface {
	Execute(context.Context, *dhcp4.Config) error
}

DHCP4 is uesd for executing DHCP4.

type DNS

type DNS interface {
	Execute(context.Context, *dns.Config) error
}

DNS is used for executing a DNS.

type ETCD

type ETCD interface {
	Execute(context.Context, *etcd.Config) error
}

ETCD is used for executing ETCD.

type Elasticsearch

type Elasticsearch interface {
	Execute(context.Context, *elasticsearch.Config) error
}

Elasticsearch is used for executing Elasticsearch.

type FTP

type FTP interface {
	Execute(context.Context, *ftp.Config) error
}

FTP is used for executing FTP/SFTP.

type GRPC

type GRPC interface {
	Execute(context.Context, *grpc.Config) error
}

GRPC is used for executing gRPC.

type GraphQL

type GraphQL interface {
	Execute(context.Context, *graphql.Config) error
}

GraphQL is used for executing GraphQL.

type HTTP

type HTTP interface {
	Execute(context.Context, *http.Config) error
}

HTTP is used for executing HTTP.

type ICMP

type ICMP interface {
	Execute(context.Context, *icmp.Config) error
}

ICMP is used for executing ICMP/Ping.

type InfluxDB

type InfluxDB interface {
	Execute(context.Context, *influxdb.Config) error
}

InfluxDB is used for executing InfluxDB.

type Kafka

type Kafka interface {
	Execute(context.Context, *kafka.Config) error
}

Kafka is used for executing Kafka.

type LDAP

type LDAP interface {
	Execute(context.Context, *ldap.Config) error
}

LDAP is used for executing LDAP.

type MQTT

type MQTT interface {
	Execute(context.Context, *mqtt.Config) error
}

MQTT is used for executing MQTT.

type Memcache

type Memcache interface {
	Execute(context.Context, *memcache.Config) error
}

Memcache is used for executing Memcache.

type MongoDB

type MongoDB interface {
	Execute(context.Context, *mongodb.Config) error
}

MongoDB is used for executing MongoDB.

type NATS

type NATS interface {
	Execute(context.Context, *nats.Config) error
}

NATS is used for executing NATS.

type NTP

type NTP interface {
	Execute(context.Context, *ntp.Config) error
}

NTP is used for executing NTP.

type Neo4j

type Neo4j interface {
	Execute(context.Context, *neo4j.Config) error
}

Neo4j is used for executing Neo4j.

type Params

type Params struct {
	Registry *prometheus.Registry
}

Params are used for configuring a Plan.

type Plan

type Plan interface {
	Execute(context.Context, *config.Plan) error
}

Plan is used for executing a Plan.

func NewPlan

func NewPlan(p Params, s Stage) (Plan, error)

NewPlan returns a new Plan executor.

type Pulsar

type Pulsar interface {
	Execute(context.Context, *pulsar.Config) error
}

Pulsar is used for executing Apache Pulsar.

type RabbitMQ

type RabbitMQ interface {
	Execute(context.Context, *rabbitmq.Config) error
}

RabbitMQ is used for executing RabbitMQ.

type Redis

type Redis interface {
	Execute(context.Context, *redis.Config) error
}

Redis is used for executing Redis.

type SNMP

type SNMP interface {
	Execute(context.Context, *snmp.Config) error
}

SNMP is used for executing SNMP.

type SQL

type SQL interface {
	Execute(context.Context, *sql.Config) error
}

SQL is used for executing SQL.

type SSH

type SSH interface {
	Execute(context.Context, *ssh.Config) error
}

SSH is used for executing SSH.

type ScyllaDB

type ScyllaDB interface {
	Execute(context.Context, *scylladb.Config) error
}

ScyllaDB is used for executing ScyllaDB.

type Stage

type Stage interface {
	Execute(context.Context, *config.Stage) error
}

Stage is used for executing a Stage.

type Syslog

type Syslog interface {
	Execute(context.Context, *syslog.Config) error
}

Syslog is used for executing Syslog.

type TCP

type TCP interface {
	Execute(context.Context, *tcp.Config) error
}

TCP is used for executing TCP.

type TFTP

type TFTP interface {
	Execute(context.Context, *tftp.Config) error
}

TFTP is used for executing TFTP.

type Telnet

type Telnet interface {
	Execute(context.Context, *telnet.Config) error
}

Telnet is used for executing Telnet.

type UDP

type UDP interface {
	Execute(context.Context, *udp.Config) error
}

UDP is used for executing UDP.

type Websocket

type Websocket interface {
	Execute(context.Context, *websocket.Config) error
}

Websocket is used for websocket.