plugin

Documentation

Index

• Constants
• Variables
• type BasePluginNode
  • func (b *BasePluginNode) Receive(upstream *model.Link) (trans []model.Transmission, err error)
  • func (b *BasePluginNode) Send(dst model.Endpoint, protocol model.Protocol) (trans []model.Transmission, err error)
• type CalicoConfig
  • func (c *CalicoConfig) BindFlags(fs *pflag.FlagSet)
  • func (c *CalicoConfig) Validate() error
• type CalicoNetworkMode
• type CalicoPluginOptions
• type FlannelBackendType
• type FlannelConfig
  • func (f *FlannelConfig) BindFlags(fs *pflag.FlagSet)
  • func (f *FlannelConfig) Validate() error
• type FlannelPluginOptions
• type GenericNetNode
  • func (n *GenericNetNode) Receive(upstream *model.Link) ([]model.Transmission, error)
  • func (n *GenericNetNode) Send(_ model.Endpoint, _ model.Protocol) ([]model.Transmission, error)
• type NetworkPolicyHandler
  • func NewNetworkPolicy(serviceAddrSkipCidrRule bool, inClusterAddrEmitCidrRule bool, ...) (NetworkPolicyHandler, error)
• type Plugin
  • func NewCalicoPlugin(ctx *ctx.Context, serviceProcessor service.Processor, ...) (Plugin, error)
  • func NewCalicoPluginWithOptions(ctx *ctx.Context, options *CalicoPluginOptions) (Plugin, error)
  • func NewFlannelPlugin(ctx *ctx.Context, serviceProcessor service.Processor, ...) (Plugin, error)
  • func NewFlannelPluginWithOptions(ctx *ctx.Context, options *FlannelPluginOptions) (Plugin, error)
• type SimplePluginNode

Constants

const (
	CalicoDefaultInterfacePrefix = "cali"
)

Variables

var Calico = &CalicoConfig{}

var Flannel = &FlannelConfig{}

Types

type BasePluginNode

type BasePluginNode struct {
	*model.NetNode
	IPCache          *k8s.IPCache
	SimplePluginNode SimplePluginNode
}

func (*BasePluginNode) Receive

func (b *BasePluginNode) Receive(upstream *model.Link) (trans []model.Transmission, err error)

func (*BasePluginNode) Send

func (b *BasePluginNode) Send(dst model.Endpoint, protocol model.Protocol) (trans []model.Transmission, err error)

type CalicoConfig

type CalicoConfig struct {
	PodMTU     int
	IPIPPodMTU int
	Interface  string
}

func (*CalicoConfig) BindFlags

func (c *CalicoConfig) BindFlags(fs *pflag.FlagSet)

func (*CalicoConfig) Validate

func (c *CalicoConfig) Validate() error

type CalicoNetworkMode

type CalicoNetworkMode string

const (
	CalicoNetworkModelBGP  CalicoNetworkMode = "BGP"
	CalicoNetworkModeIPIP  CalicoNetworkMode = "IPIP"
	CalicoNetworkModeVXLan CalicoNetworkMode = "VXLan"

	CalicoTunnelInterface = "tunl0"
)

type CalicoPluginOptions

type CalicoPluginOptions struct {
	InfraShim        network.InfraShim
	PodMTU           int
	IPIPPodMTU       int
	ServiceProcessor service.Processor
	Interface        string
}

type FlannelBackendType

type FlannelBackendType string

const (
	FlannelBackendTypeHostGW FlannelBackendType = "host-gw"
	FlannelBackendTypeVxlan  FlannelBackendType = "vxlan"
	FlannelBackendTypeAlloc  FlannelBackendType = "alloc"
)

type FlannelConfig

type FlannelConfig struct {
	BackendType string
	Bridge      string
	PodMTU      int
	IPMasq      bool
	Interface   string
}

func (*FlannelConfig) BindFlags

func (f *FlannelConfig) BindFlags(fs *pflag.FlagSet)

func (*FlannelConfig) Validate

func (f *FlannelConfig) Validate() error

type FlannelPluginOptions

type FlannelPluginOptions struct {
	InfraShim        network.InfraShim
	Bridge           string
	Interface        string
	PodMTU           int
	IPMasq           bool
	ClusterCIDR      *net.IPNet
	CNIMode          FlannelBackendType
	ServiceProcessor service.Processor
}

type GenericNetNode

type GenericNetNode struct {
	NetNode *model.NetNode
}

func (*GenericNetNode) Receive

func (n *GenericNetNode) Receive(upstream *model.Link) ([]model.Transmission, error)

func (*GenericNetNode) Send

func (n *GenericNetNode) Send(_ model.Endpoint, _ model.Protocol) ([]model.Transmission, error)

type NetworkPolicyHandler

type NetworkPolicyHandler interface {
	CheckNetworkPolicy(src, dst model.Endpoint, protocol model.Protocol) ([]model.Suspicion, error)
}

func NewNetworkPolicy

func NewNetworkPolicy(serviceAddrSkipCidrRule bool, inClusterAddrEmitCidrRule bool, ipCache *k8s.IPCache, k8sCli *clientset.Clientset, service service.Processor) (NetworkPolicyHandler, error)

type Plugin

type Plugin interface {
	CreatePod(pod *k8s.Pod) (model.NetNodeAction, error)
	CreateNode(node *k8s.NodeInfo) (model.NetNodeAction, error)
}

func NewCalicoPlugin

func NewCalicoPlugin(ctx *ctx.Context, serviceProcessor service.Processor, infraShim network.InfraShim) (Plugin, error)

func NewCalicoPluginWithOptions

func NewCalicoPluginWithOptions(ctx *ctx.Context, options *CalicoPluginOptions) (Plugin, error)

func NewFlannelPlugin

func NewFlannelPlugin(ctx *ctx.Context, serviceProcessor service.Processor, infraShim network.InfraShim) (Plugin, error)

func NewFlannelPluginWithOptions

func NewFlannelPluginWithOptions(ctx *ctx.Context, options *FlannelPluginOptions) (Plugin, error)

type SimplePluginNode

type SimplePluginNode interface {
	ToPod(upstream *model.Link, dst model.Endpoint, protocol model.Protocol, pod *v1.Pod) ([]model.Transmission, error)
	ToHost(upstream *model.Link, dst model.Endpoint, protocol model.Protocol, node *v1.Node) ([]model.Transmission, error)
	ToService(upstream *model.Link, dst model.Endpoint, protocol model.Protocol, service *v1.Service) ([]model.Transmission, error)
	ToExternal(upstream *model.Link, dst model.Endpoint, protocol model.Protocol) ([]model.Transmission, error)
	Serve(upstream *model.Link, dst model.Endpoint, protocol model.Protocol) ([]model.Transmission, error)
}