import "github.com/goodrain/rainbond/worker/appm/conversion"
autoscaler.go common.go configgroup.go conversion.go errors.go gateway.go monitor.go plugin.go resource.go service.go version.go
ErrServiceNotFound error not found
func ApplyPluginConfig(as *typesv1.AppService, servicePluginRelation *model.TenantServicePluginRelation, dbmanager db.Manager, inboundPluginConfig *api_model.ResourceSpec)
ApplyPluginConfig applyPluginConfig
func InitAppService(dbmanager db.Manager, serviceID string, configs map[string]string, enableConversionList ...string) (*v1.AppService, error)
InitAppService init a app service
InitCacheAppService init cache app service. if store manager receive a kube model belong with service and not find in store,will create
func RegistConversion(name string, fun Conversion)
RegistConversion regist conversion function list
ServiceSource conv ServiceSource
TenantServiceAutoscaler -
TenantServiceBase conv tenant service base info
TenantServiceConfigGroup -
TenantServiceMonitor tenant service monitor
TenantServicePlugin conv service all plugin
TenantServiceRegist conv inner and outer service regist
TenantServiceVersion service deploy version conv. define pod spec
type AppServiceBuild struct {
// contains filtered or unexported fields
}
AppServiceBuild has the ability to build k8s service, ingress and secret
func AppServiceBuilder(serviceID, replicationType string, dbmanager db.Manager, as *v1.AppService) (*AppServiceBuild, error)
AppServiceBuilder returns a AppServiceBuild
func (a AppServiceBuild) ApplyRules(serviceID string, containerPort, pluginContainerPort int, service *corev1.Service) ([]*extensions.Ingress, []*corev1.Secret, error)
ApplyRules applies http rules and tcp rules
func (a *AppServiceBuild) Build() (*v1.K8sResources, error)
Build builds service, ingress and secret for each port
BuildOnPort 指定端口创建Service
func (a *AppServiceBuild) CreateUpstreamPluginMappingPort( ports []*model.TenantServicesPort, pluginPorts []*model.TenantServicesStreamPluginPort, ) ( []*model.TenantServicesPort, map[int32]int, error)
CreateUpstreamPluginMappingPort 检查是否存在upstream插件,接管入口网络
func (a *AppServiceBuild) CreateUpstreamPluginMappingService(services []*corev1.Service, pp map[int32]int) ([]*corev1.Service, error)
CreateUpstreamPluginMappingService 增加service plugin mapport 标签
type CacheConversion struct { Name string Conversion Conversion }
CacheConversion conversion cache struct
Conversion conversion function Any application attribute implementation is similarly injected
Package conversion imports 31 packages (graph) and is imported by 3 packages. Updated 2021-01-16. Refresh now. Tools for package owners.