queue

type Embedded struct {
	Config EmbeddedConfig
	// contains filtered or unexported fields
}

type EmbeddedConfig struct {
	BufferSize int
	BatchSize  int
}

type Queue interface {
	// Push appends a set of tasks into the queue. If FIFO, task will be appended at the tail. If LIFO, task will be appended
	// at the head.
	Push(ctx context.Context, task ...boltzmann.Task) error
	// Pop retrieves several tasks from the queue.
	Pop(ctx context.Context) ([]boltzmann.Task, error)
}

type RedisList struct {
	Client *redis.Client
	Codec  codec.Codec
	Config RedisListConfig
}

type RedisListConfig struct {
	QueueName string
	BatchSize int64
	IsLIFO    bool
}

type Service struct {
	Config        ServiceConfig
	Queue         Queue
	AgentRegistry agent.Registry
	// contains filtered or unexported fields
}

type ServiceConfig struct {
	FetchInterval time.Duration
	RetryInterval time.Duration
	JobTimeout    time.Duration
	MaxRetries    int8
	MaxProc       int64
}

type StateUpdaterMiddleware struct {
	Repository state.Repository
	Next       Queue
}