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
- 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, 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 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
SdrProvider string
SdrConnector string
}
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" // MachineConnectors lookup identifier MachineConnectors InformerKey = "MachineConnectors" // GatewayConnectors lookup identifier GatewayConnectors InformerKey = "GatewayConnectors" )
Source Files
Click to show internal directories.
Click to hide internal directories.