plugin

type CallFunctionRequest struct {
	UserID   string
	FuncName string
	Data     map[string]interface{}
	Ctx      map[string]interface{}
}

type CallFunctionResponse struct {
	Result interface{}
	Error  string
}

type DBPlugin interface {
	InitConnection(uri string) error
	TableGet(userID, table string, selectFields []string, where map[string]interface{},
		ordering []string, groupBy []string, limit, offset int, ctx map[string]interface{}) ([]map[string]interface{}, error)
	TableCreate(userID, table string, data []map[string]interface{}, ctx map[string]interface{}) ([]map[string]interface{}, error)
	TableUpdate(userID, table string, data map[string]interface{}, where map[string]interface{}, ctx map[string]interface{}) (int, error)
	TableDelete(userID, table string, where map[string]interface{}, ctx map[string]interface{}) (int, error)
	CallFunction(userID, funcName string, data map[string]interface{}, ctx map[string]interface{}) (interface{}, error)
}

type DBPluginPlugin struct {
	Impl DBPlugin
}

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

type DBPluginRPCServer struct {
	Impl DBPlugin
}

type InitConnectionRequest struct {
	URI string
}

type InitConnectionResponse struct {
	Error string
}

type TableCreateRequest struct {
	UserID string
	Table  string
	Data   []map[string]interface{}
	Ctx    map[string]interface{}
}

type TableCreateResponse struct {
	Rows  []map[string]interface{}
	Error string
}

type TableDeleteRequest struct {
	UserID string
	Table  string
	Where  map[string]interface{}
	Ctx    map[string]interface{}
}

type TableDeleteResponse struct {
	Deleted int
	Error   string
}

type TableGetRequest struct {
	UserID       string
	Table        string
	SelectFields []string
	Where        map[string]interface{}
	Ordering     []string
	GroupBy      []string
	Limit        int
	Offset       int
	Ctx          map[string]interface{}
}

type TableGetResponse struct {
	Rows  []map[string]interface{}
	Error string
}

type TableUpdateRequest struct {
	UserID string
	Table  string
	Data   map[string]interface{}
	Where  map[string]interface{}
	Ctx    map[string]interface{}
}

type TableUpdateResponse struct {
	Updated int
	Error   string
}