topo

package
v0.1.18 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 6, 2024 License: Apache-2.0 Imports: 5 Imported by: 11

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	Vendor_name = map[int32]string{
		0:  "UNKNOWN",
		1:  "HOST",
		2:  "ARISTA",
		3:  "CISCO",
		4:  "JUNIPER",
		5:  "KEYSIGHT",
		6:  "FRR",
		7:  "QUAGGA",
		8:  "GOBGP",
		9:  "NOKIA",
		10: "OPENCONFIG",
		11: "ALPINE",
		12: "DRIVENETS",
	}
	Vendor_value = map[string]int32{
		"UNKNOWN":    0,
		"HOST":       1,
		"ARISTA":     2,
		"CISCO":      3,
		"JUNIPER":    4,
		"KEYSIGHT":   5,
		"FRR":        6,
		"QUAGGA":     7,
		"GOBGP":      8,
		"NOKIA":      9,
		"OPENCONFIG": 10,
		"ALPINE":     11,
		"DRIVENETS":  12,
	}
)

Enum value maps for Vendor.

View Source 
var (
	Node_Type_name = map[int32]string{
		0:  "UNKNOWN",
		1:  "HOST",
		2:  "ARISTA_CEOS",
		3:  "JUNIPER_CEVO",
		4:  "CISCO_CXR",
		5:  "QUAGGA",
		6:  "FRR",
		7:  "JUNIPER_VMX",
		8:  "CISCO_CSR",
		9:  "NOKIA_SRL",
		10: "IXIA_TG",
		11: "GOBGP",
		12: "CISCO_XRD",
		13: "CISCO_E8000",
		14: "LEMMING",
	}
	Node_Type_value = map[string]int32{
		"UNKNOWN":      0,
		"HOST":         1,
		"ARISTA_CEOS":  2,
		"JUNIPER_CEVO": 3,
		"CISCO_CXR":    4,
		"QUAGGA":       5,
		"FRR":          6,
		"JUNIPER_VMX":  7,
		"CISCO_CSR":    8,
		"NOKIA_SRL":    9,
		"IXIA_TG":      10,
		"GOBGP":        11,
		"CISCO_XRD":    12,
		"CISCO_E8000":  13,
		"LEMMING":      14,
	}
)

Enum value maps for Node_Type.

View Source 
var (
	Interface_InterfaceType_name = map[int32]string{
		0: "UNKNOWN",
		1: "LOOPBACK",
		2: "MANAGEMENT",
		3: "DATA",
	}
	Interface_InterfaceType_value = map[string]int32{
		"UNKNOWN":    0,
		"LOOPBACK":   1,
		"MANAGEMENT": 2,
		"DATA":       3,
	}
)

Enum value maps for Interface_InterfaceType.

View Source 
var File_topo_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type BoundedInteger added in v0.1.15 

type BoundedInteger struct {
	MaxValue int64 `protobuf:"varint,1,opt,name=max_value,json=maxValue,proto3" json:"max_value,omitempty"`
	MinValue int64 `protobuf:"varint,2,opt,name=min_value,json=minValue,proto3" json:"min_value,omitempty"`
	// contains filtered or unexported fields
}

BoundedInteger to capture the range of max or min for a particular constraint.

func (*BoundedInteger) Descriptor deprecated added in v0.1.15 

func (*BoundedInteger) Descriptor() ([]byte, []int)

Deprecated: Use BoundedInteger.ProtoReflect.Descriptor instead.

func (*BoundedInteger) GetMaxValue added in v0.1.15 

func (x *BoundedInteger) GetMaxValue() int64

func (*BoundedInteger) GetMinValue added in v0.1.15 

func (x *BoundedInteger) GetMinValue() int64

func (*BoundedInteger) ProtoMessage added in v0.1.15 

func (*BoundedInteger) ProtoMessage()

func (*BoundedInteger) ProtoReflect added in v0.1.15 

func (x *BoundedInteger) ProtoReflect() protoreflect.Message

func (*BoundedInteger) Reset added in v0.1.15 

func (x *BoundedInteger) Reset()

func (*BoundedInteger) String added in v0.1.15 

func (x *BoundedInteger) String() string

type CertificateCfg 

type CertificateCfg struct {

	// Types that are assignable to Config:
	//
	//	*CertificateCfg_SelfSigned
	Config isCertificateCfg_Config `protobuf_oneof:"config"`
	// contains filtered or unexported fields
}

