62 lines
1.2 KiB
TypeScript
62 lines
1.2 KiB
TypeScript
|
import { Integration, QueryTypes } from "../definitions/datasource"
|
||
|
|
import { IntegrationBase } from "./base/IntegrationBase"
|
||
|
|
|
||
|
|
module RedisModule {
|
||
|
|
const redis = require("ioredis")
|
||
|
|
|
||
|
|
interface RedisConfig {
|
||
|
|
host: string
|
||
|
|
port: number
|
||
|
|
username: string
|
||
|
|
password?: string
|
||
|
|
}
|
||
|
|
|
||
|
|
const SCHEMA: Integration = {
|
||
|
|
docs: "https://redis.io/docs/",
|
||
|
|
description: "",
|
||
|
|
friendlyName: "Redis",
|
||
|
|
datasource: {
|
||
|
|
host: {
|
||
|
|
type: "string",
|
||
|
|
required: true,
|
||
|
|
default: "localhost",
|
||
|
|
},
|
||
|
|
port: {
|
||
|
|
type: "number",
|
||
|
|
required: true,
|
||
|
|
default: 6379,
|
||
|
|
},
|
||
|
|
username: {
|
||
|
|
type: "string",
|
||
|
|
required: false,
|
||
|
|
},
|
||
|
|
password: {
|
||
|
|
type: "password",
|
||
|
|
required: false,
|
||
|
|
},
|
||
|
|
},
|
||
|
|
query: {
|
||
|
|
read: {
|
||
|
|
type: QueryTypes.JSON,
|
||
|
|
},
|
||
|
|
},
|
||
|
|
}
|
||
|
|
|
||
|
|
class RedisIntegration implements IntegrationBase {
|
||
|
|
private readonly config: RedisConfig
|
||
|
|
private client: any
|
||
|
|
|
||
|
|
constructor(config: RedisConfig) {
|
||
|
|
this.config = config
|
||
|
|
this.client = {}
|
||
|
|
}
|
||
|
|
|
||
|
|
async read(query: { bucket: string }) {}
|
||
|
|
}
|
||
|
|
|
||
|
|
module.exports = {
|
||
|
|
schema: SCHEMA,
|
||
|
|
integration: RedisIntegration,
|
||
|
|
}
|
||
|
|
}
|