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 (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 (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 (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
- type 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 ¶
View Source
const ( APPLICATION_JSON = "application/json" JSON_PATCH = "application/json-patch+json" MERGE_PATCH = "application/merge-patch+json" )
View Source
const OwningResourcePrefix = "/v1/connector/"
Variables ¶
This section is empty.
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 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)
Click to show internal directories.
Click to hide internal directories.