code note The Overview Usage: send `topic` with `value` and `key` pair data(also `partition`), and send with callback or send and handle future returned. Async I/O operation under implements. send process summary: - fetch metadata for target topic and partition(with cache, but remote fetch when pid undefine or pid out of cache meta) …

There are two problems we solved by trick-way, but newset sql and go-sql-driver/mysql in right way- -..so please upgrade them if you use old version~~ Long-time unused connection problem If we open and keep a connection to mysql and wait a `long-time`(over mysql-server wait_timeout configuration), connection will be killed by server, and use died…

Exported and not exported — In Go, Exported identifiers start with an upper-case letter, and lower-case identifiers only could see in own package. We should only export real needed identifiers to outer, and let our api easy to use and maintain. Golang Test As practice, Go Test just write new file aside test target and with _test…

Make it modular We often want to let our code to be many small modules, and each them has single responsibility, speically when we in situation that need to meet elusive demands from different environment. There are many reasons and benefits we should do it: easy to reuse and composite flexible to replace…

Someone said “when concat string in Go, we should use bytes.Buffer, it make more effective just like StringBuilder in Java, it reduce both duplicate locate and copy”, but is it TRUE for all situation??? So, Let’s start with a simple situation we meet.. Test We have a int variable —…

Hi, we build new Expression language to manipulate Golang structure data. Project code was hosted at https://github.com/lysu/go-el Its main purpose is to find reflect.Value by Expression, then do some reading and writing, It is very useful to build HTTP Patch API. Installation Simple as it takes to type the following command: …

Today, I write a beanstalkd client with a socket connection pool I want to use pool to let connection more reuse… But after it run a moment…I found my code reserve other tube data…. Because beanstalkd server hold connection state for special connection like `watch` command… So…If we want to reuse socket connection, before use `watch` command to switch to target tube..we MUST USE `ignore` to ignore previous watched tube config…

Build gozk in OSX El capitan and something abount Go/C interactions Gozk is a nice golang zookeeper client by call zookeeper raw C client — libzookeeper. Current document for gozk was about how to install on linux by goinstall.. There are some problem in OSX, but we still want to…

A. add a goroutine to listen SIG then dump to stdout go func() { sigs := make(chan os.Signal, 1) signal.Notify(sigs, syscall.SIGQUIT) buf := make([]byte, 1<<20) for { <-sigs runtime.Stack(buf, true) log.Printf("=== received SIGQUIT ===\n*** goroutine dump...\n%s\n*** end\n", buf) } }() B. Use pprof and export dump on http endpoint