handlers

Documentation

Index

• Constants
• func HandleConnectorDelete(ctx context.Context, connectorsService services.ConnectorsService, ...) *errors.ServiceError
• func NewAuthenticationBuilder(ServerConfig *server.ServerConfig, KeycloakConfig *keycloak.KeycloakConfig) (*authentication.HandlerBuilder, error)
• func PatchResource(resourceJson []byte, patchType string, patchBytes []byte, patched interface{}) *errors.ServiceError
• func StringListSubtract(l []string, items ...string) (result []string)
• func ValidateConnectorOperation(ctx context.Context, namespaceService services.ConnectorNamespaceService, ...) (err *errors.ServiceError)
• type ConnectorAdminHandler
  • func NewConnectorAdminHandler(handler ConnectorAdminHandler) *ConnectorAdminHandler
  • func (h *ConnectorAdminHandler) CreateConnectorNamespace(writer http.ResponseWriter, request *http.Request)
  • func (h *ConnectorAdminHandler) DeleteConnector(writer http.ResponseWriter, request *http.Request)
  • func (h *ConnectorAdminHandler) DeleteConnectorNamespace(writer http.ResponseWriter, request *http.Request)
  • func (h *ConnectorAdminHandler) GetClusterConnectors(writer http.ResponseWriter, request *http.Request)
  • func (h *ConnectorAdminHandler) GetClusterDeployments(writer http.ResponseWriter, request *http.Request)
  • func (h *ConnectorAdminHandler) GetClusterNamespaces(writer http.ResponseWriter, request *http.Request)
  • func (h *ConnectorAdminHandler) GetConnector(writer http.ResponseWriter, request *http.Request)
  • func (h *ConnectorAdminHandler) GetConnectorCluster(w http.ResponseWriter, r *http.Request)
  • func (h *ConnectorAdminHandler) GetConnectorDeployment(writer http.ResponseWriter, request *http.Request)
  • func (h *ConnectorAdminHandler) GetConnectorNamespace(writer http.ResponseWriter, request *http.Request)
  • func (h *ConnectorAdminHandler) GetConnectorNamespaces(writer http.ResponseWriter, request *http.Request)
  • func (h *ConnectorAdminHandler) GetConnectorType(writer http.ResponseWriter, request *http.Request)
  • func (h *ConnectorAdminHandler) GetNamespaceConnectors(writer http.ResponseWriter, request *http.Request)
  • func (h *ConnectorAdminHandler) GetNamespaceDeployments(writer http.ResponseWriter, request *http.Request)
  • func (h *ConnectorAdminHandler) ListConnectorClusters(w http.ResponseWriter, r *http.Request)
  • func (h *ConnectorAdminHandler) ListConnectorTypes(writer http.ResponseWriter, request *http.Request)
  • func (h *ConnectorAdminHandler) PatchConnector(writer http.ResponseWriter, request *http.Request)
  • func (h *ConnectorAdminHandler) PatchConnectorDeployment(writer http.ResponseWriter, request *http.Request)
• type ConnectorClusterHandler
  • func NewConnectorClusterHandler(handler ConnectorClusterHandler) *ConnectorClusterHandler
  • func (h *ConnectorClusterHandler) Create(w http.ResponseWriter, r *http.Request)
  • func (h *ConnectorClusterHandler) Delete(w http.ResponseWriter, r *http.Request)
  • func (h *ConnectorClusterHandler) Get(w http.ResponseWriter, r *http.Request)
  • func (h *ConnectorClusterHandler) GetAddonParameters(w http.ResponseWriter, r *http.Request)
  • func (h *ConnectorClusterHandler) GetAgentNamespace(w http.ResponseWriter, r *http.Request)
  • func (h *ConnectorClusterHandler) GetAgentNamespaces(writer http.ResponseWriter, request *http.Request)
  • func (h *ConnectorClusterHandler) GetDeployment(w http.ResponseWriter, r *http.Request)
  • func (h *ConnectorClusterHandler) GetNamespace(w http.ResponseWriter, r *http.Request)
  • func (h *ConnectorClusterHandler) GetNamespaces(writer http.ResponseWriter, request *http.Request)
  • func (h *ConnectorClusterHandler) List(w http.ResponseWriter, r *http.Request)
  • func (h *ConnectorClusterHandler) ListDeployments(w http.ResponseWriter, r *http.Request)
  • func (h *ConnectorClusterHandler) Update(w http.ResponseWriter, r *http.Request)
  • func (h *ConnectorClusterHandler) UpdateConnectorClusterStatus(w http.ResponseWriter, r *http.Request)
  • func (h *ConnectorClusterHandler) UpdateDeploymentStatus(w http.ResponseWriter, r *http.Request)
  • func (h *ConnectorClusterHandler) UpdateNamespaceStatus(w http.ResponseWriter, r *http.Request)
