validator

Documentation

Index

• type Config
• type Validator
  • func NewValidator(config *Config, logger logging.Logger) (*Validator, error)
  • func (v *Validator) FindSafeTime(ctx context.Context, endTimestamp int64) (int64, error)
  • func (v *Validator) Run(ctx context.Context) error

Types

type Config

type Config struct {
	RoundInterval time.Duration `arg:"env:ROUND_INTERVAL" default:"1m"`
	DatabaseURLs  []string      `arg:"env:DATABASE_URLS"`
}

type Validator

type Validator struct {
	OnOK       func(context.Context, int64) error
	OnConflict func(context.Context, int64) error
	// contains filtered or unexported fields
}

func NewValidator

func NewValidator(config *Config, logger logging.Logger) (*Validator, error)

func (*Validator) FindSafeTime

func (v *Validator) FindSafeTime(ctx context.Context, endTimestamp int64) (int64, error)

func (*Validator) Run

func (v *Validator) Run(ctx context.Context) error