Method getRuntimeInfo

flow/activities/flowable.go:1010–1058

(
	ctx context.Context,
	peer *protos.Peer,
	flowNames []string,
)

}

func (a *FlowableActivity) getRuntimeInfo(
	ctx context.Context,
	peer *protos.Peer,
	flowNames []string,
) (string, string, map[string]string) {
	logger := internal.LoggerFromCtx(ctx)
	version := "N/A"
	variant := "N/A"
	replicationMechanismInUseByFlow := make(map[string]string, len(flowNames))

	conn, err := connectors.GetConnector(ctx, nil, peer)
	if err != nil {
		logger.Error("failed to create connector for source peer info", slog.String("peer", peer.Name), slog.Any("error", err))
		return version, variant, replicationMechanismInUseByFlow
	}
	defer conn.Close()

	if vc, ok := conn.(connectors.GetVersionConnector); ok {
		if v, err := vc.GetVersion(ctx); err != nil {
			logger.Error("failed to get version",
				slog.String("peer", peer.Name), slog.Any("error", err))
		} else {
			version = v
		}
	}
	if dvc, ok := conn.(connectors.DatabaseVariantConnector); ok {
		if v, err := dvc.GetDatabaseVariant(ctx); err != nil {
			logger.Error("failed to get database variant",
				slog.String("peer", peer.Name), slog.Any("error", err))
		} else {
			variant = v.String()
		}
	}
	if rmc, ok := conn.(connectors.ReplicationMechanismInUseConnector); ok {
		for _, flowName := range flowNames {
			mechanismInUse, err := rmc.GetReplicationMechanismInUse(ctx, flowName)
			if err != nil {
				logger.Error("failed to get replication mechanism in use",
					slog.String("peer", peer.Name),
					slog.String("flowName", flowName),
					slog.Any("error", err))
				continue
			}
			replicationMechanismInUseByFlow[flowName] = mechanismInUse
		}
	}

	return version, variant, replicationMechanismInUseByFlow
}

type flowInformation struct {
	config     *protos.FlowConnectionConfigsCore