pkg/

Versions in this module

v0

v0.8.16

Aug 27, 2021

v0.8.15

Aug 27, 2021

v0.8.14

Sep 23, 2020

v0.8.13

Jun 20, 2020

v0.8.12

Jun 10, 2020

v0.8.11

Jun 6, 2020

v0.8.10

Jun 6, 2020

v0.8.9

Jun 5, 2020

v0.8.8

Jun 4, 2020

v0.8.7

Jun 3, 2020

v0.8.6

Jun 1, 2020

v0.8.5

May 21, 2020

v0.8.4

May 20, 2020

v0.8.3

May 20, 2020

v0.8.2

May 20, 2020

v0.8.1

May 12, 2020

v0.8.0

May 10, 2020

v0.7.5

Apr 23, 2020

v0.7.5-1

Apr 23, 2020

v0.7.4

Apr 12, 2020

v0.7.4-3

Apr 19, 2020

v0.7.4-2

Apr 12, 2020

v0.7.3

Mar 31, 2020

v0.7.2

Mar 31, 2020

v0.7.1

Mar 30, 2020

v0.7.1-1

Mar 31, 2020

v0.7.0

Mar 29, 2020

v0.7.0-2

Mar 29, 2020

v0.6.10

Mar 28, 2020

v0.6.9

Mar 12, 2020

v0.6.8

Mar 10, 2020

v0.6.8-2

Mar 10, 2020

v0.6.8-1

Mar 10, 2020

v0.6.7

Mar 10, 2020

v0.6.6

Mar 9, 2020

v0.6.6-1

Mar 9, 2020

v0.6.5

Mar 6, 2020

v0.6.4

Mar 6, 2020

v0.6.3

Mar 6, 2020

v0.6.3-2

Mar 6, 2020

v0.6.3-1

Mar 6, 2020

v0.6.2

Mar 6, 2020

v0.6.1

Mar 4, 2020

v0.6.0

Mar 4, 2020

v0.5.3

Feb 22, 2020

Changes in this version

+ func BasicLinkConstraints(model xir.Props, divisor int) (latency, capacity string)

type EdgeInfo

+ NodeInterface string

+ NodeName string

+ func (e *EdgeInfo) String() string

type LinkInfo

+ Kind LinkKind

+ Props xir.Props

+ Vindex int

+ XpID string

+ func GenLinkInfo(mzInfo *MzInfo, fragment *site.MzFragment, linkModel *site.LinkModel, ...) (*LinkInfo, error)

+ func ListLinkInfos(mzid string) ([]*LinkInfo, error)

+ func (li *LinkInfo) Edges() []*EdgeInfo

+ type MoaEmulationState int

+ const MoaEmuFinalized

+ const MoaEmuInitialized

+ const MoaEmuNone

+ const MoaEmuStarted

+ const MoaEmuStopped

+ type MoaEmulationStatus struct

+ Id int

+ Mzid string

+ State MoaEmulationState

+ func (x *MoaEmulationStatus) GetVersion() int64

+ func (x *MoaEmulationStatus) Key() string

+ func (x *MoaEmulationStatus) SetVersion(v int64)

+ func (x *MoaEmulationStatus) Value() interface{}

v0.5.2

Feb 20, 2020

Changes in this version

+ func ReadRevision(obj Object) (revision int64, err error)

type Task

+ func (t *Task) Incomplete(actionstatuses map[string]*ActionStatus) ([]*ActionStatus, error)

v0.5.1

Feb 14, 2020

v0.5.0

Feb 13, 2020

Changes in this version

+ func ActionPreRun(etcdp **clientv3.Client, cog string, doTask func(*Task) error) error

+ func EtcdPrefix(objStr, optkey string) ([]interface{}, error)

+ func GenerateID() (string, error)

+ func GetAllAS() (map[string]*ActionStatus, error)

+ func GetMzidAS(mzid, taskid string) (map[string]*ActionStatus, error)

+ func GetTaskStagesMap(mzid, taskid string) (map[string]*Stage, error)

+ func MaskAction(mzid, taskid, actionid string, unmask bool) error

+ func RunObjectTxPrefix(puts []Object, deletePrefix string) error

+ func WithMinEtcd(f func(*clientv3.Client) (interface{}, error)) (interface{}, error)

+ type ASError struct

+ Actionid string

+ Mzid string

+ Taskid string

+ func EtcdActionErrorPrefix() ([]*ASError, error)

+ func ExtractASError(asErrorJSON string) (*ASError, error)

+ func (as *ASError) GetVersion() int64

+ func (as *ASError) Key() string

+ func (as *ASError) SetVersion(v int64)

+ func (as *ASError) Value() interface{}

+ type ASReady struct

+ Actionid string

+ Mzid string

+ Taskid string

+ func EtcdActionReadyPrefix() ([]*ASReady, error)

+ func ExtractASReady(asReadyJSON string) (*ASReady, error)

+ func (as *ASReady) GetVersion() int64

+ func (as *ASReady) Key() string

+ func (as *ASReady) SetVersion(v int64)

+ func (as *ASReady) Value() interface{}

type Action

+ ID string

+ Stageid string

