ankurcha

package analytics.api;

import com.googlecode.concurrentlinkedhashmap.ConcurrentLinkedHashMap;
import org.eclipse.jetty.continuation.Continuation;
import org.eclipse.jetty.continuation.ContinuationSupport;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import javax.servlet.*;
import javax.servlet.http.HttpServletRequest;

ankurcha

#!/bin/bash

JDK_FILE="jdk-8u20-linux-x64.tar.gz"
JDK_URL="https://s3.amazonaws.com/com.brightcove.rna.repo.dev/${JDK_FILE}"
JDK_ARCHIVE="${HOME}/${JDK_FILE}"
JDKS_DIR="${HOME}/jdks"
JDK_DIR="${JDKS_DIR}/jdk1.8.0_20"

# ensure jdks directory exists
mkdir -p $JDKS_DIR

ankurcha

function knife_dl() {
  local packages="$@"
  cd ~/chef/cookbooks
  for c in ${packages}; do
    knife cookbook site download ${c};
    tar zxf ${c}*.tar.gz;
    rm ${c}-*.tar.gz;
  done
}

ankurcha

/*
var context = cubism.context(),
    cube = context.cube("https://data.brightcove.com/v1/accounts/8523")
    cube.metric("video_view")
*/
cubism_contextPrototype.analytics_api = function(url) {
  if (!arguments.length) url = "";
  var source = {},
      context = this;

ankurcha

input {
  file {
    type => "analytics-api"
    path => "/var/log/analytics-api/analytics-api.log"
  }
  file {
    type => "mongos"
    path => ["/var/log/mongodb/mongos_rolling.log", "/var/log/mongodb/mongos_historical.log", "/var/log/mongodb/mongos_collector.log"]
  }
  file {

ankurcha

function removeDB(n) {
  flushConfigs();
  var colls = findChunkedCollections(n);
  
  colls.forEach(function(coll) {
    if(!db.getSisterDB(n).getCollection(coll).exists()) {
      print("collection did not exist for chunk: " + n + "." + coll)
      getPrimaries().forEach(function(p){
        p.getDB(n).createCollection(coll);
      });

ankurcha

{
        "percent" : 6.297823041677475, 
        "bytesDone" : NumberLong("22117130240"),
        "files" : {
                "done" : 8,
                "total" : 166
        },
        "current" : {
                "source" : "/var/lib/mongodb_historical11/local_oplog_rs_p15_id__ddfdbfc0_1_19.tokumx",
                "dest" : "/backup11/local_oplog_rs_p15_id__ddfdbfc0_1_19.tokumx",

ankurcha

#!/bin/sh

GROOVY_VERSION=${$GROOVY_VERSION:-"2.1.6"}

if [ -z "$@" ]; then
  echo "No argument specified"
  exit 1
fi

if [ ! -f "$@" ]; then

ankurcha

#!/usr/bin/env ruby
def check_require(name)
  begin
    gem name    
  rescue Gem::LoadError
    # not installed
    system("gem install #{name}")
    Gem.clear_paths
  end
  require name

ankurcha

• All Channels have a one to one mapping with the entry in the credentialStore.
• The refreshing process is managed by the GoogleAuthorizationFlow api client.