cogs

package

Go to main page

Versions in this module

v0

v0.2.11

May 15, 2019

v0.2.10

May 11, 2019

v0.2.9

May 10, 2019

v0.2.8

May 10, 2019

Changes in this version

+ const HarborVid

+ const HarborVni

+ const NodeRecycleKind

+ const NodeSetupKind

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

+ type NodeSpec struct

+ Binding *ImageBinding

+ Config *foundry.MachineConfig

+ Infranet *TargetNetwork

+ Interface string

+ Mac string

+ Multidegree bool

+ Resource string

+ SvcEndpoint string

+ Xname string

+ type TargetNetwork struct

+ Vid int

+ Vni int

v0.2.7

May 9, 2019

Changes in this version

type Action

+ MzInstance string

+ MzOp MzOperation

type MzInfo

+ Instance string

+ type MzOperation string

+ const MzIncoming

+ const MzMod

+ const MzOutgoing

v0.2.6

May 8, 2019

v0.2.5

May 8, 2019

v0.2.4

May 8, 2019

Changes in this version

+ type BelugaSpec struct

+ Nodes []string

+ Soft bool

v0.2.3

May 7, 2019

Changes in this version

+ const HarborControlAddr

type Action

+ Masked bool

type Task

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

v0.2.2

May 1, 2019

v0.2.1

May 1, 2019

Changes in this version

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

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

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

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

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

type LinkSpec

+ Links []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 SledStatus struct

+ State string

+ Time string

type Task

+ func (t *Task) Reset()

v0.1.20

Apr 28, 2019

v0.1.19

Apr 28, 2019

Changes in this version

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

v0.1.18

Apr 23, 2019

v0.1.17

Apr 23, 2019

Changes in this version

+ const IdAlphabet

+ const TimeFormat

type Stage

+ func (s *Stage) Mzid() string

type Task

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

+ func (t *Task) Mzid() string

v0.1.16

Apr 23, 2019

Changes in this version

type Task

+ Timestamp string

v0.1.15

Apr 22, 2019

v0.1.14

Apr 20, 2019

v0.1.13

Apr 19, 2019

Changes in this version

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

type Container

+ Namespace string

type DeleteContainerData

+ Namespace string

+ type LeafPortMode int

+ const Access

+ const Trunk

type LeafPortState

+ Mode LeafPortMode

+ Vids []int

type MzInfo

+ LinkInfo []LinkSpec

+ NodeInfo map[string]NodeInfo

+ type NodeInfo struct

+ Config *foundry.MachineConfig

+ Image *ImageBinding

+ Nex *nex.Member

+ XpName string

v0.1.12

Apr 15, 2019

v0.1.11

Apr 13, 2019

v0.1.10

Apr 13, 2019

Changes in this version

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

type Endpoint

+ Multidegree bool

type LinkInfo

+ Vlid string

+ type MacAdvSpec struct

+ Interface string

+ Netns string

+ Vindex int

+ Vni int

+ type ReadTimer struct

+ Period time.Duration

+ Timeout time.Duration

+ 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

v0.1.9

Apr 9, 2019

Changes in this version

+ const BookkeepingKind

+ const DeleteMzinfo

v0.1.8

Apr 8, 2019

Changes in this version

+ const DefaultServiceGateway

+ const FoundryArgs

+ const FoundryEnv

+ func SvcAddress(vindex int) string

+ func SvcCidr(vindex int) string

v0.1.7

Apr 2, 2019

Changes in this version

+ const CreateEnclave

+ const DefaultInternalGateway

+ const DefaultInternalGatewayCIDR

+ const DestroyEnclave

+ const InfrapodMznIfx

+ const InfrapodSvcIfx

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

+ func CreateInfrapodNS(name string) error

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

+ func DeleteInfrapodNS(name string) error

+ type EnclaveSpec struct

+ ExternalGateway string

+ ExternalIfx string