func (*CertificateCfg) Descriptor deprecated 

func (*CertificateCfg) Descriptor() ([]byte, []int)

Deprecated: Use CertificateCfg.ProtoReflect.Descriptor instead.

func (*CertificateCfg) GetConfig 

func (m *CertificateCfg) GetConfig() isCertificateCfg_Config

func (*CertificateCfg) GetSelfSigned 

func (x *CertificateCfg) GetSelfSigned() *SelfSignedCertCfg

func (*CertificateCfg) ProtoMessage 

func (*CertificateCfg) ProtoMessage()

func (*CertificateCfg) ProtoReflect 

func (x *CertificateCfg) ProtoReflect() protoreflect.Message

func (*CertificateCfg) Reset 

func (x *CertificateCfg) Reset()

func (*CertificateCfg) String 

func (x *CertificateCfg) String() string

type CertificateCfg_SelfSigned 

type CertificateCfg_SelfSigned struct {
	// self_signed will generate local certificates on the node.
	SelfSigned *SelfSignedCertCfg `protobuf:"bytes,1,opt,name=self_signed,json=selfSigned,proto3,oneof"`
}

type Config 

type Config struct {
	Command []string `protobuf:"bytes,1,rep,name=command,proto3" json:"command,omitempty"` // Command to pass into pod.
	Args    []string `protobuf:"bytes,2,rep,name=args,proto3" json:"args,omitempty"`       // Command args to pass into the pod.
	Image   string   `protobuf:"bytes,3,opt,name=image,proto3" json:"image,omitempty"`     // Docker image to use with pod.
	// Map of environment variables to pass into the pod.
	Env map[string]string `` /* 147-byte string literal not displayed */
	// Specific entry point command for accessing the pod.
	EntryCommand string `protobuf:"bytes,5,opt,name=entry_command,json=entryCommand,proto3" json:"entry_command,omitempty"`
	// Mount point for configuration inside the pod.
	ConfigPath string `protobuf:"bytes,6,opt,name=config_path,json=configPath,proto3" json:"config_path,omitempty"`
	// Default configuration file name for the pod.
	ConfigFile string `protobuf:"bytes,7,opt,name=config_file,json=configFile,proto3" json:"config_file,omitempty"`
	Sleep      uint32 `protobuf:"varint,8,opt,name=sleep,proto3" json:"sleep,omitempty"` // Sleeptime before starting the pod.
	// Certificate configuration
	Cert *CertificateCfg `protobuf:"bytes,9,opt,name=cert,proto3" json:"cert,omitempty"`
	// Types that are assignable to ConfigData:
	//
	//	*Config_Data
	//	*Config_File
	ConfigData isConfig_ConfigData `protobuf_oneof:"config_data"`
	// Docker image to use as an init container for the pod.
	InitImage string `protobuf:"bytes,10,opt,name=init_image,json=initImage,proto3" json:"init_image,omitempty"`
	// Vendor-specific data
	VendorData *anypb.Any `protobuf:"bytes,11,opt,name=vendor_data,json=vendorData,proto3" json:"vendor_data,omitempty"`
	// contains filtered or unexported fields
}

Config is the k8s pod specific configuration for a node.

func (*Config) Descriptor deprecated 

func (*Config) Descriptor() ([]byte, []int)

Deprecated: Use Config.ProtoReflect.Descriptor instead.

func (*Config) GetArgs 

func (x *Config) GetArgs() []string

func (*Config) GetCert 

func (x *Config) GetCert() *CertificateCfg

func (*Config) GetCommand 

func (x *Config) GetCommand() []string

func (*Config) GetConfigData 

func (m *Config) GetConfigData() isConfig_ConfigData

func (*Config) GetConfigFile 

func (x *Config) GetConfigFile() string

func (*Config) GetConfigPath 

func (x *Config) GetConfigPath() string

func (*Config) GetData 

func (x *Config) GetData() []byte

func (*Config) GetEntryCommand 

func (x *Config) GetEntryCommand() string

func (*Config) GetEnv 

func (x *Config) GetEnv() map[string]string

func (*Config) GetFile 

func (x *Config) GetFile() string

func (*Config) GetImage 

func (x *Config) GetImage() string

func (*Config) GetInitImage 

func (x *Config) GetInitImage() string

func (*Config) GetSleep 