+ Taskid string

+ func EtcdActionPrefix(prefix string) ([]*Action, error)

+ func ExtractAction(actionJSON string) (*Action, error)

+ func GetAction(mzid, taskid, actionid string) (*Action, error)

+ func (a *Action) GetVersion() int64

+ func (a *Action) Key() string

+ func (a *Action) SetVersion(v int64)

+ func (a *Action) ToStatus() *ActionStatus

+ func (a *Action) Value() interface{}

type ActionStatus

+ Taskid string

+ func EtcdActionStatusPrefix(prefix string) ([]*ActionStatus, error)

+ func GetAllReadyAS() ([]*ActionStatus, error)

+ func (as *ActionStatus) ToError() *ASError

+ func (as *ActionStatus) ToReady() *ASReady

type LinkInfo

+ func ListLinkInfo(mzid string) ([]*LinkInfo, error)

type LinkSpec

+ Mzid string

+ func ListLinkSpec(mzid string) ([]*LinkSpec, error)

+ func (ls *LinkSpec) GetVersion() int64

+ func (ls *LinkSpec) Key() string

+ func (ls *LinkSpec) SetVersion(x int64)

+ func (ls *LinkSpec) Value() interface{}

type NodeInfo

+ Machine string

+ Mzid string

+ func ListNodeInfo(mzid string) ([]*NodeInfo, error)

+ func (ni *NodeInfo) GetVersion() int64

+ func (ni *NodeInfo) Key() string

+ func (ni *NodeInfo) SetVersion(x int64)

+ func (ni *NodeInfo) Value() interface{}

type Stage

+ ID string

+ Order int

+ Taskid string

+ func EtcdStagePrefix(prefix string) ([]*Stage, error)

+ func ExtractStage(stageJSON string) (*Stage, error)

+ func GetStage(mzid, taskid, stageid string) (*Stage, error)

+ func GetTaskStages(mzid, taskid string) ([]*Stage, error)

+ func (s *Stage) GetVersion() int64

+ func (s *Stage) Key() string

+ func (s *Stage) SetVersion(v int64)

+ func (s *Stage) Value() interface{}

+ type StageWithActions struct

+ Actions []*Action

+ Stage *Stage

+ func (s *StageWithActions) AddActions(actions ...*Action)

type Task

+ Instance string

+ func EtcdTaskPrefix(prefix string) ([]*Task, error)

+ func ParseAction(as *ActionStatus) (*Task, error)

+ type YamlTask struct

+ ID string

+ Instance string

+ Mzid string

+ Stages []*StageWithActions

+ Timestamp string

v0.4.6

Feb 13, 2020

Changes in this version

+ const BgpSubnetMask

v0.4.5

Feb 10, 2020

Changes in this version

type TBVLink

+ Advertisements []string

v0.4.4

Feb 10, 2020

v0.4.3

Feb 4, 2020

Changes in this version

+ const InitMoaControl

+ const MoaControlKind

+ const MoactldImage

+ const MoactldMountDest

+ const MoactldMountName

+ const MoactldMountSource

+ func Touch(obj Object) error

+ func TouchObjects(objs []Object) error

+ type MoaControlSpec struct

+ ControlHost string

+ EmulationHost string

type MoaEmulationSpec

+ ControlHost string

+ Tags []string

v0.4.2

Jan 28, 2020

Changes in this version

+ var ErrASMapEmpty error = fmt.Errorf("empty action status map")

+ var ErrASMapNil error = fmt.Errorf("nil action status map")

+ func DeleteTasks(mzid string) error

+ func GetMzidActions(mzid string) (map[string]*ActionStatus, error)

+ func TriageTask(etcd *clientv3.Client, t *Task, doTask func(*Task) error) error

type ActionStatus

+ Mzid string

+ func ExtractAS(asJSON string) (*ActionStatus, error)

+ func ExtractBadAS(asJSON string) (*ActionStatus, error)

type Task

+ func ExtractTask(taskJSON string) (*Task, error)

v0.4.1

Jan 20, 2020

Changes in this version

+ const CreateMoaLink

+ const FinalizeEmulation

+ const InitEmulation

+ const RemoveMoaLink

+ const StartEmulation

type MoaEmulationSpec

+ Mzid string

+ func (m *MoaEmulationSpec) GetVersion() int64

+ func (m *MoaEmulationSpec) Key() string

+ func (m *MoaEmulationSpec) RemoveLink(l moa.DuplexLink)

+ func (m *MoaEmulationSpec) RemoveMPL(z moa.MPL)

+ func (m *MoaEmulationSpec) SetVersion(x int64)

+ func (m *MoaEmulationSpec) Value() interface{}

type Task

+ func (t *Task) Cancel() error

v0.3.10

Jan 17, 2020

Changes in this version

+ const ActionComplete

+ func GetAllActions() (map[string]*ActionStatus, error)

type Action

+ Status string

+ func (a *Action) GenKey()

+ func (a *Action) GenStatus() error

+ func (a *Action) SetActionComplete() error

+ type ActionStatus struct

+ Complete bool

+ Error *string

+ ID string

+ Masked bool

+ func GetActionStatus(asID string) (*ActionStatus, error)

