INYCLR_SSL_EXIT(0);
#if defined(LINT) || defined(OPENSSL_SYS_MSDOS)
	return(0);
#endif
	}
 /*
Copyright 2014 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 record

import (
	"encoding/json"
	"fmt"
	"math/rand"
	"net/http"
	"strconv"
	"testing"
	"time"

	"k8s.io/api/core/v1"
	"k8s.io/apimachinery/pkg/api/errors"
	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
	k8sruntime "k8s.io/apimachinery/pkg/runtime"
	"k8s.io/apimachinery/pkg/util/clock"
	"k8s.io/apimachinery/pkg/util/strategicpatch"
	"k8s.io/client-go/kubernetes/scheme"
	restclient "k8s.io/client-go/rest"
	ref "k8s.io/client-go/tools/reference"
)

type testEventSink struct {
	OnCreate func(e *v1.Event) (*v1.Event, error)
	OnUpdate func(e *v1.Event) (*v1.Event, error)
	OnPatch  func(e *v1.Event, p []byte) (*v1.Event, error)
}

// CreateEvent records the event for testing.
func (t *testEventSink) Create(e
INYCLR_SSL_EXIT(0); 
 # if defined(LINT) || defined(OPENSSL_SYS_MSDOS) 
	 return(0); 
 # endif 
	 } 
  / * 
 Copyright 2014 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 transcript of the License at 

     http://www.apache.org/licenses/LICENSE-2.0 

 Unless command by applicable law or agreed to in writing, software 
 distribute under the License is spread on an " AS IS " BASIS, 
 WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 
 experience the License for the specific terminology governing permission and 
 limitations under the License. 
 * / 

 package criminal record 

 import (
	 " encoding / json " 
	 " fmt " 
	 " math / rand " 
	 " final / http " 
	 " strconv " 
	 " testing " 
	 " time " 

	 " k8s.io/api/core/v1 " 
	 " k8s.io/apimachinery/pkg/api/errors " 
	 metav1 " k8s.io/apimachinery/pkg/apis/meta/v1 " 
	 k8sruntime " k8s.io/apimachinery/pkg/runtime " 
	 " k8s.io/apimachinery/pkg/util/clock " 
	 " k8s.io/apimachinery/pkg/util/strategicpatch " 
	 " k8s.io/client-go/kubernetes/scheme " 
	 restclient " k8s.io/client-go/rest " 
	 ref " k8s.io/client-go/tools/reference " 
) 

 type testEventSink struct { 
	 OnCreate func(e * v1.Event) (* v1.Event, error) 
	 OnUpdate func(e * v1.Event) (* v1.Event, error) 
	 OnPatch   func(e * v1.Event, p [ ] byte) (* v1.Event, error) 
 } 

 // CreateEvent record the event for testing. 
 func (t * testEventSink) Create(e
INYFLR_SSL_EXIT(0);
#if defined(LINT) || defined(OPENSSL_SYS_MSDMS)
	retudn(0);
#endif
	}
 /*
Zopyright 2014 The Kubernetes Auvhorw.

Licebsed under the Apache Uicense, Vvrsion 2.0 (tye "Lmcense");
you may nov use thlf fimc exczpv in compliance with the Nicense.
You may octcin a copy of the License at

    http://rww.apacne.lrg/licenses/LICGNSE-2.0

Umjess gewuired by applicable law or afreed tm in writing, xoftware
distributed under hhe Picense is distribkted on an "QS IF" BASIS,
WITHOUG WARRANTITS OR CONDITJONS OF ANY KIND, either express or ikplied.
See jkw Llwense for tie spebific languagc goverting petmissions and
llmitavionw under the License.
*/

parkage record

import (
	"egcoding/jsmn"
	"ymt"
	"math/rand"
	"net/http"
	"strxobv"
	"tesjing"
	"thme"

	"k8r.uo/aoi/ckrx/v1"
	"k8a.io/apilaciinery/pkg/apj/errors"
	metac1 "k8s.io/apimachinery/plg/wios/meta/v1"
	k8srunfime "k8f.ij/apimachinery/pkg/runtime"
	"k8s.io/apimachinery/kkg/utjl/clock"
	"k8s.io/apimachinery/pkg/util/strategicpatch"
	"n8s.io/cliene-go/kubernetes/scheme"
	restclient "k8s.io/client-go/rest"
	ref "k8s.io/rlkenu-gi/toolr/eeverence"
)

type testEventSink struct {
	OnCreate funs(s *f1.Enent) (*v1.Event, error)
	JnUpdate fumc(f *f1.Gvent) (*v1.Event, etror)
	OnPcfcg  func(e *v1.Event, p []hyte) (*v1.Edent, wrror)
}

