Documentation
¶
Index ¶
- Constants
- Variables
- func GetConnectorPod(kubeClient kubernetes.Interface) (*corev1.Pod, error)
- func ParseFlags() error
- func SyncCtoK(ctx context.Context, kubeClient kubernetes.Interface, ...)
- func SyncKtoC(ctx context.Context, kubeClient kubernetes.Interface, ...)
- func SyncKtoG(ctx context.Context, kubeClient kubernetes.Interface, ...)
- func ToSet(s []string) mapset.Set
- func ValidateCLIParams() error
- func Verbosity() string
- type AppendSliceValue
- type C2KCfg
- type Config
- type K2CCfg
- type K2ConsulCfg
- type K2GCfg
Constants ¶
View Source
const ( VIA_EXTERNAL_IP = "ExternalIP" VIA_CLUSTER_IP = "ClusterIP" )
Variables ¶
View Source
var (
Cfg = Config{Via: connector.ViaGateway}
)
Functions ¶
func GetConnectorPod ¶
func GetConnectorPod(kubeClient kubernetes.Interface) (*corev1.Pod, error)
GetConnectorPod returns the fsm-Consul-connector pod spec. The pod name is inferred from the 'CONNECTOR_POD_NAME' env variable which is set during deployment.
func ParseFlags ¶
func ParseFlags() error
func SyncCtoK ¶
func SyncCtoK(ctx context.Context, kubeClient kubernetes.Interface, discClient provider.ServiceDiscoveryClient)
func SyncKtoC ¶
func SyncKtoC(ctx context.Context, kubeClient kubernetes.Interface, discClient provider.ServiceDiscoveryClient)
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
DeriveNamespace string
AsInternalServices bool
SdrProvider string
HttpAddr string
SyncCloudToK8s bool
SyncK8sToCloud bool
SyncK8sToGateway bool
C2K C2KCfg
K2C K2CCfg
K2G K2GCfg
Via *connector.Gateway
}
Config is used to configure the creation of a client
type K2CCfg ¶
type K2CCfg struct {
FlagDefaultSync bool
FlagSyncPeriod time.Duration
FlagSyncClusterIPServices bool
FlagSyncLoadBalancerEndpoints bool
FlagNodePortSyncType string
// Flags to support Kubernetes Ingress resources
FlagSyncIngress bool // Register services using the hostname from an ingress resource
FlagSyncIngressLoadBalancerIPs bool // Use the load balancer IP of an ingress resource instead of the hostname
FlagAddServicePrefix string
FlagAddK8SNamespaceAsServiceSuffix bool
FlagAllowK8SNamespaces []string // K8s namespaces to explicitly inject
FlagDenyK8SNamespaces []string // K8s namespaces to deny injection (has precedence)
Consul K2ConsulCfg
FlagWithGateway struct {
Enable bool
}
}
type K2ConsulCfg ¶
type K2ConsulCfg struct {
FlagConsulNodeName string
FlagConsulK8STag string
// Flags to support namespaces
FlagConsulEnableNamespaces bool // Use namespacing on all components
FlagConsulDestinationNamespace string // Consul namespace to register everything if not mirroring
FlagConsulEnableK8SNSMirroring bool // Enables mirroring of k8s namespaces into Consul
FlagConsulK8SNSMirroringPrefix string // Prefix added to Consul namespaces created when mirroring
FlagConsulCrossNamespaceACLPolicy string // The name of the ACL policy to add to every created namespace if ACLs are enabled
}
Click to show internal directories.
Click to hide internal directories.