+ func (as *ActionStatus) GetVersion() int64

+ func (as *ActionStatus) Key() string

+ func (as *ActionStatus) SetVersion(v int64)

+ func (as *ActionStatus) Value() interface{}

type Task

+ func (t *Task) ClearComplete() error

v0.3.9

Jan 10, 2020

v0.3.8

Dec 24, 2019

v0.3.7

Dec 11, 2019

Changes in this version

+ func DeleteMzInfo(mzinfo *MzInfo) error

type NodeState

+ func GetNodeStatus(nodeName string) (*NodeState, error)

+ type NodeStateStatus struct

+ Current NodeStatus

+ Target NodeStatus

v0.3.6

Nov 13, 2019

v0.3.5

Nov 12, 2019

Changes in this version

+ func GetNodeSwitch(nodeEndpoint *xir.Endpoint) *xir.Endpoint

type LinkKind

+ func ParseLinkKind(s string) (LinkKind, error)

type Task

+ func (t *Task) SetComplete()

v0.3.4

Sep 13, 2019

v0.3.3

Sep 13, 2019

Changes in this version

type EdgeInfo

+ Interface string

+ Multidegree bool

+ Resource string

+ type LinkAction int

+ const CreateLink

+ const DestroyLink

+ func (a LinkAction) Canopy() string

+ func (a LinkAction) Moa() string

type LinkInfo

+ Core []string

+ TBVLinks []*TBVLink

+ func (li *LinkInfo) AssignIDs() error

+ func (li *LinkInfo) Del() error

+ func (li *LinkInfo) EdgeLink(name string) *TBVLink

+ func (li *LinkInfo) Init() error

type NodeStatus

+ func (s NodeStatus) String() string

type Stage

+ func (s *Stage) AddActions(a ...*Action)

+ type TBVLink struct

+ Edges []*EdgeInfo

+ Vid int

+ Vni int

v0.3.2

Sep 11, 2019

Changes in this version

+ type EdgeInfo struct

+ Mac string

+ Name string

v0.3.1

Sep 10, 2019

Changes in this version

+ const AdvertiseInterfaceMac

+ const IDAlphabet

+ const LaunchEmulation

+ const MoaInterfaceType

+ const MoaKind

+ const MoaXDPMode

+ const TeardownEmulation

+ const WithdrawMac

+ var ErrAlreadyWorking = fmt.Errorf("cog already running")

+ var ErrNotFound = fmt.Errorf("not found")

+ var MoaAS = flag.Int("moa-as", 67420, "moa autonomous system number")

+ var MoaBgpAddr = flag.String("moa-bgp-addr", "10.99.0.20/32", "moa bgp address")

+ func AllResourceIDs(net *xir.Net) []string

+ func CogletID() string

+ func FromJSON(o Object, b []byte)

+ func ToJSON(o Object) string

type CogletInfo

+ ID string

type EvpnWithdrawData

+ Addr string

+ Asn int

+ type InterfaceMacAdvSpec struct

+ Interface string

+ Netns string

+ Vindex int

+ Vni int

type LinkKind

+ const MoaLink

type MacAdvSpec

+ Addr string

+ Asn int

+ Mac string

+ Router string

+ type MoaEmulationSpec struct

+ EmulationHost string

+ ID int

+ Links []moa.DuplexLink

+ MPLs []moa.MPL

+ Vnis []int

type MzInfo

+ IncomingTaskID string

+ LinkCreateTaskID string

+ LinkDestroyTaskID string

+ NodeRecycleTaskID string

+ NodeSetupTaskID string

+ TeardownTaskID string

type MzStatus

+ func (s MzStatus) String() string

type Task

+ ID string

v0.2.20

Jul 25, 2019

Changes in this version

+ const RetryWait

+ const SetStatus

type MzInfo

+ Status MzStatus

+ type MzStatus int

+ const Active

+ const Dematerializing

+ const Materializing

+ const MzNone

+ type NodeState struct

+ Mzid string

+ Name string

+ Status NodeStatus

+ func (n *NodeState) Key() string

+ func (v *NodeState) GetVersion() int64

+ func (v *NodeState) SetVersion(x int64)

+ func (v *NodeState) Value() interface{}

type NodeStatus

+ const Clean

+ const NodeNone

+ const Ready

+ const Recycling

+ const Setup

v0.2.19

Jul 12, 2019

Changes in this version

+ func DelEnclaveBridge(spec *EnclaveSpec, ctx *rtnl.Context) error

+ func DelEnclaveIptables(mzid string, spec *EnclaveSpec) error

+ func EnclaveBridge(spec *EnclaveSpec, ctx *rtnl.Context) error

+ func EnclaveIptables(mzid string, spec *EnclaveSpec) error

+ func NsDefaultRoute(mzid string, spec *EnclaveSpec) error

v0.2.18

Jun 28, 2019

Changes in this version

+ func FromJson(o Object, b []byte)

+ func ToJson(o Object) string

+ func WithEtcd(f func(*clientv3.Client) error) error

type LinkSpec

+ Xlid string

v0.2.17

Jun 27, 2019

Changes in this version

type LinkSpec