• type ConnectorNamespaceHandler
  • func NewConnectorNamespaceHandler(handler ConnectorNamespaceHandler) *ConnectorNamespaceHandler
  • func (h *ConnectorNamespaceHandler) Create(w http.ResponseWriter, r *http.Request)
  • func (h *ConnectorNamespaceHandler) CreateEvaluation(w http.ResponseWriter, r *http.Request)
  • func (h *ConnectorNamespaceHandler) Delete(w http.ResponseWriter, r *http.Request)
  • func (h *ConnectorNamespaceHandler) Get(w http.ResponseWriter, r *http.Request)
  • func (h *ConnectorNamespaceHandler) List(w http.ResponseWriter, r *http.Request)
  • func (h *ConnectorNamespaceHandler) Update(w http.ResponseWriter, r *http.Request)
• type ConnectorTypesHandler
  • func NewConnectorTypesHandler(service services.ConnectorTypesService, manager *workers.ConnectorManager) *ConnectorTypesHandler
  • func (h ConnectorTypesHandler) Get(w http.ResponseWriter, r *http.Request)
  • func (h ConnectorTypesHandler) List(w http.ResponseWriter, r *http.Request)
  • func (h ConnectorTypesHandler) ListLabels(w http.ResponseWriter, r *http.Request)
• type ConnectorsHandler
  • func NewConnectorsHandler(connectorsService services.ConnectorsService, ...) *ConnectorsHandler
  • func (h ConnectorsHandler) Create(w http.ResponseWriter, r *http.Request)
  • func (h ConnectorsHandler) Delete(w http.ResponseWriter, r *http.Request)
  • func (h ConnectorsHandler) Get(w http.ResponseWriter, r *http.Request)
  • func (h ConnectorsHandler) List(w http.ResponseWriter, r *http.Request)
  • func (h ConnectorsHandler) Patch(w http.ResponseWriter, r *http.Request)

Constants

const (
	APPLICATION_JSON = "application/json"
	JSON_PATCH       = "application/json-patch+json"
	MERGE_PATCH      = "application/merge-patch+json"
)

const OwningResourcePrefix = "/v1/connector/"

Functions

func HandleConnectorDelete

func HandleConnectorDelete(ctx context.Context, connectorsService services.ConnectorsService,
	namespaceService services.ConnectorNamespaceService, connectorId string) *errors.ServiceError

func NewAuthenticationBuilder

func NewAuthenticationBuilder(ServerConfig *server.ServerConfig, KeycloakConfig *keycloak.KeycloakConfig) (*authentication.HandlerBuilder, error)

func PatchResource

func PatchResource(resourceJson []byte, patchType string, patchBytes []byte, patched interface{}) *errors.ServiceError

func StringListSubtract

func StringListSubtract(l []string, items ...string) (result []string)

func ValidateConnectorOperation

func ValidateConnectorOperation(ctx context.Context, namespaceService services.ConnectorNamespaceService, connector *dbapi.Connector,
	operation phase.ConnectorOperation, updatePhase ...func(*dbapi.Connector) *errors.ServiceError) (err *errors.ServiceError)

Types

type ConnectorAdminHandler

type ConnectorAdminHandler struct {
	di.Inject
	ConnectorsConfig      *config.ConnectorsConfig
	AuthZService          authz.AuthZService
	Service               services.ConnectorClusterService
	ConnectorsService     services.ConnectorsService
	NamespaceService      services.ConnectorNamespaceService
	QuotaConfig           *config.ConnectorsQuotaConfig
	ConnectorCluster      *ConnectorClusterHandler //TODO: eventually move deployment handling into a deployment service
	ConnectorTypesService services.ConnectorTypesService
}

func NewConnectorAdminHandler

func NewConnectorAdminHandler(handler ConnectorAdminHandler) *ConnectorAdminHandler

func (*ConnectorAdminHandler) CreateConnectorNamespace

func (h *ConnectorAdminHandler) CreateConnectorNamespace(writer http.ResponseWriter, request *http.Request)

func (*ConnectorAdminHandler) DeleteConnector

func (h *ConnectorAdminHandler) DeleteConnector(writer http.ResponseWriter, request *http.Request)

func (*ConnectorAdminHandler) DeleteConnectorNamespace