func (x *Config) GetSleep() uint32

func (*Config) GetVendorData added in v0.1.7 

func (x *Config) GetVendorData() *anypb.Any

func (*Config) ProtoMessage 

func (*Config) ProtoMessage()

func (*Config) ProtoReflect 

func (x *Config) ProtoReflect() protoreflect.Message

func (*Config) Reset 

func (x *Config) Reset()

func (*Config) String 

func (x *Config) String() string

type Config_Data 

type Config_Data struct {
	// Byte data for the startup configuration file.
	Data []byte `protobuf:"bytes,101,opt,name=data,proto3,oneof"`
}

type Config_File 

type Config_File struct {
	// File is always relative to the topology configuration file.
	File string `protobuf:"bytes,102,opt,name=file,proto3,oneof"`
}

type HostConstraint added in v0.1.15 

type HostConstraint struct {

	// Types that are assignable to Constraint:
	//
	//	*HostConstraint_KernelConstraint
	Constraint isHostConstraint_Constraint `protobuf_oneof:"constraint"`
	// contains filtered or unexported fields
}

HostConstraint is a constraint on the host where the node is running.

func (*HostConstraint) Descriptor deprecated added in v0.1.15 

func (*HostConstraint) Descriptor() ([]byte, []int)

Deprecated: Use HostConstraint.ProtoReflect.Descriptor instead.

func (*HostConstraint) GetConstraint added in v0.1.15 

func (m *HostConstraint) GetConstraint() isHostConstraint_Constraint

func (*HostConstraint) GetKernelConstraint added in v0.1.15 

func (x *HostConstraint) GetKernelConstraint() *KernelParam

func (*HostConstraint) ProtoMessage added in v0.1.15 

func (*HostConstraint) ProtoMessage()

func (*HostConstraint) ProtoReflect added in v0.1.15 

func (x *HostConstraint) ProtoReflect() protoreflect.Message

func (*HostConstraint) Reset added in v0.1.15 

func (x *HostConstraint) Reset()

func (*HostConstraint) String added in v0.1.15 

func (x *HostConstraint) String() string

type HostConstraint_KernelConstraint added in v0.1.15 

type HostConstraint_KernelConstraint struct {
	// Includes the required kernel parameters that need to be configured.
	KernelConstraint *KernelParam `protobuf:"bytes,1,opt,name=kernel_constraint,json=kernelConstraint,proto3,oneof"`
}

type Interface 

type Interface struct {

	// Name of the interface provided by Node implementation. This will be used
	// to map the int_name into a vendor specific interface name. Vendor operators
	// should provide the name mapping from the node interface key to this vendor
	// specific name.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Internal device name. This name matches the key in the Node interface map.
	// It will be returned by the operator. Assigned by KNE.
	IntName string `protobuf:"bytes,2,opt,name=int_name,json=intName,proto3" json:"int_name,omitempty"`
	Mtu     uint32 `protobuf:"varint,3,opt,name=mtu,proto3" json:"mtu,omitempty"` // Desired MTU for the interface.
	// Peer node name. Assigned by KNE.
	PeerName string `protobuf:"bytes,4,opt,name=peer_name,json=peerName,proto3" json:"peer_name,omitempty"`
	// Peer interface name. Assigned by KNE.
	PeerIntName string `protobuf:"bytes,5,opt,name=peer_int_name,json=peerIntName,proto3" json:"peer_int_name,omitempty"`
	// Uid is the internal link identifier used by Meshnet.
	Uid int64 `protobuf:"varint,6,opt,name=uid,proto3" json:"uid,omitempty"`
	// Name of group to which this interface belongs
	Group string `protobuf:"bytes,7,opt,name=group,proto3" json:"group,omitempty"`
	// Type of the interface - Loopback, Management , Data etc.
	Type Interface_InterfaceType `protobuf:"varint,8,opt,name=type,proto3,enum=topo.Interface_InterfaceType" json:"type,omitempty"`
	// ip_address associated with the interface.
	IpAddress string `protobuf:"bytes,9,opt,name=ip_address,json=ipAddress,proto3" json:"ip_address,omitempty"`
	// contains filtered or unexported fields
}

Interface keys must be the same as the links a,z int.

func (*Interface) Descriptor deprecated 

func (*Interface) Descriptor() ([]byte, []int)

Deprecated: Use Interface.ProtoReflect.Descriptor instead.

