protected override void InternalRun(ICluster cluster)
        {
            ICqlCommand cmd = cluster.CreatePocoCommand();

            const string insertBatch = "INSERT INTO Foo.Bar (id, Baz) VALUES (?, ?)";
            var preparedInsert = cmd.Prepare(insertBatch);

            const int times = 10;

            var random = new Random();

            for (int i = 0; i < times; i++)
            {
                long running = Interlocked.Increment(ref _running);

                Console.WriteLine("Current {0} Running {1}", i, running);

                var data = new byte[30000];
                // var data = (float)random.NextDouble();
                preparedInsert.Execute(new {id = i, Baz = data}, ConsistencyLevel.ONE).AsFuture()
                              .ContinueWith(_ => Interlocked.Decrement(ref _running));
            }

            while (Thread.VolatileRead(ref _running) > 0)
            {
                Console.WriteLine("Running {0}", _running);
                Thread.Sleep(1000);
            }

            var result = cmd.Execute<Foo>("select * from Foo.Bar where id = 50").AsFuture().Result;
            foreach (var res in result)
            {
                Console.WriteLine("{0} len={1}", res.Id, res.Baz.Length);
            }
        }

 public VolunteerController(IDisaster disasterSvc, ICluster clusterSvc, IAdmin adminSvc, IMessageService messageSvc)
 {
     _disasterSvc = disasterSvc;
     _clusterSvc = clusterSvc;
     _adminSvc = adminSvc;
     _messageSvc = messageSvc;
 }

        protected override void DropKeyspace(ICluster cluster)
        {
            ICqlCommand cmd = cluster.CreatePocoCommand();

            const string dropExcelsor = "drop keyspace videos";
            cmd.Execute(dropExcelsor).AsFuture().Wait();
        }

        public ICqlCommand Create(ICluster cluster, IDataMapperFactory factoryIn, IDataMapperFactory factoryOut)
        {
            factoryIn.CheckArgumentNotNull("factoryIn");
            factoryOut.CheckArgumentNotNull("factoryOut");

            return new CqlCommand(cluster, factoryIn, factoryOut);
        }

        public VerifyAllClusters(List<String> listClusters, List<String> listPath, ICluster listener)
        {
            do
            {
                InitializeComponent();
                listPathDirectory.AddRange(listPath);
                mListener = listener;
                if (listClusters.Count == 0)
                {
                    Verify_Btn.Enabled = false;
                    VerifyAll_Btn.Enabled = false;
                    break;
                }

                //add items listview resultVerify
                for (int i = 0; i < listClusters.Count; i++)
                {
                    resultVerifyGridView.Rows.Add(listClusters[i], null, null);
                    //resultVerify.Items[i].SubItems.Add("null");
                    //resultGridView.Rows.Add(listClusters[i],"null");
                }
                Verify_Btn.Enabled = true;
                VerifyAll_Btn.Enabled = true;
            } while (false);
        }

 private void expandCluster(ICluster cluster)
 {
     string north = null, east = null, west = null, south = null, center = null;
     string northImg = "null", eastImg = "null", westImg = "null", southImg = "null", centerImg = "null";
     if (cluster.up == null)
         northImg = cluster.upImg;
     else
         north = cluster.up;
     if (cluster.right == null)
         eastImg = cluster.rightImg;
     else
         east = cluster.right;
     if (cluster.left == null)
         westImg = cluster.leftImg;
     else
         west = cluster.left;
     if (cluster.down == null)
         southImg = cluster.downImg;
     else
         south = cluster.down;
     if (cluster.center == null)
         centerImg = cluster.centerImg;
     else
         center = cluster.center;
     userScreen.clusterSection.east.SetElements(null, null, null, null, null, east);
     userScreen.clusterSection.west.SetElements(null, null, null, null, null, west);
     userScreen.clusterSection.south.SetElements(null, null, null, null, null, south);
     userScreen.clusterSection.center.SetElements(null, null, null, null, null, center);
     userScreen.clusterSection.north.SetElements(null, null, null, null, null, north);
     userScreen.clusterSection.east.SetImgElements("null", "null", "null", "null", "null", eastImg);
     userScreen.clusterSection.west.SetImgElements("null", "null", "null", "null", "null", westImg);
     userScreen.clusterSection.south.SetImgElements("null", "null", "null", "null", "null", southImg);
     userScreen.clusterSection.center.SetImgElements("null", "null", "null", "null", "null", centerImg);
     userScreen.clusterSection.north.SetImgElements("null", "null", "null", "null", "null", northImg);
 }

 internal DseCluster(ICluster coreCluster, DseConfiguration config)
 {
     _coreCluster = coreCluster;
     _config = config;
     _coreCluster.HostAdded += OnCoreHostAdded;
     _coreCluster.HostRemoved += OnCoreHostRemoved;
 }

 public AccountController(IVolunteerService volunteerSvc, ICluster clusterSvc, IWebSecurityWrapper webSecurity, IMessageService messageService)
 {
     _clusterSvc = clusterSvc;
     _webSecurity = webSecurity;
     _volunteerSvc = volunteerSvc;
     _messageService = messageService;
 }

 /// <summary>
 /// Gets the display label that the given cluster should use
 /// </summary>
 /// <param name="cluster"></param>
 /// <returns></returns>
 public override string GetClusterDisplayLabel(ICluster cluster)
 {
     string s = Column.ConvertGroupKeyToTitle(cluster.ClusterKey);
     if (String.IsNullOrEmpty(s))
         s = EMPTY_LABEL;
     return ApplyDisplayFormat(cluster, s);
 }

		protected NodeBase(ICluster owner, IPEndPoint endpoint, IFailurePolicy failurePolicy, ISocket socket)
		{
			this.owner = owner;
			this.endpoint = endpoint;
			this.socket = socket;
			this.failurePolicy = failurePolicy;
			this.name = endpoint.ToString();

			failLock = new Object();
			writeQueue = new ConcurrentQueue<Data>();
			readQueue = new Queue<Data>();

			mustReconnect = true;
			IsAlive = true;

			counterEnqueuePerSec = Metrics.Meter("node write enqueue/sec", endpoint.ToString(), Interval.Seconds);
			counterDequeuePerSec = Metrics.Meter("node write dequeue/sec", endpoint.ToString(), Interval.Seconds);
			counterOpReadPerSec = Metrics.Meter("node op read/sec", endpoint.ToString(), Interval.Seconds);
			counterWriteQueue = Metrics.Counter("write queue length", endpoint.ToString());
			counterReadQueue = Metrics.Counter("read queue length", endpoint.ToString());

			counterWritePerSec = Metrics.Meter("node write/sec", endpoint.ToString(), Interval.Seconds);
			counterErrorPerSec = Metrics.Meter("node in error/sec", endpoint.ToString(), Interval.Seconds);
			counterItemCount = Metrics.Counter("commands", endpoint.ToString());
			gaugeSendSpeed = Metrics.Gauge("send speed", endpoint.ToString());
		}

        protected override void InternalRun(ICluster cluster)
        {
            ICqlCommand cmd = cluster.CreatePocoCommand();

            const string insertNerdMovie = "INSERT INTO videos.NerdMovies (movie, director, main_actor, year)" +
                                           "VALUES ('Serenity', 'Joss Whedon', 'Nathan Fillion', 2005) " +
                                           "USING TTL 86400";
            Console.WriteLine(insertNerdMovie);
            cmd.Execute(insertNerdMovie).AsFuture().Wait();
            Console.WriteLine();

            const string selectNerdMovies = "select * from videos.NerdMovies";
            Console.WriteLine(selectNerdMovies);
            var taskSelectStartMovies = cmd.Execute<NerdMovie>(selectNerdMovies).AsFuture().ContinueWith(res => DisplayMovies(res.Result));
            taskSelectStartMovies.Wait();
            Console.WriteLine();

            const string selectAllFrom = "select * from videos.NerdMovies where director=? ALLOW FILTERING";
            Console.WriteLine(selectAllFrom);
            var preparedAllFrom = cmd.Prepare<NerdMovie>(selectAllFrom);
            var ds = new {Director = "Joss Whedon"};
            var taskSelectWhere =
                    preparedAllFrom.Execute(ds).AsFuture().ContinueWith(res => DisplayMovies(res.Result));
            taskSelectWhere.Wait();
            Console.WriteLine();
        }

 public MembershipEvent(ICluster cluster, IMember member, int eventType, ICollection<IMember> members)
     : base(cluster)
 {
     this.member = member;
     this.eventType = eventType;
     this.members = members;
 }

 private async static Task ClearData(ICluster cluster)
 {
     using (var binding = new WritableServerBinding(cluster))
     {
         var commandOp = new DropDatabaseOperation(_database);
         await commandOp.ExecuteAsync(binding);
     }
 }

 // constructors
 /// <summary>
 /// Initializes a new instance of the <see cref="MongoServerInstance" /> class.
 /// </summary>
 /// <param name="settings">The settings.</param>
 /// <param name="address">The address.</param>
 /// <param name="cluster">The cluster.</param>
 /// <param name="endPoint">The end point.</param>
 internal MongoServerInstance(MongoServerSettings settings, MongoServerAddress address, ICluster cluster, EndPoint endPoint)
 {
     _settings = settings;
     _address = address;
     _cluster = cluster;
     _sequentialId = Interlocked.Increment(ref __nextSequentialId);
     _endPoint = endPoint;
 }

 private void HandleEvent(ICluster cluster)
 {
     string UIActionRequest = userScreen.HandleClusterEvent(cluster, wordCompletionSwitch.IsOn);
     if (UIActionRequest != null)
     {
         ExecuteUIAction(UIActionRequest);
     }
 }

 // constructors
 /// <summary>
 /// Initializes a new instance of the <see cref="MongoServerInstance"/> class.
 /// </summary>
 /// <param name="settings">The settings.</param>
 /// <param name="address">The address.</param>
 /// <param name="cluster">The cluster.</param>
 internal MongoServerInstance(MongoServerSettings settings, MongoServerAddress address, ICluster cluster)
 {
     _settings = settings;
     _address = address;
     _cluster = cluster;
     _sequentialId = Interlocked.Increment(ref __nextSequentialId);
     _endPoint = new DnsEndPoint(address.Host, address.Port);
 }

        protected override void CreateKeyspace(ICluster cluster)
        {
            const string createKeyspaceFoo = "CREATE KEYSPACE Foo WITH replication = {'class': 'SimpleStrategy', 'replication_factor' : 1}";
            cluster.ExecuteNonQuery(createKeyspaceFoo).Wait();

            const string createBar = "CREATE TABLE Foo.Bar (id int, Baz blob, PRIMARY KEY (id))";
            cluster.ExecuteNonQuery(createBar).Wait();
        }

        protected override void InternalRun(ICluster cluster)
        {
            const string cqlKeyspaces = "SELECT * from system.schema_columns";

            var req = from t in cluster.Execute<SchemaColumns>(cqlKeyspaces).Result
                      where t.KeyspaceName == "system"
                      select t;
            DisplayResult(req);
        }

 public VolunteerController(IDisaster disasterSvc, ICluster clusterSvc, IAdmin adminSvc, IMessageService messageSvc, IVolunteerService volunteerSvc, IWebSecurityWrapper webSecurity)
 {
     _disasterSvc = disasterSvc;
     _clusterSvc = clusterSvc;
     _adminSvc = adminSvc;
     _messageSvc = messageSvc;
     _volunteerSvc = volunteerSvc;
     _webSecurity = webSecurity;
 }

 public MemberAttributeEvent(ICluster cluster, IMember member, MemberAttributeOperationType operationType,
     string key, object value)
     : base(cluster, member, MemberAttributeChanged, null)
 {
     _member = (Member) member;
     _operationType = operationType;
     _key = key;
     _value = value;
 }