resources

Documentation

Index

• Constants
• func MakeCluster(clusterName string, eps []Endpoint, isGrpc bool, clientSecret *Secret) *cluster.Cluster
• func MakeEndpoint(clusterName string, eps []Endpoint) *endpoint.ClusterLoadAssignment
• func MakeHTTPListener(listenerName, address string, port uint32, routeConfigurationName string, ...) *listener.Listener
• func MakeRoute(modelRoutes []*Route, pipelineRoutes []*PipelineRoute) (*route.RouteConfiguration, *route.RouteConfiguration)
• func MakeSecretResource(name string, validationName string, certStore tls.CertificateStoreHandler) []*tlsv3.Secret
• type Cluster
• type Endpoint
• type Listener
• type PipelineRoute
• type PipelineTrafficSplits
• type Route
• type RouteVersionKey
• type Secret
• type TrafficSplits

Constants

const (
	PipelineGatewayHttpClusterName = "pipelinegateway_http"
	PipelineGatewayGrpcClusterName = "pipelinegateway_grpc"
	MirrorHttpClusterName          = "mirror_http"
	MirrorGrpcClusterName          = "mirror_grpc"
)

const (
	SeldonLoggingHeader           = "Seldon-Logging"
	EnvoyLogPathPrefix            = "/tmp/request-log"
	SeldonModelHeader             = "seldon-model"
	SeldonPipelineHeader          = "pipeline"
	SeldonInternalModelHeader     = "seldon-internal-model"
	SeldonRouteHeader             = "x-seldon-route"
	SeldonRouteSeparator          = ":" // Tried % but this seemed to break envoy matching. Maybe % is a special character or connected to regexp. A bug?
	SeldonModelHeaderSuffix       = "model"
	SeldonPipelineHeaderSuffix    = "pipeline"
	DefaultRouteTimeoutSecs       = 60 //TODO allow configurable override
	ExternalHeaderPrefix          = "x-"
	DefaultRouteConfigurationName = "listener_0"
	MirrorRouteConfigurationName  = "listener_1"
	TLSRouteConfigurationName     = "listener_tls"
)

Functions

func MakeCluster

func MakeCluster(clusterName string, eps []Endpoint, isGrpc bool, clientSecret *Secret) *cluster.Cluster

func MakeEndpoint

func MakeEndpoint(clusterName string, eps []Endpoint) *endpoint.ClusterLoadAssignment

func MakeHTTPListener

func MakeHTTPListener(listenerName, address string,
	port uint32,
	routeConfigurationName string,
	serverSecret *Secret) *listener.Listener

func MakeRoute

func MakeRoute(modelRoutes []*Route, pipelineRoutes []*PipelineRoute) (*route.RouteConfiguration, *route.RouteConfiguration)

func MakeSecretResource

func MakeSecretResource(name string, validationName string, certStore tls.CertificateStoreHandler) []*tlsv3.Secret

Types

type Cluster

type Cluster struct {
	Name      string
	Grpc      bool
	Endpoints map[string]Endpoint
	Routes    map[RouteVersionKey]bool
}

type Endpoint

type Endpoint struct {
	UpstreamHost string
	UpstreamPort uint32
}

type Listener

type Listener struct {
	Name                   string
	Address                string
	Port                   uint32
	RouteConfigurationName string
}

type PipelineRoute

type PipelineRoute struct {
	RouteName string
	Clusters  []PipelineTrafficSplits
	Mirrors   []PipelineTrafficSplits
}

type PipelineTrafficSplits

type PipelineTrafficSplits struct {
	PipelineName  string
	TrafficWeight uint32
}

type Route

type Route struct {
	RouteName   string
	LogPayloads bool
	Clusters    []TrafficSplits
	Mirrors     []TrafficSplits
}

type RouteVersionKey

type RouteVersionKey struct {
	RouteName string
	ModelName string
	Version   uint32
}

type Secret

type Secret struct {
	Name                 string
	ValidationSecretName string
	Certificate          tls.CertificateStoreHandler
}

type TrafficSplits

type TrafficSplits struct {
	ModelName     string
	ModelVersion  uint32
	TrafficWeight uint32
	HttpCluster   string
	GrpcCluster   string
}