repo

Documentation

Index

• Constants
• Variables
• type CredentialRepo
  • func NewCredentialRepo(ctx context.Context, cfg CredentialRepoConfig) (*CredentialRepo, error)
  • func (r *CredentialRepo) GetByUsername(_ context.Context, user blinkfile.Username) (out app.Credentials, err error)
  • func (r *CredentialRepo) Remove(_ context.Context, userID blinkfile.UserID) error
  • func (r *CredentialRepo) Set(_ context.Context, cred app.Credentials) error
• type CredentialRepoConfig
• type FileRepo
  • func NewFileRepo(ctx context.Context, cfg FileRepoConfig) (*FileRepo, error)
  • func (r *FileRepo) Delete(_ context.Context, owner blinkfile.UserID, deleteFiles []blinkfile.FileID) error
  • func (r *FileRepo) DeleteExpiredBefore(ctx context.Context, t time.Time) (int, error)
  • func (r *FileRepo) Dir() string
  • func (r *FileRepo) Get(_ context.Context, fileID blinkfile.FileID) (blinkfile.FileHeader, error)
  • func (r *FileRepo) ListByUser(_ context.Context, userID blinkfile.UserID) ([]blinkfile.FileHeader, error)
  • func (r *FileRepo) PutHeader(ctx context.Context, putHeader blinkfile.FileHeader) error
  • func (r *FileRepo) Save(ctx context.Context, file blinkfile.File) error
• type FileRepoConfig
• type Log
• type SessionConfig
• type SessionRepo
  • func NewSessionRepo(ctx context.Context, cfg SessionConfig) (*SessionRepo, error)
  • func (r *SessionRepo) Delete(ctx context.Context, token app.Token) error
  • func (r *SessionRepo) DeleteAllUserSessions(ctx context.Context, userID blinkfile.UserID) (int, error)
  • func (r *SessionRepo) Get(_ context.Context, token app.Token) (app.Session, bool, error)
  • func (r *SessionRepo) Save(_ context.Context, session app.Session) error
• type UserRepo
  • func NewUserRepo(ctx context.Context, cfg UserRepoConfig) (*UserRepo, error)
  • func (r *UserRepo) Create(_ context.Context, user blinkfile.User) error
  • func (r *UserRepo) Delete(_ context.Context, userID blinkfile.UserID) error
  • func (r *UserRepo) Get(_ context.Context, userID blinkfile.UserID) (blinkfile.User, bool, error)
  • func (r *UserRepo) ListAll(_ context.Context) ([]blinkfile.User, error)
• type UserRepoConfig

Constants

const ModeDir = os.ModeDir

Variables

var (
	RemoveFile = os.Remove
	WriteFile  = os.WriteFile
	ReadFile   = os.ReadFile
	CreateFile = os.Create
	MkdirAll   = os.MkdirAll
	RemoveAll  = os.RemoveAll
	Copy       = io.Copy
	Lstat      = os.Lstat
	Unmarshal  = json.Unmarshal
	Marshal    = json.Marshal
)

Types

type CredentialRepo

type CredentialRepo struct {
	Log
	// contains filtered or unexported fields
}

func NewCredentialRepo

func NewCredentialRepo(ctx context.Context, cfg CredentialRepoConfig) (*CredentialRepo, error)

func (*CredentialRepo) GetByUsername

func (r *CredentialRepo) GetByUsername(_ context.Context, user blinkfile.Username) (out app.Credentials, err error)

func (*CredentialRepo) Remove

func (r *CredentialRepo) Remove(_ context.Context, userID blinkfile.UserID) error

func (*CredentialRepo) Set

func (r *CredentialRepo) Set(_ context.Context, cred app.Credentials) error

type CredentialRepoConfig

type CredentialRepoConfig struct {
	Log
	Dir string
}

type FileRepo

type FileRepo struct {
	Log
	// contains filtered or unexported fields
}

func NewFileRepo

func NewFileRepo(ctx context.Context, cfg FileRepoConfig) (*FileRepo, error)

func (*FileRepo) Delete

func (r *FileRepo) Delete(_ context.Context, owner blinkfile.UserID, deleteFiles []blinkfile.FileID) error

func (*FileRepo) DeleteExpiredBefore

func (r *FileRepo) DeleteExpiredBefore(ctx context.Context, t time.Time) (int, error)

func (*FileRepo) Dir

func (r *FileRepo) Dir() string

func (*FileRepo) Get

func (r *FileRepo) Get(_ context.Context, fileID blinkfile.FileID) (blinkfile.FileHeader, error)

func (*FileRepo) ListByUser

func (r *FileRepo) ListByUser(_ context.Context, userID blinkfile.UserID) ([]blinkfile.FileHeader, error)

func (*FileRepo) PutHeader

func (r *FileRepo) PutHeader(ctx context.Context, putHeader blinkfile.FileHeader) error

func (*FileRepo) Save

func (r *FileRepo) Save(ctx context.Context, file blinkfile.File) error

type FileRepoConfig

type FileRepoConfig struct {
	Log
	Dir string
}

type Log

type Log interface {
	Errorf(ctx context.Context, format string, v ...any)
}

type SessionConfig

type SessionConfig struct {
	Log
	Dir string
}

type SessionRepo

type SessionRepo struct {
	Log
	// contains filtered or unexported fields
}

func NewSessionRepo

func NewSessionRepo(ctx context.Context, cfg SessionConfig) (*SessionRepo, error)

func (*SessionRepo) Delete

func (r *SessionRepo) Delete(ctx context.Context, token app.Token) error

func (*SessionRepo) DeleteAllUserSessions

func (r *SessionRepo) DeleteAllUserSessions(ctx context.Context, userID blinkfile.UserID) (int, error)

func (*SessionRepo) Get

func (r *SessionRepo) Get(_ context.Context, token app.Token) (app.Session, bool, error)

func (*SessionRepo) Save

func (r *SessionRepo) Save(_ context.Context, session app.Session) error

type UserRepo

type UserRepo struct {
	Log
	// contains filtered or unexported fields
}

func NewUserRepo

func NewUserRepo(ctx context.Context, cfg UserRepoConfig) (*UserRepo, error)

func (*UserRepo) Create

func (r *UserRepo) Create(_ context.Context, user blinkfile.User) error

func (*UserRepo) Delete

func (r *UserRepo) Delete(_ context.Context, userID blinkfile.UserID) error

func (*UserRepo) Get

func (r *UserRepo) Get(_ context.Context, userID blinkfile.UserID) (blinkfile.User, bool, error)

func (*UserRepo) ListAll

func (r *UserRepo) ListAll(_ context.Context) ([]blinkfile.User, error)

type UserRepoConfig

type UserRepoConfig struct {
	Log
	Dir string
}