processors

Documentation

Overview

this package is where we put event processors

Index

• func StartRobotProcessor(logger *zap.SugaredLogger, robotBrokerService robotbroker.RobotBrokerInterface) (processor *robotProcessor, robotStatusChannel chan map[int64]RobotStatus, ...)
• func StartTaskProcessor(logger *zap.SugaredLogger, robotBrokerService robotbroker.RobotBrokerInterface) (processor *taskProcessor, robotStatusChannel chan map[int64]TaskStatus, ...)
• type RobotStatus
• type TaskStatus

Functions

func StartRobotProcessor

func StartRobotProcessor(
	logger *zap.SugaredLogger,
	robotBrokerService robotbroker.RobotBrokerInterface) (
	processor *robotProcessor,
	robotStatusChannel chan map[int64]RobotStatus,
	err error)

creates an instance of robotProcessor and starts it

func StartTaskProcessor

func StartTaskProcessor(
	logger *zap.SugaredLogger,
	robotBrokerService robotbroker.RobotBrokerInterface) (
	processor *taskProcessor,
	robotStatusChannel chan map[int64]TaskStatus,
	err error)

creates an instance of taskProcessor

Types

type RobotStatus

type RobotStatus struct {
	X int
	Y int
}

RobotStatus defines robot status

type TaskStatus

type TaskStatus string

TaskStatus defines running tasks status

const (
	// TaskStatusCreated is used to denote a Created task
	TaskStatusCreated TaskStatus = "Created"
	// TaskStatusInProgress is used to denote an InProgress task
	TaskStatusInProgress TaskStatus = "InProgress"
	// TaskStatusCompleted is used to denote a Completed task
	TaskStatusCompleted TaskStatus = "Completed"
	// TaskStatusCancelled is used to denote a Cancelled task
	TaskStatusCancelled TaskStatus = "Cancelled"
)