grantr

# 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
---

grantr

#!/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

grantr

package main

import (
	"context"

	"cloud.google.com/go/pubsub"
	"cloud.google.com/go/pubsub/pstest"
	"google.golang.org/api/option"
	"google.golang.org/grpc"
)

grantr

kind: Broker
spec:
  template:
    metadata:
      labels: <label map>
  ingress: <Destination>
  rules:
    attributes: <TypeMeta>
      apiVersion: eventing.knative.dev/v1alpha1
      kind: AttributesRule

grantr

{
	"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",

grantr

Packages:

• sources.eventing.knative.dev

sources.eventing.knative.dev

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

grantr

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

// 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

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

grantr

module Elastomer
  module Query
    class ElasticsearchQueryParser < LuceneQueryParser

      rule(:unbounded_range) { gte | lte | gt | lt }
      #TODO range groups e.g. age:(>=10 AND < 20) age:(+>=10 +<20)

      #TODO eliminate duplication
      rule(:field) { word.as(:field) >> str(':') >> (((group | regexp | inclusive_range.as(:inclusive_range) | exclusive_range.as(:exclusive_range)) >> boost.maybe) | ((phrase | term) >> (distance | boost).maybe)) }
    end