Documentation
¶
Index ¶
- Variables
- func ApplyPluginConfig(as *typesv1.AppService, ...)
- func InitAppService(dbmanager db.Manager, serviceID string, configs map[string]string, ...) (*v1.AppService, error)
- func InitCacheAppService(dbm db.Manager, serviceID, creatorID string) (*v1.AppService, error)
- func RegistConversion(name string, fun Conversion)
- func ServiceSource(as *v1.AppService, dbmanager db.Manager) error
- func TenantServiceAutoscaler(as *v1.AppService, dbmanager db.Manager) error
- func TenantServiceBase(as *v1.AppService, dbmanager db.Manager) error
- func TenantServicePlugin(as *typesv1.AppService, dbmanager db.Manager) error
- func TenantServiceRegist(as *v1.AppService, dbmanager db.Manager) error
- func TenantServiceVersion(as *v1.AppService, dbmanager db.Manager) error
- type AppServiceBuild
- func (a AppServiceBuild) ApplyRules(serviceID string, containerPort, pluginContainerPort int, ...) ([]*extensions.Ingress, []*corev1.Secret, error)
- func (a *AppServiceBuild) Build() (*v1.K8sResources, error)
- func (a *AppServiceBuild) BuildOnPort(p int, isOut bool) (*corev1.Service, error)
- func (a *AppServiceBuild) CreateUpstreamPluginMappingPort(ports []*model.TenantServicesPort, ...) ([]*model.TenantServicesPort, map[int32]int, error)
- func (a *AppServiceBuild) CreateUpstreamPluginMappingService(services []*corev1.Service, pp map[int32]int) ([]*corev1.Service, error)
- type CacheConversion
- type Conversion
Constants ¶
This section is empty.
Variables ¶
var ErrServiceNotFound = errors.New("service not found")
ErrServiceNotFound error not found
Functions ¶
func ApplyPluginConfig ¶
func ApplyPluginConfig(as *typesv1.AppService, servicePluginRelation *model.TenantServicePluginRelation, dbmanager db.Manager, inboundPluginConfig *api_model.ResourceSpec)
ApplyPluginConfig applyPluginConfig
func InitAppService ¶
func InitAppService(dbmanager db.Manager, serviceID string, configs map[string]string, enableConversionList ...string) (*v1.AppService, error)
InitAppService init a app service
func InitCacheAppService ¶
InitCacheAppService init cache app service. if store manager receive a kube model belong with service and not find in store,will create
func RegistConversion ¶
func RegistConversion(name string, fun Conversion)
RegistConversion regist conversion function list
func ServiceSource ¶
func ServiceSource(as *v1.AppService, dbmanager db.Manager) error
ServiceSource conv ServiceSource
func TenantServiceAutoscaler ¶
func TenantServiceAutoscaler(as *v1.AppService, dbmanager db.Manager) error
TenantServiceAutoscaler -
func TenantServiceBase ¶
func TenantServiceBase(as *v1.AppService, dbmanager db.Manager) error
TenantServiceBase conv tenant service base info
func TenantServicePlugin ¶
func TenantServicePlugin(as *typesv1.AppService, dbmanager db.Manager) error
TenantServicePlugin conv service all plugin
func TenantServiceRegist ¶
func TenantServiceRegist(as *v1.AppService, dbmanager db.Manager) error
TenantServiceRegist conv inner and outer service regist
func TenantServiceVersion ¶
func TenantServiceVersion(as *v1.AppService, dbmanager db.Manager) error
TenantServiceVersion service deploy version conv. define pod spec
Types ¶
type AppServiceBuild ¶
type AppServiceBuild struct {
// contains filtered or unexported fields
}
AppServiceBuild has the ability to build k8s service, ingress and secret
func AppServiceBuilder ¶
func AppServiceBuilder(serviceID, replicationType string, dbmanager db.Manager, as *v1.AppService) (*AppServiceBuild, error)
AppServiceBuilder returns a AppServiceBuild
func (AppServiceBuild) ApplyRules ¶
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 (*AppServiceBuild) Build ¶
func (a *AppServiceBuild) Build() (*v1.K8sResources, error)
Build builds service, ingress and secret for each port
func (*AppServiceBuild) BuildOnPort ¶
BuildOnPort 指定端口创建Service
func (*AppServiceBuild) CreateUpstreamPluginMappingPort ¶
func (a *AppServiceBuild) CreateUpstreamPluginMappingPort( ports []*model.TenantServicesPort, pluginPorts []*model.TenantServicesStreamPluginPort, ) ( []*model.TenantServicesPort, map[int32]int, error)
CreateUpstreamPluginMappingPort 检查是否存在upstream插件，接管入口网络
func (*AppServiceBuild) CreateUpstreamPluginMappingService ¶
func (a *AppServiceBuild) CreateUpstreamPluginMappingService(services []*corev1.Service, pp map[int32]int) ([]*corev1.Service, error)
CreateUpstreamPluginMappingService 增加service plugin mapport 标签
type CacheConversion ¶
type CacheConversion struct {
Name string
Conversion Conversion
}
CacheConversion conversion cache struct
type Conversion ¶
type Conversion func(*v1.AppService, db.Manager) error
Conversion conversion function Any application attribute implementation is similarly injected
Source Files