handlers

Documentation

Index

• Constants
• type CoreHandlers
  • func NewCoreHandlers(core *core.Core) (*CoreHandlers, error)
  • func (core *CoreHandlers) InitBomber() error
  • func (core *CoreHandlers) InitTopicsHandlers(signal chan int) error
  • func (core *CoreHandlers) ShutdownToServer()
  • func (core *CoreHandlers) TestSendTask(config *nats_listener.NatsConnectionConfiguration) error
• type IHandlerTopic
• type ResultConfiguration
• type StarterTopicHandler
  • func (handl *StarterTopicHandler) Configuration(signal chan int) error
• type TaskTopicHandler
  • func (handl *TaskTopicHandler) Configuration(signal chan int) error

Constants

const (
	CONFIGURED          = 0
	COMPLETED_ATTACK    = 1
	ERROR_CONFIGURATION = 3
	ERROR_ATTACK        = 2
)

Types

type CoreHandlers

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

func NewCoreHandlers

func NewCoreHandlers(core *core.Core) (*CoreHandlers, error)

func (*CoreHandlers) InitBomber

func (core *CoreHandlers) InitBomber() error

func (*CoreHandlers) InitTopicsHandlers

func (core *CoreHandlers) InitTopicsHandlers(signal chan int) error

func (*CoreHandlers) ShutdownToServer

func (core *CoreHandlers) ShutdownToServer()

func (*CoreHandlers) TestSendTask

func (core *CoreHandlers) TestSendTask(config *nats_listener.NatsConnectionConfiguration) error

type IHandlerTopic

type IHandlerTopic interface {
	Configuration(signal chan int) error
}

type ResultConfiguration

type ResultConfiguration struct {
	TaskID string `json:"task_id"`
	Result int    `json:"status"`
}

type StarterTopicHandler

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

func (*StarterTopicHandler) Configuration

func (handl *StarterTopicHandler) Configuration(signal chan int) error

type TaskTopicHandler

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

func (*TaskTopicHandler) Configuration

func (handl *TaskTopicHandler) Configuration(signal chan int) error