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 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 AppServiceBuilder(serviceID, replicationType string, dbmanager db.Manager, as *v1.AppService) (*AppServiceBuild, error)
  • 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

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

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 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

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

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