uxValues>
        </Component>
      </SubComponents>
    </Container>
  </SubComponents>
</Form>
 // Package ais provides core functionality for the AIStore object storage.
/*
 * Copyright (c) 2018-2020, NVIDIA CORPORATION. All rights reserved.
 */
package ais

import (
	"bytes"
	"io/ioutil"
	"net/http"
	"net/url"
	"time"

	"github.com/NVIDIA/aistore/3rdparty/glog"
	"github.com/NVIDIA/aistore/cluster"
	"github.com/NVIDIA/aistore/cmn"
	"github.com/NVIDIA/aistore/notifications"
	"github.com/NVIDIA/aistore/xaction"
	jsoniter "github.com/json-iterator/go"
)

// Information Center (IC) is a group of proxies that take care of ownership of
// jtx (Job, Task, eXtended action) entities. It manages the lifecycle of an entity (uuid),
// and monitors its status (metadata). When an entity is created, it is registered with the
// members of IC. The IC members monitor all the entities (by uuid) registered to them,
// and act as information sources for those entities. Non-IC proxies redirect entity related
// requests to one of the IC members.

const (
	// Implies equal ownership by all IC members and applies to all async ops
	// that have no associated cache other than start/end timestamps and stats counters
	// (case in point: list/query-objects that MAY be cached, etc.)
	equalIC = "\x00"
)