+ func FragmentToLinkSpec(topo *xir.Net, mzid string, fragment *site.MzFragment, action string, ...) (*LinkSpec, error)

v0.2.16

Jun 6, 2019

Changes in this version

+ func RUC(o Object, update func(o Object)) error

v0.2.15

Jun 4, 2019

v0.2.14

May 31, 2019

Changes in this version

+ const InfraVidKey

+ const InfraVniKey

+ const VindexKey

+ const XpVidKey

+ const XpVniKey

v0.2.13

May 30, 2019

Changes in this version

+ type PortMode int

+ type PortObj struct

+ Host string

+ Mode PortMode

+ Mzid string

+ Port string

+ Up bool

+ Vids []int

+ func (x *PortObj) GetVersion() int64

+ func (x *PortObj) Key() string

+ func (x *PortObj) SetVersion(v int64)

+ func (x *PortObj) Value() interface{}

+ type VtepObj struct

+ Host string

+ Mzid string

+ Name string

+ Vid int

+ Vni int

+ func (x *VtepObj) GetVersion() int64

+ func (x *VtepObj) Key() string

+ func (x *VtepObj) SetVersion(v int64)

+ func (x *VtepObj) Value() interface{}

v0.2.12

May 24, 2019

Changes in this version

+ const AddNexMembers

+ const AdvertiseMac

+ const BookkeepingKind

+ const CanopyKind

+ const ConfigCtrLo

+ const ContainerKind

+ const CreateCtr

+ const CreateCtrNs

+ const CreateCtrRecord

+ const CreateCtrTask

+ const CreateEnclave

+ const CreateNexNetwork

+ const CreateNimbusConfig

+ const DefaultInternalGateway

+ const DefaultInternalGatewayCIDR

+ const DefaultMountType

+ const DefaultServiceGateway

+ const DeleteCtr

+ const DeleteCtrImg

+ const DeleteCtrNS

+ const DeleteCtrRecord

+ const DeleteCtrTask

+ const DeleteMzinfo

+ const DeleteNS

+ const DeleteNexMembers

+ const DeleteNexNetwork

+ const DeleteNimbusConfig

+ const DestroyEnclave

+ const EnsureRally

+ const EtcdImage

+ const EtcdNamespace

+ const FoundryArgs

+ const FoundryCertMountDest

+ const FoundryCertMountName

+ const FoundryCertMountSource

+ const FoundryEnv

+ const FoundryImage

+ const FoundryKeyMountDest

+ const FoundryKeyMountName

+ const FoundryKeyMountSource

+ const FoundryNamespace

+ const HarborControlAddr

+ const HarborInfraVID

+ const HarborInfraVNI

+ const HarborMzid

+ const HarborNet

+ const HarborSvcAddr

+ const HarborVid

+ const HarborVindex

+ const HarborVni

+ const HarborXpVNI

+ const IdAlphabet

+ const InfraCanopyHost

+ const InfrapodMznIfx

+ const InfrapodSvcIfx

+ const LaunchCtr

+ const MaxSystemVindex

+ const NexDomainEnv

+ const NexImage

+ const NexKind

+ const NexMountDest

+ const NexMountName

+ const NexMountSource

+ const NexNamespace

+ const NimbusKind

+ const NodeRecycleKind

+ const NodeSetupKind

+ const OtterKind

+ const PlumbingKind

+ const PullCtrImage

+ const RallyKind

+ const RecycleRally

+ const RemoveCanopyLinks

+ const RemoveCanopyServiceVtep

+ const SetCanopyLinks

+ const SetCanopyServiceVtep

+ const SetOtter

+ const Svcbr

+ const TimeFormat

+ const TxnFailedPrefix

+ const XIR_FILE_PATH

+ var AlreadyWorking error = fmt.Errorf("cog already running")

+ var BgpAS = flag.Int("bgp-as", 0, "bgp autonomus system number")

+ var BgpAddr = flag.String("bgp-addr", "", "bgp address")

+ var DefaultMountOptions = []string

+ var GobgpdPort = flag.Int("gobgpd-port", 50051, "gobgpd listening port")

+ var NotFound error = fmt.Errorf("not found")

+ var Version = "undefined"

+ func AllResourceIds(net *xir.Net) []string

+ func CancelTask(prefix string) error

+ func CheckForTasks(etcd *clientv3.Client, doTask func(*Task) error) error

+ func Cmdr(cfg common.Config, f func(cm.CommanderClient) error) error

+ func CogletId() string

+ func CommanderClient(cfg common.Config) (*grpc.ClientConn, cm.CommanderClient, error)

+ func ContainerdClient() (*containerd.Client, error)

+ func CreateContainer(ctr *ContainerSpec) error

+ func CreateContainerRecord(spec *ContainerSpec) error

+ func CreateContainerTask(ctr *ContainerSpec) error

+ func CreateIfx(netns string, ifx *EnclaveVeth) error

+ func CreateInfrapodNS(name string) error

+ func CreateLinks(mzid, instance string, fragments []*site.MzFragment) error

+ func CreateTask(ctx context.Context, ctr containerd.Container, ns, name string) error

+ func Delete(obj Object) error

