Dvir Volk dvirsky

## gist:dfdfd4066c70e8391dc5
package main

import(
	"fmt"
	"runtime"
	"io/ioutil"
	"bytes"
	"strings"
)

## gist:16411e335531aef6c5bf
package redis

import (
	"fmt"

	"github.com/garyburd/redigo/redis"
)

// Batch represents a set of batched results, either a transaction or just send/receive.
//

## README.md

      
              4 files
            
          
              0 forks
            
          
              0 comments
            
          
              0 stars
            
          
                dvirsky
                / README.md
            
            
              Last active
              August 29, 2015 14:20
                — forked from jonhoo/README.md
            
          
    Distributed Read-Write Mutex in Go

The default Go implementation of
sync.RWMutex does not scale well
to multiple cores, as all readers contend on the same memory location
when they all try to atomically increment it. This gist explores an
n-way RWMutex, also known as a "big reader" lock, which gives each
CPU core its own RWMutex. Readers take only a read lock local to their
core, whereas writers must take all locks in order.

  
## disque_example.go
package main

import(
	"fmt"
	"time"
	"github.com/EverythingMe/go-disque/disque"
	"github.com/garyburd/redigo/redis"

)

## filter.go
package main

import (
	"fmt"
	"github.com/EverythingMe/inbloom/go/inbloom"
	"net/http"
)

var vocabulary = []string{"foo", "bar", "baz", "hey", "yo", "go"}

## foo_test.go
package foo

import (
	"testing"
)

type Foo struct {
	a   string
	b   int
	c   float32

## gist:f9ebf6f66f763a356d4a

import subprocess
import time
import sys


def parent():

    p = subprocess.Popen(['python', './testp.py', '--child'], stdin=subprocess.PIPE, stdout=subprocess.PIPE)

## serialization.c

// A serializer prototype - you serialize by calling Write N times.
// the key type is determined on registration so not needed here
// the list size will be determined by redis when you exit, based on the number of times you called write()
int (*Serialize)(RedisModuleCtx *ctx,  RedisModuleObjectWriter *out, RedisModuleKey *k)

// you deserialize by calling Read and reading one object at a time.
// numElements is passed so the user can preallocate stuff in advance
int (*Deserialize)(RedisModuleCtx *ctx, RedisModuleObjectReader *in, RedisModuleString *keyName, size_t numElements)

## tasks.json
{
"version": "0.1.0",
"isShellCommand": true,
"showOutput": "always",
"command": "go",
"echoCommand": true ,
"options": {
    "cwd": "${fileDirname}"
},
"tasks": [

## example.txt
# creating an index:

127.0.0.1:6379> IDX.CREATE users TYPE HASH SCHEMA name STRING age INT32
OK

# running HASH commands while indexing them:

127.0.0.1:6379> IDX.INTO users HMSET user1 name "alice" age 24
OK
127.0.0.1:6379> IDX.INTO users HMSET user2 name "bob" age 19
	package main

	import(
	"fmt"
	"runtime"
	"io/ioutil"
	"bytes"
	"strings"
	)
	package redis

	import (
	"fmt"

	"github.com/garyburd/redigo/redis"
	)

	// Batch represents a set of batched results, either a transaction or just send/receive.
	//
	package foo

	import (
	"testing"
	)

	type Foo struct {
	a string
	b int
	c float32

	import subprocess
	import time
	import sys


	def parent():

	p = subprocess.Popen(['python', './testp.py', '--child'], stdin=subprocess.PIPE, stdout=subprocess.PIPE)

	// A serializer prototype - you serialize by calling Write N times.
	// the key type is determined on registration so not needed here
	// the list size will be determined by redis when you exit, based on the number of times you called write()
	int (Serialize)(RedisModuleCtx ctx, RedisModuleObjectWriter out, RedisModuleKey k)

	// you deserialize by calling Read and reading one object at a time.
	// numElements is passed so the user can preallocate stuff in advance
	int (Deserialize)(RedisModuleCtx ctx, RedisModuleObjectReader in, RedisModuleString keyName, size_t numElements)
	{
	"version": "0.1.0",
	"isShellCommand": true,
	"showOutput": "always",
	"command": "go",
	"echoCommand": true ,
	"options": {
	"cwd": "${fileDirname}"
	},
	"tasks": [
	# creating an index:

	127.0.0.1:6379> IDX.CREATE users TYPE HASH SCHEMA name STRING age INT32
	OK

	# running HASH commands while indexing them:

	127.0.0.1:6379> IDX.INTO users HMSET user1 name "alice" age 24
	OK
	127.0.0.1:6379> IDX.INTO users HMSET user2 name "bob" age 19