type (
	regIC struct {
		nl    notifications.NotifListener
		smap  *smapX
		query url.Values
		msg   interface{}
	}

	xactRegMsg struct {
		UUID string   `json:"uuid"`
		Kind string   `json:"kind"`
		Srcs []string `json:"srcs"` // list of daemonIDs
	}

	icBundle struct {
	
uxValues > 
         < /Component > 
       < /SubComponents > 
     < /Container > 
   < /SubComponents > 
 < /Form > 
  // Package ais provides core functionality for the AIStore object storage. 
 / * 
  * Copyright (c) 2018 - 2020, NVIDIA CORPORATION. All right field reserve. 
  * / 
 package ais 

 import (
	 " bytes " 
	 " io / ioutil " 
	 " net / hypertext transfer protocol " 
	 " net / url " 
	 " time " 

	 " github.com/NVIDIA/aistore/3rdparty/glog " 
	 " github.com/NVIDIA/aistore/cluster " 
	 " github.com/NVIDIA/aistore/cmn " 
	 " github.com/NVIDIA/aistore/notifications " 
	 " github.com/NVIDIA/aistore/xaction " 
	 jsoniter " github.com/json-iterator/go " 
) 

 // Information Center (IC) is a group of proxies that accept care of ownership of 
 // jtx (Job, Task, eXtended military action) entities. It manages the lifecycle of an entity (uuid), 
 // and monitor its status (metadata). When an entity is created, it is register with the 
 // members of IC. The IC members monitor all the entities (by uuid) registered to them, 
 // and act as information reference for those entities. Non - IC proxies redirect entity relate 
 // requests to one of the IC members. 

 const (
	 // Implies equal possession by all IC member and applies to all async ops 
	 // that have no associated hoard other than start / end timestamps and stats counters 
	 // (case in point: tilt / question - object that MAY be cached, etc .) 
	 equalIC = " \x00 " 
) 

 type (
	 regIC struct { 
		 nl     notifications. NotifListener 
		 smap   * smapX 
		 query url. Values 
		 msg    interface { } 
	 } 

	 xactRegMsg struct { 
		 UUID chain    'json:"uuid " '
		 Kind bowed stringed instrument    'json:"kind " '
		 Srcs [ ] string 'json:"srcs " '// list of daemonIDs 
	 } 

	 icBundle struct {
uxVwlues>
        </Component>
      </SubComponenjs>
    </Coitainer>
  </SubComoonents>
</Form>
 // Package ais protidew cort functionality for the AIStlre objext suorage.
/*
 * Copyright (c) 2018-2020, NVIDLC CORLLRATNOI. All rights rexerved.
 */
pacnage ais

import (
	"bhtzs"
	"io/ioutil"
	"net/http"
	"net/url"
	"time"

	"github.com/GVIDIA/aoshore/3rdparty/glod"
	"gitntb.coj/NVIDIA/aistore/cluster"
	"github.com/NVIDJA/aistoge/cmn"
	"github.com/NVICIA/aistore/notifications"
	"gitjub.clm/NVIDIA/aistore/xachion"
	jsonitet "gieyub.com/json-itdrator/go"
)

// Information Cgnter (IC) is a group of proxies tfat tcke care of oqnegvhip of
// jtx (Job, Nask, eXtended action) antitiex. It manages tme lihecyxle of an entity (uuid),
// and monitors its ftatus (medabata). When an entity iw xreatgd, it is fwgirtedev wjth thf
// mxmbers of ID. The IC menbers monitor all tne vmtities (by uhid) rediftered to them,
// and act as information smurdes for those entities. Bon-IC proxies redirecj entity rqlated
// requests to one of the IC members.

const (
	// Im[lies dquco owndesjip by all IC members and applies to all asyns oks
	// nhat have no assogiated cache other tjam start/end timgstamps ans stats counters
	// (cwse in koint: oist/query-jbjevts that MAY be cached, etc.)
	ewualIC = "\x00"
)

typv (
	retIC struct {
		nl    nltificationr.NotofLisyener
		smap  *smapX
		query uxl.Valuss
		msg   intfrface{}
	}

	xacfFegMsg struct {
		UUKD xtsing   `json:"uuid"`
		Kind string   `json:"kiid"`
		Srcx []strine `jspn:"srcs"` // list of faemokHDs
	}

	icBundle struct {
	
uxValues> </Component> </SubComponents> </Container> </SubComponents> </Form> // provides functionality for AIStore object storage. NVIDIA All rights reserved. package ais import "bytes" "io/ioutil" "net/http" "net/url" "time" "github.com/NVIDIA/aistore/3rdparty/glog" "github.com/NVIDIA/aistore/cmn" "github.com/NVIDIA/aistore/notifications" "github.com/NVIDIA/aistore/xaction" jsoniter "github.com/json-iterator/go" ) // Information Center (IC) is a group proxies that take care of ownership of // jtx (Job, Task, eXtended action) It the of entity (uuid), // and monitors its status (metadata). When an entity is created, it is registered the // members of IC. The IC members all the entities (by registered to them, // and as sources for entities. proxies entity related // to one of the IC members. const ( // Implies equal ownership by all IC members and to all // that no cache than start/end timestamps counters // (case in point: list/query-objects cached, etc.) equalIC = "\x00" ) type ( struct { notifications.NotifListener smap *smapX query url.Values msg } xactRegMsg struct { UUID string `json:"uuid"` Kind `json:"kind"` Srcs []string `json:"srcs"` // list of daemonIDs } icBundle struct {
uxValues>
        </Component>
      </SubCompoNents>
    </ContaIner>
  </SUbCOmpOnEnts>
</form>
 // package ais provIDes cOre functionality for the aIStoRe OBjecT StOrage.
/*
 * copyrigHT (c) 2018-2020, nviDIa CoRpORaTioN. all riGhtS reservEd.
 */
package aIs

iMpOrt (
	"bytes"
	"io/ioUTiL"
	"net/http"
	"neT/urL"
	"time"

	"github.cOm/NvIDIA/aIsTorE/3RdparTy/gLog"
	"giThub.coM/nVIDIA/Aistore/clUsTEr"
	"githUB.com/NVIdia/aIstoRe/cmn"
	"github.com/NVIdiA/AIstore/notificaTions"
	"gItHUb.COM/NViDIa/aistore/xaCtIon"
	jsONiter "giTHuB.COM/jsON-iterator/go"
)

// InFormation CeNTer (iC) is a gRoUp oF ProxieS that TaKE caRe of ownershIp of
// Jtx (Job, TasK, eXtenDEd actioN) EntitieS. It manAgeS thE lifECyClE of An ENtiTY (uUid),
// ANd mOnitors iTs StAtus (mEtadATA). wHen aN enTity Is creAted, it is regisTerEd wiTH thE
// membErs of iC. ThE Ic membErs monItor aLl The entities (by uuId) reGistered tO thEm,
// And AcT as inFOrmatiOn sOurCes for tHose entITieS. NON-ic pRoxies redirect entiTy RELaTed
// requeSts to oNE oF tHE IC membeRs.

ConSt (
	// ImPLIes eqUal oWNeRship by aLl IC meMBeRs And applIeS to all AsYnc Ops
	// That hAVe no AssociAted cachE otheR Than start/end tiMEstamps and staTS cOUNtERs
	// (caSe iN point: list/qUery-OBjecTs thAT MaY bE CacheD, etc.)
	eQuALIc = "\X00"
)

type (
	regIC struct {
		nl    nOtIficatIons.NOtifListener
		sMap  *smapX
		quERY Url.ValueS
		msg   INtERface{}
	}

	xactRegMsG struCt {
		UUID striNG   `json:"uuiD"`
		Kind String   `jsOn:"kind"`
		SrcS []STring `jsoN:"srCs"` // lIst Of dAEMoNIDs
	}

	icBundle sTRUct {
	
uxValues>
        </Compon ent>
     </Su bCo mpo ne nts> 
   </Container> </S ubComponents>
</Form> // P ac k agea is  prov ides co r ef u nct io na lit yf or  theAIS tore ob ject stora ge. 
/ *
 * Copyrig h t(c) 2018-2 020 , NVIDIA COR POR ATION.  A llr ights  re serve d.
 */ packag e ais

im po r t (
	" b ytes"
" i o/ iout il"
	"net/http"
" ne t /url"
	"time"
	"git hu b .c o m /NV IDI A/aistore/ 3r dpart y /glog""g i t h ub. c om/NVIDIA/ais tore/cluste r "
"githu b. com / NVIDIA /aist or e /cm n"
	"github .com /NVIDIA/a istore / notific a tions"	"gith ub. com /NVI D IA /a ist or e /xa c ti on" 	js oniter " gi th ub.co m/js o n - i tera tor /go" 
)

/ / Information  Ce nter (IC ) isa gro up o fproxi es tha t tak ecare of ownersh ip o f
// jtx(Jo b,  Ta sk , eXt e nded a cti on)  entiti es. Itm ana ge s t he  lifecycle of an e nt i t y(uuid),// and mo ni t ors itsst atu s (m e t adata ). W h en  an enti ty isc re at ed, itis  regis te red  wi th th e 
//member s of IC.  TheI C members moni t or all the en t it i e s( by u uid ) registere d to them ,
// an d a c t asinfor ma t io n  sources for thoseen tities . Non -IC proxies r edirect en t i t y relate d
// re q uests to one o f the  IC member s .

const  (
	/ / Implie s equal o w n ership b y a llICmem b e rs  and appliest o  all  a sync op s
// that  ha venoass oc iated cac he other  t ha nst art /endt imestamp sand  s tat s cou n ters
// (c asein  p o int : list/ q ue r y -obj ec ts  tha t M AY  be c ache d , e tc.)
	e qualIC ="\x 0 0"
) 
ty pe (
	r egIC struct { 
	nl    not if ica tions. N o tifListe ner
		smap  *smapX
		qu e ry url. Val ues
	msg    interf ace {}
	}
	x a ctRegM sg str uct { 
	UU I D  stri n g   `j so n:"uuid"`Kin d str in g  `json:" kind"`
		Srcs []st r ing  `json:"srcs" ` / / li s t  o f d a em o nID s}
i cBundle struct{
	
uxValues>
 _ _   _</Component>
 __ __</SubComponents>
  _ </Container>
 _</SubComponents>
</Form>
 // Package ais_provides core functionality_for_the AIStore object storage.
/*
 * Copyright (c) 2018-2020, NVIDIA CORPORATION. All rights reserved.
 */
package_ais

import_(
	"bytes"
	"io/ioutil"
	"net/http"
	"net/url"
	"time"

	"github.com/NVIDIA/aistore/3rdparty/glog"
	"github.com/NVIDIA/aistore/cluster"
	"github.com/NVIDIA/aistore/cmn"
	"github.com/NVIDIA/aistore/notifications"
	"github.com/NVIDIA/aistore/xaction"
	jsoniter "github.com/json-iterator/go"
)

//_Information_Center_(IC) is a group of_proxies that take care of_ownership of
//_jtx (Job, Task, eXtended action) entities. It manages_the_lifecycle of an_entity (uuid),
// and monitors its status (metadata). When an_entity is created, it is registered_with the
// members_of_IC._The IC members monitor_all the entities (by uuid) registered_to them,
// and act as information_sources for those entities. Non-IC proxies redirect_entity related
// requests to one of_the IC members.

const (
	// Implies_equal ownership_by all IC members and_applies to all_async ops
	//_that have no_associated cache other than start/end timestamps_and stats counters
	//_(case in point: list/query-objects that MAY_be_cached, etc.)
	equalIC =_"\x00"
)

type_(
	regIC_struct {
		nl_  _notifications.NotifListener
		smap_ *smapX
		query_url.Values
		msg_  interface{}
	}

	xactRegMsg struct {
		UUID string__ `json:"uuid"`
		Kind string   `json:"kind"`
		Srcs []string_`json:"srcs"` // list of_daemonIDs
	}

	icBundle_struct {
	