queue

type Config struct {
	Address                 string        `env:"REDIS_ADDRESS,default=localhost:6379"`
	UserName                string        `env:"REDIS_USERNAME"`
	Password                string        `env:"REDIS_PASSWORD,default=pass"`
	Database                int           `env:"REDIS_DATABASE,default=0"`
	PoolSize                int           `env:"REDIS_POOL_SIZE,default=5"`
	CleanPeriod             time.Duration `env:"QUEUE_CLEANUP_PERIOD,default=300s"`
	NumberConsumersForQueue int           `env:"CONSUMERS_PER_QUEUE,default=5"`
}

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

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

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

type ServiceDataResponse struct {
	Rejected  int64 `json:"rejected"`
	New       int64 `json:"new"`
	Consumers int64 `json:"consumers"`
	InWork    int64 `json:"in_work"`
}

type TaskPost struct {
	Post      model.Post
	QueueDate time.Time `json:"queue_date"`
}

type TaskQueue struct {
	rmq.Queue
	// contains filtered or unexported fields
}

type TaskUpdateUserIdFeed struct {
	UserId int64
}