v2

package

v1.5.2 Latest Latest Go to latest Published: Jun 14, 2026 License: Apache-2.0 Imports: 42 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/flomesh-io/fsm

Links

Open Source Insights

Documentation ¶

Index ¶

func ConditionStatus(n *corev1.Node, ct corev1.NodeConditionType) corev1.ConditionStatus
type NatBrVal
type Result
type Server
- func NewXNetConfigServer(ctx context.Context, cfg configurator.Configurator, ...) *Server
- func (s *Server) BroadcastListener(stopCh <-chan struct{})
- func (s *Server) Start() error
type XNat

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func ConditionStatus ¶

func ConditionStatus(n *corev1.Node, ct corev1.NodeConditionType) corev1.ConditionStatus

ConditionStatus returns the status of the condition for a given node.

Types ¶

type NatBrVal ¶

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

type Result ¶

type Result string

Result is a string used to handle the results for probing container readiness/liveness

const (
	// Success Result
	Success Result = "success"
	// Failure Result
	Failure Result = "failure"
)

type Server ¶

type Server struct {
	Leading bool
	// contains filtered or unexported fields
}

func NewXNetConfigServer ¶

func NewXNetConfigServer(ctx context.Context,
	cfg configurator.Configurator,
	xnetworkController xnetwork.Controller,
	KubeClient kubernetes.Interface,
	kubeController k8s.Controller,
	xnetworkClient xnetworkClientset.Interface,
	msgBroker *messaging.Broker,
	enableMesh, enableE4lb bool,
	nodeName, cniBridge4, cniBridge6 string) *Server

NewXNetConfigServer creates a new xnetwork config Service server

func (*Server) BroadcastListener ¶

func (s *Server) BroadcastListener(stopCh <-chan struct{})

BroadcastListener listens for broadcast messages from the message broker

func (*Server) Start ¶

func (s *Server) Start() error

type XNat ¶

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

func (*XNat) Key ¶

func (lb *XNat) Key() string

func (*XNat) NatKeyHash ¶

func (lb *XNat) NatKeyHash() uint64

func (*XNat) NatValHash ¶

func (lb *XNat) NatValHash() uint64

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL