db

package
v0.293.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 7, 2023 License: Apache-2.0 Imports: 21 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	USER_PREFIX = "gramophile/user/"
)

Functions

func ResolveDiff added in v0.273.0 

func ResolveDiff(update *pb.RecordUpdate) []string

Types

type DB added in v0.67.0 

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

func (*DB) Clean added in v0.156.0 

func (d *DB) Clean(ctx context.Context) error

func (*DB) DeleteRecord added in v0.249.0 

func (d *DB) DeleteRecord(ctx context.Context, userid int32, iid int64) error

func (*DB) DeleteUser added in v0.67.0 

func (d *DB) DeleteUser(ctx context.Context, id string) error

func (*DB) GenerateToken added in v0.67.0 

func (d *DB) GenerateToken(ctx context.Context, token, secret string) (*pb.GramophileAuth, error)

func (*DB) GetIntent added in v0.119.0 

func (d *DB) GetIntent(ctx context.Context, userid int32, iid int64) (*pb.Intent, error)

func (*DB) GetLatestSnapshot added in v0.229.0 

func (d *DB) GetLatestSnapshot(ctx context.Context, user *pb.StoredUser, org string) (*pb.OrganisationSnapshot, error)

func (*DB) GetRecord added in v0.67.0 

func (d *DB) GetRecord(ctx context.Context, userid int32, iid int64) (*pb.Record, error)

func (*DB) GetRecords added in v0.79.0 

func (d *DB) GetRecords(ctx context.Context, userid int32) ([]int64, error)

func (*DB) GetUpdates added in v0.213.0 

func (d *DB) GetUpdates(ctx context.Context, userid int32, r *pb.Record) ([]*pb.RecordUpdate, error)

func (*DB) GetUser added in v0.67.0 

func (d *DB) GetUser(ctx context.Context, user string) (*pb.StoredUser, error)

func (*DB) GetUsers added in v0.67.0 

func (d *DB) GetUsers(ctx context.Context) ([]string, error)

func (*DB) GetWants added in v0.288.0 

func (d *DB) GetWants(ctx context.Context, user *pb.StoredUser) ([]*pb.Want, error)

func (*DB) LoadLogins added in v0.67.0 

func (d *DB) LoadLogins(ctx context.Context) (*pb.UserLoginAttempts, error)

func (*DB) LoadSnapshot added in v0.231.0 

func (d *DB) LoadSnapshot(ctx context.Context, user *pb.StoredUser, org string, name string) (*pb.OrganisationSnapshot, error)

func (*DB) LoadWantlist added in v0.282.0 

func (d *DB) LoadWantlist(ctx context.Context, user *pb.StoredUser, wantlist string) (*pb.Wantlist, error)

func (*DB) SaveIntent added in v0.120.0 

func (d *DB) SaveIntent(ctx context.Context, userid int32, iid int64, i *pb.Intent) error

func (*DB) SaveLogins added in v0.67.0 

func (d *DB) SaveLogins(ctx context.Context, logins *pb.UserLoginAttempts) error

func (*DB) SaveRecord added in v0.67.0 

func (d *DB) SaveRecord(ctx context.Context, userid int32, record *pb.Record) error

func (*DB) SaveSnapshot added in v0.229.0 

func (d *DB) SaveSnapshot(ctx context.Context, user *pb.StoredUser, org string, snapshot *pb.OrganisationSnapshot) error

func (*DB) SaveUpdate added in v0.273.0 

func (d *DB) SaveUpdate(ctx context.Context, userid int32, r *pb.Record, update *pb.RecordUpdate) error

func (*DB) SaveUser added in v0.67.0 

func (d *DB) SaveUser(ctx context.Context, user *pb.StoredUser) error

func (*DB) SaveWant added in v0.288.0 

func (d *DB) SaveWant(ctx context.Context, user *pb.StoredUser, want *pb.Want) error

func (*DB) SaveWantlist added in v0.282.0 

func (d *DB) SaveWantlist(ctx context.Context, user *pb.StoredUser, wantlist *pb.Wantlist) error

type Database 

type Database interface {
	GetRecord(ctx context.Context, userid int32, iid int64) (*pb.Record, error)
	DeleteRecord(ctx context.Context, userid int32, iid int64) error
	GetRecords(ctx context.Context, userid int32) ([]int64, error)
	SaveRecord(ctx context.Context, userid int32, record *pb.Record) error
	GetUpdates(ctx context.Context, userid int32, record *pb.Record) ([]*pb.RecordUpdate, error)
	SaveUpdate(ctx context.Context, userid int32, record *pb.Record, update *pb.RecordUpdate) error

	GetIntent(ctx context.Context, userid int32, iid int64) (*pb.Intent, error)
	SaveIntent(ctx context.Context, userid int32, iid int64, i *pb.Intent) error

	LoadLogins(ctx context.Context) (*pb.UserLoginAttempts, error)
	SaveLogins(ctx context.Context, logins *pb.UserLoginAttempts) error
	GenerateToken(ctx context.Context, token, secret string) (*pb.GramophileAuth, error)

	SaveUser(ctx context.Context, user *pb.StoredUser) error
	DeleteUser(ctx context.Context, id string) error
	GetUser(ctx context.Context, user string) (*pb.StoredUser, error)
	GetUsers(ctx context.Context) ([]string, error)

	LoadSnapshot(ctx context.Context, user *pb.StoredUser, org string, hash string) (*pb.OrganisationSnapshot, error)
	SaveSnapshot(ctx context.Context, user *pb.StoredUser, org string, snapshot *pb.OrganisationSnapshot) error
	GetLatestSnapshot(ctx context.Context, user *pb.StoredUser, org string) (*pb.OrganisationSnapshot, error)

	GetWants(ctx context.Context, user *pb.StoredUser) ([]*pb.Want, error)
	SaveWant(ctx context.Context, user *pb.StoredUser, want *pb.Want) error
	SaveWantlist(ctx context.Context, user *pb.StoredUser, wantlist *pb.Wantlist) error
	LoadWantlist(ctx context.Context, user *pb.StoredUser, name string) (*pb.Wantlist, error)

	Clean(ctx context.Context) error
}

func NewDatabase added in v0.55.0 

func NewDatabase(ctx context.Context) Database

func NewTestDB added in v0.213.0 

func NewTestDB(cl rstore_client.RStoreClient) Database

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.