mongo

Documentation

Index

• type MongoRepository
  • func NewRepository(c *mongo.Client) (*MongoRepository, error)
  • func (r *MongoRepository) BuildIndexes(ctx context.Context) error
  • func (m *MongoRepository) Create(ctx context.Context, providerId, secretID uuid.UUID, ...) (*storage.Provider, error)
  • func (m *MongoRepository) Delete(ctx context.Context, providerID uuid.UUID) error
  • func (m *MongoRepository) Get(ctx context.Context, providerID uuid.UUID) (*storage.Provider, uuid.UUID, error)
  • func (m *MongoRepository) List(ctx context.Context, pagination *model.Pagination) (iterator.Iterator[*storage.ProviderEntry], uint64, error)
  • func (m *MongoRepository) Lookup(ctx context.Context, name string) (uuid.UUID, *storage.Provider, uuid.UUID, error)
  • func (m *MongoRepository) LookupByBucket(ctx context.Context, bucket string) (uuid.UUID, *storage.Provider, uuid.UUID, error)
  • func (m *MongoRepository) Update(ctx context.Context, providerID uuid.UUID, provider *storage.Provider) (*storage.Provider, error)

Types

type MongoRepository

type MongoRepository struct {
	ProviderCollection *mongo.Collection
}

func NewRepository

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

func (*MongoRepository) BuildIndexes

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

func (*MongoRepository) Create

func (m *MongoRepository) Create(ctx context.Context, providerId, secretID uuid.UUID, provider *storage.Provider) (*storage.Provider, error)

func (*MongoRepository) Delete

func (m *MongoRepository) Delete(ctx context.Context, providerID uuid.UUID) error

func (*MongoRepository) Get

func (m *MongoRepository) Get(ctx context.Context, providerID uuid.UUID) (*storage.Provider, uuid.UUID, error)

func (*MongoRepository) List

func (m *MongoRepository) List(ctx context.Context, pagination *model.Pagination) (iterator.Iterator[*storage.ProviderEntry], uint64, error)

func (*MongoRepository) Lookup

func (m *MongoRepository) Lookup(ctx context.Context, name string) (uuid.UUID, *storage.Provider, uuid.UUID, error)

func (*MongoRepository) LookupByBucket

func (m *MongoRepository) LookupByBucket(ctx context.Context, bucket string) (uuid.UUID, *storage.Provider, uuid.UUID, error)

func (*MongoRepository) Update

func (m *MongoRepository) Update(ctx context.Context, providerID uuid.UUID, provider *storage.Provider) (*storage.Provider, error)