Documentation
¶
Index ¶
- Constants
- Variables
- func GetConnectorPod(kubeClient kubernetes.Interface) (*corev1.Pod, error)
- func NewConnectController(provider, connectorNamespace, connectorName string, context context.Context, ...) 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
- type Config
- type InformerKey
Constants ¶
View Source
const (
MinSyncPeriod = 2 * time.Second
)
Variables ¶
View Source
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 ¶ added in v1.2.1
func NewConnectController(provider, connectorNamespace, connectorName 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 ValidateCLIParams ¶
func ValidateCLIParams() error
ValidateCLIParams contains all checks necessary that various permutations of the CLI flags are consistent
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
SdrConnectorNamespace string
SdrConnectorName string
SdrConnectorUID string
LeaderElection bool
}
Config is used to configure the creation of a client
type InformerKey ¶ added in v1.2.1
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" // ZookeeperConnectors lookup identifier ZookeeperConnectors InformerKey = "ZookeeperConnectors" // 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" )
Source Files
Click to show internal directories.
Click to hide internal directories.