stream

Jun 17, 2022

Changes in this version

+ func NewLogger(lc LoggerConfig) (logrus.FieldLogger, *os.File, error)

+ type API struct

+ func NewAPI(port int, sender *Sender, storage Storage, logger logrus.FieldLogger, ...) *API

+ func (a *API) Start()

+ type APIConfig struct

+ Port int

+ type AbortRequest struct

+ Checks []string

+ type LoggerConfig struct

+ LogFile string

+ LogLevel string

+ type Message struct

+ Action string

+ AgentID string

+ CheckID string

+ ScanID string

+ type RedisConfig struct

+ DB int

+ Host string

+ Port int

+ Pwd string

+ TTL int

+ Usr string

+ type RedisDB struct

+ func NewRedisDB(c RedisConfig) *RedisDB

+ func (r *RedisDB) GetChecks(ctx context.Context) ([]string, error)

+ func (r *RedisDB) SetChecks(ctx context.Context, checks []string) error

+ type RemoteDB interface

+ GetChecks func(ctx context.Context) ([]string, error)

+ SetChecks func(ctx context.Context, checks []string) error

+ type Sender struct

+ func NewSender(l logrus.FieldLogger, c SenderConfig) *Sender

+ func (s *Sender) Broadcast(msg Message)

+ func (s *Sender) HandleConn(w http.ResponseWriter, r *http.Request)

+ func (s *Sender) Start()

+ type SenderConfig struct

+ HTTPStream string

+ PingInterval time.Duration

+ type Storage interface

+ AddAbortedChecks func(ctx context.Context, checks []string) error

+ GetAbortedChecks func(ctx context.Context) ([]string, error)

+ func NewStorage(db RemoteDB, logger log.FieldLogger) (Storage, error)