G cluster_drain Drain drain_input drain_pull pull drain_input->drain_pull drain_push push: file/stdout drain_pull->drain_push