func (*Interface) GetGroup 

func (x *Interface) GetGroup() string

func (*Interface) GetIntName 

func (x *Interface) GetIntName() string

func (*Interface) GetIpAddress added in v0.1.18 

func (x *Interface) GetIpAddress() string

func (*Interface) GetMtu 

func (x *Interface) GetMtu() uint32

func (*Interface) GetName 

func (x *Interface) GetName() string

func (*Interface) GetPeerIntName 

func (x *Interface) GetPeerIntName() string

func (*Interface) GetPeerName 

func (x *Interface) GetPeerName() string

func (*Interface) GetType added in v0.1.18 

func (x *Interface) GetType() Interface_InterfaceType

func (*Interface) GetUid 

func (x *Interface) GetUid() int64

func (*Interface) ProtoMessage 

func (*Interface) ProtoMessage()

func (*Interface) ProtoReflect 

func (x *Interface) ProtoReflect() protoreflect.Message

func (*Interface) Reset 

func (x *Interface) Reset()

func (*Interface) String 

func (x *Interface) String() string

type Interface_InterfaceType added in v0.1.18 

type Interface_InterfaceType int32
const (
	Interface_UNKNOWN    Interface_InterfaceType = 0
	Interface_LOOPBACK   Interface_InterfaceType = 1
	Interface_MANAGEMENT Interface_InterfaceType = 2
	Interface_DATA       Interface_InterfaceType = 3
)

func (Interface_InterfaceType) Descriptor added in v0.1.18 

func (Interface_InterfaceType) Descriptor() protoreflect.EnumDescriptor

func (Interface_InterfaceType) Enum added in v0.1.18 

func (x Interface_InterfaceType) Enum() *Interface_InterfaceType

func (Interface_InterfaceType) EnumDescriptor deprecated added in v0.1.18 

func (Interface_InterfaceType) EnumDescriptor() ([]byte, []int)

Deprecated: Use Interface_InterfaceType.Descriptor instead.

func (Interface_InterfaceType) Number added in v0.1.18 

func (x Interface_InterfaceType) Number() protoreflect.EnumNumber

func (Interface_InterfaceType) String added in v0.1.18 

func (x Interface_InterfaceType) String() string

func (Interface_InterfaceType) Type added in v0.1.18 

func (Interface_InterfaceType) Type() protoreflect.EnumType

type KernelParam added in v0.1.15 

type KernelParam struct {

	// MIB style name of the kernel state to constrain.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Types that are assignable to ConstraintType:
	//
	//	*KernelParam_BoundedInteger
	ConstraintType isKernelParam_ConstraintType `protobuf_oneof:"ConstraintType"`
	// contains filtered or unexported fields
}

KernelParam is a parameter on the host kernel.

func (*KernelParam) Descriptor deprecated added in v0.1.15 

func (*KernelParam) Descriptor() ([]byte, []int)

Deprecated: Use KernelParam.ProtoReflect.Descriptor instead.

func (*KernelParam) GetBoundedInteger added in v0.1.15 

func (x *KernelParam) GetBoundedInteger() *BoundedInteger

func (*KernelParam) GetConstraintType added in v0.1.15 

func (m *KernelParam) GetConstraintType() isKernelParam_ConstraintType

func (*KernelParam) GetName added in v0.1.15 

func (x *KernelParam) GetName() string

func (*KernelParam) ProtoMessage added in v0.1.15 

func (*KernelParam) ProtoMessage()

func (*KernelParam) ProtoReflect added in v0.1.15 

func (x *KernelParam) ProtoReflect() protoreflect.Message

func (*KernelParam) Reset added in v0.1.15 

func (x *KernelParam) Reset()

func (*KernelParam) String added in v0.1.15 

func (x *KernelParam) String() string

type KernelParam_BoundedInteger added in v0.1.15 

type KernelParam_BoundedInteger struct {
	BoundedInteger *BoundedInteger `protobuf:"bytes,2,opt,name=bounded_integer,json=boundedInteger,proto3,oneof"`
}
type Link struct {
	ANode string `protobuf:"bytes,1,opt,name=a_node,json=aNode,proto3" json:"a_node,omitempty"`
	AInt  string `protobuf:"bytes,2,opt,name=a_int,json=aInt,proto3" json:"a_int,omitempty"`
	ZNode string `protobuf:"bytes,3,opt,name=z_node,json=zNode,proto3" json:"z_node,omitempty"`
	ZInt  string `protobuf:"bytes,4,opt,name=z_int,json=zInt,proto3" json:"z_int,omitempty"`
	// contains filtered or unexported fields
}

