summaryrefslogtreecommitdiffstats
path: root/markup/org/convert.go
AgeCommit message (Expand)Author
2023-06-18Replace the old log setup, with structured logging etc.Bjørn Erik Pedersen
2023-03-12deps: Update go-org to v1.6.6Niklas Fasching
2023-02-24Split parse and render for GoldmarkBjørn Erik Pedersen
2022-02-24Add Markdown diagrams and render hooks for code blocksBjørn Erik Pedersen
2021-04-12org: Disable broken pretty relative links featureNiklas Fasching
2021-01-02deps: Update go-org to v1.4.0Niklas Fasching
2020-10-22Allow getJSON errors to be ignoredBjørn Erik Pedersen
2020-04-17deps: Update go-org to v1.1.0Niklas Fasching
2019-12-18Add render template hooks for links and imagesBjørn Erik Pedersen
2019-11-23Add Goldmark as the new default markdown handlerBjørn Erik Pedersen
2019-11-06Prepare for GoldmarkBjørn Erik Pedersen
pan class="cpf">"opentsdb/opentsdb.h" #if ENABLE_PROMETHEUS_REMOTE_WRITE #include "prometheus/remote_write/remote_write.h" #endif #if HAVE_KINESIS #include "aws_kinesis/aws_kinesis.h" #endif #if ENABLE_EXPORTING_PUBSUB #include "pubsub/pubsub.h" #endif #if HAVE_MONGOC #include "mongodb/mongodb.h" #endif /** * Initialize connectors * * @param engine an engine data structure. * @return Returns 0 on success, 1 on failure. */ int init_connectors(struct engine *engine) { engine->now = now_realtime_sec(); for (struct instance *instance = engine->instance_root; instance; instance = instance->next) { instance->index = engine->instance_num++; instance->after = engine->now; switch (instance->config.type) { case EXPORTING_CONNECTOR_TYPE_GRAPHITE: if (init_graphite_instance(instance) != 0) return 1; break; case EXPORTING_CONNECTOR_TYPE_JSON: if (init_json_instance(instance) != 0) return 1; break; case EXPORTING_CONNECTOR_TYPE_OPENTSDB_USING_TELNET: if (init_opentsdb_telnet_instance(instance) != 0) return 1; break; case EXPORTING_CONNECTOR_TYPE_OPENTSDB_USING_HTTP: if (init_opentsdb_http_instance(instance) != 0) return 1; break; case EXPORTING_CONNECTOR_TYPE_PROMETHEUS_REMOTE_WRITE: #if ENABLE_PROMETHEUS_REMOTE_WRITE if (init_prometheus_remote_write_instance(instance) != 0) return 1; #endif break; case EXPORTING_CONNECTOR_TYPE_KINESIS: #if HAVE_KINESIS if (init_aws_kinesis_instance(instance) != 0) return 1; #endif break; case EXPORTING_CONNECTOR_TYPE_PUBSUB: #if ENABLE_EXPORTING_PUBSUB if (init_pubsub_instance(instance) != 0) return 1; #endif break; case EXPORTING_CONNECTOR_TYPE_MONGODB: #if HAVE_MONGOC if (init_mongodb_instance(instance) != 0) return 1; #endif break; default: error("EXPORTING: unknown exporting connector type"); return 1; } // dispatch the instance worker thread int error = uv_thread_create(&instance->thread, instance->worker, instance); if (error) { error("EXPORTING: cannot create tread worker. uv_thread_create(): %s", uv_strerror(error)); return 1; } char threadname[NETDATA_THREAD_NAME_MAX + 1]; snprintfz(threadname, NETDATA_THREAD_NAME_MAX, "EXPORTING-%zu", instance->index); uv_thread_set_name_np(instance->thread, threadname); send_statistics("EXPORTING_START", "OK", instance->config.type_name); } return 0; }