silo_manager

type AddInputQueueMessage struct {
	ProcessorID uuid.UUID
	QueueID     uuid.UUID
}

type AddInputQueueOKMessage struct{}

type AddOutputQueueMessage struct {
	ProcessorID uuid.UUID
	QueueID     uuid.UUID
}

type AddOutputQueueOKMessage struct{}

type CreateProcessorMessage struct {
	Processor interface_processor.ProcessorInterface
	ID        uuid.UUID
	Config    *flow_model.Config
}

type CreateProcessorOKMessage struct {
	PID uuid.UUID
}

type CreateQueueMessage struct {
	Queue      interface_queue.QueueInterface
	ID         uuid.UUID
	Repository *repository.WALRepository
}

type CreateQueueOKMessage struct {
	PID uuid.UUID
}

type GetProcessorsMessage struct{}

type GetProcessorsOKMessage struct {
	Processors map[uuid.UUID]*actor.PID
}

type GetQueuesMessage struct{}

type GetQueuesOKMessage struct {
	Queues map[uuid.UUID]*actor.PID
}

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

type StartSiloMessage struct{}

type StartSiloOKMessage struct{}

type StopSiloMessage struct{}

type StopSiloOKMessage struct{}