+ func DeleteContainer(name, namespace string) error

+ func DeleteContainerIfx(namespace, name string) error

+ func DeleteContainerImg(name, namespace string) error

+ func DeleteContainerNs(name string) error

+ func DeleteContainerRecord(name, namespace string, a *Action) error

+ func DeleteContainerTask(name, namespace string) error

+ func DeleteIfx(netns string, ifx *EnclaveVeth) error

+ func DeleteInfrapodNS(name string) error

+ func DeleteObjects(objs []Object) error

+ func DeleteTask(ctx context.Context, container containerd.Container) error

+ func DestroyLinks(mzid, instance string, fragments []*site.MzFragment) error

+ func DestroyNetNS(netns *NetNS) error

+ func EnsureEtcd(etcdp **clientv3.Client) error

+ func EtcdConnect() (*clientv3.Client, error)

+ func EvpnAdvertiseMac(veth *rtnl.Link, vni, vindex int) error

+ func EvpnAdvertiseMulticast(vni, vindex int) error

+ func EvpnWithdrawMac(veth *rtnl.Link, vni, vindex int) error

+ func EvpnWithdrawMulticast(vni, vindex int) error

+ func Exec(etcdp **clientv3.Client, cog string, doTask func(*Task) error) error

+ func ExtractConstraint(props map[string]interface{}, key string) *xir.Constraint

+ func GetInfraEndpoint(n *xir.Node) *xir.Endpoint

+ func GetIntLike(x interface{}) (int, error)

+ func GetNativeNlri(p *api.Path) (bgp.AddrPrefixInterface, error)

+ func GetNativePathAttributes(p *api.Path) ([]bgp.PathAttributeInterface, error)

+ func GetNodeLeaf(nodeEndpoint *xir.Endpoint) *xir.Endpoint

+ func HandleIncoming(rq *cm.IncomingRequest) error

+ func HandleLinkCreate(rq *cm.MzRequest) error

+ func HandleLinkDestroy(rq *cm.MzRequest) error

+ func HandleNodeRecycle(rq *cm.MzRequest) error

+ func HandleNodeSetup(rq *cm.MzRequest) error

+ func HandleStatus(rq *cm.StatusRequest) (*cm.StatusResponse, error)

+ func HandleTask(etcd *etcd.Client, task *Task, lease etcd.LeaseID, doTask func(*Task) error)

+ func Init()

+ func InitInfranet(mzid, instance string, props map[string]interface{}, record bool) error

+ func IsTxnFailed(err error) bool

+ func KeepLeaseAlive(etcd *clientv3.Client, lease clientv3.LeaseID) (chan bool, error)

+ func LaunchTask(task *Task) error

+ func LeaseTask(c *etcd.Client, t *Task) (etcd.LeaseID, error)

+ func ListContainers(ctx context.Context) ([]containerd.Container, error)

+ func ListNamespaces() ([]string, error)

+ func LoadXIR() (*xir.Net, error)

+ func MarshalFlowSpecRules(values []bgp.FlowSpecComponentInterface) []*any.Any

+ func MarshalNLRI(value bgp.AddrPrefixInterface) *any.Any

+ func MarshalNLRIs(values []bgp.AddrPrefixInterface) []*any.Any

+ func MarshalPathAttributes(attrList []bgp.PathAttributeInterface) []*any.Any

+ func MarshalRD(rd bgp.RouteDistinguisherInterface) *any.Any

+ func MarshalRT(rt bgp.ExtendedCommunityInterface) *any.Any

+ func MarshalRTs(values []bgp.ExtendedCommunityInterface) []*any.Any

+ func Merge2Local(devId string) (string, error)

+ func NewAggregatorAttributeFromNative(a *bgp.PathAttributeAggregator) *api.AggregatorAttribute

+ func NewAigpAttributeFromNative(a *bgp.PathAttributeAigp) *api.AigpAttribute

+ func NewAs4AggregatorAttributeFromNative(a *bgp.PathAttributeAs4Aggregator) *api.As4AggregatorAttribute

+ func NewAs4PathAttributeFromNative(a *bgp.PathAttributeAs4Path) *api.As4PathAttribute

+ func NewAsPathAttributeFromNative(a *bgp.PathAttributeAsPath) *api.AsPathAttribute

+ func NewAtomicAggregateAttributeFromNative(a *bgp.PathAttributeAtomicAggregate) *api.AtomicAggregateAttribute

+ func NewClusterListAttributeFromNative(a *bgp.PathAttributeClusterList) *api.ClusterListAttribute

+ func NewCommunitiesAttributeFromNative(a *bgp.PathAttributeCommunities) *api.CommunitiesAttribute

+ func NewEthernetSegmentIdentifierFromNative(a *bgp.EthernetSegmentIdentifier) *api.EthernetSegmentIdentifier

+ func NewExtendedCommunitiesAttributeFromNative(a *bgp.PathAttributeExtendedCommunities) *api.ExtendedCommunitiesAttribute

+ func NewIP6ExtendedCommunitiesAttributeFromNative(a *bgp.PathAttributeIP6ExtendedCommunities) *api.IP6ExtendedCommunitiesAttribute