Link is single link between nodes in the topology. Interfaces must start eth1 - eth0 is the default k8s interface.

func (*Link) Descriptor deprecated 

func (*Link) Descriptor() ([]byte, []int)

Deprecated: Use Link.ProtoReflect.Descriptor instead.

func (*Link) GetAInt 

func (x *Link) GetAInt() string

func (*Link) GetANode 

func (x *Link) GetANode() string

func (*Link) GetZInt 

func (x *Link) GetZInt() string

func (*Link) GetZNode 

func (x *Link) GetZNode() string

func (*Link) ProtoMessage 

func (*Link) ProtoMessage()

func (*Link) ProtoReflect 

func (x *Link) ProtoReflect() protoreflect.Message

func (*Link) Reset 

func (x *Link) Reset()

func (*Link) String 

func (x *Link) String() string

type Node 

type Node struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Name of the node in the topology. Must be unique.
	// Deprecated: Do not use.
	Type   Node_Type         `protobuf:"varint,2,opt,name=type,proto3,enum=topo.Node_Type" json:"type,omitempty"`
	Labels map[string]string `` // Metadata labels describing the node.
	/* 153-byte string literal not displayed */
	Config *Config `protobuf:"bytes,5,opt,name=config,proto3" json:"config,omitempty"` // Pod specific configuration of the node.
	// Map of services to enable on the node.
	// The key is the external load balancer port to be used by the service.
	// Multiple external services can be mapped to a single internal service port
	// by reusing the inside_port in the service definition.
	Services    map[uint32]*Service `` /* 158-byte string literal not displayed */
	Constraints map[string]string   `` // Any k8s constraints required by node.
	/* 163-byte string literal not displayed */
	Vendor  Vendor `protobuf:"varint,8,opt,name=vendor,proto3,enum=topo.Vendor" json:"vendor,omitempty"` // Vendor enum replaces type.
	Model   string `protobuf:"bytes,9,opt,name=model,proto3" json:"model,omitempty"`                     // Model of the node.
	Version string `protobuf:"bytes,10,opt,name=version,proto3" json:"version,omitempty"`                // Version string used to identify a software release.
	Os      string `protobuf:"bytes,11,opt,name=os,proto3" json:"os,omitempty"`                          // Operating system type.
	// Interfaces is a map of container interfaces used by the node.
	// If interfaces is empty the interfaces defined in the links portion of the
	// topology will be populated into the node.
	Interfaces map[string]*Interface `` /* 162-byte string literal not displayed */
	// Any host constraints required by the node. These may not be required by a
	// vendor, but it can be used to provide requirements for the node.
	HostConstraints []*HostConstraint `protobuf:"bytes,13,rep,name=host_constraints,json=hostConstraints,proto3" json:"host_constraints,omitempty"`
	// contains filtered or unexported fields
}

Node is a single container inside the topology

func (*Node) Descriptor deprecated 

func (*Node) Descriptor() ([]byte, []int)

Deprecated: Use Node.ProtoReflect.Descriptor instead.

func (*Node) GetConfig 

func (x *Node) GetConfig() *Config

func (*Node) GetConstraints 

func (x *Node) GetConstraints() map[string]string

func (*Node) GetHostConstraints added in v0.1.15 

func (x *Node) GetHostConstraints() []*HostConstraint

func (*Node) GetInterfaces 

func (x *Node) GetInterfaces() map[string]*Interface

func (*Node) GetLabels 

func (x *Node) GetLabels() map[string]string

func (*Node) GetModel 

func (x *Node) GetModel() string

func (*Node) GetName 

func (x *Node) GetName() string

func (*Node) GetOs 

func (x *Node) GetOs() string

func (*Node) GetServices 

func (x *Node) GetServices() map[uint32]*Service

func (*Node) GetType deprecated 

func (x *Node) GetType() Node_Type

Deprecated: Do not use.

func (*Node) GetVendor 

func (x *Node) GetVendor() Vendor

func (*Node) GetVersion 

func (x *Node) GetVersion() string

func (*Node) ProtoMessage 

func (*Node) ProtoMessage()

func (*Node) ProtoReflect 

