processor_manager

type AddInputOKQueue struct{}

type AddInputQueue struct {
	QueueID  uuid.UUID
	QueuePID *actor.PID
}

type AddOutputOKQueue struct{}

type AddOutputQueue struct {
	QueueID  uuid.UUID
	QueuePID *actor.PID
}

type GetProcessorInfoMessage struct{}

type GetProcessorInfoOKMessage struct {
	ID           uuid.UUID
	Type         string
	InputQueues  []queue_model.Queue
	OutputQueues queue_model.Queue
}

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

type StartProcessorMessage struct{}

type StartProcessorOKMessage struct{}

type StopProcessorMessage struct{}

type StopProcessorOKMessage struct{}