Categorygithub.com/msd-rs/msd-sdk-go
modulepackage
0.0.3
Repository: https://github.com/msd-rs/msd-sdk-go.git
Documentation: pkg.go.dev

# README

usage

go get -u github.com/msd-rs/msd-sdk-go
import (
    "github.com/msd-rs/msd-sdk-go"
    "google.golang.org/grpc"
    "google.golang.org/grpc/credentials/insecure"
)

func main() {
    host := "127.0.0.1:50051"
    conn, err := grpc.Dial(host, grpc.WithTransportCredentials(insecure.NewCredentials()))
    if err != nil {
        fmt.Println("dail msd server failed", err)
        return
    }
    client := msd.NewApiV1Client(conn)
    req := &msd.GetDataFrameRequest{
        Sql: "select * from kline1d.SH000001"
    }
    resp, err := client.Get(req)
    if err != nil {
        fmt.Println("query failed", err)
        return
    }
    fmt.Println(resp)
    conn.Close()
}

# Functions

No description provided by the author
No description provided by the author
No description provided by the author

# Constants

DateTime 类型,timestamp, 一般基于local,单位纳秒 1/1e9 秒,是 Int64 的子类型.
Decimal 类型, 8字节, 是 Int64 的子类型.
空类型.
Float64 8字节.
Int64 类型, 8字节.
字符串类型.
UInt64 类型, 8字节.
Int8 1字节.
平均值.
计数,每次有更新加1.
跟第一个值做减后存储 *需要状态存储.
跟当上次值做减后存储 *需要状态存储.
无重复的计数,无额外设置时,以提供的值进行统计,如果设置了 op_params, 支持以提供的值从meta表中取数,其中 op_params.src_field 为JSONB的查询路径 op_params.src_schema 为meta表的表名 op_params.trigger_field 如果设置,那么当trigger_field不为空/0时进行计算.
累加到当前值.
直接存储.
如果时第一个则存储.
跟当前值比较,存较大的.
跟当前值比较,存较小的.
必须全部匹配.
通配符.
部分匹配即可.
正则表达式.
No description provided by the author
No description provided by the author
No description provided by the author
批量 Import 更新,忽略请求中的 obj 参数,而是从数据中获取.
批量 Schema 更新,忽略请求中的 obj 参数,而是从数据中获取.
来自更新链的更新, 更新链来的数据总是进行按 Schema 更新.
导入更新,一般用于第一次,数据不做处理,直接更新, row 的列数与数据结构中的列一致.
数据修改, 数据修改需要指定列 例如对于CSV格式:主键值,1=V1,5=V5 表示修改匹配主键值的记录,列1值为V1,列5值为V5.
粘贴上一笔数据,然后更改 pk_col 的值,保持其他的值不变, row 应该只有一列.
按数据结构中定义的方式进行更新, 默认, row 的列及其顺序符合字段定义的 refer 属性.
对数据进行脚本的处理后再进行更新.
BinaryRows 格式.
CSV 格式,默认 '\n' 分行 ',' 分隔.
Json Record 格式, 类似 [{column -> value}, ..
Json Values 格式, 类似 [ [value1, value2, ...], ..

# Variables

ApiV1_ServiceDesc is the grpc.ServiceDesc for ApiV1 service.
Enum value maps for FieldKind.
Enum value maps for FieldKind.
Enum value maps for FieldOp.
Enum value maps for FieldOp.
No description provided by the author
No description provided by the author
No description provided by the author
Enum value maps for FilterMode.
Enum value maps for FilterMode.
Enum value maps for ForwardOp.
Enum value maps for ForwardOp.
Enum value maps for UpdateMode.
Enum value maps for UpdateMode.
Enum value maps for UpdateRowFormat.
Enum value maps for UpdateRowFormat.

# Structs

No description provided by the author
No description provided by the author
No description provided by the author
CSV 格式的相关配置 通过CSV的配置,目的是尽可能减少数据产生方对数据的额外转换,因为在很多场景下,数据产生方无法定制,为了接收其数据, 需要一个额外的数据转换适配,通过本参数的配置,将会尽量去识别原始的数据,提升性能。.
DataFrame 是由若干 Series 组成,形成表格形式的数据结果.
DataFrameIndex 是一组 DataFrame 的索引信息.
一个单独的索引块信息.
字段定义 字段可以分为3类 - 直接存储的字段: 例如股票的价格 - 统计字段: 如最高价 - 计算字段: 如涨幅 (当前价-之前价格)/之前价格.
过滤器.
No description provided by the author
No description provided by the author
No description provided by the author
获取数据请求.
获取数据的返回.
获取数据请求参数.
获取表信息请求.
获取表信息响应.
No description provided by the author
No description provided by the author
No description provided by the author
数据结构定义 数据可以在内存中保留一部分, 以便降低对存储的频繁访问, 提高请求QPS, 一般来说, 设置内存和存储中一块相同的数目足以应对大多数场景, 但对于有大量标的, 写多读少的场景, 将内存中的数目设置成更小的值, 有利于减少系统的内存占用.
以Script模式更新时,script的相关属性.
Series 是一系列值的数组.
Sql 查询的请求.
Sql 查询的回复.
UnimplementedApiV1Server must be embedded to have forward compatible implementations.
更新请求的请求参数.
更新请求的返回.
元数据的更新请求.
元数据更新请求的返回.
更新内容为 Binary 时数据头.
待更新数据的配置选项.

# Interfaces

No description provided by the author
No description provided by the author
ApiV1Client is the client API for ApiV1 service.
ApiV1Server is the server API for ApiV1 service.
UnsafeApiV1Server may be embedded to opt out of forward compatibility for this service.

# Type aliases

No description provided by the author
字段类型.
字段的存储方式.
过滤器匹配模式.
No description provided by the author
更新方式.
待更新数据的格式.