-apiVersion: extensions/v1beta1 -kind: Deployment -metadata: - name: event-adapter - namespace: default - labels: -run: event-adapter - k8s-app: event-adapter -spec: - replicas: 1 - selector: - matchLabels: - run: event-adapter - k8s-app: event-adapter - template: - metadata: - labels: - run: event-adapter8001 - k8s-app: event-adapter - kubernetes.io/cluster-service: "true" - spec: - containers: - - image: gcr.io/google-containers/event-adapter:1.0 - imagePullPolicy: Always - name: pod-event-adapter - command: - - /adapter - - --max-retrieved-events=123 - - --retrieve-events-since-millis=0 - resources: - cpu: 250m - memory: 200Mi - requests: - cpu: 250m - memory: 200Mi --This will allow you to retrieve at most 123 events that happens after epoch (T = 0 milliseconds). - diff --git a/archived/event-adapter/adapter.go b/archived/event-adapter/adapter.go deleted file mode 100644 index 76e0e46bd..000000000 --- a/archived/event-adapter/adapter.go +++ /dev/null @@ -1,43 +0,0 @@ -/* -Copyright 2016 The Kubernetes Authors. -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - http://www.apache.org/licenses/LICENSE-2.0 -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. -*/ - -package main - -import ( - "flag" - "os" - "runtime" - - "github.com/GoogleCloudPlatform/k8s-stackdriver/event-adapter/cmd/server" - "k8s.io/apimachinery/pkg/util/wait" - "k8s.io/apiserver/pkg/util/logs" -) - -var ( - maxRetrievedEvents = flag.Int("max-retrieved-events", 100, "Maximum number of events can be retrieved") - sinceMillis = flag.Int64("retrieve-events-since-millis", -1, "Retrieve only events logged after given timestamp since epoch, if the given timestamp is < 0 the default of last 1h will be used") -) - -func main() { - logs.InitLogs() - defer logs.FlushLogs() - flag.Parse() - if len(os.Getenv("GOMAXPROCS")) == 0 { - runtime.GOMAXPROCS(runtime.NumCPU()) - } - cmd := server.NewCommandStartSampleAdapterServer(os.Stdout, os.Stderr, wait.NeverStop, *maxRetrievedEvents, *sinceMillis) - cmd.Flags().AddGoFlagSet(flag.CommandLine) - if err := cmd.Execute(); err != nil { - panic(err) - } -} diff --git a/archived/event-adapter/adapter.yaml b/archived/event-adapter/adapter.yaml deleted file mode 100644 index ade417a95..000000000 --- a/archived/event-adapter/adapter.yaml +++ /dev/null @@ -1,132 +0,0 @@ -apiVersion: v1 -kind: ServiceAccount -metadata: - name: event-adapter - namespace: default ---- -apiVersion: extensions/v1beta1 -kind: Deployment -metadata: - name: event-adapter - namespace: default - labels: - run: event-adapter - k8s-app: event-adapter -spec: - replicas: 1 - selector: - matchLabels: - run: event-adapter - k8s-app: event-adapter - template: - metadata: - labels: - run: event-adapter - k8s-app: event-adapter - kubernetes.io/cluster-service: "true" - spec: - containers: - - image: gcr.io/google-containers/event-adapter:1.0 - imagePullPolicy: Always - name: pod-event-adapter - command: - - /adapter - resources: - limits: - cpu: 250m - memory: 200Mi - requests: - cpu: 250m - memory: 200Mi ---- -apiVersion: v1 -kind: Service -metadata: - labels: - run: event-adapter - k8s-app: event-adapter - kubernetes.io/cluster-service: 'true' - kubernetes.io/name: Adapter - name: event-adapter - namespace: default -spec: - ports: - - port: 443 - protocol: TCP - targetPort: 443 - selector: - run: event-adapter - k8s-app: event-adapter - type: ClusterIP ---- -apiVersion: rbac.authorization.k8s.io/v1beta1 -kind: ClusterRoleBinding -metadata: - name: apiextensions:system:auth-delegator -roleRef: - apiGroup: rbac.authorization.k8s.io - kind: ClusterRole - name: system:auth-delegator -subjects: -- apiVersion: v1 - kind: ServiceAccount - name: event-adapter - namespace: default ---- -apiVersion: rbac.authorization.k8s.io/v1beta1 -kind: RoleBinding -metadata: - name: apiextensions-auth-reader - namespace: default -roleRef: - apiGroup: rbac.authorization.k8s.io - kind: Role - name: extension-apiserver-authentication-reader -subjects: -- apiVersion: v1 - kind: ServiceAccount - name: event-adapter - namespace: default ---- -apiVersion: apiregistration.k8s.io/v1beta1 -kind: APIService -metadata: - name: v1alpha1.v1events -spec: - insecureSkipTLSVerify: true - group: v1events - groupPriorityMinimum: 100 - versionPriority: 100 - priority: 100 - service: - name: event-adapter - namespace: default - version: v1alpha1 ---- -apiVersion: rbac.authorization.k8s.io/v1beta1 -kind: ClusterRole -metadata: - name: events-reader -rules: -- apiGroups: - - "v1events" - resources: - - "*" - verbs: ["list", "get", "post", "create"] ---- -apiVersion: rbac.authorization.k8s.io/v1beta1 -kind: ClusterRoleBinding -metadata: - creationTimestamp: null - name: all-events-reader -roleRef: - apiGroup: rbac.authorization.k8s.io - kind: ClusterRole - name: events-reader -subjects: -- apiVersion: rbac.authorization.k8s.io/v1beta1 - kind: Group - name: system:anonymous -- apiVersion: rbac.authorization.k8s.io/v1beta1 - kind: Group - name: system:unauthenticated diff --git a/archived/event-adapter/cmd/provider/provider.go b/archived/event-adapter/cmd/provider/provider.go deleted file mode 100644 index fa4a67942..000000000 --- a/archived/event-adapter/cmd/provider/provider.go +++ /dev/null @@ -1,141 +0,0 @@ -/* -Copyright 2017 The Kubernetes Authors. - -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. -*/ - -package provider - -import ( - gce "cloud.google.com/go/compute/metadata" - "fmt" - "github.com/GoogleCloudPlatform/k8s-stackdriver/event-adapter/pkg/provider" - sd "google.golang.org/api/logging/v2" - api "k8s.io/client-go/pkg/api/v1" - "time" -) - -//TODO(erocchi) Add implementation to write events to Stackdriver -//TODO(erocchi) Use the Kubernetes AIP - compatible errors, see example definitions here: https://github.com/kubernetes-incubator/custom-metrics-apiserver/blob/master/pkg/provider/errors.go - -// StackdriverProvider implements EventsProvider -type StackdriverProvider struct { - stackdriverService *sd.EntriesService - maxRetrievedEvents int - sinceMillis int64 -} - -// NewStackdriverProvider creates a new Provider with standard settings -func NewStackdriverProvider(stackdriverService *sd.Service, maxRetrievedEvents int, sinceMillis int64) provider.EventsProvider { - return &StackdriverProvider{ - stackdriverService: sd.NewEntriesService(stackdriverService), - maxRetrievedEvents: maxRetrievedEvents, - sinceMillis: sinceMillis, - } -} - -// GetNamespacedEventsByName gets the event with the given namespace and name -func (p *StackdriverProvider) GetNamespacedEventsByName(namespace, eventName string) (*api.Event, error) { - standardFilter, err := standardFilter() - if err != nil { - return nil, err - } - filter := "(" + standardFilter + " AND jsonPayload.metadata.namespace = \"" + namespace + "\" AND jsonPayload.metadata.name = \"" + eventName + "\")" - event, err := p.getEvents(filter) - if err != nil { - return nil, err - } - if len(event.Items) == 0 { - return nil, fmt.Errorf("Event not found") - } - return &event.Items[0], nil -} - -// ListAllEventsByNamespace gets all the events with the given namespace -func (p *StackdriverProvider) ListAllEventsByNamespace(namespace string) (*api.EventList, error) { - standardFilter, err := standardFilter() - if err != nil { - return nil, err - } - filter := "(" + standardFilter + " AND jsonPayload.metadata.namespace = \"" + namespace + "\")" - if err != nil { - return nil, err - } - return p.getEvents(filter) -} - -// ListAllEvents gets all the events -func (p *StackdriverProvider) ListAllEvents() (*api.EventList, error) { - filter, err := standardFilter() - if err != nil { - return nil, err - } - return p.getEvents(filter) -} - -func standardFilter() (string, error) { - projectID, err := gce.ProjectID() - if err != nil { - return "", fmt.Errorf("Cannot retrieve projectID. %v", err) - } - return "(logName = \"projects/" + projectID + "/logs/events\" AND jsonPayload.kind = \"Event\")", nil -} - -// CreateNewEvent creates a new event in the given namespace -func (p *StackdriverProvider) CreateNewEvent(namespace string) (*api.Event, error) { - return nil, fmt.Errorf("CreateNewEvent is not implemented yet.") -} - -func (p *StackdriverProvider) getEvents(filter string) (*api.EventList, error) { - projectID, err := gce.ProjectID() - if err != nil { - return nil, fmt.Errorf("Cannot retrieve projectID. %v", err) - } - resource := []string{ - "projects/" + projectID, - } - var timeLimit time.Time - if p.sinceMillis < 0 { - timeLimit = time.Now().Add(-1 * time.Hour) - } else { - timeLimit = time.Unix(0, p.sinceMillis*1e6) - } - timeFilter := "(" + filter + " AND " + "jsonPayload.metadata.creationTimestamp >= \"" + timeLimit.Format(time.RFC3339) + "\")" - eventsList := &api.EventList{} - eventIndex := make(map[string]int) - firstRedirection := true - var response *sd.ListLogEntriesResponse - for { - request := &sd.ListLogEntriesRequest{ - ResourceNames: resource, - Filter: timeFilter, - OrderBy: "timestamp desc", - } - if !firstRedirection { - request.PageToken = response.NextPageToken - } - firstRedirection = false - response, err = p.stackdriverService.List(request).Do() - if err != nil { - return nil, fmt.Errorf("Failed request to Stackdriver: %v", err) - } - eventsList, eventIndex, err = translateToEventList(response, eventsList, eventIndex, p.maxRetrievedEvents) - if err != nil { - return nil, fmt.Errorf("Failed to translate the response from Stackdriver: %v", err) - } - if response.NextPageToken == "" || len(eventsList.Items) >= p.maxRetrievedEvents { - break - } - } - return eventsList, nil -} diff --git a/archived/event-adapter/cmd/provider/translator.go b/archived/event-adapter/cmd/provider/translator.go deleted file mode 100644 index 0b5f070c0..000000000 --- a/archived/event-adapter/cmd/provider/translator.go +++ /dev/null @@ -1,92 +0,0 @@ -/* -Copyright 2017 The Kubernetes Authors. - -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. -*/ - -package provider - -import ( - "encoding/json" - "fmt" - sd "google.golang.org/api/logging/v2" - metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" - api "k8s.io/client-go/pkg/api/v1" -) - -type eventTime struct { - Timestamp metav1.Time `json:"timestamp,omitempty"` -} - -func extractEvent(e *sd.LogEntry) (*api.Event, error) { - a, err := e.JsonPayload.MarshalJSON() - if err != nil { - return nil, fmt.Errorf("Cannot marshall the answer: %v", err) - } - var event api.Event - err = json.Unmarshal(a, &event) - if err != nil { - return nil, fmt.Errorf("Cannot unmarshall the answer to an event: %v", err) - } - return &event, nil -} - -func extractTime(e *sd.LogEntry) (*eventTime, error) { - a, err := e.MarshalJSON() - if err != nil { - return nil, fmt.Errorf("Cannot marshall the time: %v", err) - } - var time eventTime - err = json.Unmarshal(a, &time) - if err != nil { - return nil, fmt.Errorf("Cannot unmarshall the time of the event: %v", err) - } - return &time, nil -} - -func translateToEventList(response *sd.ListLogEntriesResponse, eventsList *api.EventList, eventIndex map[string]int, maxListLength int) (*api.EventList, map[string]int, error) { - for _, value := range response.Entries { - event := value - newEvent, err := extractEvent(event) - if err != nil { - return nil, nil, fmt.Errorf("Failed to parse event : %v", err) - } - - time, err := extractTime(event) - if err != nil { - return nil, nil, fmt.Errorf("Failed to parse timestamp : %v", err) - } - timestamp := time.Timestamp - - if ind, ok := eventIndex[newEvent.Name]; ok { - item := &eventsList.Items[ind] - if item.FirstTimestamp.After(timestamp.Time) { - item.FirstTimestamp = timestamp - } - if item.LastTimestamp.Before(timestamp) { - item.LastTimestamp = timestamp - } - item.Count++ - } else { - newEvent.Count = 1 - newEvent.FirstTimestamp = timestamp - newEvent.LastTimestamp = timestamp - eventsList.Items = append(eventsList.Items, *newEvent) - eventIndex[newEvent.Name] = len(eventsList.Items) - 1 - } - if len(eventsList.Items) >= maxListLength { - break - } - } - return eventsList, eventIndex, nil -} diff --git a/archived/event-adapter/cmd/server/start.go b/archived/event-adapter/cmd/server/start.go deleted file mode 100644 index 66f921f2d..000000000 --- a/archived/event-adapter/cmd/server/start.go +++ /dev/null @@ -1,105 +0,0 @@ -/* -Copyright 2017 The Kubernetes Authors. - -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. -*/ - -package server - -import ( - "fmt" - "github.com/GoogleCloudPlatform/k8s-stackdriver/event-adapter/cmd/provider" - "github.com/GoogleCloudPlatform/k8s-stackdriver/event-adapter/pkg/cmd/server" - "github.com/spf13/cobra" - "golang.org/x/oauth2" - "golang.org/x/oauth2/google" - sd "google.golang.org/api/logging/v2" - "io" - coreclient "k8s.io/client-go/kubernetes/typed/core/v1" - "k8s.io/client-go/rest" - "k8s.io/client-go/tools/clientcmd" -) - -// NewCommandStartSampleAdapterServer provides a CLI handler for 'start master' command -func NewCommandStartSampleAdapterServer(out, errOut io.Writer, stopCh <-chan struct{}, maxRetrievedEvents int, sinceMillis int64) *cobra.Command { - baseOpts := server.NewEventsAdapterServerOptions(out, errOut) - o := SampleAdapterServerOptions{ - EventsAdapterServerOptions: baseOpts, - } - cmd := &cobra.Command{ - Short: "Launch the events API adapter server", - Long: "Launch the events API adapter server", - RunE: func(c *cobra.Command, args []string) error { - if err := o.Complete(); err != nil { - return err - } - if err := o.Validate(args); err != nil { - return err - } - err := o.RunEventsAdapterServer(stopCh, maxRetrievedEvents, sinceMillis) - return err - }, - } - flags := cmd.Flags() - o.SecureServing.AddFlags(flags) - o.Authentication.AddFlags(flags) - o.Authorization.AddFlags(flags) - o.Features.AddFlags(flags) - - flags.StringVar(&o.RemoteKubeConfigFile, "lister-kubeconfig", o.RemoteKubeConfigFile, ""+ - "kubeconfig file pointing at the 'core' kubernetes server with enough rights to list "+ - "any described objets") - return cmd -} - -// RunEventsAdapterServer runs Events adapter API server -func (o SampleAdapterServerOptions) RunEventsAdapterServer(stopCh <-chan struct{}, maxRetrievedEvents int, sinceMillis int64) error { - config, err := o.Config() - if err != nil { - return err - } - var clientConfig *rest.Config - if len(o.RemoteKubeConfigFile) > 0 { - loadingRules := &clientcmd.ClientConfigLoadingRules{ExplicitPath: o.RemoteKubeConfigFile} - loader := clientcmd.NewNonInteractiveDeferredLoadingClientConfig(loadingRules, &clientcmd.ConfigOverrides{}) - - clientConfig, err = loader.ClientConfig() - } else { - clientConfig, err = rest.InClusterConfig() - } - if err != nil { - return fmt.Errorf("unable to construct lister client config to initialize provider: %v", err) - } - _, err = coreclient.NewForConfig(clientConfig) - if err != nil { - return fmt.Errorf("unable to construct lister client to initialize provider: %v", err) - } - oauthClient := oauth2.NewClient(oauth2.NoContext, google.ComputeTokenSource("")) - stackdriverService, err := sd.New(oauthClient) - if err != nil { - return fmt.Errorf("Failed to create Stackdriver client: %v", err) - } - evProvider := provider.NewStackdriverProvider(stackdriverService, maxRetrievedEvents, sinceMillis) - server, err := config.Complete().New(evProvider) - if err != nil { - return err - } - return server.GenericAPIServer.PrepareRun().Run(stopCh) -} - -// SampleAdapterServerOptions contains sample EventsAdapterServerOptions -type SampleAdapterServerOptions struct { - *server.EventsAdapterServerOptions - // RemoteKubeConfigFile is the config used to list pods from the master API server - RemoteKubeConfigFile string -} diff --git a/archived/event-adapter/go.mod b/archived/event-adapter/go.mod deleted file mode 100644 index fc7c3de99..000000000 --- a/archived/event-adapter/go.mod +++ /dev/null @@ -1,123 +0,0 @@ -module github.com/GoogleCloudPlatform/k8s-stackdriver/event-adapter - -go 1.13 - -require ( - bitbucket.org/ww/goautoneg v0.0.0-20120707110453-75cd24fc2f2c // indirect - cloud.google.com/go v0.7.1-0.20170601220109-d59fc17b56f5 - github.com/BurntSushi/toml v0.3.1 // indirect - github.com/PuerkitoBio/purell v1.0.0 // indirect - github.com/PuerkitoBio/urlesc v0.0.0-20160726150825-5bd2802263f2 // indirect - github.com/beorn7/perks v0.0.0-20160229213445-3ac7bf7a47d1 // indirect - github.com/boltdb/bolt v1.3.1 // indirect - github.com/coreos/etcd v3.0.17+incompatible // indirect - github.com/coreos/go-semver v0.3.0 // indirect - github.com/coreos/go-systemd v0.0.0-20161114122254-48702e0da86b // indirect - github.com/coreos/pkg v0.0.0-20160620232715-fa29b1d70f0b // indirect - github.com/docker/distribution v2.7.1+incompatible // indirect - github.com/elazarl/go-bindata-assetfs v0.0.0-20150624150248-3dcc96556217 // indirect - github.com/emicklei/go-restful v1.1.4-0.20161212084525-09691a3b6378 - github.com/evanphx/json-patch v0.0.0-20170123154800-ba18e35c5c1b // indirect - github.com/ghodss/yaml v0.0.0-20150909031657-73d445a93680 // indirect - github.com/go-openapi/jsonpointer v0.0.0-20160704185906-46af16f9f7b1 // indirect - github.com/go-openapi/jsonreference v0.0.0-20160704190145-13c6e3589ad9 // indirect - github.com/go-openapi/spec v0.0.0-20160808142527-6aced65f8501 // indirect - github.com/go-openapi/swag v0.0.0-20160704191624-1d0bd113de87 // indirect - github.com/gogo/protobuf v0.0.0-20160718161353-e18d7aa8f8c6 // indirect - github.com/golang/glog v0.0.0-20141105023935-44145f04b68c // indirect - github.com/golang/groupcache v0.0.0-20160516000752-02826c3e7903 // indirect - github.com/golang/protobuf v0.0.0-20160608215545-8616e8ee5e20 // indirect - github.com/google/btree v1.0.0 // indirect - github.com/google/gofuzz v0.0.0-20161122191042-44d81051d367 // indirect - github.com/grpc-ecosystem/grpc-gateway v1.0.1-0.20160715013742-f52d055dc48a // indirect - github.com/howeyc/gopass v0.0.0-20160826175423-3ca23474a7c7 // indirect - github.com/imdario/mergo v0.0.0-20141206190957-6633656539c1 // indirect - github.com/inconshreveable/mousetrap v1.0.0 // indirect - github.com/jonboulle/clockwork v0.1.0 // indirect - github.com/juju/ratelimit v0.0.0-20151125201925-77ed1c8a0121 // indirect - github.com/mailru/easyjson v0.0.0-20160728113105-d5b7844b561a // indirect - github.com/matttproud/golang_protobuf_extensions v0.0.0-20150406173934-fc2b8d3a73c4 // indirect - github.com/natefinch/lumberjack v2.0.0+incompatible // indirect - github.com/niemeyer/pretty v0.0.0-20200227124842-a10e7caefd8e // indirect - github.com/opencontainers/go-digest v1.0.0-rc1 // indirect - github.com/pborman/uuid v0.0.0-20150603214016-ca53cad383ca // indirect - github.com/pkg/errors v0.7.1-0.20160808055540-a22138067af1 // indirect - github.com/prometheus/client_golang v0.0.0-20151008143247-e51041b3fa41 // indirect - github.com/prometheus/client_model v0.0.0-20150212101744-fa8ad6fec335 // indirect - github.com/prometheus/common v0.0.0-20151014055050-ffe929a3f4c4 // indirect - github.com/prometheus/procfs v0.0.0-20150928173926-454a56f35412 // indirect - github.com/spf13/cobra v0.0.0-20160722081547-f62e98d28ab7 - github.com/spf13/pflag v0.0.0-20170130214245-9ff6c6923cff // indirect - github.com/stretchr/testify v1.5.1 // indirect - github.com/ugorji/go v0.0.0-20170107133203-ded73eae5db7 // indirect - github.com/xiang90/probing v0.0.0-20190116061207-43a291ad63a2 // indirect - golang.org/x/crypto v0.0.0-20161006174701-d172538b2cfc // indirect - golang.org/x/net v0.0.0-20160715184138-e90d6d0afc4c // indirect - golang.org/x/oauth2 v0.0.0-20160902055913-3c3a985cb79f - golang.org/x/sys v0.0.0-20160916181909-8f0908ab3b24 // indirect - golang.org/x/text v0.0.0-20160726164857-2910a502d2bf // indirect - google.golang.org/api v0.0.0-20170508220804-e3824ed33c72 - google.golang.org/appengine v0.0.0-20160823001527-4f7eeb5305a4 // indirect - google.golang.org/grpc v1.0.1-0.20160819002236-231b4cfea0e7 // indirect - gopkg.in/check.v1 v1.0.0-20200227125254-8fa46927fb4f // indirect - gopkg.in/inf.v0 v0.9.0 // indirect - gopkg.in/natefinch/lumberjack.v2 v2.0.0-20150622162204-20b71e5b60d7 // indirect - gopkg.in/yaml.v1 v1.0.0-20140924161607-9f9df34309c0 // indirect - k8s.io/apimachinery v0.0.0-20170331202828-20e10d54608f - k8s.io/apiserver v0.0.0-20170405203548-dcf548fbe26d - k8s.io/client-go v0.0.0-20170405202815-dabf37f5df16 -) - -replace ( - cloud.google.com/go => cloud.google.com/go v0.7.1-0.20170601220109-d59fc17b56f5 - github.com/PuerkitoBio/purell => github.com/PuerkitoBio/purell v1.0.0 - github.com/PuerkitoBio/urlesc => github.com/PuerkitoBio/urlesc v0.0.0-20160726150825-5bd2802263f2 - github.com/beorn7/perks => github.com/beorn7/perks v0.0.0-20160229213445-3ac7bf7a47d1 - github.com/coreos/etcd => github.com/coreos/etcd v3.0.17+incompatible - github.com/coreos/go-systemd => github.com/coreos/go-systemd v0.0.0-20161114122254-48702e0da86b - github.com/coreos/pkg => github.com/coreos/pkg v0.0.0-20160620232715-fa29b1d70f0b - github.com/davecgh/go-spew => github.com/davecgh/go-spew v0.0.0-20151105211317-5215b55f46b2 - github.com/elazarl/go-bindata-assetfs => github.com/elazarl/go-bindata-assetfs v0.0.0-20150624150248-3dcc96556217 - github.com/emicklei/go-restful => github.com/emicklei/go-restful v1.1.4-0.20161212084525-09691a3b6378 - github.com/evanphx/json-patch => github.com/evanphx/json-patch v0.0.0-20170123154800-ba18e35c5c1b - github.com/ghodss/yaml => github.com/ghodss/yaml v0.0.0-20150909031657-73d445a93680 - github.com/go-openapi/jsonpointer => github.com/go-openapi/jsonpointer v0.0.0-20160704185906-46af16f9f7b1 - github.com/go-openapi/jsonreference => github.com/go-openapi/jsonreference v0.0.0-20160704190145-13c6e3589ad9 - github.com/go-openapi/spec => github.com/go-openapi/spec v0.0.0-20160808142527-6aced65f8501 - github.com/go-openapi/swag => github.com/go-openapi/swag v0.0.0-20160704191624-1d0bd113de87 - github.com/gogo/protobuf => github.com/gogo/protobuf v0.0.0-20160718161353-e18d7aa8f8c6 - github.com/golang/glog => github.com/golang/glog v0.0.0-20141105023935-44145f04b68c - github.com/golang/groupcache => github.com/golang/groupcache v0.0.0-20160516000752-02826c3e7903 - github.com/golang/protobuf => github.com/golang/protobuf v0.0.0-20160608215545-8616e8ee5e20 - github.com/google/gofuzz => github.com/google/gofuzz v0.0.0-20161122191042-44d81051d367 - github.com/grpc-ecosystem/grpc-gateway => github.com/grpc-ecosystem/grpc-gateway v1.0.1-0.20160715013742-f52d055dc48a - github.com/howeyc/gopass => github.com/howeyc/gopass v0.0.0-20160826175423-3ca23474a7c7 - github.com/imdario/mergo => github.com/imdario/mergo v0.0.0-20141206190957-6633656539c1 - github.com/inconshreveable/mousetrap => github.com/inconshreveable/mousetrap v1.0.0 - github.com/juju/ratelimit => github.com/juju/ratelimit v0.0.0-20151125201925-77ed1c8a0121 - github.com/mailru/easyjson => github.com/mailru/easyjson v0.0.0-20160728113105-d5b7844b561a - github.com/matttproud/golang_protobuf_extensions => github.com/matttproud/golang_protobuf_extensions v0.0.0-20150406173934-fc2b8d3a73c4 - github.com/pborman/uuid => github.com/pborman/uuid v0.0.0-20150603214016-ca53cad383ca - github.com/pkg/errors => github.com/pkg/errors v0.7.1-0.20160808055540-a22138067af1 - github.com/prometheus/client_golang => github.com/prometheus/client_golang v0.0.0-20151008143247-e51041b3fa41 - github.com/prometheus/client_model => github.com/prometheus/client_model v0.0.0-20150212101744-fa8ad6fec335 - github.com/prometheus/common => github.com/prometheus/common v0.0.0-20151014055050-ffe929a3f4c4 - github.com/prometheus/procfs => github.com/prometheus/procfs v0.0.0-20150928173926-454a56f35412 - github.com/spf13/cobra => github.com/spf13/cobra v0.0.0-20160722081547-f62e98d28ab7 - github.com/spf13/pflag => github.com/spf13/pflag v0.0.0-20170130214245-9ff6c6923cff - github.com/ugorji/go => github.com/ugorji/go v0.0.0-20170107133203-ded73eae5db7 - golang.org/x/crypto => golang.org/x/crypto v0.0.0-20161006174701-d172538b2cfc - golang.org/x/net => golang.org/x/net v0.0.0-20160715184138-e90d6d0afc4c - golang.org/x/oauth2 => golang.org/x/oauth2 v0.0.0-20160902055913-3c3a985cb79f - golang.org/x/sys => golang.org/x/sys v0.0.0-20160916181909-8f0908ab3b24 - golang.org/x/text => golang.org/x/text v0.0.0-20160726164857-2910a502d2bf - google.golang.org/api => google.golang.org/api v0.0.0-20170508220804-e3824ed33c72 - google.golang.org/appengine => google.golang.org/appengine v0.0.0-20160823001527-4f7eeb5305a4 - google.golang.org/grpc => google.golang.org/grpc v1.0.1-0.20160819002236-231b4cfea0e7 - gopkg.in/inf.v0 => gopkg.in/inf.v0 v0.9.0 - gopkg.in/natefinch/lumberjack.v2 => gopkg.in/natefinch/lumberjack.v2 v2.0.0-20150622162204-20b71e5b60d7 - gopkg.in/yaml.v2 => gopkg.in/yaml.v2 v2.0.0-20150924142314-53feefa2559f - k8s.io/apimachinery => k8s.io/apimachinery v0.0.0-20170331202828-20e10d54608f - k8s.io/apiserver => k8s.io/apiserver v0.0.0-20170405203548-dcf548fbe26d - k8s.io/client-go => k8s.io/client-go v0.0.0-20170405202815-dabf37f5df16 -) diff --git a/archived/event-adapter/go.sum b/archived/event-adapter/go.sum deleted file mode 100644 index 865597e48..000000000 --- a/archived/event-adapter/go.sum +++ /dev/null @@ -1,136 +0,0 @@ -bitbucket.org/ww/goautoneg v0.0.0-20120707110453-75cd24fc2f2c h1:t+Ra932MCC0eeyD/vigXqMbZTzgZjd4JOfBJWC6VSMI= -bitbucket.org/ww/goautoneg v0.0.0-20120707110453-75cd24fc2f2c/go.mod h1:1vhO7Mn/FZMgOgDVGLy5X1mE6rq1HbkBdkF/yj8zkcg= -cloud.google.com/go v0.7.1-0.20170601220109-d59fc17b56f5 h1:DWs6iLLEdgkp3qZFP1QPRs2djjyL7ICBrjHJfeO3ASI= -cloud.google.com/go v0.7.1-0.20170601220109-d59fc17b56f5/go.mod h1:aQUYkXzVsufM+DwF1aE+0xfcU+56JwCaLick0ClmMTw= -github.com/BurntSushi/toml v0.3.1 h1:WXkYYl6Yr3qBf1K79EBnL4mak0OimBfB0XUf9Vl28OQ= -github.com/BurntSushi/toml v0.3.1/go.mod h1:xHWCNGjB5oqiDr8zfno3MHue2Ht5sIBksp03qcyfWMU= -github.com/PuerkitoBio/purell v1.0.0 h1:0GoNN3taZV6QI81IXgCbxMyEaJDXMSIjArYBCYzVVvs= -github.com/PuerkitoBio/purell v1.0.0/go.mod h1:c11w/QuzBsJSee3cPx9rAFu61PvFxuPbtSwDGJws/X0= -github.com/PuerkitoBio/urlesc v0.0.0-20160726150825-5bd2802263f2 h1:JCHLVE3B+kJde7bIEo5N4J+ZbLhp0J1Fs+ulyRws4gE= -github.com/PuerkitoBio/urlesc v0.0.0-20160726150825-5bd2802263f2/go.mod h1:uGdkoq3SwY9Y+13GIhn11/XLaGBb4BfwItxLd5jeuXE= -github.com/beorn7/perks v0.0.0-20160229213445-3ac7bf7a47d1 h1:OnJHjoVbY69GG4gclp0ngXfywigLhR6rrgUxmxQRWO4= -github.com/beorn7/perks v0.0.0-20160229213445-3ac7bf7a47d1/go.mod h1:Dwedo/Wpr24TaqPxmxbtue+5NUziq4I4S80YR8gNf3Q= -github.com/boltdb/bolt v1.3.1 h1:JQmyP4ZBrce+ZQu0dY660FMfatumYDLun9hBCUVIkF4= -github.com/boltdb/bolt v1.3.1/go.mod h1:clJnj/oiGkjum5o1McbSZDSLxVThjynRyGBgiAx27Ps= -github.com/coreos/etcd v3.0.17+incompatible h1:EgZl12jaaLp5U7afELe3+h2nVcbdQOjqxRDi3sKD0TI= -github.com/coreos/etcd v3.0.17+incompatible/go.mod h1:uF7uidLiAD3TWHmW31ZFd/JWoc32PjwdhPthX9715RE= -github.com/coreos/go-semver v0.3.0 h1:wkHLiw0WNATZnSG7epLsujiMCgPAc9xhjJ4tgnAxmfM= -github.com/coreos/go-semver v0.3.0/go.mod h1:nnelYz7RCh+5ahJtPPxZlU+153eP4D4r3EedlOD2RNk= -github.com/coreos/go-systemd v0.0.0-20161114122254-48702e0da86b h1:+mtZ0WjVZwTX0RVrXMXDwuYVaNeHGvWBW1UwJeMR+2M= -github.com/coreos/go-systemd v0.0.0-20161114122254-48702e0da86b/go.mod h1:F5haX7vjVVG0kc13fIWeqUViNPyEJxv/OmvnBo0Yme4= -github.com/coreos/pkg v0.0.0-20160620232715-fa29b1d70f0b h1:IqgHacj6F3QnV+0H9PXFWAmML5HdxkZakBQgZgfD+FU= -github.com/coreos/pkg v0.0.0-20160620232715-fa29b1d70f0b/go.mod h1:E3G3o1h8I7cfcXa63jLwjI0eiQQMgzzUDFVpN/nH/eA= -github.com/davecgh/go-spew v0.0.0-20151105211317-5215b55f46b2 h1:5zdDAMuB3gvbHB1m2BZT9+t9w+xaBmK3ehb7skDXcwM= -github.com/davecgh/go-spew v0.0.0-20151105211317-5215b55f46b2/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38= -github.com/docker/distribution v2.7.1+incompatible h1:a5mlkVzth6W5A4fOsS3D2EO5BUmsJpcB+cRlLU7cSug= -github.com/docker/distribution v2.7.1+incompatible/go.mod h1:J2gT2udsDAN96Uj4KfcMRqY0/ypR+oyYUYmja8H+y+w= -github.com/elazarl/go-bindata-assetfs v0.0.0-20150624150248-3dcc96556217 h1:y2RUuraT/W7WKNBxj2QDThNkJ+dQpNS9kEk3Y75S3mk= -github.com/elazarl/go-bindata-assetfs v0.0.0-20150624150248-3dcc96556217/go.mod h1:v+YaWX3bdea5J/mo8dSETolEo7R71Vk1u8bnjau5yw4= -github.com/emicklei/go-restful v1.1.4-0.20161212084525-09691a3b6378 h1:06njwgR6pXmS73SB2BRKPCjFO0tVALxlXQUTZD/lzAk= -github.com/emicklei/go-restful v1.1.4-0.20161212084525-09691a3b6378/go.mod h1:otzb+WCGbkyDHkqmQmT5YD2WR4BBwUdeQoFo8l/7tVs= -github.com/evanphx/json-patch v0.0.0-20170123154800-ba18e35c5c1b h1:zkm+xhf4spLwb17f43Sii3RZDl/lXpC3gcnO37/JiR0= -github.com/evanphx/json-patch v0.0.0-20170123154800-ba18e35c5c1b/go.mod h1:50XU6AFN0ol/bzJsmQLiYLvXMP4fmwYFNcr97nuDLSk= -github.com/ghodss/yaml v0.0.0-20150909031657-73d445a93680 h1:ZktWZesgun21uEDrwW7iEV1zPCGQldM2atlJZ3TdvVM= -github.com/ghodss/yaml v0.0.0-20150909031657-73d445a93680/go.mod h1:4dBDuWmgqj2HViK6kFavaiC9ZROes6MMH2rRYeMEF04= -github.com/go-openapi/jsonpointer v0.0.0-20160704185906-46af16f9f7b1 h1:wSt/4CYxs70xbATrGXhokKF1i0tZjENLOo1ioIO13zk= -github.com/go-openapi/jsonpointer v0.0.0-20160704185906-46af16f9f7b1/go.mod h1:+35s3my2LFTysnkMfxsJBAMHj/DoqoB9knIWoYG/Vk0= -github.com/go-openapi/jsonreference v0.0.0-20160704190145-13c6e3589ad9 h1:tF+augKRWlWx0J0B7ZyyKSiTyV6E1zZe+7b3qQlcEf8= -github.com/go-openapi/jsonreference v0.0.0-20160704190145-13c6e3589ad9/go.mod h1:W3Z9FmVs9qj+KR4zFKmDPGiLdk1D9Rlm7cyMvf57TTg= -github.com/go-openapi/spec v0.0.0-20160808142527-6aced65f8501 h1:C1JKChikHGpXwT5UQDFaryIpDtyyGL/CR6C2kB7F1oc= -github.com/go-openapi/spec v0.0.0-20160808142527-6aced65f8501/go.mod h1:J8+jY1nAiCcj+friV/PDoE1/3eeccG9LYBs0tYvLOWc= -github.com/go-openapi/swag v0.0.0-20160704191624-1d0bd113de87 h1:zP3nY8Tk2E6RTkqGYrarZXuzh+ffyLDljLxCy1iJw80= -github.com/go-openapi/swag v0.0.0-20160704191624-1d0bd113de87/go.mod h1:DXUve3Dpr1UfpPtxFw+EFuQ41HhCWZfha5jSVRG7C7I= -github.com/gogo/protobuf v0.0.0-20160718161353-e18d7aa8f8c6 h1:ylB52oUmnSohqzSgB2yZgfZM4Xfe0YQx7yWVsOD8wL8= -github.com/gogo/protobuf v0.0.0-20160718161353-e18d7aa8f8c6/go.mod h1:r8qH/GZQm5c6nD/R0oafs1akxWv10x8SbQlK7atdtwQ= -github.com/golang/glog v0.0.0-20141105023935-44145f04b68c h1:CbdkBQ1/PiAo0FYJhQGwASD8wrgNvTdf01g6+O9tNuA= -github.com/golang/glog v0.0.0-20141105023935-44145f04b68c/go.mod h1:SBH7ygxi8pfUlaOkMMuAQtPIUF8ecWP5IEl/CR7VP2Q= -github.com/golang/groupcache v0.0.0-20160516000752-02826c3e7903 h1:LbsanbbD6LieFkXbj9YNNBupiGHJgFeLpO0j0Fza1h8= -github.com/golang/groupcache v0.0.0-20160516000752-02826c3e7903/go.mod h1:cIg4eruTrX1D+g88fzRXU5OdNfaM+9IcxsU14FzY7Hc= -github.com/golang/protobuf v0.0.0-20160608215545-8616e8ee5e20 h1:JjXLa2agJIe5O/7gydg1V7GI847H1+DTOoFmjKNDE7I= -github.com/golang/protobuf v0.0.0-20160608215545-8616e8ee5e20/go.mod h1:6lQm79b+lXiMfvg/cZm0SGofjICqVBUtrP5yJMmIC1U= -github.com/google/btree v1.0.0 h1:0udJVsspx3VBr5FwtLhQQtuAsVc79tTq0ocGIPAU6qo= -github.com/google/btree v1.0.0/go.mod h1:lNA+9X1NB3Zf8V7Ke586lFgjr2dZNuvo3lPJSGZ5JPQ= -github.com/google/gofuzz v0.0.0-20161122191042-44d81051d367 h1:ScAXWS+TR6MZKex+7Z8rneuSJH+FSDqd6ocQyl+ZHo4= -github.com/google/gofuzz v0.0.0-20161122191042-44d81051d367/go.mod h1:HP5RmnzzSNb993RKQDq4+1A4ia9nllfqcQFTQJedwGI= -github.com/grpc-ecosystem/grpc-gateway v1.0.1-0.20160715013742-f52d055dc48a h1:+zxkhDs0tTLWG4TM/OYSbA1TXVHOOLA3KJUiB0aacWc= -github.com/grpc-ecosystem/grpc-gateway v1.0.1-0.20160715013742-f52d055dc48a/go.mod h1:RSKVYQBd5MCa4OVpNdGskqpgL2+G+NZTnrVHpWWfpdw= -github.com/howeyc/gopass v0.0.0-20160826175423-3ca23474a7c7 h1:LbCYoFXPycb24uJR0m609Jat+Hq0jdrt/jnn9io95Gg= -github.com/howeyc/gopass v0.0.0-20160826175423-3ca23474a7c7/go.mod h1:lADxMC39cJJqL93Duh1xhAs4I2Zs8mKS89XWXFGp9cs= -github.com/imdario/mergo v0.0.0-20141206190957-6633656539c1 h1:FeeCi0I2Fu8kA8IXrdVPtGzym+mW9bzfj9f26EaES9k= -github.com/imdario/mergo v0.0.0-20141206190957-6633656539c1/go.mod h1:2EnlNZ0deacrJVfApfmtdGgDfMuh/nq6Ok1EcJh5FfA= -github.com/inconshreveable/mousetrap v1.0.0 h1:Z8tu5sraLXCXIcARxBp/8cbvlwVa7Z1NHg9XEKhtSvM= -github.com/inconshreveable/mousetrap v1.0.0/go.mod h1:PxqpIevigyE2G7u3NXJIT2ANytuPF1OarO4DADm73n8= -github.com/jonboulle/clockwork v0.1.0 h1:VKV+ZcuP6l3yW9doeqz6ziZGgcynBVQO+obU0+0hcPo= -github.com/jonboulle/clockwork v0.1.0/go.mod h1:Ii8DK3G1RaLaWxj9trq07+26W01tbo22gdxWY5EU2bo= -github.com/juju/ratelimit v0.0.0-20151125201925-77ed1c8a0121 h1:tK7/W+/VbVcqFcQzl3qMnrc/z3h/XOBIrJ9e/cv5hx4= -github.com/juju/ratelimit v0.0.0-20151125201925-77ed1c8a0121/go.mod h1:qapgC/Gy+xNh9UxzV13HGGl/6UXNN+ct+vwSgWNm/qk= -github.com/kr/pty v1.1.1/go.mod h1:pFQYn66WHrOpPYNljwOMqo10TkYh1fy3cYio2l3bCsQ= -github.com/kr/text v0.1.0 h1:45sCR5RtlFHMR4UwH9sdQ5TC8v0qDQCHnXt+kaKSTVE= -github.com/kr/text v0.1.0/go.mod h1:4Jbv+DJW3UT/LiOwJeYQe1efqtUx/iVham/4vfdArNI= -github.com/mailru/easyjson v0.0.0-20160728113105-d5b7844b561a h1:TpvdAwDAt1K4ANVOfcihouRdvP+MgAfDWwBuct4l6ZY= -github.com/mailru/easyjson v0.0.0-20160728113105-d5b7844b561a/go.mod h1:C1wdFJiN94OJF2b5HbByQZoLdCWB1Yqtg26g4irojpc= -github.com/matttproud/golang_protobuf_extensions v0.0.0-20150406173934-fc2b8d3a73c4 h1:NlK6WXPDxjVVwseTuj5NdNJBDabnoJryx4UqB5i/Lk8= -github.com/matttproud/golang_protobuf_extensions v0.0.0-20150406173934-fc2b8d3a73c4/go.mod h1:D8He9yQNgCq6Z5Ld7szi9bcBfOoFv/3dc6xSMkL2PC0= -github.com/natefinch/lumberjack v2.0.0+incompatible h1:4QJd3OLAMgj7ph+yZTuX13Ld4UpgHp07nNdFX7mqFfM= -github.com/natefinch/lumberjack v2.0.0+incompatible/go.mod h1:Wi9p2TTF5DG5oU+6YfsmYQpsTIOm0B1VNzQg9Mw6nPk= -github.com/niemeyer/pretty v0.0.0-20200227124842-a10e7caefd8e h1:fD57ERR4JtEqsWbfPhv4DMiApHyliiK5xCTNVSPiaAs= -github.com/niemeyer/pretty v0.0.0-20200227124842-a10e7caefd8e/go.mod h1:zD1mROLANZcx1PVRCS0qkT7pwLkGfwJo4zjcN/Tysno= -github.com/opencontainers/go-digest v1.0.0-rc1 h1:WzifXhOVOEOuFYOJAW6aQqW0TooG2iki3E3Ii+WN7gQ= -github.com/opencontainers/go-digest v1.0.0-rc1/go.mod h1:cMLVZDEM3+U2I4VmLI6N8jQYUd2OVphdqWwCJHrFt2s= -github.com/pborman/uuid v0.0.0-20150603214016-ca53cad383ca h1:dKRMHfduZ/ZqOHuYGk/0kkTIUbnyorkAfzLOp6Ts8pU= -github.com/pborman/uuid v0.0.0-20150603214016-ca53cad383ca/go.mod h1:VyrYX9gd7irzKovcSS6BIIEwPRkP2Wm2m9ufcdFSJ34= -github.com/pkg/errors v0.7.1-0.20160808055540-a22138067af1 h1:VKwwwPzRs1kuf0sQ55ye3ZV3dybDkw4JfI1Ad1eT73o= -github.com/pkg/errors v0.7.1-0.20160808055540-a22138067af1/go.mod h1:bwawxfHBFNV+L2hUp1rHADufV3IMtnDRdf1r5NINEl0= -github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM= -github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4= -github.com/prometheus/client_golang v0.0.0-20151008143247-e51041b3fa41 h1:Fui6LEXnO23GkKUMSq3bDYhVBWi44gzONQ72EeBWigM= -github.com/prometheus/client_golang v0.0.0-20151008143247-e51041b3fa41/go.mod h1:7SWBe2y4D6OKWSNQJUaRYU/AaXPKyh/dDVn+NZz0KFw= -github.com/prometheus/client_model v0.0.0-20150212101744-fa8ad6fec335 h1:0E/5GnGmzoDCtmzTycjGDWW33H0UBmAhR0h+FC8hWLs= -github.com/prometheus/client_model v0.0.0-20150212101744-fa8ad6fec335/go.mod h1:MbSGuTsp3dbXC40dX6PRTWyKYBIrTGTE9sqQNg2J8bo= -github.com/prometheus/common v0.0.0-20151014055050-ffe929a3f4c4 h1:QiQh0+a3s0Wztb8GI9ByuVKwOowcNA7PXBoOk42dZYE= -github.com/prometheus/common v0.0.0-20151014055050-ffe929a3f4c4/go.mod h1:daVV7qP5qjZbuso7PdcryaAu0sAZbrN9i7WWcTMWvro= -github.com/prometheus/procfs v0.0.0-20150928173926-454a56f35412 h1:3iQrY5Z7SUDniNXBirRXBDkWgZcZ89KuUVh5MsXH4Lw= -github.com/prometheus/procfs v0.0.0-20150928173926-454a56f35412/go.mod h1:c3At6R/oaqEKCNdg8wHV1ftS6bRYblBhIjjI8uT2IGk= -github.com/spf13/cobra v0.0.0-20160722081547-f62e98d28ab7 h1:vX79RLf8hJqzYiv0FVgbIqSD76lK4dTIoIN29Kc4MXo= -github.com/spf13/cobra v0.0.0-20160722081547-f62e98d28ab7/go.mod h1:1l0Ry5zgKvJasoi3XT1TypsSe7PqH0Sj9dhYf7v3XqQ= -github.com/spf13/pflag v0.0.0-20170130214245-9ff6c6923cff h1:VARhShG49tiji6mdRNp7JTNDtJ0FhuprF93GBQ37xGU= -github.com/spf13/pflag v0.0.0-20170130214245-9ff6c6923cff/go.mod h1:DYY7MBk1bdzusC3SYhjObp+wFpr4gzcvqqNjLnInEg4= -github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME= -github.com/stretchr/testify v1.5.1 h1:nOGnQDM7FYENwehXlg/kFVnos3rEvtKTjRvOWSzb6H4= -github.com/stretchr/testify v1.5.1/go.mod h1:5W2xD1RspED5o8YsWQXVCued0rvSQ+mT+I5cxcmMvtA= -github.com/ugorji/go v0.0.0-20170107133203-ded73eae5db7 h1:BPPUhSq7uU6E9lFzyb81vjwVOhiWwMXp0EpKL75NX+8= -github.com/ugorji/go v0.0.0-20170107133203-ded73eae5db7/go.mod h1:hnLbHMwcvSihnDhEfx2/BzKp2xb0Y+ErdfYcrs9tkJQ= -github.com/xiang90/probing v0.0.0-20190116061207-43a291ad63a2 h1:eY9dn8+vbi4tKz5Qo6v2eYzo7kUS51QINcR5jNpbZS8= -github.com/xiang90/probing v0.0.0-20190116061207-43a291ad63a2/go.mod h1:UETIi67q53MR2AWcXfiuqkDkRtnGDLqkBTpCHuJHxtU= -golang.org/x/crypto v0.0.0-20161006174701-d172538b2cfc h1:DfGUWE6VaxsoTkTHNGspjXfDCOroOPdvTIuiYeYpC4o= -golang.org/x/crypto v0.0.0-20161006174701-d172538b2cfc/go.mod h1:6SG95UA2DQfeDnfUPMdvaQW0Q7yPrPDi9nlGo2tz2b4= -golang.org/x/net v0.0.0-20160715184138-e90d6d0afc4c h1:2EAV7IIzPaLTYW+2nvyaXEO2U/6Jg6iMqR7gZ0v0i34= -golang.org/x/net v0.0.0-20160715184138-e90d6d0afc4c/go.mod h1:mL1N/T3taQHkDXs73rZJwtUhF3w3ftmwwsq0BUmARs4= -golang.org/x/oauth2 v0.0.0-20160902055913-3c3a985cb79f h1:VWt05OS3Al9w09GSPgltoHP90whAHlpik/Bys7HVEDE= -golang.org/x/oauth2 v0.0.0-20160902055913-3c3a985cb79f/go.mod h1:N/0e6XlmueqKjAGxoOufVs8QHGRruUQn6yWY3a++T0U= -golang.org/x/sys v0.0.0-20160916181909-8f0908ab3b24 h1:BL/wcoHkjubwHn2wDTAD1fehKZ9lf67KOVzucRKWPtM= -golang.org/x/sys v0.0.0-20160916181909-8f0908ab3b24/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY= -golang.org/x/text v0.0.0-20160726164857-2910a502d2bf h1:a1mkutIuyEAoG1fn3Z8Ep7h+O57k45esCFDOqht8HF8= -golang.org/x/text v0.0.0-20160726164857-2910a502d2bf/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ= -google.golang.org/api v0.0.0-20170508220804-e3824ed33c72 h1:nmNkFC1PmKi0e3OMLzDcOjqcVsRov5XtjdZLakSN1nk= -google.golang.org/api v0.0.0-20170508220804-e3824ed33c72/go.mod h1:4mhQ8q/RsB7i+udVvVy5NUi08OU8ZlA0gRVgrF7VFY0= -google.golang.org/appengine v0.0.0-20160823001527-4f7eeb5305a4 h1:WsXqDh29vwFPO3bhLP8QUL8uCcYISVMAMqbzqwaP8L0= -google.golang.org/appengine v0.0.0-20160823001527-4f7eeb5305a4/go.mod h1:EbEs0AVv82hx2wNQdGPgUI5lhzA/G0D9YwlJXL52JkM= -google.golang.org/grpc v1.0.1-0.20160819002236-231b4cfea0e7 h1:VtoFDiq5KoIVeqTtwmDDjZsYXsocrlaGiQxukZnYDJ4= -google.golang.org/grpc v1.0.1-0.20160819002236-231b4cfea0e7/go.mod h1:yo6s7OP7yaDglbqo1J04qKzAhqBH6lvTonzMVmEdcZw= -gopkg.in/check.v1 v1.0.0-20200227125254-8fa46927fb4f h1:BLraFXnmrev5lT+xlilqcH8XK9/i0At2xKjWk4p6zsU= -gopkg.in/check.v1 v1.0.0-20200227125254-8fa46927fb4f/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0= -gopkg.in/inf.v0 v0.9.0 h1:3zYtXIO92bvsdS3ggAdA8Gb4Azj0YU+TVY1uGYNFA8o= -gopkg.in/inf.v0 v0.9.0/go.mod h1:cWUDdTG/fYaXco+Dcufb5Vnc6Gp2YChqWtbxRZE0mXw= -gopkg.in/natefinch/lumberjack.v2 v2.0.0-20150622162204-20b71e5b60d7 h1:986b60BAz5vO2Vaf48yQaq+wb2bU4JsXxKu1+itW6x8= -gopkg.in/natefinch/lumberjack.v2 v2.0.0-20150622162204-20b71e5b60d7/go.mod h1:l0ndWWf7gzL7RNwBG7wST/UCcT4T24xpD6X8LsfU/+k= -gopkg.in/yaml.v1 v1.0.0-20140924161607-9f9df34309c0 h1:POO/ycCATvegFmVuPpQzZFJ+pGZeX22Ufu6fibxDVjU= -gopkg.in/yaml.v1 v1.0.0-20140924161607-9f9df34309c0/go.mod h1:WDnlLJ4WF5VGsH/HVa3CI79GS0ol3YnhVnKP89i0kNg= -gopkg.in/yaml.v2 v2.0.0-20150924142314-53feefa2559f h1:sOheF02XWNGQor9t3gRZtN/HlgP6sv3NozSahoTEmiM= -gopkg.in/yaml.v2 v2.0.0-20150924142314-53feefa2559f/go.mod h1:JAlM8MvJe8wmxCU4Bli9HhUf9+ttbYbLASfIpnQbh74= -k8s.io/apimachinery v0.0.0-20170331202828-20e10d54608f h1:7+qRKBz8AY+hNYKd1GSu9GAaUn9xANodV+eU/xX967c= -k8s.io/apimachinery v0.0.0-20170331202828-20e10d54608f/go.mod h1:ccL7Eh7zubPUSh9A3USN90/OzHNSVN6zxzde07TDCL0= -k8s.io/apiserver v0.0.0-20170405203548-dcf548fbe26d h1:XP4TAVUL3T/tgabod5IhtdKw9+c4EA0ohcJRrcJ8Wac= -k8s.io/apiserver v0.0.0-20170405203548-dcf548fbe26d/go.mod h1:6bqaTSOSJavUIXUtfaR9Os9JtTCm8ZqH2SUl2S60C4w= -k8s.io/client-go v0.0.0-20170405202815-dabf37f5df16 h1:8wXro0xibfQm325zppHuzBYb70JwU2en+SWh63Yriqw= -k8s.io/client-go v0.0.0-20170405202815-dabf37f5df16/go.mod h1:7vJpHMYJwNQCWgzmNV+VYUl1zCObLyodBc8nIyt8L5s= diff --git a/archived/event-adapter/pkg/apiserver/apiserver.go b/archived/event-adapter/pkg/apiserver/apiserver.go deleted file mode 100644 index ef71c28d7..000000000 --- a/archived/event-adapter/pkg/apiserver/apiserver.go +++ /dev/null @@ -1,108 +0,0 @@ -/* -Copyright 2017 The Kubernetes Authors. - -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. -*/ - -package apiserver - -import ( - "github.com/GoogleCloudPlatform/k8s-stackdriver/event-adapter/pkg/provider" - "github.com/GoogleCloudPlatform/k8s-stackdriver/event-adapter/pkg/types" - "k8s.io/apimachinery/pkg/apimachinery/announced" - "k8s.io/apimachinery/pkg/apimachinery/registered" - metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" - "k8s.io/apimachinery/pkg/runtime" - "k8s.io/apimachinery/pkg/runtime/schema" - "k8s.io/apimachinery/pkg/runtime/serializer" - "k8s.io/apimachinery/pkg/version" - genericapiserver "k8s.io/apiserver/pkg/server" -) - -var ( - groupFactoryRegistry = make(announced.APIGroupFactoryRegistry) - registry = registered.NewOrDie("") - // Scheme is a new scheme - Scheme = runtime.NewScheme() - // Codecs is a new CodecFactory - Codecs = serializer.NewCodecFactory(Scheme) -) - -func init() { - types.Install(groupFactoryRegistry, registry, Scheme) - - // we need to add the options to empty v1 - // TODO fix the server code to avoid this - metav1.AddToGroupVersion(Scheme, schema.GroupVersion{Version: "v1"}) - - // TODO: keep the generic API server from wanting this - unversioned := schema.GroupVersion{Group: "", Version: "v1"} - Scheme.AddUnversionedTypes(unversioned, - &metav1.Status{}, - &metav1.APIVersions{}, - &metav1.APIGroupList{}, - &metav1.APIGroup{}, - &metav1.APIResourceList{}, - ) -} - -// Config contains a configuration for the api server -type Config struct { - GenericConfig *genericapiserver.Config -} - -// EventsAdapterServer contains state for a Kubernetes cluster master/api server. -type EventsAdapterServer struct { - GenericAPIServer *genericapiserver.GenericAPIServer - Provider provider.EventsProvider -} - -type completedConfig struct { - *Config -} - -// Complete fills in any fields not set that are required to have valid data. It's mutating the receiver. -func (c *Config) Complete() completedConfig { - c.GenericConfig.Complete() - - c.GenericConfig.Version = &version.Info{ - Major: "1", - Minor: "0", - } - - return completedConfig{c} -} - -// SkipComplete provides a way to construct a server instance without config completion. -func (c *Config) SkipComplete() completedConfig { - return completedConfig{c} -} - -// New returns a new instance of EventsAdapterServer from the given config. -func (c completedConfig) New(evProvider provider.EventsProvider) (*EventsAdapterServer, error) { - genericServer, err := c.Config.GenericConfig.SkipComplete().New() // completion is done in Complete, no need for a second time - if err != nil { - return nil, err - } - - s := &EventsAdapterServer{ - GenericAPIServer: genericServer, - Provider: evProvider, - } - - if err := s.InstallEventsAPI(); err != nil { - return nil, err - } - - return s, nil -} diff --git a/archived/event-adapter/pkg/apiserver/cmapis.go b/archived/event-adapter/pkg/apiserver/cmapis.go deleted file mode 100644 index 6359faafe..000000000 --- a/archived/event-adapter/pkg/apiserver/cmapis.go +++ /dev/null @@ -1,88 +0,0 @@ -/* -Copyright 2017 The Kubernetes Authors. - -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. -*/ - -package apiserver - -import ( - specificapi "github.com/GoogleCloudPlatform/k8s-stackdriver/event-adapter/pkg/apiserver/installer" - "github.com/GoogleCloudPlatform/k8s-stackdriver/event-adapter/pkg/provider" - storage "github.com/GoogleCloudPlatform/k8s-stackdriver/event-adapter/pkg/registry" - "k8s.io/apimachinery/pkg/apimachinery" - metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" - "k8s.io/apimachinery/pkg/runtime" - "k8s.io/apimachinery/pkg/runtime/schema" - genericapi "k8s.io/apiserver/pkg/endpoints" - genericapiserver "k8s.io/apiserver/pkg/server" -) - -// InstallEventsAPI registers the api server in Kube Aggregator -func (s *EventsAdapterServer) InstallEventsAPI() error { - - groupMeta := registry.GroupOrDie("v1events") - - preferredVersionForDiscovery := metav1.GroupVersionForDiscovery{ - GroupVersion: groupMeta.GroupVersion.String(), - Version: groupMeta.GroupVersion.Version, - } - groupVersion := metav1.GroupVersionForDiscovery{ - GroupVersion: groupMeta.GroupVersion.String(), - Version: groupMeta.GroupVersion.Version, - } - apiGroup := metav1.APIGroup{ - Name: groupMeta.GroupVersion.String(), - Versions: []metav1.GroupVersionForDiscovery{groupVersion}, - PreferredVersion: preferredVersionForDiscovery, - } - - evAPI := s.evAPI(groupMeta, &groupMeta.GroupVersion) - - if err := evAPI.InstallREST(s.GenericAPIServer.HandlerContainer.Container); err != nil { - return err - } - - path := genericapiserver.APIGroupPrefix + "/" + groupMeta.GroupVersion.Group - s.GenericAPIServer.HandlerContainer.Add(genericapi.NewGroupWebService(s.GenericAPIServer.Serializer, path, apiGroup)) - - return nil -} - -func (s *EventsAdapterServer) evAPI(groupMeta *apimachinery.GroupMeta, groupVersion *schema.GroupVersion) *specificapi.EventsAPIGroupVersion { - resourceStorage := storage.NewREST(s.Provider) - - return &specificapi.EventsAPIGroupVersion{ - DynamicStorage: resourceStorage, - APIGroupVersion: &genericapi.APIGroupVersion{ - Root: genericapiserver.APIGroupPrefix, - GroupVersion: *groupVersion, - - ParameterCodec: metav1.ParameterCodec, - Serializer: Codecs, - Creater: Scheme, - Convertor: Scheme, - UnsafeConvertor: runtime.UnsafeObjectConvertor(Scheme), - Copier: Scheme, - Typer: Scheme, - Linker: groupMeta.SelfLinker, - Mapper: groupMeta.RESTMapper, - - Context: s.GenericAPIServer.RequestContextMapper(), - MinRequestTimeout: s.GenericAPIServer.MinRequestTimeout(), - OptionsExternalVersion: &schema.GroupVersion{Version: "v1"}, - - ResourceLister: provider.NewResourceLister(s.Provider), - }, - } -} diff --git a/archived/event-adapter/pkg/apiserver/installer/apiserver_test.go b/archived/event-adapter/pkg/apiserver/installer/apiserver_test.go deleted file mode 100644 index fe97a2c47..000000000 --- a/archived/event-adapter/pkg/apiserver/installer/apiserver_test.go +++ /dev/null @@ -1,240 +0,0 @@ -/* -Copyright 2017 The Kubernetes Authors. - -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. -*/ - -package installer - -import ( - "fmt" - "github.com/emicklei/go-restful" - "io/ioutil" - "net/http" - "net/http/httptest" - "testing" - - "k8s.io/apimachinery/pkg/apimachinery" - "k8s.io/apimachinery/pkg/apimachinery/announced" - "k8s.io/apimachinery/pkg/apimachinery/registered" - metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" - "k8s.io/apimachinery/pkg/runtime" - "k8s.io/apimachinery/pkg/runtime/schema" - "k8s.io/apimachinery/pkg/runtime/serializer" - genericapi "k8s.io/apiserver/pkg/endpoints" - "k8s.io/apiserver/pkg/endpoints/request" - genericapiserver "k8s.io/apiserver/pkg/server" - - "github.com/GoogleCloudPlatform/k8s-stackdriver/event-adapter/pkg/provider" - restorage "github.com/GoogleCloudPlatform/k8s-stackdriver/event-adapter/pkg/registry" - "github.com/GoogleCloudPlatform/k8s-stackdriver/event-adapter/pkg/types" - api "k8s.io/client-go/pkg/api/v1" -) - -// defaultAPIServer exposes nested objects for testability. -type defaultAPIServer struct { - http.Handler - container *restful.Container -} - -type NotFoundError struct { - event string - namespace string -} - -func (e NotFoundError) Error() string { - return fmt.Sprintf("Event %s not found in namespace %s", e.event, e.namespace) -} - -func (e NotFoundError) Status() metav1.Status { - return metav1.Status{ - Code: 404, - } -} - -var ( - groupFactoryRegistry = make(announced.APIGroupFactoryRegistry) - registry = registered.NewOrDie("") - Scheme = runtime.NewScheme() - Codecs = serializer.NewCodecFactory(Scheme) - prefix = genericapiserver.APIGroupPrefix - groupVersion schema.GroupVersion - groupMeta *apimachinery.GroupMeta -) - -func init() { - types.Install(groupFactoryRegistry, registry, Scheme) - - // we need to add the options to empty v1 - // TODO fix the server code to avoid this - metav1.AddToGroupVersion(Scheme, schema.GroupVersion{Version: "v1"}) - - // TODO: keep the generic API server from wanting this - unversioned := schema.GroupVersion{Group: "", Version: "v1"} - Scheme.AddUnversionedTypes(unversioned, - &metav1.Status{}, - &metav1.APIVersions{}, - &metav1.APIGroupList{}, - &metav1.APIGroup{}, - &metav1.APIResourceList{}, - ) - - groupMeta = registry.GroupOrDie(types.GroupName) - groupVersion = groupMeta.GroupVersion -} - -func extractBodyString(response *http.Response) (string, error) { - defer response.Body.Close() - body, err := ioutil.ReadAll(response.Body) - if err != nil { - return "", err - } - return string(body), err -} -func handle(prov provider.EventsProvider) http.Handler { - container := restful.NewContainer() - container.Router(restful.CurlyRouter{}) - mux := container.ServeMux - resourceStorage := restorage.NewREST(prov) - group := EventsAPIGroupVersion{ - DynamicStorage: resourceStorage, - APIGroupVersion: &genericapi.APIGroupVersion{ - Root: prefix, - GroupVersion: groupVersion, - - ParameterCodec: metav1.ParameterCodec, - Serializer: Codecs, - Creater: Scheme, - Convertor: Scheme, - UnsafeConvertor: runtime.UnsafeObjectConvertor(Scheme), - Copier: Scheme, - Typer: Scheme, - Linker: groupMeta.SelfLinker, - Mapper: groupMeta.RESTMapper, - - Context: request.NewRequestContextMapper(), - OptionsExternalVersion: &schema.GroupVersion{Version: "v1"}, - - ResourceLister: provider.NewResourceLister(prov), - }, - } - if err := group.InstallREST(container); err != nil { - panic(fmt.Sprintf("unable to install container %s: %v", group.GroupVersion, err)) - } - return &defaultAPIServer{mux, container} -} - -type fakeProvider struct{} - -func (p *fakeProvider) GetNamespacedEventsByName(namespace, name string) (*api.Event, error) { - if namespace == "default" && name == "existing_event" { - return &api.Event{}, nil - } - - err := NotFoundError{ - event: name, - namespace: namespace, - } - - if namespace == "default" && name == "not_existing_event" { - return nil, err - } - - if namespace == "foo" && name == "foo" { - return nil, err - } - - return nil, fmt.Errorf("Namespace : %s, event name: %s", namespace, name) -} - -func (p *fakeProvider) ListAllEventsByNamespace(namespace string) (*api.EventList, error) { - return &api.EventList{}, nil -} - -func (p *fakeProvider) ListAllEvents() (*api.EventList, error) { - return &api.EventList{}, nil -} - -func (p *fakeProvider) CreateNewEvent(namespace string) (*api.Event, error) { - return &api.Event{}, nil -} - -func TestEventsAPI(t *testing.T) { - type T struct { - Method string - Path string - Status int - } - - group := "v1events/v1alpha1" - cases := map[string]T{ - "GET list of events ": {"GET", prefix + "/" + group + "/namespaces/foo/events", http.StatusOK}, - "GET list of events wrong path": {"GET", prefix + "/" + group + "/namespaces/default/foo", http.StatusNotFound}, - - "GET event by name": {"GET", prefix + "/" + group + "/namespaces/default/events/existing_event", http.StatusOK}, - "GET not existing event by name": {"GET", prefix + "/" + group + "/namespaces/default/events/not_existing_event", http.StatusNotFound}, - "GET not existing event and namespace": {"GET", prefix + "/" + group + "/namespaces/foo/events/foo", http.StatusNotFound}, - "GET event by name wrong path": {"GET", prefix + "/" + group + "/namespaces/default/eve/foo", http.StatusNotFound}, - - "GET event with too long path": {"GET", prefix + "/" + group + "/namespaces/default/events/foo/foo", http.StatusNotFound}, - "GET event only with namespace": {"GET", prefix + "/" + group + "/namespaces/default", http.StatusNotFound}, - - "GET event with any namespaces": {"GET", prefix + "/" + group + "/events/foo", http.StatusNotFound}, - - "GET no namespace": {"GET", prefix + "/" + group + "/foo/default/events/foo", http.StatusNotFound}, - "GET wrong prefix": {"GET", "//apis/v1foo/v1alpha1/", http.StatusNotFound}, - - "GET list all events": {"GET", prefix + "/" + group + "/events", http.StatusOK}, - "GET list all events with typo": {"GET", prefix + "/" + group + "/foo", http.StatusNotFound}, - - "POST create a new event": {"POST", prefix + "/" + group + "/namespaces/default/events", http.StatusOK}, - "POST create a new event without namespace": {"POST", prefix + "/" + group + "/events", http.StatusMethodNotAllowed}, - "POST create a new event giving name": {"POST", prefix + "/" + group + "/namespaces/default/events/foo", http.StatusMethodNotAllowed}, - "POST prefix": {"POST", prefix + "/" + group, http.StatusMethodNotAllowed}, - - "POST no namespace": {"POST", prefix + "/" + group + "/foo/default/events", http.StatusNotFound}, - "POST no events": {"POST", prefix + "/" + group + "/namespaces/default/foo", http.StatusNotFound}, - "POST wrong prefix": {"POST", "//apis/v1foo/v1alpha1/", http.StatusNotFound}, - } - - prov := &fakeProvider{} - server := httptest.NewServer(handle(prov)) - defer server.Close() - client := http.Client{} - - for k, v := range cases { - - request, err := http.NewRequest(v.Method, server.URL+v.Path, nil) - - if err != nil { - t.Fatalf("unexpected error (%s): %v", k, err) - } - - response, err := client.Do(request) - if err != nil { - t.Errorf("unexpected error (%s): %v", k, err) - continue - } - - if response.StatusCode != v.Status { - body, err := extractBodyString(response) - bodyPart := body - if err != nil { - bodyPart = fmt.Sprintf("[error extracting body: %v]", err) - } - t.Errorf("request: %v", request) - t.Errorf("Expected %d for %s (%s), Got %#v -- %s", v.Status, v.Method, k, response, bodyPart) - } - } - -} diff --git a/archived/event-adapter/pkg/apiserver/installer/context/context.go b/archived/event-adapter/pkg/apiserver/installer/context/context.go deleted file mode 100644 index c3b8b5e5b..000000000 --- a/archived/event-adapter/pkg/apiserver/installer/context/context.go +++ /dev/null @@ -1,65 +0,0 @@ -/* -Copyright 2017 The Kubernetes Authors. - -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. -*/ - -package context - -import ( - "k8s.io/apiserver/pkg/endpoints/request" -) - -// requestInformation holds the resource and method for a request in the context. -type requestInformation struct { - resource string - method string -} - -type requestListInformation struct { - method string -} - -// contextKey is the type of the keys for the context in this file. -// It's private to avoid conflicts across packages. -type contextKey int - -const resourceKey contextKey = iota - -// WithRequestInformation returns a copy of parent in which the resource and method values are set -func WithRequestInformation(parent request.Context, resource, method string) request.Context { - return request.WithValue(parent, resourceKey, requestInformation{resource, method}) -} - -// WithRequestListInformation returns a copy of parent in which the method values is set -func WithRequestListInformation(parent request.Context, method string) request.Context { - return request.WithValue(parent, resourceKey, requestListInformation{method}) -} - -// RequestInformationFrom returns resource and method on the ctx -func RequestInformationFrom(ctx request.Context) (resource string, method string, ok bool) { - requestInfo, ok := ctx.Value(resourceKey).(requestInformation) - if !ok { - return "", "", ok - } - return requestInfo.resource, requestInfo.method, ok -} - -// RequestListInformationFrom returns method on the ctx -func RequestListInformationFrom(ctx request.Context) (method string, ok bool) { - requestInfo, ok := ctx.Value(resourceKey).(requestListInformation) - if !ok { - return "", ok - } - return requestInfo.method, ok -} diff --git a/archived/event-adapter/pkg/apiserver/installer/installer.go b/archived/event-adapter/pkg/apiserver/installer/installer.go deleted file mode 100644 index 8da10d4d0..000000000 --- a/archived/event-adapter/pkg/apiserver/installer/installer.go +++ /dev/null @@ -1,622 +0,0 @@ -/* -Copyright 2017 The Kubernetes Authors. - -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. -*/ - -package installer - -import ( - "bytes" - "fmt" - "net/http" - "net/url" - gpath "path" - "reflect" - "strings" - "time" - - restful "github.com/emicklei/go-restful" - "k8s.io/apimachinery/pkg/api/errors" - "k8s.io/apimachinery/pkg/api/meta" - metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" - "k8s.io/apimachinery/pkg/conversion" - "k8s.io/apimachinery/pkg/runtime" - "k8s.io/apimachinery/pkg/runtime/schema" - utilerrors "k8s.io/apimachinery/pkg/util/errors" - "k8s.io/apiserver/pkg/endpoints" - "k8s.io/apiserver/pkg/endpoints/handlers" - "k8s.io/apiserver/pkg/endpoints/handlers/negotiation" - "k8s.io/apiserver/pkg/endpoints/request" - "k8s.io/apiserver/pkg/registry/rest" - - specificcontext "github.com/GoogleCloudPlatform/k8s-stackdriver/event-adapter/pkg/apiserver/installer/context" -) - -// NB: the contents of this file should mostly be a subset of the functionality -// in "k8s.io/apiserver/pkg/endpoints". It would be nice to eventual figure out -// a way to not have to recreate/copy a bunch of the structure from the normal API -// installer, so that this trivially tracks changes to the main installer. - -// EventsAPIGroupVersion is similar to "k8s.io/apiserver/pkg/endpoints".APIGroupVersion, -// except that it installs the metrics REST handlers, which use wildcard resources -// and subresources. -// -// This basically only serves the limitted use case required by the metrics API server -- -// the only verb accepted is GET (and perhaps WATCH in the future). -type EventsAPIGroupVersion struct { - DynamicStorage rest.Storage - - *endpoints.APIGroupVersion -} - -// InstallREST registers the dynamic REST handlers into a restful Container. -// It is expected that the provided path root prefix will serve all operations. Root MUST -// NOT end in a slash. It should mirror InstallREST in the plain APIGroupVersion. -func (g *EventsAPIGroupVersion) InstallREST(container *restful.Container) error { - installer := g.newDynamicInstaller() - ws := installer.NewWebService() - - registrationErrors := installer.Install(ws) - lister := g.ResourceLister - if lister == nil { - return fmt.Errorf("must provide a dynamic lister for dynamic API groups") - } - endpoints.AddSupportedResourcesWebService(g.Serializer, ws, g.GroupVersion, lister) - container.Add(ws) - return utilerrors.NewAggregate(registrationErrors) -} - -// newDynamicInstaller is a helper to create the installer. It mirrors -// newInstaller in APIGroupVersion. -func (g *EventsAPIGroupVersion) newDynamicInstaller() *EventsAPIInstaller { - prefix := gpath.Join(g.Root, g.GroupVersion.Group, g.GroupVersion.Version) - installer := &EventsAPIInstaller{ - group: g, - prefix: prefix, - minRequestTimeout: g.MinRequestTimeout, - } - - return installer -} - -// EventsAPIInstaller is a specialized API installer for the metrics API. -// It is intended to be fully compliant with the Kubernetes API server conventions, -// but serves wildcard resource/subresource routes instead of hard-coded resources -// and subresources. -type EventsAPIInstaller struct { - group *EventsAPIGroupVersion - prefix string // Path prefix where API resources are to be registered. - minRequestTimeout time.Duration - - // TODO: do we want to embed a normal API installer here so we can serve normal - // endpoints side by side with dynamic ones (from the same API group)? -} - -// Install installs handlers for API resources. -func (a *EventsAPIInstaller) Install(ws *restful.WebService) (errors []error) { - errors = make([]error, 0) - - err := a.registerResourceHandlers(a.group.DynamicStorage, ws) - if err != nil { - errors = append(errors, fmt.Errorf("error in registering the resource: %v", err)) - } - - return errors -} - -// NewWebService creates a new restful webservice with the api installer's prefix and version. -func (a *EventsAPIInstaller) NewWebService() *restful.WebService { - ws := new(restful.WebService) - ws.Path(a.prefix) - // a.prefix contains "prefix/group/version" - ws.Doc("API at " + a.prefix) - // Backwards compatibility, we accepted objects with empty content-type at V1. - // If we stop using go-restful, we can default empty content-type to application/json on an - // endpoint by endpoint basis - ws.Consumes("*/*") - mediaTypes, streamMediaTypes := negotiation.MediaTypesForSerializer(a.group.Serializer) - ws.Produces(append(mediaTypes, streamMediaTypes...)...) - ws.ApiVersion(a.group.GroupVersion.String()) - - return ws -} - -// registerResourceHandlers registers the resource handlers for events. -// Compared to the normal installer, this plays fast and loose a bit, but should still -// follow the API conventions. -func (a *EventsAPIInstaller) registerResourceHandlers(storage rest.Storage, ws *restful.WebService) error { - context := a.group.Context - - optionsExternalVersion := a.group.GroupVersion - if a.group.OptionsExternalVersion != nil { - optionsExternalVersion = *a.group.OptionsExternalVersion - } - - mapping, err := a.restMapping() - if err != nil { - return err - } - - fqKindToRegister, err := a.getResourceKind(storage) - if err != nil { - return err - } - - kind := fqKindToRegister.Kind - - lister := storage.(rest.Lister) - list := lister.NewList() - listGVKs, _, err := a.group.Typer.ObjectKinds(list) - if err != nil { - return err - } - versionedListPtr, err := a.group.Creater.New(a.group.GroupVersion.WithKind(listGVKs[0].Kind)) - if err != nil { - return err - } - versionedList := indirectArbitraryPointer(versionedListPtr) - - versionedListOptions, err := a.group.Creater.New(optionsExternalVersion.WithKind("ListOptions")) - if err != nil { - return err - } - - scope := mapping.Scope - nameParam := ws.PathParameter("name", "name of the described event").DataType("string") - namespaceParam := ws.PathParameter(scope.ArgumentName(), scope.ParamDescription()).DataType("string") - - namespacedParams := []*restful.Parameter{ - nameParam, - namespaceParam, - } - - // REGISTER: BY NAME & NAMESPACE - namespacedPath := scope.ParamName() + "/{" + scope.ArgumentName() + "}/events/{name}" - mediaTypes, streamMediaTypes := negotiation.MediaTypesForSerializer(a.group.Serializer) - allMediaTypes := append(mediaTypes, streamMediaTypes...) - ws.Produces(allMediaTypes...) - reqScope := handlers.RequestScope{ - Serializer: a.group.Serializer, - ParameterCodec: a.group.ParameterCodec, - Creater: a.group.Creater, - Convertor: a.group.Convertor, - Copier: a.group.Copier, - Typer: a.group.Typer, - UnsafeConvertor: a.group.UnsafeConvertor, - // TODO: This seems wrong for cross-group subresources. It makes an assumption that a subresource and its parent are in the same group version. Revisit this. - Resource: a.group.GroupVersion.WithResource("*"), - Subresource: "*", - Kind: fqKindToRegister, - MetaGroupVersion: metav1.SchemeGroupVersion, - } - itemPathPrefix := gpath.Join(a.prefix, scope.ParamName()) + "/" - itemPathMiddle := "/events/" - itemPathFn := func(name, namespace string) bytes.Buffer { - var buf bytes.Buffer - buf.WriteString(itemPathPrefix) - buf.WriteString(url.QueryEscape(name)) - buf.WriteString(itemPathMiddle) - buf.WriteString(url.QueryEscape(namespace)) - return buf - } - ctxFn := func(req *restful.Request) request.Context { - var ctx request.Context - if ctx != nil { - if existingCtx, ok := context.Get(req.Request); ok { - ctx = existingCtx - } - } - if ctx == nil { - ctx = request.NewContext() - } - ctx = request.WithUserAgent(ctx, req.HeaderParameter("User-Agent")) - name := req.PathParameter("name") - ctx = specificcontext.WithRequestInformation(ctx, name, "GET") - return ctx - } - reqScope.ContextFunc = ctxFn - if a.group.MetaGroupVersion != nil { - reqScope.MetaGroupVersion = *a.group.MetaGroupVersion - } - // install the namespace-scoped route - reqScope.Namer = scopeNaming{scope, a.group.Linker, itemPathFn, false} - namespacedHandler := handlers.ListResource(lister, nil, reqScope, false, a.minRequestTimeout) - doc := "get event with the given name and namespace" - namespacedRoute := ws.GET(namespacedPath).To(namespacedHandler). - Doc(doc). - Param(ws.QueryParameter("pretty", "If 'true', then the output is pretty printed.")). - Operation("listNamespaced"+kind). - Produces(allMediaTypes...). - Returns(http.StatusOK, "OK", versionedList). - Writes(versionedList) - if err := addObjectParams(ws, namespacedRoute, versionedListOptions); err != nil { - return err - } - addParams(namespacedRoute, namespacedParams) - ws.Route(namespacedRoute) - - //PATH namespaces/{namespace}/events/{eventName} - namespacedListPath := scope.ParamName() + "/{" + scope.ArgumentName() + "}/events" - namespacedListParams := []*restful.Parameter{ - namespaceParam, - } - docList := map[string]string{ - "GET": "list events with the given namespace", - "POST": "create an event with the given namepsace", - } - itemPathListPrefix := gpath.Join(a.prefix, scope.ParamName()) + "/" - itemPathListMiddle := "/events" - itemPathListFn := func(name, namespace string) bytes.Buffer { - var buf bytes.Buffer - buf.WriteString(itemPathListPrefix) - buf.WriteString(url.QueryEscape(namespace)) - buf.WriteString(itemPathListMiddle) - return buf - } - methods := map[string]func(ws *restful.WebService, path string) *restful.RouteBuilder{ - "GET": func(ws *restful.WebService, path string) *restful.RouteBuilder { - return ws.GET(path) - }, - "POST": func(ws *restful.WebService, path string) *restful.RouteBuilder { - return ws.POST(path) - }, - } - for k, v := range methods { - method := k - namespacedCtxFn := func(req *restful.Request) request.Context { - var ctx request.Context - if ctx != nil { - if existingCtx, ok := context.Get(req.Request); ok { - ctx = existingCtx - } - } - if ctx == nil { - ctx = request.NewContext() - } - - ctx = request.WithUserAgent(ctx, req.HeaderParameter("User-Agent")) - ctx = specificcontext.WithRequestListInformation(ctx, method) - return ctx - } - reqScope.ContextFunc = namespacedCtxFn - reqScope.Namer = scopeNaming{scope, a.group.Linker, itemPathListFn, false} - namespacedHandler := handlers.ListResource(lister, nil, reqScope, false, a.minRequestTimeout) - routeBuilder := v(ws, namespacedListPath) - namespacedRoute := routeBuilder.To(namespacedHandler). - Doc(docList[method]). - Param(ws.QueryParameter("pretty", "If 'true', then the output is pretty printed.")). - Produces(allMediaTypes...). - Returns(http.StatusOK, "OK", versionedList). - Writes(versionedList) - if err := addObjectParams(ws, namespacedRoute, versionedListOptions); err != nil { - return err - } - addParams(namespacedRoute, namespacedListParams) - ws.Route(namespacedRoute) - } - - //LIST ALL EVENTS - eventsListPath := "events" - ctxFnList := func(req *restful.Request) request.Context { - var ctx request.Context - if ctx != nil { - if existingCtx, ok := context.Get(req.Request); ok { - ctx = existingCtx - } - } - if ctx == nil { - ctx = request.NewContext() - } - ctx = request.WithUserAgent(ctx, req.HeaderParameter("User-Agent")) - ctx = specificcontext.WithRequestListInformation(ctx, "GET") - return ctx - } - reqScope.ContextFunc = ctxFnList - reqScope.Namer = rootScopeNaming{scope, a.group.Linker, a.prefix, eventsListPath} - rootScopedHandler := handlers.ListResource(lister, nil, reqScope, false, a.minRequestTimeout) - doc = "list all the events" - rootScopedRoute := ws.GET(eventsListPath).To(rootScopedHandler). - Doc(doc). - Param(ws.QueryParameter("pretty", "If 'true', then the output is pretty printed.")). - Operation("listNamespaced"+kind). - Produces(allMediaTypes...). - Returns(http.StatusOK, "OK", versionedList). - Writes(versionedList) - if err := addObjectParams(ws, rootScopedRoute, versionedListOptions); err != nil { - return err - } - ws.Route(rootScopedRoute) - - return nil -} - -// This magic incantation returns *ptrToObject for an arbitrary pointer -func indirectArbitraryPointer(ptrToObject interface{}) interface{} { - return reflect.Indirect(reflect.ValueOf(ptrToObject)).Interface() -} - -// getResourceKind returns the external group version kind registered for the given storage object. -func (a *EventsAPIInstaller) getResourceKind(storage rest.Storage) (schema.GroupVersionKind, error) { - object := storage.New() - fqKinds, _, err := a.group.Typer.ObjectKinds(object) - if err != nil { - return schema.GroupVersionKind{}, err - } - - // a given go type can have multiple potential fully qualified kinds. Find the one that corresponds with the group - // we're trying to register here - fqKindToRegister := schema.GroupVersionKind{} - for _, fqKind := range fqKinds { - if fqKind.Group == a.group.GroupVersion.Group { - fqKindToRegister = a.group.GroupVersion.WithKind(fqKind.Kind) - break - } - - // TODO: keep rid of extensions api group dependency here - // This keeps it doing what it was doing before, but it doesn't feel right. - if fqKind.Group == "extensions" && fqKind.Kind == "ThirdPartyResourceData" { - fqKindToRegister = a.group.GroupVersion.WithKind(fqKind.Kind) - } - } - if fqKindToRegister.Empty() { - return schema.GroupVersionKind{}, fmt.Errorf("unable to locate fully qualified kind for %v: found %v when registering for %v", reflect.TypeOf(object), fqKinds, a.group.GroupVersion) - } - return fqKindToRegister, nil -} - -// restMapping returns rest mapper for the resource provided by DynamicStorage. -func (a *EventsAPIInstaller) restMapping() (*meta.RESTMapping, error) { - // subresources must have parent resources, and follow the namespacing rules of their parent. - // So get the storage of the resource (which is the parent resource in case of subresources) - fqKindToRegister, err := a.getResourceKind(a.group.DynamicStorage) - if err != nil { - return nil, fmt.Errorf("unable to locate fully qualified kind for mapper resource for dynamic storage: %v", err) - } - return a.group.Mapper.RESTMapping(fqKindToRegister.GroupKind(), fqKindToRegister.Version) -} - -func addParams(route *restful.RouteBuilder, params []*restful.Parameter) { - for _, param := range params { - route.Param(param) - } -} - -// addObjectParams converts a runtime.Object into a set of go-restful Param() definitions on the route. -// The object must be a pointer to a struct; only fields at the top level of the struct that are not -// themselves interfaces or structs are used; only fields with a json tag that is non empty (the standard -// Go JSON behavior for omitting a field) become query parameters. The name of the query parameter is -// the JSON field name. If a description struct tag is set on the field, that description is used on the -// query parameter. In essence, it converts a standard JSON top level object into a query param schema. -func addObjectParams(ws *restful.WebService, route *restful.RouteBuilder, obj interface{}) error { - sv, err := conversion.EnforcePtr(obj) - if err != nil { - return err - } - st := sv.Type() - switch st.Kind() { - case reflect.Struct: - for i := 0; i < st.NumField(); i++ { - name := st.Field(i).Name - sf, ok := st.FieldByName(name) - if !ok { - continue - } - switch sf.Type.Kind() { - case reflect.Interface, reflect.Struct: - case reflect.Ptr: - // TODO: This is a hack to let metav1.Time through. This needs to be fixed in a more generic way eventually. bug #36191 - if (sf.Type.Elem().Kind() == reflect.Interface || sf.Type.Elem().Kind() == reflect.Struct) && strings.TrimPrefix(sf.Type.String(), "*") != "metav1.Time" { - continue - } - fallthrough - default: - jsonTag := sf.Tag.Get("json") - if len(jsonTag) == 0 { - continue - } - jsonName := strings.SplitN(jsonTag, ",", 2)[0] - if len(jsonName) == 0 { - continue - } - - var desc string - if docable, ok := obj.(documentable); ok { - desc = docable.SwaggerDoc()[jsonName] - } - route.Param(ws.QueryParameter(jsonName, desc).DataType(typeToJSON(sf.Type.String()))) - } - } - } - return nil -} - -// TODO: this is incomplete, expand as needed. -// Convert the name of a golang type to the name of a JSON type -func typeToJSON(typeName string) string { - switch typeName { - case "bool", "*bool": - return "boolean" - case "uint8", "*uint8", "int", "*int", "int32", "*int32", "int64", "*int64", "uint32", "*uint32", "uint64", "*uint64": - return "integer" - case "float64", "*float64", "float32", "*float32": - return "number" - case "metav1.Time", "*metav1.Time": - return "string" - case "byte", "*byte": - return "string" - case "v1.DeletionPropagation", "*v1.DeletionPropagation": - return "string" - - // TODO: Fix these when go-restful supports a way to specify an array query param: - // https://github.com/emicklei/go-restful/issues/225 - case "[]string", "[]*string": - return "string" - case "[]int32", "[]*int32": - return "integer" - - default: - return typeName - } -} - -// rootScopeNaming reads only names from a request and ignores namespaces. It implements ScopeNamer -// for root scoped resources. -type rootScopeNaming struct { - scope meta.RESTScope - runtime.SelfLinker - pathPrefix string - pathSuffix string -} - -// rootScopeNaming implements ScopeNamer -var _ handlers.ScopeNamer = rootScopeNaming{} - -// Namespace returns an empty string because root scoped objects have no namespace. -func (n rootScopeNaming) Namespace(req *restful.Request) (namespace string, err error) { - return "", nil -} - -// Name returns the name from the path and an empty string for namespace, or an error if the -// name is empty. -func (n rootScopeNaming) Name(req *restful.Request) (namespace, name string, err error) { - name = req.PathParameter("name") - if len(name) == 0 { - return "", "", errEmptyName - } - return "", name, nil -} - -// GenerateLink returns the appropriate path and query to locate an object by its canonical path. -func (n rootScopeNaming) GenerateLink(req *restful.Request, obj runtime.Object) (uri string, err error) { - _, name, err := n.ObjectName(obj) - if err != nil { - return "", err - } - if len(name) == 0 { - _, name, err = n.Name(req) - if err != nil { - return "", err - } - } - return n.pathPrefix + url.QueryEscape(name) + n.pathSuffix, nil -} - -// GenerateListLink returns the appropriate path and query to locate a list by its canonical path. -func (n rootScopeNaming) GenerateListLink(req *restful.Request) (uri string, err error) { - if len(req.Request.URL.RawPath) > 0 { - return req.Request.URL.RawPath, nil - } - return req.Request.URL.EscapedPath(), nil -} - -// ObjectName returns the name set on the object, or an error if the -// name cannot be returned. Namespace is empty -// TODO: distinguish between objects with name/namespace and without via a specific error. -func (n rootScopeNaming) ObjectName(obj runtime.Object) (namespace, name string, err error) { - name, err = n.SelfLinker.Name(obj) - if err != nil { - return "", "", err - } - if len(name) == 0 { - return "", "", errEmptyName - } - return "", name, nil -} - -// scopeNaming returns naming information from a request. It implements ScopeNamer for -// namespace scoped resources. -type scopeNaming struct { - scope meta.RESTScope - runtime.SelfLinker - itemPathFn func(name, namespace string) bytes.Buffer - allNamespaces bool -} - -// scopeNaming implements ScopeNamer -var _ handlers.ScopeNamer = scopeNaming{} - -// Namespace returns the namespace from the path or the default. -func (n scopeNaming) Namespace(req *restful.Request) (namespace string, err error) { - if n.allNamespaces { - return "", nil - } - namespace = req.PathParameter(n.scope.ArgumentName()) - if len(namespace) == 0 { - // a URL was constructed without the namespace, or this method was invoked - // on an object without a namespace path parameter. - return "", fmt.Errorf("no namespace parameter found on request") - } - return namespace, nil -} - -// Name returns the name from the path, the namespace (or default), or an error if the -// name is empty. -func (n scopeNaming) Name(req *restful.Request) (namespace, name string, err error) { - namespace, _ = n.Namespace(req) - name = req.PathParameter("name") - if len(name) == 0 { - return "", "", errEmptyName - } - return -} - -// GenerateLink returns the appropriate path and query to locate an object by its canonical path. -func (n scopeNaming) GenerateLink(req *restful.Request, obj runtime.Object) (uri string, err error) { - namespace, name, err := n.ObjectName(obj) - if err != nil { - return "", err - } - if len(namespace) == 0 && len(name) == 0 { - namespace, name, err = n.Name(req) - if err != nil { - return "", err - } - } - if len(name) == 0 { - return "", errEmptyName - } - result := n.itemPathFn(name, namespace) - return result.String(), nil -} - -// GenerateListLink returns the appropriate path and query to locate a list by its canonical path. -func (n scopeNaming) GenerateListLink(req *restful.Request) (uri string, err error) { - if len(req.Request.URL.RawPath) > 0 { - return req.Request.URL.RawPath, nil - } - return req.Request.URL.EscapedPath(), nil -} - -// ObjectName returns the name and namespace set on the object, or an error if the -// name cannot be returned. -// TODO: distinguish between objects with name/namespace and without via a specific error. -func (n scopeNaming) ObjectName(obj runtime.Object) (namespace, name string, err error) { - name, err = n.SelfLinker.Name(obj) - if err != nil { - return "", "", err - } - namespace, err = n.SelfLinker.Namespace(obj) - if err != nil { - return "", "", err - } - return namespace, name, err -} - -// An interface to see if an object supports swagger documentation as a method -type documentable interface { - SwaggerDoc() map[string]string -} - -// errEmptyName is returned when API requests do not fill the name section of the path. -var errEmptyName = errors.NewBadRequest("name must be provided") diff --git a/archived/event-adapter/pkg/apiserver/installer/installer_test.go b/archived/event-adapter/pkg/apiserver/installer/installer_test.go deleted file mode 100644 index 53ae01ae4..000000000 --- a/archived/event-adapter/pkg/apiserver/installer/installer_test.go +++ /dev/null @@ -1,78 +0,0 @@ -/* -Copyright 2017 The Kubernetes Authors. - -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. -*/ -package installer - -import ( - "bytes" - "testing" - - "k8s.io/apimachinery/pkg/api/meta" - metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" - "k8s.io/apimachinery/pkg/runtime" - "k8s.io/client-go/pkg/api" - - "github.com/emicklei/go-restful" -) - -type setTestSelfLinker struct { - t *testing.T - expectedSet string - name string - namespace string - called bool - err error -} - -func (s *setTestSelfLinker) Namespace(runtime.Object) (string, error) { return s.namespace, s.err } -func (s *setTestSelfLinker) Name(runtime.Object) (string, error) { return s.name, s.err } -func (s *setTestSelfLinker) SelfLink(runtime.Object) (string, error) { return "", s.err } -func (s *setTestSelfLinker) SetSelfLink(obj runtime.Object, selfLink string) error { - if e, a := s.expectedSet, selfLink; e != a { - s.t.Errorf("expected '%v', got '%v'", e, a) - } - s.called = true - return s.err -} - -func TestScopeNamingGenerateLink(t *testing.T) { - selfLinker := &setTestSelfLinker{ - t: t, - expectedSet: "/apis/v1events/v1alpha/namespaces/other/events/foo", - name: "foo", - namespace: "other", - } - s := scopeNaming{ - meta.RESTScopeNamespace, - selfLinker, - func(name, namespace string) bytes.Buffer { - return *bytes.NewBufferString("/api/v1events/v1alpha/namespaces/" + namespace + "/events/" + name) - }, - true, - } - service := &api.Service{ - ObjectMeta: metav1.ObjectMeta{ - Name: "foo", - Namespace: "other", - }, - TypeMeta: metav1.TypeMeta{ - Kind: "Service", - }, - } - _, err := s.GenerateLink(&restful.Request{}, service) - if err != nil { - t.Errorf("Unexpected error %v", err) - } -} diff --git a/archived/event-adapter/pkg/cmd/server/start.go b/archived/event-adapter/pkg/cmd/server/start.go deleted file mode 100644 index 3bcc0a412..000000000 --- a/archived/event-adapter/pkg/cmd/server/start.go +++ /dev/null @@ -1,93 +0,0 @@ -/* -Copyright 2017 The Kubernetes Authors. - -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. -*/ - -package server - -import ( - "fmt" - "github.com/GoogleCloudPlatform/k8s-stackdriver/event-adapter/pkg/apiserver" - "io" - genericapiserver "k8s.io/apiserver/pkg/server" - genericoptions "k8s.io/apiserver/pkg/server/options" - "net" -) - -// EventsAdapterServerOptions stores a configuration for events adapter -type EventsAdapterServerOptions struct { - // genericoptions.ReccomendedOptions - EtcdOptions - SecureServing *genericoptions.SecureServingOptions - Authentication *genericoptions.DelegatingAuthenticationOptions - Authorization *genericoptions.DelegatingAuthorizationOptions - Features *genericoptions.FeatureOptions - - StdOut io.Writer - StdErr io.Writer -} - -// NewEventsAdapterServerOptions creates a EventsAdapterServerOptions for provided output interface -func NewEventsAdapterServerOptions(out, errOut io.Writer) *EventsAdapterServerOptions { - o := &EventsAdapterServerOptions{ - SecureServing: genericoptions.NewSecureServingOptions(), - Authentication: genericoptions.NewDelegatingAuthenticationOptions(), - Authorization: genericoptions.NewDelegatingAuthorizationOptions(), - Features: genericoptions.NewFeatureOptions(), - - StdOut: out, - StdErr: errOut, - } - - return o -} - -// Validate validates EventsAdapterServerOptions. Currently all fields are correctly set in -// NewsAdapterServerOptions, so this is a no-op. -func (o EventsAdapterServerOptions) Validate(args []string) error { - return nil -} - -// Complete fills in any fields not set that are required to have valid data. Currently all fields -// are set by NewEventsAdapterServerOptions, so this is a no-op. -func (o *EventsAdapterServerOptions) Complete() error { - return nil -} - -// Config returns apiserver.Config object from EventsAdapterServerOptions. -func (o EventsAdapterServerOptions) Config() (*apiserver.Config, error) { - // TODO have a "real" external address (have an AdvertiseAddress?) - if err := o.SecureServing.MaybeDefaultWithSelfSignedCerts("localhost", nil, []net.IP{net.ParseIP("127.0.0.1")}); err != nil { - return nil, fmt.Errorf("error creating self-signed certificates: %v", err) - } - - serverConfig := genericapiserver.NewConfig(apiserver.Codecs) - if err := o.SecureServing.ApplyTo(serverConfig); err != nil { - return nil, err - } - - if err := o.Authentication.ApplyTo(serverConfig); err != nil { - return nil, err - } - if err := o.Authorization.ApplyTo(serverConfig); err != nil { - return nil, err - } - - // TODO: we can't currently serve swagger because we don't have a good way to dynamically update it - // serverConfig.SwaggerConfig = genericapiserver.DefaultSwaggerConfig() - - config := &apiserver.Config{ - GenericConfig: serverConfig, - } - return config, nil -} diff --git a/archived/event-adapter/pkg/provider/interfaces.go b/archived/event-adapter/pkg/provider/interfaces.go deleted file mode 100644 index f1fca2a95..000000000 --- a/archived/event-adapter/pkg/provider/interfaces.go +++ /dev/null @@ -1,43 +0,0 @@ -/* -Copyright 2017 The Kubernetes Authors. - -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. -*/ - -package provider - -import ( - "k8s.io/apimachinery/pkg/runtime/schema" - api "k8s.io/client-go/pkg/api/v1" -) - -// EventInfo contains info relevant for an Event -type EventInfo struct { - // GroupResource is the group of the resources - GroupResource schema.GroupResource - // Namespaced will be true if the event will be namespaced - Namespaced bool - // Event will contain the name of the event - Event string -} - -// EventsProvider is an interface that contains the methods that will provide info for the given events -type EventsProvider interface { - // READ - GetNamespacedEventsByName(namespace, eventName string) (*api.Event, error) - ListAllEventsByNamespace(namespace string) (*api.EventList, error) - ListAllEvents() (*api.EventList, error) - - // WRITE - CreateNewEvent(namespace string) (*api.Event, error) -} diff --git a/archived/event-adapter/pkg/provider/resource_lister.go b/archived/event-adapter/pkg/provider/resource_lister.go deleted file mode 100644 index 74ad9f86f..000000000 --- a/archived/event-adapter/pkg/provider/resource_lister.go +++ /dev/null @@ -1,60 +0,0 @@ -/* -Copyright 2017 The Kubernetes Authors. - -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. -*/ - -package provider - -import ( - metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" - "k8s.io/apiserver/pkg/endpoints/handlers" -) - -type eventsResourceLister struct { - provider EventsProvider -} - -// NewResourceLister creates a new APIResourceLister for provided EventsProvider -func NewResourceLister(provider EventsProvider) handlers.APIResourceLister { - return &eventsResourceLister{ - provider: provider, - } -} - -// ListAPIResources lists the supported API paths -func (l *eventsResourceLister) ListAPIResources() []metav1.APIResource { - resources := make([]metav1.APIResource, 3) - resources[0] = metav1.APIResource{ - Name: "namespaces/{namespace}/events/{eventName}", - Namespaced: true, - Kind: "Event", - Verbs: metav1.Verbs{"get"}, - } - - resources[1] = metav1.APIResource{ - Name: "namespaces/{namespace}/events", - Namespaced: true, - Kind: "EventList", - Verbs: metav1.Verbs{"get", "post"}, - } - - resources[2] = metav1.APIResource{ - Name: "events", - Namespaced: true, - Kind: "EventList", - Verbs: metav1.Verbs{"get"}, - } - - return resources -} diff --git a/archived/event-adapter/pkg/registry/reststorage.go b/archived/event-adapter/pkg/registry/reststorage.go deleted file mode 100644 index ae55731a7..000000000 --- a/archived/event-adapter/pkg/registry/reststorage.go +++ /dev/null @@ -1,96 +0,0 @@ -/* -Copyright 2017 The Kubernetes Authors. - -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. -*/ - -package registry - -import ( - "fmt" - specificinstaller "github.com/GoogleCloudPlatform/k8s-stackdriver/event-adapter/pkg/apiserver/installer/context" - "github.com/GoogleCloudPlatform/k8s-stackdriver/event-adapter/pkg/provider" - metainternalversion "k8s.io/apimachinery/pkg/apis/meta/internalversion" - "k8s.io/apimachinery/pkg/runtime" - genericapirequest "k8s.io/apiserver/pkg/endpoints/request" - "k8s.io/apiserver/pkg/registry/rest" - api "k8s.io/client-go/pkg/api/v1" -) - -// REST is a wrapper for EventsProvider that provides implementation for Storage and Lister interfaces -type REST struct { - evProvider provider.EventsProvider -} - -var _ rest.Storage = &REST{} -var _ rest.Lister = &REST{} - -// NewREST creates a new REST for the given EventsProvider -func NewREST(evProvider provider.EventsProvider) *REST { - return &REST{ - evProvider: evProvider, - } -} - -// New implements Storage -func (r *REST) New() runtime.Object { - return &api.Event{} -} - -// NewList implement Lister -func (r *REST) NewList() runtime.Object { - return &api.EventList{} -} - -// List selects the events that match to the selector -func (r *REST) List(ctx genericapirequest.Context, options *metainternalversion.ListOptions) (runtime.Object, error) { - - namespace := genericapirequest.NamespaceValue(ctx) - if namespace == "" { - return r.evProvider.ListAllEvents() - } - - eventName, methodSingleEvent, ok := specificinstaller.RequestInformationFrom(ctx) - methodListEvents, list := specificinstaller.RequestListInformationFrom(ctx) - - if methodListEvents == "" && methodSingleEvent == "" { - return nil, fmt.Errorf("Unable to serve the request: forgiven method") - } - - if list { - return r.listEventsAPI(namespace, methodListEvents) - } - - if ok { - return r.singleEventAPI(namespace, eventName, methodSingleEvent) - } - - return nil, fmt.Errorf("Unable to serve the request") -} - -func (r *REST) singleEventAPI(namespace, name, method string) (runtime.Object, error) { - if method == "GET" { - return r.evProvider.GetNamespacedEventsByName(namespace, name) - } - return nil, fmt.Errorf("Method %s not allowed", method) -} - -func (r *REST) listEventsAPI(namespace, method string) (runtime.Object, error) { - switch method { - case "GET": - return r.evProvider.ListAllEventsByNamespace(namespace) - case "POST": - return r.evProvider.CreateNewEvent(namespace) - } - return nil, fmt.Errorf("Method %s not allowed", method) -} diff --git a/archived/event-adapter/pkg/types/install.go b/archived/event-adapter/pkg/types/install.go deleted file mode 100644 index 4849df5b3..000000000 --- a/archived/event-adapter/pkg/types/install.go +++ /dev/null @@ -1,45 +0,0 @@ -/* -Copyright 2017 The Kubernetes Authors. - -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. -*/ - -package types - -import ( - "k8s.io/apimachinery/pkg/apimachinery/announced" - "k8s.io/apimachinery/pkg/apimachinery/registered" - "k8s.io/apimachinery/pkg/runtime" - "k8s.io/client-go/pkg/api" -) - -func init() { - Install(api.GroupFactoryRegistry, api.Registry, api.Scheme) -} - -// Install registers the API group and adds types to a scheme -func Install(groupFactoryRegistry announced.APIGroupFactoryRegistry, registry *registered.APIRegistrationManager, scheme *runtime.Scheme) { - if err := announced.NewGroupMetaFactory( - &announced.GroupMetaFactoryArgs{ - GroupName: GroupName, - VersionPreferenceOrder: []string{SchemeGroupVersion.Version}, - ImportPrefix: "", - AddInternalObjectsToScheme: AddToScheme, - }, - announced.VersionToSchemeFunc{ - SchemeGroupVersion.Version: AddToScheme, - }, - ).Announce(groupFactoryRegistry).RegisterAndEnable(registry, scheme); err != nil { - panic(err) - } -} diff --git a/archived/event-adapter/pkg/types/register.go b/archived/event-adapter/pkg/types/register.go deleted file mode 100644 index 6cdaa3b04..000000000 --- a/archived/event-adapter/pkg/types/register.go +++ /dev/null @@ -1,56 +0,0 @@ -/* -Copyright 2017 The Kubernetes Authors. - -Licensed under the Apache License, Version 2.0 (the "License"); -you may not use this file except in compliance with the License. -You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - -Unless required by applicable law or agreed to in writing, software -distributed under the License is distributed on an "AS IS" BASIS, -WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the License for the specific language governing permissions and -limitations under the License. -*/ - -package types - -import ( - metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" - "k8s.io/apimachinery/pkg/runtime" - "k8s.io/apimachinery/pkg/runtime/schema" - api "k8s.io/client-go/pkg/api/v1" -) - -// GroupName is the group name use in this package -const GroupName = "v1events" - -// SchemeGroupVersion is group version used to register these objects -var SchemeGroupVersion = schema.GroupVersion{Group: GroupName, Version: "v1alpha1"} - -// Resource takes an unqualified resource and returns a Group qualified GroupResource -func Resource(resource string) schema.GroupResource { - return SchemeGroupVersion.WithResource(resource).GroupResource() -} - -// Kind takes an unqualified kind and returns back a Group qualified GroupKind -func Kind(kind string) schema.GroupKind { - return SchemeGroupVersion.WithKind(kind).GroupKind() -} - -var ( - // SchemeBuilder contains the builder scheme - SchemeBuilder = runtime.NewSchemeBuilder(addKnownTypes) - // AddToScheme allow to add type to the scheme - AddToScheme = SchemeBuilder.AddToScheme -) - -func addKnownTypes(scheme *runtime.Scheme) error { - scheme.AddKnownTypes(SchemeGroupVersion, - &api.Event{}, - &api.EventList{}, - ) - metav1.AddToGroupVersion(scheme, SchemeGroupVersion) - return nil -} diff --git a/archived/event-adapter/vendor/bitbucket.org/ww/goautoneg/Makefile b/archived/event-adapter/vendor/bitbucket.org/ww/goautoneg/Makefile deleted file mode 100644 index e33ee1730..000000000 --- a/archived/event-adapter/vendor/bitbucket.org/ww/goautoneg/Makefile +++ /dev/null @@ -1,13 +0,0 @@ -include $(GOROOT)/src/Make.inc - -TARG=bitbucket.org/ww/goautoneg -GOFILES=autoneg.go - -include $(GOROOT)/src/Make.pkg - -format: - gofmt -w *.go - -docs: - gomake clean - godoc ${TARG} > README.txt diff --git a/archived/event-adapter/vendor/bitbucket.org/ww/goautoneg/README.txt b/archived/event-adapter/vendor/bitbucket.org/ww/goautoneg/README.txt deleted file mode 100644 index 7723656d5..000000000 --- a/archived/event-adapter/vendor/bitbucket.org/ww/goautoneg/README.txt +++ /dev/null @@ -1,67 +0,0 @@ -PACKAGE - -package goautoneg -import "bitbucket.org/ww/goautoneg" - -HTTP Content-Type Autonegotiation. - -The functions in this package implement the behaviour specified in -http://www.w3.org/Protocols/rfc2616/rfc2616-sec14.html - -Copyright (c) 2011, Open Knowledge Foundation Ltd. -All rights reserved. - -Redistribution and use in source and binary forms, with or without -modification, are permitted provided that the following conditions are -met: - - Redistributions of source code must retain the above copyright - notice, this list of conditions and the following disclaimer. - - Redistributions in binary form must reproduce the above copyright - notice, this list of conditions and the following disclaimer in - the documentation and/or other materials provided with the - distribution. - - Neither the name of the Open Knowledge Foundation Ltd. nor the - names of its contributors may be used to endorse or promote - products derived from this software without specific prior written - permission. - -THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS -"AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT -LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR -A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT -HOLDER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, -SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT -LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, -DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY -THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT -(INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE -OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. - - -FUNCTIONS - -func Negotiate(header string, alternatives []string) (content_type string) -Negotiate the most appropriate content_type given the accept header -and a list of alternatives. - -func ParseAccept(header string) (accept []Accept) -Parse an Accept Header string returning a sorted list -of clauses - - -TYPES - -type Accept struct { - Type, SubType string - Q float32 - Params map[string]string -} -Structure to represent a clause in an HTTP Accept Header - - -SUBDIRECTORIES - - .hg diff --git a/archived/event-adapter/vendor/bitbucket.org/ww/goautoneg/autoneg.go b/archived/event-adapter/vendor/bitbucket.org/ww/goautoneg/autoneg.go deleted file mode 100644 index 648b38cb6..000000000 --- a/archived/event-adapter/vendor/bitbucket.org/ww/goautoneg/autoneg.go +++ /dev/null @@ -1,162 +0,0 @@ -/* -HTTP Content-Type Autonegotiation. - -The functions in this package implement the behaviour specified in -http://www.w3.org/Protocols/rfc2616/rfc2616-sec14.html - -Copyright (c) 2011, Open Knowledge Foundation Ltd. -All rights reserved. - -Redistribution and use in source and binary forms, with or without -modification, are permitted provided that the following conditions are -met: - - Redistributions of source code must retain the above copyright - notice, this list of conditions and the following disclaimer. - - Redistributions in binary form must reproduce the above copyright - notice, this list of conditions and the following disclaimer in - the documentation and/or other materials provided with the - distribution. - - Neither the name of the Open Knowledge Foundation Ltd. nor the - names of its contributors may be used to endorse or promote - products derived from this software without specific prior written - permission. - -THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS -"AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT -LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR -A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT -HOLDER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, -SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT -LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, -DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY -THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT -(INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE -OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. - - -*/ -package goautoneg - -import ( - "sort" - "strconv" - "strings" -) - -// Structure to represent a clause in an HTTP Accept Header -type Accept struct { - Type, SubType string - Q float64 - Params map[string]string -} - -// For internal use, so that we can use the sort interface -type accept_slice []Accept - -func (accept accept_slice) Len() int { - slice := []Accept(accept) - return len(slice) -} - -func (accept accept_slice) Less(i, j int) bool { - slice := []Accept(accept) - ai, aj := slice[i], slice[j] - if ai.Q > aj.Q { - return true - } - if ai.Type != "*" && aj.Type == "*" { - return true - } - if ai.SubType != "*" && aj.SubType == "*" { - return true - } - return false -} - -func (accept accept_slice) Swap(i, j int) { - slice := []Accept(accept) - slice[i], slice[j] = slice[j], slice[i] -} - -// Parse an Accept Header string returning a sorted list -// of clauses -func ParseAccept(header string) (accept []Accept) { - parts := strings.Split(header, ",") - accept = make([]Accept, 0, len(parts)) - for _, part := range parts { - part := strings.Trim(part, " ") - - a := Accept{} - a.Params = make(map[string]string) - a.Q = 1.0 - - mrp := strings.Split(part, ";") - - media_range := mrp[0] - sp := strings.Split(media_range, "/") - a.Type = strings.Trim(sp[0], " ") - - switch { - case len(sp) == 1 && a.Type == "*": - a.SubType = "*" - case len(sp) == 2: - a.SubType = strings.Trim(sp[1], " ") - default: - continue - } - - if len(mrp) == 1 { - accept = append(accept, a) - continue - } - - for _, param := range mrp[1:] { - sp := strings.SplitN(param, "=", 2) - if len(sp) != 2 { - continue - } - token := strings.Trim(sp[0], " ") - if token == "q" { - a.Q, _ = strconv.ParseFloat(sp[1], 32) - } else { - a.Params[token] = strings.Trim(sp[1], " ") - } - } - - accept = append(accept, a) - } - - slice := accept_slice(accept) - sort.Sort(slice) - - return -} - -// Negotiate the most appropriate content_type given the accept header -// and a list of alternatives. -func Negotiate(header string, alternatives []string) (content_type string) { - asp := make([][]string, 0, len(alternatives)) - for _, ctype := range alternatives { - asp = append(asp, strings.SplitN(ctype, "/", 2)) - } - for _, clause := range ParseAccept(header) { - for i, ctsp := range asp { - if clause.Type == ctsp[0] && clause.SubType == ctsp[1] { - content_type = alternatives[i] - return - } - if clause.Type == ctsp[0] && clause.SubType == "*" { - content_type = alternatives[i] - return - } - if clause.Type == "*" && clause.SubType == "*" { - content_type = alternatives[i] - return - } - } - } - return -} diff --git a/archived/event-adapter/vendor/cloud.google.com/go/AUTHORS b/archived/event-adapter/vendor/cloud.google.com/go/AUTHORS deleted file mode 100644 index c364af1da..000000000 --- a/archived/event-adapter/vendor/cloud.google.com/go/AUTHORS +++ /dev/null @@ -1,15 +0,0 @@ -# This is the official list of cloud authors for copyright purposes. -# This file is distinct from the CONTRIBUTORS files. -# See the latter for an explanation. - -# Names should be added to this file as: -# Name or Organization
block.
- if d != "" && d[0] == '\r' {
- d = d[1:]
- }
- if d != "" && d[0] == '\n' {
- d = d[1:]
- }
- }
- }
- d = strings.Replace(d, "\x00", "", -1)
- if d == "" {
- return true
- }
- p.reconstructActiveFormattingElements()
- p.addText(d)
- if p.framesetOK && strings.TrimLeft(d, whitespace) != "" {
- // There were non-whitespace characters inserted.
- p.framesetOK = false
- }
- case StartTagToken:
- switch p.tok.DataAtom {
- case a.Html:
- copyAttributes(p.oe[0], p.tok)
- case a.Base, a.Basefont, a.Bgsound, a.Command, a.Link, a.Meta, a.Noframes, a.Script, a.Style, a.Title:
- return inHeadIM(p)
- case a.Body:
- if len(p.oe) >= 2 {
- body := p.oe[1]
- if body.Type == ElementNode && body.DataAtom == a.Body {
- p.framesetOK = false
- copyAttributes(body, p.tok)
- }
- }
- case a.Frameset:
- if !p.framesetOK || len(p.oe) < 2 || p.oe[1].DataAtom != a.Body {
- // Ignore the token.
- return true
- }
- body := p.oe[1]
- if body.Parent != nil {
- body.Parent.RemoveChild(body)
- }
- p.oe = p.oe[:1]
- p.addElement()
- p.im = inFramesetIM
- return true
- case a.Address, a.Article, a.Aside, a.Blockquote, a.Center, a.Details, a.Dir, a.Div, a.Dl, a.Fieldset, a.Figcaption, a.Figure, a.Footer, a.Header, a.Hgroup, a.Menu, a.Nav, a.Ol, a.P, a.Section, a.Summary, a.Ul:
- p.popUntil(buttonScope, a.P)
- p.addElement()
- case a.H1, a.H2, a.H3, a.H4, a.H5, a.H6:
- p.popUntil(buttonScope, a.P)
- switch n := p.top(); n.DataAtom {
- case a.H1, a.H2, a.H3, a.H4, a.H5, a.H6:
- p.oe.pop()
- }
- p.addElement()
- case a.Pre, a.Listing:
- p.popUntil(buttonScope, a.P)
- p.addElement()
- // The newline, if any, will be dealt with by the TextToken case.
- p.framesetOK = false
- case a.Form:
- if p.form == nil {
- p.popUntil(buttonScope, a.P)
- p.addElement()
- p.form = p.top()
- }
- case a.Li:
- p.framesetOK = false
- for i := len(p.oe) - 1; i >= 0; i-- {
- node := p.oe[i]
- switch node.DataAtom {
- case a.Li:
- p.oe = p.oe[:i]
- case a.Address, a.Div, a.P:
- continue
- default:
- if !isSpecialElement(node) {
- continue
- }
- }
- break
- }
- p.popUntil(buttonScope, a.P)
- p.addElement()
- case a.Dd, a.Dt:
- p.framesetOK = false
- for i := len(p.oe) - 1; i >= 0; i-- {
- node := p.oe[i]
- switch node.DataAtom {
- case a.Dd, a.Dt:
- p.oe = p.oe[:i]
- case a.Address, a.Div, a.P:
- continue
- default:
- if !isSpecialElement(node) {
- continue
- }
- }
- break
- }
- p.popUntil(buttonScope, a.P)
- p.addElement()
- case a.Plaintext:
- p.popUntil(buttonScope, a.P)
- p.addElement()
- case a.Button:
- p.popUntil(defaultScope, a.Button)
- p.reconstructActiveFormattingElements()
- p.addElement()
- p.framesetOK = false
- case a.A:
- for i := len(p.afe) - 1; i >= 0 && p.afe[i].Type != scopeMarkerNode; i-- {
- if n := p.afe[i]; n.Type == ElementNode && n.DataAtom == a.A {
- p.inBodyEndTagFormatting(a.A)
- p.oe.remove(n)
- p.afe.remove(n)
- break
- }
- }
- p.reconstructActiveFormattingElements()
- p.addFormattingElement()
- case a.B, a.Big, a.Code, a.Em, a.Font, a.I, a.S, a.Small, a.Strike, a.Strong, a.Tt, a.U:
- p.reconstructActiveFormattingElements()
- p.addFormattingElement()
- case a.Nobr:
- p.reconstructActiveFormattingElements()
- if p.elementInScope(defaultScope, a.Nobr) {
- p.inBodyEndTagFormatting(a.Nobr)
- p.reconstructActiveFormattingElements()
- }
- p.addFormattingElement()
- case a.Applet, a.Marquee, a.Object:
- p.reconstructActiveFormattingElements()
- p.addElement()
- p.afe = append(p.afe, &scopeMarker)
- p.framesetOK = false
- case a.Table:
- if !p.quirks {
- p.popUntil(buttonScope, a.P)
- }
- p.addElement()
- p.framesetOK = false
- p.im = inTableIM
- return true
- case a.Area, a.Br, a.Embed, a.Img, a.Input, a.Keygen, a.Wbr:
- p.reconstructActiveFormattingElements()
- p.addElement()
- p.oe.pop()
- p.acknowledgeSelfClosingTag()
- if p.tok.DataAtom == a.Input {
- for _, t := range p.tok.Attr {
- if t.Key == "type" {
- if strings.ToLower(t.Val) == "hidden" {
- // Skip setting framesetOK = false
- return true
- }
- }
- }
- }
- p.framesetOK = false
- case a.Param, a.Source, a.Track:
- p.addElement()
- p.oe.pop()
- p.acknowledgeSelfClosingTag()
- case a.Hr:
- p.popUntil(buttonScope, a.P)
- p.addElement()
- p.oe.pop()
- p.acknowledgeSelfClosingTag()
- p.framesetOK = false
- case a.Image:
- p.tok.DataAtom = a.Img
- p.tok.Data = a.Img.String()
- return false
- case a.Isindex:
- if p.form != nil {
- // Ignore the token.
- return true
- }
- action := ""
- prompt := "This is a searchable index. Enter search keywords: "
- attr := []Attribute{{Key: "name", Val: "isindex"}}
- for _, t := range p.tok.Attr {
- switch t.Key {
- case "action":
- action = t.Val
- case "name":
- // Ignore the attribute.
- case "prompt":
- prompt = t.Val
- default:
- attr = append(attr, t)
- }
- }
- p.acknowledgeSelfClosingTag()
- p.popUntil(buttonScope, a.P)
- p.parseImpliedToken(StartTagToken, a.Form, a.Form.String())
- if action != "" {
- p.form.Attr = []Attribute{{Key: "action", Val: action}}
- }
- p.parseImpliedToken(StartTagToken, a.Hr, a.Hr.String())
- p.parseImpliedToken(StartTagToken, a.Label, a.Label.String())
- p.addText(prompt)
- p.addChild(&Node{
- Type: ElementNode,
- DataAtom: a.Input,
- Data: a.Input.String(),
- Attr: attr,
- })
- p.oe.pop()
- p.parseImpliedToken(EndTagToken, a.Label, a.Label.String())
- p.parseImpliedToken(StartTagToken, a.Hr, a.Hr.String())
- p.parseImpliedToken(EndTagToken, a.Form, a.Form.String())
- case a.Textarea:
- p.addElement()
- p.setOriginalIM()
- p.framesetOK = false
- p.im = textIM
- case a.Xmp:
- p.popUntil(buttonScope, a.P)
- p.reconstructActiveFormattingElements()
- p.framesetOK = false
- p.addElement()
- p.setOriginalIM()
- p.im = textIM
- case a.Iframe:
- p.framesetOK = false
- p.addElement()
- p.setOriginalIM()
- p.im = textIM
- case a.Noembed, a.Noscript:
- p.addElement()
- p.setOriginalIM()
- p.im = textIM
- case a.Select:
- p.reconstructActiveFormattingElements()
- p.addElement()
- p.framesetOK = false
- p.im = inSelectIM
- return true
- case a.Optgroup, a.Option:
- if p.top().DataAtom == a.Option {
- p.oe.pop()
- }
- p.reconstructActiveFormattingElements()
- p.addElement()
- case a.Rp, a.Rt:
- if p.elementInScope(defaultScope, a.Ruby) {
- p.generateImpliedEndTags()
- }
- p.addElement()
- case a.Math, a.Svg:
- p.reconstructActiveFormattingElements()
- if p.tok.DataAtom == a.Math {
- adjustAttributeNames(p.tok.Attr, mathMLAttributeAdjustments)
- } else {
- adjustAttributeNames(p.tok.Attr, svgAttributeAdjustments)
- }
- adjustForeignAttributes(p.tok.Attr)
- p.addElement()
- p.top().Namespace = p.tok.Data
- if p.hasSelfClosingToken {
- p.oe.pop()
- p.acknowledgeSelfClosingTag()
- }
- return true
- case a.Caption, a.Col, a.Colgroup, a.Frame, a.Head, a.Tbody, a.Td, a.Tfoot, a.Th, a.Thead, a.Tr:
- // Ignore the token.
- default:
- p.reconstructActiveFormattingElements()
- p.addElement()
- }
- case EndTagToken:
- switch p.tok.DataAtom {
- case a.Body:
- if p.elementInScope(defaultScope, a.Body) {
- p.im = afterBodyIM
- }
- case a.Html:
- if p.elementInScope(defaultScope, a.Body) {
- p.parseImpliedToken(EndTagToken, a.Body, a.Body.String())
- return false
- }
- return true
- case a.Address, a.Article, a.Aside, a.Blockquote, a.Button, a.Center, a.Details, a.Dir, a.Div, a.Dl, a.Fieldset, a.Figcaption, a.Figure, a.Footer, a.Header, a.Hgroup, a.Listing, a.Menu, a.Nav, a.Ol, a.Pre, a.Section, a.Summary, a.Ul:
- p.popUntil(defaultScope, p.tok.DataAtom)
- case a.Form:
- node := p.form
- p.form = nil
- i := p.indexOfElementInScope(defaultScope, a.Form)
- if node == nil || i == -1 || p.oe[i] != node {
- // Ignore the token.
- return true
- }
- p.generateImpliedEndTags()
- p.oe.remove(node)
- case a.P:
- if !p.elementInScope(buttonScope, a.P) {
- p.parseImpliedToken(StartTagToken, a.P, a.P.String())
- }
- p.popUntil(buttonScope, a.P)
- case a.Li:
- p.popUntil(listItemScope, a.Li)
- case a.Dd, a.Dt:
- p.popUntil(defaultScope, p.tok.DataAtom)
- case a.H1, a.H2, a.H3, a.H4, a.H5, a.H6:
- p.popUntil(defaultScope, a.H1, a.H2, a.H3, a.H4, a.H5, a.H6)
- case a.A, a.B, a.Big, a.Code, a.Em, a.Font, a.I, a.Nobr, a.S, a.Small, a.Strike, a.Strong, a.Tt, a.U:
- p.inBodyEndTagFormatting(p.tok.DataAtom)
- case a.Applet, a.Marquee, a.Object:
- if p.popUntil(defaultScope, p.tok.DataAtom) {
- p.clearActiveFormattingElements()
- }
- case a.Br:
- p.tok.Type = StartTagToken
- return false
- default:
- p.inBodyEndTagOther(p.tok.DataAtom)
- }
- case CommentToken:
- p.addChild(&Node{
- Type: CommentNode,
- Data: p.tok.Data,
- })
- }
-
- return true
-}
-
-func (p *parser) inBodyEndTagFormatting(tagAtom a.Atom) {
- // This is the "adoption agency" algorithm, described at
- // https://html.spec.whatwg.org/multipage/syntax.html#adoptionAgency
-
- // TODO: this is a fairly literal line-by-line translation of that algorithm.
- // Once the code successfully parses the comprehensive test suite, we should
- // refactor this code to be more idiomatic.
-
- // Steps 1-4. The outer loop.
- for i := 0; i < 8; i++ {
- // Step 5. Find the formatting element.
- var formattingElement *Node
- for j := len(p.afe) - 1; j >= 0; j-- {
- if p.afe[j].Type == scopeMarkerNode {
- break
- }
- if p.afe[j].DataAtom == tagAtom {
- formattingElement = p.afe[j]
- break
- }
- }
- if formattingElement == nil {
- p.inBodyEndTagOther(tagAtom)
- return
- }
- feIndex := p.oe.index(formattingElement)
- if feIndex == -1 {
- p.afe.remove(formattingElement)
- return
- }
- if !p.elementInScope(defaultScope, tagAtom) {
- // Ignore the tag.
- return
- }
-
- // Steps 9-10. Find the furthest block.
- var furthestBlock *Node
- for _, e := range p.oe[feIndex:] {
- if isSpecialElement(e) {
- furthestBlock = e
- break
- }
- }
- if furthestBlock == nil {
- e := p.oe.pop()
- for e != formattingElement {
- e = p.oe.pop()
- }
- p.afe.remove(e)
- return
- }
-
- // Steps 11-12. Find the common ancestor and bookmark node.
- commonAncestor := p.oe[feIndex-1]
- bookmark := p.afe.index(formattingElement)
-
- // Step 13. The inner loop. Find the lastNode to reparent.
- lastNode := furthestBlock
- node := furthestBlock
- x := p.oe.index(node)
- // Steps 13.1-13.2
- for j := 0; j < 3; j++ {
- // Step 13.3.
- x--
- node = p.oe[x]
- // Step 13.4 - 13.5.
- if p.afe.index(node) == -1 {
- p.oe.remove(node)
- continue
- }
- // Step 13.6.
- if node == formattingElement {
- break
- }
- // Step 13.7.
- clone := node.clone()
- p.afe[p.afe.index(node)] = clone
- p.oe[p.oe.index(node)] = clone
- node = clone
- // Step 13.8.
- if lastNode == furthestBlock {
- bookmark = p.afe.index(node) + 1
- }
- // Step 13.9.
- if lastNode.Parent != nil {
- lastNode.Parent.RemoveChild(lastNode)
- }
- node.AppendChild(lastNode)
- // Step 13.10.
- lastNode = node
- }
-
- // Step 14. Reparent lastNode to the common ancestor,
- // or for misnested table nodes, to the foster parent.
- if lastNode.Parent != nil {
- lastNode.Parent.RemoveChild(lastNode)
- }
- switch commonAncestor.DataAtom {
- case a.Table, a.Tbody, a.Tfoot, a.Thead, a.Tr:
- p.fosterParent(lastNode)
- default:
- commonAncestor.AppendChild(lastNode)
- }
-
- // Steps 15-17. Reparent nodes from the furthest block's children
- // to a clone of the formatting element.
- clone := formattingElement.clone()
- reparentChildren(clone, furthestBlock)
- furthestBlock.AppendChild(clone)
-
- // Step 18. Fix up the list of active formatting elements.
- if oldLoc := p.afe.index(formattingElement); oldLoc != -1 && oldLoc < bookmark {
- // Move the bookmark with the rest of the list.
- bookmark--
- }
- p.afe.remove(formattingElement)
- p.afe.insert(bookmark, clone)
-
- // Step 19. Fix up the stack of open elements.
- p.oe.remove(formattingElement)
- p.oe.insert(p.oe.index(furthestBlock)+1, clone)
- }
-}
-
-// inBodyEndTagOther performs the "any other end tag" algorithm for inBodyIM.
-// "Any other end tag" handling from 12.2.5.5 The rules for parsing tokens in foreign content
-// https://html.spec.whatwg.org/multipage/syntax.html#parsing-main-inforeign
-func (p *parser) inBodyEndTagOther(tagAtom a.Atom) {
- for i := len(p.oe) - 1; i >= 0; i-- {
- if p.oe[i].DataAtom == tagAtom {
- p.oe = p.oe[:i]
- break
- }
- if isSpecialElement(p.oe[i]) {
- break
- }
- }
-}
-
-// Section 12.2.5.4.8.
-func textIM(p *parser) bool {
- switch p.tok.Type {
- case ErrorToken:
- p.oe.pop()
- case TextToken:
- d := p.tok.Data
- if n := p.oe.top(); n.DataAtom == a.Textarea && n.FirstChild == nil {
- // Ignore a newline at the start of a