conversion

package
v5.2.0-beta2+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 11, 2020 License: LGPL-3.0 Imports: 27 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL