antifraud

Documentation

Index

• Constants
• func NewBlacklistWatcher(addr common.Address, cc *grpc.ClientConn, log *zap.Logger) *blacklistWatcher
• type AntiFraud
  • func NewAntiFraud(cfg Config, log *zap.Logger, processors ProcessorFactory, ...) AntiFraud
• type Config
  • func (c Config) Validate() error
• type LogProcessorConfig
• type Option
  • func WithClientConn(cc *grpc.ClientConn) Option
  • func WithLogger(log *zap.Logger) Option
• type PoolProcessorConfig
• type Processor
• type ProcessorConfig
• type ProcessorFactory
  • func NewProcessorFactory(cfg *Config) ProcessorFactory

Constants

const (
	AllChecks = iota
	SkipBlacklisting
)

const (
	LogFormatCommon         = "common"
	PoolFormatDwarf         = "dwarf"
	PoolFormatUley          = "uley"
	ProcessorFormatDisabled = "disabled"
)

Functions

func NewBlacklistWatcher

func NewBlacklistWatcher(addr common.Address, cc *grpc.ClientConn, log *zap.Logger) *blacklistWatcher

Types

type AntiFraud

type AntiFraud interface {
	Run(ctx context.Context) error
	DealOpened(deal *sonm.Deal) error
	TrackTask(ctx context.Context, deal *sonm.Deal, taskID string) error
	FinishDeal(ctx context.Context, deal *sonm.Deal, optsFlags flags) error
}

func NewAntiFraud

func NewAntiFraud(cfg Config, log *zap.Logger, processors ProcessorFactory, dealFactory types.DealFactory, nodeConnection *grpc.ClientConn) AntiFraud

type Config

type Config struct {
	TaskQuality            float64             `yaml:"task_quality" required:"true"`
	QualityCheckInterval   time.Duration       `yaml:"quality_check_interval" default:"15s"`
	BlacklistCheckInterval time.Duration       `yaml:"blacklist_check_interval" default:"5m"`
	ConnectionTimeout      time.Duration       `yaml:"connection_timeout" default:"60s"`
	LogProcessorConfig     LogProcessorConfig  `yaml:"log_processor"`
	PoolProcessorConfig    PoolProcessorConfig `yaml:"pool_processor"`
	Whitelist              []common.Address    `yaml:"whitelist"`
}

func (Config) Validate

func (c Config) Validate() error

type LogProcessorConfig

type LogProcessorConfig struct {
	ProcessorConfig `yaml:",inline"`
	Pattern         string  `yaml:"pattern" required:"true"`
	Field           int     `yaml:"field"`
	Multiplier      float64 `yaml:"multiplier" required:"true"`
	LogDir          string  `yaml:"log_dir"`
}

type Option

type Option func(options *processorOpts)

func WithClientConn

func WithClientConn(cc *grpc.ClientConn) Option

func WithLogger

func WithLogger(log *zap.Logger) Option

type PoolProcessorConfig

type PoolProcessorConfig struct {
	ProcessorConfig `yaml:",inline"`
	URL             string `yaml:"url"`
}

type Processor

type Processor interface {
	Run(ctx context.Context) error
	TaskID() string
	TaskQuality() (accurate bool, quality float64)
}

Processor is part of AntiFraud module that continuously processing results of container execution (like logs, pool reports, etc) and calculate task quality value.

type ProcessorConfig

type ProcessorConfig struct {
	Format          string        `yaml:"format" required:"true"`
	TrackInterval   time.Duration `yaml:"track_interval" default:"10s"`
	TaskWarmupDelay time.Duration `yaml:"warmup_delay" required:"true"`
	DecayTime       float64       `yaml:"decay_time" required:"true"`
}

type ProcessorFactory

type ProcessorFactory interface {
	LogProcessor(deal *types.Deal, taskID string, opts ...Option) Processor
	PoolProcessor(deal *types.Deal, taskID string, opts ...Option) Processor
}

ProcessorFactory builds particular processors for the anti-fraud

func NewProcessorFactory

func NewProcessorFactory(cfg *Config) ProcessorFactory