silo_manager

package

v0.0.0-...-8ab07fe Latest Latest Go to latest Published: Nov 2, 2020 License: AGPL-3.0 Imports: 11 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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
}

func NewSiloManager() *SiloManager

func (state *SiloManager) AddInputQueue(processorID uuid.UUID, queueID uuid.UUID) error

func (state *SiloManager) AddOutputQueue(processorID uuid.UUID, queueID uuid.UUID) error

func (state *SiloManager) CreateNewProcessor(msg *CreateProcessorMessage) (uuid.UUID, error)

func (state *SiloManager) CreateNewQueue(msg *CreateQueueMessage) (uuid.UUID, error)

func (state *SiloManager) GetProcessors() map[uuid.UUID]*actor.PID

func (state *SiloManager) Receive(context actor.Context)

func (state *SiloManager) StartSilo() error

func (state *SiloManager) StopSilo() error

type StartSiloMessage struct{}

type StartSiloOKMessage struct{}

type StopSiloMessage struct{}

type StopSiloOKMessage struct{}