handler

package

v0.11.2-alpha Latest Latest Go to latest Published: Apr 26, 2023 License: Apache-2.0 Imports: 35 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/instill-ai/pipeline-backend

Documentation ¶

Index ¶

func DBToPBPipeline(dbPipeline *datamodel.Pipeline) *pipelinePB.Pipeline
func HandleTriggerPipelineBinaryFileUpload(s service.Service, w http.ResponseWriter, req *http.Request, ...)
func NewPrivateHandler(s service.Service) pipelinePB.PipelinePrivateServiceServer
func NewPublicHandler(s service.Service) pipelinePB.PipelinePublicServiceServer
func PBToDBPipeline(owner string, pbPipeline *pipelinePB.Pipeline) *datamodel.Pipeline
type PrivateHandler
type PublicHandler

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func DBToPBPipeline ¶

func DBToPBPipeline(dbPipeline *datamodel.Pipeline) *pipelinePB.Pipeline

DBToPBPipeline converts db data model to protobuf data model

func HandleTriggerPipelineBinaryFileUpload ¶

func HandleTriggerPipelineBinaryFileUpload(s service.Service, w http.ResponseWriter, req *http.Request, pathParams map[string]string)

HandleTriggerPipelineBinaryFileUpload is for POST multipart form data

func NewPrivateHandler ¶

func NewPrivateHandler(s service.Service) pipelinePB.PipelinePrivateServiceServer

NewPrivateHandler initiates a handler instance

func NewPublicHandler ¶

func NewPublicHandler(s service.Service) pipelinePB.PipelinePublicServiceServer

NewPublicHandler initiates a handler instance

func PBToDBPipeline ¶

func PBToDBPipeline(owner string, pbPipeline *pipelinePB.Pipeline) *datamodel.Pipeline

PBToDBPipeline converts protobuf data model to db data model

Types ¶

type PrivateHandler ¶

type PrivateHandler struct {
	pipelinePB.UnimplementedPipelinePrivateServiceServer
	// contains filtered or unexported fields
}

PrivateHandler handles private API

func (*PrivateHandler) GetPipelineAdmin ¶

func (h *PrivateHandler) GetPipelineAdmin(ctx context.Context, req *pipelinePB.GetPipelineAdminRequest) (*pipelinePB.GetPipelineAdminResponse, error)

func (*PrivateHandler) GetService ¶

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

GetService returns the service

func (*PrivateHandler) ListPipelinesAdmin ¶

func (h *PrivateHandler) ListPipelinesAdmin(ctx context.Context, req *pipelinePB.ListPipelinesAdminRequest) (*pipelinePB.ListPipelinesAdminResponse, error)

func (*PrivateHandler) LookUpPipelineAdmin ¶

func (h *PrivateHandler) LookUpPipelineAdmin(ctx context.Context, req *pipelinePB.LookUpPipelineAdminRequest) (*pipelinePB.LookUpPipelineAdminResponse, error)

func (*PrivateHandler) SetService ¶

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

SetService sets the service

type PublicHandler ¶

type PublicHandler struct {
	pipelinePB.UnimplementedPipelinePublicServiceServer
	// contains filtered or unexported fields
}

PublicHandler handles public API

func (*PublicHandler) ActivatePipeline ¶

func (h *PublicHandler) ActivatePipeline(ctx context.Context, req *pipelinePB.ActivatePipelineRequest) (*pipelinePB.ActivatePipelineResponse, error)

func (*PublicHandler) CreatePipeline ¶

func (h *PublicHandler) CreatePipeline(ctx context.Context, req *pipelinePB.CreatePipelineRequest) (*pipelinePB.CreatePipelineResponse, error)

func (*PublicHandler) DeactivatePipeline ¶

func (h *PublicHandler) DeactivatePipeline(ctx context.Context, req *pipelinePB.DeactivatePipelineRequest) (*pipelinePB.DeactivatePipelineResponse, error)

func (*PublicHandler) DeletePipeline ¶

func (h *PublicHandler) DeletePipeline(ctx context.Context, req *pipelinePB.DeletePipelineRequest) (*pipelinePB.DeletePipelineResponse, error)

func (*PublicHandler) GetPipeline ¶

func (h *PublicHandler) GetPipeline(ctx context.Context, req *pipelinePB.GetPipelineRequest) (*pipelinePB.GetPipelineResponse, error)

func (*PublicHandler) GetService ¶

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

GetService returns the service

func (*PublicHandler) ListPipelines ¶

func (h *PublicHandler) ListPipelines(ctx context.Context, req *pipelinePB.ListPipelinesRequest) (*pipelinePB.ListPipelinesResponse, error)

func (*PublicHandler) Liveness ¶

func (h *PublicHandler) Liveness(ctx context.Context, req *pipelinePB.LivenessRequest) (*pipelinePB.LivenessResponse, error)

func (*PublicHandler) LookUpPipeline ¶

func (h *PublicHandler) LookUpPipeline(ctx context.Context, req *pipelinePB.LookUpPipelineRequest) (*pipelinePB.LookUpPipelineResponse, error)

func (*PublicHandler) Readiness ¶

func (h *PublicHandler) Readiness(ctx context.Context, req *pipelinePB.ReadinessRequest) (*pipelinePB.ReadinessResponse, error)

func (*PublicHandler) RenamePipeline ¶

func (h *PublicHandler) RenamePipeline(ctx context.Context, req *pipelinePB.RenamePipelineRequest) (*pipelinePB.RenamePipelineResponse, error)

func (*PublicHandler) SetService ¶

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

SetService sets the service

func (*PublicHandler) TriggerPipeline ¶

func (h *PublicHandler) TriggerPipeline(ctx context.Context, req *pipelinePB.TriggerPipelineRequest) (*pipelinePB.TriggerPipelineResponse, error)

func (*PublicHandler) TriggerPipelineBinaryFileUpload ¶

func (h *PublicHandler) TriggerPipelineBinaryFileUpload(stream pipelinePB.PipelinePublicService_TriggerPipelineBinaryFileUploadServer) error

func (*PublicHandler) UpdatePipeline ¶

func (h *PublicHandler) UpdatePipeline(ctx context.Context, req *pipelinePB.UpdatePipelineRequest) (*pipelinePB.UpdatePipelineResponse, error)

func (*PublicHandler) WatchPipeline ¶

func (h *PublicHandler) WatchPipeline(ctx context.Context, req *pipelinePB.WatchPipelineRequest) (*pipelinePB.WatchPipelineResponse, error)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL