util

Documentation

Index

• func CompareEndpointSpec(left, right subv1.EndpointSpec) bool
• func CreateChainIfNotExists(ipt *iptables.IPTables, table, chain string) error
• func FlattenColors(colorCodes []string) string
• func GetClusterCRDName(cluster *types.SubmarinerCluster) (string, error)
• func GetClusterIDFromCableName(cableName string) string
• func GetDefaultGatewayInterface() (*net.Interface, error)
• func GetEndpointCRDName(endpoint *types.SubmarinerEndpoint) (string, error)
• func GetEndpointCRDNameFromParams(clusterID, cableName string) (string, error)
• func GetLocalEndpoint(clusterID, backend string, backendConfig map[string]string, natEnabled bool, ...) (types.SubmarinerEndpoint, error)
• func GetLocalIP() string
• func IsOverlappingCIDR(cidrList []string, cidr string) (bool, error)
• func ParseSecure(token string) (types.Secure, error)
• func PrependUnique(ipt *iptables.IPTables, table, chain string, ruleSpec []string) error
• type StringSet
  • func NewStringSet() *StringSet
  • func (set *StringSet) Add(s string) bool
  • func (set *StringSet) Contains(s string) bool
  • func (set *StringSet) Delete(s string) bool
  • func (set *StringSet) DeleteAll()
  • func (set *StringSet) Elements() []string
  • func (set *StringSet) Size() int

Functions

func CompareEndpointSpec

func CompareEndpointSpec(left, right subv1.EndpointSpec) bool

func CreateChainIfNotExists

func CreateChainIfNotExists(ipt *iptables.IPTables, table, chain string) error

func FlattenColors

func FlattenColors(colorCodes []string) string

func GetClusterCRDName

func GetClusterCRDName(cluster *types.SubmarinerCluster) (string, error)

func GetClusterIDFromCableName

func GetClusterIDFromCableName(cableName string) string

func GetDefaultGatewayInterface

func GetDefaultGatewayInterface() (*net.Interface, error)

func GetEndpointCRDName

func GetEndpointCRDName(endpoint *types.SubmarinerEndpoint) (string, error)

func GetEndpointCRDNameFromParams

func GetEndpointCRDNameFromParams(clusterID, cableName string) (string, error)

func GetLocalEndpoint

func GetLocalEndpoint(clusterID, backend string, backendConfig map[string]string, natEnabled bool,
	subnets []string, privateIP string) (types.SubmarinerEndpoint, error)

func GetLocalIP

func GetLocalIP() string

func IsOverlappingCIDR

func IsOverlappingCIDR(cidrList []string, cidr string) (bool, error)

func ParseSecure

func ParseSecure(token string) (types.Secure, error)

func PrependUnique

func PrependUnique(ipt *iptables.IPTables, table, chain string, ruleSpec []string) error

Types

type StringSet

type StringSet struct {
	// contains filtered or unexported fields
}

func NewStringSet

func NewStringSet() *StringSet

func (*StringSet) Add

func (set *StringSet) Add(s string) bool

func (*StringSet) Contains

func (set *StringSet) Contains(s string) bool

func (*StringSet) Delete

func (set *StringSet) Delete(s string) bool

func (*StringSet) DeleteAll

func (set *StringSet) DeleteAll()

func (*StringSet) Elements

func (set *StringSet) Elements() []string

func (*StringSet) Size

func (set *StringSet) Size() int