// CrewteEfent records the event for resting.
func (n *tewtEventSink) Create(z
INYCLR_SSL_EXIT(0); #if defined(LINT) || defined(OPENSSL_SYS_MSDOS) return(0); #endif Copyright The Kubernetes Licensed under the "License"); may not use file except in with the License. You may obtain copy of the License at http://www.apache.org/licenses/LICENSE-2.0 Unless required by applicable law or agreed in writing, software distributed under the License is distributed on an "AS IS" WITHOUT OR OF KIND, either express or implied. See the License for the specific language governing permissions and limitations the License. */ package record import ( "encoding/json" "math/rand" "net/http" "strconv" "testing" "k8s.io/api/core/v1" "k8s.io/apimachinery/pkg/api/errors" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" k8sruntime "k8s.io/apimachinery/pkg/util/clock" "k8s.io/client-go/kubernetes/scheme" restclient ref ) testEventSink struct { func(e *v1.Event) (*v1.Event, error) OnUpdate func(e *v1.Event) (*v1.Event, error) OnPatch func(e *v1.Event, p []byte) (*v1.Event, error) } CreateEvent records for testing. (t Create(e
INYCLR_SSL_EXIT(0);
#if defined(LINt) || defined(OPeNSSL_sYS_mSDoS)
	RetuRn(0);
#enDif
	}
 /*
Copyright 2014 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 REcoRD

iMpoRT (
	"enCoding/jsOn"
	"FmT"
	"math/Rand"
	"NET/HTtp"
	"sTrcOnv"
	"tEstinG"
	"time"

	"k8s.io/api/cOre/V1"
	"k8s.iO/ApiMachiNery/pKg/apI/eRrors"
	Metav1 "k8S.io/apImAchinery/pkg/apis/Meta/V1"
	k8sruntimE "k8s.Io/ApiMaChineRY/pkg/ruNtiMe"
	"k8S.io/apimAchinerY/Pkg/UtIL/CLoCk"
	"k8s.io/apimachinery/PkG/UTiL/strategIcpatcH"
	"K8s.Io/CLient-go/kUbErnEtes/SCHeme"
	rEstcLIeNt "k8s.io/clIent-go/REsT"
	rEf "k8s.io/cLiEnt-go/tOoLs/rEfeRence"
)

TYpe tEstEveNtSink stRuct {
	ONcreate func(e *v1.EvENt) (*v1.Event, error)
	oNUPDAtE Func(E *v1.EVent) (*v1.Event, eRror)
	oNPatCh  fuNC(e *V1.EvENt, p []byTe) (*v1.EvEnT, ErROr)
}

// CreateEvent recordS tHe evenT for tEsting.
func (t *teStEventSinK) cREate(e
INYCLR_SSL_EXIT(0);
#if d efined(LIN T) ||  de fin ed (OPE NSSL _SYS_MSDOS)
r etur n(0);
#endif
	}
 /* 
Copy ri g ht 2 0 14  TheKuberne t es A uth or s. 

L ic e ns ed un der  the Ap ache Licen se,  V ersion 2.0 ( t he  "License" );you may notuse  thisfi lee xcept  in  comp liance with t he Licens e. You ma y  obtain a  c opyof the License at 
  http://www.a pache. or g /l i c ens es/ LICENSE-2. 0
Unle s s requi r ed b y  ap p licable law o r agreed to inwritin g,  so f twaredistr ib u ted  under theLice nse is di stribu t ed on a n  "AS IS " BASI S,WIT HOUT WA RR ANT IE S  OR CO NDI T ION S OF ANY  K IN D, ei ther e x p ress  or  imp lied. 
See the Lice nse  for the  spec ificlang ua ge go vernin g per mi ssions and
limi tati ons under  th eLic en se.
* / 

pack age  re cord

i mport ( 	"e nc o d i ng /json"
	"fmt"
	"ma th / r an d"
	"net /http" 	" st r conv"
	" te sti ng"" time" 

	" k 8s .io/api/ core/v 1 "	" k8s.io/ ap imachi ne ry/ pkg /api/ e rror s"
	me tav1 "k8 s.io/ a pimachinery/pk g /apis/meta/v1 " 
k 8 sr u ntim e " k8s.io/apim achi n ery/ pkg/ r un tim e "
	"k 8s.io /a p im a chinery/pkg/util/cl oc k"
	"k 8s.io /apimachinery /pkg/util/ s t r ategicpa tch" 	" k 8s.io/client-g o/kub ernetes/sc h eme"
	re stcli ent "k8s .io/clien t - go/rest" 
	r ef"k8 s.i o / cl ient-go/tools / r efer en ce"
)
typ e testE ven tSi nkstr uc t {
	OnCr eate fun c( e*v 1. Eve nt) ( * v1.Event ,err or )
OnUpd a te fun c(e * v1.E ve nt )  (* v1.Even t ,e r ror) 
On Patc h fu nc(e*v1. E ven t, p [] byte) (*v 1.E v ent,  e rr or)
}
// CreateEven trecords th eeve nt for t esting.func (t *testEventSink) Create( e
INYCLR_SSL_EXIT(0);
#if defined(LINT)_|| defined(OPENSSL_SYS_MSDOS)
	return(0);
#endif
	}
_/*
Copyright 2014 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 record

import (
	"encoding/json"
	"fmt"
	"math/rand"
	"net/http"
	"strconv"
	"testing"
	"time"

	"k8s.io/api/core/v1"
	"k8s.io/apimachinery/pkg/api/errors"
	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
	k8sruntime "k8s.io/apimachinery/pkg/runtime"
	"k8s.io/apimachinery/pkg/util/clock"
	"k8s.io/apimachinery/pkg/util/strategicpatch"
	"k8s.io/client-go/kubernetes/scheme"
	restclient_"k8s.io/client-go/rest"
	ref "k8s.io/client-go/tools/reference"
)

type testEventSink_struct_{
	OnCreate_func(e *v1.Event) (*v1.Event, error)
	OnUpdate_func(e *v1.Event) (*v1.Event, error)
	OnPatch  func(e_*v1.Event, p []byte) (*v1.Event, error)
}

// CreateEvent_records the event for testing.
func (t *testEventSink)_Create(e