mongodb

Documentation

Index

• type FlowRepository
  • func NewFlowRepository(db *mongo.Database) *FlowRepository
  • func (r *FlowRepository) GetFlow(ctx context.Context, flowID string) (*flow.Flow, error)
  • func (r *FlowRepository) UpsertFlow(ctx context.Context, flow *flow.Flow) error
• type PipelineGuard
  • func NewPipelineGuard(db *mongo.Database) *PipelineGuard
  • func (g *PipelineGuard) AcquirePipeline(ctx context.Context, pipeID string) error
  • func (g *PipelineGuard) ReleasePipeline(ctx context.Context, pipeID string) error
• type PipelineRepository
  • func NewPipelineRepository(db *mongo.Database) *PipelineRepository
  • func (r *PipelineRepository) AddPipeline(ctx context.Context, pipe *pipeline.Pipeline) error
  • func (r *PipelineRepository) GetPipeline(ctx context.Context, pipeID string, specGetter service.SpecificationGetter, ...) (*pipeline.Pipeline, error)
• type SpecificationRepository
  • func NewSpecificationRepository(db *mongo.Database) *SpecificationRepository
  • func (r *SpecificationRepository) AddSpecification(ctx context.Context, spec *specification.Specification) error
  • func (r *SpecificationRepository) FindSpecification(ctx context.Context, qry query.Specification) (query.SpecificationModel, error)
  • func (r *SpecificationRepository) GetActiveSpecificationByTestCampaignID(ctx context.Context, testCampaignID string) (*specification.Specification, error)
  • func (r *SpecificationRepository) GetSpecification(ctx context.Context, specID string) (*specification.Specification, error)
• type TestCampaignRepository
  • func NewTestCampaignRepository(db *mongo.Database) *TestCampaignRepository
  • func (r *TestCampaignRepository) AddTestCampaign(ctx context.Context, tc *testcampaign.TestCampaign) error
  • func (r *TestCampaignRepository) FindTestCampaign(ctx context.Context, qry query.TestCampaign) (query.TestCampaignModel, error)
  • func (r *TestCampaignRepository) GetTestCampaign(ctx context.Context, tcID string) (*testcampaign.TestCampaign, error)
  • func (r *TestCampaignRepository) UpdateTestCampaign(ctx context.Context, tcID string, updater service.TestCampaignUpdater) error

Types

type FlowRepository

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

func NewFlowRepository

func NewFlowRepository(db *mongo.Database) *FlowRepository

func (*FlowRepository) GetFlow

func (r *FlowRepository) GetFlow(ctx context.Context, flowID string) (*flow.Flow, error)

func (*FlowRepository) UpsertFlow

func (r *FlowRepository) UpsertFlow(ctx context.Context, flow *flow.Flow) error

type PipelineGuard

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

func NewPipelineGuard

func NewPipelineGuard(db *mongo.Database) *PipelineGuard

func (*PipelineGuard) AcquirePipeline

func (g *PipelineGuard) AcquirePipeline(ctx context.Context, pipeID string) error

func (*PipelineGuard) ReleasePipeline

func (g *PipelineGuard) ReleasePipeline(ctx context.Context, pipeID string) error

type PipelineRepository

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

func NewPipelineRepository

func NewPipelineRepository(db *mongo.Database) *PipelineRepository

func (*PipelineRepository) AddPipeline

func (r *PipelineRepository) AddPipeline(ctx context.Context, pipe *pipeline.Pipeline) error

func (*PipelineRepository) GetPipeline

func (r *PipelineRepository) GetPipeline(
	ctx context.Context,
	pipeID string,
	specGetter service.SpecificationGetter,
	registrars ...pipeline.ExecutorRegistrar,
) (*pipeline.Pipeline, error)

type SpecificationRepository

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

func NewSpecificationRepository

func NewSpecificationRepository(db *mongo.Database) *SpecificationRepository

func (*SpecificationRepository) AddSpecification

func (r *SpecificationRepository) AddSpecification(ctx context.Context, spec *specification.Specification) error

func (*SpecificationRepository) FindSpecification

func (r *SpecificationRepository) FindSpecification(
	ctx context.Context,
	qry query.Specification,
) (query.SpecificationModel, error)

func (*SpecificationRepository) GetActiveSpecificationByTestCampaignID

func (r *SpecificationRepository) GetActiveSpecificationByTestCampaignID(
	ctx context.Context,
	testCampaignID string,
) (*specification.Specification, error)

func (*SpecificationRepository) GetSpecification

func (r *SpecificationRepository) GetSpecification(
	ctx context.Context,
	specID string,
) (*specification.Specification, error)

type TestCampaignRepository

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

func NewTestCampaignRepository

func NewTestCampaignRepository(db *mongo.Database) *TestCampaignRepository

func (*TestCampaignRepository) AddTestCampaign

func (r *TestCampaignRepository) AddTestCampaign(ctx context.Context, tc *testcampaign.TestCampaign) error

func (*TestCampaignRepository) FindTestCampaign

func (r *TestCampaignRepository) FindTestCampaign(
	ctx context.Context,
	qry query.TestCampaign,
) (query.TestCampaignModel, error)

func (*TestCampaignRepository) GetTestCampaign

func (r *TestCampaignRepository) GetTestCampaign(
	ctx context.Context,
	tcID string,
) (*testcampaign.TestCampaign, error)

func (*TestCampaignRepository) UpdateTestCampaign

func (r *TestCampaignRepository) UpdateTestCampaign(
	ctx context.Context,
	tcID string,
	updater service.TestCampaignUpdater,
) error