Ai
1 Star 0 Fork 0

ryancartoon/sensu-go

加入 Gitee
与超过 1200万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
文件
克隆/下载
check.pb.go 121.10 KB
一键复制 编辑 原始数据 按行查看 历史
1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137213821392140214121422143214421452146214721482149215021512152215321542155215621572158215921602161216221632164216521662167216821692170217121722173217421752176217721782179218021812182218321842185218621872188218921902191219221932194219521962197219821992200220122022203220422052206220722082209221022112212221322142215221622172218221922202221222222232224222522262227222822292230223122322233223422352236223722382239224022412242224322442245224622472248224922502251225222532254225522562257225822592260226122622263226422652266226722682269227022712272227322742275227622772278227922802281228222832284228522862287228822892290229122922293229422952296229722982299230023012302230323042305230623072308230923102311231223132314231523162317231823192320232123222323232423252326232723282329233023312332233323342335233623372338233923402341234223432344234523462347234823492350235123522353235423552356235723582359236023612362236323642365236623672368236923702371237223732374237523762377237823792380238123822383238423852386238723882389239023912392239323942395239623972398239924002401240224032404240524062407240824092410241124122413241424152416241724182419242024212422242324242425242624272428242924302431243224332434243524362437243824392440244124422443244424452446244724482449245024512452245324542455245624572458245924602461246224632464246524662467246824692470247124722473247424752476247724782479248024812482248324842485248624872488248924902491249224932494249524962497249824992500250125022503250425052506250725082509251025112512251325142515251625172518251925202521252225232524252525262527252825292530253125322533253425352536253725382539254025412542254325442545254625472548254925502551255225532554255525562557255825592560256125622563256425652566256725682569257025712572257325742575257625772578257925802581258225832584258525862587258825892590259125922593259425952596259725982599260026012602260326042605260626072608260926102611261226132614261526162617261826192620262126222623262426252626262726282629263026312632263326342635263626372638263926402641264226432644264526462647264826492650265126522653265426552656265726582659266026612662266326642665266626672668266926702671267226732674267526762677267826792680268126822683268426852686268726882689269026912692269326942695269626972698269927002701270227032704270527062707270827092710271127122713271427152716271727182719272027212722272327242725272627272728272927302731273227332734273527362737273827392740274127422743274427452746274727482749275027512752275327542755275627572758275927602761276227632764276527662767276827692770277127722773277427752776277727782779278027812782278327842785278627872788278927902791279227932794279527962797279827992800280128022803280428052806280728082809281028112812281328142815281628172818281928202821282228232824282528262827282828292830283128322833283428352836283728382839284028412842284328442845284628472848284928502851285228532854285528562857285828592860286128622863286428652866286728682869287028712872287328742875287628772878287928802881288228832884288528862887288828892890289128922893289428952896289728982899290029012902290329042905290629072908290929102911291229132914291529162917291829192920292129222923292429252926292729282929293029312932293329342935293629372938293929402941294229432944294529462947294829492950295129522953295429552956295729582959296029612962296329642965296629672968296929702971297229732974297529762977297829792980298129822983298429852986298729882989299029912992299329942995299629972998299930003001300230033004300530063007300830093010301130123013301430153016301730183019302030213022302330243025302630273028302930303031303230333034303530363037303830393040304130423043304430453046304730483049305030513052305330543055305630573058305930603061306230633064306530663067306830693070307130723073307430753076307730783079308030813082308330843085308630873088308930903091309230933094309530963097309830993100310131023103310431053106310731083109311031113112311331143115311631173118311931203121312231233124312531263127312831293130313131323133313431353136313731383139314031413142314331443145314631473148314931503151315231533154315531563157315831593160316131623163316431653166316731683169317031713172317331743175317631773178317931803181318231833184318531863187318831893190319131923193319431953196319731983199320032013202320332043205320632073208320932103211321232133214321532163217321832193220322132223223322432253226322732283229323032313232323332343235323632373238323932403241324232433244324532463247324832493250325132523253325432553256325732583259326032613262326332643265326632673268326932703271327232733274327532763277327832793280328132823283328432853286328732883289329032913292329332943295329632973298329933003301330233033304330533063307330833093310331133123313331433153316331733183319332033213322332333243325332633273328332933303331333233333334333533363337333833393340334133423343334433453346334733483349335033513352335333543355335633573358335933603361336233633364336533663367336833693370337133723373337433753376337733783379338033813382338333843385338633873388338933903391339233933394339533963397339833993400340134023403340434053406340734083409341034113412341334143415341634173418341934203421342234233424342534263427342834293430343134323433343434353436343734383439344034413442344334443445344634473448344934503451345234533454345534563457345834593460346134623463346434653466346734683469347034713472347334743475347634773478347934803481348234833484348534863487348834893490349134923493349434953496349734983499350035013502350335043505350635073508350935103511351235133514351535163517351835193520352135223523352435253526352735283529353035313532353335343535353635373538353935403541354235433544354535463547354835493550355135523553355435553556355735583559356035613562356335643565356635673568356935703571357235733574357535763577357835793580358135823583358435853586358735883589359035913592359335943595359635973598359936003601360236033604360536063607360836093610361136123613361436153616361736183619362036213622362336243625362636273628362936303631363236333634363536363637363836393640364136423643364436453646364736483649365036513652365336543655365636573658365936603661366236633664366536663667366836693670367136723673367436753676367736783679368036813682368336843685368636873688368936903691369236933694369536963697369836993700370137023703370437053706370737083709371037113712371337143715371637173718371937203721372237233724372537263727372837293730373137323733373437353736373737383739374037413742374337443745374637473748374937503751375237533754375537563757375837593760376137623763376437653766376737683769377037713772377337743775377637773778377937803781378237833784378537863787378837893790379137923793379437953796379737983799380038013802380338043805380638073808380938103811381238133814381538163817381838193820382138223823382438253826382738283829383038313832383338343835383638373838383938403841384238433844384538463847384838493850385138523853385438553856385738583859386038613862386338643865386638673868386938703871387238733874387538763877387838793880388138823883388438853886388738883889389038913892389338943895389638973898389939003901390239033904390539063907390839093910391139123913391439153916391739183919392039213922392339243925392639273928392939303931393239333934393539363937393839393940394139423943394439453946394739483949395039513952395339543955395639573958395939603961396239633964396539663967396839693970397139723973397439753976397739783979398039813982398339843985398639873988398939903991399239933994399539963997399839994000400140024003400440054006400740084009401040114012401340144015401640174018401940204021402240234024402540264027402840294030403140324033403440354036403740384039404040414042404340444045404640474048404940504051405240534054405540564057405840594060406140624063406440654066406740684069407040714072407340744075407640774078407940804081408240834084408540864087408840894090409140924093409440954096409740984099410041014102410341044105410641074108410941104111411241134114411541164117411841194120412141224123412441254126412741284129413041314132413341344135413641374138413941404141414241434144414541464147414841494150415141524153415441554156415741584159416041614162416341644165416641674168416941704171417241734174417541764177417841794180418141824183418441854186418741884189419041914192419341944195419641974198419942004201420242034204420542064207420842094210421142124213421442154216421742184219422042214222422342244225422642274228422942304231423242334234423542364237423842394240424142424243424442454246424742484249425042514252425342544255425642574258425942604261426242634264426542664267426842694270427142724273427442754276427742784279428042814282428342844285428642874288428942904291429242934294429542964297429842994300430143024303430443054306430743084309431043114312431343144315431643174318431943204321432243234324432543264327432843294330433143324333433443354336433743384339434043414342434343444345434643474348434943504351435243534354435543564357435843594360436143624363436443654366436743684369437043714372437343744375437643774378437943804381438243834384438543864387438843894390439143924393439443954396439743984399440044014402440344044405440644074408440944104411441244134414441544164417441844194420442144224423442444254426442744284429443044314432443344344435443644374438443944404441444244434444444544464447444844494450445144524453445444554456445744584459446044614462446344644465446644674468446944704471447244734474447544764477447844794480448144824483448444854486448744884489449044914492449344944495449644974498449945004501450245034504450545064507450845094510451145124513451445154516451745184519452045214522452345244525452645274528452945304531453245334534453545364537453845394540454145424543454445454546454745484549455045514552455345544555455645574558455945604561456245634564456545664567456845694570457145724573457445754576457745784579458045814582458345844585458645874588458945904591459245934594459545964597459845994600460146024603460446054606460746084609461046114612461346144615461646174618461946204621462246234624462546264627462846294630463146324633463446354636463746384639464046414642464346444645464646474648464946504651465246534654465546564657465846594660466146624663466446654666466746684669467046714672467346744675467646774678467946804681468246834684468546864687468846894690469146924693469446954696469746984699470047014702470347044705470647074708470947104711471247134714471547164717471847194720472147224723472447254726472747284729473047314732473347344735473647374738473947404741474247434744474547464747474847494750475147524753475447554756475747584759476047614762476347644765476647674768476947704771477247734774477547764777477847794780478147824783478447854786478747884789479047914792479347944795479647974798479948004801480248034804480548064807480848094810481148124813481448154816481748184819482048214822482348244825482648274828482948304831483248334834483548364837483848394840484148424843484448454846484748484849485048514852485348544855485648574858485948604861486248634864486548664867486848694870487148724873487448754876487748784879488048814882488348844885488648874888488948904891489248934894489548964897489848994900490149024903490449054906490749084909491049114912491349144915491649174918491949204921492249234924492549264927492849294930493149324933493449354936493749384939
// Code generated by protoc-gen-gogo. DO NOT EDIT.
// source: check.proto
package v2
import proto "github.com/golang/protobuf/proto"
import fmt "fmt"
import math "math"
import _ "github.com/gogo/protobuf/gogoproto"
import bytes "bytes"
import github_com_golang_protobuf_proto "github.com/golang/protobuf/proto"
import encoding_binary "encoding/binary"
import io "io"
// Reference imports to suppress errors if they are not otherwise used.
var _ = proto.Marshal
var _ = fmt.Errorf
var _ = math.Inf
// This is a compile-time assertion to ensure that this generated file
// is compatible with the proto package it is being compiled against.
// A compilation error at this line likely means your copy of the
// proto package needs to be updated.
const _ = proto.ProtoPackageIsVersion2 // please upgrade the proto package
// A CheckRequest represents a request to execute a check
type CheckRequest struct {
// Config is the specification of a check.
Config *CheckConfig `protobuf:"bytes,1,opt,name=config" json:"config,omitempty"`
// Assets are a list of assets required to execute check.
Assets []Asset `protobuf:"bytes,2,rep,name=assets" json:"assets"`
// Hooks are a list of hooks to be executed after a check.
Hooks []HookConfig `protobuf:"bytes,3,rep,name=hooks" json:"hooks"`
// Issued describes the time in which the check request was issued
Issued int64 `protobuf:"varint,4,opt,name=Issued,proto3" json:"issued"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *CheckRequest) Reset() { *m = CheckRequest{} }
func (m *CheckRequest) String() string { return proto.CompactTextString(m) }
func (*CheckRequest) ProtoMessage() {}
func (*CheckRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_check_a2362dce6de70879, []int{0}
}
func (m *CheckRequest) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
}
func (m *CheckRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
if deterministic {
return xxx_messageInfo_CheckRequest.Marshal(b, m, deterministic)
} else {
b = b[:cap(b)]
n, err := m.MarshalTo(b)
if err != nil {
return nil, err
}
return b[:n], nil
}
}
func (dst *CheckRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_CheckRequest.Merge(dst, src)
}
func (m *CheckRequest) XXX_Size() int {
return m.Size()
}
func (m *CheckRequest) XXX_DiscardUnknown() {
xxx_messageInfo_CheckRequest.DiscardUnknown(m)
}
var xxx_messageInfo_CheckRequest proto.InternalMessageInfo
func (m *CheckRequest) GetConfig() *CheckConfig {
if m != nil {
return m.Config
}
return nil
}
func (m *CheckRequest) GetAssets() []Asset {
if m != nil {
return m.Assets
}
return nil
}
func (m *CheckRequest) GetHooks() []HookConfig {
if m != nil {
return m.Hooks
}
return nil
}
func (m *CheckRequest) GetIssued() int64 {
if m != nil {
return m.Issued
}
return 0
}
// A ProxyRequests represents a request to execute a proxy check
type ProxyRequests struct {
// EntityAttributes store serialized arbitrary JSON-encoded data to match
// entities in the registry.
EntityAttributes []string `protobuf:"bytes,1,rep,name=entity_attributes,json=entityAttributes" json:"entity_attributes"`
// Splay indicates if proxy check requests should be splayed, published
// evenly over a window of time.
Splay bool `protobuf:"varint,2,opt,name=splay,proto3" json:"splay"`
// SplayCoverage is the percentage used for proxy check request splay
// calculation.
SplayCoverage uint32 `protobuf:"varint,3,opt,name=splay_coverage,json=splayCoverage,proto3" json:"splay_coverage"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *ProxyRequests) Reset() { *m = ProxyRequests{} }
func (m *ProxyRequests) String() string { return proto.CompactTextString(m) }
func (*ProxyRequests) ProtoMessage() {}
func (*ProxyRequests) Descriptor() ([]byte, []int) {
return fileDescriptor_check_a2362dce6de70879, []int{1}
}
func (m *ProxyRequests) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
}
func (m *ProxyRequests) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
if deterministic {
return xxx_messageInfo_ProxyRequests.Marshal(b, m, deterministic)
} else {
b = b[:cap(b)]
n, err := m.MarshalTo(b)
if err != nil {
return nil, err
}
return b[:n], nil
}
}
func (dst *ProxyRequests) XXX_Merge(src proto.Message) {
xxx_messageInfo_ProxyRequests.Merge(dst, src)
}
func (m *ProxyRequests) XXX_Size() int {
return m.Size()
}
func (m *ProxyRequests) XXX_DiscardUnknown() {
xxx_messageInfo_ProxyRequests.DiscardUnknown(m)
}
var xxx_messageInfo_ProxyRequests proto.InternalMessageInfo
func (m *ProxyRequests) GetEntityAttributes() []string {
if m != nil {
return m.EntityAttributes
}
return nil
}
func (m *ProxyRequests) GetSplay() bool {
if m != nil {
return m.Splay
}
return false
}
func (m *ProxyRequests) GetSplayCoverage() uint32 {
if m != nil {
return m.SplayCoverage
}
return 0
}
// CheckConfig is the specification of a check.
type CheckConfig struct {
// Command is the command to be executed.
Command string `protobuf:"bytes,1,opt,name=command,proto3" json:"command,omitempty"`
// Handlers are the event handler for the check (incidents and/or metrics).
Handlers []string `protobuf:"bytes,3,rep,name=handlers" json:"handlers"`
// HighFlapThreshold is the flap detection high threshold (% state change)
// for the check. Sensu uses the same flap detection algorithm as Nagios.
HighFlapThreshold uint32 `protobuf:"varint,4,opt,name=high_flap_threshold,json=highFlapThreshold,proto3" json:"high_flap_threshold"`
// Interval is the interval, in seconds, at which the check should be run.
Interval uint32 `protobuf:"varint,5,opt,name=interval,proto3" json:"interval"`
// LowFlapThreshold is the flap detection low threshold (% state change) for
// the check. Sensu uses the same flap detection algorithm as Nagios.
LowFlapThreshold uint32 `protobuf:"varint,6,opt,name=low_flap_threshold,json=lowFlapThreshold,proto3" json:"low_flap_threshold"`
// Publish indicates if check requests are published for the check
Publish bool `protobuf:"varint,9,opt,name=publish,proto3" json:"publish"`
// RuntimeAssets are a list of assets required to execute check.
RuntimeAssets []string `protobuf:"bytes,10,rep,name=runtime_assets,json=runtimeAssets" json:"runtime_assets"`
// Subscriptions is the list of subscribers for the check.
Subscriptions []string `protobuf:"bytes,11,rep,name=subscriptions" json:"subscriptions"`
// ExtendedAttributes store serialized arbitrary JSON-encoded data
ExtendedAttributes []byte `protobuf:"bytes,12,opt,name=ExtendedAttributes,proto3" json:"-"`
// Sources indicates the name of the entity representing an external
// resource
ProxyEntityName string `protobuf:"bytes,13,opt,name=proxy_entity_name,json=proxyEntityName,proto3" json:"proxy_entity_name"`
// CheckHooks is the list of check hooks for the check
CheckHooks []HookList `protobuf:"bytes,14,rep,name=check_hooks,json=checkHooks" json:"check_hooks"`
// STDIN indicates if the check command accepts JSON via stdin from the
// agent
Stdin bool `protobuf:"varint,15,opt,name=stdin,proto3" json:"stdin"`
// Subdue represents one or more time windows when the check should be
// subdued.
Subdue *TimeWindowWhen `protobuf:"bytes,16,opt,name=subdue" json:"subdue"`
// Cron is the cron string at which the check should be run.
Cron string `protobuf:"bytes,17,opt,name=cron,proto3" json:"cron,omitempty"`
// TTL represents the length of time in seconds for which a check result is
// valid.
Ttl int64 `protobuf:"varint,18,opt,name=ttl,proto3" json:"ttl"`
// Timeout is the timeout, in seconds, at which the check has to run
Timeout uint32 `protobuf:"varint,19,opt,name=timeout,proto3" json:"timeout"`
// ProxyRequests represents a request to execute a proxy check
ProxyRequests *ProxyRequests `protobuf:"bytes,20,opt,name=proxy_requests,json=proxyRequests" json:"proxy_requests,omitempty"`
// RoundRobin enables round-robin scheduling if set true.
RoundRobin bool `protobuf:"varint,21,opt,name=round_robin,json=roundRobin,proto3" json:"round_robin"`
// OutputOutputMetricFormat is the metric protocol that the check's output
// will be expected to follow in order to be extracted.
OutputMetricFormat string `protobuf:"bytes,22,opt,name=output_metric_format,json=outputMetricFormat,proto3" json:"output_metric_format"`
// OutputOutputMetricHandlers is the list of event handlers that will
// respond to metrics that have been extracted from the check.
OutputMetricHandlers []string `protobuf:"bytes,23,rep,name=output_metric_handlers,json=outputMetricHandlers" json:"output_metric_handlers"`
// EnvVars is the list of environment variables to set for the check's
// execution environment.
EnvVars []string `protobuf:"bytes,24,rep,name=env_vars,json=envVars" json:"env_vars"`
// Metadata contains the name, namespace, labels and annotations of the
// check
ObjectMeta `protobuf:"bytes,26,opt,name=metadata,embedded=metadata" json:"metadata,omitempty"`
// MaxOutputSize is the maximum size in bytes that will be stored for check
// output. If check output is larger than MaxOutputSize, it will be
// truncated when stored. Filters, mutators, and handlers will still have
// access to the full check output at the time the event occurs.
MaxOutputSize int64 `protobuf:"varint,27,opt,name=max_output_size,json=maxOutputSize,proto3" json:"max_output_size,omitempty"`
// DiscardOutput causes agents to discard check output. No check output is
// written to the backend, but metrics extraction is still performed.
DiscardOutput bool `protobuf:"varint,28,opt,name=discard_output,json=discardOutput,proto3" json:"discard_output,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *CheckConfig) Reset() { *m = CheckConfig{} }
func (m *CheckConfig) String() string { return proto.CompactTextString(m) }
func (*CheckConfig) ProtoMessage() {}
func (*CheckConfig) Descriptor() ([]byte, []int) {
return fileDescriptor_check_a2362dce6de70879, []int{2}
}
func (m *CheckConfig) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
}
func (m *CheckConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
if deterministic {
return xxx_messageInfo_CheckConfig.Marshal(b, m, deterministic)
} else {
b = b[:cap(b)]
n, err := m.MarshalTo(b)
if err != nil {
return nil, err
}
return b[:n], nil
}
}
func (dst *CheckConfig) XXX_Merge(src proto.Message) {
xxx_messageInfo_CheckConfig.Merge(dst, src)
}
func (m *CheckConfig) XXX_Size() int {
return m.Size()
}
func (m *CheckConfig) XXX_DiscardUnknown() {
xxx_messageInfo_CheckConfig.DiscardUnknown(m)
}
var xxx_messageInfo_CheckConfig proto.InternalMessageInfo
// A Check is a check specification and optionally the results of the check's
// execution.
type Check struct {
// Command is the command to be executed.
Command string `protobuf:"bytes,1,opt,name=command,proto3" json:"command,omitempty"`
// Handlers are the event handler for the check (incidents and/or metrics).
Handlers []string `protobuf:"bytes,3,rep,name=handlers" json:"handlers"`
// HighFlapThreshold is the flap detection high threshold (% state change)
// for the check. Sensu uses the same flap detection algorithm as Nagios.
HighFlapThreshold uint32 `protobuf:"varint,4,opt,name=high_flap_threshold,json=highFlapThreshold,proto3" json:"high_flap_threshold"`
// Interval is the interval, in seconds, at which the check should be run.
Interval uint32 `protobuf:"varint,5,opt,name=interval,proto3" json:"interval"`
// LowFlapThreshold is the flap detection low threshold (% state change) for
// the check. Sensu uses the same flap detection algorithm as Nagios.
LowFlapThreshold uint32 `protobuf:"varint,6,opt,name=low_flap_threshold,json=lowFlapThreshold,proto3" json:"low_flap_threshold"`
// Publish indicates if check requests are published for the check
Publish bool `protobuf:"varint,9,opt,name=publish,proto3" json:"publish"`
// RuntimeAssets are a list of assets required to execute check.
RuntimeAssets []string `protobuf:"bytes,10,rep,name=runtime_assets,json=runtimeAssets" json:"runtime_assets"`
// Subscriptions is the list of subscribers for the check.
Subscriptions []string `protobuf:"bytes,11,rep,name=subscriptions" json:"subscriptions"`
// Sources indicates the name of the entity representing an external
// resource
ProxyEntityName string `protobuf:"bytes,13,opt,name=proxy_entity_name,json=proxyEntityName,proto3" json:"proxy_entity_name"`
// CheckHooks is the list of check hooks for the check
CheckHooks []HookList `protobuf:"bytes,14,rep,name=check_hooks,json=checkHooks" json:"check_hooks"`
// STDIN indicates if the check command accepts JSON via stdin from the
// agent
Stdin bool `protobuf:"varint,15,opt,name=stdin,proto3" json:"stdin"`
// Subdue represents one or more time windows when the check should be
// subdued.
Subdue *TimeWindowWhen `protobuf:"bytes,16,opt,name=subdue" json:"subdue"`
// Cron is the cron string at which the check should be run.
Cron string `protobuf:"bytes,17,opt,name=cron,proto3" json:"cron,omitempty"`
// TTL represents the length of time in seconds for which a check result is
// valid.
Ttl int64 `protobuf:"varint,18,opt,name=ttl,proto3" json:"ttl"`
// Timeout is the timeout, in seconds, at which the check has to run
Timeout uint32 `protobuf:"varint,19,opt,name=timeout,proto3" json:"timeout"`
// ProxyRequests represents a request to execute a proxy check
ProxyRequests *ProxyRequests `protobuf:"bytes,20,opt,name=proxy_requests,json=proxyRequests" json:"proxy_requests,omitempty"`
// RoundRobin enables round-robin scheduling if set true.
RoundRobin bool `protobuf:"varint,21,opt,name=round_robin,json=roundRobin,proto3" json:"round_robin"`
// Duration of execution
Duration float64 `protobuf:"fixed64,22,opt,name=duration,proto3" json:"duration,omitempty"`
// Executed describes the time in which the check request was executed
Executed int64 `protobuf:"varint,23,opt,name=executed,proto3" json:"executed"`
// History is the check state history.
History []CheckHistory `protobuf:"bytes,24,rep,name=history" json:"history"`
// Issued describes the time in which the check request was issued
Issued int64 `protobuf:"varint,25,opt,name=issued,proto3" json:"issued"`
// Output from the execution of Command
Output string `protobuf:"bytes,26,opt,name=output,proto3" json:"output"`
// State provides handlers with more information about the state change
State string `protobuf:"bytes,27,opt,name=state,proto3" json:"state,omitempty"`
// Status is the exit status code produced by the check
Status uint32 `protobuf:"varint,28,opt,name=status,proto3" json:"status"`
// TotalStateChange indicates the total state change percentage for the
// check's history
TotalStateChange uint32 `protobuf:"varint,29,opt,name=total_state_change,json=totalStateChange,proto3" json:"total_state_change"`
// LastOK displays last time this check was ok; if event status is 0 this is
// set to timestamp
LastOK int64 `protobuf:"varint,30,opt,name=last_ok,json=lastOk,proto3" json:"last_ok"`
// Occurrences indicates the number of times an event has occurred for a
// client/check pair with the same check status
Occurrences int64 `protobuf:"varint,31,opt,name=occurrences,proto3" json:"occurrences"`
// OccurrencesWatermark indicates the high water mark tracking number of
// occurrences at the current severity
OccurrencesWatermark int64 `protobuf:"varint,32,opt,name=occurrences_watermark,json=occurrencesWatermark,proto3" json:"occurrences_watermark"`
// Silenced is a list of silenced entry ids (subscription and check name)
Silenced []string `protobuf:"bytes,33,rep,name=silenced" json:"silenced,omitempty"`
// Hooks describes the results of multiple hooks; if event is associated to
// hook execution.
Hooks []*Hook `protobuf:"bytes,34,rep,name=hooks" json:"hooks,omitempty"`
// OutputOutputMetricFormat is the metric protocol that the check's output
// will be expected to follow in order to be extracted.
OutputMetricFormat string `protobuf:"bytes,35,opt,name=output_metric_format,json=outputMetricFormat,proto3" json:"output_metric_format"`
// OutputOutputMetricHandlers is the list of event handlers that will
// respond to metrics that have been extracted from the check.
OutputMetricHandlers []string `protobuf:"bytes,36,rep,name=output_metric_handlers,json=outputMetricHandlers" json:"output_metric_handlers"`
// EnvVars is the list of environment variables to set for the check's
// execution environment.
EnvVars []string `protobuf:"bytes,37,rep,name=env_vars,json=envVars" json:"env_vars"`
// Metadata contains the name, namespace, labels and annotations of the
// check
ObjectMeta `protobuf:"bytes,38,opt,name=metadata,embedded=metadata" json:"metadata,omitempty"`
// MaxOutputSize is the maximum size in bytes that will be stored for check
// output. If check output is larger than MaxOutputSize, it will be
// truncated when stored. Filters, mutators, and handlers will still have
// access to the full check output at the time the event occurs.
MaxOutputSize int64 `protobuf:"varint,39,opt,name=max_output_size,json=maxOutputSize,proto3" json:"max_output_size,omitempty"`
// DiscardOutput causes agents to discard check output. No check output is
// written to the backend, but metrics extraction is still performed.
DiscardOutput bool `protobuf:"varint,40,opt,name=discard_output,json=discardOutput,proto3" json:"discard_output,omitempty"`
// ExtendedAttributes store serialized arbitrary JSON-encoded data
ExtendedAttributes []byte `protobuf:"bytes,99,opt,name=ExtendedAttributes,proto3" json:"-"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *Check) Reset() { *m = Check{} }
func (m *Check) String() string { return proto.CompactTextString(m) }
func (*Check) ProtoMessage() {}
func (*Check) Descriptor() ([]byte, []int) {
return fileDescriptor_check_a2362dce6de70879, []int{3}
}
func (m *Check) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
}
func (m *Check) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
if deterministic {
return xxx_messageInfo_Check.Marshal(b, m, deterministic)
} else {
b = b[:cap(b)]
n, err := m.MarshalTo(b)
if err != nil {
return nil, err
}
return b[:n], nil
}
}
func (dst *Check) XXX_Merge(src proto.Message) {
xxx_messageInfo_Check.Merge(dst, src)
}
func (m *Check) XXX_Size() int {
return m.Size()
}
func (m *Check) XXX_DiscardUnknown() {
xxx_messageInfo_Check.DiscardUnknown(m)
}
var xxx_messageInfo_Check proto.InternalMessageInfo
// CheckHistory is a record of a check execution and its status
type CheckHistory struct {
// Status is the exit status code produced by the check.
Status uint32 `protobuf:"varint,1,opt,name=status,proto3" json:"status"`
// Executed describes the time in which the check request was executed
Executed int64 `protobuf:"varint,2,opt,name=executed,proto3" json:"executed"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *CheckHistory) Reset() { *m = CheckHistory{} }
func (m *CheckHistory) String() string { return proto.CompactTextString(m) }
func (*CheckHistory) ProtoMessage() {}
func (*CheckHistory) Descriptor() ([]byte, []int) {
return fileDescriptor_check_a2362dce6de70879, []int{4}
}
func (m *CheckHistory) XXX_Unmarshal(b []byte) error {
return m.Unmarshal(b)
}
func (m *CheckHistory) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
if deterministic {
return xxx_messageInfo_CheckHistory.Marshal(b, m, deterministic)
} else {
b = b[:cap(b)]
n, err := m.MarshalTo(b)
if err != nil {
return nil, err
}
return b[:n], nil
}
}
func (dst *CheckHistory) XXX_Merge(src proto.Message) {
xxx_messageInfo_CheckHistory.Merge(dst, src)
}
func (m *CheckHistory) XXX_Size() int {
return m.Size()
}
func (m *CheckHistory) XXX_DiscardUnknown() {
xxx_messageInfo_CheckHistory.DiscardUnknown(m)
}
var xxx_messageInfo_CheckHistory proto.InternalMessageInfo
func (m *CheckHistory) GetStatus() uint32 {
if m != nil {
return m.Status
}
return 0
}
func (m *CheckHistory) GetExecuted() int64 {
if m != nil {
return m.Executed
}
return 0
}
func init() {
proto.RegisterType((*CheckRequest)(nil), "sensu.core.v2.CheckRequest")
proto.RegisterType((*ProxyRequests)(nil), "sensu.core.v2.ProxyRequests")
proto.RegisterType((*CheckConfig)(nil), "sensu.core.v2.CheckConfig")
proto.RegisterType((*Check)(nil), "sensu.core.v2.Check")
proto.RegisterType((*CheckHistory)(nil), "sensu.core.v2.CheckHistory")
}
func (this *CheckRequest) Equal(that interface{}) bool {
if that == nil {
return this == nil
}
that1, ok := that.(*CheckRequest)
if !ok {
that2, ok := that.(CheckRequest)
if ok {
that1 = &that2
} else {
return false
}
}
if that1 == nil {
return this == nil
} else if this == nil {
return false
}
if !this.Config.Equal(that1.Config) {
return false
}
if len(this.Assets) != len(that1.Assets) {
return false
}
for i := range this.Assets {
if !this.Assets[i].Equal(&that1.Assets[i]) {
return false
}
}
if len(this.Hooks) != len(that1.Hooks) {
return false
}
for i := range this.Hooks {
if !this.Hooks[i].Equal(&that1.Hooks[i]) {
return false
}
}
if this.Issued != that1.Issued {
return false
}
if !bytes.Equal(this.XXX_unrecognized, that1.XXX_unrecognized) {
return false
}
return true
}
func (this *ProxyRequests) Equal(that interface{}) bool {
if that == nil {
return this == nil
}
that1, ok := that.(*ProxyRequests)
if !ok {
that2, ok := that.(ProxyRequests)
if ok {
that1 = &that2
} else {
return false
}
}
if that1 == nil {
return this == nil
} else if this == nil {
return false
}
if len(this.EntityAttributes) != len(that1.EntityAttributes) {
return false
}
for i := range this.EntityAttributes {
if this.EntityAttributes[i] != that1.EntityAttributes[i] {
return false
}
}
if this.Splay != that1.Splay {
return false
}
if this.SplayCoverage != that1.SplayCoverage {
return false
}
if !bytes.Equal(this.XXX_unrecognized, that1.XXX_unrecognized) {
return false
}
return true
}
func (this *CheckConfig) Equal(that interface{}) bool {
if that == nil {
return this == nil
}
that1, ok := that.(*CheckConfig)
if !ok {
that2, ok := that.(CheckConfig)
if ok {
that1 = &that2
} else {
return false
}
}
if that1 == nil {
return this == nil
} else if this == nil {
return false
}
if this.Command != that1.Command {
return false
}
if len(this.Handlers) != len(that1.Handlers) {
return false
}
for i := range this.Handlers {
if this.Handlers[i] != that1.Handlers[i] {
return false
}
}
if this.HighFlapThreshold != that1.HighFlapThreshold {
return false
}
if this.Interval != that1.Interval {
return false
}
if this.LowFlapThreshold != that1.LowFlapThreshold {
return false
}
if this.Publish != that1.Publish {
return false
}
if len(this.RuntimeAssets) != len(that1.RuntimeAssets) {
return false
}
for i := range this.RuntimeAssets {
if this.RuntimeAssets[i] != that1.RuntimeAssets[i] {
return false
}
}
if len(this.Subscriptions) != len(that1.Subscriptions) {
return false
}
for i := range this.Subscriptions {
if this.Subscriptions[i] != that1.Subscriptions[i] {
return false
}
}
if !bytes.Equal(this.ExtendedAttributes, that1.ExtendedAttributes) {
return false
}
if this.ProxyEntityName != that1.ProxyEntityName {
return false
}
if len(this.CheckHooks) != len(that1.CheckHooks) {
return false
}
for i := range this.CheckHooks {
if !this.CheckHooks[i].Equal(&that1.CheckHooks[i]) {
return false
}
}
if this.Stdin != that1.Stdin {
return false
}
if !this.Subdue.Equal(that1.Subdue) {
return false
}
if this.Cron != that1.Cron {
return false
}
if this.Ttl != that1.Ttl {
return false
}
if this.Timeout != that1.Timeout {
return false
}
if !this.ProxyRequests.Equal(that1.ProxyRequests) {
return false
}
if this.RoundRobin != that1.RoundRobin {
return false
}
if this.OutputMetricFormat != that1.OutputMetricFormat {
return false
}
if len(this.OutputMetricHandlers) != len(that1.OutputMetricHandlers) {
return false
}
for i := range this.OutputMetricHandlers {
if this.OutputMetricHandlers[i] != that1.OutputMetricHandlers[i] {
return false
}
}
if len(this.EnvVars) != len(that1.EnvVars) {
return false
}
for i := range this.EnvVars {
if this.EnvVars[i] != that1.EnvVars[i] {
return false
}
}
if !this.ObjectMeta.Equal(&that1.ObjectMeta) {
return false
}
if this.MaxOutputSize != that1.MaxOutputSize {
return false
}
if this.DiscardOutput != that1.DiscardOutput {
return false
}
if !bytes.Equal(this.XXX_unrecognized, that1.XXX_unrecognized) {
return false
}
return true
}
func (this *Check) Equal(that interface{}) bool {
if that == nil {
return this == nil
}
that1, ok := that.(*Check)
if !ok {
that2, ok := that.(Check)
if ok {
that1 = &that2
} else {
return false
}
}
if that1 == nil {
return this == nil
} else if this == nil {
return false
}
if this.Command != that1.Command {
return false
}
if len(this.Handlers) != len(that1.Handlers) {
return false
}
for i := range this.Handlers {
if this.Handlers[i] != that1.Handlers[i] {
return false
}
}
if this.HighFlapThreshold != that1.HighFlapThreshold {
return false
}
if this.Interval != that1.Interval {
return false
}
if this.LowFlapThreshold != that1.LowFlapThreshold {
return false
}
if this.Publish != that1.Publish {
return false
}
if len(this.RuntimeAssets) != len(that1.RuntimeAssets) {
return false
}
for i := range this.RuntimeAssets {
if this.RuntimeAssets[i] != that1.RuntimeAssets[i] {
return false
}
}
if len(this.Subscriptions) != len(that1.Subscriptions) {
return false
}
for i := range this.Subscriptions {
if this.Subscriptions[i] != that1.Subscriptions[i] {
return false
}
}
if this.ProxyEntityName != that1.ProxyEntityName {
return false
}
if len(this.CheckHooks) != len(that1.CheckHooks) {
return false
}
for i := range this.CheckHooks {
if !this.CheckHooks[i].Equal(&that1.CheckHooks[i]) {
return false
}
}
if this.Stdin != that1.Stdin {
return false
}
if !this.Subdue.Equal(that1.Subdue) {
return false
}
if this.Cron != that1.Cron {
return false
}
if this.Ttl != that1.Ttl {
return false
}
if this.Timeout != that1.Timeout {
return false
}
if !this.ProxyRequests.Equal(that1.ProxyRequests) {
return false
}
if this.RoundRobin != that1.RoundRobin {
return false
}
if this.Duration != that1.Duration {
return false
}
if this.Executed != that1.Executed {
return false
}
if len(this.History) != len(that1.History) {
return false
}
for i := range this.History {
if !this.History[i].Equal(&that1.History[i]) {
return false
}
}
if this.Issued != that1.Issued {
return false
}
if this.Output != that1.Output {
return false
}
if this.State != that1.State {
return false
}
if this.Status != that1.Status {
return false
}
if this.TotalStateChange != that1.TotalStateChange {
return false
}
if this.LastOK != that1.LastOK {
return false
}
if this.Occurrences != that1.Occurrences {
return false
}
if this.OccurrencesWatermark != that1.OccurrencesWatermark {
return false
}
if len(this.Silenced) != len(that1.Silenced) {
return false
}
for i := range this.Silenced {
if this.Silenced[i] != that1.Silenced[i] {
return false
}
}
if len(this.Hooks) != len(that1.Hooks) {
return false
}
for i := range this.Hooks {
if !this.Hooks[i].Equal(that1.Hooks[i]) {
return false
}
}
if this.OutputMetricFormat != that1.OutputMetricFormat {
return false
}
if len(this.OutputMetricHandlers) != len(that1.OutputMetricHandlers) {
return false
}
for i := range this.OutputMetricHandlers {
if this.OutputMetricHandlers[i] != that1.OutputMetricHandlers[i] {
return false
}
}
if len(this.EnvVars) != len(that1.EnvVars) {
return false
}
for i := range this.EnvVars {
if this.EnvVars[i] != that1.EnvVars[i] {
return false
}
}
if !this.ObjectMeta.Equal(&that1.ObjectMeta) {
return false
}
if this.MaxOutputSize != that1.MaxOutputSize {
return false
}
if this.DiscardOutput != that1.DiscardOutput {
return false
}
if !bytes.Equal(this.ExtendedAttributes, that1.ExtendedAttributes) {
return false
}
if !bytes.Equal(this.XXX_unrecognized, that1.XXX_unrecognized) {
return false
}
return true
}
func (this *CheckHistory) Equal(that interface{}) bool {
if that == nil {
return this == nil
}
that1, ok := that.(*CheckHistory)
if !ok {
that2, ok := that.(CheckHistory)
if ok {
that1 = &that2
} else {
return false
}
}
if that1 == nil {
return this == nil
} else if this == nil {
return false
}
if this.Status != that1.Status {
return false
}
if this.Executed != that1.Executed {
return false
}
if !bytes.Equal(this.XXX_unrecognized, that1.XXX_unrecognized) {
return false
}
return true
}
type CheckConfigFace interface {
Proto() github_com_golang_protobuf_proto.Message
GetCommand() string
GetHandlers() []string
GetHighFlapThreshold() uint32
GetInterval() uint32
GetLowFlapThreshold() uint32
GetPublish() bool
GetRuntimeAssets() []string
GetSubscriptions() []string
GetExtendedAttributes() []byte
GetProxyEntityName() string
GetCheckHooks() []HookList
GetStdin() bool
GetSubdue() *TimeWindowWhen
GetCron() string
GetTtl() int64
GetTimeout() uint32
GetProxyRequests() *ProxyRequests
GetRoundRobin() bool
GetOutputMetricFormat() string
GetOutputMetricHandlers() []string
GetEnvVars() []string
GetObjectMeta() ObjectMeta
GetMaxOutputSize() int64
GetDiscardOutput() bool
}
func (this *CheckConfig) Proto() github_com_golang_protobuf_proto.Message {
return this
}
func (this *CheckConfig) TestProto() github_com_golang_protobuf_proto.Message {
return NewCheckConfigFromFace(this)
}
func (this *CheckConfig) GetCommand() string {
return this.Command
}
func (this *CheckConfig) GetHandlers() []string {
return this.Handlers
}
func (this *CheckConfig) GetHighFlapThreshold() uint32 {
return this.HighFlapThreshold
}
func (this *CheckConfig) GetInterval() uint32 {
return this.Interval
}
func (this *CheckConfig) GetLowFlapThreshold() uint32 {
return this.LowFlapThreshold
}
func (this *CheckConfig) GetPublish() bool {
return this.Publish
}
func (this *CheckConfig) GetRuntimeAssets() []string {
return this.RuntimeAssets
}
func (this *CheckConfig) GetSubscriptions() []string {
return this.Subscriptions
}
func (this *CheckConfig) GetExtendedAttributes() []byte {
return this.ExtendedAttributes
}
func (this *CheckConfig) GetProxyEntityName() string {
return this.ProxyEntityName
}
func (this *CheckConfig) GetCheckHooks() []HookList {
return this.CheckHooks
}
func (this *CheckConfig) GetStdin() bool {
return this.Stdin
}
func (this *CheckConfig) GetSubdue() *TimeWindowWhen {
return this.Subdue
}
func (this *CheckConfig) GetCron() string {
return this.Cron
}
func (this *CheckConfig) GetTtl() int64 {
return this.Ttl
}
func (this *CheckConfig) GetTimeout() uint32 {
return this.Timeout
}
func (this *CheckConfig) GetProxyRequests() *ProxyRequests {
return this.ProxyRequests
}
func (this *CheckConfig) GetRoundRobin() bool {
return this.RoundRobin
}
func (this *CheckConfig) GetOutputMetricFormat() string {
return this.OutputMetricFormat
}
func (this *CheckConfig) GetOutputMetricHandlers() []string {
return this.OutputMetricHandlers
}
func (this *CheckConfig) GetEnvVars() []string {
return this.EnvVars
}
func (this *CheckConfig) GetObjectMeta() ObjectMeta {
return this.ObjectMeta
}
func (this *CheckConfig) GetMaxOutputSize() int64 {
return this.MaxOutputSize
}
func (this *CheckConfig) GetDiscardOutput() bool {
return this.DiscardOutput
}
func NewCheckConfigFromFace(that CheckConfigFace) *CheckConfig {
this := &CheckConfig{}
this.Command = that.GetCommand()
this.Handlers = that.GetHandlers()
this.HighFlapThreshold = that.GetHighFlapThreshold()
this.Interval = that.GetInterval()
this.LowFlapThreshold = that.GetLowFlapThreshold()
this.Publish = that.GetPublish()
this.RuntimeAssets = that.GetRuntimeAssets()
this.Subscriptions = that.GetSubscriptions()
this.ExtendedAttributes = that.GetExtendedAttributes()
this.ProxyEntityName = that.GetProxyEntityName()
this.CheckHooks = that.GetCheckHooks()
this.Stdin = that.GetStdin()
this.Subdue = that.GetSubdue()
this.Cron = that.GetCron()
this.Ttl = that.GetTtl()
this.Timeout = that.GetTimeout()
this.ProxyRequests = that.GetProxyRequests()
this.RoundRobin = that.GetRoundRobin()
this.OutputMetricFormat = that.GetOutputMetricFormat()
this.OutputMetricHandlers = that.GetOutputMetricHandlers()
this.EnvVars = that.GetEnvVars()
this.ObjectMeta = that.GetObjectMeta()
this.MaxOutputSize = that.GetMaxOutputSize()
this.DiscardOutput = that.GetDiscardOutput()
return this
}
type CheckFace interface {
Proto() github_com_golang_protobuf_proto.Message
GetCommand() string
GetHandlers() []string
GetHighFlapThreshold() uint32
GetInterval() uint32
GetLowFlapThreshold() uint32
GetPublish() bool
GetRuntimeAssets() []string
GetSubscriptions() []string
GetProxyEntityName() string
GetCheckHooks() []HookList
GetStdin() bool
GetSubdue() *TimeWindowWhen
GetCron() string
GetTtl() int64
GetTimeout() uint32
GetProxyRequests() *ProxyRequests
GetRoundRobin() bool
GetDuration() float64
GetExecuted() int64
GetHistory() []CheckHistory
GetIssued() int64
GetOutput() string
GetState() string
GetStatus() uint32
GetTotalStateChange() uint32
GetLastOK() int64
GetOccurrences() int64
GetOccurrencesWatermark() int64
GetSilenced() []string
GetHooks() []*Hook
GetOutputMetricFormat() string
GetOutputMetricHandlers() []string
GetEnvVars() []string
GetObjectMeta() ObjectMeta
GetMaxOutputSize() int64
GetDiscardOutput() bool
GetExtendedAttributes() []byte
}
func (this *Check) Proto() github_com_golang_protobuf_proto.Message {
return this
}
func (this *Check) TestProto() github_com_golang_protobuf_proto.Message {
return NewCheckFromFace(this)
}
func (this *Check) GetCommand() string {
return this.Command
}
func (this *Check) GetHandlers() []string {
return this.Handlers
}
func (this *Check) GetHighFlapThreshold() uint32 {
return this.HighFlapThreshold
}
func (this *Check) GetInterval() uint32 {
return this.Interval
}
func (this *Check) GetLowFlapThreshold() uint32 {
return this.LowFlapThreshold
}
func (this *Check) GetPublish() bool {
return this.Publish
}
func (this *Check) GetRuntimeAssets() []string {
return this.RuntimeAssets
}
func (this *Check) GetSubscriptions() []string {
return this.Subscriptions
}
func (this *Check) GetProxyEntityName() string {
return this.ProxyEntityName
}
func (this *Check) GetCheckHooks() []HookList {
return this.CheckHooks
}
func (this *Check) GetStdin() bool {
return this.Stdin
}
func (this *Check) GetSubdue() *TimeWindowWhen {
return this.Subdue
}
func (this *Check) GetCron() string {
return this.Cron
}
func (this *Check) GetTtl() int64 {
return this.Ttl
}
func (this *Check) GetTimeout() uint32 {
return this.Timeout
}
func (this *Check) GetProxyRequests() *ProxyRequests {
return this.ProxyRequests
}
func (this *Check) GetRoundRobin() bool {
return this.RoundRobin
}
func (this *Check) GetDuration() float64 {
return this.Duration
}
func (this *Check) GetExecuted() int64 {
return this.Executed
}
func (this *Check) GetHistory() []CheckHistory {
return this.History
}
func (this *Check) GetIssued() int64 {
return this.Issued
}
func (this *Check) GetOutput() string {
return this.Output
}
func (this *Check) GetState() string {
return this.State
}
func (this *Check) GetStatus() uint32 {
return this.Status
}
func (this *Check) GetTotalStateChange() uint32 {
return this.TotalStateChange
}
func (this *Check) GetLastOK() int64 {
return this.LastOK
}
func (this *Check) GetOccurrences() int64 {
return this.Occurrences
}
func (this *Check) GetOccurrencesWatermark() int64 {
return this.OccurrencesWatermark
}
func (this *Check) GetSilenced() []string {
return this.Silenced
}
func (this *Check) GetHooks() []*Hook {
return this.Hooks
}
func (this *Check) GetOutputMetricFormat() string {
return this.OutputMetricFormat
}
func (this *Check) GetOutputMetricHandlers() []string {
return this.OutputMetricHandlers
}
func (this *Check) GetEnvVars() []string {
return this.EnvVars
}
func (this *Check) GetObjectMeta() ObjectMeta {
return this.ObjectMeta
}
func (this *Check) GetMaxOutputSize() int64 {
return this.MaxOutputSize
}
func (this *Check) GetDiscardOutput() bool {
return this.DiscardOutput
}
func (this *Check) GetExtendedAttributes() []byte {
return this.ExtendedAttributes
}
func NewCheckFromFace(that CheckFace) *Check {
this := &Check{}
this.Command = that.GetCommand()
this.Handlers = that.GetHandlers()
this.HighFlapThreshold = that.GetHighFlapThreshold()
this.Interval = that.GetInterval()
this.LowFlapThreshold = that.GetLowFlapThreshold()
this.Publish = that.GetPublish()
this.RuntimeAssets = that.GetRuntimeAssets()
this.Subscriptions = that.GetSubscriptions()
this.ProxyEntityName = that.GetProxyEntityName()
this.CheckHooks = that.GetCheckHooks()
this.Stdin = that.GetStdin()
this.Subdue = that.GetSubdue()
this.Cron = that.GetCron()
this.Ttl = that.GetTtl()
this.Timeout = that.GetTimeout()
this.ProxyRequests = that.GetProxyRequests()
this.RoundRobin = that.GetRoundRobin()
this.Duration = that.GetDuration()
this.Executed = that.GetExecuted()
this.History = that.GetHistory()
this.Issued = that.GetIssued()
this.Output = that.GetOutput()
this.State = that.GetState()
this.Status = that.GetStatus()
this.TotalStateChange = that.GetTotalStateChange()
this.LastOK = that.GetLastOK()
this.Occurrences = that.GetOccurrences()
this.OccurrencesWatermark = that.GetOccurrencesWatermark()
this.Silenced = that.GetSilenced()
this.Hooks = that.GetHooks()
this.OutputMetricFormat = that.GetOutputMetricFormat()
this.OutputMetricHandlers = that.GetOutputMetricHandlers()
this.EnvVars = that.GetEnvVars()
this.ObjectMeta = that.GetObjectMeta()
this.MaxOutputSize = that.GetMaxOutputSize()
this.DiscardOutput = that.GetDiscardOutput()
this.ExtendedAttributes = that.GetExtendedAttributes()
return this
}
func (m *CheckRequest) Marshal() (dAtA []byte, err error) {
size := m.Size()
dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA)
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *CheckRequest) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
if m.Config != nil {
dAtA[i] = 0xa
i++
i = encodeVarintCheck(dAtA, i, uint64(m.Config.Size()))
n1, err := m.Config.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n1
}
if len(m.Assets) > 0 {
for _, msg := range m.Assets {
dAtA[i] = 0x12
i++
i = encodeVarintCheck(dAtA, i, uint64(msg.Size()))
n, err := msg.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n
}
}
if len(m.Hooks) > 0 {
for _, msg := range m.Hooks {
dAtA[i] = 0x1a
i++
i = encodeVarintCheck(dAtA, i, uint64(msg.Size()))
n, err := msg.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n
}
}
if m.Issued != 0 {
dAtA[i] = 0x20
i++
i = encodeVarintCheck(dAtA, i, uint64(m.Issued))
}
if m.XXX_unrecognized != nil {
i += copy(dAtA[i:], m.XXX_unrecognized)
}
return i, nil
}
func (m *ProxyRequests) Marshal() (dAtA []byte, err error) {
size := m.Size()
dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA)
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *ProxyRequests) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
if len(m.EntityAttributes) > 0 {
for _, s := range m.EntityAttributes {
dAtA[i] = 0xa
i++
l = len(s)
for l >= 1<<7 {
dAtA[i] = uint8(uint64(l)&0x7f | 0x80)
l >>= 7
i++
}
dAtA[i] = uint8(l)
i++
i += copy(dAtA[i:], s)
}
}
if m.Splay {
dAtA[i] = 0x10
i++
if m.Splay {
dAtA[i] = 1
} else {
dAtA[i] = 0
}
i++
}
if m.SplayCoverage != 0 {
dAtA[i] = 0x18
i++
i = encodeVarintCheck(dAtA, i, uint64(m.SplayCoverage))
}
if m.XXX_unrecognized != nil {
i += copy(dAtA[i:], m.XXX_unrecognized)
}
return i, nil
}
func (m *CheckConfig) Marshal() (dAtA []byte, err error) {
size := m.Size()
dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA)
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *CheckConfig) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
if len(m.Command) > 0 {
dAtA[i] = 0xa
i++
i = encodeVarintCheck(dAtA, i, uint64(len(m.Command)))
i += copy(dAtA[i:], m.Command)
}
if len(m.Handlers) > 0 {
for _, s := range m.Handlers {
dAtA[i] = 0x1a
i++
l = len(s)
for l >= 1<<7 {
dAtA[i] = uint8(uint64(l)&0x7f | 0x80)
l >>= 7
i++
}
dAtA[i] = uint8(l)
i++
i += copy(dAtA[i:], s)
}
}
if m.HighFlapThreshold != 0 {
dAtA[i] = 0x20
i++
i = encodeVarintCheck(dAtA, i, uint64(m.HighFlapThreshold))
}
if m.Interval != 0 {
dAtA[i] = 0x28
i++
i = encodeVarintCheck(dAtA, i, uint64(m.Interval))
}
if m.LowFlapThreshold != 0 {
dAtA[i] = 0x30
i++
i = encodeVarintCheck(dAtA, i, uint64(m.LowFlapThreshold))
}
if m.Publish {
dAtA[i] = 0x48
i++
if m.Publish {
dAtA[i] = 1
} else {
dAtA[i] = 0
}
i++
}
if len(m.RuntimeAssets) > 0 {
for _, s := range m.RuntimeAssets {
dAtA[i] = 0x52
i++
l = len(s)
for l >= 1<<7 {
dAtA[i] = uint8(uint64(l)&0x7f | 0x80)
l >>= 7
i++
}
dAtA[i] = uint8(l)
i++
i += copy(dAtA[i:], s)
}
}
if len(m.Subscriptions) > 0 {
for _, s := range m.Subscriptions {
dAtA[i] = 0x5a
i++
l = len(s)
for l >= 1<<7 {
dAtA[i] = uint8(uint64(l)&0x7f | 0x80)
l >>= 7
i++
}
dAtA[i] = uint8(l)
i++
i += copy(dAtA[i:], s)
}
}
if len(m.ExtendedAttributes) > 0 {
dAtA[i] = 0x62
i++
i = encodeVarintCheck(dAtA, i, uint64(len(m.ExtendedAttributes)))
i += copy(dAtA[i:], m.ExtendedAttributes)
}
if len(m.ProxyEntityName) > 0 {
dAtA[i] = 0x6a
i++
i = encodeVarintCheck(dAtA, i, uint64(len(m.ProxyEntityName)))
i += copy(dAtA[i:], m.ProxyEntityName)
}
if len(m.CheckHooks) > 0 {
for _, msg := range m.CheckHooks {
dAtA[i] = 0x72
i++
i = encodeVarintCheck(dAtA, i, uint64(msg.Size()))
n, err := msg.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n
}
}
if m.Stdin {
dAtA[i] = 0x78
i++
if m.Stdin {
dAtA[i] = 1
} else {
dAtA[i] = 0
}
i++
}
if m.Subdue != nil {
dAtA[i] = 0x82
i++
dAtA[i] = 0x1
i++
i = encodeVarintCheck(dAtA, i, uint64(m.Subdue.Size()))
n2, err := m.Subdue.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n2
}
if len(m.Cron) > 0 {
dAtA[i] = 0x8a
i++
dAtA[i] = 0x1
i++
i = encodeVarintCheck(dAtA, i, uint64(len(m.Cron)))
i += copy(dAtA[i:], m.Cron)
}
if m.Ttl != 0 {
dAtA[i] = 0x90
i++
dAtA[i] = 0x1
i++
i = encodeVarintCheck(dAtA, i, uint64(m.Ttl))
}
if m.Timeout != 0 {
dAtA[i] = 0x98
i++
dAtA[i] = 0x1
i++
i = encodeVarintCheck(dAtA, i, uint64(m.Timeout))
}
if m.ProxyRequests != nil {
dAtA[i] = 0xa2
i++
dAtA[i] = 0x1
i++
i = encodeVarintCheck(dAtA, i, uint64(m.ProxyRequests.Size()))
n3, err := m.ProxyRequests.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n3
}
if m.RoundRobin {
dAtA[i] = 0xa8
i++
dAtA[i] = 0x1
i++
if m.RoundRobin {
dAtA[i] = 1
} else {
dAtA[i] = 0
}
i++
}
if len(m.OutputMetricFormat) > 0 {
dAtA[i] = 0xb2
i++
dAtA[i] = 0x1
i++
i = encodeVarintCheck(dAtA, i, uint64(len(m.OutputMetricFormat)))
i += copy(dAtA[i:], m.OutputMetricFormat)
}
if len(m.OutputMetricHandlers) > 0 {
for _, s := range m.OutputMetricHandlers {
dAtA[i] = 0xba
i++
dAtA[i] = 0x1
i++
l = len(s)
for l >= 1<<7 {
dAtA[i] = uint8(uint64(l)&0x7f | 0x80)
l >>= 7
i++
}
dAtA[i] = uint8(l)
i++
i += copy(dAtA[i:], s)
}
}
if len(m.EnvVars) > 0 {
for _, s := range m.EnvVars {
dAtA[i] = 0xc2
i++
dAtA[i] = 0x1
i++
l = len(s)
for l >= 1<<7 {
dAtA[i] = uint8(uint64(l)&0x7f | 0x80)
l >>= 7
i++
}
dAtA[i] = uint8(l)
i++
i += copy(dAtA[i:], s)
}
}
dAtA[i] = 0xd2
i++
dAtA[i] = 0x1
i++
i = encodeVarintCheck(dAtA, i, uint64(m.ObjectMeta.Size()))
n4, err := m.ObjectMeta.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n4
if m.MaxOutputSize != 0 {
dAtA[i] = 0xd8
i++
dAtA[i] = 0x1
i++
i = encodeVarintCheck(dAtA, i, uint64(m.MaxOutputSize))
}
if m.DiscardOutput {
dAtA[i] = 0xe0
i++
dAtA[i] = 0x1
i++
if m.DiscardOutput {
dAtA[i] = 1
} else {
dAtA[i] = 0
}
i++
}
if m.XXX_unrecognized != nil {
i += copy(dAtA[i:], m.XXX_unrecognized)
}
return i, nil
}
func (m *Check) Marshal() (dAtA []byte, err error) {
size := m.Size()
dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA)
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *Check) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
if len(m.Command) > 0 {
dAtA[i] = 0xa
i++
i = encodeVarintCheck(dAtA, i, uint64(len(m.Command)))
i += copy(dAtA[i:], m.Command)
}
if len(m.Handlers) > 0 {
for _, s := range m.Handlers {
dAtA[i] = 0x1a
i++
l = len(s)
for l >= 1<<7 {
dAtA[i] = uint8(uint64(l)&0x7f | 0x80)
l >>= 7
i++
}
dAtA[i] = uint8(l)
i++
i += copy(dAtA[i:], s)
}
}
if m.HighFlapThreshold != 0 {
dAtA[i] = 0x20
i++
i = encodeVarintCheck(dAtA, i, uint64(m.HighFlapThreshold))
}
if m.Interval != 0 {
dAtA[i] = 0x28
i++
i = encodeVarintCheck(dAtA, i, uint64(m.Interval))
}
if m.LowFlapThreshold != 0 {
dAtA[i] = 0x30
i++
i = encodeVarintCheck(dAtA, i, uint64(m.LowFlapThreshold))
}
if m.Publish {
dAtA[i] = 0x48
i++
if m.Publish {
dAtA[i] = 1
} else {
dAtA[i] = 0
}
i++
}
if len(m.RuntimeAssets) > 0 {
for _, s := range m.RuntimeAssets {
dAtA[i] = 0x52
i++
l = len(s)
for l >= 1<<7 {
dAtA[i] = uint8(uint64(l)&0x7f | 0x80)
l >>= 7
i++
}
dAtA[i] = uint8(l)
i++
i += copy(dAtA[i:], s)
}
}
if len(m.Subscriptions) > 0 {
for _, s := range m.Subscriptions {
dAtA[i] = 0x5a
i++
l = len(s)
for l >= 1<<7 {
dAtA[i] = uint8(uint64(l)&0x7f | 0x80)
l >>= 7
i++
}
dAtA[i] = uint8(l)
i++
i += copy(dAtA[i:], s)
}
}
if len(m.ProxyEntityName) > 0 {
dAtA[i] = 0x6a
i++
i = encodeVarintCheck(dAtA, i, uint64(len(m.ProxyEntityName)))
i += copy(dAtA[i:], m.ProxyEntityName)
}
if len(m.CheckHooks) > 0 {
for _, msg := range m.CheckHooks {
dAtA[i] = 0x72
i++
i = encodeVarintCheck(dAtA, i, uint64(msg.Size()))
n, err := msg.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n
}
}
if m.Stdin {
dAtA[i] = 0x78
i++
if m.Stdin {
dAtA[i] = 1
} else {
dAtA[i] = 0
}
i++
}
if m.Subdue != nil {
dAtA[i] = 0x82
i++
dAtA[i] = 0x1
i++
i = encodeVarintCheck(dAtA, i, uint64(m.Subdue.Size()))
n5, err := m.Subdue.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n5
}
if len(m.Cron) > 0 {
dAtA[i] = 0x8a
i++
dAtA[i] = 0x1
i++
i = encodeVarintCheck(dAtA, i, uint64(len(m.Cron)))
i += copy(dAtA[i:], m.Cron)
}
if m.Ttl != 0 {
dAtA[i] = 0x90
i++
dAtA[i] = 0x1
i++
i = encodeVarintCheck(dAtA, i, uint64(m.Ttl))
}
if m.Timeout != 0 {
dAtA[i] = 0x98
i++
dAtA[i] = 0x1
i++
i = encodeVarintCheck(dAtA, i, uint64(m.Timeout))
}
if m.ProxyRequests != nil {
dAtA[i] = 0xa2
i++
dAtA[i] = 0x1
i++
i = encodeVarintCheck(dAtA, i, uint64(m.ProxyRequests.Size()))
n6, err := m.ProxyRequests.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n6
}
if m.RoundRobin {
dAtA[i] = 0xa8
i++
dAtA[i] = 0x1
i++
if m.RoundRobin {
dAtA[i] = 1
} else {
dAtA[i] = 0
}
i++
}
if m.Duration != 0 {
dAtA[i] = 0xb1
i++
dAtA[i] = 0x1
i++
encoding_binary.LittleEndian.PutUint64(dAtA[i:], uint64(math.Float64bits(float64(m.Duration))))
i += 8
}
if m.Executed != 0 {
dAtA[i] = 0xb8
i++
dAtA[i] = 0x1
i++
i = encodeVarintCheck(dAtA, i, uint64(m.Executed))
}
if len(m.History) > 0 {
for _, msg := range m.History {
dAtA[i] = 0xc2
i++
dAtA[i] = 0x1
i++
i = encodeVarintCheck(dAtA, i, uint64(msg.Size()))
n, err := msg.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n
}
}
if m.Issued != 0 {
dAtA[i] = 0xc8
i++
dAtA[i] = 0x1
i++
i = encodeVarintCheck(dAtA, i, uint64(m.Issued))
}
if len(m.Output) > 0 {
dAtA[i] = 0xd2
i++
dAtA[i] = 0x1
i++
i = encodeVarintCheck(dAtA, i, uint64(len(m.Output)))
i += copy(dAtA[i:], m.Output)
}
if len(m.State) > 0 {
dAtA[i] = 0xda
i++
dAtA[i] = 0x1
i++
i = encodeVarintCheck(dAtA, i, uint64(len(m.State)))
i += copy(dAtA[i:], m.State)
}
if m.Status != 0 {
dAtA[i] = 0xe0
i++
dAtA[i] = 0x1
i++
i = encodeVarintCheck(dAtA, i, uint64(m.Status))
}
if m.TotalStateChange != 0 {
dAtA[i] = 0xe8
i++
dAtA[i] = 0x1
i++
i = encodeVarintCheck(dAtA, i, uint64(m.TotalStateChange))
}
if m.LastOK != 0 {
dAtA[i] = 0xf0
i++
dAtA[i] = 0x1
i++
i = encodeVarintCheck(dAtA, i, uint64(m.LastOK))
}
if m.Occurrences != 0 {
dAtA[i] = 0xf8
i++
dAtA[i] = 0x1
i++
i = encodeVarintCheck(dAtA, i, uint64(m.Occurrences))
}
if m.OccurrencesWatermark != 0 {
dAtA[i] = 0x80
i++
dAtA[i] = 0x2
i++
i = encodeVarintCheck(dAtA, i, uint64(m.OccurrencesWatermark))
}
if len(m.Silenced) > 0 {
for _, s := range m.Silenced {
dAtA[i] = 0x8a
i++
dAtA[i] = 0x2
i++
l = len(s)
for l >= 1<<7 {
dAtA[i] = uint8(uint64(l)&0x7f | 0x80)
l >>= 7
i++
}
dAtA[i] = uint8(l)
i++
i += copy(dAtA[i:], s)
}
}
if len(m.Hooks) > 0 {
for _, msg := range m.Hooks {
dAtA[i] = 0x92
i++
dAtA[i] = 0x2
i++
i = encodeVarintCheck(dAtA, i, uint64(msg.Size()))
n, err := msg.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n
}
}
if len(m.OutputMetricFormat) > 0 {
dAtA[i] = 0x9a
i++
dAtA[i] = 0x2
i++
i = encodeVarintCheck(dAtA, i, uint64(len(m.OutputMetricFormat)))
i += copy(dAtA[i:], m.OutputMetricFormat)
}
if len(m.OutputMetricHandlers) > 0 {
for _, s := range m.OutputMetricHandlers {
dAtA[i] = 0xa2
i++
dAtA[i] = 0x2
i++
l = len(s)
for l >= 1<<7 {
dAtA[i] = uint8(uint64(l)&0x7f | 0x80)
l >>= 7
i++
}
dAtA[i] = uint8(l)
i++
i += copy(dAtA[i:], s)
}
}
if len(m.EnvVars) > 0 {
for _, s := range m.EnvVars {
dAtA[i] = 0xaa
i++
dAtA[i] = 0x2
i++
l = len(s)
for l >= 1<<7 {
dAtA[i] = uint8(uint64(l)&0x7f | 0x80)
l >>= 7
i++
}
dAtA[i] = uint8(l)
i++
i += copy(dAtA[i:], s)
}
}
dAtA[i] = 0xb2
i++
dAtA[i] = 0x2
i++
i = encodeVarintCheck(dAtA, i, uint64(m.ObjectMeta.Size()))
n7, err := m.ObjectMeta.MarshalTo(dAtA[i:])
if err != nil {
return 0, err
}
i += n7
if m.MaxOutputSize != 0 {
dAtA[i] = 0xb8
i++
dAtA[i] = 0x2
i++
i = encodeVarintCheck(dAtA, i, uint64(m.MaxOutputSize))
}
if m.DiscardOutput {
dAtA[i] = 0xc0
i++
dAtA[i] = 0x2
i++
if m.DiscardOutput {
dAtA[i] = 1
} else {
dAtA[i] = 0
}
i++
}
if len(m.ExtendedAttributes) > 0 {
dAtA[i] = 0x9a
i++
dAtA[i] = 0x6
i++
i = encodeVarintCheck(dAtA, i, uint64(len(m.ExtendedAttributes)))
i += copy(dAtA[i:], m.ExtendedAttributes)
}
if m.XXX_unrecognized != nil {
i += copy(dAtA[i:], m.XXX_unrecognized)
}
return i, nil
}
func (m *CheckHistory) Marshal() (dAtA []byte, err error) {
size := m.Size()
dAtA = make([]byte, size)
n, err := m.MarshalTo(dAtA)
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *CheckHistory) MarshalTo(dAtA []byte) (int, error) {
var i int
_ = i
var l int
_ = l
if m.Status != 0 {
dAtA[i] = 0x8
i++
i = encodeVarintCheck(dAtA, i, uint64(m.Status))
}
if m.Executed != 0 {
dAtA[i] = 0x10
i++
i = encodeVarintCheck(dAtA, i, uint64(m.Executed))
}
if m.XXX_unrecognized != nil {
i += copy(dAtA[i:], m.XXX_unrecognized)
}
return i, nil
}
func encodeVarintCheck(dAtA []byte, offset int, v uint64) int {
for v >= 1<<7 {
dAtA[offset] = uint8(v&0x7f | 0x80)
v >>= 7
offset++
}
dAtA[offset] = uint8(v)
return offset + 1
}
func NewPopulatedCheckRequest(r randyCheck, easy bool) *CheckRequest {
this := &CheckRequest{}
if r.Intn(10) != 0 {
this.Config = NewPopulatedCheckConfig(r, easy)
}
if r.Intn(10) != 0 {
v1 := r.Intn(5)
this.Assets = make([]Asset, v1)
for i := 0; i < v1; i++ {
v2 := NewPopulatedAsset(r, easy)
this.Assets[i] = *v2
}
}
if r.Intn(10) != 0 {
v3 := r.Intn(5)
this.Hooks = make([]HookConfig, v3)
for i := 0; i < v3; i++ {
v4 := NewPopulatedHookConfig(r, easy)
this.Hooks[i] = *v4
}
}
this.Issued = int64(r.Int63())
if r.Intn(2) == 0 {
this.Issued *= -1
}
if !easy && r.Intn(10) != 0 {
this.XXX_unrecognized = randUnrecognizedCheck(r, 5)
}
return this
}
func NewPopulatedProxyRequests(r randyCheck, easy bool) *ProxyRequests {
this := &ProxyRequests{}
v5 := r.Intn(10)
this.EntityAttributes = make([]string, v5)
for i := 0; i < v5; i++ {
this.EntityAttributes[i] = string(randStringCheck(r))
}
this.Splay = bool(bool(r.Intn(2) == 0))
this.SplayCoverage = uint32(r.Uint32())
if !easy && r.Intn(10) != 0 {
this.XXX_unrecognized = randUnrecognizedCheck(r, 4)
}
return this
}
func NewPopulatedCheckConfig(r randyCheck, easy bool) *CheckConfig {
this := &CheckConfig{}
this.Command = string(randStringCheck(r))
v6 := r.Intn(10)
this.Handlers = make([]string, v6)
for i := 0; i < v6; i++ {
this.Handlers[i] = string(randStringCheck(r))
}
this.HighFlapThreshold = uint32(r.Uint32())
this.Interval = uint32(r.Uint32())
this.LowFlapThreshold = uint32(r.Uint32())
this.Publish = bool(bool(r.Intn(2) == 0))
v7 := r.Intn(10)
this.RuntimeAssets = make([]string, v7)
for i := 0; i < v7; i++ {
this.RuntimeAssets[i] = string(randStringCheck(r))
}
v8 := r.Intn(10)
this.Subscriptions = make([]string, v8)
for i := 0; i < v8; i++ {
this.Subscriptions[i] = string(randStringCheck(r))
}
v9 := r.Intn(100)
this.ExtendedAttributes = make([]byte, v9)
for i := 0; i < v9; i++ {
this.ExtendedAttributes[i] = byte(r.Intn(256))
}
this.ProxyEntityName = string(randStringCheck(r))
if r.Intn(10) != 0 {
v10 := r.Intn(5)
this.CheckHooks = make([]HookList, v10)
for i := 0; i < v10; i++ {
v11 := NewPopulatedHookList(r, easy)
this.CheckHooks[i] = *v11
}
}
this.Stdin = bool(bool(r.Intn(2) == 0))
if r.Intn(10) != 0 {
this.Subdue = NewPopulatedTimeWindowWhen(r, easy)
}
this.Cron = string(randStringCheck(r))
this.Ttl = int64(r.Int63())
if r.Intn(2) == 0 {
this.Ttl *= -1
}
this.Timeout = uint32(r.Uint32())
if r.Intn(10) != 0 {
this.ProxyRequests = NewPopulatedProxyRequests(r, easy)
}
this.RoundRobin = bool(bool(r.Intn(2) == 0))
this.OutputMetricFormat = string(randStringCheck(r))
v12 := r.Intn(10)
this.OutputMetricHandlers = make([]string, v12)
for i := 0; i < v12; i++ {
this.OutputMetricHandlers[i] = string(randStringCheck(r))
}
v13 := r.Intn(10)
this.EnvVars = make([]string, v13)
for i := 0; i < v13; i++ {
this.EnvVars[i] = string(randStringCheck(r))
}
v14 := NewPopulatedObjectMeta(r, easy)
this.ObjectMeta = *v14
this.MaxOutputSize = int64(r.Int63())
if r.Intn(2) == 0 {
this.MaxOutputSize *= -1
}
this.DiscardOutput = bool(bool(r.Intn(2) == 0))
if !easy && r.Intn(10) != 0 {
this.XXX_unrecognized = randUnrecognizedCheck(r, 29)
}
return this
}
func NewPopulatedCheck(r randyCheck, easy bool) *Check {
this := &Check{}
this.Command = string(randStringCheck(r))
v15 := r.Intn(10)
this.Handlers = make([]string, v15)
for i := 0; i < v15; i++ {
this.Handlers[i] = string(randStringCheck(r))
}
this.HighFlapThreshold = uint32(r.Uint32())
this.Interval = uint32(r.Uint32())
this.LowFlapThreshold = uint32(r.Uint32())
this.Publish = bool(bool(r.Intn(2) == 0))
v16 := r.Intn(10)
this.RuntimeAssets = make([]string, v16)
for i := 0; i < v16; i++ {
this.RuntimeAssets[i] = string(randStringCheck(r))
}
v17 := r.Intn(10)
this.Subscriptions = make([]string, v17)
for i := 0; i < v17; i++ {
this.Subscriptions[i] = string(randStringCheck(r))
}
this.ProxyEntityName = string(randStringCheck(r))
if r.Intn(10) != 0 {
v18 := r.Intn(5)
this.CheckHooks = make([]HookList, v18)
for i := 0; i < v18; i++ {
v19 := NewPopulatedHookList(r, easy)
this.CheckHooks[i] = *v19
}
}
this.Stdin = bool(bool(r.Intn(2) == 0))
if r.Intn(10) != 0 {
this.Subdue = NewPopulatedTimeWindowWhen(r, easy)
}
this.Cron = string(randStringCheck(r))
this.Ttl = int64(r.Int63())
if r.Intn(2) == 0 {
this.Ttl *= -1
}
this.Timeout = uint32(r.Uint32())
if r.Intn(10) != 0 {
this.ProxyRequests = NewPopulatedProxyRequests(r, easy)
}
this.RoundRobin = bool(bool(r.Intn(2) == 0))
this.Duration = float64(r.Float64())
if r.Intn(2) == 0 {
this.Duration *= -1
}
this.Executed = int64(r.Int63())
if r.Intn(2) == 0 {
this.Executed *= -1
}
if r.Intn(10) != 0 {
v20 := r.Intn(5)
this.History = make([]CheckHistory, v20)
for i := 0; i < v20; i++ {
v21 := NewPopulatedCheckHistory(r, easy)
this.History[i] = *v21
}
}
this.Issued = int64(r.Int63())
if r.Intn(2) == 0 {
this.Issued *= -1
}
this.Output = string(randStringCheck(r))
this.State = string(randStringCheck(r))
this.Status = uint32(r.Uint32())
this.TotalStateChange = uint32(r.Uint32())
this.LastOK = int64(r.Int63())
if r.Intn(2) == 0 {
this.LastOK *= -1
}
this.Occurrences = int64(r.Int63())
if r.Intn(2) == 0 {
this.Occurrences *= -1
}
this.OccurrencesWatermark = int64(r.Int63())
if r.Intn(2) == 0 {
this.OccurrencesWatermark *= -1
}
v22 := r.Intn(10)
this.Silenced = make([]string, v22)
for i := 0; i < v22; i++ {
this.Silenced[i] = string(randStringCheck(r))
}
if r.Intn(10) != 0 {
v23 := r.Intn(5)
this.Hooks = make([]*Hook, v23)
for i := 0; i < v23; i++ {
this.Hooks[i] = NewPopulatedHook(r, easy)
}
}
this.OutputMetricFormat = string(randStringCheck(r))
v24 := r.Intn(10)
this.OutputMetricHandlers = make([]string, v24)
for i := 0; i < v24; i++ {
this.OutputMetricHandlers[i] = string(randStringCheck(r))
}
v25 := r.Intn(10)
this.EnvVars = make([]string, v25)
for i := 0; i < v25; i++ {
this.EnvVars[i] = string(randStringCheck(r))
}
v26 := NewPopulatedObjectMeta(r, easy)
this.ObjectMeta = *v26
this.MaxOutputSize = int64(r.Int63())
if r.Intn(2) == 0 {
this.MaxOutputSize *= -1
}
this.DiscardOutput = bool(bool(r.Intn(2) == 0))
v27 := r.Intn(100)
this.ExtendedAttributes = make([]byte, v27)
for i := 0; i < v27; i++ {
this.ExtendedAttributes[i] = byte(r.Intn(256))
}
if !easy && r.Intn(10) != 0 {
this.XXX_unrecognized = randUnrecognizedCheck(r, 100)
}
return this
}
func NewPopulatedCheckHistory(r randyCheck, easy bool) *CheckHistory {
this := &CheckHistory{}
this.Status = uint32(r.Uint32())
this.Executed = int64(r.Int63())
if r.Intn(2) == 0 {
this.Executed *= -1
}
if !easy && r.Intn(10) != 0 {
this.XXX_unrecognized = randUnrecognizedCheck(r, 3)
}
return this
}
type randyCheck interface {
Float32() float32
Float64() float64
Int63() int64
Int31() int32
Uint32() uint32
Intn(n int) int
}
func randUTF8RuneCheck(r randyCheck) rune {
ru := r.Intn(62)
if ru < 10 {
return rune(ru + 48)
} else if ru < 36 {
return rune(ru + 55)
}
return rune(ru + 61)
}
func randStringCheck(r randyCheck) string {
v28 := r.Intn(100)
tmps := make([]rune, v28)
for i := 0; i < v28; i++ {
tmps[i] = randUTF8RuneCheck(r)
}
return string(tmps)
}
func randUnrecognizedCheck(r randyCheck, maxFieldNumber int) (dAtA []byte) {
l := r.Intn(5)
for i := 0; i < l; i++ {
wire := r.Intn(4)
if wire == 3 {
wire = 5
}
fieldNumber := maxFieldNumber + r.Intn(100)
dAtA = randFieldCheck(dAtA, r, fieldNumber, wire)
}
return dAtA
}
func randFieldCheck(dAtA []byte, r randyCheck, fieldNumber int, wire int) []byte {
key := uint32(fieldNumber)<<3 | uint32(wire)
switch wire {
case 0:
dAtA = encodeVarintPopulateCheck(dAtA, uint64(key))
v29 := r.Int63()
if r.Intn(2) == 0 {
v29 *= -1
}
dAtA = encodeVarintPopulateCheck(dAtA, uint64(v29))
case 1:
dAtA = encodeVarintPopulateCheck(dAtA, uint64(key))
dAtA = append(dAtA, byte(r.Intn(256)), byte(r.Intn(256)), byte(r.Intn(256)), byte(r.Intn(256)), byte(r.Intn(256)), byte(r.Intn(256)), byte(r.Intn(256)), byte(r.Intn(256)))
case 2:
dAtA = encodeVarintPopulateCheck(dAtA, uint64(key))
ll := r.Intn(100)
dAtA = encodeVarintPopulateCheck(dAtA, uint64(ll))
for j := 0; j < ll; j++ {
dAtA = append(dAtA, byte(r.Intn(256)))
}
default:
dAtA = encodeVarintPopulateCheck(dAtA, uint64(key))
dAtA = append(dAtA, byte(r.Intn(256)), byte(r.Intn(256)), byte(r.Intn(256)), byte(r.Intn(256)))
}
return dAtA
}
func encodeVarintPopulateCheck(dAtA []byte, v uint64) []byte {
for v >= 1<<7 {
dAtA = append(dAtA, uint8(uint64(v)&0x7f|0x80))
v >>= 7
}
dAtA = append(dAtA, uint8(v))
return dAtA
}
func (m *CheckRequest) Size() (n int) {
var l int
_ = l
if m.Config != nil {
l = m.Config.Size()
n += 1 + l + sovCheck(uint64(l))
}
if len(m.Assets) > 0 {
for _, e := range m.Assets {
l = e.Size()
n += 1 + l + sovCheck(uint64(l))
}
}
if len(m.Hooks) > 0 {
for _, e := range m.Hooks {
l = e.Size()
n += 1 + l + sovCheck(uint64(l))
}
}
if m.Issued != 0 {
n += 1 + sovCheck(uint64(m.Issued))
}
if m.XXX_unrecognized != nil {
n += len(m.XXX_unrecognized)
}
return n
}
func (m *ProxyRequests) Size() (n int) {
var l int
_ = l
if len(m.EntityAttributes) > 0 {
for _, s := range m.EntityAttributes {
l = len(s)
n += 1 + l + sovCheck(uint64(l))
}
}
if m.Splay {
n += 2
}
if m.SplayCoverage != 0 {
n += 1 + sovCheck(uint64(m.SplayCoverage))
}
if m.XXX_unrecognized != nil {
n += len(m.XXX_unrecognized)
}
return n
}
func (m *CheckConfig) Size() (n int) {
var l int
_ = l
l = len(m.Command)
if l > 0 {
n += 1 + l + sovCheck(uint64(l))
}
if len(m.Handlers) > 0 {
for _, s := range m.Handlers {
l = len(s)
n += 1 + l + sovCheck(uint64(l))
}
}
if m.HighFlapThreshold != 0 {
n += 1 + sovCheck(uint64(m.HighFlapThreshold))
}
if m.Interval != 0 {
n += 1 + sovCheck(uint64(m.Interval))
}
if m.LowFlapThreshold != 0 {
n += 1 + sovCheck(uint64(m.LowFlapThreshold))
}
if m.Publish {
n += 2
}
if len(m.RuntimeAssets) > 0 {
for _, s := range m.RuntimeAssets {
l = len(s)
n += 1 + l + sovCheck(uint64(l))
}
}
if len(m.Subscriptions) > 0 {
for _, s := range m.Subscriptions {
l = len(s)
n += 1 + l + sovCheck(uint64(l))
}
}
l = len(m.ExtendedAttributes)
if l > 0 {
n += 1 + l + sovCheck(uint64(l))
}
l = len(m.ProxyEntityName)
if l > 0 {
n += 1 + l + sovCheck(uint64(l))
}
if len(m.CheckHooks) > 0 {
for _, e := range m.CheckHooks {
l = e.Size()
n += 1 + l + sovCheck(uint64(l))
}
}
if m.Stdin {
n += 2
}
if m.Subdue != nil {
l = m.Subdue.Size()
n += 2 + l + sovCheck(uint64(l))
}
l = len(m.Cron)
if l > 0 {
n += 2 + l + sovCheck(uint64(l))
}
if m.Ttl != 0 {
n += 2 + sovCheck(uint64(m.Ttl))
}
if m.Timeout != 0 {
n += 2 + sovCheck(uint64(m.Timeout))
}
if m.ProxyRequests != nil {
l = m.ProxyRequests.Size()
n += 2 + l + sovCheck(uint64(l))
}
if m.RoundRobin {
n += 3
}
l = len(m.OutputMetricFormat)
if l > 0 {
n += 2 + l + sovCheck(uint64(l))
}
if len(m.OutputMetricHandlers) > 0 {
for _, s := range m.OutputMetricHandlers {
l = len(s)
n += 2 + l + sovCheck(uint64(l))
}
}
if len(m.EnvVars) > 0 {
for _, s := range m.EnvVars {
l = len(s)
n += 2 + l + sovCheck(uint64(l))
}
}
l = m.ObjectMeta.Size()
n += 2 + l + sovCheck(uint64(l))
if m.MaxOutputSize != 0 {
n += 2 + sovCheck(uint64(m.MaxOutputSize))
}
if m.DiscardOutput {
n += 3
}
if m.XXX_unrecognized != nil {
n += len(m.XXX_unrecognized)
}
return n
}
func (m *Check) Size() (n int) {
var l int
_ = l
l = len(m.Command)
if l > 0 {
n += 1 + l + sovCheck(uint64(l))
}
if len(m.Handlers) > 0 {
for _, s := range m.Handlers {
l = len(s)
n += 1 + l + sovCheck(uint64(l))
}
}
if m.HighFlapThreshold != 0 {
n += 1 + sovCheck(uint64(m.HighFlapThreshold))
}
if m.Interval != 0 {
n += 1 + sovCheck(uint64(m.Interval))
}
if m.LowFlapThreshold != 0 {
n += 1 + sovCheck(uint64(m.LowFlapThreshold))
}
if m.Publish {
n += 2
}
if len(m.RuntimeAssets) > 0 {
for _, s := range m.RuntimeAssets {
l = len(s)
n += 1 + l + sovCheck(uint64(l))
}
}
if len(m.Subscriptions) > 0 {
for _, s := range m.Subscriptions {
l = len(s)
n += 1 + l + sovCheck(uint64(l))
}
}
l = len(m.ProxyEntityName)
if l > 0 {
n += 1 + l + sovCheck(uint64(l))
}
if len(m.CheckHooks) > 0 {
for _, e := range m.CheckHooks {
l = e.Size()
n += 1 + l + sovCheck(uint64(l))
}
}
if m.Stdin {
n += 2
}
if m.Subdue != nil {
l = m.Subdue.Size()
n += 2 + l + sovCheck(uint64(l))
}
l = len(m.Cron)
if l > 0 {
n += 2 + l + sovCheck(uint64(l))
}
if m.Ttl != 0 {
n += 2 + sovCheck(uint64(m.Ttl))
}
if m.Timeout != 0 {
n += 2 + sovCheck(uint64(m.Timeout))
}
if m.ProxyRequests != nil {
l = m.ProxyRequests.Size()
n += 2 + l + sovCheck(uint64(l))
}
if m.RoundRobin {
n += 3
}
if m.Duration != 0 {
n += 10
}
if m.Executed != 0 {
n += 2 + sovCheck(uint64(m.Executed))
}
if len(m.History) > 0 {
for _, e := range m.History {
l = e.Size()
n += 2 + l + sovCheck(uint64(l))
}
}
if m.Issued != 0 {
n += 2 + sovCheck(uint64(m.Issued))
}
l = len(m.Output)
if l > 0 {
n += 2 + l + sovCheck(uint64(l))
}
l = len(m.State)
if l > 0 {
n += 2 + l + sovCheck(uint64(l))
}
if m.Status != 0 {
n += 2 + sovCheck(uint64(m.Status))
}
if m.TotalStateChange != 0 {
n += 2 + sovCheck(uint64(m.TotalStateChange))
}
if m.LastOK != 0 {
n += 2 + sovCheck(uint64(m.LastOK))
}
if m.Occurrences != 0 {
n += 2 + sovCheck(uint64(m.Occurrences))
}
if m.OccurrencesWatermark != 0 {
n += 2 + sovCheck(uint64(m.OccurrencesWatermark))
}
if len(m.Silenced) > 0 {
for _, s := range m.Silenced {
l = len(s)
n += 2 + l + sovCheck(uint64(l))
}
}
if len(m.Hooks) > 0 {
for _, e := range m.Hooks {
l = e.Size()
n += 2 + l + sovCheck(uint64(l))
}
}
l = len(m.OutputMetricFormat)
if l > 0 {
n += 2 + l + sovCheck(uint64(l))
}
if len(m.OutputMetricHandlers) > 0 {
for _, s := range m.OutputMetricHandlers {
l = len(s)
n += 2 + l + sovCheck(uint64(l))
}
}
if len(m.EnvVars) > 0 {
for _, s := range m.EnvVars {
l = len(s)
n += 2 + l + sovCheck(uint64(l))
}
}
l = m.ObjectMeta.Size()
n += 2 + l + sovCheck(uint64(l))
if m.MaxOutputSize != 0 {
n += 2 + sovCheck(uint64(m.MaxOutputSize))
}
if m.DiscardOutput {
n += 3
}
l = len(m.ExtendedAttributes)
if l > 0 {
n += 2 + l + sovCheck(uint64(l))
}
if m.XXX_unrecognized != nil {
n += len(m.XXX_unrecognized)
}
return n
}
func (m *CheckHistory) Size() (n int) {
var l int
_ = l
if m.Status != 0 {
n += 1 + sovCheck(uint64(m.Status))
}
if m.Executed != 0 {
n += 1 + sovCheck(uint64(m.Executed))
}
if m.XXX_unrecognized != nil {
n += len(m.XXX_unrecognized)
}
return n
}
func sovCheck(x uint64) (n int) {
for {
n++
x >>= 7
if x == 0 {
break
}
}
return n
}
func sozCheck(x uint64) (n int) {
return sovCheck(uint64((x << 1) ^ uint64((int64(x) >> 63))))
}
func (m *CheckRequest) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCheck
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: CheckRequest: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: CheckRequest: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Config", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCheck
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthCheck
}
postIndex := iNdEx + msglen
if postIndex > l {
return io.ErrUnexpectedEOF
}
if m.Config == nil {
m.Config = &CheckConfig{}
}
if err := m.Config.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
case 2:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Assets", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCheck
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthCheck
}
postIndex := iNdEx + msglen
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.Assets = append(m.Assets, Asset{})
if err := m.Assets[len(m.Assets)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
case 3:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Hooks", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCheck
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthCheck
}
postIndex := iNdEx + msglen
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.Hooks = append(m.Hooks, HookConfig{})
if err := m.Hooks[len(m.Hooks)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
case 4:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field Issued", wireType)
}
m.Issued = 0
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCheck
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.Issued |= (int64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
default:
iNdEx = preIndex
skippy, err := skipCheck(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthCheck
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *ProxyRequests) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCheck
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: ProxyRequests: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: ProxyRequests: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field EntityAttributes", wireType)
}
var stringLen uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCheck
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
stringLen |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
intStringLen := int(stringLen)
if intStringLen < 0 {
return ErrInvalidLengthCheck
}
postIndex := iNdEx + intStringLen
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.EntityAttributes = append(m.EntityAttributes, string(dAtA[iNdEx:postIndex]))
iNdEx = postIndex
case 2:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field Splay", wireType)
}
var v int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCheck
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
v |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
m.Splay = bool(v != 0)
case 3:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field SplayCoverage", wireType)
}
m.SplayCoverage = 0
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCheck
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.SplayCoverage |= (uint32(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
default:
iNdEx = preIndex
skippy, err := skipCheck(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthCheck
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *CheckConfig) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCheck
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: CheckConfig: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: CheckConfig: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Command", wireType)
}
var stringLen uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCheck
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
stringLen |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
intStringLen := int(stringLen)
if intStringLen < 0 {
return ErrInvalidLengthCheck
}
postIndex := iNdEx + intStringLen
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.Command = string(dAtA[iNdEx:postIndex])
iNdEx = postIndex
case 3:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Handlers", wireType)
}
var stringLen uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCheck
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
stringLen |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
intStringLen := int(stringLen)
if intStringLen < 0 {
return ErrInvalidLengthCheck
}
postIndex := iNdEx + intStringLen
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.Handlers = append(m.Handlers, string(dAtA[iNdEx:postIndex]))
iNdEx = postIndex
case 4:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field HighFlapThreshold", wireType)
}
m.HighFlapThreshold = 0
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCheck
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.HighFlapThreshold |= (uint32(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
case 5:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field Interval", wireType)
}
m.Interval = 0
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCheck
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.Interval |= (uint32(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
case 6:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field LowFlapThreshold", wireType)
}
m.LowFlapThreshold = 0
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCheck
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.LowFlapThreshold |= (uint32(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
case 9:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field Publish", wireType)
}
var v int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCheck
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
v |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
m.Publish = bool(v != 0)
case 10:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field RuntimeAssets", wireType)
}
var stringLen uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCheck
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
stringLen |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
intStringLen := int(stringLen)
if intStringLen < 0 {
return ErrInvalidLengthCheck
}
postIndex := iNdEx + intStringLen
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.RuntimeAssets = append(m.RuntimeAssets, string(dAtA[iNdEx:postIndex]))
iNdEx = postIndex
case 11:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Subscriptions", wireType)
}
var stringLen uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCheck
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
stringLen |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
intStringLen := int(stringLen)
if intStringLen < 0 {
return ErrInvalidLengthCheck
}
postIndex := iNdEx + intStringLen
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.Subscriptions = append(m.Subscriptions, string(dAtA[iNdEx:postIndex]))
iNdEx = postIndex
case 12:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field ExtendedAttributes", wireType)
}
var byteLen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCheck
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
byteLen |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
if byteLen < 0 {
return ErrInvalidLengthCheck
}
postIndex := iNdEx + byteLen
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.ExtendedAttributes = append(m.ExtendedAttributes[:0], dAtA[iNdEx:postIndex]...)
if m.ExtendedAttributes == nil {
m.ExtendedAttributes = []byte{}
}
iNdEx = postIndex
case 13:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field ProxyEntityName", wireType)
}
var stringLen uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCheck
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
stringLen |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
intStringLen := int(stringLen)
if intStringLen < 0 {
return ErrInvalidLengthCheck
}
postIndex := iNdEx + intStringLen
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.ProxyEntityName = string(dAtA[iNdEx:postIndex])
iNdEx = postIndex
case 14:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field CheckHooks", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCheck
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthCheck
}
postIndex := iNdEx + msglen
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.CheckHooks = append(m.CheckHooks, HookList{})
if err := m.CheckHooks[len(m.CheckHooks)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
case 15:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field Stdin", wireType)
}
var v int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCheck
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
v |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
m.Stdin = bool(v != 0)
case 16:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Subdue", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCheck
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthCheck
}
postIndex := iNdEx + msglen
if postIndex > l {
return io.ErrUnexpectedEOF
}
if m.Subdue == nil {
m.Subdue = &TimeWindowWhen{}
}
if err := m.Subdue.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
case 17:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Cron", wireType)
}
var stringLen uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCheck
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
stringLen |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
intStringLen := int(stringLen)
if intStringLen < 0 {
return ErrInvalidLengthCheck
}
postIndex := iNdEx + intStringLen
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.Cron = string(dAtA[iNdEx:postIndex])
iNdEx = postIndex
case 18:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field Ttl", wireType)
}
m.Ttl = 0
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCheck
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.Ttl |= (int64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
case 19:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field Timeout", wireType)
}
m.Timeout = 0
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCheck
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.Timeout |= (uint32(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
case 20:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field ProxyRequests", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCheck
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthCheck
}
postIndex := iNdEx + msglen
if postIndex > l {
return io.ErrUnexpectedEOF
}
if m.ProxyRequests == nil {
m.ProxyRequests = &ProxyRequests{}
}
if err := m.ProxyRequests.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
case 21:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field RoundRobin", wireType)
}
var v int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCheck
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
v |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
m.RoundRobin = bool(v != 0)
case 22:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field OutputMetricFormat", wireType)
}
var stringLen uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCheck
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
stringLen |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
intStringLen := int(stringLen)
if intStringLen < 0 {
return ErrInvalidLengthCheck
}
postIndex := iNdEx + intStringLen
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.OutputMetricFormat = string(dAtA[iNdEx:postIndex])
iNdEx = postIndex
case 23:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field OutputMetricHandlers", wireType)
}
var stringLen uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCheck
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
stringLen |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
intStringLen := int(stringLen)
if intStringLen < 0 {
return ErrInvalidLengthCheck
}
postIndex := iNdEx + intStringLen
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.OutputMetricHandlers = append(m.OutputMetricHandlers, string(dAtA[iNdEx:postIndex]))
iNdEx = postIndex
case 24:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field EnvVars", wireType)
}
var stringLen uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCheck
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
stringLen |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
intStringLen := int(stringLen)
if intStringLen < 0 {
return ErrInvalidLengthCheck
}
postIndex := iNdEx + intStringLen
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.EnvVars = append(m.EnvVars, string(dAtA[iNdEx:postIndex]))
iNdEx = postIndex
case 26:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field ObjectMeta", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCheck
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthCheck
}
postIndex := iNdEx + msglen
if postIndex > l {
return io.ErrUnexpectedEOF
}
if err := m.ObjectMeta.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
case 27:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field MaxOutputSize", wireType)
}
m.MaxOutputSize = 0
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCheck
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.MaxOutputSize |= (int64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
case 28:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field DiscardOutput", wireType)
}
var v int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCheck
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
v |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
m.DiscardOutput = bool(v != 0)
default:
iNdEx = preIndex
skippy, err := skipCheck(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthCheck
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *Check) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCheck
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: Check: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: Check: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Command", wireType)
}
var stringLen uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCheck
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
stringLen |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
intStringLen := int(stringLen)
if intStringLen < 0 {
return ErrInvalidLengthCheck
}
postIndex := iNdEx + intStringLen
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.Command = string(dAtA[iNdEx:postIndex])
iNdEx = postIndex
case 3:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Handlers", wireType)
}
var stringLen uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCheck
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
stringLen |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
intStringLen := int(stringLen)
if intStringLen < 0 {
return ErrInvalidLengthCheck
}
postIndex := iNdEx + intStringLen
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.Handlers = append(m.Handlers, string(dAtA[iNdEx:postIndex]))
iNdEx = postIndex
case 4:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field HighFlapThreshold", wireType)
}
m.HighFlapThreshold = 0
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCheck
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.HighFlapThreshold |= (uint32(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
case 5:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field Interval", wireType)
}
m.Interval = 0
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCheck
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.Interval |= (uint32(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
case 6:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field LowFlapThreshold", wireType)
}
m.LowFlapThreshold = 0
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCheck
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.LowFlapThreshold |= (uint32(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
case 9:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field Publish", wireType)
}
var v int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCheck
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
v |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
m.Publish = bool(v != 0)
case 10:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field RuntimeAssets", wireType)
}
var stringLen uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCheck
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
stringLen |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
intStringLen := int(stringLen)
if intStringLen < 0 {
return ErrInvalidLengthCheck
}
postIndex := iNdEx + intStringLen
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.RuntimeAssets = append(m.RuntimeAssets, string(dAtA[iNdEx:postIndex]))
iNdEx = postIndex
case 11:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Subscriptions", wireType)
}
var stringLen uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCheck
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
stringLen |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
intStringLen := int(stringLen)
if intStringLen < 0 {
return ErrInvalidLengthCheck
}
postIndex := iNdEx + intStringLen
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.Subscriptions = append(m.Subscriptions, string(dAtA[iNdEx:postIndex]))
iNdEx = postIndex
case 13:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field ProxyEntityName", wireType)
}
var stringLen uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCheck
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
stringLen |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
intStringLen := int(stringLen)
if intStringLen < 0 {
return ErrInvalidLengthCheck
}
postIndex := iNdEx + intStringLen
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.ProxyEntityName = string(dAtA[iNdEx:postIndex])
iNdEx = postIndex
case 14:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field CheckHooks", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCheck
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthCheck
}
postIndex := iNdEx + msglen
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.CheckHooks = append(m.CheckHooks, HookList{})
if err := m.CheckHooks[len(m.CheckHooks)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
case 15:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field Stdin", wireType)
}
var v int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCheck
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
v |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
m.Stdin = bool(v != 0)
case 16:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Subdue", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCheck
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthCheck
}
postIndex := iNdEx + msglen
if postIndex > l {
return io.ErrUnexpectedEOF
}
if m.Subdue == nil {
m.Subdue = &TimeWindowWhen{}
}
if err := m.Subdue.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
case 17:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Cron", wireType)
}
var stringLen uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCheck
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
stringLen |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
intStringLen := int(stringLen)
if intStringLen < 0 {
return ErrInvalidLengthCheck
}
postIndex := iNdEx + intStringLen
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.Cron = string(dAtA[iNdEx:postIndex])
iNdEx = postIndex
case 18:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field Ttl", wireType)
}
m.Ttl = 0
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCheck
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.Ttl |= (int64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
case 19:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field Timeout", wireType)
}
m.Timeout = 0
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCheck
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.Timeout |= (uint32(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
case 20:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field ProxyRequests", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCheck
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthCheck
}
postIndex := iNdEx + msglen
if postIndex > l {
return io.ErrUnexpectedEOF
}
if m.ProxyRequests == nil {
m.ProxyRequests = &ProxyRequests{}
}
if err := m.ProxyRequests.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
case 21:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field RoundRobin", wireType)
}
var v int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCheck
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
v |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
m.RoundRobin = bool(v != 0)
case 22:
if wireType != 1 {
return fmt.Errorf("proto: wrong wireType = %d for field Duration", wireType)
}
var v uint64
if (iNdEx + 8) > l {
return io.ErrUnexpectedEOF
}
v = uint64(encoding_binary.LittleEndian.Uint64(dAtA[iNdEx:]))
iNdEx += 8
m.Duration = float64(math.Float64frombits(v))
case 23:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field Executed", wireType)
}
m.Executed = 0
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCheck
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.Executed |= (int64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
case 24:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field History", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCheck
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthCheck
}
postIndex := iNdEx + msglen
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.History = append(m.History, CheckHistory{})
if err := m.History[len(m.History)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
case 25:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field Issued", wireType)
}
m.Issued = 0
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCheck
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.Issued |= (int64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
case 26:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Output", wireType)
}
var stringLen uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCheck
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
stringLen |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
intStringLen := int(stringLen)
if intStringLen < 0 {
return ErrInvalidLengthCheck
}
postIndex := iNdEx + intStringLen
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.Output = string(dAtA[iNdEx:postIndex])
iNdEx = postIndex
case 27:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field State", wireType)
}
var stringLen uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCheck
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
stringLen |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
intStringLen := int(stringLen)
if intStringLen < 0 {
return ErrInvalidLengthCheck
}
postIndex := iNdEx + intStringLen
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.State = string(dAtA[iNdEx:postIndex])
iNdEx = postIndex
case 28:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field Status", wireType)
}
m.Status = 0
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCheck
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.Status |= (uint32(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
case 29:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field TotalStateChange", wireType)
}
m.TotalStateChange = 0
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCheck
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.TotalStateChange |= (uint32(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
case 30:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field LastOK", wireType)
}
m.LastOK = 0
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCheck
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.LastOK |= (int64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
case 31:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field Occurrences", wireType)
}
m.Occurrences = 0
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCheck
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.Occurrences |= (int64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
case 32:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field OccurrencesWatermark", wireType)
}
m.OccurrencesWatermark = 0
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCheck
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.OccurrencesWatermark |= (int64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
case 33:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Silenced", wireType)
}
var stringLen uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCheck
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
stringLen |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
intStringLen := int(stringLen)
if intStringLen < 0 {
return ErrInvalidLengthCheck
}
postIndex := iNdEx + intStringLen
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.Silenced = append(m.Silenced, string(dAtA[iNdEx:postIndex]))
iNdEx = postIndex
case 34:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Hooks", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCheck
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthCheck
}
postIndex := iNdEx + msglen
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.Hooks = append(m.Hooks, &Hook{})
if err := m.Hooks[len(m.Hooks)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
case 35:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field OutputMetricFormat", wireType)
}
var stringLen uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCheck
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
stringLen |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
intStringLen := int(stringLen)
if intStringLen < 0 {
return ErrInvalidLengthCheck
}
postIndex := iNdEx + intStringLen
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.OutputMetricFormat = string(dAtA[iNdEx:postIndex])
iNdEx = postIndex
case 36:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field OutputMetricHandlers", wireType)
}
var stringLen uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCheck
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
stringLen |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
intStringLen := int(stringLen)
if intStringLen < 0 {
return ErrInvalidLengthCheck
}
postIndex := iNdEx + intStringLen
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.OutputMetricHandlers = append(m.OutputMetricHandlers, string(dAtA[iNdEx:postIndex]))
iNdEx = postIndex
case 37:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field EnvVars", wireType)
}
var stringLen uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCheck
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
stringLen |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
intStringLen := int(stringLen)
if intStringLen < 0 {
return ErrInvalidLengthCheck
}
postIndex := iNdEx + intStringLen
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.EnvVars = append(m.EnvVars, string(dAtA[iNdEx:postIndex]))
iNdEx = postIndex
case 38:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field ObjectMeta", wireType)
}
var msglen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCheck
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
msglen |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
if msglen < 0 {
return ErrInvalidLengthCheck
}
postIndex := iNdEx + msglen
if postIndex > l {
return io.ErrUnexpectedEOF
}
if err := m.ObjectMeta.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
return err
}
iNdEx = postIndex
case 39:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field MaxOutputSize", wireType)
}
m.MaxOutputSize = 0
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCheck
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.MaxOutputSize |= (int64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
case 40:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field DiscardOutput", wireType)
}
var v int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCheck
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
v |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
m.DiscardOutput = bool(v != 0)
case 99:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field ExtendedAttributes", wireType)
}
var byteLen int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCheck
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
byteLen |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
if byteLen < 0 {
return ErrInvalidLengthCheck
}
postIndex := iNdEx + byteLen
if postIndex > l {
return io.ErrUnexpectedEOF
}
m.ExtendedAttributes = append(m.ExtendedAttributes[:0], dAtA[iNdEx:postIndex]...)
if m.ExtendedAttributes == nil {
m.ExtendedAttributes = []byte{}
}
iNdEx = postIndex
default:
iNdEx = preIndex
skippy, err := skipCheck(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthCheck
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *CheckHistory) Unmarshal(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
preIndex := iNdEx
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCheck
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: CheckHistory: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: CheckHistory: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field Status", wireType)
}
m.Status = 0
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCheck
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.Status |= (uint32(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
case 2:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field Executed", wireType)
}
m.Executed = 0
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return ErrIntOverflowCheck
}
if iNdEx >= l {
return io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
m.Executed |= (int64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
default:
iNdEx = preIndex
skippy, err := skipCheck(dAtA[iNdEx:])
if err != nil {
return err
}
if skippy < 0 {
return ErrInvalidLengthCheck
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
m.XXX_unrecognized = append(m.XXX_unrecognized, dAtA[iNdEx:iNdEx+skippy]...)
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func skipCheck(dAtA []byte) (n int, err error) {
l := len(dAtA)
iNdEx := 0
for iNdEx < l {
var wire uint64
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return 0, ErrIntOverflowCheck
}
if iNdEx >= l {
return 0, io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
wire |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
wireType := int(wire & 0x7)
switch wireType {
case 0:
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return 0, ErrIntOverflowCheck
}
if iNdEx >= l {
return 0, io.ErrUnexpectedEOF
}
iNdEx++
if dAtA[iNdEx-1] < 0x80 {
break
}
}
return iNdEx, nil
case 1:
iNdEx += 8
return iNdEx, nil
case 2:
var length int
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return 0, ErrIntOverflowCheck
}
if iNdEx >= l {
return 0, io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
length |= (int(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
iNdEx += length
if length < 0 {
return 0, ErrInvalidLengthCheck
}
return iNdEx, nil
case 3:
for {
var innerWire uint64
var start int = iNdEx
for shift := uint(0); ; shift += 7 {
if shift >= 64 {
return 0, ErrIntOverflowCheck
}
if iNdEx >= l {
return 0, io.ErrUnexpectedEOF
}
b := dAtA[iNdEx]
iNdEx++
innerWire |= (uint64(b) & 0x7F) << shift
if b < 0x80 {
break
}
}
innerWireType := int(innerWire & 0x7)
if innerWireType == 4 {
break
}
next, err := skipCheck(dAtA[start:])
if err != nil {
return 0, err
}
iNdEx = start + next
}
return iNdEx, nil
case 4:
return iNdEx, nil
case 5:
iNdEx += 4
return iNdEx, nil
default:
return 0, fmt.Errorf("proto: illegal wireType %d", wireType)
}
}
panic("unreachable")
}
var (
ErrInvalidLengthCheck = fmt.Errorf("proto: negative length found during unmarshaling")
ErrIntOverflowCheck = fmt.Errorf("proto: integer overflow")
)
func init() { proto.RegisterFile("check.proto", fileDescriptor_check_a2362dce6de70879) }
var fileDescriptor_check_a2362dce6de70879 = []byte{
// 1321 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xec, 0x57, 0xcd, 0x72, 0xdb, 0xb6,
0x16, 0x36, 0xed, 0x58, 0xb6, 0x21, 0xcb, 0x3f, 0xb0, 0x1d, 0xc3, 0x4e, 0x22, 0xea, 0xfa, 0xde,
0x24, 0x5a, 0xdc, 0x38, 0xf7, 0xba, 0x93, 0xe9, 0xcf, 0xce, 0x74, 0x93, 0xba, 0x6d, 0x12, 0x67,
0x90, 0xb4, 0x99, 0xe9, 0x74, 0x86, 0x03, 0x91, 0xb0, 0xc4, 0x5a, 0x24, 0x54, 0x02, 0x94, 0xed,
0x3c, 0x41, 0x1f, 0xa1, 0xcb, 0x2c, 0xd3, 0x55, 0xb7, 0x7d, 0x84, 0x2c, 0xb3, 0xeb, 0x8e, 0xd3,
0xaa, 0x3b, 0x3e, 0x41, 0x77, 0xed, 0xe0, 0x10, 0x94, 0x25, 0x59, 0x6e, 0xb3, 0x48, 0x67, 0x3a,
0x9d, 0x6c, 0xc4, 0x73, 0xbe, 0x73, 0x8e, 0x00, 0x9e, 0x9f, 0x0f, 0x20, 0x2a, 0x7b, 0x2d, 0xee,
0x1d, 0x6d, 0x77, 0x62, 0xa1, 0x04, 0xae, 0x48, 0x1e, 0xc9, 0x64, 0xdb, 0x13, 0x31, 0xdf, 0xee,
0xee, 0x6c, 0xde, 0x6a, 0x06, 0xaa, 0x95, 0x34, 0xb6, 0x3d, 0x11, 0xde, 0x6e, 0x8a, 0xa6, 0xb8,
0x0d, 0x5e, 0x8d, 0xe4, 0x10, 0x34, 0x50, 0x40, 0xca, 0xa3, 0x37, 0xcb, 0x4c, 0x4a, 0xae, 0x8c,
0x82, 0x5a, 0x42, 0x1c, 0x15, 0x72, 0xc8, 0x15, 0x33, 0xf2, 0xb2, 0x0a, 0x42, 0xee, 0x1e, 0x07,
0x91, 0x2f, 0x8e, 0x73, 0x68, 0xeb, 0x47, 0x0b, 0xcd, 0xef, 0xe9, 0x5d, 0x50, 0xfe, 0x75, 0xc2,
0xa5, 0xc2, 0xef, 0xa1, 0x92, 0x27, 0xa2, 0xc3, 0xa0, 0x49, 0xac, 0x9a, 0x55, 0x2f, 0xef, 0x6c,
0x6e, 0x0f, 0xed, 0x6b, 0x1b, 0x9c, 0xf7, 0xc0, 0xc3, 0xb9, 0xf4, 0x32, 0xb5, 0x2d, 0x6a, 0xfc,
0xf1, 0x0e, 0x2a, 0xc1, 0x26, 0x24, 0x99, 0xac, 0x4d, 0xd5, 0xcb, 0x3b, 0xab, 0x23, 0x91, 0xbb,
0xda, 0x08, 0x31, 0x13, 0xd4, 0x78, 0xe2, 0x3b, 0x68, 0x5a, 0xef, 0x55, 0x92, 0x29, 0x08, 0xd9,
0x18, 0x09, 0xd9, 0x17, 0x62, 0x70, 0xad, 0x09, 0x9a, 0x7b, 0xe3, 0x2d, 0x54, 0xfa, 0x58, 0xca,
0x84, 0xfb, 0xe4, 0x52, 0xcd, 0xaa, 0x4f, 0x39, 0x28, 0x4b, 0xed, 0x52, 0x00, 0x08, 0x35, 0x96,
0xad, 0xef, 0x2d, 0x54, 0x79, 0x14, 0x8b, 0x93, 0x53, 0xf3, 0x66, 0x12, 0x3b, 0x68, 0x99, 0x47,
0x2a, 0x50, 0xa7, 0x2e, 0x53, 0x2a, 0x0e, 0x1a, 0x89, 0xe2, 0x92, 0x58, 0xb5, 0xa9, 0xfa, 0x9c,
0xb3, 0x96, 0xa5, 0xf6, 0x79, 0x23, 0x5d, 0xca, 0xa1, 0xdd, 0x3e, 0x82, 0x6d, 0x34, 0x2d, 0x3b,
0x6d, 0x76, 0x4a, 0x26, 0x6b, 0x56, 0x7d, 0xd6, 0x99, 0xcb, 0x52, 0x3b, 0x07, 0x68, 0xfe, 0xc0,
0xef, 0xa3, 0x05, 0x10, 0x5c, 0x4f, 0x74, 0x79, 0xcc, 0x9a, 0x9c, 0x4c, 0xd5, 0xac, 0x7a, 0xc5,
0xc1, 0x59, 0x6a, 0x8f, 0x58, 0x68, 0x05, 0xf4, 0x3d, 0xa3, 0x6e, 0x7d, 0x87, 0x50, 0x79, 0x20,
0xbd, 0x98, 0xa0, 0x19, 0x4f, 0x84, 0x21, 0x8b, 0x7c, 0xa8, 0xc5, 0x1c, 0x2d, 0x54, 0x5c, 0x47,
0xb3, 0x2d, 0x16, 0xf9, 0x6d, 0x1e, 0xe7, 0x99, 0x9b, 0x73, 0xe6, 0xb3, 0xd4, 0xee, 0x63, 0xb4,
0x2f, 0xe1, 0x8f, 0xd0, 0x4a, 0x2b, 0x68, 0xb6, 0xdc, 0xc3, 0x36, 0xeb, 0xb8, 0xaa, 0x15, 0x73,
0xd9, 0x12, 0xed, 0x3c, 0x6d, 0x15, 0x67, 0x3d, 0x4b, 0xed, 0x71, 0x66, 0xba, 0xac, 0xc1, 0x7b,
0x6d, 0xd6, 0x79, 0x52, 0x40, 0x7a, 0xc9, 0x20, 0x52, 0x3c, 0xee, 0xb2, 0x36, 0x99, 0x86, 0x68,
0x58, 0xb2, 0xc0, 0x68, 0x5f, 0xc2, 0x1f, 0x22, 0xdc, 0x16, 0xc7, 0xa3, 0x2b, 0x96, 0x20, 0xe6,
0x72, 0x96, 0xda, 0x63, 0xac, 0x74, 0xa9, 0x2d, 0x8e, 0x87, 0xd7, 0xbb, 0x8e, 0x66, 0x3a, 0x49,
0xa3, 0x1d, 0xc8, 0x16, 0x99, 0x83, 0x54, 0x97, 0xb3, 0xd4, 0x2e, 0x20, 0x5a, 0x08, 0x3a, 0xdd,
0x71, 0x12, 0x41, 0x5f, 0x9b, 0xe6, 0x43, 0x90, 0x0f, 0x48, 0xf7, 0xb0, 0x85, 0x56, 0x8c, 0xbe,
0x9b, 0xf7, 0xde, 0xbb, 0xa8, 0x22, 0x93, 0x86, 0xf4, 0xe2, 0xa0, 0xa3, 0x02, 0x11, 0x49, 0x52,
0x86, 0xc8, 0xe5, 0x2c, 0xb5, 0x87, 0x0d, 0x74, 0x58, 0xc5, 0x77, 0x10, 0xbe, 0x7b, 0xa2, 0x78,
0xe4, 0x73, 0xff, 0xac, 0x33, 0xc8, 0x7c, 0xcd, 0xaa, 0xcf, 0x3b, 0xd3, 0x59, 0x6a, 0x5b, 0xb7,
0xe8, 0x18, 0x07, 0xfc, 0x04, 0x2d, 0x77, 0x74, 0x3f, 0xba, 0xa6, 0xcf, 0x22, 0x16, 0x72, 0x52,
0xd1, 0x85, 0x75, 0xea, 0xbd, 0xd4, 0x5e, 0x84, 0x66, 0xbd, 0x0b, 0xb6, 0x87, 0x2c, 0xe4, 0xba,
0x23, 0xcf, 0xf9, 0xd3, 0xc5, 0xce, 0xb0, 0x17, 0x7e, 0x60, 0x58, 0xc4, 0xcd, 0xe7, 0x68, 0x01,
0xe6, 0x68, 0x7d, 0xcc, 0x1c, 0xdd, 0x0f, 0xa4, 0x72, 0x56, 0xf4, 0x14, 0x65, 0xa9, 0x3d, 0x18,
0x43, 0x11, 0x28, 0xfb, 0x30, 0x59, 0xba, 0xbf, 0x95, 0x1f, 0x44, 0x64, 0x71, 0xa0, 0xbf, 0x35,
0x40, 0xf3, 0x07, 0xde, 0x45, 0x25, 0x99, 0x34, 0xfc, 0x84, 0x93, 0x25, 0xe0, 0x87, 0x6b, 0x23,
0x4b, 0x3d, 0x09, 0x42, 0xfe, 0x14, 0x18, 0xe6, 0x69, 0x8b, 0x47, 0xf9, 0x64, 0xe6, 0x01, 0xd4,
0x3c, 0x31, 0x46, 0x97, 0xbc, 0x58, 0x44, 0x64, 0x19, 0x9a, 0x1a, 0x64, 0xbc, 0x81, 0xa6, 0x94,
0x6a, 0x13, 0x0c, 0xe3, 0x3c, 0x93, 0xa5, 0xb6, 0x56, 0xa9, 0xfe, 0xd1, 0x9d, 0xa0, 0xab, 0x26,
0x12, 0x45, 0x56, 0xa0, 0x89, 0xa0, 0x13, 0x0c, 0x44, 0x0b, 0x01, 0xef, 0xa1, 0x85, 0x3c, 0x5d,
0xb1, 0x99, 0x77, 0xb2, 0x0a, 0x1b, 0xbc, 0x3a, 0xb2, 0xc1, 0x21, 0x4e, 0xa0, 0x95, 0xce, 0x10,
0x45, 0xfc, 0x0f, 0x95, 0x63, 0x91, 0x44, 0xbe, 0x1b, 0x8b, 0x46, 0x10, 0x91, 0x35, 0x48, 0xc2,
0xa2, 0x4e, 0xd8, 0x00, 0x4c, 0x11, 0x28, 0x54, 0xcb, 0xf8, 0x13, 0xb4, 0x2a, 0x12, 0xd5, 0x49,
0x94, 0x1b, 0x72, 0x15, 0x07, 0x9e, 0x7b, 0x28, 0xe2, 0x90, 0x29, 0x72, 0x19, 0x0a, 0x4b, 0xb2,
0xd4, 0x1e, 0x6b, 0xa7, 0x38, 0x47, 0x1f, 0x00, 0x78, 0x0f, 0x30, 0xfc, 0x08, 0x5d, 0x1e, 0xf6,
0xed, 0x0f, 0xf9, 0x3a, 0xb4, 0xe6, 0x66, 0x96, 0xda, 0x17, 0x78, 0xd0, 0xd5, 0xc1, 0xff, 0xdb,
0x2f, 0xc6, 0xff, 0x26, 0x9a, 0xe5, 0x51, 0xd7, 0xed, 0xb2, 0x58, 0x12, 0x72, 0x46, 0x14, 0x05,
0x46, 0x67, 0x78, 0xd4, 0xfd, 0x9c, 0xc5, 0x12, 0x7f, 0x86, 0x66, 0xf5, 0x41, 0xe1, 0x33, 0xc5,
0xc8, 0x26, 0xe4, 0x6d, 0x94, 0x8b, 0x0f, 0x1a, 0x5f, 0x71, 0x4f, 0xff, 0x3f, 0x73, 0xaa, 0xba,
0x8b, 0x5e, 0xa5, 0xb6, 0xa5, 0xa7, 0xb9, 0x08, 0xfb, 0xaf, 0x08, 0x03, 0xc5, 0xc3, 0x8e, 0x3a,
0xa5, 0xfd, 0xbf, 0xc2, 0x37, 0xd0, 0x62, 0xc8, 0x4e, 0x5c, 0xb3, 0x67, 0x19, 0x3c, 0xe3, 0xe4,
0x8a, 0x2e, 0x31, 0xad, 0x84, 0xec, 0xe4, 0x00, 0xd0, 0xc7, 0xc1, 0x33, 0x8e, 0xaf, 0xa3, 0x05,
0x3f, 0x90, 0x1e, 0x8b, 0x7d, 0xe3, 0x4b, 0xae, 0xea, 0xd4, 0xd3, 0x8a, 0x41, 0x73, 0xd7, 0x0f,
0x66, 0xbf, 0x79, 0x6e, 0x4f, 0xbc, 0x78, 0x6e, 0x5b, 0x5b, 0xbf, 0x2d, 0xa0, 0x69, 0xe0, 0xca,
0xb7, 0x2c, 0xf9, 0x37, 0x65, 0xc9, 0xb7, 0x74, 0xf7, 0x4f, 0xa4, 0xbb, 0x4d, 0x34, 0xeb, 0x27,
0x31, 0xd3, 0x25, 0x06, 0x8a, 0xb3, 0x68, 0x5f, 0xd7, 0xcd, 0xcf, 0x4f, 0xb8, 0x97, 0x28, 0xee,
0x93, 0x75, 0x78, 0xb3, 0x9c, 0x6c, 0x0c, 0x46, 0xfb, 0x12, 0xbe, 0x87, 0x66, 0x5a, 0x81, 0x54,
0x22, 0x3e, 0x05, 0x56, 0x2a, 0xef, 0x5c, 0x19, 0x77, 0xcb, 0xdc, 0xcf, 0x5d, 0x9c, 0x45, 0x53,
0xc5, 0x22, 0x86, 0x16, 0x82, 0xbe, 0x07, 0xe6, 0xb7, 0x3e, 0xb2, 0x71, 0xfe, 0x1e, 0x98, 0x3f,
0xb5, 0x8f, 0xa1, 0x94, 0x4d, 0x68, 0x3e, 0xf0, 0xc9, 0x11, 0x6a, 0x9e, 0x78, 0x55, 0xb7, 0x01,
0x53, 0x39, 0x39, 0xcd, 0xd1, 0x5c, 0xd1, 0x91, 0x5a, 0x48, 0x24, 0x90, 0x51, 0xc5, 0x14, 0x17,
0x10, 0x6a, 0x9e, 0x7a, 0x8c, 0x95, 0x50, 0xac, 0xed, 0x42, 0x88, 0xeb, 0xb5, 0x58, 0xd4, 0xe4,
0xe4, 0xda, 0xd9, 0x18, 0x9f, 0xb7, 0xd2, 0x25, 0xc0, 0x1e, 0x6b, 0x68, 0x0f, 0x10, 0xbc, 0x8d,
0x66, 0xda, 0x4c, 0x2a, 0x57, 0x1c, 0x91, 0x2a, 0xbc, 0xc8, 0x5a, 0x2f, 0xb5, 0x4b, 0xf7, 0x99,
0x54, 0x07, 0x9f, 0xea, 0x17, 0x37, 0x46, 0x5a, 0xd2, 0xc2, 0xc1, 0x11, 0xfe, 0x3f, 0x2a, 0x0b,
0xcf, 0x4b, 0xe2, 0x98, 0x47, 0x1e, 0x97, 0xc4, 0x86, 0x18, 0xa8, 0xdb, 0x00, 0x4c, 0x07, 0x15,
0xfc, 0x10, 0xad, 0x0d, 0xa8, 0xee, 0x31, 0x53, 0x3c, 0x0e, 0x59, 0x7c, 0x44, 0x6a, 0x10, 0xbc,
0x91, 0xa5, 0xf6, 0x78, 0x07, 0xba, 0x3a, 0x00, 0x3f, 0x2d, 0x50, 0x5c, 0x43, 0xb3, 0x32, 0x68,
0x6b, 0xd0, 0x27, 0xff, 0x02, 0x4a, 0xc8, 0xbf, 0x06, 0xfa, 0x28, 0xbe, 0x5d, 0xdc, 0xed, 0xb7,
0xa0, 0xc4, 0x2b, 0x63, 0x86, 0xd4, 0xc4, 0x98, 0x5b, 0xfd, 0x45, 0x47, 0xe9, 0xbf, 0xdf, 0xe8,
0x51, 0xfa, 0x9f, 0x37, 0x70, 0x94, 0x5e, 0x7f, 0xdd, 0xa3, 0xf4, 0xc6, 0x5f, 0x7a, 0x94, 0xde,
0x7c, 0xbd, 0xa3, 0xb4, 0x3e, 0xe6, 0x28, 0xbd, 0xe0, 0x12, 0xeb, 0xfd, 0xc9, 0x25, 0x76, 0xe0,
0x04, 0xfe, 0xd2, 0x7c, 0x38, 0xee, 0x9f, 0xcd, 0xa2, 0x99, 0x16, 0xeb, 0xc2, 0x69, 0x19, 0x64,
0x88, 0xc9, 0x3f, 0x62, 0x08, 0xa7, 0xf6, 0xeb, 0xcf, 0x55, 0xeb, 0x45, 0xaf, 0x6a, 0xfd, 0xd0,
0xab, 0x5a, 0x2f, 0x7b, 0x55, 0xeb, 0x55, 0xaf, 0x6a, 0xfd, 0xd4, 0xab, 0x5a, 0xdf, 0xfe, 0x52,
0x9d, 0xf8, 0x62, 0xb2, 0xbb, 0xd3, 0x28, 0xc1, 0x07, 0xec, 0x3b, 0xbf, 0x07, 0x00, 0x00, 0xff,
0xff, 0xc7, 0x3b, 0xc1, 0x9b, 0x45, 0x0f, 0x00, 0x00,
}
Loading...
马建仓 AI 助手
尝试更多
代码解读
代码找茬
代码优化
1
https://gitee.com/ryancartoon/sensu-go.git
git@gitee.com:ryancartoon/sensu-go.git
ryancartoon
sensu-go
sensu-go
v5.10.1

搜索帮助