Documentation
¶
Index ¶
- Variables
- func DefaultConfigurationFilter(obj interface{}) bool
- func GetFsmNamespace() string
- func GetFsmPodName() string
- func GetFsmPodNamespace() string
- func RegisterConfigurationHanlder(handler ConfigEventHandler, configmapInformer ctrlruntimecache.Informer, ...)
- type Certificate
- type Cluster
- type ConfigEventHandler
- type ConnectorConfig
- type FlomeshConfigurationHandler
- type FsmMetadata
- type GatewayApi
- type Images
- type Ingress
- type MeshConfig
- func (o *MeshConfig) AggregatorPort() string
- func (o *MeshConfig) GetDefaultIngressPath() string
- func (o *MeshConfig) GetDefaultServicesPath() string
- func (o *MeshConfig) IngressCodebasePath() string
- func (o *MeshConfig) NamespacedIngressCodebasePath(namespace string) string
- func (o *MeshConfig) PipyImage() string
- func (o *MeshConfig) ProxyInitImage() string
- func (o *MeshConfig) RepoAddr() string
- func (o *MeshConfig) RepoApiBaseURL() string
- func (o *MeshConfig) RepoBaseURL() string
- func (o *MeshConfig) ServiceLbImage() string
- func (o *MeshConfig) ToJson() string
- type MeshConfigChangeListener
- type MeshConfigClient
- type ProxyInitEnvironmentConfiguration
- type Repo
- type SSLPassthrough
- type ServiceAggregator
- type ServiceLB
- type Store
- type TLS
- type Webhook
Constants ¶
This section is empty.
Variables ¶
View Source
var (
DefaultWatchedConfigMaps = sets.String{}
)
Functions ¶
func DefaultConfigurationFilter ¶
func DefaultConfigurationFilter(obj interface{}) bool
func GetFsmNamespace ¶
func GetFsmNamespace() string
func GetFsmPodName ¶ added in v0.1.6
func GetFsmPodName() string
func GetFsmPodNamespace ¶ added in v0.1.6
func GetFsmPodNamespace() string
func RegisterConfigurationHanlder ¶
func RegisterConfigurationHanlder(handler ConfigEventHandler, configmapInformer ctrlruntimecache.Informer, resyncPeriod time.Duration)
Types ¶
type Certificate ¶
type Certificate struct {
Manager string `json:"manager,omitempty"`
}
type ConfigEventHandler ¶
type ConnectorConfig ¶
type ConnectorConfig struct {
ClusterName string `envconfig:"CLUSTER_NAME" required:"true" split_words:"true"`
ClusterRegion string `envconfig:"CLUSTER_REGION" default:"default" split_words:"true"`
ClusterZone string `envconfig:"CLUSTER_ZONE" default:"default" split_words:"true"`
ClusterGroup string `envconfig:"CLUSTER_GROUP" default:"default" split_words:"true"`
ClusterGateway string `envconfig:"CLUSTER_GATEWAY" required:"true" split_words:"true"`
//ClusterConnectorNamespace string `envconfig:"CLUSTER_CONNECTOR_NAMESPACE" required:"true" split_words:"true"`
ClusterConnectorIsInCluster bool `envconfig:"CLUSTER_CONNECTOR_IS_IN_CLUSTER" required:"true" split_words:"true"`
ClusterControlPlaneRepoRootUrl string `envconfig:"CLUSTER_CONTROL_PLANE_REPO_ROOT_URL" default:"http://fsm-repo-service:6060" split_words:"true"`
ClusterControlPlaneRepoPath string `envconfig:"CLUSTER_CONTROL_PLANE_REPO_PATH" default:"/repo" split_words:"true"`
ClusterControlPlaneRepoApiPath string `envconfig:"CLUSTER_CONTROL_PLANE_REPO_API_PATH" default:"/api/v1/repo" split_words:"true"`
}
func (*ConnectorConfig) UID ¶
func (c *ConnectorConfig) UID() string
type FlomeshConfigurationHandler ¶
type FlomeshConfigurationHandler struct {
// contains filtered or unexported fields
}
func (FlomeshConfigurationHandler) OnConfigMapAdd ¶
func (f FlomeshConfigurationHandler) OnConfigMapAdd(cm *corev1.ConfigMap)
func (FlomeshConfigurationHandler) OnConfigMapDelete ¶
func (f FlomeshConfigurationHandler) OnConfigMapDelete(cm *corev1.ConfigMap)
func (FlomeshConfigurationHandler) OnConfigMapUpdate ¶
func (f FlomeshConfigurationHandler) OnConfigMapUpdate(oldCm, cm *corev1.ConfigMap)
type FsmMetadata ¶ added in v0.1.6
type GatewayApi ¶
type GatewayApi struct {
Enabled bool `json:"enabled,omitempty"`
}
type MeshConfig ¶
type MeshConfig struct {
IsControlPlane bool `json:"isControlPlane,omitempty"`
Repo Repo `json:"repo"`
Images Images `json:"images"`
ServiceAggregator ServiceAggregator `json:"serviceAggregator"`
Webhook Webhook `json:"webhook"`
Ingress Ingress `json:"ingress"`
GatewayApi GatewayApi `json:"gatewayApi"`
Certificate Certificate `json:"certificate"`
Cluster Cluster `json:"cluster"`
ServiceLB ServiceLB `json:"serviceLB"`
}
func ParseMeshConfig ¶
func ParseMeshConfig(cm *corev1.ConfigMap) *MeshConfig
func (*MeshConfig) AggregatorPort ¶ added in v0.1.6
func (o *MeshConfig) AggregatorPort() string
func (*MeshConfig) GetDefaultIngressPath ¶ added in v0.1.7
func (o *MeshConfig) GetDefaultIngressPath() string
func (*MeshConfig) GetDefaultServicesPath ¶ added in v0.1.7
func (o *MeshConfig) GetDefaultServicesPath() string
func (*MeshConfig) IngressCodebasePath ¶
func (o *MeshConfig) IngressCodebasePath() string
func (*MeshConfig) NamespacedIngressCodebasePath ¶ added in v0.1.7
func (o *MeshConfig) NamespacedIngressCodebasePath(namespace string) string
func (*MeshConfig) PipyImage ¶
func (o *MeshConfig) PipyImage() string
func (*MeshConfig) ProxyInitImage ¶
func (o *MeshConfig) ProxyInitImage() string
func (*MeshConfig) RepoAddr ¶ added in v0.1.6
func (o *MeshConfig) RepoAddr() string
func (*MeshConfig) RepoApiBaseURL ¶
func (o *MeshConfig) RepoApiBaseURL() string
func (*MeshConfig) RepoBaseURL ¶
func (o *MeshConfig) RepoBaseURL() string
func (*MeshConfig) ServiceLbImage ¶ added in v0.1.8
func (o *MeshConfig) ServiceLbImage() string
func (*MeshConfig) ToJson ¶
func (o *MeshConfig) ToJson() string
type MeshConfigChangeListener ¶
type MeshConfigChangeListener interface {
OnConfigCreate(cfg *MeshConfig)
OnConfigUpdate(oldCfg, cfg *MeshConfig)
OnConfigDelete(cfg *MeshConfig)
}
type MeshConfigClient ¶
type MeshConfigClient struct {
// contains filtered or unexported fields
}
func NewMeshConfigClient ¶
func NewMeshConfigClient(k8sApi *kube.K8sAPI) *MeshConfigClient
func (*MeshConfigClient) GetConfig ¶
func (c *MeshConfigClient) GetConfig() *MeshConfig
func (*MeshConfigClient) UpdateConfig ¶
func (c *MeshConfigClient) UpdateConfig(config *MeshConfig)
type ProxyInitEnvironmentConfiguration ¶
type ProxyInitEnvironmentConfiguration struct {
MatchedProxyProfile string `envconfig:"MATCHED_PROXY_PROFILE" required:"true" split_words:"true"`
ProxyRepoBaseUrl string `envconfig:"PROXY_REPO_BASE_URL" required:"true" split_words:"true"`
ProxyRepoApiBaseUrl string `envconfig:"PROXY_REPO_API_BASE_URL" required:"true" split_words:"true"`
ProxyParentPath string `envconfig:"PROXY_PARENT_PATH" required:"true" split_words:"true"`
ProxyPaths []string `envconfig:"PROXY_PATHS" required:"true" split_words:"true"`
}
type SSLPassthrough ¶ added in v0.1.7
type ServiceAggregator ¶
type ServiceAggregator struct {
Addr string `json:"addr" validate:"required,hostname_port"`
}
type Store ¶
type Store struct {
MeshConfig *MeshConfigClient
}
type TLS ¶ added in v0.1.7
type TLS struct {
Enabled bool `json:"enabled,omitempty"`
SSLPassthrough SSLPassthrough `json:"sslPassthrough,omitempty"`
}
Click to show internal directories.
Click to hide internal directories.