servicebuilder

Documentation

Index

• Variables
• func GetComponentName(routerVersion *models.RouterVersion, componentType string) string
• func GetNamespace(project *mlp.Project) string
• type ClusterServiceBuilder
  • func NewClusterServiceBuilder(cpuLimit resource.Quantity, memoryLimit resource.Quantity) ClusterServiceBuilder

Variables

var ComponentTypes = struct {
	Enricher             string
	Ensembler            string
	Router               string
	FluentdLogger        string
	Secret               string
	ServiceAccountSecret string
	CacheVolume          string
	FiberConfig          string
}{
	Enricher:      "enricher",
	Ensembler:     "ensembler",
	Router:        "router",
	FluentdLogger: "fluentd-logger",
	Secret:        "secret",
	CacheVolume:   "cache-volume",
	FiberConfig:   "fiber-config",
}

Functions

func GetComponentName

func GetComponentName(routerVersion *models.RouterVersion, componentType string) string

func GetNamespace

func GetNamespace(project *mlp.Project) string

Types

type ClusterServiceBuilder

type ClusterServiceBuilder interface {
	NewEnricherService(
		ver *models.RouterVersion,
		project *mlp.Project,
		envType string,
		secretName string,
	) (*cluster.KnativeService, error)
	NewEnsemblerService(
		ver *models.RouterVersion,
		project *mlp.Project,
		envType string,
		secretName string,
	) (*cluster.KnativeService, error)
	NewRouterService(
		ver *models.RouterVersion,
		project *mlp.Project,
		envType string,
		secretName string,
		experimentConfig json.RawMessage,
		fluentdTag string,
		jaegerEndpoint string,
		sentryEnabled bool,
		sentryDSN string,
	) (*cluster.KnativeService, error)
	NewFluentdService(
		routerVersion *models.RouterVersion,
		project *mlp.Project,
		envType string,
		secretName string,
		fluentdConfig *config.FluentdConfig,
	) *cluster.KubernetesService
	NewRouterEndpoint(
		routerVersion *models.RouterVersion,
		project *mlp.Project,
		envType string,
		versionEndpoint string,
	) (*cluster.VirtualService, error)
	NewSecret(
		routerVersion *models.RouterVersion,
		project *mlp.Project,
		routerServiceAccountKey string,
		enricherServiceAccountKey string,
		ensemblerServiceAccountKey string,
		experimentPasskey string,
	) *cluster.Secret
	GetRouterServiceName(ver *models.RouterVersion) string
}

ClusterServiceBuilder parses the Router Config to build a service definition compatible with the cluster package

func NewClusterServiceBuilder

func NewClusterServiceBuilder(
	cpuLimit resource.Quantity,
	memoryLimit resource.Quantity,
) ClusterServiceBuilder

NewClusterServiceBuilder creates a new service builder with the supplied configs for defaults