controlplane

Documentation

Index

• Constants
• func DecodeNPMNetworkPolicy(payload *bytes.Buffer) (*policies.NPMNetworkPolicy, error)
• func DecodeString(payload *bytes.Buffer) (string, error)
• func EncodeControllerIPSet(ipset *ControllerIPSets) (*bytes.Buffer, error)
• func EncodeNPMNetworkPolicy(netpol *policies.NPMNetworkPolicy) (*bytes.Buffer, error)
• func EncodeString(name string) (*bytes.Buffer, error)
• type ControllerIPSets
  • func DecodeControllerIPSet(payload *bytes.Buffer) (*ControllerIPSets, error)
  • func NewControllerIPSets(metadata *ipsets.IPSetMetadata) *ControllerIPSets
  • func (c *ControllerIPSets) GetMetadata() *ipsets.IPSetMetadata

Constants

const (
	IpsetApply   string = "IPSETAPPLY"
	IpsetRemove  string = "IPSETREMOVE"
	PolicyApply  string = "POLICYAPPLY"
	PolicyRemove string = "POLICYREMOVE"
)

Functions

func DecodeNPMNetworkPolicy

func DecodeNPMNetworkPolicy(payload *bytes.Buffer) (*policies.NPMNetworkPolicy, error)

func DecodeString

func DecodeString(payload *bytes.Buffer) (string, error)

func EncodeControllerIPSet

func EncodeControllerIPSet(ipset *ControllerIPSets) (*bytes.Buffer, error)

func EncodeNPMNetworkPolicy

func EncodeNPMNetworkPolicy(netpol *policies.NPMNetworkPolicy) (*bytes.Buffer, error)

func EncodeString

func EncodeString(name string) (*bytes.Buffer, error)

Types

type ControllerIPSets

type ControllerIPSets struct {
	*ipsets.IPSetMetadata
	// IPPodMetadata is used for setMaps to store Ips and ports as keys
	// and podMetadata as value
	IPPodMetadata map[string]*dp.PodMetadata
	// MemberIPSets is used for listMaps to store child IP Sets
	MemberIPSets map[string]*ipsets.IPSetMetadata
}

ControllerIPSets is used in fan-out design for controller pod to calculate and push to daemon pod

func DecodeControllerIPSet

func DecodeControllerIPSet(payload *bytes.Buffer) (*ControllerIPSets, error)

func NewControllerIPSets

func NewControllerIPSets(metadata *ipsets.IPSetMetadata) *ControllerIPSets

func (*ControllerIPSets) GetMetadata

func (c *ControllerIPSets) GetMetadata() *ipsets.IPSetMetadata