queue

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

type EmbeddedQueueConfig struct {
	Address           string
	DataPath          string
	MemQueueSize      int64
	SyncEvery         int64
	SyncTimeout       time.Duration
	NumberOfProducers int
	NumberOfConsumers int
}

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

type EmbeddedQueueMessageHandler func(msg []byte) error

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