Skip to content

Instantly share code, notes, and snippets.

@grantr
grantr / gist:1105416
Created July 25, 2011 22:31
Chef mysql master/slave recipes
## mysql::master
ruby_block "store_mysql_master_status" do
block do
node.set[:mysql][:master] = true
m = Mysql.new("localhost", "root", node[:mysql][:server_root_password])
m.query("show master status") do |row|
row.each_hash do |h|
node.set[:mysql][:master_file] = h['File']
node.set[:mysql][:master_position] = h['Position']
end
# diff pkg/reconciler/{pubsub,intevents}
diff pkg/reconciler/pubsub/controller.go pkg/reconciler/intevents/controller.go
17c17
< package pubsub
---
> package intevents
diff pkg/reconciler/pubsub/controller_test.go pkg/reconciler/intevents/controller_test.go
17c17
< package pubsub
---
#!/usr/bin/env bash
git diff --stat=260 master.. vendor > updates.txt
/usr/bin/env ruby -e 'ARGF.each_line do |line|
next if line !~ /\.go\s/
dirs = line.split("/")
if dirs[1] == "github.com"
puts "#{dirs[1]}/#{dirs[2]}/#{dirs[3]}"
else
package main
import (
"context"
"cloud.google.com/go/pubsub"
"cloud.google.com/go/pubsub/pstest"
"google.golang.org/api/option"
"google.golang.org/grpc"
)
kind: Broker
spec:
template:
metadata:
labels: <label map>
ingress: <Destination>
rules:
attributes: <TypeMeta>
apiVersion: eventing.knative.dev/v1alpha1
kind: AttributesRule
{
"level": "error",
"ts": "2020-01-03T14:42:08.615Z",
"logger": "activator",
"caller": "network/error_handler.go:31",
"msg": "error reverse proxying request; sockstat: sockets: used 2178\nTCP: inuse 1145 orphan 41 tw 494 alloc 3535 mem 2947\nUDP: inuse 0 mem 35\nUDPLITE: inuse 0\nRAW: inuse 0\nFRAG: inuse 0 memory 0\n",
"knative.dev/controller": "activator",
"knative.dev/pod": "activator-947bd7448-9mxxv",
"knative.dev/key": "event-example/wathola-forwarder-d96jq",
"error": "read tcp 10.128.4.9:56414->10.131.0.14:8012: read: connection reset by peer",

Packages:

sources.eventing.knative.dev

Package v1alpha1 contains API Schema definitions for the sources v1alpha1 API group

@grantr
grantr / main.go
Last active April 8, 2019 22:06
CEL int to float conversion bug
package main
import (
"fmt"
"log"
"strings"
"github.com/golang/protobuf/jsonpb"
structpb "github.com/golang/protobuf/ptypes/struct"
"github.com/google/cel-go/cel"
@grantr
grantr / reconciler.go
Last active March 25, 2019 21:23
A controller interface that can live peacefully in knative/pkg
// ObjectReconciler is what the user implements. This is the generic version.
// The controller MUST be aware of whether it's running with CR or CG.
// With this interface, at least the code will be structured similarly
// and the client interaction can converge over time (or not, as desired)
// This is called ObjectReconciler to avoid confusion with existing Reconciler
// interfaces.
type ObjectReconciler interface {
// This could alternately be called ReconcileObject.
Reconcile(context.Context, runtime.Object) error
}
@grantr
grantr / eventing-and-sources.txt
Last active February 26, 2019 22:33
Percentage of code 2018Q4 - 2019Q1
Using https://github.com/Harwayne/github-reviews@3c503f6.
$ go run main.go --token_file=$HOME/.github.oauth --owner=knative --repos=eventing --repos=eventing-sources --users=grantr --start=08-31-2018 --end=02-25-2019
2019/02/26 10:57:46 Searching for PRs between 8-31-2018 and 2-25-2019
2019/02/26 10:58:38 Finished listing PRs. 725
2019/02/26 10:58:38 Finished filtering PRs for time. 464
2019/02/26 10:58:38 Finished filtering PRs for authors. 408
2019/02/26 11:10:32 Total PRs: 408. Commented PRs: 162
2019/02/26 11:37:07 Total lines added: 124303
2019/02/26 11:37:07 Total non-authored lines added: 117903