+ func NewLargeCommunitiesAttributeFromNative(a *bgp.PathAttributeLargeCommunities) *api.LargeCommunitiesAttribute

+ func NewLocalPrefAttributeFromNative(a *bgp.PathAttributeLocalPref) *api.LocalPrefAttribute

+ func NewMpReachNLRIAttributeFromNative(a *bgp.PathAttributeMpReachNLRI) *api.MpReachNLRIAttribute

+ func NewMpUnreachNLRIAttributeFromNative(a *bgp.PathAttributeMpUnreachNLRI) *api.MpUnreachNLRIAttribute

+ func NewMultiExitDiscAttributeFromNative(a *bgp.PathAttributeMultiExitDisc) *api.MultiExitDiscAttribute

+ func NewNextHopAttributeFromNative(a *bgp.PathAttributeNextHop) *api.NextHopAttribute

+ func NewOriginAttributeFromNative(a *bgp.PathAttributeOrigin) *api.OriginAttribute

+ func NewOriginatorIdAttributeFromNative(a *bgp.PathAttributeOriginatorId) *api.OriginatorIdAttribute

+ func NewPath(nlri bgp.AddrPrefixInterface, isWithdraw bool, ...) *api.Path

+ func NewPmsiTunnelAttributeFromNative(a *bgp.PathAttributePmsiTunnel) *api.PmsiTunnelAttribute

+ func NewTunnelEncapAttributeFromNative(a *bgp.PathAttributeTunnelEncap) *api.TunnelEncapAttribute

+ func NewUnknownAttributeFromNative(a *bgp.PathAttributeUnknown) *api.UnknownAttribute

+ func NodeOps(kind, mzid, instance string, fragments []*site.MzFragment) error

+ func NodeRecycle(mzid, instance string, fragments []*site.MzFragment) error

+ func NodeSetup(mzid, instance string, fragments []*site.MzFragment) error

+ func PullContainerImage(namespace, image string) error

+ func Read(obj Object) error

+ func ReadNew(obj Object) error

+ func ReadObjects(objs []Object) (error, int)

+ func ReadWait(obj Object, timer *ReadTimer) error

+ func RegisterCoglet(c *etcd.Client, cog string) (error, etcd.LeaseID)

+ func RegisterWithCommander()

+ func RevokeLease(etcd *clientv3.Client, lease clientv3.LeaseID)

+ func RunObjectTx(otx ObjectTx) error

+ func SetupContainerLo(namespace string) error

+ func SvcAddress(vindex int) string

+ func SvcCidr(vindex int) string

+ func TeardownInfranet(mzid, instance string, props map[string]interface{}, record bool) error

+ func ToApiFamily(afi uint16, safi uint8) *api.Family

+ func ToRouteFamily(f *api.Family) bgp.RouteFamily

+ func TxnFailed(message string) error

+ func UnmarshalAttribute(an *any.Any) (bgp.PathAttributeInterface, error)

+ func UnmarshalFlowSpecRules(values []*any.Any) ([]bgp.FlowSpecComponentInterface, error)

+ func UnmarshalNLRI(rf bgp.RouteFamily, an *any.Any) (bgp.AddrPrefixInterface, error)

+ func UnmarshalNLRIs(rf bgp.RouteFamily, values []*any.Any) ([]bgp.AddrPrefixInterface, error)

+ func UnmarshalPathAttributes(values []*any.Any) ([]bgp.PathAttributeInterface, error)

+ func UnmarshalRD(a *any.Any) (bgp.RouteDistinguisherInterface, error)

+ func UnmarshalRT(a *any.Any) (bgp.ExtendedCommunityInterface, error)

+ func UnmarshalRTs(values []*any.Any) ([]bgp.ExtendedCommunityInterface, error)

+ func WithCogCNI(netns string) oci.SpecOpts

+ func WithCtrMounts(mounts []*ContainerMount) oci.SpecOpts

+ func Write(obj Object, opts ...etcd.OpOption) error

+ func WriteObjects(objs []Object, opts ...etcd.OpOption) error

+ type Action struct

+ Action string

+ Complete bool

+ Data interface{}

+ Error *string

+ Kind string

+ Masked bool

+ MzInstance string

+ MzOp MzOperation

+ Mzid string

+ func NexCreateMembers(mzid string, endpoints []Endpoint) *Action

+ func NexDeleteMembers(mzid string, endpoints []Endpoint) *Action

+ func NexDeleteNetwork(name string) *Action

+ func (a *Action) SetStage(s *Stage)

+ func (a *Action) SetTask(t *Task)

+ func (a *Action) Stage() *Stage

+ func (a *Action) Task() *Task

+ type BelugaSpec struct

+ Nodes []string

+ Soft bool

+ type CogletInfo struct

+ Cog string

+ Host string

+ Id string

+ Pid int

+ func ListCoglets() ([]*CogletInfo, error)

+ func (c *CogletInfo) GetVersion() int64

+ func (c *CogletInfo) Key() string

+ func (c *CogletInfo) SetVersion(v int64)

+ func (c *CogletInfo) Value() interface{}

+ type Container struct

+ Image string

