mongo

Documentation

Overview

Mongo implements the repository.Group interface.

Index

• type MongoRepository
  • func NewRepository(c *mongo.Client) (*MongoRepository, error)
  • func (m *MongoRepository) ActiveRollouts(ctx context.Context, pagination *model.Pagination) (iterator.Iterator[repo_capsule.ActiveRollout], error)
  • func (r *MongoRepository) BuildIndexes(ctx context.Context) error
  • func (c *MongoRepository) Create(ctx context.Context, p *capsule.Capsule) error
  • func (m *MongoRepository) CreateBuild(ctx context.Context, capsuleID uuid.UUID, b *capsule.Build) error
  • func (m *MongoRepository) CreateEvent(ctx context.Context, capsuleID uuid.UUID, e *capsule.Event) error
  • func (c *MongoRepository) CreateMetrics(ctx context.Context, metrics *capsule.InstanceMetrics) error
  • func (m *MongoRepository) CreateRollout(ctx context.Context, capsuleID uuid.UUID, rc *capsule.RolloutConfig, ...) (uint64, error)
  • func (c *MongoRepository) Delete(ctx context.Context, capsuleID uuid.UUID) error
  • func (m *MongoRepository) DeleteBuild(ctx context.Context, capsuleID uuid.UUID, buildID string) error
  • func (c *MongoRepository) Get(ctx context.Context, capsuleID uuid.UUID) (*capsule.Capsule, error)
  • func (m *MongoRepository) GetBuild(ctx context.Context, capsuleID uuid.UUID, buildID string) (*capsule.Build, error)
  • func (c *MongoRepository) GetByName(ctx context.Context, name string) (*capsule.Capsule, error)
  • func (c *MongoRepository) GetInstanceMetrics(ctx context.Context, pagination *model.Pagination, capsuleID uuid.UUID, ...) (iterator.Iterator[*capsule.InstanceMetrics], error)
  • func (c *MongoRepository) GetMetrics(ctx context.Context, pagination *model.Pagination, capsuleID uuid.UUID) (iterator.Iterator[*capsule.InstanceMetrics], error)
  • func (m *MongoRepository) GetRollout(ctx context.Context, capsuleID uuid.UUID, rolloutID uint64) (*capsule.RolloutConfig, *rollout.Status, uint64, error)
  • func (r *MongoRepository) List(ctx context.Context, pagination *model.Pagination) (iterator.Iterator[*capsule.Capsule], int64, error)
  • func (m *MongoRepository) ListBuilds(ctx context.Context, pagination *model.Pagination, capsuleID uuid.UUID) (iterator.Iterator[*capsule.Build], uint64, error)
  • func (m *MongoRepository) ListEvents(ctx context.Context, pagination *model.Pagination, capsuleID uuid.UUID, ...) (iterator.Iterator[*capsule.Event], uint64, error)
  • func (c *MongoRepository) ListMetrics(ctx context.Context, pagination *model.Pagination) (iterator.Iterator[*capsule.InstanceMetrics], error)
  • func (m *MongoRepository) ListRollouts(ctx context.Context, pagination *model.Pagination, capsuleID uuid.UUID) (iterator.Iterator[*capsule.Rollout], uint64, error)
  • func (r *MongoRepository) Update(ctx context.Context, p *capsule.Capsule) error
  • func (m *MongoRepository) UpdateRolloutStatus(ctx context.Context, capsuleID uuid.UUID, rolloutID uint64, version uint64, ...) error

Types

type MongoRepository

type MongoRepository struct {
	CapsuleCol      *mongo.Collection
	BuildCol        *mongo.Collection
	RolloutCol      *mongo.Collection
	CapsuleEventCol *mongo.Collection
	MetricsCol      *mongo.Collection
}

func NewRepository

func NewRepository(c *mongo.Client) (*MongoRepository, error)

func (*MongoRepository) ActiveRollouts

func (m *MongoRepository) ActiveRollouts(ctx context.Context, pagination *model.Pagination) (iterator.Iterator[repo_capsule.ActiveRollout], error)

func (*MongoRepository) BuildIndexes

