service

Documentation

Index

• type UserDeploymentRequestService
• type UserDeploymentRequestServiceImpl
  • func NewUserDeploymentRequestServiceImpl(logger *zap.SugaredLogger, ...) *UserDeploymentRequestServiceImpl
  • func (impl *UserDeploymentRequestServiceImpl) GetAllInCompleteRequests(ctx context.Context) ([]*eventProcessorBean.UserDeploymentRequest, error)
  • func (impl *UserDeploymentRequestServiceImpl) GetLatestAsyncCdDeployRequestForPipeline(ctx context.Context, deploymentReqId int) (*eventProcessorBean.UserDeploymentRequest, error)
  • func (impl *UserDeploymentRequestServiceImpl) IsLatestForPipelineId(id, pipelineId int) (isLatest bool, err error)
  • func (impl *UserDeploymentRequestServiceImpl) SaveNewDeployment(ctx context.Context, tx *pg.Tx, ...) (userDeploymentRequestId int, err error)

Types

type UserDeploymentRequestService

type UserDeploymentRequestService interface {
	SaveNewDeployment(ctx context.Context, tx *pg.Tx, deploymentRequest *eventProcessorBean.UserDeploymentRequest) (int, error)
	GetLatestAsyncCdDeployRequestForPipeline(ctx context.Context, deploymentReqId int) (*eventProcessorBean.UserDeploymentRequest, error)
	IsLatestForPipelineId(id, pipelineId int) (isLatest bool, err error)
	GetAllInCompleteRequests(ctx context.Context) ([]*eventProcessorBean.UserDeploymentRequest, error)
}

type UserDeploymentRequestServiceImpl

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

func NewUserDeploymentRequestServiceImpl

func NewUserDeploymentRequestServiceImpl(logger *zap.SugaredLogger,
	userDeploymentRequestRepo repository.UserDeploymentRequestRepository) *UserDeploymentRequestServiceImpl

func (*UserDeploymentRequestServiceImpl) GetAllInCompleteRequests

func (impl *UserDeploymentRequestServiceImpl) GetAllInCompleteRequests(ctx context.Context) ([]*eventProcessorBean.UserDeploymentRequest, error)

func (*UserDeploymentRequestServiceImpl) GetLatestAsyncCdDeployRequestForPipeline

func (impl *UserDeploymentRequestServiceImpl) GetLatestAsyncCdDeployRequestForPipeline(ctx context.Context, deploymentReqId int) (*eventProcessorBean.UserDeploymentRequest, error)

func (*UserDeploymentRequestServiceImpl) IsLatestForPipelineId

func (impl *UserDeploymentRequestServiceImpl) IsLatestForPipelineId(id, pipelineId int) (isLatest bool, err error)

func (*UserDeploymentRequestServiceImpl) SaveNewDeployment

func (impl *UserDeploymentRequestServiceImpl) SaveNewDeployment(ctx context.Context, tx *pg.Tx, deploymentRequest *eventProcessorBean.UserDeploymentRequest) (userDeploymentRequestId int, err error)