+ Name string

+ Namespace string

+ Vindex int

+ func (x *Container) GetVersion() int64

+ func (x *Container) Key() string

+ func (x *Container) SetVersion(v int64)

+ func (x *Container) Value() interface{}

+ type ContainerImageData struct

+ Image string

+ Namespace string

+ type ContainerMount struct

+ Name string

+ func (x *ContainerMount) GetVersion() int64

+ func (x *ContainerMount) Key() string

+ func (x *ContainerMount) SetVersion(v int64)

+ func (x *ContainerMount) Value() interface{}

+ type ContainerSpec struct

+ Environment map[string]string

+ Mounts []*ContainerMount

+ func (ctr *ContainerSpec) Env() []string

+ type CountSet struct

+ Name string

+ Offset int

+ Size int

+ Values []int

+ func (c *CountSet) GetVersion() int64

+ func (c *CountSet) Key() string

+ func (c *CountSet) SetVersion(v int64)

+ func (c *CountSet) Value() interface{}

+ func (cs CountSet) Add() (int, CountSet, error)

+ func (cs CountSet) Next() (int, int)

+ func (cs CountSet) Remove(i int) CountSet

+ type CtrComponent struct

+ CtrName string

+ CtrNamespace string

+ type DeleteContainerData struct

+ Name string

+ Namespace string

+ type DeleteContainerIfxData struct

+ EvpnWithdraw bool

+ Name string

+ type DeleteContainerNsData struct

+ Name string

+ type Destination struct

+ Paths []*Path

+ func NewDestination(dst *api.Destination) *Destination

+ func (d *Destination) MarshalJSON() ([]byte, error)

+ type EnclaveSpec struct

+ ExternalGateway string

+ ExternalIfx string

+ ExternalSubnet string

+ Interfaces []*EnclaveVeth

+ InternalGateway string

+ Mzid string

+ NatSourceIP string

+ Vindex int

+ func (e *EnclaveSpec) GetVersion() int64

+ func (e *EnclaveSpec) Key() string

+ func (e *EnclaveSpec) SetVersion(v int64)

+ func (e *EnclaveSpec) Value() interface{}

+ type EnclaveVeth struct

+ Address string

+ Bridge string

+ CtrMac string

+ EvpnAdvertise bool

+ HostMac string

+ Inner string

+ Outer string

+ Vid int

+ Vindex int

+ Vni int

+ func (x *EnclaveVeth) GetVersion() int64

+ func (x *EnclaveVeth) Key() string

+ func (x *EnclaveVeth) SetVersion(v int64)

+ func (x *EnclaveVeth) Value() interface{}

+ type Endpoint struct

+ Interface string

+ Multidegree bool

+ Node string

+ type EvpnInfo struct

+ BgpIP net.IP

+ Rd bgp.RouteDistinguisherInterface

+ Rt bgp.ExtendedCommunityInterface

+ type EvpnWithdrawData struct

+ Vindex int

+ Vni int

+ type FoundrySetSpec struct

+ Endpoint string

+ Machines []*foundry.MachineConfig

+ type ImageBinding struct

+ Image *sled.Image

+ Kexec *sled.Kexec

+ type ImageDefaults struct

+ Image sled.Image

+ func (d *ImageDefaults) GetVersion() int64

+ func (d *ImageDefaults) Key() string

+ func (d *ImageDefaults) SetVersion(v int64)

+ func (d *ImageDefaults) Value() interface{}

+ type ImageSpec struct

+ Endpoint string

+ List []ImageBinding

+ NoVerify bool

+ type LeafPortMode int

+ const Access

+ const Trunk

+ type LeafPortState struct

+ Leaf string

+ Mode LeafPortMode

+ Mzid string

+ Port string

+ Vids []int

+ func (x *LeafPortState) GetVersion() int64

+ func (x *LeafPortState) Key() string

+ func (x *LeafPortState) SetVersion(v int64)

+ func (x *LeafPortState) Value() interface{}

+ type LinkInfo struct

+ Mzid string

+ Vid int

+ Vlid string

+ Vni int

+ func (l *LinkInfo) GetVersion() int64

+ func (l *LinkInfo) Key() string

+ func (l *LinkInfo) SetVersion(v int64)

+ func (l *LinkInfo) Value() interface{}

+ type LinkKind string

+ const InfraLink

+ const XpLink

+ type LinkSpec struct

+ Endpoints []Endpoint

+ Kind LinkKind

+ Links []string

+ Vid int

+ Vni int

+ type MacAdvSpec struct

+ Interface string

+ Netns string

+ Vindex int

+ Vni int

+ type MzInfo struct

+ IncomingTaskId string

+ Instance string

+ LinkCreateTaskId string

+ LinkDestroyTaskId string

+ LinkInfo []LinkSpec

+ Mzid string

+ NodeInfo map[string]NodeInfo

+ NodeRecycleTaskId string

+ NodeSetupTaskId string

+ TeardownTaskId string

+ Vid int

+ Vindex int

+ Vni int

+ func ListMaterializations(prefix string) ([]*MzInfo, error)

+ func (m *MzInfo) GetVersion() int64

+ func (m *MzInfo) Key() string

