processor

Documentation

Index

• type CurrentTimeChecker
• type MockTime
  • func NewMockTime(time time.Time) MockTime
  • func (m MockTime) Now() time.Time
• type Processor
  • func (p *Processor) Boot(ctx context.Context, dispatcher dispatcher.Dispatcher, ...) error
  • func (p *Processor) Process() error
  • func (p *Processor) SetTime(time CurrentTimeChecker)
  • func (p *Processor) Stop() error
• type RealTime
  • func (RealTime) Now() time.Time

Types

type CurrentTimeChecker

type CurrentTimeChecker interface {
	Now() time.Time
}

type MockTime

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

func NewMockTime

func NewMockTime(time time.Time) MockTime

func (MockTime) Now

func (m MockTime) Now() time.Time

type Processor

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

func (*Processor) Boot

func (p *Processor) Boot(ctx context.Context, dispatcher dispatcher.Dispatcher, dataStorage *storage.PqStorage, cluster *raft.Raft, channel channel.Channel) error

func (*Processor) Process

func (p *Processor) Process() error

func (*Processor) SetTime

func (p *Processor) SetTime(time CurrentTimeChecker)

func (*Processor) Stop

func (p *Processor) Stop() error

type RealTime

type RealTime struct {
}

func (RealTime) Now

func (RealTime) Now() time.Time