func (x *Node) ProtoReflect() protoreflect.Message

func (*Node) Reset 

func (x *Node) Reset()

func (*Node) String 

func (x *Node) String() string

type Node_Type 

type Node_Type int32
const (
	Node_UNKNOWN      Node_Type = 0
	Node_HOST         Node_Type = 1
	Node_ARISTA_CEOS  Node_Type = 2
	Node_JUNIPER_CEVO Node_Type = 3
	Node_CISCO_CXR    Node_Type = 4
	Node_QUAGGA       Node_Type = 5
	Node_FRR          Node_Type = 6
	Node_JUNIPER_VMX  Node_Type = 7
	Node_CISCO_CSR    Node_Type = 8
	Node_NOKIA_SRL    Node_Type = 9
	Node_IXIA_TG      Node_Type = 10
	Node_GOBGP        Node_Type = 11
	Node_CISCO_XRD    Node_Type = 12
	Node_CISCO_E8000  Node_Type = 13
	Node_LEMMING      Node_Type = 14
)

func (Node_Type) Descriptor 

func (Node_Type) Descriptor() protoreflect.EnumDescriptor

func (Node_Type) Enum 

func (x Node_Type) Enum() *Node_Type

func (Node_Type) EnumDescriptor deprecated 

func (Node_Type) EnumDescriptor() ([]byte, []int)

Deprecated: Use Node_Type.Descriptor instead.

func (Node_Type) Number 

func (x Node_Type) Number() protoreflect.EnumNumber

func (Node_Type) String 

func (x Node_Type) String() string

func (Node_Type) Type 

func (Node_Type) Type() protoreflect.EnumType

type SelfSignedCertCfg 

type SelfSignedCertCfg struct {

	// Certificate name on the node.
	CertName string `protobuf:"bytes,1,opt,name=cert_name,json=certName,proto3" json:"cert_name,omitempty"`
	// Key name on the node.
	KeyName string `protobuf:"bytes,2,opt,name=key_name,json=keyName,proto3" json:"key_name,omitempty"`
	// RSA keysize to use for key generation.
	KeySize uint32 `protobuf:"varint,3,opt,name=key_size,json=keySize,proto3" json:"key_size,omitempty"`
	// Common name to set in the cert.
	CommonName string `protobuf:"bytes,4,opt,name=common_name,json=commonName,proto3" json:"common_name,omitempty"`
	// contains filtered or unexported fields
}

func (*SelfSignedCertCfg) Descriptor deprecated 

func (*SelfSignedCertCfg) Descriptor() ([]byte, []int)

Deprecated: Use SelfSignedCertCfg.ProtoReflect.Descriptor instead.

func (*SelfSignedCertCfg) GetCertName 

func (x *SelfSignedCertCfg) GetCertName() string

func (*SelfSignedCertCfg) GetCommonName 

func (x *SelfSignedCertCfg) GetCommonName() string

func (*SelfSignedCertCfg) GetKeyName 

func (x *SelfSignedCertCfg) GetKeyName() string

func (*SelfSignedCertCfg) GetKeySize 

func (x *SelfSignedCertCfg) GetKeySize() uint32

func (*SelfSignedCertCfg) ProtoMessage 

func (*SelfSignedCertCfg) ProtoMessage()

func (*SelfSignedCertCfg) ProtoReflect 

func (x *SelfSignedCertCfg) ProtoReflect() protoreflect.Message

func (*SelfSignedCertCfg) Reset 

func (x *SelfSignedCertCfg) Reset()

func (*SelfSignedCertCfg) String 

func (x *SelfSignedCertCfg) String() string

type Service 