func (h *ConnectorAdminHandler) DeleteConnectorNamespace(writer http.ResponseWriter, request *http.Request)

func (*ConnectorAdminHandler) GetClusterConnectors

func (h *ConnectorAdminHandler) GetClusterConnectors(writer http.ResponseWriter, request *http.Request)

func (*ConnectorAdminHandler) GetClusterDeployments

func (h *ConnectorAdminHandler) GetClusterDeployments(writer http.ResponseWriter, request *http.Request)

func (*ConnectorAdminHandler) GetClusterNamespaces

func (h *ConnectorAdminHandler) GetClusterNamespaces(writer http.ResponseWriter, request *http.Request)

func (*ConnectorAdminHandler) GetConnector

func (h *ConnectorAdminHandler) GetConnector(writer http.ResponseWriter, request *http.Request)

func (*ConnectorAdminHandler) GetConnectorCluster

func (h *ConnectorAdminHandler) GetConnectorCluster(w http.ResponseWriter, r *http.Request)

func (*ConnectorAdminHandler) GetConnectorDeployment

func (h *ConnectorAdminHandler) GetConnectorDeployment(writer http.ResponseWriter, request *http.Request)

func (*ConnectorAdminHandler) GetConnectorNamespace

func (h *ConnectorAdminHandler) GetConnectorNamespace(writer http.ResponseWriter, request *http.Request)

func (*ConnectorAdminHandler) GetConnectorNamespaces

func (h *ConnectorAdminHandler) GetConnectorNamespaces(writer http.ResponseWriter, request *http.Request)

func (*ConnectorAdminHandler) GetConnectorType

func (h *ConnectorAdminHandler) GetConnectorType(writer http.ResponseWriter, request *http.Request)

func (*ConnectorAdminHandler) GetNamespaceConnectors

func (h *ConnectorAdminHandler) GetNamespaceConnectors(writer http.ResponseWriter, request *http.Request)

func (*ConnectorAdminHandler) GetNamespaceDeployments

func (h *ConnectorAdminHandler) GetNamespaceDeployments(writer http.ResponseWriter, request *http.Request)

func (*ConnectorAdminHandler) ListConnectorClusters

func (h *ConnectorAdminHandler) ListConnectorClusters(w http.ResponseWriter, r *http.Request)

func (*ConnectorAdminHandler) ListConnectorTypes

func (h *ConnectorAdminHandler) ListConnectorTypes(writer http.ResponseWriter, request *http.Request)

func (*ConnectorAdminHandler) PatchConnector

func (h *ConnectorAdminHandler) PatchConnector(writer http.ResponseWriter, request *http.Request)

func (*ConnectorAdminHandler) PatchConnectorDeployment

func (h *ConnectorAdminHandler) PatchConnectorDeployment(writer http.ResponseWriter, request *http.Request)

type ConnectorClusterHandler

type ConnectorClusterHandler struct {
	di.Inject
	Bus                signalbus.SignalBus
	Service            services.ConnectorClusterService
	Keycloak           sso.KafkaKeycloakService
	Connectors         services.ConnectorsService
	ConnectorNamespace services.ConnectorNamespaceService
	Vault              vault.VaultService
	ServerConfig       *server.ServerConfig
	AuthZ              authz.AuthZService
	QuotaConfig        *config.ConnectorsQuotaConfig
}

func NewConnectorClusterHandler

func NewConnectorClusterHandler(handler ConnectorClusterHandler) *ConnectorClusterHandler

func (*ConnectorClusterHandler) Create

func (h *ConnectorClusterHandler) Create(w http.ResponseWriter, r *http.Request)

func (*ConnectorClusterHandler) Delete

func (h *ConnectorClusterHandler) Delete(w http.ResponseWriter, r *http.Request)

func (*ConnectorClusterHandler) Get

func (h *ConnectorClusterHandler) Get(w http.ResponseWriter, r *http.Request)

func (*ConnectorClusterHandler) GetAddonParameters

func (h *ConnectorClusterHandler) GetAddonParameters(w http.ResponseWriter, r *http.Request)

func (*ConnectorClusterHandler) GetAgentNamespace

func (h *ConnectorClusterHandler) GetAgentNamespace(w http.ResponseWriter, r *http.Request)

func (*ConnectorClusterHandler) GetAgentNamespaces

func (h *ConnectorClusterHandler) GetAgentNamespaces(writer http.ResponseWriter, request *http.Request)

func (*ConnectorClusterHandler) GetDeployment

func (h *ConnectorClusterHandler) GetDeployment(w http.ResponseWriter, r *http.Request)

