Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewProcessRecord ¶
Types ¶
type PersistenceOperationRepo ¶
type PersistenceOperationRepo interface {
ReadAll() ([]*processRecord, error)
WriteAll([]*processRecord) error
}
func NewProcessPersistenceRepo ¶
func NewProcessPersistenceRepo(log log.Logger, persistenceFilePath string) PersistenceOperationRepo
type ProcessPersistenceRepo ¶
type ProcessPersistenceRepo struct {
sync.Mutex
ProcessOperationLog string
// contains filtered or unexported fields
}
func (*ProcessPersistenceRepo) ReadAll ¶
func (p *ProcessPersistenceRepo) ReadAll() (processRecords []*processRecord, err error)
func (*ProcessPersistenceRepo) WriteAll ¶
func (p *ProcessPersistenceRepo) WriteAll(processRecords []*processRecord) error
type ProcessRecordQueue ¶
type ProcessRecordQueue struct {
sync.Mutex
PersistenceOperationRepo
// contains filtered or unexported fields
}
func NewProcessRecordQueue ¶
func NewProcessRecordQueue(logger log.Logger, recordFilePath string) *ProcessRecordQueue
func (*ProcessRecordQueue) List ¶
func (u *ProcessRecordQueue) List() []*processRecord
func (*ProcessRecordQueue) Push ¶
func (u *ProcessRecordQueue) Push(user, url string) *processRecord
func (*ProcessRecordQueue) Save ¶
func (u *ProcessRecordQueue) Save()
func (*ProcessRecordQueue) SetGcSeconds ¶
func (u *ProcessRecordQueue) SetGcSeconds(gcSeconds int) error
Source Files
Click to show internal directories.
Click to hide internal directories.