persistence

Documentation

Index

• type Bucket
  • func (b *Bucket) Cleanup()
  • func (b *Bucket) CreateAsyncJob(nodeID node.ID, t job.Job) (*job.Async, error)
  • func (b *Bucket) DeleteAsyncJob(asyncJob *job.Async) error
  • func (b *Bucket) GetAllAsyncJobs() ([]job.Async, error)
• type Repository
  • func NewRepository(directory string, logger zap.SugaredLogger) (*Repository, error)
  • func (r *Repository) Bucket(name, hash string, logger zap.SugaredLogger) (*Bucket, error)

Types

type Bucket

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

func (*Bucket) Cleanup

func (b *Bucket) Cleanup()

func (*Bucket) CreateAsyncJob

func (b *Bucket) CreateAsyncJob(nodeID node.ID, t job.Job) (*job.Async, error)

func (*Bucket) DeleteAsyncJob

func (b *Bucket) DeleteAsyncJob(asyncJob *job.Async) error

func (*Bucket) GetAllAsyncJobs

func (b *Bucket) GetAllAsyncJobs() ([]job.Async, error)

type Repository

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

func NewRepository

func NewRepository(directory string, logger zap.SugaredLogger) (*Repository, error)

func (*Repository) Bucket

func (r *Repository) Bucket(name, hash string, logger zap.SugaredLogger) (*Bucket, error)