mongo

Documentation

Index

• type Resource
• type Storage
  • func (storage *Storage) Alloc(ctx context.Context, amount int) ([]resource.ID, error)
  • func (storage *Storage) Dealloc(ctx context.Context, ids []resource.ID) error
  • func (storage *Storage) Init(ctx context.Context, resources []resource.Resource) error
  • func (storage *Storage) Load(ctx context.Context, ids ...resource.ID) ([]resource.Resource, error)

Types

type Resource

type Resource struct {
	ID        string    `bson:"_id"`
	Data      []byte    `bson:"data"`
	Status    string    `bson:"status"`
	Version   *string   `bson:"version"`
	UpdatedAt time.Time `bson:"updated_at"`
}

type Storage

type Storage struct {
	Collection  *mongo.Collection
	LockTimeout time.Duration
}

func (*Storage) Alloc

func (storage *Storage) Alloc(ctx context.Context, amount int) ([]resource.ID, error)

func (*Storage) Dealloc

func (storage *Storage) Dealloc(ctx context.Context, ids []resource.ID) error

func (*Storage) Init

func (storage *Storage) Init(ctx context.Context, resources []resource.Resource) error

func (*Storage) Load

func (storage *Storage) Load(ctx context.Context, ids ...resource.ID) ([]resource.Resource, error)