func (r *MongoRepository) BuildIndexes(ctx context.Context) error

BuildIndexes TODO: implement.

func (*MongoRepository) Create

func (c *MongoRepository) Create(ctx context.Context, p *capsule.Capsule) error

func (*MongoRepository) CreateBuild

func (m *MongoRepository) CreateBuild(ctx context.Context, capsuleID uuid.UUID, b *capsule.Build) error

func (*MongoRepository) CreateEvent

func (m *MongoRepository) CreateEvent(ctx context.Context, capsuleID uuid.UUID, e *capsule.Event) error

func (*MongoRepository) CreateMetrics

func (c *MongoRepository) CreateMetrics(ctx context.Context, metrics *capsule.InstanceMetrics) error

func (*MongoRepository) CreateRollout

func (m *MongoRepository) CreateRollout(ctx context.Context, capsuleID uuid.UUID, rc *capsule.RolloutConfig, rs *rollout.Status) (uint64, error)

func (*MongoRepository) Delete

func (c *MongoRepository) Delete(ctx context.Context, capsuleID uuid.UUID) error

Delete removes the project (document) from the database.

func (*MongoRepository) DeleteBuild

func (m *MongoRepository) DeleteBuild(ctx context.Context, capsuleID uuid.UUID, buildID string) error

func (*MongoRepository) Get

func (c *MongoRepository) Get(ctx context.Context, capsuleID uuid.UUID) (*capsule.Capsule, error)

Get returns the requested Project (document) from the database.

func (*MongoRepository) GetBuild

func (m *MongoRepository) GetBuild(ctx context.Context, capsuleID uuid.UUID, buildID string) (*capsule.Build, error)

func (*MongoRepository) GetByName

func (c *MongoRepository) GetByName(ctx context.Context, name string) (*capsule.Capsule, error)

Get returns the requested Project (document) from the database.

func (*MongoRepository) GetInstanceMetrics

func (c *MongoRepository) GetInstanceMetrics(
	ctx context.Context,
	pagination *model.Pagination,
	capsuleID uuid.UUID,
	instanceID string,
) (iterator.Iterator[*capsule.InstanceMetrics], error)

func (*MongoRepository) GetMetrics

func (c *MongoRepository) GetMetrics(
	ctx context.Context,
	pagination *model.Pagination,
	capsuleID uuid.UUID,
) (iterator.Iterator[*capsule.InstanceMetrics], error)

func (*MongoRepository) GetRollout

func (m *MongoRepository) GetRollout(ctx context.Context, capsuleID uuid.UUID, rolloutID uint64) (*capsule.RolloutConfig, *rollout.Status, uint64, error)

func (*MongoRepository) List

func (r *MongoRepository) List(ctx context.Context, pagination *model.Pagination) (iterator.Iterator[*capsule.Capsule], int64, error)

func (*MongoRepository) ListBuilds

func (m *MongoRepository) ListBuilds(ctx context.Context, pagination *model.Pagination, capsuleID uuid.UUID) (iterator.Iterator[*capsule.Build], uint64, error)

func (*MongoRepository) ListEvents

func (m *MongoRepository) ListEvents(ctx context.Context, pagination *model.Pagination, capsuleID uuid.UUID, rolloutID uint64) (iterator.Iterator[*capsule.Event], uint64, error)

func (*MongoRepository) ListMetrics

func (c *MongoRepository) ListMetrics(
	ctx context.Context,
	pagination *model.Pagination,
) (iterator.Iterator[*capsule.InstanceMetrics], error)

func (*MongoRepository) ListRollouts

func (m *MongoRepository) ListRollouts(ctx context.Context, pagination *model.Pagination, capsuleID uuid.UUID) (iterator.Iterator[*capsule.Rollout], uint64, error)

func (*MongoRepository) Update

func (r *MongoRepository) Update(ctx context.Context, p *capsule.Capsule) error

func (*MongoRepository) UpdateRolloutStatus

func (m *MongoRepository) UpdateRolloutStatus(ctx context.Context, capsuleID uuid.UUID, rolloutID uint64, version uint64, rs *rollout.Status) error