func (*ConnectorClusterHandler) GetNamespace

func (h *ConnectorClusterHandler) GetNamespace(w http.ResponseWriter, r *http.Request)

func (*ConnectorClusterHandler) GetNamespaces

func (h *ConnectorClusterHandler) GetNamespaces(writer http.ResponseWriter, request *http.Request)

func (*ConnectorClusterHandler) List

func (h *ConnectorClusterHandler) List(w http.ResponseWriter, r *http.Request)

func (*ConnectorClusterHandler) ListDeployments

func (h *ConnectorClusterHandler) ListDeployments(w http.ResponseWriter, r *http.Request)

func (*ConnectorClusterHandler) Update

func (h *ConnectorClusterHandler) Update(w http.ResponseWriter, r *http.Request)

func (*ConnectorClusterHandler) UpdateConnectorClusterStatus

func (h *ConnectorClusterHandler) UpdateConnectorClusterStatus(w http.ResponseWriter, r *http.Request)

func (*ConnectorClusterHandler) UpdateDeploymentStatus

func (h *ConnectorClusterHandler) UpdateDeploymentStatus(w http.ResponseWriter, r *http.Request)

func (*ConnectorClusterHandler) UpdateNamespaceStatus

func (h *ConnectorClusterHandler) UpdateNamespaceStatus(w http.ResponseWriter, r *http.Request)

type ConnectorNamespaceHandler

type ConnectorNamespaceHandler struct {
	di.Inject
	Bus          signalbus.SignalBus
	Service      services.ConnectorNamespaceService
	AuthZService authz.AuthZService
	QuotaConfig  *config.ConnectorsQuotaConfig
}

func NewConnectorNamespaceHandler

func NewConnectorNamespaceHandler(handler ConnectorNamespaceHandler) *ConnectorNamespaceHandler

func (*ConnectorNamespaceHandler) Create

func (h *ConnectorNamespaceHandler) Create(w http.ResponseWriter, r *http.Request)

func (*ConnectorNamespaceHandler) CreateEvaluation

func (h *ConnectorNamespaceHandler) CreateEvaluation(w http.ResponseWriter, r *http.Request)

func (*ConnectorNamespaceHandler) Delete

func (h *ConnectorNamespaceHandler) Delete(w http.ResponseWriter, r *http.Request)

func (*ConnectorNamespaceHandler) Get

func (h *ConnectorNamespaceHandler) Get(w http.ResponseWriter, r *http.Request)

func (*ConnectorNamespaceHandler) List

func (h *ConnectorNamespaceHandler) List(w http.ResponseWriter, r *http.Request)

func (*ConnectorNamespaceHandler) Update

func (h *ConnectorNamespaceHandler) Update(w http.ResponseWriter, r *http.Request)

type ConnectorTypesHandler

type ConnectorTypesHandler struct {
	// contains filtered or unexported fields
}

func NewConnectorTypesHandler

func NewConnectorTypesHandler(service services.ConnectorTypesService, manager *workers.ConnectorManager) *ConnectorTypesHandler

func (ConnectorTypesHandler) Get

func (h ConnectorTypesHandler) Get(w http.ResponseWriter, r *http.Request)

func (ConnectorTypesHandler) List

func (h ConnectorTypesHandler) List(w http.ResponseWriter, r *http.Request)

func (ConnectorTypesHandler) ListLabels

func (h ConnectorTypesHandler) ListLabels(w http.ResponseWriter, r *http.Request)

type ConnectorsHandler

type ConnectorsHandler struct {
	// contains filtered or unexported fields
}

func NewConnectorsHandler

func NewConnectorsHandler(connectorsService services.ConnectorsService, connectorTypesService services.ConnectorTypesService,
	namespaceService services.ConnectorNamespaceService, vaultService vault.VaultService, authZService authz.AuthZService,
	connectorsConfig *config.ConnectorsConfig) *ConnectorsHandler

func (ConnectorsHandler) Create

func (h ConnectorsHandler) Create(w http.ResponseWriter, r *http.Request)

func (ConnectorsHandler) Delete

func (h ConnectorsHandler) Delete(w http.ResponseWriter, r *http.Request)

Delete is the handler for deleting a connector

func (ConnectorsHandler) Get

func (h ConnectorsHandler) Get(w http.ResponseWriter, r *http.Request)

func (ConnectorsHandler) List

func (h ConnectorsHandler) List(w http.ResponseWriter, r *http.Request)

func (ConnectorsHandler) Patch

func (h ConnectorsHandler) Patch(w http.ResponseWriter, r *http.Request)