pipelinehdl

Documentation

Index

• type PipelineHTTPHandler
  • func NewPipelineHTTPHandler(pipelineService port.PipelineService, jobQueue port.JobQueue) *PipelineHTTPHandler
  • func (hdl *PipelineHTTPHandler) Create(c *gin.Context)
  • func (hdl *PipelineHTTPHandler) Delete(c *gin.Context)
  • func (hdl *PipelineHTTPHandler) Get(c *gin.Context)
  • func (hdl *PipelineHTTPHandler) GetPipelineJobs(c *gin.Context)
  • func (hdl *PipelineHTTPHandler) GetPipelines(c *gin.Context)
  • func (hdl *PipelineHTTPHandler) Update(c *gin.Context)
• type PipelinegRPCHandler
  • func NewPipelinegRPCHandler(pipelineService port.PipelineService, jobQueue port.JobQueue) *PipelinegRPCHandler
  • func (hdl *PipelinegRPCHandler) Create(ctx context.Context, in *pb.CreatePipelineRequest) (*pb.CreatePipelineResponse, error)
  • func (hdl *PipelinegRPCHandler) Delete(ctx context.Context, in *pb.DeletePipelineRequest) (*pb.DeletePipelineResponse, error)
  • func (hdl *PipelinegRPCHandler) Get(ctx context.Context, in *pb.GetPipelineRequest) (*pb.GetPipelineResponse, error)
  • func (hdl *PipelinegRPCHandler) GetPipelineJobs(ctx context.Context, in *pb.GetPipelineJobsRequest) (*pb.GetPipelineJobsResponse, error)
  • func (hdl *PipelinegRPCHandler) GetPipelines(ctx context.Context, in *pb.GetPipelinesRequest) (*pb.GetPipelinesResponse, error)
  • func (hdl *PipelinegRPCHandler) Update(ctx context.Context, in *pb.UpdatePipelineRequest) (*pb.UpdatePipelineResponse, error)
• type RequestBodyDTO
  • func NewRequestBodyDTO() *RequestBodyDTO
• type ResponseBodyDTO
  • func BuildResponseBodyDTO(resource *domain.Pipeline) ResponseBodyDTO

Types

type PipelineHTTPHandler

type PipelineHTTPHandler struct {
	handler.HTTPHandler
	// contains filtered or unexported fields
}

PipelineHTTPHandler is an HTTP handler that exposes pipeline endpoints.

func NewPipelineHTTPHandler

func NewPipelineHTTPHandler(
	pipelineService port.PipelineService,
	jobQueue port.JobQueue) *PipelineHTTPHandler

NewPipelineHTTPHandler creates and returns a new PipelineHTTPHandler.

func (*PipelineHTTPHandler) Create

func (hdl *PipelineHTTPHandler) Create(c *gin.Context)

Create creates a new pipeline and all of its jobs.

func (*PipelineHTTPHandler) Delete

func (hdl *PipelineHTTPHandler) Delete(c *gin.Context)

Delete deletes a pipelines and all its jobs.

func (*PipelineHTTPHandler) Get

func (hdl *PipelineHTTPHandler) Get(c *gin.Context)

Get fetches a pipeline.

func (*PipelineHTTPHandler) GetPipelineJobs

func (hdl *PipelineHTTPHandler) GetPipelineJobs(c *gin.Context)

GetPipelineJobs fetches the jobs of a specified pipeline.

func (*PipelineHTTPHandler) GetPipelines

func (hdl *PipelineHTTPHandler) GetPipelines(c *gin.Context)

GetPipelines fetches all pipelines, optionally filters them by status.

func (*PipelineHTTPHandler) Update

func (hdl *PipelineHTTPHandler) Update(c *gin.Context)

Update updates a pipeline.

type PipelinegRPCHandler

type PipelinegRPCHandler struct {
	pb.UnimplementedPipelineServer
	// contains filtered or unexported fields
}

PipelinegRPCHandler is a gRPC handler that exposes job endpoints.

func NewPipelinegRPCHandler

func NewPipelinegRPCHandler(pipelineService port.PipelineService, jobQueue port.JobQueue) *PipelinegRPCHandler

NewPipelinegRPCHandler creates and returns a new PipelinegRPCHandler.

func (*PipelinegRPCHandler) Create

func (hdl *PipelinegRPCHandler) Create(ctx context.Context, in *pb.CreatePipelineRequest) (*pb.CreatePipelineResponse, error)

Create creates a new pipeline and all of its jobs.

func (*PipelinegRPCHandler) Delete

func (hdl *PipelinegRPCHandler) Delete(ctx context.Context, in *pb.DeletePipelineRequest) (*pb.DeletePipelineResponse, error)

Delete deletes a pipelines and all its jobs.

func (*PipelinegRPCHandler) Get

func (hdl *PipelinegRPCHandler) Get(ctx context.Context, in *pb.GetPipelineRequest) (*pb.GetPipelineResponse, error)

Get fetches a pipeline.

func (*PipelinegRPCHandler) GetPipelineJobs

func (hdl *PipelinegRPCHandler) GetPipelineJobs(ctx context.Context, in *pb.GetPipelineJobsRequest) (*pb.GetPipelineJobsResponse, error)

GetPipelineJobs fetches the jobs of a specified pipeline.

func (*PipelinegRPCHandler) GetPipelines

func (hdl *PipelinegRPCHandler) GetPipelines(ctx context.Context, in *pb.GetPipelinesRequest) (*pb.GetPipelinesResponse, error)

GetPipelines fetches all pipelines, optionally filters them by status.

func (*PipelinegRPCHandler) Update

func (hdl *PipelinegRPCHandler) Update(ctx context.Context, in *pb.UpdatePipelineRequest) (*pb.UpdatePipelineResponse, error)

Update updates a pipeline.

type RequestBodyDTO

type RequestBodyDTO struct {
	Name        string                   `json:"name"`
	Description string                   `json:"description"`
	RunAt       string                   `json:"run_at"`
	Jobs        []*jobhdl.RequestBodyDTO `json:"jobs"`
}

RequestBodyDTO is the data transfer object used for a job creation or update.

func NewRequestBodyDTO

func NewRequestBodyDTO() *RequestBodyDTO

NewRequestBodyDTO initializes and returns a new BodyDTO instance.

type ResponseBodyDTO

type ResponseBodyDTO *domain.Pipeline

ResponseBodyDTO is the response data transfer object used for a pipeline creation or update.

func BuildResponseBodyDTO

func BuildResponseBodyDTO(resource *domain.Pipeline) ResponseBodyDTO

BuildResponseDTO creates a new ResponseDTO.