handler

package
v0.9.3-alpha Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 5, 2023 License: Apache-2.0 Imports: 28 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func DBToPBConnector 

func DBToPBConnector(
	dbConnector *datamodel.Connector,
	connectorType datamodel.ConnectorType,
	owner string,
	connectorDefinition string) interface{}

DBToPBConnector converts db data model to protobuf data model

func DBToPBConnectorDefinition 

func DBToPBConnectorDefinition(dbSrcDef *datamodel.ConnectorDefinition, connectorType datamodel.ConnectorType) interface{}

DBToPBConnectorDefinition converts db data model to protobuf data model

func NewPrivateHandler 

func NewPrivateHandler(s service.Service) connectorPB.ConnectorPrivateServiceServer

NewPrivateHandler initiates a handler instance

func NewPublicHandler 

func NewPublicHandler(s service.Service) connectorPB.ConnectorPublicServiceServer

NewPublicHandler initiates a handler instance

func PBToDBConnector 

func PBToDBConnector(
	pbConnector interface{},
	connectorType datamodel.ConnectorType,
	ownerRscName string,
	connectorDefinitionUID uuid.UUID) *datamodel.Connector

PBToDBConnector converts protobuf data model to db data model

Types

type PrivateHandler 

type PrivateHandler struct {
	connectorPB.UnimplementedConnectorPrivateServiceServer
	// contains filtered or unexported fields
}

func (*PrivateHandler) CheckDestinationConnector 

func (h *PrivateHandler) CheckDestinationConnector(ctx context.Context, req *connectorPB.CheckDestinationConnectorRequest) (*connectorPB.CheckDestinationConnectorResponse, error)

func (*PrivateHandler) CheckSourceConnector 

func (h *PrivateHandler) CheckSourceConnector(ctx context.Context, req *connectorPB.CheckSourceConnectorRequest) (*connectorPB.CheckSourceConnectorResponse, error)

func (*PrivateHandler) GetDestinationConnectorAdmin 

func (h *PrivateHandler) GetDestinationConnectorAdmin(ctx context.Context, req *connectorPB.GetDestinationConnectorAdminRequest) (*connectorPB.GetDestinationConnectorAdminResponse, error)

func (*PrivateHandler) GetService 

func (h *PrivateHandler) GetService() service.Service

GetService returns the service

func (*PrivateHandler) GetSourceConnectorAdmin 

func (h *PrivateHandler) GetSourceConnectorAdmin(ctx context.Context, req *connectorPB.GetSourceConnectorAdminRequest) (*connectorPB.GetSourceConnectorAdminResponse, error)

func (*PrivateHandler) ListDestinationConnectorsAdmin 

func (h *PrivateHandler) ListDestinationConnectorsAdmin(ctx context.Context, req *connectorPB.ListDestinationConnectorsAdminRequest) (*connectorPB.ListDestinationConnectorsAdminResponse, error)

func (*PrivateHandler) ListSourceConnectorsAdmin 

func (h *PrivateHandler) ListSourceConnectorsAdmin(ctx context.Context, req *connectorPB.ListSourceConnectorsAdminRequest) (*connectorPB.ListSourceConnectorsAdminResponse, error)

func (*PrivateHandler) LookUpDestinationConnectorAdmin 

func (h *PrivateHandler) LookUpDestinationConnectorAdmin(ctx context.Context, req *connectorPB.LookUpDestinationConnectorAdminRequest) (*connectorPB.LookUpDestinationConnectorAdminResponse, error)

func (*PrivateHandler) LookUpSourceConnectorAdmin 

func (h *PrivateHandler) LookUpSourceConnectorAdmin(ctx context.Context, req *connectorPB.LookUpSourceConnectorAdminRequest) (*connectorPB.LookUpSourceConnectorAdminResponse, error)

func (*PrivateHandler) SetService 

func (h *PrivateHandler) SetService(s service.Service)

SetService sets the service

type PublicHandler 

type PublicHandler struct {
	connectorPB.UnimplementedConnectorPublicServiceServer
	// contains filtered or unexported fields
}

func (*PublicHandler) ConnectDestinationConnector 

func (h *PublicHandler) ConnectDestinationConnector(ctx context.Context, req *connectorPB.ConnectDestinationConnectorRequest) (*connectorPB.ConnectDestinationConnectorResponse, error)

func (*PublicHandler) ConnectSourceConnector 

func (h *PublicHandler) ConnectSourceConnector(ctx context.Context, req *connectorPB.ConnectSourceConnectorRequest) (*connectorPB.ConnectSourceConnectorResponse, error)

func (*PublicHandler) CreateDestinationConnector 

func (h *PublicHandler) CreateDestinationConnector(ctx context.Context, req *connectorPB.CreateDestinationConnectorRequest) (*connectorPB.CreateDestinationConnectorResponse, error)

func (*PublicHandler) CreateSourceConnector 

func (h *PublicHandler) CreateSourceConnector(ctx context.Context, req *connectorPB.CreateSourceConnectorRequest) (*connectorPB.CreateSourceConnectorResponse, error)

func (*PublicHandler) DeleteDestinationConnector 

func (h *PublicHandler) DeleteDestinationConnector(ctx context.Context, req *connectorPB.DeleteDestinationConnectorRequest) (*connectorPB.DeleteDestinationConnectorResponse, error)

func (*PublicHandler) DeleteSourceConnector 

func (h *PublicHandler) DeleteSourceConnector(ctx context.Context, req *connectorPB.DeleteSourceConnectorRequest) (*connectorPB.DeleteSourceConnectorResponse, error)

func (*PublicHandler) DisconnectDestinationConnector 

func (h *PublicHandler) DisconnectDestinationConnector(ctx context.Context, req *connectorPB.DisconnectDestinationConnectorRequest) (*connectorPB.DisconnectDestinationConnectorResponse, error)

func (*PublicHandler) DisconnectSourceConnector 

func (h *PublicHandler) DisconnectSourceConnector(ctx context.Context, req *connectorPB.DisconnectSourceConnectorRequest) (*connectorPB.DisconnectSourceConnectorResponse, error)

func (*PublicHandler) GetConnectorOperation 

func (h *PublicHandler) GetConnectorOperation(ctx context.Context, req *connectorPB.GetConnectorOperationRequest) (*connectorPB.GetConnectorOperationResponse, error)

func (*PublicHandler) GetDestinationConnector 

func (h *PublicHandler) GetDestinationConnector(ctx context.Context, req *connectorPB.GetDestinationConnectorRequest) (*connectorPB.GetDestinationConnectorResponse, error)

func (*PublicHandler) GetDestinationConnectorDefinition 

func (h *PublicHandler) GetDestinationConnectorDefinition(ctx context.Context, req *connectorPB.GetDestinationConnectorDefinitionRequest) (*connectorPB.GetDestinationConnectorDefinitionResponse, error)

func (*PublicHandler) GetService 

func (h *PublicHandler) GetService() service.Service

GetService returns the service

func (*PublicHandler) GetSourceConnector 

func (h *PublicHandler) GetSourceConnector(ctx context.Context, req *connectorPB.GetSourceConnectorRequest) (*connectorPB.GetSourceConnectorResponse, error)

func (*PublicHandler) GetSourceConnectorDefinition 

func (h *PublicHandler) GetSourceConnectorDefinition(ctx context.Context, req *connectorPB.GetSourceConnectorDefinitionRequest) (*connectorPB.GetSourceConnectorDefinitionResponse, error)

func (*PublicHandler) ListDestinationConnectorDefinitions 

func (h *PublicHandler) ListDestinationConnectorDefinitions(ctx context.Context, req *connectorPB.ListDestinationConnectorDefinitionsRequest) (*connectorPB.ListDestinationConnectorDefinitionsResponse, error)