+ func (m *MzInfo) SetVersion(v int64)

+ func (m *MzInfo) Value() interface{}

+ type MzOperation string

+ const MzIncoming

+ const MzMod

+ const MzOutgoing

+ type MzfIndex struct

+ Fragment *site.MzFragment

+ Resource string

+ func (l *MzfIndex) GetVersion() int64

+ func (l *MzfIndex) SetVersion(v int64)

+ func (l *MzfIndex) Value() interface{}

+ func (x *MzfIndex) Key() string

+ type NetNS struct

+ Containers []string

+ Name string

+ func (x *NetNS) GetVersion() int64

+ func (x *NetNS) Key() string

+ func (x *NetNS) RemoveContainer(ctr string)

+ func (x *NetNS) SetVersion(v int64)

+ func (x *NetNS) Value() interface{}

+ type NexMemberSpec struct

+ Endpoint string

+ type NexNetworkSpec struct

+ Endpoint string

+ Network nex.Network

+ type NimbusConfig struct

+ Node string

+ Users []NimbusUser

+ type NimbusUser struct

+ Name string

+ SshAuthorizedKeys []string

+ Sudo bool

+ type NodeInfo struct

+ Config *foundry.MachineConfig

+ Image *ImageBinding

+ Nex *nex.Member

+ XpName string

+ type NodeInfraInfo struct

+ Endpoint Endpoint

+ Image string

+ Mac string

+ Name string

+ type NodeSpec struct

+ Binding *ImageBinding

+ Config *foundry.MachineConfig

+ Infranet *TargetNetwork

+ Interface string

+ Mac string

+ Multidegree bool

+ Resource string

+ SvcEndpoint string

+ Xname string

+ type NodeStatus struct

+ Mzid string

+ Name string

+ Sled SledStatus

+ func ListNodes() ([]*NodeStatus, error)

+ func (n *NodeStatus) Key() string

+ func (v *NodeStatus) GetVersion() int64

+ func (v *NodeStatus) SetVersion(x int64)

+ func (v *NodeStatus) Value() interface{}

+ type NsnatSpec struct

+ Addr string

+ Dst string

+ Gateway string

+ Src string

+ type Object interface

+ GetVersion func() int64

+ Key func() string

+ SetVersion func(int64)

+ Value func() interface{}

+ type ObjectTx struct

+ Delete []Object

+ Put []Object

+ type OtterSpec struct

+ Endpoints []Endpoint

+ Pubkeys []string

+ type Path struct

+ Age int64

+ Attrs []bgp.PathAttributeInterface

+ Best bool

+ NeighborIP net.IP

+ Nlri bgp.AddrPrefixInterface

+ SourceID net.IP

+ Stale bool

+ Withdrawal bool

+ type RallyStore struct

+ Id string

+ type ReadTimer struct

+ Period time.Duration

+ Timeout time.Duration

+ type SledStatus struct

+ State string

+ Time string

+ type Stage struct

+ Actions []*Action

+ Next *Stage

+ func NewStage(actions ...*Action) *Stage

+ func (s *Stage) Mzid() string

+ type TargetNetwork struct

+ Vid int

+ Vni int

+ type Task struct

+ Coglet string

+ Deps []string

+ Id string

+ Stages []*Stage

+ Timestamp string

+ func ListTasks() ([]*Task, error)

+ func NewTask(stages ...*Stage) *Task

+ func ReadTask(file string) (*Task, error)

+ func (t *Task) AddDep(id string)

+ func (t *Task) AddStage(s *Stage) *Stage

+ func (t *Task) ClearErrors()

+ func (t *Task) Complete() bool

+ func (t *Task) DepsSatisfied() bool

+ func (t *Task) Failed() []*Action

+ func (t *Task) GetVersion() int64

+ func (t *Task) Init()

+ func (t *Task) InsertStage(after *Stage, new *Stage) *Stage

+ func (t *Task) Key() string

+ func (t *Task) MaskAction(stage, action int)

+ func (t *Task) Mzid() string

+ func (t *Task) Reset()

+ func (t *Task) SetVersion(v int64)

+ func (t *Task) Value() interface{}

+ func (t *Task) Wait() error

+ type VLMap struct

+ Entries map[int]*VLMentry

+ Mzid string

+ func (v *VLMap) GetVersion() int64

+ func (v *VLMap) Key() string

+ func (v *VLMap) SetVersion(x int64)

+ func (v *VLMap) Value() interface{}

+ type VLMentry struct

+ Vid int

+ Vni int

+ type VLinkEdge int

+ const VlanAccess

+ const VlanTrunk

+ const Vxlan

+ type Vtep struct

+ Bridge string

+ Dev string

+ Node string

+ TunnelIP string

+ type VtepSpec struct

+ Vid int

+ Vni int

+ Vteps []Vtep

+ type VxLan struct

+ Interfaces []string

+ Vni int

+ func (x *VxLan) GetVersion() int64

+ func (x *VxLan) Key() string

+ func (x *VxLan) RemoveInterface(mac string)

+ func (x *VxLan) SetVersion(v int64)

+ func (x *VxLan) Value() interface{}

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL