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 RewriteContainerPathInWindows(mountPath string) string
• func RewriteHostPathInWindows(hostPath string) string
• func ServiceSource(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 RewriteContainerPathInWindows

func RewriteContainerPathInWindows(mountPath string) string

RewriteContainerPathInWindows mount path in windows

func RewriteHostPathInWindows

func RewriteHostPathInWindows(hostPath string) string

RewriteHostPathInWindows rewrite host path

func ServiceSource

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

ServiceSource conv ServiceSource

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