+ ExternalSubnet string

+ Interfaces []*EnclaveVeth

+ InternalGateway string

+ Mzid string

+ NatSourceIP string

+ Vindex int

+ func (e *EnclaveSpec) Key() string

+ func (l *EnclaveSpec) GetVersion() int64

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

+ func (l *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{}

v0.1.6

Mar 29, 2019

v0.1.5

Mar 29, 2019

v0.1.4

Mar 29, 2019

v0.1.3

Mar 28, 2019

Changes in this version

type ImageSpec

+ NoVerify bool

v0.1.2

Mar 28, 2019

Changes in this version

+ const DefaultMountType

+ const EtcdImage

+ const EtcdNamespace

+ const FoundryCertMountDest

+ const FoundryCertMountName

+ const FoundryCertMountSource

+ const FoundryDelete

+ const FoundryImage

+ const FoundryKeyMountDest

+ const FoundryKeyMountName

+ const FoundryKeyMountSource

+ const FoundryKind

+ const FoundryNamespace

+ const FoundrySet

+ const HarborSvcAddr

+ const HarborVindex

+ const ImageActionSled

+ const KexecActionSled

+ const Svcbr

+ const WipeActionSled

+ const WriteActionSled

+ var DefaultMountOptions = []string

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

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

+ type FoundrySetSpec struct

+ Endpoint string

+ Machines []*foundry.MachineConfig

type ImageBinding

+ Kexec sled.Kexec

+ Mac string

+ 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

+ 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

v0.1.1

Mar 19, 2019

Changes in this version

+ const AddNexMembers

+ const AdvertiseMac

+ const AdvertiseMulticast

+ const BelugaKind

+ const CanopyKind

+ const ConfigCtrLo

+ const ContainerKind

+ const CreateCtr

+ const CreateCtrIfx

+ const CreateCtrNs

+ const CreateCtrRecord

+ const CreateCtrTask

+ const CreateNexNetwork

+ const CreateNimbusConfig

+ const CreateNsnat

+ const CycleBeluga

+ const DeleteCtr

+ const DeleteCtrIfx

+ const DeleteCtrRecord

+ const DeleteCtrTask

+ const DeleteNS

+ const DeleteNexMembers

+ const DeleteNexNetwork

+ const DeleteNimbusConfig

+ const EnsureRally

+ const HarborInfraVID

+ const HarborInfraVNI

+ const HarborMzid

+ const HarborNet

+ const HarborXpVNI

+ const ImageSled

+ const InfraCanopyHost

+ const LaunchCtr

+ const Mzbr

+ const NexDomainEnv

+ const NexImage

+ const NexKind

+ const NexMountDest

+ const NexMountName

+ const NexMountSource

+ const NexMountType

+ const NexNamespace

+ const Nexbr

+ const NimbusKind

+ const OffBeluga

+ const OnBeluga

+ const OtterKind

+ const PlumbingKind

+ const PullCtrImage

+ const RallyKind

+ const RecycleRally

+ const RemoveCanopyLinks

+ const RemoveCanopyServiceVtep

+ const RemoveVtep

+ const SetCanopyLinks

+ const SetCanopyServiceVtep

+ const SetOtter

+ const SledKind

+ const TxnFailedPrefix

+ const WipeSled

+ const WithdrawMulticast

+ 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 GobgpdPort = flag.Int("gobgpd-port", 50051, "gobgpd listening port")

+ var NexIP net.IP

+ var NexMountOptions = []string

+ var NexPrefix = net.IPv4Mask(255, 255, 0, 0)

+ 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 CreateContainer(ctr *ContainerSpec) error

+ func CreateContainerIfx(netns string, ifx *ContainerInterface) error

+ func CreateContainerNS(name string) error

+ func CreateContainerRecord(spec *ContainerSpec) error

+ func CreateContainerTask(ctr *ContainerSpec) error

+ func Delete(obj Object) error

+ func DeleteContainer(service, name string) error

+ func DeleteContainerIfx(namespace, name string) error

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

+ func DeleteContainerTask(service, name string) error

+ func DeleteObjects(objs []Object) 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 HandleTask(etcd *etcd.Client, task *Task, lease etcd.LeaseID, doTask func(*Task) error)

+ func Init()

+ 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(namespace string) ([]containerd.Container, 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 PullContainerImage(namespace, image string) error

+ func Read(obj Object) error

+ func ReadNew(obj Object) error

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

+ 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 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

+ Mzid string

+ func BelugaCycle(mzid string, nodes ...string) *Action

+ func BelugaOff(mzid string, nodes ...string) *Action

+ func BelugaOn(mzid string, nodes ...string) *Action

+ func CanopySetLinks(mzid string, links ...LinkSpec) *Action

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

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

+ func NexDeleteNetwork(name string) *Action

+ func NimbusCreateConfigs(mzid string, configs ...NimbusConfig) *Action

+ func NimbusDeleteConfigs(mzid string, nodes ...string) *Action

+ func OtterSetPortKeys(mzid string, ports ...OtterSpec) *Action

+ func RallyEnsure(mzid string, stores ...RallyStore) *Action

+ func RallyRecycle(mzid string, stores ...RallyStore) *Action

+ func SledImage(mzid string, bindings ...ImageBinding) *Action

+ func SledWipe(mzid string, nodes ...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 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

+ CtrNamespace string

+ Image string

+ Name string

+ NetNamespace string

+ Vindex int

+ func (x *Container) GetInterfaces() ([]*ContainerInterface, error)

+ 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 ContainerInterface struct

+ Address string

+ Bridge string

+ CtrIfx string

+ CtrMac string

+ EvpnAdvertise bool

+ HostIfx string

+ HostMac string

+ Vid int

+ Vindex int

+ Vni int

+ func (x *ContainerInterface) GetVersion() int64

+ func (x *ContainerInterface) Key() string

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

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

+ 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

+ Interfaces []*ContainerInterface

+ 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

+ Service string

+ type DeleteContainerIfxData struct

+ EvpnWithdraw bool

+ Name string

+ type Destination struct

+ Paths []*Path

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

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

+ type Endpoint struct

+ Interface string

+ Node string

+ type EvpnInfo struct

+ BgpIP net.IP

+ Rd bgp.RouteDistinguisherInterface

+ Rt bgp.ExtendedCommunityInterface

+ type EvpnWithdrawData struct

+ Vindex int

+ Vni int

+ type ImageBinding struct

+ Image SledImg

+ Node string

+ type LeafPortState struct

+ Leaf string

+ Mzid string

+ Port string

+ Vid int

+ Vni 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

+ Vni int

+ Xpid string

+ 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

+ Vid int

+ Vni int

+ type MzInfo struct

+ IncomingTaskId string

+ LinkCreateTaskId string

+ LinkDestroyTaskId string

+ Mzid string

+ NodeRecycleTaskId string

+ NodeSetupTaskId string

+ TeardownTaskId string

+ Vid int

+ Vindex int

+ Vni int

+ func (m *MzInfo) GetVersion() int64

+ func (m *MzInfo) Key() string

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

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

+ 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 NodeImage struct

+ Image string

+ Mac string

+ type NodeInfraInfo struct

+ Endpoint Endpoint

+ Image string

+ Mac string

+ Name string

+ 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

+ func RallyEphemeralStorage(node string) []RallyStore

+ func RallyStorage(node string) []RallyStore

+ type SledImg struct

+ Name string

+ type Stage struct

+ Actions []*Action

+ Next *Stage

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

+ type Task struct

+ Coglet string

+ Deps []string

+ Id string

+ Stages []*Stage

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

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

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

+ 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) SetVersion(v int64)

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

+ func (t *Task) Wait() error

+ 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