type Service struct {
	Name   string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`      // Name of the service (optional)
	Inside uint32 `protobuf:"varint,2,opt,name=inside,proto3" json:"inside,omitempty"` // Inside port to map Node (container listening port)
	// Assigned by KNE.
	Outside   uint32 `protobuf:"varint,3,opt,name=outside,proto3" json:"outside,omitempty"`                     // Outside port used by service. (same a service key)
	OutsideIp string `protobuf:"bytes,5,opt,name=outside_ip,json=outsideIp,proto3" json:"outside_ip,omitempty"` // External IP assigned by cluster load balancer.
	// Used internally by KNE.
	InsideIp string `protobuf:"bytes,4,opt,name=inside_ip,json=insideIp,proto3" json:"inside_ip,omitempty"`  // Cluster IP for the service.
	NodePort uint32 `protobuf:"varint,6,opt,name=node_port,json=nodePort,proto3" json:"node_port,omitempty"` // Port on the K8s worker node used by the cluster.
	// List of service names to be mapped to the port (optional).
	// If only one field out of "name" or "names" is provided in the input topo,
	// the unspecified field is ignored.
	// If both are provided, names in both fields are considered excluding any
	// duplicate values.
	Names []string `protobuf:"bytes,7,rep,name=names,proto3" json:"names,omitempty"`
	// contains filtered or unexported fields
}

Service is k8s Service to exposed to the cluster. The initial input can be provided by the user for which services they would like exposed. Once the service is created KNE will fill in the outside information for the user to access the services. The user should specify inside port for this is the port the container will listen on.

func (*Service) Descriptor deprecated 

func (*Service) Descriptor() ([]byte, []int)

Deprecated: Use Service.ProtoReflect.Descriptor instead.

func (*Service) GetInside 

func (x *Service) GetInside() uint32

func (*Service) GetInsideIp 

func (x *Service) GetInsideIp() string

func (*Service) GetName 

func (x *Service) GetName() string

func (*Service) GetNames added in v0.1.17 

func (x *Service) GetNames() []string

func (*Service) GetNodePort 

func (x *Service) GetNodePort() uint32

func (*Service) GetOutside 

func (x *Service) GetOutside() uint32

func (*Service) GetOutsideIp 

func (x *Service) GetOutsideIp() string

func (*Service) ProtoMessage 

func (*Service) ProtoMessage()

func (*Service) ProtoReflect 

func (x *Service) ProtoReflect() protoreflect.Message

func (*Service) Reset 

func (x *Service) Reset()

func (*Service) String 

func (x *Service) String() string

type Topology 

type Topology struct {
	Name  string  `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`   // Name of the topology - will be linked to the cluster name
	Nodes []*Node `protobuf:"bytes,2,rep,name=nodes,proto3" json:"nodes,omitempty"` // List of nodes in the topology
	Links []*Link `protobuf:"bytes,3,rep,name=links,proto3" json:"links,omitempty"` // connections between Nodes.
	// contains filtered or unexported fields
}

Topology message defines what nodes and links will be created inside the mesh.

func (*Topology) Descriptor deprecated 

func (*Topology) Descriptor() ([]byte, []int)

Deprecated: Use Topology.ProtoReflect.Descriptor instead. 

func (x *Topology) GetLinks() []*Link

func (*Topology) GetName 

func (x *Topology) GetName() string

func (*Topology) GetNodes 

func (x *Topology) GetNodes() []*Node

func (*Topology) ProtoMessage 

func (*Topology) ProtoMessage()

func (*Topology) ProtoReflect 

func (x *Topology) ProtoReflect() protoreflect.Message

func (*Topology) Reset 

func (x *Topology) Reset()

func (*Topology) String 

func (x *Topology) String() string

type Vendor 

type Vendor int32

Vendor of the node. Topology manager uses this enum to dispatch the node to the correct controller. 

const (
	Vendor_UNKNOWN    Vendor = 0
	Vendor_HOST       Vendor = 1
	Vendor_ARISTA     Vendor = 2
	Vendor_CISCO      Vendor = 3
	Vendor_JUNIPER    Vendor = 4
	Vendor_KEYSIGHT   Vendor = 5
	Vendor_FRR        Vendor = 6
	Vendor_QUAGGA     Vendor = 7
	Vendor_GOBGP      Vendor = 8
	Vendor_NOKIA      Vendor = 9
	Vendor_OPENCONFIG Vendor = 10
	Vendor_ALPINE     Vendor = 11
	Vendor_DRIVENETS  Vendor = 12
)

func (Vendor) Descriptor 

func (Vendor) Descriptor() protoreflect.EnumDescriptor

func (Vendor) Enum 

func (x Vendor) Enum() *Vendor

func (Vendor) EnumDescriptor deprecated 

func (Vendor) EnumDescriptor() ([]byte, []int)

Deprecated: Use Vendor.Descriptor instead.

func (Vendor) Number 

func (x Vendor) Number() protoreflect.EnumNumber

func (Vendor) String 

func (x Vendor) String() string

func (Vendor) Type 

func (Vendor) Type() protoreflect.EnumType

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.