process_queue

Documentation

Index

• func NewProcessRecord(user string, request string) *processRecord
• type PersistenceOperationRepo
  • func NewProcessPersistenceRepo(log log.Logger, persistenceFilePath string) PersistenceOperationRepo
• type ProcessPersistenceRepo
  • func (p *ProcessPersistenceRepo) ReadAll() (processRecords []*processRecord, err error)
  • func (p *ProcessPersistenceRepo) WriteAll(processRecords []*processRecord) error
• type ProcessRecordQueue
  • func NewProcessRecordQueue(logger log.Logger, recordFilePath string) *ProcessRecordQueue
  • func (u *ProcessRecordQueue) List() []*processRecord
  • func (u *ProcessRecordQueue) Push(user, url string) *processRecord
  • func (u *ProcessRecordQueue) Save()
  • func (u *ProcessRecordQueue) SetGcSeconds(gcSeconds int) error

Functions

func NewProcessRecord

func NewProcessRecord(user string, request string) *processRecord

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