mirrordb

Documentation

Index

• Constants
• type Event
• type Log
• type LogDB
  • func OpenLogDB(ctx context.Context, bucket *blob.Bucket, dataDir string, repository string) (*LogDB, error)
  • func (db *LogDB) AddLog(ctx context.Context, level string, message string) error
  • func (db *LogDB) WalkLogs(ctx context.Context, walkFn WalkLogFunc) error
• type Properties
• type RepositoryDB
  • func OpenRepositoryDB(ctx context.Context, bucket *blob.Bucket, dataDir string, repository string) (*RepositoryDB, error)
  • func (db *RepositoryDB) AddFile(ctx context.Context, file *RepositoryFile) error
  • func (db *RepositoryDB) CountFiles(ctx context.Context) (int, error)
  • func (db *RepositoryDB) GetFileByName(ctx context.Context, name string) (*RepositoryFile, error)
  • func (db *RepositoryDB) GetFileByTag(ctx context.Context, tag string) (*RepositoryFile, error)
  • func (db *RepositoryDB) RemoveFile(ctx context.Context, tag string) (bool, error)
  • func (db *RepositoryDB) WalkFiles(ctx context.Context, walkFn WalkFileFunc) error
  • func (db *RepositoryDB) WalkSymlinks(ctx context.Context, walkFn WalkFileFunc) error
• type RepositoryFile
• type StatusDB
  • func OpenStatusDB(ctx context.Context, bucket *blob.Bucket, dataDir string, repository string) (*StatusDB, error)
  • func (db *StatusDB) AddEvent(ctx context.Context, event *eventv1.EventPayload) error
  • func (db *StatusDB) CountEvents(ctx context.Context) (int, error)
  • func (db *StatusDB) GetProperties(ctx context.Context) (*Properties, error)
  • func (db *StatusDB) GetSync(ctx context.Context) (*Sync, error)
  • func (db *StatusDB) RemoveEvent(ctx context.Context, event *eventv1.EventPayload) error
  • func (db *StatusDB) SetCreatedProperty(ctx context.Context) error
  • func (db *StatusDB) UpdateProperties(ctx context.Context, properties *Properties) error
  • func (db *StatusDB) UpdateSync(ctx context.Context, sync *Sync) error
  • func (db *StatusDB) WalkEvents(ctx context.Context, walkFn WalkEventsFunc) error
• type Sync
• type WalkEventsFunc
• type WalkFileFunc
• type WalkLogFunc

Constants

const (
	LogError string = "ERROR"
	LogInfo  string = "INFO"
)

Types

type Event

type Event struct {
	ID      string `db:"id"`
	Payload []byte `db:"payload"`
}

events table

type Log

type Log struct {
	ID      uint64 `db:"id"`
	Level   string `db:"level"`
	Date    int64  `db:"date"`
	Message string `db:"message"`
}

type LogDB

type LogDB struct {
	*sqlite.DB
}

func OpenLogDB

func OpenLogDB(ctx context.Context, bucket *blob.Bucket, dataDir string, repository string) (*LogDB, error)

func (*LogDB) AddLog

func (db *LogDB) AddLog(ctx context.Context, level string, message string) error

func (*LogDB) WalkLogs

func (db *LogDB) WalkLogs(ctx context.Context, walkFn WalkLogFunc) error

type Properties

type Properties struct {
	Created    bool   `db:"created"`
	Mirror     bool   `db:"mirror"`
	MirrorURLs []byte `db:"mirror_urls"`
}

type RepositoryDB

type RepositoryDB struct {
	*sqlite.DB
}

func OpenRepositoryDB

func OpenRepositoryDB(ctx context.Context, bucket *blob.Bucket, dataDir string, repository string) (*RepositoryDB, error)

func (*RepositoryDB) AddFile

func (db *RepositoryDB) AddFile(ctx context.Context, file *RepositoryFile) error

func (*RepositoryDB) CountFiles

func (db *RepositoryDB) CountFiles(ctx context.Context) (int, error)

func (*RepositoryDB) GetFileByName

func (db *RepositoryDB) GetFileByName(ctx context.Context, name string) (*RepositoryFile, error)

func (*RepositoryDB) GetFileByTag

func (db *RepositoryDB) GetFileByTag(ctx context.Context, tag string) (*RepositoryFile, error)

func (*RepositoryDB) RemoveFile

func (db *RepositoryDB) RemoveFile(ctx context.Context, tag string) (bool, error)

func (*RepositoryDB) WalkFiles

func (db *RepositoryDB) WalkFiles(ctx context.Context, walkFn WalkFileFunc) error

func (*RepositoryDB) WalkSymlinks

func (db *RepositoryDB) WalkSymlinks(ctx context.Context, walkFn WalkFileFunc) error

type RepositoryFile

type RepositoryFile struct {
	Tag          string `db:"tag"`
	Name         string `db:"name"`
	Link         string `db:"link"`
	ModifiedTime int64  `db:"modified_time"`
	Mode         uint32 `db:"mode"`
	Size         uint64 `db:"size"`
}

type StatusDB

type StatusDB struct {
	*sqlite.DB
}

func OpenStatusDB

func OpenStatusDB(ctx context.Context, bucket *blob.Bucket, dataDir string, repository string) (*StatusDB, error)

func (*StatusDB) AddEvent

func (db *StatusDB) AddEvent(ctx context.Context, event *eventv1.EventPayload) error

func (*StatusDB) CountEvents

func (db *StatusDB) CountEvents(ctx context.Context) (int, error)

func (*StatusDB) GetProperties

func (db *StatusDB) GetProperties(ctx context.Context) (*Properties, error)

func (*StatusDB) GetSync

func (db *StatusDB) GetSync(ctx context.Context) (*Sync, error)

func (*StatusDB) RemoveEvent

func (db *StatusDB) RemoveEvent(ctx context.Context, event *eventv1.EventPayload) error

func (*StatusDB) SetCreatedProperty

func (db *StatusDB) SetCreatedProperty(ctx context.Context) error

func (*StatusDB) UpdateProperties

func (db *StatusDB) UpdateProperties(ctx context.Context, properties *Properties) error

func (*StatusDB) UpdateSync

func (db *StatusDB) UpdateSync(ctx context.Context, sync *Sync) error

func (*StatusDB) WalkEvents

func (db *StatusDB) WalkEvents(ctx context.Context, walkFn WalkEventsFunc) error

type Sync

type Sync struct {
	Syncing     bool   `db:"syncing"`
	StartTime   int64  `db:"start_time"`
	EndTime     int64  `db:"end_time"`
	TotalFiles  int    `db:"total_files"`
	SyncedFiles int    `db:"synced_files"`
	SyncError   string `db:"sync_error"`
}

type WalkEventsFunc

type WalkEventsFunc func(*eventv1.EventPayload) error

type WalkFileFunc

type WalkFileFunc func(*RepositoryFile) error

type WalkLogFunc

type WalkLogFunc func(*Log) error