\nUsage of polymur:\n  -api-addr string\n        API listen address [POLYMUR_API_ADDR] (default \"localhost:2030\")\n  -console-out\n        Dump output to console [POLYMUR_CONSOLE_OUT]\n  -destinations string\n        Comma-delimited list of ip:port destinations [POLYMUR_DESTINATIONS]\n  -distribution string\n        Destination distribution methods: broadcast, hash-route [POLYMUR_DISTRIBUTION] (default \"broadcast\")\n  -incoming-queue-cap int\n        In-flight incoming message queue capacity (number of data point batches [100 points max per batch]) [POLYMUR_INCOMING_QUEUE_CAP] (default 32768)\n  -listen-addr string\n        Polymur listen address [POLYMUR_LISTEN_ADDR] (default \"0.0.0.0:2003\")\n  -metrics-flush int\n        Graphite flush interval for runtime metrics (0 is disabled) [POLYMUR_METRICS_FLUSH]\n  -outgoing-queue-cap int\n        In-flight message queue capacity per destination (number of data points) [POLYMUR_OUTGOING_QUEUE_CAP] (default 4096)\n  -stat-addr string\n        runstats listen address [POLYMUR_STAT_ADDR] (default \"localhost:2020\")\n

\n\n### Examples\n\n#### Running\n\nListening for incoming metrics on `0.0.0.0:2003` and mirroring to `10.0.5.20:2003` and `10.0.5.30:2003`:\n

\n./polymur -destinations=\"10.0.5.20:2003,10.0.5.30:2003\" -metrics-flush=30 -\"listen-addr=0.0.0.0:2003\" -distribution=\"broadcast\"\n2015/05/14 15:19:08 ::: Polymur :::\n2015/05/14 15:19:08 Registered destination 10.0.5.20:2003\n2015/05/14 15:19:08 Registered destination 10.0.5.30:2003\n2015/05/14 15:19:08 Adding destination to connection pool: 10.0.5.30:2003\n2015/05/14 15:19:08 Adding destination to connection pool: 10.0.5.20:2003\n2015/05/14 15:19:09 API started: localhost:2030\n2015/05/14 15:19:09 Runstats started: localhost:2020\n2015/05/14 15:19:09 Metrics listener started: 0.0.0.0:2003\n2015/05/14 15:19:14 Last 5s: Received 7276 data points | Avg: 1455.20/sec.\n2015/05/14 15:19:19 Last 5s: Received 6471 data points | Avg: 1294.20/sec.\n2015/05/14 15:19:24 Last 5s: Received 6744 data points | Avg: 1348.80/sec.\n2015/05/14 15:19:29 Last 5s: Received 5806 data points | Avg: 1161.20/sec.\n

\n\n#### Changing destinations\n\nPolymur started with no initial destinations:\n

\n./polymur\n2015/05/14 09:09:15 ::: Polymur :::\n2015/05/14 09:09:15 Metrics listener started: 0.0.0.0:2003\n2015/05/14 09:09:15 API started: localhost:2030\n2015/05/14 09:09:15 Runstats started: localhost:2020\n

\n\n

\n% echo getdest | nc localhost 2030\n{\n \"active\": [],\n \"registered\": {}\n}\n

\n\nAdd destination at runtime:\n

\n% echo putdest localhost:6020 | nc localhost 2030          \nRegistered destination: localhost:6020\n

\n\n

\n2015/05/14 09:09:23 Registered destination localhost:6020\n2015/05/14 09:09:23 Adding destination to connection pool: localhost:6020\n

\n\n

\n% echo getdest | nc localhost 2030\n{\n \"active\": [\n  \"localhost:6020\"\n ],\n \"registered\": {\n  \"localhost:6020\": \"2015-05-14T09:09:23.620410265-06:00\"\n }\n}\n

\n\n\n### Internals\n\nTerminology:\n\n- **Destination**: where metrics will be forwarded using the Graphite plaintext protocol\n- **Destination queue**: metrics in-flight for a given destination\n- **Registered**: a candidate destination loaded into Polymur, but not necessarily active\n- **Connection**: a registered destination with an active connection\n- **Connection pool**: global list of all active connections and their respective destination queue\n- **Distribution mode**: how metrics are distributed to destinations (broadcast, hash-route)\n- **Retry queue**: messages that couldn't be sent to their destination are loaded into the retry queue and retried on remaining active connections\n\nPolymur listens on the configured addr:port for incoming connections, each connection handled in a dedicated Goroutine. A connection Goroutine reads the inbound stream and allocates a message string at LF boundaries. Messages are batched and flushed on size and time thresholds.\n\nMessage batches from the inbound queue are then distributed (broadcast or hash-routed) to a dedicated queue for each output destination. Destination output is also handled using dedicated Goroutines, where transient latency or full disconnects to one destination will not impact write performance to another destination. If a destination becomes unreachable, the endpoint will be retried at 10 second intervals while the respective destination queue buffers new incoming messages. Per destination queue capacity is determined by the `-queue-cap` directive. Any destination queue with an outstanding length greater than 0 will be logged to stdout. Any destination queue that exceeds the configured `-queue-cap` will not receive any new messages until the queue is cleared. If the distribution mode is configured as hash-route, three consecutive reconnect attempt failures will result in removing the connection from the connection pool and redistributing any in-flight messages to a retry-queue for distribution to remaining healthy destinations.\n\nDiagram:\n\n![ScreenShot](https://raw.githubusercontent.com/jamiealquiza/catpics/master/polymur-internals.jpg)\n","has_starred","hub_user","immutable_tags_settings",{"_71":11,"_72":73},"enabled","rules",[74],".*","is_automated","permissions",{"_78":17,"_79":11,"_80":11},"read","write","admin","user","storage_size",422960526,"orgData","recentTags",[87],{"_88":40,"_89":90,"_91":92,"_93":94,"_95":96,"_46":114,"_115":90,"_116":29,"_117":52,"_53":118,"_119":120,"_121":105,"_122":114,"_123":62,"_124":17},"content_type","creator",367082,"full_size",116114564,"id",11191741,"images",[97],{"_98":99,"_100":101,"_102":103,"_104":105,"_106":107,"_108":109,"_110":103,"_111":-5,"_112":92,"_59":62,"_113":-5},"architecture","amd64","digest","sha256:61d82e3525a55a678964b79c50c226bc6602364e9795a8cd4fe5a8899ed3bfd8","features","","last_pulled","2026-09-22T01:52:11.950351316Z","last_pushed","2017-07-31T16:36:17Z","os","linux","os_features","os_version","size","variant","2017-07-31T16:36:16.189319Z","last_updater","last_updater_username","media_type","latest","repository",1512264,"tag_last_pulled","tag_last_pushed","tag_status","v2","sbxKitMetadata","isPotentialSpam","isHubSbxKitsEnabled","showSbxLogoOverride","sbxTrademarkText","displaySecurityMetadata","tagAttestations","tagsHaveAttestations",[],"routes/_layout.r.$namespace.$reponame.tags",{"_34":136,"_143":144,"_132":153,"_154":11},{"_36":137,"_38":138,"_41":42,"_43":44,"_45":11,"_46":47,"_48":49,"_50":139,"_53":31,"_28":29,"_54":55,"_56":40,"_57":58,"_59":60,"_61":62,"_63":-5,"_64":58,"_65":66,"_67":11,"_68":29,"_69":140,"_75":17,"_76":142,"_81":29,"_82":83},[],[40],[52],{"_71":11,"_72":141},[74],{"_78":17,"_79":11,"_80":11},"tags",{"_145":60,"_146":-5,"_147":-5,"_148":149},"count","next","previous","results",[150],{"_88":40,"_89":90,"_91":92,"_93":94,"_95":151,"_46":114,"_115":90,"_116":29,"_117":52,"_53":118,"_119":120,"_121":105,"_122":114,"_123":62,"_124":17},[152],{"_98":99,"_100":101,"_102":103,"_104":105,"_106":107,"_108":109,"_110":103,"_111":-5,"_112":92,"_59":62,"_113":-5},[],"canDeleteTags","actionData","errors"]

ehlers320/polymur-proxy

Tags for ehlers320/polymur-proxy