logslinecount

Documentation

Index

• type Publisher
  • func NewPublisher() *Publisher
  • func (p *Publisher) Publish(r postfix.Record)
• type Reporter
  • func NewReporter(pub *Publisher) *Reporter
  • func (r *Reporter) Close() error
  • func (r *Reporter) ExecutionInterval() time.Duration
  • func (r *Reporter) ID() string
  • func (r *Reporter) Step(tx *sql.Tx, clock timeutil.Clock) error

Types

type Publisher

type Publisher struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewPublisher

func NewPublisher() *Publisher

func (*Publisher) Publish

func (p *Publisher) Publish(r postfix.Record)

type Reporter

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

func NewReporter

func NewReporter(pub *Publisher) *Reporter

func (*Reporter) Close

func (r *Reporter) Close() error

func (*Reporter) ExecutionInterval

func (r *Reporter) ExecutionInterval() time.Duration

func (*Reporter) ID

func (r *Reporter) ID() string

func (*Reporter) Step

func (r *Reporter) Step(tx *sql.Tx, clock timeutil.Clock) error