Skip to content

Commit d75e801

Browse files
committed
Add splitting batch inserts based on limit
Signed-off-by: Enrique Lacal <enrique.lacal@kaleido.io>
1 parent 91255ab commit d75e801

File tree

3 files changed

+565
-7
lines changed

3 files changed

+565
-7
lines changed
Lines changed: 45 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,45 @@
1+
// Copyright © 2025 Kaleido, Inc.
2+
//
3+
// SPDX-License-Identifier: Apache-2.0
4+
//
5+
// Licensed under the Apache License, Version 2.0 (the "License");
6+
// you may not use this file except in compliance with the License.
7+
// You may obtain a copy of the License at
8+
//
9+
// http://www.apache.org/licenses/LICENSE-2.0
10+
//
11+
// Unless required by applicable law or agreed to in writing, software
12+
// distributed under the License is distributed on an "AS IS" BASIS,
13+
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14+
// See the License for the specific language governing permissions and
15+
// limitations under the License.
16+
17+
package paladin
18+
19+
import (
20+
"github.com/hyperledger/firefly-common/pkg/config"
21+
"github.com/hyperledger/firefly-common/pkg/ffresty"
22+
"github.com/hyperledger/firefly-common/pkg/wsclient"
23+
)
24+
25+
const (
26+
// PaladinClientConfigKey is a sub-key in the config to contain all the connection details for RPC client
27+
PaladinRPCClientConfigKey = "rpc"
28+
29+
// PaladinClientConfigKey is a sub-key in the config to contain all the connection details for RPC client HTTP section
30+
PaladinRPCHTTPClientConfigKey = "http"
31+
32+
// PaladinClientConfigKey is a sub-key in the config to contain all the connection details for RPC client WS section
33+
PaladinRPCWSClientConfigKey = "ws"
34+
)
35+
36+
func (p *Paladin) InitConfig(config config.Section) {
37+
rpcConf := config.SubSection(PaladinRPCClientConfigKey)
38+
wsRPCConf := rpcConf.SubSection(PaladinRPCWSClientConfigKey)
39+
wsclient.InitConfig(wsRPCConf)
40+
41+
httpRPCConf := rpcConf.SubSection(PaladinRPCHTTPClientConfigKey)
42+
ffresty.InitConfig(httpRPCConf)
43+
44+
// TODO Config for receipt listener?
45+
}

0 commit comments

Comments
 (0)