func (*PublicHandler) ListDestinationConnectors 

func (h *PublicHandler) ListDestinationConnectors(ctx context.Context, req *connectorPB.ListDestinationConnectorsRequest) (*connectorPB.ListDestinationConnectorsResponse, error)

func (*PublicHandler) ListSourceConnectorDefinitions 

func (h *PublicHandler) ListSourceConnectorDefinitions(ctx context.Context, req *connectorPB.ListSourceConnectorDefinitionsRequest) (*connectorPB.ListSourceConnectorDefinitionsResponse, error)

func (*PublicHandler) ListSourceConnectors 

func (h *PublicHandler) ListSourceConnectors(ctx context.Context, req *connectorPB.ListSourceConnectorsRequest) (*connectorPB.ListSourceConnectorsResponse, error)

func (*PublicHandler) Liveness 

func (h *PublicHandler) Liveness(ctx context.Context, in *connectorPB.LivenessRequest) (*connectorPB.LivenessResponse, error)

func (*PublicHandler) LookUpDestinationConnector 

func (h *PublicHandler) LookUpDestinationConnector(ctx context.Context, req *connectorPB.LookUpDestinationConnectorRequest) (*connectorPB.LookUpDestinationConnectorResponse, error)

func (*PublicHandler) LookUpSourceConnector 

func (h *PublicHandler) LookUpSourceConnector(ctx context.Context, req *connectorPB.LookUpSourceConnectorRequest) (*connectorPB.LookUpSourceConnectorResponse, error)

func (*PublicHandler) ReadSourceConnector 

func (h *PublicHandler) ReadSourceConnector(context.Context, *connectorPB.ReadSourceConnectorRequest) (*connectorPB.ReadSourceConnectorResponse, error)

func (*PublicHandler) Readiness 

func (h *PublicHandler) Readiness(ctx context.Context, in *connectorPB.ReadinessRequest) (*connectorPB.ReadinessResponse, error)

func (*PublicHandler) RenameDestinationConnector 

func (h *PublicHandler) RenameDestinationConnector(ctx context.Context, req *connectorPB.RenameDestinationConnectorRequest) (*connectorPB.RenameDestinationConnectorResponse, error)

func (*PublicHandler) RenameSourceConnector 

func (h *PublicHandler) RenameSourceConnector(ctx context.Context, req *connectorPB.RenameSourceConnectorRequest) (*connectorPB.RenameSourceConnectorResponse, error)

func (*PublicHandler) SetService 

func (h *PublicHandler) SetService(s service.Service)

SetService sets the service

func (*PublicHandler) UpdateDestinationConnector 

func (h *PublicHandler) UpdateDestinationConnector(ctx context.Context, req *connectorPB.UpdateDestinationConnectorRequest) (*connectorPB.UpdateDestinationConnectorResponse, error)

func (*PublicHandler) UpdateSourceConnector 

func (h *PublicHandler) UpdateSourceConnector(ctx context.Context, req *connectorPB.UpdateSourceConnectorRequest) (*connectorPB.UpdateSourceConnectorResponse, error)

func (*PublicHandler) WatchDestinationConnector 

func (h *PublicHandler) WatchDestinationConnector(ctx context.Context, req *connectorPB.WatchDestinationConnectorRequest) (*connectorPB.WatchDestinationConnectorResponse, error)

func (*PublicHandler) WatchSourceConnector 

func (h *PublicHandler) WatchSourceConnector(ctx context.Context, req *connectorPB.WatchSourceConnectorRequest) (*connectorPB.WatchSourceConnectorResponse, error)

func (*PublicHandler) WriteDestinationConnector 

func (h *PublicHandler) WriteDestinationConnector(ctx context.Context, req *connectorPB.WriteDestinationConnectorRequest) (*connectorPB.WriteDestinationConnectorResponse, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.