connector

Documentation

Index

• Constants
• type ProtoBufHandler
  • func NewProtoBufHandler(context *operator.Context, ...) ProtoBufHandler
• type ServiceEndpoints
  • func (s *ServiceEndpoints) IsEmpty() bool
  • func (s *ServiceEndpoints) String() string
• type URLHandler
  • func NewURLHandler(context *operator.Context, runtimeHandler manager.KogitoRuntimeHandler, ...) URLHandler

Constants

const (

	// ConfigMapProtoBufEnabledLabelKey label key used by configMaps that are meant to hold protobuf files
	ConfigMapProtoBufEnabledLabelKey = "kogito-protobuf"
)

Types

type ProtoBufHandler

type ProtoBufHandler interface {
	MountProtoBufConfigMapsOnDeployment(deployment *appsv1.Deployment) (err error)
	MountProtoBufConfigMapOnDataIndex(kogitoRuntime api.KogitoRuntimeInterface) (err error)
}

ProtoBufHandler ...

func NewProtoBufHandler

func NewProtoBufHandler(context *operator.Context, supportingServiceHandler manager.KogitoSupportingServiceHandler) ProtoBufHandler

NewProtoBufHandler ...

type ServiceEndpoints

type ServiceEndpoints struct {
	// HTTPRouteURI ...
	HTTPRouteURI string
	// HTTPRouteEnv name of the environment variable that will hold the HTTP URI
	HTTPRouteEnv string
	// WSRouteURI ...
	WSRouteURI string
	// WSRouteEnv name of the environment variable that will hold the HTTP URI
	WSRouteEnv string
}

ServiceEndpoints represents the endpoints for a deployed Kogito Data Index service

func (*ServiceEndpoints) IsEmpty

func (s *ServiceEndpoints) IsEmpty() bool

IsEmpty returns true if route URIs are empty

func (*ServiceEndpoints) String

func (s *ServiceEndpoints) String() string

type URLHandler

type URLHandler interface {
	InjectDataIndexURLIntoKogitoRuntimeServices(namespace string) error
	InjectDataIndexURLIntoDeployment(namespace string, deployment *appsv1.Deployment) error
	InjectDataIndexURLIntoSupportingService(namespace string, serviceTypes ...api.ServiceType) error
	InjectJobsServicesURLIntoKogitoRuntimeServices(namespace string) error
	InjectJobsServiceURLIntoKogitoRuntimeDeployment(namespace string, deployment *appsv1.Deployment) error
	InjectTrustyURLIntoKogitoRuntimeServices(namespace string) error
	InjectTrustyURLIntoDeployment(namespace string, deployment *appsv1.Deployment) error
}

URLHandler ...

func NewURLHandler

func NewURLHandler(context *operator.Context, runtimeHandler manager.KogitoRuntimeHandler, supportingServiceHandler manager.KogitoSupportingServiceHandler) URLHandler

NewURLHandler ...