cli

Documentation

Index

• Constants
• Variables
• func GetConnectorPod(kubeClient kubernetes.Interface) (*corev1.Pod, error)
• func NewConnectController(provider, connector string, context context.Context, kubeConfig *rest.Config, ...) connector.ConnectController
• func ParseFlags() error
• func ToMetaSet(s []ctv1.Metadata) mapset.Set
• func ToSet(s []string) mapset.Set
• func ValidateCLIParams() error
• func Verbosity() string
• type AppendSliceValue
  • func (s *AppendSliceValue) Set(value string) error
  • func (s *AppendSliceValue) String() string
• type Config
• type InformerKey

Constants

const (
	MinSyncPeriod = 2 * time.Second
)

Variables

var (
	Cfg = Config{}
)

Functions

func GetConnectorPod

func GetConnectorPod(kubeClient kubernetes.Interface) (*corev1.Pod, error)

GetConnectorPod returns the fsm connector pod spec. The pod name is inferred from the 'CONNECTOR_POD_NAME' env variable which is set during deployment.

func NewConnectController

func NewConnectController(provider, connector string,
	context context.Context,
	kubeConfig *rest.Config,
	kubeClient kubernetes.Interface,
	configClient configClientset.Interface,
	connectorClient connectorClientset.Interface,
	machineClient machineClientset.Interface,
	gatewayClient gwapi.Interface,
	informerCollection *fsminformers.InformerCollection,
	msgBroker *messaging.Broker,
	selectInformers ...InformerKey) connector.ConnectController

NewConnectController returns a new Connector.Controller which means to provide access to locally-cached connector resources

func ParseFlags

func ParseFlags() error

func ToMetaSet

func ToMetaSet(s []ctv1.Metadata) mapset.Set

ToMetaSet creates a set from s.

func ToSet

func ToSet(s []string) mapset.Set

ToSet creates a set from s.

func ValidateCLIParams

func ValidateCLIParams() error

ValidateCLIParams contains all checks necessary that various permutations of the CLI flags are consistent

func Verbosity

func Verbosity() string

Types

type AppendSliceValue

type AppendSliceValue []string

AppendSliceValue implements the flag.Value interface and allows multiple calls to the same variable to append a list.

func (*AppendSliceValue) Set

func (s *AppendSliceValue) Set(value string) error

func (*AppendSliceValue) String

func (s *AppendSliceValue) String() string

type Config

type Config struct {
	Verbosity         string
	MeshName          string // An ID that uniquely identifies an FSM instance
	KubeConfigFile    string
	FsmNamespace      string
	FsmMeshConfigName string
	FsmVersion        string
	TrustDomain       string
	Workers           uint
	Limit             uint
	Burst             uint
	Timeout           uint
	SdrProvider       string
	SdrConnector      string
	LeaderElection    bool
}

Config is used to configure the creation of a client

type InformerKey

type InformerKey string

InformerKey stores the different Informers we keep for K8s resources

const (
	// ConsulConnectors lookup identifier
	ConsulConnectors InformerKey = "ConsulConnectors"
	// EurekaConnectors lookup identifier
	EurekaConnectors InformerKey = "EurekaConnectors"
	// NacosConnectors lookup identifier
	NacosConnectors InformerKey = "NacosConnectors"
	// MachineConnectors lookup identifier
	MachineConnectors InformerKey = "MachineConnectors"
	// GatewayConnectors lookup identifier
	GatewayConnectors InformerKey = "GatewayConnectors"
	// GatewayHTTPRoutes lookup identifier
	GatewayHTTPRoutes InformerKey = "GatewayHTTPRoutes"
	// GatewayGRPCRoutes lookup identifier
	GatewayGRPCRoutes InformerKey = "GatewayGRPCRoutes"
	// GatewayTCPRoutes lookup identifier
	GatewayTCPRoutes InformerKey = "GatewayTCPRoutes"
)