MCPcopy
hub / github.com/PeerDB-io/peerdb / syncStateToConfigProtoInCatalog

Function syncStateToConfigProtoInCatalog

flow/workflows/cdc_flow.go:70–78  ·  view source on GitHub ↗
(
	ctx workflow.Context,
	cfg *protos.FlowConnectionConfigsCore,
	state *cdc_state.CDCFlowWorkflowState,
)

Source from the content-addressed store, hash-verified

68type CDCFlowWorkflowResult = cdc_state.CDCFlowWorkflowState
69
70func syncStateToConfigProtoInCatalog(
71 ctx workflow.Context,
72 cfg *protos.FlowConnectionConfigsCore,
73 state *cdc_state.CDCFlowWorkflowState,
74) *protos.FlowConnectionConfigsCore {
75 cloneCfg := updateFlowConfigWithLatestSettings(cfg, state)
76 uploadConfigToCatalog(ctx, cloneCfg)
77 return cloneCfg
78}
79
80func uploadConfigToCatalog(
81 ctx workflow.Context,

Callers 5

processCDCFlowConfigUpdateFunction · 0.85
handleFlowSignalStateChangeFunction · 0.85
processTableAdditionsFunction · 0.85
processTableRemovalsFunction · 0.85
CDCFlowWorkflowFunction · 0.85

Calls 2

updateFlowConfigWithLatestSettingsFunction · 0.85
uploadConfigToCatalogFunction · 0.85

Tested by

no test coverage detected