1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137213821392140214121422143214421452146214721482149215021512152215321542155215621572158215921602161216221632164216521662167216821692170217121722173217421752176217721782179218021812182218321842185218621872188218921902191219221932194219521962197219821992200220122022203220422052206220722082209221022112212221322142215221622172218221922202221222222232224222522262227222822292230223122322233223422352236223722382239224022412242224322442245224622472248224922502251225222532254225522562257225822592260226122622263226422652266226722682269227022712272227322742275227622772278227922802281228222832284228522862287228822892290229122922293229422952296229722982299230023012302230323042305230623072308230923102311231223132314231523162317231823192320232123222323232423252326232723282329233023312332233323342335233623372338233923402341234223432344234523462347234823492350235123522353235423552356235723582359236023612362236323642365236623672368236923702371237223732374237523762377237823792380238123822383238423852386238723882389239023912392239323942395239623972398239924002401240224032404240524062407240824092410241124122413241424152416241724182419242024212422242324242425242624272428242924302431243224332434243524362437243824392440244124422443244424452446244724482449245024512452245324542455245624572458245924602461246224632464246524662467246824692470247124722473247424752476247724782479248024812482248324842485248624872488248924902491249224932494249524962497249824992500250125022503250425052506250725082509251025112512251325142515251625172518251925202521252225232524252525262527252825292530253125322533253425352536253725382539254025412542254325442545254625472548254925502551255225532554255525562557255825592560256125622563256425652566256725682569257025712572257325742575257625772578257925802581258225832584258525862587258825892590259125922593259425952596259725982599260026012602260326042605260626072608260926102611261226132614261526162617261826192620262126222623262426252626262726282629263026312632263326342635263626372638263926402641264226432644264526462647264826492650265126522653265426552656265726582659266026612662266326642665266626672668266926702671267226732674267526762677267826792680268126822683268426852686268726882689269026912692269326942695269626972698269927002701270227032704270527062707270827092710271127122713271427152716271727182719272027212722272327242725272627272728272927302731273227332734273527362737273827392740274127422743274427452746274727482749275027512752275327542755275627572758275927602761276227632764276527662767276827692770277127722773277427752776277727782779278027812782278327842785278627872788278927902791279227932794279527962797279827992800280128022803280428052806280728082809281028112812281328142815281628172818281928202821282228232824282528262827282828292830283128322833283428352836283728382839284028412842284328442845284628472848284928502851285228532854285528562857285828592860286128622863286428652866286728682869287028712872287328742875287628772878287928802881288228832884288528862887288828892890289128922893289428952896289728982899290029012902290329042905290629072908290929102911291229132914291529162917291829192920292129222923292429252926292729282929293029312932293329342935293629372938293929402941294229432944294529462947294829492950295129522953295429552956295729582959296029612962296329642965296629672968296929702971297229732974297529762977297829792980298129822983298429852986298729882989299029912992299329942995299629972998299930003001300230033004300530063007300830093010301130123013301430153016301730183019302030213022302330243025302630273028302930303031303230333034303530363037303830393040304130423043304430453046304730483049305030513052305330543055305630573058305930603061306230633064306530663067306830693070307130723073307430753076307730783079308030813082308330843085308630873088308930903091309230933094309530963097309830993100310131023103310431053106310731083109311031113112311331143115311631173118311931203121312231233124312531263127312831293130313131323133313431353136313731383139314031413142314331443145314631473148314931503151315231533154315531563157315831593160316131623163316431653166316731683169317031713172317331743175317631773178317931803181318231833184318531863187318831893190319131923193319431953196319731983199320032013202320332043205320632073208320932103211321232133214321532163217321832193220322132223223322432253226322732283229323032313232323332343235323632373238323932403241324232433244324532463247324832493250325132523253325432553256325732583259326032613262326332643265326632673268326932703271327232733274327532763277327832793280328132823283328432853286328732883289329032913292329332943295329632973298329933003301330233033304330533063307330833093310331133123313331433153316331733183319332033213322332333243325332633273328332933303331333233333334333533363337333833393340334133423343334433453346334733483349335033513352335333543355335633573358335933603361336233633364336533663367336833693370337133723373337433753376337733783379338033813382338333843385338633873388338933903391339233933394339533963397339833993400340134023403340434053406340734083409341034113412341334143415341634173418341934203421342234233424342534263427342834293430343134323433343434353436343734383439344034413442344334443445344634473448344934503451345234533454345534563457345834593460346134623463346434653466346734683469347034713472347334743475347634773478347934803481348234833484348534863487348834893490349134923493349434953496349734983499350035013502350335043505350635073508350935103511351235133514351535163517351835193520352135223523352435253526352735283529353035313532353335343535353635373538353935403541354235433544354535463547354835493550355135523553355435553556355735583559356035613562356335643565356635673568356935703571357235733574357535763577357835793580358135823583358435853586358735883589359035913592359335943595359635973598359936003601360236033604360536063607360836093610361136123613361436153616361736183619362036213622362336243625362636273628362936303631363236333634363536363637363836393640364136423643364436453646364736483649365036513652365336543655365636573658365936603661366236633664366536663667366836693670367136723673367436753676367736783679368036813682368336843685368636873688368936903691369236933694369536963697369836993700370137023703370437053706370737083709371037113712371337143715371637173718371937203721372237233724372537263727372837293730373137323733373437353736373737383739374037413742374337443745374637473748374937503751375237533754375537563757375837593760376137623763376437653766376737683769377037713772377337743775377637773778377937803781378237833784378537863787378837893790379137923793379437953796379737983799380038013802380338043805380638073808380938103811381238133814381538163817381838193820382138223823382438253826382738283829383038313832383338343835383638373838383938403841384238433844384538463847 |
- // Code generated by protoc-gen-gogo.
- // source: dispatcher.proto
- // DO NOT EDIT!
- package api
- import proto "github.com/gogo/protobuf/proto"
- import fmt "fmt"
- import math "math"
- import _ "github.com/gogo/protobuf/gogoproto"
- import _ "github.com/docker/swarmkit/protobuf/plugin"
- import _ "github.com/gogo/protobuf/types"
- import time "time"
- import github_com_docker_swarmkit_api_deepcopy "github.com/docker/swarmkit/api/deepcopy"
- import (
- context "golang.org/x/net/context"
- grpc "google.golang.org/grpc"
- )
- import github_com_gogo_protobuf_types "github.com/gogo/protobuf/types"
- import raftselector "github.com/docker/swarmkit/manager/raftselector"
- import codes "google.golang.org/grpc/codes"
- import metadata "google.golang.org/grpc/metadata"
- import transport "google.golang.org/grpc/transport"
- import rafttime "time"
- import strings "strings"
- import reflect "reflect"
- import io "io"
- // Reference imports to suppress errors if they are not otherwise used.
- var _ = proto.Marshal
- var _ = fmt.Errorf
- var _ = math.Inf
- var _ = time.Kitchen
- type AssignmentChange_AssignmentAction int32
- const (
- AssignmentChange_AssignmentActionUpdate AssignmentChange_AssignmentAction = 0
- AssignmentChange_AssignmentActionRemove AssignmentChange_AssignmentAction = 1
- )
- var AssignmentChange_AssignmentAction_name = map[int32]string{
- 0: "UPDATE",
- 1: "REMOVE",
- }
- var AssignmentChange_AssignmentAction_value = map[string]int32{
- "UPDATE": 0,
- "REMOVE": 1,
- }
- func (x AssignmentChange_AssignmentAction) String() string {
- return proto.EnumName(AssignmentChange_AssignmentAction_name, int32(x))
- }
- func (AssignmentChange_AssignmentAction) EnumDescriptor() ([]byte, []int) {
- return fileDescriptorDispatcher, []int{10, 0}
- }
- // AssignmentType specifies whether this assignment message carries
- // the full state, or is an update to an existing state.
- type AssignmentsMessage_Type int32
- const (
- AssignmentsMessage_COMPLETE AssignmentsMessage_Type = 0
- AssignmentsMessage_INCREMENTAL AssignmentsMessage_Type = 1
- )
- var AssignmentsMessage_Type_name = map[int32]string{
- 0: "COMPLETE",
- 1: "INCREMENTAL",
- }
- var AssignmentsMessage_Type_value = map[string]int32{
- "COMPLETE": 0,
- "INCREMENTAL": 1,
- }
- func (x AssignmentsMessage_Type) String() string {
- return proto.EnumName(AssignmentsMessage_Type_name, int32(x))
- }
- func (AssignmentsMessage_Type) EnumDescriptor() ([]byte, []int) {
- return fileDescriptorDispatcher, []int{11, 0}
- }
- // SessionRequest starts a session.
- type SessionRequest struct {
- Description *NodeDescription `protobuf:"bytes,1,opt,name=description" json:"description,omitempty"`
- // SessionID can be provided to attempt resuming an existing session. If the
- // SessionID is empty or invalid, a new SessionID will be assigned.
- //
- // See SessionMessage.SessionID for details.
- SessionID string `protobuf:"bytes,2,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
- }
- func (m *SessionRequest) Reset() { *m = SessionRequest{} }
- func (*SessionRequest) ProtoMessage() {}
- func (*SessionRequest) Descriptor() ([]byte, []int) { return fileDescriptorDispatcher, []int{0} }
- // SessionMessage instructs an agent on various actions as part of the current
- // session. An agent should act immediately on the contents.
- type SessionMessage struct {
- // SessionID is allocated after a successful registration. It should be
- // used on all RPC calls after registration. A dispatcher may choose to
- // change the SessionID, at which time an agent must re-register and obtain
- // a new one.
- //
- // All Dispatcher calls after register should include the SessionID. If the
- // Dispatcher so chooses, it may reject the call with an InvalidArgument
- // error code, at which time the agent should call Register to start a new
- // session.
- //
- // As a rule, once an agent has a SessionID, it should never save it to
- // disk or try to otherwise reuse. If the agent loses its SessionID, it
- // must start a new session through a call to Register. A Dispatcher may
- // choose to reuse the SessionID, if it sees fit, but it is not advised.
- //
- // The actual implementation of the SessionID is Dispatcher specific and
- // should be treated as opaque by agents.
- //
- // From a Dispatcher perspective, there are many ways to use the SessionID
- // to ensure uniqueness of a set of client RPC calls. One method is to keep
- // the SessionID unique to every call to Register in a single Dispatcher
- // instance. This ensures that the SessionID represents the unique
- // session from a single Agent to Manager. If the Agent restarts, we
- // allocate a new session, since the restarted Agent is not aware of the
- // new SessionID.
- //
- // The most compelling use case is to support duplicate node detection. If
- // one clones a virtual machine, including certificate material, two nodes
- // may end up with the same identity. This can also happen if two identical
- // agent processes are coming from the same node. If the SessionID is
- // replicated through the cluster, we can immediately detect the condition
- // and address it.
- //
- // Extending from the case above, we can actually detect a compromised
- // identity. Coupled with provisions to rebuild node identity, we can ban
- // the compromised node identity and have the nodes re-authenticate and
- // build a new identity. At this time, an administrator can then
- // re-authorize the compromised nodes, if it was a mistake or ensure that a
- // misbehaved node can no longer connect to the cluster.
- //
- // We considered placing this field in a GRPC header. Because this is a
- // critical feature of the protocol, we thought it should be represented
- // directly in the RPC message set.
- SessionID string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
- // Node identifies the registering node.
- Node *Node `protobuf:"bytes,2,opt,name=node" json:"node,omitempty"`
- // Managers provides a weight list of alternative dispatchers
- Managers []*WeightedPeer `protobuf:"bytes,3,rep,name=managers" json:"managers,omitempty"`
- // Symmetric encryption key distributed by the lead manager. Used by agents
- // for securing network bootstrapping and communication.
- NetworkBootstrapKeys []*EncryptionKey `protobuf:"bytes,4,rep,name=network_bootstrap_keys,json=networkBootstrapKeys" json:"network_bootstrap_keys,omitempty"`
- // Which root certificates to trust
- RootCA []byte `protobuf:"bytes,5,opt,name=RootCA,proto3" json:"RootCA,omitempty"`
- }
- func (m *SessionMessage) Reset() { *m = SessionMessage{} }
- func (*SessionMessage) ProtoMessage() {}
- func (*SessionMessage) Descriptor() ([]byte, []int) { return fileDescriptorDispatcher, []int{1} }
- // HeartbeatRequest provides identifying properties for a single heartbeat.
- type HeartbeatRequest struct {
- SessionID string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
- }
- func (m *HeartbeatRequest) Reset() { *m = HeartbeatRequest{} }
- func (*HeartbeatRequest) ProtoMessage() {}
- func (*HeartbeatRequest) Descriptor() ([]byte, []int) { return fileDescriptorDispatcher, []int{2} }
- type HeartbeatResponse struct {
- // Period is the duration to wait before sending the next heartbeat.
- // Well-behaved agents should update this on every heartbeat round trip.
- Period time.Duration `protobuf:"bytes,1,opt,name=period,stdduration" json:"period"`
- }
- func (m *HeartbeatResponse) Reset() { *m = HeartbeatResponse{} }
- func (*HeartbeatResponse) ProtoMessage() {}
- func (*HeartbeatResponse) Descriptor() ([]byte, []int) { return fileDescriptorDispatcher, []int{3} }
- type UpdateTaskStatusRequest struct {
- // Tasks should contain all statuses for running tasks. Only the status
- // field must be set. The spec is not required.
- SessionID string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
- Updates []*UpdateTaskStatusRequest_TaskStatusUpdate `protobuf:"bytes,3,rep,name=updates" json:"updates,omitempty"`
- }
- func (m *UpdateTaskStatusRequest) Reset() { *m = UpdateTaskStatusRequest{} }
- func (*UpdateTaskStatusRequest) ProtoMessage() {}
- func (*UpdateTaskStatusRequest) Descriptor() ([]byte, []int) {
- return fileDescriptorDispatcher, []int{4}
- }
- type UpdateTaskStatusRequest_TaskStatusUpdate struct {
- TaskID string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
- Status *TaskStatus `protobuf:"bytes,2,opt,name=status" json:"status,omitempty"`
- }
- func (m *UpdateTaskStatusRequest_TaskStatusUpdate) Reset() {
- *m = UpdateTaskStatusRequest_TaskStatusUpdate{}
- }
- func (*UpdateTaskStatusRequest_TaskStatusUpdate) ProtoMessage() {}
- func (*UpdateTaskStatusRequest_TaskStatusUpdate) Descriptor() ([]byte, []int) {
- return fileDescriptorDispatcher, []int{4, 0}
- }
- type UpdateTaskStatusResponse struct {
- }
- func (m *UpdateTaskStatusResponse) Reset() { *m = UpdateTaskStatusResponse{} }
- func (*UpdateTaskStatusResponse) ProtoMessage() {}
- func (*UpdateTaskStatusResponse) Descriptor() ([]byte, []int) {
- return fileDescriptorDispatcher, []int{5}
- }
- type TasksRequest struct {
- SessionID string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
- }
- func (m *TasksRequest) Reset() { *m = TasksRequest{} }
- func (*TasksRequest) ProtoMessage() {}
- func (*TasksRequest) Descriptor() ([]byte, []int) { return fileDescriptorDispatcher, []int{6} }
- type TasksMessage struct {
- // Tasks is the set of tasks that should be running on the node.
- // Tasks outside of this set running on the node should be terminated.
- Tasks []*Task `protobuf:"bytes,1,rep,name=tasks" json:"tasks,omitempty"`
- }
- func (m *TasksMessage) Reset() { *m = TasksMessage{} }
- func (*TasksMessage) ProtoMessage() {}
- func (*TasksMessage) Descriptor() ([]byte, []int) { return fileDescriptorDispatcher, []int{7} }
- type AssignmentsRequest struct {
- SessionID string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
- }
- func (m *AssignmentsRequest) Reset() { *m = AssignmentsRequest{} }
- func (*AssignmentsRequest) ProtoMessage() {}
- func (*AssignmentsRequest) Descriptor() ([]byte, []int) { return fileDescriptorDispatcher, []int{8} }
- type Assignment struct {
- // Types that are valid to be assigned to Item:
- // *Assignment_Task
- // *Assignment_Secret
- // *Assignment_Config
- Item isAssignment_Item `protobuf_oneof:"item"`
- }
- func (m *Assignment) Reset() { *m = Assignment{} }
- func (*Assignment) ProtoMessage() {}
- func (*Assignment) Descriptor() ([]byte, []int) { return fileDescriptorDispatcher, []int{9} }
- type isAssignment_Item interface {
- isAssignment_Item()
- MarshalTo([]byte) (int, error)
- Size() int
- }
- type Assignment_Task struct {
- Task *Task `protobuf:"bytes,1,opt,name=task,oneof"`
- }
- type Assignment_Secret struct {
- Secret *Secret `protobuf:"bytes,2,opt,name=secret,oneof"`
- }
- type Assignment_Config struct {
- Config *Config `protobuf:"bytes,3,opt,name=config,oneof"`
- }
- func (*Assignment_Task) isAssignment_Item() {}
- func (*Assignment_Secret) isAssignment_Item() {}
- func (*Assignment_Config) isAssignment_Item() {}
- func (m *Assignment) GetItem() isAssignment_Item {
- if m != nil {
- return m.Item
- }
- return nil
- }
- func (m *Assignment) GetTask() *Task {
- if x, ok := m.GetItem().(*Assignment_Task); ok {
- return x.Task
- }
- return nil
- }
- func (m *Assignment) GetSecret() *Secret {
- if x, ok := m.GetItem().(*Assignment_Secret); ok {
- return x.Secret
- }
- return nil
- }
- func (m *Assignment) GetConfig() *Config {
- if x, ok := m.GetItem().(*Assignment_Config); ok {
- return x.Config
- }
- return nil
- }
- // XXX_OneofFuncs is for the internal use of the proto package.
- func (*Assignment) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{}) {
- return _Assignment_OneofMarshaler, _Assignment_OneofUnmarshaler, _Assignment_OneofSizer, []interface{}{
- (*Assignment_Task)(nil),
- (*Assignment_Secret)(nil),
- (*Assignment_Config)(nil),
- }
- }
- func _Assignment_OneofMarshaler(msg proto.Message, b *proto.Buffer) error {
- m := msg.(*Assignment)
- // item
- switch x := m.Item.(type) {
- case *Assignment_Task:
- _ = b.EncodeVarint(1<<3 | proto.WireBytes)
- if err := b.EncodeMessage(x.Task); err != nil {
- return err
- }
- case *Assignment_Secret:
- _ = b.EncodeVarint(2<<3 | proto.WireBytes)
- if err := b.EncodeMessage(x.Secret); err != nil {
- return err
- }
- case *Assignment_Config:
- _ = b.EncodeVarint(3<<3 | proto.WireBytes)
- if err := b.EncodeMessage(x.Config); err != nil {
- return err
- }
- case nil:
- default:
- return fmt.Errorf("Assignment.Item has unexpected type %T", x)
- }
- return nil
- }
- func _Assignment_OneofUnmarshaler(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error) {
- m := msg.(*Assignment)
- switch tag {
- case 1: // item.task
- if wire != proto.WireBytes {
- return true, proto.ErrInternalBadWireType
- }
- msg := new(Task)
- err := b.DecodeMessage(msg)
- m.Item = &Assignment_Task{msg}
- return true, err
- case 2: // item.secret
- if wire != proto.WireBytes {
- return true, proto.ErrInternalBadWireType
- }
- msg := new(Secret)
- err := b.DecodeMessage(msg)
- m.Item = &Assignment_Secret{msg}
- return true, err
- case 3: // item.config
- if wire != proto.WireBytes {
- return true, proto.ErrInternalBadWireType
- }
- msg := new(Config)
- err := b.DecodeMessage(msg)
- m.Item = &Assignment_Config{msg}
- return true, err
- default:
- return false, nil
- }
- }
- func _Assignment_OneofSizer(msg proto.Message) (n int) {
- m := msg.(*Assignment)
- // item
- switch x := m.Item.(type) {
- case *Assignment_Task:
- s := proto.Size(x.Task)
- n += proto.SizeVarint(1<<3 | proto.WireBytes)
- n += proto.SizeVarint(uint64(s))
- n += s
- case *Assignment_Secret:
- s := proto.Size(x.Secret)
- n += proto.SizeVarint(2<<3 | proto.WireBytes)
- n += proto.SizeVarint(uint64(s))
- n += s
- case *Assignment_Config:
- s := proto.Size(x.Config)
- n += proto.SizeVarint(3<<3 | proto.WireBytes)
- n += proto.SizeVarint(uint64(s))
- n += s
- case nil:
- default:
- panic(fmt.Sprintf("proto: unexpected type %T in oneof", x))
- }
- return n
- }
- type AssignmentChange struct {
- Assignment *Assignment `protobuf:"bytes,1,opt,name=assignment" json:"assignment,omitempty"`
- Action AssignmentChange_AssignmentAction `protobuf:"varint,2,opt,name=action,proto3,enum=docker.swarmkit.v1.AssignmentChange_AssignmentAction" json:"action,omitempty"`
- }
- func (m *AssignmentChange) Reset() { *m = AssignmentChange{} }
- func (*AssignmentChange) ProtoMessage() {}
- func (*AssignmentChange) Descriptor() ([]byte, []int) { return fileDescriptorDispatcher, []int{10} }
- type AssignmentsMessage struct {
- Type AssignmentsMessage_Type `protobuf:"varint,1,opt,name=type,proto3,enum=docker.swarmkit.v1.AssignmentsMessage_Type" json:"type,omitempty"`
- // AppliesTo references the previous ResultsIn value, to chain
- // incremental updates together. For the first update in a stream,
- // AppliesTo is empty. If AppliesTo does not match the previously
- // received ResultsIn, the consumer of the stream should start a new
- // Assignments stream to re-sync.
- AppliesTo string `protobuf:"bytes,2,opt,name=applies_to,json=appliesTo,proto3" json:"applies_to,omitempty"`
- // ResultsIn identifies the result of this assignments message, to
- // match against the next message's AppliesTo value and protect
- // against missed messages.
- ResultsIn string `protobuf:"bytes,3,opt,name=results_in,json=resultsIn,proto3" json:"results_in,omitempty"`
- // AssignmentChange is a set of changes to apply on this node.
- Changes []*AssignmentChange `protobuf:"bytes,4,rep,name=changes" json:"changes,omitempty"`
- }
- func (m *AssignmentsMessage) Reset() { *m = AssignmentsMessage{} }
- func (*AssignmentsMessage) ProtoMessage() {}
- func (*AssignmentsMessage) Descriptor() ([]byte, []int) { return fileDescriptorDispatcher, []int{11} }
- func init() {
- proto.RegisterType((*SessionRequest)(nil), "docker.swarmkit.v1.SessionRequest")
- proto.RegisterType((*SessionMessage)(nil), "docker.swarmkit.v1.SessionMessage")
- proto.RegisterType((*HeartbeatRequest)(nil), "docker.swarmkit.v1.HeartbeatRequest")
- proto.RegisterType((*HeartbeatResponse)(nil), "docker.swarmkit.v1.HeartbeatResponse")
- proto.RegisterType((*UpdateTaskStatusRequest)(nil), "docker.swarmkit.v1.UpdateTaskStatusRequest")
- proto.RegisterType((*UpdateTaskStatusRequest_TaskStatusUpdate)(nil), "docker.swarmkit.v1.UpdateTaskStatusRequest.TaskStatusUpdate")
- proto.RegisterType((*UpdateTaskStatusResponse)(nil), "docker.swarmkit.v1.UpdateTaskStatusResponse")
- proto.RegisterType((*TasksRequest)(nil), "docker.swarmkit.v1.TasksRequest")
- proto.RegisterType((*TasksMessage)(nil), "docker.swarmkit.v1.TasksMessage")
- proto.RegisterType((*AssignmentsRequest)(nil), "docker.swarmkit.v1.AssignmentsRequest")
- proto.RegisterType((*Assignment)(nil), "docker.swarmkit.v1.Assignment")
- proto.RegisterType((*AssignmentChange)(nil), "docker.swarmkit.v1.AssignmentChange")
- proto.RegisterType((*AssignmentsMessage)(nil), "docker.swarmkit.v1.AssignmentsMessage")
- proto.RegisterEnum("docker.swarmkit.v1.AssignmentChange_AssignmentAction", AssignmentChange_AssignmentAction_name, AssignmentChange_AssignmentAction_value)
- proto.RegisterEnum("docker.swarmkit.v1.AssignmentsMessage_Type", AssignmentsMessage_Type_name, AssignmentsMessage_Type_value)
- }
- type authenticatedWrapperDispatcherServer struct {
- local DispatcherServer
- authorize func(context.Context, []string) error
- }
- func NewAuthenticatedWrapperDispatcherServer(local DispatcherServer, authorize func(context.Context, []string) error) DispatcherServer {
- return &authenticatedWrapperDispatcherServer{
- local: local,
- authorize: authorize,
- }
- }
- func (p *authenticatedWrapperDispatcherServer) Session(r *SessionRequest, stream Dispatcher_SessionServer) error {
- if err := p.authorize(stream.Context(), []string{"swarm-worker", "swarm-manager"}); err != nil {
- return err
- }
- return p.local.Session(r, stream)
- }
- func (p *authenticatedWrapperDispatcherServer) Heartbeat(ctx context.Context, r *HeartbeatRequest) (*HeartbeatResponse, error) {
- if err := p.authorize(ctx, []string{"swarm-worker", "swarm-manager"}); err != nil {
- return nil, err
- }
- return p.local.Heartbeat(ctx, r)
- }
- func (p *authenticatedWrapperDispatcherServer) UpdateTaskStatus(ctx context.Context, r *UpdateTaskStatusRequest) (*UpdateTaskStatusResponse, error) {
- if err := p.authorize(ctx, []string{"swarm-worker", "swarm-manager"}); err != nil {
- return nil, err
- }
- return p.local.UpdateTaskStatus(ctx, r)
- }
- func (p *authenticatedWrapperDispatcherServer) Tasks(r *TasksRequest, stream Dispatcher_TasksServer) error {
- if err := p.authorize(stream.Context(), []string{"swarm-worker", "swarm-manager"}); err != nil {
- return err
- }
- return p.local.Tasks(r, stream)
- }
- func (p *authenticatedWrapperDispatcherServer) Assignments(r *AssignmentsRequest, stream Dispatcher_AssignmentsServer) error {
- if err := p.authorize(stream.Context(), []string{"swarm-worker", "swarm-manager"}); err != nil {
- return err
- }
- return p.local.Assignments(r, stream)
- }
- func (m *SessionRequest) Copy() *SessionRequest {
- if m == nil {
- return nil
- }
- o := &SessionRequest{}
- o.CopyFrom(m)
- return o
- }
- func (m *SessionRequest) CopyFrom(src interface{}) {
- o := src.(*SessionRequest)
- *m = *o
- if o.Description != nil {
- m.Description = &NodeDescription{}
- github_com_docker_swarmkit_api_deepcopy.Copy(m.Description, o.Description)
- }
- }
- func (m *SessionMessage) Copy() *SessionMessage {
- if m == nil {
- return nil
- }
- o := &SessionMessage{}
- o.CopyFrom(m)
- return o
- }
- func (m *SessionMessage) CopyFrom(src interface{}) {
- o := src.(*SessionMessage)
- *m = *o
- if o.Node != nil {
- m.Node = &Node{}
- github_com_docker_swarmkit_api_deepcopy.Copy(m.Node, o.Node)
- }
- if o.Managers != nil {
- m.Managers = make([]*WeightedPeer, len(o.Managers))
- for i := range m.Managers {
- m.Managers[i] = &WeightedPeer{}
- github_com_docker_swarmkit_api_deepcopy.Copy(m.Managers[i], o.Managers[i])
- }
- }
- if o.NetworkBootstrapKeys != nil {
- m.NetworkBootstrapKeys = make([]*EncryptionKey, len(o.NetworkBootstrapKeys))
- for i := range m.NetworkBootstrapKeys {
- m.NetworkBootstrapKeys[i] = &EncryptionKey{}
- github_com_docker_swarmkit_api_deepcopy.Copy(m.NetworkBootstrapKeys[i], o.NetworkBootstrapKeys[i])
- }
- }
- if o.RootCA != nil {
- m.RootCA = make([]byte, len(o.RootCA))
- copy(m.RootCA, o.RootCA)
- }
- }
- func (m *HeartbeatRequest) Copy() *HeartbeatRequest {
- if m == nil {
- return nil
- }
- o := &HeartbeatRequest{}
- o.CopyFrom(m)
- return o
- }
- func (m *HeartbeatRequest) CopyFrom(src interface{}) {
- o := src.(*HeartbeatRequest)
- *m = *o
- }
- func (m *HeartbeatResponse) Copy() *HeartbeatResponse {
- if m == nil {
- return nil
- }
- o := &HeartbeatResponse{}
- o.CopyFrom(m)
- return o
- }
- func (m *HeartbeatResponse) CopyFrom(src interface{}) {
- o := src.(*HeartbeatResponse)
- *m = *o
- github_com_docker_swarmkit_api_deepcopy.Copy(&m.Period, &o.Period)
- }
- func (m *UpdateTaskStatusRequest) Copy() *UpdateTaskStatusRequest {
- if m == nil {
- return nil
- }
- o := &UpdateTaskStatusRequest{}
- o.CopyFrom(m)
- return o
- }
- func (m *UpdateTaskStatusRequest) CopyFrom(src interface{}) {
- o := src.(*UpdateTaskStatusRequest)
- *m = *o
- if o.Updates != nil {
- m.Updates = make([]*UpdateTaskStatusRequest_TaskStatusUpdate, len(o.Updates))
- for i := range m.Updates {
- m.Updates[i] = &UpdateTaskStatusRequest_TaskStatusUpdate{}
- github_com_docker_swarmkit_api_deepcopy.Copy(m.Updates[i], o.Updates[i])
- }
- }
- }
- func (m *UpdateTaskStatusRequest_TaskStatusUpdate) Copy() *UpdateTaskStatusRequest_TaskStatusUpdate {
- if m == nil {
- return nil
- }
- o := &UpdateTaskStatusRequest_TaskStatusUpdate{}
- o.CopyFrom(m)
- return o
- }
- func (m *UpdateTaskStatusRequest_TaskStatusUpdate) CopyFrom(src interface{}) {
- o := src.(*UpdateTaskStatusRequest_TaskStatusUpdate)
- *m = *o
- if o.Status != nil {
- m.Status = &TaskStatus{}
- github_com_docker_swarmkit_api_deepcopy.Copy(m.Status, o.Status)
- }
- }
- func (m *UpdateTaskStatusResponse) Copy() *UpdateTaskStatusResponse {
- if m == nil {
- return nil
- }
- o := &UpdateTaskStatusResponse{}
- o.CopyFrom(m)
- return o
- }
- func (m *UpdateTaskStatusResponse) CopyFrom(src interface{}) {}
- func (m *TasksRequest) Copy() *TasksRequest {
- if m == nil {
- return nil
- }
- o := &TasksRequest{}
- o.CopyFrom(m)
- return o
- }
- func (m *TasksRequest) CopyFrom(src interface{}) {
- o := src.(*TasksRequest)
- *m = *o
- }
- func (m *TasksMessage) Copy() *TasksMessage {
- if m == nil {
- return nil
- }
- o := &TasksMessage{}
- o.CopyFrom(m)
- return o
- }
- func (m *TasksMessage) CopyFrom(src interface{}) {
- o := src.(*TasksMessage)
- *m = *o
- if o.Tasks != nil {
- m.Tasks = make([]*Task, len(o.Tasks))
- for i := range m.Tasks {
- m.Tasks[i] = &Task{}
- github_com_docker_swarmkit_api_deepcopy.Copy(m.Tasks[i], o.Tasks[i])
- }
- }
- }
- func (m *AssignmentsRequest) Copy() *AssignmentsRequest {
- if m == nil {
- return nil
- }
- o := &AssignmentsRequest{}
- o.CopyFrom(m)
- return o
- }
- func (m *AssignmentsRequest) CopyFrom(src interface{}) {
- o := src.(*AssignmentsRequest)
- *m = *o
- }
- func (m *Assignment) Copy() *Assignment {
- if m == nil {
- return nil
- }
- o := &Assignment{}
- o.CopyFrom(m)
- return o
- }
- func (m *Assignment) CopyFrom(src interface{}) {
- o := src.(*Assignment)
- *m = *o
- if o.Item != nil {
- switch o.Item.(type) {
- case *Assignment_Task:
- v := Assignment_Task{
- Task: &Task{},
- }
- github_com_docker_swarmkit_api_deepcopy.Copy(v.Task, o.GetTask())
- m.Item = &v
- case *Assignment_Secret:
- v := Assignment_Secret{
- Secret: &Secret{},
- }
- github_com_docker_swarmkit_api_deepcopy.Copy(v.Secret, o.GetSecret())
- m.Item = &v
- case *Assignment_Config:
- v := Assignment_Config{
- Config: &Config{},
- }
- github_com_docker_swarmkit_api_deepcopy.Copy(v.Config, o.GetConfig())
- m.Item = &v
- }
- }
- }
- func (m *AssignmentChange) Copy() *AssignmentChange {
- if m == nil {
- return nil
- }
- o := &AssignmentChange{}
- o.CopyFrom(m)
- return o
- }
- func (m *AssignmentChange) CopyFrom(src interface{}) {
- o := src.(*AssignmentChange)
- *m = *o
- if o.Assignment != nil {
- m.Assignment = &Assignment{}
- github_com_docker_swarmkit_api_deepcopy.Copy(m.Assignment, o.Assignment)
- }
- }
- func (m *AssignmentsMessage) Copy() *AssignmentsMessage {
- if m == nil {
- return nil
- }
- o := &AssignmentsMessage{}
- o.CopyFrom(m)
- return o
- }
- func (m *AssignmentsMessage) CopyFrom(src interface{}) {
- o := src.(*AssignmentsMessage)
- *m = *o
- if o.Changes != nil {
- m.Changes = make([]*AssignmentChange, len(o.Changes))
- for i := range m.Changes {
- m.Changes[i] = &AssignmentChange{}
- github_com_docker_swarmkit_api_deepcopy.Copy(m.Changes[i], o.Changes[i])
- }
- }
- }
- // Reference imports to suppress errors if they are not otherwise used.
- var _ context.Context
- var _ grpc.ClientConn
- // This is a compile-time assertion to ensure that this generated file
- // is compatible with the grpc package it is being compiled against.
- const _ = grpc.SupportPackageIsVersion4
- // Client API for Dispatcher service
- type DispatcherClient interface {
- // Session starts an agent session with the dispatcher. The session is
- // started after the first SessionMessage is received.
- //
- // Once started, the agent is controlled with a stream of SessionMessage.
- // Agents should list on the stream at all times for instructions.
- Session(ctx context.Context, in *SessionRequest, opts ...grpc.CallOption) (Dispatcher_SessionClient, error)
- // Heartbeat is heartbeat method for nodes. It returns new TTL in response.
- // Node should send new heartbeat earlier than now + TTL, otherwise it will
- // be deregistered from dispatcher and its status will be updated to NodeStatus_DOWN
- Heartbeat(ctx context.Context, in *HeartbeatRequest, opts ...grpc.CallOption) (*HeartbeatResponse, error)
- // UpdateTaskStatus updates status of task. Node should send such updates
- // on every status change of its tasks.
- //
- // Whether receiving batch updates or single status updates, this method
- // should be accepting. Errors should only be returned if the entire update
- // should be retried, due to data loss or other problems.
- //
- // If a task is unknown the dispatcher, the status update should be
- // accepted regardless.
- UpdateTaskStatus(ctx context.Context, in *UpdateTaskStatusRequest, opts ...grpc.CallOption) (*UpdateTaskStatusResponse, error)
- // Tasks is a stream of tasks state for node. Each message contains full list
- // of tasks which should be run on node, if task is not present in that list,
- // it should be terminated.
- Tasks(ctx context.Context, in *TasksRequest, opts ...grpc.CallOption) (Dispatcher_TasksClient, error)
- // Assignments is a stream of assignments such as tasks and secrets for node.
- // The first message in the stream contains all of the tasks and secrets
- // that are relevant to the node. Future messages in the stream are updates to
- // the set of assignments.
- Assignments(ctx context.Context, in *AssignmentsRequest, opts ...grpc.CallOption) (Dispatcher_AssignmentsClient, error)
- }
- type dispatcherClient struct {
- cc *grpc.ClientConn
- }
- func NewDispatcherClient(cc *grpc.ClientConn) DispatcherClient {
- return &dispatcherClient{cc}
- }
- func (c *dispatcherClient) Session(ctx context.Context, in *SessionRequest, opts ...grpc.CallOption) (Dispatcher_SessionClient, error) {
- stream, err := grpc.NewClientStream(ctx, &_Dispatcher_serviceDesc.Streams[0], c.cc, "/docker.swarmkit.v1.Dispatcher/Session", opts...)
- if err != nil {
- return nil, err
- }
- x := &dispatcherSessionClient{stream}
- if err := x.ClientStream.SendMsg(in); err != nil {
- return nil, err
- }
- if err := x.ClientStream.CloseSend(); err != nil {
- return nil, err
- }
- return x, nil
- }
- type Dispatcher_SessionClient interface {
- Recv() (*SessionMessage, error)
- grpc.ClientStream
- }
- type dispatcherSessionClient struct {
- grpc.ClientStream
- }
- func (x *dispatcherSessionClient) Recv() (*SessionMessage, error) {
- m := new(SessionMessage)
- if err := x.ClientStream.RecvMsg(m); err != nil {
- return nil, err
- }
- return m, nil
- }
- func (c *dispatcherClient) Heartbeat(ctx context.Context, in *HeartbeatRequest, opts ...grpc.CallOption) (*HeartbeatResponse, error) {
- out := new(HeartbeatResponse)
- err := grpc.Invoke(ctx, "/docker.swarmkit.v1.Dispatcher/Heartbeat", in, out, c.cc, opts...)
- if err != nil {
- return nil, err
- }
- return out, nil
- }
- func (c *dispatcherClient) UpdateTaskStatus(ctx context.Context, in *UpdateTaskStatusRequest, opts ...grpc.CallOption) (*UpdateTaskStatusResponse, error) {
- out := new(UpdateTaskStatusResponse)
- err := grpc.Invoke(ctx, "/docker.swarmkit.v1.Dispatcher/UpdateTaskStatus", in, out, c.cc, opts...)
- if err != nil {
- return nil, err
- }
- return out, nil
- }
- func (c *dispatcherClient) Tasks(ctx context.Context, in *TasksRequest, opts ...grpc.CallOption) (Dispatcher_TasksClient, error) {
- stream, err := grpc.NewClientStream(ctx, &_Dispatcher_serviceDesc.Streams[1], c.cc, "/docker.swarmkit.v1.Dispatcher/Tasks", opts...)
- if err != nil {
- return nil, err
- }
- x := &dispatcherTasksClient{stream}
- if err := x.ClientStream.SendMsg(in); err != nil {
- return nil, err
- }
- if err := x.ClientStream.CloseSend(); err != nil {
- return nil, err
- }
- return x, nil
- }
- type Dispatcher_TasksClient interface {
- Recv() (*TasksMessage, error)
- grpc.ClientStream
- }
- type dispatcherTasksClient struct {
- grpc.ClientStream
- }
- func (x *dispatcherTasksClient) Recv() (*TasksMessage, error) {
- m := new(TasksMessage)
- if err := x.ClientStream.RecvMsg(m); err != nil {
- return nil, err
- }
- return m, nil
- }
- func (c *dispatcherClient) Assignments(ctx context.Context, in *AssignmentsRequest, opts ...grpc.CallOption) (Dispatcher_AssignmentsClient, error) {
- stream, err := grpc.NewClientStream(ctx, &_Dispatcher_serviceDesc.Streams[2], c.cc, "/docker.swarmkit.v1.Dispatcher/Assignments", opts...)
- if err != nil {
- return nil, err
- }
- x := &dispatcherAssignmentsClient{stream}
- if err := x.ClientStream.SendMsg(in); err != nil {
- return nil, err
- }
- if err := x.ClientStream.CloseSend(); err != nil {
- return nil, err
- }
- return x, nil
- }
- type Dispatcher_AssignmentsClient interface {
- Recv() (*AssignmentsMessage, error)
- grpc.ClientStream
- }
- type dispatcherAssignmentsClient struct {
- grpc.ClientStream
- }
- func (x *dispatcherAssignmentsClient) Recv() (*AssignmentsMessage, error) {
- m := new(AssignmentsMessage)
- if err := x.ClientStream.RecvMsg(m); err != nil {
- return nil, err
- }
- return m, nil
- }
- // Server API for Dispatcher service
- type DispatcherServer interface {
- // Session starts an agent session with the dispatcher. The session is
- // started after the first SessionMessage is received.
- //
- // Once started, the agent is controlled with a stream of SessionMessage.
- // Agents should list on the stream at all times for instructions.
- Session(*SessionRequest, Dispatcher_SessionServer) error
- // Heartbeat is heartbeat method for nodes. It returns new TTL in response.
- // Node should send new heartbeat earlier than now + TTL, otherwise it will
- // be deregistered from dispatcher and its status will be updated to NodeStatus_DOWN
- Heartbeat(context.Context, *HeartbeatRequest) (*HeartbeatResponse, error)
- // UpdateTaskStatus updates status of task. Node should send such updates
- // on every status change of its tasks.
- //
- // Whether receiving batch updates or single status updates, this method
- // should be accepting. Errors should only be returned if the entire update
- // should be retried, due to data loss or other problems.
- //
- // If a task is unknown the dispatcher, the status update should be
- // accepted regardless.
- UpdateTaskStatus(context.Context, *UpdateTaskStatusRequest) (*UpdateTaskStatusResponse, error)
- // Tasks is a stream of tasks state for node. Each message contains full list
- // of tasks which should be run on node, if task is not present in that list,
- // it should be terminated.
- Tasks(*TasksRequest, Dispatcher_TasksServer) error
- // Assignments is a stream of assignments such as tasks and secrets for node.
- // The first message in the stream contains all of the tasks and secrets
- // that are relevant to the node. Future messages in the stream are updates to
- // the set of assignments.
- Assignments(*AssignmentsRequest, Dispatcher_AssignmentsServer) error
- }
- func RegisterDispatcherServer(s *grpc.Server, srv DispatcherServer) {
- s.RegisterService(&_Dispatcher_serviceDesc, srv)
- }
- func _Dispatcher_Session_Handler(srv interface{}, stream grpc.ServerStream) error {
- m := new(SessionRequest)
- if err := stream.RecvMsg(m); err != nil {
- return err
- }
- return srv.(DispatcherServer).Session(m, &dispatcherSessionServer{stream})
- }
- type Dispatcher_SessionServer interface {
- Send(*SessionMessage) error
- grpc.ServerStream
- }
- type dispatcherSessionServer struct {
- grpc.ServerStream
- }
- func (x *dispatcherSessionServer) Send(m *SessionMessage) error {
- return x.ServerStream.SendMsg(m)
- }
- func _Dispatcher_Heartbeat_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
- in := new(HeartbeatRequest)
- if err := dec(in); err != nil {
- return nil, err
- }
- if interceptor == nil {
- return srv.(DispatcherServer).Heartbeat(ctx, in)
- }
- info := &grpc.UnaryServerInfo{
- Server: srv,
- FullMethod: "/docker.swarmkit.v1.Dispatcher/Heartbeat",
- }
- handler := func(ctx context.Context, req interface{}) (interface{}, error) {
- return srv.(DispatcherServer).Heartbeat(ctx, req.(*HeartbeatRequest))
- }
- return interceptor(ctx, in, info, handler)
- }
- func _Dispatcher_UpdateTaskStatus_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
- in := new(UpdateTaskStatusRequest)
- if err := dec(in); err != nil {
- return nil, err
- }
- if interceptor == nil {
- return srv.(DispatcherServer).UpdateTaskStatus(ctx, in)
- }
- info := &grpc.UnaryServerInfo{
- Server: srv,
- FullMethod: "/docker.swarmkit.v1.Dispatcher/UpdateTaskStatus",
- }
- handler := func(ctx context.Context, req interface{}) (interface{}, error) {
- return srv.(DispatcherServer).UpdateTaskStatus(ctx, req.(*UpdateTaskStatusRequest))
- }
- return interceptor(ctx, in, info, handler)
- }
- func _Dispatcher_Tasks_Handler(srv interface{}, stream grpc.ServerStream) error {
- m := new(TasksRequest)
- if err := stream.RecvMsg(m); err != nil {
- return err
- }
- return srv.(DispatcherServer).Tasks(m, &dispatcherTasksServer{stream})
- }
- type Dispatcher_TasksServer interface {
- Send(*TasksMessage) error
- grpc.ServerStream
- }
- type dispatcherTasksServer struct {
- grpc.ServerStream
- }
- func (x *dispatcherTasksServer) Send(m *TasksMessage) error {
- return x.ServerStream.SendMsg(m)
- }
- func _Dispatcher_Assignments_Handler(srv interface{}, stream grpc.ServerStream) error {
- m := new(AssignmentsRequest)
- if err := stream.RecvMsg(m); err != nil {
- return err
- }
- return srv.(DispatcherServer).Assignments(m, &dispatcherAssignmentsServer{stream})
- }
- type Dispatcher_AssignmentsServer interface {
- Send(*AssignmentsMessage) error
- grpc.ServerStream
- }
- type dispatcherAssignmentsServer struct {
- grpc.ServerStream
- }
- func (x *dispatcherAssignmentsServer) Send(m *AssignmentsMessage) error {
- return x.ServerStream.SendMsg(m)
- }
- var _Dispatcher_serviceDesc = grpc.ServiceDesc{
- ServiceName: "docker.swarmkit.v1.Dispatcher",
- HandlerType: (*DispatcherServer)(nil),
- Methods: []grpc.MethodDesc{
- {
- MethodName: "Heartbeat",
- Handler: _Dispatcher_Heartbeat_Handler,
- },
- {
- MethodName: "UpdateTaskStatus",
- Handler: _Dispatcher_UpdateTaskStatus_Handler,
- },
- },
- Streams: []grpc.StreamDesc{
- {
- StreamName: "Session",
- Handler: _Dispatcher_Session_Handler,
- ServerStreams: true,
- },
- {
- StreamName: "Tasks",
- Handler: _Dispatcher_Tasks_Handler,
- ServerStreams: true,
- },
- {
- StreamName: "Assignments",
- Handler: _Dispatcher_Assignments_Handler,
- ServerStreams: true,
- },
- },
- Metadata: "dispatcher.proto",
- }
- func (m *SessionRequest) 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 *SessionRequest) MarshalTo(dAtA []byte) (int, error) {
- var i int
- _ = i
- var l int
- _ = l
- if m.Description != nil {
- dAtA[i] = 0xa
- i++
- i = encodeVarintDispatcher(dAtA, i, uint64(m.Description.Size()))
- n1, err := m.Description.MarshalTo(dAtA[i:])
- if err != nil {
- return 0, err
- }
- i += n1
- }
- if len(m.SessionID) > 0 {
- dAtA[i] = 0x12
- i++
- i = encodeVarintDispatcher(dAtA, i, uint64(len(m.SessionID)))
- i += copy(dAtA[i:], m.SessionID)
- }
- return i, nil
- }
- func (m *SessionMessage) 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 *SessionMessage) MarshalTo(dAtA []byte) (int, error) {
- var i int
- _ = i
- var l int
- _ = l
- if len(m.SessionID) > 0 {
- dAtA[i] = 0xa
- i++
- i = encodeVarintDispatcher(dAtA, i, uint64(len(m.SessionID)))
- i += copy(dAtA[i:], m.SessionID)
- }
- if m.Node != nil {
- dAtA[i] = 0x12
- i++
- i = encodeVarintDispatcher(dAtA, i, uint64(m.Node.Size()))
- n2, err := m.Node.MarshalTo(dAtA[i:])
- if err != nil {
- return 0, err
- }
- i += n2
- }
- if len(m.Managers) > 0 {
- for _, msg := range m.Managers {
- dAtA[i] = 0x1a
- i++
- i = encodeVarintDispatcher(dAtA, i, uint64(msg.Size()))
- n, err := msg.MarshalTo(dAtA[i:])
- if err != nil {
- return 0, err
- }
- i += n
- }
- }
- if len(m.NetworkBootstrapKeys) > 0 {
- for _, msg := range m.NetworkBootstrapKeys {
- dAtA[i] = 0x22
- i++
- i = encodeVarintDispatcher(dAtA, i, uint64(msg.Size()))
- n, err := msg.MarshalTo(dAtA[i:])
- if err != nil {
- return 0, err
- }
- i += n
- }
- }
- if len(m.RootCA) > 0 {
- dAtA[i] = 0x2a
- i++
- i = encodeVarintDispatcher(dAtA, i, uint64(len(m.RootCA)))
- i += copy(dAtA[i:], m.RootCA)
- }
- return i, nil
- }
- func (m *HeartbeatRequest) 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 *HeartbeatRequest) MarshalTo(dAtA []byte) (int, error) {
- var i int
- _ = i
- var l int
- _ = l
- if len(m.SessionID) > 0 {
- dAtA[i] = 0xa
- i++
- i = encodeVarintDispatcher(dAtA, i, uint64(len(m.SessionID)))
- i += copy(dAtA[i:], m.SessionID)
- }
- return i, nil
- }
- func (m *HeartbeatResponse) 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 *HeartbeatResponse) MarshalTo(dAtA []byte) (int, error) {
- var i int
- _ = i
- var l int
- _ = l
- dAtA[i] = 0xa
- i++
- i = encodeVarintDispatcher(dAtA, i, uint64(github_com_gogo_protobuf_types.SizeOfStdDuration(m.Period)))
- n3, err := github_com_gogo_protobuf_types.StdDurationMarshalTo(m.Period, dAtA[i:])
- if err != nil {
- return 0, err
- }
- i += n3
- return i, nil
- }
- func (m *UpdateTaskStatusRequest) 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 *UpdateTaskStatusRequest) MarshalTo(dAtA []byte) (int, error) {
- var i int
- _ = i
- var l int
- _ = l
- if len(m.SessionID) > 0 {
- dAtA[i] = 0xa
- i++
- i = encodeVarintDispatcher(dAtA, i, uint64(len(m.SessionID)))
- i += copy(dAtA[i:], m.SessionID)
- }
- if len(m.Updates) > 0 {
- for _, msg := range m.Updates {
- dAtA[i] = 0x1a
- i++
- i = encodeVarintDispatcher(dAtA, i, uint64(msg.Size()))
- n, err := msg.MarshalTo(dAtA[i:])
- if err != nil {
- return 0, err
- }
- i += n
- }
- }
- return i, nil
- }
- func (m *UpdateTaskStatusRequest_TaskStatusUpdate) 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 *UpdateTaskStatusRequest_TaskStatusUpdate) MarshalTo(dAtA []byte) (int, error) {
- var i int
- _ = i
- var l int
- _ = l
- if len(m.TaskID) > 0 {
- dAtA[i] = 0xa
- i++
- i = encodeVarintDispatcher(dAtA, i, uint64(len(m.TaskID)))
- i += copy(dAtA[i:], m.TaskID)
- }
- if m.Status != nil {
- dAtA[i] = 0x12
- i++
- i = encodeVarintDispatcher(dAtA, i, uint64(m.Status.Size()))
- n4, err := m.Status.MarshalTo(dAtA[i:])
- if err != nil {
- return 0, err
- }
- i += n4
- }
- return i, nil
- }
- func (m *UpdateTaskStatusResponse) 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 *UpdateTaskStatusResponse) MarshalTo(dAtA []byte) (int, error) {
- var i int
- _ = i
- var l int
- _ = l
- return i, nil
- }
- func (m *TasksRequest) 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 *TasksRequest) MarshalTo(dAtA []byte) (int, error) {
- var i int
- _ = i
- var l int
- _ = l
- if len(m.SessionID) > 0 {
- dAtA[i] = 0xa
- i++
- i = encodeVarintDispatcher(dAtA, i, uint64(len(m.SessionID)))
- i += copy(dAtA[i:], m.SessionID)
- }
- return i, nil
- }
- func (m *TasksMessage) 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 *TasksMessage) MarshalTo(dAtA []byte) (int, error) {
- var i int
- _ = i
- var l int
- _ = l
- if len(m.Tasks) > 0 {
- for _, msg := range m.Tasks {
- dAtA[i] = 0xa
- i++
- i = encodeVarintDispatcher(dAtA, i, uint64(msg.Size()))
- n, err := msg.MarshalTo(dAtA[i:])
- if err != nil {
- return 0, err
- }
- i += n
- }
- }
- return i, nil
- }
- func (m *AssignmentsRequest) 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 *AssignmentsRequest) MarshalTo(dAtA []byte) (int, error) {
- var i int
- _ = i
- var l int
- _ = l
- if len(m.SessionID) > 0 {
- dAtA[i] = 0xa
- i++
- i = encodeVarintDispatcher(dAtA, i, uint64(len(m.SessionID)))
- i += copy(dAtA[i:], m.SessionID)
- }
- return i, nil
- }
- func (m *Assignment) 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 *Assignment) MarshalTo(dAtA []byte) (int, error) {
- var i int
- _ = i
- var l int
- _ = l
- if m.Item != nil {
- nn5, err := m.Item.MarshalTo(dAtA[i:])
- if err != nil {
- return 0, err
- }
- i += nn5
- }
- return i, nil
- }
- func (m *Assignment_Task) MarshalTo(dAtA []byte) (int, error) {
- i := 0
- if m.Task != nil {
- dAtA[i] = 0xa
- i++
- i = encodeVarintDispatcher(dAtA, i, uint64(m.Task.Size()))
- n6, err := m.Task.MarshalTo(dAtA[i:])
- if err != nil {
- return 0, err
- }
- i += n6
- }
- return i, nil
- }
- func (m *Assignment_Secret) MarshalTo(dAtA []byte) (int, error) {
- i := 0
- if m.Secret != nil {
- dAtA[i] = 0x12
- i++
- i = encodeVarintDispatcher(dAtA, i, uint64(m.Secret.Size()))
- n7, err := m.Secret.MarshalTo(dAtA[i:])
- if err != nil {
- return 0, err
- }
- i += n7
- }
- return i, nil
- }
- func (m *Assignment_Config) MarshalTo(dAtA []byte) (int, error) {
- i := 0
- if m.Config != nil {
- dAtA[i] = 0x1a
- i++
- i = encodeVarintDispatcher(dAtA, i, uint64(m.Config.Size()))
- n8, err := m.Config.MarshalTo(dAtA[i:])
- if err != nil {
- return 0, err
- }
- i += n8
- }
- return i, nil
- }
- func (m *AssignmentChange) 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 *AssignmentChange) MarshalTo(dAtA []byte) (int, error) {
- var i int
- _ = i
- var l int
- _ = l
- if m.Assignment != nil {
- dAtA[i] = 0xa
- i++
- i = encodeVarintDispatcher(dAtA, i, uint64(m.Assignment.Size()))
- n9, err := m.Assignment.MarshalTo(dAtA[i:])
- if err != nil {
- return 0, err
- }
- i += n9
- }
- if m.Action != 0 {
- dAtA[i] = 0x10
- i++
- i = encodeVarintDispatcher(dAtA, i, uint64(m.Action))
- }
- return i, nil
- }
- func (m *AssignmentsMessage) 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 *AssignmentsMessage) MarshalTo(dAtA []byte) (int, error) {
- var i int
- _ = i
- var l int
- _ = l
- if m.Type != 0 {
- dAtA[i] = 0x8
- i++
- i = encodeVarintDispatcher(dAtA, i, uint64(m.Type))
- }
- if len(m.AppliesTo) > 0 {
- dAtA[i] = 0x12
- i++
- i = encodeVarintDispatcher(dAtA, i, uint64(len(m.AppliesTo)))
- i += copy(dAtA[i:], m.AppliesTo)
- }
- if len(m.ResultsIn) > 0 {
- dAtA[i] = 0x1a
- i++
- i = encodeVarintDispatcher(dAtA, i, uint64(len(m.ResultsIn)))
- i += copy(dAtA[i:], m.ResultsIn)
- }
- if len(m.Changes) > 0 {
- for _, msg := range m.Changes {
- dAtA[i] = 0x22
- i++
- i = encodeVarintDispatcher(dAtA, i, uint64(msg.Size()))
- n, err := msg.MarshalTo(dAtA[i:])
- if err != nil {
- return 0, err
- }
- i += n
- }
- }
- return i, nil
- }
- func encodeFixed64Dispatcher(dAtA []byte, offset int, v uint64) int {
- dAtA[offset] = uint8(v)
- dAtA[offset+1] = uint8(v >> 8)
- dAtA[offset+2] = uint8(v >> 16)
- dAtA[offset+3] = uint8(v >> 24)
- dAtA[offset+4] = uint8(v >> 32)
- dAtA[offset+5] = uint8(v >> 40)
- dAtA[offset+6] = uint8(v >> 48)
- dAtA[offset+7] = uint8(v >> 56)
- return offset + 8
- }
- func encodeFixed32Dispatcher(dAtA []byte, offset int, v uint32) int {
- dAtA[offset] = uint8(v)
- dAtA[offset+1] = uint8(v >> 8)
- dAtA[offset+2] = uint8(v >> 16)
- dAtA[offset+3] = uint8(v >> 24)
- return offset + 4
- }
- func encodeVarintDispatcher(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
- }
- type raftProxyDispatcherServer struct {
- local DispatcherServer
- connSelector raftselector.ConnProvider
- localCtxMods, remoteCtxMods []func(context.Context) (context.Context, error)
- }
- func NewRaftProxyDispatcherServer(local DispatcherServer, connSelector raftselector.ConnProvider, localCtxMod, remoteCtxMod func(context.Context) (context.Context, error)) DispatcherServer {
- redirectChecker := func(ctx context.Context) (context.Context, error) {
- s, ok := transport.StreamFromContext(ctx)
- if !ok {
- return ctx, grpc.Errorf(codes.InvalidArgument, "remote addr is not found in context")
- }
- addr := s.ServerTransport().RemoteAddr().String()
- md, ok := metadata.FromContext(ctx)
- if ok && len(md["redirect"]) != 0 {
- return ctx, grpc.Errorf(codes.ResourceExhausted, "more than one redirect to leader from: %s", md["redirect"])
- }
- if !ok {
- md = metadata.New(map[string]string{})
- }
- md["redirect"] = append(md["redirect"], addr)
- return metadata.NewContext(ctx, md), nil
- }
- remoteMods := []func(context.Context) (context.Context, error){redirectChecker}
- remoteMods = append(remoteMods, remoteCtxMod)
- var localMods []func(context.Context) (context.Context, error)
- if localCtxMod != nil {
- localMods = []func(context.Context) (context.Context, error){localCtxMod}
- }
- return &raftProxyDispatcherServer{
- local: local,
- connSelector: connSelector,
- localCtxMods: localMods,
- remoteCtxMods: remoteMods,
- }
- }
- func (p *raftProxyDispatcherServer) runCtxMods(ctx context.Context, ctxMods []func(context.Context) (context.Context, error)) (context.Context, error) {
- var err error
- for _, mod := range ctxMods {
- ctx, err = mod(ctx)
- if err != nil {
- return ctx, err
- }
- }
- return ctx, nil
- }
- func (p *raftProxyDispatcherServer) pollNewLeaderConn(ctx context.Context) (*grpc.ClientConn, error) {
- ticker := rafttime.NewTicker(500 * rafttime.Millisecond)
- defer ticker.Stop()
- for {
- select {
- case <-ticker.C:
- conn, err := p.connSelector.LeaderConn(ctx)
- if err != nil {
- return nil, err
- }
- client := NewHealthClient(conn)
- resp, err := client.Check(ctx, &HealthCheckRequest{Service: "Raft"})
- if err != nil || resp.Status != HealthCheckResponse_SERVING {
- continue
- }
- return conn, nil
- case <-ctx.Done():
- return nil, ctx.Err()
- }
- }
- }
- type Dispatcher_SessionServerWrapper struct {
- Dispatcher_SessionServer
- ctx context.Context
- }
- func (s Dispatcher_SessionServerWrapper) Context() context.Context {
- return s.ctx
- }
- func (p *raftProxyDispatcherServer) Session(r *SessionRequest, stream Dispatcher_SessionServer) error {
- ctx := stream.Context()
- conn, err := p.connSelector.LeaderConn(ctx)
- if err != nil {
- if err == raftselector.ErrIsLeader {
- ctx, err = p.runCtxMods(ctx, p.localCtxMods)
- if err != nil {
- return err
- }
- streamWrapper := Dispatcher_SessionServerWrapper{
- Dispatcher_SessionServer: stream,
- ctx: ctx,
- }
- return p.local.Session(r, streamWrapper)
- }
- return err
- }
- ctx, err = p.runCtxMods(ctx, p.remoteCtxMods)
- if err != nil {
- return err
- }
- clientStream, err := NewDispatcherClient(conn).Session(ctx, r)
- if err != nil {
- return err
- }
- for {
- msg, err := clientStream.Recv()
- if err == io.EOF {
- break
- }
- if err != nil {
- return err
- }
- if err := stream.Send(msg); err != nil {
- return err
- }
- }
- return nil
- }
- func (p *raftProxyDispatcherServer) Heartbeat(ctx context.Context, r *HeartbeatRequest) (*HeartbeatResponse, error) {
- conn, err := p.connSelector.LeaderConn(ctx)
- if err != nil {
- if err == raftselector.ErrIsLeader {
- ctx, err = p.runCtxMods(ctx, p.localCtxMods)
- if err != nil {
- return nil, err
- }
- return p.local.Heartbeat(ctx, r)
- }
- return nil, err
- }
- modCtx, err := p.runCtxMods(ctx, p.remoteCtxMods)
- if err != nil {
- return nil, err
- }
- resp, err := NewDispatcherClient(conn).Heartbeat(modCtx, r)
- if err != nil {
- if !strings.Contains(err.Error(), "is closing") && !strings.Contains(err.Error(), "the connection is unavailable") && !strings.Contains(err.Error(), "connection error") {
- return resp, err
- }
- conn, err := p.pollNewLeaderConn(ctx)
- if err != nil {
- if err == raftselector.ErrIsLeader {
- return p.local.Heartbeat(ctx, r)
- }
- return nil, err
- }
- return NewDispatcherClient(conn).Heartbeat(modCtx, r)
- }
- return resp, err
- }
- func (p *raftProxyDispatcherServer) UpdateTaskStatus(ctx context.Context, r *UpdateTaskStatusRequest) (*UpdateTaskStatusResponse, error) {
- conn, err := p.connSelector.LeaderConn(ctx)
- if err != nil {
- if err == raftselector.ErrIsLeader {
- ctx, err = p.runCtxMods(ctx, p.localCtxMods)
- if err != nil {
- return nil, err
- }
- return p.local.UpdateTaskStatus(ctx, r)
- }
- return nil, err
- }
- modCtx, err := p.runCtxMods(ctx, p.remoteCtxMods)
- if err != nil {
- return nil, err
- }
- resp, err := NewDispatcherClient(conn).UpdateTaskStatus(modCtx, r)
- if err != nil {
- if !strings.Contains(err.Error(), "is closing") && !strings.Contains(err.Error(), "the connection is unavailable") && !strings.Contains(err.Error(), "connection error") {
- return resp, err
- }
- conn, err := p.pollNewLeaderConn(ctx)
- if err != nil {
- if err == raftselector.ErrIsLeader {
- return p.local.UpdateTaskStatus(ctx, r)
- }
- return nil, err
- }
- return NewDispatcherClient(conn).UpdateTaskStatus(modCtx, r)
- }
- return resp, err
- }
- type Dispatcher_TasksServerWrapper struct {
- Dispatcher_TasksServer
- ctx context.Context
- }
- func (s Dispatcher_TasksServerWrapper) Context() context.Context {
- return s.ctx
- }
- func (p *raftProxyDispatcherServer) Tasks(r *TasksRequest, stream Dispatcher_TasksServer) error {
- ctx := stream.Context()
- conn, err := p.connSelector.LeaderConn(ctx)
- if err != nil {
- if err == raftselector.ErrIsLeader {
- ctx, err = p.runCtxMods(ctx, p.localCtxMods)
- if err != nil {
- return err
- }
- streamWrapper := Dispatcher_TasksServerWrapper{
- Dispatcher_TasksServer: stream,
- ctx: ctx,
- }
- return p.local.Tasks(r, streamWrapper)
- }
- return err
- }
- ctx, err = p.runCtxMods(ctx, p.remoteCtxMods)
- if err != nil {
- return err
- }
- clientStream, err := NewDispatcherClient(conn).Tasks(ctx, r)
- if err != nil {
- return err
- }
- for {
- msg, err := clientStream.Recv()
- if err == io.EOF {
- break
- }
- if err != nil {
- return err
- }
- if err := stream.Send(msg); err != nil {
- return err
- }
- }
- return nil
- }
- type Dispatcher_AssignmentsServerWrapper struct {
- Dispatcher_AssignmentsServer
- ctx context.Context
- }
- func (s Dispatcher_AssignmentsServerWrapper) Context() context.Context {
- return s.ctx
- }
- func (p *raftProxyDispatcherServer) Assignments(r *AssignmentsRequest, stream Dispatcher_AssignmentsServer) error {
- ctx := stream.Context()
- conn, err := p.connSelector.LeaderConn(ctx)
- if err != nil {
- if err == raftselector.ErrIsLeader {
- ctx, err = p.runCtxMods(ctx, p.localCtxMods)
- if err != nil {
- return err
- }
- streamWrapper := Dispatcher_AssignmentsServerWrapper{
- Dispatcher_AssignmentsServer: stream,
- ctx: ctx,
- }
- return p.local.Assignments(r, streamWrapper)
- }
- return err
- }
- ctx, err = p.runCtxMods(ctx, p.remoteCtxMods)
- if err != nil {
- return err
- }
- clientStream, err := NewDispatcherClient(conn).Assignments(ctx, r)
- if err != nil {
- return err
- }
- for {
- msg, err := clientStream.Recv()
- if err == io.EOF {
- break
- }
- if err != nil {
- return err
- }
- if err := stream.Send(msg); err != nil {
- return err
- }
- }
- return nil
- }
- func (m *SessionRequest) Size() (n int) {
- var l int
- _ = l
- if m.Description != nil {
- l = m.Description.Size()
- n += 1 + l + sovDispatcher(uint64(l))
- }
- l = len(m.SessionID)
- if l > 0 {
- n += 1 + l + sovDispatcher(uint64(l))
- }
- return n
- }
- func (m *SessionMessage) Size() (n int) {
- var l int
- _ = l
- l = len(m.SessionID)
- if l > 0 {
- n += 1 + l + sovDispatcher(uint64(l))
- }
- if m.Node != nil {
- l = m.Node.Size()
- n += 1 + l + sovDispatcher(uint64(l))
- }
- if len(m.Managers) > 0 {
- for _, e := range m.Managers {
- l = e.Size()
- n += 1 + l + sovDispatcher(uint64(l))
- }
- }
- if len(m.NetworkBootstrapKeys) > 0 {
- for _, e := range m.NetworkBootstrapKeys {
- l = e.Size()
- n += 1 + l + sovDispatcher(uint64(l))
- }
- }
- l = len(m.RootCA)
- if l > 0 {
- n += 1 + l + sovDispatcher(uint64(l))
- }
- return n
- }
- func (m *HeartbeatRequest) Size() (n int) {
- var l int
- _ = l
- l = len(m.SessionID)
- if l > 0 {
- n += 1 + l + sovDispatcher(uint64(l))
- }
- return n
- }
- func (m *HeartbeatResponse) Size() (n int) {
- var l int
- _ = l
- l = github_com_gogo_protobuf_types.SizeOfStdDuration(m.Period)
- n += 1 + l + sovDispatcher(uint64(l))
- return n
- }
- func (m *UpdateTaskStatusRequest) Size() (n int) {
- var l int
- _ = l
- l = len(m.SessionID)
- if l > 0 {
- n += 1 + l + sovDispatcher(uint64(l))
- }
- if len(m.Updates) > 0 {
- for _, e := range m.Updates {
- l = e.Size()
- n += 1 + l + sovDispatcher(uint64(l))
- }
- }
- return n
- }
- func (m *UpdateTaskStatusRequest_TaskStatusUpdate) Size() (n int) {
- var l int
- _ = l
- l = len(m.TaskID)
- if l > 0 {
- n += 1 + l + sovDispatcher(uint64(l))
- }
- if m.Status != nil {
- l = m.Status.Size()
- n += 1 + l + sovDispatcher(uint64(l))
- }
- return n
- }
- func (m *UpdateTaskStatusResponse) Size() (n int) {
- var l int
- _ = l
- return n
- }
- func (m *TasksRequest) Size() (n int) {
- var l int
- _ = l
- l = len(m.SessionID)
- if l > 0 {
- n += 1 + l + sovDispatcher(uint64(l))
- }
- return n
- }
- func (m *TasksMessage) Size() (n int) {
- var l int
- _ = l
- if len(m.Tasks) > 0 {
- for _, e := range m.Tasks {
- l = e.Size()
- n += 1 + l + sovDispatcher(uint64(l))
- }
- }
- return n
- }
- func (m *AssignmentsRequest) Size() (n int) {
- var l int
- _ = l
- l = len(m.SessionID)
- if l > 0 {
- n += 1 + l + sovDispatcher(uint64(l))
- }
- return n
- }
- func (m *Assignment) Size() (n int) {
- var l int
- _ = l
- if m.Item != nil {
- n += m.Item.Size()
- }
- return n
- }
- func (m *Assignment_Task) Size() (n int) {
- var l int
- _ = l
- if m.Task != nil {
- l = m.Task.Size()
- n += 1 + l + sovDispatcher(uint64(l))
- }
- return n
- }
- func (m *Assignment_Secret) Size() (n int) {
- var l int
- _ = l
- if m.Secret != nil {
- l = m.Secret.Size()
- n += 1 + l + sovDispatcher(uint64(l))
- }
- return n
- }
- func (m *Assignment_Config) Size() (n int) {
- var l int
- _ = l
- if m.Config != nil {
- l = m.Config.Size()
- n += 1 + l + sovDispatcher(uint64(l))
- }
- return n
- }
- func (m *AssignmentChange) Size() (n int) {
- var l int
- _ = l
- if m.Assignment != nil {
- l = m.Assignment.Size()
- n += 1 + l + sovDispatcher(uint64(l))
- }
- if m.Action != 0 {
- n += 1 + sovDispatcher(uint64(m.Action))
- }
- return n
- }
- func (m *AssignmentsMessage) Size() (n int) {
- var l int
- _ = l
- if m.Type != 0 {
- n += 1 + sovDispatcher(uint64(m.Type))
- }
- l = len(m.AppliesTo)
- if l > 0 {
- n += 1 + l + sovDispatcher(uint64(l))
- }
- l = len(m.ResultsIn)
- if l > 0 {
- n += 1 + l + sovDispatcher(uint64(l))
- }
- if len(m.Changes) > 0 {
- for _, e := range m.Changes {
- l = e.Size()
- n += 1 + l + sovDispatcher(uint64(l))
- }
- }
- return n
- }
- func sovDispatcher(x uint64) (n int) {
- for {
- n++
- x >>= 7
- if x == 0 {
- break
- }
- }
- return n
- }
- func sozDispatcher(x uint64) (n int) {
- return sovDispatcher(uint64((x << 1) ^ uint64((int64(x) >> 63))))
- }
- func (this *SessionRequest) String() string {
- if this == nil {
- return "nil"
- }
- s := strings.Join([]string{`&SessionRequest{`,
- `Description:` + strings.Replace(fmt.Sprintf("%v", this.Description), "NodeDescription", "NodeDescription", 1) + `,`,
- `SessionID:` + fmt.Sprintf("%v", this.SessionID) + `,`,
- `}`,
- }, "")
- return s
- }
- func (this *SessionMessage) String() string {
- if this == nil {
- return "nil"
- }
- s := strings.Join([]string{`&SessionMessage{`,
- `SessionID:` + fmt.Sprintf("%v", this.SessionID) + `,`,
- `Node:` + strings.Replace(fmt.Sprintf("%v", this.Node), "Node", "Node", 1) + `,`,
- `Managers:` + strings.Replace(fmt.Sprintf("%v", this.Managers), "WeightedPeer", "WeightedPeer", 1) + `,`,
- `NetworkBootstrapKeys:` + strings.Replace(fmt.Sprintf("%v", this.NetworkBootstrapKeys), "EncryptionKey", "EncryptionKey", 1) + `,`,
- `RootCA:` + fmt.Sprintf("%v", this.RootCA) + `,`,
- `}`,
- }, "")
- return s
- }
- func (this *HeartbeatRequest) String() string {
- if this == nil {
- return "nil"
- }
- s := strings.Join([]string{`&HeartbeatRequest{`,
- `SessionID:` + fmt.Sprintf("%v", this.SessionID) + `,`,
- `}`,
- }, "")
- return s
- }
- func (this *HeartbeatResponse) String() string {
- if this == nil {
- return "nil"
- }
- s := strings.Join([]string{`&HeartbeatResponse{`,
- `Period:` + strings.Replace(strings.Replace(this.Period.String(), "Duration", "google_protobuf1.Duration", 1), `&`, ``, 1) + `,`,
- `}`,
- }, "")
- return s
- }
- func (this *UpdateTaskStatusRequest) String() string {
- if this == nil {
- return "nil"
- }
- s := strings.Join([]string{`&UpdateTaskStatusRequest{`,
- `SessionID:` + fmt.Sprintf("%v", this.SessionID) + `,`,
- `Updates:` + strings.Replace(fmt.Sprintf("%v", this.Updates), "UpdateTaskStatusRequest_TaskStatusUpdate", "UpdateTaskStatusRequest_TaskStatusUpdate", 1) + `,`,
- `}`,
- }, "")
- return s
- }
- func (this *UpdateTaskStatusRequest_TaskStatusUpdate) String() string {
- if this == nil {
- return "nil"
- }
- s := strings.Join([]string{`&UpdateTaskStatusRequest_TaskStatusUpdate{`,
- `TaskID:` + fmt.Sprintf("%v", this.TaskID) + `,`,
- `Status:` + strings.Replace(fmt.Sprintf("%v", this.Status), "TaskStatus", "TaskStatus", 1) + `,`,
- `}`,
- }, "")
- return s
- }
- func (this *UpdateTaskStatusResponse) String() string {
- if this == nil {
- return "nil"
- }
- s := strings.Join([]string{`&UpdateTaskStatusResponse{`,
- `}`,
- }, "")
- return s
- }
- func (this *TasksRequest) String() string {
- if this == nil {
- return "nil"
- }
- s := strings.Join([]string{`&TasksRequest{`,
- `SessionID:` + fmt.Sprintf("%v", this.SessionID) + `,`,
- `}`,
- }, "")
- return s
- }
- func (this *TasksMessage) String() string {
- if this == nil {
- return "nil"
- }
- s := strings.Join([]string{`&TasksMessage{`,
- `Tasks:` + strings.Replace(fmt.Sprintf("%v", this.Tasks), "Task", "Task", 1) + `,`,
- `}`,
- }, "")
- return s
- }
- func (this *AssignmentsRequest) String() string {
- if this == nil {
- return "nil"
- }
- s := strings.Join([]string{`&AssignmentsRequest{`,
- `SessionID:` + fmt.Sprintf("%v", this.SessionID) + `,`,
- `}`,
- }, "")
- return s
- }
- func (this *Assignment) String() string {
- if this == nil {
- return "nil"
- }
- s := strings.Join([]string{`&Assignment{`,
- `Item:` + fmt.Sprintf("%v", this.Item) + `,`,
- `}`,
- }, "")
- return s
- }
- func (this *Assignment_Task) String() string {
- if this == nil {
- return "nil"
- }
- s := strings.Join([]string{`&Assignment_Task{`,
- `Task:` + strings.Replace(fmt.Sprintf("%v", this.Task), "Task", "Task", 1) + `,`,
- `}`,
- }, "")
- return s
- }
- func (this *Assignment_Secret) String() string {
- if this == nil {
- return "nil"
- }
- s := strings.Join([]string{`&Assignment_Secret{`,
- `Secret:` + strings.Replace(fmt.Sprintf("%v", this.Secret), "Secret", "Secret", 1) + `,`,
- `}`,
- }, "")
- return s
- }
- func (this *Assignment_Config) String() string {
- if this == nil {
- return "nil"
- }
- s := strings.Join([]string{`&Assignment_Config{`,
- `Config:` + strings.Replace(fmt.Sprintf("%v", this.Config), "Config", "Config", 1) + `,`,
- `}`,
- }, "")
- return s
- }
- func (this *AssignmentChange) String() string {
- if this == nil {
- return "nil"
- }
- s := strings.Join([]string{`&AssignmentChange{`,
- `Assignment:` + strings.Replace(fmt.Sprintf("%v", this.Assignment), "Assignment", "Assignment", 1) + `,`,
- `Action:` + fmt.Sprintf("%v", this.Action) + `,`,
- `}`,
- }, "")
- return s
- }
- func (this *AssignmentsMessage) String() string {
- if this == nil {
- return "nil"
- }
- s := strings.Join([]string{`&AssignmentsMessage{`,
- `Type:` + fmt.Sprintf("%v", this.Type) + `,`,
- `AppliesTo:` + fmt.Sprintf("%v", this.AppliesTo) + `,`,
- `ResultsIn:` + fmt.Sprintf("%v", this.ResultsIn) + `,`,
- `Changes:` + strings.Replace(fmt.Sprintf("%v", this.Changes), "AssignmentChange", "AssignmentChange", 1) + `,`,
- `}`,
- }, "")
- return s
- }
- func valueToStringDispatcher(v interface{}) string {
- rv := reflect.ValueOf(v)
- if rv.IsNil() {
- return "nil"
- }
- pv := reflect.Indirect(rv).Interface()
- return fmt.Sprintf("*%v", pv)
- }
- func (m *SessionRequest) 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 ErrIntOverflowDispatcher
- }
- 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: SessionRequest: wiretype end group for non-group")
- }
- if fieldNum <= 0 {
- return fmt.Errorf("proto: SessionRequest: illegal tag %d (wire type %d)", fieldNum, wire)
- }
- switch fieldNum {
- case 1:
- if wireType != 2 {
- return fmt.Errorf("proto: wrong wireType = %d for field Description", wireType)
- }
- var msglen int
- for shift := uint(0); ; shift += 7 {
- if shift >= 64 {
- return ErrIntOverflowDispatcher
- }
- if iNdEx >= l {
- return io.ErrUnexpectedEOF
- }
- b := dAtA[iNdEx]
- iNdEx++
- msglen |= (int(b) & 0x7F) << shift
- if b < 0x80 {
- break
- }
- }
- if msglen < 0 {
- return ErrInvalidLengthDispatcher
- }
- postIndex := iNdEx + msglen
- if postIndex > l {
- return io.ErrUnexpectedEOF
- }
- if m.Description == nil {
- m.Description = &NodeDescription{}
- }
- if err := m.Description.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
- return err
- }
- iNdEx = postIndex
- case 2:
- if wireType != 2 {
- return fmt.Errorf("proto: wrong wireType = %d for field SessionID", wireType)
- }
- var stringLen uint64
- for shift := uint(0); ; shift += 7 {
- if shift >= 64 {
- return ErrIntOverflowDispatcher
- }
- 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 ErrInvalidLengthDispatcher
- }
- postIndex := iNdEx + intStringLen
- if postIndex > l {
- return io.ErrUnexpectedEOF
- }
- m.SessionID = string(dAtA[iNdEx:postIndex])
- iNdEx = postIndex
- default:
- iNdEx = preIndex
- skippy, err := skipDispatcher(dAtA[iNdEx:])
- if err != nil {
- return err
- }
- if skippy < 0 {
- return ErrInvalidLengthDispatcher
- }
- if (iNdEx + skippy) > l {
- return io.ErrUnexpectedEOF
- }
- iNdEx += skippy
- }
- }
- if iNdEx > l {
- return io.ErrUnexpectedEOF
- }
- return nil
- }
- func (m *SessionMessage) 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 ErrIntOverflowDispatcher
- }
- 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: SessionMessage: wiretype end group for non-group")
- }
- if fieldNum <= 0 {
- return fmt.Errorf("proto: SessionMessage: illegal tag %d (wire type %d)", fieldNum, wire)
- }
- switch fieldNum {
- case 1:
- if wireType != 2 {
- return fmt.Errorf("proto: wrong wireType = %d for field SessionID", wireType)
- }
- var stringLen uint64
- for shift := uint(0); ; shift += 7 {
- if shift >= 64 {
- return ErrIntOverflowDispatcher
- }
- 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 ErrInvalidLengthDispatcher
- }
- postIndex := iNdEx + intStringLen
- if postIndex > l {
- return io.ErrUnexpectedEOF
- }
- m.SessionID = string(dAtA[iNdEx:postIndex])
- iNdEx = postIndex
- case 2:
- if wireType != 2 {
- return fmt.Errorf("proto: wrong wireType = %d for field Node", wireType)
- }
- var msglen int
- for shift := uint(0); ; shift += 7 {
- if shift >= 64 {
- return ErrIntOverflowDispatcher
- }
- if iNdEx >= l {
- return io.ErrUnexpectedEOF
- }
- b := dAtA[iNdEx]
- iNdEx++
- msglen |= (int(b) & 0x7F) << shift
- if b < 0x80 {
- break
- }
- }
- if msglen < 0 {
- return ErrInvalidLengthDispatcher
- }
- postIndex := iNdEx + msglen
- if postIndex > l {
- return io.ErrUnexpectedEOF
- }
- if m.Node == nil {
- m.Node = &Node{}
- }
- if err := m.Node.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
- return err
- }
- iNdEx = postIndex
- case 3:
- if wireType != 2 {
- return fmt.Errorf("proto: wrong wireType = %d for field Managers", wireType)
- }
- var msglen int
- for shift := uint(0); ; shift += 7 {
- if shift >= 64 {
- return ErrIntOverflowDispatcher
- }
- if iNdEx >= l {
- return io.ErrUnexpectedEOF
- }
- b := dAtA[iNdEx]
- iNdEx++
- msglen |= (int(b) & 0x7F) << shift
- if b < 0x80 {
- break
- }
- }
- if msglen < 0 {
- return ErrInvalidLengthDispatcher
- }
- postIndex := iNdEx + msglen
- if postIndex > l {
- return io.ErrUnexpectedEOF
- }
- m.Managers = append(m.Managers, &WeightedPeer{})
- if err := m.Managers[len(m.Managers)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
- return err
- }
- iNdEx = postIndex
- case 4:
- if wireType != 2 {
- return fmt.Errorf("proto: wrong wireType = %d for field NetworkBootstrapKeys", wireType)
- }
- var msglen int
- for shift := uint(0); ; shift += 7 {
- if shift >= 64 {
- return ErrIntOverflowDispatcher
- }
- if iNdEx >= l {
- return io.ErrUnexpectedEOF
- }
- b := dAtA[iNdEx]
- iNdEx++
- msglen |= (int(b) & 0x7F) << shift
- if b < 0x80 {
- break
- }
- }
- if msglen < 0 {
- return ErrInvalidLengthDispatcher
- }
- postIndex := iNdEx + msglen
- if postIndex > l {
- return io.ErrUnexpectedEOF
- }
- m.NetworkBootstrapKeys = append(m.NetworkBootstrapKeys, &EncryptionKey{})
- if err := m.NetworkBootstrapKeys[len(m.NetworkBootstrapKeys)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
- return err
- }
- iNdEx = postIndex
- case 5:
- if wireType != 2 {
- return fmt.Errorf("proto: wrong wireType = %d for field RootCA", wireType)
- }
- var byteLen int
- for shift := uint(0); ; shift += 7 {
- if shift >= 64 {
- return ErrIntOverflowDispatcher
- }
- if iNdEx >= l {
- return io.ErrUnexpectedEOF
- }
- b := dAtA[iNdEx]
- iNdEx++
- byteLen |= (int(b) & 0x7F) << shift
- if b < 0x80 {
- break
- }
- }
- if byteLen < 0 {
- return ErrInvalidLengthDispatcher
- }
- postIndex := iNdEx + byteLen
- if postIndex > l {
- return io.ErrUnexpectedEOF
- }
- m.RootCA = append(m.RootCA[:0], dAtA[iNdEx:postIndex]...)
- if m.RootCA == nil {
- m.RootCA = []byte{}
- }
- iNdEx = postIndex
- default:
- iNdEx = preIndex
- skippy, err := skipDispatcher(dAtA[iNdEx:])
- if err != nil {
- return err
- }
- if skippy < 0 {
- return ErrInvalidLengthDispatcher
- }
- if (iNdEx + skippy) > l {
- return io.ErrUnexpectedEOF
- }
- iNdEx += skippy
- }
- }
- if iNdEx > l {
- return io.ErrUnexpectedEOF
- }
- return nil
- }
- func (m *HeartbeatRequest) 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 ErrIntOverflowDispatcher
- }
- 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: HeartbeatRequest: wiretype end group for non-group")
- }
- if fieldNum <= 0 {
- return fmt.Errorf("proto: HeartbeatRequest: illegal tag %d (wire type %d)", fieldNum, wire)
- }
- switch fieldNum {
- case 1:
- if wireType != 2 {
- return fmt.Errorf("proto: wrong wireType = %d for field SessionID", wireType)
- }
- var stringLen uint64
- for shift := uint(0); ; shift += 7 {
- if shift >= 64 {
- return ErrIntOverflowDispatcher
- }
- 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 ErrInvalidLengthDispatcher
- }
- postIndex := iNdEx + intStringLen
- if postIndex > l {
- return io.ErrUnexpectedEOF
- }
- m.SessionID = string(dAtA[iNdEx:postIndex])
- iNdEx = postIndex
- default:
- iNdEx = preIndex
- skippy, err := skipDispatcher(dAtA[iNdEx:])
- if err != nil {
- return err
- }
- if skippy < 0 {
- return ErrInvalidLengthDispatcher
- }
- if (iNdEx + skippy) > l {
- return io.ErrUnexpectedEOF
- }
- iNdEx += skippy
- }
- }
- if iNdEx > l {
- return io.ErrUnexpectedEOF
- }
- return nil
- }
- func (m *HeartbeatResponse) 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 ErrIntOverflowDispatcher
- }
- 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: HeartbeatResponse: wiretype end group for non-group")
- }
- if fieldNum <= 0 {
- return fmt.Errorf("proto: HeartbeatResponse: illegal tag %d (wire type %d)", fieldNum, wire)
- }
- switch fieldNum {
- case 1:
- if wireType != 2 {
- return fmt.Errorf("proto: wrong wireType = %d for field Period", wireType)
- }
- var msglen int
- for shift := uint(0); ; shift += 7 {
- if shift >= 64 {
- return ErrIntOverflowDispatcher
- }
- if iNdEx >= l {
- return io.ErrUnexpectedEOF
- }
- b := dAtA[iNdEx]
- iNdEx++
- msglen |= (int(b) & 0x7F) << shift
- if b < 0x80 {
- break
- }
- }
- if msglen < 0 {
- return ErrInvalidLengthDispatcher
- }
- postIndex := iNdEx + msglen
- if postIndex > l {
- return io.ErrUnexpectedEOF
- }
- if err := github_com_gogo_protobuf_types.StdDurationUnmarshal(&m.Period, dAtA[iNdEx:postIndex]); err != nil {
- return err
- }
- iNdEx = postIndex
- default:
- iNdEx = preIndex
- skippy, err := skipDispatcher(dAtA[iNdEx:])
- if err != nil {
- return err
- }
- if skippy < 0 {
- return ErrInvalidLengthDispatcher
- }
- if (iNdEx + skippy) > l {
- return io.ErrUnexpectedEOF
- }
- iNdEx += skippy
- }
- }
- if iNdEx > l {
- return io.ErrUnexpectedEOF
- }
- return nil
- }
- func (m *UpdateTaskStatusRequest) 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 ErrIntOverflowDispatcher
- }
- 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: UpdateTaskStatusRequest: wiretype end group for non-group")
- }
- if fieldNum <= 0 {
- return fmt.Errorf("proto: UpdateTaskStatusRequest: illegal tag %d (wire type %d)", fieldNum, wire)
- }
- switch fieldNum {
- case 1:
- if wireType != 2 {
- return fmt.Errorf("proto: wrong wireType = %d for field SessionID", wireType)
- }
- var stringLen uint64
- for shift := uint(0); ; shift += 7 {
- if shift >= 64 {
- return ErrIntOverflowDispatcher
- }
- 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 ErrInvalidLengthDispatcher
- }
- postIndex := iNdEx + intStringLen
- if postIndex > l {
- return io.ErrUnexpectedEOF
- }
- m.SessionID = string(dAtA[iNdEx:postIndex])
- iNdEx = postIndex
- case 3:
- if wireType != 2 {
- return fmt.Errorf("proto: wrong wireType = %d for field Updates", wireType)
- }
- var msglen int
- for shift := uint(0); ; shift += 7 {
- if shift >= 64 {
- return ErrIntOverflowDispatcher
- }
- if iNdEx >= l {
- return io.ErrUnexpectedEOF
- }
- b := dAtA[iNdEx]
- iNdEx++
- msglen |= (int(b) & 0x7F) << shift
- if b < 0x80 {
- break
- }
- }
- if msglen < 0 {
- return ErrInvalidLengthDispatcher
- }
- postIndex := iNdEx + msglen
- if postIndex > l {
- return io.ErrUnexpectedEOF
- }
- m.Updates = append(m.Updates, &UpdateTaskStatusRequest_TaskStatusUpdate{})
- if err := m.Updates[len(m.Updates)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
- return err
- }
- iNdEx = postIndex
- default:
- iNdEx = preIndex
- skippy, err := skipDispatcher(dAtA[iNdEx:])
- if err != nil {
- return err
- }
- if skippy < 0 {
- return ErrInvalidLengthDispatcher
- }
- if (iNdEx + skippy) > l {
- return io.ErrUnexpectedEOF
- }
- iNdEx += skippy
- }
- }
- if iNdEx > l {
- return io.ErrUnexpectedEOF
- }
- return nil
- }
- func (m *UpdateTaskStatusRequest_TaskStatusUpdate) 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 ErrIntOverflowDispatcher
- }
- 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: TaskStatusUpdate: wiretype end group for non-group")
- }
- if fieldNum <= 0 {
- return fmt.Errorf("proto: TaskStatusUpdate: illegal tag %d (wire type %d)", fieldNum, wire)
- }
- switch fieldNum {
- case 1:
- if wireType != 2 {
- return fmt.Errorf("proto: wrong wireType = %d for field TaskID", wireType)
- }
- var stringLen uint64
- for shift := uint(0); ; shift += 7 {
- if shift >= 64 {
- return ErrIntOverflowDispatcher
- }
- 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 ErrInvalidLengthDispatcher
- }
- postIndex := iNdEx + intStringLen
- if postIndex > l {
- return io.ErrUnexpectedEOF
- }
- m.TaskID = string(dAtA[iNdEx:postIndex])
- iNdEx = postIndex
- case 2:
- if wireType != 2 {
- return fmt.Errorf("proto: wrong wireType = %d for field Status", wireType)
- }
- var msglen int
- for shift := uint(0); ; shift += 7 {
- if shift >= 64 {
- return ErrIntOverflowDispatcher
- }
- if iNdEx >= l {
- return io.ErrUnexpectedEOF
- }
- b := dAtA[iNdEx]
- iNdEx++
- msglen |= (int(b) & 0x7F) << shift
- if b < 0x80 {
- break
- }
- }
- if msglen < 0 {
- return ErrInvalidLengthDispatcher
- }
- postIndex := iNdEx + msglen
- if postIndex > l {
- return io.ErrUnexpectedEOF
- }
- if m.Status == nil {
- m.Status = &TaskStatus{}
- }
- if err := m.Status.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
- return err
- }
- iNdEx = postIndex
- default:
- iNdEx = preIndex
- skippy, err := skipDispatcher(dAtA[iNdEx:])
- if err != nil {
- return err
- }
- if skippy < 0 {
- return ErrInvalidLengthDispatcher
- }
- if (iNdEx + skippy) > l {
- return io.ErrUnexpectedEOF
- }
- iNdEx += skippy
- }
- }
- if iNdEx > l {
- return io.ErrUnexpectedEOF
- }
- return nil
- }
- func (m *UpdateTaskStatusResponse) 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 ErrIntOverflowDispatcher
- }
- 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: UpdateTaskStatusResponse: wiretype end group for non-group")
- }
- if fieldNum <= 0 {
- return fmt.Errorf("proto: UpdateTaskStatusResponse: illegal tag %d (wire type %d)", fieldNum, wire)
- }
- switch fieldNum {
- default:
- iNdEx = preIndex
- skippy, err := skipDispatcher(dAtA[iNdEx:])
- if err != nil {
- return err
- }
- if skippy < 0 {
- return ErrInvalidLengthDispatcher
- }
- if (iNdEx + skippy) > l {
- return io.ErrUnexpectedEOF
- }
- iNdEx += skippy
- }
- }
- if iNdEx > l {
- return io.ErrUnexpectedEOF
- }
- return nil
- }
- func (m *TasksRequest) 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 ErrIntOverflowDispatcher
- }
- 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: TasksRequest: wiretype end group for non-group")
- }
- if fieldNum <= 0 {
- return fmt.Errorf("proto: TasksRequest: illegal tag %d (wire type %d)", fieldNum, wire)
- }
- switch fieldNum {
- case 1:
- if wireType != 2 {
- return fmt.Errorf("proto: wrong wireType = %d for field SessionID", wireType)
- }
- var stringLen uint64
- for shift := uint(0); ; shift += 7 {
- if shift >= 64 {
- return ErrIntOverflowDispatcher
- }
- 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 ErrInvalidLengthDispatcher
- }
- postIndex := iNdEx + intStringLen
- if postIndex > l {
- return io.ErrUnexpectedEOF
- }
- m.SessionID = string(dAtA[iNdEx:postIndex])
- iNdEx = postIndex
- default:
- iNdEx = preIndex
- skippy, err := skipDispatcher(dAtA[iNdEx:])
- if err != nil {
- return err
- }
- if skippy < 0 {
- return ErrInvalidLengthDispatcher
- }
- if (iNdEx + skippy) > l {
- return io.ErrUnexpectedEOF
- }
- iNdEx += skippy
- }
- }
- if iNdEx > l {
- return io.ErrUnexpectedEOF
- }
- return nil
- }
- func (m *TasksMessage) 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 ErrIntOverflowDispatcher
- }
- 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: TasksMessage: wiretype end group for non-group")
- }
- if fieldNum <= 0 {
- return fmt.Errorf("proto: TasksMessage: illegal tag %d (wire type %d)", fieldNum, wire)
- }
- switch fieldNum {
- case 1:
- if wireType != 2 {
- return fmt.Errorf("proto: wrong wireType = %d for field Tasks", wireType)
- }
- var msglen int
- for shift := uint(0); ; shift += 7 {
- if shift >= 64 {
- return ErrIntOverflowDispatcher
- }
- if iNdEx >= l {
- return io.ErrUnexpectedEOF
- }
- b := dAtA[iNdEx]
- iNdEx++
- msglen |= (int(b) & 0x7F) << shift
- if b < 0x80 {
- break
- }
- }
- if msglen < 0 {
- return ErrInvalidLengthDispatcher
- }
- postIndex := iNdEx + msglen
- if postIndex > l {
- return io.ErrUnexpectedEOF
- }
- m.Tasks = append(m.Tasks, &Task{})
- if err := m.Tasks[len(m.Tasks)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
- return err
- }
- iNdEx = postIndex
- default:
- iNdEx = preIndex
- skippy, err := skipDispatcher(dAtA[iNdEx:])
- if err != nil {
- return err
- }
- if skippy < 0 {
- return ErrInvalidLengthDispatcher
- }
- if (iNdEx + skippy) > l {
- return io.ErrUnexpectedEOF
- }
- iNdEx += skippy
- }
- }
- if iNdEx > l {
- return io.ErrUnexpectedEOF
- }
- return nil
- }
- func (m *AssignmentsRequest) 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 ErrIntOverflowDispatcher
- }
- 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: AssignmentsRequest: wiretype end group for non-group")
- }
- if fieldNum <= 0 {
- return fmt.Errorf("proto: AssignmentsRequest: illegal tag %d (wire type %d)", fieldNum, wire)
- }
- switch fieldNum {
- case 1:
- if wireType != 2 {
- return fmt.Errorf("proto: wrong wireType = %d for field SessionID", wireType)
- }
- var stringLen uint64
- for shift := uint(0); ; shift += 7 {
- if shift >= 64 {
- return ErrIntOverflowDispatcher
- }
- 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 ErrInvalidLengthDispatcher
- }
- postIndex := iNdEx + intStringLen
- if postIndex > l {
- return io.ErrUnexpectedEOF
- }
- m.SessionID = string(dAtA[iNdEx:postIndex])
- iNdEx = postIndex
- default:
- iNdEx = preIndex
- skippy, err := skipDispatcher(dAtA[iNdEx:])
- if err != nil {
- return err
- }
- if skippy < 0 {
- return ErrInvalidLengthDispatcher
- }
- if (iNdEx + skippy) > l {
- return io.ErrUnexpectedEOF
- }
- iNdEx += skippy
- }
- }
- if iNdEx > l {
- return io.ErrUnexpectedEOF
- }
- return nil
- }
- func (m *Assignment) 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 ErrIntOverflowDispatcher
- }
- 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: Assignment: wiretype end group for non-group")
- }
- if fieldNum <= 0 {
- return fmt.Errorf("proto: Assignment: illegal tag %d (wire type %d)", fieldNum, wire)
- }
- switch fieldNum {
- case 1:
- if wireType != 2 {
- return fmt.Errorf("proto: wrong wireType = %d for field Task", wireType)
- }
- var msglen int
- for shift := uint(0); ; shift += 7 {
- if shift >= 64 {
- return ErrIntOverflowDispatcher
- }
- if iNdEx >= l {
- return io.ErrUnexpectedEOF
- }
- b := dAtA[iNdEx]
- iNdEx++
- msglen |= (int(b) & 0x7F) << shift
- if b < 0x80 {
- break
- }
- }
- if msglen < 0 {
- return ErrInvalidLengthDispatcher
- }
- postIndex := iNdEx + msglen
- if postIndex > l {
- return io.ErrUnexpectedEOF
- }
- v := &Task{}
- if err := v.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
- return err
- }
- m.Item = &Assignment_Task{v}
- iNdEx = postIndex
- case 2:
- if wireType != 2 {
- return fmt.Errorf("proto: wrong wireType = %d for field Secret", wireType)
- }
- var msglen int
- for shift := uint(0); ; shift += 7 {
- if shift >= 64 {
- return ErrIntOverflowDispatcher
- }
- if iNdEx >= l {
- return io.ErrUnexpectedEOF
- }
- b := dAtA[iNdEx]
- iNdEx++
- msglen |= (int(b) & 0x7F) << shift
- if b < 0x80 {
- break
- }
- }
- if msglen < 0 {
- return ErrInvalidLengthDispatcher
- }
- postIndex := iNdEx + msglen
- if postIndex > l {
- return io.ErrUnexpectedEOF
- }
- v := &Secret{}
- if err := v.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
- return err
- }
- m.Item = &Assignment_Secret{v}
- iNdEx = postIndex
- case 3:
- 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 ErrIntOverflowDispatcher
- }
- if iNdEx >= l {
- return io.ErrUnexpectedEOF
- }
- b := dAtA[iNdEx]
- iNdEx++
- msglen |= (int(b) & 0x7F) << shift
- if b < 0x80 {
- break
- }
- }
- if msglen < 0 {
- return ErrInvalidLengthDispatcher
- }
- postIndex := iNdEx + msglen
- if postIndex > l {
- return io.ErrUnexpectedEOF
- }
- v := &Config{}
- if err := v.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
- return err
- }
- m.Item = &Assignment_Config{v}
- iNdEx = postIndex
- default:
- iNdEx = preIndex
- skippy, err := skipDispatcher(dAtA[iNdEx:])
- if err != nil {
- return err
- }
- if skippy < 0 {
- return ErrInvalidLengthDispatcher
- }
- if (iNdEx + skippy) > l {
- return io.ErrUnexpectedEOF
- }
- iNdEx += skippy
- }
- }
- if iNdEx > l {
- return io.ErrUnexpectedEOF
- }
- return nil
- }
- func (m *AssignmentChange) 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 ErrIntOverflowDispatcher
- }
- 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: AssignmentChange: wiretype end group for non-group")
- }
- if fieldNum <= 0 {
- return fmt.Errorf("proto: AssignmentChange: illegal tag %d (wire type %d)", fieldNum, wire)
- }
- switch fieldNum {
- case 1:
- if wireType != 2 {
- return fmt.Errorf("proto: wrong wireType = %d for field Assignment", wireType)
- }
- var msglen int
- for shift := uint(0); ; shift += 7 {
- if shift >= 64 {
- return ErrIntOverflowDispatcher
- }
- if iNdEx >= l {
- return io.ErrUnexpectedEOF
- }
- b := dAtA[iNdEx]
- iNdEx++
- msglen |= (int(b) & 0x7F) << shift
- if b < 0x80 {
- break
- }
- }
- if msglen < 0 {
- return ErrInvalidLengthDispatcher
- }
- postIndex := iNdEx + msglen
- if postIndex > l {
- return io.ErrUnexpectedEOF
- }
- if m.Assignment == nil {
- m.Assignment = &Assignment{}
- }
- if err := m.Assignment.Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
- return err
- }
- iNdEx = postIndex
- case 2:
- if wireType != 0 {
- return fmt.Errorf("proto: wrong wireType = %d for field Action", wireType)
- }
- m.Action = 0
- for shift := uint(0); ; shift += 7 {
- if shift >= 64 {
- return ErrIntOverflowDispatcher
- }
- if iNdEx >= l {
- return io.ErrUnexpectedEOF
- }
- b := dAtA[iNdEx]
- iNdEx++
- m.Action |= (AssignmentChange_AssignmentAction(b) & 0x7F) << shift
- if b < 0x80 {
- break
- }
- }
- default:
- iNdEx = preIndex
- skippy, err := skipDispatcher(dAtA[iNdEx:])
- if err != nil {
- return err
- }
- if skippy < 0 {
- return ErrInvalidLengthDispatcher
- }
- if (iNdEx + skippy) > l {
- return io.ErrUnexpectedEOF
- }
- iNdEx += skippy
- }
- }
- if iNdEx > l {
- return io.ErrUnexpectedEOF
- }
- return nil
- }
- func (m *AssignmentsMessage) 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 ErrIntOverflowDispatcher
- }
- 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: AssignmentsMessage: wiretype end group for non-group")
- }
- if fieldNum <= 0 {
- return fmt.Errorf("proto: AssignmentsMessage: illegal tag %d (wire type %d)", fieldNum, wire)
- }
- switch fieldNum {
- case 1:
- if wireType != 0 {
- return fmt.Errorf("proto: wrong wireType = %d for field Type", wireType)
- }
- m.Type = 0
- for shift := uint(0); ; shift += 7 {
- if shift >= 64 {
- return ErrIntOverflowDispatcher
- }
- if iNdEx >= l {
- return io.ErrUnexpectedEOF
- }
- b := dAtA[iNdEx]
- iNdEx++
- m.Type |= (AssignmentsMessage_Type(b) & 0x7F) << shift
- if b < 0x80 {
- break
- }
- }
- case 2:
- if wireType != 2 {
- return fmt.Errorf("proto: wrong wireType = %d for field AppliesTo", wireType)
- }
- var stringLen uint64
- for shift := uint(0); ; shift += 7 {
- if shift >= 64 {
- return ErrIntOverflowDispatcher
- }
- 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 ErrInvalidLengthDispatcher
- }
- postIndex := iNdEx + intStringLen
- if postIndex > l {
- return io.ErrUnexpectedEOF
- }
- m.AppliesTo = string(dAtA[iNdEx:postIndex])
- iNdEx = postIndex
- case 3:
- if wireType != 2 {
- return fmt.Errorf("proto: wrong wireType = %d for field ResultsIn", wireType)
- }
- var stringLen uint64
- for shift := uint(0); ; shift += 7 {
- if shift >= 64 {
- return ErrIntOverflowDispatcher
- }
- 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 ErrInvalidLengthDispatcher
- }
- postIndex := iNdEx + intStringLen
- if postIndex > l {
- return io.ErrUnexpectedEOF
- }
- m.ResultsIn = string(dAtA[iNdEx:postIndex])
- iNdEx = postIndex
- case 4:
- if wireType != 2 {
- return fmt.Errorf("proto: wrong wireType = %d for field Changes", wireType)
- }
- var msglen int
- for shift := uint(0); ; shift += 7 {
- if shift >= 64 {
- return ErrIntOverflowDispatcher
- }
- if iNdEx >= l {
- return io.ErrUnexpectedEOF
- }
- b := dAtA[iNdEx]
- iNdEx++
- msglen |= (int(b) & 0x7F) << shift
- if b < 0x80 {
- break
- }
- }
- if msglen < 0 {
- return ErrInvalidLengthDispatcher
- }
- postIndex := iNdEx + msglen
- if postIndex > l {
- return io.ErrUnexpectedEOF
- }
- m.Changes = append(m.Changes, &AssignmentChange{})
- if err := m.Changes[len(m.Changes)-1].Unmarshal(dAtA[iNdEx:postIndex]); err != nil {
- return err
- }
- iNdEx = postIndex
- default:
- iNdEx = preIndex
- skippy, err := skipDispatcher(dAtA[iNdEx:])
- if err != nil {
- return err
- }
- if skippy < 0 {
- return ErrInvalidLengthDispatcher
- }
- if (iNdEx + skippy) > l {
- return io.ErrUnexpectedEOF
- }
- iNdEx += skippy
- }
- }
- if iNdEx > l {
- return io.ErrUnexpectedEOF
- }
- return nil
- }
- func skipDispatcher(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, ErrIntOverflowDispatcher
- }
- 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, ErrIntOverflowDispatcher
- }
- 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, ErrIntOverflowDispatcher
- }
- 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, ErrInvalidLengthDispatcher
- }
- return iNdEx, nil
- case 3:
- for {
- var innerWire uint64
- var start int = iNdEx
- for shift := uint(0); ; shift += 7 {
- if shift >= 64 {
- return 0, ErrIntOverflowDispatcher
- }
- 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 := skipDispatcher(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 (
- ErrInvalidLengthDispatcher = fmt.Errorf("proto: negative length found during unmarshaling")
- ErrIntOverflowDispatcher = fmt.Errorf("proto: integer overflow")
- )
- func init() { proto.RegisterFile("dispatcher.proto", fileDescriptorDispatcher) }
- var fileDescriptorDispatcher = []byte{
- // 983 bytes of a gzipped FileDescriptorProto
- 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x9c, 0x55, 0x4f, 0x6f, 0x1b, 0x45,
- 0x14, 0xf7, 0x38, 0xce, 0x26, 0x7e, 0x4e, 0x82, 0x19, 0xaa, 0xb0, 0xac, 0x54, 0xc7, 0x6c, 0x68,
- 0x14, 0xa9, 0x61, 0x53, 0xcc, 0x9f, 0x0b, 0x51, 0x20, 0x8e, 0x2d, 0xc5, 0x6a, 0x93, 0x46, 0x13,
- 0xb7, 0x3d, 0x5a, 0x6b, 0xef, 0x74, 0xb3, 0x38, 0xde, 0x59, 0x76, 0xc6, 0x2d, 0x3e, 0x20, 0x71,
- 0xa0, 0x12, 0xe2, 0x84, 0x38, 0x45, 0x42, 0x7c, 0x05, 0xc4, 0xc7, 0x88, 0x38, 0x71, 0xe4, 0x14,
- 0xa8, 0x3f, 0x00, 0x1f, 0x80, 0x13, 0xda, 0xd9, 0x59, 0xdb, 0x75, 0xed, 0xd4, 0xc9, 0xc9, 0x9e,
- 0x37, 0xbf, 0xdf, 0x9b, 0xdf, 0xbc, 0xf7, 0xdb, 0x37, 0x90, 0x77, 0x3c, 0x1e, 0xd8, 0xa2, 0x75,
- 0x4a, 0x43, 0x2b, 0x08, 0x99, 0x60, 0x18, 0x3b, 0xac, 0xd5, 0xa6, 0xa1, 0xc5, 0x9f, 0xdb, 0x61,
- 0xa7, 0xed, 0x09, 0xeb, 0xd9, 0x47, 0x46, 0x4e, 0xf4, 0x02, 0xca, 0x63, 0x80, 0xb1, 0xcc, 0x9a,
- 0x5f, 0xd1, 0x96, 0x48, 0x96, 0xb7, 0x5c, 0xe6, 0x32, 0xf9, 0x77, 0x3b, 0xfa, 0xa7, 0xa2, 0xef,
- 0x04, 0x67, 0x5d, 0xd7, 0xf3, 0xb7, 0xe3, 0x1f, 0x15, 0x2c, 0xb8, 0x8c, 0xb9, 0x67, 0x74, 0x5b,
- 0xae, 0x9a, 0xdd, 0xa7, 0xdb, 0x4e, 0x37, 0xb4, 0x85, 0xc7, 0xd4, 0xbe, 0xf9, 0x02, 0xc1, 0xca,
- 0x09, 0xe5, 0xdc, 0x63, 0x3e, 0xa1, 0x5f, 0x77, 0x29, 0x17, 0xb8, 0x0a, 0x39, 0x87, 0xf2, 0x56,
- 0xe8, 0x05, 0x11, 0x4e, 0x47, 0x45, 0xb4, 0x99, 0x2b, 0xad, 0x5b, 0xaf, 0x6b, 0xb4, 0x8e, 0x98,
- 0x43, 0x2b, 0x43, 0x28, 0x19, 0xe5, 0xe1, 0x2d, 0x00, 0x1e, 0x27, 0x6e, 0x78, 0x8e, 0x9e, 0x2e,
- 0xa2, 0xcd, 0x6c, 0x79, 0xb9, 0x7f, 0xb9, 0x96, 0x55, 0xc7, 0xd5, 0x2a, 0x24, 0xab, 0x00, 0x35,
- 0xc7, 0xfc, 0x25, 0x3d, 0xd0, 0x71, 0x48, 0x39, 0xb7, 0x5d, 0x3a, 0x96, 0x00, 0x5d, 0x9d, 0x00,
- 0x6f, 0x41, 0xc6, 0x67, 0x0e, 0x95, 0x07, 0xe5, 0x4a, 0xfa, 0x34, 0xb9, 0x44, 0xa2, 0xf0, 0x0e,
- 0x2c, 0x76, 0x6c, 0xdf, 0x76, 0x69, 0xc8, 0xf5, 0xb9, 0xe2, 0xdc, 0x66, 0xae, 0x54, 0x9c, 0xc4,
- 0x78, 0x42, 0x3d, 0xf7, 0x54, 0x50, 0xe7, 0x98, 0xd2, 0x90, 0x0c, 0x18, 0xf8, 0x09, 0xac, 0xfa,
- 0x54, 0x3c, 0x67, 0x61, 0xbb, 0xd1, 0x64, 0x4c, 0x70, 0x11, 0xda, 0x41, 0xa3, 0x4d, 0x7b, 0x5c,
- 0xcf, 0xc8, 0x5c, 0xef, 0x4f, 0xca, 0x55, 0xf5, 0x5b, 0x61, 0x4f, 0x96, 0xe6, 0x3e, 0xed, 0x91,
- 0x5b, 0x2a, 0x41, 0x39, 0xe1, 0xdf, 0xa7, 0x3d, 0x8e, 0x57, 0x41, 0x23, 0x8c, 0x89, 0xfd, 0x3d,
- 0x7d, 0xbe, 0x88, 0x36, 0x97, 0x88, 0x5a, 0x99, 0x5f, 0x42, 0xfe, 0x80, 0xda, 0xa1, 0x68, 0x52,
- 0x5b, 0x24, 0x6d, 0xba, 0x56, 0x79, 0xcc, 0x63, 0x78, 0x7b, 0x24, 0x03, 0x0f, 0x98, 0xcf, 0x29,
- 0xfe, 0x1c, 0xb4, 0x80, 0x86, 0x1e, 0x73, 0x54, 0x93, 0xdf, 0xb3, 0x62, 0xb7, 0x58, 0x89, 0x5b,
- 0xac, 0x8a, 0x72, 0x4b, 0x79, 0xf1, 0xe2, 0x72, 0x2d, 0x75, 0xfe, 0xf7, 0x1a, 0x22, 0x8a, 0x62,
- 0xfe, 0x94, 0x86, 0x77, 0x1f, 0x05, 0x8e, 0x2d, 0x68, 0xdd, 0xe6, 0xed, 0x13, 0x61, 0x8b, 0x2e,
- 0xbf, 0x91, 0x36, 0xfc, 0x18, 0x16, 0xba, 0x32, 0x51, 0xd2, 0x8b, 0x9d, 0x49, 0xf5, 0x9b, 0x72,
- 0x96, 0x35, 0x8c, 0xc4, 0x08, 0x92, 0x24, 0x33, 0x18, 0xe4, 0xc7, 0x37, 0xf1, 0x3a, 0x2c, 0x08,
- 0x9b, 0xb7, 0x87, 0xb2, 0xa0, 0x7f, 0xb9, 0xa6, 0x45, 0xb0, 0x5a, 0x85, 0x68, 0xd1, 0x56, 0xcd,
- 0xc1, 0x9f, 0x81, 0xc6, 0x25, 0x49, 0xb9, 0xa9, 0x30, 0x49, 0xcf, 0x88, 0x12, 0x85, 0x36, 0x0d,
- 0xd0, 0x5f, 0x57, 0x19, 0xd7, 0xda, 0xdc, 0x81, 0xa5, 0x28, 0x7a, 0xb3, 0x12, 0x99, 0xbb, 0x8a,
- 0x9d, 0x7c, 0x1b, 0x16, 0xcc, 0x47, 0x5a, 0xb9, 0x8e, 0x64, 0xc1, 0xf4, 0x69, 0x02, 0x49, 0x0c,
- 0x33, 0xcb, 0x80, 0xf7, 0x38, 0xf7, 0x5c, 0xbf, 0x43, 0x7d, 0x71, 0x43, 0x0d, 0xbf, 0x23, 0x80,
- 0x61, 0x12, 0x6c, 0x41, 0x26, 0xca, 0xad, 0xac, 0x33, 0x55, 0xc1, 0x41, 0x8a, 0x48, 0x1c, 0xfe,
- 0x04, 0x34, 0x4e, 0x5b, 0x21, 0x15, 0xaa, 0xa8, 0xc6, 0x24, 0xc6, 0x89, 0x44, 0x1c, 0xa4, 0x88,
- 0xc2, 0x46, 0xac, 0x16, 0xf3, 0x9f, 0x7a, 0xae, 0x3e, 0x37, 0x9d, 0xb5, 0x2f, 0x11, 0x11, 0x2b,
- 0xc6, 0x96, 0x35, 0xc8, 0x78, 0x82, 0x76, 0xcc, 0x17, 0x69, 0xc8, 0x0f, 0x25, 0xef, 0x9f, 0xda,
- 0xbe, 0x4b, 0xf1, 0x2e, 0x80, 0x3d, 0x88, 0x29, 0xf9, 0x13, 0x3b, 0x3c, 0x64, 0x92, 0x11, 0x06,
- 0x3e, 0x04, 0xcd, 0x6e, 0xc9, 0xd1, 0x18, 0x5d, 0x64, 0xa5, 0xf4, 0xe9, 0xd5, 0xdc, 0xf8, 0xd4,
- 0x91, 0xc0, 0x9e, 0x24, 0x13, 0x95, 0xc4, 0x6c, 0x8e, 0x4a, 0x8c, 0xf7, 0xf0, 0x06, 0x68, 0x8f,
- 0x8e, 0x2b, 0x7b, 0xf5, 0x6a, 0x3e, 0x65, 0x18, 0x3f, 0xfe, 0x5a, 0x5c, 0x1d, 0x47, 0x28, 0x37,
- 0x6f, 0x80, 0x46, 0xaa, 0x87, 0x0f, 0x1f, 0x57, 0xf3, 0x68, 0x32, 0x8e, 0xd0, 0x0e, 0x7b, 0x46,
- 0xcd, 0xff, 0xd0, 0x2b, 0xfd, 0x4f, 0x5c, 0xf4, 0x05, 0x64, 0xa2, 0x57, 0x46, 0xd6, 0x60, 0xa5,
- 0x74, 0xf7, 0xea, 0x7b, 0x24, 0x2c, 0xab, 0xde, 0x0b, 0x28, 0x91, 0x44, 0x7c, 0x1b, 0xc0, 0x0e,
- 0x82, 0x33, 0x8f, 0xf2, 0x86, 0x60, 0xf1, 0x8c, 0x27, 0x59, 0x15, 0xa9, 0xb3, 0x68, 0x3b, 0xa4,
- 0xbc, 0x7b, 0x26, 0x78, 0xc3, 0xf3, 0x65, 0x03, 0xb3, 0x24, 0xab, 0x22, 0x35, 0x1f, 0xef, 0xc2,
- 0x42, 0x4b, 0x16, 0x27, 0x99, 0x9b, 0x1f, 0xcc, 0x52, 0x49, 0x92, 0x90, 0xcc, 0x3b, 0x90, 0x89,
- 0xb4, 0xe0, 0x25, 0x58, 0xdc, 0x7f, 0x78, 0x78, 0xfc, 0xa0, 0x1a, 0xd5, 0x0b, 0xbf, 0x05, 0xb9,
- 0xda, 0xd1, 0x3e, 0xa9, 0x1e, 0x56, 0x8f, 0xea, 0x7b, 0x0f, 0xf2, 0xa8, 0x74, 0x3e, 0x0f, 0x50,
- 0x19, 0x3c, 0xb9, 0xf8, 0x1b, 0x58, 0x50, 0xf6, 0xc6, 0xe6, 0x64, 0x0b, 0x8e, 0xbe, 0x86, 0xc6,
- 0x55, 0x18, 0x55, 0x11, 0x73, 0xfd, 0x8f, 0xdf, 0xfe, 0x3d, 0x4f, 0xdf, 0x86, 0x25, 0x89, 0xf9,
- 0x30, 0x9a, 0xeb, 0x34, 0x84, 0xe5, 0x78, 0xa5, 0x5e, 0x8d, 0x7b, 0x08, 0x7f, 0x0b, 0xd9, 0xc1,
- 0x0c, 0xc6, 0x13, 0xef, 0x3a, 0x3e, 0xe4, 0x8d, 0x3b, 0x6f, 0x40, 0xa9, 0xe1, 0x32, 0x8b, 0x00,
- 0xfc, 0x33, 0x82, 0xfc, 0xf8, 0x78, 0xc2, 0x77, 0xaf, 0x31, 0x6a, 0x8d, 0xad, 0xd9, 0xc0, 0xd7,
- 0x11, 0xd5, 0x85, 0x79, 0x39, 0xd8, 0x70, 0x71, 0xda, 0x00, 0x19, 0x9c, 0x3e, 0x1d, 0x91, 0xf4,
- 0x61, 0x63, 0x86, 0x13, 0x7f, 0x48, 0xa3, 0x7b, 0x08, 0x7f, 0x8f, 0x20, 0x37, 0x62, 0x6d, 0xbc,
- 0xf1, 0x06, 0xef, 0x27, 0x1a, 0x36, 0x66, 0xfb, 0x46, 0x66, 0x74, 0x44, 0x59, 0xbf, 0x78, 0x59,
- 0x48, 0xfd, 0xf5, 0xb2, 0x90, 0xfa, 0xae, 0x5f, 0x40, 0x17, 0xfd, 0x02, 0xfa, 0xb3, 0x5f, 0x40,
- 0xff, 0xf4, 0x0b, 0xa8, 0xa9, 0xc9, 0x27, 0xf8, 0xe3, 0xff, 0x03, 0x00, 0x00, 0xff, 0xff, 0x6c,
- 0xba, 0x38, 0xbd, 0x2d, 0x0a, 0x00, 0x00,
- }
|