fix: hstreamdb connector use unified schema

This commit is contained in:
JimMoen 2023-07-13 10:18:27 +08:00
parent 8ebe099653
commit c23c3a1f78
No known key found for this signature in database
GPG Key ID: 87A520B4F76BA86D
2 changed files with 11 additions and 8 deletions

View File

@ -119,10 +119,13 @@ roots() ->
fields(config) -> fields(config) ->
[ [
{url, mk(binary(), #{required => true, desc => ?DESC("url")})}, {url,
mk(binary(), #{
required => true, desc => ?DESC("url"), default => <<"http://127.0.0.1:6570">>
})},
{stream, mk(binary(), #{required => true, desc => ?DESC("stream_name")})}, {stream, mk(binary(), #{required => true, desc => ?DESC("stream_name")})},
{partition_key, mk(binary(), #{required => false, desc => ?DESC("partition_key")})}, {partition_key, mk(binary(), #{required => false, desc => ?DESC("partition_key")})},
{pool_size, mk(pos_integer(), #{required => true, desc => ?DESC("pool_size")})}, {pool_size, fun emqx_connector_schema_lib:pool_size/1},
{grpc_timeout, fun grpc_timeout/1} {grpc_timeout, fun grpc_timeout/1}
] ++ emqx_connector_schema_lib:ssl_fields(). ] ++ emqx_connector_schema_lib:ssl_fields().

View File

@ -19,31 +19,31 @@ name.label:
"""Connector Name""" """Connector Name"""
url.desc: url.desc:
"""HStreamDB Server URL""" """HStreamDB Server URL. Using gRPC http server address."""
url.label: url.label:
"""HStreamDB Server URL""" """HStreamDB Server URL"""
stream_name.desc: stream_name.desc:
"""HStreamDB Stream Name""" """HStreamDB Stream Name."""
stream_name.label: stream_name.label:
"""HStreamDB Stream Name""" """HStreamDB Stream Name"""
partition_key.desc: partition_key.desc:
"""HStreamDB Ordering Key""" """HStreamDB Partition Key. Placeholders supported."""
partition_key.label: partition_key.label:
"""HStreamDB Ordering Key""" """HStreamDB Partition Key"""
pool_size.desc: pool_size.desc:
"""HStreamDB Pool Size""" """HStreamDB Pool Size."""
pool_size.label: pool_size.label:
"""HStreamDB Pool Size""" """HStreamDB Pool Size"""
grpc_timeout.desc: grpc_timeout.desc:
"""HStreamDB gRPC Timeout""" """HStreamDB gRPC Timeout."""
grpc_timeout.label: grpc_timeout.label:
"""HStreamDB gRPC Timeout""" """HStreamDB gRPC Timeout"""