conversion

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 TenantEnvServiceAutoscaler(as *v1.AppService, dbmanager db.Manager) error
• func TenantEnvServiceBase(as *v1.AppService, dbmanager db.Manager) error
• func TenantEnvServiceConfigGroup(as *v1.AppService, dbm db.Manager) error
• func TenantEnvServiceMonitor(as *v1.AppService, dbmanager db.Manager) error
• func TenantEnvServicePlugin(as *typesv1.AppService, dbmanager db.Manager) error
• func TenantEnvServiceRegist(as *v1.AppService, dbmanager db.Manager) error
• func TenantEnvServiceVersion(as *v1.AppService, dbmanager db.Manager) error
• type AppServiceBuild
  • func AppServiceBuilder(serviceID, replicationType string, dbmanager db.Manager, as *v1.AppService) (*AppServiceBuild, error)
  • func (a AppServiceBuild) ApplyRules(serviceID string, containerPort, pluginContainerPort int, ...) ([]interface{}, []*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.TenantEnvServicesPort, ...) ([]*model.TenantEnvServicesPort, map[int32]int, error)
  • func (a *AppServiceBuild) CreateUpstreamPluginMappingService(services []*corev1.Service, pp map[int32]int) ([]*corev1.Service, error)
• type CacheConversion
• type Conversion

Variables

var ErrServiceNotFound = errors.New("service not found")

ErrServiceNotFound error not found

Functions

func ApplyPluginConfig

func ApplyPluginConfig(as *typesv1.AppService, servicePluginRelation *model.TenantEnvServicePluginRelation,
	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

func InitCacheAppService(dbm db.Manager, serviceID, creatorID string) (*v1.AppService, error)

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 TenantEnvServiceAutoscaler

func TenantEnvServiceAutoscaler(as *v1.AppService, dbmanager db.Manager) error

TenantEnvServiceAutoscaler -

func TenantEnvServiceBase

func TenantEnvServiceBase(as *v1.AppService, dbmanager db.Manager) error

TenantEnvServiceBase conv tenant env service base info

func TenantEnvServiceConfigGroup

func TenantEnvServiceConfigGroup(as *v1.AppService, dbm db.Manager) error

TenantEnvServiceConfigGroup -

func TenantEnvServiceMonitor

func TenantEnvServiceMonitor(as *v1.AppService, dbmanager db.Manager) error

TenantEnvServiceMonitor tenant env service monitor

func TenantEnvServicePlugin

func TenantEnvServicePlugin(as *typesv1.AppService, dbmanager db.Manager) error

TenantEnvServicePlugin conv service all plugin

func TenantEnvServiceRegist

func TenantEnvServiceRegist(as *v1.AppService, dbmanager db.Manager) error

TenantEnvServiceRegist conv inner and outer service regist

func TenantEnvServiceVersion

func TenantEnvServiceVersion(as *v1.AppService, dbmanager db.Manager) error

TenantEnvServiceVersion 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) ([]interface{}, []*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

func (a *AppServiceBuild) BuildOnPort(p int, isOut bool) (*corev1.Service, error)

BuildOnPort 指定端口创建Service

func (*AppServiceBuild) CreateUpstreamPluginMappingPort

func (a *AppServiceBuild) CreateUpstreamPluginMappingPort(
	ports []*model.TenantEnvServicesPort,
	pluginPorts []*model.TenantEnvServicesStreamPluginPort,
) (
	[]*model.TenantEnvServicesPort,
	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